diff --git a/net/streampool/streampool.go b/net/streampool/streampool.go index 48345bcb..62a0b8a7 100644 --- a/net/streampool/streampool.go +++ b/net/streampool/streampool.go @@ -235,8 +235,6 @@ func (s *streamPool) Send(ctx context.Context, msg drpc.Message, peerGetter Peer for _, p := range peers { if e := s.sendOne(ctx, p, msg); e != nil { log.InfoCtx(ctx, "send peer error", zap.Error(e), zap.String("peerId", p.Id())) - } else { - log.DebugCtx(ctx, "send success", zap.String("peerId", p.Id())) } } }) @@ -261,7 +259,6 @@ func (s *streamPool) SendById(ctx context.Context, msg drpc.Message, peerIds ... if e := st.write(msg); e != nil { st.l.Debug("sendById write error", zap.Error(e)) } else { - st.l.DebugCtx(ctx, "sendById success") return } } @@ -284,8 +281,6 @@ func (s *streamPool) sendOne(ctx context.Context, p peer.Peer, msg drpc.Message) // continue with next stream continue } else { - st.l.DebugCtx(ctx, "sendOne success") - // stop sending on success break } }