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

added a knob

This commit is contained in:
Evan Tschannen 2021-12-03 10:31:51 -08:00
parent 58ea185278
commit 243927c964
3 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
fdbclient/ServerKnobs.cpp
View File

@ -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

1
fdbclient/ServerKnobs.h
View File

@ -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);

2
fdbserver/BlobManager.actor.cpp
View File

@ -976,7 +976,7 @@ ACTOR Future<Void> monitorBlobWorker(BlobManagerData* bmData, BlobWorkerInterfac
ACTOR Future<Void> checkBlobWorkerList(BlobManagerData* bmData) {
loop {
wait(delay(1.0));
wait(delay(SERVER_KNOBS->BLOB_WORKERLIST_FETCH_INTERVAL));
std::vector<BlobWorkerInterface> blobWorkers = wait(getBlobWorkers(bmData->db));
for (auto& worker : blobWorkers) {
if (!bmData->workerAddresses.count(worker.stableAddress())) {