| | |
|---|
| | | |
|---|
| | | void BusServerSocket::_proxy_reg(const char *topic, size_t topic_size, const char *buf, size_t buf_size, int key, int flag) |
|---|
| | | { |
|---|
| | | char data_buf[MAX_STR_LEN] = { 0x00 }; |
|---|
| | | char buf_temp[MAX_STR_LEN * MAX_TOPICS_NUN] = { 0x00 }; |
|---|
| | | int count = 0; |
|---|
| | | int i = 0; |
|---|
| | |
|---|
| | | count = 0; |
|---|
| | | } |
|---|
| | | |
|---|
| | | memset(buf_temp, 0x00, sizeof(buf_temp)); |
|---|
| | | sprintf(buf_temp, "%d", count); |
|---|
| | | shm_sendto(shm_socket, buf_temp, strlen(buf_temp), key, &timeout, BUS_TIMEOUT_FLAG); |
|---|
| | | memset(data_buf, 0x00, sizeof(data_buf)); |
|---|
| | | sprintf(data_buf, "%d", count); |
|---|
| | | shm_sendto(shm_socket, data_buf, strlen(data_buf), key, &timeout, BUS_TIMEOUT_FLAG); |
|---|
| | | |
|---|
| | | } else { |
|---|
| | | |
|---|
