* called after the select call.
*/
struct sched {
- /** Initial value before any pre_select call. */
- struct timeval default_timeout;
- /** The current timeout for the upcoming select call. */
- struct timeval select_timeout;
+ /** Initial value (in milliseconds) before any pre_select call. */
+ int default_timeout;
+ /** The timeout (also in milliseconds) for the next select call. */
+ int timeout;
/** fds that should be watched for readability. */
fd_set rfds;
/** fds that should be watched for writability. */
/** Highest numbered file descriptor in any of the above fd sets. */
int max_fileno;
/** If non-NULL, use this function instead of para_select. */
- int (*select_function)(int, fd_set *, fd_set *, struct timeval *);
+ int (*select_function)(int, fd_set *, fd_set *, int timeout);
/** Tasks which have been registered to the scheduler. */
struct list_head task_list;
};
void sched_request_timeout_ms(long unsigned ms, struct sched *s);
int sched_request_barrier(struct timeval *barrier, struct sched *s);
int sched_request_barrier_or_min_delay(struct timeval *barrier, struct sched *s);
+
+static inline bool sched_read_ok(int fd, const struct sched *s)
+{
+ return FD_ISSET(fd, &s->rfds);
+}
+
+static inline bool sched_write_ok(int fd, const struct sched *s)
+{
+ return FD_ISSET(fd, &s->wfds);
+}