| /dports/devel/grpc134/grpc-1.34.1/src/core/ext/filters/client_channel/resolver/dns/c_ares/ |
| H A D | grpc_ares_ev_driver_libuv.cc | 57 GPR_ASSERT(read_closure_ == nullptr); in RegisterForOnReadableLocked()
59 read_closure_ = read_closure; in RegisterForOnReadableLocked()
81 if (read_closure_ != nullptr) { in ShutdownInternalLocked()
82 grpc_core::ExecCtx::Run(DEBUG_LOCATION, read_closure_, in ShutdownInternalLocked()
108 grpc_closure* read_closure_ = nullptr; member in grpc_core::GrpcPolledFdLibuv
138 GPR_ASSERT(polled_fd->read_closure_ != nullptr); in ares_uv_poll_cb_locked()
139 grpc_core::ExecCtx::Run(DEBUG_LOCATION, polled_fd->read_closure_, error); in ares_uv_poll_cb_locked()
140 polled_fd->read_closure_ = nullptr; in ares_uv_poll_cb_locked()
|
| H A D | grpc_ares_ev_driver_windows.cc | 129 GPR_ASSERT(read_closure_ == nullptr); in ~GrpcPolledFdWindows()
135 grpc_core::ExecCtx::Run(DEBUG_LOCATION, read_closure_, error); in ScheduleAndNullReadClosure()
136 read_closure_ = nullptr; in ScheduleAndNullReadClosure()
145 GPR_ASSERT(read_closure_ == nullptr); in RegisterForOnReadableLocked()
146 read_closure_ = read_closure; in RegisterForOnReadableLocked()
668 grpc_closure* read_closure_ = nullptr; member in grpc_core::GrpcPolledFdWindows
|
| /dports/devel/grpc130/grpc-1.30.2/src/core/ext/filters/client_channel/resolver/dns/c_ares/ |
| H A D | grpc_ares_ev_driver_libuv.cc | 56 GPR_ASSERT(read_closure_ == nullptr); in RegisterForOnReadableLocked()
58 read_closure_ = read_closure; in RegisterForOnReadableLocked()
80 if (read_closure_ != nullptr) { in ShutdownInternalLocked()
81 grpc_core::ExecCtx::Run(DEBUG_LOCATION, read_closure_, in ShutdownInternalLocked()
106 grpc_closure* read_closure_ = nullptr; member in grpc_core::GrpcPolledFdLibuv
136 GPR_ASSERT(polled_fd->read_closure_ != nullptr); in ares_uv_poll_cb_locked()
137 grpc_core::ExecCtx::Run(DEBUG_LOCATION, polled_fd->read_closure_, error); in ares_uv_poll_cb_locked()
138 polled_fd->read_closure_ = nullptr; in ares_uv_poll_cb_locked()
|
| H A D | grpc_ares_ev_driver_windows.cc | 127 GPR_ASSERT(read_closure_ == nullptr); in ~GrpcPolledFdWindows()
134 grpc_core::ExecCtx::Run(DEBUG_LOCATION, read_closure_, error); in ScheduleAndNullReadClosure()
135 read_closure_ = nullptr; in ScheduleAndNullReadClosure()
144 GPR_ASSERT(read_closure_ == nullptr); in RegisterForOnReadableLocked()
145 read_closure_ = read_closure; in RegisterForOnReadableLocked()
666 grpc_closure* read_closure_ = nullptr; member in grpc_core::GrpcPolledFdWindows
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/grpc/src/src/core/ext/filters/client_channel/resolver/dns/c_ares/ |
| H A D | grpc_ares_ev_driver_libuv.cc | 59 GPR_ASSERT(read_closure_ == nullptr); in RegisterForOnReadableLocked()
61 read_closure_ = read_closure; in RegisterForOnReadableLocked()
83 if (read_closure_ != nullptr) { in ShutdownInternalLocked()
84 GRPC_CLOSURE_SCHED(read_closure_, GRPC_ERROR_CANCELLED); in ShutdownInternalLocked()
107 grpc_closure* read_closure_ = nullptr; member in grpc_core::GrpcPolledFdLibuv
137 GPR_ASSERT(polled_fd->read_closure_ != nullptr); in ares_uv_poll_cb_locked()
138 GRPC_CLOSURE_SCHED(polled_fd->read_closure_, error); in ares_uv_poll_cb_locked()
139 polled_fd->read_closure_ = nullptr; in ares_uv_poll_cb_locked()
|
| H A D | grpc_ares_ev_driver_windows.cc | 133 GPR_ASSERT(read_closure_ == nullptr); in ~GrpcPolledFdWindows()
140 GRPC_CLOSURE_SCHED(read_closure_, error); in ScheduleAndNullReadClosure()
141 read_closure_ = nullptr; in ScheduleAndNullReadClosure()
150 GPR_ASSERT(read_closure_ == nullptr); in RegisterForOnReadableLocked()
151 read_closure_ = read_closure; in RegisterForOnReadableLocked()
680 grpc_closure* read_closure_ = nullptr; member in grpc_core::GrpcPolledFdWindows
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/base/message_loop/ |
| H A D | fd_watch_controller_posix_unittest.cc | 85 : read_closure_(std::move(read_closure)), in CallClosureHandler()
89 EXPECT_TRUE(read_closure_.is_null()); in ~CallClosureHandler()
94 EXPECT_TRUE(read_closure_.is_null()); in SetReadClosure()
95 read_closure_ = std::move(read_closure); in SetReadClosure()
116 ASSERT_FALSE(read_closure_.is_null()); in OnFileCanReadWithoutBlocking()
117 std::move(read_closure_).Run(); in OnFileCanReadWithoutBlocking()
126 OnceClosure read_closure_; member in base::__anon9a1277c40111::CallClosureHandler
|
| /dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/base/message_loop/ |
| H A D | fd_watch_controller_posix_unittest.cc | 85 : read_closure_(std::move(read_closure)), in CallClosureHandler()
89 EXPECT_TRUE(read_closure_.is_null()); in ~CallClosureHandler()
94 EXPECT_TRUE(read_closure_.is_null()); in SetReadClosure()
95 read_closure_ = std::move(read_closure); in SetReadClosure()
116 ASSERT_FALSE(read_closure_.is_null()); in OnFileCanReadWithoutBlocking()
117 std::move(read_closure_).Run(); in OnFileCanReadWithoutBlocking()
126 OnceClosure read_closure_; member in base::__anonece81b3f0111::CallClosureHandler
|
| /dports/devel/grpc/grpc-1.42.0/src/core/ext/filters/client_channel/resolver/dns/c_ares/ |
| H A D | grpc_ares_ev_driver_windows.cc | 130 GPR_ASSERT(read_closure_ == nullptr); in ~GrpcPolledFdWindows()
136 grpc_core::ExecCtx::Run(DEBUG_LOCATION, read_closure_, error); in ScheduleAndNullReadClosure()
137 read_closure_ = nullptr; in ScheduleAndNullReadClosure()
146 GPR_ASSERT(read_closure_ == nullptr); in RegisterForOnReadableLocked()
147 read_closure_ = read_closure; in RegisterForOnReadableLocked()
671 grpc_closure* read_closure_ = nullptr; member in grpc_core::GrpcPolledFdWindows
|
| /dports/devel/pecl-grpc/grpc-1.42.0/src/core/ext/filters/client_channel/resolver/dns/c_ares/ |
| H A D | grpc_ares_ev_driver_windows.cc | 130 GPR_ASSERT(read_closure_ == nullptr); in ~GrpcPolledFdWindows()
136 grpc_core::ExecCtx::Run(DEBUG_LOCATION, read_closure_, error); in ScheduleAndNullReadClosure()
137 read_closure_ = nullptr; in ScheduleAndNullReadClosure()
146 GPR_ASSERT(read_closure_ == nullptr); in RegisterForOnReadableLocked()
147 read_closure_ = read_closure; in RegisterForOnReadableLocked()
671 grpc_closure* read_closure_ = nullptr; member in grpc_core::GrpcPolledFdWindows
|
| /dports/devel/py-grpcio/grpcio-1.43.0/src/core/ext/filters/client_channel/resolver/dns/c_ares/ |
| H A D | grpc_ares_ev_driver_windows.cc | 130 GPR_ASSERT(read_closure_ == nullptr); in ~GrpcPolledFdWindows()
136 ExecCtx::Run(DEBUG_LOCATION, read_closure_, error); in ScheduleAndNullReadClosure()
137 read_closure_ = nullptr; in ScheduleAndNullReadClosure()
146 GPR_ASSERT(read_closure_ == nullptr); in RegisterForOnReadableLocked()
147 read_closure_ = read_closure; in RegisterForOnReadableLocked()
667 grpc_closure* read_closure_ = nullptr; member in grpc_core::GrpcPolledFdWindows
|
| /dports/devel/grpc130/grpc-1.30.2/src/core/lib/iomgr/ |
| H A D | udp_server.cc | 121 grpc_closure read_closure_; member in GrpcUdpListener
456 grpc_fd_notify_on_read(sp->emfd_, &sp->read_closure_); in do_read()
492 grpc_fd_notify_on_read(emfd_, &read_closure_); in OnRead()
727 GRPC_CLOSURE_INIT(&read_closure_, on_read, this, grpc_schedule_on_exec_ctx); in StartListening()
728 grpc_fd_notify_on_read(emfd_, &read_closure_); in StartListening()
|
| /dports/devel/grpc134/grpc-1.34.1/src/core/lib/iomgr/ |
| H A D | udp_server.cc | 125 grpc_closure read_closure_; member in GrpcUdpListener
457 grpc_fd_notify_on_read(sp->emfd_, &sp->read_closure_); in do_read()
493 grpc_fd_notify_on_read(emfd_, &read_closure_); in OnRead()
728 GRPC_CLOSURE_INIT(&read_closure_, on_read, this, grpc_schedule_on_exec_ctx); in StartListening()
729 grpc_fd_notify_on_read(emfd_, &read_closure_); in StartListening()
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/grpc/src/src/core/lib/iomgr/ |
| H A D | udp_server.cc | 120 grpc_closure read_closure_; member in GrpcUdpListener
456 grpc_fd_notify_on_read(sp->emfd_, &sp->read_closure_); in do_read()
492 grpc_fd_notify_on_read(emfd_, &read_closure_); in OnRead()
728 GRPC_CLOSURE_INIT(&read_closure_, on_read, this, grpc_schedule_on_exec_ctx); in StartListening()
729 grpc_fd_notify_on_read(emfd_, &read_closure_); in StartListening()
|
| /dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/content/browser/cache_storage/ |
| H A D | cache_storage_manager_unittest.cc | 102 read_closure_(std::move(read_closure)) {} in DelayedBlob()
125 std::move(read_closure_).Run(); in ReadAll()
141 base::OnceClosure read_closure_; member in content::cache_storage_manager_unittest::DelayedBlob
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/content/browser/cache_storage/ |
| H A D | cache_storage_manager_unittest.cc | 99 read_closure_(std::move(read_closure)) {} in DelayedBlob()
122 std::move(read_closure_).Run(); in ReadAll()
138 base::OnceClosure read_closure_; member in content::cache_storage_manager_unittest::DelayedBlob
|