Fu Juntang
2021-08-30 ab578ff5dbdc19b9647e3535e7d41306e46fab5d
Fix the return stat check.
1个文件已修改
30 ■■■■■ 已修改文件
src/bh_api.cpp 30 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/bh_api.cpp
@@ -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;