| | |
| | |
|
| | | 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);
|
| | |
|
| | | if (msg.empty()) return NULL;
|
| | |
|
| | | // bug 已修复, 在 bus_nng 中
|
| | | // bus_query_procs 获取数据失败, 暂时改用BHQueryProcs
|
| | | if (!BHQueryProcs(pbaddr.data(), pbaddr.size(), pbtopic.data(), pbtopic.size(), &rep, &repl, sndto)) {
|
| | | return NULL;
|
| | | }
|
| | | // if (!BHQueryProcs(pbaddr.data(), pbaddr.size(), pbtopic.data(), pbtopic.size(), &rep, &repl, sndto)) {
|
| | | // return NULL;
|
| | | // }
|
| | |
|
| | | MsgQueryProcReply msgR;
|
| | | msgR.ParseFromArray(rep, repl);
|