12395709513

Committed 18 Dec 2024 03:04PM UTC coverage: 57.495% (-1.1%) from 58.595%

Build # 12395709513

Build Type

Pull #8777

github

Committed by

ziggie1984

Commit Message

funding: refactor gossip msg code

We almost never need to create all messages at the same time
(ChanUpdate,ChanAnnouncement,Proof) so we split it up into own
functions.

Pull Request Pull Request #8777: multi: make reassignment of alias channel edge atomic

Run Details

196 of 330 new or added lines in 7 files covered. (59.39%)

19293 existing lines in 251 files now uncovered.

102055 of 177501 relevant lines covered (57.5%)

24852.05 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

6.56

/log.go

package lnd

import (
        "github.com/btcsuite/btcd/connmgr"
        "github.com/btcsuite/btcd/rpcclient"
        btclogv1 "github.com/btcsuite/btclog"
        "github.com/btcsuite/btclog/v2"
        "github.com/lightninglabs/neutrino"
        sphinx "github.com/lightningnetwork/lightning-onion"
        "github.com/lightningnetwork/lnd/autopilot"
        "github.com/lightningnetwork/lnd/build"
        "github.com/lightningnetwork/lnd/chainntnfs"
        "github.com/lightningnetwork/lnd/chainreg"
        "github.com/lightningnetwork/lnd/chanacceptor"
        "github.com/lightningnetwork/lnd/chanbackup"
        "github.com/lightningnetwork/lnd/chanfitness"
        "github.com/lightningnetwork/lnd/channeldb"
        "github.com/lightningnetwork/lnd/channelnotifier"
        "github.com/lightningnetwork/lnd/cluster"
        "github.com/lightningnetwork/lnd/contractcourt"
        "github.com/lightningnetwork/lnd/discovery"
        "github.com/lightningnetwork/lnd/funding"
        "github.com/lightningnetwork/lnd/graph"
        graphdb "github.com/lightningnetwork/lnd/graph/db"
        "github.com/lightningnetwork/lnd/healthcheck"
        "github.com/lightningnetwork/lnd/htlcswitch"
        "github.com/lightningnetwork/lnd/invoices"
        "github.com/lightningnetwork/lnd/lncfg"
        "github.com/lightningnetwork/lnd/lnrpc/autopilotrpc"
        "github.com/lightningnetwork/lnd/lnrpc/chainrpc"
        "github.com/lightningnetwork/lnd/lnrpc/devrpc"
        "github.com/lightningnetwork/lnd/lnrpc/invoicesrpc"
        "github.com/lightningnetwork/lnd/lnrpc/neutrinorpc"
        "github.com/lightningnetwork/lnd/lnrpc/peersrpc"
        "github.com/lightningnetwork/lnd/lnrpc/routerrpc"
        "github.com/lightningnetwork/lnd/lnrpc/signrpc"
        "github.com/lightningnetwork/lnd/lnrpc/verrpc"
        "github.com/lightningnetwork/lnd/lnrpc/walletrpc"
        "github.com/lightningnetwork/lnd/lnwallet"
        "github.com/lightningnetwork/lnd/lnwallet/btcwallet"
        "github.com/lightningnetwork/lnd/lnwallet/chancloser"
        "github.com/lightningnetwork/lnd/lnwallet/chanfunding"
        "github.com/lightningnetwork/lnd/lnwallet/rpcwallet"
        "github.com/lightningnetwork/lnd/monitoring"
        "github.com/lightningnetwork/lnd/netann"
        "github.com/lightningnetwork/lnd/peer"
        "github.com/lightningnetwork/lnd/peernotifier"
        "github.com/lightningnetwork/lnd/routing"
        "github.com/lightningnetwork/lnd/routing/blindedpath"
        "github.com/lightningnetwork/lnd/routing/localchans"
        "github.com/lightningnetwork/lnd/rpcperms"
        "github.com/lightningnetwork/lnd/signal"
        "github.com/lightningnetwork/lnd/sweep"
        "github.com/lightningnetwork/lnd/tor"
        "github.com/lightningnetwork/lnd/watchtower"
        "github.com/lightningnetwork/lnd/watchtower/wtclient"
)

// replaceableLogger is a thin wrapper around a logger that is used so the
// logger can be replaced easily without some black pointer magic.
type replaceableLogger struct {
        btclog.Logger
        subsystem string
}

// Loggers can not be used before the log rotator has been initialized with a
// log file. This must be performed early during application startup by
// calling InitLogRotator() on the main log writer instance in the config.
var (
        // lndPkgLoggers is a list of all lnd package level loggers that are
        // registered. They are tracked here so they can be replaced once the
        // SetupLoggers function is called with the final root logger.
        lndPkgLoggers []*replaceableLogger

        // addLndPkgLogger is a helper function that creates a new replaceable
        // main lnd package level logger and adds it to the list of loggers that
        // are replaced again later, once the final root logger is ready.
        addLndPkgLogger = func(subsystem string) *replaceableLogger {
                l := &replaceableLogger{
                        Logger:    build.NewSubLogger(subsystem, nil),
                        subsystem: subsystem,
                }
                lndPkgLoggers = append(lndPkgLoggers, l)
                return l
        }

        // Loggers that need to be accessible from the lnd package can be placed
        // here. Loggers that are only used in sub modules can be added directly
        // by using the addSubLogger method. We declare all loggers so we never
        // run into a nil reference if they are used early. But the SetupLoggers
        // function should always be called as soon as possible to finish
        // setting them up properly with a root logger.
        ltndLog = addLndPkgLogger("LTND")
        rpcsLog = addLndPkgLogger("RPCS")
        srvrLog = addLndPkgLogger("SRVR")
        atplLog = addLndPkgLogger("ATPL")
)

// genSubLogger creates a logger for a subsystem. We provide an instance of
// a signal.Interceptor to be able to shutdown in the case of a critical error.
func genSubLogger(root *build.SubLoggerManager,
        interceptor signal.Interceptor) func(string) btclog.Logger {

        // Create a shutdown function which will request shutdown from our
        // interceptor if it is listening.
        shutdown := func() {
                if !interceptor.Listening() {
                        return
                }

                interceptor.RequestShutdown()
        }

        // Return a function which will create a sublogger from our root
        // logger without shutdown fn.
        return func(tag string) btclog.Logger {
                return root.GenSubLogger(tag, shutdown)
        }
}

// SetupLoggers initializes all package-global logger variables.
//
//nolint:ll
func SetupLoggers(root *build.SubLoggerManager, interceptor signal.Interceptor) {
        genLogger := genSubLogger(root, interceptor)

        // Now that we have the proper root logger, we can replace the
        // placeholder lnd package loggers.
        for _, l := range lndPkgLoggers {
                l.Logger = build.NewSubLogger(l.subsystem, genLogger)
                SetSubLogger(root, l.subsystem, l.Logger)
        }

        // Initialize loggers from packages outside of `lnd` first. The
        // packages below will overwrite the names of the loggers they import.
        // For instance, the logger in `neutrino.query` is overwritten by
        // `btcwallet.chain`, which is overwritten by `lnwallet`. To ensure the
        // overwriting works, we need to initialize the loggers here so they
        // can be overwritten later.
        AddV1SubLogger(root, "BTCN", interceptor, neutrino.UseLogger)
        AddV1SubLogger(root, "CMGR", interceptor, connmgr.UseLogger)
        AddV1SubLogger(root, "RPCC", interceptor, rpcclient.UseLogger)

        // Some of the loggers declared in the main lnd package are also used
        // in sub packages.
        signal.UseLogger(ltndLog)
        autopilot.UseLogger(atplLog)

        AddSubLogger(root, "LNWL", interceptor, lnwallet.UseLogger)
        AddSubLogger(root, "DISC", interceptor, discovery.UseLogger)
        AddSubLogger(root, "NTFN", interceptor, chainntnfs.UseLogger)
        AddSubLogger(root, "CHDB", interceptor, channeldb.UseLogger)
        AddSubLogger(root, "HSWC", interceptor, htlcswitch.UseLogger)
        AddSubLogger(root, "CNCT", interceptor, contractcourt.UseLogger)
        AddSubLogger(root, "UTXN", interceptor, contractcourt.UseNurseryLogger)
        AddSubLogger(root, "BRAR", interceptor, contractcourt.UseBreachLogger)
        AddV1SubLogger(root, "SPHX", interceptor, sphinx.UseLogger)
        AddSubLogger(root, "SWPR", interceptor, sweep.UseLogger)
        AddSubLogger(root, "SGNR", interceptor, signrpc.UseLogger)
        AddSubLogger(root, "WLKT", interceptor, walletrpc.UseLogger)
        AddSubLogger(root, "ARPC", interceptor, autopilotrpc.UseLogger)
        AddSubLogger(root, "NRPC", interceptor, neutrinorpc.UseLogger)
        AddSubLogger(root, "DRPC", interceptor, devrpc.UseLogger)
        AddSubLogger(root, "INVC", interceptor, invoices.UseLogger)
        AddSubLogger(root, "NANN", interceptor, netann.UseLogger)
        AddSubLogger(root, "WTWR", interceptor, watchtower.UseLogger)
        AddSubLogger(root, "NTFR", interceptor, chainrpc.UseLogger)
        AddSubLogger(root, "IRPC", interceptor, invoicesrpc.UseLogger)
        AddSubLogger(root, "CHNF", interceptor, channelnotifier.UseLogger)
        AddSubLogger(root, "CHBU", interceptor, chanbackup.UseLogger)
        AddSubLogger(root, "PROM", interceptor, monitoring.UseLogger)
        AddSubLogger(root, "WTCL", interceptor, wtclient.UseLogger)
        AddSubLogger(root, "PRNF", interceptor, peernotifier.UseLogger)
        AddSubLogger(root, "CHFD", interceptor, chanfunding.UseLogger)
        AddSubLogger(root, "PEER", interceptor, peer.UseLogger)
        AddSubLogger(root, "CHCL", interceptor, chancloser.UseLogger)
        AddSubLogger(root, "LCHN", interceptor, localchans.UseLogger)

        AddSubLogger(root, routing.Subsystem, interceptor, routing.UseLogger)
        AddSubLogger(root, routerrpc.Subsystem, interceptor, routerrpc.UseLogger)
        AddSubLogger(root, chanfitness.Subsystem, interceptor, chanfitness.UseLogger)
        AddSubLogger(root, verrpc.Subsystem, interceptor, verrpc.UseLogger)
        AddSubLogger(root, healthcheck.Subsystem, interceptor, healthcheck.UseLogger)
        AddSubLogger(root, chainreg.Subsystem, interceptor, chainreg.UseLogger)
        AddSubLogger(root, chanacceptor.Subsystem, interceptor, chanacceptor.UseLogger)
        AddSubLogger(root, funding.Subsystem, interceptor, funding.UseLogger)
        AddSubLogger(root, cluster.Subsystem, interceptor, cluster.UseLogger)
        AddSubLogger(root, rpcperms.Subsystem, interceptor, rpcperms.UseLogger)
        AddSubLogger(root, tor.Subsystem, interceptor, tor.UseLogger)
        AddSubLogger(root, btcwallet.Subsystem, interceptor, btcwallet.UseLogger)
        AddSubLogger(root, rpcwallet.Subsystem, interceptor, rpcwallet.UseLogger)
        AddSubLogger(root, peersrpc.Subsystem, interceptor, peersrpc.UseLogger)
        AddSubLogger(root, graph.Subsystem, interceptor, graph.UseLogger)
        AddSubLogger(root, lncfg.Subsystem, interceptor, lncfg.UseLogger)
        AddSubLogger(
                root, blindedpath.Subsystem, interceptor, blindedpath.UseLogger,
        )
        AddV1SubLogger(root, graphdb.Subsystem, interceptor, graphdb.UseLogger)
}

// AddSubLogger is a helper method to conveniently create and register the
// logger of one or more sub systems.
func AddSubLogger(root *build.SubLoggerManager, subsystem string,
        interceptor signal.Interceptor, useLoggers ...func(btclog.Logger)) {

        // genSubLogger will return a callback for creating a logger instance,
        // which we will give to the root logger.
        genLogger := genSubLogger(root, interceptor)

        // Create and register just a single logger to prevent them from
        // overwriting each other internally.
        logger := build.NewSubLogger(subsystem, genLogger)
        SetSubLogger(root, subsystem, logger, useLoggers...)
}

// SetSubLogger is a helper method to conveniently register the logger of a
// sub system.
func SetSubLogger(root *build.SubLoggerManager, subsystem string,
        logger btclog.Logger, useLoggers ...func(btclog.Logger)) {

        root.RegisterSubLogger(subsystem, logger)
        for _, useLogger := range useLoggers {
                useLogger(logger)
        }
}

// AddV1SubLogger is a helper method to conveniently create and register the
// logger of one or more sub systems.
func AddV1SubLogger(root *build.SubLoggerManager, subsystem string,
        interceptor signal.Interceptor, useLoggers ...func(btclogv1.Logger)) {

        // genSubLogger will return a callback for creating a logger instance,
        // which we will give to the root logger.
        genLogger := genSubLogger(root, interceptor)

        // Create and register just a single logger to prevent them from
        // overwriting each other internally.
        logger := build.NewSubLogger(subsystem, genLogger)
        SetV1SubLogger(root, subsystem, logger, useLoggers...)
}

// SetV1SubLogger is a helper method to conveniently register the logger of a
// sub system. Note that the btclog v2 logger implements the btclog v1 logger
// which is why we can pass the v2 logger to the UseLogger call-backs that
// expect the v1 logger.
func SetV1SubLogger(root *build.SubLoggerManager, subsystem string,
        logger btclog.Logger, useLoggers ...func(btclogv1.Logger)) {

        root.RegisterSubLogger(subsystem, logger)
        for _, useLogger := range useLoggers {
                useLogger(logger)
        }
}

1	package lnd
2
3	import (
4	"github.com/btcsuite/btcd/connmgr"
5	"github.com/btcsuite/btcd/rpcclient"
6	btclogv1 "github.com/btcsuite/btclog"
7	"github.com/btcsuite/btclog/v2"
8	"github.com/lightninglabs/neutrino"
9	sphinx "github.com/lightningnetwork/lightning-onion"
10	"github.com/lightningnetwork/lnd/autopilot"
11	"github.com/lightningnetwork/lnd/build"
12	"github.com/lightningnetwork/lnd/chainntnfs"
13	"github.com/lightningnetwork/lnd/chainreg"
14	"github.com/lightningnetwork/lnd/chanacceptor"
15	"github.com/lightningnetwork/lnd/chanbackup"
16	"github.com/lightningnetwork/lnd/chanfitness"
17	"github.com/lightningnetwork/lnd/channeldb"
18	"github.com/lightningnetwork/lnd/channelnotifier"
19	"github.com/lightningnetwork/lnd/cluster"
20	"github.com/lightningnetwork/lnd/contractcourt"
21	"github.com/lightningnetwork/lnd/discovery"
22	"github.com/lightningnetwork/lnd/funding"
23	"github.com/lightningnetwork/lnd/graph"
24	graphdb "github.com/lightningnetwork/lnd/graph/db"
25	"github.com/lightningnetwork/lnd/healthcheck"
26	"github.com/lightningnetwork/lnd/htlcswitch"
27	"github.com/lightningnetwork/lnd/invoices"
28	"github.com/lightningnetwork/lnd/lncfg"
29	"github.com/lightningnetwork/lnd/lnrpc/autopilotrpc"
30	"github.com/lightningnetwork/lnd/lnrpc/chainrpc"
31	"github.com/lightningnetwork/lnd/lnrpc/devrpc"
32	"github.com/lightningnetwork/lnd/lnrpc/invoicesrpc"
33	"github.com/lightningnetwork/lnd/lnrpc/neutrinorpc"
34	"github.com/lightningnetwork/lnd/lnrpc/peersrpc"
35	"github.com/lightningnetwork/lnd/lnrpc/routerrpc"
36	"github.com/lightningnetwork/lnd/lnrpc/signrpc"
37	"github.com/lightningnetwork/lnd/lnrpc/verrpc"
38	"github.com/lightningnetwork/lnd/lnrpc/walletrpc"
39	"github.com/lightningnetwork/lnd/lnwallet"
40	"github.com/lightningnetwork/lnd/lnwallet/btcwallet"
41	"github.com/lightningnetwork/lnd/lnwallet/chancloser"
42	"github.com/lightningnetwork/lnd/lnwallet/chanfunding"
43	"github.com/lightningnetwork/lnd/lnwallet/rpcwallet"
44	"github.com/lightningnetwork/lnd/monitoring"
45	"github.com/lightningnetwork/lnd/netann"
46	"github.com/lightningnetwork/lnd/peer"
47	"github.com/lightningnetwork/lnd/peernotifier"
48	"github.com/lightningnetwork/lnd/routing"
49	"github.com/lightningnetwork/lnd/routing/blindedpath"
50	"github.com/lightningnetwork/lnd/routing/localchans"
51	"github.com/lightningnetwork/lnd/rpcperms"
52	"github.com/lightningnetwork/lnd/signal"
53	"github.com/lightningnetwork/lnd/sweep"
54	"github.com/lightningnetwork/lnd/tor"
55	"github.com/lightningnetwork/lnd/watchtower"
56	"github.com/lightningnetwork/lnd/watchtower/wtclient"
57	)
58
59	// replaceableLogger is a thin wrapper around a logger that is used so the
60	// logger can be replaced easily without some black pointer magic.
61	type replaceableLogger struct {
62	btclog.Logger
63	subsystem string
64	}
65
66	// Loggers can not be used before the log rotator has been initialized with a
67	// log file. This must be performed early during application startup by
68	// calling InitLogRotator() on the main log writer instance in the config.
69	var (
70	// lndPkgLoggers is a list of all lnd package level loggers that are
71	// registered. They are tracked here so they can be replaced once the
72	// SetupLoggers function is called with the final root logger.
73	lndPkgLoggers []*replaceableLogger
74
75	// addLndPkgLogger is a helper function that creates a new replaceable
76	// main lnd package level logger and adds it to the list of loggers that
77	// are replaced again later, once the final root logger is ready.
78	addLndPkgLogger = func(subsystem string) *replaceableLogger {	12✔
79	l := &replaceableLogger{	12✔
80	Logger: build.NewSubLogger(subsystem, nil),	12✔
81	subsystem: subsystem,	12✔
82	}	12✔
83	lndPkgLoggers = append(lndPkgLoggers, l)	12✔
84	return l	12✔
85	}	12✔
86
87	// Loggers that need to be accessible from the lnd package can be placed
88	// here. Loggers that are only used in sub modules can be added directly
89	// by using the addSubLogger method. We declare all loggers so we never
90	// run into a nil reference if they are used early. But the SetupLoggers
91	// function should always be called as soon as possible to finish
92	// setting them up properly with a root logger.
93	ltndLog = addLndPkgLogger("LTND")
94	rpcsLog = addLndPkgLogger("RPCS")
95	srvrLog = addLndPkgLogger("SRVR")
96	atplLog = addLndPkgLogger("ATPL")
97	)
98
99	// genSubLogger creates a logger for a subsystem. We provide an instance of
100	// a signal.Interceptor to be able to shutdown in the case of a critical error.
101	func genSubLogger(root *build.SubLoggerManager,
UNCOV 102	interceptor signal.Interceptor) func(string) btclog.Logger {	×
UNCOV 103		×
UNCOV 104	// Create a shutdown function which will request shutdown from our	×
UNCOV 105	// interceptor if it is listening.	×
UNCOV 106	shutdown := func() {	×
107	if !interceptor.Listening() {	×
108	return	×
109	}	×
110
111	interceptor.RequestShutdown()	×
112	}
113
114	// Return a function which will create a sublogger from our root
115	// logger without shutdown fn.
UNCOV 116	return func(tag string) btclog.Logger {	×
UNCOV 117	return root.GenSubLogger(tag, shutdown)	×
UNCOV 118	}	×
119	}
120
121	// SetupLoggers initializes all package-global logger variables.
122	//
123	//nolint:ll
UNCOV 124	func SetupLoggers(root *build.SubLoggerManager, interceptor signal.Interceptor) {	×
UNCOV 125	genLogger := genSubLogger(root, interceptor)	×
UNCOV 126		×
UNCOV 127	// Now that we have the proper root logger, we can replace the	×
UNCOV 128	// placeholder lnd package loggers.	×
UNCOV 129	for _, l := range lndPkgLoggers {	×
UNCOV 130	l.Logger = build.NewSubLogger(l.subsystem, genLogger)	×
UNCOV 131	SetSubLogger(root, l.subsystem, l.Logger)	×
UNCOV 132	}	×
133
134	// Initialize loggers from packages outside of `lnd` first. The
135	// packages below will overwrite the names of the loggers they import.
136	// For instance, the logger in `neutrino.query` is overwritten by
137	// `btcwallet.chain`, which is overwritten by `lnwallet`. To ensure the
138	// overwriting works, we need to initialize the loggers here so they
139	// can be overwritten later.
UNCOV 140	AddV1SubLogger(root, "BTCN", interceptor, neutrino.UseLogger)	×
UNCOV 141	AddV1SubLogger(root, "CMGR", interceptor, connmgr.UseLogger)	×
UNCOV 142	AddV1SubLogger(root, "RPCC", interceptor, rpcclient.UseLogger)	×
UNCOV 143		×
UNCOV 144	// Some of the loggers declared in the main lnd package are also used	×
UNCOV 145	// in sub packages.	×
UNCOV 146	signal.UseLogger(ltndLog)	×
UNCOV 147	autopilot.UseLogger(atplLog)	×
UNCOV 148		×
UNCOV 149	AddSubLogger(root, "LNWL", interceptor, lnwallet.UseLogger)	×
UNCOV 150	AddSubLogger(root, "DISC", interceptor, discovery.UseLogger)	×
UNCOV 151	AddSubLogger(root, "NTFN", interceptor, chainntnfs.UseLogger)	×
UNCOV 152	AddSubLogger(root, "CHDB", interceptor, channeldb.UseLogger)	×
UNCOV 153	AddSubLogger(root, "HSWC", interceptor, htlcswitch.UseLogger)	×
UNCOV 154	AddSubLogger(root, "CNCT", interceptor, contractcourt.UseLogger)	×
UNCOV 155	AddSubLogger(root, "UTXN", interceptor, contractcourt.UseNurseryLogger)	×
UNCOV 156	AddSubLogger(root, "BRAR", interceptor, contractcourt.UseBreachLogger)	×
UNCOV 157	AddV1SubLogger(root, "SPHX", interceptor, sphinx.UseLogger)	×
UNCOV 158	AddSubLogger(root, "SWPR", interceptor, sweep.UseLogger)	×
UNCOV 159	AddSubLogger(root, "SGNR", interceptor, signrpc.UseLogger)	×
UNCOV 160	AddSubLogger(root, "WLKT", interceptor, walletrpc.UseLogger)	×
UNCOV 161	AddSubLogger(root, "ARPC", interceptor, autopilotrpc.UseLogger)	×
UNCOV 162	AddSubLogger(root, "NRPC", interceptor, neutrinorpc.UseLogger)	×
UNCOV 163	AddSubLogger(root, "DRPC", interceptor, devrpc.UseLogger)	×
UNCOV 164	AddSubLogger(root, "INVC", interceptor, invoices.UseLogger)	×
UNCOV 165	AddSubLogger(root, "NANN", interceptor, netann.UseLogger)	×
UNCOV 166	AddSubLogger(root, "WTWR", interceptor, watchtower.UseLogger)	×
UNCOV 167	AddSubLogger(root, "NTFR", interceptor, chainrpc.UseLogger)	×
UNCOV 168	AddSubLogger(root, "IRPC", interceptor, invoicesrpc.UseLogger)	×
UNCOV 169	AddSubLogger(root, "CHNF", interceptor, channelnotifier.UseLogger)	×
UNCOV 170	AddSubLogger(root, "CHBU", interceptor, chanbackup.UseLogger)	×
UNCOV 171	AddSubLogger(root, "PROM", interceptor, monitoring.UseLogger)	×
UNCOV 172	AddSubLogger(root, "WTCL", interceptor, wtclient.UseLogger)	×
UNCOV 173	AddSubLogger(root, "PRNF", interceptor, peernotifier.UseLogger)	×
UNCOV 174	AddSubLogger(root, "CHFD", interceptor, chanfunding.UseLogger)	×
UNCOV 175	AddSubLogger(root, "PEER", interceptor, peer.UseLogger)	×
UNCOV 176	AddSubLogger(root, "CHCL", interceptor, chancloser.UseLogger)	×
UNCOV 177	AddSubLogger(root, "LCHN", interceptor, localchans.UseLogger)	×
UNCOV 178		×
UNCOV 179	AddSubLogger(root, routing.Subsystem, interceptor, routing.UseLogger)	×
UNCOV 180	AddSubLogger(root, routerrpc.Subsystem, interceptor, routerrpc.UseLogger)	×
UNCOV 181	AddSubLogger(root, chanfitness.Subsystem, interceptor, chanfitness.UseLogger)	×
UNCOV 182	AddSubLogger(root, verrpc.Subsystem, interceptor, verrpc.UseLogger)	×
UNCOV 183	AddSubLogger(root, healthcheck.Subsystem, interceptor, healthcheck.UseLogger)	×
UNCOV 184	AddSubLogger(root, chainreg.Subsystem, interceptor, chainreg.UseLogger)	×
UNCOV 185	AddSubLogger(root, chanacceptor.Subsystem, interceptor, chanacceptor.UseLogger)	×
UNCOV 186	AddSubLogger(root, funding.Subsystem, interceptor, funding.UseLogger)	×
UNCOV 187	AddSubLogger(root, cluster.Subsystem, interceptor, cluster.UseLogger)	×
UNCOV 188	AddSubLogger(root, rpcperms.Subsystem, interceptor, rpcperms.UseLogger)	×
UNCOV 189	AddSubLogger(root, tor.Subsystem, interceptor, tor.UseLogger)	×
UNCOV 190	AddSubLogger(root, btcwallet.Subsystem, interceptor, btcwallet.UseLogger)	×
UNCOV 191	AddSubLogger(root, rpcwallet.Subsystem, interceptor, rpcwallet.UseLogger)	×
UNCOV 192	AddSubLogger(root, peersrpc.Subsystem, interceptor, peersrpc.UseLogger)	×
UNCOV 193	AddSubLogger(root, graph.Subsystem, interceptor, graph.UseLogger)	×
UNCOV 194	AddSubLogger(root, lncfg.Subsystem, interceptor, lncfg.UseLogger)	×
UNCOV 195	AddSubLogger(	×
UNCOV 196	root, blindedpath.Subsystem, interceptor, blindedpath.UseLogger,	×
UNCOV 197	)	×
UNCOV 198	AddV1SubLogger(root, graphdb.Subsystem, interceptor, graphdb.UseLogger)	×
199	}
200
201	// AddSubLogger is a helper method to conveniently create and register the
202	// logger of one or more sub systems.
203	func AddSubLogger(root *build.SubLoggerManager, subsystem string,
UNCOV 204	interceptor signal.Interceptor, useLoggers ...func(btclog.Logger)) {	×
UNCOV 205		×
UNCOV 206	// genSubLogger will return a callback for creating a logger instance,	×
UNCOV 207	// which we will give to the root logger.	×
UNCOV 208	genLogger := genSubLogger(root, interceptor)	×
UNCOV 209		×
UNCOV 210	// Create and register just a single logger to prevent them from	×
UNCOV 211	// overwriting each other internally.	×
UNCOV 212	logger := build.NewSubLogger(subsystem, genLogger)	×
UNCOV 213	SetSubLogger(root, subsystem, logger, useLoggers...)	×
UNCOV 214	}	×
215
216	// SetSubLogger is a helper method to conveniently register the logger of a
217	// sub system.
218	func SetSubLogger(root *build.SubLoggerManager, subsystem string,
UNCOV 219	logger btclog.Logger, useLoggers ...func(btclog.Logger)) {	×
UNCOV 220		×
UNCOV 221	root.RegisterSubLogger(subsystem, logger)	×
UNCOV 222	for _, useLogger := range useLoggers {	×
UNCOV 223	useLogger(logger)	×
UNCOV 224	}	×
225	}
226
227	// AddV1SubLogger is a helper method to conveniently create and register the
228	// logger of one or more sub systems.
229	func AddV1SubLogger(root *build.SubLoggerManager, subsystem string,
UNCOV 230	interceptor signal.Interceptor, useLoggers ...func(btclogv1.Logger)) {	×
UNCOV 231		×
UNCOV 232	// genSubLogger will return a callback for creating a logger instance,	×
UNCOV 233	// which we will give to the root logger.	×
UNCOV 234	genLogger := genSubLogger(root, interceptor)	×
UNCOV 235		×
UNCOV 236	// Create and register just a single logger to prevent them from	×
UNCOV 237	// overwriting each other internally.	×
UNCOV 238	logger := build.NewSubLogger(subsystem, genLogger)	×
UNCOV 239	SetV1SubLogger(root, subsystem, logger, useLoggers...)	×
UNCOV 240	}	×
241
242	// SetV1SubLogger is a helper method to conveniently register the logger of a
243	// sub system. Note that the btclog v2 logger implements the btclog v1 logger
244	// which is why we can pass the v2 logger to the UseLogger call-backs that
245	// expect the v1 logger.
246	func SetV1SubLogger(root *build.SubLoggerManager, subsystem string,
UNCOV 247	logger btclog.Logger, useLoggers ...func(btclogv1.Logger)) {	×
UNCOV 248		×
UNCOV 249	root.RegisterSubLogger(subsystem, logger)	×
UNCOV 250	for _, useLogger := range useLoggers {	×
UNCOV 251	useLogger(logger)	×
UNCOV 252	}	×
253	}

lightningnetwork / lnd / 12395709513

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous