akovalenko/lnd.xprv
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

chainntnfs/neutrinonotify: log height hint for spend notifications

Browse Source
This commit is contained in:
Olaoluwa Osuntokun 2018-03-01 16:49:19 -08:00
parent 9479b085e2
commit a9dc4f80f2
No known key found for this signature in database
GPG Key ID: 964EA263DD637C21
1 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
chainntnfs/neutrinonotify/neutrino.go
View File

@ -285,7 +285,8 @@ func (n *NeutrinoNotifier) notificationDispatcher() {
switch msg := registerMsg.(type) { switch msg := registerMsg.(type) {
case *spendNotification: case *spendNotification:
chainntnfs.Log.Infof("New spend subscription: "+ chainntnfs.Log.Infof("New spend subscription: "+
"utxo=%v", msg.targetOutpoint) "utxo=%v, height_hint=%v",
msg.targetOutpoint, msg.heightHint)
op := *msg.targetOutpoint op := *msg.targetOutpoint
if _, ok := n.spendNotifications[op]; !ok { if _, ok := n.spendNotifications[op]; !ok {
@ -556,6 +557,8 @@ type spendNotification struct {
spendChan chan *chainntnfs.SpendDetail spendChan chan *chainntnfs.SpendDetail
spendID uint64 spendID uint64
heightHint uint32
} }
// spendCancel is a message sent to the NeutrinoNotifier when a client wishes // spendCancel is a message sent to the NeutrinoNotifier when a client wishes
@ -586,6 +589,7 @@ func (n *NeutrinoNotifier) RegisterSpendNtfn(outpoint *wire.OutPoint,
targetOutpoint: outpoint, targetOutpoint: outpoint,
spendChan: make(chan *chainntnfs.SpendDetail, 1), spendChan: make(chan *chainntnfs.SpendDetail, 1),
spendID: atomic.AddUint64(&n.spendClientCounter, 1), spendID: atomic.AddUint64(&n.spendClientCounter, 1),
heightHint: heightHint,
} }
spendEvent := &chainntnfs.SpendEvent{ spendEvent := &chainntnfs.SpendEvent{
Spend: ntfn.spendChan, Spend: ntfn.spendChan,