Add ThresholdMonitorTimeout.

This commit is contained in:
Ben Johnson
2014-01-08 15:51:13 -07:00
parent 88e0263d08
commit b47042634a

View File

@ -22,6 +22,8 @@ import (
const retryInterval = 10 const retryInterval = 10
const ThresholdMonitorTimeout = 5 * time.Second
type PeerServer struct { type PeerServer struct {
raftServer raft.Server raftServer raft.Server
server *Server server *Server
@ -512,6 +514,6 @@ func (s *PeerServer) monitorTimeoutThreshold(closeChan chan bool) {
return return
} }
time.Sleep(5 * time.Second) time.Sleep(ThresholdMonitorTimeout)
} }
} }