bool fd_activityout = false, fd_activityerr = false;
unsigned long long end_usec, start_usec;
_cleanup_free_ struct buffer *buf_out = NULL, *buf_err = NULL;
+ int n_fd = 0;
fd_ep = epoll_create1(EPOLL_CLOEXEC);
if (fd_ep < 0) {
goto out;
}
buf_out = calloc(2, sizeof(*buf_out));
+ n_fd++;
} else
fdout = -1;
goto out;
}
buf_err = calloc(2, sizeof(*buf_err));
+ n_fd++;
} else
fderr = -1;
ERR("could not add monitor fd to epoll: %m\n");
goto out;
}
+ n_fd++;
start_usec = now_usec();
end_usec = start_usec + TEST_TIMEOUT_USEC;
- for (err = 0; fdmonitor >= 0 || fdout >= 0 || fderr >= 0;) {
+ for (err = 0; n_fd > 0;) {
int fdcount, i, timeout;
struct epoll_event ev[4];
unsigned long long curr_usec = now_usec();
ERR("could not remove fd %d from epoll: %m\n", fd);
}
*(int *)ev[i].data.ptr = -1;
+ n_fd--;
}
}
}