|
|
@ -20,7 +20,7 @@ import ( |
|
|
|
const ( |
|
|
|
const ( |
|
|
|
defaultDialTimeout = 10 * time.Second |
|
|
|
defaultDialTimeout = 10 * time.Second |
|
|
|
refreshPeersInterval = 30 * time.Second |
|
|
|
refreshPeersInterval = 30 * time.Second |
|
|
|
trustedPeerCheckInterval = 15 * time.Second |
|
|
|
staticPeerCheckInterval = 15 * time.Second |
|
|
|
|
|
|
|
|
|
|
|
// This is the maximum number of inbound connection
|
|
|
|
// This is the maximum number of inbound connection
|
|
|
|
// that are allowed to linger between 'accepted' and
|
|
|
|
// that are allowed to linger between 'accepted' and
|
|
|
@ -345,7 +345,7 @@ func (srv *Server) listenLoop() { |
|
|
|
// staticNodesLoop is responsible for periodically checking that static
|
|
|
|
// staticNodesLoop is responsible for periodically checking that static
|
|
|
|
// connections are actually live, and requests dialing if not.
|
|
|
|
// connections are actually live, and requests dialing if not.
|
|
|
|
func (srv *Server) staticNodesLoop() { |
|
|
|
func (srv *Server) staticNodesLoop() { |
|
|
|
tick := time.Tick(trustedPeerCheckInterval) |
|
|
|
tick := time.Tick(staticPeerCheckInterval) |
|
|
|
for { |
|
|
|
for { |
|
|
|
select { |
|
|
|
select { |
|
|
|
case <-srv.quit: |
|
|
|
case <-srv.quit: |
|
|
|