/dports/lang/spidermonkey60/firefox-60.9.0/servo/components/script/ |
H A D | serviceworkerjob.rs | 24 use task_source::TaskSource; 25 use task_source::dom_manipulation::DOMManipulationTaskSource; 273 fn queue_settle_promise_for_job(job: &Job, settle: SettleType, task_source: &DOMManipulationTaskSou… in queue_settle_promise_for_job() 277 let _ = task_source.queue( in queue_settle_promise_for_job() 288 fn queue_settle_promise(job: &Job, settle: SettleType, task_source: &DOMManipulationTaskSource) { in queue_settle_promise() 290 queue_settle_promise_for_job(job, settle.clone(), task_source); in queue_settle_promise() 293 queue_settle_promise_for_job(job, settle.clone(), task_source); in queue_settle_promise() 297 fn reject_job_promise(job: &Job, err: Error, task_source: &DOMManipulationTaskSource) { in reject_job_promise() 298 queue_settle_promise(job, SettleType::Reject(err), task_source) in reject_job_promise() 301 fn resolve_job_promise(job: &Job, reg: &ServiceWorkerRegistration, task_source: &DOMManipulationTas… in resolve_job_promise() [all …]
|
H A D | network_listener.rs | 8 use task_source::TaskSource; 9 use task_source::networking::NetworkingTaskSource; 15 pub task_source: NetworkingTaskSource, field 26 self.task_source.queue_with_canceller(task, canceller) in notify() 28 self.task_source.queue_unconditionally(task) in notify()
|
/dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/base/task/thread_pool/ |
H A D | pooled_task_runner_delegate.h | 33 virtual bool ShouldYield(const TaskSource* task_source) const = 0; 47 scoped_refptr<JobTaskSource> task_source) = 0; 51 scoped_refptr<JobTaskSource> task_source) = 0; 57 virtual void UpdatePriority(scoped_refptr<TaskSource> task_source,
|
H A D | test_utils.h | 64 bool EnqueueJobTaskSource(scoped_refptr<JobTaskSource> task_source) override; 65 void RemoveJobTaskSource(scoped_refptr<JobTaskSource> task_source) override; 66 bool ShouldYield(const TaskSource* task_source) const override; 67 void UpdatePriority(scoped_refptr<TaskSource> task_source, 153 scoped_refptr<TaskSource> task_source);
|
H A D | task_source.h | 118 TaskSource* task_source() const { return task_source_; } in task_source() function 121 explicit Transaction(TaskSource* task_source); 249 scoped_refptr<TaskSource> task_source, 284 RegisteredTaskSource(scoped_refptr<TaskSource> task_source, 318 RegisteredTaskSource task_source; member
|
H A D | task_tracker.h | 112 scoped_refptr<TaskSource> task_source); 123 RegisteredTaskSource RunAndPopNextTask(RegisteredTaskSource task_source); 165 TaskSource* task_source, 192 scoped_refptr<TaskSource> task_source);
|
H A D | thread_pool_impl.h | 107 bool EnqueueJobTaskSource(scoped_refptr<JobTaskSource> task_source) override; 108 void RemoveJobTaskSource(scoped_refptr<JobTaskSource> task_source) override; 109 void UpdatePriority(scoped_refptr<TaskSource> task_source, 147 bool ShouldYield(const TaskSource* task_source) const override;
|
H A D | worker_thread.cc | 326 RegisteredTaskSource task_source = delegate_->GetWork(this); in RunWorker() local 327 if (!task_source) { in RunWorker() 339 task_source = task_tracker_->RunAndPopNextTask(std::move(task_source)); in RunWorker() 341 delegate_->DidProcessTask(std::move(task_source)); in RunWorker()
|
H A D | task_tracker_posix.cc | 18 TaskSource* task_source, in RunTask() argument 22 TaskTracker::RunTask(std::move(task), task_source, traits); in RunTask()
|
H A D | thread_group_impl.cc | 234 void DidProcessTask(RegisteredTaskSource task_source) override; 635 RegisteredTaskSource task_source; in GetWork() local 637 while (!task_source && !outer_->priority_queue_.IsEmpty()) { in GetWork() 648 task_source = outer_->TakeRegisteredTaskSource(&executor); in GetWork() 650 if (!task_source) { in GetWork() 661 return task_source; in GetWork() 665 RegisteredTaskSource task_source) { in DidProcessTask() argument 676 if (task_source) { in DidProcessTask() 679 std::move(task_source))); in DidProcessTask()
|
/dports/www/chromium-legacy/chromium-88.0.4324.182/base/task/thread_pool/ |
H A D | test_utils.h | 65 bool EnqueueJobTaskSource(scoped_refptr<JobTaskSource> task_source) override; 66 void RemoveJobTaskSource(scoped_refptr<JobTaskSource> task_source) override; 67 bool ShouldYield(const TaskSource* task_source) override; 68 void UpdatePriority(scoped_refptr<TaskSource> task_source, 70 void UpdateJobPriority(scoped_refptr<TaskSource> task_source, 157 scoped_refptr<TaskSource> task_source);
|
H A D | thread_pool_impl.h | 108 bool EnqueueJobTaskSource(scoped_refptr<JobTaskSource> task_source) override; 109 void RemoveJobTaskSource(scoped_refptr<JobTaskSource> task_source) override; 110 void UpdatePriority(scoped_refptr<TaskSource> task_source, 112 void UpdateJobPriority(scoped_refptr<TaskSource> task_source, 155 bool ShouldYield(const TaskSource* task_source) override;
|
H A D | task_tracker.h | 112 scoped_refptr<TaskSource> task_source); 123 RegisteredTaskSource RunAndPopNextTask(RegisteredTaskSource task_source); 157 TaskSource* task_source, 184 scoped_refptr<TaskSource> task_source);
|
H A D | task_source.h | 115 TaskSource* task_source() const { return task_source_; } in task_source() function 118 explicit Transaction(TaskSource* task_source); 247 scoped_refptr<TaskSource> task_source, 282 RegisteredTaskSource(scoped_refptr<TaskSource> task_source, 318 RegisteredTaskSource task_source; member
|
H A D | priority_queue.h | 32 void Push(RegisteredTaskSource task_source, 54 RegisteredTaskSource RemoveTaskSource(const TaskSource& task_source); 59 void UpdateSortKey(const TaskSource& task_source, TaskSourceSortKey sort_key);
|
H A D | worker_thread.cc | 337 RegisteredTaskSource task_source = delegate_->GetWork(this); in RunWorker() local 338 if (!task_source) { in RunWorker() 350 task_source = task_tracker_->RunAndPopNextTask(std::move(task_source)); in RunWorker() 352 delegate_->DidProcessTask(std::move(task_source)); in RunWorker()
|
H A D | task_tracker_posix.cc | 18 TaskSource* task_source, in RunTask() argument 22 TaskTracker::RunTask(std::move(task), task_source, traits); in RunTask()
|
H A D | thread_group_impl.cc | 237 void DidProcessTask(RegisteredTaskSource task_source) override; 601 RegisteredTaskSource task_source; in GetWork() local 603 while (!task_source && !outer_->priority_queue_.IsEmpty()) { in GetWork() 614 task_source = outer_->TakeRegisteredTaskSource(&executor); in GetWork() 616 if (!task_source) { in GetWork() 633 return task_source; in GetWork() 637 RegisteredTaskSource task_source) { in DidProcessTask() argument 648 if (task_source) { in DidProcessTask() 651 std::move(task_source))); in DidProcessTask()
|
/dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/base/task/sequence_manager/ |
H A D | thread_controller_with_message_pump_impl.cc | 76 SequencedTaskSource* task_source) { in SetSequencedTaskSource() argument 77 DCHECK(task_source); in SetSequencedTaskSource() 78 DCHECK(!main_thread_only().task_source); in SetSequencedTaskSource() 79 main_thread_only().task_source = task_source; in SetSequencedTaskSource() 301 DCHECK(main_thread_only().task_source); in DoWorkImpl() 304 Task* task = main_thread_only().task_source->SelectNextTask(); in DoWorkImpl() 337 main_thread_only().task_source->DidRunTask(); in DoWorkImpl() 351 main_thread_only().task_source->DelayTillNextTask(continuation_lazy_now); in DoWorkImpl() 368 main_thread_only().task_source->HasPendingHighResolutionTasks(); in DoIdleWork() 379 if (main_thread_only().task_source->OnSystemIdle()) { in DoIdleWork()
|
/dports/www/chromium-legacy/chromium-88.0.4324.182/base/task/sequence_manager/ |
H A D | thread_controller_with_message_pump_impl.cc | 80 SequencedTaskSource* task_source) { in SetSequencedTaskSource() argument 81 DCHECK(task_source); in SetSequencedTaskSource() 82 DCHECK(!main_thread_only().task_source); in SetSequencedTaskSource() 83 main_thread_only().task_source = task_source; in SetSequencedTaskSource() 323 DCHECK(main_thread_only().task_source); in DoWorkImpl() 331 main_thread_only().task_source->SelectNextTask(select_task_option); in DoWorkImpl() 369 main_thread_only().task_source->DidRunTask(); in DoWorkImpl() 390 TimeDelta do_work_delay = main_thread_only().task_source->DelayTillNextTask( in DoWorkImpl() 411 main_thread_only().task_source->HasPendingHighResolutionTasks(); in DoIdleWork() 423 if (main_thread_only().task_source->OnSystemIdle()) { in DoIdleWork()
|
/dports/lang/spidermonkey60/firefox-60.9.0/servo/components/script/dom/ |
H A D | websocket.rs | 40 use task_source::TaskSource; 41 use task_source::networking::NetworkingTaskSource; 71 task_source: &NetworkingTaskSource, in close_the_websocket_connection() 82 task_source.queue_with_canceller(close_task, &canceller).unwrap(); in close_the_websocket_connection() 87 task_source: &NetworkingTaskSource, in fail_the_websocket_connection() 96 task_source.queue_with_canceller(close_task, &canceller).unwrap(); in fail_the_websocket_connection() 201 let task_source = global.networking_task_source(); in Constructor() localVariable 211 task_source.queue_with_canceller(open_thread, &canceller).unwrap(); in Constructor() 222 &task_source, &canceller); in Constructor() 226 &task_source, &canceller, code, reason); in Constructor() [all …]
|
H A D | htmlmediaelement.rs | 49 use task_source::TaskSource; 186 let task_source = window.dom_manipulation_task_source(); in play() localVariable 203 task_source.queue_simple_event( in play() 219 task_source.queue( in play() 328 let task_source = window.dom_manipulation_task_source(); in change_ready_state() localVariable 333 task_source.queue_simple_event( in change_ready_state() 347 let _ = task_source.queue( in change_ready_state() 373 task_source.queue_simple_event( in change_ready_state() 396 task_source.queue_simple_event( in change_ready_state() 409 task_source.queue_simple_event( in change_ready_state() [all …]
|
H A D | filereader.rs | 38 use task_source::TaskSource; 39 use task_source::file_reading::{FileReadingTask, FileReadingTaskSource}; 389 let task_source = global.file_reading_task_source(); in read() localVariable 397 task_source, in read() 416 task_source: FileReadingTaskSource, in perform_annotated_read_operation() 421 task_source.queue_with_canceller(task, &canceller).unwrap(); in perform_annotated_read_operation() 424 task_source.queue_with_canceller(task, &canceller).unwrap(); in perform_annotated_read_operation() 427 task_source.queue_with_canceller(task, &canceller).unwrap(); in perform_annotated_read_operation()
|
/dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/base/task/ |
H A D | post_job.h | 32 JobDelegate(internal::JobTaskSource* task_source, 116 explicit JobHandle(scoped_refptr<internal::JobTaskSource> task_source);
|
/dports/www/chromium-legacy/chromium-88.0.4324.182/base/task/ |
H A D | post_job.h | 35 JobDelegate(internal::JobTaskSource* task_source, 127 explicit JobHandle(scoped_refptr<internal::JobTaskSource> task_source);
|