Searched refs:error_closure (Results 1 – 7 of 7) sorted by relevance
| /external/grpc-grpc/src/core/lib/iomgr/ |
| D | ev_epoll1_linux.cc | 146 grpc_core::ManualConstructor<grpc_core::LockfreeEvent> error_closure; member
332 new_fd->error_closure.Init(); in fd_create()
337 new_fd->error_closure->InitEvent(); in fd_create()
380 fd->error_closure->SetShutdown(GRPC_ERROR_REF(why)); in fd_shutdown_internal()
414 fd->error_closure->DestroyEvent(); in fd_orphan()
435 fd->error_closure->NotifyOn(closure); in fd_notify_on_error()
442 static void fd_has_errors(grpc_fd* fd) { fd->error_closure->SetReady(); } in fd_has_errors()
|
| D | ev_epollsig_linux.cc | 135 grpc_core::ManualConstructor<grpc_core::LockfreeEvent> error_closure; member
772 fd->error_closure->DestroyEvent();
825 new_fd->error_closure.Init();
842 new_fd->error_closure->InitEvent();
934 fd->error_closure->SetShutdown(GRPC_ERROR_REF(why));
948 fd->error_closure->NotifyOn(closure);
955 static void fd_has_errors(grpc_fd* fd) { fd->error_closure->SetReady(); }
|
| D | tcp_posix.cc | 103 grpc_closure error_closure; member
757 GRPC_CLOSURE_INIT(&tcp->error_closure, tcp_handle_error, tcp, in tcp_handle_error()
759 grpc_fd_notify_on_error(tcp->em_fd, &tcp->error_closure); in tcp_handle_error()
1083 GRPC_CLOSURE_INIT(&tcp->error_closure, tcp_handle_error, tcp, in grpc_tcp_create()
1085 grpc_fd_notify_on_error(tcp->em_fd, &tcp->error_closure); in grpc_tcp_create()
|
| D | ev_epollex_linux.cc | 219 grpc_core::ManualConstructor<grpc_core::LockfreeEvent> error_closure; member
370 fd->error_closure->DestroyEvent();
430 new_fd->error_closure.Init();
441 new_fd->error_closure->InitEvent();
526 fd->error_closure->SetShutdown(GRPC_ERROR_REF(why));
540 fd->error_closure->NotifyOn(closure);
872 static void fd_has_errors(grpc_fd* fd) { fd->error_closure->SetReady(); }
|
| /external/rust/crates/grpcio-sys/grpc/src/core/lib/iomgr/ |
| D | ev_epoll1_linux.cc | 152 grpc_core::ManualConstructor<grpc_core::LockfreeEvent> error_closure; member
346 new_fd->error_closure.Init(); in fd_create()
351 new_fd->error_closure->InitEvent(); in fd_create()
399 fd->error_closure->SetShutdown(GRPC_ERROR_REF(why)); in fd_shutdown_internal()
433 fd->error_closure->DestroyEvent(); in fd_orphan()
454 fd->error_closure->NotifyOn(closure); in fd_notify_on_error()
461 static void fd_has_errors(grpc_fd* fd) { fd->error_closure->SetReady(); } in fd_has_errors()
|
| D | ev_epollex_linux.cc | 170 error_closure.InitEvent(); in grpc_fd()
204 error_closure.DestroyEvent(); in destroy()
245 grpc_core::LockfreeEvent error_closure; member
521 fd->error_closure.SetShutdown(GRPC_ERROR_REF(why));
535 fd->error_closure.NotifyOn(closure);
824 static void fd_has_errors(grpc_fd* fd) { fd->error_closure.SetReady(); }
|
| D | tcp_posix.cc | 390 grpc_closure error_closure; member
1239 grpc_fd_notify_on_error(tcp->em_fd, &tcp->error_closure); in tcp_handle_error()
1847 GRPC_CLOSURE_INIT(&tcp->error_closure, tcp_handle_error, tcp, in grpc_tcp_create()
1849 grpc_fd_notify_on_error(tcp->em_fd, &tcp->error_closure); in grpc_tcp_create()
|