This is an automated email from the ASF dual-hosted git repository. pnoltes pushed a commit to branch feature/pstm_missing_receiver_fix in repository https://gitbox.apache.org/repos/asf/celix.git
commit 8468d829c992166b1461cd8968dc92cc0a282f8e Author: Pepijn Noltes <[email protected]> AuthorDate: Mon Dec 5 17:27:31 2022 +0100 Update import/export remote service component to use locking instead of suspend strategy --- .../integration/src/TestExportImportRemoteServiceFactory.cc | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/bundles/cxx_remote_services/integration/src/TestExportImportRemoteServiceFactory.cc b/bundles/cxx_remote_services/integration/src/TestExportImportRemoteServiceFactory.cc index cc7da48a..21a167a1 100644 --- a/bundles/cxx_remote_services/integration/src/TestExportImportRemoteServiceFactory.cc +++ b/bundles/cxx_remote_services/integration/src/TestExportImportRemoteServiceFactory.cc @@ -263,13 +263,16 @@ private: auto& cmp = ctx->getDependencyManager()->createComponent(std::make_unique<ImportedCalculator>(logHelper)); cmp.createServiceDependency<pubsub_publisher>(PUBSUB_PUBLISHER_SERVICE_NAME) .setRequired(true) + .setStrategy(DependencyUpdateStrategy::locking) .setFilter(std::string{"(&(topic="}.append(invokeTopic).append(")(scope=").append(scope).append("))")) .setCallbacks(&ImportedCalculator::setPublisher); cmp.createServiceDependency<celix::PromiseFactory>() .setRequired(true) + .setStrategy(DependencyUpdateStrategy::locking) .setCallbacks(&ImportedCalculator::setPromiseFactory); cmp.createServiceDependency<celix::PushStreamProvider>() .setRequired(true) + .setStrategy(DependencyUpdateStrategy::locking) .setCallbacks(&ImportedCalculator::setPushStreamProvider); cmp.setCallbacks(&ImportedCalculator::init, &ImportedCalculator::start, &ImportedCalculator::stop, &ImportedCalculator::deinit); @@ -512,15 +515,18 @@ private: auto& cmp = ctx->getDependencyManager()->createComponent(std::make_unique<ExportedCalculator>(logHelper)); cmp.createServiceDependency<pubsub_publisher>(PUBSUB_PUBLISHER_SERVICE_NAME) .setRequired(true) + .setStrategy(DependencyUpdateStrategy::locking) .setFilter(std::string{"(&(topic="}.append(returnTopic).append(")(scope=").append(scope).append("))")) .setCallbacks(&ExportedCalculator::setPublisher); cmp.createServiceDependency<celix::PromiseFactory>() .setRequired(true) + .setStrategy(DependencyUpdateStrategy::locking) .setCallbacks(&ExportedCalculator::setPromiseFactory); cmp.createServiceDependency<ICalculator>() .setRequired(true) + .setStrategy(DependencyUpdateStrategy::locking) .setFilter(std::string{"("}.append(celix::SERVICE_ID).append("=").append(svcId).append(")")) .setCallbacks(&ExportedCalculator::setICalculator);
