add timeout nowait

wangzhengquan

2020-08-03 b63ce299ddacea2ad487dc635926ed52ff422c20

 src/util/sem_util.c

@@ -72,7 +72,7 @@

/* Reserve semaphore - decrement it by 1 */
int SemUtil::dec(int semId) {
logger.debug("%d: SemUtil::dec\n", semId);
// logger.debug("%d: SemUtil::dec\n", semId);
  struct sembuf sops;

  sops.sem_num = 0;
@@ -81,7 +81,7 @@

  while (semop(semId, &sops, 1) == -1)
    if (errno != EINTR) {
      err_msg(errno, "SemUtil::dec");
     // err_msg(errno, "SemUtil::dec");
      return -1;
    }

@@ -97,7 +97,7 @@

  while (semop(semId, &sops, 1) == -1)
    if (errno != EINTR) {
      err_msg(errno, "SemUtil::dec_nowait");
     // err_msg(errno, "SemUtil::dec_nowait");
      return -1;
    }

@@ -113,7 +113,7 @@

  while (semtimedop(semId, &sops, 1, timeout) == -1)
    if (errno != EINTR) {
      err_msg(errno, "SemUtil::dec_timeout");
      //err_msg(errno, "SemUtil::dec_timeout");
      return -1;
    }