Home
last modified time | relevance | path

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

12345678910>>...22

/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 …]
/external/ltp/testcases/kernel/controllers/cpuctl_fj/
Drun_cpuctl_test_fj.sh70 echo $tmppid > $CPUCTL/tasks
71 done < $tmpdir/tasks
140 task=`cat $CPUCTL/tasks | grep "\b$pid\b"`
168 task=`cat $CPUCTL/tmp/tasks`
200 task=`cat $CPUCTL/tmp/tmp1/tasks`
216 echo 1 > $CPUCTL/tmp/tasks
222 tasks=`cat $CPUCTL/tmp/tasks`
223 if [ $tasks -ne 1 ]
238 ./cpuctl_fj_simple_echo 3 $CPUCTL/tmp/tasks
244 tasks=`cat $CPUCTL/tmp/tasks`
[all …]
/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/toolchain-utils/bestflags/
Dsteering_test.py40 def __init__(self, tasks, next_generations): argument
48 Generation.__init__(self, tasks, None)
91 tasks = [IdentifierMockTask(STEERING_TEST_STAGE, t) for t in test_ranges]
92 steering_tasks = set(tasks)
120 tasks = [task for task in generation.Pool()]
123 while tasks:
126 assert task in tasks
127 tasks.remove(task)
148 tasks = [IdentifierMockTask(STEERING_TEST_STAGE, t) for t in test_ranges]
149 steering_tasks = set(tasks)
/external/ltp/testcases/kernel/controllers/io-throttle/
Drun_io_throttle_test.sh51 for tasks in 1 2 4; do
76 if [ $tasks -eq 1 ]; then
81 echo -n ">> testing $tasks parallel $stream per cgroup "
89 /bin/echo $$ > /dev/blockioctl/$MYGROUP/tasks
96 ./iobw -direct $tasks $BUFSIZE $DATASIZE > /tmp/$MYGROUP.out &
99 /bin/echo $$ > /dev/blockioctl/tasks
107 echo "ERROR: error code $ret during test $tasks.$strategy.$i. Exiting test."
115 echo "TPASS Block device I/O bandwidth controller: test $tasks.$strategy.$i PASSED";
117 echo "TFAIL Block device I/O bandwidth controller: test $tasks.$strategy.$i FAILED";
/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.py352 def _check_special_tasks(self, tasks, task_types): argument
353 self.assertEquals(len(tasks), len(task_types))
354 for task, (task_type, queue_entry_id) in zip(tasks, task_types):
364 tasks = self._test_pre_job_tasks_helper()
366 self._check_special_tasks(tasks, [(models.SpecialTask.Task.RESET, 1)])
374 tasks = self._test_pre_job_tasks_helper()
376 self._check_special_tasks(tasks, [(models.SpecialTask.Task.RESET, 1)])
382 tasks = self._test_pre_job_tasks_helper()
384 self._check_special_tasks(tasks, [(models.SpecialTask.Task.RESET, 1)])
392 tasks = self._test_pre_job_tasks_helper()
[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/grpc-grpc-java/core/src/test/java/io/grpc/internal/
DFakeClock.java53 private final PriorityBlockingQueue<ScheduledTask> tasks = field in FakeClock
82 tasks.remove(this); in cancel()
119 tasks.add(task); in schedule()
137 @Override public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks) { in invokeAll() argument
142 Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) { in invokeAll() argument
146 @Override public <T> T invokeAny(Collection<? extends Callable<T>> tasks) { in invokeAny() argument
151 Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) { in invokeAny() argument
219 ScheduledTask task = tasks.peek(); in runDueTasks()
223 if (tasks.remove(task)) { in runDueTasks()
237 for (ScheduledTask task : tasks) { in getDueTasks()
[all …]
/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/tensorflow/tensorflow/python/client/
Dsession_clusterspec_prop_test.py59 job.tasks[0] = server1.target[len('grpc://'):]
60 job.tasks[1] = server2.target[len('grpc://'):]
74 job.tasks[0] = server1.target[len('grpc://'):]
75 job.tasks[1] = server2.target[len('grpc://'):]
102 job.tasks[0] = server1.target[len('grpc://'):]
103 job.tasks[1] = server2.target[len('grpc://'):]
118 job.tasks[0] = server1.target[len('grpc://'):]
119 job.tasks[1] = server2.target[len('grpc://'):]
146 job.tasks[0] = server1.target[len('grpc://'):]
147 job.tasks[1] = server2.target[len('grpc://'):]
[all …]
/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/tensorflow/tensorflow/core/protobuf/
Dcluster.proto34 // job { name: 'local' tasks { key: 0 value: 'localhost:2222' } }
42 // job { name: 'local' tasks { key: 0 value: 'localhost:2222' }
43 // tasks { key: 1 value: 'localhost:2223' } }
53 // job { name: 'worker' tasks { key: 0 value: 'worker1:2222' }
54 // tasks { key: 1 value: 'worker2:2222' }
55 // tasks { key: 2 value: 'worker3:2222' } }
56 // job { name: 'ps' tasks { key: 0 value: 'ps0:2222' }
57 // tasks { key: 1 value: 'ps1:2222' } }
73 // If the `name` field contains "worker", and the `tasks` map contains a
76 map<int32, string> tasks = 2; field
/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.java83 final List<Future<State>> tasks = Lists.newArrayList(); in compose()
85 tasks.add(injector.getInstance(service).start()); in compose()
88 return futureGet(tasks, State.STARTED); in compose()
93 final List<Future<State>> tasks = Lists.newArrayList(); in compose() local
95 tasks.add(injector.getInstance(service).stop()); in compose()
98 return futureGet(tasks, State.STOPPED); in compose()
109 final List<Future<Service.State>> tasks, final Service.State state) {
115 for (Future<Service.State> task : tasks) {
/external/skqp/infra/bots/
DREADME.md10 Files in this directory define a DAG of tasks which run at every Skia commit. A
15 Jobs are collections of related tasks which help define sub-sections of the DAG,
19 The tasks.json file in this directory is the master list of tasks and jobs for
20 the repo. Note that tasks.json is NEVER edited by hand but generated via
23 reads the tasks.json file at each commit to determine which jobs to run. For
24 convenience, gen_tasks.go is provided to generate tasks.json and also to test it
25 for correct syntax and detecting cycles and orphaned tasks. Always edit
26 gen_tasks.go or one of the following input JSON files, rather than tasks.json
40 need to run gen_tasks.go to regenerate tasks.json:
49 tasks.json is unchanged:
[all …]
/external/python/google-api-python-client/samples/tasks_appengine/
Dmain.py39 result = service.tasks().list(tasklist='@default').execute(
41 tasks = result.get('items', [])
42 for task in tasks:
44 self.render_response('index.html', tasks=tasks)
47 self.render_response('index.html', tasks=[], authorize_url=url)
/external/tensorflow/tensorflow/python/distribute/cluster_resolver/
DREADME.slurm3 …res the specification of total number of tasks launched, process ID/rank of the running process, n…
5 …tasks launched is extract from ```SLURM_NTASKS```. The number of tasks per node is extracted from …
22 …tasks will be launched on each node. The jobs are specified in form of a dictionary where the key …
27 tasks {
33 tasks {
36 tasks {
40 tasks {
/external/gemmlowp/meta/
Dlegacy_multi_thread_common.h84 std::int32_t k, std::vector<internal::TaskRect>* tasks) { in PrepareTasks() argument
94 tasks->push_back(TaskRect(0, m, 0, n)); in PrepareTasks()
101 tasks->push_back(TaskRect(i * m_chunk, m_chunk, 0, n)); in PrepareTasks()
104 tasks->push_back(TaskRect(last_m_offset, m - last_m_offset, 0, n)); in PrepareTasks()
108 tasks->push_back(TaskRect(0, m, i * n_chunk, n_chunk)); in PrepareTasks()
111 tasks->push_back(TaskRect(0, m, last_n_offset, n - last_n_offset)); in PrepareTasks()
135 std::vector<Task*> tasks; in MultiThreadedMatrixMatrix() local
138 [&tasks, &task_scratch, lhs, rhs, k, result, result_stride, operation, in MultiThreadedMatrixMatrix()
140 tasks.push_back(new internal::MetaTask<IN_TYPE, OUT_TYPE, F>( in MultiThreadedMatrixMatrix()
144 pool->Execute(tasks); in MultiThreadedMatrixMatrix()
/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/ltp/testcases/kernel/controllers/cpuctl/
Dcpuctl_testplan.txt18 * of this group and it would create no effect on tasks in other group. So a
21 * Even if task is run with different nice value it will affect the tasks in
43 tasks in different groups on the basis of the shares assigned to that group.
46 number of tasks in that group(in this case only 1).
51 respectively. Hence if the tasks are running infinitely they are supposed to
67 of system default tasks which can run any time.
93 Renice all tasks of a group to -20 and let tasks in all other groups run with
99 In this test for the first run the test is run with say n tasks in m groups.
105 In the following three testcases a total tasks are same and each task is
109 Test 06: N X M (N groups with M tasks each)
[all …]
/external/tensorflow/tensorflow/python/training/
Dserver_lib.py286 for job_name, tasks in cluster.items():
287 if isinstance(tasks, (list, tuple)):
288 job_tasks = {i: task for i, task in enumerate(tasks)}
289 elif isinstance(tasks, dict):
290 job_tasks = {i: task for i, task in tasks.items()}
301 i: t for i, t in job_def.tasks.items()}
308 i: t for i, t in job_def.tasks.items()}
472 for job_name, tasks in sorted(self._cluster_spec.items()):
481 for i, task_address in sorted(tasks.items()):
487 job_def.tasks[i] = task_address
/external/libchrome/base/
Dat_exit.cc77 base::stack<base::Closure> tasks; in ProcessCallbacksNow() local
80 tasks.swap(g_top_manager->stack_); in ProcessCallbacksNow()
88 while (!tasks.empty()) { in ProcessCallbacksNow()
89 base::Closure task = tasks.top(); in ProcessCallbacksNow()
91 tasks.pop(); in ProcessCallbacksNow()

12345678910>>...22