固定bus key

wangzhengquan

2020-12-04 aa2f3b2a9968bb4928463bdae05fb026d16b60bb

 src/socket/shm_socket.h

@@ -41,7 +41,7 @@
};

typedef struct shm_msg_t {
   int port;
   int key;
   shm_msg_type_t type;
   size_t size;
   void * buf;
@@ -53,8 +53,8 @@

typedef struct shm_socket_t {
   shm_socket_type_t socket_type;
   // 本地port
   int port;
   // 本地key
   int key;
   bool force_bind;
   int mutex;
   shm_connection_status_t status;
@@ -77,33 +77,33 @@
int shm_close_socket(shm_socket_t * socket) ;


int shm_socket_bind(shm_socket_t * socket, int port) ;
int shm_socket_bind(shm_socket_t * socket, int key) ;

int shm_socket_force_bind(shm_socket_t * socket, int port) ;
int shm_socket_force_bind(shm_socket_t * socket, int key) ;


int shm_listen(shm_socket_t * socket) ;

shm_socket_t* shm_accept(shm_socket_t* socket);

int shm_connect(shm_socket_t * socket, int port);
int shm_connect(shm_socket_t * socket, int key);

int shm_send(shm_socket_t * socket, const void *buf, const int size) ;


int shm_recv(shm_socket_t * socket, void **buf, int *size) ;

int shm_sendto(shm_socket_t *socket, const void *buf, const int size, const int port, 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 shm_recvfrom(shm_socket_t *socket, void **buf, int *size, int *port,   struct timespec * timeout = NULL,  int flags=0);
int shm_recvfrom(shm_socket_t *socket, void **buf, int *size, int *key,   struct timespec * timeout = NULL,  int flags=0);

int shm_sendandrecv(shm_socket_t *socket, const void *send_buf, const int send_size, const int send_port, void **recv_buf, int *recv_size,  
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,  
   struct timespec * timeout = NULL,  int flags=0);

/**
 * 功能同shm_sendandrecv, 但是不是线程安全的
 */
int shm_sendandrecv_unsafe(shm_socket_t *socket, const void *send_buf, const int send_size, const int send_port, void **recv_buf, int *recv_size,  
int shm_sendandrecv_unsafe(shm_socket_t *socket, const void *send_buf, const int send_size, const int send_key, void **recv_buf, int *recv_size,  
   struct timespec * timeout = NULL,  int flags=0);