/external/chromium_org/components/domain_reliability/ |
H A D | dispatcher.cc | 58 Task* task = new Task(closure, time_->CreateTimer(), min_delay, max_delay); local 59 tasks_.insert(task); 61 RunAndDeleteTask(task); 63 MakeTaskEligible(task); 65 MakeTaskWaiting(task); 71 // keeps RunEligibleTasks from running forever if a task adds a new, already- 72 // eligible task that does the same, and so on.) 79 Task* task = *it; local 80 DCHECK(task); 81 DCHECK(task 86 MakeTaskWaiting(Task* task) argument 98 MakeTaskEligible(Task* task) argument 110 RunAndDeleteTask(Task* task) argument [all...] |
/external/skia/dm/ |
H A D | DMTaskRunner.cpp | 8 void TaskRunner::add(CpuTask* task) { fCpu.add(task); } argument 9 void TaskRunner::addNext(CpuTask* task) { fCpu.addNext(task); } argument 10 void TaskRunner::add(GpuTask* task) { fGpu.add(task); } argument
|
H A D | DMTaskRunner.h | 20 void add(CpuTask* task); 21 void addNext(CpuTask* task); 22 void add(GpuTask* task);
|
/external/chromium_org/third_party/skia/dm/ |
H A D | DMTaskRunner.cpp | 6 void TaskRunner::add(CpuTask* task) { fCpuWork.add(task); } argument 7 void TaskRunner::add(GpuTask* task) { fGpuWork.push(task); } argument
|
/external/chromium_org/base/ |
H A D | deferred_sequenced_task_runner.cc | 30 const Closure& task, 35 return target_task_runner_->PostDelayedTask(from_here, task, delay); 38 QueueDeferredTask(from_here, task, delay, false /* is_non_nestable */); 48 const Closure& task, 54 task, 57 QueueDeferredTask(from_here, task, delay, true /* is_non_nestable */); 63 const Closure& task, 68 deferred_task.task = task; 82 const DeferredTask& task local 28 PostDelayedTask( const tracked_objects::Location& from_here, const Closure& task, TimeDelta delay) argument 46 PostNonNestableDelayedTask( const tracked_objects::Location& from_here, const Closure& task, TimeDelta delay) argument 61 QueueDeferredTask( const tracked_objects::Location& from_here, const Closure& task, TimeDelta delay, bool is_non_nestable) argument [all...] |
H A D | task_runner.cc | 24 const Closure& task) OVERRIDE; 37 const Closure& task) { 38 return destination_->PostTask(from_here, task); 44 const Closure& task) { 45 return PostDelayedTask(from_here, task, base::TimeDelta()); 50 const Closure& task, 53 from_here, task, reply); 35 PostTask( const tracked_objects::Location& from_here, const Closure& task) argument 43 PostTask(const tracked_objects::Location& from_here, const Closure& task) argument 48 PostTaskAndReply( const tracked_objects::Location& from_here, const Closure& task, const Closure& reply) argument
|
/external/chromium_org/extensions/common/ |
H A D | one_shot_event.cc | 22 const base::Closure& task, 24 : from_here(from_here), runner(runner), task(task), delay(delay) { 29 base::Closure task; member in struct:extensions::OneShotEvent::TaskInfo 44 const base::Closure& task) const { 46 from_here, task, base::MessageLoopProxy::current(), base::TimeDelta()); 50 const base::Closure& task, 52 PostImpl(from_here, task, runner, base::TimeDelta()); 56 const base::Closure& task, 58 PostImpl(from_here, task, bas 20 TaskInfo(const tracked_objects::Location& from_here, const scoped_refptr<TaskRunner>& runner, const base::Closure& task, const base::TimeDelta& delay) argument 49 Post(const tracked_objects::Location& from_here, const base::Closure& task, const scoped_refptr<TaskRunner>& runner) const argument 55 PostDelayed(const tracked_objects::Location& from_here, const base::Closure& task, const base::TimeDelta& delay) const argument 74 const TaskInfo& task = tasks_[i]; local 82 PostImpl(const tracked_objects::Location& from_here, const base::Closure& task, const scoped_refptr<TaskRunner>& runner, const base::TimeDelta& delay) const argument [all...] |
/external/guava/guava-tests/test/com/google/common/util/concurrent/ |
H A D | ListenableFutureTaskTest.java | 43 protected final ListenableFutureTask<Integer> task = field in class:ListenableFutureTaskTest 62 task.addListener(new Runnable() { 83 assertFalse(task.isDone()); 84 assertFalse(task.isCancelled()); 86 // Start the task to put it in the RUNNING state. Have to use a separate 87 // thread because the task will block on the task latch after unblocking 89 exec.execute(task); 92 assertFalse(task.isDone()); 93 assertFalse(task [all...] |
/external/guava/guava/src/com/google/common/util/concurrent/ |
H A D | ForwardingListeningExecutorService.java | 39 public <T> ListenableFuture<T> submit(Callable<T> task) { argument 40 return delegate().submit(task); 44 public ListenableFuture<?> submit(Runnable task) { argument 45 return delegate().submit(task); 49 public <T> ListenableFuture<T> submit(Runnable task, T result) { argument 50 return delegate().submit(task, result);
|
/external/chromium_org/base/test/ |
H A D | test_pending_task_unittest.cc | 16 base::TestPendingTask task; local 19 TRACE_EVENT1("test", "TestPendingTask::TraceSupport", "task", task.AsValue()); 22 EXPECT_THAT(task.AsValue()->ToString(), ::testing::HasSubstr("post_time")); 26 base::TestPendingTask task; local 29 EXPECT_THAT(task.ToString(), ::testing::StartsWith("TestPendingTask(")); 33 base::TestPendingTask task; local 36 EXPECT_THAT(::testing::PrintToString(task), 40 EXPECT_NONFATAL_FAILURE(EXPECT_TRUE(false) << task, "TestPendingTask(");
|
/external/chromium_org/chrome/test/base/ |
H A D | history_index_restore_observer.cc | 8 const base::Closure& task) 9 : task_(task), 7 HistoryIndexRestoreObserver( const base::Closure& task) argument
|
/external/chromium_org/google_apis/drive/ |
H A D | task_util.cc | 12 const base::Closure& task) { 13 const bool posted = task_runner->PostTask(FROM_HERE, task); 11 RunTaskWithTaskRunner(scoped_refptr<base::TaskRunner> task_runner, const base::Closure& task) argument
|
/external/chromium_org/ui/base/test/ |
H A D | ui_controls_internal_win.h | 15 // run the task. These functions are internal, but exported so that 22 const base::Closure& task); 23 bool SendMouseMoveImpl(long screen_x, long screen_y, const base::Closure& task); 26 const base::Closure& task); 27 void RunClosureAfterAllPendingUITasksImpl(const base::Closure& task);
|
/external/chromium_org/v8/src/libplatform/ |
H A D | worker-thread.cc | 8 #include "src/libplatform/task-queue.h" 25 while (Task* task = queue_->GetNext()) { 26 task->Run(); 27 delete task;
|
/external/libcxx/test/utilities/function.objects/bind/func.bind/func.bind.bind/ |
H A D | copy.pass.cpp | 31 auto task = std::bind(fnc, 2.f, 4.f); local 32 auto task2(task); 33 assert(task() == 16);
|
/external/chromium_org/third_party/webrtc/base/ |
H A D | taskrunner.cc | 17 #include "webrtc/base/task.h" 39 void TaskRunner::StartTask(Task * task) { argument 40 tasks_.push_back(task); 42 // the task we just started could be about to timeout -- 43 // make sure our "next timeout task" is correct 44 UpdateTaskTimeout(task, 0); 58 // Subsequent use of those task may cause data corruption or crashes. 84 Task* task = tasks_[i]; local 86 task->unique_id() == next_timeout_task_->unique_id()) { 92 deleting_task_ = task; 152 UpdateTaskTimeout(Task* task, int64 previous_task_timeout_time) argument 197 Task *task = tasks_[i]; local [all...] |
/external/apache-xml/src/main/java/org/apache/xml/utils/ |
H A D | ThreadControllerWrapper.java | 38 public static void waitThread(Thread worker, Runnable task) argument 41 m_tpool.waitThread(worker, task); 54 * Will get a thread from the pool, execute the task 60 * NEEDSDOC @param task 61 * @param priority if >0 the task will run with the given priority 63 * @return The thread that is running the task, can be used 66 public Thread run(Runnable task, int priority) argument 69 Thread t = new Thread(task); 79 * Wait until the task is completed on the worker 83 * NEEDSDOC @param task 87 waitThread(Thread worker, Runnable task) argument [all...] |
/external/chromium_org/jingle/glue/ |
H A D | task_pump_unittest.cc | 24 MockTask* task = new MockTask(&task_pump); local 28 EXPECT_CALL(*task, ProcessStart()).WillOnce(Return(TASK_STATE_DONE)); 29 task->Start(); 36 MockTask* task = new MockTask(&task_pump); local 40 ON_CALL(*task, ProcessStart()).WillByDefault(Return(TASK_STATE_ERROR)); 41 EXPECT_CALL(*task, ProcessStart()).Times(0); 42 task->Start();
|
/external/lldb/tools/debugserver/source/MacOSX/ |
H A 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 ti, cpu_type_t cputype, nub_process_t pid, vm_statistics_data_t &vm_stats, uint64_t &physical_memory, mach_vm_size_t &rprvt, mach_vm_size_t &rsize, mach_vm_size_t &vprvt, mach_vm_size_t &vsize, mach_vm_size_t &dirty_size, mach_vm_size_t &purgable, mach_vm_size_t &anonymous); 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 &rprvt, mach_vm_size_t &vprvt); 41 nub_size_t WriteRegion(task_t task, cons [all...] |
/external/chromium_org/sandbox/linux/services/ |
H A D | thread_helpers_unittests.cc | 41 fd_ = open("/proc/self/task/", O_RDONLY | O_DIRECTORY); 66 ScopedProcSelfTask task; local 67 ASSERT_TRUE(ThreadHelpers::IsSingleThreaded(task.fd())); 72 ASSERT_FALSE(ThreadHelpers::IsSingleThreaded(task.fd())); 75 ASSERT_TRUE(ThreadHelpers::StopThreadAndWatchProcFS(task.fd(), &thread)); 79 ScopedProcSelfTask task; local 80 ASSERT_TRUE(ThreadHelpers::IsSingleThreaded(task.fd())); 86 ASSERT_FALSE(ThreadHelpers::IsSingleThreaded(task.fd())); 88 ASSERT_TRUE(ThreadHelpers::StopThreadAndWatchProcFS(task.fd(), &thread)); 93 ScopedProcSelfTask task; local [all...] |
/external/emma/ant/ant14/com/vladium/emma/ |
H A D | emmaTask.java | 50 final NestedTask task = (NestedTask) m_tasks.remove (0); 55 setTaskName (task.getTaskName ()); 57 task.execute (); 86 protected NestedTask addTask (final NestedTask task, final String pseudoName) argument 88 initTask (task, pseudoName); 90 m_tasks.add (task); 91 return task; 94 protected void initTask (final NestedTask task, final String pseudoName) argument 96 task.setTaskName (pseudoName); 97 task [all...] |
/external/chromium_org/third_party/mesa/src/src/gallium/drivers/llvmpipe/ |
H A D | lp_rast.c | 94 lp_rast_tile_begin(struct lp_rasterizer_task *task, argument 97 const struct lp_scene *scene = task->scene; 102 task->bin = bin; 103 task->x = bin->x * TILE_SIZE; 104 task->y = bin->y * TILE_SIZE; 107 memset(task->color_tiles, 0, sizeof(task->color_tiles)); 111 struct pipe_surface *zsbuf = task->scene->fb.zsbuf; 127 task->x, 128 task 150 lp_rast_clear_color(struct lp_rasterizer_task *task, const union lp_rast_cmd_arg arg) argument 212 lp_rast_clear_zstencil(struct lp_rasterizer_task *task, const union lp_rast_cmd_arg arg) argument 333 lp_rast_shade_tile(struct lp_rasterizer_task *task, const union lp_rast_cmd_arg arg) argument 396 lp_rast_shade_tile_opaque(struct lp_rasterizer_task *task, const union lp_rast_cmd_arg arg) argument 425 lp_rast_shade_quads_mask(struct lp_rasterizer_task *task, const struct lp_rast_shader_inputs *inputs, unsigned x, unsigned y, unsigned mask) argument 483 lp_rast_begin_query(struct lp_rasterizer_task *task, const union lp_rast_cmd_arg arg) argument 500 lp_rast_end_query(struct lp_rasterizer_task *task, const union lp_rast_cmd_arg arg) argument 512 lp_rast_set_state(struct lp_rasterizer_task *task, const union lp_rast_cmd_arg arg) argument 577 lp_rast_tile_end(struct lp_rasterizer_task *task) argument 636 do_rasterize_bin(struct lp_rasterizer_task *task, const struct cmd_bin *bin) argument 661 rasterize_bin(struct lp_rasterizer_task *task, const struct cmd_bin *bin ) argument 701 rasterize_scene(struct lp_rasterizer_task *task, struct lp_scene *scene) argument 802 struct lp_rasterizer_task *task = (struct lp_rasterizer_task *) init_data; local 897 struct lp_rasterizer_task *task = &rast->tasks[i]; local [all...] |
/external/mesa3d/src/gallium/drivers/llvmpipe/ |
H A D | lp_rast.c | 94 lp_rast_tile_begin(struct lp_rasterizer_task *task, argument 97 const struct lp_scene *scene = task->scene; 102 task->bin = bin; 103 task->x = bin->x * TILE_SIZE; 104 task->y = bin->y * TILE_SIZE; 107 memset(task->color_tiles, 0, sizeof(task->color_tiles)); 111 struct pipe_surface *zsbuf = task->scene->fb.zsbuf; 127 task->x, 128 task 150 lp_rast_clear_color(struct lp_rasterizer_task *task, const union lp_rast_cmd_arg arg) argument 212 lp_rast_clear_zstencil(struct lp_rasterizer_task *task, const union lp_rast_cmd_arg arg) argument 333 lp_rast_shade_tile(struct lp_rasterizer_task *task, const union lp_rast_cmd_arg arg) argument 396 lp_rast_shade_tile_opaque(struct lp_rasterizer_task *task, const union lp_rast_cmd_arg arg) argument 425 lp_rast_shade_quads_mask(struct lp_rasterizer_task *task, const struct lp_rast_shader_inputs *inputs, unsigned x, unsigned y, unsigned mask) argument 483 lp_rast_begin_query(struct lp_rasterizer_task *task, const union lp_rast_cmd_arg arg) argument 500 lp_rast_end_query(struct lp_rasterizer_task *task, const union lp_rast_cmd_arg arg) argument 512 lp_rast_set_state(struct lp_rasterizer_task *task, const union lp_rast_cmd_arg arg) argument 577 lp_rast_tile_end(struct lp_rasterizer_task *task) argument 636 do_rasterize_bin(struct lp_rasterizer_task *task, const struct cmd_bin *bin) argument 661 rasterize_bin(struct lp_rasterizer_task *task, const struct cmd_bin *bin ) argument 701 rasterize_scene(struct lp_rasterizer_task *task, struct lp_scene *scene) argument 802 struct lp_rasterizer_task *task = (struct lp_rasterizer_task *) init_data; local 897 struct lp_rasterizer_task *task = &rast->tasks[i]; local [all...] |
/external/chromium_org/base/android/java/src/org/chromium/base/ |
H A D | ThreadUtils.java | 66 FutureTask<Void> task = new FutureTask<Void>(r, null); 67 postOnUiThread(task); 69 task.get(); 100 FutureTask<T> task = new FutureTask<T>(c); 101 runOnUiThread(task); 103 return task.get(); 113 * @param task The FutureTask to run 114 * @return The queried task (to aid inline construction) 116 public static <T> FutureTask<T> runOnUiThread(FutureTask<T> task) { argument 118 task 157 postOnUiThread(FutureTask<T> task) argument 168 postOnUiThread(Runnable task) argument 179 postOnUiThreadDelayed(Runnable task, long delayMillis) argument [all...] |
/external/chromium_org/third_party/WebKit/Source/core/dom/ |
H A D | MainThreadTaskRunner.cpp | 41 PerformTaskContext(WeakPtr<MainThreadTaskRunner> runner, PassOwnPtr<ExecutionContextTask> task, bool isInspectorTask) argument 43 , m_task(task) 80 void MainThreadTaskRunner::postTask(PassOwnPtr<ExecutionContextTask> task) argument 82 if (!task->taskNameForInstrumentation().isEmpty()) 83 InspectorInstrumentation::didPostExecutionContextTask(m_context, task.get()); 84 callOnMainThread(PerformTaskContext::didReceiveTask, new PerformTaskContext(m_weakFactory.createWeakPtr(), task, false)); 87 void MainThreadTaskRunner::postInspectorTask(PassOwnPtr<ExecutionContextTask> task) argument 89 callOnMainThread(PerformTaskContext::didReceiveTask, new PerformTaskContext(m_weakFactory.createWeakPtr(), task, true)); 92 void MainThreadTaskRunner::perform(PassOwnPtr<ExecutionContextTask> task, bool isInspectorTask) argument 95 m_pendingTasks.append(task); 126 OwnPtr<ExecutionContextTask> task = m_pendingTasks[0].release(); local [all...] |