Commit e34bd42f authored by Kirill Smelkov's avatar Kirill Smelkov

.

parent bf8c0af0
...@@ -243,7 +243,7 @@ func (m *Master) Run(ctx context.Context, l xnet.Listener) (err error) { ...@@ -243,7 +243,7 @@ func (m *Master) Run(ctx context.Context, l xnet.Listener) (err error) {
// update nodeTab with self // update nodeTab with self
m.updateNodeTab(ctx, m.node.MyInfo) m.updateNodeTab(ctx, m.node.MyInfo)
// wrap listener with link / identificaton hello checker // wrap listener with link / identification hello checker
lli := xneo.NewListener(neonet.NewLinkListener(l)) lli := xneo.NewListener(neonet.NewLinkListener(l))
// accept: accept incoming connections and pass them to main driver // accept: accept incoming connections and pass them to main driver
...@@ -1285,7 +1285,7 @@ func (p *_MasteredPeer) run(ctx context.Context, f func() error) error { ...@@ -1285,7 +1285,7 @@ func (p *_MasteredPeer) run(ctx context.Context, f func() error) error {
} }
} }
// notify proxies δnodeTab/δpeerTab/δClusterState update to the peer. // notify proxies δnodeTab/δpartTab/δClusterState update to the peer.
// XXX merge into m.acceptPeer ? // XXX merge into m.acceptPeer ?
func (p *_MasteredPeer) notify(ctx context.Context) (err error) { func (p *_MasteredPeer) notify(ctx context.Context) (err error) {
defer task.Runningf(&ctx, "notify %s", p.node.NID)(&err) defer task.Runningf(&ctx, "notify %s", p.node.NID)(&err)
......
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