sigsuspend sigprocmask函数的用法

一个进程的信号屏蔽字规定了当前堵塞而不能递送给该进程的信号集。调用函数sigprocmask能够检測或更改其信号屏蔽字，或者在一个步骤中同一时候运行这两个操作。

#include <signal.h>
int sigprocmask( int how, const sigset_t *restrict set, sigset_t *restrict oset );
返回值：若成功则返回0，若出错则返回-1

首先，若oset是非空指针，那么进程的当前信号屏蔽字通过oset返回。

其次，若set是一个非空指针，则參数how指示怎样改动当前信号屏蔽字。

表10-4说明了how可选用的值。注意，不能堵塞SIGKILL和SIGSTOP信号。

表10-4 用sigprocmask更改当前信号屏蔽字的方法

how	说明
SIG_BLOCK	该进程新的信号屏蔽字是其当前信号屏蔽字和set指向信号集的并集。set包括了我们希望堵塞的附加信号
SIG_UNBLOCK	该进程新的信号屏蔽字是其当前信号屏蔽字和set所指向信号集补集的交集。set包括了我希望解除堵塞的信号
SIG_SETMASK	该进程新的信号屏蔽字将被set指向的信号集的值取代

假设set是空指针，则不改变该进程的信号屏蔽字，how的值也无意义。

在调用sigprocmask后假设有不论什么未决的、不再堵塞的信号，则在sigprocmask返回前，至少会将当中一个信号递送给该进程。

1、有时候不希望在接到信号时就马上停止当前运行，去处理信号，同一时候也不希望忽略该信号，而是延时一段时间去调用信号处理函数。这样的情况是通过堵塞信号实现的。

 

2、信号堵塞和忽略信号的差别。

堵塞的概念和忽略信号是不同的。操作系统在信号被进程解除堵塞之前不会讲信号传递出去，被堵塞的信号也不会影响进程的行为，信号仅仅是临时被阻止传递。当进程忽略一个信号时，信号会被传递出去但进程会将信号丢弃。

1)头文件：#include <signal.h>

2）一个保护临界区代码的错误实例：(sigprocmask()和pause()实现)

#include <unistd.h>

#include <signal.h>

#include <stdio.h>

 

void handler(intsig)   //信号处理函数的实现

{

   printf("SIGINT sig");

}

int main()

{

    sigset_tnew,old;

    structsigaction act;

   act.sa_handler = handler;  //信号处理函数handler

   sigemptyset(&act.sa_mask);

   act.sa_flags = 0;

   sigaction(SIGINT, &act, 0); //准备捕捉SIGINT信号

   sigemptyset(&new);

   sigaddset(&new, SIGINT);

   sigprocmask(SIG_BLOCK, &new,&old); //将SIGINT信号堵塞，同一时候保存当前信号集

   printf("Blocked");

   sigprocmask(SIG_SETMASK, &old,NULL);  //取消堵塞

   pause();

    return0；

}

上面实例的问题是：本来期望pause()之后，来SIGINT信号，能够结束程序；但是，假设当“取消堵塞”和“pause”之间，正好来了SIGINT信号，结果程序由于pause的原因会一直挂起。。。

解决的方式，当然是sigsuspend()函数了。

 

3）使用sigsuspend()的程序

#include <unistd.h>

#include <signal.h>

#include <stdio.h>

void handler(int sig)  //信号处理程序

{

   if(sig == SIGINT)

     printf("SIGINT sig");

   else if(sig == SIGQUIT)

     printf("SIGQUIT sig");

   else

     printf("SIGUSR1 sig");

}

 

int main()

{

    sigset_tnew,old,wait;   //三个信号集

    structsigaction act;

   act.sa_handler = handler;

   sigemptyset(&act.sa_mask);

   act.sa_flags = 0;

   sigaction(SIGINT, &act,0);   //能够捕捉下面三个信号：SIGINT/SIGQUIT/SIGUSR1

   sigaction(SIGQUIT, &act, 0);

   sigaction(SIGUSR1, &act, 0);

   

   sigemptyset(&new);

    sigaddset(&new,SIGINT);  //SIGINT信号增加到new信号集中

   sigemptyset(&wait);

   sigaddset(&wait, SIGUSR1); //SIGUSR1信号增加wait

   sigprocmask(SIG_BLOCK, &new,&old);      //将SIGINT堵塞，保存当前信号集到old中

   

    //临界区代码运行    

  

   if(sigsuspend(&wait) != -1) //程序在此处挂起；用wait信号集替换new信号集。即：过来SIGUSR1信 号，堵塞掉，程序继续挂起；过来其它信号，比如SIGINT，则会唤醒程序。运行sigsuspend的原子操作。注意：假设“sigaddset(&wait,SIGUSR1);”这句没有，则此处不会堵塞不论什么信号，即过来不论什么信号均会唤醒程序。

       printf("sigsuspend error");

    printf("Aftersigsuspend");

   sigprocmask(SIG_SETMASK, &old, NULL);

    return0;

}

sigsuspend的原子操作是：

（1）设置新的mask堵塞当前进程(上面是用wait替换new，即堵塞SIGUSR1信号)

（2）收到SIGUSR1信号，堵塞，程序继续挂起；收到其它信号，恢复原先的mask(即包括SIGINT信号的)。

（3）调用该进程设置的信号处理函数(程序中假设先来SIGUSR1信号，然后过来SIGINT信号，则信号处理函数会调用两次，打印不同的内容。第一次打印SIGINT,第二次打印SIGUSR1，由于SIGUSR1是前面堵塞的)

（4）待信号处理函数返回，sigsuspend返回了。(sigsuspend将捕捉信号和信号处理函数集成到一起了)

总结：

在nginx源代码中，ngx_master_process_cycle函数中，首先调用了sigprocmask()函数堵塞了部分信号，在for循环中调用了sigsuspend函数 ，可是sigsuspend函数中的set为空，也就是说，在for循环之前，假设有set集合中的信号到来就堵塞，在for循环之内，不论什么信号到来都进程处理。函数返回之后同一时候也恢复了原来的信号掩码！

sigsuspend的整个原子操作过程为：
(1) 设置新的mask堵塞当前进程；
(2) 收到信号，恢复原先mask；
(3) 调用该进程设置的信号处理函数；
(4) 待信号处理函数返回后，sigsuspend返回。
大致就是上面这个过程，噢，原来signal handler是原子操作的一部分，并且是在恢复屏蔽字后运行的，

int sigsuspend(const sigset_t *sigmask);

此函数用于进程的挂起，sigmask指向一个信号集。当此函数被调用时，sigmask所指向的信号集中的信号将赋值给信号掩码。之后进程挂起。直到进程捕捉到信号，并调用处理函数返回时，函数sigsuspend返回。信号掩码恢复为信号调用前的值，同一时候将errno设为EINTR。进程结束信号可将其马上停止。

    #include <stdio.h>  
    #include <signal.h>  
      
    void checkset();  
    void func();  
    void main()  
    {  
         sigset_tblockset,oldblockset,zeroset,pendmask;  
         printf("pid:%ld
",(long)getpid());  
         signal(SIGINT,func);  
      
         sigemptyset(&blockset);  
         sigemptyset(&zeroset);  
         sigaddset(&blockset,SIGINT);  
      
         sigprocmask(SIG_SETMASK,&blockset,&oldblockset);  
         checkset();  
         sigpending(&pendmask);  
      
         if(sigismember(&pendmask,SIGINT))  
             printf("SIGINTpending
");  
      //不堵塞不论什么信号 不论什么信号到来都会激活进程
         if(sigsuspend(&zeroset)!= -1)  
         {  
         printf("sigsuspenderror
");  
         exit(0);  
         }  
      
         printf("afterreturn
");  
         sigprocmask(SIG_SETMASK,&oldblockset,NULL);  
      
         printf("SIGINTunblocked
");  
    }  
      
    void checkset()  
    {    sigset_tset;  
         printf("checksetstart:
");  
         if(sigprocmask(0,NULL,&set)<0)  
         {  
         printf("checksetsigprocmask error!!
");  
         exit(0);  
         }  
      
         if(sigismember(&set,SIGINT))  
         printf("sigint
");  
      
         if(sigismember(&set,SIGTSTP))  
         printf("sigtstp
");  
      
         if(sigismember(&set,SIGTERM))  
         printf("sigterm
");  
         printf("checksetend
");  
    }  
      
    void func()  
    {  
         printf("hellofunc
");  
    }  

结果：

pid:5474
checksetstart:
sigint
checksetend
^Chellofunc
afterreturn
checksetstart:
checksetend
SIGINTunblocked

从执行的结果 以及和上面的样例进行比較较就能够知道这两个函数的函数。