Skip to content

Commit

Permalink
add message type debug info to redundant messages log
Browse files Browse the repository at this point in the history
  • Loading branch information
danwt committed May 16, 2024
1 parent f4c7f07 commit 268b90d
Showing 1 changed file with 5 additions and 0 deletions.
5 changes: 5 additions & 0 deletions relayer/processor/message_processor.go
Original file line number Diff line number Diff line change
Expand Up @@ -494,12 +494,17 @@ func (mp *messageProcessor) sendBatchMessages(
for _, t := range batch {
dst.finishedProcessing <- t
}
var mTypes []string
for _, m := range msgs {
mTypes = append(mTypes, m.Type())
}
errFields := []zapcore.Field{
zap.String("path_name", src.info.PathName),
zap.String("src_chain_id", src.info.ChainID),
zap.String("dst_chain_id", dst.info.ChainID),
zap.String("src_client_id", src.info.ClientID),
zap.String("dst_client_id", dst.info.ClientID),
zap.Any("types", mTypes),
zap.Error(err),
}

Expand Down

0 comments on commit 268b90d

Please sign in to comment.