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

Added changes to OltPipeline to create filtering flows for DHCP packets

Browse Source 
Change-Id: I5287f05d2a51de82ff4ac89bdb017dfd856b237f
This commit is contained in:
Amit Ghosh 2016-12-23 21:36:19 +00:00 committed by Jonathan Hart
parent c1f4aa7cce
commit cbaf86763f
1 changed files with 24 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
drivers/default/src/main/java/org/onosproject/driver/pipeline/OltPipeline.java
View File

@ -50,6 +50,7 @@ import org.onosproject.net.flow.criteria.EthTypeCriterion;
import org.onosproject.net.flow.criteria.IPCriterion; import org.onosproject.net.flow.criteria.IPCriterion;
import org.onosproject.net.flow.criteria.IPProtocolCriterion; import org.onosproject.net.flow.criteria.IPProtocolCriterion;
import org.onosproject.net.flow.criteria.PortCriterion; import org.onosproject.net.flow.criteria.PortCriterion;
import org.onosproject.net.flow.criteria.UdpPortCriterion;
import org.onosproject.net.flow.criteria.VlanIdCriterion; import org.onosproject.net.flow.criteria.VlanIdCriterion;
import org.onosproject.net.flow.instructions.Instruction; import org.onosproject.net.flow.instructions.Instruction;
import org.onosproject.net.flow.instructions.Instructions; import org.onosproject.net.flow.instructions.Instructions;
@ -184,12 +185,24 @@ public class OltPipeline extends AbstractHandlerBehaviour implements Pipeliner {
filterForCriterion(filter.conditions(), Criterion.Type.IP_PROTO); filterForCriterion(filter.conditions(), Criterion.Type.IP_PROTO);
if (ipProto.protocol() == IPv4.PROTOCOL_IGMP) { if (ipProto.protocol() == IPv4.PROTOCOL_IGMP) {
provisionIgmp(filter, ethType, ipProto, output); provisionIgmp(filter, ethType, ipProto, output);
} else if (ipProto.protocol() == IPv4.PROTOCOL_UDP) {
UdpPortCriterion udpSrcPort = (UdpPortCriterion)
filterForCriterion(filter.conditions(), Criterion.Type.UDP_SRC);
UdpPortCriterion udpDstPort = (UdpPortCriterion)
filterForCriterion(filter.conditions(), Criterion.Type.UDP_DST);
if (udpSrcPort.udpPort().toInt() != 68 || udpDstPort.udpPort().toInt() != 67) {
log.error("OLT can only filte DHCP, wrong UDP Src or Dst Port");
fail(filter, ObjectiveError.UNSUPPORTED);
}
provisionDhcp(filter, ethType, ipProto, udpSrcPort, udpDstPort, output);
} else { } else {
log.error("OLT can only filter igmp"); log.error("OLT can only filter igmp and DHCP");
fail(filter, ObjectiveError.UNSUPPORTED); fail(filter, ObjectiveError.UNSUPPORTED);
} }
} else { } else {
log.error("OLT can only filter eapol and igmp"); log.error("OLT can only filter eapol igmp");
fail(filter, ObjectiveError.UNSUPPORTED); fail(filter, ObjectiveError.UNSUPPORTED);
} }
@ -540,6 +553,15 @@ public class OltPipeline extends AbstractHandlerBehaviour implements Pipeliner {
buildAndApplyRule(filter, selector, treatment); buildAndApplyRule(filter, selector, treatment);
} }
private void provisionDhcp(FilteringObjective filter, EthTypeCriterion ethType,
IPProtocolCriterion ipProto,
UdpPortCriterion udpSrcPort,
UdpPortCriterion udpDstPort,
Instructions.OutputInstruction output) {
TrafficSelector selector = buildSelector(filter.key(), ethType, ipProto, udpSrcPort, udpDstPort);
TrafficTreatment treatment = buildTreatment(output);
buildAndApplyRule(filter, selector, treatment);
}
private void buildAndApplyRule(FilteringObjective filter, TrafficSelector selector, private void buildAndApplyRule(FilteringObjective filter, TrafficSelector selector,
TrafficTreatment treatment) { TrafficTreatment treatment) {
FlowRule rule = DefaultFlowRule.builder() FlowRule rule = DefaultFlowRule.builder()