update

wangzhengquan

2021-01-25 c46be6db32872bfd7c4010b43526b5e6bc0fa6a5

 src/queue/lock_free_queue.h

@@ -213,15 +213,15 @@
    LoggerFactory::getLogger()->debug("==================LockFreeQueue push before\n");
    if ((flag & BUS_NOWAIT_FLAG) == BUS_NOWAIT_FLAG) {
        if (psem_trywait(&slots) == -1) {
            return -1;
          return errno;
        }
    } else if ((flag & BUS_TIMEOUT_FLAG) == BUS_TIMEOUT_FLAG && timeout != NULL) {
        if (psem_timedwait(&slots, timeout) == -1) {
            return -1;
          return errno;
        }
    } else {
        if (psem_wait(&slots) == -1) {
            return -1;
          return errno;
        }
    }

@@ -239,21 +239,20 @@
        typename Allocator,
        template<typename T, typename AT> class Q_TYPE>
int LockFreeQueue<ELEM_T, Allocator, Q_TYPE>::pop(ELEM_T &a_data, const struct timespec *timeout, int flag) {

    LoggerFactory::getLogger()->debug("==================LockFreeQueue pop before\n");

  LoggerFactory::getLogger()->debug("==================LockFreeQueue pop before....");

    if ((flag & BUS_NOWAIT_FLAG) == BUS_NOWAIT_FLAG) {
        if (psem_trywait(&items) == -1) {
            return -1;
          return errno;
        }
    } else if ((flag & BUS_TIMEOUT_FLAG) == BUS_TIMEOUT_FLAG && timeout != NULL) {
    LoggerFactory::getLogger()->debug("==================LockFreeQueue pop before. flag=%d ,  %d\n", flag, timeout->tv_sec);
        if (psem_timedwait(&items, timeout) == -1) {
            return -1;
          return errno;
        }
    } else {
        if (psem_wait(&items) == -1) {
            return -1;
          return errno;
        }
    }