signal问题，SIGTERM被忽略？

leo314034

我发送SIGTERM，但是总不跳出循环，不知为什么，大虾们请看看。。。

static sig_atomic_t graceful_quit = 0;

void terminate(int signum)
{
    INFO_LOG("Received signal %s, Terminate the ptRouter program"\
             " gracefully..", strsignal(signum));
    graceful_quit = 1;
    return;  
}

int main(int argc, char **argv)
{
   int fifo_ctrl, fifo_data;
   int recvnum = 0;
   struct dlog_msg dmsg;
   char buff[MAXLINE];
  
  
   // Open control fifo
   if ((mkfifo(DLOG_FIFO_ROUTER_CTRL,0666) == -1) && (errno != EEXIST))
    {
      CRIT_LOG("dlog_create mkfifo fail: %m (%d)",errno);   
      exit(1);
    }
    if ((fifo_ctrl = open(DLOG_FIFO_ROUTER_CTRL,O_NONBLOCK | O_RDWR)) == -1)
    {
      CRIT_LOG("dlog_create fifo open fail: %m (%d)",errno);
      exit(1);
    }
   
     DEBUG_LOG("conrtol fifo opened");
   
    // Open data fifo
    if ((mkfifo(DLOG_FIFO_ROUTER_DATA,0666) == -1) && (errno != EEXIST))
    {
      CRIT_LOG("dlog_create mkfifo fail: %m (%d)",errno);   
      exit(1);
    }
   
    if ((fifo_data = open(DLOG_FIFO_ROUTER_DATA, O_RDWR)) == -1)
    {
      CRIT_LOG("dlog_create fifo open fail: %m (%d)",errno);
      exit(1);
    }
          
    if (signal(SIGTERM, terminate) == SIG_ERR)
    {
              CRIT_LOG("Unable to install the new signal handler for signal %s\n",
                 strsignal(SIGTERM));
       exit(1);
    }
   
    DEBUG_LOG("message send to ptSession");
    while ((recvnum = read(fifo_data,buff,MAXLINE)) > 0)
    {
              DEBUG_LOG("message from ptSession %d", recvnum);
              
              if (graceful_quit)
              {
             DEBUG_LOG("Terminate gracefully");
             break;
        }
        
        int retStatus = 0;
        
        retStatus = write(STDOUTPUT, buff, recvnum);

        if (retStatus == -1)
        {
            CRIT_LOG("Write to stdout failed %d", errno);
            break;
        }
    }
   
  
    return 0;
}

leo314034

不好意思，又看了一下， 应该是由于read阻塞了，运行 不好break那里，不知道有没有更好的写法

  while ((recvnum = read(fifo_data,buff,MAXLINE)) > 0)
    {
              DEBUG_LOG("message from ptSession %d", recvnum);
              
              if (graceful_quit)
              {
             DEBUG_LOG("Terminate gracefully");
             break;
        }

leo314034

不好意思，刚刚晕了，只要把graceful_quit移上去就可以了

leo314034

好像还是不行，我有晕了。。。

Sorehead

看看系统调用是否是中断后自动重启动的。

另外，这样方法怎么都有可能造成永远阻塞。

alpbrook

建议楼主用SELECT函数，这样可以在SELECT函数超时的时候检查FLAG

alpbrook

while  循环可改为如下
while(!graceful_quit )
{
   FD_ZERO(&rfds);
   FD_SET(fifo_data, &rfds);
   tv.tv_sec = 1;
   ret = select(fifo_data+1, &rfds, NULL, NULL, &tv);
    if(ret < 0)
    {
        if(EINTR == errno)
              continue;
        break;
    }
    if(0 == ret)
        continue;

    recvnum = read(fifo_data,buff,MAXLINE);
   ....
}