aboutsummaryrefslogtreecommitdiff
path: root/weed/replication/replicator.go
diff options
context:
space:
mode:
authorChris Lu <chris.lu@gmail.com>2018-09-21 01:54:29 -0700
committerChris Lu <chris.lu@gmail.com>2018-09-21 01:54:29 -0700
commita6cfaba018984ba17b9eab802db909bac644b67b (patch)
tree71d00727c28ac5cc527412306db3b98763f2eb68 /weed/replication/replicator.go
parenta8cd7df44ae5d3bea4b0c9ce3d3ab71c7b3cc60c (diff)
downloadseaweedfs-a6cfaba018984ba17b9eab802db909bac644b67b.tar.xz
seaweedfs-a6cfaba018984ba17b9eab802db909bac644b67b.zip
able to sync the changes
Diffstat (limited to 'weed/replication/replicator.go')
-rw-r--r--weed/replication/replicator.go2
1 files changed, 2 insertions, 0 deletions
diff --git a/weed/replication/replicator.go b/weed/replication/replicator.go
index 4f5d5203e..add7f5e2b 100644
--- a/weed/replication/replicator.go
+++ b/weed/replication/replicator.go
@@ -30,6 +30,8 @@ func NewReplicator(sourceConfig, sinkConfig util.Configuration) *Replicator {
}
}
+ sink.SetSourceFiler(source)
+
return &Replicator{
sink: sink,
source: source,