.

go/neo/mastered.go

@@ -243,6 +243,7 @@ func (node *_MasteredNode) talkMaster1(ctx, ctxPreTalkM context.Context, f func(
 
 		wg := xsync.NewWorkGroup(ctx)
 		// receive and handle notifications from master
+		// XXX no need to spawn "rx prefilter" - just make MasterLink.Recv1() call mlink.Recv1(), check if message should be prefiltered and call Master.recvMaster1. (-> yes)
 		node.rxm = make(chan _RxM)
 		wg.Go(func(ctx context.Context) error {
 			defer task.Running(&ctx, "rx prefilter")(&err)
@@ -292,8 +293,8 @@ func (node *_MasteredNode) recvMaster1(ctx context.Context, req neonet.Request)
 		}
 	}
 
-	// pass request -> RecvM1
-	// NOTE req ownership is passed into RecvM1 caller who becomes responsible to close it
+	// pass request -> recvM1
+	// NOTE req ownership is passed into recvM1 caller who becomes responsible to close it
 	select {
 	case <-ctx.Done():
 		req.Close()

go/neo/storage.go

@@ -48,7 +48,7 @@ import (
 //
 // Storage implements only NEO protocol logic with data being persisted via provided storage.Backend.
 type Storage struct {
-	node *_MasteredNode // XXX -> nodem ?
+	node *_MasteredNode
 
 	// context for providing operational service
 	// it is renewed every time master tells us StartOpertion, so users