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

discovery/gossiper: define ErrGossiperShuttingDown

Browse Source
This commit is contained in:
Johan T. Halseth 2018-08-20 14:28:09 +02:00
parent 18e680f192
commit 54f67f72b1
No known key found for this signature in database
GPG Key ID: 15BAADA29DA20D26
1 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
discovery/gossiper.go
View File

@ -31,6 +31,10 @@ var (
// AnnounceSignatures messages, by persisting them until a send // AnnounceSignatures messages, by persisting them until a send
// operation has succeeded. // operation has succeeded.
messageStoreKey = []byte("message-store") messageStoreKey = []byte("message-store")
// ErrGossiperShuttingDown is an error that is returned if the gossiper
// is in the process of being shut down.
ErrGossiperShuttingDown = errors.New("gossiper is shutting down")
) )
// networkMsg couples a routing related wire message with the peer that // networkMsg couples a routing related wire message with the peer that
@ -476,7 +480,7 @@ func (d *AuthenticatedGossiper) ProcessRemoteAnnouncement(msg lnwire.Message,
select { select {
case d.networkMsgs <- nMsg: case d.networkMsgs <- nMsg:
case <-d.quit: case <-d.quit:
nMsg.err <- errors.New("gossiper has shut down") nMsg.err <- ErrGossiperShuttingDown
} }
return nMsg.err return nMsg.err
@ -502,7 +506,7 @@ func (d *AuthenticatedGossiper) ProcessLocalAnnouncement(msg lnwire.Message,
select { select {
case d.networkMsgs <- nMsg: case d.networkMsgs <- nMsg:
case <-d.quit: case <-d.quit:
nMsg.err <- errors.New("gossiper has shut down") nMsg.err <- ErrGossiperShuttingDown
} }
return nMsg.err return nMsg.err