.

go/neo/mastered.go

@@ -149,6 +149,7 @@ func (node *_MasteredNode) talkMaster1(ctx, ctxPreTalkM context.Context, f func(
 		return err
 	}
 
+	// XXX close on RetCancel
 	return xcontext.WithCloseOnErrCancel(ctx, mlink, func() (err error) {
 		if accept.YourNID != node.MyInfo.NID {
 			log.Infof(ctx, "master %s told us to be %s", accept.MyNID, accept.YourNID)
@@ -202,6 +203,8 @@ func (node *_MasteredNode) talkMaster1(ctx, ctxPreTalkM context.Context, f func(
 
 		// run user code
 		return f(ctx, &_MasterLink{mlink, node})
+
+		// TODO ? send "disconnect" on Close (? proto.CloseClient)
 	})
 }