| /external/perfetto/src/ipc/ |
| D | deferred_unittest.cc | 39 deferred.Bind([num_callbacks](AsyncResult<TestMessage> msg) { in TEST()
48 AsyncResult<TestMessage> res = AsyncResult<TestMessage>::Create(); in TEST()
66 deferred.Bind([num_callbacks](AsyncResult<TestMessage> msg) { in TEST()
74 AsyncResult<TestMessage> res = AsyncResult<TestMessage>::Create(); in TEST()
87 deferred.Bind([num_callbacks](AsyncResult<TestMessage> msg) { in TEST()
102 [num_callbacks](AsyncResult<TestMessage>) { (*num_callbacks)++; }); in TEST()
110 deferred.Bind([](AsyncResult<TestMessage>) {}); in TEST()
115 deferred.Bind([num_callbacks](AsyncResult<TestMessage> msg) { in TEST()
120 AsyncResult<TestMessage> res = AsyncResult<TestMessage>::Create(); in TEST()
130 std::function<void(AsyncResult<TestMessage>)> callback = in TEST()
[all …]
|
| D | deferred.cc | 26 std::function<void(AsyncResult<ProtoMessage>)> callback) in DeferredBase()
54 std::function<void(AsyncResult<ProtoMessage>)> callback) { in Bind()
62 void DeferredBase::Resolve(AsyncResult<ProtoMessage> async_result) { in Resolve()
75 Resolve(AsyncResult<ProtoMessage>()); in Reject()
|
| D | client_impl_unittest.cc | 252 [on_invoke_reply](AsyncResult<ProtoMessage> reply) { in TEST_F()
262 [on_invalid_invoke](AsyncResult<ProtoMessage> reply) { in TEST_F()
332 [on_last_reply, &replies_seen](AsyncResult<ProtoMessage> reply) { in TEST_F()
374 [on_reply](AsyncResult<ProtoMessage> reply) { in TEST_F()
418 [on_reply](AsyncResult<ProtoMessage> reply) { in TEST_F()
516 [on_reject](AsyncResult<ProtoMessage> res) { in TEST_F()
539 DeferredBase deferred_reply([on_reject](AsyncResult<ProtoMessage> res) { in TEST_F()
|
| D | host_impl_unittest.cc | 261 reply->Resolve(AsyncResult<ProtoMessage>( in TEST_F()
299 reply->Resolve(AsyncResult<ProtoMessage>( in TEST_F()
346 auto async_res = AsyncResult<ProtoMessage>( in TEST_F()
463 moved_reply.Resolve(AsyncResult<ProtoMessage>( in TEST_F()
|
| D | host_impl.h | 79 void ReplyToMethodInvocation(ClientID, RequestID, AsyncResult<ProtoMessage>);
|
| D | service_proxy.cc | 94 AsyncResult<ProtoMessage> reply(std::move(result), has_more); in EndInvoke()
|
| D | host_impl.cc | 213 request_id](AsyncResult<ProtoMessage> reply) { in OnInvokeMethod()
231 AsyncResult<ProtoMessage> reply) { in ReplyToMethodInvocation()
|
| /external/perfetto/include/perfetto/ext/ipc/ |
| D | deferred.h | 71 std::function<void(AsyncResult<ProtoMessage>)> callback = nullptr);
80 void Bind(std::function<void(AsyncResult<ProtoMessage>)> callback);
82 void Resolve(AsyncResult<ProtoMessage>);
90 std::function<void(AsyncResult<ProtoMessage>)> callback_;
96 explicit Deferred(std::function<void(AsyncResult<T>)> callback = nullptr) {
108 void Bind(std::function<void(AsyncResult<T>)> callback) { in Bind()
116 AsyncResult<ProtoMessage> async_result_base) { in Bind()
119 AsyncResult<T> async_result( in Bind()
128 void Resolve(AsyncResult<T> async_result) { in Resolve()
130 AsyncResult<ProtoMessage> async_result_base( in Resolve()
|
| D | async_result.h | 33 class AsyncResult {
35 static AsyncResult Create() { in Create()
36 return AsyncResult(std::unique_ptr<T>(new T())); in Create()
39 AsyncResult(std::unique_ptr<T> msg = nullptr,
45 AsyncResult(AsyncResult&&) noexcept = default;
46 AsyncResult& operator=(AsyncResult&&) = default;
|
| /external/perfetto/src/tracing/ipc/consumer/ |
| D | consumer_ipc_client_impl.cc | 92 ipc::AsyncResult<protos::gen::EnableTracingResponse> response) { in EnableTracing()
111 [](ipc::AsyncResult<protos::gen::ChangeTraceConfigResponse> response) { in ChangeTraceConfig()
128 [](ipc::AsyncResult<protos::gen::StartTracingResponse> response) { in StartTracing()
144 [](ipc::AsyncResult<protos::gen::DisableTracingResponse> response) { in DisableTracing()
165 [this](ipc::AsyncResult<protos::gen::ReadBuffersResponse> response) { in ReadBuffers()
173 ipc::AsyncResult<protos::gen::ReadBuffersResponse> response) { in OnReadBuffersResponse()
192 ipc::AsyncResult<protos::gen::EnableTracingResponse> response) { in OnEnableTracingResponse()
216 [](ipc::AsyncResult<protos::gen::FreeBuffersResponse> response) { in FreeBuffers()
233 [callback](ipc::AsyncResult<protos::gen::FlushResponse> response) { in Flush()
251 [weak_this](ipc::AsyncResult<protos::gen::DetachResponse> response) { in Detach()
[all …]
|
| D | consumer_ipc_client_impl.h | 96 ipc::AsyncResult<protos::gen::ReadBuffersResponse>);
98 ipc::AsyncResult<protos::gen::EnableTracingResponse>);
100 ipc::AsyncResult<protos::gen::QueryServiceStateResponse>,
|
| /external/perfetto/src/tracing/ipc/service/ |
| D | producer_ipc_service.cc | 133 ipc::AsyncResult<protos::gen::InitializeConnectionResponse>::Create(); in InitializeConnection()
158 ipc::AsyncResult<protos::gen::RegisterDataSourceResponse>::Create()); in RegisterDataSource()
191 ipc::AsyncResult<protos::gen::UnregisterDataSourceResponse>::Create()); in UnregisterDataSource()
213 ipc::AsyncResult<protos::gen::RegisterTraceWriterResponse>::Create()); in RegisterTraceWriter()
234 ipc::AsyncResult<protos::gen::UnregisterTraceWriterResponse>::Create()); in UnregisterTraceWriter()
260 resp.Resolve(ipc::AsyncResult<protos::gen::CommitDataResponse>::Create()); in CommitData()
283 response.Resolve(ipc::AsyncResult< in NotifyDataSourceStarted()
305 response.Resolve(ipc::AsyncResult< in NotifyDataSourceStopped()
330 ipc::AsyncResult<protos::gen::ActivateTriggersResponse>::Create()); in ActivateTriggers()
369 pending_resp.Resolve(ipc::AsyncResult<protos::gen::SyncResponse>::Create()); in Sync()
[all …]
|
| D | consumer_ipc_service.cc | 86 resp.Resolve(ipc::AsyncResult<protos::gen::StartTracingResponse>::Create()); in StartTracing()
96 ipc::AsyncResult<protos::gen::ChangeTraceConfigResponse>::Create()); in ChangeTraceConfig()
104 resp.Resolve(ipc::AsyncResult<protos::gen::DisableTracingResponse>::Create()); in DisableTracing()
119 resp.Resolve(ipc::AsyncResult<protos::gen::FreeBuffersResponse>::Create()); in FreeBuffers()
239 ipc::AsyncResult<protos::gen::QueryServiceStateResponse>::Create(); in OnQueryServiceCallback()
279 response.Resolve(ipc::AsyncResult<protos::gen::FlushResponse>::Create()); in OnFlushCallback()
306 ipc::AsyncResult<protos::gen::QueryCapabilitiesResponse>::Create(); in OnQueryCapabilitiesCallback()
335 ipc::AsyncResult<protos::gen::SaveTraceForBugreportResponse>::Create(); in OnSaveTraceForBugreportCallback()
361 ipc::AsyncResult<protos::gen::EnableTracingResponse>::Create(); in OnTracingDisabled()
375 auto result = ipc::AsyncResult<protos::gen::ReadBuffersResponse>::Create(); in OnTraceData()
[all …]
|
| /external/crosvm/cros_async/src/ |
| D | executor.rs | 12 AsyncResult, FdExecutor, IntoAsync, IoSourceExt, PollSource, URingExecutor, UringSource,
18 ) -> AsyncResult<Box<dyn IoSourceExt<F> + 'a>> { in async_uring_from()
26 ) -> AsyncResult<Box<dyn IoSourceExt<F> + 'a>> { in async_poll_from()
127 pub fn new() -> AsyncResult<Self> { in new()
143 ) -> AsyncResult<Box<dyn IoSourceExt<F> + 'a>> { in async_from()
263 pub fn run(&self) -> AsyncResult<()> { in run() argument
299 pub fn run_until<F: Future>(&self, f: F) -> AsyncResult<F::Output> { in run_until()
|
| D | event.rs | 7 use crate::{AsyncResult, Executor, IntoAsync, IoSourceExt};
15 pub fn new(event: EventFd, ex: &Executor) -> AsyncResult<EventAsync> { in new()
21 pub(crate) fn new_poll(event: EventFd, ex: &crate::FdExecutor) -> AsyncResult<EventAsync> { in new_poll()
26 pub(crate) fn new_uring(event: EventFd, ex: &crate::URingExecutor) -> AsyncResult<EventAsync> { in new_uring()
32 pub async fn next_val(&self) -> AsyncResult<u64> { in next_val()
|
| D | timer.rs | 9 use crate::{AsyncResult, Executor, IntoAsync, IoSourceExt};
19 pub fn new(timer: TimerFd, ex: &Executor) -> AsyncResult<TimerAsync> { in new()
25 pub(crate) fn new_poll(timer: TimerFd, ex: &FdExecutor) -> AsyncResult<TimerAsync> { in new_poll()
30 pub(crate) fn new_uring(timer: TimerFd, ex: &URingExecutor) -> AsyncResult<TimerAsync> { in new_uring()
35 pub async fn next_val(&self) -> AsyncResult<u64> { in next_val()
|
| D | poll_source.rs | 17 use crate::{AsyncError, AsyncResult};
86 ) -> AsyncResult<(usize, Vec<u8>)> { in read_to_vec()
118 ) -> AsyncResult<usize> { in read_to_mem()
151 async fn wait_readable(&self) -> AsyncResult<()> { in wait_readable() argument
157 async fn read_u64(&self) -> AsyncResult<u64> { in read_u64()
191 ) -> AsyncResult<(usize, Vec<u8>)> { in write_from_vec()
223 ) -> AsyncResult<usize> { in write_from_mem()
257 async fn fallocate(&self, file_offset: u64, len: u64, mode: u32) -> AsyncResult<()> { in fallocate() argument
274 async fn fsync(&self) -> AsyncResult<()> { in fsync() argument
|
| D | uring_source.rs | 16 use crate::AsyncResult;
69 ) -> AsyncResult<(usize, Vec<u8>)> { in read_to_vec()
90 async fn wait_readable(&self) -> AsyncResult<()> { in wait_readable() argument
97 async fn read_u64(&self) -> AsyncResult<u64> { in read_u64()
133 ) -> AsyncResult<usize> { in read_to_mem()
149 ) -> AsyncResult<(usize, Vec<u8>)> { in write_from_vec()
175 ) -> AsyncResult<usize> { in write_from_mem()
184 async fn fallocate(&self, file_offset: u64, len: u64, mode: u32) -> AsyncResult<()> { in fallocate() argument
193 async fn fsync(&self) -> AsyncResult<()> { in fsync() argument
|
| D | lib.rs | 80 Error as AsyncError, IntoAsync, IoSourceExt, ReadAsync, Result as AsyncResult, WriteAsync,
|
| /external/perfetto/src/ipc/test/ |
| D | ipc_integrationtest.cc | 31 using ::perfetto::ipc::AsyncResult;
95 [on_reply](AsyncResult<GreeterReplyMsg> reply) { in TEST_F()
105 auto reply = AsyncResult<GreeterReplyMsg>::Create(); in TEST_F()
118 [on_reply](AsyncResult<GreeterReplyMsg> reply) { in TEST_F()
128 auto reply = AsyncResult<GreeterReplyMsg>::Create(); in TEST_F()
|
| /external/perfetto/src/tracing/ipc/producer/ |
| D | producer_ipc_client_impl.cc | 133 [this](ipc::AsyncResult<protos::gen::InitializeConnectionResponse> resp) { in OnConnect()
179 [this](ipc::AsyncResult<protos::gen::GetAsyncCommandResponse> resp) { in OnConnect()
323 [](ipc::AsyncResult<protos::gen::RegisterDataSourceResponse> response) { in RegisterDataSource()
383 [callback](ipc::AsyncResult<protos::gen::CommitDataResponse> response) { in CommitData()
443 resp.Bind([callback](ipc::AsyncResult<protos::gen::SyncResponse>) { in Sync()
|
| /external/python/cpython2/Lib/multiprocessing/ |
| D | pool.py | 586 AsyncResult = ApplyResult # create alias -- see #17805 variable
|
| /external/python/cpython3/Lib/multiprocessing/ |
| D | pool.py | 785 AsyncResult = ApplyResult # create alias -- see #17805 variable
|
| /external/python/cpython3/Doc/library/ |
| D | multiprocessing.rst | 2178 :class:`~multiprocessing.pool.AsyncResult` object.
2209 :class:`~multiprocessing.pool.AsyncResult` object.
2283 .. class:: AsyncResult
|
| /external/python/cpython2/Doc/library/ |
| D | multiprocessing.rst | 1892 .. class:: AsyncResult
|