From d3cd402ef846557006068c1bf4b96b0db50e7e4c Mon Sep 17 00:00:00 2001 From: Junhua Zhai Date: Tue, 11 Jan 2022 09:21:41 +0800 Subject: [PATCH] [p4rt-tests] Bind response consumer to appl_state_db (#2105) What I did In p4rt test scripts, bind response consumer to appl_state_db for consistency. Why I did it In p4orch, the relating notification producer for table P4RT_TABLE is on database appl state db How I verified it Run vstest Details if related notification channel name would be tagged dbId - Azure/sonic-swss-common#568 --- tests/p4rt/test_l3.py | 2 +- tests/p4rt/test_p4rt_acl.py | 2 +- tests/p4rt/test_p4rt_mirror.py | 2 +- 3 files changed, 3 insertions(+), 3 deletions(-) diff --git a/tests/p4rt/test_l3.py b/tests/p4rt/test_l3.py index dbd6ae9781c6..42f32facbdfe 100644 --- a/tests/p4rt/test_l3.py +++ b/tests/p4rt/test_l3.py @@ -23,7 +23,7 @@ def _set_up(self, dvs): self._p4rt_route_obj.set_up_databases(dvs) self._p4rt_wcmp_group_obj.set_up_databases(dvs) self.response_consumer = swsscommon.NotificationConsumer( - self._p4rt_route_obj.appl_db, "APPL_DB_P4RT_TABLE_RESPONSE_CHANNEL") + self._p4rt_route_obj.appl_state_db, "APPL_DB_P4RT_TABLE_RESPONSE_CHANNEL") def _set_vrf(self, dvs): # Create VRF. diff --git a/tests/p4rt/test_p4rt_acl.py b/tests/p4rt/test_p4rt_acl.py index 201a38f9789f..89015fc9d5ee 100644 --- a/tests/p4rt/test_p4rt_acl.py +++ b/tests/p4rt/test_p4rt_acl.py @@ -63,7 +63,7 @@ def _set_up(self, dvs): self._p4rt_udf_obj.set_up_databases(dvs) self.response_consumer = swsscommon.NotificationConsumer( - self._p4rt_acl_table_definition_obj.appl_db, "APPL_DB_P4RT_TABLE_RESPONSE_CHANNEL" + self._p4rt_acl_table_definition_obj.appl_state_db, "APPL_DB_P4RT_TABLE_RESPONSE_CHANNEL" ) @pytest.mark.skip(reason="p4orch is not enabled") diff --git a/tests/p4rt/test_p4rt_mirror.py b/tests/p4rt/test_p4rt_mirror.py index c62574929350..bc218df14742 100644 --- a/tests/p4rt/test_p4rt_mirror.py +++ b/tests/p4rt/test_p4rt_mirror.py @@ -42,7 +42,7 @@ def _set_up(self, dvs): self._p4rt_mirror_session_wrapper = P4RtMirrorSessionWrapper() self._p4rt_mirror_session_wrapper.set_up_databases(dvs) self._response_consumer = swsscommon.NotificationConsumer( - self._p4rt_mirror_session_wrapper.appl_db, "APPL_DB_P4RT_TABLE_RESPONSE_CHANNEL") + self._p4rt_mirror_session_wrapper.appl_state_db, "APPL_DB_P4RT_TABLE_RESPONSE_CHANNEL") def test_MirrorSessionAddModifyAndDelete(self, dvs, testlog): # Initialize database connectors