Skip to content

Commit

Permalink
experiment
Browse files Browse the repository at this point in the history
  • Loading branch information
dabasov committed Nov 15, 2023
1 parent 65a0152 commit 6b6578b
Showing 1 changed file with 6 additions and 6 deletions.
12 changes: 6 additions & 6 deletions zboxcore/zboxutil/http.go
Expand Up @@ -817,7 +817,7 @@ func MakeSCRestAPICall(scAddress string, relativePath string, params map[string]
return nil, err
}

var urls []string
urls := make(map[string]string)
for _, sharder := range sharders {
urlString := fmt.Sprintf("%v/%v%v%v", sharder, SC_REST_API_URL, scAddress, relativePath)
urlObj, err := url.Parse(urlString)
Expand All @@ -830,17 +830,17 @@ func MakeSCRestAPICall(scAddress string, relativePath string, params map[string]
q.Add(k, v)
}
urlObj.RawQuery = q.Encode()
urls = append(urls, urlObj.String())
urls[sharder] = urlObj.String()
}

for _, sharder := range urls {
for sharder, url := range urls {
wg.Add(1)
go func(sharder string) {
go func(sharder, url string) {
defer wg.Done()

client := &http.Client{Transport: DefaultTransport}

response, err := client.Get(sharder)
response, err := client.Get(url)
if err != nil {
blockchain.Sharders.Fail(sharder)
return
Expand All @@ -867,7 +867,7 @@ func MakeSCRestAPICall(scAddress string, relativePath string, params map[string]
entityResult[sharder] = entityBytes
blockchain.Sharders.Success(sharder)
mu.Unlock()
}(sharder)
}(sharder, url)
}
wg.Wait()

Expand Down

0 comments on commit 6b6578b

Please sign in to comment.