mirrors/onos
1
0
Fork 0
mirror of https://github.com/opennetworkinglab/onos.git synced 2025-10-18 19:01:06 +02:00
Code Issues Projects Releases Wiki Activity

Add trace for OpenstackRoutingFloatingIpHandler

Browse Source 
Change-Id: I176c22889065082301e398b7bf4f858be57e6d28
This commit is contained in:
daniel park 2018-04-10 15:17:42 +09:00 committed by Thomas Vachuska
parent d0f8d89ec7
commit c2a2ed64f3
1 changed files with 12 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
apps/openstacknetworking/app/src/main/java/org/onosproject/openstacknetworking/impl/OpenstackRoutingFloatingIpHandler.java
View File

@ -153,6 +153,7 @@ public class OpenstackRoutingFloatingIpHandler {
} }
MacAddress srcMac = MacAddress.valueOf(osPort.getMacAddress()); MacAddress srcMac = MacAddress.valueOf(osPort.getMacAddress());
log.trace("Mac address of openstack port: {}", srcMac);
InstancePort instPort = instancePortService.instancePort(srcMac); InstancePort instPort = instancePortService.instancePort(srcMac);
if (instPort == null) { if (instPort == null) {
final String errorFormat = ERR_FLOW + "no host(MAC:%s) found"; final String errorFormat = ERR_FLOW + "no host(MAC:%s) found";
@ -164,12 +165,17 @@ public class OpenstackRoutingFloatingIpHandler {
ExternalPeerRouter externalPeerRouter = externalPeerRouter(osNet); ExternalPeerRouter externalPeerRouter = externalPeerRouter(osNet);
if (externalPeerRouter == null) { if (externalPeerRouter == null) {
return; final String errorFormat = ERR_FLOW + "no external peer router found";
throw new IllegalStateException(errorFormat);
} }
setComputeNodeToGateway(instPort, osNet, install); setComputeNodeToGateway(instPort, osNet, install);
setDownstreamRules(floatingIp, osNet, instPort, externalPeerRouter, install); setDownstreamRules(floatingIp, osNet, instPort, externalPeerRouter, install);
setUpstreamRules(floatingIp, osNet, instPort, externalPeerRouter, install); setUpstreamRules(floatingIp, osNet, instPort, externalPeerRouter, install);
log.trace("Succeeded to set flow rules for floating ip {}:{} and install: {}",
floatingIp.getFloatingIpAddress(),
floatingIp.getFixedIpAddress(),
install);
} }
private void setComputeNodeToGateway(InstancePort instPort, Network osNet, boolean install) { private void setComputeNodeToGateway(InstancePort instPort, Network osNet, boolean install) {
@ -196,7 +202,8 @@ public class OpenstackRoutingFloatingIpHandler {
OpenstackNode selectedGatewayNode = selectGatewayNode(); OpenstackNode selectedGatewayNode = selectGatewayNode();
if (selectedGatewayNode == null) { if (selectedGatewayNode == null) {
return; final String errorFormat = ERR_FLOW + "no gateway node selected";
throw new IllegalStateException(errorFormat);
} }
treatment = DefaultTrafficTreatment.builder() treatment = DefaultTrafficTreatment.builder()
.extension(buildExtension( .extension(buildExtension(
@ -215,6 +222,7 @@ public class OpenstackRoutingFloatingIpHandler {
PRIORITY_EXTERNAL_FLOATING_ROUTING_RULE, PRIORITY_EXTERNAL_FLOATING_ROUTING_RULE,
ROUTING_TABLE, ROUTING_TABLE,
install); install);
log.trace("Succeeded to set flow rules from compute node to gateway on compute node");
} }
private OpenstackNode selectGatewayNode() { private OpenstackNode selectGatewayNode() {
@ -332,6 +340,7 @@ public class OpenstackRoutingFloatingIpHandler {
GW_COMMON_TABLE, GW_COMMON_TABLE,
install); install);
}); });
log.trace("Succeeded to set flow rules for downstream on gateway nodes");
} }
private void setUpstreamRules(NetFloatingIP floatingIp, Network osNet, private void setUpstreamRules(NetFloatingIP floatingIp, Network osNet,
@ -379,6 +388,7 @@ public class OpenstackRoutingFloatingIpHandler {
GW_COMMON_TABLE, GW_COMMON_TABLE,
install); install);
}); });
log.trace("Succeeded to set flow rules for upstream on gateway nodes");
} }
private ExternalPeerRouter externalPeerRouter(Network network) { private ExternalPeerRouter externalPeerRouter(Network network) {