Package org.opendaylight.openflowplugin.impl.statistics.services.compatibility

Class AbstractCompatibleStatService<I extends org.opendaylight.yangtools.yang.binding.DataContainer,O,N extends org.opendaylight.yangtools.yang.binding.Notification>

java.lang.Object

org.opendaylight.openflowplugin.impl.services.AbstractService<I,List<T>>

org.opendaylight.openflowplugin.impl.services.AbstractMultipartService<I,MultipartReply>

org.opendaylight.openflowplugin.impl.statistics.services.compatibility.AbstractCompatibleStatService<I,O,N>

All Implemented Interfaces:

BackwardCompatibleAtomicService<I,O>

Direct Known Subclasses:

AggregateFlowsInTableService, AllFlowsInAllTablesService, AllFlowsInTableService, FlowsInTableService, OpendaylightFlowTableStatisticsServiceImpl

public abstract class AbstractCompatibleStatService<I extends org.opendaylight.yangtools.yang.binding.DataContainer,O,N extends org.opendaylight.yangtools.yang.binding.Notification>
extends AbstractMultipartService<I,MultipartReply>
implements BackwardCompatibleAtomicService<I,O>

Pulled up common functionality of notification emitting stats services (backward compatibility relic).

Constructor Summary

Constructors

Constructor	Description
AbstractCompatibleStatService(RequestContextStack requestContextStack, DeviceContext deviceContext, AtomicLong compatibilityXidSeed)

Method Summary

Modifier and Type	Method	Description
abstract O	buildTxCapableResult(TransactionId emulatedTxId)
OpenflowVersion	getOfVersion()
com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<O>>	handleAndNotify(I input, org.opendaylight.mdsal.binding.api.NotificationPublishService notificationPublishService)	process rpc request and publish corresponding notification upon success.
abstract N	transformToNotification(List<MultipartReply> result, TransactionId emulatedTxId)

Methods inherited from class org.opendaylight.openflowplugin.impl.services.AbstractMultipartService

createCallback, handleServiceCall

Methods inherited from class org.opendaylight.openflowplugin.impl.services.AbstractService

buildRequest, canUseSingleLayerSerialization, getDatapathId, getDeviceContext, getDeviceInfo, getDeviceRegistry, getEventIdentifier, getMessageSpy, getRequestContextStack, getTxFacade, getVersion, handleServiceCall, setEventIdentifier

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractCompatibleStatService

public AbstractCompatibleStatService(RequestContextStack requestContextStack,
                                     DeviceContext deviceContext,
                                     AtomicLong compatibilityXidSeed)

Method Detail

getOfVersion

public OpenflowVersion getOfVersion()

handleAndNotify

public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<O>> handleAndNotify(I input,
                                                                                                                               org.opendaylight.mdsal.binding.api.NotificationPublishService notificationPublishService)

Description copied from interface: BackwardCompatibleAtomicService

process rpc request and publish corresponding notification upon success.

Specified by:

handleAndNotify in interface BackwardCompatibleAtomicService<I extends org.opendaylight.yangtools.yang.binding.DataContainer,O>

Parameters:

input - rpc input

notificationPublishService - publisher handle

buildTxCapableResult

public abstract O buildTxCapableResult(TransactionId emulatedTxId)

transformToNotification

public abstract N transformToNotification(List<MultipartReply> result,
                                          TransactionId emulatedTxId)