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