Skip to content

Commit cc0f429

Browse files
move to low priority thread
1 parent 4bda00a commit cc0f429

File tree

5 files changed

+190
-84
lines changed

5 files changed

+190
-84
lines changed

fdbclient/ServerKnobs.cpp

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -609,7 +609,7 @@ void ServerKnobs::initialize(Randomize randomize, ClientKnobs* clientKnobs, IsSi
609609
init( SHARDED_ROCKSDB_MAX_OPEN_FILES, 50000 ); // Should be smaller than OS's fd limit.
610610
init (SHARDED_ROCKSDB_READ_ASYNC_IO, false ); if (isSimulated) SHARDED_ROCKSDB_READ_ASYNC_IO = deterministicRandom()->coinflip();
611611
init( SHARDED_ROCKSDB_PREFIX_LEN, 0 ); if( randomize && BUGGIFY ) SHARDED_ROCKSDB_PREFIX_LEN = deterministicRandom()->randomInt(1, 20);
612-
612+
init ( SHARDED_ROCKSDB_CLEAR_RANGE_COMPACTION_LIMIT, 10 ); if (isSimulated) SHARDED_ROCKSDB_CLEAR_RANGE_COMPACTION_LIMIT = deterministicRandom()->randomInt(0, 100);
613613

614614
// Leader election
615615
bool longLeaderElection = randomize && BUGGIFY;

fdbclient/include/fdbclient/IKeyValueStore.actor.h

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -85,6 +85,11 @@ class IKeyValueStore : public IClosable {
8585
// Adds key range to a physical shard.
8686
virtual Future<Void> addRange(KeyRangeRef range, std::string id, bool active = true) { return Void(); }
8787

88+
// Creates new physical shards for key ranges.
89+
virtual Future<Void> addRanges(std::vector<std::pair<KeyRange, std::string>> ranges, bool active = true) {
90+
return Void();
91+
}
92+
8893
// Removes a key range from KVS and returns a list of empty physical shards after the removal.
8994
virtual std::vector<std::string> removeRange(KeyRangeRef range) { return std::vector<std::string>(); }
9095

fdbclient/include/fdbclient/ServerKnobs.h

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -573,6 +573,7 @@ class SWIFT_CXX_IMMORTAL_SINGLETON_TYPE ServerKnobs : public KnobsImpl<ServerKno
573573
int SHARDED_ROCKSDB_MAX_OPEN_FILES;
574574
bool SHARDED_ROCKSDB_READ_ASYNC_IO;
575575
int SHARDED_ROCKSDB_PREFIX_LEN;
576+
int SHARDED_ROCKSDB_CLEAR_RANGE_COMPACTION_LIMIT;
576577

577578
// Leader election
578579
int MAX_NOTIFICATIONS;

0 commit comments

Comments
 (0)