Skip to content

Commit

Permalink
added more logs in chunked_upload.go uploadToBlobbers method.
Browse files Browse the repository at this point in the history
  • Loading branch information
yash10019coder committed Sep 14, 2024
1 parent fa99f3f commit 8099511
Showing 1 changed file with 4 additions and 4 deletions.
8 changes: 4 additions & 4 deletions zboxcore/sdk/chunked_upload.go
Original file line number Diff line number Diff line change
Expand Up @@ -707,20 +707,20 @@ func (su *ChunkedUpload) uploadToBlobbers(uploadData UploadData) error {

if err != nil {
if strings.Contains(err.Error(), "duplicate") {
//logger.Logger.Fatal("**************************Duplicate upload detected for blobber at position: ", pos)
logger.Logger.Fatal("**************************Duplicate upload detected for blobber at position: ", pos)
su.consensus.Done()
errC := atomic.AddInt32(&su.addConsensus, 1)
//logger.Logger.Debug("****************************Consensus count after duplicate detection: ", errC)
logger.Logger.Debug("****************************Consensus count after duplicate detection: ", errC)
if errC >= int32(su.consensus.consensusThresh) {
wgErrors <- err
}
return
}
logger.Logger.Error("error during sendUploadRequest", err, " connectionID: ", su.progress.ConnectionID)
errC := atomic.AddInt32(&errCount, 1)
//logger.Logger.Info("***********************************Error count after failure: ", errC)
logger.Logger.Info("***********************************Error count after failure: ", errC)
if errC > int32(su.allocationObj.ParityShards-1) { // If atleast data shards + 1 number of blobbers can process the upload, it can be repaired later
//logger.Logger.Error("************************************Error count exceeded for blobber at position: ", pos)
logger.Logger.Error("************************************Error count exceeded for blobber at position: ", pos)
wgErrors <- err
}
}
Expand Down

0 comments on commit 8099511

Please sign in to comment.