12343072627

Committed 15 Dec 2024 11:09PM UTC coverage: 57.504% (-1.1%) from 58.636%

Build # 12343072627

Build Type

Pull #9315

github

Committed by

yyforyongyu

Commit Message

contractcourt: offer outgoing htlc one block earlier before its expiry

We need to offer the outgoing htlc one block earlier to make sure when
the expiry height hits, the sweeper will not miss sweeping it in the
same block. This also means the outgoing contest resolver now only does
one thing - watch for preimage spend till height expiry-1, which can
easily be moved into the timeout resolver instead in the future.

Pull Request Pull Request #9315: Implement `blockbeat`

Run Details

1445 of 2007 new or added lines in 26 files covered. (72.0%)

19246 existing lines in 249 files now uncovered.

102342 of 177975 relevant lines covered (57.5%)

24772.24 hits per line

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

0.0

/lncfg/pprof.go

package lncfg

import (
        "net"
        "strconv"
)

// Pprof holds the configuration options for LND's built-in pprof server.
//
//nolint:ll
type Pprof struct {
        CPUProfile string `long:"cpuprofile" description:"Write CPU profile to the specified file"`

        Profile string `long:"profile" description:"Enable HTTP profiling on either a port or host:port"`

        BlockingProfile int `long:"blockingprofile" description:"Used to enable a blocking profile to be served on the profiling port. This takes a value from 0 to 1, with 1 including every blocking event, and 0 including no events."`

        MutexProfile int `long:"mutexprofile" description:"Used to Enable a mutex profile to be served on the profiling port. This takes a value from 0 to 1, with 1 including every mutex event, and 0 including no events."`
}

// Validate checks the values configured for the profiler.
func (p *Pprof) Validate() error {
        if p.BlockingProfile > 0 {
                log.Warn("Blocking profile enabled only useful for " +
                        "debugging because of significant performance impact")
        }

        if p.MutexProfile > 0 {
                log.Warn("Mutex profile enabled only useful for " +
                        "debugging because of significant performance impact")
        }

        if p.CPUProfile != "" {
                log.Warn("CPU profile enabled only useful for " +
                        "debugging because of significant performance impact")
        }

        if p.Profile != "" {
                str := "%v: The profile port must be between 1024 and 65535"

                // Try to parse Profile as a host:port.
                _, hostPort, err := net.SplitHostPort(p.Profile)
                if err == nil {
                        // Determine if the port is valid.
                        profilePort, err := strconv.Atoi(hostPort)

                        if err != nil || profilePort < 1024 ||
                                profilePort > 65535 {

                                return &UsageError{Err: mkErr(str, hostPort)}
                        }
                } else {
                        // Try to parse Profile as a port.
                        profilePort, err := strconv.Atoi(p.Profile)
                        if err != nil || profilePort < 1024 ||
                                profilePort > 65535 {

                                return &UsageError{Err: mkErr(str, p.Profile)}
                        }

                        // Since the user just set a port, we will serve
                        // debugging information over localhost.
                        p.Profile = net.JoinHostPort("127.0.0.1", p.Profile)
                }
        }

        return nil
}

1	package lncfg
2
3	import (
4	"net"
5	"strconv"
6	)
7
8	// Pprof holds the configuration options for LND's built-in pprof server.
9	//
10	//nolint:ll
11	type Pprof struct {
12	CPUProfile string `long:"cpuprofile" description:"Write CPU profile to the specified file"`
13
14	Profile string `long:"profile" description:"Enable HTTP profiling on either a port or host:port"`
15
16	BlockingProfile int `long:"blockingprofile" description:"Used to enable a blocking profile to be served on the profiling port. This takes a value from 0 to 1, with 1 including every blocking event, and 0 including no events."`
17
18	MutexProfile int `long:"mutexprofile" description:"Used to Enable a mutex profile to be served on the profiling port. This takes a value from 0 to 1, with 1 including every mutex event, and 0 including no events."`
19	}
20
21	// Validate checks the values configured for the profiler.
UNCOV 22	func (p *Pprof) Validate() error {	×
UNCOV 23	if p.BlockingProfile > 0 {	×
24	log.Warn("Blocking profile enabled only useful for " +	×
25	"debugging because of significant performance impact")	×
26	}	×
27
UNCOV 28	if p.MutexProfile > 0 {	×
29	log.Warn("Mutex profile enabled only useful for " +	×
30	"debugging because of significant performance impact")	×
31	}	×
32
UNCOV 33	if p.CPUProfile != "" {	×
34	log.Warn("CPU profile enabled only useful for " +	×
35	"debugging because of significant performance impact")	×
36	}	×
37
UNCOV 38	if p.Profile != "" {	×
39	str := "%v: The profile port must be between 1024 and 65535"	×
40		×
41	// Try to parse Profile as a host:port.	×
42	_, hostPort, err := net.SplitHostPort(p.Profile)	×
43	if err == nil {	×
44	// Determine if the port is valid.	×
45	profilePort, err := strconv.Atoi(hostPort)	×
46		×
47	if err != nil \|\| profilePort < 1024 \|\|	×
48	profilePort > 65535 {	×
49		×
50	return &UsageError{Err: mkErr(str, hostPort)}	×
51	}	×
52	} else {	×
53	// Try to parse Profile as a port.	×
54	profilePort, err := strconv.Atoi(p.Profile)	×
55	if err != nil \|\| profilePort < 1024 \|\|	×
56	profilePort > 65535 {	×
57		×
58	return &UsageError{Err: mkErr(str, p.Profile)}	×
59	}	×
60
61	// Since the user just set a port, we will serve
62	// debugging information over localhost.
63	p.Profile = net.JoinHostPort("127.0.0.1", p.Profile)	×
64	}
65	}
66
UNCOV 67	return nil	×
68	}

lightningnetwork / lnd / 12343072627

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