Commit 367842e1 authored by Kirill Smelkov's avatar Kirill Smelkov

.

parent f793d3da
......@@ -891,7 +891,8 @@ func storCtlService(ctx context.Context, stor *xneo.PeerNode) (err error) {
defer task.Runningf(&ctx, "%s: stor service", slink.RemoteAddr())(&err)
// XXX current neo/py does StartOperation / NotifyReady as separate
// sends, not exchange on the same conn. - py draftly fixed in 4eaaf186.
// sends, not exchange on the same conn. - py draftly fixed: see
// https://lab.nexedi.com/kirr/neo/commit/4eaaf186 for context.
ready := proto.NotifyReady{}
err = slink.Ask1(&proto.StartOperation{Backup: false}, &ready)
//err = slink.Send1(&proto.StartOperation{Backup: false})
......
......@@ -265,7 +265,8 @@ func (stor *Storage) m1serve(ctx context.Context, mlink *_MasterLink, reqStart *
defer opCancel()
// reply M we are ready
// XXX NEO/py sends NotifyReady on another conn; we patched py: see 4eaaf186 for context
// XXX NEO/py sends NotifyReady on another conn; we patched py: see
// https://lab.nexedi.com/kirr/neo/commit/4eaaf186 for context.
err = reqStart.Reply(&proto.NotifyReady{})
reqStart.Close()
if err != nil {
......
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