signal問(wèn)題，SIGTERM被忽略？

leo314034

我發(fā)送SIGTERM，但是總不跳出循環(huán)，不知為什么，大蝦們請(qǐng)看看。。。

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

不好意思，又看了一下， 應(yīng)該是由于read阻塞了，運(yùn)行 不好break那里，不知道有沒(méi)有更好的寫法

  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

看看系統(tǒng)調(diào)用是否是中斷后自動(dòng)重啟動(dòng)的。

另外，這樣方法怎么都有可能造成永遠(yuǎn)阻塞。

alpbrook

建議樓主用SELECT函數(shù)，這樣可以在SELECT函數(shù)超時(shí)的時(shí)候檢查FLAG

alpbrook

while  循環(huán)可改為如下
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);
   ....
}