| /external/libmojo/mojo/public/cpp/bindings/lib/ |
| D | scoped_interface_endpoint_handle.cc | 46 runner_ = nullptr; in Close()
102 runner_ = nullptr; in SetAssociationEventHandler()
106 runner_ = base::ThreadTaskRunnerHandle::Get(); in SetAssociationEventHandler()
108 runner_->PostTask( in SetAssociationEventHandler()
112 this, runner_, ASSOCIATED)); in SetAssociationEventHandler()
114 runner_->PostTask( in SetAssociationEventHandler()
118 this, runner_, PEER_CLOSED_BEFORE_ASSOCIATION)); in SetAssociationEventHandler()
194 if (runner_->BelongsToCurrentThread()) { in OnAssociated()
196 runner_ = nullptr; in OnAssociated()
198 runner_->PostTask(FROM_HERE, in OnAssociated()
[all …]
|
| D | interface_ptr_state.h | 91 runner_.swap(other->runner_); in Swap()
106 runner_ = std::move(runner); in Bind()
189 router_ = new MultiplexRouter(std::move(handle_), config, true, runner_); in ConfigureProxyIfNecessary()
194 std::move(runner_), in ConfigureProxyIfNecessary()
216 scoped_refptr<base::SingleThreadTaskRunner> 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/libmojo/mojo/edk/js/ |
| D | waiting_callback.cc | 58 runner_ = gin::PerContextData::From(context)->runner()->GetWeakPtr(); in WaitingCallback()
69 if (!runner_) in OnHandleReady()
72 gin::Runner::Scope scope(runner_.get()); in OnHandleReady()
73 v8::Isolate* isolate = runner_->GetContextHolder()->isolate(); in OnHandleReady()
77 ->GetPrivate(runner_->GetContextHolder()->context(), in OnHandleReady()
84 runner_->Call(callback, runner_->global(), 1, args); in OnHandleReady()
87 runner_.reset(); in OnHandleReady()
|
| D | drain_data.cc | 25 runner_ = gin::PerContextData::From(context)->runner()->GetWeakPtr(); in DrainData()
76 if (!runner_) { in DeliverData()
86 gin::Runner::Scope scope(runner_.get()); in DeliverData()
|
| D | drain_data.h | 54 base::WeakPtr<gin::Runner> runner_; variable
|
| D | waiting_callback.h | 56 base::WeakPtr<gin::Runner> 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/perfetto/src/ftrace_reader/ |
| D | end_to_end_integrationtest.cc | 88 runner_.Quit(); in OnBundleComplete()
91 base::UnixTaskRunner* runner() { return &runner_; } in runner()
95 base::UnixTaskRunner runner_; member in perfetto::__anon0c0380990111::EndToEndIntegrationTest
|
| D | ftrace_controller_unittest.cc | 202 runner_(std::move(runner)), in TestFtraceController()
207 MockTaskRunner* runner() { return runner_.get(); } in runner()
239 std::unique_ptr<MockTaskRunner> runner_; member in perfetto::TestFtraceController
|
| /external/tensorflow/tensorflow/contrib/data/kernels/ |
| D | prefetching_kernels.cc | 56 runner_ = [this](std::function<void()> c) { in FunctionBufferingResource()
175 opts.runner = &runner_; in FillBuffer()
234 std::function<void(std::function<void()>)> runner_ = nullptr; member in tensorflow::FunctionBufferingResource
|
| /external/tensorflow/tensorflow/core/distributed_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
|
| /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.cc | 1187 Executor::Args::Runner runner_; member in tensorflow::__anon59a581e80111::ExecutorState
1306 runner_(args.runner), in ExecutorState()
1519 params.runner = &runner_; in Process()
2094 runner_([=]() { Process(tagged_node, scheduled_usec); }); in ScheduleReady()
2109 runner_(std::bind(&ExecutorState::Process, this, *curr_expensive_node, in ScheduleReady()
2122 runner_(std::bind(&ExecutorState::Process, this, *curr_expensive_node, in ScheduleReady()
2263 auto runner = std::move(runner_); in Finish()
|