update

wangzhengquan

2021-02-04 6600a375ac386a0d384c4e9f1af4f235b8d67262

update

 src/socket/shm_socket.cpp

@@ -153,7 +153,7 @@

  int rv;
 
  shm_packet_t sendpak;
  shm_packet_t sendpak = {0};
  sendpak.key = sockt->key;
  sendpak.size = size;
  sendpak.buf = mm_malloc(size);
@@ -253,7 +253,7 @@
 
  void *sendbuf = NULL;
  int sendsize = 0;
  shm_packet_t recvpak;
  shm_packet_t recvpak = {0};

  rv = shm_recvpakfrom(sockt , &recvpak, timeout, flag);

@@ -273,7 +273,7 @@
  mm_free(recvpak.buf);
  callback(recvbuf, recvpak.size, recvpak.key, &sendbuf, &sendsize, user_data);

  shm_packet_t sendpak;
  shm_packet_t sendpak = {0};
  sendpak.key = sockt->key;
  sendpak.size = sendsize;
  memcpy(sendpak.uuid, recvpak.uuid, sizeof sendpak.uuid);

 src/socket/shm_socket.h

@@ -41,7 +41,6 @@

} 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);