package org.opendaylight.controller.cluster.datastore;
import akka.actor.ActorSystem;
-import akka.actor.Props;
-import akka.osgi.BundleDelegatingClassLoader;
-import com.typesafe.config.ConfigFactory;
-import org.opendaylight.controller.cluster.datastore.config.ConfigurationReader;
-import org.opendaylight.controller.cluster.datastore.shardstrategy.ShardStrategyFactory;
+import org.opendaylight.controller.cluster.ActorSystemProvider;
+import org.opendaylight.controller.cluster.databroker.ClientBackedDataStore;
+import org.opendaylight.controller.cluster.datastore.config.Configuration;
+import org.opendaylight.controller.cluster.datastore.config.ConfigurationImpl;
+import org.opendaylight.controller.cluster.datastore.persisted.DatastoreSnapshot;
import org.opendaylight.controller.sal.core.api.model.SchemaService;
import org.osgi.framework.BundleContext;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
public class DistributedDataStoreFactory {
- private static final String ACTOR_SYSTEM_NAME = "opendaylight-cluster-data";
- private static final String CONFIGURATION_NAME = "odl-cluster-data";
+ private static final Logger LOG = LoggerFactory.getLogger(DistributedDataStoreFactory.class);
- private static volatile ActorSystem persistentActorSystem = null;
+ public static AbstractDataStore createInstance(final SchemaService schemaService,
+ final DatastoreContext datastoreContext, final DatastoreSnapshotRestore datastoreSnapshotRestore,
+ final ActorSystemProvider actorSystemProvider, final BundleContext bundleContext) {
- public static DistributedDataStore createInstance(SchemaService schemaService,
- DatastoreContext datastoreContext, BundleContext bundleContext) {
+ LOG.info("Create data store instance of type : {}", datastoreContext.getDataStoreName());
+ ActorSystem actorSystem = actorSystemProvider.getActorSystem();
+ DatastoreSnapshot restoreFromSnapshot = datastoreSnapshotRestore.getAndRemove(
+ datastoreContext.getDataStoreName());
DatastoreContextIntrospector introspector = new DatastoreContextIntrospector(datastoreContext);
DatastoreContextConfigAdminOverlay overlay = new DatastoreContextConfigAdminOverlay(
introspector, bundleContext);
- ActorSystem actorSystem = getOrCreateInstance(bundleContext, datastoreContext.getConfigurationReader());
Configuration config = new ConfigurationImpl("module-shards.conf", "modules.conf");
- final DistributedDataStore dataStore = new DistributedDataStore(actorSystem,
- new ClusterWrapperImpl(actorSystem), config, introspector.getContext());
+ ClusterWrapper clusterWrapper = new ClusterWrapperImpl(actorSystem);
+ DatastoreContextFactory contextFactory = introspector.newContextFactory();
+
+ final AbstractDataStore dataStore = datastoreContext.isUseTellBasedProtocol()
+ ? new ClientBackedDataStore(actorSystem, clusterWrapper, config, contextFactory, restoreFromSnapshot) :
+ new DistributedDataStore(actorSystem, clusterWrapper, config, contextFactory, restoreFromSnapshot);
overlay.setListener(dataStore);
- ShardStrategyFactory.setConfiguration(config);
schemaService.registerSchemaContextListener(dataStore);
dataStore.setCloseable(overlay);
dataStore.waitTillReady();
- return dataStore;
- }
-
- private static final ActorSystem getOrCreateInstance(final BundleContext bundleContext, ConfigurationReader configurationReader) {
- ActorSystem ret = persistentActorSystem;
- if (ret == null) {
- synchronized (DistributedDataStoreFactory.class) {
- ret = persistentActorSystem;
- if (ret == null) {
- // Create an OSGi bundle classloader for actor system
- BundleDelegatingClassLoader classLoader = new BundleDelegatingClassLoader(bundleContext.getBundle(),
- Thread.currentThread().getContextClassLoader());
- ret = ActorSystem.create(ACTOR_SYSTEM_NAME,
- ConfigFactory.load(configurationReader.read()).getConfig(CONFIGURATION_NAME), classLoader);
- ret.actorOf(Props.create(TerminationMonitor.class), "termination-monitor");
-
- persistentActorSystem = ret;
- }
- }
- }
-
- return ret;
+ return dataStore;
}
}