概述
最近在看Nginx源码，看的是ngx_master_process_cycle()函数，这个函数中用到了信号处理。以下是节选:
...
sigset_t set;
...
sigemptyset(&set);
sigaddset(&set, SIGCHLD);
sigaddset(&set, SIGALRM);
sigaddset(&set, SIGIO);
sigaddset(&set, SIGINT);
sigaddset(&set, ngx_signal_value(NGX_RECONFIGURE_SIGNAL));
sigaddset(&set, ngx_signal_value(NGX_REOPEN_SIGNAL));
sigaddset(&set, ngx_signal_value(NGX_NOACCEPT_SIGNAL));
sigaddset(&set, ngx_signal_value(NGX_TERMINATE_SIGNAL));
sigaddset(&set, ngx_signal_value(NGX_SHUTDOWN_SIGNAL));
sigaddset(&set, ngx_signal_value(NGX_CHANGEBIN_SIGNAL));
if (sigprocmask(SIG_BLOCK, &set, NULL) == -1) {
ngx_log_error(NGX_LOG_ALERT, cycle->log, ngx_errno,
"sigprocmask() failed");
}
sigemptyset(&set);
...
for( ；；){
...
sigsuspend(&set);
...
}
...
这段代码让我有几个问题：
- 每个函数的作用是什么？
- 怎么收到信号？在哪实现？
- 为何在sigaddset之后还要sigemptyset呢？
几个问题的解答
每个函数的作用是什么？
这个问题在我的文章——Nginx源码|ngx_master_process_cycle()函数中的“补充”部分有解释;
怎么收到信号？在哪实现？
一开始我也在找接收信号的代码。因为当进程被sigsuspend
(&set)函数挂起时，在set收到新的信号的情况下才会被唤醒，但是，什么时候set才会有新的信号呢?
之后我进入了ngx_process.c文件,找到了ngx_int_t
ngx_init_signals(ngx_log_t *log):
ngx_int_t
ngx_init_signals(ngx_log_t *log)
{
ngx_signal_t *sig;
struct sigaction sa;
for (sig = signals; sig->signo != 0; sig++) {
ngx_memzero(&sa, sizeof(struct sigaction));
if (sig->handler) {
sa.sa_sigaction = sig->handler;
sa.sa_flags = SA_SIGINFO;
} else {
sa.sa_handler = SIG_IGN;
}
sigemptyset(&sa.sa_mask);
if (sigaction(sig->signo, &sa, NULL) == -1) {
#if (NGX_VALGRIND)
ngx_log_error(NGX_LOG_ALERT, log, ngx_errno,
"sigaction(%s) failed, ignored", sig->signame);
#else
ngx_log_error(NGX_LOG_EMERG, log, ngx_errno,
"sigaction(%s) failed", sig->signame);
return NGX_ERROR;
#endif
}
}
return NGX_OK;
}
这个函数用到了sigaction()函数
int sigaction(int sig, const struct sigaction *act, struct sigaction *oact)
还有struct sigaction结构体
stuct sigaction
{
void (*)(int) sa_handle;
sigset_t sa_mask;
int sa_flags;
}
功能:
- 用来查询或设置信号处理方式,设置某一信号的处理函数。
- sa_mask，信号屏蔽集，可以通过函数sigemptyset/sigaddset等来清空和增加需要屏蔽的信号，上面代码中，对信号SIGINT处理时，如果来信号SIGQUIT，其将被屏蔽，但是如果在处理SIGQUIT，来了SIGINT，则首先处理SIGINT，然后接着处理SIGQUIT。
- sa_flags如果取值为0，则表示默认行为。还可以取如下俩值，但是我没觉得这俩值有啥用。
SA_NODEFER，如果设置来该标志，则不进行当前处理信号到阻塞
SA_RESETHAND，如果设置来该标志，则处理完当前信号后，将信号处理函数设置为SIG_DFL行为
- sa_handle是信号处理函数,当有信号来时,会调用该信号处理函数对信号进行处理。
因此,接收信号是在ngx_int_t
ngx_init_signals(ngx_log_t *log)函数中实现的,通过sigaction与sigsuspend相配合实现信号机制。
为何在sigaddset之后还要sigemptyset呢？
因为sigsuspend(&set)函数需要set中有新的信号来才会被唤醒,所以一开始用sigaddset函数将所有信号添加入set中,再用sigprocmask进行掩码设置,添加set中的信号掩码到目前的信号掩码中,设置了信号掩码后,set就可被清空了,然后调用sigsuspend函数,如果没有清空,就算接收到信号也不会唤醒进程,因为set中所有的信号都有,接收到的任何信号都不是新的信号,所以不会唤醒进程。
