update

wangzhengquan

2021-02-08 e1bea2c6430ddadd589fd3377b69ca06226bb872

update

 src/CMakeLists.txt

@@ -30,10 +30,11 @@
if (BUILD_SHARED_LIBS)
  add_library(shm_queue SHARED ${_SOURCES_})
else()
 add_library(shm_queue STATIC ${_SOURCES_})
 add_library(shm_queue SHARED ${_SOURCES_})
endif()

#add_library(shm_queue ${_SOURCES_})
# STATIC
# add_library(shm_queue ${_SOURCES_})

target_include_directories(shm_queue PUBLIC ${EXTRA_INCLUDES} )


 src/bus_error.cpp

@@ -11,7 +11,7 @@
static pthread_key_t strerrorKey;


static char *_bus_errlist[_bus_nerr] = {
static const char *_bus_errlist[_bus_nerr] = {
  "\0",
  "Timed out",
  "The other end is not inline",

 src/shm/shm_mm_wrapper.cpp

@@ -31,6 +31,7 @@
    if(difftime(time(NULL), mqueue->getCreateTime()) > BUFFER_TIME ) {
      delete mqueue;
      hashtable_remove(hashtable, keys[i]);
      LoggerFactory::getLogger()->debug("remove queue %d",  keys[i]);
      count++;
    }
    
@@ -62,6 +63,7 @@
      if(difftime(time(NULL), mqueue->getCreateTime()) > BUFFER_TIME ) {
        delete mqueue;
        hashtable_remove(hashtable, *keyItr);
        LoggerFactory::getLogger()->debug("remove queue %d",  *keyItr);
        count++;
      }
     

 src/socket/shm_socket.cpp

@@ -418,12 +418,13 @@
    void *_buf = malloc(recvpak.size);
    memcpy(_buf, recvpak.buf, recvpak.size);
    *recv_buf = _buf; 
    mm_free(recvpak.buf);
  }
 
  if(recv_size != NULL)
    *recv_size = recvpak.size;

  mm_free(recvpak.buf);
 

  return 0;

@@ -524,12 +525,13 @@
    void *_buf = malloc(recvpak.size);
    memcpy(_buf, recvpak.buf, recvpak.size);
    *recv_buf = _buf; 
    mm_free(recvpak.buf);
  }
 
  if(recv_size != NULL)
    *recv_size = recvpak.size;

  mm_free(recvpak.buf);
  
  return 0;
}