| /cts/suite/audio_quality/lib/src/ |
| GenericFactory.cpp | 19 #include "task/TaskAll.h"
28 TaskGeneric* task; local
31 task = new TaskBatch();
34 task = new TaskCase();
37 task = new TaskSequential();
40 task = new TaskProcess();
43 task = new TaskInput();
46 task = new TaskOutput();
49 task = new TaskSound();
52 task = new TaskSave()
[all...] |
| /ndk/sources/cxx-stl/llvm-libc++/libcxx/test/utilities/function.objects/bind/func.bind/func.bind.bind/ |
| copy.pass.cpp | 31 auto task = std::bind(fnc, 2.f, 4.f); local
32 auto task2(task);
33 assert(task() == 16);
|
| /external/chromium/base/threading/ |
| worker_pool_win.cc | 8 #include "base/task.h"
15 Task* task = static_cast<Task*>(param); local
16 task->Run();
17 delete task;
24 Task* task, bool task_is_slow) {
25 task->SetBirthPlace(from_here);
31 if (!QueueUserWorkItem(WorkItemCallback, task, flags))
[all...] |
| /external/chromium_org/chrome/browser/metrics/variations/ |
| variations_request_scheduler_unittest.cc | 23 const base::Closure task = base::Bind(&DoNothing); local
24 VariationsRequestScheduler scheduler(task);
|
| /external/chromium_org/chrome/browser/resources/task_manager/ |
| preload.js | 13 * @param {Array of task} tasks The array of updated task
16 var task = {type: 'change', start: start, length: length, tasks: tasks};
18 if (taskmanager) taskmanager.processTaskChange(task);
|
| /cts/suite/audio_quality/test/ |
| ModelBuilderTest.cpp | 19 #include <task/ModelBuilder.h>
53 TaskGeneric* task = mModelBuilder.parseTestDescriptionXml(xmlFile, true); local
54 ASSERT_TRUE(task == NULL);
56 delete task;
61 TaskGeneric* task = mModelBuilder.parseTestDescriptionXml(xmlFile); local
62 ASSERT_TRUE(task == NULL);
63 delete task;
68 TaskGeneric* task = mModelBuilder.parseTestDescriptionXml(xmlFile); local
69 ASSERT_TRUE(task == NULL);
70 delete task;
75 TaskGeneric* task = mModelBuilder.parseTestDescriptionXml(xmlFile); local
82 TaskGeneric* task = mModelBuilder.parseTestDescriptionXml(xmlFile); local
[all...] |
| /external/emma/ant/ant14/com/vladium/emma/ |
| emmaTask.java | 50 final NestedTask task = (NestedTask) m_tasks.remove (0); local
55 setTaskName (task.getTaskName ());
57 task.execute ();
86 protected NestedTask addTask (final NestedTask task, final String pseudoName)
88 initTask (task, pseudoName);
90 m_tasks.add (task);
91 return task;
94 protected void initTask (final NestedTask task, final String pseudoName)
96 task.setTaskName (pseudoName);
97 task.setProject (getProject ())
[all...] |
| /external/apache-harmony/x-net/src/test/impl/java.injected/org/apache/harmony/xnet/provider/jsse/ |
| DelegatedTaskTest.java | 36 DelegatedTask task = new DelegatedTask(null, protocol, null); local
37 task.run();
|
| /external/jmonkeyengine/engine/src/core/com/jme3/scene/control/ |
| UpdateControl.java | 61 * Enqueues a task/callable object to execute in the jME3
65 AppTask<V> task = new AppTask<V>(callable); local
66 taskQueue.add(task);
67 return task;
72 AppTask<?> task = taskQueue.poll(); local
74 if (task == null) break;
75 while (task.isCancelled()) {
76 task = taskQueue.poll();
77 if (task == null) break toploop;
79 task.invoke()
[all...] |
| /external/chromium/base/ |
| task_queue.cc | 18 void TaskQueue::Push(Task* task) {
19 DCHECK(task);
21 // Add the task to the back of the queue.
22 queue_.push_back(task);
39 std::deque<Task*> ready;
43 std::deque<Task*>::const_iterator task; local
44 for (task = ready.begin(); task != ready.end(); ++task)
[all...] |
| /external/chromium_org/base/ |
| at_exit.cc | 51 void AtExitManager::RegisterTask(base::Closure task) {
58 g_top_manager->stack_.push(task);
71 base::Closure task = g_top_manager->stack_.top(); local
72 task.Run();
|
| pending_task.h | 18 // Contains data about a pending task. Stored in TaskQueue and DelayedTaskQueue
25 const Closure& task);
27 const Closure& task,
35 // The task to run.
36 Closure task; member in struct:base::PendingTask
|
| 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 = *i local
[all...] |
| deferred_sequenced_task_runner.h | 31 const Closure& task,
38 const Closure& task,
42 // deferred tasks are posted with their initial delay, meaning that the task
53 Closure task; member in struct:base::DeferredSequencedTaskRunner::DeferredTask
54 // The delay this task was initially posted with.
61 // Creates a |Task| object and adds it to |deferred_tasks_queue_|.
63 const Closure& task,
|
| /external/chromium_org/extensions/common/ |
| one_shot_event.cc | 20 const base::Closure& task)
21 : from_here(from_here), runner(runner), task(task) {
26 base::Closure task; member in struct:extensions::OneShotEvent::TaskInfo
37 const base::Closure& task) const {
38 Post(from_here, task, base::MessageLoopProxy::current());
42 const base::Closure& task,
47 runner->PostTask(from_here, task);
49 tasks_.push_back(TaskInfo(from_here, runner, task));
66 tasks_[i].runner->PostTask(tasks_[i].from_here, tasks_[i].task);
[all...] |
| /external/chromium_org/jingle/glue/ |
| task_pump_unittest.cc | 24 MockTask* task = new MockTask(&task_pump); local
26 // talk_base::Task.
28 EXPECT_CALL(*task, ProcessStart()).WillOnce(Return(TASK_STATE_DONE));
29 task->Start();
36 MockTask* task = new MockTask(&task_pump); local
38 // talk_base::Task.
40 ON_CALL(*task, ProcessStart()).WillByDefault(Return(TASK_STATE_ERROR));
41 EXPECT_CALL(*task, ProcessStart()).Times(0);
42 task->Start();
|
| /external/chromium_org/sandbox/linux/services/ |
| thread_helpers_unittests.cc | 40 fd_ = open("/proc/self/task/", O_RDONLY | O_DIRECTORY);
54 ScopedProcSelfTask task; local
55 ASSERT_TRUE(ThreadHelpers::IsSingleThreaded(task.fd()));
59 ASSERT_FALSE(ThreadHelpers::IsSingleThreaded(task.fd()));
63 ScopedProcSelfTask task; local
64 ASSERT_TRUE(ThreadHelpers::IsSingleThreaded(task.fd()));
70 ASSERT_FALSE(ThreadHelpers::IsSingleThreaded(task.fd()));
75 ScopedProcSelfTask task; local
76 ASSERT_TRUE(ThreadHelpers::IsSingleThreaded(task.fd()));
83 ASSERT_FALSE(ThreadHelpers::IsSingleThreaded(task.fd()))
[all...] |
| /external/guava/guava-tests/test/com/google/common/util/concurrent/ |
| 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.isCancelled())
[all...] |
| /packages/apps/Gallery2/src/com/android/gallery3d/filtershow/pipeline/ |
| ProcessingTaskController.java | 42 ProcessingTask task = mTasks.get(msg.what);
43 if (task != null) {
45 task.onResult((ProcessingTask.Result) msg.obj);
47 task.onUpdate((ProcessingTask.Update) msg.obj);
57 ProcessingTask task = mTasks.get(msg.what); local
58 if (task != null) {
59 task.processRequest((ProcessingTask.Request) msg.obj);
89 public void add(ProcessingTask task) {
90 task.added(this);
91 mTasks.put(task.getType(), task) local
[all...] |
| /external/chromium_org/base/android/java/src/org/chromium/base/ |
| ThreadUtils.java | 66 FutureTask<Void> task = new FutureTask<Void>(r, null); local
67 postOnUiThread(task);
69 task.get();
100 FutureTask<T> task = new FutureTask<T>(c); local
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) {
118 task.run()
[all...] |
| /bionic/libc/kernel/common/linux/ |
| mutex.h | 36 struct task_struct *task; member in struct:mutex_waiter
|
| /development/ndk/platforms/android-3/include/linux/ |
| mutex.h | 31 struct task_struct *task; member in struct:mutex_waiter
|
| /external/chromium/chrome/browser/ |
| transport_security_persister.cc | 32 Task* task = NewRunnableMethod(this, local
34 BrowserThread::PostDelayedTask(BrowserThread::FILE, FROM_HERE, task, 1000);
73 Task* task = save_coalescer_.NewRunnableMethod(
75 MessageLoop::current()->PostDelayedTask(FROM_HERE, task, 1000);
|
| /external/chromium_org/base/test/android/javatests/src/org/chromium/base/test/util/ |
| InstrumentationUtils.java | 23 FutureTask<R> task = new FutureTask<R>(callable); local
24 instrumentation.runOnMainSync(task);
26 return task.get();
|
| /external/chromium_org/base/test/ |
| test_pending_task.h | 22 const Closure& task,
31 // Returns true if this task is nestable and |other| isn't, or if
32 // this task's time to run is strictly earlier than |other|'s time
50 Closure task; member in struct:base::TestPendingTask
|
