Skip to content

Commit

Permalink
Browse files Browse the repository at this point in the history
…wss-common into zmq_new
  • Loading branch information
divyagayathri-hcl committed Jan 7, 2025
2 parents 1c2c16b + c872f42 commit b2ca158
Show file tree
Hide file tree
Showing 3 changed files with 6 additions and 2 deletions.
1 change: 1 addition & 0 deletions base-tooling-requirements.txt
Original file line number Diff line number Diff line change
@@ -0,0 +1 @@
Pympler ==0.8 --hash=sha256:f74cd2982c5cd92ded55561191945616f2bb904a0ae5cdacdb566c6696bdb922
4 changes: 4 additions & 0 deletions common/schema.h
Original file line number Diff line number Diff line change
Expand Up @@ -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"
Expand Down Expand Up @@ -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"
Expand Down
3 changes: 1 addition & 2 deletions tests/c_api_ut.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -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);
Expand All @@ -295,7 +295,6 @@ TEST(c_api, ZmqConsumerProducerStateTable) {
EXPECT_EQ(fieldValues1[0].first, "myfield3");
EXPECT_EQ(fieldValues1[0].second, "myvalue3");

sleep(2);
arr = SWSSZmqConsumerStateTable_pops(cst);
ASSERT_EQ(arr.len, 0);
freeKeyOpFieldValuesArray(arr);
Expand Down

0 comments on commit b2ca158

Please sign in to comment.