From 7f2a8246a94c367c409bb66d1b501f9ea5f51057 Mon Sep 17 00:00:00 2001 From: Chris Lu Date: Thu, 2 Sep 2021 12:32:59 -0700 Subject: [PATCH] minor --- weed/command/filer_remote_sync.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/weed/command/filer_remote_sync.go b/weed/command/filer_remote_sync.go index 1312a1045..33926b720 100644 --- a/weed/command/filer_remote_sync.go +++ b/weed/command/filer_remote_sync.go @@ -105,8 +105,6 @@ func followUpdatesAndUploadToRemote(option *RemoteSyncOptions, filerSource *sour return fmt.Errorf("read mount info: %v", detectErr) } - lastOffsetTs := collectLastSyncOffset(option, mountedDir) - eachEntryFunc, err := makeEventProcessor(remoteStorage, mountedDir, remoteStorageMountLocation, filerSource) if err != nil { return err @@ -118,6 +116,8 @@ func followUpdatesAndUploadToRemote(option *RemoteSyncOptions, filerSource *sour return remote_storage.SetSyncOffset(option.grpcDialOption, *option.filerAddress, mountedDir, lastTsNs) }) + lastOffsetTs := collectLastSyncOffset(option, mountedDir) + return pb.FollowMetadata(*option.filerAddress, option.grpcDialOption, "filer.remote.sync", mountedDir, []string{filer.DirectoryEtcRemote}, lastOffsetTs.UnixNano(), 0, processEventFnWithOffset, false) }