diff options
| author | Chris Lu <chris.lu@gmail.com> | 2020-07-05 15:52:36 -0700 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2020-07-05 15:52:36 -0700 |
| commit | 49929e0869b27efb1d13dd9883a7f4f0351ac980 (patch) | |
| tree | b836db092631dfe9a6eb249a38b0e268519ba8bc /weed/server | |
| parent | 70d8a3a1d3395ece4a37c5aac1249293b57d5975 (diff) | |
| download | seaweedfs-49929e0869b27efb1d13dd9883a7f4f0351ac980.tar.xz seaweedfs-49929e0869b27efb1d13dd9883a7f4f0351ac980.zip | |
rename
Diffstat (limited to 'weed/server')
| -rw-r--r-- | weed/server/filer_grpc_server_sub_meta.go | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/weed/server/filer_grpc_server_sub_meta.go b/weed/server/filer_grpc_server_sub_meta.go index c82a58b16..e7e5b0d48 100644 --- a/weed/server/filer_grpc_server_sub_meta.go +++ b/weed/server/filer_grpc_server_sub_meta.go @@ -37,7 +37,7 @@ func (fs *FilerServer) SubscribeMetadata(req *filer_pb.SubscribeMetadataRequest, lastReadTime = time.Unix(0, processedTsNs) } - err = fs.filer.MetaLogBuffer.LoopProcessLogData(lastReadTime, func() bool { + err = fs.filer.LocalMetaLogBuffer.LoopProcessLogData(lastReadTime, func() bool { fs.listenersLock.Lock() fs.listenersCond.Wait() fs.listenersLock.Unlock() @@ -63,7 +63,7 @@ func (fs *FilerServer) SubscribeLocalMetadata(req *filer_pb.SubscribeMetadataReq eachLogEntryFn := eachLogEntryFn(eachEventNotificationFn) - err := fs.filer.MetaLogBuffer.LoopProcessLogData(lastReadTime, func() bool { + err := fs.filer.LocalMetaLogBuffer.LoopProcessLogData(lastReadTime, func() bool { fs.listenersLock.Lock() fs.listenersCond.Wait() fs.listenersLock.Unlock() |