| /external/grpc-grpc/src/core/lib/iomgr/ |
| D | resolve_address.h | 57 using TaskHandle = LookupTaskHandle; variable
59 TaskHandle,
60 grpc_event_engine::experimental::TaskHandleComparator<TaskHandle>::Hash>;
62 static const TaskHandle kNullHandle;
66 static std::string HandleToString(TaskHandle handle);
79 virtual TaskHandle LookupHostname(
98 virtual TaskHandle LookupSRV(
108 virtual TaskHandle LookupTXT(
117 virtual bool Cancel(TaskHandle handle) = 0;
|
| D | resolve_address_windows.h | 34 TaskHandle LookupHostname(
44 TaskHandle LookupSRV(
51 TaskHandle LookupTXT(
58 bool Cancel(TaskHandle handle) override;
|
| D | resolve_address_posix.h | 34 TaskHandle LookupHostname(
44 TaskHandle LookupSRV(
51 TaskHandle LookupTXT(
58 bool Cancel(TaskHandle handle) override;
|
| /external/grpc-grpc/src/core/lib/event_engine/ |
| D | event_engine.cc | 21 const EventEngine::TaskHandle EventEngine::TaskHandle::kInvalid = {-1, -1};
25 bool operator==(const EventEngine::TaskHandle& lhs, in operator ==()
26 const EventEngine::TaskHandle& rhs) { in operator ==()
30 bool operator!=(const EventEngine::TaskHandle& lhs, in operator !=()
31 const EventEngine::TaskHandle& rhs) { in operator !=()
|
| D | handle_containers.h | 33 template <typename TaskHandle>
38 size_t operator()(const TaskHandle& handle) const { in operator()
45 absl::flat_hash_set<EventEngine::TaskHandle,
46 TaskHandleComparator<EventEngine::TaskHandle>::Hash>;
|
| /external/rust/android-crates-io/crates/grpcio-sys/grpc/src/core/lib/iomgr/ |
| D | resolve_address.h | 46 using TaskHandle = ::grpc_event_engine::experimental::EventEngine::
48 static constexpr TaskHandle kNullHandle{0, 0};
52 static std::string HandleToString(TaskHandle handle);
65 virtual TaskHandle LookupHostname(
84 virtual TaskHandle LookupSRV(
94 virtual TaskHandle LookupTXT(
103 virtual bool Cancel(TaskHandle handle) = 0;
|
| D | resolve_address_posix.h | 34 TaskHandle LookupHostname(
44 TaskHandle LookupSRV(
51 TaskHandle LookupTXT(
58 bool Cancel(TaskHandle handle) override;
|
| D | resolve_address_windows.h | 34 TaskHandle LookupHostname(
44 TaskHandle LookupSRV(
51 TaskHandle LookupTXT(
58 bool Cancel(TaskHandle handle) override;
|
| /external/rust/android-crates-io/crates/grpcio-sys/grpc/src/core/lib/event_engine/ |
| D | event_engine.cc | 23 const EventEngine::TaskHandle EventEngine::TaskHandle::kInvalid = {-1, -1};
29 bool operator==(const EventEngine::TaskHandle& lhs, in operator ==()
30 const EventEngine::TaskHandle& rhs) { in operator ==()
34 bool operator!=(const EventEngine::TaskHandle& lhs, in operator !=()
35 const EventEngine::TaskHandle& rhs) { in operator !=()
|
| D | handle_containers.h | 33 template <typename TaskHandle>
38 size_t operator()(const TaskHandle& handle) const { in operator()
45 absl::flat_hash_set<EventEngine::TaskHandle,
46 TaskHandleComparator<EventEngine::TaskHandle>::Hash>;
|
| /external/crosvm/cros_async/src/ |
| D | executor.rs | 156 pub enum TaskHandle<R> { enum
167 impl<R: Send + 'static> TaskHandle<R> { implementation
171 TaskHandle::Fd(f) => f.detach(), in detach()
173 TaskHandle::Uring(u) => u.detach(), in detach()
175 TaskHandle::Handle(h) => h.detach(), in detach()
177 TaskHandle::Tokio(t) => t.detach(), in detach()
186 TaskHandle::Fd(f) => f.cancel().await, in cancel()
188 TaskHandle::Uring(u) => u.cancel().await, in cancel()
190 TaskHandle::Handle(h) => h.cancel().await, in cancel()
192 TaskHandle::Tokio(t) => t.cancel().await, in cancel()
[all …]
|
| D | tokio_executor.rs | 21 use crate::TaskHandle;
98 fn spawn<F>(&self, f: F) -> TaskHandle<F::Output> in spawn()
103 TaskHandle::Tokio(TokioTaskHandle { in spawn()
108 fn spawn_blocking<F, R>(&self, f: F) -> TaskHandle<R> in spawn_blocking()
113 TaskHandle::Tokio(TokioTaskHandle { in spawn_blocking()
118 fn spawn_local<F>(&self, f: F) -> TaskHandle<F::Output> in spawn_local()
126 TaskHandle::Tokio(TokioTaskHandle { in spawn_local()
|
| /external/grpc-grpc/include/grpc/event_engine/ |
| D | event_engine.h | 132 struct TaskHandle { struct
134 static const GRPC_DLL TaskHandle kInvalid; argument
135 friend bool operator==(const TaskHandle& lhs, const TaskHandle& rhs);
136 friend bool operator!=(const TaskHandle& lhs, const TaskHandle& rhs);
449 virtual TaskHandle RunAfter(Duration when, Closure* closure) = 0;
464 virtual TaskHandle RunAfter(Duration when,
474 virtual bool Cancel(TaskHandle handle) = 0;
|
| /external/rust/android-crates-io/crates/grpcio-sys/grpc/spm-core-include/grpc/event_engine/ |
| D | event_engine.h | 123 struct TaskHandle { struct
125 static const TaskHandle kInvalid; argument
126 friend bool operator==(const TaskHandle& lhs, const TaskHandle& rhs);
127 friend bool operator!=(const TaskHandle& lhs, const TaskHandle& rhs);
448 virtual TaskHandle RunAfter(Duration when, Closure* closure) = 0;
463 virtual TaskHandle RunAfter(Duration when,
478 virtual bool Cancel(TaskHandle handle) = 0;
|
| /external/rust/android-crates-io/crates/grpcio-sys/grpc/include/grpc/event_engine/ |
| D | event_engine.h | 123 struct TaskHandle { struct
125 static const TaskHandle kInvalid; argument
126 friend bool operator==(const TaskHandle& lhs, const TaskHandle& rhs);
127 friend bool operator!=(const TaskHandle& lhs, const TaskHandle& rhs);
448 virtual TaskHandle RunAfter(Duration when, Closure* closure) = 0;
463 virtual TaskHandle RunAfter(Duration when,
478 virtual bool Cancel(TaskHandle handle) = 0;
|
| /external/grpc-grpc/test/core/transport/chttp2/ |
| D | ping_callbacks_test.cc | 122 return EventEngine::TaskHandle{123, 456}; in TEST()
132 EXPECT_CALL(event_engine, Cancel(EventEngine::TaskHandle{123, 456})) in TEST()
202 return EventEngine::TaskHandle{123, 456}; in TEST()
210 EXPECT_CALL(event_engine, Cancel(EventEngine::TaskHandle{123, 456})) in TEST()
244 return EventEngine::TaskHandle{123, 456}; in TEST()
261 EXPECT_CALL(event_engine, Cancel(EventEngine::TaskHandle{123, 456})) in TEST()
285 return EventEngine::TaskHandle{123, 456}; in TEST()
292 EXPECT_CALL(event_engine, Cancel(EventEngine::TaskHandle{123, 456})) in TEST()
325 return EventEngine::TaskHandle{123, 456}; in TEST()
352 return EventEngine::TaskHandle{123, 789}; in TEST()
[all …]
|
| /external/grpc-grpc/src/core/lib/event_engine/windows/ |
| D | windows_engine.h | 95 TaskHandle RunAfter(Duration when, Closure* closure) override;
96 TaskHandle RunAfter(Duration when,
98 bool Cancel(TaskHandle handle) override;
116 EventEngine::TaskHandle timer_handle ABSL_GUARDED_BY(mu) =
117 EventEngine::TaskHandle::kInvalid;
154 EventEngine::TaskHandle RunAfterInternal(Duration when,
|
| /external/grpc-grpc/src/core/lib/event_engine/cf_engine/ |
| D | cf_engine.h | 60 TaskHandle RunAfter(Duration when, Closure* closure) override;
61 TaskHandle RunAfter(Duration when,
63 bool Cancel(TaskHandle handle) override;
67 EventEngine::TaskHandle RunAfterInternal(Duration when,
|
| D | cf_engine.cc | 42 EventEngine::TaskHandle handle;
180 EventEngine::TaskHandle CFEventEngine::RunAfter(Duration when, in RunAfter()
185 EventEngine::TaskHandle CFEventEngine::RunAfter( in RunAfter()
190 bool CFEventEngine::Cancel(TaskHandle handle) { in Cancel()
200 EventEngine::TaskHandle CFEventEngine::RunAfterInternal( in RunAfterInternal()
206 EventEngine::TaskHandle handle{reinterpret_cast<intptr_t>(cd), in RunAfterInternal()
|
| /external/rust/android-crates-io/crates/grpcio-sys/grpc/src/core/lib/event_engine/cf_engine/ |
| D | cf_engine.h | 58 TaskHandle RunAfter(Duration when, Closure* closure) override;
59 TaskHandle RunAfter(Duration when,
61 bool Cancel(TaskHandle handle) override;
65 EventEngine::TaskHandle RunAfterInternal(Duration when,
|
| D | cf_engine.cc | 39 EventEngine::TaskHandle handle;
171 EventEngine::TaskHandle CFEventEngine::RunAfter(Duration when, in RunAfter()
176 EventEngine::TaskHandle CFEventEngine::RunAfter( in RunAfter()
181 bool CFEventEngine::Cancel(TaskHandle handle) { in Cancel()
191 EventEngine::TaskHandle CFEventEngine::RunAfterInternal( in RunAfterInternal()
197 EventEngine::TaskHandle handle{reinterpret_cast<intptr_t>(cd), in RunAfterInternal()
|
| /external/rust/android-crates-io/crates/grpcio-sys/grpc/src/core/lib/event_engine/windows/ |
| D | windows_engine.cc | 85 EventEngine::TaskHandle handle;
90 HandleToString<EventEngine::TaskHandle>(handle).c_str()); in Run()
121 HandleToString<EventEngine::TaskHandle>(handle).c_str()); in ~WindowsEventEngine()
148 bool WindowsEventEngine::Cancel(EventEngine::TaskHandle handle) { in Cancel()
153 HandleToString<EventEngine::TaskHandle>(handle).c_str()); in Cancel()
161 EventEngine::TaskHandle WindowsEventEngine::RunAfter( in RunAfter()
166 EventEngine::TaskHandle WindowsEventEngine::RunAfter( in RunAfter()
179 EventEngine::TaskHandle WindowsEventEngine::RunAfterInternal( in RunAfterInternal()
185 EventEngine::TaskHandle handle{reinterpret_cast<intptr_t>(cd), in RunAfterInternal()
192 HandleToString<EventEngine::TaskHandle>(handle).c_str()); in RunAfterInternal()
|
| D | windows_engine.h | 86 TaskHandle RunAfter(Duration when, Closure* closure) override;
87 TaskHandle RunAfter(Duration when,
89 bool Cancel(TaskHandle handle) override;
107 EventEngine::TaskHandle timer_handle ABSL_GUARDED_BY(mu);
144 EventEngine::TaskHandle RunAfterInternal(Duration when,
|
| /external/grpc-grpc/test/core/event_engine/util/ |
| D | aborting_event_engine.h | 57 TaskHandle RunAfter(Duration /* when */, Closure* /* closure */) override { in RunAfter()
60 TaskHandle RunAfter(Duration /* when */, in RunAfter()
64 bool Cancel(TaskHandle /* handle */) override { abort(); } in Cancel() argument
|
| /external/grpc-grpc/test/core/event_engine/ |
| D | mock_event_engine.h | 50 MOCK_METHOD(TaskHandle, RunAfter, (Duration when, Closure* closure));
51 MOCK_METHOD(TaskHandle, RunAfter,
53 MOCK_METHOD(bool, Cancel, (TaskHandle handle));
|