16012627499

Committed 01 Jul 2025 11:49PM UTC coverage: 67.305% (-0.3%) from 67.561%

Build # 16012627499

Build Type

Pull #10012

github

Committed by

web-flow

Commit Message

Merge b870fb76f into 538723e33

Pull Request Pull Request #10012: multi: prevent goroutine leak in brontide

Run Details

9 of 24 new or added lines in 2 files covered. (37.5%)

1090 existing lines in 35 files now uncovered.

134600 of 199985 relevant lines covered (67.31%)

21889.96 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() {	15✔
22	g.mu.Lock()	15✔
23	g.numChannels++	15✔
24	g.mu.Unlock()	15✔
25	}	15✔
26
27	// incNumUpdates increments the number of channel updates processed.
28	func (g *builderStats) incNumChannelUpdates() {	6✔
29	g.mu.Lock()	6✔
30	g.numUpdates++	6✔
31	g.mu.Unlock()	6✔
32	}	6✔
33
34	// incNumNodeUpdates increments the number of node updates processed.
35	func (g *builderStats) incNumNodeUpdates() {	7✔
36	g.mu.Lock()	7✔
37	g.numNodes++	7✔
38	g.mu.Unlock()	7✔
39	}	7✔
40
41	// Empty returns true if all stats are zero.
42	func (g *builderStats) Empty() bool {	97✔
43	g.mu.RLock()	97✔
44	isEmpty := g.numChannels == 0 &&	97✔
45	g.numUpdates == 0 &&	97✔
46	g.numNodes == 0	97✔
47	g.mu.RUnlock()	97✔
48	return isEmpty	97✔
49	}	97✔
50
51	// Reset clears any stats and sets the lastReset field to now.
52	func (g *builderStats) Reset() {	21✔
53	g.mu.Lock()	21✔
54	g.numChannels = 0	21✔
55	g.numUpdates = 0	21✔
56	g.numNodes = 0	21✔
57	g.lastReset = time.Now()	21✔
58	g.mu.Unlock()	21✔
59	}	21✔
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 / 16012627499

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