.

go/neo/client.go

@@ -368,8 +368,18 @@ func (c *Client) recvMaster(ctx context.Context) (err error) {
 	for {
 		req, err := c.node.RecvM1()
 		if err != nil {
-			return err // XXX eventReconnect
+			switch {
+			// reconnected to master
+			case errors.Is(err, eventMasterReconnect):
+				c.head0 = c.head
+				// XXX -> initFromMaster
+
+			default:
+				return err
+			}
+			continue
 		}
+
 		err = c.recvMaster1(req.Msg)
 		req.Close()
 		if err != nil {

go/neo/mastered.go

@@ -219,7 +219,16 @@ func (node *_MasteredNode) talkMaster1(ctx context.Context) error {
 		}
 
 		// XXX update .masterLink + notify waiters
-		// XXX rxm <- eventReconnect
+
+		// RecvM1 <- eventReconnect
+		select {
+		case <-ctx.Done():
+			return ctx.Err()
+
+		case node.rxm <- _RxM{Err: eventMasterReconnect}:
+			// ok
+		}
+
 
 		// receive and handle notifications from master
 		defer task.Running(&ctx, "rx")(&err)
@@ -275,6 +284,8 @@ func (node *_MasteredNode) recvMaster1(ctx context.Context, req neonet.Request)
 	return nil
 }
 
+var eventMasterReconnect = errors.New("(re)connected to master")
+
 // RecvM1 receives request from master filtered through δstate handler.
 //
 // XXX eventReconnect