From 5e3e6719f7d7922decdc16d2313baf2e94210750 Mon Sep 17 00:00:00 2001
From: wangzhengquan <wangzhengquan85@126.com>
Date: 星期五, 17 七月 2020 18:29:11 +0800
Subject: [PATCH] pub_sub finished
---
queue/shm_socket.c | 4 ++++
1 files changed, 4 insertions(+), 0 deletions(-)
diff --git a/queue/shm_socket.c b/queue/shm_socket.c
index e0bdac6..27c5b0a 100644
--- a/queue/shm_socket.c
+++ b/queue/shm_socket.c
@@ -308,6 +308,10 @@
int shm_send(shm_socket_t *socket, void *buf, int size) {
// hashtable_t *hashtable = mm_get_hashtable();
+ if(socket->remoteQueue == NULL) {
+ err_msg(errno, "褰撳墠瀹㈡埛绔棤杩炴帴!");
+ return -1;
+ }
shm_msg_t dest;
dest.type=SHM_COMMON_MSG;
dest.port = socket->port;
--
Gitblit v1.8.0