highperfocused/lnd
1
0
Fork 0
mirror of https://github.com/lightningnetwork/lnd.git synced 2025-07-02 03:22:25 +02:00
Code Issues Packages Projects Releases Wiki Activity

lncli: remove error logs

Browse Source
This commit is contained in:
ErikEk
2021-09-06 19:08:21 +02:00
parent e76c4c0e9b
commit 195e57025b
3 changed files with 47 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
docs/release-notes/release-notes-0.14.0.md
View File

@ -175,6 +175,9 @@ you.
* [Fixed timeout flakes in async payment benchmark tests](https://github.com/lightningnetwork/lnd/pull/5579). * [Fixed timeout flakes in async payment benchmark tests](https://github.com/lightningnetwork/lnd/pull/5579).
* [State, subscribechannelevents, subscribepeerevents, subscribeinvoices, subscribetransactions,
subscribechannelgraph and subscribechannelbackups no longer logs certain errors](https://github.com/lightningnetwork/lnd/pull/5695).
* [Flake fix in async bidirectional payment test](https://github.com/lightningnetwork/lnd/pull/5607). * [Flake fix in async bidirectional payment test](https://github.com/lightningnetwork/lnd/pull/5607).
* [Fixed context timeout when closing channels in tests](https://github.com/lightningnetwork/lnd/pull/5616). * [Fixed context timeout when closing channels in tests](https://github.com/lightningnetwork/lnd/pull/5616).

7
rpcperms/interceptor.go
View File

@ -2,6 +2,7 @@ package rpcperms
import ( import (
"context" "context"
"errors"
"fmt" "fmt"
"sync" "sync"
@ -272,7 +273,13 @@ func (r *InterceptorChain) SubscribeState(req *lnrpc.SubscribeStateRequest,
return err return err
} }
// The response stream's context for whatever reason has been
// closed. If context is closed by an exceeded deadline we will
// return an error.
case <-stream.Context().Done(): case <-stream.Context().Done():
if errors.Is(stream.Context().Err(), context.Canceled) {
return nil
}
return stream.Context().Err() return stream.Context().Err()
case <-r.quit: case <-r.quit:

40
rpcserver.go
View File

@ -2920,7 +2920,13 @@ func (r *rpcServer) SubscribePeerEvents(req *lnrpc.PeerEventSubscription,
return err return err
} }
// The response stream's context for whatever reason has been
// closed. If context is closed by an exceeded deadline we will
// return an error.
case <-eventStream.Context().Done(): case <-eventStream.Context().Done():
if errors.Is(eventStream.Context().Err(), context.Canceled) {
return nil
}
return eventStream.Context().Err() return eventStream.Context().Err()
case <-r.quit: case <-r.quit:
@ -4210,7 +4216,13 @@ func (r *rpcServer) SubscribeChannelEvents(req *lnrpc.ChannelEventSubscription,
return err return err
} }
// The response stream's context for whatever reason has been
// closed. If context is closed by an exceeded deadline we will
// return an error.
case <-updateStream.Context().Done(): case <-updateStream.Context().Done():
if errors.Is(updateStream.Context().Err(), context.Canceled) {
return nil
}
return updateStream.Context().Err() return updateStream.Context().Err()
case <-r.quit: case <-r.quit:
@ -5158,7 +5170,13 @@ func (r *rpcServer) SubscribeInvoices(req *lnrpc.InvoiceSubscription,
return err return err
} }
// The response stream's context for whatever reason has been
// closed. If context is closed by an exceeded deadline we will
// return an error.
case <-updateStream.Context().Done(): case <-updateStream.Context().Done():
if errors.Is(updateStream.Context().Err(), context.Canceled) {
return nil
}
return updateStream.Context().Err() return updateStream.Context().Err()
case <-r.quit: case <-r.quit:
@ -5219,8 +5237,14 @@ func (r *rpcServer) SubscribeTransactions(req *lnrpc.GetTransactionsRequest,
return err return err
} }
// The response stream's context for whatever reason has been
// closed. If context is closed by an exceeded deadline we will
// return an error.
case <-updateStream.Context().Done(): case <-updateStream.Context().Done():
rpcsLog.Infof("Cancelling transaction subscription") rpcsLog.Infof("Canceling transaction subscription")
if errors.Is(updateStream.Context().Err(), context.Canceled) {
return nil
}
return updateStream.Context().Err() return updateStream.Context().Err()
case <-r.quit: case <-r.quit:
@ -5761,9 +5785,13 @@ func (r *rpcServer) SubscribeChannelGraph(req *lnrpc.GraphTopologySubscription,
return err return err
} }
// The context was cancelled so we report a cancellation error // The response stream's context for whatever reason has been
// and exit immediately. // closed. If context is closed by an exceeded deadline
// we will return an error.
case <-updateStream.Context().Done(): case <-updateStream.Context().Done():
if errors.Is(updateStream.Context().Err(), context.Canceled) {
return nil
}
return updateStream.Context().Err() return updateStream.Context().Err()
// The server is quitting, so we'll exit immediately. Returning // The server is quitting, so we'll exit immediately. Returning
@ -6688,7 +6716,13 @@ func (r *rpcServer) SubscribeChannelBackups(req *lnrpc.ChannelBackupSubscription
return err return err
} }
// The response stream's context for whatever reason has been
// closed. If context is closed by an exceeded deadline we will
// return an error.
case <-updateStream.Context().Done(): case <-updateStream.Context().Done():
if errors.Is(updateStream.Context().Err(), context.Canceled) {
return nil
}
return updateStream.Context().Err() return updateStream.Context().Err()
case <-r.quit: case <-r.quit: