Commit f793d3da authored by Kirill Smelkov's avatar Kirill Smelkov

.

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