From 603621ee6597a252ac050fd54b2bb755a9e089a2 Mon Sep 17 00:00:00 2001 From: John Shahid Date: Wed, 12 Mar 2014 12:30:37 -0400 Subject: [PATCH] add some comments --- src/wal/global_state.go | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/src/wal/global_state.go b/src/wal/global_state.go index b51bddda1f..f9fe34ea3c 100644 --- a/src/wal/global_state.go +++ b/src/wal/global_state.go @@ -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 }