From cb6e8a6831613006603c14337291174fa29d2f57 Mon Sep 17 00:00:00 2001
From: zhangmeng <775834166@qq.com>
Date: 星期四, 16 十二月 2021 15:50:41 +0800
Subject: [PATCH] add interface
---
src/bn_api.cpp | 60 ++++++------------------------------------------------------
1 files changed, 6 insertions(+), 54 deletions(-)
diff --git a/src/bn_api.cpp b/src/bn_api.cpp
index 8a37caf..db54880 100644
--- a/src/bn_api.cpp
+++ b/src/bn_api.cpp
@@ -1,62 +1,16 @@
#include "bn_api.h"
#include <string.h>
-#include <string>
-#include <unordered_map>
-#include <memory>
-#include <thread>
-using namespace std;
#include "nng_wrap.h"
using namespace nng_wrap;
+#include "common.h"
+using namespace std;
+
#include "bhome_msg.pb.h"
#include "bhome_msg_api.pb.h"
using namespace bhome_msg;
-
-enum{
- URLReg,
- URLDeReg,
- URLRegTopic,
- URLQueryTopic,
- URLQueryProcs,
- URLSubLocal,
- URLSubNet,
- URLPubProxy,
- URLSubQueue,
- URLHeartBeat,
-};
-
-static char* IPC_REGISTER = (char*)"ipc:///tmp/bhnng-center-reg.ipc"; //杩涚▼娉ㄥ唽
-static char* IPC_UNREGISTER = (char*)"ipc:///tmp/bhnng-center-unregister.ipc"; //娉ㄩ攢
-static char* IPC_REGTOPIC = (char*)"ipc:///tmp/bhnng-center-regtopic.ipc"; //娉ㄥ唽涓婚
-static char* IPC_QUERYTOPIC = (char*)"ipc:///tmp/bhnng-center-querytopic.ipc"; //鏌ヨ鎸囧畾鐨勪富棰�
-static char* IPC_QUERYPROC = (char*)"ipc:///tmp/bhnng-center-queryproc.ipc"; //鏌ヨ鎵�鏈夋敞鍐岀殑杩涚▼
-static char* IPC_SUBLOCALTOPIC = (char*)"ipc:///tmp/bhnng-center-sublocaltopic.ipc"; //璁㈤槄鏈湴涓婚
-static char* IPC_SUBNETTOPIC = (char*)"ipc:///tmp/bhnng-center-subnettopic.ipc"; //璁㈤槄缃戠粶涓婚
-static char* IPC_HEARTBEAT = (char*)"ipc:///tmp/bhnng-center-hb.ipc";
-static char* IPC_PUB_PROXY = (char*)"ipc:///tmp/bhnng-center-pub-proxy.ipc"; //杩欎釜鏄唬鐞嗕腑蹇冿紝鐢ㄤ簬鎺ユ敹寰呭彂甯冪殑娑堟伅
-static char* IPC_SUB_QUEUE = (char*)"ipc:///tmp/bhnng-center-sub-queue.ipc"; //杩欎釜鏄鎴风浠巆enter璁㈤槄鐨勯�氶亾
-
-static const unordered_map<int, string> map_url{
- {URLReg, IPC_REGISTER},
- {URLDeReg, IPC_UNREGISTER},
- {URLRegTopic, IPC_REGTOPIC},
- {URLQueryTopic, IPC_QUERYTOPIC},
- {URLQueryProcs, IPC_QUERYPROC},
- {URLSubLocal, IPC_SUBLOCALTOPIC},
- {URLSubNet, IPC_SUBNETTOPIC},
- {URLPubProxy, IPC_PUB_PROXY},
- {URLSubQueue, IPC_SUB_QUEUE},
- {URLHeartBeat, IPC_HEARTBEAT},
-};
-static string get_url(const int type){
- auto iter = map_url.find(type);
- if (iter != map_url.end()){
- return iter->second;
- }
- return {};
-}
static void fetch_set_proc_id(std::string& pid){
static string cur_proc_id{};
@@ -66,8 +20,6 @@
pid = cur_proc_id;
}
}
-
-/////////////////////////////////////////////
int BHRegister(const void *proc_info, const int proc_info_len, void **reply, int *reply_len, const int timeout_ms)
{
@@ -313,9 +265,9 @@
// return true;
}
-static int get_proc_id_from_MsgRequestTopic(
- const void* request, const int request_len, const int timeout_ms,
- string* proc_id){
+int get_proc_id_from_MsgRequestTopic(
+ const void* request, const int request_len, const int timeout_ms, string* proc_id)
+{
// BHQueryTopicAddress鑾峰彇proc_id
bhome_msg::MsgRequestTopic req;
--
Gitblit v1.8.0