Home
last modified time | relevance | path

Searched refs:task_source (Results 26 – 50 of 115) sorted by relevance

12345

/dports/lang/spidermonkey60/firefox-60.9.0/servo/components/script/
H A Dserviceworkerjob.rs24 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 Dnetwork_listener.rs8 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 Dpooled_task_runner_delegate.h33 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 Dtest_utils.h64 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 Dtask_source.h118 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 Dtask_tracker.h112 scoped_refptr<TaskSource> task_source);
123 RegisteredTaskSource RunAndPopNextTask(RegisteredTaskSource task_source);
165 TaskSource* task_source,
192 scoped_refptr<TaskSource> task_source);
H A Dthread_pool_impl.h107 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 Dworker_thread.cc326 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 Dtask_tracker_posix.cc18 TaskSource* task_source, in RunTask() argument
22 TaskTracker::RunTask(std::move(task), task_source, traits); in RunTask()
H A Dthread_group_impl.cc234 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 Dtest_utils.h65 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 Dthread_pool_impl.h108 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 Dtask_tracker.h112 scoped_refptr<TaskSource> task_source);
123 RegisteredTaskSource RunAndPopNextTask(RegisteredTaskSource task_source);
157 TaskSource* task_source,
184 scoped_refptr<TaskSource> task_source);
H A Dtask_source.h115 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 Dpriority_queue.h32 void Push(RegisteredTaskSource task_source,
54 RegisteredTaskSource RemoveTaskSource(const TaskSource& task_source);
59 void UpdateSortKey(const TaskSource& task_source, TaskSourceSortKey sort_key);
H A Dworker_thread.cc337 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 Dtask_tracker_posix.cc18 TaskSource* task_source, in RunTask() argument
22 TaskTracker::RunTask(std::move(task), task_source, traits); in RunTask()
H A Dthread_group_impl.cc237 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 Dthread_controller_with_message_pump_impl.cc76 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 Dthread_controller_with_message_pump_impl.cc80 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 Dwebsocket.rs40 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 Dhtmlmediaelement.rs49 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 Dfilereader.rs38 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 Dpost_job.h32 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 Dpost_job.h35 JobDelegate(internal::JobTaskSource* task_source,
127 explicit JobHandle(scoped_refptr<internal::JobTaskSource> task_source);

12345