| /aosp_15_r20/external/grpc-grpc/src/core/lib/iomgr/ |
| H A D | tcp_server.h | 35 typedef struct grpc_tcp_server grpc_tcp_server; typedef
40 grpc_tcp_server* from_server;
70 grpc_tcp_server_cb on_accept_cb, void* cb_arg, grpc_tcp_server** server);
71 void (*start)(grpc_tcp_server* server,
73 grpc_error_handle (*add_port)(grpc_tcp_server* s,
76 grpc_core::TcpServerFdHandler* (*create_fd_handler)(grpc_tcp_server* s);
77 unsigned (*port_fd_count)(grpc_tcp_server* s, unsigned port_index);
78 int (*port_fd)(grpc_tcp_server* s, unsigned port_index, unsigned fd_index);
79 grpc_tcp_server* (*ref)(grpc_tcp_server* s);
80 void (*shutdown_starting_add)(grpc_tcp_server* s,
[all …]
|
| H A D | tcp_server_windows.cc | 99 grpc_tcp_server* server;
111 struct grpc_tcp_server { struct
171 grpc_tcp_server** server) { in tcp_server_create()
172 grpc_tcp_server* s = (grpc_tcp_server*)gpr_malloc(sizeof(grpc_tcp_server)); in tcp_server_create()
188 grpc_tcp_server* s = (grpc_tcp_server*)arg; in destroy_server()
205 static void finish_shutdown_locked(grpc_tcp_server* s) { in finish_shutdown_locked()
217 static grpc_tcp_server* tcp_server_ref(grpc_tcp_server* s) { in tcp_server_ref()
222 static void tcp_server_shutdown_starting_add(grpc_tcp_server* s, in tcp_server_shutdown_starting_add()
230 static void tcp_server_destroy(grpc_tcp_server* s) { in tcp_server_destroy()
246 static void tcp_server_unref(grpc_tcp_server* s) { in tcp_server_unref()
[all …]
|
| H A D | tcp_server.cc | 28 grpc_tcp_server_cb on_accept_cb, void* cb_arg, grpc_tcp_server** server) { in grpc_tcp_server_create()
33 void grpc_tcp_server_start(grpc_tcp_server* server, in grpc_tcp_server_start()
38 grpc_error_handle grpc_tcp_server_add_port(grpc_tcp_server* s, in grpc_tcp_server_add_port()
45 grpc_tcp_server* s) { in grpc_tcp_server_create_fd_handler()
49 unsigned grpc_tcp_server_port_fd_count(grpc_tcp_server* s, in grpc_tcp_server_port_fd_count()
54 int grpc_tcp_server_port_fd(grpc_tcp_server* s, unsigned port_index, in grpc_tcp_server_port_fd()
59 grpc_tcp_server* grpc_tcp_server_ref(grpc_tcp_server* s) { in grpc_tcp_server_ref()
63 void grpc_tcp_server_shutdown_starting_add(grpc_tcp_server* s, in grpc_tcp_server_shutdown_starting_add()
68 void grpc_tcp_server_unref(grpc_tcp_server* s) { in grpc_tcp_server_unref()
72 void grpc_tcp_server_shutdown_listeners(grpc_tcp_server* s) { in grpc_tcp_server_shutdown_listeners()
[all …]
|
| H A D | tcp_server_posix.cc | 91 static void finish_shutdown(grpc_tcp_server* s) { in finish_shutdown()
110 grpc_tcp_server* s, grpc_closure* shutdown_complete, in CreateEventEngineListener()
111 const EndpointConfig& config, grpc_tcp_server** server) { in CreateEventEngineListener()
260 grpc_tcp_server** server) { in tcp_server_create()
261 grpc_tcp_server* s = new grpc_tcp_server; in tcp_server_create()
307 grpc_tcp_server* s = static_cast<grpc_tcp_server*>(server); in destroyed_port()
322 static void deactivated_all_ports(grpc_tcp_server* s) { in deactivated_all_ports()
353 static void tcp_server_destroy(grpc_tcp_server* s) { in tcp_server_destroy()
511 static grpc_error_handle add_wildcard_addrs_to_server(grpc_tcp_server* s, in add_wildcard_addrs_to_server()
628 static grpc_error_handle tcp_server_add_port(grpc_tcp_server* s, in tcp_server_add_port()
[all …]
|
| H A D | tcp_server_utils_posix.h | 40 grpc_tcp_server* server;
64 struct grpc_tcp_server { struct
124 grpc_error_handle grpc_tcp_server_add_addr(grpc_tcp_server* s, argument
136 grpc_error_handle grpc_tcp_server_add_all_local_addrs(grpc_tcp_server* s,
143 grpc_tcp_server*, int fd, const grpc_resolved_address* addr,
|
| H A D | systemd_utils.cc | 35 bool set_matching_sd_unix_fd(grpc_tcp_server* s, in set_matching_sd_unix_fd()
48 bool set_matching_sd_inet_fd(grpc_tcp_server* s, in set_matching_sd_inet_fd()
67 void set_matching_sd_fds(grpc_tcp_server* s, const grpc_resolved_address* addr, in set_matching_sd_fds()
111 void set_matching_sd_fds(GRPC_UNUSED grpc_tcp_server* s, in set_matching_sd_fds()
|
| H A D | tcp_server_utils_posix_common.cc | 105 static grpc_error_handle add_socket_to_server(grpc_tcp_server* s, int fd, in add_socket_to_server()
158 grpc_error_handle grpc_tcp_server_add_addr(grpc_tcp_server* s, in grpc_tcp_server_add_addr()
208 grpc_tcp_server* s, int fd, const grpc_resolved_address* addr, in grpc_tcp_server_prepare_socket()
|
| H A D | tcp_server_utils_posix_ifaddrs.cc | 45 static grpc_tcp_listener* find_listener_with_addr(grpc_tcp_server* s, in find_listener_with_addr()
98 grpc_error_handle grpc_tcp_server_add_all_local_addrs(grpc_tcp_server* s, in grpc_tcp_server_add_all_local_addrs()
|
| H A D | tcp_server_utils_posix_noifaddrs.cc | 27 grpc_error_handle grpc_tcp_server_add_all_local_addrs(grpc_tcp_server* /*s*/, in grpc_tcp_server_add_all_local_addrs() argument
|
| H A D | systemd_utils.h | 30 void set_matching_sd_fds(grpc_tcp_server* s, const grpc_resolved_address* addr,
|
| /aosp_15_r20/external/rust/android-crates-io/crates/grpcio-sys/grpc/src/core/lib/iomgr/ |
| D | tcp_server.h | 35 typedef struct grpc_tcp_server grpc_tcp_server; typedef
40 grpc_tcp_server* from_server;
70 grpc_tcp_server_cb on_accept_cb, void* cb_arg, grpc_tcp_server** server);
71 void (*start)(grpc_tcp_server* server,
73 grpc_error_handle (*add_port)(grpc_tcp_server* s,
76 grpc_core::TcpServerFdHandler* (*create_fd_handler)(grpc_tcp_server* s);
77 unsigned (*port_fd_count)(grpc_tcp_server* s, unsigned port_index);
78 int (*port_fd)(grpc_tcp_server* s, unsigned port_index, unsigned fd_index);
79 grpc_tcp_server* (*ref)(grpc_tcp_server* s);
80 void (*shutdown_starting_add)(grpc_tcp_server* s,
[all …]
|
| D | tcp_server_windows.cc | 91 grpc_tcp_server* server;
103 struct grpc_tcp_server { struct
134 grpc_tcp_server** server) { in tcp_server_create()
135 grpc_tcp_server* s = (grpc_tcp_server*)gpr_malloc(sizeof(grpc_tcp_server)); in tcp_server_create()
151 grpc_tcp_server* s = (grpc_tcp_server*)arg; in destroy_server()
167 static void finish_shutdown_locked(grpc_tcp_server* s) { in finish_shutdown_locked()
179 static grpc_tcp_server* tcp_server_ref(grpc_tcp_server* s) { in tcp_server_ref()
184 static void tcp_server_shutdown_starting_add(grpc_tcp_server* s, in tcp_server_shutdown_starting_add()
192 static void tcp_server_destroy(grpc_tcp_server* s) { in tcp_server_destroy()
208 static void tcp_server_unref(grpc_tcp_server* s) { in tcp_server_unref()
[all …]
|
| D | tcp_server.cc | 28 grpc_tcp_server_cb on_accept_cb, void* cb_arg, grpc_tcp_server** server) { in grpc_tcp_server_create()
33 void grpc_tcp_server_start(grpc_tcp_server* server, in grpc_tcp_server_start()
38 grpc_error_handle grpc_tcp_server_add_port(grpc_tcp_server* s, in grpc_tcp_server_add_port()
45 grpc_tcp_server* s) { in grpc_tcp_server_create_fd_handler()
49 unsigned grpc_tcp_server_port_fd_count(grpc_tcp_server* s, in grpc_tcp_server_port_fd_count()
54 int grpc_tcp_server_port_fd(grpc_tcp_server* s, unsigned port_index, in grpc_tcp_server_port_fd()
59 grpc_tcp_server* grpc_tcp_server_ref(grpc_tcp_server* s) { in grpc_tcp_server_ref()
63 void grpc_tcp_server_shutdown_starting_add(grpc_tcp_server* s, in grpc_tcp_server_shutdown_starting_add()
68 void grpc_tcp_server_unref(grpc_tcp_server* s) { in grpc_tcp_server_unref()
72 void grpc_tcp_server_shutdown_listeners(grpc_tcp_server* s) { in grpc_tcp_server_shutdown_listeners()
[all …]
|
| D | tcp_server_posix.cc | 94 grpc_tcp_server* s, grpc_closure* shutdown_complete, in CreateEventEngineListener()
95 const EndpointConfig& config, grpc_tcp_server** server) { in CreateEventEngineListener()
221 grpc_tcp_server** server) { in tcp_server_create()
222 grpc_tcp_server* s = new grpc_tcp_server; in tcp_server_create()
267 static void finish_shutdown(grpc_tcp_server* s) { in finish_shutdown()
292 grpc_tcp_server* s = static_cast<grpc_tcp_server*>(server); in destroyed_port()
307 static void deactivated_all_ports(grpc_tcp_server* s) { in deactivated_all_ports()
332 static void tcp_server_destroy(grpc_tcp_server* s) { in tcp_server_destroy()
484 static grpc_error_handle add_wildcard_addrs_to_server(grpc_tcp_server* s, in add_wildcard_addrs_to_server()
601 static grpc_error_handle tcp_server_add_port(grpc_tcp_server* s, in tcp_server_add_port()
[all …]
|
| D | tcp_server_utils_posix.h | 40 grpc_tcp_server* server;
64 struct grpc_tcp_server { struct
124 grpc_error_handle grpc_tcp_server_add_addr(grpc_tcp_server* s, argument
136 grpc_error_handle grpc_tcp_server_add_all_local_addrs(grpc_tcp_server* s,
143 grpc_tcp_server*, int fd, const grpc_resolved_address* addr,
|
| D | systemd_utils.cc | 35 bool set_matching_sd_unix_fd(grpc_tcp_server* s, in set_matching_sd_unix_fd()
48 bool set_matching_sd_inet_fd(grpc_tcp_server* s, in set_matching_sd_inet_fd()
67 void set_matching_sd_fds(grpc_tcp_server* s, const grpc_resolved_address* addr, in set_matching_sd_fds()
111 void set_matching_sd_fds(GRPC_UNUSED grpc_tcp_server* s, in set_matching_sd_fds()
|
| D | tcp_server_utils_posix_common.cc | 104 static grpc_error_handle add_socket_to_server(grpc_tcp_server* s, int fd, in add_socket_to_server()
157 grpc_error_handle grpc_tcp_server_add_addr(grpc_tcp_server* s, in grpc_tcp_server_add_addr()
207 grpc_tcp_server* s, int fd, const grpc_resolved_address* addr, in grpc_tcp_server_prepare_socket()
|
| D | tcp_server_utils_posix_ifaddrs.cc | 45 static grpc_tcp_listener* find_listener_with_addr(grpc_tcp_server* s, in find_listener_with_addr()
92 grpc_error_handle grpc_tcp_server_add_all_local_addrs(grpc_tcp_server* s, in grpc_tcp_server_add_all_local_addrs()
|
| D | tcp_server_utils_posix_noifaddrs.cc | 27 grpc_error_handle grpc_tcp_server_add_all_local_addrs(grpc_tcp_server* /*s*/, in grpc_tcp_server_add_all_local_addrs() argument
|
| D | systemd_utils.h | 30 void set_matching_sd_fds(grpc_tcp_server* s, const grpc_resolved_address* addr,
|
| /aosp_15_r20/external/grpc-grpc/test/core/iomgr/ |
| H A D | tcp_server_posix_test.cc | 70 grpc_tcp_server* server;
77 grpc_tcp_server* server;
144 grpc_tcp_server* server) { in server_weak_ref_set()
176 grpc_tcp_server* s; in test_no_op()
191 grpc_tcp_server* s; in test_no_op_with_start()
212 grpc_tcp_server* s; in test_no_op_with_port()
240 grpc_tcp_server* s; in test_no_op_with_port_and_start()
343 grpc_tcp_server* s; in test_connect()
476 static int pre_allocate_inet_sock(grpc_tcp_server* s, int family, int port, in pre_allocate_inet_sock()
516 grpc_tcp_server* s; in test_pre_allocated_inet_fd()
[all …]
|
| /aosp_15_r20/external/grpc-grpc/test/core/util/ |
| H A D | test_tcp_server.h | 33 grpc_tcp_server* tcp_server = nullptr;
|
| /aosp_15_r20/external/grpc-grpc/test/core/surface/ |
| H A D | concurrent_connectivity_test.cc | 144 grpc_tcp_server* s; in bad_server_thread()
|
| /aosp_15_r20/external/rust/android-crates-io/crates/grpcio-sys/grpc/src/core/ext/transport/chttp2/server/ |
| D | chttp2_server.cc | 263 grpc_tcp_server* tcp_server_;
894 grpc_tcp_server* tcp_server; in Orphan()
|
| /aosp_15_r20/external/grpc-grpc/src/core/ext/transport/chttp2/server/ |
| H A D | chttp2_server.cc | 265 grpc_tcp_server* tcp_server_;
929 grpc_tcp_server* tcp_server; in Orphan()
|