commit

wangzhengquan

2020-07-25 8ec1d776751f62c43335d36c3427dc1ab2d84a61

 src/queue/include/shm_queue.h

@@ -104,7 +104,7 @@
        delete queue;
        hashtable_t *hashtable = mm_get_hashtable();
        hashtable_remove(hashtable, KEY);
        LoggerFactory::getLogger().debug("SHMQueue destructor delete queue");
printf("SHMQueue destructor delete queue\n");
    } else {
        SemUtil::inc(queue->mutex);
    }
@@ -159,7 +159,10 @@
template < typename ELEM_T >
inline bool SHMQueue<ELEM_T>::pop(ELEM_T &a_data)
{
   return queue->pop(a_data);
// printf("SHMQueue pop before\n");
   int rv = queue->pop(a_data);
// printf("SHMQueue after before\n");
   return rv;
    
}