1

我有一个将消息接收到套接字的服务器，并且对于接收到的每条消息，执行一个 fork exec。这部分似乎工作正常。

但是我需要在非阻塞模式下执行此操作，因此我创建了一个处理程序来正确清理所有终止的子进程waitpid()（如论坛中的许多主题中所述）。

问题是这个处理程序对我的pselect命令产生了一个中断的系统调用，它通过以下消息停止程序：
"select(): Interrupted system call"

我在“Preventing race conditions”之类的论坛上找到了一些关于这个问题的解释，所以我尝试用它sigprocmask()来阻止几个信号，但它没有奏效。

我确信这是一个微不足道的问题，但这是我第一次使用这种程序。

我需要一些帮助。提前致谢。

这是程序：

void
clean_up_child_process (int signal_number)
{

  pid_t p;
  int status;

  while (1)
    {
      p = waitpid (-1, &status, WNOHANG);

      if (p == -1)
        {
          if (errno == EINTR)
            {
              continue;
            }
          break;
        }
      else if (p == 0)
        {
          break;
        }
    }


}

static void
app (void)
{
  SOCKET sock;
  char commande[BUF_SIZE];
  char res_cmd[BUF_SIZE];
  int max;
  int n;

  sock = init_connection ();
  max = sock;
  fd_set rdfs;

  sigemptyset (&sigmask);
  sigaddset (&sigmask, SIGCHLD);
  sigaddset (&sigmask, SIGINT);
  sigaddset (&sigmask, SIGTSTP);
  sigaddset (&sigmask, SIGTERM);
  sigprocmask (SIG_BLOCK, &sigmask, NULL);

  struct sigaction sigchld_action;
  memset (&sigchld_action, 0, sizeof (sigchld_action));
  sigchld_action.sa_handler = &clean_up_child_process;
  sigaction (SIGCHLD, &sigchld_action, NULL);

  while (1)
    {
      int i = 0;
      FD_ZERO (&rdfs);

      /* add STDIN_FILENO */
      FD_SET (STDIN_FILENO, &rdfs);

      /* add the connection socket */
      FD_SET (sock, &rdfs);

      sigemptyset (&empty_mask);
      if (pselect (max + 1, &rdfs, NULL, NULL, NULL, &empty_mask) == -1)
        if (errno != EINTR)
          {
            perror ("select()");
            exit (errno);
          }

      if (FD_ISSET (STDIN_FILENO, &rdfs))
        {
          /* stop process when type on keyboard */
          // break; must be disable to avoid bad exits
        }
      else if (FD_ISSET (sock, &rdfs))
        {
          /* new client */
          SOCKADDR_IN csin = { 0 };
          size_t sinsize = sizeof csin;
          int csock = accept (sock, (SOCKADDR *) & csin, &sinsize);
          if (csock == SOCKET_ERROR)
            {
              perror ("accept()");
              continue;
            }

          if ((n = recv (csock, commande, BUF_SIZE - 1, 0)) < 0)
            {
              perror ("recv(commande)");
              n = 0;
              continue;
            }
          commande[n] = 0;
          if ((n = fork ()) == -1)
            perror ("fork()");
          else if (n == 0)
            {
              close (STDOUT_FILENO);
              dup (csock);
              close (STDERR_FILENO);
              dup (csock);
              execlp (commande, commande, 0);
            }
          else
            {
              closesocket (csock);
            }
        }
    }
  end_connection (sock);
}
4

1 回答 1

0

您需要了解更多关于 POSIX 信号处理的知识。

当在可中断系统调用期间（在本例中pselect）接收到信号时，信号调用将退出回用户空间并调用信号处理程序。信号处理程序完成后，正常的行为是信号调用返回EINTR。在某些系统上，可以通过发出信号操作来避免这种SA_RESTART情况，在这种情况下内核将自动重新启动系统调用。这听起来是一个不错的选择，直到您意识到您经常想要捕获类似的信号SIGINT并让它们设置一个全局变量（例如退出程序）并对其进行测试。因此，如下结构（适用于您的程序）很常见：

volatile sig_atomic_t rxsig_quit = 0;

void
handlesignal (int sig)
{
  /* Only do signal safe things here; remember mutexes may be held */
  switch (sig)
    {
    case SIGINT:
    case SIGTERM:
      rxsig_quit++;
      break;
    case SIGCHLD:
      /* do all our waiting here */
      while (1)
        {
          int status;
          waitpid (WAIT_ANY, &status, WNOHANG);
        }
      break;
    }
}

static void
app (void)
{

  /* ... */

  while (!rxsig_quit)
    {
      /* ... */

      do
        {
          int ret;
          ret = pselect (max + 1, &rdfs, NULL, NULL, NULL, &empty_mask);
        }
      while ((ret < 0) && (errno == EINTR) && !rxsig_quit);

      /* ... */
    }

  /* ... */
}

您可以使用 获取更多信息man -s7 signal。这还列出了异步安全函数，即您可以在信号处理程序中安全调用的函数。

但是，您假设您根本需要这样做wait。在现代 POSIX 系统上，情况并非如此。您可以设置SIGCHLD为SIG_IGN，在这种情况下操作系统将完成工作，根据手册页中的这一段wait(2)：

POSIX.1-2001指定如果 的处置设置为SIGCHLD或SIG_IGN标志SA_NOCLDWAIT设置SIGCHLD为设置为. （原始 POSIX 标准未指定设置行为。请注意，即使默认处置是“忽略”，显式设置处置会导致对僵尸进程子进程的不同处理。） Linux 2.6 符合此规范。但是，Linux 2.4（及更早版本）不会：如果在忽略时进行了 wait() 或调用，则调用的行为就像sigaction(2)wait()waitpid()ECHILDSIGCHLDSIG_IGNSIGCHLDSIG_IGNwaitpid()SIGCHLDSIGCHLD没有被忽略，也就是说，调用会阻塞，直到下一个子进程终止，然后返回该子进程的进程 ID 和状态。

显然，这不太便携。

于 2014-08-16T16:21:30.833 回答