org.opendaylight.topoprocessing.impl.writer

Class TopologyWriter

java.lang.Object

org.opendaylight.topoprocessing.impl.writer.TopologyWriter

All Implemented Interfaces:

EventListener, org.opendaylight.controller.md.sal.common.api.data.TransactionChainListener

public class TopologyWriter
extends Object
implements org.opendaylight.controller.md.sal.common.api.data.TransactionChainListener

Author:

michal.polkorab

Field Summary

Fields

Modifier and Type	Field and Description
protected static org.slf4j.Logger	LOGGER

Constructor Summary

Constructors

Constructor and Description
TopologyWriter(String topologyId, Class<? extends Model> model) Default constructor

Method Summary

Methods

Modifier and Type	Method and Description
void	deleteItem(OverlayItemWrapper wrapper, CorrelationItemEnum itemType)
void	initOverlayTopology() Writes empty overlay topology with provided topologyId.
void	onTransactionChainFailed(org.opendaylight.controller.md.sal.common.api.data.TransactionChain<?,?> chain, org.opendaylight.controller.md.sal.common.api.data.AsyncTransaction<?,?> transaction, Throwable cause)
void	onTransactionChainSuccessful(org.opendaylight.controller.md.sal.common.api.data.TransactionChain<?,?> chain)
void	setTransactionChain(org.opendaylight.controller.md.sal.dom.api.DOMTransactionChain transactionChain)
void	setTranslator(OverlayItemTranslator translator)
void	tearDown() Signals that allocated resources should be released
void	waitForTearDownCompletion(int timeOut) Wait until all threads/writes are finished
void	writeItem(OverlayItemWrapper wrapper, CorrelationItemEnum itemType)
void	writeTopologyTypes(org.opendaylight.yangtools.yang.data.api.schema.DataContainerChild<? extends org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier.PathArgument,?> topologyTypes) Writes topology-types

Methods inherited from class java.lang.Object

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

Field Detail

LOGGER

protected static final org.slf4j.Logger LOGGER

Constructor Detail

TopologyWriter

public TopologyWriter(String topologyId,
              Class<? extends Model> model)

Default constructor

Parameters:

topologyId - topologyId of overlay topology

Method Detail

initOverlayTopology

public void initOverlayTopology()

Writes empty overlay topology with provided topologyId. Also writes empty Link and Node mapnode.

writeItem

public void writeItem(OverlayItemWrapper wrapper,
             CorrelationItemEnum itemType)

Parameters:

wrapper - LogicalNodeWrapper to be written into datastore

itemType - item type

deleteItem

public void deleteItem(OverlayItemWrapper wrapper,
              CorrelationItemEnum itemType)

Parameters:

wrapper - LogicalNodeWrapper to be removed from datastore

itemType - item type

onTransactionChainFailed

public void onTransactionChainFailed(org.opendaylight.controller.md.sal.common.api.data.TransactionChain<?,?> chain,
                            org.opendaylight.controller.md.sal.common.api.data.AsyncTransaction<?,?> transaction,
                            Throwable cause)

Specified by:

onTransactionChainFailed in interface org.opendaylight.controller.md.sal.common.api.data.TransactionChainListener

onTransactionChainSuccessful

public void onTransactionChainSuccessful(org.opendaylight.controller.md.sal.common.api.data.TransactionChain<?,?> chain)

Specified by:

onTransactionChainSuccessful in interface org.opendaylight.controller.md.sal.common.api.data.TransactionChainListener

setTransactionChain

public void setTransactionChain(org.opendaylight.controller.md.sal.dom.api.DOMTransactionChain transactionChain)

Parameters:

transactionChain - Sets TransactionChain

setTranslator

public void setTranslator(OverlayItemTranslator translator)

writeTopologyTypes

public void writeTopologyTypes(org.opendaylight.yangtools.yang.data.api.schema.DataContainerChild<? extends org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier.PathArgument,?> topologyTypes)

Writes topology-types

Parameters:

topologyTypes - - taken from overlay topology request

tearDown

public void tearDown()

Signals that allocated resources should be released

waitForTearDownCompletion

public void waitForTearDownCompletion(int timeOut)
                               throws InterruptedException

Wait until all threads/writes are finished

Parameters:

timeOut - timeout to wait for threads/writes to finish in ms

Throws:

InterruptedException