add logs for commit

Author: Hitenjain14

code/go/0chain.net/blobbercore/allocation/allocationchange.go

@@ -14,7 +14,7 @@ import (
 	"github.com/0chain/blobber/code/go/0chain.net/core/common"
 	"github.com/0chain/blobber/code/go/0chain.net/core/logging"
 	"github.com/0chain/gosdk/constants"
-	"github.com/remeh/sizedwaitgroup"
+	"golang.org/x/sync/errgroup"
 
 	"go.uber.org/zap"
 	"gorm.io/gorm"
@@ -236,35 +236,19 @@ func (cc *AllocationChangeCollector) ApplyChanges(ctx context.Context, allocatio
 }
 
 func (a *AllocationChangeCollector) CommitToFileStore(ctx context.Context) error {
-	commitCtx, cancel := context.WithCancel(ctx)
-	defer cancel()
-	// Can be configured at runtime, this number will depend on the number of active allocations
-	swg := sizedwaitgroup.New(5)
+	// Limit can be configured at runtime, this number will depend on the number of active allocations
+	eg, _ := errgroup.WithContext(ctx)
+	eg.SetLimit(5)
 	mut := &sync.Mutex{}
-	var (
-		commitError error
-		errorMutex  sync.Mutex
-	)
 	for _, change := range a.AllocationChanges {
-		select {
-		case <-commitCtx.Done():
-			return fmt.Errorf("commit to filestore failed: %s", commitError.Error())
-		default:
-		}
-		swg.Add()
-		go func(change AllocationChangeProcessor) {
-			err := change.CommitToFileStore(ctx, mut)
-			if err != nil && !errors.Is(common.ErrFileWasDeleted, err) {
-				cancel()
-				errorMutex.Lock()
-				commitError = err
-				errorMutex.Unlock()
-			}
-			swg.Done()
-		}(change)
+		allocChange := change
+		eg.Go(func() error {
+			return allocChange.CommitToFileStore(ctx, mut)
+		})
 	}
-	swg.Wait()
-	return commitError
+	logging.Logger.Info("Waiting for commit to filestore", zap.String("allocation_id", a.AllocationID))
+
+	return eg.Wait()
 }
 
 func (a *AllocationChangeCollector) DeleteChanges(ctx context.Context) {

code/go/0chain.net/blobbercore/handler/object_operation_handler.go

@@ -502,6 +502,8 @@ func (fsh *StorageHandler) CommitWrite(ctx context.Context, r *http.Request) (*b
 	clientKey := ctx.Value(constants.ContextKeyClientKey).(string)
 	clientKeyBytes, _ := hex.DecodeString(clientKey)
 
+	logging.Logger.Info("commit_write", zap.String("allocation_id", allocationId))
+
 	if clientID == "" || clientKey == "" {
 		return nil, common.NewError("invalid_parameters", "Please provide clientID and clientKey")
 	}
@@ -711,7 +713,7 @@ func (fsh *StorageHandler) CommitWrite(ctx context.Context, r *http.Request) (*b
 		}
 	}
 	elapsedCommitStore := time.Since(startTime) - elapsedAllocation - elapsedGetLock - elapsedGetConnObj - elapsedVerifyWM - elapsedWritePreRedeem - elapsedApplyChanges - elapsedSaveAllocation
-
+	logging.Logger.Info("commit_filestore", zap.String("allocation_id", allocationId), zap.String("allocation_root", allocationRoot))
 	connectionObj.DeleteChanges(ctx)
 
 	db.Model(connectionObj).Updates(allocation.AllocationChangeCollector{Status: allocation.CommittedConnection})

code/go/0chain.net/blobbercore/handler/worker.go

@@ -33,6 +33,7 @@ func CleanupDiskFiles(ctx context.Context) error {
 
 func cleanupAllocationFiles(ctx context.Context, allocationObj allocation.Allocation) {
 	mutex := lock.GetMutex(allocationObj.TableName(), allocationObj.ID)
+	logging.Logger.Info("cleanupAllocationLock", zap.Any("allocation_id", allocationObj.ID))
 	mutex.Lock()
 	defer mutex.Unlock()
 	db := datastore.GetStore().GetTransaction(ctx)