Searched refs:WorkerTaskRunner (Results 1 – 17 of 17) sorted by relevance
31 struct WorkerTaskRunner::ThreadLocalState {37 ObserverList<WorkerTaskRunner::Observer> stop_observers_;40 WorkerTaskRunner::WorkerTaskRunner() { in WorkerTaskRunner() function in webkit_glue::WorkerTaskRunner46 bool WorkerTaskRunner::PostTask( in PostTask()56 int WorkerTaskRunner::PostTaskToAllThreads(const base::Closure& closure) { in PostTaskToAllThreads()64 int WorkerTaskRunner::CurrentWorkerId() { in CurrentWorkerId()70 WorkerTaskRunner* WorkerTaskRunner::Instance() { in Instance()71 static base::LazyInstance<WorkerTaskRunner>::Leaky in Instance()76 void WorkerTaskRunner::AddStopObserver(Observer* obs) { in AddStopObserver()81 void WorkerTaskRunner::RemoveStopObserver(Observer* obs) { in RemoveStopObserver()[all …]
19 class WEBKIT_CHILD_EXPORT WorkerTaskRunner {21 WorkerTaskRunner();26 static WorkerTaskRunner* Instance();45 ~WorkerTaskRunner();
84 WorkerTaskRunner* worker_task_runner = WorkerTaskRunner::Instance(); in didStartWorkerRunLoop()90 WorkerTaskRunner* worker_task_runner = WorkerTaskRunner::Instance(); in didStopWorkerRunLoop()
20 WorkerTaskRunner task_runner_;23 class MockObserver : public WorkerTaskRunner::Observer {33 WorkerTaskRunner* runner_;
10 using webkit_glue::WorkerTaskRunner;19 int worker_thread_id = WorkerTaskRunner::Instance()->CurrentWorkerId(); in current()31 return WorkerTaskRunner::Instance()->PostTask(worker_thread_id_, task); in PostDelayedTask()35 return worker_thread_id_ == WorkerTaskRunner::Instance()->CurrentWorkerId(); in RunsTasksOnCurrentThread()
25 using webkit_glue::WorkerTaskRunner;58 return WorkerTaskRunner::Instance()->CurrentWorkerId(); in CurrentWorkerId()88 if (WorkerTaskRunner::Instance()->CurrentWorkerId()) in ThreadSpecificInstance()89 WorkerTaskRunner::Instance()->AddStopObserver(dispatcher); in ThreadSpecificInstance()
36 class QuotaDispatcher : public webkit_glue::WorkerTaskRunner::Observer {
17 using webkit_glue::WorkerTaskRunner;30 return WorkerTaskRunner::Instance()->CurrentWorkerId(); in CurrentWorkerId()92 if (WorkerTaskRunner::Instance()->CurrentWorkerId()) in ThreadSpecificInstance()93 webkit_glue::WorkerTaskRunner::Instance()->AddStopObserver(dispatcher); in ThreadSpecificInstance()
33 class ServiceWorkerDispatcher : public webkit_glue::WorkerTaskRunner::Observer {
18 using webkit_glue::WorkerTaskRunner;79 DCHECK_NE(0, WorkerTaskRunner::Instance()->CurrentWorkerId()); in workerContextStarted()90 DCHECK_NE(0, WorkerTaskRunner::Instance()->CurrentWorkerId()); in workerContextDestroyed()
14 using webkit_glue::WorkerTaskRunner;37 thread_id_(WorkerTaskRunner::Instance()->CurrentWorkerId()), in WriterBridge()112 WorkerTaskRunner::Instance()->PostTask(thread_id_, closure); in PostTaskToWorker()
34 using webkit_glue::WorkerTaskRunner;79 return WorkerTaskRunner::Instance()->CurrentWorkerId(); in CurrentWorkerId()126 WorkerTaskRunner::Instance()->PostTask(thread_id, results_closure); in DispatchResultsClosure()302 if (WorkerTaskRunner::Instance()->CurrentWorkerId()) in ThreadSpecificInstance()303 WorkerTaskRunner::Instance()->AddStopObserver(filesystem); in ThreadSpecificInstance()308 DCHECK(!WorkerTaskRunner::Instance()->CurrentWorkerId()); in DeleteThreadSpecificInstance()
31 public webkit_glue::WorkerTaskRunner::Observer,
46 : public webkit_glue::WorkerTaskRunner::Observer {167 return webkit_glue::WorkerTaskRunner::Instance()->CurrentWorkerId(); in CurrentWorkerId()
32 using webkit_glue::WorkerTaskRunner;74 if (WorkerTaskRunner::Instance()->CurrentWorkerId()) in ThreadSpecificInstance()75 webkit_glue::WorkerTaskRunner::Instance()->AddStopObserver(dispatcher); in ThreadSpecificInstance()
27 using webkit_glue::WorkerTaskRunner;
859 return webkit_glue::WorkerTaskRunner::Instance()->PostTaskToAllThreads( in PostTaskToAllWebWorkers()