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-05-07 17:19:59 -07:00
parent 5d824f5fbc
commit d45e7bf0b1
1 changed files with 4 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -29,11 +29,9 @@ struct TriggerRecoveryLoopWorkload : TestWorkload {
virtual std::string description() { return "TriggerRecoveryLoop"; }
ACTOR Future<Void> setOriginalNumOfResolvers(Database cx, TriggerRecoveryLoopWorkload* self) {
loop {
DatabaseConfiguration config = wait(getDatabaseConfiguration(cx));
self->originalNumOfResolvers = self->currentNumOfResolvers = config.getDesiredResolvers();
return Void();
}
DatabaseConfiguration config = wait(getDatabaseConfiguration(cx));
self->originalNumOfResolvers = self->currentNumOfResolvers = config.getDesiredResolvers();
return Void();
}
virtual Future<Void> setup(Database const& cx) {
@ -47,9 +45,9 @@ struct TriggerRecoveryLoopWorkload : TestWorkload {
loop {
state ReadYourWritesTransaction tr(cx);
try {
state Version v = wait(tr.getReadVersion());
tr.setOption(FDBTransactionOptions::LOCK_AWARE);
tr.setOption(FDBTransactionOptions::PRIORITY_SYSTEM_IMMEDIATE);
state Version v = wait(tr.getReadVersion());
tr.makeSelfConflicting();
wait(tr.commit());
TraceEvent(SevInfo, "TriggerRecoveryLoop_ClusterVersion").detail("Version", v);