Merge pull request #9650 from Roasbeef/early-offer-chan-flushing-flake
lnwallet/chancloser: fix flake in TestRbfChannelFlushingTransitions/early_offer
This commit is contained in:
2 files changed
+3
-7
No files matched your search
@@ -1353,8 +1353,8 @@ func TestRbfChannelFlushingTransitions(t *testing.T) {
|
|||||||
// offer and send our sig).
|
// offer and send our sig).
|
||||||
closeHarness.chanCloser.SendEvent(ctx, &flushEvent)
|
closeHarness.chanCloser.SendEvent(ctx, &flushEvent)
|
||||||
closeHarness.assertSingleRemoteRbfIteration(
|
closeHarness.assertSingleRemoteRbfIteration(
|
||||||
remoteOffer, absoluteFee, absoluteFee, sequence, false,
|
remoteOffer, absoluteFee, absoluteFee, sequence, true,
|
||||||
true,
|
false,
|
||||||
)
|
)
|
||||||
})
|
})
|
||||||
|
|
||||||
|
|||||||
@@ -237,8 +237,7 @@ func (s *StateMachine[Event, Env]) Stop() {
|
|||||||
//
|
//
|
||||||
// TODO(roasbeef): bool if processed?
|
// TODO(roasbeef): bool if processed?
|
||||||
func (s *StateMachine[Event, Env]) SendEvent(ctx context.Context, event Event) {
|
func (s *StateMachine[Event, Env]) SendEvent(ctx context.Context, event Event) {
|
||||||
s.log.DebugS(ctx, "Sending event",
|
s.log.Debugf("Sending event %T", event)
|
||||||
"event", lnutils.SpewLogClosure(event))
|
|
||||||
|
|
||||||
select {
|
select {
|
||||||
case s.events <- event:
|
case s.events <- event:
|
||||||
@@ -544,9 +543,6 @@ func (s *StateMachine[Event, Env]) applyEvents(ctx context.Context,
|
|||||||
currentState State[Event, Env], newEvent Event) (State[Event, Env],
|
currentState State[Event, Env], newEvent Event) (State[Event, Env],
|
||||||
error) {
|
error) {
|
||||||
|
|
||||||
s.log.DebugS(ctx, "Applying new event",
|
|
||||||
"event", lnutils.SpewLogClosure(newEvent))
|
|
||||||
|
|
||||||
eventQueue := fn.NewQueue(newEvent)
|
eventQueue := fn.NewQueue(newEvent)
|
||||||
|
|
||||||
// Given the next event to handle, we'll process the event, then add
|
// Given the next event to handle, we'll process the event, then add
|
||||||
|
|||||||
Reference in new issue
Block a user