| /external/perfetto/src/ipc/ |
| D | deferred_unittest.cc | 37 deferred.Bind([num_callbacks](AsyncResult<TestMessage> msg) { in TEST()
46 AsyncResult<TestMessage> res = AsyncResult<TestMessage>::Create(); in TEST()
64 deferred.Bind([num_callbacks](AsyncResult<TestMessage> msg) { in TEST()
72 AsyncResult<TestMessage> res = AsyncResult<TestMessage>::Create(); in TEST()
85 deferred.Bind([num_callbacks](AsyncResult<TestMessage> msg) { in TEST()
100 [num_callbacks](AsyncResult<TestMessage>) { (*num_callbacks)++; }); in TEST()
108 deferred.Bind([](AsyncResult<TestMessage>) {}); in TEST()
113 deferred.Bind([num_callbacks](AsyncResult<TestMessage> msg) { in TEST()
118 AsyncResult<TestMessage> res = AsyncResult<TestMessage>::Create(); in TEST()
128 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 | 249 [on_invoke_reply](AsyncResult<ProtoMessage> reply) { in TEST_F()
259 [on_invalid_invoke](AsyncResult<ProtoMessage> reply) { in TEST_F()
329 [on_last_reply, &replies_seen](AsyncResult<ProtoMessage> reply) { in TEST_F()
369 [on_reply](AsyncResult<ProtoMessage> reply) { in TEST_F()
413 [on_reply](AsyncResult<ProtoMessage> reply) { in TEST_F()
510 [on_reject](AsyncResult<ProtoMessage> res) { in TEST_F()
533 DeferredBase deferred_reply([on_reject](AsyncResult<ProtoMessage> res) { in TEST_F()
|
| D | host_impl_unittest.cc | 258 reply->Resolve(AsyncResult<ProtoMessage>( in TEST_F()
296 reply->Resolve(AsyncResult<ProtoMessage>( in TEST_F()
341 auto async_res = AsyncResult<ProtoMessage>( in TEST_F()
457 moved_reply.Resolve(AsyncResult<ProtoMessage>( in TEST_F()
|
| D | host_impl.h | 81 void ReplyToMethodInvocation(ClientID, RequestID, AsyncResult<ProtoMessage>);
|
| D | service_proxy.cc | 93 AsyncResult<ProtoMessage> reply(std::move(result), has_more); in EndInvoke()
|
| D | host_impl.cc | 191 request_id](AsyncResult<ProtoMessage> reply) { in OnInvokeMethod()
208 AsyncResult<ProtoMessage> reply) { in ReplyToMethodInvocation()
|
| /external/perfetto/include/perfetto/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 | 80 [weak_this](ipc::AsyncResult<protos::EnableTracingResponse> response) { in EnableTracing()
99 [](ipc::AsyncResult<protos::ChangeTraceConfigResponse> response) { in ChangeTraceConfig()
115 [](ipc::AsyncResult<protos::StartTracingResponse> response) { in StartTracing()
131 [](ipc::AsyncResult<protos::DisableTracingResponse> response) { in DisableTracing()
152 [this](ipc::AsyncResult<protos::ReadBuffersResponse> response) { in ReadBuffers()
160 ipc::AsyncResult<protos::ReadBuffersResponse> response) { in OnReadBuffersResponse()
177 ipc::AsyncResult<protos::EnableTracingResponse> response) { in OnEnableTracingResponse()
191 [](ipc::AsyncResult<protos::FreeBuffersResponse> response) { in FreeBuffers()
208 [callback](ipc::AsyncResult<protos::FlushResponse> response) { in Flush()
226 [weak_this](ipc::AsyncResult<protos::DetachResponse> response) { in Detach()
[all …]
|
| D | consumer_ipc_client_impl.h | 81 void OnReadBuffersResponse(ipc::AsyncResult<protos::ReadBuffersResponse>);
82 void OnEnableTracingResponse(ipc::AsyncResult<protos::EnableTracingResponse>);
|
| /external/perfetto/src/tracing/ipc/service/ |
| D | producer_ipc_service.cc | 95 ipc::AsyncResult<protos::InitializeConnectionResponse>::Create(); in InitializeConnection()
119 ipc::AsyncResult<protos::RegisterDataSourceResponse>::Create()); in RegisterDataSource()
152 ipc::AsyncResult<protos::UnregisterDataSourceResponse>::Create()); in UnregisterDataSource()
174 ipc::AsyncResult<protos::RegisterTraceWriterResponse>::Create()); in RegisterTraceWriter()
195 ipc::AsyncResult<protos::UnregisterTraceWriterResponse>::Create()); in UnregisterTraceWriter()
223 resp.Resolve(ipc::AsyncResult<protos::CommitDataResponse>::Create()); in CommitData()
247 ipc::AsyncResult<protos::NotifyDataSourceStartedResponse>::Create()); in NotifyDataSourceStarted()
269 ipc::AsyncResult<protos::NotifyDataSourceStoppedResponse>::Create()); in NotifyDataSourceStopped()
292 resp.Resolve(ipc::AsyncResult<protos::ActivateTriggersResponse>::Create()); in ActivateTriggers()
339 auto cmd = ipc::AsyncResult<protos::GetAsyncCommandResponse>::Create(); in SetupDataSource()
[all …]
|
| D | consumer_ipc_service.cc | 84 resp.Resolve(ipc::AsyncResult<protos::StartTracingResponse>::Create()); in StartTracing()
95 resp.Resolve(ipc::AsyncResult<protos::ChangeTraceConfigResponse>::Create()); in ChangeTraceConfig()
102 resp.Resolve(ipc::AsyncResult<protos::DisableTracingResponse>::Create()); in DisableTracing()
117 resp.Resolve(ipc::AsyncResult<protos::FreeBuffersResponse>::Create()); in FreeBuffers()
197 response.Resolve(ipc::AsyncResult<protos::FlushResponse>::Create()); in OnFlushCallback()
221 auto result = ipc::AsyncResult<protos::EnableTracingResponse>::Create(); in OnTracingDisabled()
233 auto result = ipc::AsyncResult<protos::ReadBuffersResponse>::Create(); in OnTraceData()
247 result = ipc::AsyncResult<protos::ReadBuffersResponse>::Create(); in OnTraceData()
284 auto resp = ipc::AsyncResult<protos::DetachResponse>::Create(); in OnDetach()
295 auto response = ipc::AsyncResult<protos::AttachResponse>::Create(); in OnAttach()
[all …]
|
| /external/perfetto/src/ipc/test/ |
| D | ipc_integrationtest.cc | 32 using ::perfetto::ipc::AsyncResult;
93 [on_reply](AsyncResult<GreeterReplyMsg> reply) { in TEST_F()
103 auto reply = AsyncResult<GreeterReplyMsg>::Create(); in TEST_F()
116 [on_reply](AsyncResult<GreeterReplyMsg> reply) { in TEST_F()
126 auto reply = AsyncResult<GreeterReplyMsg>::Create(); in TEST_F()
|
| /external/perfetto/src/tracing/ipc/producer/ |
| D | producer_ipc_client_impl.cc | 79 [this](ipc::AsyncResult<protos::InitializeConnectionResponse> resp) { in OnConnect()
102 on_cmd.Bind([this](ipc::AsyncResult<protos::GetAsyncCommandResponse> resp) { in OnConnect()
222 [](ipc::AsyncResult<protos::RegisterDataSourceResponse> response) { in RegisterDataSource()
284 [callback](ipc::AsyncResult<protos::CommitDataResponse> response) { in CommitData()
|
| /external/python/cpython2/Lib/multiprocessing/ |
| D | pool.py | 586 AsyncResult = ApplyResult # create alias -- see #17805 variable
|
| /external/python/cpython3/Lib/multiprocessing/ |
| D | pool.py | 668 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 | 2231 .. class:: AsyncResult
|