src/queue/include/shm_queue.h
@@ -103,12 +103,11 @@ SemUtil::dec(queue->mutex); queue->reference--; // LoggerFactory::getLogger().debug("SHMQueue destructor reference===%d", // queue->reference.load()); if (queue->reference.load() == 0) { // delete queue; delete queue; hashtable_t *hashtable = mm_get_hashtable(); hashtable_remove(hashtable, KEY); // LoggerFactory::getLogger().debug("SHMQueue destructor delete queue\n"); // printf("SHMQueue destructor delete queue\n"); } else { SemUtil::inc(queue->mutex); }