rpcserver: log connections to transaction subscription stream

This commit is contained in:
ErikEk 2021-06-05 23:05:54 +02:00
parent 42099ef5e1
commit 70901dc157

@ -5015,6 +5015,7 @@ func (r *rpcServer) SubscribeTransactions(req *lnrpc.GetTransactionsRequest,
return err return err
} }
defer txClient.Cancel() defer txClient.Cancel()
rpcsLog.Infof("New transaction subscription")
for { for {
select { select {
@ -5056,6 +5057,7 @@ func (r *rpcServer) SubscribeTransactions(req *lnrpc.GetTransactionsRequest,
} }
case <-updateStream.Context().Done(): case <-updateStream.Context().Done():
rpcsLog.Infof("Cancelling transaction subscription")
return updateStream.Context().Err() return updateStream.Context().Err()
case <-r.quit: case <-r.quit: