added a retry of sending traffic in ptf test_fib in case packet wasn't correctly sent to the DUT (sonic-net#18012)

In case of a weak nic, when a packet is not received, resend the packet
Related PR: sonic-net#14139

Signed-off-by: Guy Shemesh <gshemesh@nvidia.com>

Author: illia-kotvitskyi

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

@@ -393,8 +393,20 @@ def check_ipv4_route(self, src_port, dst_ip_addr, dst_port_lists):
 
         dst_ports = list(itertools.chain(*dst_port_lists))
         if self.pkt_action == self.ACTION_FWD:
-            rcvd_port_index, rcvd_pkt = verify_packet_any_port(
-                self, masked_exp_pkt, dst_ports, timeout=1)
+            try:
+                rcvd_port_index, rcvd_pkt = verify_packet_any_port(
+                    self, masked_exp_pkt, dst_ports, timeout=1)
+            except AssertionError:
+                logging.warning("Traffic wasn't sent successfully, trying again")
+                send_packet(self, src_port, pkt, count=5)
+
+                logging.info('Sent Ether(src={}, dst={})/IP(src={}, dst={})/TCP(sport={}, dport={}) on port {}'
+                             .format(pkt.src, pkt.dst, pkt['IP'].src, pkt['IP'].dst, sport, dport, src_port))
+                logging.info('Expect Ether(src={}, dst={})/IP(src={}, dst={})/TCP(sport={}, dport={})'
+                             .format('any', 'any', ip_src, ip_dst, sport, dport))
+
+                rcvd_port_index, rcvd_pkt = verify_packet_any_port(
+                    self, masked_exp_pkt, dst_ports, timeout=1)
             rcvd_port = dst_ports[rcvd_port_index]
             len_rcvd_pkt = len(rcvd_pkt)
             logging.info('Recieved packet at port {} and packet is {} bytes'.format(
@@ -488,8 +500,21 @@ def check_ipv6_route(self, src_port, dst_ip_addr, dst_port_lists):
 
         dst_ports = list(itertools.chain(*dst_port_lists))
         if self.pkt_action == self.ACTION_FWD:
-            rcvd_port_index, rcvd_pkt = verify_packet_any_port(
-                self, masked_exp_pkt, dst_ports, timeout=1)
+            try:
+                rcvd_port_index, rcvd_pkt = verify_packet_any_port(
+                    self, masked_exp_pkt, dst_ports, timeout=1)
+            except AssertionError:
+                logging.warning("Traffic wasn't sent successfully, trying again")
+                send_packet(self, src_port, pkt, count=5)
+
+                logging.info('Sent Ether(src={}, dst={})/IPv6(src={}, dst={})/TCP(sport={}, dport={}) on port {}'
+                             .format(pkt.src, pkt.dst, pkt['IPv6'].src, pkt['IPv6'].dst, sport, dport, src_port))
+                logging.info('Expect Ether(src={}, dst={})/IPv6(src={}, dst={})/TCP(sport={}, dport={})'
+                             .format('any', 'any', ip_src, ip_dst, sport, dport))
+
+                rcvd_port_index, rcvd_pkt = verify_packet_any_port(
+                    self, masked_exp_pkt, dst_ports, timeout=1)
+
             rcvd_port = dst_ports[rcvd_port_index]
             len_rcvd_pkt = len(rcvd_pkt)
             logging.info('Recieved packet at port {} and packet is {} bytes'.format(