From bef24e7b4001c7c7cd7a03a22f8eaf7c8af3c4b7 Mon Sep 17 00:00:00 2001 From: zhangmeng <775834166@qq.com> Date: 星期四, 20 一月 2022 14:08:35 +0800 Subject: [PATCH] performance --- src/nng_wrap.cpp | 4 ++-- 1 files changed, 2 insertions(+), 2 deletions(-) diff --git a/src/nng_wrap.cpp b/src/nng_wrap.cpp index c8fbaa3..a3b0bd3 100644 --- a/src/nng_wrap.cpp +++ b/src/nng_wrap.cpp @@ -213,7 +213,7 @@ const auto topic{tmp_msg.c_str()}; string msg{}; { - lock_guard<mutex> l{(*sub)()}; + lock_guard<mutex> l{sub->operator()()}; for(auto && i : sub->topics_){ if (!!!i.compare(topic)){ msg = move(tmp_msg.substr(i.size()+1)); @@ -233,7 +233,7 @@ lock_guard<mutex> l{sub->mtx_failed_topics_}; if (!sub->failed_topics_.empty()){ for(auto iter = sub->failed_topics_.begin(); iter != sub->failed_topics_.end();){ - if (nn_setsockopt(sub->socket_, NN_SUB, NN_SUB_UNSUBSCRIBE, iter->c_str(), iter->length()) >= 0){ + if (nn_setsockopt(sub->socket_, NN_SUB, NN_SUB_SUBSCRIBE, iter->c_str(), iter->length()) >= 0){ iter = sub->failed_topics_.erase(iter); }else{ iter++; -- Gitblit v1.8.0