diff options
| author | Chris Lu <chris.lu@gmail.com> | 2020-05-10 03:48:35 -0700 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2020-05-10 03:48:35 -0700 |
| commit | 6bf3eb69cb9abd02e1d63ecdee485d198a3cab9a (patch) | |
| tree | f1cf35c6d8322db60b36793cf8bf1f0d0fdc537c /weed/messaging/msgclient | |
| parent | 78afb8bf4699f85083160f8bfee2f04493985cd1 (diff) | |
| download | seaweedfs-6bf3eb69cb9abd02e1d63ecdee485d198a3cab9a.tar.xz seaweedfs-6bf3eb69cb9abd02e1d63ecdee485d198a3cab9a.zip | |
async chan write read, no write for closed chan
Diffstat (limited to 'weed/messaging/msgclient')
| -rw-r--r-- | weed/messaging/msgclient/sub_chan.go | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/weed/messaging/msgclient/sub_chan.go b/weed/messaging/msgclient/sub_chan.go index aae5c0c71..ed25a850c 100644 --- a/weed/messaging/msgclient/sub_chan.go +++ b/weed/messaging/msgclient/sub_chan.go @@ -55,8 +55,8 @@ func (mc *MessagingClient) NewSubChannel(chanName string) (*SubChannel, error) { close(t.ch) return } - t.md5hash.Write(resp.Data.Value) t.ch <- resp.Data.Value + t.md5hash.Write(resp.Data.Value) } }() |