修改请求在线进程接口

zhangzengfei

2023-01-16 5385a225b71d95875eeb70a5c7cdda5f630fd642

修改请求在线进程接口

 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;

}