Don't update store index if we failed to upload blocks

CHANGELOG.md

@@ -1,6 +1,7 @@
 ##
 - **ADDED** New option to control the number of worker thread in remote stores to avoid overflowing the network connection.
   -- `--remote-worker-count` Set number of workers created for the remote store, defaults to match number of logical CPUs with upper limit of 8 for networked remote stores
+- **FIXED** Don't update store index if we failed to upload blocks
 
 ## v0.4.3
 - **CHANGED** For multi-source downsync/get the separator for paths is changed to | to avoid problems with path that contains spaces

remotestore/remotestore.go

@@ -843,6 +843,10 @@ func contentIndexWorker(
 
 		select {
 		case <-flushMessages:
+			if err != nil {
+				flushReplyMessages <- err
+				continue
+			}
 			if len(addedBlockIndexes) > 0 && accessType != ReadOnly {
 				newStoreIndex, err := addBlocksToRemoteStoreIndex(ctx, s, client, addedBlockIndexes)
 				if err != nil {
@@ -915,6 +919,11 @@ func contentIndexWorker(
 		}
 	}
 
+	if err != nil {
+		storeIndex.Dispose()
+		return err
+	}
+
 	if accessType == ReadOnly {
 		storeIndex.Dispose()
 		return nil