12199391122

Committed 06 Dec 2024 01:10PM UTC coverage: 49.807% (-9.1%) from 58.933%

Build # 12199391122

Build Type

push

github

Committed by

web-flow

Commit Message

Merge pull request #9337 from Guayaba221/patch-1

chore: fix typo in ruby.md

Run Details

100137 of 201051 relevant lines covered (49.81%)

2.07 hits per line

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

84.44

/htlcswitch/held_htlc_set.go

package htlcswitch

import (
        "errors"
        "fmt"

        "github.com/lightningnetwork/lnd/graph/db/models"
)

// heldHtlcSet keeps track of outstanding intercepted forwards. It exposes
// several methods to manipulate the underlying map structure in a consistent
// way.
type heldHtlcSet struct {
        set map[models.CircuitKey]InterceptedForward
}

func newHeldHtlcSet() *heldHtlcSet {
        return &heldHtlcSet{
                set: make(map[models.CircuitKey]InterceptedForward),
        }
}

// forEach iterates over all held forwards and calls the given callback for each
// of them.
func (h *heldHtlcSet) forEach(cb func(InterceptedForward)) {
        for _, fwd := range h.set {
                cb(fwd)
        }
}

// popAll calls the callback for each forward and removes them from the set.
func (h *heldHtlcSet) popAll(cb func(InterceptedForward)) {
        for _, fwd := range h.set {
                cb(fwd)
        }

        h.set = make(map[models.CircuitKey]InterceptedForward)
}

// popAutoFails calls the callback for each forward that has an auto-fail height
// equal or less then the specified pop height and removes them from the set.
func (h *heldHtlcSet) popAutoFails(height uint32, cb func(InterceptedForward)) {
        for key, fwd := range h.set {
                if uint32(fwd.Packet().AutoFailHeight) > height {
                        continue
                }

                cb(fwd)

                delete(h.set, key)
        }
}

// pop returns the specified forward and removes it from the set.
func (h *heldHtlcSet) pop(key models.CircuitKey) (InterceptedForward, error) {
        intercepted, ok := h.set[key]
        if !ok {
                return nil, fmt.Errorf("fwd %v not found", key)
        }

        delete(h.set, key)

        return intercepted, nil
}

// exists tests whether the specified forward is part of the set.
func (h *heldHtlcSet) exists(key models.CircuitKey) bool {
        _, ok := h.set[key]

        return ok
}

// push adds the specified forward to the set. An error is returned if the
// forward exists already.
func (h *heldHtlcSet) push(key models.CircuitKey,
        fwd InterceptedForward) error {

        if fwd == nil {
                return errors.New("nil fwd pushed")
        }

        if h.exists(key) {
                return errors.New("htlc already exists in set")
        }

        h.set[key] = fwd

        return nil
}

1	package htlcswitch
2
3	import (
4	"errors"
5	"fmt"
6
7	"github.com/lightningnetwork/lnd/graph/db/models"
8	)
9
10	// heldHtlcSet keeps track of outstanding intercepted forwards. It exposes
11	// several methods to manipulate the underlying map structure in a consistent
12	// way.
13	type heldHtlcSet struct {
14	set map[models.CircuitKey]InterceptedForward
15	}
16
17	func newHeldHtlcSet() *heldHtlcSet {	4✔
18	return &heldHtlcSet{	4✔
19	set: make(map[models.CircuitKey]InterceptedForward),	4✔
20	}	4✔
21	}	4✔
22
23	// forEach iterates over all held forwards and calls the given callback for each
24	// of them.
25	func (h *heldHtlcSet) forEach(cb func(InterceptedForward)) {	4✔
26	for _, fwd := range h.set {	8✔
27	cb(fwd)	4✔
28	}	4✔
29	}
30
31	// popAll calls the callback for each forward and removes them from the set.
32	func (h *heldHtlcSet) popAll(cb func(InterceptedForward)) {	4✔
33	for _, fwd := range h.set {	8✔
34	cb(fwd)	4✔
35	}	4✔
36
37	h.set = make(map[models.CircuitKey]InterceptedForward)	4✔
38	}
39
40	// popAutoFails calls the callback for each forward that has an auto-fail height
41	// equal or less then the specified pop height and removes them from the set.
42	func (h *heldHtlcSet) popAutoFails(height uint32, cb func(InterceptedForward)) {	4✔
43	for key, fwd := range h.set {	8✔
44	if uint32(fwd.Packet().AutoFailHeight) > height {	8✔
45	continue	4✔
46	}
47
48	cb(fwd)	×
49		×
50	delete(h.set, key)	×
51	}
52	}
53
54	// pop returns the specified forward and removes it from the set.
55	func (h *heldHtlcSet) pop(key models.CircuitKey) (InterceptedForward, error) {	4✔
56	intercepted, ok := h.set[key]	4✔
57	if !ok {	8✔
58	return nil, fmt.Errorf("fwd %v not found", key)	4✔
59	}	4✔
60
61	delete(h.set, key)	4✔
62		4✔
63	return intercepted, nil	4✔
64	}
65
66	// exists tests whether the specified forward is part of the set.
67	func (h *heldHtlcSet) exists(key models.CircuitKey) bool {	4✔
68	_, ok := h.set[key]	4✔
69		4✔
70	return ok	4✔
71	}	4✔
72
73	// push adds the specified forward to the set. An error is returned if the
74	// forward exists already.
75	func (h *heldHtlcSet) push(key models.CircuitKey,
76	fwd InterceptedForward) error {	4✔
77		4✔
78	if fwd == nil {	4✔
79	return errors.New("nil fwd pushed")	×
80	}	×
81
82	if h.exists(key) {	4✔
83	return errors.New("htlc already exists in set")	×
84	}	×
85
86	h.set[key] = fwd	4✔
87		4✔
88	return nil	4✔
89	}

lightningnetwork / lnd / 12199391122

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