mirrors/lnd
1
0
Fork 0
mirror of https://github.com/lightningnetwork/lnd.git synced 2024-11-19 09:53:54 +01:00
Code Issues Projects Releases Wiki Activity

peer: make linter happy

Browse Source
This commit is contained in:
eugene 2022-04-26 12:51:54 -04:00
parent d881679de0
commit 5ec6aafce3
No known key found for this signature in database
GPG Key ID: 118759E83439A9B1
1 changed files with 3 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
peer/brontide.go
View File

@ -60,11 +60,6 @@ const (
// message. // message.
handshakeTimeout = 15 * time.Second handshakeTimeout = 15 * time.Second
// outgoingQueueLen is the buffer size of the channel which houses
// messages to be sent across the wire, requested by objects outside
// this struct.
outgoingQueueLen = 50
// ErrorBufferSize is the number of historic peer errors that we store. // ErrorBufferSize is the number of historic peer errors that we store.
ErrorBufferSize = 10 ErrorBufferSize = 10
) )
@ -348,7 +343,7 @@ type Config struct {
// several helper goroutines to handle events such as HTLC timeouts, new // several helper goroutines to handle events such as HTLC timeouts, new
// funding workflow, and detecting an uncooperative closure of any active // funding workflow, and detecting an uncooperative closure of any active
// channels. // channels.
// TODO(roasbeef): proper reconnection logic // TODO(roasbeef): proper reconnection logic.
type Brontide struct { type Brontide struct {
// MUST be used atomically. // MUST be used atomically.
started int32 started int32
@ -709,6 +704,7 @@ func (p *Brontide) loadActiveChannels(chans []*channeldb.OpenChannel) (
if dbChan.HasChanStatus( if dbChan.HasChanStatus(
channeldb.ChanStatusCoopBroadcasted, channeldb.ChanStatusCoopBroadcasted,
) { ) {
shutdownMsg, err := p.restartCoopClose(lnChan) shutdownMsg, err := p.restartCoopClose(lnChan)
if err != nil { if err != nil {
peerLog.Errorf("Unable to restart "+ peerLog.Errorf("Unable to restart "+
@ -1055,7 +1051,7 @@ func (p *Brontide) readNextMessage() (lnwire.Message, error) {
// delivered via closure to a receiver. These messages MUST be in order due to // delivered via closure to a receiver. These messages MUST be in order due to
// the nature of the lightning channel commitment and gossiper state machines. // the nature of the lightning channel commitment and gossiper state machines.
// TODO(conner): use stream handler interface to abstract out stream // TODO(conner): use stream handler interface to abstract out stream
// state/logging // state/logging.
type msgStream struct { type msgStream struct {
streamShutdown int32 // To be used atomically. streamShutdown int32 // To be used atomically.
@ -2664,7 +2660,6 @@ func (p *Brontide) handleLocalCloseReq(req *htlcswitch.ChanClose) {
} }
switch req.CloseType { switch req.CloseType {
// A type of CloseRegular indicates that the user has opted to close // A type of CloseRegular indicates that the user has opted to close
// out this channel on-chain, so we execute the cooperative channel // out this channel on-chain, so we execute the cooperative channel
// closure workflow. // closure workflow.
@ -2924,7 +2919,6 @@ func (p *Brontide) finalizeChanClosure(chanCloser *chancloser.ChanCloser) {
go WaitForChanToClose(chanCloser.NegotiationHeight(), notifier, errChan, go WaitForChanToClose(chanCloser.NegotiationHeight(), notifier, errChan,
chanPoint, &closingTxid, closingTx.TxOut[0].PkScript, func() { chanPoint, &closingTxid, closingTx.TxOut[0].PkScript, func() {
// Respond to the local subsystem which requested the // Respond to the local subsystem which requested the
// channel closure. // channel closure.
if closeReq != nil { if closeReq != nil {