Home
last modified time | relevance | path

Searched refs:read_closure (Results 1 – 11 of 11) sorted by relevance

/external/grpc-grpc/src/core/ext/filters/client_channel/resolver/dns/c_ares/
Dgrpc_ares_ev_driver_posix.cc61 void RegisterForOnReadableLocked(grpc_closure* read_closure) override { in RegisterForOnReadableLocked() argument
62 grpc_fd_notify_on_read(fd_, read_closure); in RegisterForOnReadableLocked()
Dgrpc_ares_ev_driver.cc42 grpc_closure read_closure; member
260 GRPC_CLOSURE_INIT(&fdn->read_closure, on_readable_locked, fdn, in grpc_ares_notify_on_event_locked()
274 fdn->grpc_polled_fd->RegisterForOnReadableLocked(&fdn->read_closure); in grpc_ares_notify_on_event_locked()
Dgrpc_ares_ev_driver.h66 virtual void RegisterForOnReadableLocked(grpc_closure* read_closure)
Dgrpc_ares_ev_driver_windows.cc107 void RegisterForOnReadableLocked(grpc_closure* read_closure) override { in RegisterForOnReadableLocked() argument
109 read_closure_ = read_closure; in RegisterForOnReadableLocked()
/external/libchrome/base/message_loop/
Dmessage_loop_io_posix_unittest.cc82 CallClosureHandler(OnceClosure read_closure, OnceClosure write_closure) in CallClosureHandler() argument
83 : read_closure_(std::move(read_closure)), in CallClosureHandler()
91 void SetReadClosure(OnceClosure read_closure) { in SetReadClosure() argument
93 read_closure_ = std::move(read_closure); in SetReadClosure()
/external/grpc-grpc/src/core/lib/iomgr/
Dev_epoll1_linux.cc144 grpc_core::ManualConstructor<grpc_core::LockfreeEvent> read_closure; member
330 new_fd->read_closure.Init(); in fd_create()
335 new_fd->read_closure->InitEvent(); in fd_create()
375 if (fd->read_closure->SetShutdown(GRPC_ERROR_REF(why))) { in fd_shutdown_internal()
395 if (!fd->read_closure->IsShutdown()) { in fd_orphan()
412 fd->read_closure->DestroyEvent(); in fd_orphan()
423 return fd->read_closure->IsShutdown(); in fd_is_shutdown()
427 fd->read_closure->NotifyOn(closure); in fd_notify_on_read()
438 static void fd_become_readable(grpc_fd* fd) { fd->read_closure->SetReady(); } in fd_become_readable()
Dtcp_server_posix.cc205 grpc_fd_notify_on_read(sp->emfd, &sp->read_closure); in on_read()
495 GRPC_CLOSURE_INIT(&sp->read_closure, on_read, sp, in tcp_server_start()
497 grpc_fd_notify_on_read(sp->emfd, &sp->read_closure); in tcp_server_start()
505 GRPC_CLOSURE_INIT(&sp->read_closure, on_read, sp, in tcp_server_start()
507 grpc_fd_notify_on_read(sp->emfd, &sp->read_closure); in tcp_server_start()
Dev_epollsig_linux.cc133 grpc_core::ManualConstructor<grpc_core::LockfreeEvent> read_closure; member
770 fd->read_closure->DestroyEvent();
823 new_fd->read_closure.Init();
840 new_fd->read_closure->InitEvent();
926 return fd->read_closure->IsShutdown();
931 if (fd->read_closure->SetShutdown(GRPC_ERROR_REF(why))) {
940 fd->read_closure->NotifyOn(closure);
951 static void fd_become_readable(grpc_fd* fd) { fd->read_closure->SetReady(); }
Dtcp_server_utils_posix.h38 grpc_closure read_closure; member
Dev_epollex_linux.cc217 grpc_core::ManualConstructor<grpc_core::LockfreeEvent> read_closure; member
368 fd->read_closure->DestroyEvent();
428 new_fd->read_closure.Init();
439 new_fd->read_closure->InitEvent();
513 return fd->read_closure->IsShutdown();
518 if (fd->read_closure->SetShutdown(GRPC_ERROR_REF(why))) {
532 fd->read_closure->NotifyOn(closure);
868 static void fd_become_readable(grpc_fd* fd) { fd->read_closure->SetReady(); }
Dev_poll_posix.cc118 grpc_closure* read_closure; member
414 r->read_closure = CLOSURE_NOT_READY;
587 set_ready_locked(fd, &fd->read_closure);
604 notify_on_locked(fd, &fd->read_closure, closure);
623 set_ready_locked(fd, &fd->read_closure);
662 cur = fd->read_closure;
723 if (set_ready_locked(fd, &fd->read_closure)) {