Commit bb5aa1ec authored by Kirill Smelkov's avatar Kirill Smelkov

.

parent 7984e2ba
...@@ -1170,12 +1170,12 @@ func (m *Master) identify(ctx context.Context, n nodeCome) (peer *_MasteredPeer, ...@@ -1170,12 +1170,12 @@ func (m *Master) identify(ctx context.Context, n nodeCome) (peer *_MasteredPeer,
// and subscribe it for updates. // and subscribe it for updates.
peerCtx, peerCancel := context.WithCancel(m.runCtx) peerCtx, peerCancel := context.WithCancel(m.runCtx)
peer = &_MasteredPeer{ peer = &_MasteredPeer{
node: node, node: node,
wg: xsync.NewWorkGroup(peerCtx), wg: xsync.NewWorkGroup(peerCtx),
cancel: peerCancel, cancel: peerCancel,
idReq: n.req, idReq: n.req,
acceptMsg: accept, acceptMsg: accept,
state0: m.node.State.Snapshot(), state0: m.node.State.Snapshot(),
// TODO change limiting by buffer size -> to limiting by time // TODO change limiting by buffer size -> to limiting by time
// (see notifyAll for details) // (see notifyAll for details)
notifyq: make(chan _ΔClusterState, 1024), notifyq: make(chan _ΔClusterState, 1024),
......
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