Linux基础(08)信号通信机制

#define SIGHUP         1
#define SIGINT         2
#define SIGQUIT         3
#define SIGILL         4
#define SIGTRAP         5
#define SIGABRT         6
#define SIGIOT         6
#define SIGBUS         7
#define SIGFPE         8
#define SIGKILL         9
#define SIGUSR1        10
#define SIGSEGV        11
#define SIGUSR2        12
#define SIGPIPE        13
#define SIGALRM        14
#define SIGTERM        15
#define SIGSTKFLT    16
#define SIGCHLD        17
#define SIGCONT        18
#define SIGSTOP        19
#define SIGTSTP        20
#define SIGTTIN        21
#define SIGTTOU        22
#define SIGURG        23
#define SIGXCPU        24
#define SIGXFSZ        25
#define SIGVTALRM    26
#define SIGPROF        27
#define SIGWINCH    28
#define SIGIO        29
#define SIGPOLL        SIGIO
/*
#define SIGLOST        29
*/
#define SIGPWR        30
#define SIGSYS        31
/* signal 31 is no longer "unused", but the SIGUNUSED macro remains for backwards compatibility */
#define    SIGUNUSED    31

/* These should not be considered constants from userland.  */
#define SIGRTMIN    32
#define SIGRTMAX    _NSIG

#include<stdio.h>
#include<unistd.h>
#include<signal.h>
#include<string.h>
//#include<sys/siginfo.h>

void handler(int,siginfo_t *,void *);

int main(void)
{
    struct sigaction act;
    act.sa_sigaction=handler;
    sigemptyset(&act.sa_mask);
    act.sa_flags=SA_SIGINFO;
    if(sigaction(SIGINT,&act,NULL)<0)
    {
        printf("error");
        exit(0);
    }
    for(;;)
        pause();
    return 0;
}

void handler(int sig,siginfo_t * info,void *ctx)
{
    printf("recv a sid=%d data=%d data=%d
",sig,info->si_value.sival_int,info->si_int);
}

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

int main(int argc,char *argv[])
{
    if(argc!=2)
    {
        printf("arguments error!");
        exit(0);
    }

    pid_t pid=atoi(argv[1]);//将进程号转化为整数
    union sigval v;
    v.sival_int=100;
    //这儿只是利用SIGINT来发送数据，
    //任何信号都行，只需要发送端与接收端规定一致即可
    sigqueue(pid,SIGINT,v);
    return 0;
}

#include<stdio.h>
#include<stdlib.h>
#include<signal.h>
#include<unistd.h>
#include<sys/time.h>
#include<error.h>
#include<arpa/inet.h>
#include<sys/epoll.h>
#include <fcntl.h>
#include<errno.h>




#if  1
/*****************************************************************************
 函 数 名  : MyHandler
 功能描述  : 信号处理函数
 输入参数  : int sig , struct siginfo_t *info , void *ctx
 输出参数  : 无
 返 回 值  : void 
 调用函数  : 
 被调函数  : 
 
 修改历史      :
  1.日    期   : 2019年11月8日 星期五
    作    者   : ljf
    修改内容   : 新生成函数

*****************************************************************************/
void  MyHandler( int sig , struct siginfo_t *info , int *pipefd)
{
    char *buff = "hello world
";
    size_t len = sizeof(buff);
    write(pipefd[1], buff, len);
}

/*****************************************************************************
 函 数 名  : readn
 功能描述  : 不被信号所打断的完整读取
 输入参数  : int fd , void* buf , size_t len
 输出参数  : 无
 返 回 值  : ssize_t 
 调用函数  : 
 被调函数  : 
 
 修改历史      :
  1.日    期   : 2019年11月8日 星期五
    作    者   : ljf
    修改内容   : 新生成函数

*****************************************************************************/
ssize_t readn(int fd , void* buf , size_t len)
{
    size_t nleft = len;
    ssize_t nread;
    char* pbuf = buf;
    while ( nleft > 0 )
    {
        if ( (nread = read(fd , pbuf , nleft)) == -1 )
        {
            if(errno == EINTR)    //如果被信号所中断
                nread = 0;        //continue 因为nread=0 所以等同于重新开始下一次循环
            else
                return -1;
        }else if ( nread == 0 )
        {
            break;
        }
        nleft -= nread;    //实际大小减去已读取的大小 等于未读取的大小
        pbuf += nread;    //从未完的位置开始继续读取
    }
    return (len - nleft);
}



int main(int argc, char *argv[])
{
    struct sigaction act , oact;
    int pipe_fd[2] = {0,};
    int epoll_fd;
    
    pipe(pipe_fd);
    
    act.sa_handler = MyHandler;        //捕捉信号和处理
    sigemptyset(&act.sa_mask);
    act.sa_flags = SA_SIGINFO;
    if ( sigaction(SIGUSR1 , &act , pipe_fd) < 0 )
    {
        perror("sigaction");
        exit(1);
    }

    epoll_fd = epoll_create(256);
    if ( epoll_fd < 0 )
    {
        perror("epoll_create1");
        exit(2);
    }
    struct epoll_event ep_ev;
    ep_ev.events = EPOLLIN;
    ep_ev.data.fd = pipe_fd[0];
    if ( epoll_ctl(epoll_fd , EPOLL_CTL_ADD , pipe_fd[0] , &ep_ev) < 0 )
    {
        perror("epoll_ctl");
        exit(3);
    }

    struct epoll_event ready_event[128];    //存放就绪事件
    int maxnum = 128;                        //就绪事件最大数
    int timeout = 3000;                        //超时时间10s
    int ret = 0;                            //接收就绪事件的数量
    while(1)
    {
        ep_wait:
        switch ( ret = epoll_wait(epoll_fd , ready_event , maxnum , timeout) )
        {

            case -1 :
            {
                if ( errno == EINTR )
                {
                    goto ep_wait;
                }
                else
                {
                    perror("epoll_wait");
                    exit(4);
                }
            }break;

            case 0 :
                fputs("time out...
", stdout);
                break;
            default:
            {
                int i=0;
                char buf[1024];
                for (  ; i< ret ; i++ )
                {
                    if ( ready_event[i].events & EPOLLIN )
                    {
                        memset(buf,'