diff --git a/chainntnfs/bitcoindnotify/bitcoind.go b/chainntnfs/bitcoindnotify/bitcoind.go index 20e09d7f2..1dae68995 100644 --- a/chainntnfs/bitcoindnotify/bitcoind.go +++ b/chainntnfs/bitcoindnotify/bitcoind.go @@ -171,6 +171,8 @@ func (b *BitcoindNotifier) Started() bool { } func (b *BitcoindNotifier) startNotifier() error { + chainntnfs.Log.Infof("bitcoind notifier starting...") + // Connect to bitcoind, and register for notifications on connected, // and disconnected blocks. if err := b.chainConn.Start(); err != nil { @@ -207,6 +209,8 @@ func (b *BitcoindNotifier) startNotifier() error { // startup. atomic.StoreInt32(&b.active, 1) + chainntnfs.Log.Debugf("bitcoind notifier started") + return nil } diff --git a/chainntnfs/btcdnotify/btcd.go b/chainntnfs/btcdnotify/btcd.go index d5750ec2a..b89cde9ac 100644 --- a/chainntnfs/btcdnotify/btcd.go +++ b/chainntnfs/btcdnotify/btcd.go @@ -204,7 +204,11 @@ func (b *BtcdNotifier) Stop() error { return nil } +// startNotifier is the main starting point for the BtcdNotifier. It connects +// to btcd and start the main dispatcher goroutine. func (b *BtcdNotifier) startNotifier() error { + chainntnfs.Log.Infof("btcd notifier starting...") + // Start our concurrent queues before starting the chain connection, to // ensure onBlockConnected and onRedeemingTx callbacks won't be // blocked. @@ -257,6 +261,8 @@ func (b *BtcdNotifier) startNotifier() error { // startup. atomic.StoreInt32(&b.active, 1) + chainntnfs.Log.Debugf("btcd notifier started") + return nil } diff --git a/chainntnfs/neutrinonotify/neutrino.go b/chainntnfs/neutrinonotify/neutrino.go index 784f55a47..51e82a118 100644 --- a/chainntnfs/neutrinonotify/neutrino.go +++ b/chainntnfs/neutrinonotify/neutrino.go @@ -168,6 +168,8 @@ func (n *NeutrinoNotifier) Started() bool { } func (n *NeutrinoNotifier) startNotifier() error { + chainntnfs.Log.Infof("neutrino notifier starting...") + // Start our concurrent queues before starting the rescan, to ensure // onFilteredBlockConnected and onRelavantTx callbacks won't be // blocked. @@ -234,6 +236,8 @@ func (n *NeutrinoNotifier) startNotifier() error { // startup. atomic.StoreInt32(&n.active, 1) + chainntnfs.Log.Debugf("neutrino notifier started") + return nil }