anyproto/any-sync
1
0
Fork 0
mirror of https://github.com/anyproto/any-sync.git synced 2025-06-08 05:57:03 +09:00
Code Activity

Remove success logs

Browse source
This commit is contained in:
Mikhail Rakhmanov 2025-03-11 17:41:11 +01:00
parent 0cac23037c
commit a3f2e5f725
No known key found for this signature in database
GPG key ID: DED12CFEF5B8396B
1 changed files with 0 additions and 5 deletions
Download patch file Download diff file Expand all files Collapse all files

5
net/streampool/streampool.go
View file

@ -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
}
}