Home
last modified time | relevance | path

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

12345678910>>...33

/external/tensorflow/tensorflow/lite/delegates/gpu/metal/kernels/
DBUILD25 "//tensorflow/lite/delegates/gpu/common/tasks:add_test_util",
48 "//tensorflow/lite/delegates/gpu/common/tasks:concat_test_util",
71 "//tensorflow/lite/delegates/gpu/common/tasks:conv_metal",
72 "//tensorflow/lite/delegates/gpu/common/tasks:conv_powervr_test_util",
73 "//tensorflow/lite/delegates/gpu/common/tasks:winograd",
96 "//tensorflow/lite/delegates/gpu/common/tasks:conv_weights_converter_test_util",
119 "//tensorflow/lite/delegates/gpu/common/tasks:depthwise_conv_3x3_stride_h2_test_util",
120 "//tensorflow/lite/delegates/gpu/common/tasks:depthwise_conv_3x3_test_util",
121 "//tensorflow/lite/delegates/gpu/common/tasks:depthwise_conv_test_util",
144 "//tensorflow/lite/delegates/gpu/common/tasks:elementwise_test_util",
[all …]
/external/tensorflow/tensorflow/lite/delegates/gpu/common/selectors/
DBUILD103 "//tensorflow/lite/delegates/gpu/common/tasks:elementwise",
104 "//tensorflow/lite/delegates/gpu/common/tasks:mean_stddev_normalization",
105 "//tensorflow/lite/delegates/gpu/common/tasks:transpose",
121 "//tensorflow/lite/delegates/gpu/common/tasks:add",
122 "//tensorflow/lite/delegates/gpu/common/tasks:concat_xy",
123 "//tensorflow/lite/delegates/gpu/common/tasks:concat_z",
124 "//tensorflow/lite/delegates/gpu/common/tasks:depthwise_conv",
125 "//tensorflow/lite/delegates/gpu/common/tasks:lstm",
126 "//tensorflow/lite/delegates/gpu/common/tasks:max_unpooling",
127 "//tensorflow/lite/delegates/gpu/common/tasks:padding",
[all …]
/external/rust/crates/futures/tests/
Dstream_select_all.rs9 let mut tasks = SelectAll::new(); in is_terminated() localVariable
11 assert_eq!(tasks.is_terminated(), false); in is_terminated()
12 assert_eq!(tasks.poll_next_unpin(&mut cx), Poll::Ready(None)); in is_terminated()
13 assert_eq!(tasks.is_terminated(), true); in is_terminated()
16 assert_eq!(tasks.is_empty(), true); in is_terminated()
17 assert_eq!(tasks.len(), 0); in is_terminated()
19 tasks.push(future::ready(1).into_stream()); in is_terminated()
21 assert_eq!(tasks.is_empty(), false); in is_terminated()
22 assert_eq!(tasks.len(), 1); in is_terminated()
24 assert_eq!(tasks.is_terminated(), false); in is_terminated()
[all …]
Dfutures_unordered.rs16 let mut tasks = FuturesUnordered::new(); in is_terminated() localVariable
18 assert_eq!(tasks.is_terminated(), false); in is_terminated()
19 assert_eq!(tasks.poll_next_unpin(&mut cx), Poll::Ready(None)); in is_terminated()
20 assert_eq!(tasks.is_terminated(), true); in is_terminated()
23 assert_eq!(tasks.is_empty(), true); in is_terminated()
24 assert_eq!(tasks.len(), 0); in is_terminated()
25 assert_eq!(tasks.iter_mut().len(), 0); in is_terminated()
27 tasks.push(future::ready(1)); in is_terminated()
29 assert_eq!(tasks.is_empty(), false); in is_terminated()
30 assert_eq!(tasks.len(), 1); in is_terminated()
[all …]
/external/tensorflow/tensorflow/lite/delegates/gpu/common/selectors/default/
DBUILD19 "//tensorflow/lite/delegates/gpu/common/tasks:conv_buffer_1x1",
20 "//tensorflow/lite/delegates/gpu/common/tasks:conv_constants",
21 "//tensorflow/lite/delegates/gpu/common/tasks:conv_metal",
22 "//tensorflow/lite/delegates/gpu/common/tasks:conv_powervr",
23 "//tensorflow/lite/delegates/gpu/common/tasks:conv_weights_converter",
37 "//tensorflow/lite/delegates/gpu/common/tasks:convolution_transposed",
38 "//tensorflow/lite/delegates/gpu/common/tasks:convolution_transposed_3x3",
39 "//tensorflow/lite/delegates/gpu/common/tasks:convolution_transposed_3x3_thin",
40 "//tensorflow/lite/delegates/gpu/common/tasks:convolution_transposed_4x4",
41 "//tensorflow/lite/delegates/gpu/common/tasks:convolution_transposed_thin",
[all …]
/external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/scheduling/
DLimitingCoroutineDispatcherStressTest.kt27 val tasks = ArrayList<Deferred<*>>(iterations * 2) in <lambda>() constant
29 tasks += task(cpuView, 3) in <lambda>()
30 tasks += task(cpuView2, 3) in <lambda>()
33 tasks.awaitAll() in <lambda>()
38 val tasks = ArrayList<Deferred<*>>(iterations * 2) in <lambda>() constant
40 tasks += task(cpuView, 4) in <lambda>()
41 tasks += task(blocking, 4) in <lambda>()
44 tasks.awaitAll() in <lambda>()
/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/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/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/guava/android/guava-tests/test/com/google/common/util/concurrent/
DWrappingExecutorServiceTest.java95 List<Callable<String>> tasks = createTasks(3); in testInvokeAll() local
99 List<Future<String>> futures = testExecutor.invokeAll(tasks); in testInvokeAll()
108 List<Future<String>> futures = testExecutor.invokeAll(tasks, timeout, unit); in testInvokeAll()
115 List<Callable<String>> tasks = createTasks(3); in testInvokeAny() local
119 String s = testExecutor.invokeAny(tasks); in testInvokeAny()
128 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/guava/guava-tests/test/com/google/common/util/concurrent/
DWrappingExecutorServiceTest.java95 List<Callable<String>> tasks = createTasks(3); in testInvokeAll() local
99 List<Future<String>> futures = testExecutor.invokeAll(tasks); in testInvokeAll()
108 List<Future<String>> futures = testExecutor.invokeAll(tasks, timeout, unit); in testInvokeAll()
115 List<Callable<String>> tasks = createTasks(3); in testInvokeAny() local
119 String s = testExecutor.invokeAny(tasks); in testInvokeAny()
128 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/dagger2/java/dagger/hilt/android/plugin/src/main/kotlin/dagger/hilt/android/plugin/
DHiltTransformTestClassesTask.kt30 import org.gradle.api.tasks.Classpath in <lambda>()
31 import org.gradle.api.tasks.OutputDirectory in <lambda>()
32 import org.gradle.api.tasks.TaskAction in <lambda>()
33 import org.gradle.api.tasks.TaskProvider in <lambda>()
34 import org.gradle.api.tasks.compile.JavaCompile in <lambda>()
35 import org.gradle.api.tasks.testing.Test in <lambda>()
40 import org.jetbrains.kotlin.gradle.tasks.KotlinCompile in <lambda>()
135 val testCompileTaskProvider = project.tasks.named( in <lambda>()
144 val kotlinCompileTaskProvider = project.tasks.named( in <lambda>()
153 val hiltTransformProvider = project.tasks.register( in <lambda>()
[all …]
/external/tensorflow/tensorflow/core/data/service/
Ddispatcher_state_test.cc222 std::vector<std::shared_ptr<const Task>> tasks; in TEST() local
223 TF_EXPECT_OK(state.TasksForJob(job_id, tasks)); in TEST()
224 EXPECT_THAT(tasks, IsEmpty()); in TEST()
279 std::vector<std::shared_ptr<const Task>> tasks; in TEST() local
280 TF_EXPECT_OK(state.TasksForJob(job_id, tasks)); in TEST()
281 EXPECT_THAT(tasks, SizeIs(1)); in TEST()
284 std::vector<std::shared_ptr<const Task>> tasks; in TEST() local
285 TF_EXPECT_OK(state.TasksForWorker(worker_address, tasks)); in TEST()
286 EXPECT_EQ(1, tasks.size()); in TEST()
302 std::vector<std::shared_ptr<const Task>> tasks; in TEST() local
[all …]
/external/tensorflow/tensorflow/lite/delegates/gpu/cl/kernels/
DBUILD23 "//tensorflow/lite/delegates/gpu/common/tasks:add_test_util",
58 "//tensorflow/lite/delegates/gpu/common/tasks:concat_test_util",
75 "//tensorflow/lite/delegates/gpu/common/tasks:conv_buffer_1x1",
92 "//tensorflow/lite/delegates/gpu/common/tasks:conv_constants",
109 "//tensorflow/lite/delegates/gpu/common/tasks:conv_powervr_test_util",
126 "//tensorflow/lite/delegates/gpu/common/tasks:conv_weights_converter_test_util",
164 "//tensorflow/lite/delegates/gpu/common/tasks:convolution_transposed_test_util",
182 "//tensorflow/lite/delegates/gpu/common/tasks:convolution_transposed_3x3",
199 "//tensorflow/lite/delegates/gpu/common/tasks:convolution_transposed_3x3_thin",
217 "//tensorflow/lite/delegates/gpu/common/tasks:convolution_transposed_4x4_test_util",
[all …]
/external/guava/guava-testlib/src/com/google/common/util/concurrent/testing/
DSameThreadScheduledExecutorService.java98 public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks) in invokeAll() argument
100 Preconditions.checkNotNull(tasks, "tasks must not be null!"); in invokeAll()
101 return delegate.invokeAll(tasks); in invokeAll()
106 Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) in invokeAll() argument
108 Preconditions.checkNotNull(tasks, "tasks must not be null!"); in invokeAll()
110 return delegate.invokeAll(tasks, timeout, unit); in invokeAll()
114 public <T> T invokeAny(Collection<? extends Callable<T>> tasks) in invokeAny() argument
116 Preconditions.checkNotNull(tasks, "tasks must not be null!"); in invokeAny()
117 return delegate.invokeAny(tasks); in invokeAny()
121 public <T> T invokeAny(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) in invokeAny() argument
[all …]
/external/guava/android/guava-testlib/src/com/google/common/util/concurrent/testing/
DSameThreadScheduledExecutorService.java98 public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks) in invokeAll() argument
100 Preconditions.checkNotNull(tasks, "tasks must not be null!"); in invokeAll()
101 return delegate.invokeAll(tasks); in invokeAll()
106 Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) in invokeAll() argument
108 Preconditions.checkNotNull(tasks, "tasks must not be null!"); in invokeAll()
110 return delegate.invokeAll(tasks, timeout, unit); in invokeAll()
114 public <T> T invokeAny(Collection<? extends Callable<T>> tasks) in invokeAny() argument
116 Preconditions.checkNotNull(tasks, "tasks must not be null!"); in invokeAny()
117 return delegate.invokeAny(tasks); in invokeAny()
121 public <T> T invokeAny(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) in invokeAny() argument
[all …]
/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/guava/guava/src/com/google/common/util/concurrent/
DWrappingExecutorService.java82 private <T> ImmutableList<Callable<T>> wrapTasks(Collection<? extends Callable<T>> tasks) {
84 for (Callable<T> task : tasks) {
112 public final <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks)
114 return delegate.invokeAll(wrapTasks(tasks));
119 Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit)
121 return delegate.invokeAll(wrapTasks(tasks), timeout, unit);
125 public final <T> T invokeAny(Collection<? extends Callable<T>> tasks)
127 return delegate.invokeAny(wrapTasks(tasks));
131 public final <T> T invokeAny(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit)
133 return delegate.invokeAny(wrapTasks(tasks), timeout, unit);
DForwardingExecutorService.java53 public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks) in invokeAll() argument
55 return delegate().invokeAll(tasks); in invokeAll()
60 Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) in invokeAll() argument
62 return delegate().invokeAll(tasks, timeout, unit); in invokeAll()
66 public <T> T invokeAny(Collection<? extends Callable<T>> tasks) in invokeAny() argument
68 return delegate().invokeAny(tasks); in invokeAny()
72 public <T> T invokeAny(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) in invokeAny() argument
74 return delegate().invokeAny(tasks, timeout, unit); in invokeAny()
/external/guava/android/guava/src/com/google/common/util/concurrent/
DWrappingExecutorService.java82 private <T> ImmutableList<Callable<T>> wrapTasks(Collection<? extends Callable<T>> tasks) {
84 for (Callable<T> task : tasks) {
112 public final <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks)
114 return delegate.invokeAll(wrapTasks(tasks));
119 Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit)
121 return delegate.invokeAll(wrapTasks(tasks), timeout, unit);
125 public final <T> T invokeAny(Collection<? extends Callable<T>> tasks)
127 return delegate.invokeAny(wrapTasks(tasks));
131 public final <T> T invokeAny(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit)
133 return delegate.invokeAny(wrapTasks(tasks), timeout, unit);
DForwardingExecutorService.java53 public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks) in invokeAll() argument
55 return delegate().invokeAll(tasks); in invokeAll()
60 Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) in invokeAll() argument
62 return delegate().invokeAll(tasks, timeout, unit); in invokeAll()
66 public <T> T invokeAny(Collection<? extends Callable<T>> tasks) in invokeAny() argument
68 return delegate().invokeAny(tasks); in invokeAny()
72 public <T> T invokeAny(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) in invokeAny() argument
74 return delegate().invokeAny(tasks, timeout, unit); in invokeAny()
/external/angle/src/libANGLE/
DWorkerThread_unittest.cpp34 std::array<std::shared_ptr<TestTask>, 4> tasks = { in TEST() local
38 {WorkerThreadPool::PostWorkerTask(pool, tasks[0]), in TEST()
39 WorkerThreadPool::PostWorkerTask(pool, tasks[1]), in TEST()
40 WorkerThreadPool::PostWorkerTask(pool, tasks[2]), in TEST()
41 WorkerThreadPool::PostWorkerTask(pool, tasks[3])}}; in TEST()
45 for (const auto &task : tasks) in TEST()
/external/rust/crates/tokio/src/runtime/
Dbasic_scheduler.rs42 tasks: Option<Tasks>, field
103 tasks: RefCell<Tasks>, field
134 tasks: Some(Tasks { in new()
226 .tasks in block_on()
234 .tasks in block_on()
261 let removed = context.tasks.borrow_mut().owned.remove(ptr); in block_on()
304 let Context { tasks, .. } = self.context.take().expect("context missing"); in enter()
305 self.scheduler.tasks = Some(tasks.into_inner()); in enter()
310 let tasks = scheduler.tasks.take().expect("invalid state"); in enter() localVariable
315 tasks: RefCell::new(tasks), in enter()
[all …]
/external/tensorflow/tensorflow/core/protobuf/
Ddevice_filters.proto29 // Configure device filters for remote tasks in the cluster. When associated
41 // job { name: 'worker' tasks { key: 0 value: 'worker1:2222' }
42 // tasks { key: 1 value: 'worker2:2222' } }
43 // job { name: 'ps' tasks { key: 0 value: 'ps0:2222' }
44 // tasks { key: 1 value: 'ps1:2222' } }
46 // Set device filters to isolate worker tasks:
49 // job { name: 'worker' tasks { key: 0
52 // tasks { key: 1
61 // Defines the device filters for tasks in a job.
67 map<int32, TaskDeviceFilters> tasks = 2; field
/external/python/parse_type/tasks/_vendor/
DREADME.rst1 tasks/_vendor: Bundled vendor parts -- needed by tasks
4 This directory contains bundled archives that may be needed to run the tasks.
11 python -m tasks/_vendor/invoke.zip --help
12 python -m tasks/_vendor/invoke.zip --version
22 python ${HERE}/../tasks/_vendor/invoke.zip $*
35 %PYTHON% %HERE%../tasks/_vendor/invoke.zip "%*"

12345678910>>...33