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

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

model - model (NT, I2RS...)

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 - when interrupted, what a surprise