update

wangzhengquan

2021-01-22 6a1a06f1506b88b769955ddc57035cf166f64ef4

update

 src/queue/lock_free_queue.h

@@ -303,7 +303,7 @@
int LockFreeQueue<ELEM_T, Allocator, Q_TYPE>::pop(ELEM_T &a_data)
{

 // LoggerFactory::getLogger()->debug("==================LockFreeQueue pop before\n");
 LoggerFactory::getLogger()->debug("==================LockFreeQueue pop before\n");
    if (sem_wait(&items) == -1) {
        LoggerFactory::getLogger()->error(errno, "LockFreeQueue pop");
        return errno;
@@ -311,7 +311,7 @@

    if (m_qImpl.pop(a_data)) {
        sem_post(&slots);
// LoggerFactory::getLogger()->debug("==================LockFreeQueue pop after\n");      
LoggerFactory::getLogger()->debug("==================LockFreeQueue pop after\n");      
        return 0;
    }
    return -1;

 src/queue/shm_queue.h

@@ -186,15 +186,15 @@
}

template <typename ELEM_T> inline int SHMQueue<ELEM_T>::pop(ELEM_T &a_data) {
  // printf("SHMQueue pop before\n");
 printf("SHMQueue pop before\n");
  int rv = queue->pop(a_data);
  // printf("SHMQueue after before\n");
 printf("SHMQueue after before\n");
  return rv;
}

template <typename ELEM_T>
inline int SHMQueue<ELEM_T>::pop_nowait(ELEM_T &a_data) {
  return queue->pop_nowait(a_data);
  int rv = queue->pop_nowait(a_data);
}

template <typename ELEM_T>