Searched refs:task (Results 1 - 25 of 688) sorted by relevance

1234567891011>>

/external/chromium_org/components/domain_reliability/
H A Ddispatcher.cc58 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 DDMTaskRunner.cpp8 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 DDMTaskRunner.h20 void add(CpuTask* task);
21 void addNext(CpuTask* task);
22 void add(GpuTask* task);
/external/chromium_org/third_party/skia/dm/
H A DDMTaskRunner.cpp6 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 Ddeferred_sequenced_task_runner.cc30 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 Dtask_runner.cc24 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 Done_shot_event.cc22 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 DListenableFutureTaskTest.java43 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 DForwardingListeningExecutorService.java39 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 Dtest_pending_task_unittest.cc16 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 Dhistory_index_restore_observer.cc8 const base::Closure& task)
9 : task_(task),
7 HistoryIndexRestoreObserver( const base::Closure& task) argument
/external/chromium_org/google_apis/drive/
H A Dtask_util.cc12 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 Dui_controls_internal_win.h15 // 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 Dworker-thread.cc8 #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 Dcopy.pass.cpp31 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 Dtaskrunner.cc17 #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 DThreadControllerWrapper.java38 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 Dtask_pump_unittest.cc24 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 DMachVMMemory.h27 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 Dthread_helpers_unittests.cc41 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 DemmaTask.java50 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 Dlp_rast.c94 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 Dlp_rast.c94 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 DThreadUtils.java66 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 DMainThreadTaskRunner.cpp41 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...]

Completed in 704 milliseconds

1234567891011>>