diff options
| author | chrislu <chris.lu@gmail.com> | 2024-06-14 09:17:58 -0700 |
|---|---|---|
| committer | chrislu <chris.lu@gmail.com> | 2024-06-14 09:17:58 -0700 |
| commit | 70b31e3a28b8169289bb9c55052355a3daacfd12 (patch) | |
| tree | 13d530e6df30c724a178f9a79b9ccf18bbc168e7 | |
| parent | 8ffda89ed60526a0162c9de90063dbd208b7a4c7 (diff) | |
| parent | 2a169dde9a4dab7d3b66f1be47b29d42b730f3a6 (diff) | |
| download | seaweedfs-70b31e3a28b8169289bb9c55052355a3daacfd12.tar.xz seaweedfs-70b31e3a28b8169289bb9c55052355a3daacfd12.zip | |
Merge branch 'master' into mq
| -rw-r--r-- | weed/server/filer_grpc_server_sub_meta.go | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/weed/server/filer_grpc_server_sub_meta.go b/weed/server/filer_grpc_server_sub_meta.go index 5deb9d7ca..436d6746a 100644 --- a/weed/server/filer_grpc_server_sub_meta.go +++ b/weed/server/filer_grpc_server_sub_meta.go @@ -29,6 +29,7 @@ func (fs *FilerServer) SubscribeMetadata(req *filer_pb.SubscribeMetadataRequest, if isReplacing { fs.filer.MetaAggregator.ListenersCond.Broadcast() // nudges the subscribers that are waiting } else if alreadyKnown { + fs.filer.MetaAggregator.ListenersCond.Broadcast() // nudges the subscribers that are waiting return fmt.Errorf("duplicated subscription detected for client %s id %d", clientName, req.ClientId) } defer func() { |