From c28cdf2fbf1565709b359c9cca6c5e29d9592dce Mon Sep 17 00:00:00 2001 From: lichao <lichao@aiotlink.com> Date: 星期五, 02 四月 2021 15:51:20 +0800 Subject: [PATCH] typedef Topic. --- src/reqrep.h | 20 ++++++++++---------- 1 files changed, 10 insertions(+), 10 deletions(-) diff --git a/src/reqrep.h b/src/reqrep.h index e8a38f7..9e43c7b 100644 --- a/src/reqrep.h +++ b/src/reqrep.h @@ -42,13 +42,13 @@ bool StartWorker(const RequestResultCB &rrcb, int nworker = 2); bool StartWorker(int nworker = 2) { return StartWorker(RequestResultCB(), nworker); } bool Stop() { return Socket::Stop(); } - bool AsyncRequest(const std::string &topic, const void *data, const size_t size, const int timeout_ms, const RequestResultCB &rrcb); - bool AsyncRequest(const std::string &topic, const std::string &data, const int timeout_ms, const RequestResultCB &rrcb) + bool AsyncRequest(const Topic &topic, const void *data, const size_t size, const int timeout_ms, const RequestResultCB &rrcb); + bool AsyncRequest(const Topic &topic, const std::string &data, const int timeout_ms, const RequestResultCB &rrcb) { return AsyncRequest(topic, data.data(), data.size(), timeout_ms, rrcb); } - bool SyncRequest(const std::string &topic, const void *data, const size_t size, std::string &out, const int timeout_ms); - bool SyncRequest(const std::string &topic, const std::string &data, std::string &out, const int timeout_ms) + bool SyncRequest(const Topic &topic, const void *data, const size_t size, std::string &out, const int timeout_ms); + bool SyncRequest(const Topic &topic, const std::string &data, std::string &out, const int timeout_ms) { return SyncRequest(topic, data.data(), data.size(), out, timeout_ms); } @@ -56,7 +56,7 @@ private: bool AsyncSend(const void *remote, const void *msg, const int timeout_ms, const RecvCB &cb); bool SyncSendAndRecv(const void *remote, const void *msg, void *result, const int timeout_ms); - bool QueryRPCTopic(const std::string &topic, bhome::msg::BHAddress &addr, const int timeout_ms); + bool QueryRPCTopic(const Topic &topic, bhome::msg::BHAddress &addr, const int timeout_ms); std::unordered_map<std::string, RecvCB> async_cbs_; typedef bhome_msg::BHAddress Address; @@ -64,11 +64,11 @@ { class Impl { - typedef std::unordered_map<std::string, Address> Store; + typedef std::unordered_map<Topic, Address> Store; Store store_; public: - bool Find(const std::string &topic, Address &addr) + bool Find(const Topic &topic, Address &addr) { auto pos = store_.find(topic); if (pos != store_.end()) { @@ -78,7 +78,7 @@ return false; } } - bool Update(const std::string &topic, const Address &addr) + bool Update(const Topic &topic, const Address &addr) { store_[topic] = addr; return true; @@ -92,8 +92,8 @@ // } public: - bool Find(const std::string &topic, Address &addr) { return impl_->Find(topic, addr); } - bool Update(const std::string &topic, const Address &addr) { return impl_->Update(topic, addr); } + bool Find(const Topic &topic, Address &addr) { return impl_->Find(topic, addr); } + bool Update(const Topic &topic, const Address &addr) { return impl_->Update(topic, addr); } }; TopicCache topic_cache_; }; -- Gitblit v1.8.0