19 #ifndef GRPC_CORE_LIB_IOMGR_TCP_SERVER_H
20 #define GRPC_CORE_LIB_IOMGR_TCP_SERVER_H
60 virtual void Handle(
int listener_fd,
int fd,
70 const std::vector<grpc_pollset*>* pollsets,
94 const std::vector<grpc_pollset*>* pollsets,
Definition: tcp_server.h:57
virtual void Handle(int listener_fd, int fd, grpc_byte_buffer *pending_read)=0
virtual ~TcpServerFdHandler()=default
grpc_error * grpc_error_handle
Definition: error.h:48
Round Robin Policy.
Definition: backend_metric.cc:26
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:106
Definition: error_internal.h:41
Definition: pollset_custom.cc:40
Definition: resolve_address.h:44
Definition: tcp_server.h:36
grpc_byte_buffer * pending_data
Definition: tcp_server.h:46
int listener_fd
Definition: tcp_server.h:45
bool external_connection
Definition: tcp_server.h:44
grpc_tcp_server * from_server
Definition: tcp_server.h:39
unsigned port_index
Definition: tcp_server.h:41
unsigned fd_index
Definition: tcp_server.h:42
Definition: tcp_server.h:65
grpc_error_handle(* add_port)(grpc_tcp_server *s, const grpc_resolved_address *addr, int *out_port)
Definition: tcp_server.h:72
grpc_error_handle(* create)(grpc_closure *shutdown_complete, const grpc_channel_args *args, grpc_tcp_server **server)
Definition: tcp_server.h:66
int(* port_fd)(grpc_tcp_server *s, unsigned port_index, unsigned fd_index)
Definition: tcp_server.h:77
unsigned(* port_fd_count)(grpc_tcp_server *s, unsigned port_index)
Definition: tcp_server.h:76
void(* shutdown_starting_add)(grpc_tcp_server *s, grpc_closure *shutdown_starting)
Definition: tcp_server.h:79
void(* start)(grpc_tcp_server *server, const std::vector< grpc_pollset * > *pollsets, grpc_tcp_server_cb on_accept_cb, void *cb_arg)
Definition: tcp_server.h:69
void(* unref)(grpc_tcp_server *s)
Definition: tcp_server.h:81
void(* shutdown_listeners)(grpc_tcp_server *s)
Definition: tcp_server.h:82
Definition: tcp_server_custom.cc:58
struct grpc_tcp_server_vtable grpc_tcp_server_vtable
grpc_error_handle grpc_tcp_server_create(grpc_closure *shutdown_complete, const grpc_channel_args *args, grpc_tcp_server **server)
Definition: tcp_server.cc:25
void grpc_tcp_server_global_init()
void grpc_tcp_server_shutdown_starting_add(grpc_tcp_server *s, grpc_closure *shutdown_starting)
Definition: tcp_server.cc:62
void grpc_tcp_server_start(grpc_tcp_server *server, const std::vector< grpc_pollset * > *pollsets, grpc_tcp_server_cb on_accept_cb, void *cb_arg)
Definition: tcp_server.cc:31
void grpc_set_tcp_server_impl(grpc_tcp_server_vtable *impl)
Definition: tcp_server.cc:75
void(* grpc_tcp_server_cb)(void *arg, grpc_endpoint *ep, grpc_pollset *accepting_pollset, grpc_tcp_server_acceptor *acceptor)
Definition: tcp_server.h:51
grpc_tcp_server * grpc_tcp_server_ref(grpc_tcp_server *s)
Definition: tcp_server.cc:58
unsigned grpc_tcp_server_port_fd_count(grpc_tcp_server *s, unsigned port_index)
Definition: tcp_server.cc:48
void grpc_tcp_server_shutdown_listeners(grpc_tcp_server *s)
Definition: tcp_server.cc:71
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)
Definition: tcp_server.cc:53
grpc_error_handle grpc_tcp_server_add_port(grpc_tcp_server *s, const grpc_resolved_address *addr, int *out_port)
Definition: tcp_server.cc:37
grpc_core::TcpServerFdHandler * grpc_tcp_server_create_fd_handler(grpc_tcp_server *s)
Definition: tcp_server.cc:43
void grpc_tcp_server_unref(grpc_tcp_server *s)
Definition: tcp_server.cc:67