import org.opendaylight.netvirt.utils.mdsal.openflow.FlowUtils;
import org.opendaylight.netvirt.utils.mdsal.openflow.InstructionUtils;
import org.opendaylight.netvirt.utils.servicehelper.ServiceHelper;
-import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev100924.Uri;
+import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.Uri;
import org.opendaylight.yang.gen.v1.urn.opendaylight.action.types.rev131112.action.action.GroupActionCase;
import org.opendaylight.yang.gen.v1.urn.opendaylight.action.types.rev131112.action.action.GroupActionCaseBuilder;
import org.opendaylight.yang.gen.v1.urn.opendaylight.action.types.rev131112.action.action.OutputActionCase;
private boolean addTunnelPort (Node node, String tunnelType, InetAddress src, InetAddress dst) {
String tunnelBridgeName = configurationService.getIntegrationBridgeName();
String portName = getTunnelName(tunnelType, dst);
- LOG.info("addTunnelPort enter: portName: {}", portName);
+ LOG.info("Added TunnelPort : portName: {}", portName);
if (southbound.extractTerminationPointAugmentation(node, portName) != null
|| southbound.isTunnelTerminationPointExist(node, tunnelBridgeName, portName)) {
LOG.info("Tunnel {} is present in {} of {}", portName, tunnelBridgeName, node.getNodeId().getValue());
if (dstBridgeNode != null) {
destTunnelStatus = addTunnelPort(dstBridgeNode, networkType, dst, src);
}
-
+ if (sourceTunnelStatus && destTunnelStatus) {
+ LOG.debug("Created Source and destination TunnelPorts :{}, {}", src, dst);
+ } else {
+ LOG.debug("Source and destination TunnelPort status :{}, {}", sourceTunnelStatus, destTunnelStatus);
+ }
if (sourceTunnelStatus) {
boolean isDestinNw = tenantNetworkManager.isTenantNetworkPresentInNode(dstBridgeNode, segmentationId);
//Check whether the network is present in src & dst node
}
private void triggerInterfaceUpdates(Node node) {
- LOG.debug("enter triggerInterfaceUpdates for {}", node.getNodeId());
+ LOG.debug("enter triggerInterfaceUpdates for : {}", node.getNodeId());
List<OvsdbTerminationPointAugmentation> ports = southbound.extractTerminationPointAugmentations(node);
if (ports != null && !ports.isEmpty()) {
for (OvsdbTerminationPointAugmentation port : ports) {
private void initializeFlowRules(Node node, String bridgeName) {
Long dpid = southbound.getDataPathId(node);
String datapathId = southbound.getDatapathId(node);
- LOG.info("initializeFlowRules: bridgeName: {}, dpid: {} - {}",
- bridgeName, dpid, datapathId);
+ LOG.trace("initializeFlowRules: bridgeName: {}, datapathId: {} ",
+ bridgeName, datapathId);
if (dpid == 0L) {
LOG.debug("Openflow Datapath-ID not set for the integration bridge in {}", node);
initializeFlowRules(openflowNode, configurationService.getIntegrationBridgeName());
triggerInterfaceUpdates(openflowNode);
} else if (bridgeName.equals(configurationService.getExternalBridgeName())) {
- initializeFlowRules(openflowNode, configurationService.getExternalBridgeName());
- LOG.info("initializeOFFlowRules after writeFlow: bridgeName: {}", bridgeName);
+ initializeFlowRules(openflowNode, configurationService.getExternalBridgeName());
triggerInterfaceUpdates(openflowNode);
- LOG.info("initializeOFFlowRules after triggerUpdates: bridgeName: {}", bridgeName);
}
}