lsm/seaweedfs
1
0
Fork 0
mirror of https://github.com/seaweedfs/seaweedfs.git synced 2025-09-20 09:37:56 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

minor

Browse Source
This commit is contained in:
chrislu
2024-07-16 09:20:59 -07:00
parent b796c21fa9
commit 19d14b4c71
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
weed/command/filer_sync.go
View File

@@ -474,14 +474,14 @@ func genProcessFunction(sourcePath string, targetPath string, excludePaths []str
} }
} else { } else {
// new key is outside of the watched directory // new key is outside the watched directory
if doDeleteFiles { if doDeleteFiles {
key := buildKey(dataSink, message, targetPath, sourceOldKey, sourcePath) key := buildKey(dataSink, message, targetPath, sourceOldKey, sourcePath)
return dataSink.DeleteEntry(key, message.OldEntry.IsDirectory, message.DeleteChunks, message.Signatures) return dataSink.DeleteEntry(key, message.OldEntry.IsDirectory, message.DeleteChunks, message.Signatures)
} }
} }
} else { } else {
// old key is outside of the watched directory // old key is outside the watched directory
if strings.HasPrefix(string(sourceNewKey), sourcePath) { if strings.HasPrefix(string(sourceNewKey), sourcePath) {
// new key is in the watched directory // new key is in the watched directory
key := buildKey(dataSink, message, targetPath, sourceNewKey, sourcePath) key := buildKey(dataSink, message, targetPath, sourceNewKey, sourcePath)
@@ -491,7 +491,7 @@ func genProcessFunction(sourcePath string, targetPath string, excludePaths []str
return nil return nil
} }
} else { } else {
// new key is also outside of the watched directory // new key is also outside the watched directory
// skip // skip
} }
} }