Skip to content

Commit

Permalink
mixpool: Debug log accepted messages
Browse files Browse the repository at this point in the history
This allows us to remove an unnecessary log from the wallet (which was only
being done in RPC mode and missing from SPV).
  • Loading branch information
jrick committed May 30, 2024
1 parent 3c84d00 commit 2d5fada
Showing 1 changed file with 26 additions and 4 deletions.
30 changes: 26 additions & 4 deletions mixing/mixpool/mixpool.go
Original file line number Diff line number Diff line change
Expand Up @@ -22,6 +22,7 @@ import (
"github.com/decred/dcrd/txscript/v4/stdaddr"
"github.com/decred/dcrd/txscript/v4/stdscript"
"github.com/decred/dcrd/wire"
"github.com/decred/slog"
)

const minconf = 1
Expand Down Expand Up @@ -838,10 +839,31 @@ var zeroHash chainhash.Hash
func (p *Pool) AcceptMessage(msg mixing.Message) (accepted []mixing.Message, err error) {
hash := msg.Hash()
defer func() {
if err == nil {
log.Tracef("AcceptMessage: accepted message %T %v", msg, hash)
} else {
log.Tracef("AcceptMessage: rejected message %T %v: %v", msg, hash, err)
if err == nil && len(accepted) == 0 {
// Duplicate message; don't log it again.
return
}
if log.Level() > slog.LevelDebug {
return
}
if err != nil {
switch msg.(type) {
case *wire.MsgMixPairReq:
log.Debugf("Rejected message %T %v: %v", msg, hash, err)
default:
log.Debugf("Rejected message %T %v (session %x run %d): %v",
msg, hash, msg.Sid(), msg.GetRun(), err)
}
return
}
for _, msg := range accepted {
switch msg.(type) {
case *wire.MsgMixPairReq:
log.Debugf("Accepted message %T %v", msg, hash)
default:
log.Debugf("Accepted message %T %v (session %x run %d)",
msg, hash, msg.Sid(), msg.GetRun())
}
}
}()

Expand Down

0 comments on commit 2d5fada

Please sign in to comment.