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