cerc-io/lotus
10
0
Fork 0
Code Issues Pull Requests Packages Projects Releases 27 Wiki Activity

Merge pull request #7169 from filecoin-project/feat/dagstore-zero-concurrency

Browse Source 
Ignore nil throttler
This commit is contained in:
Aarsh Shah 2021-08-24 13:20:49 +05:30 committed by GitHub
commit 5993257eb1
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 7 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
node/impl/storminer.go
View File

@ -725,12 +725,14 @@ func (sm *StorageMinerAPI) DagstoreInitializeAll(ctx context.Context, params api
go func() { go func() {
for i, k := range toInitialize { for i, k := range toInitialize {
if throttle != nil {
select { select {
case <-throttle: case <-throttle:
// acquired a throttle token, proceed. // acquired a throttle token, proceed.
case <-ctx.Done(): case <-ctx.Done():
return return
} }
}
go func(k string, i int) { go func(k string, i int) {
r := api.DagstoreInitializeAllEvent{ r := api.DagstoreInitializeAllEvent{