Class SimplifiedOperationalListener
java.lang.Object
org.opendaylight.openflowplugin.applications.frsync.impl.AbstractFrmSyncListener<Node>
org.opendaylight.openflowplugin.applications.frsync.impl.SimplifiedOperationalListener
- All Implemented Interfaces:
EventListener
,org.opendaylight.mdsal.binding.api.ClusteredDataTreeChangeListener<Node>
,org.opendaylight.mdsal.binding.api.DataTreeChangeListener<Node>
,NodeListener<Node>
Listens to operational changes and starts reconciliation through
SyncReactor
when necessary.-
Field Summary
-
Constructor Summary
ConstructorDescriptionSimplifiedOperationalListener
(SyncReactor reactor, FlowCapableNodeSnapshotDao operationalSnapshot, FlowCapableNodeDao configDao, ReconciliationRegistry reconciliationRegistry, DeviceMastershipManager deviceMastershipManager) -
Method Summary
Modifier and TypeMethodDescriptionorg.opendaylight.mdsal.common.api.LogicalDatastoreType
dsType()
void
onDataTreeChanged
(@NonNull Collection<org.opendaylight.mdsal.binding.api.DataTreeModification<Node>> modifications) processNodeModification
(org.opendaylight.mdsal.binding.api.DataTreeModification<Node> modification) Update cache, register for device mastership when device connected and start reconciliation if device is registered and actual modification is consistent.Skip the event otherwise.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
-
Field Details
-
DATE_AND_TIME_FORMAT
- See Also:
-
-
Constructor Details
-
SimplifiedOperationalListener
public SimplifiedOperationalListener(SyncReactor reactor, FlowCapableNodeSnapshotDao operationalSnapshot, FlowCapableNodeDao configDao, ReconciliationRegistry reconciliationRegistry, DeviceMastershipManager deviceMastershipManager)
-
-
Method Details
-
onDataTreeChanged
public void onDataTreeChanged(@NonNull Collection<org.opendaylight.mdsal.binding.api.DataTreeModification<Node>> modifications) - Specified by:
onDataTreeChanged
in interfaceorg.opendaylight.mdsal.binding.api.DataTreeChangeListener<Node>
- Overrides:
onDataTreeChanged
in classAbstractFrmSyncListener<Node>
-
processNodeModification
protected Optional<com.google.common.util.concurrent.ListenableFuture<Boolean>> processNodeModification(org.opendaylight.mdsal.binding.api.DataTreeModification<Node> modification) Update cache, register for device mastership when device connected and start reconciliation if device is registered and actual modification is consistent.Skip the event otherwise.- Specified by:
processNodeModification
in classAbstractFrmSyncListener<Node>
-
dsType
public org.opendaylight.mdsal.common.api.LogicalDatastoreType dsType()- Specified by:
dsType
in classAbstractFrmSyncListener<Node>
-