@Test public void testL3flow_ipv6Arp() { Endpoint testEp = buildEndpoint(IPV6_1, MAC_1, CONNECTOR_1).build(); flows.l3Flow((short) 2, testEp, new NodeConnectorId(CONNECTOR_1), new MacAddress(MAC_1), 100, true, ofWriter); verifyZeroInteractions(ofWriter); }
void l3Flow(short goToTable, Endpoint endpoint, NodeConnectorId connectorId, MacAddress macAddress, int priority, boolean arp, OfWriter ofWriter) { if (endpoint.getL3Address() != null) { for (L3Address l3Address : endpoint.getL3Address()) { if (l3Address.getIpAddress() == null) { continue; } Match match; if (arp) { match = createL3ArpMatch(connectorId, macAddress, l3Address.getIpAddress()); } else { match = createL3IpMatch(connectorId, macAddress, l3Address.getIpAddress()); } if (match == null) { continue; } FlowId flowid = FlowIdUtils.newFlowId(tableId, "L3", match); Flow flow = FlowUtils.base(tableId) .setPriority(priority) .setId(flowid) .setMatch(match) .setInstructions(FlowUtils.gotoTableInstructions(goToTable)) .build(); ofWriter.writeFlow(nodeId, tableId, flow); } } }
PortSecurityFlows { void l3Flow(short goToTable, Endpoint endpoint, NodeConnectorId connectorId, MacAddress macAddress, int priority, boolean arp, OfWriter ofWriter) { if (endpoint.getL3Address() != null) { for (L3Address l3Address : endpoint.getL3Address()) { if (l3Address.getIpAddress() == null) { continue; } Match match; if (arp) { match = createL3ArpMatch(connectorId, macAddress, l3Address.getIpAddress()); } else { match = createL3IpMatch(connectorId, macAddress, l3Address.getIpAddress()); } if (match == null) { continue; } FlowId flowid = FlowIdUtils.newFlowId(tableId, "L3", match); Flow flow = FlowUtils.base(tableId) .setPriority(priority) .setId(flowid) .setMatch(match) .setInstructions(FlowUtils.gotoTableInstructions(goToTable)) .build(); ofWriter.writeFlow(nodeId, tableId, flow); } } } }
PortSecurityFlows { void l3Flow(short goToTable, Endpoint endpoint, NodeConnectorId connectorId, MacAddress macAddress, int priority, boolean arp, OfWriter ofWriter) { if (endpoint.getL3Address() != null) { for (L3Address l3Address : endpoint.getL3Address()) { if (l3Address.getIpAddress() == null) { continue; } Match match; if (arp) { match = createL3ArpMatch(connectorId, macAddress, l3Address.getIpAddress()); } else { match = createL3IpMatch(connectorId, macAddress, l3Address.getIpAddress()); } if (match == null) { continue; } FlowId flowid = FlowIdUtils.newFlowId(tableId, "L3", match); Flow flow = FlowUtils.base(tableId) .setPriority(priority) .setId(flowid) .setMatch(match) .setInstructions(FlowUtils.gotoTableInstructions(goToTable)) .build(); ofWriter.writeFlow(nodeId, tableId, flow); } } } PortSecurityFlows(NodeId nodeId, Short tableId); }
PortSecurityFlows { void l3Flow(short goToTable, Endpoint endpoint, NodeConnectorId connectorId, MacAddress macAddress, int priority, boolean arp, OfWriter ofWriter) { if (endpoint.getL3Address() != null) { for (L3Address l3Address : endpoint.getL3Address()) { if (l3Address.getIpAddress() == null) { continue; } Match match; if (arp) { match = createL3ArpMatch(connectorId, macAddress, l3Address.getIpAddress()); } else { match = createL3IpMatch(connectorId, macAddress, l3Address.getIpAddress()); } if (match == null) { continue; } FlowId flowid = FlowIdUtils.newFlowId(tableId, "L3", match); Flow flow = FlowUtils.base(tableId) .setPriority(priority) .setId(flowid) .setMatch(match) .setInstructions(FlowUtils.gotoTableInstructions(goToTable)) .build(); ofWriter.writeFlow(nodeId, tableId, flow); } } } PortSecurityFlows(NodeId nodeId, Short tableId);  }
PortSecurityFlows { void l3Flow(short goToTable, Endpoint endpoint, NodeConnectorId connectorId, MacAddress macAddress, int priority, boolean arp, OfWriter ofWriter) { if (endpoint.getL3Address() != null) { for (L3Address l3Address : endpoint.getL3Address()) { if (l3Address.getIpAddress() == null) { continue; } Match match; if (arp) { match = createL3ArpMatch(connectorId, macAddress, l3Address.getIpAddress()); } else { match = createL3IpMatch(connectorId, macAddress, l3Address.getIpAddress()); } if (match == null) { continue; } FlowId flowid = FlowIdUtils.newFlowId(tableId, "L3", match); Flow flow = FlowUtils.base(tableId) .setPriority(priority) .setId(flowid) .setMatch(match) .setInstructions(FlowUtils.gotoTableInstructions(goToTable)) .build(); ofWriter.writeFlow(nodeId, tableId, flow); } } } PortSecurityFlows(NodeId nodeId, Short tableId);   }