parent
d98d4523e1
commit
4af9da40c5
@ -17,6 +17,11 @@ import (
|
|||||||
// to signal the number of slots available, and a condition variable to allow
|
// to signal the number of slots available, and a condition variable to allow
|
||||||
// the packetQueue to know when new items have been added to the queue.
|
// the packetQueue to know when new items have been added to the queue.
|
||||||
type packetQueue struct {
|
type packetQueue struct {
|
||||||
|
// totalHtlcAmt is the sum of the value of all pending HTLC's currently
|
||||||
|
// residing within the overflow queue. This value should only read or
|
||||||
|
// modified *atomically*.
|
||||||
|
totalHtlcAmt int64
|
||||||
|
|
||||||
// queueLen is an internal counter that reflects the size of the queue
|
// queueLen is an internal counter that reflects the size of the queue
|
||||||
// at any given instance. This value is intended to be use atomically
|
// at any given instance. This value is intended to be use atomically
|
||||||
// as this value is used by internal methods to obtain the length of
|
// as this value is used by internal methods to obtain the length of
|
||||||
@ -25,11 +30,6 @@ type packetQueue struct {
|
|||||||
// with the lock held.
|
// with the lock held.
|
||||||
queueLen int32
|
queueLen int32
|
||||||
|
|
||||||
// totalHtlcAmt is the sum of the value of all pending HTLC's currently
|
|
||||||
// residing within the overflow queue. This value should only read or
|
|
||||||
// modified *atomically*.
|
|
||||||
totalHtlcAmt int64
|
|
||||||
|
|
||||||
queue []*htlcPacket
|
queue []*htlcPacket
|
||||||
|
|
||||||
wg sync.WaitGroup
|
wg sync.WaitGroup
|
||||||
|
Loading…
Reference in New Issue
Block a user