mirror of
https://github.com/chrislusf/seaweedfs
synced 2024-07-07 09:37:49 +02:00
adjust invalidation logic
This commit is contained in:
parent
ccc44059e8
commit
223c1b3571
|
@ -41,8 +41,10 @@ func SubscribeMetaEvents(mc *MetaCache, selfSignature int32, client filer_pb.Fil
|
||||||
if message.OldEntry != nil && message.NewEntry != nil {
|
if message.OldEntry != nil && message.NewEntry != nil {
|
||||||
oldKey := util.NewFullPath(resp.Directory, message.OldEntry.Name)
|
oldKey := util.NewFullPath(resp.Directory, message.OldEntry.Name)
|
||||||
mc.invalidateFunc(oldKey)
|
mc.invalidateFunc(oldKey)
|
||||||
newKey := util.NewFullPath(dir, message.NewEntry.Name)
|
if message.OldEntry.Name != message.NewEntry.Name {
|
||||||
mc.invalidateFunc(newKey)
|
newKey := util.NewFullPath(dir, message.NewEntry.Name)
|
||||||
|
mc.invalidateFunc(newKey)
|
||||||
|
}
|
||||||
} else if message.OldEntry == nil && message.NewEntry != nil {
|
} else if message.OldEntry == nil && message.NewEntry != nil {
|
||||||
// no need to invaalidate
|
// no need to invaalidate
|
||||||
} else if message.OldEntry != nil && message.NewEntry == nil {
|
} else if message.OldEntry != nil && message.NewEntry == nil {
|
||||||
|
|
Loading…
Reference in a new issue