diff options
| author | chrislu <chris.lu@gmail.com> | 2022-01-30 20:23:24 -0800 |
|---|---|---|
| committer | chrislu <chris.lu@gmail.com> | 2022-01-30 20:23:24 -0800 |
| commit | 84c9bc4389e8a52f82cb149ccb72226a6df62d62 (patch) | |
| tree | 517b9042568dab0ea720a9e0da479e2827e01f42 | |
| parent | b8490fe427a6d8a3e7b2c2d3a586c7e5863cf59f (diff) | |
| download | seaweedfs-84c9bc4389e8a52f82cb149ccb72226a6df62d62.tar.xz seaweedfs-84c9bc4389e8a52f82cb149ccb72226a6df62d62.zip | |
edge case: old entry was not replicated to remote storage
| -rw-r--r-- | weed/command/filer_remote_gateway_buckets.go | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/weed/command/filer_remote_gateway_buckets.go b/weed/command/filer_remote_gateway_buckets.go index 4f65b5842..afe640f5f 100644 --- a/weed/command/filer_remote_gateway_buckets.go +++ b/weed/command/filer_remote_gateway_buckets.go @@ -264,7 +264,7 @@ func (option *RemoteGatewayOptions) makeBucketedEventProcessor(filerSource *sour // update directory property 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) oldDest := toRemoteStorageLocation(oldBucket, util.NewFullPath(resp.Directory, message.OldEntry.Name), oldRemoteStorageMountLocation) return client.UpdateFileMetadata(oldDest, message.OldEntry, message.NewEntry) |