Блог

У меня проблема в теме процессов posix, и я не могу обойти.

У меня есть процесс, который разветвляет несколько дочерних процессов (дерево процессов может быть сложным, а не только на одном уровне). Он также отслеживает PID активных дочерних процессов. В какой-то момент родитель получает сигнал (скажем, SIGINT).

В обработчике сигналов для SIGINT он перебирает список дочерних процессов и отправляет им тот же сигнал, чтобы предотвратить зомби. Теперь проблема в том, что

1. если родитель не выполняет функцию waitpid() для остановки дочернего процесса, сигнал, похоже, никогда не отправляется (зомби продолжают работать)
2. если родительский элемент ожидает после каждого kill(), отправленного дочернему элементу, он просто зависает там, и дочерний элемент, похоже, игнорирует сигнал

У родительских и дочерних процессов один и тот же обработчик сигналов, поскольку он установлен перед разветвлением. Вот псевдокод.

 signal_handler( signal )
    foreach child in children
        kill( child, signal )
        waitpid( child, status )

    // Releasing system resources, etc.
    clean_up()

    // Restore signal handlers.
    set_signal_handlers_to_default()

    // Send back the expected "I exited after XY signal" to the parent by
    // executing the default signal handler again.
    kill( getpid(), signal )
 

В этой реализации выполнение останавливается на идентификаторе ожидания. Если я удалю идентификатор ожидания, дочерние процессы продолжат работать.

Я предполагаю, что, если обработчик сигналов не завершен, сигналы, отправленные с него, не отправляются дочерним процессам. Но почему они не отправляются, если я опускаю wait?

Заранее большое спасибо!

То, что вы описываете, должно работать, и это действительно так, со следующим тестовым примером:

 #include <stdio.h>
#include <unistd.h>
#include <signal.h>

#define NCHILDREN 3
pid_t child [NCHILDREN];

struct sigaction sa, old;

static void
handler (int ignore)
{
  int i;

  /* Kill the children.  */
  for (i = 0; i < NCHILDREN;   i)
    {
      if (child [i] > 0)
        {
          kill (child [i], SIGUSR1);
          waitpid (child [i], 0, 0);
        }
    }

  /* Restore the default handler.  */
  sigaction (SIGUSR1, amp;old, 0);

  /* Kill self.  */
  kill (getpid (), SIGUSR1);
}

int
main ()
{
  int i;

  /* Install the signal handler.  */
  sa.sa_handler = handler;
  sigemptyset (amp;sa.sa_mask);
  sa.sa_flags = 0;
  sigaction (SIGUSR1, amp;sa, amp;old);

  /* Spawn the children.  */
  for (i = 0; i < NCHILDREN;   i)
    {
      if ((child [i] = fork ()) == 0)
        {
          /* Each of the children: clear the array, wait for a signal
             and exit.  */
          while (i >= 0)
            child [i--] = -1;
          pause ();
          return 0;
        }
    }

  /* Wait to be interrupted by a signal.  */
  pause ();
  return 0;
}
 

Если вы видите, что родительский элемент зависает waitpid , это означает, что дочерний элемент не вышел. Попробуйте подключиться с помощью отладчика, чтобы увидеть, где заблокирован дочерний процесс, или, что проще, запустите программу strace(1) . Как вы очищаете свой pid-массив? Убедитесь, что дочерние процессы не пытаются выполнить вызов waitpid с параметром pid, равным <= 0. Убедитесь, что дочерние процессы не блокируют или игнорируют сигнал.