Skip to content

Commit 74d915d

Browse files
authored
Merge pull request #1536 from 0chain/fix/precommit-v2
Add delete to v2
2 parents 9fd30ab + 24e3245 commit 74d915d

File tree

1 file changed

+5
-0
lines changed

1 file changed

+5
-0
lines changed

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

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -609,6 +609,11 @@ func (a *AllocationChangeCollector) MoveToFilestoreV2(ctx context.Context, alloc
609609

610610
wg.Wait()
611611
elapsedMove := time.Since(now) - elapsedUpdateAllocation - elapsedDeleteFromFilestore
612+
err = filestore.GetFileStore().DeletePreCommitDir(a.AllocationID)
613+
if err != nil {
614+
logging.Logger.Error("Error while deleting precommit dir", zap.Error(err))
615+
return err
616+
}
612617
logging.Logger.Info("moveToFilestoreV2", zap.Duration("elapsedAllocation", elapsedUpdateAllocation), zap.Duration("elapsedDelete", elapsedDeleteFromFilestore), zap.Duration("elapsedMove", elapsedMove), zap.Duration("elapsedTotal", time.Since(now)), zap.Bool("useRefCache", useRefCache), zap.Int("createRefs", len(refs)), zap.Int("deleteRefs", len(deletedRefs)))
613618
return nil
614619
}

0 commit comments

Comments
 (0)