diff options
author | Geir Storli <geirst@verizonmedia.com> | 2020-12-10 10:07:26 +0000 |
---|---|---|
committer | Geir Storli <geirst@verizonmedia.com> | 2020-12-10 10:07:26 +0000 |
commit | d4f175578d97d280b6ef498bab17fea246a8e01e (patch) | |
tree | f20aff3021f10bf3d31f3dfc3177960155a50970 /storage/src/tests/storageserver/rpc | |
parent | 2050d83063418bca2c04f73918c7548dbaddb5ed (diff) |
Make "events before wakeup" configurable for SharedRpcResources.
Diffstat (limited to 'storage/src/tests/storageserver/rpc')
-rw-r--r-- | storage/src/tests/storageserver/rpc/cluster_controller_rpc_api_service_test.cpp | 2 | ||||
-rw-r--r-- | storage/src/tests/storageserver/rpc/storage_api_rpc_service_test.cpp | 2 |
2 files changed, 2 insertions, 2 deletions
diff --git a/storage/src/tests/storageserver/rpc/cluster_controller_rpc_api_service_test.cpp b/storage/src/tests/storageserver/rpc/cluster_controller_rpc_api_service_test.cpp index 8b009e02f28..a39ee819f64 100644 --- a/storage/src/tests/storageserver/rpc/cluster_controller_rpc_api_service_test.cpp +++ b/storage/src/tests/storageserver/rpc/cluster_controller_rpc_api_service_test.cpp @@ -57,7 +57,7 @@ struct FixtureBase { config.getConfig("stor-server").set("node_index", "1"); addSlobrokConfig(config, slobrok); - shared_rpc_resources = std::make_unique<SharedRpcResources>(config.getConfigId(), 0, 1); + shared_rpc_resources = std::make_unique<SharedRpcResources>(config.getConfigId(), 0, 1, 1); cc_service = std::make_unique<ClusterControllerApiRpcService>(dispatcher, *shared_rpc_resources); shared_rpc_resources->start_server_and_register_slobrok("my_cool_rpc_test"); } diff --git a/storage/src/tests/storageserver/rpc/storage_api_rpc_service_test.cpp b/storage/src/tests/storageserver/rpc/storage_api_rpc_service_test.cpp index d1cdd649787..0b33da39c41 100644 --- a/storage/src/tests/storageserver/rpc/storage_api_rpc_service_test.cpp +++ b/storage/src/tests/storageserver/rpc/storage_api_rpc_service_test.cpp @@ -119,7 +119,7 @@ public: cfg.set("is_distributor", is_distributor ? "true" : "false"); addSlobrokConfig(_config, slobrok); - _shared_rpc_resources = std::make_unique<SharedRpcResources>(_config.getConfigId(), 0, 1); + _shared_rpc_resources = std::make_unique<SharedRpcResources>(_config.getConfigId(), 0, 1, 1); // TODO make codec provider into interface so we can test decode-failures more easily? _codec_provider = std::make_unique<MessageCodecProvider>(_doc_type_repo); } |