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 dataBroker, GlobalSchemaContextHolder schemaHolder, RpcServices rpcServices, Map.Entry<org.opendaylight.yangtools.yang.binding.InstanceIdentifier<?>,org.opendaylight.yangtools.yang.binding.DataObject> fromNormalizedNode) Default constructor

Method Summary

Methods

Modifier and Type	Method and Description
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(DatastoreType 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 dataBroker,
                      GlobalSchemaContextHolder schemaHolder,
                      RpcServices rpcServices,
                      Map.Entry<org.opendaylight.yangtools.yang.binding.InstanceIdentifier<?>,org.opendaylight.yangtools.yang.binding.DataObject> fromNormalizedNode)

Default constructor

Parameters:

dataBroker - 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

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(DatastoreType 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