update

wangzhengquan

2021-01-30 8e8a7a018f5724e3f645ff6186879e6dcc195c94

update

 src/socket/shm_socket.cpp

@@ -519,10 +519,16 @@

  if ((rv = shm_sendto(tmp_socket, send_buf, send_size, send_key, timeout, flags)) == 0) {
    rv = shm_recvfrom(tmp_socket, recv_buf, recv_size, &recv_key, timeout, flags);
printf("======send key =%d , recv key=%d\n", send_key, recv_key);
    assert( send_key == recv_key);
    if(send_key != recv_key)
      err_exit(0, "send key need to equal to recv key! send key =%d , recv key=%d", send_key, recv_key);
    if(rv != 0) {
      printf("_shm_sendandrecv_thread_local : %s\n", bus_strerror(rv));
    }
    else if(rv == 0 ) {
      assert( send_key == recv_key);
      if(send_key != recv_key) {
         err_exit(0, "_shm_sendandrecv_thread_local: send key expect to equal to recv key! send key =%d , recv key=%d", send_key, recv_key);
      }
     
    }
    return rv;
  } else {
    return rv;
@@ -554,12 +560,12 @@
    printf("======send key =%d , recv key=%d\n", send_key, recv_key);
    
    if(rv != 0) {
      printf("_shm_sendandrecv_alloc_new shm_recvfrom : %s\n", bus_strerror(rv));
      printf("_shm_sendandrecv_alloc_new : %s\n", bus_strerror(rv));
    }
    else if(rv == 0 ) {
      assert( send_key == recv_key);
      if(send_key != recv_key) {
         err_exit(0, "send key need to equal to recv key! send key =%d , recv key=%d", send_key, recv_key);
         err_exit(0, "_shm_sendandrecv_alloc_new: send key expect to equal to recv key! send key =%d , recv key=%d", send_key, recv_key);
      }
     
    }