logos-messaging/logos-messaging-go
1
0
Fork 0
mirror of https://github.com/logos-messaging/logos-messaging-go.git synced 2026-01-05 23:43:05 +00:00
Code Issues Packages Projects Releases Wiki Activity

chore: change log levels (#1165)

Browse Source
This commit is contained in:
Prem Chaitanya Prathi 2024-07-17 15:32:32 +05:30 committed by GitHub
parent dacff8a6ae
commit 8afeb529df
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
2 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
waku/v2/peermanager/peer_discovery.go
View File

@ -112,7 +112,7 @@ func (pm *PeerManager) discoverPeersByPubsubTopics(pubsubTopics []string, proto
for _, shardInfo := range shardsInfo { for _, shardInfo := range shardsInfo {
err = pm.DiscoverAndConnectToPeers(ctx, shardInfo.ClusterID, shardInfo.ShardIDs[0], proto, maxCount) err = pm.DiscoverAndConnectToPeers(ctx, shardInfo.ClusterID, shardInfo.ShardIDs[0], proto, maxCount)
if err != nil { if err != nil {
pm.logger.Error("failed to discover and connect to peers", zap.Error(err)) pm.logger.Warn("failed to discover and connect to peers", zap.Error(err))
} }
} }
} else { } else {

2
waku/v2/protocol/peer_exchange/protocol.go
View File

@ -98,7 +98,7 @@ func (wakuPX *WakuPeerExchange) onRequest() func(network.Stream) {
if wakuPX.limiter != nil && !wakuPX.limiter.Allow() { if wakuPX.limiter != nil && !wakuPX.limiter.Allow() {
wakuPX.metrics.RecordError(rateLimitFailure) wakuPX.metrics.RecordError(rateLimitFailure)
wakuPX.log.Error("exceeds the rate limit") wakuPX.log.Info("exceeds the rate limit")
// TODO: peer exchange protocol should contain an err field // TODO: peer exchange protocol should contain an err field
if err := stream.Reset(); err != nil { if err := stream.Reset(); err != nil {
wakuPX.log.Error("resetting connection", zap.Error(err)) wakuPX.log.Error("resetting connection", zap.Error(err))