| /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/perfetto/test/ |
| D | task_runner_thread.cc | 43 PERFETTO_DCHECK(!runner_); in Start()
48 [this]() { return runner_ != nullptr; }); in Start()
54 if (runner_) in Stop()
55 runner_->Quit(); in Stop()
67 if (!runner_) in GetThreadCPUTimeNs()
70 runner_->PostTask([this, &thread_time_ns, &cv] { in GetThreadCPUTimeNs()
94 runner_ = &task_runner; in Run()
110 runner_ = nullptr; in Run()
|
| D | task_runner_thread.h | 64 base::PlatformTaskRunner* runner_ = nullptr; 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/core/kernels/data/ |
| D | single_threaded_executor_test.cc | 71 runner_ = [](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::__anonf76da2850111::ExecutorTest
|
| D | dataset_test_base.cc | 163 runner_ = [](std::function<void()> fn) { fn(); }; in InitFunctionLibraryRuntime()
165 runner_ = [this](std::function<void()> fn) { in InitFunctionLibraryRuntime()
188 params_->runner = &runner_; in CreateOpKernelContext()
|
| D | dataset_test_base.h | 190 std::function<void(std::function<void()>)> runner_; variable
|
| /external/tensorflow/tensorflow/core/common_runtime/data/ |
| D | standalone.cc | 95 op_params.runner = &runner_; in MakeIterator()
119 runner_ = [this](std::function<void()> c) { pool_->Schedule(std::move(c)); }; in Dataset()
|
| D | standalone.h | 115 std::function<void(std::function<void()>)> runner_; variable
|
| /external/tensorflow/tensorflow/core/common_runtime/eager/ |
| D | kernel_and_device.cc | 263 params.runner = runner_ != nullptr ? runner_ : &default_runner_; in Run()
334 opts.runner = (runner_ == nullptr) ? &default_runner_ : runner_; in Run()
|
| D | kernel_and_device.h | 73 runner_(runner), in KernelAndDevice()
124 std::function<void(std::function<void()>)>* const runner_; variable
|
| D | context.h | 103 std::function<void(std::function<void()>)>* runner() { return &runner_; } in runner()
281 std::function<void(std::function<void()>)> runner_; variable
|
| D | context.cc | 80 runner_ = [this](std::function<void()> closure) { in EagerContext()
|
| /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 __anonc17630240111::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.h | 147 ConformanceTestRunner* runner_; variable
|
| D | conformance_test.cc | 227 runner_->RunTest(test_name, serialized_request, &serialized_response); in RunTest()
602 runner_ = runner; in RunSuite()
|
| /external/tensorflow/tensorflow/core/common_runtime/ |
| D | executor_test.cc | 73 runner_ = [this](std::function<void()> fn) { thread_pool_->Schedule(fn); }; in Create()
81 args.runner = runner_; in Run()
90 Executor::Args::Runner runner_; member in tensorflow::ExecutorTest
|
| D | executor.cc | 1263 Executor::Args::Runner runner_; member in tensorflow::__anon675242740111::ExecutorState
1396 runner_(args.runner), in ExecutorState()
1642 params.runner = &runner_; in Process()
2265 runner_([=]() { Process(tagged_node, scheduled_nsec); }); in ScheduleReady()
2281 runner_(std::bind(&ExecutorState::Process, this, *curr_expensive_node, in ScheduleReady()
2294 runner_(std::bind(&ExecutorState::Process, this, *curr_expensive_node, in ScheduleReady()
2454 auto runner = std::move(runner_); in Finish()
|
| /external/perfetto/src/traced/probes/ftrace/ |
| D | ftrace_controller_unittest.cc | 215 runner_(std::move(runner)), in TestFtraceController()
220 MockTaskRunner* runner() { return runner_.get(); } in runner()
262 std::unique_ptr<MockTaskRunner> runner_; member in perfetto::TestFtraceController
|