aboutsummaryrefslogtreecommitdiffstats
path: root/framework/src/onos/core/net/src/test/java/org/onosproject/net/flowobjective/impl/FlowObjectiveCompositionTreeTest.java
diff options
context:
space:
mode:
Diffstat (limited to 'framework/src/onos/core/net/src/test/java/org/onosproject/net/flowobjective/impl/FlowObjectiveCompositionTreeTest.java')
-rw-r--r--framework/src/onos/core/net/src/test/java/org/onosproject/net/flowobjective/impl/FlowObjectiveCompositionTreeTest.java603
1 files changed, 603 insertions, 0 deletions
diff --git a/framework/src/onos/core/net/src/test/java/org/onosproject/net/flowobjective/impl/FlowObjectiveCompositionTreeTest.java b/framework/src/onos/core/net/src/test/java/org/onosproject/net/flowobjective/impl/FlowObjectiveCompositionTreeTest.java
new file mode 100644
index 00000000..1e898d37
--- /dev/null
+++ b/framework/src/onos/core/net/src/test/java/org/onosproject/net/flowobjective/impl/FlowObjectiveCompositionTreeTest.java
@@ -0,0 +1,603 @@
+/*
+ * Copyright 2014-2015 Open Networking Laboratory
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.onosproject.net.flowobjective.impl;
+
+import org.junit.After;
+import org.junit.Before;
+import org.junit.Ignore;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+/**
+ * Test FlowObjectiveCompositionTree.
+ */
+@Ignore
+public class FlowObjectiveCompositionTreeTest {
+
+ private final Logger log = LoggerFactory.getLogger(getClass());
+
+ @Before
+ public void setUp() {}
+
+ @After
+ public void tearDown() {}
+
+ /*@Test
+ public void testParallelComposition() {
+ FlowObjectiveCompositionTree policyTree = FlowObjectiveCompositionUtil.parsePolicyString("31+32");
+
+ {
+ TrafficSelector selector = DefaultTrafficSelector.builder()
+ .matchIPSrc(IpPrefix.valueOf("1.0.0.0/24"))
+ .build();
+
+ TrafficTreatment treatment = DefaultTrafficTreatment.builder().build();
+
+ ForwardingObjective forwardingObjective = DefaultForwardingObjective.builder()
+ .fromApp(new DefaultApplicationId(31, "a"))
+ .makePermanent()
+ .withFlag(ForwardingObjective.Flag.VERSATILE)
+ .withPriority(1)
+ .withSelector(selector)
+ .withTreatment(treatment)
+ .add();
+
+ helper(policyTree, forwardingObjective);
+ }
+
+ {
+ TrafficSelector selector = DefaultTrafficSelector.builder().build();
+
+ TrafficTreatment treatment = DefaultTrafficTreatment.builder().build();
+
+ ForwardingObjective forwardingObjective = DefaultForwardingObjective.builder()
+ .fromApp(new DefaultApplicationId(31, "a"))
+ .makePermanent()
+ .withFlag(ForwardingObjective.Flag.VERSATILE)
+ .withPriority(0)
+ .withSelector(selector)
+ .withTreatment(treatment)
+ .add();
+
+ helper(policyTree, forwardingObjective);
+ }
+
+
+ {
+ TrafficSelector selector = DefaultTrafficSelector.builder()
+ .matchIPDst(IpPrefix.valueOf("2.0.0.1/32"))
+ .build();
+
+ TrafficTreatment treatment = DefaultTrafficTreatment.builder()
+ .setOutput(PortNumber.portNumber(1))
+ .build();
+
+ ForwardingObjective forwardingObjective = DefaultForwardingObjective.builder()
+ .fromApp(new DefaultApplicationId(32, "b"))
+ .makePermanent()
+ .withFlag(ForwardingObjective.Flag.VERSATILE)
+ .withPriority(1)
+ .withSelector(selector)
+ .withTreatment(treatment)
+ .add();
+
+ helper(policyTree, forwardingObjective);
+ }
+
+ {
+ TrafficSelector selector = DefaultTrafficSelector.builder()
+ .matchIPDst(IpPrefix.valueOf("2.0.0.2/32"))
+ .build();
+
+ TrafficTreatment treatment = DefaultTrafficTreatment.builder()
+ .setOutput(PortNumber.portNumber(2))
+ .build();
+
+ ForwardingObjective forwardingObjective = DefaultForwardingObjective.builder()
+ .fromApp(new DefaultApplicationId(32, "b"))
+ .makePermanent()
+ .withFlag(ForwardingObjective.Flag.VERSATILE)
+ .withPriority(1)
+ .withSelector(selector)
+ .withTreatment(treatment)
+ .add();
+ helper(policyTree, forwardingObjective);
+ }
+
+ {
+ TrafficSelector selector = DefaultTrafficSelector.builder().build();
+
+ TrafficTreatment treatment = DefaultTrafficTreatment.builder().build();
+
+ ForwardingObjective forwardingObjective = DefaultForwardingObjective.builder()
+ .fromApp(new DefaultApplicationId(32, "b"))
+ .makePermanent()
+ .withFlag(ForwardingObjective.Flag.VERSATILE)
+ .withPriority(0)
+ .withSelector(selector)
+ .withTreatment(treatment)
+ .add();
+
+ helper(policyTree, forwardingObjective);
+ }
+
+ System.out.println("---------- Parallel ----------");
+ for (ForwardingObjective fo : policyTree.forwardTable.getForwardingObjectives()) {
+ System.out.println(forwardingObjectiveToString(fo));
+ }
+
+ {
+ TrafficSelector selector = DefaultTrafficSelector.builder()
+ .matchIPDst(IpPrefix.valueOf("2.0.0.3/32"))
+ .build();
+
+ TrafficTreatment treatment = DefaultTrafficTreatment.builder()
+ .setOutput(PortNumber.portNumber(3))
+ .build();
+
+ ForwardingObjective forwardingObjective = DefaultForwardingObjective.builder()
+ .fromApp(new DefaultApplicationId(32, "b"))
+ .makePermanent()
+ .withFlag(ForwardingObjective.Flag.VERSATILE)
+ .withPriority(1)
+ .withSelector(selector)
+ .withTreatment(treatment)
+ .add();
+ helper(policyTree, forwardingObjective);
+ }
+
+ System.out.println("---------- Parallel ----------");
+ for (ForwardingObjective fo : policyTree.forwardTable.getForwardingObjectives()) {
+ System.out.println(forwardingObjectiveToString(fo));
+ }
+
+ {
+ TrafficSelector selector = DefaultTrafficSelector.builder()
+ .matchIPDst(IpPrefix.valueOf("2.0.0.3/32"))
+ .build();
+
+ TrafficTreatment treatment = DefaultTrafficTreatment.builder()
+ .setOutput(PortNumber.portNumber(3))
+ .build();
+
+ ForwardingObjective forwardingObjective = DefaultForwardingObjective.builder()
+ .fromApp(new DefaultApplicationId(32, "b"))
+ .makePermanent()
+ .withFlag(ForwardingObjective.Flag.VERSATILE)
+ .withPriority(1)
+ .withSelector(selector)
+ .withTreatment(treatment)
+ .remove();
+ helper(policyTree, forwardingObjective);
+ }
+
+ {
+ TrafficSelector selector = DefaultTrafficSelector.builder()
+ .matchIPSrc(IpPrefix.valueOf("1.0.0.0/24"))
+ .build();
+
+ TrafficTreatment treatment = DefaultTrafficTreatment.builder().build();
+
+ ForwardingObjective forwardingObjective = DefaultForwardingObjective.builder()
+ .fromApp(new DefaultApplicationId(31, "a"))
+ .makePermanent()
+ .withFlag(ForwardingObjective.Flag.VERSATILE)
+ .withPriority(1)
+ .withSelector(selector)
+ .withTreatment(treatment)
+ .remove();
+
+ helper(policyTree, forwardingObjective);
+ }
+
+ {
+ TrafficSelector selector = DefaultTrafficSelector.builder().build();
+
+ TrafficTreatment treatment = DefaultTrafficTreatment.builder().build();
+
+ ForwardingObjective forwardingObjective = DefaultForwardingObjective.builder()
+ .fromApp(new DefaultApplicationId(31, "a"))
+ .makePermanent()
+ .withFlag(ForwardingObjective.Flag.VERSATILE)
+ .withPriority(0)
+ .withSelector(selector)
+ .withTreatment(treatment)
+ .remove();
+
+ helper(policyTree, forwardingObjective);
+ }
+
+ System.out.println("---------- Parallel ----------");
+ for (ForwardingObjective fo : policyTree.forwardTable.getForwardingObjectives()) {
+ System.out.println(forwardingObjectiveToString(fo));
+ }
+ }
+
+ @Test
+ public void testSequentialComposition() {
+ FlowObjectiveCompositionTree policyTree = FlowObjectiveCompositionUtil.parsePolicyString("31>32");
+
+ {
+ TrafficSelector selector = DefaultTrafficSelector.builder()
+ .matchIPSrc(IpPrefix.valueOf("0.0.0.0/2"))
+ .matchIPDst(IpPrefix.valueOf("3.0.0.0/32"))
+ .build();
+
+ TrafficTreatment treatment = DefaultTrafficTreatment.builder()
+ .setIpDst(IpAddress.valueOf("2.0.0.1"))
+ .build();
+
+ ForwardingObjective forwardingObjective = DefaultForwardingObjective.builder()
+ .fromApp(new DefaultApplicationId(31, "a"))
+ .makePermanent()
+ .withFlag(ForwardingObjective.Flag.VERSATILE)
+ .withPriority(3)
+ .withSelector(selector)
+ .withTreatment(treatment)
+ .add();
+
+ helper(policyTree, forwardingObjective);
+ }
+
+ {
+ TrafficSelector selector = DefaultTrafficSelector.builder()
+ .matchIPDst(IpPrefix.valueOf("3.0.0.0/32"))
+ .build();
+
+ TrafficTreatment treatment = DefaultTrafficTreatment.builder()
+ .setIpDst(IpAddress.valueOf("2.0.0.2"))
+ .build();
+
+ ForwardingObjective forwardingObjective = DefaultForwardingObjective.builder()
+ .fromApp(new DefaultApplicationId(31, "a"))
+ .makePermanent()
+ .withFlag(ForwardingObjective.Flag.VERSATILE)
+ .withPriority(1)
+ .withSelector(selector)
+ .withTreatment(treatment)
+ .add();
+
+ helper(policyTree, forwardingObjective);
+ }
+
+ {
+ TrafficSelector selector = DefaultTrafficSelector.builder().build();
+
+ TrafficTreatment treatment = DefaultTrafficTreatment.builder().build();
+
+ ForwardingObjective forwardingObjective = DefaultForwardingObjective.builder()
+ .fromApp(new DefaultApplicationId(31, "a"))
+ .makePermanent()
+ .withFlag(ForwardingObjective.Flag.VERSATILE)
+ .withPriority(0)
+ .withSelector(selector)
+ .withTreatment(treatment)
+ .add();
+
+ helper(policyTree, forwardingObjective);
+ }
+
+ {
+ TrafficSelector selector = DefaultTrafficSelector.builder()
+ .matchIPDst(IpPrefix.valueOf("2.0.0.1/32"))
+ .build();
+
+ TrafficTreatment treatment = DefaultTrafficTreatment.builder()
+ .setOutput(PortNumber.portNumber(1))
+ .build();
+
+ ForwardingObjective forwardingObjective = DefaultForwardingObjective.builder()
+ .fromApp(new DefaultApplicationId(32, "b"))
+ .makePermanent()
+ .withFlag(ForwardingObjective.Flag.VERSATILE)
+ .withPriority(1)
+ .withSelector(selector)
+ .withTreatment(treatment)
+ .add();
+
+ helper(policyTree, forwardingObjective);
+ }
+
+ {
+ TrafficSelector selector = DefaultTrafficSelector.builder()
+ .matchIPDst(IpPrefix.valueOf("2.0.0.2/32"))
+ .build();
+
+ TrafficTreatment treatment = DefaultTrafficTreatment.builder()
+ .setOutput(PortNumber.portNumber(2))
+ .build();
+
+ ForwardingObjective forwardingObjective = DefaultForwardingObjective.builder()
+ .fromApp(new DefaultApplicationId(32, "b"))
+ .makePermanent()
+ .withFlag(ForwardingObjective.Flag.VERSATILE)
+ .withPriority(1)
+ .withSelector(selector)
+ .withTreatment(treatment)
+ .add();
+ helper(policyTree, forwardingObjective);
+ }
+
+ {
+ TrafficSelector selector = DefaultTrafficSelector.builder().build();
+
+ TrafficTreatment treatment = DefaultTrafficTreatment.builder().build();
+
+ ForwardingObjective forwardingObjective = DefaultForwardingObjective.builder()
+ .fromApp(new DefaultApplicationId(32, "b"))
+ .makePermanent()
+ .withFlag(ForwardingObjective.Flag.VERSATILE)
+ .withPriority(0)
+ .withSelector(selector)
+ .withTreatment(treatment)
+ .add();
+
+ helper(policyTree, forwardingObjective);
+ }
+
+ System.out.println("---------- Sequential ----------");
+ for (ForwardingObjective fo : policyTree.forwardTable.getForwardingObjectives()) {
+ System.out.println(forwardingObjectiveToString(fo));
+ }
+
+ {
+ TrafficSelector selector = DefaultTrafficSelector.builder()
+ .matchIPDst(IpPrefix.valueOf("2.0.0.3/32"))
+ .build();
+
+ TrafficTreatment treatment = DefaultTrafficTreatment.builder()
+ .setOutput(PortNumber.portNumber(3))
+ .build();
+
+ ForwardingObjective forwardingObjective = DefaultForwardingObjective.builder()
+ .fromApp(new DefaultApplicationId(32, "b"))
+ .makePermanent()
+ .withFlag(ForwardingObjective.Flag.VERSATILE)
+ .withPriority(1)
+ .withSelector(selector)
+ .withTreatment(treatment)
+ .add();
+
+ helper(policyTree, forwardingObjective);
+ }
+
+ {
+ TrafficSelector selector = DefaultTrafficSelector.builder()
+ .matchIPSrc(IpPrefix.valueOf("0.0.0.0/1"))
+ .matchIPDst(IpPrefix.valueOf("3.0.0.0/32"))
+ .build();
+
+ TrafficTreatment treatment = DefaultTrafficTreatment.builder()
+ .setIpDst(IpAddress.valueOf("2.0.0.3"))
+ .build();
+
+ ForwardingObjective forwardingObjective = DefaultForwardingObjective.builder()
+ .fromApp(new DefaultApplicationId(31, "a"))
+ .makePermanent()
+ .withFlag(ForwardingObjective.Flag.VERSATILE)
+ .withPriority(3)
+ .withSelector(selector)
+ .withTreatment(treatment)
+ .add();
+
+ helper(policyTree, forwardingObjective);
+ }
+
+ System.out.println("---------- Sequential ----------");
+ for (ForwardingObjective fo : policyTree.forwardTable.getForwardingObjectives()) {
+ System.out.println(forwardingObjectiveToString(fo));
+ }
+
+ {
+ TrafficSelector selector = DefaultTrafficSelector.builder()
+ .matchIPDst(IpPrefix.valueOf("2.0.0.3/32"))
+ .build();
+
+ TrafficTreatment treatment = DefaultTrafficTreatment.builder()
+ .setOutput(PortNumber.portNumber(3))
+ .build();
+
+ ForwardingObjective forwardingObjective = DefaultForwardingObjective.builder()
+ .fromApp(new DefaultApplicationId(32, "b"))
+ .makePermanent()
+ .withFlag(ForwardingObjective.Flag.VERSATILE)
+ .withPriority(1)
+ .withSelector(selector)
+ .withTreatment(treatment)
+ .remove();
+
+ helper(policyTree, forwardingObjective);
+ }
+
+ {
+ TrafficSelector selector = DefaultTrafficSelector.builder()
+ .matchIPSrc(IpPrefix.valueOf("0.0.0.0/1"))
+ .matchIPDst(IpPrefix.valueOf("3.0.0.0/32"))
+ .build();
+
+ TrafficTreatment treatment = DefaultTrafficTreatment.builder()
+ .setIpDst(IpAddress.valueOf("2.0.0.3"))
+ .build();
+
+ ForwardingObjective forwardingObjective = DefaultForwardingObjective.builder()
+ .fromApp(new DefaultApplicationId(31, "a"))
+ .makePermanent()
+ .withFlag(ForwardingObjective.Flag.VERSATILE)
+ .withPriority(3)
+ .withSelector(selector)
+ .withTreatment(treatment)
+ .remove();
+
+ helper(policyTree, forwardingObjective);
+ }
+
+ System.out.println("---------- Sequential ----------");
+ for (ForwardingObjective fo : policyTree.forwardTable.getForwardingObjectives()) {
+ System.out.println(forwardingObjectiveToString(fo));
+ }
+ }
+
+ @Test
+ public void testOverrideComposition() {
+ FlowObjectiveCompositionTree policyTree = FlowObjectiveCompositionUtil.parsePolicyString("31/32");
+
+ {
+ TrafficSelector selector = DefaultTrafficSelector.builder()
+ .matchIPSrc(IpPrefix.valueOf("1.0.0.0/32"))
+ .matchIPDst(IpPrefix.valueOf("2.0.0.1/32"))
+ .build();
+
+ TrafficTreatment treatment = DefaultTrafficTreatment.builder()
+ .setOutput(PortNumber.portNumber(3))
+ .build();
+
+ ForwardingObjective forwardingObjective = DefaultForwardingObjective.builder()
+ .fromApp(new DefaultApplicationId(31, "a"))
+ .makePermanent()
+ .withFlag(ForwardingObjective.Flag.VERSATILE)
+ .withPriority(1)
+ .withSelector(selector)
+ .withTreatment(treatment)
+ .add();
+
+ helper(policyTree, forwardingObjective);
+ }
+
+ {
+ TrafficSelector selector = DefaultTrafficSelector.builder()
+ .matchIPDst(IpPrefix.valueOf("2.0.0.1/32"))
+ .build();
+
+ TrafficTreatment treatment = DefaultTrafficTreatment.builder()
+ .setOutput(PortNumber.portNumber(1))
+ .build();
+
+ ForwardingObjective forwardingObjective = DefaultForwardingObjective.builder()
+ .fromApp(new DefaultApplicationId(32, "b"))
+ .makePermanent()
+ .withFlag(ForwardingObjective.Flag.VERSATILE)
+ .withPriority(1)
+ .withSelector(selector)
+ .withTreatment(treatment)
+ .add();
+
+ helper(policyTree, forwardingObjective);
+ }
+
+ {
+ TrafficSelector selector = DefaultTrafficSelector.builder()
+ .matchIPDst(IpPrefix.valueOf("2.0.0.2/32"))
+ .build();
+
+ TrafficTreatment treatment = DefaultTrafficTreatment.builder()
+ .setOutput(PortNumber.portNumber(2))
+ .build();
+
+ ForwardingObjective forwardingObjective = DefaultForwardingObjective.builder()
+ .fromApp(new DefaultApplicationId(32, "b"))
+ .makePermanent()
+ .withFlag(ForwardingObjective.Flag.VERSATILE)
+ .withPriority(1)
+ .withSelector(selector)
+ .withTreatment(treatment)
+ .add();
+ helper(policyTree, forwardingObjective);
+ }
+
+ {
+ TrafficSelector selector = DefaultTrafficSelector.builder().build();
+
+ TrafficTreatment treatment = DefaultTrafficTreatment.builder().build();
+
+ ForwardingObjective forwardingObjective = DefaultForwardingObjective.builder()
+ .fromApp(new DefaultApplicationId(32, "b"))
+ .makePermanent()
+ .withFlag(ForwardingObjective.Flag.VERSATILE)
+ .withPriority(0)
+ .withSelector(selector)
+ .withTreatment(treatment)
+ .add();
+
+ helper(policyTree, forwardingObjective);
+ }
+
+ System.out.println("---------- Override ----------");
+ for (ForwardingObjective fo : policyTree.forwardTable.getForwardingObjectives()) {
+ System.out.println(forwardingObjectiveToString(fo));
+ }
+
+ {
+ TrafficSelector selector = DefaultTrafficSelector.builder()
+ .matchIPDst(IpPrefix.valueOf("2.0.0.3/32"))
+ .build();
+
+ TrafficTreatment treatment = DefaultTrafficTreatment.builder()
+ .setOutput(PortNumber.portNumber(3))
+ .build();
+
+ ForwardingObjective forwardingObjective = DefaultForwardingObjective.builder()
+ .fromApp(new DefaultApplicationId(32, "b"))
+ .makePermanent()
+ .withFlag(ForwardingObjective.Flag.VERSATILE)
+ .withPriority(1)
+ .withSelector(selector)
+ .withTreatment(treatment)
+ .add();
+ helper(policyTree, forwardingObjective);
+ }
+
+ System.out.println("---------- Override ----------");
+ for (ForwardingObjective fo : policyTree.forwardTable.getForwardingObjectives()) {
+ System.out.println(forwardingObjectiveToString(fo));
+ }
+
+ {
+ TrafficSelector selector = DefaultTrafficSelector.builder()
+ .matchIPDst(IpPrefix.valueOf("2.0.0.3/32"))
+ .build();
+
+ TrafficTreatment treatment = DefaultTrafficTreatment.builder()
+ .setOutput(PortNumber.portNumber(3))
+ .build();
+
+ ForwardingObjective forwardingObjective = DefaultForwardingObjective.builder()
+ .fromApp(new DefaultApplicationId(32, "b"))
+ .makePermanent()
+ .withFlag(ForwardingObjective.Flag.VERSATILE)
+ .withPriority(1)
+ .withSelector(selector)
+ .withTreatment(treatment)
+ .remove();
+ helper(policyTree, forwardingObjective);
+ }
+
+ System.out.println("---------- Override ----------");
+ for (ForwardingObjective fo : policyTree.forwardTable.getForwardingObjectives()) {
+ System.out.println(forwardingObjectiveToString(fo));
+ }
+ }
+
+ private void helper(FlowObjectiveCompositionTree policyTree, ForwardingObjective forwardingObjective) {
+ log.info("before composition");
+ log.info("\t{}", forwardingObjectiveToString(forwardingObjective));
+ List<ForwardingObjective> forwardingObjectives
+ = policyTree.updateForward(forwardingObjective);
+ log.info("after composition");
+ for (ForwardingObjective fo : forwardingObjectives) {
+ log.info("\t{}", forwardingObjectiveToString(fo));
+ }
+ }*/
+}