From 243927c9648c528f8e0d6cab20cab35e65aa6b60 Mon Sep 17 00:00:00 2001 From: Evan Tschannen Date: Fri, 3 Dec 2021 10:31:51 -0800 Subject: [PATCH] added a knob --- fdbclient/ServerKnobs.cpp | 1 + fdbclient/ServerKnobs.h | 1 + fdbserver/BlobManager.actor.cpp | 2 +- 3 files changed, 3 insertions(+), 1 deletion(-) diff --git a/fdbclient/ServerKnobs.cpp b/fdbclient/ServerKnobs.cpp index b11bd8e88c..38b1bbb18c 100644 --- a/fdbclient/ServerKnobs.cpp +++ b/fdbclient/ServerKnobs.cpp @@ -787,6 +787,7 @@ void ServerKnobs::initialize(Randomize randomize, ClientKnobs* clientKnobs, IsSi init( BG_DELTA_FILE_TARGET_BYTES, BG_DELTA_BYTES_BEFORE_COMPACT/10 ); init( BLOB_WORKER_TIMEOUT, 10.0 ); if( randomize && BUGGIFY ) BLOB_WORKER_TIMEOUT = 1.0; + init( BLOB_WORKERLIST_FETCH_INTERVAL, 1.0 ); // clang-format on diff --git a/fdbclient/ServerKnobs.h b/fdbclient/ServerKnobs.h index 050804a9a6..68f4456e1f 100644 --- a/fdbclient/ServerKnobs.h +++ b/fdbclient/ServerKnobs.h @@ -742,6 +742,7 @@ public: int BG_DELTA_BYTES_BEFORE_COMPACT; double BLOB_WORKER_TIMEOUT; // Blob Manager's reaction time to a blob worker failure + double BLOB_WORKERLIST_FETCH_INTERVAL; ServerKnobs(Randomize, ClientKnobs*, IsSimulated); void initialize(Randomize, ClientKnobs*, IsSimulated); diff --git a/fdbserver/BlobManager.actor.cpp b/fdbserver/BlobManager.actor.cpp index 5bea27cbf1..c6f210d88e 100644 --- a/fdbserver/BlobManager.actor.cpp +++ b/fdbserver/BlobManager.actor.cpp @@ -976,7 +976,7 @@ ACTOR Future monitorBlobWorker(BlobManagerData* bmData, BlobWorkerInterfac ACTOR Future checkBlobWorkerList(BlobManagerData* bmData) { loop { - wait(delay(1.0)); + wait(delay(SERVER_KNOBS->BLOB_WORKERLIST_FETCH_INTERVAL)); std::vector blobWorkers = wait(getBlobWorkers(bmData->db)); for (auto& worker : blobWorkers) { if (!bmData->workerAddresses.count(worker.stableAddress())) {