.

go/neo/master.go

@@ -531,7 +531,12 @@ func (m *Master) recovery(ctx context.Context) (err error) {
 			inprogress--
 
 			if r.err != nil {
-				log.Error(ctx, r.err)
+				// log error if it is not caused by verify cancel
+				// TODO -> xxcontext.Canceled(err) but currently err is
+				//         "...: use of closed network connection"
+				if ctx.Err() == nil {
+					log.Error(ctx, r.err)
+				}
 			} else {
 				// we are interested in latest partTab
 				// NOTE during recovery no one must be subscribed to
@@ -736,7 +741,12 @@ func (m *Master) verify(ctx context.Context) (err error) {
 			inprogress--
 
 			if v.err != nil {
-				log.Error(ctx, v.err)
+				// log error if it is not caused by verify cancel
+				// TODO -> xxcontext.Canceled(err) but currently err is
+				//         "...: use of closed network connection"
+				if ctx.Err() == nil {
+					log.Error(ctx, v.err)
+				}
 
 				// check partTab is still operational
 				// if not -> cancel to go back to recovery
@@ -935,6 +945,15 @@ func (m *Master) serve(ctx context.Context) (err error) {
 		case d := <-servedq:
 			close(d.ack) // XXX explain why (see recovery)
 			inprogress--
+
+			if d.err != nil {
+				// log error if it is not caused by verify cancel
+				// TODO -> xxcontext.Canceled(err) but currently err is
+				//         "...: use of closed network connection"
+				if ctx.Err() == nil {
+					log.Error(ctx, d.err)
+				}
+			}
 		}
 	}