update

wangzhengquan

2021-02-05 14c345b38d57fd814f217eb8465963a08ca79f7e

 src/socket/shm_socket.h

@@ -14,13 +14,15 @@
   
};
 
 

#define BUS_ACTION_STOP 1 

typedef struct shm_packet_t {
   int key;
   size_t size;
   void * buf;
   char uuid[64];
   int action;

} shm_packet_t;

@@ -41,16 +43,18 @@

} shm_socket_t;

// typedef void (*recvandsend_callback_fn)(void **sendbuf, int *sendsize);
typedef std::function<void(void *recvbuf, int recvsize, int key, void **sendbuf, int *sendsize, void *user_data)> recvandsend_callback_fn;

size_t shm_socket_remove_keys(int keys[], size_t length);
size_t shm_socket_remove_keys_exclude(int keys[], size_t length);

shm_socket_t *shm_open_socket(shm_socket_type_t socket_type);


int shm_close_socket(shm_socket_t * socket) ;

int shm_socket_stop(shm_socket_t *sockt);


int shm_socket_bind(shm_socket_t * socket, int key) ;