org.opendaylight.genius.alivenessmonitor.internal

Class AlivenessMonitor

java.lang.Object

org.opendaylight.serviceutils.tools.listener.AbstractClusteredSyncDataTreeChangeListener<MonitoringState>

org.opendaylight.genius.alivenessmonitor.internal.AlivenessMonitor

All Implemented Interfaces:

AutoCloseable, EventListener, org.opendaylight.mdsal.binding.api.ClusteredDataTreeChangeListener<MonitoringState>, org.opendaylight.mdsal.binding.api.DataTreeChangeListener<MonitoringState>, org.opendaylight.serviceutils.tools.listener.ChainableDataTreeChangeListener<MonitoringState>, AlivenessMonitorService, org.opendaylight.yang.gen.v1.urn.opendaylight.packet.service.rev130709.PacketProcessingListener, org.opendaylight.yangtools.yang.binding.NotificationListener, org.opendaylight.yangtools.yang.binding.RpcService

@Singleton
public class AlivenessMonitor
extends org.opendaylight.serviceutils.tools.listener.AbstractClusteredSyncDataTreeChangeListener<MonitoringState>
implements AlivenessMonitorService, org.opendaylight.yang.gen.v1.urn.opendaylight.packet.service.rev130709.PacketProcessingListener

Constructor Summary

Constructors

Constructor and Description
AlivenessMonitor(org.opendaylight.mdsal.binding.api.DataBroker dataBroker, IdManagerService idManager, org.opendaylight.controller.md.sal.binding.api.NotificationPublishService notificationPublishService, AlivenessProtocolHandlerRegistry alivenessProtocolHandlerRegistry)

Method Summary

Modifier and Type	Method and Description
default void	add(org.opendaylight.yangtools.yang.binding.InstanceIdentifier<T> arg0, T arg1)
void	close()
protected org.opendaylight.mdsal.binding.api.DataBroker	getDataBroker()
protected org.opendaylight.serviceutils.tools.listener.DataStoreMetrics	getDataStoreMetrics()
com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<MonitorPauseOutput>>	monitorPause(MonitorPauseInput input)
com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<MonitorProfileCreateOutput>>	monitorProfileCreate(MonitorProfileCreateInput input)
com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<MonitorProfileDeleteOutput>>	monitorProfileDelete(MonitorProfileDeleteInput input)
com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<MonitorProfileGetOutput>>	monitorProfileGet(MonitorProfileGetInput input)
com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<MonitorStartOutput>>	monitorStart(MonitorStartInput input)
com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<MonitorStopOutput>>	monitorStop(MonitorStopInput input)
com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<MonitorUnpauseOutput>>	monitorUnpause(MonitorUnpauseInput input)
default void	onDataTreeChanged(Collection<org.opendaylight.mdsal.binding.api.DataTreeModification<T>> arg0, org.opendaylight.serviceutils.tools.listener.DataStoreMetrics arg1)
void	onInterfaceStateDown(String interfaceName)
void	onInterfaceStateUp(String interfaceName)
void	onPacketReceived(org.opendaylight.yang.gen.v1.urn.opendaylight.packet.service.rev130709.PacketReceived packetReceived)
void	remove(org.opendaylight.yangtools.yang.binding.InstanceIdentifier<MonitoringState> instanceIdentifier, MonitoringState removedDataObject)
void	update(org.opendaylight.yangtools.yang.binding.InstanceIdentifier<MonitoringState> instanceIdentifier, MonitoringState originalDataObject, MonitoringState updatedDataObject)

Methods inherited from class org.opendaylight.serviceutils.tools.listener.AbstractClusteredSyncDataTreeChangeListener

onDataTreeChanged

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.opendaylight.mdsal.binding.api.DataTreeChangeListener

onInitialData

Constructor Detail

AlivenessMonitor

@Inject
public AlivenessMonitor(org.opendaylight.mdsal.binding.api.DataBroker dataBroker,
                                IdManagerService idManager,
                                org.opendaylight.controller.md.sal.binding.api.NotificationPublishService notificationPublishService,
                                AlivenessProtocolHandlerRegistry alivenessProtocolHandlerRegistry)

Method Detail

close

@PreDestroy
public void close()

Specified by:

close in interface AutoCloseable

Overrides:

close in class org.opendaylight.serviceutils.tools.listener.AbstractClusteredSyncDataTreeChangeListener<MonitoringState>

onPacketReceived

public void onPacketReceived(org.opendaylight.yang.gen.v1.urn.opendaylight.packet.service.rev130709.PacketReceived packetReceived)

Specified by:

onPacketReceived in interface org.opendaylight.yang.gen.v1.urn.opendaylight.packet.service.rev130709.PacketProcessingListener

monitorStart

public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<MonitorStartOutput>> monitorStart(MonitorStartInput input)

Specified by:

monitorStart in interface AlivenessMonitorService

monitorPause

public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<MonitorPauseOutput>> monitorPause(MonitorPauseInput input)

Specified by:

monitorPause in interface AlivenessMonitorService

monitorUnpause

public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<MonitorUnpauseOutput>> monitorUnpause(MonitorUnpauseInput input)

Specified by:

monitorUnpause in interface AlivenessMonitorService

monitorProfileCreate

public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<MonitorProfileCreateOutput>> monitorProfileCreate(MonitorProfileCreateInput input)

Specified by:

monitorProfileCreate in interface AlivenessMonitorService

monitorProfileGet

public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<MonitorProfileGetOutput>> monitorProfileGet(MonitorProfileGetInput input)

Specified by:

monitorProfileGet in interface AlivenessMonitorService

monitorProfileDelete

public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<MonitorProfileDeleteOutput>> monitorProfileDelete(MonitorProfileDeleteInput input)

Specified by:

monitorProfileDelete in interface AlivenessMonitorService

monitorStop

public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<MonitorStopOutput>> monitorStop(MonitorStopInput input)

Specified by:

monitorStop in interface AlivenessMonitorService

onInterfaceStateUp

public void onInterfaceStateUp(String interfaceName)

onInterfaceStateDown

public void onInterfaceStateDown(String interfaceName)

remove

public void remove(@Nonnull
                   org.opendaylight.yangtools.yang.binding.InstanceIdentifier<MonitoringState> instanceIdentifier,
                   @Nonnull
                   MonitoringState removedDataObject)

update

public void update(@Nonnull
                   org.opendaylight.yangtools.yang.binding.InstanceIdentifier<MonitoringState> instanceIdentifier,
                   @Nonnull
                   MonitoringState originalDataObject,
                   @Nonnull
                   MonitoringState updatedDataObject)

getDataBroker

protected org.opendaylight.mdsal.binding.api.DataBroker getDataBroker()

getDataStoreMetrics

protected org.opendaylight.serviceutils.tools.listener.DataStoreMetrics getDataStoreMetrics()

onDataTreeChanged

public void onDataTreeChanged(@Nonnull
                              Collection<org.opendaylight.mdsal.binding.api.DataTreeModification<T>> arg0,
                              org.opendaylight.serviceutils.tools.listener.DataStoreMetrics arg1)

add

public void add(@Nonnull
                org.opendaylight.yangtools.yang.binding.InstanceIdentifier<T> arg0,
                @Nonnull
                T arg1)