|
|
@ -288,7 +288,7 @@ func (pm *ProtocolManager) handle(p *peer) error { |
|
|
|
} |
|
|
|
} |
|
|
|
// Start a timer to disconnect if the peer doesn't reply in time
|
|
|
|
// Start a timer to disconnect if the peer doesn't reply in time
|
|
|
|
p.forkDrop = time.AfterFunc(daoChallengeTimeout, func() { |
|
|
|
p.forkDrop = time.AfterFunc(daoChallengeTimeout, func() { |
|
|
|
glog.V(logger.Warn).Infof("%v: timed out DAO fork-check, dropping", p) |
|
|
|
glog.V(logger.Debug).Infof("%v: timed out DAO fork-check, dropping", p) |
|
|
|
pm.removePeer(p.id) |
|
|
|
pm.removePeer(p.id) |
|
|
|
}) |
|
|
|
}) |
|
|
|
// Make sure it's cleaned up if the peer dies off
|
|
|
|
// Make sure it's cleaned up if the peer dies off
|
|
|
|