From 287d5ef4d4497748658bc4127061c23b3b8c4421 Mon Sep 17 00:00:00 2001
From: shenxin <shenxin@basic.com>
Date: 星期一, 30 八月 2021 20:15:07 +0800
Subject: [PATCH] add bhome_node.go
---
src/bh_api.cpp | 42 ++++++++++++++++++++++++++----------------
1 files changed, 26 insertions(+), 16 deletions(-)
diff --git a/src/bh_api.cpp b/src/bh_api.cpp
index 9875cfa..b492faa 100644
--- a/src/bh_api.cpp
+++ b/src/bh_api.cpp
@@ -1289,6 +1289,12 @@
const char *topic;
const char *data;
}_input1;
+
+ struct _RequestReply
+ {
+ std::string proc_id;
+ std::string data;
+ }rr;
::bhome_msg::BHAddress input0;
::bhome_msg::MsgRequestTopic input1;
@@ -1389,12 +1395,6 @@
memset(errString, 0x00, sizeof(errString));
strncpy(errString, bus_strerror(rv), sizeof(errString));
-
- struct _RequestReply
- {
- std::string proc_id;
- std::string data;
- }rr;
if (rv == 0) {
memset(topics_buf, 0x00, sizeof(topics_buf));
@@ -1408,16 +1408,6 @@
memset(topics_buf, 0x00, sizeof(topics_buf));
memcpy(topics_buf, buf, size);
rr.data = topics_buf;
-
-#if defined(PRO_DE_SERIALIZE)
- ::bhome_msg::MsgRequestTopicReply mrt;
- mrt.mutable_errmsg()->set_errcode(::bhome_msg::ErrorCode(rv));
- mrt.mutable_errmsg()->set_errstring(errString);
- mrt.set_data(rr.data.data());
- *reply_len = mrt.ByteSizeLong();
- *reply = malloc(*reply_len);
- mrt.SerializePartialToArray(*reply, *reply_len);
-#endif
}
pthread_mutex_unlock(&mutex);
@@ -1429,6 +1419,26 @@
strncpy(errString, bus_strerror(rv), sizeof(errString));
}
+#if defined(PRO_DE_SERIALIZE)
+ ::bhome_msg::MsgRequestTopicReply mrt;
+ mrt.mutable_errmsg()->set_errcode(::bhome_msg::ErrorCode(rv));
+ mrt.mutable_errmsg()->set_errstring(errString);
+ mrt.set_data(rr.data.data());
+ *reply_len = mrt.ByteSizeLong();
+ *reply = malloc(*reply_len);
+ mrt.SerializePartialToArray(*reply, *reply_len);
+#else
+ if (rv > 0) {
+ min = strlen(errString) + 1;
+ buf = malloc(min);
+ memcpy(buf, errString, strlen(errString));
+ *((char *)buf + min - 1) = '\0';
+
+ *reply = buf;
+ *reply_len = min;
+ }
+#endif
+
if (rv == 0)
return true;
--
Gitblit v1.8.0