X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsal-distributed-datastore%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fcluster%2Fdatastore%2FDistributedDataStore.java;h=96f5ce816b722c8f28f6bc587663b84a9cf1f7a5;hb=0b9b1dcba996fd76e0e1bde731692570747f5efd;hp=8051f7d49bab43e48ad1a82215d35b49a55281e5;hpb=db0dbb7e7976efc860012dfdba61d5416d45900c;p=controller.git diff --git a/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/DistributedDataStore.java b/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/DistributedDataStore.java index 8051f7d49b..96f5ce816b 100644 --- a/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/DistributedDataStore.java +++ b/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/DistributedDataStore.java @@ -21,6 +21,7 @@ import org.opendaylight.controller.cluster.datastore.jmx.mbeans.DatastoreInfoMXB import org.opendaylight.controller.cluster.datastore.shardstrategy.ShardStrategyFactory; import org.opendaylight.controller.cluster.datastore.utils.ActorContext; import org.opendaylight.controller.cluster.datastore.utils.Dispatchers; +import org.opendaylight.controller.cluster.datastore.utils.PrimaryShardInfoFutureCache; import org.opendaylight.controller.md.sal.common.api.data.AsyncDataBroker; import org.opendaylight.controller.md.sal.common.api.data.AsyncDataChangeListener; import org.opendaylight.controller.md.sal.dom.api.DOMDataTreeChangeListener; @@ -63,6 +64,8 @@ public class DistributedDataStore implements DOMStore, SchemaContextListener, private final String type; + private final TransactionContextFactory txContextFactory; + public DistributedDataStore(ActorSystem actorSystem, ClusterWrapper cluster, Configuration configuration, DatastoreContext datastoreContext) { Preconditions.checkNotNull(actorSystem, "actorSystem should not be null"); @@ -79,12 +82,15 @@ public class DistributedDataStore implements DOMStore, SchemaContextListener, String shardDispatcher = new Dispatchers(actorSystem.dispatchers()).getDispatcherPath(Dispatchers.DispatcherType.Shard); + PrimaryShardInfoFutureCache primaryShardInfoCache = new PrimaryShardInfoFutureCache(); actorContext = new ActorContext(actorSystem, createShardManager(actorSystem, cluster, configuration, - datastoreContext, shardDispatcher, shardManagerId ), cluster, configuration, datastoreContext); + datastoreContext, shardDispatcher, shardManagerId, primaryShardInfoCache), cluster, + configuration, datastoreContext, primaryShardInfoCache); this.waitTillReadyTimeInMillis = actorContext.getDatastoreContext().getShardLeaderElectionTimeout().duration().toMillis() * READY_WAIT_FACTOR; + this.txContextFactory = TransactionContextFactory.create(actorContext); datastoreConfigMXBean = new DatastoreConfigurationMXBeanImpl(datastoreContext.getDataStoreMXBeanType()); datastoreConfigMXBean.setContext(datastoreContext); @@ -94,12 +100,13 @@ public class DistributedDataStore implements DOMStore, SchemaContextListener, datastoreInfoMXBean.registerMBean(); } - public DistributedDataStore(ActorContext actorContext) { + @VisibleForTesting + DistributedDataStore(ActorContext actorContext) { this.actorContext = Preconditions.checkNotNull(actorContext, "actorContext should not be null"); + this.txContextFactory = TransactionContextFactory.create(actorContext); this.type = UNKNOWN_TYPE; this.waitTillReadyTimeInMillis = actorContext.getDatastoreContext().getShardLeaderElectionTimeout().duration().toMillis() * READY_WAIT_FACTOR; - } public void setCloseable(AutoCloseable closeable) { @@ -144,24 +151,24 @@ public class DistributedDataStore implements DOMStore, SchemaContextListener, @Override public DOMStoreTransactionChain createTransactionChain() { - return new TransactionChainProxy(actorContext); + return txContextFactory.createTransactionChain(); } @Override public DOMStoreReadTransaction newReadOnlyTransaction() { - return new TransactionProxy(actorContext, TransactionType.READ_ONLY); + return new TransactionProxy(txContextFactory, TransactionType.READ_ONLY); } @Override public DOMStoreWriteTransaction newWriteOnlyTransaction() { actorContext.acquireTxCreationPermit(); - return new TransactionProxy(actorContext, TransactionType.WRITE_ONLY); + return new TransactionProxy(txContextFactory, TransactionType.WRITE_ONLY); } @Override public DOMStoreReadWriteTransaction newReadWriteTransaction() { actorContext.acquireTxCreationPermit(); - return new TransactionProxy(actorContext, TransactionType.READ_WRITE); + return new TransactionProxy(txContextFactory, TransactionType.READ_WRITE); } @Override @@ -182,7 +189,7 @@ public class DistributedDataStore implements DOMStore, SchemaContextListener, datastoreConfigMXBean.unregisterMBean(); datastoreInfoMXBean.unregisterMBean(); - if(closeable != null) { + if (closeable != null) { try { closeable.close(); } catch (Exception e) { @@ -190,12 +197,12 @@ public class DistributedDataStore implements DOMStore, SchemaContextListener, } } + txContextFactory.close(); actorContext.shutdown(); DistributedDataStoreFactory.destroyInstance(this); } - @VisibleForTesting - ActorContext getActorContext() { + public ActorContext getActorContext() { return actorContext; } @@ -214,14 +221,16 @@ public class DistributedDataStore implements DOMStore, SchemaContextListener, } private ActorRef createShardManager(ActorSystem actorSystem, ClusterWrapper cluster, Configuration configuration, - DatastoreContext datastoreContext, String shardDispatcher, String shardManagerId){ + DatastoreContext datastoreContext, String shardDispatcher, String shardManagerId, + PrimaryShardInfoFutureCache primaryShardInfoCache){ Exception lastException = null; for(int i=0;i<100;i++) { try { return actorSystem.actorOf( - ShardManager.props(cluster, configuration, datastoreContext, waitTillReadyCountDownLatch) - .withDispatcher(shardDispatcher).withMailbox(ActorContext.MAILBOX), shardManagerId); + ShardManager.props(cluster, configuration, datastoreContext, waitTillReadyCountDownLatch, + primaryShardInfoCache).withDispatcher(shardDispatcher).withMailbox( + ActorContext.MAILBOX), shardManagerId); } catch (Exception e){ lastException = e; Uninterruptibles.sleepUninterruptibly(100, TimeUnit.MILLISECONDS);