ptf/saiqosmap.py [5366:5451]: - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - qos_map_dict = { "qos_pfc_priority_to_priority_group_map": 0, "qos_dot1p_to_tc_map": 0, "qos_tc_to_priority_group_map": 0, "qos_dscp_to_tc_map": 0} for port in self.test_ports: self.setPortMultipleQosMapIds( port, qos_map_dict) for ingress_port in range(0, len(self.test_dev_ports)): pfc_to_pg_map_id = self.test_pfc_to_pg_map_id[ingress_port] tc_to_pg_map_id = self.test_tc_to_pg_map_id[ingress_port] if (pfc_to_pg_map_id == 0) or (tc_to_pg_map_id == 0): continue # update QOS MAP PFC TO PRIORITY GROUP self.assertEqual( update_and_verify_qos_map( self.client, pfc_to_pg_map_id, SAI_QOS_MAP_TYPE_PFC_PRIORITY_TO_PRIORITY_GROUP, pfc_list, pfc_pg_list), True, "Failed verify updated qos_map attribute") # update QOS MAP TC TO PRIORITY GROUP self.assertEqual( update_and_verify_qos_map( self.client, tc_to_pg_map_id, SAI_QOS_MAP_TYPE_TC_TO_PRIORITY_GROUP, tc_list, tc_pg_list[ingress_port]), True, "Failed verify updated qos_map attribute") p = 0 for port in self.test_ports: if self.test_pfc_to_pg_map_id[p] == 0: continue if qos_map_type == SAI_QOS_MAP_TYPE_DOT1P_TO_TC: sai_thrift_set_port_attribute( self.client, port, qos_dot1p_to_tc_map=self.dot1_to_tc_map_id) else: sai_thrift_set_port_attribute( self.client, port, qos_dscp_to_tc_map=self.qos_dscp_tc_map_id) # set the QOS PFC TO PRIORITY GROUP mapping sai_thrift_set_port_attribute( self.client, port, qos_tc_to_priority_group_map=self.test_tc_to_pg_map_id[p]) # set the QOS PFC TO PRIORITY GROUP mapping sai_thrift_set_port_attribute( self.client, port, qos_pfc_priority_to_priority_group_map=self. test_pfc_to_pg_map_id[p]) p += 1 # get the initial counters expected_cnt = self.getPortPPGStats(self.test_dev_ports) for port in range(0, len(self.test_dev_ports)): ingress_port = self.test_dev_ports[port] for key, ppg in self.test_mapping[port]: ingress_ip_tos = key << 2 pkts = 1 + port expected_cnt[port][ppg] += pkts self.ipv4_pkt[IP].tos = ingress_ip_tos send_packet(self, ingress_port, self.ipv4_pkt, pkts) print("Verify port/ppg pktcounters") time.sleep(5) post_cnt = self.getPortPPGStats(self.test_dev_ports) self.assertEqual( self.comparePortPPGStats(expected_cnt, post_cnt), True) print("\tok") # get the initial counters expected_cnt = self.getPortPPGStats(self.test_dev_ports) for port in range(0, len(self.test_dev_ports)): ingress_port = self.test_dev_ports[port] for key, ppg in self.test_mapping[port]: ingress_ip_tos = key << 2 pkts = 1 + port expected_cnt[port][ppg] += pkts self.ipv6_pkt.tc = ingress_ip_tos send_packet(self, ingress_port, self.ipv6_pkt, pkts) print("Verify port/ppg pktcounters") time.sleep(5) post_cnt = self.getPortPPGStats(self.test_dev_ports) self.assertEqual( self.comparePortPPGStats(expected_cnt, post_cnt), True) print("\tok") - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - ptf/saiqosmap.py [5815:5900]: - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - qos_map_dict = { "qos_pfc_priority_to_priority_group_map": 0, "qos_dot1p_to_tc_map": 0, "qos_tc_to_priority_group_map": 0, "qos_dscp_to_tc_map": 0} for port in self.test_ports: self.setPortMultipleQosMapIds( port, qos_map_dict) for ingress_port in range(0, len(self.test_dev_ports)): pfc_to_pg_map_id = self.test_pfc_to_pg_map_id[ingress_port] tc_to_pg_map_id = self.test_tc_to_pg_map_id[ingress_port] if (pfc_to_pg_map_id == 0) or (tc_to_pg_map_id == 0): continue # update QOS MAP PFC TO PRIORITY GROUP self.assertEqual( update_and_verify_qos_map( self.client, pfc_to_pg_map_id, SAI_QOS_MAP_TYPE_PFC_PRIORITY_TO_PRIORITY_GROUP, pfc_list, pfc_pg_list), True, "Failed verify updated qos_map attribute") # update QOS MAP TC TO PRIORITY GROUP self.assertEqual( update_and_verify_qos_map( self.client, tc_to_pg_map_id, SAI_QOS_MAP_TYPE_TC_TO_PRIORITY_GROUP, tc_list, tc_pg_list[ingress_port]), True, "Failed verify updated qos_map attribute") p = 0 for port in self.test_ports: if self.test_pfc_to_pg_map_id[p] == 0: continue if qos_map_type == SAI_QOS_MAP_TYPE_DOT1P_TO_TC: sai_thrift_set_port_attribute( self.client, port, qos_dot1p_to_tc_map=self.dot1_to_tc_map_id) else: sai_thrift_set_port_attribute( self.client, port, qos_dscp_to_tc_map=self.qos_dscp_tc_map_id) # set the QOS PFC TO PRIORITY GROUP mapping sai_thrift_set_port_attribute( self.client, port, qos_tc_to_priority_group_map=self.test_tc_to_pg_map_id[p]) # set the QOS PFC TO PRIORITY GROUP mapping sai_thrift_set_port_attribute( self.client, port, qos_pfc_priority_to_priority_group_map=self. test_pfc_to_pg_map_id[p]) p += 1 # get the initial counters expected_cnt = self.getPortPPGStats(self.test_dev_ports) for port in range(0, len(self.test_dev_ports)): ingress_port = self.test_dev_ports[port] for key, ppg in self.test_mapping[port]: ingress_ip_tos = key << 2 pkts = 1 + port expected_cnt[port][ppg] += pkts self.ipv4_pkt[IP].tos = ingress_ip_tos send_packet(self, ingress_port, self.ipv4_pkt, pkts) print("Verify port/ppg pktcounters") time.sleep(5) post_cnt = self.getPortPPGStats(self.test_dev_ports) self.assertEqual( self.comparePortPPGStats(expected_cnt, post_cnt), True) print("\tok") # get the initial counters expected_cnt = self.getPortPPGStats(self.test_dev_ports) for port in range(0, len(self.test_dev_ports)): ingress_port = self.test_dev_ports[port] for key, ppg in self.test_mapping[port]: ingress_ip_tos = key << 2 pkts = 1 + port expected_cnt[port][ppg] += pkts self.ipv6_pkt.tc = ingress_ip_tos send_packet(self, ingress_port, self.ipv6_pkt, pkts) print("Verify port/ppg pktcounters") time.sleep(5) post_cnt = self.getPortPPGStats(self.test_dev_ports) self.assertEqual( self.comparePortPPGStats(expected_cnt, post_cnt), True) print("\tok") - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -