Home
last modified time | relevance | path

Searched refs:outer_ (Results 1 – 24 of 24) sorted by relevance

/external/cronet/base/task/thread_pool/
Dthread_group_impl.cc98 explicit ScopedCommandsExecutor(ThreadGroupImpl* outer) : outer_(outer) {} in ScopedCommandsExecutor()
179 worker->Start(outer_->after_start().service_thread_task_runner, in FlushImpl()
180 outer_->after_start().worker_thread_observer); in FlushImpl()
181 if (outer_->worker_started_for_testing_) in FlushImpl()
182 outer_->worker_started_for_testing_->Wait(); in FlushImpl()
186 outer_->ScheduleAdjustMaxTasks(); in FlushImpl()
189 const raw_ptr<ThreadGroupImpl> outer_; member in base::internal::ThreadGroupImpl::ScopedCommandsExecutor
227 EXCLUSIVE_LOCKS_REQUIRED(outer_->lock_);
233 EXCLUSIVE_LOCKS_REQUIRED(outer_->lock_);
238 EXCLUSIVE_LOCKS_REQUIRED(outer_->lock_);
[all …]
Dworker_thread_unittest.cc154 : outer_(outer) {} in TestWorkerThreadDelegate()
165 outer_->worker_set_.Wait(); in OnMainEntry()
166 EXPECT_EQ(outer_->worker_.get(), worker); in OnMainEntry()
171 CheckedAutoLock auto_lock(outer_->lock_); in OnMainEntry()
172 EXPECT_FALSE(outer_->main_entry_called_.IsSignaled()); in OnMainEntry()
173 outer_->main_entry_called_.Signal(); in OnMainEntry()
178 EXPECT_EQ(outer_->worker_.get(), worker); in GetWork()
181 CheckedAutoLock auto_lock(outer_->lock_); in GetWork()
184 ++outer_->num_get_work_; in GetWork()
185 outer_->num_get_work_cv_->Signal(); in GetWork()
[all …]
Dpooled_single_thread_task_runner_manager.cc420 : outer_(outer), in PooledSingleThreadTaskRunner()
427 DCHECK(outer_); in PooledSingleThreadTaskRunner()
494 outer_->UnregisterWorkerThread(worker_); in ~PooledSingleThreadTaskRunner()
499 if (!outer_->task_tracker_->WillPostTask(&task, in PostTask()
514 outer_->delayed_task_manager_->AddDelayedTask( in PostTask()
529 outer_; member in base::internal::PooledSingleThreadTaskRunnerManager::PooledSingleThreadTaskRunner
/external/libchrome/base/task_scheduler/
Dscheduler_worker_pool_impl.cc98 outer_->lock_.AssertAcquired(); in is_running_background_task_lock_required()
115 const TrackedRef<SchedulerWorkerPoolImpl> outer_; member in base::internal::SchedulerWorkerPoolImpl::SchedulerWorkerDelegateImpl
365 : outer_(std::move(outer)) { in SchedulerWorkerDelegateImpl()
377 outer_->OnCanScheduleSequence(std::move(sequence)); in OnCanScheduleSequence()
391 AutoSchedulerLock auto_lock(outer_->lock_); in OnMainEntry()
392 DCHECK(ContainsWorker(outer_->workers_, worker)); in OnMainEntry()
397 if (outer_->worker_environment_ == WorkerEnvironment::COM_MTA) { in OnMainEntry()
411 StringPrintf("TaskScheduler%sWorker", outer_->pool_label_.c_str())); in OnMainEntry()
413 outer_->BindToCurrentThread(); in OnMainEntry()
425 AutoSchedulerLock auto_lock(outer_->lock_); in GetWork()
[all …]
Dscheduler_worker_unittest.cc143 : outer_(outer) {} in TestSchedulerWorkerDelegate()
151 outer_->worker_set_.Wait(); in OnMainEntry()
152 EXPECT_EQ(outer_->worker_.get(), worker); in OnMainEntry()
157 AutoSchedulerLock auto_lock(outer_->lock_); in OnMainEntry()
158 EXPECT_FALSE(outer_->main_entry_called_.IsSignaled()); in OnMainEntry()
159 outer_->main_entry_called_.Signal(); in OnMainEntry()
164 EXPECT_EQ(outer_->worker_.get(), worker); in GetWork()
167 AutoSchedulerLock auto_lock(outer_->lock_); in GetWork()
170 ++outer_->num_get_work_; in GetWork()
171 outer_->num_get_work_cv_->Signal(); in GetWork()
[all …]
Dscheduler_single_thread_task_runner_manager.cc285 : outer_(outer), in SchedulerSingleThreadTaskRunner()
289 DCHECK(outer_); in SchedulerSingleThreadTaskRunner()
303 if (!outer_->task_tracker_->WillPostTask(&task)) in PostDelayedTask()
309 outer_->delayed_task_manager_->AddDelayedTask( in PostDelayedTask()
352 outer_->UnregisterSchedulerWorker(worker_); in ~SchedulerSingleThreadTaskRunner()
365 sequence = outer_->task_tracker_->WillScheduleSequence( in PostTaskNow()
378 SchedulerSingleThreadTaskRunnerManager* const outer_; member in base::internal::SchedulerSingleThreadTaskRunnerManager::SchedulerSingleThreadTaskRunner
/external/cronet/base/message_loop/
Dmessage_pump.h90 ScopedDoWorkItem() : outer_(nullptr), work_item_depth_(0) {} in ScopedDoWorkItem()
93 if (outer_) { in ~ScopedDoWorkItem()
94 outer_->OnEndWorkItem(work_item_depth_); in ~ScopedDoWorkItem()
99 : outer_(std::exchange(rhs.outer_, nullptr)), in ScopedDoWorkItem()
107 if (outer_) {
108 outer_->OnEndWorkItem(work_item_depth_);
112 outer_ = std::exchange(rhs.outer_, nullptr);
116 bool IsNull() { return !outer_; } in IsNull()
121 explicit ScopedDoWorkItem(Delegate* outer) : outer_(outer) { in ScopedDoWorkItem()
122 outer_->OnBeginWorkItem(); in ScopedDoWorkItem()
[all …]
/external/cronet/base/task/common/
Doperations_controller.h67 if (outer_) in ~OperationToken()
68 outer_->DecrementBy(1); in ~OperationToken()
72 this->outer_ = other.outer_; in OperationToken()
73 other.outer_ = nullptr; in OperationToken()
76 operator bool() const { return !!outer_; }
80 explicit OperationToken(OperationsController* outer) : outer_(outer) {} in OperationToken()
84 RAW_PTR_EXCLUSION OperationsController* outer_; variable
/external/libchrome/base/message_loop/
Dmessage_loop_perftest.cc72 : outer_(outer), action_(std::move(action)) { in Delegate()
73 DCHECK(outer_); in Delegate()
81 outer_->thread_started_.Signal(); in ThreadMain()
82 outer_->start_event_->Wait(); in ThreadMain()
86 PostingThread* const outer_; member in base::__anon8e90598f0111::PostingThread::Delegate
142 ContinuouslyPostTasks(MessageLoopPerfTest* outer) : outer_(outer) { in ContinuouslyPostTasks()
143 DCHECK(outer_); in ContinuouslyPostTasks()
151 &outer_->num_tasks_run_); in Run()
152 while (!outer_->stop_posting_threads_.IsSet()) { in Run()
153 outer_->message_loop_task_runner_->PostTask(FROM_HERE, task_to_run); in Run()
[all …]
Dincoming_task_queue.cc93 : outer_(outer) {} in TriageQueue()
98 DCHECK_CALLED_ON_VALID_SEQUENCE(outer_->sequence_checker_); in Peek()
105 DCHECK_CALLED_ON_VALID_SEQUENCE(outer_->sequence_checker_); in Pop()
114 DCHECK_CALLED_ON_VALID_SEQUENCE(outer_->sequence_checker_); in HasTasks()
120 DCHECK_CALLED_ON_VALID_SEQUENCE(outer_->sequence_checker_); in Clear()
123 DCHECK(outer_->accept_new_tasks_); in Clear()
138 outer_->AddToIncomingQueue( in Clear()
148 outer_->delayed_tasks().Push(std::move(pending_task)); in Clear()
154 DCHECK_CALLED_ON_VALID_SEQUENCE(outer_->sequence_checker_); in ReloadFromIncomingQueueIfEmpty()
156 outer_->ReloadWorkQueue(&queue_); in ReloadFromIncomingQueueIfEmpty()
Dincoming_task_queue.h167 IncomingTaskQueue* const outer_; variable
/external/cronet/base/task/sequence_manager/
Dthread_controller.cc32 : outer_(outer) {} in RunLevelTracker()
35 DCHECK_CALLED_ON_VALID_THREAD(outer_->associated_thread_->thread_checker); in ~RunLevelTracker()
82 DCHECK_CALLED_ON_VALID_THREAD(outer_->associated_thread_->thread_checker); in OnRunLoopStarted()
98 DCHECK_CALLED_ON_VALID_THREAD(outer_->associated_thread_->thread_checker); in OnRunLoopEnded()
106 LazyNow exit_lazy_now(outer_->time_source_); in OnRunLoopEnded()
112 DCHECK_CALLED_ON_VALID_THREAD(outer_->associated_thread_->thread_checker); in OnWorkStarted()
147 DCHECK_CALLED_ON_VALID_THREAD(outer_->associated_thread_->thread_checker); in OnApplicationTaskSelected()
162 DCHECK_CALLED_ON_VALID_THREAD(outer_->associated_thread_->thread_checker); in OnWorkEnded()
182 DCHECK_CALLED_ON_VALID_THREAD(outer_->associated_thread_->thread_checker); in OnIdle()
194 if (outer_->associated_thread_->IsBoundToCurrentThread()) { in RecordScheduleWork()
[all …]
Datomic_flag_set.cc35 : outer_(outer), group_(element), flag_bit_(flag_bit) {} in AtomicFlag()
38 : outer_(other.outer_), group_(other.group_), flag_bit_(other.flag_bit_) { in AtomicFlag()
39 other.outer_ = nullptr; in AtomicFlag()
62 DCHECK_CALLED_ON_VALID_THREAD(outer_->associated_thread_->thread_checker); in ReleaseAtomicFlag()
67 outer_->AddToPartiallyFreeList(group_); in ReleaseAtomicFlag()
77 outer_->RemoveFromPartiallyFreeList(ptr); in ReleaseAtomicFlag()
78 outer_->RemoveFromAllocList(ptr); in ReleaseAtomicFlag()
81 outer_ = nullptr; in ReleaseAtomicFlag()
Dthread_controller.h261 DCHECK_CALLED_ON_VALID_THREAD(outer_->associated_thread_->thread_checker); in num_run_levels()
367 const raw_ref<const RunLevelTracker> outer_; variable
430 [[maybe_unused]] const raw_ref<const ThreadController> outer_; variable
438 GUARDED_BY_CONTEXT(outer_->associated_thread_->thread_checker);
Ddelayed_task_handle_delegate.cc14 : outer_(outer) {} in DelayedTaskHandleDelegate()
40 outer_->RemoveCancelableTask(heap_handle_); in CancelTask()
Ddelayed_task_handle_delegate.h45 const raw_ptr<TaskQueueImpl, DanglingUntriaged> outer_
Datomic_flag_set.h70 raw_ptr<AtomicFlagSet, DanglingUntriaged> outer_ = nullptr; variable
Dtask_queue_impl.h324 outer_ = nullptr; in ShutdownAndWaitForZeroOperations()
334 raw_ptr<TaskQueueImpl> outer_; variable
Dtask_queue_impl.cc72 : outer_(outer) {} in GuardedTaskPoster()
85 outer_->PostTask(std::move(task)); in PostTask()
100 std::make_unique<DelayedTaskHandleDelegate>(outer_); in PostCancelableTask()
103 outer_->PostTask(std::move(task)); in PostCancelableTask()
/external/cronet/components/prefs/
Dsegregated_pref_store.cc21 : outer_(outer) { in UnderlyingPrefStoreObserver()
22 DCHECK(outer_); in UnderlyingPrefStoreObserver()
29 if (!outer_->IsInitializationComplete()) in OnPrefValueChanged()
32 for (auto& observer : outer_->observers_) in OnPrefValueChanged()
42 if (!outer_->IsInitializationComplete()) in OnInitializationCompleted()
45 if (outer_->read_error_delegate_) { in OnInitializationCompleted()
46 PersistentPrefStore::PrefReadError read_error = outer_->GetReadError(); in OnInitializationCompleted()
48 outer_->read_error_delegate_->OnError(read_error); in OnInitializationCompleted()
51 for (auto& observer : outer_->observers_) in OnInitializationCompleted()
52 observer.OnInitializationCompleted(outer_->IsInitializationSuccessful()); in OnInitializationCompleted()
Dsegregated_pref_store.h107 const raw_ptr<SegregatedPrefStore> outer_;
/external/webrtc/modules/rtp_rtcp/source/
Dvideo_rtp_depacketizer_av1.cc97 if (++inner_ == outer_->size()) { in operator ++()
98 ++outer_; in operator ++()
103 uint8_t operator*() const { return (*outer_)[inner_]; } in operator *()
106 return lhs.outer_ == rhs.outer_ && lhs.inner_ == rhs.inner_; in operator ==()
112 : outer_(outer), inner_(inner) {} in const_iterator()
114 Storage::const_iterator outer_; member in webrtc::__anonb701a4520111::ArrayOfArrayViews::const_iterator
132 size_t first_chunk_size = first.outer_->size() - first.inner_; in CopyTo()
133 memcpy(destination, first.outer_->data() + first.inner_, first_chunk_size); in CopyTo()
135 for (auto it = std::next(first.outer_); it != data_.end(); ++it) { in CopyTo()
/external/cronet/base/threading/
Dthread_local_internal.h73 : outer_(outer), ptr_(std::move(ptr)) { in PtrTracker()
74 outer_->num_assigned_threads_.fetch_add(1, std::memory_order_relaxed); in PtrTracker()
78 outer_->num_assigned_threads_.fetch_sub(1, std::memory_order_relaxed); in ~PtrTracker()
81 const raw_ptr<CheckedThreadLocalOwnedPointer<T>> outer_; member
/external/tensorflow/tensorflow/compiler/xla/service/
Dcall_inliner.cc40 : call_(call), outer_(call->parent()) { in SubcomputationInsertionVisitor()
55 outer_->AddInstruction(std::move(new_hlo)); in DefaultAction()
84 return outer_->ReplaceInstruction(call_, new_root); in FinishVisit()
120 HloComputation* outer_; member in xla::__anon81770a780111::SubcomputationInsertionVisitor