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

add some comments

pull/333/head
John Shahid 2014-03-12 12:30:37 -04:00
parent b5f68b7c9d
commit 603621ee65
1 changed files with 6 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/wal/global_state.go
View File

@ -114,6 +114,12 @@ func (self *GlobalState) setCurrentSequenceNumber(shardId uint32, sequenceNumber
}
func (self *GlobalState) commitRequestNumber(serverId, requestNumber uint32) {
// TODO: we need a way to verify the request numbers, the following
// won't work though when the request numbers roll over
// if currentRequestNumber := self.ServerLastRequestNumber[serverId]; requestNumber < currentRequestNumber {
// panic(fmt.Errorf("Expected rn %d to be >= %d", requestNumber, currentRequestNumber))
// }
self.ServerLastRequestNumber[serverId] = requestNumber
}