|
|
@ -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) |
|
|
|
} |
|
|
|