[inner hashing] extend inner hashing test with dynamic Policy Base Hashing configurations

ansible/roles/test/files/ptftests/inner_hash_test.py

@@ -26,8 +26,9 @@ class InnerHashTest(BaseTest):
     #---------------------------------------------------------------------
     # Class variables
     #---------------------------------------------------------------------
-    DEFAULT_BALANCING_RANGE = 0.25
+    DEFAULT_BALANCING_RANGE = 0.3
     BALANCING_TEST_TIMES = 625
+    OUTER_ENCAP_FORMATS = ["vxlan", "nvgre"]
 
     _required_params = [
         'fib_info',
@@ -88,14 +89,16 @@ def setUp(self):
 
         self.balancing_range = self.test_params.get('balancing_range', self.DEFAULT_BALANCING_RANGE)
         self.balancing_test_times = self.test_params.get('balancing_test_times', self.BALANCING_TEST_TIMES)
+        self.outer_encap_formats = self.test_params.get('outer_encap_formats', self.OUTER_ENCAP_FORMATS)
+
+        logging.info("balancing_test_times:  {}".format(self.balancing_test_times))
 
 
     def check_hash(self, hash_key):
         src_port = int(random.choice(self.src_ports))
         logging.info("outer_dst_ip={}, src_port={}, exp_port_list={}".format(self.outer_dst_ip, src_port, self.exp_port_list))
-        outer_encap_formats = ['vxlan', 'nvgre']
 
-        for outer_encap_format in outer_encap_formats:
+        for outer_encap_format in self.outer_encap_formats:
             hit_count_map = {}
             for _ in range(0, self.balancing_test_times*len(self.exp_port_list)):
                 src_port = int(random.choice(self.src_ports))
@@ -154,16 +157,30 @@ def generate_inner_pkt(self, sport, dport, ip_src, ip_dst, ip_proto):
         rand_int = random.randint(1, 99)
         src_mac = '00:12:ab:34:cd:' + str(rand_int)
         dst_mac = str(rand_int) + ':12:ab:34:cd:00'
-        pkt = simple_tcp_packet(
-                        eth_dst=dst_mac,
-                        eth_src=src_mac,
-                        ip_src=ip_src,
-                        ip_dst=ip_dst,
-                        tcp_sport=sport,
-                        tcp_dport=dport,
-                        ip_ttl=64)
-
-        pkt['IP'].proto = ip_proto
+        if ip_network(unicode(ip_src)).version == 4:
+            pkt = simple_tcp_packet(
+                eth_dst=dst_mac,
+                eth_src=src_mac,
+                ip_dst=ip_dst,
+                ip_src=ip_src,
+                tcp_sport=sport,
+                tcp_dport=dport,
+                ip_ttl=64
+            )
+
+            pkt["IP"].proto = ip_proto
+        else:
+            pkt = simple_tcpv6_packet(
+                eth_dst=dst_mac,
+                eth_src=src_mac,
+                ipv6_dst=ip_dst,
+                ipv6_src=ip_src,
+                tcp_sport=sport,
+                tcp_dport=dport,
+                ipv6_hlim=64
+            )
+
+            pkt["IPv6"].nh = ip_proto
         return pkt