| /external/rust/crates/grpcio-sys/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;
|
| /external/grpc-grpc/src/core/lib/iomgr/ |
| D | endpoint.h | 34 typedef struct grpc_endpoint grpc_endpoint; typedef
39 void (*read)(grpc_endpoint* ep, grpc_slice_buffer* slices, grpc_closure* cb);
40 void (*write)(grpc_endpoint* ep, grpc_slice_buffer* slices, grpc_closure* cb,
42 void (*add_to_pollset)(grpc_endpoint* ep, grpc_pollset* pollset);
43 void (*add_to_pollset_set)(grpc_endpoint* ep, grpc_pollset_set* pollset);
44 void (*delete_from_pollset_set)(grpc_endpoint* ep, grpc_pollset_set* pollset);
45 void (*shutdown)(grpc_endpoint* ep, grpc_error* why);
46 void (*destroy)(grpc_endpoint* ep);
47 grpc_resource_user* (*get_resource_user)(grpc_endpoint* ep);
48 char* (*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 char* grpc_endpoint_get_peer(grpc_endpoint* ep) { in grpc_endpoint_get_peer()
59 int grpc_endpoint_get_fd(grpc_endpoint* ep) { return ep->vtable->get_fd(ep); } in grpc_endpoint_get_fd()
61 grpc_resource_user* grpc_endpoint_get_resource_user(grpc_endpoint* ep) { in grpc_endpoint_get_resource_user()
|
| D | tcp_custom.cc | 57 grpc_endpoint base;
195 static void endpoint_read(grpc_endpoint* ep, grpc_slice_buffer* read_slices, in endpoint_read()
223 static void endpoint_write(grpc_endpoint* ep, grpc_slice_buffer* write_slices, in endpoint_write()
261 static void endpoint_add_to_pollset(grpc_endpoint* ep, grpc_pollset* pollset) { in endpoint_add_to_pollset()
267 static void endpoint_add_to_pollset_set(grpc_endpoint* ep, in endpoint_add_to_pollset_set()
274 static void endpoint_delete_from_pollset_set(grpc_endpoint* ep, in endpoint_delete_from_pollset_set()
281 static void endpoint_shutdown(grpc_endpoint* ep, grpc_error* why) { in endpoint_shutdown()
311 static void endpoint_destroy(grpc_endpoint* ep) { in endpoint_destroy()
317 static char* endpoint_get_peer(grpc_endpoint* ep) { in endpoint_get_peer()
322 static grpc_resource_user* endpoint_get_resource_user(grpc_endpoint* ep) { in endpoint_get_resource_user()
[all …]
|
| D | endpoint_cfstream.cc | 43 grpc_endpoint base;
253 static void CFStreamRead(grpc_endpoint* ep, grpc_slice_buffer* slices, in CFStreamRead()
270 static void CFStreamWrite(grpc_endpoint* ep, grpc_slice_buffer* slices, in CFStreamWrite()
284 void CFStreamShutdown(grpc_endpoint* ep, grpc_error* why) { in CFStreamShutdown()
298 void CFStreamDestroy(grpc_endpoint* ep) { in CFStreamDestroy()
306 grpc_resource_user* CFStreamGetResourceUser(grpc_endpoint* ep) { in CFStreamGetResourceUser()
311 char* CFStreamGetPeer(grpc_endpoint* ep) { in CFStreamGetPeer()
316 int CFStreamGetFD(grpc_endpoint* ep) { return 0; } in CFStreamGetFD()
318 void CFStreamAddToPollset(grpc_endpoint* ep, grpc_pollset* pollset) {} in CFStreamAddToPollset()
319 void CFStreamAddToPollsetSet(grpc_endpoint* ep, grpc_pollset_set* pollset) {} in CFStreamAddToPollsetSet()
[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 | 104 grpc_endpoint base;
212 static void win_read(grpc_endpoint* ep, grpc_slice_buffer* read_slices, in win_read()
298 static void win_write(grpc_endpoint* ep, grpc_slice_buffer* slices, in win_write()
373 static void win_add_to_pollset(grpc_endpoint* ep, grpc_pollset* ps) { in win_add_to_pollset()
380 static void win_add_to_pollset_set(grpc_endpoint* ep, grpc_pollset_set* pss) { in win_add_to_pollset_set()
387 static void win_delete_from_pollset_set(grpc_endpoint* ep, in win_delete_from_pollset_set()
396 static void win_shutdown(grpc_endpoint* ep, grpc_error* why) { in win_shutdown()
412 static void win_destroy(grpc_endpoint* ep) { in win_destroy()
418 static char* win_get_peer(grpc_endpoint* ep) { in win_get_peer()
423 static grpc_resource_user* win_get_resource_user(grpc_endpoint* ep) { in win_get_resource_user()
[all …]
|
| D | network_status_tracker.h | 28 void grpc_network_status_register_endpoint(grpc_endpoint* ep);
29 void grpc_network_status_unregister_endpoint(grpc_endpoint* ep);
|
| D | endpoint_pair.h | 27 grpc_endpoint* client;
28 grpc_endpoint* server;
|
| D | network_status_tracker.cc | 32 void grpc_network_status_register_endpoint(grpc_endpoint* ep) { (void)ep; } in grpc_network_status_register_endpoint()
34 void grpc_network_status_unregister_endpoint(grpc_endpoint* ep) { (void)ep; } in grpc_network_status_unregister_endpoint()
|
| /external/grpc-grpc/test/core/util/ |
| D | mock_endpoint.cc | 34 grpc_endpoint base;
43 static void me_read(grpc_endpoint* ep, grpc_slice_buffer* slices, in me_read()
57 static void me_write(grpc_endpoint* ep, grpc_slice_buffer* slices, in me_write()
66 static void me_add_to_pollset(grpc_endpoint* ep, grpc_pollset* pollset) {} in me_add_to_pollset()
68 static void me_add_to_pollset_set(grpc_endpoint* ep, in me_add_to_pollset_set()
71 static void me_delete_from_pollset_set(grpc_endpoint* ep, in me_delete_from_pollset_set()
74 static void me_shutdown(grpc_endpoint* ep, grpc_error* why) { in me_shutdown()
88 static void me_destroy(grpc_endpoint* ep) { in me_destroy()
95 static char* me_get_peer(grpc_endpoint* ep) { in me_get_peer()
99 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()
64 static void te_write(grpc_endpoint* ep, grpc_slice_buffer* slices, in te_write()
81 static void te_add_to_pollset(grpc_endpoint* ep, grpc_pollset* pollset) { in te_add_to_pollset()
86 static void te_add_to_pollset_set(grpc_endpoint* ep, in te_add_to_pollset_set()
92 static void te_delete_from_pollset_set(grpc_endpoint* ep, in te_delete_from_pollset_set()
98 static void te_shutdown(grpc_endpoint* ep, grpc_error* why) { in te_shutdown()
109 static void te_destroy(grpc_endpoint* ep) { in te_destroy()
119 static grpc_resource_user* te_get_resource_user(grpc_endpoint* ep) { in te_get_resource_user()
[all …]
|
| D | passthru_endpoint.cc | 39 grpc_endpoint base;
56 static void me_read(grpc_endpoint* ep, grpc_slice_buffer* slices, in me_read()
78 static void me_write(grpc_endpoint* ep, grpc_slice_buffer* slices, in me_write()
102 static void me_add_to_pollset(grpc_endpoint* ep, grpc_pollset* pollset) {} in me_add_to_pollset()
104 static void me_add_to_pollset_set(grpc_endpoint* ep, in me_add_to_pollset_set()
107 static void me_delete_from_pollset_set(grpc_endpoint* ep, in me_delete_from_pollset_set()
110 static void me_shutdown(grpc_endpoint* ep, grpc_error* why) { in me_shutdown()
132 static void me_destroy(grpc_endpoint* ep) { in me_destroy()
149 static char* me_get_peer(grpc_endpoint* ep) { in me_get_peer()
156 static int me_get_fd(grpc_endpoint* ep) { return -1; } in me_get_fd()
[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,
|
| /external/rust/crates/grpcio-sys/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 …]
|
| /external/grpc-grpc/src/core/lib/security/transport/ |
| D | secure_endpoint.cc | 44 grpc_endpoint base;
45 grpc_endpoint* wrapped_ep;
230 static void endpoint_read(grpc_endpoint* secure_ep, grpc_slice_buffer* slices, in endpoint_read()
256 static void endpoint_write(grpc_endpoint* secure_ep, grpc_slice_buffer* slices, in endpoint_write()
348 static void endpoint_shutdown(grpc_endpoint* secure_ep, grpc_error* why) { in endpoint_shutdown()
353 static void endpoint_destroy(grpc_endpoint* secure_ep) { in endpoint_destroy()
358 static void endpoint_add_to_pollset(grpc_endpoint* secure_ep, in endpoint_add_to_pollset()
364 static void endpoint_add_to_pollset_set(grpc_endpoint* secure_ep, in endpoint_add_to_pollset_set()
370 static void endpoint_delete_from_pollset_set(grpc_endpoint* secure_ep, in endpoint_delete_from_pollset_set()
376 static char* endpoint_get_peer(grpc_endpoint* secure_ep) { in endpoint_get_peer()
[all …]
|
| D | secure_endpoint.h | 35 grpc_endpoint* grpc_secure_endpoint_create(
38 grpc_endpoint* to_wrap, grpc_slice* leftover_slices,
|
| /external/grpc-grpc/test/cpp/microbenchmarks/ |
| D | bm_chttp2_transport.cc | 45 class DummyEndpoint : public grpc_endpoint {
58 grpc_endpoint::vtable = &my_vtable; in DummyEndpoint()
93 static void read(grpc_endpoint* ep, grpc_slice_buffer* slices, in read()
98 static void write(grpc_endpoint* ep, grpc_slice_buffer* slices, in write()
103 static grpc_workqueue* get_workqueue(grpc_endpoint* ep) { return nullptr; } in get_workqueue()
105 static void add_to_pollset(grpc_endpoint* ep, grpc_pollset* pollset) {} in add_to_pollset()
107 static void add_to_pollset_set(grpc_endpoint* ep, grpc_pollset_set* pollset) { in add_to_pollset_set()
110 static void delete_from_pollset_set(grpc_endpoint* ep, in delete_from_pollset_set()
113 static void shutdown(grpc_endpoint* ep, grpc_error* why) { in shutdown()
118 static void destroy(grpc_endpoint* ep) { in destroy()
[all …]
|