16181619122

Committed 09 Jul 2025 10:33PM UTC coverage: 55.326% (-2.3%) from 57.611%

Build # 16181619122

Build Type

Pull #10060

github

Committed by

web-flow

Commit Message

Merge d15e8671f into 0e830da9d

Pull Request Pull Request #10060: sweep: fix expected spending events being missed

Run Details

9 of 26 new or added lines in 2 files covered. (34.62%)

23695 existing lines in 280 files now uncovered.

108518 of 196143 relevant lines covered (55.33%)

22354.81 hits per line

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

79.49

/graph/stats.go

package graph

import (
        "fmt"
        "sync"
        "time"
)

// builderStats is a struct that tracks various updates to the graph and
// facilitates aggregate logging of the statistics.
type builderStats struct {
        numChannels uint32
        numUpdates  uint32
        numNodes    uint32
        lastReset   time.Time

        mu sync.RWMutex
}

// incNumEdges increments the number of discovered edges.
func (g *builderStats) incNumEdgesDiscovered() {
        g.mu.Lock()
        g.numChannels++
        g.mu.Unlock()
}

// incNumUpdates increments the number of channel updates processed.
func (g *builderStats) incNumChannelUpdates() {
        g.mu.Lock()
        g.numUpdates++
        g.mu.Unlock()
}

// incNumNodeUpdates increments the number of node updates processed.
func (g *builderStats) incNumNodeUpdates() {
        g.mu.Lock()
        g.numNodes++
        g.mu.Unlock()
}

// Empty returns true if all stats are zero.
func (g *builderStats) Empty() bool {
        g.mu.RLock()
        isEmpty := g.numChannels == 0 &&
                g.numUpdates == 0 &&
                g.numNodes == 0
        g.mu.RUnlock()
        return isEmpty
}

// Reset clears any stats and sets the lastReset field to now.
func (g *builderStats) Reset() {
        g.mu.Lock()
        g.numChannels = 0
        g.numUpdates = 0
        g.numNodes = 0
        g.lastReset = time.Now()
        g.mu.Unlock()
}

// String returns a human-readable description of the stats.
func (g *builderStats) String() string {
        g.mu.RLock()
        str := fmt.Sprintf("Processed channels=%d updates=%d nodes=%d in "+
                "last %v", g.numChannels, g.numUpdates, g.numNodes,
                time.Since(g.lastReset))
        g.mu.RUnlock()
        return str
}

1	package graph
2
3	import (
4	"fmt"
5	"sync"
6	"time"
7	)
8
9	// builderStats is a struct that tracks various updates to the graph and
10	// facilitates aggregate logging of the statistics.
11	type builderStats struct {
12	numChannels uint32
13	numUpdates uint32
14	numNodes uint32
15	lastReset time.Time
16
17	mu sync.RWMutex
18	}
19
20	// incNumEdges increments the number of discovered edges.
21	func (g *builderStats) incNumEdgesDiscovered() {	14✔
22	g.mu.Lock()	14✔
23	g.numChannels++	14✔
24	g.mu.Unlock()	14✔
25	}	14✔
26
27	// incNumUpdates increments the number of channel updates processed.
28	func (g *builderStats) incNumChannelUpdates() {	5✔
29	g.mu.Lock()	5✔
30	g.numUpdates++	5✔
31	g.mu.Unlock()	5✔
32	}	5✔
33
34	// incNumNodeUpdates increments the number of node updates processed.
35	func (g *builderStats) incNumNodeUpdates() {	6✔
36	g.mu.Lock()	6✔
37	g.numNodes++	6✔
38	g.mu.Unlock()	6✔
39	}	6✔
40
41	// Empty returns true if all stats are zero.
42	func (g *builderStats) Empty() bool {	94✔
43	g.mu.RLock()	94✔
44	isEmpty := g.numChannels == 0 &&	94✔
45	g.numUpdates == 0 &&	94✔
46	g.numNodes == 0	94✔
47	g.mu.RUnlock()	94✔
48	return isEmpty	94✔
49	}	94✔
50
51	// Reset clears any stats and sets the lastReset field to now.
52	func (g *builderStats) Reset() {	20✔
53	g.mu.Lock()	20✔
54	g.numChannels = 0	20✔
55	g.numUpdates = 0	20✔
56	g.numNodes = 0	20✔
57	g.lastReset = time.Now()	20✔
58	g.mu.Unlock()	20✔
59	}	20✔
60
61	// String returns a human-readable description of the stats.
UNCOV 62	func (g *builderStats) String() string {	×
UNCOV 63	g.mu.RLock()	×
UNCOV 64	str := fmt.Sprintf("Processed channels=%d updates=%d nodes=%d in "+	×
UNCOV 65	"last %v", g.numChannels, g.numUpdates, g.numNodes,	×
UNCOV 66	time.Since(g.lastReset))	×
UNCOV 67	g.mu.RUnlock()	×
UNCOV 68	return str	×
UNCOV 69	}	×

lightningnetwork / lnd / 16181619122

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