diff options
author | obscuren <geffobscura@gmail.com> | 2014-01-18 00:14:59 +0800 |
---|---|---|
committer | obscuren <geffobscura@gmail.com> | 2014-01-18 00:14:59 +0800 |
commit | 87434a09418e6cc2dd4b92d7e35afc6f155994bc (patch) | |
tree | 76914e772618c2d31050ef63fbc3ea589a6a30d1 /server.go | |
parent | ddf82c333702e22d3cd7e5c693ad0603089a57a4 (diff) | |
download | go-tangerine-87434a09418e6cc2dd4b92d7e35afc6f155994bc.tar go-tangerine-87434a09418e6cc2dd4b92d7e35afc6f155994bc.tar.gz go-tangerine-87434a09418e6cc2dd4b92d7e35afc6f155994bc.tar.bz2 go-tangerine-87434a09418e6cc2dd4b92d7e35afc6f155994bc.tar.lz go-tangerine-87434a09418e6cc2dd4b92d7e35afc6f155994bc.tar.xz go-tangerine-87434a09418e6cc2dd4b92d7e35afc6f155994bc.tar.zst go-tangerine-87434a09418e6cc2dd4b92d7e35afc6f155994bc.zip |
Ping pong message
Diffstat (limited to 'server.go')
-rw-r--r-- | server.go | 4 |
1 files changed, 2 insertions, 2 deletions
@@ -81,13 +81,13 @@ func (s *Server) Broadcast(msgType ethwire.MsgType, data []byte) { } const ( - processReapingTimeout = 10 // TODO increase + processReapingTimeout = 1 // TODO increase ) func (s *Server) ReapDeadPeers() { for { eachPeer(s.peers, func(p *Peer, e *list.Element) { - if atomic.LoadInt32(&p.disconnect) == 1 { + if atomic.LoadInt32(&p.disconnect) == 1 || (p.inbound && (time.Now().Unix()-p.lastPong) > int64(5*time.Minute)) { log.Println("Dead peer found .. reaping") s.peers.Remove(e) |