From 5385a225b71d95875eeb70a5c7cdda5f630fd642 Mon Sep 17 00:00:00 2001
From: zhangzengfei <zhangzengfei@smartai.com>
Date: 星期一, 16 一月 2023 18:00:33 +0800
Subject: [PATCH] 修改请求在线进程接口
---
cbhomeclient.cpp | 11 +++++++++--
1 files changed, 9 insertions(+), 2 deletions(-)
diff --git a/cbhomeclient.cpp b/cbhomeclient.cpp
index 3332ff7..b8b7269 100644
--- a/cbhomeclient.cpp
+++ b/cbhomeclient.cpp
@@ -10,6 +10,7 @@
#include "fixed_q.h"
#include "3rdparty/bus_nng/interface_bus_api.h"
+#include "3rdparty/bus_nng/bn_api.h"
#include "bhome_msg.pb.h"
@@ -354,8 +355,13 @@
void* rep = NULL;
int repl = 0;
- auto msg = to_bus<4,5>(ptr(handle), bus_query_procs, pbaddr.data(), pbaddr.size(),
- pbtopic.data(), pbtopic.size(), &rep, &repl, sndto);
+ //auto msg = to_bus<4,5>(ptr(handle), bus_query_procs, pbaddr.data(), pbaddr.size(),
+ // pbtopic.data(), pbtopic.size(), &rep, &repl, sndto);
+
+ // bus_query_procs 鑾峰彇鏁版嵁澶辫触, 鏆傛椂鏀圭敤BHQueryProcs
+ if (!BHQueryProcs(pbaddr.data(), pbaddr.size(), pbtopic.data(), pbtopic.size(), &rep, &repl, sndto)) {
+ return NULL;
+ }
MsgQueryProcReply msgR;
msgR.ParseFromArray(rep, repl);
@@ -370,6 +376,7 @@
memcpy(id, p.proc().proc_id().data(), idl);
procs[i] = cqueryprocs{ .id = id, .idl = idl, .online = p.online() };
}
+
return procs;
}
--
Gitblit v1.8.0