兄弟们救救我，系统信号的问题

longtem

描述：
系统使用异步信号触动数据处理动作。但发现在数据量很大的时候，信号就没有了。

相关信息：

信号安装：
static int install_signal_handler(void)
{
#define __INSTALL(handler,signal,word) \
do\
{\
        sa.sa_handler=handler;\
        if(sigaction(signal,&sa,NULL) == -1)\
        {\
                PWRN(word);\
                return -1;\
        }\
}while(0)

        struct sigaction sa;

        /*start to install all the handlers */
        sa.sa_flags = 0; /*the handler could reset itself */

        if (sigfillset(&(sa.sa_mask)) == -1) /*block all signal */
        {
                PWRN ("Fail while filling the signal set");
                return -1;
        }
        __INSTALL (sh_shutdown, IFMS_SIG_SHUTDOWN,
                        "Fail while registering the shutdown signal");
        __INSTALL (sh_alarm, IFMS_SIG_TIME_REACH,
                        "Fail while registering the alarm signal");
        __INSTALL (SIG_IGN, IFMS_SIG_CHLD_DIE,
                        "Fail while registering the heart beat signal");

        if (sigdelset(&(sa.sa_mask), IFMS_SIG_SHUTDOWN) == -1) /*mask all signal except 9 and shutdown */
        {
                PWRN ("Fail while deleting the signal from the signal set");
                return -1;
        }
        __INSTALL (sh_heartbeat, IFMS_SIG_HEARTBEAT,
                        "Fail while registering the heart beat signal");
        __INSTALL (sh_aio, IFMS_SIG_NEWFILE, "Fail while registering the AIO signal"); /*tell the pproc ... */

        return 0;
#undef __INSTALL
}

处理信号的相关设置：
    /*preparing for the aio signal for socket */
    if (fcntl(srvsock, F_SETOWN, getpid()) == -1)
    {
        PFLR ("Fail while setting the socket pid");
        return;
    }
    if (ioctl(srvsock, FIOASYNC, &on) == -1)
    {
        PFLR ("Fail while setting the file descriptor aio");
        return;
    }
    if (ioctl(srvsock, FIONBIO, &on) == -1)
    {
        PFLR ("Fail while setting the file descriptor unblockable");
        return;
    }

    if (sigprocmask(SIG_SETMASK, NULL, &cur_sigset) == -1) /*get the current signal set */
    {
        PFLR ("Fail to get the current signal set");
        return;
    }
    /*------------------------initialize the server finished---------------*/
    while (1)
    {
        sigsuspend(&cur_sigset); /*start to accept the client, i.e. signal SIGIO */
    }

aio处理函数：
static void sh_aio(int sig)
{ /*the socket informed us that there is data arriving... */
    int m, n;

    for (m = 0; m < PPROCSCALE; m++)
    { /*looking for the idel client node */
        for (n = 0; n < PPROCCNT; n++)
        {
            if (shm->rt_fd_clt.client_queue[n][m].clt_inuse == -1)
                goto FOUND;
            /*idel inode found! */
        }
    }
    PWRN_NR ("No client node available. Your net is so busy.");
    PWRN_NR ("You should compile the ifms with more client node.");
    PWRN_NR ("Or you should upgrade your DCS hardware especially cpu.");
    /* Note: This message would burst the DMS log system if DCS is overloaded.
     * */
    return;

    FOUND:
#define CNODE (shm->rt_fd_clt.client_queue[n][m])    /*current client node */
    CNODE.clt_addr_len = sizeof(struct sockaddr); /*filling the length */
    CNODE.clt_data_len = recvfrom(srvsock, CNODE.clt_data, MAX_NF_PACKAGE_SIZE,
            0, (struct sockaddr *) &CNODE.clt_addr, &CNODE.clt_addr_len);

#ifdef DEBUG_SEE_ACTIVITY
    {
        fprintf(ifms_act,"%s:%s\n",time_now(),inet_ntoa(CNODE.clt_addr.sin_addr));
    }
#endif
    if (CNODE.clt_data_len == -1) /*most possibly udp checksum error... */
        return;

    if (CNODE.clt_data_len > 0)
        CNODE.clt_inuse = 0;
#undef CNODE

    if (shm->rt_fd_clt.pproc_node[n].pproc_pid > 0)
        kill(shm->rt_fd_clt.pproc_node[n].pproc_pid, IFMS_SIG_NEWFILE); /*tell the process that there are new data available */
    return;
}

系统一开始的时候，什么都正常，aio信号能正常产生。但数据一大，有某好几个aio处理中没有找到空闲的数据缓冲，直接返回之后，就不行了，aio信号就一直没有。程序还活着，因为心跳还有。不知道是不是信号有个队列，没有清理就不再填充的原因呢？哪位达人给我指点一下啊，谢谢！
平常这个系统数据量小的时候是很正常很稳定的。都运行了半年了。现在数据量打起来的时候，就出现了现在的问题。一秒之内起码有一百多几百的aio中断。

雨过白鹭洲

信号这种东西，也就只能在最简单的情况下用一用

cugb_cat

数据量很大时，会丢失信号，还是改用IO多路复用吧。

longtem

中午的时候想到是什么问题了。在aio的信号处理那里加上了一条
recvfrom(srvsock, NULL, 0, 0, NULL, NULL);
就行了。
各位一哥，一看就知道是哪里的问题了吧~~哈哈

reiase

看成信号与系统了

eveson

那么长的宏定义都搞到函数内？

longtem

是啊，不用的话，这个代码就更长了。所以再函数里面定义一个宏，用完就扔了，感觉还好。