Class DeviceFlowRegistryImpl
- java.lang.Object
-
- org.opendaylight.openflowplugin.impl.registry.flow.DeviceFlowRegistryImpl
-
- All Implemented Interfaces:
AutoCloseable
,CommonDeviceRegistry<FlowRegistryKey>
,DeviceFlowRegistry
public class DeviceFlowRegistryImpl extends Object implements DeviceFlowRegistry
-
-
Constructor Summary
Constructors Constructor Description DeviceFlowRegistryImpl(short version, org.opendaylight.mdsal.binding.api.DataBroker dataBroker, org.opendaylight.yangtools.yang.binding.KeyedInstanceIdentifier<org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.nodes.Node,org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.nodes.NodeKey> instanceIdentifier, FlowGroupInfoHistoryAppender history)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
addMark(FlowRegistryKey flowRegistryKey)
Add mark for specified KEY.void
appendHistoryFlow(FlowId id, org.opendaylight.yangtools.yang.common.Uint8 tableId, FlowGroupStatus status)
void
clearFlowRegistry()
void
close()
com.google.common.util.concurrent.ListenableFuture<List<Optional<FlowCapableNode>>>
fill()
void
forEach(Consumer<FlowRegistryKey> consumer)
Iterate over all keys in device registry.void
processMarks()
Process marked keys.FlowDescriptor
retrieveDescriptor(@NonNull FlowRegistryKey flowRegistryKey)
int
size()
Get device registry size.void
store(FlowRegistryKey flowRegistryKey)
Store KEY in device registry.void
storeDescriptor(@NonNull FlowRegistryKey flowRegistryKey, @NonNull FlowDescriptor flowDescriptor)
-
-
-
Constructor Detail
-
DeviceFlowRegistryImpl
public DeviceFlowRegistryImpl(short version, org.opendaylight.mdsal.binding.api.DataBroker dataBroker, org.opendaylight.yangtools.yang.binding.KeyedInstanceIdentifier<org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.nodes.Node,org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.nodes.NodeKey> instanceIdentifier, FlowGroupInfoHistoryAppender history)
-
-
Method Detail
-
fill
public com.google.common.util.concurrent.ListenableFuture<List<Optional<FlowCapableNode>>> fill()
- Specified by:
fill
in interfaceDeviceFlowRegistry
-
retrieveDescriptor
public FlowDescriptor retrieveDescriptor(@NonNull FlowRegistryKey flowRegistryKey)
- Specified by:
retrieveDescriptor
in interfaceDeviceFlowRegistry
-
storeDescriptor
public void storeDescriptor(@NonNull FlowRegistryKey flowRegistryKey, @NonNull FlowDescriptor flowDescriptor)
- Specified by:
storeDescriptor
in interfaceDeviceFlowRegistry
-
store
public void store(FlowRegistryKey flowRegistryKey)
Description copied from interface:CommonDeviceRegistry
Store KEY in device registry.- Specified by:
store
in interfaceCommonDeviceRegistry<FlowRegistryKey>
- Parameters:
flowRegistryKey
- device registry key
-
addMark
public void addMark(FlowRegistryKey flowRegistryKey)
Description copied from interface:CommonDeviceRegistry
Add mark for specified KEY.- Specified by:
addMark
in interfaceCommonDeviceRegistry<FlowRegistryKey>
- Parameters:
flowRegistryKey
- device registry key
-
processMarks
public void processMarks()
Description copied from interface:CommonDeviceRegistry
Process marked keys.- Specified by:
processMarks
in interfaceCommonDeviceRegistry<FlowRegistryKey>
-
forEach
public void forEach(Consumer<FlowRegistryKey> consumer)
Description copied from interface:CommonDeviceRegistry
Iterate over all keys in device registry.- Specified by:
forEach
in interfaceCommonDeviceRegistry<FlowRegistryKey>
- Parameters:
consumer
- key consumer
-
size
public int size()
Description copied from interface:CommonDeviceRegistry
Get device registry size.- Specified by:
size
in interfaceCommonDeviceRegistry<FlowRegistryKey>
- Returns:
- device registry size
-
appendHistoryFlow
public void appendHistoryFlow(FlowId id, org.opendaylight.yangtools.yang.common.Uint8 tableId, FlowGroupStatus status)
- Specified by:
appendHistoryFlow
in interfaceDeviceFlowRegistry
-
clearFlowRegistry
public void clearFlowRegistry()
- Specified by:
clearFlowRegistry
in interfaceDeviceFlowRegistry
-
close
public void close()
- Specified by:
close
in interfaceAutoCloseable
- Specified by:
close
in interfaceCommonDeviceRegistry<FlowRegistryKey>
-
-