From 8e8a7a018f5724e3f645ff6186879e6dcc195c94 Mon Sep 17 00:00:00 2001
From: wangzhengquan <wangzhengquan85@126.com>
Date: 星期六, 30 一月 2021 14:55:43 +0800
Subject: [PATCH] update
---
src/socket/shm_socket.cpp | 18 ++++++++++++------
1 files changed, 12 insertions(+), 6 deletions(-)
diff --git a/src/socket/shm_socket.cpp b/src/socket/shm_socket.cpp
index 785eb4d..daa7f1a 100644
--- a/src/socket/shm_socket.cpp
+++ b/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);
}
}
--
Gitblit v1.8.0