aboutsummaryrefslogtreecommitdiff
path: root/weed/command/filer_sync.go
diff options
context:
space:
mode:
authorcreeew <hzq233@foxmail.com>2022-06-02 01:28:47 +0800
committercreeew <hzq233@foxmail.com>2022-06-02 01:28:47 +0800
commit02ae102731496689885dd133e2b6aa57ba634b4e (patch)
tree0795b931e9ce6c7b147cff99159c68959bfffd26 /weed/command/filer_sync.go
parent6793bc853c8b54823157bda6af4385411f8f6aea (diff)
downloadseaweedfs-02ae102731496689885dd133e2b6aa57ba634b4e.tar.xz
seaweedfs-02ae102731496689885dd133e2b6aa57ba634b4e.zip
fix filer.sync missing source srv uploaded files to target when target down
Diffstat (limited to 'weed/command/filer_sync.go')
-rw-r--r--weed/command/filer_sync.go2
1 files changed, 1 insertions, 1 deletions
diff --git a/weed/command/filer_sync.go b/weed/command/filer_sync.go
index 2dd780a75..deb458525 100644
--- a/weed/command/filer_sync.go
+++ b/weed/command/filer_sync.go
@@ -178,7 +178,7 @@ func doSubscribeFilerMetaChanges(clientId int32, grpcDialOption grpc.DialOption,
})
return pb.FollowMetadata(sourceFiler, grpcDialOption, "syncTo_"+string(targetFiler), clientId,
- sourcePath, nil, sourceFilerOffsetTsNs, 0, targetFilerSignature, processEventFnWithOffset, false)
+ sourcePath, nil, sourceFilerOffsetTsNs, 0, targetFilerSignature, processEventFnWithOffset, pb.RetryForeverOnError)
}