Merge branch 'master' of https://github.com/divyagayathri-hcl/sonic-s…

…wss-common into zmq_new
sonic-net · Jan 8, 2025 · 3979572 · 3979572
2 parents 1c2c16b + c872f42
commit 3979572
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 1 deletion.
diff --git a/common/schema.h b/common/schema.h
@@ -212,6 +212,7 @@ namespace swss {
 #define COUNTERS_RIF_TYPE_MAP               "COUNTERS_RIF_TYPE_MAP"
 #define COUNTERS_RIF_NAME_MAP               "COUNTERS_RIF_NAME_MAP"
 #define COUNTERS_TRAP_NAME_MAP              "COUNTERS_TRAP_NAME_MAP"
+#define COUNTERS_POLICER_NAME_MAP           "COUNTERS_POLICER_NAME_MAP"
 #define COUNTERS_CRM_TABLE                  "CRM"
 #define COUNTERS_BUFFER_POOL_NAME_MAP       "COUNTERS_BUFFER_POOL_NAME_MAP"
 #define COUNTERS_SWITCH_NAME_MAP            "COUNTERS_SWITCH_NAME_MAP"
@@ -279,10 +280,13 @@ namespace swss {
 #define TUNNEL_ATTR_ID_LIST             "TUNNEL_ATTR_ID_LIST"
 #define ACL_COUNTER_ATTR_ID_LIST        "ACL_COUNTER_ATTR_ID_LIST"
 #define FLOW_COUNTER_ID_LIST            "FLOW_COUNTER_ID_LIST"
+#define POLICER_COUNTER_ID_LIST         "POLICER_COUNTER_ID_LIST"
 #define PLUGIN_TABLE                    "PLUGIN_TABLE"
 #define LUA_PLUGIN_TYPE                 "LUA_PLUGIN_TYPE"
 #define SAI_OBJECT_TYPE                 "SAI_OBJECT_TYPE"
 
+#define BULK_CHUNK_SIZE_FIELD               "BULK_CHUNK_SIZE"
+#define BULK_CHUNK_SIZE_PER_PREFIX_FIELD    "BULK_CHUNK_SIZE_PER_PREFIX"
 #define POLL_INTERVAL_FIELD                 "POLL_INTERVAL"
 #define STATS_MODE_FIELD                    "STATS_MODE"
 #define STATS_MODE_READ                     "STATS_MODE_READ"

diff --git a/common/zmqclient.cpp b/common/zmqclient.cpp
@@ -203,6 +203,7 @@ void ZmqClient::sendMsg(
 }
 
 //TODO: To implement the wait() method later.
+// To implement ZMQ_CLIENT and ZMQ_SERVER socket types for response path.
 bool ZmqClient::wait(const std::string& dbName,
                      const std::string& tableName,
                      const std::vector<std::shared_ptr<KeyOpFieldsValuesTuple>>& kcos)

diff --git a/tests/c_api_ut.cpp b/tests/c_api_ut.cpp
@@ -268,10 +268,10 @@ TEST(c_api, ZmqConsumerProducerStateTable) {
         else
         {
             SWSSZmqClient_sendMsg(cli, "TEST_DB", "mytable", arr);
+            sleep(2);
         }
 
         ASSERT_EQ(SWSSZmqConsumerStateTable_readData(cst, 1500, true), SWSSSelectResult_DATA);
-        sleep(2);
         arr = SWSSZmqConsumerStateTable_pops(cst);
 
         vector<KeyOpFieldsValuesTuple> kfvs = takeKeyOpFieldValuesArray(arr);