@Service public class OvsdbControllerImpl extends java.lang.Object implements OvsdbController
| Modifier and Type | Field and Description |
|---|---|
protected OvsdbAgent |
agent |
static org.slf4j.Logger |
log |
protected java.util.concurrent.ConcurrentHashMap<OvsdbNodeId,OvsdbClientService> |
ovsdbClients |
protected java.util.Set<OvsdbEventListener> |
ovsdbEventListener |
protected java.util.Set<OvsdbNodeListener> |
ovsdbNodeListener |
protected java.util.concurrent.ConcurrentHashMap<java.lang.String,java.lang.String> |
requestDbName |
protected java.util.concurrent.ConcurrentHashMap<java.lang.String,OvsdbClientService> |
requestNotification |
protected org.onosproject.ovsdb.controller.impl.OvsdbControllerImpl.InternalMonitorCallBack |
updateCallback |
| Constructor and Description |
|---|
OvsdbControllerImpl() |
| Modifier and Type | Method and Description |
|---|---|
void |
activate(org.osgi.service.component.ComponentContext context) |
void |
addNodeListener(OvsdbNodeListener listener)
Adds Node Event Listener.
|
void |
addOvsdbEventListener(OvsdbEventListener listener)
Adds ovsdb event listener.
|
void |
connect(org.onlab.packet.IpAddress ip,
org.onlab.packet.TpPort port)
Connect to the ovsdb server with given ip address and port number.
|
void |
connect(org.onlab.packet.IpAddress ip,
org.onlab.packet.TpPort port,
java.util.function.Consumer<java.lang.Exception> failhandler)
Connect to the ovsdb server with given ip address, port number, and connection failure handler.
|
void |
deactivate() |
java.util.List<OvsdbNodeId> |
getNodeIds()
Gets all the nodes information.
|
OvsdbClientService |
getOvsdbClient(OvsdbNodeId nodeId)
Gets an ovsdb client by node identifier.
|
void |
removeNodeListener(OvsdbNodeListener listener)
Removes Node Event Listener.
|
void |
removeOvsdbEventListener(OvsdbEventListener listener)
Removes ovsdb event listener.
|
public static final org.slf4j.Logger log
protected java.util.concurrent.ConcurrentHashMap<OvsdbNodeId,OvsdbClientService> ovsdbClients
protected OvsdbAgent agent
protected org.onosproject.ovsdb.controller.impl.OvsdbControllerImpl.InternalMonitorCallBack updateCallback
protected java.util.Set<OvsdbNodeListener> ovsdbNodeListener
protected java.util.Set<OvsdbEventListener> ovsdbEventListener
protected java.util.concurrent.ConcurrentHashMap<java.lang.String,OvsdbClientService> requestNotification
protected java.util.concurrent.ConcurrentHashMap<java.lang.String,java.lang.String> requestDbName
@Activate public void activate(org.osgi.service.component.ComponentContext context)
@Deactivate public void deactivate()
public void addNodeListener(OvsdbNodeListener listener)
OvsdbControlleraddNodeListener in interface OvsdbControllerlistener - node listenerpublic void removeNodeListener(OvsdbNodeListener listener)
OvsdbControllerremoveNodeListener in interface OvsdbControllerlistener - node listenerpublic void addOvsdbEventListener(OvsdbEventListener listener)
OvsdbControlleraddOvsdbEventListener in interface OvsdbControllerlistener - event listenerpublic void removeOvsdbEventListener(OvsdbEventListener listener)
OvsdbControllerremoveOvsdbEventListener in interface OvsdbControllerlistener - event listenerpublic java.util.List<OvsdbNodeId> getNodeIds()
OvsdbControllergetNodeIds in interface OvsdbControllerpublic OvsdbClientService getOvsdbClient(OvsdbNodeId nodeId)
OvsdbControllergetOvsdbClient in interface OvsdbControllernodeId - node identifierpublic void connect(org.onlab.packet.IpAddress ip,
org.onlab.packet.TpPort port)
OvsdbControllerconnect in interface OvsdbControllerip - ip addressport - port numberpublic void connect(org.onlab.packet.IpAddress ip,
org.onlab.packet.TpPort port,
java.util.function.Consumer<java.lang.Exception> failhandler)
OvsdbControllerconnect in interface OvsdbControllerip - ip addressport - port numberfailhandler - connection failure handler