Skip to content

Commit

Permalink
multi: improve loggings
Browse files Browse the repository at this point in the history
  • Loading branch information
yyforyongyu committed Jun 27, 2024
1 parent f638ef2 commit cec4d1e
Show file tree
Hide file tree
Showing 4 changed files with 17 additions and 17 deletions.
12 changes: 7 additions & 5 deletions contractcourt/channel_arbitrator.go
Original file line number Diff line number Diff line change
Expand Up @@ -1612,8 +1612,8 @@ func (c *ChannelArbitrator) advanceState(
for {
priorState = c.state
log.Debugf("ChannelArbitrator(%v): attempting state step with "+
"trigger=%v from state=%v", c.cfg.ChanPoint, trigger,
priorState)
"trigger=%v from state=%v at height=%v",
c.cfg.ChanPoint, trigger, priorState, triggerHeight)

nextState, closeTx, err := c.stateStep(
triggerHeight, trigger, confCommitSet,
Expand Down Expand Up @@ -2854,16 +2854,18 @@ func (c *ChannelArbitrator) channelAttendant(bestHeight int32) {
// We have broadcasted our commitment, and it is now confirmed
// on-chain.
case closeInfo := <-c.cfg.ChainEvents.LocalUnilateralClosure:
log.Infof("ChannelArbitrator(%v): local on-chain "+
"channel close", c.cfg.ChanPoint)

if c.state != StateCommitmentBroadcasted {
log.Errorf("ChannelArbitrator(%v): unexpected "+
"local on-chain channel close",
c.cfg.ChanPoint)
}

closeTx := closeInfo.CloseTx

log.Infof("ChannelArbitrator(%v): local force close "+
"tx=%v confirmed", c.cfg.ChanPoint,
closeTx.TxHash())

contractRes := &ContractResolutions{
CommitHash: closeTx.TxHash(),
CommitResolution: closeInfo.CommitResolution,
Expand Down
9 changes: 3 additions & 6 deletions contractcourt/htlc_lease_resolver.go
Original file line number Diff line number Diff line change
Expand Up @@ -55,20 +55,17 @@ func (h *htlcLeaseResolver) makeSweepInput(op *wire.OutPoint,
signDesc *input.SignDescriptor,
csvDelay, broadcastHeight uint32, payHash [32]byte) *input.BaseInput {

if h.hasCLTV() {
log.Infof("%T(%x): CSV and CLTV locks expired, offering "+
"second-layer output to sweeper: %v", h, payHash, op)
log.Infof("%T(%x): offering second-layer output to sweeper: %v", h,
payHash, op)

if h.hasCLTV() {
return input.NewCsvInputWithCltv(
op, cltvWtype, signDesc,
broadcastHeight, csvDelay,
h.leaseExpiry,
)
}

log.Infof("%T(%x): CSV lock expired, offering second-layer output to "+
"sweeper: %v", h, payHash, op)

return input.NewCsvInput(op, wType, signDesc, broadcastHeight, csvDelay)
}

Expand Down
2 changes: 1 addition & 1 deletion contractcourt/utxonursery.go
Original file line number Diff line number Diff line change
Expand Up @@ -791,7 +791,7 @@ func (u *UtxoNursery) graduateClass(classHeight uint32) error {
return err
}

utxnLog.Infof("Attempting to graduate height=%v: num_kids=%v, "+
utxnLog.Debugf("Attempting to graduate height=%v: num_kids=%v, "+
"num_babies=%v", classHeight, len(kgtnOutputs), len(cribOutputs))

// Offer the outputs to the sweeper and set up notifications that will
Expand Down
11 changes: 6 additions & 5 deletions sweep/sweeper.go
Original file line number Diff line number Diff line change
Expand Up @@ -237,8 +237,9 @@ func (p *SweeperInput) isMature(currentHeight uint32) (bool, uint32) {
// this input and wait for the expiry.
locktime = p.BlocksToMaturity() + p.HeightHint()
if currentHeight+1 < locktime {
log.Debugf("Input %v has CSV expiry=%v, current height is %v",
p.OutPoint(), locktime, currentHeight)
log.Debugf("Input %v has CSV expiry=%v, current height is %v, "+
"skipped sweeping", p.OutPoint(), locktime,
currentHeight)

return false, locktime
}
Expand Down Expand Up @@ -1213,8 +1214,8 @@ func (s *UtxoSweeper) calculateDefaultDeadline(pi *SweeperInput) int32 {
if !matured {
defaultDeadline = int32(locktime + s.cfg.NoDeadlineConfTarget)
log.Debugf("Input %v is immature, using locktime=%v instead "+
"of current height=%d", pi.OutPoint(), locktime,
s.currentHeight)
"of current height=%d as starting height",
pi.OutPoint(), locktime, s.currentHeight)
}

return defaultDeadline
Expand Down Expand Up @@ -1540,7 +1541,7 @@ func (s *UtxoSweeper) updateSweeperInputs() InputsMap {
// skip this input and wait for the locktime to be reached.
mature, locktime := input.isMature(uint32(s.currentHeight))
if !mature {
log.Infof("Skipping input %v due to locktime=%v not "+
log.Debugf("Skipping input %v due to locktime=%v not "+
"reached, current height is %v", op, locktime,
s.currentHeight)

Expand Down

0 comments on commit cec4d1e

Please sign in to comment.