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

Added /fdbserver/ConfigDB/ConfigBroadcaster/Compact unit test

This commit is contained in:
sfc-gh-tclinkenbeard 2021-05-14 12:30:17 -07:00
parent 2a1593f6b3
commit bfb88805ab
2 changed files with 36 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

32
fdbserver/ConfigDatabaseUnitTests.actor.cpp
View File

@ -206,6 +206,7 @@ TEST_CASE("/fdbserver/ConfigDB/ConfigBroadcaster/CheckpointedUpdates") {
actors.add(localConfigurationA.consume(cfi));
actors.add(localConfigurationB.consume(cfi));
while (version <= 10) {
versionedMutations = Standalone<VectorRef<VersionedConfigMutationRef>>{};
appendVersionedMutation(versionedMutations, version, "class-A"_sr, "test_long"_sr, versionToValue(version));
appendVersionedMutation(
versionedMutations, version, "class-B"_sr, "test_long"_sr, versionToValue(version * 10));
@ -221,3 +222,34 @@ TEST_CASE("/fdbserver/ConfigDB/ConfigBroadcaster/CheckpointedUpdates") {
}
return Void();
}
TEST_CASE("/fdbserver/ConfigDB/ConfigBroadcaster/Compact") {
state DummyConfigSource dummyConfigSource;
state ConfigBroadcaster broadcaster(dummyConfigSource.getInterface(), deterministicRandom()->randomUniqueID());
state Reference<IDependentAsyncVar<ConfigFollowerInterface>> cfi =
IDependentAsyncVar<ConfigFollowerInterface>::create(makeReference<AsyncVar<ConfigFollowerInterface>>());
state LocalConfiguration localConfiguration("class-A", testManualKnobOverrides);
state Version version = 1;
state ActorCollection actors(false);
state Standalone<VectorRef<VersionedConfigMutationRef>> versionedMutations;
wait(localConfiguration.initialize("./", deterministicRandom()->randomUniqueID()));
TraceEvent("StartedTestBroadcasterAndLocalConfigs")
.detail("Broadcaster", broadcaster.getID())
.detail("LocalConfiguration", localConfiguration.getID());
actors.add(dummyConfigSource.serve());
actors.add(broadcaster.serve(cfi->get()));
while (version <= 10) {
versionedMutations = Standalone<VectorRef<VersionedConfigMutationRef>>{};
appendVersionedMutation(versionedMutations, version, "class-A"_sr, "test_long"_sr, versionToValue(version));
wait(broadcaster.addVersionedMutations(versionedMutations, version));
++version;
}
wait(cfi->get().compact.getReply(ConfigFollowerCompactRequest{ version }));
actors.add(localConfiguration.consume(cfi));
loop {
if (localConfiguration.getTestKnobs().TEST_LONG == 10) {
return Void();
}
wait(delayJittered(1.0));
}
}

5
fdbserver/ConfigFollowerInterface.h
View File

@ -149,9 +149,12 @@ struct ConfigFollowerGetChangesRequest {
struct ConfigFollowerCompactRequest {
static constexpr FileIdentifier file_identifier = 568910;
Version version;
Version version{ 0 };
ReplyPromise<Void> reply;
ConfigFollowerCompactRequest() = default;
explicit ConfigFollowerCompactRequest(Version version) : version(version) {}
template <class Ar>
void serialize(Ar& ar) {
serializer(ar, version, reply);