apple/foundationdb
1
0
Fork 0
mirror of https://github.com/apple/foundationdb.git synced 2025-05-22 23:19:02 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix timeout buggify

Browse Source
This commit is contained in:
Xiaoxi Wang 2022-06-29 22:46:50 -07:00
parent 1b0780398f
commit b51e9430a5
2 changed files with 3 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
fdbclient/NativeAPI.actor.cpp
View File

@ -7887,10 +7887,6 @@ ACTOR Future<std::vector<std::pair<UID, StorageWiggleValue>>> readStorageWiggleV
IncludeVersion()); IncludeVersion());
state Reference<ReadYourWritesTransaction> tr(new ReadYourWritesTransaction(cx)); state Reference<ReadYourWritesTransaction> tr(new ReadYourWritesTransaction(cx));
state std::vector<std::pair<UID, StorageWiggleValue>> res; state std::vector<std::pair<UID, StorageWiggleValue>> res;
if (g_network->isSimulated() && BUGGIFY_WITH_PROB(0.01)) {
throw timed_out();
}
// read the wiggling pairs // read the wiggling pairs
loop { loop {
try { try {

6
fdbserver/Status.actor.cpp
View File

@ -3105,9 +3105,9 @@ ACTOR Future<StatusReply> clusterGetStatus(
if (configuration.get().perpetualStorageWiggleSpeed > 0) { if (configuration.get().perpetualStorageWiggleSpeed > 0) {
state Future<std::vector<std::pair<UID, StorageWiggleValue>>> primaryWiggleValues; state Future<std::vector<std::pair<UID, StorageWiggleValue>>> primaryWiggleValues;
state Future<std::vector<std::pair<UID, StorageWiggleValue>>> remoteWiggleValues; state Future<std::vector<std::pair<UID, StorageWiggleValue>>> remoteWiggleValues;
storageWiggler["error"] = ""; double timeout = g_network->isSimulated() && BUGGIFY_WITH_PROB(0.01) ? 0.0 : 2.0;
primaryWiggleValues = timeoutError(readStorageWiggleValues(cx, true, true), 1.0); primaryWiggleValues = timeoutError(readStorageWiggleValues(cx, true, true), timeout);
remoteWiggleValues = timeoutError(readStorageWiggleValues(cx, false, true), 1.0); remoteWiggleValues = timeoutError(readStorageWiggleValues(cx, false, true), timeout);
wait(store( wait(store(
storageWiggler, storageWiggler,
storageWigglerStatsFetcher(db->get().distributor, configuration.get(), cx, true, &messages)) && storageWigglerStatsFetcher(db->get().distributor, configuration.get(), cx, true, &messages)) &&