* will test both the options.
*/
@TypedColumn(name="name", method=MethodType.GETDATA)
- public String getName();
+ String getName();
@TypedColumn(name="name", method=MethodType.GETCOLUMN)
- public Column<GenericTableSchema, String> getNameColumn();
+ Column<GenericTableSchema, String> getNameColumn();
@TypedColumn(name="name", method=MethodType.SETDATA)
- public void setName(String name);
+ void setName(String name);
/*
* Annotations are NOT added to the Status column on purpose to test the backup
* functionality on getter, setter, column name derivation etc. TyperHelper.java.
*/
- public Column<GenericTableSchema, Map<String, String>> getStatusColumn();
- public void setStatus(Map<String, String> status);
+ Column<GenericTableSchema, Map<String, String>> getStatusColumn();
+ void setStatus(Map<String, String> status);
/*
* TypedColumn's name Annotation should override the method name based Column derivation.
* resolution priority of TyperHelper.java
*/
@TypedColumn(name="flood_vlans", method=MethodType.GETCOLUMN)
- public Column<GenericTableSchema, Set<Integer>> getFloodVlansColumn();
+ Column<GenericTableSchema, Set<Integer>> getFloodVlansColumn();
@TypedColumn(name="flood_vlans", method=MethodType.SETDATA)
- public void setFloodVlans(Set<Integer> vlans);
+ void setFloodVlans(Set<Integer> vlans);
@TypedColumn(name="ports", method=MethodType.GETCOLUMN)
- public Column<GenericTableSchema, Set<UUID>> getPortsColumn();
+ Column<GenericTableSchema, Set<UUID>> getPortsColumn();
@TypedColumn(name="ports", method=MethodType.SETDATA)
- public void setPorts(Set<UUID> ports);
+ void setPorts(Set<UUID> ports);
@TypedColumn(name="mirrors", method=MethodType.GETCOLUMN)
- public Column<GenericTableSchema, Set<UUID>> getMirrorsColumn();
+ Column<GenericTableSchema, Set<UUID>> getMirrorsColumn();
@TypedColumn(name="mirrors", method=MethodType.SETDATA)
- public void setMirrors(Set<UUID> mirrors);
+ void setMirrors(Set<UUID> mirrors);
@TypedColumn(name="controller", method=MethodType.GETCOLUMN)
- public Column<GenericTableSchema, Set<UUID>> getControllerColumn();
+ Column<GenericTableSchema, Set<UUID>> getControllerColumn();
@TypedColumn(name="controller", method=MethodType.SETDATA)
- public void setController(Set<UUID> controller);
+ void setController(Set<UUID> controller);
@TypedColumn(name="datapath_id", method=MethodType.GETCOLUMN)
- public Column<GenericTableSchema, Set<String>> getDatapathIdColumn();
+ Column<GenericTableSchema, Set<String>> getDatapathIdColumn();
@TypedColumn(name="datapath_id", method=MethodType.SETDATA)
- public void setDatapathId(Set<String> datapathId);
+ void setDatapathId(Set<String> datapathId);
@TypedColumn(name="datapath_type", method=MethodType.GETCOLUMN)
- public Column<GenericTableSchema, String> getDatapathTypeColumn();
+ Column<GenericTableSchema, String> getDatapathTypeColumn();
@TypedColumn(name="datapath_type", method=MethodType.SETDATA)
- public void setDatapathType(String datapathType);
+ void setDatapathType(String datapathType);
@TypedColumn(name="fail_mode", method=MethodType.GETCOLUMN)
- public Column<GenericTableSchema, Set<String>> getFailModeColumn();
+ Column<GenericTableSchema, Set<String>> getFailModeColumn();
@TypedColumn(name="fail_mode", method=MethodType.SETDATA)
- public void setFailMode(Set<String> failMode);
+ void setFailMode(Set<String> failMode);
@TypedColumn(name="sflow", method=MethodType.GETCOLUMN)
- public Column<GenericTableSchema, Set<UUID>> getSflowColumn();
+ Column<GenericTableSchema, Set<UUID>> getSflowColumn();
@TypedColumn(name="sflow", method=MethodType.SETDATA)
- public void setSflow(Set<UUID> sflow);
+ void setSflow(Set<UUID> sflow);
@TypedColumn(name="netflow", method=MethodType.GETCOLUMN)
- public Column<GenericTableSchema, Set<UUID>> getNetflowColumn();
+ Column<GenericTableSchema, Set<UUID>> getNetflowColumn();
@TypedColumn(name="netflow", method=MethodType.SETDATA)
- public void setNetflow(Set<UUID> netflow);
+ void setNetflow(Set<UUID> netflow);
@TypedColumn(name="flow_tables", method=MethodType.GETCOLUMN)
- public Column<GenericTableSchema, Map<Integer, UUID>> getFlowTablesColumn();
+ Column<GenericTableSchema, Map<Integer, UUID>> getFlowTablesColumn();
@TypedColumn(name="flow_tables", method=MethodType.SETDATA)
- public void setFlowTables(Map<Integer, UUID> flowTables);
+ void setFlowTables(Map<Integer, UUID> flowTables);
@TypedColumn(name="stp_enable", method=MethodType.GETCOLUMN)
- public Column<GenericTableSchema, Boolean> getStpEnableColumn();
+ Column<GenericTableSchema, Boolean> getStpEnableColumn();
@TypedColumn(name="stp_enable", method=MethodType.SETDATA)
- public void setStpEnable(Boolean stp_enable);
+ void setStpEnable(Boolean stp_enable);
@TypedColumn(name="protocols", method=MethodType.GETCOLUMN)
- public Column<GenericTableSchema, Set<String>> getProtocolsColumn();
+ Column<GenericTableSchema, Set<String>> getProtocolsColumn();
@TypedColumn(name="protocols", method=MethodType.SETDATA)
- public void setProtocols(Set<String> protocols);
+ void setProtocols(Set<String> protocols);
@TypedColumn(name="other_config", method=MethodType.GETCOLUMN)
- public Column<GenericTableSchema, Map<String, String>> getOtherConfigColumn();
+ Column<GenericTableSchema, Map<String, String>> getOtherConfigColumn();
@TypedColumn(name="other_config", method=MethodType.SETDATA)
- public void setOtherConfig(Map<String, String> other_config);
+ void setOtherConfig(Map<String, String> other_config);
@TypedColumn(name="external_ids", method=MethodType.GETCOLUMN)
- public Column<GenericTableSchema, Map<String, String>> getExternalIdsColumn();
+ Column<GenericTableSchema, Map<String, String>> getExternalIdsColumn();
@TypedColumn(name="external_ids", method=MethodType.SETDATA)
- public void setExternalIds(Map<String, String> externalIds);
+ void setExternalIds(Map<String, String> externalIds);
@TypedColumn(name="ipfix", method=MethodType.GETCOLUMN)
- public Column<GenericTableSchema, Set<UUID>> getIpfixColumn();
+ Column<GenericTableSchema, Set<UUID>> getIpfixColumn();
@TypedColumn(name="ipfix", method=MethodType.SETDATA)
- public void setIpfix(Set<UUID> ipfix);
+ void setIpfix(Set<UUID> ipfix);
}
* @author Madhu Venugopal
*/
public interface PipelineOrchestrator {
- public Service getNextServiceInPipeline(Service service);
+ Service getNextServiceInPipeline(Service service);
AbstractServiceInstance getServiceInstance(Service service);
- public void enqueue(Node node);
- public void registerService(final ServiceReference ref, AbstractServiceInstance serviceInstance);
- public void unregisterService(final ServiceReference ref);
+ void enqueue(Node node);
+ void registerService(final ServiceReference ref, AbstractServiceInstance serviceInstance);
+ void unregisterService(final ServiceReference ref);
}
* @param bridgeName the name of the bridge
* @return the UUID of the bridge
*/
- public String getBridgeUuid(Node node, String bridgeName);
+ String getBridgeUuid(Node node, String bridgeName);
/**
* Checks for the existence of the Integration Bridge on a given Node
* @param node the {@link Node} where the bridge should be configured
* @return True if the bridge exists, False if it does not
*/
- public boolean isNodeNeutronReady(Node node);
+ boolean isNodeNeutronReady(Node node);
/**
* Checks for the existence of the Network Bridge on a given Node
* @param node the {@link Node} where the bridge should be configured
* @return True if the bridge exists, False if it does not
*/
- public boolean isNodeOverlayReady(Node node);
+ boolean isNodeOverlayReady(Node node);
/**
* Checks for the existence of the Network Bridge on a given Node
* @param ovsdbNode the {@link Node} where the bridge is configured
* @return True or False
*/
- public boolean isNodeTunnelReady(Node bridgeNode, Node ovsdbNode);
+ boolean isNodeTunnelReady(Node bridgeNode, Node ovsdbNode);
/* Determine if internal network is ready for vlan network types.
* - OF 1.0 requires br-int, br-net, a patch connecting them and
* @param network the {@link org.opendaylight.neutron.spi.NeutronNetwork}
* @return True or False
*/
- public boolean isNodeVlanReady(Node bridgeNode, Node ovsdbNode, NeutronNetwork network);
+ boolean isNodeVlanReady(Node bridgeNode, Node ovsdbNode, NeutronNetwork network);
/**
* A helper function to determine if a port exists on a given bridge
* @param portName the name of the port to search for
* @return True if the port exists, otherwise False
*/
- public boolean isPortOnBridge (Node node, String portName);
+ boolean isPortOnBridge(Node node, String portName);
/**
* @param network the {@link org.opendaylight.neutron.spi.NeutronNetwork}
* @return True or False
*/
- public boolean createLocalNetwork(Node node, NeutronNetwork network);
+ boolean createLocalNetwork(Node node, NeutronNetwork network);
/**
* Prepares the given Node for Neutron Networking by creating the Integration Bridge
* @param node the {@link Node} to prepare
*/
- public void prepareNode(Node node);
+ void prepareNode(Node node);
/**
* Returns the physical interface mapped to the given neutron physical network.
* @param physicalNetwork
* @return
*/
- public String getPhysicalInterfaceName (Node node, String physicalNetwork);
+ String getPhysicalInterfaceName(Node node, String physicalNetwork);
/** Returns all physical interfaces configured in the bridge mapping
* Bridge mappings will be of the following format:
* @param node the {@link Node} to query
* @return a List in the format {eth1, eth2} given bridge_mappings=physnet1:eth1,physnet2:eth2
*/
- public List<String> getAllPhysicalInterfaceNames(Node node);
+ List<String> getAllPhysicalInterfaceNames(Node node);
}
* This interface allows Classifier flows to be written to devices
*/
public interface ClassifierProvider {
- public void programLocalInPort(Long dpidLong, String segmentationId, Long inPort, String attachedMac, boolean write);
- public void programLocalInPortSetVlan(Long dpidLong, String segmentationId, Long inPort, String attachedMac, boolean write);
- public void programDropSrcIface(Long dpidLong, Long inPort, boolean write);
- public void programTunnelIn(Long dpidLong, String segmentationId, Long ofPort, boolean write);
- public void programVlanIn(Long dpidLong, String segmentationId, Long ethPort, boolean write);
- public void programLLDPPuntRule(Long dpidLong);
+ void programLocalInPort(Long dpidLong, String segmentationId, Long inPort, String attachedMac, boolean write);
+ void programLocalInPortSetVlan(Long dpidLong, String segmentationId, Long inPort, String attachedMac, boolean write);
+ void programDropSrcIface(Long dpidLong, Long inPort, boolean write);
+ void programTunnelIn(Long dpidLong, String segmentationId, Long ofPort, boolean write);
+ void programVlanIn(Long dpidLong, String segmentationId, Long ethPort, boolean write);
+ void programLLDPPuntRule(Long dpidLong);
}
* @param localPort the local port
* @param securityGroup the security group
*/
- public void programPortSecurityACL(Long dpid, String segmentationId, String attachedMac,
- long localPort, NeutronSecurityGroup securityGroup);
+ void programPortSecurityACL(Long dpid, String segmentationId, String attachedMac,
+ long localPort, NeutronSecurityGroup securityGroup);
/**
* Program fixed egress ACL rules that will be associated with the VM port when a vm is spawned.
*
* @param isComputePort indicates whether this port is a compute port or not
* @param write is this flow writing or deleting
*/
- public void programFixedSecurityACL(Long dpid, String segmentationId,String attachedMac,
- long localPort, List<Neutron_IPs> srcAddressList, boolean isLastPortinBridge, boolean isComputePort, boolean write);
+ void programFixedSecurityACL(Long dpid, String segmentationId, String attachedMac,
+ long localPort, List<Neutron_IPs> srcAddressList, boolean isLastPortinBridge, boolean isComputePort, boolean write);
}
* Enqueue the event.
* @param event the {@link org.opendaylight.ovsdb.openstack.netvirt.AbstractEvent} event to be handled.
*/
- public void enqueueEvent(AbstractEvent event);
- public void eventHandlerAdded(final ServiceReference ref, AbstractHandler handler);
- public void eventHandlerRemoved(final ServiceReference ref);
+ void enqueueEvent(AbstractEvent event);
+ void eventHandlerAdded(final ServiceReference ref, AbstractHandler handler);
+ void eventHandlerRemoved(final ServiceReference ref);
}
* @param localPort the local port
* @param securityGroup the security group
*/
- public void programPortSecurityACL(Long dpid, String segmentationId, String attachedMac,
- long localPort, NeutronSecurityGroup securityGroup);
+ void programPortSecurityACL(Long dpid, String segmentationId, String attachedMac,
+ long localPort, NeutronSecurityGroup securityGroup);
/**
* Program fixed ingress ACL rules that will be associated with the VM port when a vm is spawned.
* *
* @param isComputePort indicates whether this port is a compute port or not
* @param write is this flow writing or deleting
*/
- public void programFixedSecurityACL(Long dpid, String segmentationId,
- String attachedMac, long localPort, boolean isLastPortinSubnet, boolean isComputePort, boolean write);
+ void programFixedSecurityACL(Long dpid, String segmentationId,
+ String attachedMac, long localPort, boolean isLastPortinSubnet, boolean isComputePort, boolean write);
}
* This interface allows L2Forwarding flows to be written to devices
*/
public interface L2ForwardingProvider {
- public void programLocalUcastOut(Long dpidLong, String segmentationId, Long localPort, String attachedMac, boolean write);
- public void programLocalVlanUcastOut(Long dpidLong, String segmentationId, Long localPort, String attachedMac, boolean write);
- public void programLocalBcastOut(Long dpidLong, String segmentationId, Long localPort, boolean write);
- public void programLocalVlanBcastOut(Long dpidLong, String segmentationId, Long localPort, Long ethPort, boolean write);
- public void programLocalTableMiss(Long dpidLong, String segmentationId, boolean write);
- public void programLocalVlanTableMiss(Long dpidLong, String segmentationId, boolean write);
- public void programTunnelOut(Long dpidLong, String segmentationId, Long OFPortOut, String attachedMac, boolean write);
- public void programVlanOut(Long dpidLong, String segmentationId, Long ethPort, String attachedMac, boolean write);
- public void programTunnelFloodOut(Long dpidLong, String segmentationId, Long OFPortOut, boolean write);
- public void programVlanFloodOut(Long dpidLong, String segmentationId, Long ethPort, boolean write);
- public void programTunnelMiss(Long dpidLong, String segmentationId, boolean write);
- public void programVlanMiss(Long dpidLong, String segmentationId, Long ethPort, boolean write);
+ void programLocalUcastOut(Long dpidLong, String segmentationId, Long localPort, String attachedMac, boolean write);
+ void programLocalVlanUcastOut(Long dpidLong, String segmentationId, Long localPort, String attachedMac, boolean write);
+ void programLocalBcastOut(Long dpidLong, String segmentationId, Long localPort, boolean write);
+ void programLocalVlanBcastOut(Long dpidLong, String segmentationId, Long localPort, Long ethPort, boolean write);
+ void programLocalTableMiss(Long dpidLong, String segmentationId, boolean write);
+ void programLocalVlanTableMiss(Long dpidLong, String segmentationId, boolean write);
+ void programTunnelOut(Long dpidLong, String segmentationId, Long OFPortOut, String attachedMac, boolean write);
+ void programVlanOut(Long dpidLong, String segmentationId, Long ethPort, String attachedMac, boolean write);
+ void programTunnelFloodOut(Long dpidLong, String segmentationId, Long OFPortOut, boolean write);
+ void programVlanFloodOut(Long dpidLong, String segmentationId, Long ethPort, boolean write);
+ void programTunnelMiss(Long dpidLong, String segmentationId, boolean write);
+ void programVlanMiss(Long dpidLong, String segmentationId, Long ethPort, boolean write);
}
/**
* Returns the name of the NetworkingProvider
*/
- public String getName();
+ String getName();
/**
* Return true if the provider supports Network Service Instances
*/
- public boolean supportsServices();
+ boolean supportsServices();
/**
* Return true if the provider supports per-tenant or "static" tunneling
*/
- public boolean hasPerTenantTunneling();
+ boolean hasPerTenantTunneling();
/**
* Handle Interface Update Callback Method
*/
- public boolean handleInterfaceUpdate(NeutronNetwork network, Node source, OvsdbTerminationPointAugmentation intf);
+ boolean handleInterfaceUpdate(NeutronNetwork network, Node source, OvsdbTerminationPointAugmentation intf);
/**
* Handle Interface Delete Callback Method
*/
- public boolean handleInterfaceDelete(String tunnelType, NeutronNetwork network, Node source,
- OvsdbTerminationPointAugmentation intf, boolean isLastInstanceOnNode);
+ boolean handleInterfaceDelete(String tunnelType, NeutronNetwork network, Node source,
+ OvsdbTerminationPointAugmentation intf, boolean isLastInstanceOnNode);
/**
* Initialize the Flow rules given the OVSDB node.
* that are Openflow Version specific. Hence we have this method in addition to the following
* Openflow Node specific initialization method.
*/
- public void initializeFlowRules(Node node);
+ void initializeFlowRules(Node node);
/**
* Initialize the Flow rules for a given OpenFlow node
*/
- public void initializeOFFlowRules(Node openflowNode);
+ void initializeOFFlowRules(Node openflowNode);
}
* @see NetworkingProvider
*/
NetworkingProvider getProvider(Node ovsdbNode);
- public void providerAdded(final ServiceReference ref, final NetworkingProvider provider);
- public void providerRemoved(final ServiceReference ref);
+ void providerAdded(final ServiceReference ref, final NetworkingProvider provider);
+ void providerRemoved(final ServiceReference ref);
}
* @author Sam Hague (shague@redhat.com)
*/
public interface NodeCacheListener {
- public void notifyNode(Node node, Action action);
+ void notifyNode(Node node, Action action);
}
* @author Sam Hague (shague@redhat.com)
*/
public interface NodeCacheManager {
- public void nodeAdded(Node node);
- public void nodeRemoved(Node node);
- public List<Node> getNodes();
- public Map<NodeId, Node> getOvsdbNodes();
- public List<Node> getBridgeNodes();
- public void cacheListenerAdded(final ServiceReference ref, NodeCacheListener handler);
- public void cacheListenerRemoved(final ServiceReference ref);
+ void nodeAdded(Node node);
+ void nodeRemoved(Node node);
+ List<Node> getNodes();
+ Map<NodeId, Node> getOvsdbNodes();
+ List<Node> getBridgeNodes();
+ void cacheListenerAdded(final ServiceReference ref, NodeCacheListener handler);
+ void cacheListenerRemoved(final ServiceReference ref);
}
import org.opendaylight.yangtools.yang.binding.DataObject;
public interface OvsdbInventoryListener {
- public enum OvsdbType {
+ enum OvsdbType {
NODE,
ROW,
OPENVSWITCH,
CONTROLLER,
PORT
}
- public void ovsdbUpdate(Node node, DataObject augmentationDataChanges, OvsdbType type, Action action);
- public void triggerUpdates();
+ void ovsdbUpdate(Node node, DataObject augmentationDataChanges, OvsdbType type, Action action);
+ void triggerUpdates();
}
* @author Sam Hague (shague@redhat.com)
*/
public interface OvsdbInventoryService {
- public void listenerAdded(OvsdbInventoryListener listener);
- public void listenerRemoved(OvsdbInventoryListener listener);
- public void providersReady();
+ void listenerAdded(OvsdbInventoryListener listener);
+ void listenerRemoved(OvsdbInventoryListener listener);
+ void providersReady();
}
* @param intf the intf
* @return the boolean
*/
- public boolean isPortSecurityReady(OvsdbTerminationPointAugmentation intf);
+ boolean isPortSecurityReady(OvsdbTerminationPointAugmentation intf);
/**
* Gets security group in port.
*
* @param intf the intf
* @return the security group in port
*/
- public NeutronSecurityGroup getSecurityGroupInPort(OvsdbTerminationPointAugmentation intf);
+ NeutronSecurityGroup getSecurityGroupInPort(OvsdbTerminationPointAugmentation intf);
/**
* Gets the DHCP server port corresponding to a network.
*
* @param intf the intf
* @return the security group in port
*/
- public NeutronPort getDHCPServerPort(OvsdbTerminationPointAugmentation intf);
+ NeutronPort getDHCPServerPort(OvsdbTerminationPointAugmentation intf);
/**
* Is the port a compute port.
* @param intf the intf
* @return the security group in port
*/
- public boolean isComputePort(OvsdbTerminationPointAugmentation intf);
+ boolean isComputePort(OvsdbTerminationPointAugmentation intf);
/**
* Is this the last port in the subnet to which interface belongs to.
* @param intf the intf
* @return the security group in port
*/
- public boolean isLastPortinSubnet(Node node, OvsdbTerminationPointAugmentation intf);
+ boolean isLastPortinSubnet(Node node, OvsdbTerminationPointAugmentation intf);
/**
* Is this the last port in the bridge to which interface belongs to.
* @param intf the intf
* @return the security group in port
*/
- public boolean isLastPortinBridge(Node node, OvsdbTerminationPointAugmentation intf);
+ boolean isLastPortinBridge(Node node, OvsdbTerminationPointAugmentation intf);
/**
* Returns the list of ip adddress assigned to the interface.
*
* @param intf the intf
* @return the security group in port
*/
- public List<Neutron_IPs> getIpAddress(Node node, OvsdbTerminationPointAugmentation intf);
+ List<Neutron_IPs> getIpAddress(Node node, OvsdbTerminationPointAugmentation intf);
}
\ No newline at end of file
* @param networkId the Neutron Network ID
* @return the assigned VLAN ID or 0 in case of an error
*/
- public int getInternalVlan(Node node, String networkId);
+ int getInternalVlan(Node node, String networkId);
/**
* Reclaim the assigned VLAN for the given Network
* @param node the {@link Node} to query
* @param network the Neutron Network ID
*/
- public void reclaimInternalVlan(Node node, NeutronNetwork network);
+ void reclaimInternalVlan(Node node, NeutronNetwork network);
/**
* Configures the VLAN for a Tenant Network
* @param tp the termination point
* @param network the Neutron Network ID
*/
- public void programInternalVlan(Node node, OvsdbTerminationPointAugmentation tp, NeutronNetwork network);
+ void programInternalVlan(Node node, OvsdbTerminationPointAugmentation tp, NeutronNetwork network);
/**
* Check is the given network is present on a Node
* @param segmentationId the Neutron Segementation ID
* @return True or False
*/
- public boolean isTenantNetworkPresentInNode(Node node, String segmentationId);
+ boolean isTenantNetworkPresentInNode(Node node, String segmentationId);
/**
* Get the Neutron Network ID for a given Segmentation ID
*/
- public String getNetworkId (String segmentationId);
+ String getNetworkId(String segmentationId);
/**
* Network Created Callback
*/
- public int networkCreated (Node node, String networkId);
+ int networkCreated(Node node, String networkId);
/**
* Network Deleted Callback
*/
- public void networkDeleted(String id);
+ void networkDeleted(String id);
NeutronNetwork getTenantNetwork(OvsdbTerminationPointAugmentation terminationPointAugmentation);
- public NeutronPort getTenantPort(OvsdbTerminationPointAugmentation terminationPointAugmentation);
+ NeutronPort getTenantPort(OvsdbTerminationPointAugmentation terminationPointAugmentation);
}
* @param networkId the Neutron Network ID
* @return a VLAN ID or 0 in case of an error
*/
- public Integer assignInternalVlan (Node node, String networkId);
+ Integer assignInternalVlan(Node node, String networkId);
/**
* Recovers an assigned VLAN ID when it is no longer required
* @param networkId the Neutron Network ID
* @return the reclaimed VLAN ID or 0 in case of an error
*/
- public Integer reclaimInternalVlan (Node node, String networkId);
+ Integer reclaimInternalVlan(Node node, String networkId);
/**
* Returns a VLAN ID assigned to a given tenant network
* @param networkId the Neutron Network ID
* @return the VLAN ID or 0 in case of an error
*/
- public Integer getInternalVlan (Node node, String networkId);
+ Integer getInternalVlan(Node node, String networkId);
}
* @return UUID of the inserted Row
*/
@Deprecated
- public StatusWithUuid insertRow(Node node, String tableName, String parentUuid, Row<GenericTableSchema> row);
+ StatusWithUuid insertRow(Node node, String tableName, String parentUuid, Row<GenericTableSchema> row);
/**
* insert a Row in a Table of a specified Database Schema. This is a convenience method on top of
* @throws OvsdbPluginException Any failure during the insert transaction will result in a specific exception.
* @return UUID of the inserted Row
*/
- public UUID insertRow(Node node, String databaseName, String tableName, UUID parentRowUuid,
- Row<GenericTableSchema> row) throws OvsdbPluginException;
+ UUID insertRow(Node node, String databaseName, String tableName, UUID parentRowUuid,
+ Row<GenericTableSchema> row) throws OvsdbPluginException;
/**
* insert a Row in a Table of a specified Database Schema.
* @throws OvsdbPluginException Any failure during the insert transaction will result in a specific exception.
* @return UUID of the inserted Row
*/
- public UUID insertRow(Node node, String databaseName, String tableName, String parentTable, UUID parentRowUuid,
- String parentColumn, Row<GenericTableSchema> row) throws OvsdbPluginException;
+ UUID insertRow(Node node, String databaseName, String tableName, String parentTable, UUID parentRowUuid,
+ String parentColumn, Row<GenericTableSchema> row) throws OvsdbPluginException;
/**
* inserts a Tree of Rows in multiple Tables that has parent-child relationships referenced through the OVSDB schema's refTable construct.
* @throws OvsdbPluginException Any failure during the insert transaction will result in a specific exception.
* @return Returns the row tree with the UUID of every inserted Row populated in the _uuid column of every row in the tree
*/
- public Row<GenericTableSchema> insertTree(Node node, String databaseName, String tableName, UUID parentRowUuid,
- Row<GenericTableSchema> row) throws OvsdbPluginException;
+ Row<GenericTableSchema> insertTree(Node node, String databaseName, String tableName, UUID parentRowUuid,
+ Row<GenericTableSchema> row) throws OvsdbPluginException;
/**
* inserts a Tree of Rows in multiple Tables that has parent-child relationships referenced through the OVSDB schema's refTable construct
* @throws OvsdbPluginException Any failure during the insert transaction will result in a specific exception.
* @return Returns the row tree with the UUID of every inserted Row populated in the _uuid column of every row in the tree
*/
- public Row<GenericTableSchema> insertTree(Node node, String databaseName, String tableName, String parentTable, UUID parentRowUuid,
- String parentColumn, Row<GenericTableSchema> row) throws OvsdbPluginException;
+ Row<GenericTableSchema> insertTree(Node node, String databaseName, String tableName, String parentTable, UUID parentRowUuid,
+ String parentColumn, Row<GenericTableSchema> row) throws OvsdbPluginException;
/**
* @deprecated This version of updateRow is a short-term replacement for the older and now deprecated method of the same name.
* @param row Row of table Content to be Updated. Include just those columns that needs to be updated.
*/
@Deprecated
- public Status updateRow (Node node, String tableName, String parentUuid, String rowUuid, Row row);
+ Status updateRow(Node node, String tableName, String parentUuid, String rowUuid, Row row);
/**
* update or mutate a Row in a Table of a specified Database Schema.
* @throws OvsdbPluginException Any failure during the update operation will result in a specific exception.
* @return Returns the entire Row after the update operation.
*/
- public Row<GenericTableSchema> updateRow(Node node, String databaseName, String tableName, UUID rowUuid,
- Row<GenericTableSchema> row, boolean overwrite) throws OvsdbPluginException;
+ Row<GenericTableSchema> updateRow(Node node, String databaseName, String tableName, UUID rowUuid,
+ Row<GenericTableSchema> row, boolean overwrite) throws OvsdbPluginException;
/**
* @deprecated This version of deleteRow is a short-term replacement for the older and now deprecated method of the same name.
* @param rowUuid UUID of the row that is being deleted
*/
@Deprecated
- public Status deleteRow (Node node, String tableName, String rowUuid);
+ Status deleteRow(Node node, String tableName, String rowUuid);
/**
* update or mutate a Row in a Table of a specified Database Schema.
* @throws OvsdbPluginException Any failure during the delete operation will result in a specific exception.
*/
- public void deleteRow (Node node, String databaseName, String tableName, UUID rowUuid) throws OvsdbPluginException;
+ void deleteRow(Node node, String databaseName, String tableName, UUID rowUuid) throws OvsdbPluginException;
/**
* update or mutate a Row in a Table of a specified Database Schema.
* @throws OvsdbPluginException Any failure during the delete operation will result in a specific exception.
*/
- public void deleteRow (Node node, String databaseName, String tableName, String parentTable,
- UUID parentRowUuid, String parentColumn, UUID rowUuid) throws OvsdbPluginException;
+ void deleteRow(Node node, String databaseName, String tableName, String parentTable,
+ UUID parentRowUuid, String parentColumn, UUID rowUuid) throws OvsdbPluginException;
/**
* @deprecated This version of getRow is a short-term replacement for the older and now deprecated method of the same name.
* @return a row with a list of Column data that corresponds to an unique Row-identifier called uuid in a given table.
*/
@Deprecated
- public Row getRow(Node node, String tableName, String uuid);
+ Row getRow(Node node, String tableName, String uuid);
/**
* Returns a Row from a table for the specified uuid.
* @throws OvsdbPluginException Any failure during the get operation will result in a specific exception.
* @return a row with a list of Column data that corresponds to an unique Row-identifier called uuid in a given table.
*/
- public Row<GenericTableSchema> getRow(Node node, String databaseName, String tableName, UUID uuid) throws OvsdbPluginException;
+ Row<GenericTableSchema> getRow(Node node, String databaseName, String tableName, UUID uuid) throws OvsdbPluginException;
/**
* @deprecated This version of getRows is a short-term replacement for the older and now deprecated method of the same name.
* @return List of rows that makes the entire Table.
*/
@Deprecated
- public ConcurrentMap<String, Row> getRows(Node node, String tableName);
+ ConcurrentMap<String, Row> getRows(Node node, String tableName);
/**
* Returns all rows of a table.
* @throws OvsdbPluginException Any failure during the get operation will result in a specific exception.
* @return Map of rows to its UUID that makes the entire Table.
*/
- public ConcurrentMap<UUID, Row<GenericTableSchema>> getRows(Node node, String databaseName, String tableName) throws OvsdbPluginException;
+ ConcurrentMap<UUID, Row<GenericTableSchema>> getRows(Node node, String databaseName, String tableName) throws OvsdbPluginException;
/**
* Returns all rows of a table filtered by query string.
* @throws OvsdbPluginException Any failure during the get operation will result in a specific exception.
* @return Map of rows to its UUID that makes the entire Table.
*/
- public ConcurrentMap<UUID, Row<GenericTableSchema>> getRows(Node node, String databaseName, String tableName, String fiqlQuery) throws OvsdbPluginException;
+ ConcurrentMap<UUID, Row<GenericTableSchema>> getRows(Node node, String databaseName, String tableName, String fiqlQuery) throws OvsdbPluginException;
/**
* @deprecated Returns all the Tables in a given Ndoe.
* @return List of Table Names that make up Open_vSwitch schema.
*/
@Deprecated
- public List<String> getTables(Node node);
+ List<String> getTables(Node node);
/**
* Returns all the Tables in a given Node.
* @throws OvsdbPluginException Any failure during the get operation will result in a specific exception.
* @return List of Table Names that make up the schema represented by the databaseName
*/
- public List<String> getTables(Node node, String databaseName) throws OvsdbPluginException;
+ List<String> getTables(Node node, String databaseName) throws OvsdbPluginException;
/**
* setOFController is a convenience method used by existing applications to setup Openflow Controller on
* @throws InterruptedException
* @throws ExecutionException
*/
- public Boolean setOFController(Node node, String bridgeUUID) throws InterruptedException, ExecutionException;
+ Boolean setOFController(Node node, String bridgeUUID) throws InterruptedException, ExecutionException;
- public <T extends TypedBaseTable<?>> String getTableName(Node node, Class<T> typedClass);
- public <T extends TypedBaseTable<?>> T getTypedRow(Node node, Class<T> typedClass, Row row);
- public <T extends TypedBaseTable<?>> T createTypedRow(Node node, Class<T> typedClass);
+ <T extends TypedBaseTable<?>> String getTableName(Node node, Class<T> typedClass);
+ <T extends TypedBaseTable<?>> T getTypedRow(Node node, Class<T> typedClass, Row row);
+ <T extends TypedBaseTable<?>> T createTypedRow(Node node, Class<T> typedClass);
}
import org.opendaylight.ovsdb.plugin.api.ConnectionConstants;
public interface OvsdbConnectionService {
- public Connection getConnection(Node node);
- public List<Node> getNodes();
- public Node getNode(String identifier);
- public Node connect(String identifier, Map<ConnectionConstants, String> params);
+ Connection getConnection(Node node);
+ List<Node> getNodes();
+ Node getNode(String identifier);
+ Node connect(String identifier, Map<ConnectionConstants, String> params);
}
import java.net.InetAddress;
public interface OvsdbInventoryListener {
- public void nodeAdded(Node node, InetAddress address, int port );
- public void nodeRemoved(Node node);
- public void rowAdded(Node node, String tableName, String uuid, Row row);
- public void rowUpdated(Node node, String tableName, String uuid, Row old, Row row);
- public void rowRemoved(Node node, String tableName, String uuid, Row row, Object context);
+ void nodeAdded(Node node, InetAddress address, int port);
+ void nodeRemoved(Node node);
+ void rowAdded(Node node, String tableName, String uuid, Row row);
+ void rowUpdated(Node node, String tableName, String uuid, Row old, Row row);
+ void rowRemoved(Node node, String tableName, String uuid, Row row, Object context);
}
import org.opendaylight.ovsdb.lib.notation.Row;
public interface OvsdbInventoryService{
- public ConcurrentMap<String, ConcurrentMap<String, Row>> getCache(Node n, String databaseName);
- public ConcurrentMap<String, Row> getTableCache(Node n, String databaseName, String tableName);
- public Row getRow (Node n, String databaseName, String tableName, String uuid);
- public void updateRow(Node n, String databaseName, String tableName, String uuid, Row row);
- public void removeRow(Node n, String databaseName, String tableName, String uuid);
- public void processTableUpdates(Node n, String databaseName,TableUpdates tableUpdates);
- public void printCache(Node n);
-
public void addNode(Node n, Set<Property> props);
- public void notifyNodeAdded(Node n, InetAddress address, int port);
- public void removeNode(Node n);
-
public void addNodeProperty(Node node, UpdateType type, Set<Property> props);
+ ConcurrentMap<String, ConcurrentMap<String, Row>> getCache(Node n, String databaseName);
+ ConcurrentMap<String, Row> getTableCache(Node n, String databaseName, String tableName);
+ Row getRow(Node n, String databaseName, String tableName, String uuid);
+ void updateRow(Node n, String databaseName, String tableName, String uuid, Row row);
+ void removeRow(Node n, String databaseName, String tableName, String uuid);
+ void processTableUpdates(Node n, String databaseName, TableUpdates tableUpdates);
+ void printCache(Node n);
+ void addNode(Node n, Set<Property> props);
+ void notifyNodeAdded(Node n, InetAddress address, int port);
+ void removeNode(Node n);
+ void addNodeProperty(Node node, UpdateType type, Set<Property> props);
}
\ No newline at end of file
* @return UUID of the inserted Row
*/
@Deprecated
- public StatusWithUuid insertRow(Node node, String tableName, String parentUuid, Row<GenericTableSchema> row);
+ StatusWithUuid insertRow(Node node, String tableName, String parentUuid, Row<GenericTableSchema> row);
/**
* insert a Row in a Table of a specified Database Schema. This is a convenience method on top of
* @throws OvsdbPluginException Any failure during the insert transaction will result in a specific exception.
* @return UUID of the inserted Row
*/
- public UUID insertRow(Node node, String databaseName, String tableName, UUID parentRowUuid,
- Row<GenericTableSchema> row) throws OvsdbPluginException;
+ UUID insertRow(Node node, String databaseName, String tableName, UUID parentRowUuid,
+ Row<GenericTableSchema> row) throws OvsdbPluginException;
/**
* insert a Row in a Table of a specified Database Schema.
* @throws OvsdbPluginException Any failure during the insert transaction will result in a specific exception.
* @return UUID of the inserted Row
*/
- public UUID insertRow(Node node, String databaseName, String tableName, String parentTable, UUID parentRowUuid,
- String parentColumn, Row<GenericTableSchema> row) throws OvsdbPluginException;
+ UUID insertRow(Node node, String databaseName, String tableName, String parentTable, UUID parentRowUuid,
+ String parentColumn, Row<GenericTableSchema> row) throws OvsdbPluginException;
/**
* inserts a Tree of Rows in multiple Tables that has parent-child relationships referenced through the OVSDB schema's refTable construct.
* @throws OvsdbPluginException Any failure during the insert transaction will result in a specific exception.
* @return Returns the row tree with the UUID of every inserted Row populated in the _uuid column of every row in the tree
*/
- public Row<GenericTableSchema> insertTree(Node node, String databaseName, String tableName, UUID parentRowUuid,
- Row<GenericTableSchema> row) throws OvsdbPluginException;
+ Row<GenericTableSchema> insertTree(Node node, String databaseName, String tableName, UUID parentRowUuid,
+ Row<GenericTableSchema> row) throws OvsdbPluginException;
/**
* inserts a Tree of Rows in multiple Tables that has parent-child relationships referenced through the OVSDB schema's refTable construct
* @throws OvsdbPluginException Any failure during the insert transaction will result in a specific exception.
* @return Returns the row tree with the UUID of every inserted Row populated in the _uuid column of every row in the tree
*/
- public Row<GenericTableSchema> insertTree(Node node, String databaseName, String tableName, String parentTable, UUID parentRowUuid,
- String parentColumn, Row<GenericTableSchema> row) throws OvsdbPluginException;
+ Row<GenericTableSchema> insertTree(Node node, String databaseName, String tableName, String parentTable, UUID parentRowUuid,
+ String parentColumn, Row<GenericTableSchema> row) throws OvsdbPluginException;
/**
* @deprecated This version of updateRow is a short-term replacement for the older and now deprecated method of the same name.
* @param row Row of table Content to be Updated. Include just those columns that needs to be updated.
*/
@Deprecated
- public Status updateRow (Node node, String tableName, String parentUuid, String rowUuid, Row row);
+ Status updateRow(Node node, String tableName, String parentUuid, String rowUuid, Row row);
/**
* update or mutate a Row in a Table of a specified Database Schema.
* @throws OvsdbPluginException Any failure during the update operation will result in a specific exception.
* @return Returns the entire Row after the update operation.
*/
- public Row<GenericTableSchema> updateRow(Node node, String databaseName, String tableName, UUID rowUuid,
- Row<GenericTableSchema> row, boolean overwrite) throws OvsdbPluginException;
+ Row<GenericTableSchema> updateRow(Node node, String databaseName, String tableName, UUID rowUuid,
+ Row<GenericTableSchema> row, boolean overwrite) throws OvsdbPluginException;
/**
* @deprecated This version of deleteRow is a short-term replacement for the older and now deprecated method of the same name.
* @param rowUuid UUID of the row that is being deleted
*/
@Deprecated
- public Status deleteRow (Node node, String tableName, String rowUuid);
+ Status deleteRow(Node node, String tableName, String rowUuid);
/**
* update or mutate a Row in a Table of a specified Database Schema.
* @throws OvsdbPluginException Any failure during the delete operation will result in a specific exception.
*/
- public void deleteRow (Node node, String databaseName, String tableName, UUID rowUuid) throws OvsdbPluginException;
+ void deleteRow(Node node, String databaseName, String tableName, UUID rowUuid) throws OvsdbPluginException;
/**
* update or mutate a Row in a Table of a specified Database Schema.
* @throws OvsdbPluginException Any failure during the delete operation will result in a specific exception.
*/
- public void deleteRow (Node node, String databaseName, String tableName, String parentTable,
- UUID parentRowUuid, String parentColumn, UUID rowUuid) throws OvsdbPluginException;
+ void deleteRow(Node node, String databaseName, String tableName, String parentTable,
+ UUID parentRowUuid, String parentColumn, UUID rowUuid) throws OvsdbPluginException;
/**
* @deprecated This version of getRow is a short-term replacement for the older and now deprecated method of the same name.
* @return a row with a list of Column data that corresponds to an unique Row-identifier called uuid in a given table.
*/
@Deprecated
- public Row getRow(Node node, String tableName, String uuid);
+ Row getRow(Node node, String tableName, String uuid);
/**
* Returns a Row from a table for the specified uuid.
* @throws OvsdbPluginException Any failure during the get operation will result in a specific exception.
* @return a row with a list of Column data that corresponds to an unique Row-identifier called uuid in a given table.
*/
- public Row<GenericTableSchema> getRow(Node node, String databaseName, String tableName, UUID uuid) throws OvsdbPluginException;
+ Row<GenericTableSchema> getRow(Node node, String databaseName, String tableName, UUID uuid) throws OvsdbPluginException;
/**
* @deprecated This version of getRows is a short-term replacement for the older and now deprecated method of the same name.
* @return List of rows that makes the entire Table.
*/
@Deprecated
- public ConcurrentMap<String, Row> getRows(Node node, String tableName);
+ ConcurrentMap<String, Row> getRows(Node node, String tableName);
/**
* Returns all rows of a table.
* @throws OvsdbPluginException Any failure during the get operation will result in a specific exception.
* @return Map of rows to its UUID that makes the entire Table.
*/
- public ConcurrentMap<UUID, Row<GenericTableSchema>> getRows(Node node, String databaseName, String tableName) throws OvsdbPluginException;
+ ConcurrentMap<UUID, Row<GenericTableSchema>> getRows(Node node, String databaseName, String tableName) throws OvsdbPluginException;
/**
* Returns all rows of a table filtered by query string.
* @throws OvsdbPluginException Any failure during the get operation will result in a specific exception.
* @return Map of rows to its UUID that makes the entire Table.
*/
- public ConcurrentMap<UUID, Row<GenericTableSchema>> getRows(Node node, String databaseName, String tableName, String fiqlQuery) throws OvsdbPluginException;
+ ConcurrentMap<UUID, Row<GenericTableSchema>> getRows(Node node, String databaseName, String tableName, String fiqlQuery) throws OvsdbPluginException;
/**
* @deprecated Returns all the Tables in a given Ndoe.
* @return List of Table Names that make up Open_vSwitch schema.
*/
@Deprecated
- public List<String> getTables(Node node);
+ List<String> getTables(Node node);
/**
* Returns all the Tables in a given Node.
* @throws OvsdbPluginException Any failure during the get operation will result in a specific exception.
* @return List of Table Names that make up the schema represented by the databaseName
*/
- public List<String> getTables(Node node, String databaseName) throws OvsdbPluginException;
+ List<String> getTables(Node node, String databaseName) throws OvsdbPluginException;
/**
* setOFController is a convenience method used by existing applications to setup Openflow Controller on
* @throws InterruptedException
* @throws ExecutionException
*/
- public Boolean setOFController(Node node, String bridgeUUID) throws InterruptedException, ExecutionException;
+ Boolean setOFController(Node node, String bridgeUUID) throws InterruptedException, ExecutionException;
- public <T extends TypedBaseTable<?>> String getTableName(Node node, Class<T> typedClass);
- public <T extends TypedBaseTable<?>> T getTypedRow(Node node, Class<T> typedClass, Row row);
- public <T extends TypedBaseTable<?>> T createTypedRow(Node node, Class<T> typedClass);
+ <T extends TypedBaseTable<?>> String getTableName(Node node, Class<T> typedClass);
+ <T extends TypedBaseTable<?>> T getTypedRow(Node node, Class<T> typedClass, Row row);
+ <T extends TypedBaseTable<?>> T createTypedRow(Node node, Class<T> typedClass);
}
import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.nodes.Node;
public interface OvsdbConnectionService {
- public Connection getConnection(Node node);
- public List<Node> getNodes();
- public Node getNode(String identifier);
- public Node connect(String identifier, Map<ConnectionConstants, String> params);
+ Connection getConnection(Node node);
+ List<Node> getNodes();
+ Node getNode(String identifier);
+ Node connect(String identifier, Map<ConnectionConstants, String> params);
}
import java.net.InetAddress;
public interface OvsdbInventoryListener {
- public void nodeAdded(Node node, InetAddress address, int port );
- public void nodeRemoved(Node node);
- public void rowAdded(Node node, String tableName, String uuid, Row row);
- public void rowUpdated(Node node, String tableName, String uuid, Row old, Row row);
- public void rowRemoved(Node node, String tableName, String uuid, Row row, Object context);
+ void nodeAdded(Node node, InetAddress address, int port);
+ void nodeRemoved(Node node);
+ void rowAdded(Node node, String tableName, String uuid, Row row);
+ void rowUpdated(Node node, String tableName, String uuid, Row old, Row row);
+ void rowRemoved(Node node, String tableName, String uuid, Row row, Object context);
}
import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.nodes.Node;
public interface OvsdbInventoryService {
- public ConcurrentMap<String, ConcurrentMap<String, Row>> getCache(Node n, String databaseName);
- public ConcurrentMap<String, Row> getTableCache(Node n, String databaseName, String tableName);
- public Row getRow (Node n, String databaseName, String tableName, String uuid);
- public void updateRow(Node n, String databaseName, String tableName, String uuid, Row row);
- public void removeRow(Node n, String databaseName, String tableName, String uuid);
- public void processTableUpdates(Node n, String databaseName,TableUpdates tableUpdates);
- public void printCache(Node n);
- public void notifyNodeAdded(Node n, InetAddress address, int port);
- public void removeNode(Node n);
+ ConcurrentMap<String, ConcurrentMap<String, Row>> getCache(Node n, String databaseName);
+ ConcurrentMap<String, Row> getTableCache(Node n, String databaseName, String tableName);
+ Row getRow(Node n, String databaseName, String tableName, String uuid);
+ void updateRow(Node n, String databaseName, String tableName, String uuid, Row row);
+ void removeRow(Node n, String databaseName, String tableName, String uuid);
+ void processTableUpdates(Node n, String databaseName, TableUpdates tableUpdates);
+ void printCache(Node n);
+ void notifyNodeAdded(Node n, InetAddress address, int port);
+ void removeNode(Node n);
}
\ No newline at end of file
Code Review / netvirt.git / commitdiff