Home
last modified time | relevance | path

Searched refs:tasks (Results 1 – 25 of 229) sorted by relevance

12345678910

/external/libchrome/base/
Dtracked_objects_unittest.cc80 ASSERT_EQ(1u, process_data_phase.tasks.size()); in ExpectSimpleProcessData()
82 EXPECT_EQ(kFile, process_data_phase.tasks[0].birth.location.file_name); in ExpectSimpleProcessData()
84 process_data_phase.tasks[0].birth.location.function_name); in ExpectSimpleProcessData()
86 process_data_phase.tasks[0].birth.location.line_number); in ExpectSimpleProcessData()
88 EXPECT_EQ(birth_thread, process_data_phase.tasks[0].birth.thread_name); in ExpectSimpleProcessData()
90 EXPECT_EQ(count, process_data_phase.tasks[0].death_data.count); in ExpectSimpleProcessData()
92 process_data_phase.tasks[0].death_data.run_duration_sum); in ExpectSimpleProcessData()
93 EXPECT_EQ(run_ms, process_data_phase.tasks[0].death_data.run_duration_max); in ExpectSimpleProcessData()
95 process_data_phase.tasks[0].death_data.run_duration_sample); in ExpectSimpleProcessData()
97 process_data_phase.tasks[0].death_data.queue_duration_sum); in ExpectSimpleProcessData()
[all …]
/external/autotest/site_utils/suite_scheduler/
Dbase_event_unittest.py81 tasks = [FakeTask(*task, pymox=self.mox) for task in self._TASKS]
82 tasks.append(FakeTask(*self._TASKS[0], pymox=self.mox))
86 event.tasks = tasks
87 self.assertEquals(len(event.tasks), len(self._TASKS))
92 tasks = [FakeTask(*task, pymox=self.mox) for task in self._TASKS]
93 for task in tasks:
99 event.tasks = tasks
105 for task in tasks:
114 tasks = [FakeTask(*task, pymox=self.mox) for task in self._TASKS]
115 all_tasks = tasks + [FakeOneShot(*self._TASKS[0], pymox=self.mox)]
[all …]
Dbase_event.py102 def tasks(self): member in BaseEvent
106 @tasks.setter
107 def tasks(self, iterable_of_tasks): member in BaseEvent
125 self.tasks = to_merge.tasks
174 return list(self.tasks)
Ddriver.py84 tasks = self.TasksFromConfig(config)
85 for keyword, task_list in tasks.iteritems():
87 events[keyword].tasks = task_list
105 tasks = {}
114 tasks.setdefault(keyword, []).append(new_task)
115 return tasks
Dtimed_event.py34 return self._deadline != other._deadline or self.tasks != other.tasks
38 return self._deadline == other._deadline and self.tasks == other.tasks
126 return [task for task in self.tasks
216 return [task for task in self.tasks
/external/chromium-trace/catapult/perf_insights/perf_insights/endpoints/cloud_mapper/
Dtask.py68 tasks = {}
90 tasks[task_id] = {'status': 'IN_PROGRESS'}
109 'tasks': json.dumps(tasks),
122 tasks = json.loads(self.request.get('tasks'))
132 for task_id, task_values in tasks.iteritems():
140 tasks[task_id]['status'] = 'DONE'
144 logging.info("Tasks: %s" % str(tasks))
154 'tasks': json.dumps(tasks),
159 self._CancelTasks(tasks)
162 for task_id, _ in tasks.iteritems():
[all …]
/external/guava/guava-bootstrap/src/java/util/concurrent/
DAbstractExecutorService.java38 private <T> T doInvokeAny(Collection<? extends Callable<T>> tasks, in doInvokeAny() argument
41 if (tasks == null) in doInvokeAny()
43 int ntasks = tasks.size(); in doInvokeAny()
53 Iterator<? extends Callable<T>> it = tasks.iterator(); in doInvokeAny()
104 public <T> T invokeAny(Collection<? extends Callable<T>> tasks) in invokeAny() argument
107 return doInvokeAny(tasks, false, 0); in invokeAny()
114 public <T> T invokeAny(Collection<? extends Callable<T>> tasks, in invokeAny() argument
117 return doInvokeAny(tasks, true, unit.toNanos(timeout)); in invokeAny()
120 public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks) in invokeAll() argument
122 if (tasks == null) in invokeAll()
[all …]
DExecutorService.java34 <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks) in invokeAll() argument
38 Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) in invokeAll() argument
41 <T> T invokeAny(Collection<? extends Callable<T>> tasks) in invokeAny() argument
45 Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) in invokeAny() argument
/external/guava/guava-tests/test/com/google/common/util/concurrent/
DWrappingExecutorServiceTest.java96 List<Callable<String>> tasks = createTasks(3); in testInvokeAll() local
100 List<Future<String>> futures = testExecutor.invokeAll(tasks); in testInvokeAll()
109 List<Future<String>> futures = testExecutor.invokeAll(tasks, timeout, unit); in testInvokeAll()
116 List<Callable<String>> tasks = createTasks(3); in testInvokeAny() local
120 String s = testExecutor.invokeAny(tasks); in testInvokeAny()
129 String s = testExecutor.invokeAny(tasks, timeout, unit); in testInvokeAny()
213 public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks) in invokeAll() argument
216 assertTaskWrapped(tasks); in invokeAll()
217 return inline.invokeAll(tasks); in invokeAll()
222 Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) in invokeAll() argument
[all …]
/external/autotest/scheduler/
Dmonitor_db_cleanup_test.py43 tasks = models.SpecialTask.objects.all()
44 self.assertEquals(len(tasks), 1)
45 self.assertEquals(tasks[0].host.id, 1)
46 self.assertEquals(tasks[0].task, models.SpecialTask.Task.VERIFY)
69 tasks = models.SpecialTask.objects.all()
71 self.assertEquals(len(tasks), 2)
72 self.assertTrue(tasks[0].host.id in (1, 4, 5, 6))
73 self.assertTrue(tasks[1].host.id in (1, 4, 5, 6))
74 self.assertEquals(tasks[0].task, models.SpecialTask.Task.VERIFY)
75 self.assertEquals(tasks[1].task, models.SpecialTask.Task.VERIFY)
Dscheduler_models_unittest.py376 def _check_special_tasks(self, tasks, task_types): argument
377 self.assertEquals(len(tasks), len(task_types))
378 for task, (task_type, queue_entry_id) in zip(tasks, task_types):
388 tasks = self._test_pre_job_tasks_helper()
390 self._check_special_tasks(tasks, [(models.SpecialTask.Task.RESET, 1)])
398 tasks = self._test_pre_job_tasks_helper()
400 self._check_special_tasks(tasks, [(models.SpecialTask.Task.RESET, 1)])
406 tasks = self._test_pre_job_tasks_helper()
408 self._check_special_tasks(tasks, [(models.SpecialTask.Task.RESET, 1)])
416 tasks = self._test_pre_job_tasks_helper()
[all …]
Dhost_scheduler_unittests.py159 tasks = self.job_query_manager.get_prioritized_special_tasks()
160 self.assertTrue(tasks[1].queue_entry_id is None and
161 tasks[0].queue_entry_id == hqe.id)
165 tasks = self.job_query_manager.get_prioritized_special_tasks()
166 self.assertTrue(tasks[0].id == task1.id)
221 tasks = self.job_query_manager.get_prioritized_special_tasks(
223 self.assertTrue(tasks == [])
224 tasks = self.job_query_manager.get_prioritized_special_tasks(
226 self.assertTrue(tasks[0].id == task.id)
228 tasks = self.job_query_manager.get_prioritized_special_tasks(
[all …]
/external/guava/guava-testlib/src/com/google/common/util/concurrent/testing/
DSameThreadScheduledExecutorService.java101 Collection<? extends Callable<T>> tasks) throws InterruptedException { in invokeAll() argument
102 Preconditions.checkNotNull(tasks, "tasks must not be null!"); in invokeAll()
103 return delegate.invokeAll(tasks); in invokeAll()
108 Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) in invokeAll() argument
110 Preconditions.checkNotNull(tasks, "tasks must not be null!"); in invokeAll()
112 return delegate.invokeAll(tasks, timeout, unit); in invokeAll()
116 public <T> T invokeAny(Collection<? extends Callable<T>> tasks) in invokeAny() argument
118 Preconditions.checkNotNull(tasks, "tasks must not be null!"); in invokeAny()
119 return delegate.invokeAny(tasks); in invokeAny()
123 public <T> T invokeAny(Collection<? extends Callable<T>> tasks, in invokeAny() argument
[all …]
/external/guava/guava/src/com/google/common/util/concurrent/
DWrappingExecutorService.java84 Collection<? extends Callable<T>> tasks) {
86 for (Callable<T> task : tasks) {
115 Collection<? extends Callable<T>> tasks) throws InterruptedException {
116 return delegate.invokeAll(wrapTasks(tasks));
121 Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit)
123 return delegate.invokeAll(wrapTasks(tasks), timeout, unit);
127 public final <T> T invokeAny(Collection<? extends Callable<T>> tasks)
129 return delegate.invokeAny(wrapTasks(tasks));
134 Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit)
136 return delegate.invokeAny(wrapTasks(tasks), timeout, unit);
DForwardingExecutorService.java55 Collection<? extends Callable<T>> tasks) throws InterruptedException { in invokeAll() argument
56 return delegate().invokeAll(tasks); in invokeAll()
61 Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) in invokeAll() argument
63 return delegate().invokeAll(tasks, timeout, unit); in invokeAll()
67 public <T> T invokeAny(Collection<? extends Callable<T>> tasks) in invokeAny() argument
69 return delegate().invokeAny(tasks); in invokeAny()
74 Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) in invokeAny() argument
76 return delegate().invokeAny(tasks, timeout, unit); in invokeAny()
/external/autotest/contrib/
Dcompare_suite.py151 tasks = tasks_cache.get(self.hostname, None)
152 if not tasks:
153 tasks = models.SpecialTask.objects.filter(
157 tasks_cache[self.hostname] = tasks
158 for task in tasks:
228 tasks = []
230 tasks += [task for task in job.get_all_tasks()
232 if not tasks:
235 task_min = tasks[0]
236 task_max = tasks[0]
[all …]
/external/guava/guava-tests/test/com/google/common/eventbus/
DAsyncEventBusTest.java56 List<Runnable> tasks = executor.getTasks(); in testBasicDistribution() local
57 assertEquals("One event dispatch task should be queued.", 1, tasks.size()); in testBasicDistribution()
59 tasks.get(0).run(); in testBasicDistribution()
73 List<Runnable> tasks = Lists.newArrayList(); field in AsyncEventBusTest.FakeExecutor
77 tasks.add(task); in execute()
81 return tasks; in getTasks()
/external/guice/extensions/service/src/com/google/inject/service/
DCompositeService.java81 final List<Future<State>> tasks = Lists.newArrayList(); in compose()
83 tasks.add(injector.getInstance(service).start()); in compose()
86 return futureGet(tasks, State.STARTED); in compose()
90 final List<Future<State>> tasks = Lists.newArrayList(); in compose() local
92 tasks.add(injector.getInstance(service).stop()); in compose()
95 return futureGet(tasks, State.STOPPED); in compose()
104 private FutureTask<Service.State> futureGet(final List<Future<Service.State>> tasks,
109 for (Future<Service.State> task : tasks) {
/external/vogar/src/vogar/tasks/
DTaskQueue.java17 package vogar.tasks;
39 private final LinkedList<Task> tasks = new LinkedList<Task>(); field in TaskQueue
53 tasks.add(task); in enqueue()
56 public void enqueueAll(Collection<Task> tasks) { in enqueueAll() argument
57 this.tasks.addAll(tasks); in enqueueAll()
61 return new ArrayList<Task>(tasks); in getTasks()
91 for (Task task : tasks) { in printTasks()
120 for (Task task : tasks) { in printProblemTasks()
200 for (Iterator<Task> it = tasks.iterator(); it.hasNext(); ) { in promoteBlockedTasks()
/external/autotest/site_utils/
Djob_history.py150 tasks = models.SpecialTask.objects.filter(
154 self[host_id] = TaskCache(tasks, search_start_time, search_end_time)
161 def __init__(self, tasks=[], start_time=None, end_time=None): argument
164 self.tasks = tasks
180 return [task for task in self.tasks if task.queue_entry and
266 tasks = task_caches.try_get(self.host.id, self.id,
268 if tasks is None:
271 tasks = task_caches.try_get(self.host.id, self.id,
274 tasks = models.SpecialTask.objects.filter(
278 tasks = [task for task in tasks if task.queue_entry and
[all …]
/external/robolectric/v1/src/main/java/com/xtremelabs/robolectric/shadows/
DShadowActivityManager.java17 private List<ActivityManager.RunningTaskInfo> tasks = field in ShadowActivityManager
28 return tasks; in getRunningTasks()
52 public void setTasks(List<ActivityManager.RunningTaskInfo> tasks) { in setTasks() argument
53 this.tasks = tasks; in setTasks()
/external/jmdns/src/javax/jmdns/impl/
DDNSTaskStarter.java13 import javax.jmdns.impl.tasks.RecordReaper;
14 import javax.jmdns.impl.tasks.Responder;
15 import javax.jmdns.impl.tasks.resolver.ServiceInfoResolver;
16 import javax.jmdns.impl.tasks.resolver.ServiceResolver;
17 import javax.jmdns.impl.tasks.resolver.TypeResolver;
18 import javax.jmdns.impl.tasks.state.Announcer;
19 import javax.jmdns.impl.tasks.state.Canceler;
20 import javax.jmdns.impl.tasks.state.Prober;
21 import javax.jmdns.impl.tasks.state.Renewer;
/external/autotest/server/cros/clique_lib/
Dclique_dut_log_collector.py45 tasks = []
52 tasks.append(task)
54 for task in tasks:
56 for task in tasks:
/external/autotest/client/tests/disktest/src/
Ddisktest.c248 int tasks, opt, retcode, pid; in main() local
357 for (tasks = 0; tasks < linear_tasks; tasks++) in main()
361 for (tasks = 0; tasks < random_tasks; tasks++) in main()
370 for (tasks = 0; tasks < linear_tasks + random_tasks + 4; tasks++) { in main()
/external/ltrace/sysdeps/linux-gnu/
Dtrace.c191 if (pids->tasks[i].pid == pid) in get_task_info()
192 return &pids->tasks[i]; in get_task_info()
202 struct pid_task *n = realloc(pids->tasks, in add_task_info()
203 sizeof(*pids->tasks) * ns); in add_task_info()
206 pids->tasks = n; in add_task_info()
209 struct pid_task * task_info = &pids->tasks[pids->count++]; in add_task_info()
354 if (self->pids.tasks[i].pid != 0 in process_stopping_done()
355 && (self->pids.tasks[i].delivered in process_stopping_done()
356 || self->pids.tasks[i].sysret)) in process_stopping_done()
357 continue_process(self->pids.tasks[i].pid); in process_stopping_done()
[all …]

12345678910