wbtiger
/
foundationdb
mirror of https://github.com/apple/foundationdb.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Addressed review comments.

This commit is contained in:
Balachandar Namasivayam 2019-02-25 18:29:30 -08:00
parent f44f26c232
commit ab99497695
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
fdbserver/workloads/ConsistencyCheck.actor.cpp
View File

@ -62,7 +62,7 @@ struct ConsistencyCheckWorkload : TestWorkload
int rateLimitMax; int rateLimitMax;
// DataSet Size // DataSet Size
int64_t dataSetSize; int64_t bytesReadInPreviousRound;
//Randomize shard order with each iteration if true //Randomize shard order with each iteration if true
bool shuffleShards; bool shuffleShards;
@ -92,7 +92,7 @@ struct ConsistencyCheckWorkload : TestWorkload
firstClient = clientId == 0; firstClient = clientId == 0;
repetitions = 0; repetitions = 0;
dataSetSize = 0; bytesReadInPreviousRound = 0;
} }
virtual std::string description() virtual std::string description()
@ -583,8 +583,8 @@ struct ConsistencyCheckWorkload : TestWorkload
state int effectiveClientCount = (self->distributed) ? self->clientCount : 1; state int effectiveClientCount = (self->distributed) ? self->clientCount : 1;
state int i = self->clientId * (self->shardSampleFactor + 1); state int i = self->clientId * (self->shardSampleFactor + 1);
state int increment = (self->distributed && !self->firstClient) ? effectiveClientCount * self->shardSampleFactor : 1; state int increment = (self->distributed && !self->firstClient) ? effectiveClientCount * self->shardSampleFactor : 1;
state int rateLimitForThisRound = self->dataSetSize == 0 ? self->rateLimitMax : state int rateLimitForThisRound = self->bytesReadInPreviousRound == 0 ? self->rateLimitMax :
std::min(self->rateLimitMax, static_cast<int>(ceil(self->dataSetSize / (float) CLIENT_KNOBS->CONSISTENCY_CHECK_ONE_ROUND_TARGET_COMPLETION_TIME))); std::min(self->rateLimitMax, static_cast<int>(ceil(self->bytesReadInPreviousRound / (float) CLIENT_KNOBS->CONSISTENCY_CHECK_ONE_ROUND_TARGET_COMPLETION_TIME)));
ASSERT(rateLimitForThisRound >= 0 && rateLimitForThisRound <= self->rateLimitMax); ASSERT(rateLimitForThisRound >= 0 && rateLimitForThisRound <= self->rateLimitMax);
TraceEvent("ConsistencyCheck_RateLimitForThisRound").detail("RateLimit", rateLimitForThisRound); TraceEvent("ConsistencyCheck_RateLimitForThisRound").detail("RateLimit", rateLimitForThisRound);
state Reference<IRateControl> rateLimiter = Reference<IRateControl>( new SpeedLimit(rateLimitForThisRound, CLIENT_KNOBS->CONSISTENCY_CHECK_RATE_WINDOW) ); state Reference<IRateControl> rateLimiter = Reference<IRateControl>( new SpeedLimit(rateLimitForThisRound, CLIENT_KNOBS->CONSISTENCY_CHECK_RATE_WINDOW) );
@ -1033,7 +1033,7 @@ struct ConsistencyCheckWorkload : TestWorkload
} }
}*/ }*/
self->dataSetSize = bytesReadInthisRound; self->bytesReadInPreviousRound = bytesReadInthisRound;
return true; return true;
} }