Merge pull request #5676 from ErikEk/chainnotifier-remove-error-log

chainnotifier: remove error logs
This commit is contained in:
Olaoluwa Osuntokun authored and GitHub committed 2021-08-30 18:35:12 -07:00
commit 844874252f
2 files changed
+18 -7

No files matched your search

@@ -169,6 +169,8 @@ you.
* [Link channel point logging](https://github.com/lightningnetwork/lnd/pull/5508) * [Link channel point logging](https://github.com/lightningnetwork/lnd/pull/5508)
* [Canceling the chain notifier no longer logs certain errors](https://github.com/lightningnetwork/lnd/pull/5676)
* [Fixed context leak in integration tests, and properly handled context * [Fixed context leak in integration tests, and properly handled context
timeout](https://github.com/lightningnetwork/lnd/pull/5646). timeout](https://github.com/lightningnetwork/lnd/pull/5646).
+16 -7
View File
@@ -300,7 +300,7 @@ func (s *Server) RegisterConfirmationsNtfn(in *ConfRequest,
} }
// The transaction satisfying the request has been reorged out // The transaction satisfying the request has been reorged out
// of the chain, so we'll send an event describing so. // of the chain, so we'll send an event describing it.
case _, ok := <-confEvent.NegativeConf: case _, ok := <-confEvent.NegativeConf:
if !ok { if !ok {
return chainntnfs.ErrChainNotifierShuttingDown return chainntnfs.ErrChainNotifierShuttingDown
@@ -324,9 +324,12 @@ func (s *Server) RegisterConfirmationsNtfn(in *ConfRequest,
return nil return nil
// The response stream's context for whatever reason has been // The response stream's context for whatever reason has been
// closed. We'll return the error indicated by the context // closed. If context is closed by an exceeded deadline we will
// itself to the caller. // return an error.
case <-confStream.Context().Done(): case <-confStream.Context().Done():
if errors.Is(confStream.Context().Err(), context.Canceled) {
return nil
}
return confStream.Context().Err() return confStream.Context().Err()
// The server has been requested to shut down. // The server has been requested to shut down.
@@ -432,9 +435,12 @@ func (s *Server) RegisterSpendNtfn(in *SpendRequest,
return nil return nil
// The response stream's context for whatever reason has been // The response stream's context for whatever reason has been
// closed. We'll return the error indicated by the context // closed. If context is closed by an exceeded deadline we will
// itself to the caller. // return an error.
case <-spendStream.Context().Done(): case <-spendStream.Context().Done():
if errors.Is(spendStream.Context().Err(), context.Canceled) {
return nil
}
return spendStream.Context().Err() return spendStream.Context().Err()
// The server has been requested to shut down. // The server has been requested to shut down.
@@ -503,9 +509,12 @@ func (s *Server) RegisterBlockEpochNtfn(in *BlockEpoch,
} }
// The response stream's context for whatever reason has been // The response stream's context for whatever reason has been
// closed. We'll return the error indicated by the context // closed. If context is closed by an exceeded deadline we will
// itself to the caller. // return an error.
case <-epochStream.Context().Done(): case <-epochStream.Context().Done():
if errors.Is(epochStream.Context().Err(), context.Canceled) {
return nil
}
return epochStream.Context().Err() return epochStream.Context().Err()
// The server has been requested to shut down. // The server has been requested to shut down.