mirror of
https://github.com/lightningnetwork/lnd.git
synced 2025-03-26 01:33:02 +01:00
multi: hook up protofsm to logging
This commit is contained in:
parent
bdfd79425b
commit
82a969bba5
@ -5063,9 +5063,7 @@ func (lc *LightningChannel) computeView(view *HtlcView, remoteChain bool,
|
||||
// need this to determine which HTLCs are dust, and also the final fee
|
||||
// rate.
|
||||
view.FeePerKw = commitChain.tip().feePerKw
|
||||
|
||||
// TODO(roasbeef): also need to pass blob here as well for final
|
||||
// balances?
|
||||
view.NextHeight = nextHeight
|
||||
|
||||
// We evaluate the view at this stage, meaning settled and failed HTLCs
|
||||
// will remove their corresponding added HTLCs. The resulting filtered
|
||||
|
2
log.go
2
log.go
@ -40,6 +40,7 @@ import (
|
||||
"github.com/lightningnetwork/lnd/netann"
|
||||
"github.com/lightningnetwork/lnd/peer"
|
||||
"github.com/lightningnetwork/lnd/peernotifier"
|
||||
"github.com/lightningnetwork/lnd/protofsm"
|
||||
"github.com/lightningnetwork/lnd/routing"
|
||||
"github.com/lightningnetwork/lnd/rpcperms"
|
||||
"github.com/lightningnetwork/lnd/signal"
|
||||
@ -164,6 +165,7 @@ func SetupLoggers(root *build.RotatingLogWriter, interceptor signal.Interceptor)
|
||||
AddSubLogger(root, "CHFD", interceptor, chanfunding.UseLogger)
|
||||
AddSubLogger(root, "PEER", interceptor, peer.UseLogger)
|
||||
AddSubLogger(root, "CHCL", interceptor, chancloser.UseLogger)
|
||||
AddSubLogger(root, "PFSM", interceptor, protofsm.UseLogger)
|
||||
|
||||
AddSubLogger(root, routing.Subsystem, interceptor, routing.UseLogger)
|
||||
AddSubLogger(root, routerrpc.Subsystem, interceptor, routerrpc.UseLogger)
|
||||
|
@ -5,7 +5,6 @@ import (
|
||||
"container/list"
|
||||
"errors"
|
||||
"fmt"
|
||||
"math/rand"
|
||||
"net"
|
||||
"sync"
|
||||
"sync/atomic"
|
||||
@ -595,7 +594,8 @@ func NewBrontide(cfg Config) *Brontide {
|
||||
return uint16(
|
||||
// We don't need cryptographic randomness here.
|
||||
/* #nosec */
|
||||
rand.Intn(lnwire.MaxPongBytes + 1),
|
||||
//rand.Intn(lnwire.MaxPongBytes + 1),
|
||||
2,
|
||||
)
|
||||
}
|
||||
|
||||
|
@ -260,7 +260,7 @@ func (p *MultiMsgRouter) msgRouter() {
|
||||
var couldSend bool
|
||||
for _, endpoint := range endpoints {
|
||||
if endpoint.CanHandle(msg) {
|
||||
log.Tracef("MsgRouter: sending "+
|
||||
log.Infof("MsgRouter: sending "+
|
||||
"msg %T to endpoint %s", msg,
|
||||
endpoint.Name())
|
||||
|
||||
@ -271,7 +271,7 @@ func (p *MultiMsgRouter) msgRouter() {
|
||||
|
||||
var err error
|
||||
if !couldSend {
|
||||
log.Tracef("MsgRouter: unable to route "+
|
||||
log.Infof("MsgRouter: unable to route "+
|
||||
"msg %T", msg)
|
||||
|
||||
err = ErrUnableToRouteMsg
|
||||
|
Loading…
x
Reference in New Issue
Block a user