diff --git a/chainntnfs/bitcoindnotify/bitcoind.go b/chainntnfs/bitcoindnotify/bitcoind.go index 3dce1ae8..d4206d31 100644 --- a/chainntnfs/bitcoindnotify/bitcoind.go +++ b/chainntnfs/bitcoindnotify/bitcoind.go @@ -118,6 +118,8 @@ func (b *BitcoindNotifier) Stop() error { return nil } + chainntnfs.Log.Info("bitcoind notifier shutting down") + // Shutdown the rpc client, this gracefully disconnects from bitcoind, // and cleans up all related resources. b.chainConn.Stop() diff --git a/chainntnfs/btcdnotify/btcd.go b/chainntnfs/btcdnotify/btcd.go index 6a84df7d..9ddcbb93 100644 --- a/chainntnfs/btcdnotify/btcd.go +++ b/chainntnfs/btcdnotify/btcd.go @@ -161,6 +161,8 @@ func (b *BtcdNotifier) Stop() error { return nil } + chainntnfs.Log.Info("btcd notifier shutting down") + // Shutdown the rpc client, this gracefully disconnects from btcd, and // cleans up all related resources. b.chainConn.Shutdown() diff --git a/chainntnfs/neutrinonotify/neutrino.go b/chainntnfs/neutrinonotify/neutrino.go index fbe03c64..8f7d702a 100644 --- a/chainntnfs/neutrinonotify/neutrino.go +++ b/chainntnfs/neutrinonotify/neutrino.go @@ -136,6 +136,8 @@ func (n *NeutrinoNotifier) Stop() error { return nil } + chainntnfs.Log.Info("neutrino notifier shutting down") + close(n.quit) n.wg.Wait() diff --git a/channelnotifier/channelnotifier.go b/channelnotifier/channelnotifier.go index b99d18d4..74c2b15e 100644 --- a/channelnotifier/channelnotifier.go +++ b/channelnotifier/channelnotifier.go @@ -97,6 +97,7 @@ func (c *ChannelNotifier) Start() error { func (c *ChannelNotifier) Stop() error { var err error c.stopped.Do(func() { + log.Info("ChannelNotifier shutting down") err = c.ntfnServer.Stop() }) return err diff --git a/contractcourt/chain_arbitrator.go b/contractcourt/chain_arbitrator.go index 2ddc9c8c..426382dd 100644 --- a/contractcourt/chain_arbitrator.go +++ b/contractcourt/chain_arbitrator.go @@ -893,7 +893,7 @@ func (c *ChainArbitrator) Stop() error { return nil } - log.Infof("Stopping ChainArbitrator") + log.Info("ChainArbitrator shutting down") close(c.quit) diff --git a/discovery/gossiper.go b/discovery/gossiper.go index d7f2fd5f..e4d2d739 100644 --- a/discovery/gossiper.go +++ b/discovery/gossiper.go @@ -467,7 +467,10 @@ func (d *AuthenticatedGossiper) start() error { // Stop signals any active goroutines for a graceful closure. func (d *AuthenticatedGossiper) Stop() error { - d.stopped.Do(d.stop) + d.stopped.Do(func() { + log.Info("Authenticated gossiper shutting down") + d.stop() + }) return nil } diff --git a/htlcswitch/hop/iterator.go b/htlcswitch/hop/iterator.go index 00929334..20963bd7 100644 --- a/htlcswitch/hop/iterator.go +++ b/htlcswitch/hop/iterator.go @@ -137,6 +137,9 @@ func (p *OnionProcessor) Start() error { // Stop shutsdown the onion processor's sphinx router. func (p *OnionProcessor) Stop() error { + + log.Info("Onion processor shutting down") + p.router.Stop() return nil } diff --git a/htlcswitch/htlcnotifier.go b/htlcswitch/htlcnotifier.go index 4c15c2a6..fd067e2b 100644 --- a/htlcswitch/htlcnotifier.go +++ b/htlcswitch/htlcnotifier.go @@ -91,6 +91,7 @@ func (h *HtlcNotifier) Start() error { func (h *HtlcNotifier) Stop() error { var err error h.stopped.Do(func() { + log.Info("HtlcNotifier shutting down") if err = h.ntfnServer.Stop(); err != nil { log.Warnf("error stopping htlc notifier: %v", err) } diff --git a/htlcswitch/switch.go b/htlcswitch/switch.go index a9874c42..676eab8e 100644 --- a/htlcswitch/switch.go +++ b/htlcswitch/switch.go @@ -1942,7 +1942,7 @@ func (s *Switch) Stop() error { return errors.New("htlc switch already shutdown") } - log.Infof("HTLC Switch shutting down") + log.Info("HTLC Switch shutting down") close(s.quit) diff --git a/invoices/invoiceregistry.go b/invoices/invoiceregistry.go index 7bb9a4df..1e705c65 100644 --- a/invoices/invoiceregistry.go +++ b/invoices/invoiceregistry.go @@ -257,6 +257,8 @@ func (i *InvoiceRegistry) Start() error { // Stop signals the registry for a graceful shutdown. func (i *InvoiceRegistry) Stop() error { + log.Info("InvoiceRegistry shutting down") + i.expiryWatcher.Stop() close(i.quit) diff --git a/netann/chan_status_manager.go b/netann/chan_status_manager.go index b0188625..212bd4da 100644 --- a/netann/chan_status_manager.go +++ b/netann/chan_status_manager.go @@ -217,6 +217,7 @@ func (m *ChanStatusManager) start() error { // Stop safely shuts down the ChanStatusManager. func (m *ChanStatusManager) Stop() error { m.stopped.Do(func() { + log.Info("Channel Status Manager shutting down") close(m.quit) m.wg.Wait() }) diff --git a/netann/host_ann.go b/netann/host_ann.go index 48189cfe..3e87c4b0 100644 --- a/netann/host_ann.go +++ b/netann/host_ann.go @@ -68,6 +68,7 @@ func (h *HostAnnouncer) Start() error { // Stop signals the HostAnnouncer for a graceful stop. func (h *HostAnnouncer) Stop() error { h.stopOnce.Do(func() { + log.Info("HostAnnouncer shutting down") close(h.quit) h.wg.Wait() }) diff --git a/peernotifier/peernotifier.go b/peernotifier/peernotifier.go index 4a92ff26..d24c2cf9 100644 --- a/peernotifier/peernotifier.go +++ b/peernotifier/peernotifier.go @@ -52,7 +52,7 @@ func (p *PeerNotifier) Start() error { func (p *PeerNotifier) Stop() error { var err error p.stopped.Do(func() { - log.Info("Stopping PeerNotifier") + log.Info("PeerNotifier shutting down") err = p.ntfnServer.Stop() }) return err diff --git a/routing/router.go b/routing/router.go index 8b9cd97d..6ebf86c1 100644 --- a/routing/router.go +++ b/routing/router.go @@ -691,7 +691,7 @@ func (r *ChannelRouter) Stop() error { return nil } - log.Tracef("Channel Router shutting down") + log.Info("Channel Router shutting down") // Our filtered chain view could've only been started if // AssumeChannelValid isn't present. diff --git a/sweep/sweeper.go b/sweep/sweeper.go index 5869e456..f1f93aa6 100644 --- a/sweep/sweeper.go +++ b/sweep/sweeper.go @@ -427,7 +427,7 @@ func (s *UtxoSweeper) Stop() error { return nil } - log.Debugf("Sweeper shutting down") + log.Info("Sweeper shutting down") close(s.quit) s.wg.Wait()