check p4 flow table for test case verification

test/test-cases/functional/ptf/p4_dash_utils.py

@@ -113,3 +113,28 @@ def tearDown(self, *args, **kwargs):
     setattr(cls, "tearDown", tearDown)
     return cls
 
+
+class P4Table():
+    def __init__(self):
+        channel = grpc.insecure_channel('localhost:9559')
+        self.stub = p4runtime_pb2_grpc.P4RuntimeStub(channel)
+
+    def read(self, table_id):
+        entry = p4runtime_pb2.TableEntry()
+        entry.table_id = table_id
+
+        req = p4runtime_pb2.ReadRequest()
+        req.device_id = 0
+        entity = req.entities.add()
+        entity.table_entry.CopyFrom(entry)
+        for response in self.stub.Read(req):
+            for entity in response.entities:
+                yield entity.table_entry
+
+    def print_flow_table(self):
+        p4info = P4info(self.stub)
+        p4info_flow_entry = p4info.get_table("dash_ingress.conntrack_lookup_stage.flow_entry")
+
+        for entry in self.read(p4info_flow_entry.preamble.id):
+            print(entry)
+

test/test-cases/functional/ptf/saidashdpapp_sanity.py

@@ -195,6 +195,7 @@ def trafficUdpTest(self):
         send_packet(self, 0, vxlan_pkt)
         print("\tVerifying packet in dpapp port...")
         verify_packet(self, self.pkt_exp, 0)
+        P4Table().print_flow_table()
         print ("SaiThriftDpappUdpPktTest OK")
 
     def trafficTcpTest(self):
@@ -238,10 +239,11 @@ def trafficTcpTest(self):
                                         inner_frame=inner_exp_pkt)
 
         self.pkt_exp = vxlan_exp_pkt
-        print("\tSending outbound packet...")
+        print("\tSending outbound packet TCP SYN ...")
         send_packet(self, 0, vxlan_pkt)
         print("\tVerifying packet in dpapp port...")
         verify_packet(self, self.pkt_exp, 0)
+        P4Table().print_flow_table()
 
         # customer packet: tcp FIN
         inner_pkt = simple_tcp_packet(eth_dst="02:02:02:02:02:02",