org.opendaylight.mdsal.dom.broker

Class SerializedDOMDataBroker

java.lang.Object

org.opendaylight.mdsal.dom.broker.AbstractDOMDataBroker

org.opendaylight.mdsal.dom.broker.SerializedDOMDataBroker

All Implemented Interfaces:

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

public class SerializedDOMDataBroker
extends AbstractDOMDataBroker

Implementation of blocking three phase commit coordinator, which which supports coordination on multiple DOMStoreThreePhaseCommitCohort.

This implementation does not support cancellation of commit,

In order to advance to next phase of three phase commit all subtasks of previous step must be finish.

This executor does not have an upper bound on subtask timeout.

Constructor Summary

Constructors

Constructor and Description
SerializedDOMDataBroker(Map<LogicalDatastoreType,DOMStore> datastores, com.google.common.util.concurrent.ListeningExecutorService executor) Construct DOMDataCommitCoordinator which uses supplied executor to process commit coordinations.

Method Summary

Modifier and Type	Method and Description
protected void	checkNotClosed() Checks if instance is not closed.
org.opendaylight.yangtools.util.DurationStatisticsTracker	getCommitStatsTracker()
protected Map<LogicalDatastoreType,T>	getTxFactories() Convenience accessor of backing factories intended to be used only by finalization of this class.
DOMDataTreeReadTransaction	newReadOnlyTransaction() Creates a new composite read-only transaction.
DOMDataTreeWriteTransaction	newWriteOnlyTransaction() Creates a new composite write-only transaction
protected com.google.common.util.concurrent.CheckedFuture<Void,TransactionCommitFailedException>	submit(DOMDataTreeWriteTransaction transaction, Collection<DOMStoreThreePhaseCommitCohort> cohorts) User-supplied implementation of AsyncWriteTransaction.submit() for transaction.

Methods inherited from class org.opendaylight.mdsal.dom.broker.AbstractDOMDataBroker

close, createTransactionChain, getSupportedExtensions, newTransactionIdentifier, setCloseable

Methods inherited from class java.lang.Object

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

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

newReadOnlyTransaction, newWriteOnlyTransaction

Constructor Detail

SerializedDOMDataBroker

public SerializedDOMDataBroker(Map<LogicalDatastoreType,DOMStore> datastores,
                               com.google.common.util.concurrent.ListeningExecutorService executor)

Construct DOMDataCommitCoordinator which uses supplied executor to process commit coordinations.

Parameters:

datastores - the Map of backing DOMStore instances

executor - the ListeningExecutorService to use

Method Detail

getCommitStatsTracker

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

submit

protected com.google.common.util.concurrent.CheckedFuture<Void,TransactionCommitFailedException> submit(DOMDataTreeWriteTransaction transaction,
                                                                                                        Collection<DOMStoreThreePhaseCommitCohort> cohorts)

User-supplied implementation of AsyncWriteTransaction.submit() for transaction.

Callback invoked when AsyncWriteTransaction.submit() is invoked on transaction created by this factory.

Parameters:

transaction - Transaction on which AsyncWriteTransaction.submit() was invoked.

cohorts - Iteratable of cohorts for subtransactions associated with the transaction being committed.

Returns:

a CheckedFuture. if commit coordination on cohorts finished successfully, nothing is returned from the Future, On failure, the Future fails with a TransactionCommitFailedException.

newReadOnlyTransaction

public final DOMDataTreeReadTransaction newReadOnlyTransaction()

Creates a new composite read-only transaction.

Creates a new composite read-only transaction backed by one transaction per factory in getTxFactories().

Subtransaction for reading is selected by supplied LogicalDatastoreType as parameter for DOMDataTreeReadTransaction.read(LogicalDatastoreType, org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier)

Id of returned transaction is retrieved via newTransactionIdentifier().

Returns:

New composite read-only transaction.

newWriteOnlyTransaction

public final DOMDataTreeWriteTransaction newWriteOnlyTransaction()

Creates a new composite write-only transaction

Creates a new composite write-only transaction backed by one write-only transaction per factory in getTxFactories().

Implementation of composite Write-only transaction is following:

• DOMDataTreeWriteTransaction.put(LogicalDatastoreType, org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier, org.opendaylight.yangtools.yang.data.api.schema.NormalizedNode) - backing subtransaction is selected by LogicalDatastoreType, DOMStoreWriteTransaction.write(org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier, org.opendaylight.yangtools.yang.data.api.schema.NormalizedNode) is invoked on selected subtransaction.
• DOMDataTreeWriteTransaction.merge(LogicalDatastoreType, org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier, org.opendaylight.yangtools.yang.data.api.schema.NormalizedNode) - backing subtransaction is selected by LogicalDatastoreType, DOMStoreWriteTransaction.merge(org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier, org.opendaylight.yangtools.yang.data.api.schema.NormalizedNode) is invoked on selected subtransaction.
• DOMDataTreeWriteTransaction.delete(LogicalDatastoreType, org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier) - backing subtransaction is selected by LogicalDatastoreType, DOMStoreWriteTransaction.delete(org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier) is invoked on selected subtransaction.
• AsyncWriteTransaction.submit() - results in invoking DOMStoreWriteTransaction.ready(), gathering all resulting cohorts and then invoking finalized implementation callback submit(DOMDataTreeWriteTransaction, Collection) with transaction which was commited and gathered results.

Id of returned transaction is generated via newTransactionIdentifier().

Returns:

New composite write-only transaction associated with this factory.

getTxFactories

protected final Map<LogicalDatastoreType,T> getTxFactories()

Convenience accessor of backing factories intended to be used only by finalization of this class. Note: Finalization of this class may want to access other functionality of supplied Transaction factories.

Returns:

Map of backing transaction factories.

checkNotClosed

protected final void checkNotClosed()

Checks if instance is not closed.

Throws:

IllegalStateException - If instance of this class was closed.