Commit 635ba959 authored by Kirill Smelkov's avatar Kirill Smelkov

.

parent 4503a0ce
...@@ -506,7 +506,7 @@ func (m *Master) recovery(ctx context.Context) (err error) { ...@@ -506,7 +506,7 @@ func (m *Master) recovery(ctx context.Context) (err error) {
// node comes in and asks to be identified // node comes in and asks to be identified
case n := <-nodeComeq: case n := <-nodeComeq:
peer, ok := m.identify(ctx, n, peer, ok := m.identify(ctx, n,
// XXX only accept: // TODO only accept:
// - S -> PENDING // - S -> PENDING
// - M // - M
) )
...@@ -708,7 +708,7 @@ func (m *Master) verify(ctx context.Context) (err error) { ...@@ -708,7 +708,7 @@ func (m *Master) verify(ctx context.Context) (err error) {
// node comes in and asks to be identified // node comes in and asks to be identified
case n := <-nodeComeq: case n := <-nodeComeq:
peer, ok := m.identify(ctx, n, peer, ok := m.identify(ctx, n,
// XXX only accept: // TODO only accept:
// - S -> known ? RUNNING : PENDING // - S -> known ? RUNNING : PENDING
// - M // - M
) )
...@@ -919,7 +919,7 @@ func (m *Master) serve(ctx context.Context) (err error) { ...@@ -919,7 +919,7 @@ func (m *Master) serve(ctx context.Context) (err error) {
// new connection comes in -> start serving it // new connection comes in -> start serving it
case n := <-nodeComeq: case n := <-nodeComeq:
peer, ok := m.identify(ctx, n, /* XXX accept everyone */) peer, ok := m.identify(ctx, n, /* TODO accept everyone */)
if !ok { if !ok {
break break
} }
......
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