forks/go-ethereum
1
0
Fork 1
mirror of https://github.com/ethereum/go-ethereum.git synced 2026-08-20 10:52:25 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

rpc : fix quit channel goroutine leak

Browse source
This commit is contained in:
ucwong 2020-04-03 08:52:47 +00:00
parent f7b29ec942
commit 6c678a5cc0
2 changed files with 4 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
rpc/client.go
View file

@ -209,9 +209,9 @@ func initClient(conn ServerCodec, idgen func() ID, services *serviceRegistry) *C
isHTTP: isHTTP, isHTTP: isHTTP,
services: services, services: services,
writeConn: conn, writeConn: conn,
close: make(chan struct{}), close: make(chan struct{}, 1),
closing: make(chan struct{}), closing: make(chan struct{}, 1),
didClose: make(chan struct{}), didClose: make(chan struct{}, 1),
reconnected: make(chan ServerCodec), reconnected: make(chan ServerCodec),
readOp: make(chan readOp), readOp: make(chan readOp),
readErr: make(chan error), readErr: make(chan error),

2
rpc/subscription.go
View file

@ -219,7 +219,7 @@ func newClientSubscription(c *Client, namespace string, channel reflect.Value) *
namespace: namespace, namespace: namespace,
etype: channel.Type().Elem(), etype: channel.Type().Elem(),
channel: channel, channel: channel,
quit: make(chan struct{}), quit: make(chan struct{}, 1),
err: make(chan error, 1), err: make(chan error, 1),
in: make(chan json.RawMessage), in: make(chan json.RawMessage),
} }