chainntnfs: ensure ntfn cancellation loop will exit
This commit fixes a slight bug introduced. We now ensure that the cancel loop always exists if the ChainNotifier has been signaled for a quit.
This commit is contained in:
2 files changed
+4
No files matched your search
@@ -692,6 +692,7 @@ func (b *BtcdNotifier) RegisterSpendNtfn(outpoint *wire.OutPoint,
|
||||
return
|
||||
}
|
||||
case <-b.quit:
|
||||
return
|
||||
}
|
||||
}
|
||||
case <-b.quit:
|
||||
@@ -788,6 +789,7 @@ func (b *BtcdNotifier) RegisterBlockEpochNtfn() (*chainntnfs.BlockEpochEvent, er
|
||||
return
|
||||
}
|
||||
case <-b.quit:
|
||||
return
|
||||
}
|
||||
}
|
||||
case <-b.quit:
|
||||
|
||||
@@ -722,6 +722,7 @@ func (n *NeutrinoNotifier) RegisterSpendNtfn(outpoint *wire.OutPoint,
|
||||
return
|
||||
}
|
||||
case <-n.quit:
|
||||
return
|
||||
}
|
||||
}
|
||||
case <-n.quit:
|
||||
@@ -891,6 +892,7 @@ func (n *NeutrinoNotifier) RegisterBlockEpochNtfn() (*chainntnfs.BlockEpochEvent
|
||||
return
|
||||
}
|
||||
case <-n.quit:
|
||||
return
|
||||
}
|
||||
}
|
||||
case <-n.quit:
|
||||
|
||||
Reference in new issue
Block a user