mirror of
https://github.com/lightningnetwork/lnd.git
synced 2024-11-19 01:43:16 +01:00
Merge pull request #9261 from yyforyongyu/fix-rpcclient-shutdown
multi: fix rpcclient shutdown
This commit is contained in:
commit
0876173c45
@ -139,6 +139,7 @@ func (b *BitcoindNotifier) Stop() error {
|
|||||||
// Shutdown the rpc client, this gracefully disconnects from bitcoind,
|
// Shutdown the rpc client, this gracefully disconnects from bitcoind,
|
||||||
// and cleans up all related resources.
|
// and cleans up all related resources.
|
||||||
b.chainConn.Stop()
|
b.chainConn.Stop()
|
||||||
|
b.chainConn.WaitForShutdown()
|
||||||
|
|
||||||
close(b.quit)
|
close(b.quit)
|
||||||
b.wg.Wait()
|
b.wg.Wait()
|
||||||
|
@ -180,7 +180,7 @@ func (b *BtcdNotifier) Stop() error {
|
|||||||
|
|
||||||
// Shutdown the rpc client, this gracefully disconnects from btcd, and
|
// Shutdown the rpc client, this gracefully disconnects from btcd, and
|
||||||
// cleans up all related resources.
|
// cleans up all related resources.
|
||||||
b.chainConn.Shutdown()
|
b.chainConn.Stop()
|
||||||
|
|
||||||
close(b.quit)
|
close(b.quit)
|
||||||
b.wg.Wait()
|
b.wg.Wait()
|
||||||
|
@ -50,6 +50,12 @@ type FlapCount struct {
|
|||||||
// bucket for the peer's pubkey if necessary. Note that this function overwrites
|
// bucket for the peer's pubkey if necessary. Note that this function overwrites
|
||||||
// the current value.
|
// the current value.
|
||||||
func (d *DB) WriteFlapCounts(flapCounts map[route.Vertex]*FlapCount) error {
|
func (d *DB) WriteFlapCounts(flapCounts map[route.Vertex]*FlapCount) error {
|
||||||
|
// Exit early if there are no updates.
|
||||||
|
if len(flapCounts) == 0 {
|
||||||
|
log.Debugf("No flap counts to write, skipped db update")
|
||||||
|
return nil
|
||||||
|
}
|
||||||
|
|
||||||
return kvdb.Update(d, func(tx kvdb.RwTx) error {
|
return kvdb.Update(d, func(tx kvdb.RwTx) error {
|
||||||
// Run through our set of flap counts and record them for
|
// Run through our set of flap counts and record them for
|
||||||
// each peer, creating a bucket for the peer pubkey if required.
|
// each peer, creating a bucket for the peer pubkey if required.
|
||||||
|
@ -48,6 +48,9 @@
|
|||||||
* [Fixed a bug](https://github.com/lightningnetwork/lnd/pull/9249) found in the
|
* [Fixed a bug](https://github.com/lightningnetwork/lnd/pull/9249) found in the
|
||||||
mission control store that can block the shutdown process of LND.
|
mission control store that can block the shutdown process of LND.
|
||||||
|
|
||||||
|
* Make sure the RPC clients used to access the chain backend are [properly
|
||||||
|
shutdown](https://github.com/lightningnetwork/lnd/pull/9261).
|
||||||
|
|
||||||
# New Features
|
# New Features
|
||||||
## Functional Enhancements
|
## Functional Enhancements
|
||||||
## RPC Additions
|
## RPC Additions
|
||||||
@ -196,4 +199,5 @@ The underlying functionality between those two options remain the same.
|
|||||||
* Oliver Gugger
|
* Oliver Gugger
|
||||||
* Pins
|
* Pins
|
||||||
* Viktor Tigerström
|
* Viktor Tigerström
|
||||||
* Ziggie
|
* Ziggie
|
||||||
|
|
||||||
|
2
go.mod
2
go.mod
@ -11,7 +11,7 @@ require (
|
|||||||
github.com/btcsuite/btcd/chaincfg/chainhash v1.1.0
|
github.com/btcsuite/btcd/chaincfg/chainhash v1.1.0
|
||||||
github.com/btcsuite/btclog v0.0.0-20241003133417-09c4e92e319c
|
github.com/btcsuite/btclog v0.0.0-20241003133417-09c4e92e319c
|
||||||
github.com/btcsuite/btclog/v2 v2.0.0-20241017175713-3428138b75c7
|
github.com/btcsuite/btclog/v2 v2.0.0-20241017175713-3428138b75c7
|
||||||
github.com/btcsuite/btcwallet v0.16.10-0.20240912233857-ffb143c77cc5
|
github.com/btcsuite/btcwallet v0.16.10-0.20241113134707-b4ff60753aaa
|
||||||
github.com/btcsuite/btcwallet/wallet/txauthor v1.3.5
|
github.com/btcsuite/btcwallet/wallet/txauthor v1.3.5
|
||||||
github.com/btcsuite/btcwallet/wallet/txrules v1.2.2
|
github.com/btcsuite/btcwallet/wallet/txrules v1.2.2
|
||||||
github.com/btcsuite/btcwallet/walletdb v1.4.4
|
github.com/btcsuite/btcwallet/walletdb v1.4.4
|
||||||
|
4
go.sum
4
go.sum
@ -95,8 +95,8 @@ github.com/btcsuite/btclog v0.0.0-20241003133417-09c4e92e319c/go.mod h1:w7xnGOhw
|
|||||||
github.com/btcsuite/btclog/v2 v2.0.0-20241017175713-3428138b75c7 h1:3Ct3zN3VCEKVm5nceWBBEKczc+jvTfVyOEG71ob2Yuc=
|
github.com/btcsuite/btclog/v2 v2.0.0-20241017175713-3428138b75c7 h1:3Ct3zN3VCEKVm5nceWBBEKczc+jvTfVyOEG71ob2Yuc=
|
||||||
github.com/btcsuite/btclog/v2 v2.0.0-20241017175713-3428138b75c7/go.mod h1:XItGUfVOxotJL8kkuk2Hj3EVow5KCugXl3wWfQ6K0AE=
|
github.com/btcsuite/btclog/v2 v2.0.0-20241017175713-3428138b75c7/go.mod h1:XItGUfVOxotJL8kkuk2Hj3EVow5KCugXl3wWfQ6K0AE=
|
||||||
github.com/btcsuite/btcutil v0.0.0-20190425235716-9e5f4b9a998d/go.mod h1:+5NJ2+qvTyV9exUAL/rxXi3DcLg2Ts+ymUAY5y4NvMg=
|
github.com/btcsuite/btcutil v0.0.0-20190425235716-9e5f4b9a998d/go.mod h1:+5NJ2+qvTyV9exUAL/rxXi3DcLg2Ts+ymUAY5y4NvMg=
|
||||||
github.com/btcsuite/btcwallet v0.16.10-0.20240912233857-ffb143c77cc5 h1:zYy233eUBvkF3lq2MUkybEhxhDsrRDSgiToIKN57mtk=
|
github.com/btcsuite/btcwallet v0.16.10-0.20241113134707-b4ff60753aaa h1:x7vYpwkPL5zeJEWPPaRunybH9ERRMGWeNf7x/0aU/38=
|
||||||
github.com/btcsuite/btcwallet v0.16.10-0.20240912233857-ffb143c77cc5/go.mod h1:1HJXYbjJzgumlnxOC2+ViR1U+gnHWoOn7WeK5OfY1eU=
|
github.com/btcsuite/btcwallet v0.16.10-0.20241113134707-b4ff60753aaa/go.mod h1:1HJXYbjJzgumlnxOC2+ViR1U+gnHWoOn7WeK5OfY1eU=
|
||||||
github.com/btcsuite/btcwallet/wallet/txauthor v1.3.5 h1:Rr0njWI3r341nhSPesKQ2JF+ugDSzdPoeckS75SeDZk=
|
github.com/btcsuite/btcwallet/wallet/txauthor v1.3.5 h1:Rr0njWI3r341nhSPesKQ2JF+ugDSzdPoeckS75SeDZk=
|
||||||
github.com/btcsuite/btcwallet/wallet/txauthor v1.3.5/go.mod h1:+tXJ3Ym0nlQc/iHSwW1qzjmPs3ev+UVWMbGgfV1OZqU=
|
github.com/btcsuite/btcwallet/wallet/txauthor v1.3.5/go.mod h1:+tXJ3Ym0nlQc/iHSwW1qzjmPs3ev+UVWMbGgfV1OZqU=
|
||||||
github.com/btcsuite/btcwallet/wallet/txrules v1.2.2 h1:YEO+Lx1ZJJAtdRrjuhXjWrYsmAk26wLTlNzxt2q0lhk=
|
github.com/btcsuite/btcwallet/wallet/txrules v1.2.2 h1:YEO+Lx1ZJJAtdRrjuhXjWrYsmAk26wLTlNzxt2q0lhk=
|
||||||
|
@ -238,6 +238,7 @@ func (b *BtcdEstimator) Stop() error {
|
|||||||
b.filterManager.Stop()
|
b.filterManager.Stop()
|
||||||
|
|
||||||
b.btcdConn.Shutdown()
|
b.btcdConn.Shutdown()
|
||||||
|
b.btcdConn.WaitForShutdown()
|
||||||
|
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
@ -136,6 +136,7 @@ func (b *BitcoindFilteredChainView) Stop() error {
|
|||||||
// Shutdown the rpc client, this gracefully disconnects from bitcoind's
|
// Shutdown the rpc client, this gracefully disconnects from bitcoind's
|
||||||
// zmq socket, and cleans up all related resources.
|
// zmq socket, and cleans up all related resources.
|
||||||
b.chainClient.Stop()
|
b.chainClient.Stop()
|
||||||
|
b.chainClient.WaitForShutdown()
|
||||||
|
|
||||||
b.blockQueue.Stop()
|
b.blockQueue.Stop()
|
||||||
|
|
||||||
|
@ -146,6 +146,7 @@ func (b *BtcdFilteredChainView) Stop() error {
|
|||||||
// Shutdown the rpc client, this gracefully disconnects from btcd, and
|
// Shutdown the rpc client, this gracefully disconnects from btcd, and
|
||||||
// cleans up all related resources.
|
// cleans up all related resources.
|
||||||
b.btcdConn.Shutdown()
|
b.btcdConn.Shutdown()
|
||||||
|
b.btcdConn.WaitForShutdown()
|
||||||
|
|
||||||
b.blockQueue.Stop()
|
b.blockQueue.Stop()
|
||||||
|
|
||||||
|
Loading…
Reference in New Issue
Block a user