.

go/neo/master.go

@@ -415,7 +415,7 @@ func (m *Master) recovery(ctx context.Context) (err error) {
 	// XXX set cluster state = RECOVERY
 	// XXX down clients
 
-	// goStorCtlRecovery spawns recovery task on a storage.
+	// goStorCtlRecovery spawns recovery task on a storage peer.
 	goStorCtlRecovery := func(stor *_MasteredPeer) {
 		inprogress++
 		// XXX wg.Add(1) + defer wg.Done() ?
@@ -541,14 +541,9 @@ loop2:
 	for {
 		select {
 		case r := <-recoveryq:
-			// XXX dup wrt <-recovery handler above
+			close(r.ack)
 			log.Error(ctx, r.err)
 
-			if !xcontext.Canceled(r.err) {
-				r.stor.ResetLink(ctx)
-				m.updateNodeState(ctx, r.stor, proto.DOWN)
-				// XXX nodeLeave <-
-			}
 
 		case <-done:
 			break loop2