| | |
| | | void *dgram_mod_open_socket(int mod) { |
| | | dgram_mod_socket_t * socket = (dgram_mod_socket_t *)calloc(1, sizeof(dgram_mod_socket_t)); |
| | | socket->mod = (socket_mod_t)mod; |
| | | // socket->recv_thread = 0; |
| | | // socket->recv_queue_map = NULL; |
| | | socket->shm_socket = shm_open_socket(SHM_SOCKET_DGRAM); |
| | | return (void *)socket; |
| | | } |
| | |
| | | dgram_mod_socket_t * socket = (dgram_mod_socket_t *) _socket; |
| | | return shm_sendandrecv(socket->shm_socket, send_buf, send_size, send_port, recv_buf, recv_size); |
| | | |
| | | } |
| | | |
| | | |
| | | |
| | | int dgram_mod_get_socket_port(void * _socket) { |
| | | dgram_mod_socket_t * socket = (dgram_mod_socket_t *) _socket; |
| | | return socket->shm_socket->port; |
| | | } |
| | | |
| | | |
| | | void dgram_mod_free(void *buf) { |
| | | free(buf); |
| | | } |