mirror of
https://github.com/etcd-io/etcd.git
synced 2024-09-27 06:25:44 +00:00
etcdserver: make tick duration calculation clear
This commit is contained in:
parent
230323255a
commit
35e285674b
@ -173,16 +173,16 @@ func (c *ServerConfig) ShouldDiscover() bool { return c.DiscoveryURL != "" }
|
|||||||
func (c *ServerConfig) ReqTimeout() time.Duration {
|
func (c *ServerConfig) ReqTimeout() time.Duration {
|
||||||
// 5s for queue waiting, computation and disk IO delay
|
// 5s for queue waiting, computation and disk IO delay
|
||||||
// + 2 * election timeout for possible leader election
|
// + 2 * election timeout for possible leader election
|
||||||
return 5*time.Second + 2*time.Duration(c.ElectionTicks)*time.Duration(c.TickMs)*time.Millisecond
|
return 5*time.Second + 2*time.Duration(c.ElectionTicks*int(c.TickMs))*time.Millisecond
|
||||||
}
|
}
|
||||||
|
|
||||||
func (c *ServerConfig) electionTimeout() time.Duration {
|
func (c *ServerConfig) electionTimeout() time.Duration {
|
||||||
return time.Duration(c.ElectionTicks) * time.Duration(c.TickMs) * time.Millisecond
|
return time.Duration(c.ElectionTicks*int(c.TickMs)) * time.Millisecond
|
||||||
}
|
}
|
||||||
|
|
||||||
func (c *ServerConfig) peerDialTimeout() time.Duration {
|
func (c *ServerConfig) peerDialTimeout() time.Duration {
|
||||||
// 1s for queue wait and election timeout
|
// 1s for queue wait and election timeout
|
||||||
return time.Second + time.Duration(c.ElectionTicks)*time.Duration(c.TickMs)*time.Millisecond
|
return time.Second + time.Duration(c.ElectionTicks*int(c.TickMs))*time.Millisecond
|
||||||
}
|
}
|
||||||
|
|
||||||
func (c *ServerConfig) PrintWithInitial() { c.print(true) }
|
func (c *ServerConfig) PrintWithInitial() { c.print(true) }
|
||||||
|
Loading…
x
Reference in New Issue
Block a user