Searched refs:write_closure (Results 1 – 11 of 11) sorted by relevance
| /external/grpc-grpc/src/core/ext/filters/client_channel/resolver/dns/c_ares/ |
| D | grpc_ares_ev_driver_posix.cc | 65 void RegisterForOnWriteableLocked(grpc_closure* write_closure) override { in RegisterForOnWriteableLocked() argument
66 grpc_fd_notify_on_write(fd_, write_closure); in RegisterForOnWriteableLocked()
|
| D | grpc_ares_ev_driver.cc | 45 grpc_closure write_closure; member
262 GRPC_CLOSURE_INIT(&fdn->write_closure, on_writable_locked, fdn, in grpc_ares_notify_on_event_locked()
285 &fdn->write_closure); in grpc_ares_notify_on_event_locked()
|
| D | grpc_ares_ev_driver.h | 69 virtual void RegisterForOnWriteableLocked(grpc_closure* write_closure)
|
| D | grpc_ares_ev_driver_windows.cc | 137 void RegisterForOnWriteableLocked(grpc_closure* write_closure) override { in RegisterForOnWriteableLocked() argument
142 write_closure_ = write_closure; in RegisterForOnWriteableLocked()
|
| /external/grpc-grpc/src/core/lib/iomgr/ |
| D | tcp_client_posix.cc | 58 grpc_closure write_closure; member
201 grpc_fd_notify_on_write(fd, &ac->write_closure); in on_writable()
325 GRPC_CLOSURE_INIT(&ac->write_closure, on_writable, ac, in grpc_tcp_client_create_from_prepared_fd()
337 grpc_fd_notify_on_write(ac->fd, &ac->write_closure); in grpc_tcp_client_create_from_prepared_fd()
|
| D | ev_epoll1_linux.cc | 145 grpc_core::ManualConstructor<grpc_core::LockfreeEvent> write_closure; member
331 new_fd->write_closure.Init(); in fd_create()
336 new_fd->write_closure->InitEvent(); in fd_create()
379 fd->write_closure->SetShutdown(GRPC_ERROR_REF(why)); in fd_shutdown_internal()
413 fd->write_closure->DestroyEvent(); in fd_orphan()
431 fd->write_closure->NotifyOn(closure); in fd_notify_on_write()
440 static void fd_become_writable(grpc_fd* fd) { fd->write_closure->SetReady(); } in fd_become_writable()
|
| D | ev_epollsig_linux.cc | 134 grpc_core::ManualConstructor<grpc_core::LockfreeEvent> write_closure; member
771 fd->write_closure->DestroyEvent();
824 new_fd->write_closure.Init();
841 new_fd->write_closure->InitEvent();
933 fd->write_closure->SetShutdown(GRPC_ERROR_REF(why));
944 fd->write_closure->NotifyOn(closure);
953 static void fd_become_writable(grpc_fd* fd) { fd->write_closure->SetReady(); }
|
| D | ev_epollex_linux.cc | 218 grpc_core::ManualConstructor<grpc_core::LockfreeEvent> write_closure; member
369 fd->write_closure->DestroyEvent();
429 new_fd->write_closure.Init();
440 new_fd->write_closure->InitEvent();
525 fd->write_closure->SetShutdown(GRPC_ERROR_REF(why));
536 fd->write_closure->NotifyOn(closure);
870 static void fd_become_writable(grpc_fd* fd) { fd->write_closure->SetReady(); }
|
| D | ev_poll_posix.cc | 119 grpc_closure* write_closure; member
415 r->write_closure = CLOSURE_NOT_READY;
588 set_ready_locked(fd, &fd->write_closure);
610 notify_on_locked(fd, &fd->write_closure, closure);
629 set_ready_locked(fd, &fd->write_closure);
670 cur = fd->write_closure;
728 if (set_ready_locked(fd, &fd->write_closure)) {
|
| /external/libchrome/base/message_loop/ |
| D | message_loop_io_posix_unittest.cc | 82 CallClosureHandler(OnceClosure read_closure, OnceClosure write_closure) in CallClosureHandler() argument
84 write_closure_(std::move(write_closure)) {} in CallClosureHandler()
96 void SetWriteClosure(OnceClosure write_closure) { in SetWriteClosure() argument
98 write_closure_ = std::move(write_closure); in SetWriteClosure()
|
| /external/grpc-grpc/test/core/iomgr/ |
| D | fd_posix_test.cc | 279 grpc_closure write_closure; member
320 GRPC_CLOSURE_INIT(&cl->write_closure, client_session_write, cl, in client_session_write()
322 grpc_fd_notify_on_write(cl->em_fd, &cl->write_closure); in client_session_write()
|