WIP

scylladb · Nov 17, 2023 · 40c8136 · 40c8136
1 parent 3337295
commit 40c8136
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 0 deletions.
diff --git a/fs/accounting/transfer.go b/fs/accounting/transfer.go
@@ -181,6 +181,14 @@ func (tr *Transfer) Done(ctx context.Context, err error) {
  tr.stats.PruneTransfers()
 }
 
+func (tr *Transfer) IdenticalCheck() {
+ tr.mu.Lock()
+ defer tr.mu.Unlock()
+ tr.acc.mu.Lock()
+ defer tr.acc.mu.Unlock()
+ tr.acc.values.bytes = -1
+}
+
 // Reset allows to switch the Account to another transfer method.
 func (tr *Transfer) Reset(ctx context.Context) {
  tr.mu.RLock()

diff --git a/fs/operations/check.go b/fs/operations/check.go
@@ -118,6 +118,7 @@ func (c *checkMarch) checkIdentical(ctx context.Context, dst, src fs.Object) (di
  tr := accounting.Stats(ctx).NewCheckingTransfer(src)
  defer func() {
  tr.Done(ctx, err)
+ tr.IdenticalCheck()
  }()
  if sizeDiffers(ctx, src, dst) {
  err = errors.Errorf("Sizes differ")