local: try to eliminate hash memory leak

backend/local/local.go

@@ -654,9 +654,9 @@ func (f *Fs) Purge(ctx context.Context, dir string) error {
 
 // Move src to this remote using server-side move operations.
 //
-// This is stored with the remote path given
+// # This is stored with the remote path given
 //
-// It returns the destination Object and a possible error
+// # It returns the destination Object and a possible error
 //
 // Will only be called if src.Fs().Name() == f.Name()
 //
@@ -898,6 +898,13 @@ func (o *Object) Hash(ctx context.Context, r hash.Type) (string, error) {
  return hashValue, nil
 }
 
+// ClearHashes clears all types of calculated hashes.
+func (o *Object) ClearHashes() {
+ o.fs.objectMetaMu.RLock()
+ defer o.fs.objectMetaMu.RUnlock()
+ o.hashes = nil
+}
+
 // Size returns the size of an object in bytes
 func (o *Object) Size() int64 {
  o.fs.objectMetaMu.RLock()

fs/sync/sync.go

@@ -11,6 +11,7 @@ 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"
@@ -408,6 +409,10 @@ func (s *syncCopyMove) pairCopyOrMove(ctx context.Context, in *pipe, fdst fs.Fs,
  } else {
  _, 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()
+ }
  s.processError(err)
  }
 }