We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent c535b27 commit 60d07deCopy full SHA for 60d07de
storage/hasherstore.go
@@ -153,6 +153,7 @@ func (h *hasherStore) startWait(ctx context.Context) {
153
// if context is done earlier, just return with the error
154
case <-ctx.Done():
155
h.waitC <- ctx.Err()
156
+ return
157
// doneC is closed if all chunks have been submitted, from then we just wait until all of them are also stored
158
case <-doneC:
159
done = true
@@ -161,6 +162,7 @@ func (h *hasherStore) startWait(ctx context.Context) {
161
162
case err := <-h.errC:
163
if err != nil {
164
h.waitC <- err
165
166
}
167
nrStoredChunks++
168
0 commit comments