Skip to content

N
neo
Commit 149be5e9 authored by Kirill Smelkov's avatar Kirill Smelkov
Browse files
Options

.

parent 1d3db8a3
Hide whitespace changes
Inline Side-by-side
Showing with 1 addition and 0 deletions
go/neo/client.go
View file @ 149be5e9
...@@ -121,6 +121,7 @@ func (cli *Client) Run(ctx context.Context) (err error) { ...@@ -121,6 +121,7 @@ func (cli *Client) Run(ctx context.Context) (err error) {
cli.runCancel = cancel cli.runCancel = cancel
// cli.node.OnShutdown = cancel // XXX ok? // cli.node.OnShutdown = cancel // XXX ok?
// return cli.talkMaster(ctx) // return cli.talkMaster(ctx)
cli.runWG = xsync.NewWorkGroup(ctx) // XXX create it in NewClient ? (Close also uses it)
cli.runWG.Go(cli.node.talkMaster) cli.runWG.Go(cli.node.talkMaster)
cli.runWG.Go(cli.recvMaster) cli.runWG.Go(cli.recvMaster)
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment
GitLab Nexedi Edition | About GitLab | About Nexedi | 沪ICP备2021021310号-2 | 沪ICP备2021021310号-7