| /third_party/grpc/src/core/lib/iomgr/ |
| D | endpoint.h | 36 typedef struct grpc_endpoint grpc_endpoint; typedef
40 void (*read)(grpc_endpoint* ep, grpc_slice_buffer* slices, grpc_closure* cb,
42 void (*write)(grpc_endpoint* ep, grpc_slice_buffer* slices, grpc_closure* cb,
44 void (*add_to_pollset)(grpc_endpoint* ep, grpc_pollset* pollset);
45 void (*add_to_pollset_set)(grpc_endpoint* ep, grpc_pollset_set* pollset);
46 void (*delete_from_pollset_set)(grpc_endpoint* ep, grpc_pollset_set* pollset);
47 void (*shutdown)(grpc_endpoint* ep, grpc_error* why);
48 void (*destroy)(grpc_endpoint* ep);
49 grpc_resource_user* (*get_resource_user)(grpc_endpoint* ep);
50 absl::string_view (*get_peer)(grpc_endpoint* ep);
[all …]
|
| D | endpoint.cc | 25 void grpc_endpoint_read(grpc_endpoint* ep, grpc_slice_buffer* slices, in grpc_endpoint_read()
30 void grpc_endpoint_write(grpc_endpoint* ep, grpc_slice_buffer* slices, in grpc_endpoint_write()
35 void grpc_endpoint_add_to_pollset(grpc_endpoint* ep, grpc_pollset* pollset) { in grpc_endpoint_add_to_pollset()
39 void grpc_endpoint_add_to_pollset_set(grpc_endpoint* ep, in grpc_endpoint_add_to_pollset_set()
44 void grpc_endpoint_delete_from_pollset_set(grpc_endpoint* ep, in grpc_endpoint_delete_from_pollset_set()
49 void grpc_endpoint_shutdown(grpc_endpoint* ep, grpc_error* why) { in grpc_endpoint_shutdown()
53 void grpc_endpoint_destroy(grpc_endpoint* ep) { ep->vtable->destroy(ep); } in grpc_endpoint_destroy()
55 absl::string_view grpc_endpoint_get_peer(grpc_endpoint* ep) { in grpc_endpoint_get_peer()
59 absl::string_view grpc_endpoint_get_local_address(grpc_endpoint* ep) { in grpc_endpoint_get_local_address()
63 int grpc_endpoint_get_fd(grpc_endpoint* ep) { return ep->vtable->get_fd(ep); } in grpc_endpoint_get_fd()
[all …]
|
| D | tcp_custom.cc | 57 grpc_endpoint base;
199 static void endpoint_read(grpc_endpoint* ep, grpc_slice_buffer* read_slices, in endpoint_read()
231 static void endpoint_write(grpc_endpoint* ep, grpc_slice_buffer* write_slices, in endpoint_write()
270 static void endpoint_add_to_pollset(grpc_endpoint* ep, grpc_pollset* pollset) { in endpoint_add_to_pollset()
276 static void endpoint_add_to_pollset_set(grpc_endpoint* ep, in endpoint_add_to_pollset_set()
283 static void endpoint_delete_from_pollset_set(grpc_endpoint* ep, in endpoint_delete_from_pollset_set()
290 static void endpoint_shutdown(grpc_endpoint* ep, grpc_error* why) { in endpoint_shutdown()
322 static void endpoint_destroy(grpc_endpoint* ep) { in endpoint_destroy()
327 static absl::string_view endpoint_get_peer(grpc_endpoint* ep) { in endpoint_get_peer()
332 static absl::string_view endpoint_get_local_address(grpc_endpoint* ep) { in endpoint_get_local_address()
[all …]
|
| D | endpoint_cfstream.cc | 45 grpc_endpoint base;
256 static void CFStreamRead(grpc_endpoint* ep, grpc_slice_buffer* slices, in CFStreamRead()
275 static void CFStreamWrite(grpc_endpoint* ep, grpc_slice_buffer* slices, in CFStreamWrite()
289 void CFStreamShutdown(grpc_endpoint* ep, grpc_error* why) { in CFStreamShutdown()
303 void CFStreamDestroy(grpc_endpoint* ep) { in CFStreamDestroy()
311 grpc_resource_user* CFStreamGetResourceUser(grpc_endpoint* ep) { in CFStreamGetResourceUser()
316 absl::string_view CFStreamGetPeer(grpc_endpoint* ep) { in CFStreamGetPeer()
321 absl::string_view CFStreamGetLocalAddress(grpc_endpoint* ep) { in CFStreamGetLocalAddress()
326 int CFStreamGetFD(grpc_endpoint* ep) { return 0; } in CFStreamGetFD()
328 bool CFStreamCanTrackErr(grpc_endpoint* ep) { return false; } in CFStreamCanTrackErr()
[all …]
|
| D | tcp_posix.h | 45 grpc_endpoint* grpc_tcp_create(grpc_fd* fd, const grpc_channel_args* args,
52 int grpc_tcp_fd(grpc_endpoint* ep);
57 void grpc_tcp_destroy_and_release_fd(grpc_endpoint* ep, int* fd,
|
| D | tcp_windows.cc | 102 grpc_endpoint base;
241 static void win_read(grpc_endpoint* ep, grpc_slice_buffer* read_slices, in win_read()
346 static void win_write(grpc_endpoint* ep, grpc_slice_buffer* slices, in win_write()
434 static void win_add_to_pollset(grpc_endpoint* ep, grpc_pollset* ps) { in win_add_to_pollset()
441 static void win_add_to_pollset_set(grpc_endpoint* ep, grpc_pollset_set* pss) { in win_add_to_pollset_set()
448 static void win_delete_from_pollset_set(grpc_endpoint* ep, in win_delete_from_pollset_set()
457 static void win_shutdown(grpc_endpoint* ep, grpc_error* why) { in win_shutdown()
473 static void win_destroy(grpc_endpoint* ep) { in win_destroy()
479 static absl::string_view win_get_peer(grpc_endpoint* ep) { in win_get_peer()
484 static absl::string_view win_get_local_address(grpc_endpoint* ep) { in win_get_local_address()
[all …]
|
| D | endpoint_pair.h | 27 grpc_endpoint* client;
28 grpc_endpoint* server;
|
| D | tcp_client_posix.h | 35 grpc_endpoint* grpc_tcp_client_create_from_fd(
66 grpc_millis deadline, grpc_endpoint** ep);
|
| D | tcp_client.h | 31 void (*connect)(grpc_closure* on_connect, grpc_endpoint** endpoint,
42 void grpc_tcp_client_connect(grpc_closure* on_connect, grpc_endpoint** endpoint,
|
| D | tcp_client_posix.cc | 62 grpc_endpoint** ep;
124 grpc_endpoint* grpc_tcp_client_create_from_fd( in grpc_tcp_client_create_from_fd()
135 grpc_endpoint** ep = ac->ep; in on_writable()
279 grpc_millis deadline, grpc_endpoint** ep) { in grpc_tcp_client_create_from_prepared_fd()
331 static void tcp_connect(grpc_closure* closure, grpc_endpoint** ep, in tcp_connect()
|
| D | tcp_custom.h | 36 grpc_endpoint* endpoint;
80 grpc_endpoint* custom_tcp_endpoint_create(grpc_custom_socket* socket,
|
| /third_party/grpc/test/core/util/ |
| D | mock_endpoint.cc | 38 grpc_endpoint base;
47 static void me_read(grpc_endpoint* ep, grpc_slice_buffer* slices, in me_read()
61 static void me_write(grpc_endpoint* ep, grpc_slice_buffer* slices, in me_write()
70 static void me_add_to_pollset(grpc_endpoint* /*ep*/, in me_add_to_pollset() argument
73 static void me_add_to_pollset_set(grpc_endpoint* /*ep*/, in me_add_to_pollset_set() argument
76 static void me_delete_from_pollset_set(grpc_endpoint* /*ep*/, in me_delete_from_pollset_set() argument
79 static void me_shutdown(grpc_endpoint* ep, grpc_error* why) { in me_shutdown()
93 static void me_destroy(grpc_endpoint* ep) { in me_destroy()
101 static char* me_get_peer(grpc_endpoint* /*ep*/) { in me_get_peer() argument
105 static grpc_resource_user* me_get_resource_user(grpc_endpoint* ep) { in me_get_resource_user()
[all …]
|
| D | trickle_endpoint.cc | 36 grpc_endpoint base;
38 grpc_endpoint* wrapped;
49 static void te_read(grpc_endpoint* ep, grpc_slice_buffer* slices, in te_read()
65 static void te_write(grpc_endpoint* ep, grpc_slice_buffer* slices, in te_write()
82 static void te_add_to_pollset(grpc_endpoint* ep, grpc_pollset* pollset) { in te_add_to_pollset()
87 static void te_add_to_pollset_set(grpc_endpoint* ep, in te_add_to_pollset_set()
93 static void te_delete_from_pollset_set(grpc_endpoint* ep, in te_delete_from_pollset_set()
99 static void te_shutdown(grpc_endpoint* ep, grpc_error* why) { in te_shutdown()
110 static void te_destroy(grpc_endpoint* ep) { in te_destroy()
120 static grpc_resource_user* te_get_resource_user(grpc_endpoint* ep) { in te_get_resource_user()
[all …]
|
| D | passthru_endpoint.cc | 43 grpc_endpoint base;
60 static void me_read(grpc_endpoint* ep, grpc_slice_buffer* slices, in me_read()
83 static void me_write(grpc_endpoint* ep, grpc_slice_buffer* slices, in me_write()
107 static void me_add_to_pollset(grpc_endpoint* /*ep*/, in me_add_to_pollset() argument
110 static void me_add_to_pollset_set(grpc_endpoint* /*ep*/, in me_add_to_pollset_set() argument
113 static void me_delete_from_pollset_set(grpc_endpoint* /*ep*/, in me_delete_from_pollset_set() argument
116 static void me_shutdown(grpc_endpoint* ep, grpc_error* why) { in me_shutdown()
138 static void me_destroy(grpc_endpoint* ep) { in me_destroy()
155 static char* me_get_peer(grpc_endpoint* ep) { in me_get_peer()
162 static int me_get_fd(grpc_endpoint* /*ep*/) { return -1; } in me_get_fd() argument
[all …]
|
| D | trickle_endpoint.h | 24 grpc_endpoint* grpc_trickle_endpoint_create(grpc_endpoint* wrap,
28 size_t grpc_trickle_endpoint_trickle(grpc_endpoint* endpoint);
30 size_t grpc_trickle_get_backlog(grpc_endpoint* endpoint);
|
| D | mock_endpoint.h | 24 grpc_endpoint* grpc_mock_endpoint_create(void (*on_write)(grpc_slice slice),
26 void grpc_mock_endpoint_put_read(grpc_endpoint* mock_endpoint,
|
| D | passthru_endpoint.h | 34 void grpc_passthru_endpoint_create(grpc_endpoint** client,
35 grpc_endpoint** server,
|
| /third_party/grpc/src/core/lib/security/transport/ |
| D | secure_endpoint.cc | 53 grpc_endpoint* transport, grpc_slice* leftover_slices, in secure_endpoint()
83 grpc_endpoint base;
84 grpc_endpoint* wrapped_ep;
257 static void endpoint_read(grpc_endpoint* secure_ep, grpc_slice_buffer* slices, in endpoint_read()
283 static void endpoint_write(grpc_endpoint* secure_ep, grpc_slice_buffer* slices, in endpoint_write()
376 static void endpoint_shutdown(grpc_endpoint* secure_ep, grpc_error* why) { in endpoint_shutdown()
381 static void endpoint_destroy(grpc_endpoint* secure_ep) { in endpoint_destroy()
386 static void endpoint_add_to_pollset(grpc_endpoint* secure_ep, in endpoint_add_to_pollset()
392 static void endpoint_add_to_pollset_set(grpc_endpoint* secure_ep, in endpoint_add_to_pollset_set()
398 static void endpoint_delete_from_pollset_set(grpc_endpoint* secure_ep, in endpoint_delete_from_pollset_set()
[all …]
|
| D | secure_endpoint.h | 35 grpc_endpoint* grpc_secure_endpoint_create(
38 grpc_endpoint* to_wrap, grpc_slice* leftover_slices,
|
| /third_party/grpc/test/core/iomgr/ |
| D | endpoint_tests.h | 30 grpc_endpoint* client_ep;
31 grpc_endpoint* server_ep;
|
| /third_party/grpc/test/cpp/microbenchmarks/ |
| D | bm_chttp2_transport.cc | 44 class DummyEndpoint : public grpc_endpoint {
58 grpc_endpoint::vtable = &my_vtable; in DummyEndpoint()
94 static void read(grpc_endpoint* ep, grpc_slice_buffer* slices, in read()
99 static void write(grpc_endpoint* /*ep*/, grpc_slice_buffer* /*slices*/, in write() argument
104 static void add_to_pollset(grpc_endpoint* /*ep*/, grpc_pollset* /*pollset*/) { in add_to_pollset() argument
107 static void add_to_pollset_set(grpc_endpoint* /*ep*/, in add_to_pollset_set() argument
110 static void delete_from_pollset_set(grpc_endpoint* /*ep*/, in delete_from_pollset_set() argument
113 static void shutdown(grpc_endpoint* ep, grpc_error* why) { in shutdown()
119 static void destroy(grpc_endpoint* ep) { in destroy()
124 static grpc_resource_user* get_resource_user(grpc_endpoint* ep) { in get_resource_user()
[all …]
|
| /third_party/grpc/src/core/lib/http/ |
| D | httpcli_security_connector.cc | 91 void check_peer(tsi_peer peer, grpc_endpoint* /*ep*/, in check_peer() argument
159 void (*func)(void* arg, grpc_endpoint* endpoint);
180 static void ssl_handshake(void* arg, grpc_endpoint* tcp, const char* host, in ssl_handshake()
182 void (*on_done)(void* arg, grpc_endpoint* endpoint)) { in ssl_handshake()
|
| D | httpcli.h | 46 void (*handshake)(void* arg, grpc_endpoint* endpoint, const char* host,
48 void (*on_done)(void* arg, grpc_endpoint* endpoint));
|
| /third_party/grpc/src/core/lib/security/authorization/ |
| D | evaluate_args.h | 35 grpc_endpoint* endpoint) in EvaluateArgs()
54 grpc_endpoint* endpoint_;
|
| /third_party/grpc/src/core/lib/security/security_connector/insecure/ |
| D | insecure_security_connector.h | 59 void check_peer(tsi_peer peer, grpc_endpoint* ep,
77 void check_peer(tsi_peer peer, grpc_endpoint* ep,
|