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

more logging

pull/302/head
John Shahid 2014-03-11 16:28:14 -04:00
parent 5db312db88
commit e1b996ea3a
1 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/cluster/cluster_configuration.go
View File

@ -941,7 +941,9 @@ func (self *ClusterConfiguration) RecoverFromWAL() error {
} }
func (self *ClusterConfiguration) recover(serverId uint32, writer Writer) error { func (self *ClusterConfiguration) recover(serverId uint32, writer Writer) error {
return self.wal.RecoverServerFromLastCommit(serverId, self.shardIdsForServerId(serverId), func(request *protocol.Request, shardId uint32) error { shardIds := self.shardIdsForServerId(serverId)
log.Debug("replaying wal for server %d and shardIds %#v", serverId, shardIds)
return self.wal.RecoverServerFromLastCommit(serverId, shardIds, func(request *protocol.Request, shardId uint32) error {
if request == nil { if request == nil {
log.Error("Error on recover, the wal yielded a nil request") log.Error("Error on recover, the wal yielded a nil request")
return nil return nil