| /external/perfetto/test/ |
| D | test_helper.h | 61 if (!runner_) in ~ServiceThread()
63 runner_->PostTaskAndWaitForTesting([this]() { svc_.reset(); }); in ~ServiceThread()
67 runner_ = base::ThreadTaskRunner::CreateAndStart("perfetto.svc"); in Start()
68 runner_->PostTaskAndWaitForTesting([this]() { in Start()
69 svc_ = ServiceIPCHost::CreateInstance(runner_->get()); in Start()
89 base::ThreadTaskRunner* runner() { return runner_ ? &*runner_ : nullptr; } in runner()
92 base::Optional<base::ThreadTaskRunner> runner_; // Keep first.
115 if (!runner_) in ~ProbesProducerThread()
117 runner_->PostTaskAndWaitForTesting([this]() { producer_.reset(); }); in ~ProbesProducerThread()
121 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::__anon983fe3950111::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/libchrome/base/ |
| D | deferred_sequenced_task_runner_unittest.cc | 45 runner_->PostTask(FROM_HERE, in PostExecuteTask()
51 runner_->Start(); in StartRunner()
60 runner_(new DeferredSequencedTaskRunner(loop_.task_runner())) {} in DeferredSequencedTaskRunnerTest()
63 scoped_refptr<DeferredSequencedTaskRunner> runner_; member in base::__anonc4c731810111::DeferredSequencedTaskRunnerTest
147 runner_ = new DeferredSequencedTaskRunner(thread.task_runner()); in TEST_F()
154 runner_->PostTask( in TEST_F()
|
| /external/tensorflow/tensorflow/lite/delegates/gpu/cl/ |
| D | gpu_api_delegate.cc | 211 return builder->Build(&runner_); in Prepare()
218 runner_->SetInputObject(i++, GetTensorObject(index, context))); in SetInputsAndOutputs()
223 runner_->SetOutputObject(i++, GetTensorObject(index, context))); in SetInputsAndOutputs()
230 return runner_->Run(); in Invoke()
297 std::unique_ptr<InferenceRunner> runner_; member in tflite::gpu::cl::__anon7ea745220111::Delegate
|
| /external/tensorflow/tensorflow/lite/delegates/gpu/ |
| D | delegate.cc | 177 return builder->Build(&runner_); in Prepare()
221 RETURN_IF_ERROR(runner_->Run()); in Invoke()
232 RETURN_IF_ERROR(runner_->SetInputObject( in SetInputsAndOutputs()
236 RETURN_IF_ERROR(runner_->SetOutputObject( in SetInputsAndOutputs()
347 std::unique_ptr<InferenceRunner> runner_; member in tflite::gpu::__anon84c75a400111::DelegateKernel
|
| /external/tensorflow/tensorflow/core/data/ |
| D | standalone.cc | 113 op_params.runner = &runner_; in MakeIterator()
152 runner_ = [this](std::function<void()> c) { pool_->Schedule(std::move(c)); }; in Dataset()
|
| D | standalone.h | 121 std::function<void(std::function<void()>)> runner_; variable
|
| /external/tensorflow/tensorflow/core/kernels/data/ |
| D | single_threaded_executor_test.cc | 73 runner_ = [](const std::function<void()>& fn) { fn(); }; in Create()
80 args.runner = runner_; in Run()
87 args.runner = runner_; in Run()
93 Executor::Args::Runner runner_; member in tensorflow::data::__anon06655fe30111::ExecutorTest
|
| D | dataset_test_base.cc | 414 runner_ = [](const std::function<void()>& fn) { fn(); }; in InitFunctionLibraryRuntime()
416 runner_ = [this](std::function<void()> fn) { in InitFunctionLibraryRuntime()
468 exec_args.runner = runner_; in RunFunction()
502 params->runner = &runner_; in CreateOpKernelContext()
|
| D | dataset_test_base.h | 766 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 __anon81a6c5020111::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/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/tensorflow/tensorflow/core/common_runtime/eager/ |
| D | kernel_and_device.h | 121 runner_(runner) {} in KernelAndDevice()
186 std::function<void(std::function<void()>)>* const runner_; // can be null
|
| D | kernel_and_device.cc | 79 if (runner_) { in get_runner()
80 return runner_; in get_runner()
|
| D | context.h | 155 std::function<void(std::function<void()>)>* runner() { return &runner_; } in runner()
616 std::function<void(std::function<void()>)> runner_; variable
|
| D | context.cc | 108 runner_ = [this](std::function<void()> closure) { in __anonceee8e1b0302()
|
| /external/perfetto/src/traced/probes/ftrace/ |
| D | ftrace_controller_unittest.cc | 179 runner_(std::move(runner)), in TestFtraceController()
182 MockTaskRunner* runner() { return runner_.get(); } in runner()
203 std::unique_ptr<MockTaskRunner> runner_; member in perfetto::TestFtraceController
|
| /external/tensorflow/tensorflow/core/common_runtime/ |
| D | executor.cc | 369 Executor::Args::Runner runner_; member in tensorflow::__anonce8950920111::ExecutorState
413 runner_(args.runner), in ExecutorState()
451 runner_([c = std::forward<Closure>(c)]() mutable { in RunTask()
712 params.runner = &runner_; in Process()
1229 auto runner = std::move(runner_); in Finish()
|
| D | executor_test.cc | 86 runner_ = [this](std::function<void()> fn) { thread_pool_->Schedule(fn); }; in Create()
93 args.runner = runner_; in Run()
102 Executor::Args::Runner runner_; member in tensorflow::ExecutorTest
|