update

wangzhengquan

2021-01-14 be5decd9d3386542062f095aad29bf0267d604b8

update

 src/queue/lock_free_queue.h

@@ -355,7 +355,7 @@
        else if(errno == EINTR)
            continue;
        else {
          // LoggerFactory::getLogger()->error(errno, "LockFreeQueue pop_timeout %d", errno);
          LoggerFactory::getLogger()->error(errno, "LockFreeQueue pop_timeout %d", errno);
          return errno;
        }
    }

 src/socket/shm_socket.cpp

@@ -387,7 +387,7 @@
    mm_free(dest.buf);
    if(rv == EBUS_TIMEOUT) {
      // bus_errno = EBUS_TIMEOUT;
      logger->error(rv, "sendto key %d failed, %s", key, bus_strerror(EBUS_TIMEOUT));
      // logger->error("sendto key %d failed, %s", key, bus_strerror(EBUS_TIMEOUT));
      return EBUS_TIMEOUT;
    } else {
      //logger->error(errno, "sendto key %d failed!", key);
@@ -459,11 +459,10 @@
  } else {

    if(rv == EBUS_TIMEOUT) {
      // bus_errno = EBUS_TIMEOUT;
      logger->error("shm_recvfrom  failed, %s", bus_strerror(EBUS_TIMEOUT));
      // logger->error("shm_recvfrom  failed, %s", bus_strerror(EBUS_TIMEOUT));
      return EBUS_TIMEOUT;
    } else {
      logger->error(rv, "shm_recvfrom  failed!");
      // logger->error(rv, "shm_recvfrom  failed!");
      return rv;
    }