From 9900e1211bc905eba5f333d699d74f28ceb94aed Mon Sep 17 00:00:00 2001 From: zhangmeng <775834166@qq.com> Date: 星期一, 17 一月 2022 14:00:52 +0800 Subject: [PATCH] performance --- src/bn_api.cpp | 20 ++++++++------------ 1 files changed, 8 insertions(+), 12 deletions(-) diff --git a/src/bn_api.cpp b/src/bn_api.cpp index 90e74ca..07773df 100644 --- a/src/bn_api.cpp +++ b/src/bn_api.cpp @@ -319,26 +319,23 @@ { if (!request || request_len <= 0) return false; + string url{}; // BHQueryTopicAddress鑾峰彇proc_id string procid{}; - if (!get_proc_id_from_MsgRequestTopic(request, request_len, timeout_ms, &procid)){ - return false; + if (get_proc_id_from_MsgRequestTopic(request, request_len, timeout_ms, &procid)){ + // PRNTVITAG("get_proc_id_from_MsgRequestTopic failed"); + // return false; + url = "ipc:///tmp/" + procid; } - - auto url("ipc:///tmp/" + procid); - if (remote && remote_len > 0){ BHAddress addr; if (addr.ParseFromArray(remote, remote_len)){ if (!addr.ip().empty() && addr.port() > 0){ - // url = "tcp://" + addr.ip() + ":" + to_string(addr.port()); + url = "tcp://" + addr.ip() + ":" + to_string(addr.port()); printf("======>> BHRequest use remote address %s\n", url.c_str()); } } } - // 浣跨敤procid浣滀负ipc閫氫俊 - // printf("BHRequest procid %s\n", procid.c_str()); - int rc = request2(url, request, request_len, reply, reply_len, timeout_ms); if (rc < 0) return false; @@ -360,11 +357,10 @@ if (ret != 0) return false; string procid{}; - if (!get_proc_id_from_MsgRequestTopic(msg.data(), msg.size(), timeout_ms, &procid)){ - return false; + if (get_proc_id_from_MsgRequestTopic(msg.data(), msg.size(), timeout_ms, &procid)){ + copy_memory(proc_id, proc_id_len, procid.data(), procid.size()); } - copy_memory(proc_id, proc_id_len, procid.data(), procid.size()); copy_memory(request, request_len, msg.data(), msg.size()); return true; -- Gitblit v1.8.0