Bug 1534: Changed blocking calls to async in dist data store 65/9965/7
authortpantelis <tpanteli@brocade.com>
Thu, 14 Aug 2014 07:03:47 +0000 (03:03 -0400)
committertpantelis <tpanteli@brocade.com>
Sat, 16 Aug 2014 05:37:09 +0000 (01:37 -0400)
commit3145f4149ff58cd393819e24454a08b384122bb2
treebbd1b55d48a16b75ca0c18aff725feac2e9f2d85
parentefbeac00372d85440d46e2e5e04b124036ad3721
Bug 1534: Changed blocking calls to async in dist data store

Changed the read and commit methods to use async akka actor calls instead of
submitting tasks to a ListeningExecutorService that do blocking akka
calls. This obviates the need for the ListeningExecutorService.

Change-Id: I7a3f369917431067ad1817a3ab53a358bc21f123
Signed-off-by: tpantelis <tpanteli@brocade.com>
12 files changed:
opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/DistributedDataStore.java
opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/ShardReadWriteTransaction.java
opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/ShardWriteTransaction.java
opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/ThreePhaseCommitCohortProxy.java
opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/TransactionChainProxy.java
opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/TransactionProxy.java
opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/messages/DeleteData.java
opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/utils/ActorContext.java
opendaylight/md-sal/sal-distributed-datastore/src/test/java/org/opendaylight/controller/cluster/datastore/ThreePhaseCommitCohortProxyTest.java
opendaylight/md-sal/sal-distributed-datastore/src/test/java/org/opendaylight/controller/cluster/datastore/TransactionProxyTest.java
opendaylight/md-sal/sal-distributed-datastore/src/test/java/org/opendaylight/controller/cluster/datastore/utils/ActorContextTest.java
opendaylight/md-sal/sal-distributed-datastore/src/test/java/org/opendaylight/controller/cluster/datastore/utils/MockActorContext.java