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/interface_bus_api.cpp | 23 ++++++++++++----------- 1 files changed, 12 insertions(+), 11 deletions(-) diff --git a/src/interface_bus_api.cpp b/src/interface_bus_api.cpp index 60c195d..b005bdf 100644 --- a/src/interface_bus_api.cpp +++ b/src/interface_bus_api.cpp @@ -259,6 +259,7 @@ return false; } + // msgpublish(msgpublish(msg)) MsgPublish newPub; newPub.set_topic(get<8>(*b)); newPub.set_data(string{(const char*)msgpub, (const size_t)msgpub_len}); @@ -319,20 +320,19 @@ return false; } + string url{}; // BHQueryTopicAddress鑾峰彇proc_id string procid{}; - if (!get_proc_id_from_MsgRequestTopic(request, request_len, timeout_ms, &procid)){ - PRNTVITAG("get_proc_id_from_MsgRequestTopic failed"); - 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()); } } @@ -361,15 +361,16 @@ string msg; auto ret = read_request(src, &msg, timeout_ms, &get<6>(*b)); + // printf("bus_recv_request read_request ret %d msg %s\n", ret, msg.c_str()); if (ret != 0) return false; string procid{}; - if (!get_proc_id_from_MsgRequestTopic(msg.data(), msg.size(), timeout_ms, &procid)){ - PRNTVITAG("get_proc_id_from_MsgRequestTopic failed"); - return false; + if (get_proc_id_from_MsgRequestTopic(msg.data(), msg.size(), timeout_ms, &procid)){ + // PRNTVITAG("get_proc_id_from_MsgRequestTopic failed"); + // return false; + 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