Skip to content

Commit 3371992

Browse files
committed
Fix assertions w.r.t. VV
1 parent 7121350 commit 3371992

File tree

1 file changed

+4
-2
lines changed

1 file changed

+4
-2
lines changed

fdbserver/storageserver.actor.cpp

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -2978,7 +2978,8 @@ ACTOR Future<GetKeyValuesReply> readRange(StorageServer* data,
29782978

29792979
while (limit > 0 && *pLimitBytes > 0 && readBegin < range.end) {
29802980
ASSERT(!vCurrent || vCurrent.key() >= readBegin);
2981-
ASSERT(data->storageVersion() <= version);
2981+
ASSERT((!SERVER_KNOBS->ENABLE_VERSION_VECTOR && data->storageVersion() <= version) ||
2982+
(SERVER_KNOBS->ENABLE_VERSION_VECTOR && data->storageVersion() <= origVersion));
29822983

29832984
/* Traverse the PTree further, if thare are no unconsumed resultCache items */
29842985
if (pos == resultCache.size()) {
@@ -3078,7 +3079,8 @@ ACTOR Future<GetKeyValuesReply> readRange(StorageServer* data,
30783079

30793080
while (limit < 0 && *pLimitBytes > 0 && readEnd > range.begin) {
30803081
ASSERT(!vCurrent || vCurrent.key() < readEnd);
3081-
ASSERT(data->storageVersion() <= version);
3082+
ASSERT((!SERVER_KNOBS->ENABLE_VERSION_VECTOR && data->storageVersion() <= version) ||
3083+
(SERVER_KNOBS->ENABLE_VERSION_VECTOR && data->storageVersion() <= origVersion));
30823084

30833085
/* Traverse the PTree further, if thare are no unconsumed resultCache items */
30843086
if (pos == resultCache.size()) {

0 commit comments

Comments
 (0)