| | |
|---|
| | | #include "usg_common.h" |
|---|
| | | #include "usg_typedef.h" |
|---|
| | | #include "shm_queue.h" |
|---|
| | | #include "lock_free_queue.h" |
|---|
| | | |
|---|
| | | enum shm_socket_flag_t |
|---|
| | | { |
|---|
| | | SHM_MSG_TIMEOUT = 1, |
|---|
| | | SHM_MSG_NOWAIT = 2 |
|---|
| | | }; |
|---|
| | | |
|---|
| | | |
|---|
| | | enum shm_connection_status_t { |
|---|
| | | SHM_CONN_CLOSED=1, |
|---|
| | |
|---|
| | | int key; |
|---|
| | | bool force_bind; |
|---|
| | | pthread_mutex_t mutex; |
|---|
| | | shm_connection_status_t status; |
|---|
| | | SHMQueue<shm_msg_t> *queue; |
|---|
| | | SHMQueue<shm_msg_t> *remoteQueue; |
|---|
| | | shm_connection_status_t status; |
|---|
| | | SHMQueue<shm_msg_t> *queue; //self queue |
|---|
| | | SHMQueue<shm_msg_t> *remoteQueue; // peer queue |
|---|
| | | LockFreeQueue<shm_msg_t, DM_Allocator> *messageQueue; |
|---|
| | | LockFreeQueue<shm_msg_t, DM_Allocator> *acceptQueue; |
|---|
| | | std::map<int, shm_socket_t* > *clientSocketMap; |
|---|
| | |
|---|
| | | int shm_recv(shm_socket_t * socket, void **buf, int *size) ; |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * @flags : SHM_MSG_NOWAIT |
|---|
| | | * @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); |
|---|
| | | |
|---|
