update

wangzhengquan

2020-12-24 dbf7fd6f620b86c382431ce10fd5fe3c5ddca955

 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;
printf("sizeof(head.action) = %d\n", sizeof(head.action));
   void *buf;
   int size = get_bus_sendbuf(head, topic,  topic_size, NULL,  0, &buf);
   if(size > 0) {
@@ -349,7 +347,6 @@
  tmp_ptr += 4;
  head.content_size = ntohl(GET(tmp_ptr));
 
printf("ShmModSocket::decode_bus_head action : %s\n", head.action);
  return head;
}