0

在使用 poll 系统调用时，我发现了一种奇怪的行为。我有以下代码片段。

struct pollfd myPollfds[nCount];
ACE_Time_Value selectTime;
selectTime.set(60);

 myPollfds[0].fd = rtrrmEvent[0];
 myPollfds[0].events = POLLIN | POLLRDHUP | POLLHUP | POLLERR;
        myPollfds[0].revents = 0;

        myPollfds[1].fd = rtrfeEvent[0];
        myPollfds[1].events = POLLIN | POLLRDHUP | POLLHUP | POLLERR;
        myPollfds[1].revents = 0;

        myPollfds[2].fd = _h[msclient_pos];
        myPollfds[2].events = POLLIN | POLLRDHUP | POLLHUP | POLLERR;
        myPollfds[2].revents = 0;

        myPollfds[3].fd = holdTimeEvent[0];
        myPollfds[3].events = POLLIN | POLLRDHUP | POLLHUP | POLLERR;
        myPollfds[3].revents = 0;

        ACE_Time_Value sleepTime(0,20000);
        while(isRunning() && !_stopRequested)
        {
                ACE_OS::sleep(sleepTime);
                for(int i = 0; i < 4; i++)
                        myPollfds[i].revents = 0;
                waitResult = ACE_OS::poll (myPollfds, nCount, &selectTime);
                if(waitResult == -1) // poll failed
                {
                       DEBUG("%s", "poll failed");
                         continue;
                }
                else if(waitResult == 0) // Time out
                {
                        //Do something .
                }
                char nodata[256];

                for(short i = 0; i < nCount; i++)
  if(myPollfds[i].revents == POLLIN)
                        {
                                if(i == rtrrm_pos)
                                {
                                         // Stop channel
                                }
                                else if(i == rtrfe_pos) // 'rtrfe' command
                                {
                                        DEBUG("%s", "fe issued");

                                }
                                else if(i == msclient_pos || waitResult == 0)
                                {
                                      //Do something
                                }
                                else if(i == holdTime_pos)
                                {
                                        DEBUG("%s", "Hold issued");
                                }
                        }
                        else
                        {
                                DEBUG("polling failed with with myPollfds[i].revents == %d",myPollfds[i].revents);
                        }

问题是我有时会遇到：“轮询失败，myPollfds[i].revents == 0”：“轮询失败，myPollfds[i].revents == 8193”

轮询呼叫不等待 fd 设置。有人可以帮忙吗？

4

2 回答 2

4

这个测试是不正确的：

  if(myPollfds[i].revents == POLLIN)

它应该可能（不能确定，因为你删除了所有的逻辑）是：

  if((myPollfds[i].revents & POLLIN) != 0)

此外，看到“轮询失败”消息是完全正常的。这只是意味着该特定文件描述符上没有任何活动。您正在对多个描述符进行轮询，对吗？所以他们中的一些人没有活动是正常的。

于 2013-06-12T10:01:02.410 回答
0

正如大卫所说，

“轮询失败”消息是完全正常的。

在任何情况下，当 poll 返回时不仅仅是 POLLIN 例如：

poll ... = 1



{fd=8193, revents=POLLIN|**POLLHUP**}
if (POLLIN|POLLHUP == POLLIN)

正在进入“其他”子句。

我的 C 语言不太好，所以我无法判断 David 的“if 语句”是否正确。

于 2013-10-15T08:37:24.243 回答