| /external/tensorflow/tensorflow/python/kernel_tests/ |
| D | decode_jpeg_op_test.py | 42 parallelism, argument
92 for _ in xrange(parallelism):
127 for parallelism in [1, 100]:
128 duration_decode = self._evalDecodeJpeg('small.jpg', parallelism,
130 duration_decode_crop = self._evalDecodeJpeg('small.jpg', parallelism,
133 'small.jpg', parallelism, num_iters, True, crop_window)
135 name='decode_jpeg_small_p%d' % (parallelism),
139 name='decode_crop_jpeg_small_p%d' % (parallelism),
143 name='decode_after_crop_jpeg_small_p%d' % (parallelism),
151 for parallelism in [1, 100]:
[all …]
|
| D | record_input_test.py | 53 parallelism=1,
70 parallelism=1,
89 parallelism=1,
108 parallelism=2,
137 parallelism=1,
165 parallelism=2,
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/src/scheduling/ |
| D | Deprecated.kt | 79 fun blocking(parallelism: Int = 16): CoroutineDispatcher { in blocking()
80 require(parallelism > 0) { "Expected positive parallelism level, but have $parallelism" } in blocking()
81 return LimitingDispatcher(this, parallelism, null, TASK_PROBABLY_BLOCKING) in blocking()
91 fun limited(parallelism: Int): CoroutineDispatcher { in limited()
92 require(parallelism > 0) { "Expected positive parallelism level, but have $parallelism" } in limited()
93 …require(parallelism <= corePoolSize) { "Expected parallelism level lesser than core pool size ($co… in limited()
94 return LimitingDispatcher(this, parallelism, null, TASK_NON_BLOCKING) in limited()
113 private val parallelism: Int, in createScheduler() constant in kotlinx.coroutines.scheduling.LimitingDispatcher
137 if (inFlight <= parallelism) { in createScheduler()
160 if (inFlightTasks.decrementAndGet() >= parallelism) { in createScheduler()
|
| D | Dispatcher.kt | 59 override fun limitedParallelism(parallelism: Int): CoroutineDispatcher { in execute()
61 return UnlimitedIoScheduler.limitedParallelism(parallelism) in execute()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/internal/ |
| D | LimitedDispatcher.kt | 18 private val parallelism: Int constant in kotlinx.coroutines.internal.LimitedDispatcher
30 override fun limitedParallelism(parallelism: Int): CoroutineDispatcher { in <lambda>()
31 parallelism.checkParallelism() in <lambda>()
32 if (parallelism >= this.parallelism) return this in <lambda>()
33 return super.limitedParallelism(parallelism) in <lambda>()
93 if (runningWorkers >= parallelism) return false in <lambda>()
101 return runningWorkers >= parallelism in <lambda>()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/scheduling/ |
| D | SchedulerTestBase.kt | 81 protected fun blockingDispatcher(parallelism: Int): CoroutineDispatcher { in blockingDispatcher()
83 return _dispatcher!!.blocking(parallelism) in blockingDispatcher()
86 protected fun view(parallelism: Int): CoroutineDispatcher { in view()
88 return _dispatcher!!.limitedParallelism(parallelism) in view()
101 internal fun SchedulerCoroutineDispatcher.blocking(parallelism: Int = 16): CoroutineDispatcher { in blocking()
112 }.limitedParallelism(parallelism) in blocking()
|
| D | DefaultDispatchersTest.kt | 52 val parallelism = Runtime.getRuntime().availableProcessors() in <lambda>() constant
53 val defaultBarrier = CyclicBarrier(parallelism + 1) in <lambda>()
54 repeat(parallelism) { in <lambda>()
|
| /external/tensorflow/tensorflow/compiler/xla/pjrt/ |
| D | transpose_test.cc | 356 void TestTranspose(int parallelism) { in TestTranspose() argument
359 "Transpose", parallelism); in TestTranspose()
366 TransposePlan::Transformation::kNone, parallelism)); in TestTranspose()
451 void BM_Eigen(const TransposeTestCase& bm, int parallelism, in BM_Eigen() argument
453 CHECK_EQ(parallelism, 1); in BM_Eigen()
464 static void BM_Eigen_uint8(const TransposeTestCase& bm, int parallelism, in BM_Eigen_uint8() argument
466 BM_Eigen<uint8_t>(std::move(bm), parallelism, state); in BM_Eigen_uint8()
468 static void BM_Eigen_float(const TransposeTestCase& bm, int parallelism, in BM_Eigen_float() argument
470 BM_Eigen<float>(bm, parallelism, state); in BM_Eigen_float()
474 void BM_Transpose(const TransposeTestCase& bm, int parallelism, in BM_Transpose() argument
[all …]
|
| /external/kotlinx.coroutines/benchmarks/src/jmh/kotlin/benchmarks/ |
| D | SemaphoreBenchmark.kt | 82 enum class SemaphoreBenchDispatcherCreator(val create: (parallelism: Int) -> CoroutineDispatcher) {
83 FORK_JOIN({ parallelism -> ForkJoinPool(parallelism).asCoroutineDispatcher() }), in parallelism() method
84 … EXPERIMENTAL({ parallelism -> Dispatchers.Default }) // TODO doesn't take parallelism into account in parallelism() method
|
| D | ChannelProducerConsumerBenchmark.kt | 130 enum class DispatcherCreator(val create: (parallelism: Int) -> CoroutineDispatcher) {
131 FORK_JOIN({ parallelism -> ForkJoinPool(parallelism).asCoroutineDispatcher() }) in parallelism() method
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/ |
| D | CoroutineDispatcher.kt | 105 public open fun limitedParallelism(parallelism: Int): CoroutineDispatcher { in isDispatchNeeded()
106 parallelism.checkParallelism() in isDispatchNeeded()
107 return LimitedDispatcher(this, parallelism) in isDispatchNeeded()
|
| D | MainCoroutineDispatcher.kt | 56 override fun limitedParallelism(parallelism: Int): CoroutineDispatcher { in toString()
57 parallelism.checkParallelism() in toString()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/concurrent/test/ |
| D | LimitedParallelismConcurrentTest.kt | 16 private val parallelism = atomic(0) constant in kotlinx.coroutines.LimitedParallelismConcurrentTest
19 val value = parallelism.incrementAndGet() in checkParallelism()
22 parallelism.decrementAndGet() in checkParallelism()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/ |
| D | LimitedParallelismStressTest.kt | 28 private val parallelism = AtomicInteger(0) constant in kotlinx.coroutines.LimitedParallelismStressTest
31 val value = parallelism.incrementAndGet() in checkParallelism()
34 parallelism.decrementAndGet() in checkParallelism()
|
| /external/tensorflow/tensorflow/core/api_def/base_api/ |
| D | api_def_ExperimentalMaxIntraOpParallelismDataset.pbtxt | 6 Identifies the maximum intra-op parallelism to use.
10 Creates a dataset that overrides the maximum intra-op parallelism.
|
| D | api_def_MaxIntraOpParallelismDataset.pbtxt | 6 Identifies the maximum intra-op parallelism to use.
10 Creates a dataset that overrides the maximum intra-op parallelism.
|
| D | api_def_MapDefun.pbtxt | 49 limit the intra op parallelism. To limit inter-op parallelism, a user can
|
| /external/tensorflow/tensorflow/core/framework/ |
| D | model.cc | 352 double parallelism = num_inputs() - 1; // default to cycle length in OutputTimeLocked() local
355 parallelism = std::min(parallelism, (*parameter)->value); in OutputTimeLocked()
361 static_cast<double>(num_inputs() - 1) / parallelism; in OutputTimeLocked()
367 wait_time = ComputeWaitTime(producer_time, consumer_time, parallelism, in OutputTimeLocked()
374 producer_time_der * inputs_time_der_sum / parallelism; in OutputTimeLocked()
381 static_cast<double>(num_inputs() - 1) / parallelism); in OutputTimeLocked()
394 buffer_size_der - producer_time_der * producer_time / parallelism; in OutputTimeLocked()
397 wait_time = ComputeWaitTime(producer_time, consumer_time, parallelism, in OutputTimeLocked()
570 double parallelism = 1.0; in InputTimeLocked() local
573 parallelism = (*parallelism_parameter)->value; in InputTimeLocked()
[all …]
|
| D | device_base.cc | 95 const int parallelism = std::max<int>( in eigen_cpu_device() local
98 return eigen_cpu_devices_[parallelism - 1]; in eigen_cpu_device()
|
| D | model_test.cc | 45 const int64_t parallelism = std::get<0>(GetParam()); in TEST_P() local
52 /*value=*/parallelism, nullptr, nullptr), in TEST_P()
80 110 * parallelism / 10); in TEST_P()
107 100 + 250 / parallelism); in TEST_P()
114 50 + 250 / parallelism); in TEST_P()
127 const int64_t parallelism = std::get<0>(GetParam()); in TEST_P() local
133 std::make_shared<SharedState>(/*value=*/parallelism, in TEST_P()
151 ? 110.0 * parallelism / 10 in TEST_P()
152 : 110.0 * parallelism / 10 / num_inputs_per_output); in TEST_P()
195 num_inputs_per_output * (50 + 100) + 128 / parallelism); in TEST_P()
[all …]
|
| /external/tensorflow/tensorflow/core/profiler/protobuf/ |
| D | op_stats.proto | 81 // The number of replicas, corresponds to input parallelism.
82 // If there is no model parallelism, replica_count = device_core_count
84 // The number of cores used for a single replica, e.g. model parallelism.
85 // If there is no model parallelism, then num_cores_per_replica = 1
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/js/src/ |
| D | JSDispatcher.kt | 34 override fun limitedParallelism(parallelism: Int): CoroutineDispatcher { in <lambda>()
35 parallelism.checkParallelism() in <lambda>()
|
| /external/libjpeg-turbo/simd/nasm/ |
| D | jsimdcfg.inc.h | 104 ; To maximize parallelism, Type DCTELEM is changed to short (originally, int). variable
112 ; To maximize parallelism, Type MULTIPLIER is changed to short. variable
|
| D | jsimdcfg.inc | 70 ; To maximize parallelism, Type DCTELEM is changed to short (originally, int).
76 ; To maximize parallelism, Type short is changed to short.
|
| /external/tensorflow/tensorflow/compiler/mlir/tensorflow/tests/ |
| D | outside_compiled_to_host_launch.mlir | 3 // Tests that outside compilation and model parallelism together fail.
6 // expected-error@+1 {{outside compilation is not supported with model parallelism}}
56 // Tests the launch wrap of a single outside compiled cluster with data parallelism.
|