LBRYCommunity/lbcd
1
0
Fork 0
Code Issues17 Pull requests4 Projects Releases28 Packages Wiki Activity

Set peer.timeConnected when we are actualy connected.

Browse source
This commit is contained in:
Owain G. Ainsworth 2013-10-18 18:48:51 +01:00
parent c242d75866
commit d26b8b2d43
1 changed files with 2 additions and 1 deletions

3
peer.go
View file

@ -1262,7 +1262,6 @@ func newPeerBase(s *server, inbound bool) *peer {
protocolVersion: btcwire.ProtocolVersion, protocolVersion: btcwire.ProtocolVersion,
btcnet: s.btcnet, btcnet: s.btcnet,
services: btcwire.SFNodeNetwork, services: btcwire.SFNodeNetwork,
timeConnected: time.Now(),
inbound: inbound, inbound: inbound,
knownAddresses: make(map[string]bool), knownAddresses: make(map[string]bool),
knownInventory: NewMruInventoryMap(maxKnownInventory), knownInventory: NewMruInventoryMap(maxKnownInventory),
@ -1285,6 +1284,7 @@ func newInboundPeer(s *server, conn net.Conn) *peer {
p := newPeerBase(s, true) p := newPeerBase(s, true)
p.conn = conn p.conn = conn
p.addr = conn.RemoteAddr().String() p.addr = conn.RemoteAddr().String()
p.timeConnected = time.Now()
atomic.AddInt32(&p.connected, 1) atomic.AddInt32(&p.connected, 1)
return p return p
} }
@ -1362,6 +1362,7 @@ func newOutboundPeer(s *server, addr string, persistent bool) *peer {
// may have scheduled a shutdown. In that case ditch // may have scheduled a shutdown. In that case ditch
// the peer immediately. // the peer immediately.
if atomic.LoadInt32(&p.disconnect) == 0 { if atomic.LoadInt32(&p.disconnect) == 0 {
p.timeConnected = time.Now()
p.server.addrManager.Attempt(p.na) p.server.addrManager.Attempt(p.na)
// Connection was successful so log it and start peer. // Connection was successful so log it and start peer.