edge case: old entry was not replicated to remote storage

This commit is contained in:
chrislu 2022-01-30 20:23:24 -08:00
parent b8490fe427
commit 84c9bc4389

View file

@ -264,7 +264,7 @@ func (option *RemoteGatewayOptions) makeBucketedEventProcessor(filerSource *sour
// update directory property // update directory property
return nil return nil
} }
if filer.IsSameData(message.OldEntry, message.NewEntry) { if message.OldEntry.RemoteEntry != nil && filer.IsSameData(message.OldEntry, message.NewEntry) {
glog.V(2).Infof("update meta: %+v", resp) glog.V(2).Infof("update meta: %+v", resp)
oldDest := toRemoteStorageLocation(oldBucket, util.NewFullPath(resp.Directory, message.OldEntry.Name), oldRemoteStorageMountLocation) oldDest := toRemoteStorageLocation(oldBucket, util.NewFullPath(resp.Directory, message.OldEntry.Name), oldRemoteStorageMountLocation)
return client.UpdateFileMetadata(oldDest, message.OldEntry, message.NewEntry) return client.UpdateFileMetadata(oldDest, message.OldEntry, message.NewEntry)