slight change
This commit is contained in:
parent
1c483d3423
commit
f3ee60b10b
|
@ -54,7 +54,10 @@ public:
|
|||
const_iterator end() const {
|
||||
return tags.end();
|
||||
}
|
||||
|
||||
void clear() {
|
||||
tags.clear();
|
||||
bytes = 0;
|
||||
}
|
||||
//private:
|
||||
Arena arena;
|
||||
std::set<TransactionTagRef> tags;
|
||||
|
|
|
@ -212,6 +212,7 @@ struct WriteTagThrottlingWorkload : KVWorkload {
|
|||
state int i;
|
||||
// give tag to client
|
||||
if (self->writeThrottle) {
|
||||
tr.options.tags.clear();
|
||||
if (isBadActor) {
|
||||
tr.options.tags.addTag(self->badWriteTag);
|
||||
tr.options.tags.addTag(self->badReadTag);
|
||||
|
@ -219,6 +220,7 @@ struct WriteTagThrottlingWorkload : KVWorkload {
|
|||
tr.options.tags.addTag(self->goodTag);
|
||||
}
|
||||
}
|
||||
|
||||
trStart = now();
|
||||
while (true) {
|
||||
try {
|
||||
|
|
|
@ -104,7 +104,7 @@ if(WITH_PYTHON)
|
|||
add_fdb_test(TEST_FILES pt.TXT IGNORE)
|
||||
add_fdb_test(TEST_FILES randomSelector.txt IGNORE)
|
||||
add_fdb_test(TEST_FILES selectorCorrectness.txt IGNORE)
|
||||
add_fdb_test(TEST_FILES WriteTagThrottling.txt IGNORE)
|
||||
add_fdb_test(TEST_FILES fast/WriteTagThrottling.txt)
|
||||
add_fdb_test(TEST_FILES fast/AtomicBackupCorrectness.txt)
|
||||
add_fdb_test(TEST_FILES fast/AtomicBackupToDBCorrectness.txt)
|
||||
add_fdb_test(TEST_FILES fast/AtomicOps.txt)
|
||||
|
|
|
@ -1,25 +0,0 @@
|
|||
testTitle=withoutWriteThrottling
|
||||
testName=WriteTagThrottling
|
||||
trPerSecond=10000000
|
||||
keyCount=5000
|
||||
absentFrac=0.01
|
||||
numWritePerTr=1
|
||||
numReadPerTr=1
|
||||
numClearPerTr=1
|
||||
badOpRate = 0.9
|
||||
|
||||
testName=HealthMetricsApi
|
||||
|
||||
testTitle=withWriteThrottling
|
||||
testName=WriteTagThrottling
|
||||
writeThrottle = true
|
||||
trPerSecond=10000000
|
||||
keyCount=5000
|
||||
absentFrac=0.01
|
||||
numWritePerTr=1
|
||||
numReadPerTr=1
|
||||
numClearPerTr=1
|
||||
badOpRate = 0.9
|
||||
tpsRate=20
|
||||
|
||||
testName=HealthMetricsApi
|
Loading…
Reference in New Issue