summaryrefslogtreecommitdiff
path: root/src/mongo/dbtests/framework_options.cpp
diff options
context:
space:
mode:
authorMaria van Keulen <maria@mongodb.com>2019-05-02 15:15:17 -0400
committerMaria van Keulen <maria@mongodb.com>2019-05-08 15:00:26 -0400
commit4cfe7bd17640acd296fad4d916aecc27ba8b5f4f (patch)
tree946923d34eb76d45b95b55556809940679577dff /src/mongo/dbtests/framework_options.cpp
parentd3ee35d6e3ac7a42cd5ad106c3ecb9fb554900c7 (diff)
downloadmongo-4cfe7bd17640acd296fad4d916aecc27ba8b5f4f.tar.gz
SERVER-40823 Enable Flow Control in testing
Diffstat (limited to 'src/mongo/dbtests/framework_options.cpp')
-rw-r--r--src/mongo/dbtests/framework_options.cpp6
1 files changed, 6 insertions, 0 deletions
diff --git a/src/mongo/dbtests/framework_options.cpp b/src/mongo/dbtests/framework_options.cpp
index c8940e3df68..ea4f54b65d8 100644
--- a/src/mongo/dbtests/framework_options.cpp
+++ b/src/mongo/dbtests/framework_options.cpp
@@ -40,6 +40,7 @@
#include "mongo/base/status.h"
#include "mongo/bson/util/builder.h"
#include "mongo/db/query/find.h"
+#include "mongo/db/storage/flow_control_parameters_gen.h"
#include "mongo/db/storage/storage_options.h"
#include "mongo/dbtests/dbtests.h"
#include "mongo/unittest/unittest.h"
@@ -123,6 +124,11 @@ Status storeTestFrameworkOptions(const moe::Environment& params,
storageGlobalParams.dbpath = dbpathString.c_str();
storageGlobalParams.engine = params["storage.engine"].as<string>();
+ gFlowControlEnabled.store(params["enableFlowControl"].as<bool>());
+
+ if (gFlowControlEnabled.load()) {
+ log() << "Flow Control enabled" << endl;
+ }
if (storageGlobalParams.engine == "wiredTiger" &&
params.count("replication.enableMajorityReadConcern")) {