home
/
code
/
khatus.git
/ commitdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
| commitdiff |
tree
raw
|
patch
|
inline
| side by side (parent:
0741fd0
)
Timeout IO poll at desired intervals
author
Siraaj Khandkar
<siraaj@khandkar.net>
Wed, 25 Mar 2020 01:07:04 +0000
(21:07 -0400)
committer
Siraaj Khandkar
<siraaj@khandkar.net>
Wed, 25 Mar 2020 01:07:46 +0000
(21:07 -0400)
x5/khatus.c
patch
|
blob
|
blame
|
history
diff --git
a/x5/khatus.c
b/x5/khatus.c
index
18abc19
..
ce7db95
100644
(file)
--- a/
x5/khatus.c
+++ b/
x5/khatus.c
@@
-397,7
+397,7
@@
fifo_read_one(Fifo *f, struct timespec t, char *buf)
}
void
}
void
-fifo_read_all(Config *cfg, char *buf)
+fifo_read_all(Config *cfg,
struct timespec *ti,
char *buf)
{
fd_set fds;
int maxfd = -1;
{
fd_set fds;
int maxfd = -1;
@@
-436,12
+436,9
@@
fifo_read_all(Config *cfg, char *buf)
FD_SET(f->fd, &fds);
}
debug("selecting...\n");
FD_SET(f->fd, &fds);
}
debug("selecting...\n");
- ready =
select(maxfd + 1, &fds, NULL, NULL
, NULL);
+ ready =
pselect(maxfd + 1, &fds, NULL, NULL, ti
, NULL);
debug("ready: %d\n", ready);
debug("ready: %d\n", ready);
- assert(ready != 0);
- if (ready < 0)
- /* TODO: Do we really want to fail here? */
- fatal("%s", strerror(errno));
+ assert(ready >= 0);
clock_gettime(CLOCK_MONOTONIC, &t);
while (ready) {
for (Fifo *f = cfg->fifos; f; f = f->next) {
clock_gettime(CLOCK_MONOTONIC, &t);
while (ready) {
for (Fifo *f = cfg->fifos; f; f = f->next) {
@@
-557,11
+554,7
@@
main(int argc, char *argv[])
/* TODO: Handle signals */
for (;;) {
clock_gettime(CLOCK_MONOTONIC, &t0); // FIXME: check errors
/* TODO: Handle signals */
for (;;) {
clock_gettime(CLOCK_MONOTONIC, &t0); // FIXME: check errors
- /* TODO: Set timeout on fifo_read_all based on diff of last time of
- * fifo_read_all and desired time of next TTL check?
- */
- /* TODO: How long to wait on IO? Max TTL? */
- fifo_read_all(cfg, buf);
+ fifo_read_all(cfg, &ti, buf);
if (cfg->output_to_x_root_window) {
if (XStoreName(display, DefaultRootWindow(display), buf) < 0)
fatal("XStoreName failed.\n");
if (cfg->output_to_x_root_window) {
if (XStoreName(display, DefaultRootWindow(display), buf) < 0)
fatal("XStoreName failed.\n");
This page took
0.028253 seconds
and
4
git commands to generate.