org.opendaylight.mdsal.dom.broker

Class AbstractDOMDataBroker

java.lang.Object

org.opendaylight.mdsal.dom.broker.AbstractDOMDataBroker

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

Direct Known Subclasses:

SerializedDOMDataBroker

public abstract class AbstractDOMDataBroker
extends Object
implements DOMDataBroker, AutoCloseable

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractDOMDataBroker(Map<LogicalDatastoreType,DOMStore> datastores)

Method Summary

Modifier and Type	Method and Description
protected void	checkNotClosed() Checks if instance is not closed.
void	close()
DOMTransactionChain	createTransactionChain(TransactionChainListener listener) Create a new transaction chain.
Map<Class<? extends DOMDataBrokerExtension>,DOMDataBrokerExtension>	getSupportedExtensions() Return a map of currently-supported extensions, along with accessor services which provide access to the specific functionality bound to this service.
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.
protected Object	newTransactionIdentifier() Implementations must return unique identifier for each and every call of this method.
DOMDataTreeWriteTransaction	newWriteOnlyTransaction() Creates a new composite write-only transaction
void	setCloseable(AutoCloseable closeable)
protected abstract 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 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

AbstractDOMDataBroker

protected AbstractDOMDataBroker(Map<LogicalDatastoreType,DOMStore> datastores)

Method Detail

setCloseable

public void setCloseable(AutoCloseable closeable)

close

public void close()

Specified by:

close in interface AutoCloseable

newTransactionIdentifier

protected Object newTransactionIdentifier()

Implementations must return unique identifier for each and every call of this method.

Returns:

new Unique transaction identifier.

getSupportedExtensions

public Map<Class<? extends DOMDataBrokerExtension>,DOMDataBrokerExtension> getSupportedExtensions()

Description copied from interface: DOMExtensibleService

Return a map of currently-supported extensions, along with accessor services which provide access to the specific functionality bound to this service.

Specified by:

getSupportedExtensions in interface DOMExtensibleService<DOMDataBroker,DOMDataBrokerExtension>

Returns:

A map of supported functionality.

createTransactionChain

public DOMTransactionChain createTransactionChain(TransactionChainListener listener)

Description copied from interface: TransactionChainFactory

Create a new transaction chain. The chain will be initialized to read from its backing datastore, with no outstanding transaction. Listener will be registered to handle chain-level events.

Specified by:

createTransactionChain in interface TransactionChainFactory<org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier,org.opendaylight.yangtools.yang.data.api.schema.NormalizedNode<?,?>>

Specified by:

createTransactionChain in interface DOMDataBroker

Parameters:

listener - Transaction chain event listener

Returns:

A new transaction chain.

submit

protected abstract 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.