Home
last modified time | relevance | path

Searched refs:grpc_tcp_server (Results 1 – 15 of 15) sorted by relevance

/external/grpc-grpc/src/core/lib/iomgr/
Dtcp_server.h31 typedef struct grpc_tcp_server grpc_tcp_server; typedef
36 grpc_tcp_server* from_server;
51 grpc_tcp_server** server);
52 void (*start)(grpc_tcp_server* server, grpc_pollset** pollsets,
55 grpc_error* (*add_port)(grpc_tcp_server* s, const grpc_resolved_address* addr,
57 unsigned (*port_fd_count)(grpc_tcp_server* s, unsigned port_index);
58 int (*port_fd)(grpc_tcp_server* s, unsigned port_index, unsigned fd_index);
59 grpc_tcp_server* (*ref)(grpc_tcp_server* s);
60 void (*shutdown_starting_add)(grpc_tcp_server* s,
62 void (*unref)(grpc_tcp_server* s);
[all …]
Dtcp_server.cc27 grpc_tcp_server** server) { in grpc_tcp_server_create()
31 void grpc_tcp_server_start(grpc_tcp_server* server, grpc_pollset** pollsets, in grpc_tcp_server_start()
38 grpc_error* grpc_tcp_server_add_port(grpc_tcp_server* s, in grpc_tcp_server_add_port()
44 unsigned grpc_tcp_server_port_fd_count(grpc_tcp_server* s, in grpc_tcp_server_port_fd_count()
49 int grpc_tcp_server_port_fd(grpc_tcp_server* s, unsigned port_index, in grpc_tcp_server_port_fd()
54 grpc_tcp_server* grpc_tcp_server_ref(grpc_tcp_server* s) { in grpc_tcp_server_ref()
58 void grpc_tcp_server_shutdown_starting_add(grpc_tcp_server* s, in grpc_tcp_server_shutdown_starting_add()
63 void grpc_tcp_server_unref(grpc_tcp_server* s) { in grpc_tcp_server_unref()
67 void grpc_tcp_server_shutdown_listeners(grpc_tcp_server* s) { in grpc_tcp_server_shutdown_listeners()
Dtcp_server_windows.cc61 grpc_tcp_server* server;
73 struct grpc_tcp_server { struct
101 grpc_tcp_server** server) { in tcp_server_create()
102 grpc_tcp_server* s = (grpc_tcp_server*)gpr_malloc(sizeof(grpc_tcp_server)); in tcp_server_create()
119 grpc_tcp_server* s = (grpc_tcp_server*)arg; in destroy_server()
136 static void finish_shutdown_locked(grpc_tcp_server* s) { in finish_shutdown_locked()
146 static grpc_tcp_server* tcp_server_ref(grpc_tcp_server* s) { in tcp_server_ref()
151 static void tcp_server_shutdown_starting_add(grpc_tcp_server* s, in tcp_server_shutdown_starting_add()
159 static void tcp_server_destroy(grpc_tcp_server* s) { in tcp_server_destroy()
176 static void tcp_server_unref(grpc_tcp_server* s) { in tcp_server_unref()
[all …]
Dtcp_server_custom.cc43 grpc_tcp_server* server;
55 struct grpc_tcp_server { struct
81 grpc_tcp_server** server) { in tcp_server_create() argument
82 grpc_tcp_server* s = (grpc_tcp_server*)gpr_malloc(sizeof(grpc_tcp_server)); in tcp_server_create()
112 static grpc_tcp_server* tcp_server_ref(grpc_tcp_server* s) { in tcp_server_ref()
118 static void tcp_server_shutdown_starting_add(grpc_tcp_server* s, in tcp_server_shutdown_starting_add()
124 static void finish_shutdown(grpc_tcp_server* s) { in finish_shutdown()
174 static void tcp_server_destroy(grpc_tcp_server* s) { in tcp_server_destroy()
193 static void tcp_server_unref(grpc_tcp_server* s) { in tcp_server_unref()
270 static grpc_error* add_socket_to_server(grpc_tcp_server* s, in add_socket_to_server()
[all …]
Dtcp_server_posix.cc60 grpc_tcp_server** server) { in tcp_server_create()
61 grpc_tcp_server* s = in tcp_server_create()
62 static_cast<grpc_tcp_server*>(gpr_zalloc(sizeof(grpc_tcp_server))); in tcp_server_create()
104 static void finish_shutdown(grpc_tcp_server* s) { in finish_shutdown()
125 grpc_tcp_server* s = static_cast<grpc_tcp_server*>(server); in destroyed_port()
140 static void deactivated_all_ports(grpc_tcp_server* s) { in deactivated_all_ports()
162 static void tcp_server_destroy(grpc_tcp_server* s) { in tcp_server_destroy()
267 static grpc_error* add_wildcard_addrs_to_server(grpc_tcp_server* s, in add_wildcard_addrs_to_server()
381 static grpc_error* tcp_server_add_port(grpc_tcp_server* s, in tcp_server_add_port()
434 static grpc_tcp_listener* get_port_index(grpc_tcp_server* s, in get_port_index()
[all …]
Dtcp_server_utils_posix.h33 grpc_tcp_server* server;
52 struct grpc_tcp_server { struct
99 grpc_error* grpc_tcp_server_add_addr(grpc_tcp_server* s, argument
110 grpc_error* grpc_tcp_server_add_all_local_addrs(grpc_tcp_server* s,
116 grpc_error* grpc_tcp_server_prepare_socket(grpc_tcp_server*, int fd,
Dtcp_server_utils_posix_common.cc80 static grpc_error* add_socket_to_server(grpc_tcp_server* s, int fd, in add_socket_to_server()
127 grpc_error* grpc_tcp_server_add_addr(grpc_tcp_server* s, in grpc_tcp_server_add_addr()
147 grpc_error* grpc_tcp_server_prepare_socket(grpc_tcp_server* s, int fd, in grpc_tcp_server_prepare_socket()
Dtcp_server_utils_posix_ifaddrs.cc41 static grpc_tcp_listener* find_listener_with_addr(grpc_tcp_server* s, in find_listener_with_addr()
89 grpc_error* grpc_tcp_server_add_all_local_addrs(grpc_tcp_server* s, in grpc_tcp_server_add_all_local_addrs()
Dtcp_server_utils_posix_noifaddrs.cc27 grpc_error* grpc_tcp_server_add_all_local_addrs(grpc_tcp_server* s, in grpc_tcp_server_add_all_local_addrs()
/external/grpc-grpc/test/core/iomgr/
Dtcp_server_uv_test.cc50 grpc_tcp_server* server;
56 grpc_tcp_server* server;
94 grpc_tcp_server* server) { in server_weak_ref_set()
119 grpc_tcp_server* s; in test_no_op()
126 grpc_tcp_server* s; in test_no_op_with_start()
137 grpc_tcp_server* s; in test_no_op_with_port()
156 grpc_tcp_server* s; in test_no_op_with_port_and_start()
225 grpc_tcp_server* s; in test_connect()
Dtcp_server_posix_test.cc56 grpc_tcp_server* server;
63 grpc_tcp_server* server;
130 grpc_tcp_server* server) { in server_weak_ref_set()
167 grpc_tcp_server* s; in test_no_op()
174 grpc_tcp_server* s; in test_no_op_with_start()
186 grpc_tcp_server* s; in test_no_op_with_port()
206 grpc_tcp_server* s; in test_no_op_with_port_and_start()
300 grpc_tcp_server* s; in test_connect()
/external/grpc-grpc/src/core/ext/transport/chttp2/server/
Dchttp2_server.cc49 grpc_tcp_server* tcp_server;
247 grpc_tcp_server* tcp_server = state->tcp_server; in server_destroy_listener()
257 grpc_tcp_server* tcp_server = nullptr; in grpc_chttp2_server_add_port()
/external/grpc-grpc/test/core/util/
Dtest_tcp_server.h26 grpc_tcp_server* tcp_server;
/external/grpc-grpc/test/core/surface/
Dconcurrent_connectivity_test.cc129 grpc_tcp_server* s; in bad_server_thread()
/external/grpc-grpc/test/core/end2end/fixtures/
Dhttp_proxy_fixture.cc67 grpc_tcp_server* server;