From 323593f2e61d16571bc1deedf42e8a4006b59016 Mon Sep 17 00:00:00 2001 From: Robert Varga Date: Wed, 29 Jul 2020 12:09:34 +0200 Subject: [PATCH] Convert FileModuleShardConfigProvider to OSGi DS This is a simple injected holder, convert it to a full-blown component. JIRA: CONTROLLER-1882 Change-Id: I6676055801c178c4ffb4137ec6721128014dedde Signed-off-by: Robert Varga --- .../config/FileModuleShardConfigProvider.java | 22 +++++++++++++++++++ .../blueprint/clustered-datastore.xml | 5 +---- 2 files changed, 23 insertions(+), 4 deletions(-) diff --git a/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/config/FileModuleShardConfigProvider.java b/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/config/FileModuleShardConfigProvider.java index adafa54aa2..7ee67be47c 100644 --- a/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/config/FileModuleShardConfigProvider.java +++ b/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/config/FileModuleShardConfigProvider.java @@ -9,16 +9,28 @@ package org.opendaylight.controller.cluster.datastore.config; import com.typesafe.config.Config; import java.util.Map; +import org.osgi.service.component.annotations.Activate; +import org.osgi.service.component.annotations.Component; +import org.osgi.service.component.annotations.Deactivate; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; /** * Implementation of ModuleShardConfigProvider that reads the module and shard configuration from files. * * @author Thomas Pantelis */ +@Component(immediate = true, service = ModuleShardConfigProvider.class) public class FileModuleShardConfigProvider extends AbstractModuleShardConfigProvider { + private static final Logger LOG = LoggerFactory.getLogger(FileModuleShardConfigProvider.class); + private final String moduleShardsConfigPath; private final String modulesConfigPath; + public FileModuleShardConfigProvider() { + this("./configuration/initial/module-shards.conf", "./configuration/initial/modules.conf"); + } + public FileModuleShardConfigProvider(final String moduleShardsConfigPath, final String modulesConfigPath) { this.moduleShardsConfigPath = moduleShardsConfigPath; this.modulesConfigPath = modulesConfigPath; @@ -33,4 +45,14 @@ public class FileModuleShardConfigProvider extends AbstractModuleShardConfigProv readModulesConfig(modulesConfig, moduleConfigMap, configuration); return moduleConfigMap; } + + @Activate + void activate() { + LOG.info("Shard configuration provider started"); + } + + @Deactivate + void deactivate() { + LOG.info("Shard configuration provider stopped"); + } } diff --git a/opendaylight/md-sal/sal-distributed-datastore/src/main/resources/OSGI-INF/blueprint/clustered-datastore.xml b/opendaylight/md-sal/sal-distributed-datastore/src/main/resources/OSGI-INF/blueprint/clustered-datastore.xml index c97bfc471f..14463207e2 100644 --- a/opendaylight/md-sal/sal-distributed-datastore/src/main/resources/OSGI-INF/blueprint/clustered-datastore.xml +++ b/opendaylight/md-sal/sal-distributed-datastore/src/main/resources/OSGI-INF/blueprint/clustered-datastore.xml @@ -16,6 +16,7 @@ + @@ -49,10 +50,6 @@ - - - - -- 2.36.6