From 74c2df658e7254c40eedc57f2b4c86a4629816ea Mon Sep 17 00:00:00 2001 From: Joost Jager Date: Fri, 15 Nov 2019 11:15:22 +0100 Subject: [PATCH] localchans: log policy update error --- log.go | 2 ++ routing/localchans/log.go | 16 ++++++++++++++++ routing/localchans/manager.go | 3 +++ 3 files changed, 21 insertions(+) create mode 100644 routing/localchans/log.go diff --git a/log.go b/log.go index 23b1699d..f7ba8e10 100644 --- a/log.go +++ b/log.go @@ -31,6 +31,7 @@ import ( "github.com/lightningnetwork/lnd/netann" "github.com/lightningnetwork/lnd/peernotifier" "github.com/lightningnetwork/lnd/routing" + "github.com/lightningnetwork/lnd/routing/localchans" "github.com/lightningnetwork/lnd/signal" "github.com/lightningnetwork/lnd/sweep" "github.com/lightningnetwork/lnd/watchtower" @@ -99,6 +100,7 @@ func init() { addSubLogger("CHFD", chanfunding.UseLogger) addSubLogger(routing.Subsystem, routing.UseLogger) + addSubLogger(routing.Subsystem, localchans.UseLogger) addSubLogger(routerrpc.Subsystem, routerrpc.UseLogger) addSubLogger(wtclientrpc.Subsystem, wtclientrpc.UseLogger) addSubLogger(chanfitness.Subsystem, chanfitness.UseLogger) diff --git a/routing/localchans/log.go b/routing/localchans/log.go new file mode 100644 index 00000000..9ebcf4d0 --- /dev/null +++ b/routing/localchans/log.go @@ -0,0 +1,16 @@ +package localchans + +import ( + "github.com/btcsuite/btclog" +) + +// log is a logger that is initialized with no output filters. This +// means the package will not perform any logging by default until the caller +// requests it. +var log btclog.Logger + +// UseLogger uses a specified Logger to output package logging info. This +// function is called from the parent package htlcswitch logger initialization. +func UseLogger(logger btclog.Logger) { + log = logger +} diff --git a/routing/localchans/manager.go b/routing/localchans/manager.go index e99a5a35..19fdbe5e 100644 --- a/routing/localchans/manager.go +++ b/routing/localchans/manager.go @@ -79,6 +79,9 @@ func (r *Manager) UpdatePolicy(newSchema routing.ChannelPolicy, // Apply the new policy to the edge. err := r.updateEdge(info.ChannelPoint, edge, newSchema) if err != nil { + log.Warnf("Cannot update policy for %v: %v\n", + info.ChannelPoint, err, + ) return nil }