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

Fix a few typos

pull/856/head
Ruben Kerkhof 2014-08-21 15:51:38 +02:00
parent e27044b4c4
commit 471e6a2c80
2 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
cluster/cluster_server.go
View File

@ -168,7 +168,7 @@ func (self *ClusterServer) heartbeat() {
}
if !self.isUp {
log.Warn("Server marked as up. Hearbeat succeeded")
log.Warn("Server marked as up. Heartbeat succeeded")
}
// otherwise, reset the backoff and mark the server as up
self.isUp = true
@ -202,7 +202,7 @@ func (self *ClusterServer) markServerAsDown() {
func (self *ClusterServer) handleHeartbeatError(err error) {
if self.isUp {
log.Warn("Server marked as down. Hearbeat error for server: %d - %s: %s", self.Id, self.ProtobufConnectionString, err)
log.Warn("Server marked as down. Heartbeat error for server: %d - %s: %s", self.Id, self.ProtobufConnectionString, err)
}
self.markServerAsDown()
self.Backoff *= 2

4
coordinator/protobuf_client_test.go
View File

@ -76,7 +76,7 @@ func (prs *PingResponseServer) handleConnection(conn net.Conn) {
conn.Close()
}
func FakeHearbeatServer() *PingResponseServer {
func FakeHeartbeatServer() *PingResponseServer {
l, err := net.Listen("tcp", "127.0.0.1:0")
if err != nil {
panic(err)
@ -88,7 +88,7 @@ func FakeHearbeatServer() *PingResponseServer {
func BenchmarkSingle(b *testing.B) {
var HEARTBEAT_TYPE = protocol.Request_HEARTBEAT
prs := FakeHearbeatServer()
prs := FakeHeartbeatServer()
client := NewProtobufClient(prs.Listener.Addr().String(), time.Second)
client.Connect()
b.ResetTimer()