| /external/chromium_org/components/domain_reliability/ |
| D | dispatcher.cc | 58 Task* task = new Task(closure, time_->CreateTimer(), min_delay, max_delay); in ScheduleTask() local
59 tasks_.insert(task); in ScheduleTask()
61 RunAndDeleteTask(task); in ScheduleTask()
63 MakeTaskEligible(task); in ScheduleTask()
65 MakeTaskWaiting(task); in ScheduleTask()
79 Task* task = *it; in RunEligibleTasks() local
80 DCHECK(task); in RunEligibleTasks()
81 DCHECK(task->eligible); in RunEligibleTasks()
82 RunAndDeleteTask(task); in RunEligibleTasks()
86 void DomainReliabilityDispatcher::MakeTaskWaiting(Task* task) { in MakeTaskWaiting() argument
[all …]
|
| /external/chromium_org/third_party/mesa/src/src/gallium/drivers/llvmpipe/ |
| D | lp_rast.c | 94 lp_rast_tile_begin(struct lp_rasterizer_task *task, in lp_rast_tile_begin() argument
97 const struct lp_scene *scene = task->scene; in lp_rast_tile_begin()
102 task->bin = bin; in lp_rast_tile_begin()
103 task->x = bin->x * TILE_SIZE; in lp_rast_tile_begin()
104 task->y = bin->y * TILE_SIZE; in lp_rast_tile_begin()
107 memset(task->color_tiles, 0, sizeof(task->color_tiles)); in lp_rast_tile_begin()
111 struct pipe_surface *zsbuf = task->scene->fb.zsbuf; in lp_rast_tile_begin()
127 task->x, in lp_rast_tile_begin()
128 task->y); in lp_rast_tile_begin()
132 task->depth_tile = lp_rast_get_depth_block_pointer(task, in lp_rast_tile_begin()
[all …]
|
| D | lp_rast_priv.h | 53 #define BEGIN_JIT_CALL(state, task) \ argument
57 jit_task = task; \
134 lp_rast_shade_quads_mask(struct lp_rasterizer_task *task,
149 lp_rast_get_depth_block_pointer(struct lp_rasterizer_task *task, in lp_rast_get_depth_block_pointer() argument
152 const struct lp_scene *scene = task->scene; in lp_rast_get_depth_block_pointer()
182 lp_rast_get_color_tile_pointer(struct lp_rasterizer_task *task, in lp_rast_get_color_tile_pointer() argument
185 const struct lp_scene *scene = task->scene; in lp_rast_get_color_tile_pointer()
187 assert(task->x < scene->tiles_x * TILE_SIZE); in lp_rast_get_color_tile_pointer()
188 assert(task->y < scene->tiles_y * TILE_SIZE); in lp_rast_get_color_tile_pointer()
189 assert(task->x % TILE_SIZE == 0); in lp_rast_get_color_tile_pointer()
[all …]
|
| /external/mesa3d/src/gallium/drivers/llvmpipe/ |
| D | lp_rast.c | 94 lp_rast_tile_begin(struct lp_rasterizer_task *task, in lp_rast_tile_begin() argument
97 const struct lp_scene *scene = task->scene; in lp_rast_tile_begin()
102 task->bin = bin; in lp_rast_tile_begin()
103 task->x = bin->x * TILE_SIZE; in lp_rast_tile_begin()
104 task->y = bin->y * TILE_SIZE; in lp_rast_tile_begin()
107 memset(task->color_tiles, 0, sizeof(task->color_tiles)); in lp_rast_tile_begin()
111 struct pipe_surface *zsbuf = task->scene->fb.zsbuf; in lp_rast_tile_begin()
127 task->x, in lp_rast_tile_begin()
128 task->y); in lp_rast_tile_begin()
132 task->depth_tile = lp_rast_get_depth_block_pointer(task, in lp_rast_tile_begin()
[all …]
|
| D | lp_rast_priv.h | 53 #define BEGIN_JIT_CALL(state, task) \ argument
57 jit_task = task; \
134 lp_rast_shade_quads_mask(struct lp_rasterizer_task *task,
149 lp_rast_get_depth_block_pointer(struct lp_rasterizer_task *task, in lp_rast_get_depth_block_pointer() argument
152 const struct lp_scene *scene = task->scene; in lp_rast_get_depth_block_pointer()
182 lp_rast_get_color_tile_pointer(struct lp_rasterizer_task *task, in lp_rast_get_color_tile_pointer() argument
185 const struct lp_scene *scene = task->scene; in lp_rast_get_color_tile_pointer()
187 assert(task->x < scene->tiles_x * TILE_SIZE); in lp_rast_get_color_tile_pointer()
188 assert(task->y < scene->tiles_y * TILE_SIZE); in lp_rast_get_color_tile_pointer()
189 assert(task->x % TILE_SIZE == 0); in lp_rast_get_color_tile_pointer()
[all …]
|
| /external/chromium_org/extensions/common/ |
| D | one_shot_event.cc | 22 const base::Closure& task, in TaskInfo()
24 : from_here(from_here), runner(runner), task(task), delay(delay) { in TaskInfo()
29 base::Closure task; member
44 const base::Closure& task) const { in Post()
46 from_here, task, base::MessageLoopProxy::current(), base::TimeDelta()); in Post()
50 const base::Closure& task, in Post() argument
52 PostImpl(from_here, task, runner, base::TimeDelta()); in Post()
56 const base::Closure& task, in PostDelayed() argument
58 PostImpl(from_here, task, base::MessageLoopProxy::current(), delay); in PostDelayed()
74 const TaskInfo& task = tasks_[i]; in Signal() local
[all …]
|
| /external/guava/guava-tests/test/com/google/common/util/concurrent/ |
| D | ListenableFutureTaskTest.java | 43 protected final ListenableFutureTask<Integer> task = field in ListenableFutureTaskTest
62 task.addListener(new Runnable() { in setUp()
83 assertFalse(task.isDone()); in testListenerDoesNotRunUntilTaskCompletes()
84 assertFalse(task.isCancelled()); in testListenerDoesNotRunUntilTaskCompletes()
89 exec.execute(task); in testListenerDoesNotRunUntilTaskCompletes()
92 assertFalse(task.isDone()); in testListenerDoesNotRunUntilTaskCompletes()
93 assertFalse(task.isCancelled()); in testListenerDoesNotRunUntilTaskCompletes()
98 assertEquals(25, task.get().intValue()); in testListenerDoesNotRunUntilTaskCompletes()
100 assertTrue(task.isDone()); in testListenerDoesNotRunUntilTaskCompletes()
101 assertFalse(task.isCancelled()); in testListenerDoesNotRunUntilTaskCompletes()
[all …]
|
| /external/chromium_org/base/ |
| D | deferred_sequenced_task_runner.cc | 30 const Closure& task, in PostDelayedTask() argument
35 return target_task_runner_->PostDelayedTask(from_here, task, delay); in PostDelayedTask()
38 QueueDeferredTask(from_here, task, delay, false /* is_non_nestable */); in PostDelayedTask()
48 const Closure& task, in PostNonNestableDelayedTask() argument
54 task, in PostNonNestableDelayedTask()
57 QueueDeferredTask(from_here, task, delay, true /* is_non_nestable */); in PostNonNestableDelayedTask()
63 const Closure& task, in QueueDeferredTask() argument
68 deferred_task.task = task; in QueueDeferredTask()
82 const DeferredTask& task = *i; in Start() local
83 if (task.is_non_nestable) { in Start()
[all …]
|
| /external/chromium_org/third_party/WebKit/Source/core/html/parser/ |
| D | HTMLConstructionSite.cpp | 99 static inline void insert(HTMLConstructionSiteTask& task) in insert() argument
101 if (isHTMLTemplateElement(*task.parent)) in insert()
102 task.parent = toHTMLTemplateElement(task.parent.get())->content(); in insert()
104 if (ContainerNode* parent = task.child->parentNode()) in insert()
105 parent->parserRemoveChild(*task.child); in insert()
107 if (task.nextChild) in insert()
108 task.parent->parserInsertBefore(task.child.get(), *task.nextChild); in insert()
110 task.parent->parserAppendChild(task.child.get()); in insert()
113 static inline void executeInsertTask(HTMLConstructionSiteTask& task) in executeInsertTask() argument
115 ASSERT(task.operation == HTMLConstructionSiteTask::Insert); in executeInsertTask()
[all …]
|
| /external/chromium_org/third_party/webrtc/base/ |
| D | taskrunner.cc | 39 void TaskRunner::StartTask(Task * task) { in StartTask() argument
40 tasks_.push_back(task); in StartTask()
44 UpdateTaskTimeout(task, 0); in StartTask()
84 Task* task = tasks_[i]; in InternalRunTasks() local
86 task->unique_id() == next_timeout_task_->unique_id()) { in InternalRunTasks()
92 deleting_task_ = task; in InternalRunTasks()
94 delete task; in InternalRunTasks()
152 void TaskRunner::UpdateTaskTimeout(Task* task, in UpdateTaskTimeout() argument
154 ASSERT(task != NULL); in UpdateTaskTimeout()
157 task->unique_id() == next_timeout_task_->unique_id(); in UpdateTaskTimeout()
[all …]
|
| /external/chromium_org/third_party/WebKit/Source/core/dom/ |
| D | MainThreadTaskRunner.cpp | 41 …PerformTaskContext(WeakPtr<MainThreadTaskRunner> runner, PassOwnPtr<ExecutionContextTask> task, bo… in PerformTaskContext()
43 , m_task(task) in PerformTaskContext()
80 void MainThreadTaskRunner::postTask(PassOwnPtr<ExecutionContextTask> task) in postTask() argument
82 if (!task->taskNameForInstrumentation().isEmpty()) in postTask()
83 InspectorInstrumentation::didPostExecutionContextTask(m_context, task.get()); in postTask()
84 …rmTaskContext::didReceiveTask, new PerformTaskContext(m_weakFactory.createWeakPtr(), task, false)); in postTask()
87 void MainThreadTaskRunner::postInspectorTask(PassOwnPtr<ExecutionContextTask> task) in postInspectorTask() argument
89 …ormTaskContext::didReceiveTask, new PerformTaskContext(m_weakFactory.createWeakPtr(), task, true)); in postInspectorTask()
92 void MainThreadTaskRunner::perform(PassOwnPtr<ExecutionContextTask> task, bool isInspectorTask) in perform() argument
95 m_pendingTasks.append(task); in perform()
[all …]
|
| /external/chromium_org/base/android/java/src/org/chromium/base/ |
| D | ThreadUtils.java | 66 FutureTask<Void> task = new FutureTask<Void>(r, null); in runOnUiThreadBlocking() local
67 postOnUiThread(task); in runOnUiThreadBlocking()
69 task.get(); in runOnUiThreadBlocking()
100 FutureTask<T> task = new FutureTask<T>(c); in runOnUiThreadBlocking() local
101 runOnUiThread(task); in runOnUiThreadBlocking()
103 return task.get(); in runOnUiThreadBlocking()
116 public static <T> FutureTask<T> runOnUiThread(FutureTask<T> task) { in runOnUiThread() argument
118 task.run(); in runOnUiThread()
120 postOnUiThread(task); in runOnUiThread()
122 return task; in runOnUiThread()
[all …]
|
| /external/chromium_org/cc/resources/ |
| D | pixel_buffer_raster_worker_pool.cc | 100 RasterTask* task, in RasterTaskState() argument
102 : type(UNSCHEDULED), task(task), task_sets(task_sets) { in RasterTaskState()
182 completed_raster_tasks_.push_back(state.task); in Shutdown()
203 RasterTask* task = item.task; in ScheduleTasks() local
211 RasterTaskQueue::Item::TaskComparator(task)); in ScheduleTasks()
220 RasterTaskState::TaskComparator(task)); in ScheduleTasks()
234 DCHECK(!task->HasBeenScheduled()); in ScheduleTasks()
235 raster_task_states_.push_back(RasterTaskState(task, item.task_sets)); in ScheduleTasks()
245 RasterTask* task = item.task; in ScheduleTasks() local
250 RasterTaskState::TaskComparator(task)); in ScheduleTasks()
[all …]
|
| D | task_graph_runner.h | 46 explicit TaskComparator(const Task* task) : task_(task) {} in TaskComparator()
48 bool operator()(const Node& node) const { return node.task == task_; } in operator()
56 Node(Task* task, unsigned priority, size_t dependencies) in Node()
57 : task(task), priority(priority), dependencies(dependencies) {} in Node()
59 Task* task; member
67 Edge(const Task* task, Task* dependent) in Edge()
68 : task(task), dependent(dependent) {} in Edge()
70 const Task* task; member
144 PrioritizedTask(Task* task, unsigned priority) in PrioritizedTask()
145 : task(task), priority(priority) {} in PrioritizedTask()
[all …]
|
| /external/chromium_org/base/threading/ |
| D | sequenced_worker_pool.cc | 68 Closure task; member
102 const Closure& task,
128 const Closure& task, in PostDelayedTask() argument
132 from_here, task, shutdown_behavior_); in PostDelayedTask()
134 return pool_->PostDelayedWorkerTask(from_here, task, delay); in PostDelayedTask()
155 const Closure& task,
162 const Closure& task,
192 const Closure& task, in PostDelayedTask() argument
196 token_, from_here, task, shutdown_behavior_); in PostDelayedTask()
198 return pool_->PostDelayedSequencedWorkerTask(token_, from_here, task, delay); in PostDelayedTask()
[all …]
|
| /external/chromium_org/third_party/libjingle/source/talk/xmpp/ |
| D | pubsubtasks_unittest.cc | 26 void OnReceiveUpdate(buzz::PubSubReceiveTask* task, in OnReceiveUpdate() argument
31 void OnRequestResult(buzz::PubSubRequestTask* task, in OnRequestResult() argument
48 void OnPublishResult(buzz::PubSubPublishTask* task) { in OnPublishResult() argument
52 void OnRetractResult(buzz::PubSubRetractTask* task) { in OnRetractResult() argument
56 void OnError(buzz::IqTask* task, const buzz::XmlElement* stanza) { in OnError() argument
86 buzz::PubSubRequestTask* task = in TEST_F() local
88 task->SignalResult.connect( in TEST_F()
90 task->Start(); in TEST_F()
136 buzz::PubSubRequestTask* task = in TEST_F() local
138 task->SignalResult.connect( in TEST_F()
[all …]
|
| /external/emma/ant/ant14/com/vladium/emma/ |
| D | emmaTask.java | 50 final NestedTask task = (NestedTask) m_tasks.remove (0); in execute() local
55 setTaskName (task.getTaskName ()); in execute()
57 task.execute (); in execute()
86 protected NestedTask addTask (final NestedTask task, final String pseudoName) in addTask() argument
88 initTask (task, pseudoName); in addTask()
90 m_tasks.add (task); in addTask()
91 return task; in addTask()
94 protected void initTask (final NestedTask task, final String pseudoName) in initTask() argument
96 task.setTaskName (pseudoName); in initTask()
97 task.setProject (getProject ()); in initTask()
[all …]
|
| /external/chromium_org/sandbox/linux/services/ |
| D | thread_helpers_unittests.cc | 66 ScopedProcSelfTask task; in TEST() local
67 ASSERT_TRUE(ThreadHelpers::IsSingleThreaded(task.fd())); in TEST()
72 ASSERT_FALSE(ThreadHelpers::IsSingleThreaded(task.fd())); in TEST()
75 ASSERT_TRUE(ThreadHelpers::StopThreadAndWatchProcFS(task.fd(), &thread)); in TEST()
79 ScopedProcSelfTask task; in TEST() local
80 ASSERT_TRUE(ThreadHelpers::IsSingleThreaded(task.fd())); in TEST()
86 ASSERT_FALSE(ThreadHelpers::IsSingleThreaded(task.fd())); in TEST()
88 ASSERT_TRUE(ThreadHelpers::StopThreadAndWatchProcFS(task.fd(), &thread)); in TEST()
93 ScopedProcSelfTask task; in TEST() local
94 ASSERT_TRUE(ThreadHelpers::IsSingleThreaded(task.fd())); in TEST()
[all …]
|
| /external/chromium_org/sync/internal_api/public/attachments/ |
| D | task_queue.h | 96 void AddToQueue(const T& task);
105 void MarkAsSucceeded(const T& task);
114 void MarkAsFailed(const T& task);
123 void Cancel(const T& task);
138 void FinishTask(const T& task);
190 void TaskQueue<T>::AddToQueue(const T& task) { in AddToQueue() argument
193 if (tasks_.find(task) == tasks_.end()) { in AddToQueue()
194 queue_.push_back(task); in AddToQueue()
195 tasks_.insert(task); in AddToQueue()
201 void TaskQueue<T>::MarkAsSucceeded(const T& task) { in MarkAsSucceeded() argument
[all …]
|
| /external/lldb/tools/debugserver/source/MacOSX/ |
| D | MachVMMemory.cpp | 33 MachVMMemory::PageSize(task_t task) in PageSize() argument
38 if (task != TASK_NULL) in PageSize()
43 kr = task_info (task, TASK_VM_INFO, (task_info_t) &vm_info, &info_count); in PageSize()
64 MachVMMemory::MaxBytesLeftInPage(task_t task, nub_addr_t addr, nub_size_t count) in MaxBytesLeftInPage() argument
66 const nub_size_t page_size = PageSize(task); in MaxBytesLeftInPage()
78 MachVMMemory::GetMemoryRegionInfo(task_t task, nub_addr_t address, DNBRegionInfo *region_info) in GetMemoryRegionInfo() argument
80 MachVMRegion vmRegion(task); in GetMemoryRegionInfo()
115 MachVMMemory::GetStolenPages(task_t task) in GetStolenPages() argument
210 stolenPages = stolen / PageSize (task); in GetStolenPages()
236 MachVMMemory::GetRegionSizes(task_t task, mach_vm_size_t &rsize, mach_vm_size_t &dirty_size) in GetRegionSizes() argument
[all …]
|
| D | MachTask.cpp | 77 task_t task = TaskPort(); in Suspend() local
78 err = ::task_suspend (task); in Suspend()
80 err.LogThreaded("::task_suspend ( target_task = 0x%4.4x )", task); in Suspend()
92 task_t task = TaskPort(); in Resume() local
93 if (task == TASK_NULL) in Resume()
97 err = BasicInfo(task, &task_info); in Resume()
106 err = ::task_resume (task); in Resume()
108 err.LogThreaded("::task_resume ( target_task = 0x%4.4x )", task); in Resume()
173 task_t task = TaskPort(); in ReadMemory() local
174 if (task != TASK_NULL) in ReadMemory()
[all …]
|
| D | MachVMMemory.h | 27 nub_size_t Read(task_t task, nub_addr_t address, void *data, nub_size_t data_count);
28 nub_size_t Write(task_t task, nub_addr_t address, const void *data, nub_size_t data_count);
29 nub_size_t PageSize(task_t task);
30 nub_bool_t GetMemoryRegionInfo(task_t task, nub_addr_t address, DNBRegionInfo *region_info);
31 …nub_bool_t GetMemoryProfile(DNBProfileDataScanType scanType, task_t task, struct task_basic_info t…
34 nub_size_t MaxBytesLeftInPage(task_t task, nub_addr_t addr, nub_size_t count);
36 uint64_t GetStolenPages(task_t task);
37 void GetRegionSizes(task_t task, mach_vm_size_t &rsize, mach_vm_size_t &dirty_size);
38 …void GetMemorySizes(task_t task, cpu_type_t cputype, nub_process_t pid, mach_vm_size_t &rpr…
41 …nub_size_t WriteRegion(task_t task, const nub_addr_t address, const void *data, const nub_size_t …
|
| /external/chromium_org/ui/file_manager/file_manager/foreground/js/ |
| D | file_tasks.js | 221 var task = tasks[i];
222 var taskParts = task.taskId.split('|');
235 task.iconType = 'audio';
236 task.title = loadTimeData.getString('ACTION_LISTEN');
238 task.iconType = 'archive';
239 task.title = loadTimeData.getString('MOUNT_ARCHIVE');
242 task.iconType = 'generic';
244 task.iconType = FileType.getIcon(this.entries_[0]);
245 task.title = loadTimeData.getString('ACTION_OPEN');
247 task.iconType = 'gdoc';
[all …]
|
| /external/chromium_org/media/cast/test/ |
| D | fake_single_thread_task_runner.cc | 24 const base::Closure& task, in PostDelayedTask() argument
32 task, in PostDelayedTask()
52 PostedTask task = it->second; in RunTasks() local
53 if (clock_->NowTicks() < task.GetTimeToRun()) in RunTasks()
57 task.task.Run(); in RunTasks()
77 PostedTask task = it->second; in Sleep() local
78 if (run_until < task.GetTimeToRun()) { in Sleep()
83 clock_->Advance(task.GetTimeToRun() - clock_->NowTicks()); in Sleep()
85 task.task.Run(); in Sleep()
95 const base::Closure& task, in PostNonNestableDelayedTask() argument
|
| /external/chromium_org/cc/test/ |
| D | fake_tile_manager.cc | 27 RasterTask* task = it->task; in ScheduleTasks() local
29 task->WillSchedule(); in ScheduleTasks()
30 task->ScheduleOnOriginThread(this); in ScheduleTasks()
31 task->DidSchedule(); in ScheduleTasks()
33 completed_tasks_.push_back(task); in ScheduleTasks()
40 RasterTask* task = it->get(); in CheckForCompletedTasks() local
42 task->WillComplete(); in CheckForCompletedTasks()
43 task->CompleteOnOriginThread(this); in CheckForCompletedTasks()
44 task->DidComplete(); in CheckForCompletedTasks()
46 task->RunReplyOnOriginThread(); in CheckForCompletedTasks()
|