dev
Mzack9999 2020-10-23 11:38:45 +02:00
parent 058b1a6300
commit cb5ceed1f4
1 changed files with 6 additions and 7 deletions

View File

@ -161,18 +161,17 @@ func (e *HTTPExecuter) ExecuteRaceRequest(reqURL string) *Result {
e.bulkHTTPRequest.CreateGenerator(reqURL) e.bulkHTTPRequest.CreateGenerator(reqURL)
// base request
request, err := e.bulkHTTPRequest.MakeHTTPRequest(reqURL, dynamicvalues, e.bulkHTTPRequest.Current(reqURL))
if err != nil {
result.Error = err
return result
}
// Workers that keeps enqueuing new requests // Workers that keeps enqueuing new requests
maxWorkers := e.bulkHTTPRequest.RaceNumberRequests maxWorkers := e.bulkHTTPRequest.RaceNumberRequests
swg := sizedwaitgroup.New(maxWorkers) swg := sizedwaitgroup.New(maxWorkers)
for i := 0; i < e.bulkHTTPRequest.RaceNumberRequests; i++ { for i := 0; i < e.bulkHTTPRequest.RaceNumberRequests; i++ {
swg.Add() swg.Add()
// base request
request, err := e.bulkHTTPRequest.MakeHTTPRequest(reqURL, dynamicvalues, e.bulkHTTPRequest.Current(reqURL))
if err != nil {
result.Error = err
return result
}
go func(httpRequest *requests.HTTPRequest) { go func(httpRequest *requests.HTTPRequest) {
defer swg.Done() defer swg.Done()