| | |
| | | char data_buf[MAX_STR_LEN] = { 0x00 }; |
| | | char buf_temp[MAX_STR_LEN] = { 0x00 }; |
| | | char *topics_buf = NULL; |
| | | hashtable_t *hashtable = mm_get_hashtable(); |
| | | |
| | | #if defined(PRO_DE_SERIALIZE) |
| | | struct _BHAddress |
| | |
| | | |
| | | str = buf_temp; |
| | | val = net_mod_socket_buf_data_get(gNetmod_socket, str); |
| | | if(val > 0) { |
| | | if ((val > 0) && (hashtable_get(hashtable, val) != NULL)) { |
| | | |
| | | rv = 0; |
| | | |
| | | } else { |
| | | |
| | | if ((val > 0) && (hashtable_get(hashtable, val) == NULL)) { |
| | | net_mod_socket_buf_data_del(gNetmod_socket, str); |
| | | } |
| | | |
| | | rv = net_mod_socket_reg(gNetmod_socket, buf_temp, strlen(buf_temp), &buf, &size, timeout_ms, PROC_QUE_STCS); |
| | | if (rv == 0) { |
| | | |
| | |
| | | char *errString = NULL; |
| | | char buf_temp[MAX_STR_LEN] = { 0x00 }; |
| | | char *topics_buf = NULL; |
| | | hashtable_t *hashtable = mm_get_hashtable(); |
| | | |
| | | struct _RequestReply |
| | | { |
| | |
| | | |
| | | str = buf_temp; |
| | | val = net_mod_socket_buf_data_get(gNetmod_socket, str); |
| | | if(val > 0) { |
| | | if ((val > 0) && (hashtable_get(hashtable, val) != NULL)) { |
| | | rv = 0; |
| | | |
| | | } else { |
| | | if ((val > 0) && (hashtable_get(hashtable, val) == NULL)) { |
| | | net_mod_socket_buf_data_del(gNetmod_socket, str); |
| | | } |
| | | |
| | | rv = net_mod_socket_reg(gNetmod_socket, buf_temp, strlen(buf_temp), &buf, &size, timeout_ms, PROC_QUE_STCS); |
| | | if (rv == 0) { |
| | | |