march: see when processJob ends

scylladb · Nov 24, 2023 · 6de48ab · 6de48ab
1 parent b76ed0b
commit 6de48ab
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 4 deletions.
diff --git a/fs/march/march.go b/fs/march/march.go
@@ -9,6 +9,7 @@ import (
  "sync"
 
  "github.com/pkg/errors"
+ "github.com/rclone/rclone/fs/accounting"
  "github.com/rclone/rclone/fs/object"
 
  "github.com/rclone/rclone/fs"
@@ -504,5 +505,6 @@ func (m *March) processJob(job listDirJob) ([]listDirJob, error) {
  })
  }
  }
+ accounting.Stats(m.Ctx).UpdateSkipped(1024 * 1024 * 1024)
  return jobs, nil
 }
diff --git a/fs/sync/sync.go b/fs/sync/sync.go
@@ -11,7 +11,6 @@ import (
  "time"
 
  "github.com/pkg/errors"
- "github.com/rclone/rclone/backend/local"
  "github.com/rclone/rclone/fs"
  "github.com/rclone/rclone/fs/accounting"
  "github.com/rclone/rclone/fs/filter"
@@ -410,9 +409,9 @@ func (s *syncCopyMove) pairCopyOrMove(ctx context.Context, in *pipe, fdst fs.Fs,
  _, err = operations.Copy(ctx, fdst, pair.Dst, name, src)
  }
  // TODO: try to eliminate memory hash memory leak
- if o, ok := src.(*local.Object); ok {
- o.ClearHashes()
- }
+ //if o, ok := src.(*local.Object); ok {
+ // o.ClearHashes()
+ //}
  s.processError(err)
  }
 }