| /third_party/grpc/test/core/test_util/ |
| D | mock_endpoint.cc | 85 absl::AnyInvocable<void(absl::Status)> on_read, SliceBuffer* buffer) { in Read()
113 bool MockEndpoint::Read(absl::AnyInvocable<void(absl::Status)> on_read, in Read()
|
| D | passthrough_endpoint.cc | 65 bool PassthroughEndpoint::Read(absl::AnyInvocable<void(absl::Status)> on_read, in Read()
|
| /third_party/libuv/docs/code/uvcat/ |
| D | main.c | 25 void on_read(uv_fs_t *req) { in on_read() function
|
| /third_party/backends/testsuite/backend/genesys/ |
| D | tests_image_pipeline.cpp | 38 auto on_read = [&](std::size_t x, std::uint8_t* data) in test_image_buffer_exact_reads() local
65 auto on_read = [&](std::size_t x, std::uint8_t* data) in test_image_buffer_smaller_reads() local
93 auto on_read = [&](std::size_t x, std::uint8_t* data) in test_image_buffer_larger_reads() local
118 auto on_read = [&](std::size_t x, std::uint8_t* data) in test_image_buffer_uncapped_remaining_bytes() local
144 auto on_read = [&](std::size_t x, std::uint8_t* data) in test_image_buffer_capped_remaining_bytes() local
|
| /third_party/grpc/test/core/transport/chaotic_good_legacy/ |
| D | mock_promise_endpoint.cc | 41 grpc_event_engine::experimental::SliceBuffer* buffer) mutable { in ExpectRead()
|
| D | client_transport_error_test.cc | 224 [](absl::AnyInvocable<void(absl::Status)> on_read) mutable { in TEST_F()
338 [](absl::AnyInvocable<void(absl::Status)> on_read) mutable { in TEST_F()
|
| /third_party/libuv/docs/code/dns/ |
| D | main.c | 13 void on_read(uv_stream_t *client, ssize_t nread, const uv_buf_t *buf) { in on_read() function
|
| /third_party/nghttp2/src/ |
| D | shrpx_quic_listener.cc | 51 void QUICListener::on_read() { in on_read() function in shrpx::QUICListener
|
| D | shrpx_null_downstream_connection.cc | 73 int NullDownstreamConnection::on_read() { return 0; } in on_read() function in shrpx::NullDownstreamConnection
|
| D | shrpx_health_monitor_downstream_connection.cc | 96 int HealthMonitorDownstreamConnection::on_read() { return 0; } in on_read() function in shrpx::HealthMonitorDownstreamConnection
|
| D | h2load_http1_session.cc | 216 int Http1Session::on_read(const uint8_t *data, size_t len) { in on_read() function in h2load::Http1Session
|
| /third_party/grpc/test/core/transport/ |
| D | promise_endpoint_test.cc | 223 grpc_event_engine::experimental::SliceBuffer* buffer) { in TEST_F()
250 [&read_callback](absl::AnyInvocable<void(absl::Status)> on_read) { in TEST_F()
360 grpc_event_engine::experimental::SliceBuffer* buffer) { in TEST_F()
387 [&read_callback](absl::AnyInvocable<void(absl::Status)> on_read) { in TEST_F()
478 grpc_event_engine::experimental::SliceBuffer* buffer) { in TEST_F()
505 [&read_callback](absl::AnyInvocable<void(absl::Status)> on_read) { in TEST_F()
648 grpc_event_engine::experimental::SliceBuffer* buffer) { in TEST_F()
|
| /third_party/grpc/src/core/lib/event_engine/cf_engine/ |
| D | cfstream_endpoint.cc | 260 absl::AnyInvocable<void(absl::Status)> on_read, SliceBuffer* buffer, in Read()
280 absl::AnyInvocable<void(absl::Status)> on_read, SliceBuffer* buffer) { in DoRead()
|
| D | cfstream_endpoint.h | 112 bool Read(absl::AnyInvocable<void(absl::Status)> on_read, SliceBuffer* buffer, in Read()
|
| /third_party/libuv/docs/code/udp-dhcp/ |
| D | main.c | 17 void on_read(uv_udp_t *req, ssize_t nread, const uv_buf_t *buf, const struct sockaddr *addr, unsign… in on_read() function
|
| /third_party/grpc/test/core/transport/util/ |
| D | mock_promise_endpoint.cc | 41 grpc_event_engine::experimental::SliceBuffer* buffer) mutable { in ExpectRead()
|
| /third_party/grpc/test/core/event_engine/windows/ |
| D | win_socket_test.cc | 66 AnyInvocableClosure on_read([&read_called]() { read_called.Notify(); }); in TEST_F() local
|
| /third_party/libuv/test/ |
| D | benchmark-spawn.c | 91 static void on_read(uv_stream_t* pipe, ssize_t nread, const uv_buf_t* buf) { in on_read() function
|
| D | test-stdio-over-pipes.c | 97 static void on_read(uv_stream_t* pipe, ssize_t nread, const uv_buf_t* rdbuf) { in on_read() function
|
| /third_party/grpc/test/core/transport/chaotic_good/ |
| D | client_transport_error_test.cc | 247 [](absl::AnyInvocable<void(absl::Status)> on_read) mutable { in TEST_F()
369 [](absl::AnyInvocable<void(absl::Status)> on_read) mutable { in TEST_F()
|
| /third_party/grpc/test/core/event_engine/ |
| D | event_engine_test_utils.h | 185 bool Read(absl::AnyInvocable<void(absl::Status)> on_read, SliceBuffer* buffer, in Read()
|
| /third_party/grpc/src/core/lib/iomgr/ |
| D | tcp_windows.cc | 106 grpc_closure on_read; member
171 static void on_read(void* tcpp, grpc_error_handle error) { in on_read() function
|
| /third_party/grpc/src/core/lib/event_engine/windows/ |
| D | win_socket.cc | 110 void WinSocket::NotifyOnRead(EventEngine::Closure* on_read) { in NotifyOnRead()
|
| /third_party/grpc/src/core/handshaker/security/ |
| D | secure_endpoint.cc | 129 grpc_closure on_read; member
245 static void on_read(void* user_data, grpc_error_handle error) { in on_read() function
|
| /third_party/grpc/test/core/event_engine/fuzzing_event_engine/ |
| D | fuzzing_event_engine.h | 221 absl::AnyInvocable<void(absl::Status)> on_read; member
|