fluencelabs/tendermint
1
0
Fork 0
mirror of https://github.com/fluencelabs/tendermint synced 2025-06-25 18:51:39 +00:00
Code Issues Projects Releases Wiki Activity

dont expose makePersistent

Browse Source
This commit is contained in:
Ethan Buchman
2017-04-10 16:04:55 -04:00
parent b6f744c732
commit 9a1a6c56b4
3 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
peer.go
View File

@ -80,8 +80,8 @@ func (p *Peer) CloseConn() {
p.conn.Close() p.conn.Close()
} }
// MakePersistent marks the peer as persistent. // makePersistent marks the peer as persistent.
func (p *Peer) MakePersistent() { func (p *Peer) makePersistent() {
if !p.outbound { if !p.outbound {
panic("inbound peers can't be made persistent") panic("inbound peers can't be made persistent")
} }

2
switch.go
View File

@ -319,7 +319,7 @@ func (sw *Switch) DialPeerWithAddress(addr *NetAddress, persistent bool) (*Peer,
peer, err := newPeer(addr, sw.reactorsByCh, sw.chDescs, sw.StopPeerForError, sw.config, sw.nodePrivKey) peer, err := newPeer(addr, sw.reactorsByCh, sw.chDescs, sw.StopPeerForError, sw.config, sw.nodePrivKey)
if persistent { if persistent {
peer.MakePersistent() peer.makePersistent()
} }
if err != nil { if err != nil {
log.Info("Failed dialing peer", "address", addr, "error", err) log.Info("Failed dialing peer", "address", addr, "error", err)

2
switch_test.go
View File

@ -275,7 +275,7 @@ func TestSwitchReconnectsToPersistentPeer(t *testing.T) {
defer close(done) defer close(done)
peer, err := newPeer(NewNetAddress(serverAddr), sw.reactorsByCh, sw.chDescs, sw.StopPeerForError, sw.config, sw.nodePrivKey) peer, err := newPeer(NewNetAddress(serverAddr), sw.reactorsByCh, sw.chDescs, sw.StopPeerForError, sw.config, sw.nodePrivKey)
peer.MakePersistent() peer.makePersistent()
require.Nil(err) require.Nil(err)
err = sw.AddPeer(peer) err = sw.AddPeer(peer)
require.Nil(err) require.Nil(err)