Class SimplifiedOperationalListener
- java.lang.Object
-
- org.opendaylight.openflowplugin.applications.frsync.impl.AbstractFrmSyncListener<org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.nodes.Node>
-
- org.opendaylight.openflowplugin.applications.frsync.impl.SimplifiedOperationalListener
-
- All Implemented Interfaces:
EventListener
,org.opendaylight.mdsal.binding.api.ClusteredDataTreeChangeListener<org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.nodes.Node>
,org.opendaylight.mdsal.binding.api.DataTreeChangeListener<org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.nodes.Node>
,NodeListener<org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.nodes.Node>
public class SimplifiedOperationalListener extends AbstractFrmSyncListener<org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.nodes.Node>
Listens to operational changes and starts reconciliation throughSyncReactor
when necessary.
-
-
Field Summary
Fields Modifier and Type Field Description static String
DATE_AND_TIME_FORMAT
-
Constructor Summary
Constructors Constructor Description SimplifiedOperationalListener(SyncReactor reactor, FlowCapableNodeSnapshotDao operationalSnapshot, FlowCapableNodeDao configDao, ReconciliationRegistry reconciliationRegistry, DeviceMastershipManager deviceMastershipManager)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description org.opendaylight.mdsal.common.api.LogicalDatastoreType
dsType()
void
onDataTreeChanged(@NonNull Collection<org.opendaylight.mdsal.binding.api.DataTreeModification<org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.nodes.Node>> modifications)
protected Optional<com.google.common.util.concurrent.ListenableFuture<Boolean>>
processNodeModification(org.opendaylight.mdsal.binding.api.DataTreeModification<org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.nodes.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.
-
-
-
Field Detail
-
DATE_AND_TIME_FORMAT
public static final String DATE_AND_TIME_FORMAT
- See Also:
- Constant Field Values
-
-
Constructor Detail
-
SimplifiedOperationalListener
public SimplifiedOperationalListener(SyncReactor reactor, FlowCapableNodeSnapshotDao operationalSnapshot, FlowCapableNodeDao configDao, ReconciliationRegistry reconciliationRegistry, DeviceMastershipManager deviceMastershipManager)
-
-
Method Detail
-
onDataTreeChanged
public void onDataTreeChanged(@NonNull Collection<org.opendaylight.mdsal.binding.api.DataTreeModification<org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.nodes.Node>> modifications)
- Specified by:
onDataTreeChanged
in interfaceorg.opendaylight.mdsal.binding.api.DataTreeChangeListener<org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.nodes.Node>
- Overrides:
onDataTreeChanged
in classAbstractFrmSyncListener<org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.nodes.Node>
-
processNodeModification
protected Optional<com.google.common.util.concurrent.ListenableFuture<Boolean>> processNodeModification(org.opendaylight.mdsal.binding.api.DataTreeModification<org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.nodes.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<org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.nodes.Node>
-
dsType
public org.opendaylight.mdsal.common.api.LogicalDatastoreType dsType()
- Specified by:
dsType
in classAbstractFrmSyncListener<org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.nodes.Node>
-
-