19 #ifndef GRPC_CORE_LIB_IOMGR_EV_POSIX_H
20 #define GRPC_CORE_LIB_IOMGR_EV_POSIX_H
39 #define GRPC_FD_TRACE(format, ...) \
40 if (GRPC_TRACE_FLAG_ENABLED(grpc_fd_trace)) { \
41 gpr_log(GPR_INFO, "(fd-trace) " format, __VA_ARGS__); \
51 grpc_fd* (*fd_create)(
int fd,
const char* name,
bool track_err);
void grpc_event_engine_init(void)
void grpc_fd_set_error(grpc_fd *fd)
void grpc_event_engine_shutdown(void)
void grpc_fd_notify_on_read(grpc_fd *fd, grpc_closure *closure)
int grpc_fd_wrapped_fd(grpc_fd *fd)
grpc_fd * grpc_fd_create(int fd, const char *name, bool track_err)
GPR_GLOBAL_CONFIG_DECLARE_STRING(grpc_poll_strategy)
void grpc_fd_set_readable(grpc_fd *fd)
grpc_core::DebugOnlyTraceFlag grpc_fd_trace
grpc_poll_function_type grpc_poll_function
void grpc_fd_shutdown(grpc_fd *fd, grpc_error *why)
const char * grpc_get_poll_strategy_name()
struct grpc_event_engine_vtable grpc_event_engine_vtable
bool grpc_fd_is_shutdown(grpc_fd *fd)
void grpc_pollset_set_add_fd(grpc_pollset_set *pollset_set, grpc_fd *fd)
bool grpc_add_closure_to_background_poller(grpc_closure *closure, grpc_error *error)
void grpc_fd_notify_on_error(grpc_fd *fd, grpc_closure *closure)
void grpc_shutdown_background_closure()
bool grpc_is_any_background_poller_thread()
bool grpc_event_engine_run_in_background()
struct grpc_fd grpc_fd
Definition: ev_posix.h:44
grpc_core::DebugOnlyTraceFlag grpc_polling_trace
void grpc_fd_notify_on_write(grpc_fd *fd, grpc_closure *closure)
void grpc_register_event_engine_factory(const char *name, const grpc_event_engine_vtable *(*factory)(bool), bool add_at_head)
void grpc_fd_set_writable(grpc_fd *fd)
int(* grpc_poll_function_type)(struct pollfd *, nfds_t, int)
Definition: ev_posix.h:204
void grpc_pollset_add_fd(grpc_pollset *pollset, struct grpc_fd *fd)
void grpc_fd_orphan(grpc_fd *fd, grpc_closure *on_done, int *release_fd, const char *reason)
bool grpc_event_engine_can_track_errors()
void grpc_pollset_set_del_fd(grpc_pollset_set *pollset_set, grpc_fd *fd)
int64_t grpc_millis
Definition: exec_ctx.h:35
struct grpc_pollset_worker grpc_pollset_worker
Definition: pollset.h:39
struct grpc_pollset_set grpc_pollset_set
Definition: pollset_set.h:31
Definition: sync_windows.h:26
A closure over a grpc_iomgr_cb_func.
Definition: closure.h:56
Definition: error_internal.h:39
Definition: ev_posix.h:46
bool(* add_closure_to_background_poller)(grpc_closure *closure, grpc_error *error)
Definition: ev_posix.h:90
bool run_in_background
Definition: ev_posix.h:49
void(* fd_set_error)(grpc_fd *fd)
Definition: ev_posix.h:61
void(* shutdown_background_closure)(void)
Definition: ev_posix.h:88
void(* pollset_set_add_pollset)(grpc_pollset_set *pollset_set, grpc_pollset *pollset)
Definition: ev_posix.h:76
void(* fd_set_writable)(grpc_fd *fd)
Definition: ev_posix.h:60
void(* pollset_destroy)(grpc_pollset *pollset)
Definition: ev_posix.h:66
void(* fd_notify_on_read)(grpc_fd *fd, grpc_closure *closure)
Definition: ev_posix.h:56
size_t pollset_size
Definition: ev_posix.h:47
int(* fd_wrapped_fd)(grpc_fd *fd)
Definition: ev_posix.h:52
void(* fd_orphan)(grpc_fd *fd, grpc_closure *on_done, int *release_fd, const char *reason)
Definition: ev_posix.h:53
bool(* fd_is_shutdown)(grpc_fd *fd)
Definition: ev_posix.h:62
void(* pollset_init)(grpc_pollset *pollset, gpr_mu **mu)
Definition: ev_posix.h:64
void(* pollset_set_add_pollset_set)(grpc_pollset_set *bag, grpc_pollset_set *item)
Definition: ev_posix.h:80
void(* pollset_set_destroy)(grpc_pollset_set *pollset_set)
Definition: ev_posix.h:75
void(* fd_notify_on_error)(grpc_fd *fd, grpc_closure *closure)
Definition: ev_posix.h:58
void(* pollset_shutdown)(grpc_pollset *pollset, grpc_closure *closure)
Definition: ev_posix.h:65
void(* pollset_set_del_pollset)(grpc_pollset_set *pollset_set, grpc_pollset *pollset)
Definition: ev_posix.h:78
void(* fd_notify_on_write)(grpc_fd *fd, grpc_closure *closure)
Definition: ev_posix.h:57
void(* pollset_set_del_pollset_set)(grpc_pollset_set *bag, grpc_pollset_set *item)
Definition: ev_posix.h:82
void(* pollset_add_fd)(grpc_pollset *pollset, struct grpc_fd *fd)
Definition: ev_posix.h:72
bool(* is_any_background_poller_thread)(void)
Definition: ev_posix.h:87
void(* fd_set_readable)(grpc_fd *fd)
Definition: ev_posix.h:59
void(* pollset_set_add_fd)(grpc_pollset_set *pollset_set, grpc_fd *fd)
Definition: ev_posix.h:84
void(* pollset_set_del_fd)(grpc_pollset_set *pollset_set, grpc_fd *fd)
Definition: ev_posix.h:85
void(* shutdown_engine)(void)
Definition: ev_posix.h:89
bool can_track_err
Definition: ev_posix.h:48
void(* fd_shutdown)(grpc_fd *fd, grpc_error *why)
Definition: ev_posix.h:55
Definition: pollset_custom.cc:40
gpr_mu mu
Definition: timer_generic.cc:6