summaryrefslogtreecommitdiffstats
path: root/srv6/srv6-impl/src/test/java/io
diff options
context:
space:
mode:
authorMichal Cmarada <michal.cmarada@pantheon.tech>2018-06-15 13:12:53 +0200
committerMarek Gradzki <mgradzki@cisco.com>2018-06-19 18:56:53 +0000
commitb77a5725338dc700873b36c98af85d70acd7bbe4 (patch)
tree6006938757b2f3ac28eabc90eff821b3290f50af /srv6/srv6-impl/src/test/java/io
parenta0884f2792c31a3a93fb1654ceea754b6c612920 (diff)
HC2VPP-304 - add SRv6 policy module
new models: - hc2vpp-oc-srte-policy@2017-09-18.yang (ietf draft for srte-policies) - vpp-oc-srte-policy@2018-05-14.yang (augments oc-srte-policy model with VPP specific configuration) - policy-context@2018-06-07.yang defines policy contexts for policies and candidate paths new features: - adds support for writing/reading SRv6 policies - adds support for writing/reading L2 steering - adds support for writing/reading L3 steering - implements support for FIB table management (HC2VPP-345) Change-Id: Ie83ac8ecdcc0e46086e1ecdaecbb811746151c2f Signed-off-by: Michal Cmarada <michal.cmarada@pantheon.tech>
Diffstat (limited to 'srv6/srv6-impl/src/test/java/io')
-rw-r--r--srv6/srv6-impl/src/test/java/io/fd/hc2vpp/srv6/Srv6ModuleTest.java15
-rw-r--r--srv6/srv6-impl/src/test/java/io/fd/hc2vpp/srv6/read/policy/NamedSegmentCustomizerTest.java101
-rw-r--r--srv6/srv6-impl/src/test/java/io/fd/hc2vpp/srv6/read/policy/PoliciesTest.java122
-rw-r--r--srv6/srv6-impl/src/test/java/io/fd/hc2vpp/srv6/read/policy/PolicyCustomizerTest.java143
-rw-r--r--srv6/srv6-impl/src/test/java/io/fd/hc2vpp/srv6/read/steering/InterfaceCustomizerTest.java90
-rw-r--r--srv6/srv6-impl/src/test/java/io/fd/hc2vpp/srv6/read/steering/PrefixCustomizerTest.java78
-rw-r--r--srv6/srv6-impl/src/test/java/io/fd/hc2vpp/srv6/read/steering/PrefixesStateCustomizerTest.java54
-rw-r--r--srv6/srv6-impl/src/test/java/io/fd/hc2vpp/srv6/read/steering/SteeringTest.java82
-rw-r--r--srv6/srv6-impl/src/test/java/io/fd/hc2vpp/srv6/util/JvppRequestTest.java41
-rw-r--r--srv6/srv6-impl/src/test/java/io/fd/hc2vpp/srv6/util/Srv6UtilTest.java64
-rw-r--r--srv6/srv6-impl/src/test/java/io/fd/hc2vpp/srv6/write/policy/PolicyCustomizerTest.java166
-rw-r--r--srv6/srv6-impl/src/test/java/io/fd/hc2vpp/srv6/write/steering/InterfacesConfigCustomizerTest.java117
-rw-r--r--srv6/srv6-impl/src/test/java/io/fd/hc2vpp/srv6/write/steering/PrefixCustomizerTest.java134
-rw-r--r--srv6/srv6-impl/src/test/java/io/fd/hc2vpp/srv6/write/steering/PrefixesConfigCustomizerTest.java103
14 files changed, 1306 insertions, 4 deletions
diff --git a/srv6/srv6-impl/src/test/java/io/fd/hc2vpp/srv6/Srv6ModuleTest.java b/srv6/srv6-impl/src/test/java/io/fd/hc2vpp/srv6/Srv6ModuleTest.java
index 54e4cdd26..068ea128a 100644
--- a/srv6/srv6-impl/src/test/java/io/fd/hc2vpp/srv6/Srv6ModuleTest.java
+++ b/srv6/srv6-impl/src/test/java/io/fd/hc2vpp/srv6/Srv6ModuleTest.java
@@ -31,7 +31,9 @@ import com.google.inject.name.Named;
import com.google.inject.testing.fieldbinder.Bind;
import com.google.inject.testing.fieldbinder.BoundFieldModule;
import io.fd.hc2vpp.common.translate.util.NamingContext;
+import io.fd.hc2vpp.srv6.read.Srv6PolicyReaderFactory;
import io.fd.hc2vpp.srv6.read.Srv6ReaderFactory;
+import io.fd.hc2vpp.srv6.write.Srv6PolicyWriterFactory;
import io.fd.hc2vpp.srv6.write.Srv6WriterFactory;
import io.fd.hc2vpp.vpp.classifier.context.VppClassifierContextManager;
import io.fd.honeycomb.translate.ModificationCache;
@@ -42,6 +44,7 @@ import io.fd.honeycomb.translate.util.YangDAG;
import io.fd.honeycomb.translate.write.WriterFactory;
import io.fd.vpp.jvpp.core.future.FutureJVppCore;
import java.util.HashSet;
+import java.util.Iterator;
import java.util.Set;
import org.junit.Before;
import org.junit.Test;
@@ -100,8 +103,10 @@ public class Srv6ModuleTest {
readerFactories.forEach(factory -> factory.init(registryBuilder));
registryBuilder.addStructuralReader(Srv6IIds.RT, RoutingBuilder.class);
assertNotNull(registryBuilder.build());
- assertEquals(1, readerFactories.size());
- assertTrue(readerFactories.iterator().next() instanceof Srv6ReaderFactory);
+ assertEquals(2, readerFactories.size());
+ Iterator<ReaderFactory> readerFactoryIterator = readerFactories.iterator();
+ assertTrue(readerFactoryIterator.next() instanceof Srv6ReaderFactory);
+ assertTrue(readerFactoryIterator.next() instanceof Srv6PolicyReaderFactory);
}
@Test
@@ -112,7 +117,9 @@ public class Srv6ModuleTest {
final FlatWriterRegistryBuilder registryBuilder = new FlatWriterRegistryBuilder(new YangDAG());
writerFactories.forEach(factory -> factory.init(registryBuilder));
assertNotNull(registryBuilder.build());
- assertEquals(1, writerFactories.size());
- assertTrue(writerFactories.iterator().next() instanceof Srv6WriterFactory);
+ assertEquals(2, writerFactories.size());
+ Iterator<WriterFactory> writerFactoryIterator = writerFactories.iterator();
+ assertTrue(writerFactoryIterator.next() instanceof Srv6WriterFactory);
+ assertTrue(writerFactoryIterator.next() instanceof Srv6PolicyWriterFactory);
}
}
diff --git a/srv6/srv6-impl/src/test/java/io/fd/hc2vpp/srv6/read/policy/NamedSegmentCustomizerTest.java b/srv6/srv6-impl/src/test/java/io/fd/hc2vpp/srv6/read/policy/NamedSegmentCustomizerTest.java
new file mode 100644
index 000000000..6cc2f555d
--- /dev/null
+++ b/srv6/srv6-impl/src/test/java/io/fd/hc2vpp/srv6/read/policy/NamedSegmentCustomizerTest.java
@@ -0,0 +1,101 @@
+/*
+ * Copyright (c) 2018 Bell Canada, Pantheon Technologies and/or its affiliates.
+ *
+ * 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 io.fd.hc2vpp.srv6.read.policy;
+
+import com.google.common.collect.ImmutableSet;
+import io.fd.hc2vpp.srv6.Srv6PolicyIIds;
+import io.fd.honeycomb.translate.read.ReadFailedException;
+import java.util.List;
+import org.junit.Assert;
+import org.junit.Test;
+import org.opendaylight.yang.gen.v1.http.cisco.com.ns.yang.oc.srte.policy.rev170918.named.segment.lists.NamedSegmentListsBuilder;
+import org.opendaylight.yang.gen.v1.http.cisco.com.ns.yang.oc.srte.policy.rev170918.named.segment.lists.named.segment.lists.NamedSegmentList;
+import org.opendaylight.yang.gen.v1.http.cisco.com.ns.yang.oc.srte.policy.rev170918.named.segment.lists.named.segment.lists.NamedSegmentListBuilder;
+import org.opendaylight.yang.gen.v1.http.cisco.com.ns.yang.oc.srte.policy.rev170918.named.segment.lists.named.segment.lists.NamedSegmentListKey;
+import org.opendaylight.yangtools.yang.binding.KeyedInstanceIdentifier;
+
+public class NamedSegmentCustomizerTest extends PoliciesTest {
+
+ private NamedSegmentListKey SEGMENT_KEY_1 = new NamedSegmentListKey("a::e-0");
+ private NamedSegmentListKey SEGMENT_KEY_2 = new NamedSegmentListKey("e::a-0");
+
+ @Test
+ public void getAllIdsTest() throws ReadFailedException {
+ NamedSegmentCustomizer customizer = new NamedSegmentCustomizer(api, policyCtx, candidatePathCtx);
+ List<NamedSegmentListKey> segmentListKeys = customizer.getAllIds(Srv6PolicyIIds.SR_TE_NSLS_NSL_IID, readCtx);
+
+ Assert.assertNotNull(segmentListKeys);
+ Assert.assertFalse(segmentListKeys.isEmpty());
+ Assert.assertEquals(replyDump.srPoliciesDetails.size(), segmentListKeys.size());
+ Assert.assertTrue(segmentListKeys.containsAll(ImmutableSet.of(SEGMENT_KEY_1, SEGMENT_KEY_2)));
+ }
+
+ @Test
+ public void readCurrentAttributesTest() throws ReadFailedException {
+ NamedSegmentCustomizer customizer = new NamedSegmentCustomizer(api, policyCtx, candidatePathCtx);
+ NamedSegmentListBuilder segmentListBuilder = new NamedSegmentListBuilder();
+ KeyedInstanceIdentifier<NamedSegmentList, NamedSegmentListKey>
+ key = Srv6PolicyIIds.SR_TE_NSLS.child(NamedSegmentList.class, SEGMENT_KEY_1);
+ customizer.readCurrentAttributes(key, segmentListBuilder, readCtx);
+
+ Assert.assertEquals(SEGMENT_KEY_1, segmentListBuilder.getKey());
+ Assert.assertEquals(SEGMENT_KEY_1.getName(), segmentListBuilder.getName());
+ Assert.assertNotNull(customizer.getBuilder(key));
+
+ //verify State container
+ Assert.assertNotNull(segmentListBuilder.getState());
+ Assert.assertEquals(SEGMENT_KEY_1.getName(), segmentListBuilder.getState().getName());
+
+ //verify State container
+ Assert.assertNotNull(segmentListBuilder.getSegments());
+ Assert.assertNotNull(segmentListBuilder.getSegments().getSegment());
+ Assert.assertEquals(3, segmentListBuilder.getSegments().getSegment().size());
+
+ Assert.assertEquals(B_ADDR.getValue(),
+ segmentListBuilder.getSegments().getSegment().get(0).getState().getSidValue().getIpAddress()
+ .getIpv6Address().getValue());
+ Assert.assertEquals(C_ADDR.getValue(),
+ segmentListBuilder.getSegments().getSegment().get(1).getState().getSidValue().getIpAddress()
+ .getIpv6Address().getValue());
+ Assert.assertEquals(A_ADDR.getValue(),
+ segmentListBuilder.getSegments().getSegment().get(2).getState().getSidValue().getIpAddress()
+ .getIpv6Address().getValue());
+
+ //verify different path
+ key = Srv6PolicyIIds.SR_TE_NSLS.child(NamedSegmentList.class, SEGMENT_KEY_2);
+ customizer.readCurrentAttributes(key, segmentListBuilder, readCtx);
+ Assert.assertEquals(SEGMENT_KEY_2.getName(), segmentListBuilder.getState().getName());
+ Assert.assertEquals(3, segmentListBuilder.getSegments().getSegment().size());
+
+ Assert.assertEquals(A_ADDR.getValue(),
+ segmentListBuilder.getSegments().getSegment().get(0).getState().getSidValue().getIpAddress()
+ .getIpv6Address().getValue());
+ Assert.assertEquals(C_ADDR.getValue(),
+ segmentListBuilder.getSegments().getSegment().get(1).getState().getSidValue().getIpAddress()
+ .getIpv6Address().getValue());
+ Assert.assertEquals(B_ADDR.getValue(),
+ segmentListBuilder.getSegments().getSegment().get(2).getState().getSidValue().getIpAddress()
+ .getIpv6Address().getValue());
+
+ //verify merge
+ NamedSegmentList segmentList = segmentListBuilder.build();
+ NamedSegmentListsBuilder parentBuilder = new NamedSegmentListsBuilder();
+ customizer.merge(parentBuilder, segmentList);
+ Assert.assertEquals(segmentList, parentBuilder.getNamedSegmentList().get(0));
+ }
+}
diff --git a/srv6/srv6-impl/src/test/java/io/fd/hc2vpp/srv6/read/policy/PoliciesTest.java b/srv6/srv6-impl/src/test/java/io/fd/hc2vpp/srv6/read/policy/PoliciesTest.java
new file mode 100644
index 000000000..d1abd15e8
--- /dev/null
+++ b/srv6/srv6-impl/src/test/java/io/fd/hc2vpp/srv6/read/policy/PoliciesTest.java
@@ -0,0 +1,122 @@
+/*
+ * Copyright (c) 2018 Bell Canada, Pantheon Technologies and/or its affiliates.
+ *
+ * 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 io.fd.hc2vpp.srv6.read.policy;
+
+import static org.mockito.ArgumentMatchers.any;
+import static org.mockito.Mockito.when;
+
+import com.google.common.collect.ImmutableSet;
+import io.fd.hc2vpp.common.translate.util.AddressTranslator;
+import io.fd.hc2vpp.common.translate.util.ByteDataTranslator;
+import io.fd.hc2vpp.srv6.util.CandidatePathContextManager;
+import io.fd.hc2vpp.srv6.util.PolicyContextManager;
+import io.fd.hc2vpp.srv6.write.sid.request.LocalSidRequestTest;
+import io.fd.honeycomb.translate.ModificationCache;
+import io.fd.honeycomb.translate.read.ReadContext;
+import io.fd.vpp.jvpp.core.dto.SrPoliciesDetails;
+import io.fd.vpp.jvpp.core.dto.SrPoliciesDetailsReplyDump;
+import io.fd.vpp.jvpp.core.types.Srv6Sid;
+import io.fd.vpp.jvpp.core.types.Srv6SidList;
+import java.util.Arrays;
+import org.mockito.Mock;
+import org.opendaylight.yang.gen.v1.http.cisco.com.ns.yang.oc.srte.policy.rev170918.ProvisioningMethodConfig;
+import org.opendaylight.yang.gen.v1.http.cisco.com.ns.yang.oc.srte.policy.rev170918.ProvisioningMethodType;
+import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.IpAddress;
+import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.Ipv6Address;
+import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.Ipv6AddressNoZone;
+
+public abstract class PoliciesTest extends LocalSidRequestTest {
+ Ipv6AddressNoZone BSID_ADR = new Ipv6AddressNoZone("a::e");
+ Ipv6AddressNoZone BSID_2_ADR = new Ipv6AddressNoZone("e::a");
+ IpAddress ENDPOINT_1 = new IpAddress(new Ipv6Address("e::1"));
+ IpAddress ENDPOINT_2 = new IpAddress(new Ipv6Address("a::1"));
+ Long COLOR_1 = 1L;
+ Long COLOR_2 = 2L;
+ long DISTINGUISHER_1 = 1L;
+ long DISTINGUISHER_2 = 2L;
+ long PREFERENCE_1 = 100L;
+ long PREFERENCE_2 = 200L;
+ Class<? extends ProvisioningMethodType> PROVISIONING_METHOD = ProvisioningMethodConfig.class;
+ int WEIGHT = 0;
+ SrPoliciesDetailsReplyDump replyDump = new SrPoliciesDetailsReplyDump();
+
+ @Mock
+ ReadContext readCtx;
+ @Mock
+ PolicyContextManager policyCtx;
+ @Mock
+ CandidatePathContextManager candidatePathCtx;
+ Ipv6AddressNoZone A_ADDR = new Ipv6AddressNoZone("a::");
+ Ipv6AddressNoZone B_ADDR = new Ipv6AddressNoZone("b::");
+ Ipv6AddressNoZone C_ADDR = new Ipv6AddressNoZone("c::");
+
+ @Mock
+ private
+ ModificationCache modificationCache;
+ private Srv6Sid A = new Srv6Sid();
+ private Srv6Sid B = new Srv6Sid();
+ private Srv6Sid C = new Srv6Sid();
+ private SrPoliciesDetails srPoliciesDetails1 = new SrPoliciesDetails();
+ private SrPoliciesDetails srPoliciesDetails2 = new SrPoliciesDetails();
+
+ @Override
+ public void init() {
+ Srv6Sid bsid = new Srv6Sid();
+ bsid.addr = AddressTranslator.INSTANCE.ipAddressToArray(new IpAddress(BSID_ADR));
+ srPoliciesDetails1.bsid = bsid;
+
+ srPoliciesDetails1.numSidLists = 1;
+ Srv6SidList[] srv6SidLists = new Srv6SidList[1];
+ Srv6SidList srv6SidList = new Srv6SidList();
+ srv6SidList.weight = WEIGHT;
+ srv6SidList.numSids = 3;
+ A.addr = AddressTranslator.INSTANCE.ipAddressToArray(new IpAddress(A_ADDR));
+ B.addr = AddressTranslator.INSTANCE.ipAddressToArray(new IpAddress(B_ADDR));
+ C.addr = AddressTranslator.INSTANCE.ipAddressToArray(new IpAddress(C_ADDR));
+
+ srv6SidList.sids = ImmutableSet.of(B, C, A).toArray(new Srv6Sid[3]);
+
+ srv6SidLists[0] = srv6SidList;
+ srPoliciesDetails1.sidLists = srv6SidLists;
+ // is_encap - behavior of SR policy.(0.SRH insert // 1.Encapsulation)
+ srPoliciesDetails1.isEncap = ByteDataTranslator.BYTE_TRUE;
+ // type is the type of the SR policy. (0.Default // 1.Spray)
+ srPoliciesDetails1.type = 0;
+
+ Srv6Sid bsid2 = new Srv6Sid();
+ bsid2.addr = AddressTranslator.INSTANCE.ipAddressToArray(new IpAddress(BSID_2_ADR));
+ srPoliciesDetails2.bsid = bsid2;
+ srPoliciesDetails2.numSidLists = 1;
+ Srv6SidList[] srv6SidLists2 = new Srv6SidList[1];
+ Srv6SidList srv6SidList2 = new Srv6SidList();
+ srv6SidList2.weight = WEIGHT;
+ srv6SidList2.numSids = 3;
+
+ srv6SidList2.sids = ImmutableSet.of(A, C, B).toArray(new Srv6Sid[3]);
+ srv6SidLists2[0] = srv6SidList2;
+ srPoliciesDetails2.sidLists = srv6SidLists2;
+ srPoliciesDetails2.isEncap = ByteDataTranslator.BYTE_TRUE;
+ srPoliciesDetails2.type = 0;
+
+ replyDump.srPoliciesDetails = Arrays.asList(srPoliciesDetails1, srPoliciesDetails2);
+
+ when(readCtx.getModificationCache()).thenReturn(modificationCache);
+ when(readCtx.getMappingContext()).thenReturn(mappingContext);
+ when(modificationCache.get(any())).thenReturn(replyDump);
+ }
+}
diff --git a/srv6/srv6-impl/src/test/java/io/fd/hc2vpp/srv6/read/policy/PolicyCustomizerTest.java b/srv6/srv6-impl/src/test/java/io/fd/hc2vpp/srv6/read/policy/PolicyCustomizerTest.java
new file mode 100644
index 000000000..49c3942c5
--- /dev/null
+++ b/srv6/srv6-impl/src/test/java/io/fd/hc2vpp/srv6/read/policy/PolicyCustomizerTest.java
@@ -0,0 +1,143 @@
+/*
+ * Copyright (c) 2018 Bell Canada, Pantheon Technologies and/or its affiliates.
+ *
+ * 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 io.fd.hc2vpp.srv6.read.policy;
+
+import static org.mockito.ArgumentMatchers.any;
+import static org.mockito.ArgumentMatchers.eq;
+import static org.mockito.Mockito.when;
+
+import com.google.common.collect.ImmutableSet;
+import io.fd.hc2vpp.srv6.Srv6PolicyIIds;
+import io.fd.hc2vpp.srv6.util.Srv6Util;
+import io.fd.honeycomb.translate.MappingContext;
+import io.fd.honeycomb.translate.read.ReadFailedException;
+import java.util.List;
+import org.junit.Assert;
+import org.junit.Test;
+import org.opendaylight.yang.gen.v1.http.cisco.com.ns.yang.oc.srte.policy.rev170918.DataplaneType;
+import org.opendaylight.yang.gen.v1.http.cisco.com.ns.yang.oc.srte.policy.rev170918.PathExplicitlyDefined;
+import org.opendaylight.yang.gen.v1.http.cisco.com.ns.yang.oc.srte.policy.rev170918.ProvisioningMethodConfig;
+import org.opendaylight.yang.gen.v1.http.cisco.com.ns.yang.oc.srte.policy.rev170918.SegmentListOperState;
+import org.opendaylight.yang.gen.v1.http.cisco.com.ns.yang.oc.srte.policy.rev170918.candidate.paths.candidate.paths.CandidatePath;
+import org.opendaylight.yang.gen.v1.http.cisco.com.ns.yang.oc.srte.policy.rev170918.path.segment.list.properties.segment.lists.SegmentList;
+import org.opendaylight.yang.gen.v1.http.cisco.com.ns.yang.oc.srte.policy.rev170918.policies.PoliciesBuilder;
+import org.opendaylight.yang.gen.v1.http.cisco.com.ns.yang.oc.srte.policy.rev170918.policies.policies.Policy;
+import org.opendaylight.yang.gen.v1.http.cisco.com.ns.yang.oc.srte.policy.rev170918.policies.policies.PolicyBuilder;
+import org.opendaylight.yang.gen.v1.http.cisco.com.ns.yang.oc.srte.policy.rev170918.policies.policies.PolicyKey;
+import org.opendaylight.yang.gen.v1.urn.honeycomb.params.xml.ns.yang.policy.context.rev180607.srv6.candidate.path.context.attributes.srv6.candidate.path.mappings.Srv6CandidatePathMappingBuilder;
+import org.opendaylight.yang.gen.v1.urn.honeycomb.params.xml.ns.yang.policy.context.rev180607.srv6.policy.context.attributes.srv6.policy.mappings.Srv6PolicyMappingBuilder;
+import org.opendaylight.yangtools.yang.binding.KeyedInstanceIdentifier;
+
+public class PolicyCustomizerTest extends PoliciesTest {
+
+ private PolicyKey POLICY_KEY = new PolicyKey(COLOR_1, ENDPOINT_1);
+ private PolicyKey POLICY_KEY_2 = new PolicyKey(COLOR_2, ENDPOINT_2);
+
+ @Override
+ public void init() {
+ super.init();
+ when(policyCtx.getPolicy(eq(BSID_ADR), any(MappingContext.class))).thenReturn(
+ new Srv6PolicyMappingBuilder().setBsid(BSID_ADR).setColor(COLOR_1)
+ .setEndpoint(ENDPOINT_1.getIpv6Address()).setName(BSID_ADR.getValue()).build());
+ when(policyCtx.getPolicy(eq(BSID_2_ADR), any(MappingContext.class))).thenReturn(
+ new Srv6PolicyMappingBuilder().setBsid(BSID_2_ADR).setColor(COLOR_2)
+ .setEndpoint(ENDPOINT_2.getIpv6Address()).setName(BSID_2_ADR.getValue()).build());
+ when(policyCtx.getPolicyBsid(COLOR_1, ENDPOINT_1.getIpv6Address(), mappingContext)).thenReturn(BSID_ADR);
+ when(policyCtx.getPolicyBsid(COLOR_2, ENDPOINT_2.getIpv6Address(), mappingContext)).thenReturn(BSID_2_ADR);
+
+ when(candidatePathCtx.getCandidatePath(BSID_ADR, mappingContext)).thenReturn(
+ new Srv6CandidatePathMappingBuilder().setBsid(BSID_ADR).setDistinguisher(DISTINGUISHER_1)
+ .setPreference(PREFERENCE_1).setName(BSID_ADR.getValue())
+ .setProvisioningMethod(PROVISIONING_METHOD).build());
+ when(candidatePathCtx.getCandidatePath(BSID_2_ADR, mappingContext)).thenReturn(
+ new Srv6CandidatePathMappingBuilder().setBsid(BSID_2_ADR).setDistinguisher(DISTINGUISHER_2)
+ .setPreference(PREFERENCE_2).setName(BSID_2_ADR.getValue())
+ .setProvisioningMethod(PROVISIONING_METHOD).build());
+ }
+
+ @Test
+ public void getAllIdsTest() throws ReadFailedException {
+ PolicyCustomizer customizer = new PolicyCustomizer(api, policyCtx, candidatePathCtx);
+ List<PolicyKey> policyKeys = customizer.getAllIds(Srv6PolicyIIds.SR_TE_PLS_POL, readCtx);
+
+ Assert.assertNotNull(policyKeys);
+ Assert.assertFalse(policyKeys.isEmpty());
+ Assert.assertEquals(replyDump.srPoliciesDetails.size(), policyKeys.size());
+ Assert.assertTrue(policyKeys.containsAll(ImmutableSet.of(POLICY_KEY, POLICY_KEY_2)));
+ }
+
+ @Test
+ public void readCurrentAttributesTest() throws ReadFailedException {
+ PolicyCustomizer customizer = new PolicyCustomizer(api, policyCtx, candidatePathCtx);
+ PolicyBuilder policyBuilder = new PolicyBuilder();
+ KeyedInstanceIdentifier<Policy, PolicyKey> key = Srv6PolicyIIds.SR_TE_PLS.child(Policy.class, POLICY_KEY);
+ customizer.readCurrentAttributes(key, policyBuilder, readCtx);
+
+ Assert.assertEquals(POLICY_KEY, policyBuilder.getKey());
+ Assert.assertEquals(BSID_ADR.getValue(), policyBuilder.getName());
+ Assert.assertNotNull(customizer.getBuilder(key));
+
+ //verify BSID container
+ Assert.assertNotNull(policyBuilder.getBindingSid());
+ Assert.assertNotNull(policyBuilder.getBindingSid().getState());
+ Assert.assertEquals(DataplaneType.Srv6, policyBuilder.getBindingSid().getState().getType());
+ Assert.assertEquals(BSID_ADR,
+ policyBuilder.getBindingSid().getState().getValue().getIpAddress().getIpv6Address());
+
+ //verify state container
+ Assert.assertNotNull(policyBuilder.getState());
+ Assert.assertEquals(COLOR_1, policyBuilder.getState().getColor());
+ Assert.assertEquals(ENDPOINT_1, policyBuilder.getState().getEndpoint());
+ Assert.assertEquals(BSID_ADR.getValue(), policyBuilder.getState().getName());
+
+ //verify candidate-paths container
+ Assert.assertNotNull(policyBuilder.getCandidatePaths());
+ Assert.assertNotNull(policyBuilder.getCandidatePaths().getCandidatePath());
+ Assert.assertEquals(1, policyBuilder.getCandidatePaths().getCandidatePath().size());
+ CandidatePath candidatePath = policyBuilder.getCandidatePaths().getCandidatePath().get(0);
+ Assert.assertEquals(DISTINGUISHER_1, candidatePath.getDistinguisher().longValue());
+ Assert.assertEquals(PREFERENCE_1, candidatePath.getPreference().longValue());
+ Assert.assertEquals(ProvisioningMethodConfig.class, candidatePath.getProvisioningMethod());
+
+ //verify candidate-paths/state container
+ Assert.assertNotNull(candidatePath.getState());
+ Assert.assertEquals(DISTINGUISHER_1, candidatePath.getState().getDistinguisher().longValue());
+ Assert.assertEquals(PREFERENCE_1, candidatePath.getState().getPreference().longValue());
+ Assert.assertEquals(ProvisioningMethodConfig.class, candidatePath.getState().getProvisioningMethod());
+ Assert.assertEquals(PathExplicitlyDefined.class, candidatePath.getState().getComputationMethod());
+ Assert.assertNotNull(candidatePath.getBindingSid());
+ Assert.assertNotNull(candidatePath.getBindingSid().getState());
+ Assert.assertEquals(BSID_ADR.getValue(),
+ candidatePath.getBindingSid().getState().getValue().getIpAddress().getIpv6Address().getValue());
+
+ //verify candidate-paths/segment-lists container
+ Assert.assertNotNull(candidatePath.getSegmentLists());
+ Assert.assertNotNull(candidatePath.getSegmentLists().getSegmentList());
+ Assert.assertEquals(1, candidatePath.getSegmentLists().getSegmentList().size());
+ SegmentList segmentList = candidatePath.getSegmentLists().getSegmentList().get(0);
+ Assert.assertEquals(Srv6Util.getCandidatePathName(BSID_ADR, WEIGHT), segmentList.getName());
+ Assert.assertNotNull(segmentList.getState());
+ Assert.assertEquals(WEIGHT, segmentList.getState().getWeight().intValue());
+ Assert.assertEquals(SegmentListOperState.ACTIVE, segmentList.getState().getOperState());
+
+ //verify merge
+ PoliciesBuilder policiesBuilder = new PoliciesBuilder();
+ Policy policy = policyBuilder.build();
+ customizer.merge(policiesBuilder, policy);
+ Assert.assertEquals(policy, policiesBuilder.getPolicy().get(0));
+ }
+}
diff --git a/srv6/srv6-impl/src/test/java/io/fd/hc2vpp/srv6/read/steering/InterfaceCustomizerTest.java b/srv6/srv6-impl/src/test/java/io/fd/hc2vpp/srv6/read/steering/InterfaceCustomizerTest.java
new file mode 100644
index 000000000..bc5ad681f
--- /dev/null
+++ b/srv6/srv6-impl/src/test/java/io/fd/hc2vpp/srv6/read/steering/InterfaceCustomizerTest.java
@@ -0,0 +1,90 @@
+/*
+ * Copyright (c) 2018 Bell Canada, Pantheon Technologies and/or its affiliates.
+ *
+ * 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 io.fd.hc2vpp.srv6.read.steering;
+
+import static org.mockito.Mockito.when;
+
+import com.google.common.collect.ImmutableSet;
+import io.fd.hc2vpp.common.translate.util.NamingContext;
+import io.fd.hc2vpp.srv6.Srv6PolicyIIds;
+import io.fd.honeycomb.translate.read.ReadFailedException;
+import java.util.List;
+import org.junit.Assert;
+import org.junit.Test;
+import org.opendaylight.yang.gen.v1.http.cisco.com.ns.yang.oc.srte.policy.rev170918.autoroute.include.AutorouteInclude;
+import org.opendaylight.yang.gen.v1.http.cisco.com.ns.yang.oc.srte.policy.rev170918.policies.policies.Policy;
+import org.opendaylight.yang.gen.v1.http.cisco.com.ns.yang.oc.srte.policy.rev170918.policies.policies.PolicyKey;
+import org.opendaylight.yang.gen.v1.urn.hc2vpp.params.xml.ns.yang.vpp.oc.srte.policy.rev180514.VppL2AutorouteIncludeAugmentation;
+import org.opendaylight.yang.gen.v1.urn.hc2vpp.params.xml.ns.yang.vpp.oc.srte.policy.rev180514.segment.routing.traffic.engineering.policies.policy.autoroute.include.Interfaces;
+import org.opendaylight.yang.gen.v1.urn.hc2vpp.params.xml.ns.yang.vpp.oc.srte.policy.rev180514.segment.routing.traffic.engineering.policies.policy.autoroute.include.InterfacesBuilder;
+import org.opendaylight.yang.gen.v1.urn.hc2vpp.params.xml.ns.yang.vpp.oc.srte.policy.rev180514.sr.interfaces.Interface;
+import org.opendaylight.yang.gen.v1.urn.hc2vpp.params.xml.ns.yang.vpp.oc.srte.policy.rev180514.sr.interfaces.InterfaceBuilder;
+import org.opendaylight.yang.gen.v1.urn.hc2vpp.params.xml.ns.yang.vpp.oc.srte.policy.rev180514.sr.interfaces.InterfaceKey;
+import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.IpAddress;
+import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.Ipv6Address;
+import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
+
+public class InterfaceCustomizerTest extends SteeringTest {
+
+ private static final String LOCAL_0 = "local0";
+ private static final InterfaceKey L2_KEY = new InterfaceKey(LOCAL_0);
+
+ private NamingContext interfaceContext;
+
+ @Override
+ protected void init() {
+ super.init();
+ defineMapping(mappingContext, LOCAL_0, 1, "interface-context");
+ defineMapping(mappingContext, "vlan0", 2, "interface-context");
+ when(ctx.getMappingContext()).thenReturn(mappingContext);
+ when(readCtx.getMappingContext()).thenReturn(mappingContext);
+ interfaceContext = new NamingContext("iface", "interface-context");
+ }
+
+ @Test
+ public void readCurrentAttributesTest() throws ReadFailedException {
+ InstanceIdentifier<Interface> key =
+ Srv6PolicyIIds.SR_TE_PLS.child(Policy.class, new PolicyKey(0L, new IpAddress(new Ipv6Address("e::1"))))
+ .child(AutorouteInclude.class)
+ .augmentation(VppL2AutorouteIncludeAugmentation.class).child(Interfaces.class)
+ .child(Interface.class, L2_KEY);
+
+ InterfaceCustomizer customizer = new InterfaceCustomizer(api, interfaceContext);
+ InterfaceBuilder builder = customizer.getBuilder(key);
+ customizer.readCurrentAttributes(key, builder, readCtx);
+
+ Assert.assertEquals(L2_KEY, builder.getKey());
+ Assert.assertEquals(LOCAL_0, builder.getInputInterface());
+
+ InterfacesBuilder policyBuilder = new InterfacesBuilder();
+ customizer.merge(policyBuilder, builder.build());
+
+ Assert.assertNotNull(policyBuilder.getInterface());
+ Assert.assertEquals(1, policyBuilder.getInterface().size());
+ }
+
+ @Test
+ public void getAllIdsTest() throws ReadFailedException {
+ InterfaceCustomizer customizer = new InterfaceCustomizer(api, interfaceContext);
+ List<InterfaceKey> l2SteeringKeys = customizer.getAllIds(Srv6PolicyIIds.SR_TE_PLS_POL_AI_IFCS_IFC, readCtx);
+
+ Assert.assertNotNull(l2SteeringKeys);
+ Assert.assertFalse(l2SteeringKeys.isEmpty());
+ Assert.assertEquals(1, l2SteeringKeys.size());
+ Assert.assertTrue(l2SteeringKeys.containsAll(ImmutableSet.of(L2_KEY)));
+ }
+}
diff --git a/srv6/srv6-impl/src/test/java/io/fd/hc2vpp/srv6/read/steering/PrefixCustomizerTest.java b/srv6/srv6-impl/src/test/java/io/fd/hc2vpp/srv6/read/steering/PrefixCustomizerTest.java
new file mode 100644
index 000000000..56850078f
--- /dev/null
+++ b/srv6/srv6-impl/src/test/java/io/fd/hc2vpp/srv6/read/steering/PrefixCustomizerTest.java
@@ -0,0 +1,78 @@
+/*
+ * Copyright (c) 2018 Bell Canada, Pantheon Technologies and/or its affiliates.
+ *
+ * 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 io.fd.hc2vpp.srv6.read.steering;
+
+import com.google.common.collect.ImmutableSet;
+import io.fd.hc2vpp.srv6.Srv6PolicyIIds;
+import io.fd.honeycomb.translate.read.ReadFailedException;
+import java.util.List;
+import org.junit.Assert;
+import org.junit.Test;
+import org.opendaylight.yang.gen.v1.http.cisco.com.ns.yang.oc.srte.policy.rev170918.autoroute.include.AutorouteInclude;
+import org.opendaylight.yang.gen.v1.http.cisco.com.ns.yang.oc.srte.policy.rev170918.policies.policies.Policy;
+import org.opendaylight.yang.gen.v1.http.cisco.com.ns.yang.oc.srte.policy.rev170918.policies.policies.PolicyKey;
+import org.opendaylight.yang.gen.v1.http.cisco.com.ns.yang.oc.srte.policy.rev170918.prefixes.properties.Prefixes;
+import org.opendaylight.yang.gen.v1.http.cisco.com.ns.yang.oc.srte.policy.rev170918.prefixes.properties.PrefixesBuilder;
+import org.opendaylight.yang.gen.v1.http.cisco.com.ns.yang.oc.srte.policy.rev170918.prefixes.properties.prefixes.Prefix;
+import org.opendaylight.yang.gen.v1.http.cisco.com.ns.yang.oc.srte.policy.rev170918.prefixes.properties.prefixes.PrefixBuilder;
+import org.opendaylight.yang.gen.v1.http.cisco.com.ns.yang.oc.srte.policy.rev170918.prefixes.properties.prefixes.PrefixKey;
+import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.IpAddress;
+import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.IpPrefix;
+import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.Ipv4Prefix;
+import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.Ipv6Address;
+import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.Ipv6Prefix;
+import org.opendaylight.yangtools.yang.binding.KeyedInstanceIdentifier;
+
+public class PrefixCustomizerTest extends SteeringTest {
+
+ private static final IpPrefix IPV6_PREFIX = new IpPrefix(new Ipv6Prefix("a::/64"));
+ private static final PrefixKey L3_KEY = new PrefixKey(IPV6_PREFIX);
+ private static final IpPrefix IPV4_PREFIX = new IpPrefix(new Ipv4Prefix("10.0.0.1/24"));
+ private static final PrefixKey L3_KEY_2 = new PrefixKey(IPV4_PREFIX);
+
+ @Test
+ public void readCurrentAttributesTest() throws ReadFailedException {
+ KeyedInstanceIdentifier<Prefix, PrefixKey> key =
+ Srv6PolicyIIds.SR_TE_PLS.child(Policy.class, new PolicyKey(0L, new IpAddress(new Ipv6Address("e::1"))))
+ .child(AutorouteInclude.class).child(Prefixes.class).child(Prefix.class, L3_KEY);
+
+ PrefixCustomizer customizer = new PrefixCustomizer(api);
+ PrefixBuilder builder = customizer.getBuilder(key);
+
+ customizer.readCurrentAttributes(key, builder, readCtx);
+
+ Assert.assertEquals(L3_KEY, builder.getKey());
+ Assert.assertEquals(IPV6_PREFIX, builder.getIpPrefix());
+
+ PrefixesBuilder policyBuilder = new PrefixesBuilder();
+ customizer.merge(policyBuilder, builder.build());
+
+ Assert.assertNotNull(policyBuilder.getPrefix());
+ Assert.assertEquals(1, policyBuilder.getPrefix().size());
+ }
+
+ @Test
+ public void getAllIdsTest() throws ReadFailedException {
+ PrefixCustomizer customizer = new PrefixCustomizer(api);
+ List<PrefixKey> l3SteeringKeys = customizer.getAllIds(Srv6PolicyIIds.SR_TE_PLS_POL_AI_PFS_PF_IID, readCtx);
+
+ Assert.assertNotNull(l3SteeringKeys);
+ Assert.assertFalse(l3SteeringKeys.isEmpty());
+ Assert.assertEquals(2, l3SteeringKeys.size());
+ Assert.assertTrue(l3SteeringKeys.containsAll(ImmutableSet.of(L3_KEY, L3_KEY_2)));
+ }
+}
diff --git a/srv6/srv6-impl/src/test/java/io/fd/hc2vpp/srv6/read/steering/PrefixesStateCustomizerTest.java b/srv6/srv6-impl/src/test/java/io/fd/hc2vpp/srv6/read/steering/PrefixesStateCustomizerTest.java
new file mode 100644
index 000000000..951f94d1d
--- /dev/null
+++ b/srv6/srv6-impl/src/test/java/io/fd/hc2vpp/srv6/read/steering/PrefixesStateCustomizerTest.java
@@ -0,0 +1,54 @@
+/*
+ * Copyright (c) 2018 Bell Canada, Pantheon Technologies and/or its affiliates.
+ *
+ * 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 io.fd.hc2vpp.srv6.read.steering;
+
+import io.fd.hc2vpp.srv6.Srv6PolicyIIds;
+import io.fd.honeycomb.translate.read.ReadFailedException;
+import org.junit.Assert;
+import org.junit.Test;
+import org.opendaylight.yang.gen.v1.http.cisco.com.ns.yang.oc.srte.policy.rev170918.autoroute.include.AutorouteInclude;
+import org.opendaylight.yang.gen.v1.http.cisco.com.ns.yang.oc.srte.policy.rev170918.policies.policies.Policy;
+import org.opendaylight.yang.gen.v1.http.cisco.com.ns.yang.oc.srte.policy.rev170918.policies.policies.PolicyKey;
+import org.opendaylight.yang.gen.v1.http.cisco.com.ns.yang.oc.srte.policy.rev170918.prefixes.properties.Prefixes;
+import org.opendaylight.yang.gen.v1.http.cisco.com.ns.yang.oc.srte.policy.rev170918.prefixes.properties.PrefixesBuilder;
+import org.opendaylight.yang.gen.v1.http.cisco.com.ns.yang.oc.srte.policy.rev170918.prefixes.properties.prefixes.State;
+import org.opendaylight.yang.gen.v1.http.cisco.com.ns.yang.oc.srte.policy.rev170918.prefixes.properties.prefixes.StateBuilder;
+import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.IpAddress;
+import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.Ipv6Address;
+import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
+
+public class PrefixesStateCustomizerTest extends SteeringTest {
+
+ @Test
+ public void readCurrentAttributesTest() throws ReadFailedException {
+ InstanceIdentifier<State> iId =
+ Srv6PolicyIIds.SR_TE_PLS.child(Policy.class, new PolicyKey(0L, new IpAddress(new Ipv6Address("e::1"))))
+ .child(AutorouteInclude.class).child(Prefixes.class).child(State.class);
+
+ PrefixesStateCustomizer customizer = new PrefixesStateCustomizer(api);
+ StateBuilder builder = customizer.getBuilder(Srv6PolicyIIds.SR_TE_PLS_POL_AI_PFS_STATE);
+
+ customizer.readCurrentAttributes(iId, builder, readCtx);
+ Assert.assertEquals(false, builder.isPrefixesAll());
+
+ PrefixesBuilder parentBuilder = new PrefixesBuilder();
+ customizer.merge(parentBuilder, builder.build());
+
+ Assert.assertNotNull(parentBuilder.getState());
+ Assert.assertEquals(false, parentBuilder.getState().isPrefixesAll());
+ }
+}
diff --git a/srv6/srv6-impl/src/test/java/io/fd/hc2vpp/srv6/read/steering/SteeringTest.java b/srv6/srv6-impl/src/test/java/io/fd/hc2vpp/srv6/read/steering/SteeringTest.java
new file mode 100644
index 000000000..57f4fe806
--- /dev/null
+++ b/srv6/srv6-impl/src/test/java/io/fd/hc2vpp/srv6/read/steering/SteeringTest.java
@@ -0,0 +1,82 @@
+/*
+ * Copyright (c) 2018 Bell Canada, Pantheon Technologies and/or its affiliates.
+ *
+ * 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 io.fd.hc2vpp.srv6.read.steering;
+
+import static org.mockito.ArgumentMatchers.any;
+import static org.mockito.Mockito.when;
+
+import io.fd.hc2vpp.common.translate.util.AddressTranslator;
+import io.fd.hc2vpp.srv6.write.sid.request.LocalSidRequestTest;
+import io.fd.honeycomb.translate.ModificationCache;
+import io.fd.honeycomb.translate.read.ReadContext;
+import io.fd.vpp.jvpp.core.dto.SrSteeringPolDetails;
+import io.fd.vpp.jvpp.core.dto.SrSteeringPolDetailsReplyDump;
+import io.fd.vpp.jvpp.core.types.Srv6Sid;
+import java.util.ArrayList;
+import org.mockito.Mock;
+import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.IpAddress;
+import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.Ipv4Address;
+import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.Ipv6Address;
+
+public abstract class SteeringTest extends LocalSidRequestTest {
+ private static final Ipv6Address A = new Ipv6Address("a::");
+ private static final Ipv4Address B = new Ipv4Address("10.0.0.1");
+ static final Ipv6Address BSID_ADR = new Ipv6Address("a::e");
+
+ @Mock
+ ReadContext readCtx;
+
+ @Mock
+ ModificationCache modificationCache;
+
+ SrSteeringPolDetailsReplyDump replyDump = new SrSteeringPolDetailsReplyDump();
+
+ @Override
+ protected void init() {
+ when(readCtx.getModificationCache()).thenReturn(modificationCache);
+ when(modificationCache.get(any())).thenReturn(replyDump);
+ replyDump.srSteeringPolDetails = new ArrayList<>();
+ SrSteeringPolDetails polDetailsA = new SrSteeringPolDetails();
+ polDetailsA.trafficType = 6;
+ polDetailsA.fibTable = 1;
+ polDetailsA.prefixAddr = AddressTranslator.INSTANCE.ipAddressToArray(new IpAddress(A));
+ Srv6Sid bsidA = new Srv6Sid();
+ bsidA.addr = AddressTranslator.INSTANCE.ipAddressToArray(new IpAddress(BSID_ADR));
+ polDetailsA.bsid = bsidA;
+ polDetailsA.maskWidth = 64;
+
+ SrSteeringPolDetails polDetailsB = new SrSteeringPolDetails();
+ polDetailsB.trafficType = 4;
+ polDetailsB.fibTable = 0;
+ polDetailsB.prefixAddr = AddressTranslator.INSTANCE.ipAddressToArray(new IpAddress(B));
+ Srv6Sid bsidB = new Srv6Sid();
+ bsidB.addr = AddressTranslator.INSTANCE.ipAddressToArray(new IpAddress(BSID_ADR));
+ polDetailsB.bsid = bsidB;
+ polDetailsB.maskWidth = 24;
+
+ SrSteeringPolDetails polDetailsC = new SrSteeringPolDetails();
+ polDetailsC.trafficType = 2;
+ polDetailsC.swIfIndex = 1;
+ bsidA.addr = AddressTranslator.INSTANCE.ipAddressToArray(new IpAddress(BSID_ADR));
+ polDetailsA.bsid = bsidA;
+
+ replyDump.srSteeringPolDetails.add(polDetailsA);
+ replyDump.srSteeringPolDetails.add(polDetailsB);
+ replyDump.srSteeringPolDetails.add(polDetailsC);
+ }
+}
diff --git a/srv6/srv6-impl/src/test/java/io/fd/hc2vpp/srv6/util/JvppRequestTest.java b/srv6/srv6-impl/src/test/java/io/fd/hc2vpp/srv6/util/JvppRequestTest.java
index cd3369956..f241716d5 100644
--- a/srv6/srv6-impl/src/test/java/io/fd/hc2vpp/srv6/util/JvppRequestTest.java
+++ b/srv6/srv6-impl/src/test/java/io/fd/hc2vpp/srv6/util/JvppRequestTest.java
@@ -20,6 +20,7 @@ import com.google.common.collect.ImmutableSet;
import com.google.inject.Inject;
import io.fd.hc2vpp.common.test.util.FutureProducer;
import io.fd.hc2vpp.common.test.util.NamingContextHelper;
+import io.fd.hc2vpp.common.translate.util.AddressTranslator;
import io.fd.hc2vpp.common.translate.util.NamingContext;
import io.fd.hc2vpp.srv6.util.function.LocalSidFunctionReadBindingRegistry;
import io.fd.hc2vpp.srv6.util.function.LocalSidFunctionWriteBindingRegistry;
@@ -35,12 +36,18 @@ import io.fd.honeycomb.test.tools.HoneycombTestRunner;
import io.fd.honeycomb.test.tools.annotations.SchemaContextProvider;
import io.fd.honeycomb.translate.MappingContext;
import io.fd.honeycomb.translate.write.WriteContext;
+import io.fd.vpp.jvpp.core.dto.SrSteeringAddDel;
import io.fd.vpp.jvpp.core.future.FutureJVppCore;
+import org.junit.Assert;
import org.junit.Before;
import org.junit.runner.RunWith;
import org.mockito.Mock;
import org.mockito.MockitoAnnotations;
import org.opendaylight.mdsal.binding.generator.impl.ModuleInfoBackedContext;
+import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.IpAddress;
+import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.IpPrefix;
+import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.Ipv6Address;
+
@RunWith(HoneycombTestRunner.class)
public abstract class JvppRequestTest implements FutureProducer, NamingContextHelper {
@@ -49,6 +56,14 @@ public abstract class JvppRequestTest implements FutureProducer, NamingContextHe
protected static final LocalSidFunctionWriteBindingRegistry WRITE_REGISTRY =
new LocalSidFunctionWriteBindingRegistry();
+ protected static final String NAMED_SEG_LISTS_PATH = "/hc2vpp-oc-srte-policy:segment-routing" +
+ "/hc2vpp-oc-srte-policy:traffic-engineering" +
+ "/hc2vpp-oc-srte-policy:named-segment-lists";
+
+ protected static final String POLICIES_LISTS_PATH = "/hc2vpp-oc-srte-policy:segment-routing" +
+ "/hc2vpp-oc-srte-policy:traffic-engineering" +
+ "/hc2vpp-oc-srte-policy:policies";
+
@Inject
@Mock
protected static FutureJVppCore api;
@@ -104,9 +119,35 @@ public abstract class JvppRequestTest implements FutureProducer, NamingContextHe
org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.$YangModuleInfoImpl
.getInstance(),
org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.$YangModuleInfoImpl
+ .getInstance(),
+ org.opendaylight.yang.gen.v1.http.cisco.com.ns.yang.oc.srte.policy.rev170918.$YangModuleInfoImpl
+ .getInstance(),
+ org.opendaylight.yang.gen.v1.urn.hc2vpp.params.xml.ns.yang.vpp.oc.srte.policy.rev180514.$YangModuleInfoImpl
.getInstance()));
return mibContext;
}
protected abstract void init();
+
+ protected void testSrSteeringAddDelValidity(SrSteeringAddDel srSteering, byte isDel, byte trafficType, boolean ipV6,
+ Ipv6Address bsidAdr, IpPrefix prefix) {
+ Assert.assertEquals((long) 0, srSteering.tableId);
+ Assert.assertArrayEquals(AddressTranslator.INSTANCE.ipAddressToArray(new IpAddress(bsidAdr)),
+ srSteering.bsidAddr);
+ Assert.assertEquals(isDel, srSteering.isDel);
+ Assert.assertEquals(trafficType, srSteering.trafficType);
+
+ if (ipV6) {
+ Assert.assertArrayEquals(AddressTranslator.INSTANCE.ipv6AddressPrefixToArray(prefix.getIpv6Prefix()),
+ srSteering.prefixAddr);
+ Assert.assertEquals(AddressTranslator.INSTANCE.extractPrefix(prefix.getIpv6Prefix()),
+ srSteering.maskWidth);
+ } else {
+ Assert.assertArrayEquals(AddressTranslator.INSTANCE.ipv4AddressPrefixToArray(prefix.getIpv4Prefix()),
+ srSteering.prefixAddr);
+ Assert.assertEquals(AddressTranslator.INSTANCE.extractPrefix(prefix.getIpv4Prefix()),
+ srSteering.maskWidth);
+ }
+
+ }
}
diff --git a/srv6/srv6-impl/src/test/java/io/fd/hc2vpp/srv6/util/Srv6UtilTest.java b/srv6/srv6-impl/src/test/java/io/fd/hc2vpp/srv6/util/Srv6UtilTest.java
new file mode 100644
index 000000000..89d97be31
--- /dev/null
+++ b/srv6/srv6-impl/src/test/java/io/fd/hc2vpp/srv6/util/Srv6UtilTest.java
@@ -0,0 +1,64 @@
+/*
+ * Copyright (c) 2018 Bell Canada, Pantheon Technologies and/or its affiliates.
+ *
+ * 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 io.fd.hc2vpp.srv6.util;
+
+import static org.mockito.Mockito.when;
+
+import com.google.common.base.Optional;
+import io.fd.hc2vpp.srv6.Srv6PolicyIIds;
+import io.fd.honeycomb.test.tools.annotations.InjectTestData;
+import org.junit.Assert;
+import org.junit.Test;
+import org.opendaylight.yang.gen.v1.http.cisco.com.ns.yang.oc.srte.policy.rev170918.policies.Policies;
+import org.opendaylight.yang.gen.v1.http.cisco.com.ns.yang.oc.srte.policy.rev170918.policies.policies.Policy;
+import org.opendaylight.yang.gen.v1.http.cisco.com.ns.yang.oc.srte.policy.rev170918.policies.policies.PolicyKey;
+import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.IpAddress;
+import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.Ipv6Address;
+import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
+
+public class Srv6UtilTest extends JvppRequestTest{
+ private static final Ipv6Address BSID = new Ipv6Address("a::e");
+ private static final String CANDIDATE_PATH_NAME = BSID.getValue() + "-0";
+ private static final PolicyKey POLICY_KEY = new PolicyKey(1L, new IpAddress(new Ipv6Address("e::1")));
+ private static final InstanceIdentifier<Policy> POLICY_IID =
+ Srv6PolicyIIds.SR_TE_PLS.child(Policy.class, POLICY_KEY);
+
+ @InjectTestData(resourcePath = "/policy.json", id = POLICIES_LISTS_PATH)
+ private Policies policies;
+
+ @Override
+ protected void init() {
+ when(ctx.readAfter(Srv6PolicyIIds.SR_TE_PLS.child(Policy.class, POLICY_KEY)))
+ .thenReturn(Optional.of(policies.getPolicy().get(0)));
+ }
+
+ @Test
+ public void getCandidatePathNameTest() {
+ Assert.assertEquals(CANDIDATE_PATH_NAME, Srv6Util.getCandidatePathName(BSID, 0L));
+ }
+
+ @Test
+ public void extractBsidTest() {
+ Assert.assertEquals(BSID.getValue(), Srv6Util.extractBsid(POLICY_IID, ctx, true).getValue());
+ }
+
+ @Test
+ public void extractVrfFibTest() {
+ Assert.assertEquals(0, Srv6Util.extractVrfFib(POLICY_IID, ctx, true));
+ }
+}
diff --git a/srv6/srv6-impl/src/test/java/io/fd/hc2vpp/srv6/write/policy/PolicyCustomizerTest.java b/srv6/srv6-impl/src/test/java/io/fd/hc2vpp/srv6/write/policy/PolicyCustomizerTest.java
new file mode 100644
index 000000000..80a3149e2
--- /dev/null
+++ b/srv6/srv6-impl/src/test/java/io/fd/hc2vpp/srv6/write/policy/PolicyCustomizerTest.java
@@ -0,0 +1,166 @@
+/*
+ * Copyright (c) 2018 Bell Canada, Pantheon Technologies and/or its affiliates.
+ *
+ * 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 io.fd.hc2vpp.srv6.write.policy;
+
+import static io.fd.hc2vpp.srv6.util.Srv6Util.getCandidatePathName;
+import static org.mockito.ArgumentMatchers.any;
+import static org.mockito.Mockito.times;
+import static org.mockito.Mockito.verify;
+import static org.mockito.Mockito.when;
+
+import com.google.common.base.Optional;
+import io.fd.hc2vpp.common.translate.util.AddressTranslator;
+import io.fd.hc2vpp.common.translate.util.ByteDataTranslator;
+import io.fd.hc2vpp.fib.management.FibManagementIIds;
+import io.fd.hc2vpp.srv6.Srv6PolicyIIds;
+import io.fd.hc2vpp.srv6.util.CandidatePathContextManager;
+import io.fd.hc2vpp.srv6.util.JvppRequestTest;
+import io.fd.hc2vpp.srv6.util.PolicyContextManager;
+import io.fd.honeycomb.test.tools.annotations.InjectTestData;
+import io.fd.honeycomb.translate.write.WriteFailedException;
+import io.fd.vpp.jvpp.core.dto.SrPolicyAdd;
+import io.fd.vpp.jvpp.core.dto.SrPolicyAddReply;
+import io.fd.vpp.jvpp.core.dto.SrPolicyDel;
+import io.fd.vpp.jvpp.core.dto.SrPolicyDelReply;
+import io.fd.vpp.jvpp.core.dto.SrPolicyMod;
+import io.fd.vpp.jvpp.core.dto.SrPolicyModReply;
+import org.junit.Assert;
+import org.junit.Test;
+import org.mockito.ArgumentCaptor;
+import org.mockito.Captor;
+import org.mockito.Mock;
+import org.opendaylight.yang.gen.v1.http.cisco.com.ns.yang.oc.srte.policy.rev170918.named.segment.lists.NamedSegmentLists;
+import org.opendaylight.yang.gen.v1.http.cisco.com.ns.yang.oc.srte.policy.rev170918.named.segment.lists.named.segment.lists.NamedSegmentList;
+import org.opendaylight.yang.gen.v1.http.cisco.com.ns.yang.oc.srte.policy.rev170918.named.segment.lists.named.segment.lists.NamedSegmentListKey;
+import org.opendaylight.yang.gen.v1.http.cisco.com.ns.yang.oc.srte.policy.rev170918.policies.Policies;
+import org.opendaylight.yang.gen.v1.http.cisco.com.ns.yang.oc.srte.policy.rev170918.policies.policies.Policy;
+import org.opendaylight.yang.gen.v1.http.cisco.com.ns.yang.oc.srte.policy.rev170918.policies.policies.PolicyKey;
+import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.IpAddress;
+import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.Ipv6Address;
+import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.Ipv6AddressNoZone;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.vpp.fib.table.management.rev180521.Ipv6;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.vpp.fib.table.management.rev180521.VniReference;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.vpp.fib.table.management.rev180521.vpp.fib.table.management.fib.tables.Table;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.vpp.fib.table.management.rev180521.vpp.fib.table.management.fib.tables.TableBuilder;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.vpp.fib.table.management.rev180521.vpp.fib.table.management.fib.tables.TableKey;
+import org.opendaylight.yangtools.yang.binding.KeyedInstanceIdentifier;
+
+public class PolicyCustomizerTest extends JvppRequestTest {
+
+ private static final VniReference TABLE_ID = new VniReference(0L);
+ private static final Ipv6Address BSID_ADR = new Ipv6Address("a::e");
+ private static final String PATH_NAME = getCandidatePathName(BSID_ADR, 0L);
+ private static final String PATH_NAME_2 = getCandidatePathName(BSID_ADR, 1L);
+ private static final Ipv6AddressNoZone A_ADDR = new Ipv6AddressNoZone("a::");
+ private static final Ipv6AddressNoZone B_ADDR = new Ipv6AddressNoZone("b::");
+ private static final Ipv6AddressNoZone C_ADDR = new Ipv6AddressNoZone("c::");
+ private static final PolicyKey POLICY_KEY = new PolicyKey(1L, new IpAddress(new Ipv6Address("e::1")));
+ private static final KeyedInstanceIdentifier<Table, TableKey> VRF_IID =
+ FibManagementIIds.FM_FIB_TABLES.child(Table.class, new TableKey(Ipv6.class, TABLE_ID));
+ private static final Table VRF_TABLE = new TableBuilder().setKey(VRF_IID.getKey()).setAddressFamily(Ipv6.class)
+ .setTableId(TABLE_ID).setName("VRF-0").build();
+
+ @InjectTestData(resourcePath = "/named-segments.json", id = NAMED_SEG_LISTS_PATH)
+ private NamedSegmentLists namedSegmentLists;
+ @InjectTestData(resourcePath = "/policy.json", id = POLICIES_LISTS_PATH)
+ private Policies policies;
+
+ @Mock
+ private PolicyContextManager policyCtx;
+ @Mock
+ private CandidatePathContextManager candidatePathCtx;
+
+ @Captor
+ private ArgumentCaptor<SrPolicyAdd> requestcaptorAdd;
+ @Captor
+ private ArgumentCaptor<SrPolicyDel> requestcaptorDel;
+ @Captor
+ private ArgumentCaptor<SrPolicyMod> requestcaptorMod;
+
+ @Override
+ protected void init() {
+ when(api.srPolicyAdd(any())).thenReturn(future(new SrPolicyAddReply()));
+ when(api.srPolicyDel(any())).thenReturn(future(new SrPolicyDelReply()));
+ when(api.srPolicyMod(any())).thenReturn(future(new SrPolicyModReply()));
+ when(ctx.readAfter(
+ Srv6PolicyIIds.SR_TE_NSLS.child(NamedSegmentList.class, new NamedSegmentListKey(PATH_NAME))))
+ .thenReturn(Optional.of(namedSegmentLists.getNamedSegmentList().get(0)));
+ when(ctx.readAfter(
+ Srv6PolicyIIds.SR_TE_NSLS.child(NamedSegmentList.class, new NamedSegmentListKey(PATH_NAME_2))))
+ .thenReturn(Optional.of(namedSegmentLists.getNamedSegmentList().get(1)));
+ when(ctx.readAfter(Srv6PolicyIIds.SR_TE_PLS.child(Policy.class, POLICY_KEY)))
+ .thenReturn(Optional.of(policies.getPolicy().get(0)));
+ when(ctx.readBefore(Srv6PolicyIIds.SR_TE_PLS.child(Policy.class, POLICY_KEY)))
+ .thenReturn(Optional.of(policies.getPolicy().get(0)));
+ when(ctx.readAfter(VRF_IID)).thenReturn(Optional.of(VRF_TABLE));
+ }
+
+ @Test
+ public void writeCurrentAttributesTest() throws WriteFailedException {
+ PolicyCustomizer customizer = new PolicyCustomizer(api, policyCtx, candidatePathCtx);
+ customizer.writeCurrentAttributes(Srv6PolicyIIds.SR_TE_PLS.child(Policy.class, POLICY_KEY),
+ policies.getPolicy().get(0), ctx);
+
+ verify(api, times(1)).srPolicyAdd(requestcaptorAdd.capture());
+ SrPolicyAdd srPolicy = requestcaptorAdd.getValue();
+
+ verify(api, times(1)).srPolicyMod(requestcaptorMod.capture());
+ SrPolicyMod srPolicyMod = requestcaptorMod.getValue();
+
+ Assert.assertEquals(0L, srPolicy.fibTable);
+ Assert.assertArrayEquals(AddressTranslator.INSTANCE.ipAddressToArray(new IpAddress(BSID_ADR)),
+ srPolicy.bsidAddr);
+ Assert.assertEquals(ByteDataTranslator.BYTE_TRUE, srPolicy.isEncap);
+ Assert.assertEquals(0, srPolicy.type);
+ Assert.assertNotNull(srPolicy.sids);
+ Assert.assertEquals(3, srPolicy.sids.numSids);
+ Assert.assertEquals(0, srPolicy.sids.weight);
+ Assert.assertArrayEquals(AddressTranslator.INSTANCE.ipAddressToArray(new IpAddress(B_ADDR)),
+ srPolicy.sids.sids[0].addr);
+ Assert.assertArrayEquals(AddressTranslator.INSTANCE.ipAddressToArray(new IpAddress(C_ADDR)),
+ srPolicy.sids.sids[1].addr);
+ Assert.assertArrayEquals(AddressTranslator.INSTANCE.ipAddressToArray(new IpAddress(A_ADDR)),
+ srPolicy.sids.sids[2].addr);
+
+ Assert.assertEquals(0L, srPolicyMod.fibTable);
+ Assert.assertArrayEquals(AddressTranslator.INSTANCE.ipAddressToArray(new IpAddress(BSID_ADR)),
+ srPolicyMod.bsidAddr);
+ Assert.assertNotNull(srPolicy.sids);
+ Assert.assertEquals(3, srPolicyMod.sids.numSids);
+ Assert.assertEquals(1, srPolicyMod.sids.weight);
+ Assert.assertArrayEquals(AddressTranslator.INSTANCE.ipAddressToArray(new IpAddress(C_ADDR)),
+ srPolicyMod.sids.sids[0].addr);
+ Assert.assertArrayEquals(AddressTranslator.INSTANCE.ipAddressToArray(new IpAddress(B_ADDR)),
+ srPolicyMod.sids.sids[1].addr);
+ Assert.assertArrayEquals(AddressTranslator.INSTANCE.ipAddressToArray(new IpAddress(A_ADDR)),
+ srPolicyMod.sids.sids[2].addr);
+ }
+
+ @Test
+ public void deleteCurrentAttributesTest() throws WriteFailedException {
+ PolicyCustomizer customizer = new PolicyCustomizer(api, policyCtx, candidatePathCtx);
+ customizer.deleteCurrentAttributes(Srv6PolicyIIds.SR_TE_PLS.child(Policy.class, POLICY_KEY),
+ policies.getPolicy().get(0), ctx);
+
+ verify(api, times(1)).srPolicyDel(requestcaptorDel.capture());
+ SrPolicyDel srPolicy = requestcaptorDel.getValue();
+
+ Assert.assertArrayEquals(AddressTranslator.INSTANCE.ipAddressToArray(new IpAddress(BSID_ADR)),
+ srPolicy.bsidAddr.addr);
+ }
+
+}
diff --git a/srv6/srv6-impl/src/test/java/io/fd/hc2vpp/srv6/write/steering/InterfacesConfigCustomizerTest.java b/srv6/srv6-impl/src/test/java/io/fd/hc2vpp/srv6/write/steering/InterfacesConfigCustomizerTest.java
new file mode 100644
index 000000000..fa4787022
--- /dev/null
+++ b/srv6/srv6-impl/src/test/java/io/fd/hc2vpp/srv6/write/steering/InterfacesConfigCustomizerTest.java
@@ -0,0 +1,117 @@
+/*
+ * Copyright (c) 2018 Bell Canada, Pantheon Technologies and/or its affiliates.
+ *
+ * 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 io.fd.hc2vpp.srv6.write.steering;
+
+import static org.mockito.ArgumentMatchers.any;
+import static org.mockito.Mockito.times;
+import static org.mockito.Mockito.verify;
+import static org.mockito.Mockito.when;
+
+import com.google.common.base.Optional;
+import io.fd.hc2vpp.common.translate.util.AddressTranslator;
+import io.fd.hc2vpp.common.translate.util.ByteDataTranslator;
+import io.fd.hc2vpp.common.translate.util.NamingContext;
+import io.fd.hc2vpp.srv6.Srv6PolicyIIds;
+import io.fd.hc2vpp.srv6.util.JvppRequestTest;
+import io.fd.honeycomb.test.tools.annotations.InjectTestData;
+import io.fd.honeycomb.translate.write.WriteFailedException;
+import io.fd.vpp.jvpp.core.dto.SrSteeringAddDel;
+import io.fd.vpp.jvpp.core.dto.SrSteeringAddDelReply;
+import org.junit.Assert;
+import org.junit.Test;
+import org.mockito.ArgumentCaptor;
+import org.mockito.Captor;
+import org.opendaylight.yang.gen.v1.http.cisco.com.ns.yang.oc.srte.policy.rev170918.autoroute.include.AutorouteInclude;
+import org.opendaylight.yang.gen.v1.http.cisco.com.ns.yang.oc.srte.policy.rev170918.policies.Policies;
+import org.opendaylight.yang.gen.v1.http.cisco.com.ns.yang.oc.srte.policy.rev170918.policies.policies.Policy;
+import org.opendaylight.yang.gen.v1.http.cisco.com.ns.yang.oc.srte.policy.rev170918.policies.policies.PolicyKey;
+import org.opendaylight.yang.gen.v1.urn.hc2vpp.params.xml.ns.yang.vpp.oc.srte.policy.rev180514.VppL2AutorouteIncludeAugmentation;
+import org.opendaylight.yang.gen.v1.urn.hc2vpp.params.xml.ns.yang.vpp.oc.srte.policy.rev180514.segment.routing.traffic.engineering.policies.policy.autoroute.include.Interfaces;
+import org.opendaylight.yang.gen.v1.urn.hc2vpp.params.xml.ns.yang.vpp.oc.srte.policy.rev180514.sr.interfaces.Interface;
+import org.opendaylight.yang.gen.v1.urn.hc2vpp.params.xml.ns.yang.vpp.oc.srte.policy.rev180514.sr.interfaces.InterfaceBuilder;
+import org.opendaylight.yang.gen.v1.urn.hc2vpp.params.xml.ns.yang.vpp.oc.srte.policy.rev180514.sr.interfaces.InterfaceKey;
+import org.opendaylight.yang.gen.v1.urn.hc2vpp.params.xml.ns.yang.vpp.oc.srte.policy.rev180514.sr.interfaces._interface.ConfigBuilder;
+import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.IpAddress;
+import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.Ipv6Address;
+import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
+
+public class InterfacesConfigCustomizerTest extends JvppRequestTest {
+
+ private static final PolicyKey POLICY_KEY = new PolicyKey(1L, new IpAddress(new Ipv6Address("e::1")));
+ private static final Ipv6Address BSID_ADR = new Ipv6Address("a::e");
+ private static final String LOCAL_0 = "local0";
+ private static final InterfaceKey L2_KEY = new InterfaceKey(LOCAL_0);
+ private static final Interface L2_STEERING = new InterfaceBuilder().setInputInterface(LOCAL_0)
+ .setConfig(new ConfigBuilder().setInputInterface(LOCAL_0).build()).build();
+
+ private InstanceIdentifier<Interface> L2_STEER_IID =
+ Srv6PolicyIIds.SR_TE_PLS.child(Policy.class, POLICY_KEY)
+ .child(AutorouteInclude.class)
+ .augmentation(VppL2AutorouteIncludeAugmentation.class).child(Interfaces.class)
+ .child(Interface.class, L2_KEY);
+
+ private NamingContext interfaceContext;
+
+ @InjectTestData(resourcePath = "/policy.json", id = POLICIES_LISTS_PATH)
+ private Policies policies;
+
+ @Captor
+ private ArgumentCaptor<SrSteeringAddDel> requestcaptor;
+
+ @Override
+ protected void init() {
+ when(api.srSteeringAddDel(any())).thenReturn(future(new SrSteeringAddDelReply()));
+ defineMapping(mappingContext, LOCAL_0, 1, "interface-context");
+ defineMapping(mappingContext, "vlan0", 2, "interface-context");
+ when(ctx.getMappingContext()).thenReturn(mappingContext);
+ interfaceContext = new NamingContext("iface", "interface-context");
+ when(ctx.readAfter(Srv6PolicyIIds.SR_TE_PLS.child(Policy.class, POLICY_KEY)))
+ .thenReturn(Optional.of(policies.getPolicy().get(0)));
+ when(ctx.readBefore(Srv6PolicyIIds.SR_TE_PLS.child(Policy.class, POLICY_KEY)))
+ .thenReturn(Optional.of(policies.getPolicy().get(0)));
+ }
+
+ @Test
+ public void writeCurrentAttributesTest() throws WriteFailedException {
+ InterfacesConfigCustomizer customizer = new InterfacesConfigCustomizer(api, interfaceContext);
+ customizer.writeCurrentAttributes(L2_STEER_IID, L2_STEERING, ctx);
+
+ verify(api, times(1)).srSteeringAddDel(requestcaptor.capture());
+ SrSteeringAddDel srSteering = requestcaptor.getValue();
+
+ testRequestValidity(srSteering, ByteDataTranslator.BYTE_FALSE);
+ }
+
+ @Test
+ public void deleteCurrentAttributesV6Test() throws WriteFailedException {
+ InterfacesConfigCustomizer customizer = new InterfacesConfigCustomizer(api, interfaceContext);
+ customizer.deleteCurrentAttributes(L2_STEER_IID, L2_STEERING, ctx);
+
+ verify(api, times(1)).srSteeringAddDel(requestcaptor.capture());
+ SrSteeringAddDel srSteering = requestcaptor.getValue();
+
+ testRequestValidity(srSteering, ByteDataTranslator.BYTE_TRUE);
+ }
+
+ private void testRequestValidity(SrSteeringAddDel srSteering, byte byteTrue) {
+ Assert.assertArrayEquals(AddressTranslator.INSTANCE.ipAddressToArray(new IpAddress(BSID_ADR)),
+ srSteering.bsidAddr);
+ Assert.assertEquals(byteTrue, srSteering.isDel);
+ Assert.assertEquals((byte) 2, srSteering.trafficType);
+ Assert.assertEquals(1, srSteering.swIfIndex);
+ }
+}
diff --git a/srv6/srv6-impl/src/test/java/io/fd/hc2vpp/srv6/write/steering/PrefixCustomizerTest.java b/srv6/srv6-impl/src/test/java/io/fd/hc2vpp/srv6/write/steering/PrefixCustomizerTest.java
new file mode 100644
index 000000000..9335ab61c
--- /dev/null
+++ b/srv6/srv6-impl/src/test/java/io/fd/hc2vpp/srv6/write/steering/PrefixCustomizerTest.java
@@ -0,0 +1,134 @@
+/*
+ * Copyright (c) 2018 Bell Canada, Pantheon Technologies and/or its affiliates.
+ *
+ * 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 io.fd.hc2vpp.srv6.write.steering;
+
+import static org.mockito.ArgumentMatchers.any;
+import static org.mockito.Mockito.times;
+import static org.mockito.Mockito.verify;
+import static org.mockito.Mockito.when;
+
+import com.google.common.base.Optional;
+import io.fd.hc2vpp.common.translate.util.ByteDataTranslator;
+import io.fd.hc2vpp.srv6.Srv6PolicyIIds;
+import io.fd.hc2vpp.srv6.util.JvppRequestTest;
+import io.fd.honeycomb.test.tools.annotations.InjectTestData;
+import io.fd.honeycomb.translate.write.WriteFailedException;
+import io.fd.vpp.jvpp.core.dto.SrSteeringAddDel;
+import io.fd.vpp.jvpp.core.dto.SrSteeringAddDelReply;
+import org.junit.Test;
+import org.mockito.ArgumentCaptor;
+import org.mockito.Captor;
+import org.opendaylight.yang.gen.v1.http.cisco.com.ns.yang.oc.srte.policy.rev170918.autoroute.include.AutorouteInclude;
+import org.opendaylight.yang.gen.v1.http.cisco.com.ns.yang.oc.srte.policy.rev170918.include.prefix.ConfigBuilder;
+import org.opendaylight.yang.gen.v1.http.cisco.com.ns.yang.oc.srte.policy.rev170918.policies.Policies;
+import org.opendaylight.yang.gen.v1.http.cisco.com.ns.yang.oc.srte.policy.rev170918.policies.policies.Policy;
+import org.opendaylight.yang.gen.v1.http.cisco.com.ns.yang.oc.srte.policy.rev170918.policies.policies.PolicyKey;
+import org.opendaylight.yang.gen.v1.http.cisco.com.ns.yang.oc.srte.policy.rev170918.prefixes.properties.Prefixes;
+import org.opendaylight.yang.gen.v1.http.cisco.com.ns.yang.oc.srte.policy.rev170918.prefixes.properties.prefixes.Prefix;
+import org.opendaylight.yang.gen.v1.http.cisco.com.ns.yang.oc.srte.policy.rev170918.prefixes.properties.prefixes.PrefixBuilder;
+import org.opendaylight.yang.gen.v1.http.cisco.com.ns.yang.oc.srte.policy.rev170918.prefixes.properties.prefixes.PrefixKey;
+import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.IpAddress;
+import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.IpPrefix;
+import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.Ipv4Prefix;
+import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.Ipv6Address;
+import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.Ipv6Prefix;
+import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
+
+public class PrefixCustomizerTest extends JvppRequestTest {
+
+ private static final PolicyKey POLICY_KEY = new PolicyKey(1L, new IpAddress(new Ipv6Address("e::1")));
+ private static final InstanceIdentifier<Prefixes>
+ PREFIXES_IID = Srv6PolicyIIds.SR_TE_PLS.child(Policy.class, POLICY_KEY).child(AutorouteInclude.class)
+ .child(Prefixes.class);
+ private static final Ipv6Address BSID_ADR = new Ipv6Address("a::e");
+ private static final IpPrefix IPV6_PREFIX = new IpPrefix(new Ipv6Prefix("a::/64"));
+ private static final PrefixKey L3_STEER_KEY = new PrefixKey(IPV6_PREFIX);
+ private static final IpPrefix IPV4_PREFIX = new IpPrefix(new Ipv4Prefix("10.0.0.1/24"));
+ private static final PrefixKey L3_STEER_KEY_2 = new PrefixKey(IPV4_PREFIX);
+
+ private static final Prefix L3_STEERING_V6 = new PrefixBuilder()
+ .setIpPrefix(IPV6_PREFIX)
+ .setConfig(new ConfigBuilder().setIpPrefix(IPV6_PREFIX).build())
+ .build();
+
+ private static final Prefix L3_STEERING_V4 = new PrefixBuilder()
+ .setIpPrefix(IPV4_PREFIX)
+ .setConfig(new ConfigBuilder().setIpPrefix(IPV4_PREFIX).build())
+ .build();
+
+ private InstanceIdentifier<Prefix> L3_STEER_V6_IID = PREFIXES_IID.child(Prefix.class, L3_STEER_KEY);
+ private InstanceIdentifier<Prefix> L3_STEER_V4_IID = PREFIXES_IID.child(Prefix.class, L3_STEER_KEY_2);
+
+ @Captor
+ private ArgumentCaptor<SrSteeringAddDel> requestcaptor;
+
+ @InjectTestData(resourcePath = "/policy.json", id = POLICIES_LISTS_PATH)
+ private Policies policies;
+
+ @Override
+ protected void init() {
+ when(api.srSteeringAddDel(any())).thenReturn(future(new SrSteeringAddDelReply()));
+ when(ctx.readAfter(Srv6PolicyIIds.SR_TE_PLS.child(Policy.class, POLICY_KEY)))
+ .thenReturn(Optional.of(policies.getPolicy().get(0)));
+ when(ctx.readBefore(Srv6PolicyIIds.SR_TE_PLS.child(Policy.class, POLICY_KEY)))
+ .thenReturn(Optional.of(policies.getPolicy().get(0)));
+ }
+
+ @Test
+ public void writeCurrentAttributesV6Test() throws WriteFailedException {
+ PrefixCustomizer customizer = new PrefixCustomizer(api);
+ customizer.writeCurrentAttributes(L3_STEER_V6_IID, L3_STEERING_V6, ctx);
+
+ verify(api, times(1)).srSteeringAddDel(requestcaptor.capture());
+ SrSteeringAddDel srSteering = requestcaptor.getValue();
+
+ testSrSteeringAddDelValidity(srSteering, ByteDataTranslator.BYTE_FALSE, (byte) 6, true, BSID_ADR, IPV6_PREFIX);
+ }
+
+ @Test
+ public void writeCurrentAttributesV4Test() throws WriteFailedException {
+ PrefixCustomizer customizer = new PrefixCustomizer(api);
+ customizer.writeCurrentAttributes(L3_STEER_V4_IID, L3_STEERING_V4, ctx);
+
+ verify(api, times(1)).srSteeringAddDel(requestcaptor.capture());
+ SrSteeringAddDel srSteering = requestcaptor.getValue();
+
+ testSrSteeringAddDelValidity(srSteering, ByteDataTranslator.BYTE_FALSE, (byte) 4, false, BSID_ADR, IPV4_PREFIX);
+ }
+
+ @Test
+ public void deleteCurrentAttributesV6Test() throws WriteFailedException {
+ PrefixCustomizer customizer = new PrefixCustomizer(api);
+ customizer.deleteCurrentAttributes(L3_STEER_V6_IID, L3_STEERING_V6, ctx);
+
+ verify(api, times(1)).srSteeringAddDel(requestcaptor.capture());
+ SrSteeringAddDel srSteering = requestcaptor.getValue();
+
+ testSrSteeringAddDelValidity(srSteering, ByteDataTranslator.BYTE_TRUE, (byte) 6, true, BSID_ADR, IPV6_PREFIX);
+ }
+
+ @Test
+ public void deleteCurrentAttributesV4Test() throws WriteFailedException {
+ PrefixCustomizer customizer = new PrefixCustomizer(api);
+ customizer.deleteCurrentAttributes(L3_STEER_V4_IID, L3_STEERING_V4, ctx);
+
+ verify(api, times(1)).srSteeringAddDel(requestcaptor.capture());
+ SrSteeringAddDel srSteering = requestcaptor.getValue();
+
+ testSrSteeringAddDelValidity(srSteering, ByteDataTranslator.BYTE_TRUE, (byte) 4, false, BSID_ADR, IPV4_PREFIX);
+ }
+}
diff --git a/srv6/srv6-impl/src/test/java/io/fd/hc2vpp/srv6/write/steering/PrefixesConfigCustomizerTest.java b/srv6/srv6-impl/src/test/java/io/fd/hc2vpp/srv6/write/steering/PrefixesConfigCustomizerTest.java
new file mode 100644
index 000000000..64e0032e9
--- /dev/null
+++ b/srv6/srv6-impl/src/test/java/io/fd/hc2vpp/srv6/write/steering/PrefixesConfigCustomizerTest.java
@@ -0,0 +1,103 @@
+/*
+ * Copyright (c) 2018 Bell Canada, Pantheon Technologies and/or its affiliates.
+ *
+ * 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 io.fd.hc2vpp.srv6.write.steering;
+
+import static org.mockito.ArgumentMatchers.any;
+import static org.mockito.Mockito.times;
+import static org.mockito.Mockito.verify;
+import static org.mockito.Mockito.when;
+
+import com.google.common.base.Optional;
+import io.fd.hc2vpp.common.translate.util.ByteDataTranslator;
+import io.fd.hc2vpp.srv6.Srv6PolicyIIds;
+import io.fd.hc2vpp.srv6.util.JvppRequestTest;
+import io.fd.hc2vpp.srv6.write.steering.request.L3SteeringRequest;
+import io.fd.honeycomb.test.tools.annotations.InjectTestData;
+import io.fd.honeycomb.translate.write.WriteFailedException;
+import io.fd.vpp.jvpp.core.dto.SrSteeringAddDel;
+import io.fd.vpp.jvpp.core.dto.SrSteeringAddDelReply;
+import java.util.List;
+import org.junit.Test;
+import org.mockito.ArgumentCaptor;
+import org.mockito.Captor;
+import org.opendaylight.yang.gen.v1.http.cisco.com.ns.yang.oc.srte.policy.rev170918.autoroute.include.AutorouteInclude;
+import org.opendaylight.yang.gen.v1.http.cisco.com.ns.yang.oc.srte.policy.rev170918.policies.Policies;
+import org.opendaylight.yang.gen.v1.http.cisco.com.ns.yang.oc.srte.policy.rev170918.policies.policies.Policy;
+import org.opendaylight.yang.gen.v1.http.cisco.com.ns.yang.oc.srte.policy.rev170918.policies.policies.PolicyKey;
+import org.opendaylight.yang.gen.v1.http.cisco.com.ns.yang.oc.srte.policy.rev170918.prefixes.properties.Prefixes;
+import org.opendaylight.yang.gen.v1.http.cisco.com.ns.yang.oc.srte.policy.rev170918.prefixes.properties.prefixes.Config;
+import org.opendaylight.yang.gen.v1.http.cisco.com.ns.yang.oc.srte.policy.rev170918.prefixes.properties.prefixes.ConfigBuilder;
+import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.IpAddress;
+import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.IpPrefix;
+import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.Ipv4Prefix;
+import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.Ipv6Address;
+import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.Ipv6Prefix;
+import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
+
+public class PrefixesConfigCustomizerTest extends JvppRequestTest {
+ private static final Ipv6Address BSID_ADR = new Ipv6Address("a::e");
+ private static final IpPrefix DEFAULT_IPV6_PREFIX = new IpPrefix(new Ipv6Prefix("::/0"));
+ private static final IpPrefix DEFAULT_IPV4_PREFIX = new IpPrefix(new Ipv4Prefix("0.0.0.0/0"));
+ private static final PolicyKey POLICY_KEY = new PolicyKey(1L, new IpAddress(new Ipv6Address("e::1")));
+ private static final Config CONFIG = new ConfigBuilder().setPrefixesAll(true).build();
+ private InstanceIdentifier<Config> PREFIXES_CFG_IID =
+ Srv6PolicyIIds.SR_TE_PLS.child(Policy.class, POLICY_KEY).child(AutorouteInclude.class).child(Prefixes.class)
+ .child(Config.class);
+ @Captor
+ private ArgumentCaptor<SrSteeringAddDel> requestcaptor;
+
+ @InjectTestData(resourcePath = "/policy.json", id = POLICIES_LISTS_PATH)
+ private Policies policies;
+
+ @Override
+ protected void init() {
+ when(api.srSteeringAddDel(any())).thenReturn(future(new SrSteeringAddDelReply()));
+ when(ctx.readAfter(Srv6PolicyIIds.SR_TE_PLS.child(Policy.class, POLICY_KEY)))
+ .thenReturn(Optional.of(policies.getPolicy().get(0)));
+ when(ctx.readBefore(Srv6PolicyIIds.SR_TE_PLS.child(Policy.class, POLICY_KEY)))
+ .thenReturn(Optional.of(policies.getPolicy().get(0)));
+ }
+
+ @Test
+ public void writeCurrentAttributes() throws WriteFailedException {
+ PrefixesConfigCustomizer customizer = new PrefixesConfigCustomizer(api);
+ customizer.writeCurrentAttributes(PREFIXES_CFG_IID, CONFIG, ctx);
+
+ verify(api, times(2)).srSteeringAddDel(requestcaptor.capture());
+ List<SrSteeringAddDel> srSteerings = requestcaptor.getAllValues();
+
+ testSrSteeringAddDelValidity(srSteerings.get(0), ByteDataTranslator.BYTE_FALSE, L3SteeringRequest.VPP_IPV6_TYPE,
+ true, BSID_ADR, DEFAULT_IPV6_PREFIX);
+ testSrSteeringAddDelValidity(srSteerings.get(1), ByteDataTranslator.BYTE_FALSE,
+ L3SteeringRequest.VPP_IPV4_TYPE, false, BSID_ADR, DEFAULT_IPV4_PREFIX);
+ }
+
+ @Test
+ public void deleteCurrentAttributes() throws WriteFailedException {
+ PrefixesConfigCustomizer customizer = new PrefixesConfigCustomizer(api);
+ customizer.deleteCurrentAttributes(PREFIXES_CFG_IID, CONFIG, ctx);
+
+ verify(api, times(2)).srSteeringAddDel(requestcaptor.capture());
+ List<SrSteeringAddDel> srSteerings = requestcaptor.getAllValues();
+
+ testSrSteeringAddDelValidity(srSteerings.get(0), ByteDataTranslator.BYTE_TRUE, L3SteeringRequest.VPP_IPV6_TYPE,
+ true, BSID_ADR, DEFAULT_IPV6_PREFIX);
+ testSrSteeringAddDelValidity(srSteerings.get(1), ByteDataTranslator.BYTE_TRUE, L3SteeringRequest.VPP_IPV4_TYPE,
+ false, BSID_ADR, DEFAULT_IPV4_PREFIX);
+ }
+
+}