Skip to content

Commit

Permalink
Merge pull request #8599 from xiang90/longer_timeout
Browse files Browse the repository at this point in the history
etcdserver: make dial timeout longer
  • Loading branch information
xiang90 committed Sep 23, 2017
2 parents 6515a1d + 35e2856 commit 4830ca7
Showing 1 changed file with 4 additions and 5 deletions.
9 changes: 4 additions & 5 deletions etcdserver/config.go
Original file line number Diff line number Diff line change
Expand Up @@ -173,17 +173,16 @@ func (c *ServerConfig) ShouldDiscover() bool { return c.DiscoveryURL != "" }
func (c *ServerConfig) ReqTimeout() time.Duration {
// 5s for queue waiting, computation and disk IO delay
// + 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 {
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 {
// 1s for queue wait and system delay
// + one RTT, which is smaller than 1/5 election timeout
return time.Second + time.Duration(c.ElectionTicks)*time.Duration(c.TickMs)*time.Millisecond/5
// 1s for queue wait and election timeout
return time.Second + time.Duration(c.ElectionTicks*int(c.TickMs))*time.Millisecond
}

func (c *ServerConfig) PrintWithInitial() { c.print(true) }
Expand Down

0 comments on commit 4830ca7

Please sign in to comment.