Linux信号实践(3) --信号内核表示

信号在内核中的表示

   执行信号的处理动作称为信号递达（Delivery），信号从产生到递达之间的状态，称为信号未决（Pending）。进程可以选择阻塞（Block）某个信号。被阻塞的信号产生时将保持在未决状态，直到进程解除对此信号的阻塞，才执行递达的动作。

   注意，阻塞和忽略是不同，只要信号被阻塞就不会递达，而忽略是在递达之后可选的一种处理动作。信号在内核中的表示可以看作是这样的：

 

图-信号的发送过程

 

解释说明:

  1）PCB进程控制块(task_struct)中函数有信号屏蔽状态字（block）和信号未决状态字（pending）还有是否忽略标志；

  2） 信号屏蔽状态字（block）, 1代表阻塞、0代表不阻塞；

      信号未决状态字（pending）的1代表未决，0代表信号可以抵达了；

  3）向进程发送SIGINT，内核首先判断信号屏蔽状态字是否阻塞，若阻塞,信号未决状态字(pending)相应位制成1；若阻塞解除，信号未决状态字（pending）相应位制成0；表示信号可以抵达了。

  4）block状态字、pending状态字均64位(bit)；

  5）block状态字用户可以读写，pending状态字用户只能读；这是信号设计机制。

 

  思考1：状态字都64bit，编程时，如何表示状态字那？

  思考2：block状态字信息如何获取或者操作那？哪些api？

  思考3：pending状态字信息如何获取或者操作那？哪些api？

    答案见下;

 

信号集操作函数（状态字表示） 

#include <signal.h>
int sigemptyset(sigset_t *set);	//把信号集清零;(64bit/8=8字节)
int sigfillset(sigset_t *set); 	//把信号集64bit全部置为1
int sigaddset(sigset_t *set, int signo); 	//根据signo，把信号集中的对应位置成1
int sigdelset(sigset_t *set, int signo); 	//根据signo，把信号集中的对应位置成0
int sigismember(const sigset_t *set, int signo);	//判断signo是否在信号集中

sigprocmask:读取/更改信号屏蔽状态字(Block)

int sigprocmask(int how, const sigset_t *set, sigset_t *oset);

返回值：若成功则为0，若出错则为-1

  读取:如果oset是非空指针，则读取进程的当前信号屏蔽字通过oset参数传出。

  更改:如果set是非空指针，则更改进程的信号屏蔽字，参数how指示如何更改。如果oset和set都是非空指针，则先将原来的信号屏蔽字备份到oset里，然后根据set和how参数更改信号屏蔽字。假设当前的信号屏蔽字为mask，下表说明了how参数的可选值。

How:

 

 

sigpending获取信号未决状态字（pending）信息 

#include <signal.h>
int sigpending(sigset_t *set);

DESCRIPTION

 sigpending()  returns the set of signals that are pending for delivery to the calling thread 

(i.e., the signals which have been raised while blocked).  

The mask of pending signals is returned in set.

/**	示例1:添加信号SIGINT到信号屏蔽字
此时再按下Ctrl+C键, 进程也接收不到SIGINT信号了
**/
inline void err_exit(std::string message);
void sigHandler(int signo);
void printSigSet(const sigset_t &sigset);int main()
{
//虽然此处安装了信号处理函数, 但是该进程还是接收不到SIGINT信号if (signal(SIGINT, sigHandler) == SIG_ERR)err_exit("signal error");//添加信号屏蔽字: 屏蔽SIGINT信号sigset_t addset;sigemptyset(&addset);sigaddset(&addset, SIGINT);if (sigprocmask(SIG_BLOCK, &addset, NULL) == -1)err_exit("sigprocmask error");// 不断打印当前的信号屏蔽字sigset_t sigset;while (true){sigpending(&sigset);printSigSet(sigset);sleep(1);}
}inline void err_exit(std::string message)
{perror(message.c_str());exit(EXIT_FAILURE);
}
void sigHandler(int signo)
{cout << "catch a signal, number = " << signo << endl;
}
void printSigSet(const sigset_t &sigset)
{for (unsigned i = 1; i < NSIG; ++i){if (sigismember(&sigset, i))putchar('1');elseputchar('0');}putchar('\n');
}

/** 示例2:在示例1的基础上继续屏蔽SIGINT信号, 但是如果该进程接收到了SIGQUIT信号, 则将对SIGINT信号的屏蔽解除, 需要
1.在main函数中再安装一个SIGQUIT捕捉函数
2.对sigHandler函数进行改造
**/
int main()
{if (signal(SIGINT, sigHandler) == SIG_ERR)err_exit("signal SIGINT error");if (signal(SIGQUIT, sigHandler) == SIG_ERR)err_exit("signal SIGQUIT error");//添加信号屏蔽字: 屏蔽SIGINT信号sigset_t addset;sigemptyset(&addset);sigaddset(&addset, SIGINT);if (sigprocmask(SIG_BLOCK, &addset, NULL) == -1)err_exit("sigprocmask error");// 不断打印当前的信号屏蔽字sigset_t sigset;while (true){sigpending(&sigset);printSigSet(sigset);sleep(1);}
}void sigHandler(int signo)
{switch (signo){case SIGINT:cout << "catch a signal SIGINT" << endl;break;case SIGQUIT://如果是SIGQUIT信号, 则将SIGINT信号的屏蔽进行解除sigset_t unblockSet;sigemptyset(&unblockSet);sigaddset(&unblockSet, SIGINT);if (sigprocmask(SIG_UNBLOCK, &unblockSet, NULL) == -1)err_exit("sigprocmask unblock error");elsecout << "sigprocmask success" << endl;break;default:cerr << "unknown signal" << endl;break;}
}
/**连续的按Ctrl+c键盘，虽然发送了多个SIGINT信号，但是因为信号是不稳定的(不支持排队)，所以只保留了一个,如下图
*/

//示例: 换成实时信号SIGRTMAX
int main()
{if (signal(SIGRTMAX, sigHandler) == SIG_ERR)err_exit("signal SIGRTMAX error");if (signal(SIGQUIT, sigHandler) == SIG_ERR)err_exit("signal SIGQUIT error");//添加信号屏蔽字: 屏蔽SIGRTMAX信号sigset_t addset;sigemptyset(&addset);sigaddset(&addset, SIGRTMAX);if (sigprocmask(SIG_BLOCK, &addset, NULL) == -1)err_exit("sigprocmask error");// 不断打印当前的信号屏蔽字sigset_t sigset;while (true){sigpending(&sigset);printSigSet(sigset);sleep(1);}
}
void sigHandler(int signo)
{if (signo == SIGRTMAX)cout << "catch a signal SIGRTMAX" << endl;else if (signo == SIGQUIT){sigset_t unblockSet;sigemptyset(&unblockSet);sigaddset(&unblockSet, SIGRTMAX);if (sigprocmask(SIG_UNBLOCK, &unblockSet, NULL) == -1)err_exit("sigprocmask unblock error");elsecout << "sigprocmask success" << endl;}elsecerr << "unknown signal" << endl;
}

/** 向该进程连续发送四个SIGRTMAX, 则进程都能够收到**/

 

 

综合案例

   1) 创建子进程与父进程;

   2) 注册SIGINT非实时信号与SIGRTMIN实时信号,并将这两种信号添加到进程屏蔽信号组中;

   3) 注册用户自定义信号;

   4) 子进程发送5次非实时信号,发5次实时信号;

   5) 然后子进程发送SIGUSR1解除进程对SIGINT,SIGTRMIN信号的阻塞

   6) 观察实时信号与非实时信号的区别

//程序示例
void onSigAction(int signalNumber, siginfo_t *sigInfoStruct, void *)
{//获取接收到的数据int receiveNumber = sigInfoStruct->si_int;//如果收到的是SIGUSR1信号,则解除对SIGINT,SIGRTMIN的屏蔽if (signalNumber == SIGUSR1){sigset_t unblockSet;sigemptyset(&unblockSet);sigaddset(&unblockSet,SIGINT);sigaddset(&unblockSet,SIGRTMIN);;sigprocmask(SIG_UNBLOCK,&unblockSet,NULL);//Value值会是乱码!//cout << "Receive SIGUSR1, Value = " << receiveNumber << endl;cout << "Unblock, Receive SIGUSR1" << endl;}else if (signalNumber == SIGINT){cout << "Receive SIGINT, Value = " << receiveNumber << endl;}else if (signalNumber == SIGRTMIN){cout << "Receive SIGRTMIN, Value = " << receiveNumber << endl;}
}int main()
{struct sigaction act;//如果需要使得信号处理程序接收额外数据,//则必须将sa_flags位置为SA_SIGINFOact.sa_flags = SA_SIGINFO;sigemptyset(&act.sa_mask);act.sa_sigaction = onSigAction;//注册信号处理函数if (sigaction(SIGINT,&act,NULL) < 0)err_exit("sigaction SIGINT");if (sigaction(SIGRTMIN,&act,NULL) < 0)err_exit("sigaction SIGRTMIN");if (sigaction(SIGUSR1,&act,NULL) < 0)err_exit("sigaction SIGUSR1");//将信号SIGINT,SIGRTMIN信号阻塞sigset_t blockSet;sigemptyset(&blockSet);sigaddset(&blockSet,SIGINT);sigaddset(&blockSet,SIGRTMIN);if (sigprocmask(SIG_BLOCK,&blockSet,NULL) < 0)err_exit("sigprocmask error");pid_t pid = fork();if (pid == -1)err_exit("fork error");else if (pid == 0){union sigval Value;Value.sival_int = 200;//给父进程发送五次带额外数据的非可靠信号(其实最终只接受到了一次)for (int i = 0; i < 5; ++i){++ Value.sival_int;if (sigqueue(getppid(),SIGINT,Value) != 0)err_exit("sigqueue error");}//给父进程发送五次带额外数据的可靠信号(最终接收到了五次!!!)Value.sival_int = 0;for (int i = 0; i < 5; ++i){++ Value.sival_int;if (sigqueue(getppid(),SIGRTMIN,Value) != 0)err_exit("sigqueue error");}//给父进程发送SIGUSR1信号,解除对SIGINT,SIGRTMIN信号的阻塞kill(getppid(),SIGUSR1);}while (true){pause();}
}

运行结果:

 

 其实只是收到了一份非可靠信号SIGINT!