aboutsummaryrefslogtreecommitdiff
path: root/weed/server
diff options
context:
space:
mode:
authorChris Lu <chris.lu@gmail.com>2020-04-19 23:54:32 -0700
committerChris Lu <chris.lu@gmail.com>2020-04-19 23:54:32 -0700
commit2955b96ef1f05cc395b2625d8b1ff4556e683081 (patch)
tree91823d8c5b9c9eda0d4d78eb94f3dd1eeddba3f7 /weed/server
parentdf25ed3c5be7e1984f8a9316cbaa3deb824276fb (diff)
downloadseaweedfs-2955b96ef1f05cc395b2625d8b1ff4556e683081.tar.xz
seaweedfs-2955b96ef1f05cc395b2625d8b1ff4556e683081.zip
refactor
Diffstat (limited to 'weed/server')
-rw-r--r--weed/server/filer_grpc_server_listen.go1
1 files changed, 1 insertions, 0 deletions
diff --git a/weed/server/filer_grpc_server_listen.go b/weed/server/filer_grpc_server_listen.go
index ea3abe28f..e3de57145 100644
--- a/weed/server/filer_grpc_server_listen.go
+++ b/weed/server/filer_grpc_server_listen.go
@@ -22,6 +22,7 @@ func (fs *FilerServer) SubscribeMetadata(req *filer_pb.SubscribeMetadataRequest,
if req.SinceNs > 0 {
lastReadTime = time.Unix(0, req.SinceNs)
}
+
var readErr error
for {