Lines Matching refs:main_thread_only
87 main_thread_only().selector.SetTaskQueueSelectorObserver(this);
89 RegisterTimeDomain(main_thread_only().real_time_domain.get());
103 for (internal::TaskQueueImpl* queue : main_thread_only().active_queues) {
104 main_thread_only().selector.RemoveQueue(queue);
108 main_thread_only().active_queues.clear();
109 main_thread_only().queues_to_gracefully_shutdown.clear();
113 main_thread_only().selector.SetTaskQueueSelectorObserver(nullptr);
137 main_thread_only().time_domains.insert(time_domain);
142 main_thread_only().time_domains.erase(time_domain);
146 return main_thread_only().real_time_domain.get();
154 : main_thread_only().real_time_domain.get();
155 DCHECK(main_thread_only().time_domains.find(time_domain) !=
156 main_thread_only().time_domains.end());
159 main_thread_only().active_queues.insert(task_queue.get());
160 main_thread_only().selector.AddQueue(task_queue.get());
165 main_thread_only().observer = observer;
209 main_thread_only().selector.RemoveQueue(task_queue.get());
221 // Add |task_queue| to |main_thread_only().queues_to_delete| so we can prevent
224 main_thread_only().active_queues.erase(task_queue.get());
225 main_thread_only().queues_to_delete[task_queue.get()] = std::move(task_queue);
233 for (internal::TaskQueueImpl* queue : main_thread_only().queues_to_reload) {
242 for (TimeDomain* time_domain : main_thread_only().time_domains) {
243 if (time_domain == main_thread_only().real_time_domain.get()) {
253 main_thread_only().nesting_depth++;
254 if (main_thread_only().observer)
255 main_thread_only().observer->OnBeginNestedRunLoop();
259 main_thread_only().nesting_depth--;
260 DCHECK_GE(main_thread_only().nesting_depth, 0);
261 if (main_thread_only().nesting_depth == 0) {
265 while (!main_thread_only().non_nestable_task_queue.empty()) {
267 main_thread_only().non_nestable_task_queue.back();
270 main_thread_only().non_nestable_task_queue.pop_back();
273 if (main_thread_only().observer)
274 main_thread_only().observer->OnExitNestedRunLoop();
303 main_thread_only().queues_to_reload.clear();
308 main_thread_only().queues_to_reload.push_back(iter->queue);
324 main_thread_only().selector.SelectWorkQueueToService(&work_queue);
337 main_thread_only().nesting_depth > 0) {
345 main_thread_only().non_nestable_task_queue.push_back(
350 main_thread_only().task_execution_stack.emplace_back(
355 main_thread_only().active_queues.size());
358 *main_thread_only().task_execution_stack.rbegin();
367 *main_thread_only().task_execution_stack.rbegin();
369 main_thread_only().task_execution_stack.pop_back();
371 if (main_thread_only().nesting_depth == 0)
380 if (!main_thread_only().selector.AllEnabledWorkQueuesAreEmpty())
399 for (TimeDomain* time_domain : main_thread_only().time_domains) {
419 main_thread_only().task_time_observers.might_have_observers()) ||
430 main_thread_only().task_was_run_on_quiescence_monitored_queue = true;
434 main_thread_only().file_name_crash_key,
437 main_thread_only().function_name_crash_key,
449 for (auto& observer : main_thread_only().task_observers)
461 main_thread_only().task_time_observers.might_have_observers() ||
467 if (main_thread_only().nesting_depth == 0) {
470 for (auto& observer : main_thread_only().task_time_observers)
494 if (task_timing.has_wall_time() && main_thread_only().nesting_depth == 0) {
497 for (auto& observer : main_thread_only().task_time_observers) {
505 for (auto& observer : main_thread_only().task_observers)
527 main_thread_only().nesting_depth == 0) {
542 main_thread_only().task_observers.AddObserver(task_observer);
548 main_thread_only().task_observers.RemoveObserver(task_observer);
554 main_thread_only().task_time_observers.AddObserver(task_time_observer);
560 main_thread_only().task_time_observers.RemoveObserver(task_time_observer);
565 main_thread_only().task_was_run_on_quiescence_monitored_queue;
566 main_thread_only().task_was_run_on_quiescence_monitored_queue = false;
583 for (auto* const queue : main_thread_only().active_queues)
587 for (const auto& pair : main_thread_only().queues_to_gracefully_shutdown)
591 for (const auto& pair : main_thread_only().queues_to_delete)
595 main_thread_only().selector.AsValueInto(state.get());
604 for (auto* time_domain : main_thread_only().time_domains)
630 for (auto* const queue : main_thread_only().active_queues)
632 for (const auto& pair : main_thread_only().queues_to_gracefully_shutdown)
640 main_thread_only().queues_to_gracefully_shutdown[queue.get()] =
648 for (auto it = main_thread_only().queues_to_gracefully_shutdown.begin();
649 it != main_thread_only().queues_to_gracefully_shutdown.end();) {
652 main_thread_only().active_queues.erase(it->first);
653 main_thread_only().queues_to_gracefully_shutdown.erase(it++);
658 main_thread_only().queues_to_delete.clear();
685 main_thread_only().uniform_distribution(
686 main_thread_only().random_generator) <
705 DCHECK(!main_thread_only().file_name_crash_key);
706 DCHECK(!main_thread_only().function_name_crash_key);
708 main_thread_only().file_name_crash_key = debug::AllocateCrashKeyString(
710 main_thread_only().function_name_crash_key = debug::AllocateCrashKeyString(
717 if (main_thread_only().task_execution_stack.empty())
719 return main_thread_only().task_execution_stack.rbegin()->task_queue;
