org.opendaylight.topoprocessing.impl.request

Class TopologyRequestHandler

java.lang.Object

org.opendaylight.topoprocessing.impl.request.TopologyRequestHandler

Direct Known Subclasses:

I2RSTopologyRequestHandler, InvTopologyRequestHandler, IRTopologyRequestHandler, NTTopologyRequestHandler

public abstract class TopologyRequestHandler
extends Object

Picks up information from topology request, engages corresponding listeners, aggregators.

Author:

michal.polkorab

Constructor Summary

Constructors

Constructor and Description

TopologyRequestHandler(org.opendaylight.controller.md.sal.dom.api.DOMDataBroker domDataBroker, org.opendaylight.controller.md.sal.dom.api.DOMDataTreeChangeService domDataTreeChangeService, GlobalSchemaContextHolder schemaHolder, RpcServices rpcServices, Map.Entry<org.opendaylight.yangtools.yang.binding.InstanceIdentifier<?>,org.opendaylight.yangtools.yang.binding.DataObject> fromNormalizedNode) Default constructor.

Method Summary

Modifier and Type	Method and Description
void	close()
void	delegateTopologyTypes(org.opendaylight.yangtools.yang.data.api.schema.DataContainerChild<? extends org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier.PathArgument,?> topologyTypes) Delegate topology types to writer.
protected abstract Correlations	getCorrelations(Map.Entry<org.opendaylight.yangtools.yang.binding.InstanceIdentifier<?>,org.opendaylight.yangtools.yang.binding.DataObject> fromNormalizedNode)
protected abstract LinkComputation	getLinkComputation(Map.Entry<org.opendaylight.yangtools.yang.binding.InstanceIdentifier<?>,org.opendaylight.yangtools.yang.binding.DataObject> fromNormalizedNode)
List<org.opendaylight.yangtools.concepts.ListenerRegistration<org.opendaylight.controller.md.sal.dom.api.DOMDataTreeChangeListener>>	getListeners() Only for testing purposes.
protected abstract Class<? extends Model>	getModel(Map.Entry<org.opendaylight.yangtools.yang.binding.InstanceIdentifier<?>,org.opendaylight.yangtools.yang.binding.DataObject> fromNormalizedNode)
String	getTopologyId()
protected abstract String	getTopologyId(Map.Entry<org.opendaylight.yangtools.yang.binding.InstanceIdentifier<?>,org.opendaylight.yangtools.yang.binding.DataObject> fromNormalizedNode)
org.opendaylight.controller.md.sal.dom.api.DOMTransactionChain	getTransactionChain() Only for testing purposes.
void	processDeletionRequest(int timeOut) Closes all registered listeners and providers.
void	processNewRequest() Process new topology request.
void	setDatastoreType(org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType datastoreType)
void	setFiltrators(Map<Class<? extends FilterBase>,FiltratorFactory> filtrators)
void	setListeners(List<org.opendaylight.yangtools.concepts.ListenerRegistration<org.opendaylight.controller.md.sal.dom.api.DOMDataTreeChangeListener>> listeners) Only for testing purposes.
void	setModelAdapters(Map<Class<? extends Model>,ModelAdapter> modelAdapters)
void	setTranslator(PathTranslator translator) Only for testing purposes.

Methods inherited from class java.lang.Object

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

Constructor Detail

TopologyRequestHandler

public TopologyRequestHandler(org.opendaylight.controller.md.sal.dom.api.DOMDataBroker domDataBroker,
                              org.opendaylight.controller.md.sal.dom.api.DOMDataTreeChangeService domDataTreeChangeService,
                              GlobalSchemaContextHolder schemaHolder,
                              RpcServices rpcServices,
                              Map.Entry<org.opendaylight.yangtools.yang.binding.InstanceIdentifier<?>,org.opendaylight.yangtools.yang.binding.DataObject> fromNormalizedNode)

Default constructor.

Parameters:

domDataBroker - broker used for transaction operations

schemaHolder - provides model search

rpcServices - rpc services needed for rpc republishing

fromNormalizedNode - Normalized node with topology information

Method Detail

getModel

protected abstract Class<? extends Model> getModel(Map.Entry<org.opendaylight.yangtools.yang.binding.InstanceIdentifier<?>,org.opendaylight.yangtools.yang.binding.DataObject> fromNormalizedNode)

setTranslator

public void setTranslator(PathTranslator translator)

Only for testing purposes.

Parameters:

translator - Provides translating String to Path

setListeners

public void setListeners(List<org.opendaylight.yangtools.concepts.ListenerRegistration<org.opendaylight.controller.md.sal.dom.api.DOMDataTreeChangeListener>> listeners)

Only for testing purposes.

Parameters:

listeners - Sets UnderlayTopologyListener registrations

getListeners

public List<org.opendaylight.yangtools.concepts.ListenerRegistration<org.opendaylight.controller.md.sal.dom.api.DOMDataTreeChangeListener>> getListeners()

Only for testing purposes.

Returns:

UnderlayTopologyListener registrations

getTransactionChain

public org.opendaylight.controller.md.sal.dom.api.DOMTransactionChain getTransactionChain()

Only for testing purposes.

Returns:

Transaction Chain

setModelAdapters

public void setModelAdapters(Map<Class<? extends Model>,ModelAdapter> modelAdapters)

getTopologyId

protected abstract String getTopologyId(Map.Entry<org.opendaylight.yangtools.yang.binding.InstanceIdentifier<?>,org.opendaylight.yangtools.yang.binding.DataObject> fromNormalizedNode)

processNewRequest

public void processNewRequest()

Process new topology request.

getTopologyId

public String getTopologyId()

Returns:

ID of topology that is handled by this TopologyRequestHandler

getCorrelations

protected abstract Correlations getCorrelations(Map.Entry<org.opendaylight.yangtools.yang.binding.InstanceIdentifier<?>,org.opendaylight.yangtools.yang.binding.DataObject> fromNormalizedNode)

getLinkComputation

protected abstract LinkComputation getLinkComputation(Map.Entry<org.opendaylight.yangtools.yang.binding.InstanceIdentifier<?>,org.opendaylight.yangtools.yang.binding.DataObject> fromNormalizedNode)

processDeletionRequest

public void processDeletionRequest(int timeOut)

Closes all registered listeners and providers.

Parameters:

timeOut - time in ms to wait for close operation to finish, if timeOut == 0, there is no waiting

close

public void close()

delegateTopologyTypes

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

Delegate topology types to writer.

Parameters:

topologyTypes - - taken from overlay topology request

setDatastoreType

public void setDatastoreType(org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType datastoreType)

Parameters:

datastoreType - configures whether to use CONFIGURATION or OPERATIONAL datastore

setFiltrators

public void setFiltrators(Map<Class<? extends FilterBase>,FiltratorFactory> filtrators)

Parameters:

filtrators - sets default and registered filtrators