Fixed typo
This commit is contained in:
parent
b286102d34
commit
c45fe8c697
|
@ -4,7 +4,7 @@
|
||||||
|
|
||||||
namespace {
|
namespace {
|
||||||
|
|
||||||
ACTOR Future<StorageServerInterface> getRandomStrage(Database cx) {
|
ACTOR Future<StorageServerInterface> getRandomStorage(Database cx) {
|
||||||
state Transaction tr(cx);
|
state Transaction tr(cx);
|
||||||
loop {
|
loop {
|
||||||
try {
|
try {
|
||||||
|
@ -94,7 +94,7 @@ struct LocalRatekeeperWorkload : TestWorkload {
|
||||||
|
|
||||||
ACTOR static Future<Void> _start(LocalRatekeeperWorkload* self, Database cx) {
|
ACTOR static Future<Void> _start(LocalRatekeeperWorkload* self, Database cx) {
|
||||||
wait(delay(self->startAfter));
|
wait(delay(self->startAfter));
|
||||||
state StorageServerInterface ssi = wait(getRandomStrage(cx));
|
state StorageServerInterface ssi = wait(getRandomStorage(cx));
|
||||||
g_simulator.disableFor(format("%s/updateStorage", ssi.id().toString().c_str()), self->blockWritesFor);
|
g_simulator.disableFor(format("%s/updateStorage", ssi.id().toString().c_str()), self->blockWritesFor);
|
||||||
state Future<Void> done = delay(self->blockWritesFor);
|
state Future<Void> done = delay(self->blockWritesFor);
|
||||||
// not much will happen until the storage goes over the soft limit
|
// not much will happen until the storage goes over the soft limit
|
||||||
|
|
Loading…
Reference in New Issue