free (loop);
}
-static bool
+static void
ply_event_loop_add_source (ply_event_loop_t *loop,
ply_event_source_t *source)
{
struct epoll_event event = { 0 };
+ int status;
event.events = EPOLLIN | EPOLLPRI | EPOLLERR | EPOLLHUP;
event.data.ptr = source;
- if (epoll_ctl (loop->epoll_fd, EPOLL_CTL_ADD, source->fd, &event) < 0)
- return false;
+ status = epoll_ctl (loop->epoll_fd, EPOLL_CTL_ADD, source->fd, &event);
+
+ assert (status == 0);
ply_list_append_data (loop->sources, source);
-
- return true;
}
static void
return node;
}
-bool
-ply_event_loop_watch_fd (ply_event_loop_t *loop,
- int fd,
- ply_event_handler_t new_data_handler,
- ply_event_handler_t disconnected_handler,
- void *user_data)
+void
+ply_event_loop_watch_fd (ply_event_loop_t *loop,
+ int fd,
+ ply_event_handler_t new_data_handler,
+ ply_event_handler_t disconnected_handler,
+ void *user_data)
{
ply_list_node_t *node;
ply_event_source_t *source;
assert (node == NULL);
source = ply_event_source_new (fd,
- new_data_handler,
- disconnected_handler,
- user_data, NULL);
-
- if (!ply_event_loop_add_source (loop, source))
- return false;
+ new_data_handler,
+ disconnected_handler,
+ user_data, NULL);
- return true;
+ ply_event_loop_add_source (loop, source);
}
void
return node;
}
-bool
+void
ply_event_loop_watch_signal (ply_event_loop_t *loop,
int signal_number,
ply_event_handler_t signal_handler,
source->old_posix_signal_handler =
signal (signal_number, ply_signal_dispatcher_posix_signal_handler);
ply_list_append_data (loop->signal_dispatcher->sources, source);
-
- return true;
}
static void
ply_signal_dispatcher_remove_source_node (ply_signal_dispatcher_t *dispatcher,
- ply_list_node_t *node)
+ ply_list_node_t *node)
{
ply_signal_source_t *source;
#ifndef PLY_HIDE_FUNCTION_DECLARATIONS
ply_event_loop_t *ply_event_loop_new (void);
void ply_event_loop_free (ply_event_loop_t *loop);
-bool ply_event_loop_watch_fd (ply_event_loop_t *loop,
+void ply_event_loop_watch_fd (ply_event_loop_t *loop,
int fd,
ply_event_handler_t new_data_handler,
ply_event_handler_t disconnected_handler,
void *user_data);
void ply_event_loop_stop_watching_fd (ply_event_loop_t *loop,
int fd);
-bool ply_event_loop_watch_signal (ply_event_loop_t *loop,
+void ply_event_loop_watch_signal (ply_event_loop_t *loop,
int signal_number,
ply_event_handler_t signal_handler,
void *user_data);