org.opendaylight.controller.cluster.databroker

Class ConcurrentDOMDataBroker

java.lang.Object

org.opendaylight.controller.cluster.databroker.AbstractDOMTransactionFactory<org.opendaylight.mdsal.dom.spi.store.DOMStore>

org.opendaylight.controller.cluster.databroker.AbstractDOMBroker

org.opendaylight.controller.cluster.databroker.ConcurrentDOMDataBroker

All Implemented Interfaces:

AutoCloseable, org.opendaylight.mdsal.common.api.AsyncDataBroker<org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier,org.opendaylight.yangtools.yang.data.api.schema.NormalizedNode<?,?>>, org.opendaylight.mdsal.common.api.AsyncDataTransactionFactory<org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier,org.opendaylight.yangtools.yang.data.api.schema.NormalizedNode<?,?>>, org.opendaylight.mdsal.common.api.TransactionChainFactory<org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier,org.opendaylight.yangtools.yang.data.api.schema.NormalizedNode<?,?>>, org.opendaylight.mdsal.dom.api.DOMDataBroker, org.opendaylight.mdsal.dom.api.DOMExtensibleService<org.opendaylight.mdsal.dom.api.DOMDataBroker,org.opendaylight.mdsal.dom.api.DOMDataBrokerExtension>, org.opendaylight.mdsal.dom.api.DOMService

@Beta
public class ConcurrentDOMDataBroker
extends AbstractDOMBroker

ConcurrentDOMDataBroker commits transactions concurrently. The 3 commit phases (canCommit, preCommit, and commit) are performed serially and non-blocking (ie async) per transaction but multiple transaction commits can run concurrent.

Author:

Thomas Pantelis

Constructor Summary

Constructors

Constructor and Description
ConcurrentDOMDataBroker(Map<org.opendaylight.mdsal.common.api.LogicalDatastoreType,org.opendaylight.mdsal.dom.spi.store.DOMStore> datastores, Executor listenableFutureExecutor)
ConcurrentDOMDataBroker(Map<org.opendaylight.mdsal.common.api.LogicalDatastoreType,org.opendaylight.mdsal.dom.spi.store.DOMStore> datastores, Executor listenableFutureExecutor, org.opendaylight.yangtools.util.DurationStatisticsTracker commitStatsTracker)

Method Summary

Modifier and Type	Method and Description
protected com.google.common.util.concurrent.FluentFuture<? extends org.opendaylight.mdsal.common.api.CommitInfo>	commit(org.opendaylight.mdsal.dom.api.DOMDataTreeWriteTransaction transaction, Collection<org.opendaylight.mdsal.dom.spi.store.DOMStoreThreePhaseCommitCohort> cohorts) Submits a transaction asynchronously for commit.
org.opendaylight.yangtools.util.DurationStatisticsTracker	getCommitStatsTracker()
String	toString()

Methods inherited from class org.opendaylight.controller.cluster.databroker.AbstractDOMBroker

close, createTransactionChain, getExtensions, newTransactionIdentifier, setCloseable

Methods inherited from class org.opendaylight.controller.cluster.databroker.AbstractDOMTransactionFactory

checkNotClosed, getTxFactories, newReadOnlyTransaction, newReadWriteTransaction, newWriteOnlyTransaction

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.opendaylight.mdsal.dom.api.DOMDataBroker

newReadOnlyTransaction, newReadWriteTransaction, newWriteOnlyTransaction

Constructor Detail

ConcurrentDOMDataBroker

public ConcurrentDOMDataBroker(Map<org.opendaylight.mdsal.common.api.LogicalDatastoreType,org.opendaylight.mdsal.dom.spi.store.DOMStore> datastores,
                               Executor listenableFutureExecutor)

ConcurrentDOMDataBroker

public ConcurrentDOMDataBroker(Map<org.opendaylight.mdsal.common.api.LogicalDatastoreType,org.opendaylight.mdsal.dom.spi.store.DOMStore> datastores,
                               Executor listenableFutureExecutor,
                               org.opendaylight.yangtools.util.DurationStatisticsTracker commitStatsTracker)

Method Detail

getCommitStatsTracker

public org.opendaylight.yangtools.util.DurationStatisticsTracker getCommitStatsTracker()

commit

protected com.google.common.util.concurrent.FluentFuture<? extends org.opendaylight.mdsal.common.api.CommitInfo> commit(org.opendaylight.mdsal.dom.api.DOMDataTreeWriteTransaction transaction,
                                                                                                                        Collection<org.opendaylight.mdsal.dom.spi.store.DOMStoreThreePhaseCommitCohort> cohorts)

Description copied from class: AbstractDOMTransactionFactory

Submits a transaction asynchronously for commit.

Specified by:

commit in class AbstractDOMTransactionFactory<org.opendaylight.mdsal.dom.spi.store.DOMStore>

Parameters:

transaction - the transaction to submit

cohorts - the associated cohorts

Returns:

a resulting Future

toString

public String toString()

Overrides:

toString in class Object