Influxdata
/
influxdb
mirror of https://github.com/influxdata/influxdb.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

add mutex

pull/820/head
Fabrizio (Misto) Milo 2013-08-06 21:02:30 -07:00
parent d46748244f
commit 6fcb929318
1 changed files with 6 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
server.go
View File

@ -272,11 +272,15 @@ func (s *Server) QuorumSize() int {
// Retrieves the election timeout. // Retrieves the election timeout.
func (s *Server) ElectionTimeout() time.Duration { func (s *Server) ElectionTimeout() time.Duration {
s.mutex.RLock()
defer s.mutex.RUnlock()
return s.electionTimeout return s.electionTimeout
} }
// Sets the election timeout. // Sets the election timeout.
func (s *Server) SetElectionTimeout(duration time.Duration) { func (s *Server) SetElectionTimeout(duration time.Duration) {
s.mutex.Lock()
defer s.mutex.Unlock()
s.electionTimeout = duration s.electionTimeout = duration
} }
@ -286,6 +290,8 @@ func (s *Server) SetElectionTimeout(duration time.Duration) {
// Retrieves the heartbeat timeout. // Retrieves the heartbeat timeout.
func (s *Server) HeartbeatTimeout() time.Duration { func (s *Server) HeartbeatTimeout() time.Duration {
s.mutex.RLock()
defer s.mutex.RUnlock()
return s.heartbeatTimeout return s.heartbeatTimeout
} }