Chinaunix首页 | 论坛 | 博客
  • 博客访问: 52065
  • 博文数量: 6
  • 博客积分: 139
  • 博客等级: 入伍新兵
  • 技术积分: 120
  • 用 户 组: 普通用户
  • 注册时间: 2011-06-29 15:00
文章分类
文章存档

2011年(6)

分类: C/C++

2011-06-30 20:08:37

在阅读《APUE》的第十章第16节关于sigsuspend部分的内容时,不太清楚调用该函数后对原有进程阻塞的信号是否仍然阻塞这个问题,加上书中给出的第一个例子里信号处理程序输出的阻塞信号居然是SIGINTSIGUSR1,这就更加导致了我对这一问题的疑惑。以下是源码:

 

  1. #include <unistd.h>
  2. #include <signal.h>
  3. #include <stdio.h>
  4. #include <string.h>
  5. #include <errno.h>

  6. static void pr_mask(const char *cmd)
  7. {
  8.     sigset_t sigset;
  9.     int errno_save;

  10. /*防止对信号集进行判断操作时,改变errno里的值*/
  11.     errno_save = errno;
  12.     if(sigprocmask(0, NULL, &sigset) < 0)
  13.     {
  14.         printf("%s : sigprocmask failed!\n",__func__);
  15.         return -1;
  16.     }

  17.     printf("%s :",cmd);
  18.     if(sigismember(&sigset, SIGINT) )
  19.         printf("SIGINT ");
  20.     if(sigismember(&sigset, SIGQUIT) )
  21.         printf("SIGQUIT ");
  22.     if(sigismember(&sigset, SIGUSR1) )
  23.         printf("SIGUSR1 ");
  24.     if(sigismember(&sigset, SIGALRM) )
  25.         printf("SIGALARM ");

  26.     printf("\n");
  27.     errno = errno_save;    
  28. }

  29. static void sig_deal(int signo)
  30. {
  31.     pr_mask("\n In sig_deal!");
  32. }

  33. int main(void)
  34. {
  35.     sigset_t newmask, oldmask, waitmask;

  36.     pr_mask("program start");

  37.     if(signal(SIGINT, sig_deal) == SIG_ERR)
  38.     {
  39.         printf("%s : signal function failed!\n",__func__);
  40.         return -1;
  41.     }

  42.     sigemptyset(&newmask);
  43.     sigemptyset(&waitmask);
  44.     sigaddset(&newmask, SIGINT);
  45.     sigaddset(&waitmask ,SIGUSR1);

  46.     if(sigprocmask(SIG_BLOCK, &newmask, &oldmask) < 0)
  47.     {
  48.         printf("%s : sigprocmask failed!\n",__func__);
  49.         return -1;
  50.     }

  51.     pr_mask("\n In middle");

  52.     if(sigsuspend(&waitmask) != -1)
  53.     {
  54.         printf("%s : sigsuspend failed!\n",__func__);
  55.         return -1;
  56.     }

  57.     pr_mask("\n after sigsuspend");

  58.     if(sigprocmask(SIG_SETMASK, &oldmask, NULL) < 0)
  59.     {
  60.         printf("%s : sigprocmask failed!",__func__);
  61.         return -1;
  62.     }

  63.     pr_mask("\n In end");

  64.     return 0;
  65. }

输出信息:

       program start :

      In middle :SIGINT

^C

In sig_deal! :SIGINT SIGUSR1

after sigsuspend :SIGINT

In end :

       在网上阅读了不少网友的博文和前后回顾了《APUE》的内容之后,终于明白在信号处理函数中打印SIGINTSIGURS1的原因:这是因为执行了以下步骤:

1)  进程调用第一个sigprocmask阻塞信号SIGINT,于是打印In middle :SIGINT

2)  进程调用sigsuspend之后,进程的信号屏蔽字被替换为至阻塞信号SIGUSR1。此时进程被挂起,等待除SIGUSR1以外的信号使进程从sigsuspend中唤醒。这里有两种情况:

a)       信号使进程结束,则sigsuspend不会返回

b)      执行信号处理程序,sigsuspend返回-1,并且将进程屏蔽字替换为调用函数之前的屏蔽字。

3)  产生中断信号SIGINT之后,进入信号处理函数sig_deal,输出的内容是:

In sig_deal! :SIGINT SIGUSR1”。

此时sigsuspend并未返回,因此对信号SIGUSR1是保持阻塞的。并且因为是在信号处理程序之中,所以系统自动将SIGINT阻塞,以防止信号处理程序被中断的情况发生。这里并不是因为sigsuspend返回了,所以有对SIGINT的阻塞。

4)  sigsuspend返回之后,恢复了之前对信号SIGINT的阻塞,因此输出的内容是:

after sigsuspend :SIGINT”。

 

       Sigsuspend提供了一种等待信号的系统调用,和pause类似。只是当需要等待某个信号的时候,直接调用pause会有一个时间窗口。如果在该时间窗口内产生了信号,则pause将接收不到这个信号,永远阻塞下去。Sigsuspend则不一样,它提供了一个原子操作,先恢复信号屏蔽字,然后使其休眠。

 

注意:清晰且可靠的等待信号到达的方式,通常是先调用sigprocmask阻塞该信号,然后调用sigsuspend放开对此信号的阻塞,等待信号产生,执行信号处理程序返回之后,再调用sigprocmask将信号屏蔽字还原。

       另外如果需要在信号处理程序中执行一些复杂的操作,则可以这样设计程序:

1)  信号处理程序对全局变量置位

2)  主程序根据全局变量的置,执行后续操作。

 

以下是一个简单的演示:

 

  1. #include <stdio.h>
  2. #include <string.h>
  3. #include <stdlib.h>
  4. #include <signal.h>
  5. #include <unistd.h>

  6. #define STR_LEN 64
  7. #define CONFIG_TEST “xxx"

  8. volatile sig_atomic_t flag;

  9. static void sig_handler(int signo)
  10. {
  11.     flag = 1;
  12.     printf("In signal handler function!\n");
  13. }

  14. int show_file_info(void)
  15. {
  16.     FILE *fp = NULL;
  17.     char str_tmp[STR_LEN] = {0};

  18.     fp = fopen(CONFIG_TEST, "r");
  19.     if(NULL == fp)
  20.     {
  21.         printf("%s : can't open file %s!\n", __func__, CONFIG_TEST);
  22.         return -1;
  23.     }

  24.     printf("%s : show file info!\n",__func__);
  25.     while(fgets(str_tmp, STR_LEN, fp) != NULL)
  26.     {
  27.         printf("str_tmp is %s", str_tmp);
  28.     }

  29.     fclose(fp);
  30.     fp = NULL;

  31.     return 0;
  32. }

  33. int main()
  34. {
  35.     sigset_t newmask,oldmask,zeromask;

  36.     if(signal(SIGUSR1, sig_handler) == SIG_ERR)
  37.     {
  38.         printf("%s : signal failed!\n ",__func__);
  39.         return -1;
  40.     }

  41.     sigemptyset(&zeromask);
  42.     sigemptyset(&newmask);
  43.     sigaddset(&newmask, SIGUSR1);

  44.     if(sigprocmask(SIG_BLOCK, &newmask, &oldmask) < 0)
  45.     {
  46.         printf("%s : step1, sigprocmask failed!\n",__func__);
  47.         return-1;
  48.     }

  49.     while(flag == 0)
  50.         sigsuspend(&zeromask);

  51.     printf("%s : after signal handler!\n", __func__);
  52.     flag = 0;

  53.     if(show_file_info() < 0)
  54.     {
  55.         printf("%s : show_file_info failed!\n",__func__);
  56.         return -1;
  57.     }
  58.      if(sigprocmask(SIG_SETMASK, &oldmask, NULL) < 0)
         {
              printf("%s : sigprocmask failed!",__func__);
              return -1;
         }
         pr_mask("\n In end");
         return 0;
    }



该程序主要就是等待信号SIGUSR1到来,然后去CONFILE_TEST里读取文件内容。但是因为要将信号处理程序设计的简单一些,所以改成信号处理程序只是i只为全局的标志,主程序真正执行相对应的操作。要顺利执行此程序需要另一个程序用kill函数向其发送一个信号SIGUSR1或者在shell下输入kill –SIGUSR1 pid(进程号)。

本文参考文章:http://www.cublog.cn/u2/82750/showart_2158032.html

              http://bigwhite.blogbus.com/logs/1453143.html

 

阅读(2522) | 评论(1) | 转发(0) |
给主人留下些什么吧!~~

wangjian04122011-07-01 22:00:12

恩,APUE上说新版本的signal直接是对sigaction的封装,所以在处理一个信号函数时,会主动屏蔽同一个信号。但是老版本的就没有。