fix dup upload consensus (#1195)

0chain · Aug 30, 2023 · 0e1c494 · 0e1c494
1 parent 47cfad4
commit 0e1c494
Showing 1 changed file with 6 additions and 2 deletions.
diff --git a/zboxcore/sdk/chunked_upload.go b/zboxcore/sdk/chunked_upload.go
@@ -671,8 +671,12 @@ func (su *ChunkedUpload) processUpload(chunkStartIndex, chunkEndIndex int,
 			err = b.sendUploadRequest(ctx, su, chunkEndIndex, isFinal, su.encryptedKey, body, formData, pos)
 			if err != nil {
 				if strings.Contains(err.Error(), "duplicate") {
-					atomic.AddInt32(&su.addConsensus, 1)
-					su.consensus.Done()
+					errC := atomic.AddInt32(&su.addConsensus, 1)
+					if errC >= int32(su.consensus.consensusThresh) {
+						wgErrors <- err
+					} else {
+						su.consensus.Done()
+					}
 					return
 				}
 				logger.Logger.Error("error during sendUploadRequest", err)