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