| | |
| | | |
| | | size_t size; |
| | | void * buf; |
| | | char uuid[64]; |
| | | char uuid[1]; |
| | | int action; |
| | | |
| | | } shm_packet_t; |
| | |
| | | typedef struct shm_socket_t { |
| | | shm_socket_type_t socket_type; |
| | | int key; |
| | | char proc_id[MAX_STR_LEN]; |
| | | bool force_bind; |
| | | pthread_mutex_t mutex; |
| | | |
| | |
| | | |
| | | int shm_socket_force_bind(shm_socket_t * socket, int key) ; |
| | | |
| | | int shm_socket_bind_proc_id(shm_socket_t *sockt, const char *buf, int len); |
| | | /** |
| | | * @flags : BUS_NOWAIT_FLAG |
| | | */ |
| | | int shm_sendto(shm_socket_t *socket, const void *buf, const int size, const int key, const struct timespec * timeout = NULL, const int flags=0); |
| | | int shm_sendto(shm_socket_t *socket, const void *buf, const int size, const int key, const struct timespec * timeout = NULL, const int flags=0, int reset = 0, int data_set = 0); |
| | | |
| | | int shm_recvfrom(shm_socket_t *socket, void **buf, int *size, int *key, const struct timespec * timeout = NULL, int flags=0); |
| | | int shm_recvfrom(shm_socket_t *socket, void **buf, int *size, int *key, const struct timespec * timeout = NULL, int flags=0, int reset = 0, int data_set = 0); |
| | | |
| | | int shm_sendandrecv(shm_socket_t *socket, const void *send_buf, const int send_size, const int send_key, void **recv_buf, int *recv_size, |
| | | const struct timespec * timeout = NULL, int flags = 0); |