| /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()
372 [on_reply](AsyncResult<ProtoMessage> reply) { in TEST_F()
416 [on_reply](AsyncResult<ProtoMessage> reply) { in TEST_F()
513 [on_reject](AsyncResult<ProtoMessage> res) { in TEST_F()
536 DeferredBase deferred_reply([on_reject](AsyncResult<ProtoMessage> res) { in TEST_F()
|
| D | host_impl_unittest.cc | 260 reply->Resolve(AsyncResult<ProtoMessage>( in TEST_F()
298 reply->Resolve(AsyncResult<ProtoMessage>( in TEST_F()
343 auto async_res = AsyncResult<ProtoMessage>( in TEST_F()
459 moved_reply.Resolve(AsyncResult<ProtoMessage>( in TEST_F()
|
| D | service_proxy.cc | 94 AsyncResult<ProtoMessage> reply(std::move(result), has_more); in EndInvoke()
|
| D | host_impl.h | 79 void ReplyToMethodInvocation(ClientID, RequestID, AsyncResult<ProtoMessage>);
|
| D | host_impl.cc | 192 request_id](AsyncResult<ProtoMessage> reply) { in OnInvokeMethod()
209 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 | 82 ipc::AsyncResult<protos::gen::EnableTracingResponse> response) { in EnableTracing()
101 [](ipc::AsyncResult<protos::gen::ChangeTraceConfigResponse> response) { in ChangeTraceConfig()
117 [](ipc::AsyncResult<protos::gen::StartTracingResponse> response) { in StartTracing()
133 [](ipc::AsyncResult<protos::gen::DisableTracingResponse> response) { in DisableTracing()
154 [this](ipc::AsyncResult<protos::gen::ReadBuffersResponse> response) { in ReadBuffers()
162 ipc::AsyncResult<protos::gen::ReadBuffersResponse> response) { in OnReadBuffersResponse()
181 ipc::AsyncResult<protos::gen::EnableTracingResponse> response) { in OnEnableTracingResponse()
195 [](ipc::AsyncResult<protos::gen::FreeBuffersResponse> response) { in FreeBuffers()
212 [callback](ipc::AsyncResult<protos::gen::FlushResponse> response) { in Flush()
230 [weak_this](ipc::AsyncResult<protos::gen::DetachResponse> response) { in Detach()
[all …]
|
| D | consumer_ipc_client_impl.h | 95 ipc::AsyncResult<protos::gen::ReadBuffersResponse>);
97 ipc::AsyncResult<protos::gen::EnableTracingResponse>);
99 ipc::AsyncResult<protos::gen::QueryServiceStateResponse>,
|
| /external/perfetto/src/tracing/ipc/service/ |
| D | producer_ipc_service.cc | 137 ipc::AsyncResult<protos::gen::InitializeConnectionResponse>::Create(); in InitializeConnection()
161 ipc::AsyncResult<protos::gen::RegisterDataSourceResponse>::Create()); in RegisterDataSource()
194 ipc::AsyncResult<protos::gen::UnregisterDataSourceResponse>::Create()); in UnregisterDataSource()
216 ipc::AsyncResult<protos::gen::RegisterTraceWriterResponse>::Create()); in RegisterTraceWriter()
237 ipc::AsyncResult<protos::gen::UnregisterTraceWriterResponse>::Create()); in UnregisterTraceWriter()
263 resp.Resolve(ipc::AsyncResult<protos::gen::CommitDataResponse>::Create()); in CommitData()
286 response.Resolve(ipc::AsyncResult< in NotifyDataSourceStarted()
308 response.Resolve(ipc::AsyncResult< in NotifyDataSourceStopped()
333 ipc::AsyncResult<protos::gen::ActivateTriggersResponse>::Create()); in ActivateTriggers()
372 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()
330 ipc::AsyncResult<protos::gen::EnableTracingResponse>::Create(); in OnTracingDisabled()
342 auto result = ipc::AsyncResult<protos::gen::ReadBuffersResponse>::Create(); in OnTraceData()
356 result = ipc::AsyncResult<protos::gen::ReadBuffersResponse>::Create(); in OnTraceData()
[all …]
|
| /external/perfetto/src/ipc/test/ |
| D | ipc_integrationtest.cc | 31 using ::perfetto::ipc::AsyncResult;
94 [on_reply](AsyncResult<GreeterReplyMsg> reply) { in TEST_F()
104 auto reply = AsyncResult<GreeterReplyMsg>::Create(); in TEST_F()
117 [on_reply](AsyncResult<GreeterReplyMsg> reply) { in TEST_F()
127 auto reply = AsyncResult<GreeterReplyMsg>::Create(); in TEST_F()
|
| /external/perfetto/src/tracing/ipc/producer/ |
| D | producer_ipc_client_impl.cc | 107 [this](ipc::AsyncResult<protos::gen::InitializeConnectionResponse> resp) { in OnConnect()
151 [this](ipc::AsyncResult<protos::gen::GetAsyncCommandResponse> resp) { in OnConnect()
291 [](ipc::AsyncResult<protos::gen::RegisterDataSourceResponse> response) { in RegisterDataSource()
351 [callback](ipc::AsyncResult<protos::gen::CommitDataResponse> response) { in CommitData()
411 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 | 780 AsyncResult = ApplyResult # create alias -- see #17805 variable
|
| /external/python/cpython2/Doc/library/ |
| D | multiprocessing.rst | 1892 .. class:: AsyncResult
|
| /external/python/cpython3/Doc/library/ |
| D | multiprocessing.rst | 2259 .. class:: AsyncResult
|