update

wangzhengquan

2020-07-10 e169b50d548bc23021bea6f8971e3094e6bc216b

update

 queue/include/shm_queue.h

@@ -82,7 +82,7 @@
{
    queue->reference--;
    LoggerFactory::getLogger().debug("SHMQueue destructor  reference===%d", queue->reference.load());
    if(queue->reference == 0) {
    if(queue->reference.load() == 0) {
        delete queue;
        hashtable_t *hashtable = getHashTable();
        hashtable_remove(hashtable, KEY);

 queue/mm.c

@@ -74,9 +74,8 @@
static void *mem_sbrk(int incr);
static int is_allocated(void *ptr);


static  int shmid = -1;
static  void *shmp;
static int shmid = -1;
static void *shmp;
static int mutex = SemUtil::get(SHM_MUTEX_KEY, 1);
//static int mutex = SemUtil::get(IPC_PRIVATE, 1);