GlcoinCore/loop
1
0
Fork 0
mirror of https://github.com/lightninglabs/loop.git synced 2026-08-13 12:33:03 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions

loopout_test: fix goroutine leak in TestCustomSweepConfTarget

Browse source 
Send the batch confirmation after AssertRegisterConf so the batch
exits cleanly, and use a cancellable context so the batcher stops
before leaktest runs.
This commit is contained in:
Slyghtning 2026-03-05 13:02:04 +01:00
parent 0d7daa0945
commit fdf2b91069
No known key found for this signature in database
GPG key ID: F82D456EA023C9BF
1 changed files with 11 additions and 5 deletions
Download patch file Download diff file Expand all files Collapse all files

16
loopout_test.go
View file

@ -330,7 +330,8 @@ func testCustomSweepConfTarget(t *testing.T) {
lnd.ChainParams, batcherStore, sweepStore,
)
tctx := t.Context()
tctx, cancel := context.WithCancel(t.Context())
defer cancel()
go func() {
err := batcher.Run(tctx)
@ -484,6 +485,9 @@ func testCustomSweepConfTarget(t *testing.T) {
// confirmations.
ctx.AssertRegisterConf(true, 3)
// Send the batch confirmation so the batch exits cleanly.
ctx.NotifyConf(sweepTx)
cfg.store.(*loopdb.StoreMock).AssertLoopOutState(loopdb.StateSuccess)
status = <-statusChan
require.Equal(t, loopdb.StateSuccess, status.State)
@ -567,7 +571,8 @@ func testPreimagePush(t *testing.T) {
lnd.ChainParams, batcherStore, sweepStore,
)
tctx := t.Context()
tctx, cancel := context.WithCancel(t.Context())
defer cancel()
go func() {
err := batcher.Run(tctx)
@ -577,7 +582,7 @@ func testPreimagePush(t *testing.T) {
}()
go func() {
err := swap.execute(context.Background(), &executeConfig{
err := swap.execute(tctx, &executeConfig{
statusChan: statusChan,
blockEpochChan: blockEpochChan,
timerFactory: timerFactory,
@ -986,7 +991,8 @@ func TestLoopOutMuSig2Sweep(t *testing.T) {
lnd.ChainParams, batcherStore, sweepStore,
)
tctx := t.Context()
tctx, cancel := context.WithCancel(t.Context())
defer cancel()
go func() {
err := batcher.Run(tctx)
@ -996,7 +1002,7 @@ func TestLoopOutMuSig2Sweep(t *testing.T) {
}()
go func() {
err := swap.execute(context.Background(), &executeConfig{
err := swap.execute(tctx, &executeConfig{
statusChan: statusChan,
blockEpochChan: blockEpochChan,
timerFactory: timerFactory,