From dbf7fd6f620b86c382431ce10fd5fe3c5ddca955 Mon Sep 17 00:00:00 2001
From: wangzhengquan <wangzhengquan85@126.com>
Date: 星期四, 24 十二月 2020 14:10:44 +0800
Subject: [PATCH] update
---
src/socket/shm_mod_socket.c | 9 +++------
1 files changed, 3 insertions(+), 6 deletions(-)
diff --git a/src/socket/shm_mod_socket.c b/src/socket/shm_mod_socket.c
index e28f872..6e622a8 100644
--- a/src/socket/shm_mod_socket.c
+++ b/src/socket/shm_mod_socket.c
@@ -15,7 +15,7 @@
}
ShmModSocket::~ShmModSocket() {
- logger->debug("Destory ShmModSocket...\n");
+ // logger->debug("Close ShmModSocket...\n");
struct timespec timeout = {1, 0};
if(bus_set != NULL) {
for(auto bus_iter = bus_set->begin(); bus_iter != bus_set->end(); bus_iter++) {
@@ -25,7 +25,6 @@
}
shm_close_socket(shm_socket);
-// printf("ShmModSocket destory 4\n");
}
int ShmModSocket::bind(int key) {
@@ -236,7 +235,6 @@
memcpy(head.action, "desub", sizeof(head.action));
head.topic_size = topic_size = strlen(topic) + 1;
head.content_size = 0;
-
void *buf;
int size = get_bus_sendbuf(head, topic, topic_size, NULL, 0, &buf);
if(size > 0) {
@@ -328,7 +326,7 @@
memcpy(tmp_ptr, head.action, sizeof(head.action));
- tmp_ptr += 4;
+ tmp_ptr += sizeof(head.action);
PUT(tmp_ptr, htonl(head.topic_size));
tmp_ptr += 4;
@@ -343,12 +341,11 @@
memcpy(head.action, tmp_ptr, sizeof(head.action));
- tmp_ptr += 4;
+ tmp_ptr += sizeof(head.action);
head.topic_size = ntohl(GET(tmp_ptr));
tmp_ptr += 4;
head.content_size = ntohl(GET(tmp_ptr));
-
return head;
}
--
Gitblit v1.8.0