org.onosproject.net.pi.impl

Class PiPipeconfManager

java.lang.Object

org.onosproject.net.pi.impl.PiPipeconfManager

All Implemented Interfaces:

org.onosproject.net.pi.runtime.PiPipeconfService

@Service
 @Beta
public class PiPipeconfManager
extends Object
implements org.onosproject.net.pi.runtime.PiPipeconfService

Implementation of the PiPipeconfService.

Field Summary

Fields

Modifier and Type	Field and Description
protected org.onosproject.net.config.NetworkConfigListener	cfgListener
protected org.onosproject.net.config.NetworkConfigRegistry	cfgService
protected ConcurrentHashMap<org.onosproject.net.DeviceId,org.onosproject.net.pi.model.PiPipeconfId>	devicesToPipeconf
protected org.onosproject.net.driver.DriverAdminService	driverAdminService
protected org.onosproject.net.driver.DriverService	driverService
protected ExecutorService	executor
protected org.onosproject.net.config.ConfigFactory	factory
protected ConcurrentHashMap<org.onosproject.net.pi.model.PiPipeconfId,org.onosproject.net.pi.model.PiPipeconf>	piPipeconfs

Constructor Summary

Constructors

Constructor and Description
PiPipeconfManager()

Method Summary

Modifier and Type	Method and Description
void	activate()
CompletableFuture<Boolean>	bindToDevice(org.onosproject.net.pi.model.PiPipeconfId pipeconfId, org.onosproject.net.DeviceId deviceId)
void	deactivate()
Optional<org.onosproject.net.pi.model.PiPipeconf>	getPipeconf(org.onosproject.net.pi.model.PiPipeconfId id)
Iterable<org.onosproject.net.pi.model.PiPipeconf>	getPipeconfs()
Optional<org.onosproject.net.pi.model.PiPipeconfId>	ofDevice(org.onosproject.net.DeviceId deviceId)
void	register(org.onosproject.net.pi.model.PiPipeconf pipeconf)
void	remove(org.onosproject.net.pi.model.PiPipeconfId pipeconfId)

Methods inherited from class java.lang.Object

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

Field Detail

cfgService

@Reference(cardinality=MANDATORY_UNARY)
protected org.onosproject.net.config.NetworkConfigRegistry cfgService

driverService

@Reference(cardinality=MANDATORY_UNARY)
protected org.onosproject.net.driver.DriverService driverService

driverAdminService

@Reference(cardinality=MANDATORY_UNARY)
protected org.onosproject.net.driver.DriverAdminService driverAdminService

piPipeconfs

protected ConcurrentHashMap<org.onosproject.net.pi.model.PiPipeconfId,org.onosproject.net.pi.model.PiPipeconf> piPipeconfs

devicesToPipeconf

protected ConcurrentHashMap<org.onosproject.net.DeviceId,org.onosproject.net.pi.model.PiPipeconfId> devicesToPipeconf

executor

protected ExecutorService executor

factory

protected final org.onosproject.net.config.ConfigFactory factory

cfgListener

protected final org.onosproject.net.config.NetworkConfigListener cfgListener

Constructor Detail

PiPipeconfManager

public PiPipeconfManager()

Method Detail

activate

@Activate
public void activate()

deactivate

@Deactivate
public void deactivate()

register

public void register(org.onosproject.net.pi.model.PiPipeconf pipeconf)
              throws IllegalStateException

Specified by:

register in interface org.onosproject.net.pi.runtime.PiPipeconfService

Throws:

IllegalStateException

remove

public void remove(org.onosproject.net.pi.model.PiPipeconfId pipeconfId)
            throws IllegalStateException

Specified by:

remove in interface org.onosproject.net.pi.runtime.PiPipeconfService

Throws:

IllegalStateException

getPipeconfs

public Iterable<org.onosproject.net.pi.model.PiPipeconf> getPipeconfs()

Specified by:

getPipeconfs in interface org.onosproject.net.pi.runtime.PiPipeconfService

getPipeconf

public Optional<org.onosproject.net.pi.model.PiPipeconf> getPipeconf(org.onosproject.net.pi.model.PiPipeconfId id)

Specified by:

getPipeconf in interface org.onosproject.net.pi.runtime.PiPipeconfService

bindToDevice

public CompletableFuture<Boolean> bindToDevice(org.onosproject.net.pi.model.PiPipeconfId pipeconfId,
                                               org.onosproject.net.DeviceId deviceId)

Specified by:

bindToDevice in interface org.onosproject.net.pi.runtime.PiPipeconfService

ofDevice

public Optional<org.onosproject.net.pi.model.PiPipeconfId> ofDevice(org.onosproject.net.DeviceId deviceId)

Specified by:

ofDevice in interface org.onosproject.net.pi.runtime.PiPipeconfService