| /external/perfetto/test/ |
| D | test_helper.h | 45 if (!runner_) in ~ServiceThread()
47 runner_->PostTaskAndWaitForTesting([this]() { svc_.reset(); }); in ~ServiceThread()
51 runner_ = base::ThreadTaskRunner::CreateAndStart("perfetto.svc"); in Start()
52 runner_->PostTaskAndWaitForTesting([this]() { in Start()
53 svc_ = ServiceIPCHost::CreateInstance(runner_->get()); in Start()
63 base::ThreadTaskRunner* runner() { return runner_ ? &*runner_ : nullptr; } in runner()
66 base::Optional<base::ThreadTaskRunner> runner_; // Keep first.
80 if (!runner_) in ~ProbesProducerThread()
82 runner_->PostTaskAndWaitForTesting([this]() { producer_.reset(); }); in ~ProbesProducerThread()
86 runner_ = base::ThreadTaskRunner::CreateAndStart("perfetto.prd.probes"); in Connect()
[all …]
|
| D | end_to_end_shared_memory_fuzzer.cc | 120 if (!runner_) in ~FuzzerFakeProducerThread()
122 runner_->PostTaskAndWaitForTesting([this]() { producer_.reset(); }); in ~FuzzerFakeProducerThread()
126 runner_ = base::ThreadTaskRunner::CreateAndStart("perfetto.prd.fake"); in Connect()
127 runner_->PostTaskAndWaitForTesting([this]() { in Connect()
130 producer_->Connect(TEST_PRODUCER_SOCK_NAME, runner_->get()); in Connect()
135 base::Optional<base::ThreadTaskRunner> runner_; // Keep first. member in perfetto::shm_fuzz::__anon2faf07b90111::FuzzerFakeProducerThread
|
| /external/libchrome/mojo/public/cpp/bindings/lib/ |
| D | scoped_interface_endpoint_handle.cc | 47 runner_ = nullptr; in Close()
103 runner_ = nullptr; in SetAssociationEventHandler()
107 runner_ = base::SequencedTaskRunnerHandle::Get(); in SetAssociationEventHandler()
109 runner_->PostTask( in SetAssociationEventHandler()
113 this, runner_, ASSOCIATED)); in SetAssociationEventHandler()
115 runner_->PostTask( in SetAssociationEventHandler()
119 this, runner_, PEER_CLOSED_BEFORE_ASSOCIATION)); in SetAssociationEventHandler()
195 if (runner_->RunsTasksInCurrentSequence()) { in OnAssociated()
197 runner_ = nullptr; in OnAssociated()
199 runner_->PostTask(FROM_HERE, in OnAssociated()
[all …]
|
| D | interface_ptr_state.cc | 42 runner_.swap(other->runner_); in Swap()
58 runner_ = in Bind()
83 router_ = new MultiplexRouter(std::move(handle_), config, true, runner_); in InitializeEndpointClient()
86 std::move(payload_validator), false, std::move(runner_), in InitializeEndpointClient()
|
| D | interface_ptr_state.h | 97 scoped_refptr<base::SequencedTaskRunner> runner_; variable
|
| /external/webrtc/webrtc/base/ |
| D | taskparent.cc | 25 runner_ = parent->GetRunner(); in TaskParent()
32 runner_(derived_instance) { in TaskParent()
73 runner_->IncrementAbortCount(); in AbortAllChildren()
82 runner_->DecrementAbortCount(); in AbortAllChildren()
|
| D | taskparent.h | 31 TaskRunner *GetRunner() { return runner_; } in GetRunner()
52 TaskRunner *runner_; variable
|
| /external/tensorflow/tensorflow/lite/delegates/gpu/ |
| D | delegate.cc | 129 return builder->Build(&runner_); in Prepare()
136 runner_->SetInputObject(i++, GetTensorObject(index, context))); in SetInputsAndOutputs()
141 runner_->SetOutputObject(i++, GetTensorObject(index, context))); in SetInputsAndOutputs()
148 return runner_->Run(); in Invoke()
230 std::unique_ptr<InferenceRunner> runner_; member in tflite::gpu::__anonc9b3f0640111::Delegate
|
| /external/v8/src/libplatform/ |
| D | default-worker-threads-task-runner.cc | 65 runner_(runner) { in WorkerThread()
72 while (std::unique_ptr<Task> task = runner_->GetNext()) { in Run()
|
| D | default-worker-threads-task-runner.h | 54 DefaultWorkerThreadsTaskRunner* runner_; in NON_EXPORTED_BASE()
|
| /external/tensorflow/tensorflow/lite/delegates/gpu/cl/ |
| D | gpu_api_delegate.cc | 200 return builder->Build(&runner_); in Prepare()
207 runner_->SetInputObject(i++, GetTensorObject(index, context))); in SetInputsAndOutputs()
212 runner_->SetOutputObject(i++, GetTensorObject(index, context))); in SetInputsAndOutputs()
219 return runner_->Run(); in Invoke()
286 std::unique_ptr<InferenceRunner> runner_; member in tflite::gpu::cl::__anond3033cc60111::Delegate
|
| /external/v8/src/heap/ |
| D | item-parallel-job.cc | 30 runner_ = Runner::kForeground; in WillRunOnForeground()
34 RunInParallel(runner_); in RunInternal()
|
| D | item-parallel-job.h | 110 Runner runner_ = Runner::kBackground; variable
|
| /external/tensorflow/tensorflow/core/kernels/data/ |
| D | single_threaded_executor_test.cc | 71 runner_ = [](const std::function<void()>& fn) { fn(); }; in Create()
78 args.runner = runner_; in Run()
85 args.runner = runner_; in Run()
91 Executor::Args::Runner runner_; member in tensorflow::data::__anon39ec30070111::ExecutorTest
|
| D | dataset_test_base.cc | 401 runner_ = [](const std::function<void()>& fn) { fn(); }; in InitFunctionLibraryRuntime()
403 runner_ = [this](std::function<void()> fn) { in InitFunctionLibraryRuntime()
459 exec_args.runner = runner_; in RunFunction()
493 params->runner = &runner_; in CreateOpKernelContext()
|
| D | dataset_test_base.h | 719 std::function<void(std::function<void()>)> runner_; variable
|
| /external/libchrome/ipc/ |
| D | ipc_channel_mojo_unittest.cc | 827 runner_.reset(new ChannelProxyRunner(TakeHandle(), true)); in Init()
829 void CreateProxy(IPC::Listener* listener) { runner_->CreateProxy(listener); } in CreateProxy()
831 runner_->RunProxy(); in RunProxy()
834 runner_.reset(); in DestroyProxy()
838 IPC::ChannelProxy* proxy() { return runner_->proxy(); } in proxy()
841 std::unique_ptr<ChannelProxyRunner> runner_; member in __anonc5269e260111::IPCChannelProxyMojoTest
930 runner_.reset(new ChannelProxyRunner(std::move(handle), false)); in Init()
933 void CreateProxy(IPC::Listener* listener) { runner_->CreateProxy(listener); } in CreateProxy()
935 void RunProxy() { runner_->RunProxy(); } in RunProxy()
938 runner_.reset(); in DestroyProxy()
[all …]
|
| /external/tensorflow/tensorflow/core/common_runtime/eager/ |
| D | kernel_and_device.h | 113 runner_(runner) {} in KernelAndDevice()
164 std::function<void(std::function<void()>)>* const runner_; // can be null
|
| D | kernel_and_device.cc | 72 if (runner_) { in get_runner()
73 return runner_; in get_runner()
|
| D | context.h | 139 std::function<void(std::function<void()>)>* runner() { return &runner_; } in runner()
511 std::function<void(std::function<void()>)> runner_; variable
|
| /external/protobuf/conformance/ |
| D | conformance_test.cc | 297 runner_->RunTest(test_name, serialized_request, &serialized_response); in RunTest()
372 runner_ = runner; in RunSuite()
|
| D | conformance_test.h | 289 ConformanceTestRunner* runner_; variable
|
| /external/perfetto/src/traced/probes/ftrace/ |
| D | ftrace_controller_unittest.cc | 178 runner_(std::move(runner)), in TestFtraceController()
181 MockTaskRunner* runner() { return runner_.get(); } in runner()
202 std::unique_ptr<MockTaskRunner> runner_; member in perfetto::TestFtraceController
|
| /external/tensorflow/tensorflow/core/common_runtime/ |
| D | executor_test.cc | 81 runner_ = [this](std::function<void()> fn) { thread_pool_->Schedule(fn); }; in Create()
88 args.runner = runner_; in Run()
97 Executor::Args::Runner runner_; member in tensorflow::ExecutorTest
|
| D | executor.cc | 1333 Executor::Args::Runner runner_; member in tensorflow::__anonb108ab360111::ExecutorState
1469 runner_(args.runner), in ExecutorState()
1728 params.runner = &runner_; in Process()
2348 runner_([this, ready = std::move(*ready), scheduled_nsec]() { in ScheduleReady()
2363 runner_([=]() { Process(tagged_node, scheduled_nsec); }); in ScheduleReady()
2375 runner_(std::bind(&ExecutorState::Process, this, in ScheduleReady()
2388 runner_(std::bind(&ExecutorState::Process, this, *curr_expensive_node, in ScheduleReady()
2541 auto runner = std::move(runner_); in Finish()
|