diff options
| author | Neo <pirloandkaka@gmail.com> | 2023-02-01 10:56:11 +0800 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2023-01-31 18:56:11 -0800 |
| commit | b9b613a78e2832565e0ec6fc703e3cd4e066ee16 (patch) | |
| tree | 6a360f68d9f2dde3745531719128afda70c23010 | |
| parent | 665917fdf1c11f9558e0ab70e9e0f8503e4299ed (diff) | |
| download | seaweedfs-b9b613a78e2832565e0ec6fc703e3cd4e066ee16.tar.xz seaweedfs-b9b613a78e2832565e0ec6fc703e3cd4e066ee16.zip | |
filter system log dir does not make subscribe event (#4172)
| -rw-r--r-- | weed/filer/filer.go | 11 |
1 files changed, 7 insertions, 4 deletions
diff --git a/weed/filer/filer.go b/weed/filer/filer.go index 07d40acc8..f6f06d9b2 100644 --- a/weed/filer/filer.go +++ b/weed/filer/filer.go @@ -3,14 +3,15 @@ package filer import ( "context" "fmt" - "github.com/seaweedfs/seaweedfs/weed/cluster" - "github.com/seaweedfs/seaweedfs/weed/pb" - "github.com/seaweedfs/seaweedfs/weed/pb/master_pb" "os" "sort" "strings" "time" + "github.com/seaweedfs/seaweedfs/weed/cluster" + "github.com/seaweedfs/seaweedfs/weed/pb" + "github.com/seaweedfs/seaweedfs/weed/pb/master_pb" + "google.golang.org/grpc" "github.com/seaweedfs/seaweedfs/weed/glog" @@ -254,7 +255,9 @@ func (f *Filer) ensureParentDirectoryEntry(ctx context.Context, entry *Entry, di return fmt.Errorf("mkdir %s: %v", dirPath, mkdirErr) } } else { - f.NotifyUpdateEvent(ctx, nil, dirEntry, false, isFromOtherCluster, nil) + if !strings.HasPrefix("/"+util.Join(dirParts[:]...), SystemLogDir) { + f.NotifyUpdateEvent(ctx, nil, dirEntry, false, isFromOtherCluster, nil) + } } } else if !dirEntry.IsDirectory() { |