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

add more logging

pull/223/head
John Shahid 2014-01-30 17:58:47 -05:00
parent 7d761e6aa4
commit 6e812a9f3f
1 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
src/coordinator/cluster_configuration.go
View File

@ -301,10 +301,11 @@ func (self *ClusterConfiguration) AddPotentialServer(server *ClusterServer) {
self.servers = append(self.servers, server) self.servers = append(self.servers, server)
server.Id = uint32(len(self.servers)) server.Id = uint32(len(self.servers))
log.Info("Added server to cluster config: %d, %s, %s", server.Id, server.RaftConnectionString, server.ProtobufConnectionString) log.Info("Added server to cluster config: %d, %s, %s", server.Id, server.RaftConnectionString, server.ProtobufConnectionString)
log.Info("Checking whether this is the local server new: %s, local: %s\n", self.config.ProtobufConnectionString(), server.ProtobufConnectionString)
if server.ProtobufConnectionString != self.config.ProtobufConnectionString() { if server.ProtobufConnectionString != self.config.ProtobufConnectionString() {
log.Info("Connecting to ProtobufServer: %s", server.ProtobufConnectionString) log.Info("Connecting to ProtobufServer: %s", server.ProtobufConnectionString)
server.Connect() server.Connect()
} else { } else if !self.addedLocalServer {
log.Info("Added the local server") log.Info("Added the local server")
self.localServerId = server.Id self.localServerId = server.Id
self.addedLocalServerWait <- true self.addedLocalServerWait <- true
@ -581,9 +582,11 @@ func (self *ClusterConfiguration) Recovery(b []byte) error {
} }
for _, server := range self.servers { for _, server := range self.servers {
log.Info("Checking whether this is the local server new: %s, local: %s\n", self.config.ProtobufConnectionString(), server.ProtobufConnectionString)
if server.ProtobufConnectionString != self.config.ProtobufConnectionString() { if server.ProtobufConnectionString != self.config.ProtobufConnectionString() {
continue continue
} }
log.Info("Added the local server")
self.addedLocalServerWait <- true self.addedLocalServerWait <- true
self.addedLocalServer = true self.addedLocalServer = true
break break