Skip to content

Commit

Permalink
Merge branch 'release/0.5.0' into chore/documentation
Browse files Browse the repository at this point in the history
  • Loading branch information
Rahul Ghangas committed Apr 19, 2021
2 parents 5d2a93a + 6234359 commit 5b762f0
Showing 1 changed file with 3 additions and 3 deletions.
6 changes: 3 additions & 3 deletions peer/gossip.go
Original file line number Diff line number Diff line change
Expand Up @@ -68,7 +68,7 @@ func (g *Gossiper) Gossip(ctx context.Context, contentID []byte, subnet *id.Hash
for _, recipient := range recipients {
innerContext, cancel := context.WithTimeout(ctx, g.opts.Timeout)
if err := g.transport.Send(innerContext, recipient, msg); err != nil {
g.opts.Logger.DPanic("pushing gossip", zap.String("peer", recipient.String()), zap.Error(err))
g.opts.Logger.Error("pushing gossip", zap.String("peer", recipient.String()), zap.Error(err))
}
cancel()
}
Expand Down Expand Up @@ -148,7 +148,7 @@ func (g *Gossiper) didReceivePush(from id.Signatory, msg wire.Msg) {
To: id.Hash(from),
Data: msg.Data,
}); err != nil {
g.opts.Logger.DPanic("pull", zap.String("peer", from.String()), zap.String("id", base64.RawURLEncoding.EncodeToString(msg.Data)), zap.Error(err))
g.opts.Logger.Error("pull", zap.String("peer", from.String()), zap.String("id", base64.RawURLEncoding.EncodeToString(msg.Data)), zap.Error(err))
return
}
}
Expand Down Expand Up @@ -188,7 +188,7 @@ func (g *Gossiper) didReceivePull(from id.Signatory, msg wire.Msg) {
Data: msg.Data,
SyncData: content,
}); err != nil {
g.opts.Logger.DPanic("sync", zap.String("peer", from.String()), zap.String("id", base64.RawURLEncoding.EncodeToString(msg.Data)), zap.Error(err))
g.opts.Logger.Error("sync", zap.String("peer", from.String()), zap.String("id", base64.RawURLEncoding.EncodeToString(msg.Data)), zap.Error(err))
}
return
}
Expand Down

0 comments on commit 5b762f0

Please sign in to comment.