mirror of
https://github.com/seaweedfs/seaweedfs.git
synced 2025-10-21 02:28:50 +08:00
remember sync time
This commit is contained in:
@@ -209,6 +209,7 @@ func shouldSendToRemote(entry *filer_pb.Entry) bool {
|
|||||||
}
|
}
|
||||||
|
|
||||||
func updateLocalEntry(filerClient filer_pb.FilerClient, dir string, entry *filer_pb.Entry, remoteEntry *filer_pb.RemoteEntry) error {
|
func updateLocalEntry(filerClient filer_pb.FilerClient, dir string, entry *filer_pb.Entry, remoteEntry *filer_pb.RemoteEntry) error {
|
||||||
|
remoteEntry.LastLocalSyncTsNs = time.Now().UnixNano()
|
||||||
entry.RemoteEntry = remoteEntry
|
entry.RemoteEntry = remoteEntry
|
||||||
return filerClient.WithFilerClient(func(client filer_pb.SeaweedFilerClient) error {
|
return filerClient.WithFilerClient(func(client filer_pb.SeaweedFilerClient) error {
|
||||||
_, err := client.UpdateEntry(context.Background(), &filer_pb.UpdateEntryRequest{
|
_, err := client.UpdateEntry(context.Background(), &filer_pb.UpdateEntryRequest{
|
||||||
|
Reference in New Issue
Block a user