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

peer: remove the Stop() method in favor of only Disconnect()

Browse Source
This commit is contained in:
Olaoluwa Osuntokun 2017-04-23 19:25:15 -07:00
parent 52ffb026af
commit 0ef36dca9b
No known key found for this signature in database
GPG Key ID: 9CC5B105D03521A2
1 changed files with 0 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
peer.go
View File

@ -273,14 +273,6 @@ func (p *peer) Start() error {
return nil return nil
} }
// Stop signals the peer for a graceful shutdown. All active goroutines will be
// signaled to wrap up any final actions. This function will also block until
// all goroutines have exited.
func (p *peer) Stop() error {
// If we're already disconnecting, just exit.
if !atomic.CompareAndSwapInt32(&p.disconnect, 0, 1) {
return nil
}
// loadActiveChannels creates indexes within the peer for tracking all active // loadActiveChannels creates indexes within the peer for tracking all active
// channels returned by the database. // channels returned by the database.
func (p *peer) loadActiveChannels(chans []*channeldb.OpenChannel) error { func (p *peer) loadActiveChannels(chans []*channeldb.OpenChannel) error {
@ -291,17 +283,12 @@ func (p *peer) loadActiveChannels(chans []*channeldb.OpenChannel) error {
continue continue
} }
// Ensure that the TCP connection is properly closed before continuing.
p.conn.Close()
lnChan, err := lnwallet.NewLightningChannel(p.server.lnwallet.Signer, lnChan, err := lnwallet.NewLightningChannel(p.server.lnwallet.Signer,
p.server.chainNotifier, dbChan) p.server.chainNotifier, dbChan)
if err != nil { if err != nil {
return err return err
} }
// Signal all worker goroutines to gracefully exit.
close(p.quit)
p.wg.Wait()
chanPoint := *dbChan.ChanID chanPoint := *dbChan.ChanID
chanID := lnwire.NewChanIDFromOutPoint(&chanPoint) chanID := lnwire.NewChanIDFromOutPoint(&chanPoint)