Skip to content

Commit

Permalink
sequence number can be nil which causes a panic
Browse files Browse the repository at this point in the history
  • Loading branch information
jvshahid committed Jan 10, 2014
1 parent 68b57bb commit 6968573
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion src/coordinator/coordinator.go
Original file line number Diff line number Diff line change
Expand Up @@ -506,7 +506,7 @@ func (self *CoordinatorImpl) getCurrentSequenceNumber(replicationFactor uint8, o
}

func (self *CoordinatorImpl) ReplayReplication(request *protocol.Request, replicationFactor *uint8, owningServerId *uint32, lastSeenSequenceNumber *uint64) {
log.Warn("COORDINATOR: ReplayReplication: SN: %d, LS: %d, RF: %d, OS: %d", *request.SequenceNumber, *lastSeenSequenceNumber, *replicationFactor, *owningServerId)
log.Warn("COORDINATOR: ReplayReplication: LS: %d, RF: %d, OS: %d", *lastSeenSequenceNumber, *replicationFactor, *owningServerId)
key := fmt.Sprintf("%d_%d_%d_%d", *replicationFactor, *request.ClusterVersion, *request.OriginatingServerId, *owningServerId)
self.runningReplaysLock.Lock()
requestsWaitingToWrite := self.runningReplays[key]
Expand Down

0 comments on commit 6968573

Please sign in to comment.