.

go/neo/master.go

@@ -81,7 +81,7 @@ type Master struct {
 
 	// main <- node come or go
 	nodeComeq  chan nodeCome  // main <- accept "node connected"
-	nodeLeaveq chan nodeLeave // main <- peerWG.wait "node (should be) disconnected"
+	nodeLeaveq chan nodeLeave // main <- peer.wait "node (should be) disconnected"
 
 	// in addition to nodeTab (which keeps information about a node) tasks
 	// and mastering context that are specific to a peer are organized
@@ -129,10 +129,9 @@ type _MasteredPeer struct {
 
 	// snapshot of nodeTab/partTab/stateCode when peer was accepted by main.
 	state0 *xneo.ClusterStateSnapshot
-	// main -> peerWG.notify  δnodeTab/δpartTab/δstateCode.
+	// main -> peer.notify  δnodeTab/δpartTab/δstateCode.
 	notifyq chan _ΔClusterState
-	// notifyqOverflow becomes ready if main detects that peer is to slow to consume updates
-	// XXX no need? (peer.notify is canceled via peerWork.cancel)
+	// main -> peer.notify  "you are slow to consume updates"
 	notifyqOverflow chan struct{}
 
 	acceptSent chan struct{} // ready after initial accept sequence is sent to the peer