Add the dynamic buf.

fujuntang

2021-09-07 b8b5059222cc99637d4a1c30e7eab26ca9fd0308

Add the dynamic buf.

 src/bh_api.cpp

@@ -1042,6 +1042,7 @@
  int key;
  int size;
  int sec, nsec;
  char buf_temp[100] = { 0x00 };
  char *topics_buf = NULL;
  char *data_buf = NULL; 

@@ -1135,13 +1136,16 @@

#if defined(PRO_DE_SERIALIZE)
    rsr.topic = topics_buf;
    rsr.data = data_buf;
    if (data_buf != NULL) {
      rsr.data = data_buf;
    } else {
      rsr.data = topics_buf;
    }

    memset(topics_buf, 0x00, sizeof(topics_buf));
    sprintf(topics_buf, "%d", key);
    sprintf(buf_temp, "%d", key);

    if ((proc_id != NULL) && (proc_id_len != NULL)) {
      rsr.proc_id = topics_buf;
      rsr.proc_id = buf_temp;
      *proc_id_len = rsr.proc_id.size();
      *proc_id = malloc(*proc_id_len);
      memcpy(*proc_id, rsr.proc_id.data(), *proc_id_len);
@@ -1168,14 +1172,17 @@
    }
    *msgpub = ptr;
    *msgpub_len = len;
    
   
    free(topics_buf);
    free(data_buf);

    if ((proc_id != NULL) && (proc_id_len != NULL)) {
      memset(topics_buf, 0x00, sizeof(topics_buf));
      sprintf(topics_buf, "%d", key);
      memset(buf_temp, 0x00, sizeof(buf_temp));
      sprintf(buf_temp, "%d", key);
      
      *proc_id_len = strlen(topics_buf);
      *proc_id_len = strlen(buf_temp);
      *proc_id = malloc(*proc_id_len);
      memcpy(*proc_id, topics_buf, *proc_id_len);
      memcpy(*proc_id, buf_temp, *proc_id_len);
    }
    
#endif