-
Notifications
You must be signed in to change notification settings - Fork 0
Expand file tree
/
Copy pathtimerfd.cpp
More file actions
87 lines (77 loc) · 2.17 KB
/
timerfd.cpp
File metadata and controls
87 lines (77 loc) · 2.17 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
//http://www.sourcexr.com/articles/2013/11/12/timer-notifications-using-file-descriptors
#include <sys/timerfd.h>
#include <sys/epoll.h>
#include <unistd.h>
#include <iostream>
#include <errno.h>
#include <string.h>
int main() {
int fd = timerfd_create (CLOCK_MONOTONIC, TFD_NONBLOCK);
if (fd == -1) {
std::cerr << strerror (errno);
return 1;
}
const int size = 10; //ignored by newer linux kernels
int epollfd = epoll_create (size);
if (epollfd == -1) {
std::cerr << strerror (errno) << "\n";
return 1;
}
epoll_event event;
epoll_event events[size];
// add timer to reactor
event.events = EPOLLIN; // notification is a read event
event.data.fd = fd; // user data
int r = epoll_ctl (epollfd, EPOLL_CTL_ADD, fd, &event);
if (r == -1) {
std::cerr << strerror (errno) << "\n";
close (epollfd);
close (fd);
return 1;
}
// add event to be triggered
int flags = 0;
itimerspec new_timer;
// 1-second periodic timer
new_timer.it_interval.tv_sec = 1;
new_timer.it_interval.tv_nsec = 0;
new_timer.it_value.tv_sec = 1;
new_timer.it_value.tv_nsec = 0;
itimerspec old_timer;
int i = timerfd_settime (fd, flags, &new_timer, &old_timer);
if (i == -1) {
std::cerr << strerror (errno) << "\n";
close (epollfd);
close (fd);
return 1;
}
// watch possibly other fds
// ...
while (true) {
const int infinity = -1;
// and wait for events
int r = epoll_wait (epollfd, events, size, infinity);
if (r == -1) {
close (epollfd);
close (fd);
return 1;
}
// demultiplex events
int i = 0;
while (i < r) {
if (events[i].data.fd == fd) {
// timer is triggered
size_t s = 0;
int i = read (fd, &s, sizeof (s));
if (i != -1) {
std::cout << "Timer triggered (" << s << ")\n";
// handle_event();
}
}
++i;
}
}
close(epollfd);
close (fd);
return 0;
}