我想使用it_interval
的newValue
设置超时间隔。
但是在我的示例中,我只能一次打印,就可以打印timeout
。
发生了什么?如何设置间隔?
这是我的代码:int main()
{
int efd =epoll_create(256);
setnonblock(efd);
struct epoll_event ev,events[256];
int tfd;//timer fd
if((tfd= timerfd_create(CLOCK_MONOTONIC,TFD_NONBLOCK)) < 0)
cout<<"timerfd create error"<<endl;
struct itimerspec newValue;
struct itimerspec oldValue;
bzero(&newValue,sizeof(newValue));
bzero(&oldValue,sizeof(oldValue));
struct timespec ts;
ts.tv_sec = 5;
ts.tv_nsec = 0;
//both interval and value have been set
newValue.it_value = ts;
newValue.it_interval = ts;
if( timerfd_settime(tfd,0,&newValue,&oldValue) <0)
{
cout<<"settime error"<<strerror(errno)<<endl;
}
ev.data.fd = tfd;
ev.events = EPOLLIN | EPOLLET;
if( epoll_ctl(efd,EPOLL_CTL_ADD,tfd,&ev) < 0)
cout<<"epoll_ctl error"<<endl;
int num = 0;
while(1)
{
if((num=epoll_wait(efd,events,256,1000)) > 0)
{//justice
for(int i=0;i<num;i++)
{
if(events[i].data.fd == tfd)
{
cout<<"timeout"<<endl;
}
}
}
}
return 0;
}
最佳答案
这是因为您正在使用EPOLLET,而不是将生成的数据读()到tfd中。计时器到期后会“写入”需要读取的8个字节的数据:您确实需要读取它。在打印“超时”时添加以下内容:
uint64_t value;
read(tfd, &value, 8);
详细信息:EPOLLET要求进行边缘触发,这意味着epoll_wait()仅在文件描述符tfd上说“数据准备好输入”一次,直到您读取该数据为止。换句话说,只要您没有读取该数据,以后对epoll_wait()的调用将不会再次返回相同的描述符。此行为在普通套接字中很有用,例如如果您在主线程中执行epoll_wait(),请注意一些数据已准备就绪,然后启动另一个线程以读取它。主线程立即返回到epoll_wait()。但是我们不希望它立即再次唤醒,即使可能尚未读取文件描述符中的数据。
请注意,我猜您没有EPOLLET的示例也会出错,这是不同的:因为您不读(),所以tfd在初始延迟后始终可读,因此它将在初始延迟后尽可能快地显示“超时”到期。