Add configuration for pubsub topology manager timeout to the C++ rsa test
@@ -31,7 +31,8 @@ public:
{celix::FRAMEWORK_CACHE_DIR, ".clientCache"},
//Static configuration to let the pubsub zmq operate without discovery
{"PSA_ZMQ_STATIC_BIND_URL_FOR_test_invoke_default", "ipc:///tmp/pubsub-test-return"},
- {"PSA_ZMQ_STATIC_CONNECT_URL_FOR_test_return_default", "ipc:///tmp/pubsub-test-invoke" }
+ {"PSA_ZMQ_STATIC_CONNECT_URL_FOR_test_return_default", "ipc:///tmp/pubsub-test-invoke" },
+ {"PUBSUB_TOPOLOGY_MANAGER_HANDLING_THREAD_SLEEPTIME_MS", "1"}
};
clientFw = celix::createFramework(clientConfig);
clientCtx = clientFw->getFrameworkBundleContext();
@@ -41,7 +42,8 @@ public:
{celix::FRAMEWORK_CACHE_DIR, ".serverCache"},
//Static configuration to let the pubsub zmq operate without discovery
{"PSA_ZMQ_STATIC_BIND_URL_FOR_test_return_default", "ipc:///tmp/pubsub-test-invoke"},
- {"PSA_ZMQ_STATIC_CONNECT_URL_FOR_test_invoke_default", "ipc:///tmp/pubsub-test-return" }
+ {"PSA_ZMQ_STATIC_CONNECT_URL_FOR_test_invoke_default", "ipc:///tmp/pubsub-test-return" },
+ {"PUBSUB_TOPOLOGY_MANAGER_HANDLING_THREAD_SLEEPTIME_MS", "1"}
};
serverFw = celix::createFramework(serverConfig);
serverCtx = serverFw->getFrameworkBundleContext();
@@ -129,7 +131,7 @@ TEST_F(RemoteServicesIntegrationTestSuite, InvokeRemoteCalcService) {
auto start = std::chrono::system_clock::now();
auto elapsed = std::chrono::system_clock::now() - start;
- while (streamCount.load() == 0 && elapsed < std::chrono::seconds{5}) {
+ while (streamCount == 0 && elapsed < std::chrono::seconds{5}) {
std::this_thread::sleep_for(std::chrono::milliseconds{10});
elapsed = std::chrono::system_clock::now() - start;
}
