modify callback function

wangzhengquan

2021-02-04 546bdaa58724ec6a19b56e800ad60963bd3bd1bc

 src/socket/shm_socket.h

@@ -41,8 +41,8 @@

} shm_socket_t;

// typedef void (*recv_callback_fn)(void **sendbuf, int *sendsize);
typedef std::function<void(void **sendbuf, int *sendsize, void *user_data)> recv_callback_fn;
// 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);

@@ -67,11 +67,15 @@
   const struct timespec * timeout = NULL,  int flags = 0);

/**
 * @callback  void (*recv_callback_fn)(void **sendbuf, int *sendsize)
 *            sendbuf 和 sendsize是callbak_fn回调函数的返回值, 分别表示发送数据，和发送数据的大小。
 * @callback  void (*recvandsend_callback_fn)(void *recvbuf, int recvsize, int key, void **sendbuf, int *sendsize, void * user_data)
 *                  @recvbuf 收到的数据
 *                  @recvsize 收到的数据的大小
 *                  @key 接受数据并并发送数据的对象
 *                  @sendbuf 存储返回值的地址，表示返回的数据
 *                  @sendsize 存储返回值的地址， 返回数据的长度
 *
 */
int shm_recvandsend(shm_socket_t *sockt, void **recvbuf, int *recvsize, int *key, recv_callback_fn callback,
int shm_recvandsend(shm_socket_t *sockt,  recvandsend_callback_fn callback,
                    const struct timespec *timeout = NULL, int flag = 0,  void * user_data = NULL);