Merge pull request #9720 from ziggie1984/add-btcd-notify-logs
chainntnfs: increase logging of the subsystems
This commit is contained in:
3 files changed
+14
No files matched your search
@@ -171,6 +171,8 @@ func (b *BitcoindNotifier) Started() bool {
|
|||||||
}
|
}
|
||||||
|
|
||||||
func (b *BitcoindNotifier) startNotifier() error {
|
func (b *BitcoindNotifier) startNotifier() error {
|
||||||
|
chainntnfs.Log.Infof("bitcoind notifier starting...")
|
||||||
|
|
||||||
// Connect to bitcoind, and register for notifications on connected,
|
// Connect to bitcoind, and register for notifications on connected,
|
||||||
// and disconnected blocks.
|
// and disconnected blocks.
|
||||||
if err := b.chainConn.Start(); err != nil {
|
if err := b.chainConn.Start(); err != nil {
|
||||||
@@ -207,6 +209,8 @@ func (b *BitcoindNotifier) startNotifier() error {
|
|||||||
// startup.
|
// startup.
|
||||||
atomic.StoreInt32(&b.active, 1)
|
atomic.StoreInt32(&b.active, 1)
|
||||||
|
|
||||||
|
chainntnfs.Log.Debugf("bitcoind notifier started")
|
||||||
|
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -204,7 +204,11 @@ func (b *BtcdNotifier) Stop() error {
|
|||||||
return nil
|
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 {
|
func (b *BtcdNotifier) startNotifier() error {
|
||||||
|
chainntnfs.Log.Infof("btcd notifier starting...")
|
||||||
|
|
||||||
// Start our concurrent queues before starting the chain connection, to
|
// Start our concurrent queues before starting the chain connection, to
|
||||||
// ensure onBlockConnected and onRedeemingTx callbacks won't be
|
// ensure onBlockConnected and onRedeemingTx callbacks won't be
|
||||||
// blocked.
|
// blocked.
|
||||||
@@ -257,6 +261,8 @@ func (b *BtcdNotifier) startNotifier() error {
|
|||||||
// startup.
|
// startup.
|
||||||
atomic.StoreInt32(&b.active, 1)
|
atomic.StoreInt32(&b.active, 1)
|
||||||
|
|
||||||
|
chainntnfs.Log.Debugf("btcd notifier started")
|
||||||
|
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -168,6 +168,8 @@ func (n *NeutrinoNotifier) Started() bool {
|
|||||||
}
|
}
|
||||||
|
|
||||||
func (n *NeutrinoNotifier) startNotifier() error {
|
func (n *NeutrinoNotifier) startNotifier() error {
|
||||||
|
chainntnfs.Log.Infof("neutrino notifier starting...")
|
||||||
|
|
||||||
// Start our concurrent queues before starting the rescan, to ensure
|
// Start our concurrent queues before starting the rescan, to ensure
|
||||||
// onFilteredBlockConnected and onRelavantTx callbacks won't be
|
// onFilteredBlockConnected and onRelavantTx callbacks won't be
|
||||||
// blocked.
|
// blocked.
|
||||||
@@ -234,6 +236,8 @@ func (n *NeutrinoNotifier) startNotifier() error {
|
|||||||
// startup.
|
// startup.
|
||||||
atomic.StoreInt32(&n.active, 1)
|
atomic.StoreInt32(&n.active, 1)
|
||||||
|
|
||||||
|
chainntnfs.Log.Debugf("neutrino notifier started")
|
||||||
|
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Reference in new issue
Block a user