Home
last modified time | relevance | path

Searched refs:on_writable (Results 1 – 25 of 27) sorted by relevance

12

/external/rust/android-crates-io/crates/grpcio-sys/grpc/src/core/lib/event_engine/cf_engine/
Dcfstream_endpoint.cc300 absl::AnyInvocable<void(absl::Status)> on_writable, SliceBuffer* data, in Write() argument
306 [that = Ref(), on_writable = std::move(on_writable), in Write()
309 that->DoWrite(std::move(on_writable), data); in Write()
311 on_writable(status); in Write()
320 absl::AnyInvocable<void(absl::Status)> on_writable, SliceBuffer* data) { in DoWrite() argument
336 [that = Ref(), on_writable = std::move(on_writable), in DoWrite()
339 that->DoWrite(std::move(on_writable), data); in DoWrite()
341 on_writable(status); in DoWrite()
348 on_writable(absl::OkStatus()); in DoWrite()
Dcfstream_endpoint.h49 bool Write(absl::AnyInvocable<void(absl::Status)> on_writable,
65 void DoWrite(absl::AnyInvocable<void(absl::Status)> on_writable,
116 bool Write(absl::AnyInvocable<void(absl::Status)> on_writable, in Write() argument
118 return impl_->Write(std::move(on_writable), data, args); in Write()
/external/grpc-grpc/src/core/lib/event_engine/cf_engine/
Dcfstream_endpoint.cc306 absl::AnyInvocable<void(absl::Status)> on_writable, SliceBuffer* data, in Write() argument
312 [that = Ref(), on_writable = std::move(on_writable), in Write()
315 that->DoWrite(std::move(on_writable), data); in Write()
317 on_writable(status); in Write()
326 absl::AnyInvocable<void(absl::Status)> on_writable, SliceBuffer* data) { in DoWrite() argument
342 [that = Ref(), on_writable = std::move(on_writable), in DoWrite()
345 that->DoWrite(std::move(on_writable), data); in DoWrite()
347 on_writable(status); in DoWrite()
354 on_writable(absl::OkStatus()); in DoWrite()
Dcfstream_endpoint.h51 bool Write(absl::AnyInvocable<void(absl::Status)> on_writable,
67 void DoWrite(absl::AnyInvocable<void(absl::Status)> on_writable,
118 bool Write(absl::AnyInvocable<void(absl::Status)> on_writable, in Write() argument
120 return impl_->Write(std::move(on_writable), data, args); in Write()
/external/grpc-grpc/test/core/transport/chaotic_good/
Dmock_promise_endpoint.cc69 absl::AnyInvocable<void(absl::Status)> on_writable, in ExpectWrite()
77 [on_writable = std::move(on_writable)]() mutable { in ExpectWrite()
78 on_writable(absl::OkStatus()); in ExpectWrite()
Dmock_promise_endpoint.h42 (absl::AnyInvocable<void(absl::Status)> on_writable,
Dclient_transport_error_test.cc84 (absl::AnyInvocable<void(absl::Status)> on_writable,
/external/rust/android-crates-io/crates/grpcio-sys/grpc/src/core/lib/event_engine/windows/
Dwindows_endpoint.cc154 bool WindowsEndpoint::Write(absl::AnyInvocable<void(absl::Status)> on_writable, in Write() argument
158 thread_pool_->Run([on_writable = std::move(on_writable)]() mutable { in Write()
159 on_writable(absl::UnavailableError("Socket is shutting down.")); in Write()
187 [cb = std::move(on_writable)]() mutable { cb(absl::OkStatus()); }); in Write()
207 thread_pool_->Run([cb = std::move(on_writable), wsa_error]() mutable { in Write()
221 thread_pool_->Run([cb = std::move(on_writable), wsa_error]() mutable { in Write()
229 io_state_->handle_write_event.Prime(io_state_, data, std::move(on_writable)); in Write()
Dwindows_endpoint.h37 bool Write(absl::AnyInvocable<void(absl::Status)> on_writable,
/external/grpc-grpc/src/core/lib/event_engine/windows/
Dwindows_endpoint.cc150 bool WindowsEndpoint::Write(absl::AnyInvocable<void(absl::Status)> on_writable, in Write() argument
155 [on_writable = std::move(on_writable)]() mutable { in Write()
156 on_writable(absl::UnavailableError("Socket is shutting down.")); in Write()
184 [cb = std::move(on_writable)]() mutable { cb(absl::OkStatus()); }); in Write()
205 [cb = std::move(on_writable), wsa_error]() mutable { in Write()
212 io_state_->handle_write_event.Prime(io_state_, data, std::move(on_writable)); in Write()
Dwindows_endpoint.h37 bool Write(absl::AnyInvocable<void(absl::Status)> on_writable,
/external/grpc-grpc/test/core/event_engine/fuzzing_event_engine/
Dfuzzing_event_engine.cc344 absl::AnyInvocable<void(absl::Status)> on_writable, SliceBuffer* data, in Write() argument
353 ScheduleDelayedWrite(middle_, my_index(), std::move(on_writable), data); in Write()
359 absl::AnyInvocable<void(absl::Status)> on_writable, SliceBuffer* data) { in ScheduleDelayedWrite() argument
362 on_writable = std::move(on_writable)]() mutable { in ScheduleDelayedWrite()
368 [on_writable = std::move(on_writable)]() mutable { in ScheduleDelayedWrite()
369 on_writable(absl::InternalError("Endpoint closed")); in ScheduleDelayedWrite()
376 on_writable(absl::OkStatus()); in ScheduleDelayedWrite()
379 ScheduleDelayedWrite(std::move(middle), index, std::move(on_writable), in ScheduleDelayedWrite()
Dfuzzing_event_engine.h224 bool Write(absl::AnyInvocable<void(absl::Status)> on_writable,
245 absl::AnyInvocable<void(absl::Status)> on_writable, SliceBuffer* data)
/external/grpc-grpc/src/core/lib/event_engine/posix_engine/
Dposix_endpoint.cc1157 absl::AnyInvocable<void(absl::Status)> on_writable, SliceBuffer* data, in Write() argument
1174 [on_writable = std::move(on_writable), status, this]() mutable { in Write()
1177 on_writable(status); in Write()
1203 write_cb_ = std::move(on_writable); in Write()
1212 [on_writable = std::move(on_writable), status, this]() mutable { in Write()
1215 on_writable(status); in Write()
Dposix_endpoint.h481 absl::AnyInvocable<void(absl::Status)> on_writable,
624 absl::AnyInvocable<void(absl::Status)> on_writable, in Write() argument
628 return impl_->Write(std::move(on_writable), data, args); in Write()
/external/rust/android-crates-io/crates/grpcio-sys/grpc/src/core/lib/event_engine/posix_engine/
Dposix_endpoint.cc1131 absl::AnyInvocable<void(absl::Status)> on_writable, SliceBuffer* data, in Write() argument
1144 engine_->Run([on_writable = std::move(on_writable), status]() mutable { in Write()
1145 on_writable(status); in Write()
1170 write_cb_ = std::move(on_writable); in Write()
1178 engine_->Run([on_writable = std::move(on_writable), status]() mutable { in Write()
1179 on_writable(status); in Write()
Dposix_endpoint.h481 absl::AnyInvocable<void(absl::Status)> on_writable,
622 absl::AnyInvocable<void(absl::Status)> on_writable, in Write() argument
626 return impl_->Write(std::move(on_writable), data, args); in Write()
/external/rust/android-crates-io/crates/grpcio-sys/grpc/src/core/lib/iomgr/
Dtcp_client_posix.cc170 static void on_writable(void* acp, grpc_error_handle error) { in on_writable() function
382 GRPC_CLOSURE_INIT(&ac->write_closure, on_writable, ac, in grpc_tcp_client_create_from_prepared_fd()
/external/grpc-grpc/src/core/lib/iomgr/
Dtcp_client_posix.cc173 static void on_writable(void* acp, grpc_error_handle error) { in on_writable() function
386 GRPC_CLOSURE_INIT(&ac->write_closure, on_writable, ac, in grpc_tcp_client_create_from_prepared_fd()
/external/grpc-grpc/test/core/event_engine/test_suite/posix/
Doracle_event_engine_posix.cc247 absl::AnyInvocable<void(absl::Status)> on_writable, SliceBuffer* data, in Write() argument
251 write_ops_channel_ = WriteOperation(data, std::move(on_writable)); in Write()
Doracle_event_engine_posix.h49 bool Write(absl::AnyInvocable<void(absl::Status)> on_writable,
/external/grpc-grpc/include/grpc/event_engine/
Devent_engine.h252 virtual bool Write(absl::AnyInvocable<void(absl::Status)> on_writable,
/external/rust/android-crates-io/crates/grpcio-sys/grpc/spm-core-include/grpc/event_engine/
Devent_engine.h243 virtual bool Write(absl::AnyInvocable<void(absl::Status)> on_writable,
/external/rust/android-crates-io/crates/grpcio-sys/grpc/include/grpc/event_engine/
Devent_engine.h243 virtual bool Write(absl::AnyInvocable<void(absl::Status)> on_writable,
/external/rust/android-crates-io/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/resolver/dns/c_ares/
Dgrpc_ares_wrapper.cc385 static void on_writable(void* arg, grpc_error_handle error) { in on_writable() function
457 GRPC_CLOSURE_INIT(&fdn->write_closure, on_writable, fdn, in grpc_ares_notify_on_event_locked()

12