| /external/tensorflow/tensorflow/python/data/kernel_tests/ |
| D | interleave_test.py | 38 def _interleave(lists, cycle_length, block_length, num_parallel_calls=None): argument
59 if cycle_length is None:
62 cycle_length = multiprocessing.cpu_count()
64 cycle_length = (multiprocessing.cpu_count() + 2) // 3
66 cycle_length = min(num_parallel_calls, multiprocessing.cpu_count())
68 for i in range(cycle_length):
76 for i in range(cycle_length):
112 cycle_length=1,
119 cycle_length=2,
126 cycle_length=2,
[all …]
|
| D | cardinality_test.py | 91 lambda _: dataset_ops.Dataset.from_tensors(0), cycle_length=1),
95 cycle_length=1,
99 cycle_length=1,
|
| /external/tensorflow/tensorflow/python/data/experimental/benchmarks/ |
| D | parallel_interleave_benchmark.py | 68 cycle_length, num_parallel_calls): argument
70 return dataset.interleave(interleave_fn, cycle_length=cycle_length)
74 interleave_fn, cycle_length=cycle_length))
77 num_parallel_calls = cycle_length
80 cycle_length=cycle_length,
89 cycle_length, argument
97 cycle_length=cycle_length,
105 cycle_length=10, argument
114 cycle_length=cycle_length,
151 cycle_length=1,
[all …]
|
| D | autotune_benchmark.py | 132 cycle_length=10,
171 cycle_length=2)
178 cycle_length=2)
218 cycle_length=2)
224 cycle_length=2)
|
| /external/tensorflow/tensorflow/python/data/experimental/kernel_tests/serialization/ |
| D | parallel_interleave_dataset_serialization_test.py | 42 def _build_ds(self, cycle_length, block_length, sloppy=False): argument
47 cycle_length, block_length, sloppy)))
52 cycle_length = 2
54 self.run_core_tests(lambda: self._build_ds(cycle_length, block_length),
57 cycle_length = 1
59 self.run_core_tests(lambda: self._build_ds(cycle_length, block_length),
62 cycle_length = 2
64 self.run_core_tests(lambda: self._build_ds(cycle_length, block_length),
74 def run_test(cycle_length, block_length): argument
76 lambda: self._build_ds(cycle_length, block_length, True),
|
| D | interleave_dataset_serialization_test.py | 36 def _build_iterator_graph(self, input_values, cycle_length, block_length, argument
42 cycle_length, block_length, num_parallel_calls)
48 cycle_length=2,
51 def testSerializationCore(self, cycle_length, block_length, argument
58 input_values, cycle_length, block_length, num_parallel_calls),
75 _interleave_fn, cycle_length=1)
|
| /external/tensorflow/tensorflow/python/data/experimental/kernel_tests/ |
| D | parallel_interleave_test.py | 59 def dataset_fn(self, input_values, cycle_length, block_length, sloppy, argument
83 interleave_fn, cycle_length, block_length, sloppy,
86 def _interleave(self, lists, cycle_length, block_length): argument
96 for i in range(cycle_length):
104 for i in range(cycle_length):
128 cycle_length=1,
137 cycle_length=2,
144 cycle_length=2,
152 cycle_length=2,
155 cycle_length, block_length): argument
[all …]
|
| D | reader_dataset_ops_test_base.py | 170 def _interleave(self, iterators, cycle_length): argument
174 for i in range(cycle_length):
180 for i in range(min(cycle_length, len(open_iterators))):
196 cycle_length=1): argument
203 def _next_record_interleaved(file_indices, cycle_length): argument
205 cycle_length)
215 if cycle_length == 1:
218 next_records = _next_record_interleaved(file_indices, cycle_length)
264 cycle_length=interleave_cycle_length):
314 def _interleave(self, iterators, cycle_length): argument
[all …]
|
| /external/tensorflow/tensorflow/python/data/benchmarks/ |
| D | map_benchmark.py | 119 def _benchmark_nested_parallel_map(self, cycle_length, num_parallel_calls): argument
133 f, cycle_length=cycle_length, num_parallel_calls=dataset_ops.AUTOTUNE)
136 if cycle_length is None else str(cycle_length))
152 for cycle_length in cycle_lengths:
154 self._benchmark_nested_parallel_map(cycle_length, num_parallel_calls)
|
| /external/autotest/client/tests/uptime/ |
| D | control | 9 The test repeatedly executes kernbench during T=cycle_length seconds and then
17 def uptime_test(cycle_length = 300, target_time = 3*60*60):
22 while time.time() < kernbench_started + cycle_length:
25 job.run_test('sleeptest', tag='%d' % counter, seconds=cycle_length)
|
| /external/webrtc/video/ |
| D | full_stack_tests_plot.py | 213 def __init__(self, fields, data_list, cycle_length=None, frames=None, argument
217 self.cycle_length = cycle_length
245 if self.cycle_length:
246 line.values = AverageOverCycle(line.values, self.cycle_length)
269 if self.cycle_length:
270 x = numpy.array(range(self.cycle_length))
340 cycle_length = None
351 cycle_length = values[0]
376 return PlotConfig(fields, LoadFiles(files), cycle_length=cycle_length,
|
| /external/tensorflow/tensorflow/core/kernels/data/ |
| D | interleave_dataset_op.cc | 54 std::unique_ptr<CapturedFunction> captured_func, int64 cycle_length, in Dataset() argument
60 cycle_length_(cycle_length), in Dataset()
68 strings::Printf("%lld", static_cast<long long>(cycle_length))}}) { in Dataset()
322 int64 cycle_length = 0; in MakeDataset() local
323 OP_REQUIRES_OK(ctx, ParseScalarArgument(ctx, kCycleLength, &cycle_length)); in MakeDataset()
324 if (cycle_length == model::kAutotune) { in MakeDataset()
325 cycle_length = port::MaxParallelism(); in MakeDataset()
328 ctx, cycle_length > 0, in MakeDataset()
342 *output = new Dataset(ctx, input, std::move(captured_func), cycle_length, in MakeDataset()
|
| D | parallel_interleave_dataset_op.cc | 134 int64 cycle_length) { in ComputePrefetchInputElements() argument
138 return kDefaultCyclePrefetchFactor * cycle_length; in ComputePrefetchInputElements()
162 std::unique_ptr<CapturedFunction> captured_func, int64 cycle_length, in Dataset() argument
170 cycle_length_(cycle_length), in Dataset()
175 prefetch_input_elements, cycle_length)), in Dataset()
187 strings::Printf("%lld", static_cast<long long>(cycle_length))}, in Dataset()
1632 int64 cycle_length = 0; in MakeDataset() local
1633 OP_REQUIRES_OK(ctx, ParseScalarArgument(ctx, kCycleLength, &cycle_length)); in MakeDataset()
1634 if (cycle_length == model::kAutotune) { in MakeDataset()
1636 cycle_length = std::min(num_parallel_calls, in MakeDataset()
[all …]
|
| /external/tensorflow/tensorflow/core/ops/compat/ops_history_v1/ |
| D | InterleaveDataset.pbtxt | 12 name: "cycle_length"
57 name: "cycle_length"
|
| D | ParallelInterleaveDatasetV2.pbtxt | 12 name: "cycle_length"
60 name: "cycle_length"
|
| D | ParallelInterleaveDataset.pbtxt | 12 name: "cycle_length"
|
| D | ExperimentalParallelInterleaveDataset.pbtxt | 12 name: "cycle_length"
|
| D | ParallelInterleaveDatasetV3.pbtxt | 12 name: "cycle_length"
|
| /external/tensorflow/tensorflow/core/ops/compat/ops_history_v2/ |
| D | InterleaveDataset.pbtxt | 12 name: "cycle_length"
57 name: "cycle_length"
|
| D | ParallelInterleaveDatasetV2.pbtxt | 12 name: "cycle_length"
60 name: "cycle_length"
|
| D | ParallelInterleaveDatasetV3.pbtxt | 12 name: "cycle_length"
|
| D | ParallelInterleaveDataset.pbtxt | 12 name: "cycle_length"
|
| D | ExperimentalParallelInterleaveDataset.pbtxt | 12 name: "cycle_length"
|
| /external/tensorflow/tensorflow/python/data/ops/ |
| D | readers.py | 101 cycle_length=num_parallel_reads,
251 def __init__(self, input_dataset, map_func, cycle_length, block_length, argument
261 cycle_length, dtype=dtypes.int64, name="cycle_length")
271 argument_default=2 * cycle_length)
|
| /external/tensorflow/tensorflow/python/data/experimental/ops/ |
| D | interleave_ops.py | 44 cycle_length, argument
96 return readers.ParallelInterleaveDataset(dataset, map_func, cycle_length,
|