Skip to content

Commit

Permalink
swig_verify
Browse files Browse the repository at this point in the history
  • Loading branch information
divyagayathri-hcl committed Dec 18, 2024
1 parent fc5589e commit 275c016
Show file tree
Hide file tree
Showing 4 changed files with 8 additions and 9 deletions.
6 changes: 3 additions & 3 deletions common/zmqclient.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -220,9 +220,9 @@ SWSS_LOG_ERROR("DIV:: Inside function client sendMsg");
throw system_error(make_error_code(errc::io_error), message);
}

bool ZmqClient::wait(std::string& dbName,
std::string& tableName,
std::vector<std::shared_ptr<KeyOpFieldsValuesTuple>>& kcos)
//bool ZmqClient::wait(std::string& dbName,
// std::string& tableName,
bool ZmqClient::wait(std::vector<std::shared_ptr<KeyOpFieldsValuesTuple>>& kcos)
{
SWSS_LOG_ERROR("DIV:: Inside function wait");
SWSS_LOG_ENTER();
Expand Down
6 changes: 3 additions & 3 deletions common/zmqclient.h
Original file line number Diff line number Diff line change
Expand Up @@ -26,9 +26,9 @@ class ZmqClient
const std::string& tableName,
const std::vector<KeyOpFieldsValuesTuple>& kcos);

bool wait(std::string& dbName,
std::string& tableName,
std::vector<std::shared_ptr<KeyOpFieldsValuesTuple>>& kcos);
//bool wait(std::string& dbName,
// std::string& tableName,
bool wait(std::vector<std::shared_ptr<KeyOpFieldsValuesTuple>>& kcos);

private:
void initialize(const std::string& endpoint, const std::string& vrf);
Expand Down
3 changes: 2 additions & 1 deletion common/zmqproducerstatetable.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -170,7 +170,8 @@ bool ZmqProducerStateTable::wait(std::string& dbName,
std::vector<std::shared_ptr<KeyOpFieldsValuesTuple>>& kcos)
{
SWSS_LOG_DEBUG("DIV:: Inside function ZmqProducerStateTable::wait");
return m_zmqClient.wait(dbName, tableName, kcos);
// return m_zmqClient.wait(m_dbName, m_tableNameStr, kcos);
return m_zmqClient.wait(kcos);
}

size_t ZmqProducerStateTable::dbUpdaterQueueSize()
Expand Down
2 changes: 0 additions & 2 deletions common/zmqproducerstatetable.h
Original file line number Diff line number Diff line change
Expand Up @@ -40,9 +40,7 @@ class ZmqProducerStateTable : public ProducerStateTable
// This method should only be used if the ZmqClient enables one-to-one sync.

virtual bool wait(std::string& dbName,

std::string& tableName,

std::vector<std::shared_ptr<KeyOpFieldsValuesTuple>>& kcos);

size_t dbUpdaterQueueSize();
Expand Down

0 comments on commit 275c016

Please sign in to comment.