| /external/grpc-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_handle why);
48 void (*destroy)(grpc_endpoint* ep);
49 absl::string_view (*get_peer)(grpc_endpoint* ep);
50 absl::string_view (*get_local_address)(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_handle 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 | endpoint_cfstream.cc | 46 grpc_endpoint base;
242 static void CFStreamRead(grpc_endpoint* ep, grpc_slice_buffer* slices, in CFStreamRead()
260 static void CFStreamWrite(grpc_endpoint* ep, grpc_slice_buffer* slices, in CFStreamWrite()
275 void CFStreamShutdown(grpc_endpoint* ep, grpc_error_handle why) { in CFStreamShutdown()
290 void CFStreamDestroy(grpc_endpoint* ep) { in CFStreamDestroy()
298 absl::string_view CFStreamGetPeer(grpc_endpoint* ep) { in CFStreamGetPeer()
303 absl::string_view CFStreamGetLocalAddress(grpc_endpoint* ep) { in CFStreamGetLocalAddress()
308 int CFStreamGetFD(grpc_endpoint* /*ep*/) { return 0; } in CFStreamGetFD() argument
310 bool CFStreamCanTrackErr(grpc_endpoint* /*ep*/) { return false; } in CFStreamCanTrackErr() argument
312 void CFStreamAddToPollset(grpc_endpoint* /*ep*/, grpc_pollset* /*pollset*/) {} in CFStreamAddToPollset() argument
[all …]
|
| D | tcp_posix.h | 45 grpc_endpoint* grpc_tcp_create(grpc_fd* fd,
51 int grpc_tcp_fd(grpc_endpoint* ep);
56 void grpc_tcp_destroy_and_release_fd(grpc_endpoint* ep, int* fd,
|
| D | tcp_windows.cc | 103 grpc_endpoint base;
237 static void win_read(grpc_endpoint* ep, grpc_slice_buffer* read_slices, in win_read()
343 static void win_write(grpc_endpoint* ep, grpc_slice_buffer* slices, in win_write()
457 static void win_add_to_pollset(grpc_endpoint* ep, grpc_pollset* ps) { in win_add_to_pollset()
464 static void win_add_to_pollset_set(grpc_endpoint* ep, grpc_pollset_set* pss) { in win_add_to_pollset_set()
471 static void win_delete_from_pollset_set(grpc_endpoint* /* ep */, in win_delete_from_pollset_set() argument
480 static void win_shutdown(grpc_endpoint* ep, grpc_error_handle why) { in win_shutdown()
493 static void win_destroy(grpc_endpoint* ep) { in win_destroy()
499 static absl::string_view win_get_peer(grpc_endpoint* ep) { in win_get_peer()
504 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/rust/android-crates-io/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_handle why);
48 void (*destroy)(grpc_endpoint* ep);
49 absl::string_view (*get_peer)(grpc_endpoint* ep);
50 absl::string_view (*get_local_address)(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_handle 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 | endpoint_cfstream.cc | 46 grpc_endpoint base;
242 static void CFStreamRead(grpc_endpoint* ep, grpc_slice_buffer* slices, in CFStreamRead()
260 static void CFStreamWrite(grpc_endpoint* ep, grpc_slice_buffer* slices, in CFStreamWrite()
275 void CFStreamShutdown(grpc_endpoint* ep, grpc_error_handle why) { in CFStreamShutdown()
290 void CFStreamDestroy(grpc_endpoint* ep) { in CFStreamDestroy()
298 absl::string_view CFStreamGetPeer(grpc_endpoint* ep) { in CFStreamGetPeer()
303 absl::string_view CFStreamGetLocalAddress(grpc_endpoint* ep) { in CFStreamGetLocalAddress()
308 int CFStreamGetFD(grpc_endpoint* /*ep*/) { return 0; } in CFStreamGetFD() argument
310 bool CFStreamCanTrackErr(grpc_endpoint* /*ep*/) { return false; } in CFStreamCanTrackErr() argument
312 void CFStreamAddToPollset(grpc_endpoint* /*ep*/, grpc_pollset* /*pollset*/) {} in CFStreamAddToPollset() argument
[all …]
|
| D | tcp_posix.h | 45 grpc_endpoint* grpc_tcp_create(grpc_fd* fd,
51 int grpc_tcp_fd(grpc_endpoint* ep);
56 void grpc_tcp_destroy_and_release_fd(grpc_endpoint* ep, int* fd,
|
| D | tcp_windows.cc | 103 grpc_endpoint base;
239 static void win_read(grpc_endpoint* ep, grpc_slice_buffer* read_slices, in win_read()
345 static void win_write(grpc_endpoint* ep, grpc_slice_buffer* slices, in win_write()
459 static void win_add_to_pollset(grpc_endpoint* ep, grpc_pollset* ps) { in win_add_to_pollset()
466 static void win_add_to_pollset_set(grpc_endpoint* ep, grpc_pollset_set* pss) { in win_add_to_pollset_set()
473 static void win_delete_from_pollset_set(grpc_endpoint* /* ep */, in win_delete_from_pollset_set() argument
482 static void win_shutdown(grpc_endpoint* ep, grpc_error_handle why) { in win_shutdown()
495 static void win_destroy(grpc_endpoint* ep) { in win_destroy()
501 static absl::string_view win_get_peer(grpc_endpoint* ep) { in win_get_peer()
506 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/test/core/util/ |
| D | mock_endpoint.cc | 37 grpc_endpoint base;
47 static void me_read(grpc_endpoint* ep, grpc_slice_buffer* slices, in me_read()
65 static void me_write(grpc_endpoint* ep, grpc_slice_buffer* slices, in me_write()
74 static void me_add_to_pollset(grpc_endpoint* /*ep*/, in me_add_to_pollset() argument
77 static void me_add_to_pollset_set(grpc_endpoint* /*ep*/, in me_add_to_pollset_set() argument
80 static void me_delete_from_pollset_set(grpc_endpoint* /*ep*/, in me_delete_from_pollset_set() argument
83 static void me_shutdown(grpc_endpoint* ep, grpc_error_handle why) { in me_shutdown()
101 static void me_destroy(grpc_endpoint* ep) { in me_destroy()
109 void grpc_mock_endpoint_finish_put_reads(grpc_endpoint* ep) { in grpc_mock_endpoint_finish_put_reads()
117 static absl::string_view me_get_peer(grpc_endpoint* /*ep*/) { in me_get_peer() argument
[all …]
|
| D | mock_authorization_endpoint.h | 28 class MockAuthorizationEndpoint : public grpc_endpoint {
36 grpc_endpoint::vtable = &vtable; in MockAuthorizationEndpoint()
39 static absl::string_view GetPeer(grpc_endpoint* ep) { in GetPeer()
45 static absl::string_view GetLocalAddress(grpc_endpoint* ep) { in GetLocalAddress()
|
| D | mock_endpoint.h | 26 grpc_endpoint* grpc_mock_endpoint_create(void (*on_write)(grpc_slice slice));
27 void grpc_mock_endpoint_put_read(grpc_endpoint* ep, grpc_slice slice);
28 void grpc_mock_endpoint_finish_put_reads(grpc_endpoint* ep);
|
| /external/grpc-grpc/test/core/security/ |
| D | secure_endpoint_test.cc | 45 grpc_endpoint base;
46 grpc_endpoint* wrapped_ep;
50 static void me_read(grpc_endpoint* ep, grpc_slice_buffer* slices, in me_read()
56 static void me_write(grpc_endpoint* ep, grpc_slice_buffer* slices, in me_write()
75 static void me_add_to_pollset(grpc_endpoint* /*ep*/, in me_add_to_pollset() argument
78 static void me_add_to_pollset_set(grpc_endpoint* /*ep*/, in me_add_to_pollset_set() argument
81 static void me_delete_from_pollset_set(grpc_endpoint* /*ep*/, in me_delete_from_pollset_set() argument
84 static void me_shutdown(grpc_endpoint* ep, grpc_error_handle why) { in me_shutdown()
89 static void me_destroy(grpc_endpoint* ep) { in me_destroy()
96 static absl::string_view me_get_peer(grpc_endpoint* /*ep*/) { in me_get_peer() argument
[all …]
|
| /external/grpc-grpc/src/core/lib/iomgr/event_engine_shims/ |
| D | endpoint.h | 30 grpc_endpoint* grpc_event_engine_endpoint_create(
34 bool grpc_is_event_engine_endpoint(grpc_endpoint* ep);
39 grpc_endpoint* ep);
48 grpc_endpoint* ep);
54 grpc_endpoint* ep, int* fd, grpc_closure* on_release_fd);
|
| D | endpoint.cc | 66 grpc_endpoint base;
99 grpc_endpoint* GetGrpcEndpoint() { return &eeep_->base; } in GetGrpcEndpoint()
301 void EndpointRead(grpc_endpoint* ep, grpc_slice_buffer* slices, in EndpointRead()
323 void EndpointWrite(grpc_endpoint* ep, grpc_slice_buffer* slices, in EndpointWrite()
342 void EndpointAddToPollset(grpc_endpoint* /* ep */, in EndpointAddToPollset() argument
344 void EndpointAddToPollsetSet(grpc_endpoint* /* ep */, in EndpointAddToPollsetSet() argument
346 void EndpointDeleteFromPollsetSet(grpc_endpoint* /* ep */, in EndpointDeleteFromPollsetSet() argument
352 void EndpointShutdown(grpc_endpoint* ep, grpc_error_handle why) { in EndpointShutdown()
366 void EndpointDestroy(grpc_endpoint* ep) { in EndpointDestroy()
374 absl::string_view EndpointGetPeerAddress(grpc_endpoint* ep) { in EndpointGetPeerAddress()
[all …]
|
| /external/rust/android-crates-io/crates/grpcio-sys/grpc/src/core/lib/iomgr/event_engine_shims/ |
| D | endpoint.cc | 61 grpc_endpoint base;
96 grpc_endpoint* GetGrpcEndpoint() { return &eeep_->base; } in GetGrpcEndpoint()
296 void EndpointRead(grpc_endpoint* ep, grpc_slice_buffer* slices, in EndpointRead()
318 void EndpointWrite(grpc_endpoint* ep, grpc_slice_buffer* slices, in EndpointWrite()
337 void EndpointAddToPollset(grpc_endpoint* /* ep */, in EndpointAddToPollset() argument
339 void EndpointAddToPollsetSet(grpc_endpoint* /* ep */, in EndpointAddToPollsetSet() argument
341 void EndpointDeleteFromPollsetSet(grpc_endpoint* /* ep */, in EndpointDeleteFromPollsetSet() argument
347 void EndpointShutdown(grpc_endpoint* ep, grpc_error_handle why) { in EndpointShutdown()
361 void EndpointDestroy(grpc_endpoint* ep) { in EndpointDestroy()
369 absl::string_view EndpointGetPeerAddress(grpc_endpoint* ep) { in EndpointGetPeerAddress()
[all …]
|
| D | endpoint.h | 28 grpc_endpoint* grpc_event_engine_endpoint_create(
32 bool grpc_is_event_engine_endpoint(grpc_endpoint* ep);
38 grpc_endpoint* ep, int* fd, grpc_closure* on_release_fd);
|
| /external/grpc-grpc/test/cpp/end2end/ |
| D | connection_attempt_injector.h | 123 QueuedAttempt(grpc_closure* closure, grpc_endpoint** ep,
138 grpc_endpoint** endpoint_;
151 grpc_endpoint** ep, grpc_pollset_set* interested_parties,
164 grpc_closure* closure, grpc_endpoint** ep,
170 grpc_closure* closure, grpc_endpoint** ep,
178 grpc_closure* closure, grpc_endpoint** ep,
|
| /external/grpc-grpc/test/cpp/microbenchmarks/ |
| D | bm_chttp2_transport.cc | 48 class PhonyEndpoint : public grpc_endpoint {
62 grpc_endpoint::vtable = &my_vtable; in PhonyEndpoint()
95 static void read(grpc_endpoint* ep, grpc_slice_buffer* slices, in read()
101 static void write(grpc_endpoint* /*ep*/, grpc_slice_buffer* /*slices*/, in write() argument
106 static void add_to_pollset(grpc_endpoint* /*ep*/, grpc_pollset* /*pollset*/) { in add_to_pollset() argument
109 static void add_to_pollset_set(grpc_endpoint* /*ep*/, in add_to_pollset_set() argument
112 static void delete_from_pollset_set(grpc_endpoint* /*ep*/, in delete_from_pollset_set() argument
115 static void shutdown(grpc_endpoint* ep, grpc_error_handle why) { in shutdown()
120 static void destroy(grpc_endpoint* ep) { in destroy()
124 static absl::string_view get_peer(grpc_endpoint* /*ep*/) { return "test"; } in get_peer() argument
[all …]
|
| /external/grpc-grpc/src/core/lib/security/transport/ |
| D | secure_endpoint.cc | 71 grpc_endpoint* transport, grpc_slice* leftover_slices, in secure_endpoint()
119 grpc_endpoint base;
120 grpc_endpoint* wrapped_ep;
351 static void endpoint_read(grpc_endpoint* secure_ep, grpc_slice_buffer* slices, in endpoint_read()
382 static void endpoint_write(grpc_endpoint* secure_ep, grpc_slice_buffer* slices, in endpoint_write()
495 static void endpoint_shutdown(grpc_endpoint* secure_ep, grpc_error_handle why) { in endpoint_shutdown()
500 static void endpoint_destroy(grpc_endpoint* secure_ep) { in endpoint_destroy()
506 static void endpoint_add_to_pollset(grpc_endpoint* secure_ep, in endpoint_add_to_pollset()
512 static void endpoint_add_to_pollset_set(grpc_endpoint* secure_ep, in endpoint_add_to_pollset_set()
518 static void endpoint_delete_from_pollset_set(grpc_endpoint* secure_ep, in endpoint_delete_from_pollset_set()
[all …]
|
| /external/rust/android-crates-io/crates/grpcio-sys/grpc/src/core/lib/security/transport/ |
| D | secure_endpoint.cc | 72 grpc_endpoint* transport, grpc_slice* leftover_slices, in secure_endpoint()
122 grpc_endpoint base;
123 grpc_endpoint* wrapped_ep;
354 static void endpoint_read(grpc_endpoint* secure_ep, grpc_slice_buffer* slices, in endpoint_read()
385 static void endpoint_write(grpc_endpoint* secure_ep, grpc_slice_buffer* slices, in endpoint_write()
498 static void endpoint_shutdown(grpc_endpoint* secure_ep, grpc_error_handle why) { in endpoint_shutdown()
503 static void endpoint_destroy(grpc_endpoint* secure_ep) { in endpoint_destroy()
509 static void endpoint_add_to_pollset(grpc_endpoint* secure_ep, in endpoint_add_to_pollset()
515 static void endpoint_add_to_pollset_set(grpc_endpoint* secure_ep, in endpoint_add_to_pollset_set()
521 static void endpoint_delete_from_pollset_set(grpc_endpoint* secure_ep, in endpoint_delete_from_pollset_set()
[all …]
|
| D | secure_endpoint.h | 37 grpc_endpoint* grpc_secure_endpoint_create(
40 grpc_endpoint* to_wrap, grpc_slice* leftover_slices,
|