19 #ifndef GRPC_CORE_LIB_IOMGR_TCP_SERVER_H
20 #define GRPC_CORE_LIB_IOMGR_TCP_SERVER_H
58 virtual void Handle(
int listener_fd,
int fd,
Definition: tcp_server.h:55
virtual void Handle(int listener_fd, int fd, grpc_byte_buffer *pending_read)=0
virtual ~TcpServerFdHandler()=default
Internal thread interface.
Definition: backoff.h:26
struct grpc_pollset grpc_pollset
Definition: pollset.h:38
Definition: grpc_types.h:40
An array of arguments that can be passed around.
Definition: grpc_types.h:132
A closure over a grpc_iomgr_cb_func.
Definition: closure.h:56
Definition: endpoint.h:102
Definition: error_internal.h:39
Definition: resolve_address.h:44
Definition: tcp_server.h:34
grpc_byte_buffer * pending_data
Definition: tcp_server.h:44
int listener_fd
Definition: tcp_server.h:43
bool external_connection
Definition: tcp_server.h:42
grpc_tcp_server * from_server
Definition: tcp_server.h:37
unsigned port_index
Definition: tcp_server.h:39
unsigned fd_index
Definition: tcp_server.h:40
Definition: tcp_server.h:63
void(* start)(grpc_tcp_server *server, grpc_pollset **pollsets, size_t pollset_count, grpc_tcp_server_cb on_accept_cb, void *cb_arg)
Definition: tcp_server.h:67
int(* port_fd)(grpc_tcp_server *s, unsigned port_index, unsigned fd_index)
Definition: tcp_server.h:74
unsigned(* port_fd_count)(grpc_tcp_server *s, unsigned port_index)
Definition: tcp_server.h:73
void(* shutdown_starting_add)(grpc_tcp_server *s, grpc_closure *shutdown_starting)
Definition: tcp_server.h:76
void(* unref)(grpc_tcp_server *s)
Definition: tcp_server.h:78
void(* shutdown_listeners)(grpc_tcp_server *s)
Definition: tcp_server.h:79
Definition: tcp_server_utils_posix.h:52
struct grpc_tcp_server_vtable grpc_tcp_server_vtable
grpc_error * grpc_tcp_server_add_port(grpc_tcp_server *s, const grpc_resolved_address *addr, int *out_port)
void grpc_tcp_server_global_init()
void grpc_tcp_server_shutdown_starting_add(grpc_tcp_server *s, grpc_closure *shutdown_starting)
void grpc_set_tcp_server_impl(grpc_tcp_server_vtable *impl)
void(* grpc_tcp_server_cb)(void *arg, grpc_endpoint *ep, grpc_pollset *accepting_pollset, grpc_tcp_server_acceptor *acceptor)
Definition: tcp_server.h:49
grpc_tcp_server * grpc_tcp_server_ref(grpc_tcp_server *s)
unsigned grpc_tcp_server_port_fd_count(grpc_tcp_server *s, unsigned port_index)
grpc_error * grpc_tcp_server_create(grpc_closure *shutdown_complete, const grpc_channel_args *args, grpc_tcp_server **server)
void grpc_tcp_server_shutdown_listeners(grpc_tcp_server *s)
struct grpc_tcp_server_acceptor grpc_tcp_server_acceptor
int grpc_tcp_server_port_fd(grpc_tcp_server *s, unsigned port_index, unsigned fd_index)
void grpc_tcp_server_start(grpc_tcp_server *server, grpc_pollset **pollsets, size_t pollset_count, grpc_tcp_server_cb on_accept_cb, void *cb_arg)
grpc_core::TcpServerFdHandler * grpc_tcp_server_create_fd_handler(grpc_tcp_server *s)
void grpc_tcp_server_unref(grpc_tcp_server *s)