| /external/tensorflow/tensorflow/python/distribute/ |
| cross_device_ops.py | 40 def check_destinations(destinations):
41 """Checks whether `destinations` is not empty.
44 destinations: a `DistributedValues`, variable, or string object.
47 Boolean which is True if `destinations` is not empty.
50 if isinstance(destinations, resource_variable_ops.ResourceVariable):
51 return bool(destinations.device)
52 return bool(destinations)
55 def validate_destinations(destinations):
56 if not isinstance(destinations,
65 raise ValueError("destinations must be one of a `DistributedValues` object,
[all...] |
| parameter_server_strategy.py | 283 def _broadcast_to(self, tensor, destinations):
291 if not cross_device_ops_lib.check_destinations(destinations):
293 destinations = values.LogicalDeviceSpec(
295 return self._cross_device_ops.broadcast(tensor, destinations)
368 def _verify_destinations_not_different_worker(self, destinations):
371 if destinations is None:
373 for d in cross_device_ops_lib.get_devices_from(destinations):
380 def _reduce_to(self, reduce_op, value, destinations):
381 self._verify_destinations_not_different_worker(destinations)
385 reduce_op, self._device_map, value, destinations)
[all...] |
| one_device_strategy.py | 93 def _broadcast_to(self, tensor, destinations):
94 del destinations
146 def _reduce_to(self, reduce_op, value, destinations):
147 del reduce_op, destinations
|
| distribute_lib.py | [all...] |
| mirrored_strategy.py | 648 def _broadcast_to(self, tensor, destinations):
657 if not destinations:
659 destinations = values.LogicalDeviceSpec(
661 return self._get_cross_device_ops().broadcast(tensor, destinations)
694 def _reduce_to(self, reduce_op, value, destinations):
705 reduce_op, self._device_map, value, destinations)
707 reduce_op, value, destinations=destinations)
[all...] |
| collective_all_reduce_strategy.py | 430 def _reduce_to(self, reduce_op, value, destinations):
449 reduce_op, self._device_map, value, destinations)
451 reduce_op, value, destinations=destinations)
|
| tpu_strategy.py | 441 def _reduce_to(self, reduce_op, value, destinations):
457 reduce_op, self._device_map, value, destinations)
459 devices = cross_device_ops_lib.get_devices_from(destinations)
522 def _broadcast_to(self, tensor, destinations):
523 del destinations
|
| values.py | 623 def _apply_aggregation(strategy, value, aggregation, destinations):
627 destinations=destinations)
629 return strategy.extended.reduce_to(reduce_op, value, destinations)
[all...] |
| /external/walt/ios/WALT/ |
| MIDIEndpoint.m | 39 NSMutableArray<MIDIDestination *> *destinations =
48 [destinations addObject:destination];
54 return destinations;
|
| WALTClient.m | 175 NSArray<MIDIDestination *> *destinations = [MIDIDestination allDestinations];
176 if (destinations.count) {
177 if (![_client connectToDestination:destinations.firstObject error:error]) {
|
| /external/tensorflow/tensorflow/python/debug/lib/ |
| source_remote.py | 104 def _send_call_tracebacks(destinations,
119 destinations: gRPC destination addresses, a `str` or a `list` of `str`s,
121 `CallTraceback` proto payload will be sent to all the destinations.
136 if not isinstance(destinations, list):
137 destinations = [destinations]
139 destinations = [
142 for dest in destinations]
171 for destination in destinations:
188 def send_graph_tracebacks(destinations,
[all...] |
| /external/tensorflow/tensorflow/contrib/distribute/python/ |
| cross_device_ops_test.py | 150 for destinations in all_destinations:
155 destinations=destinations),
156 _fake_mirrored(mean, destinations))
161 destinations=destinations),
162 _fake_mirrored(mean_2, destinations))
166 destinations=destinations),
167 _fake_mirrored(mean * len(devices), destinations))
[all...] |
| strategy_test_lib.py | 146 reduce_util.ReduceOp.SUM, g, destinations=v)
198 reduce_util.ReduceOp.SUM, g, destinations=v)
|
| collective_all_reduce_strategy_test.py | 192 # TODO(yuefengz): support non-Mirrored variable as destinations.
194 reduce_util.ReduceOp.SUM, g, destinations=v)
|
| parameter_server_strategy_test.py | 530 # TODO(yuefengz): support non-Mirrored variable as destinations.
532 reduce_util.ReduceOp.SUM, g, destinations=v)
[all...] |
| /external/v8/tools/ignition/ |
| bytecode_dispatches_report.py | 45 # Display the top 5 sources and destinations of dispatches to/from LdaZero
98 for source, destinations in iteritems(dispatches_table):
99 total = float(sum(itervalues(destinations)))
100 if bytecode in destinations:
101 count = destinations[bytecode]
104 destinations = []
108 destinations.append((destination, count, count / bytecode_total))
112 heapq.nlargest(top_count, destinations, key=lambda x: x[1]))
123 print "\nTop destinations of dispatches from {}:".format(bytecode)
217 help="print top dispatch sources and destinations to the specified bytecode
[all...] |
| /external/gemmlowp/meta/generators/ |
| neon_emitter.py | 407 def EmitVLoadA(self, load_no, load_type, destinations, source):
409 '{%s}' % ', '.join(_ExpandQuads(destinations)), source)
414 destinations,
418 destinations = _ExpandQuads(destinations)
419 if len(destinations) * 64 < bits_to_load:
420 raise ArgumentError('To few destinations: %d to load %d bits.' %
421 (len(destinations), bits_to_load))
425 self.EmitVLoadA(1, 32, destinations[:4],
428 destinations = destinations[4:
[all...] |
| neon_emitter_64.py | 810 def EmitVLoadA(self, load_no, load_type, destinations, source):
813 [_LoadStoreSize(destination) for destination in destinations]) / 8
814 self.EmitVLoadAPostIncrement(load_no, load_type, destinations, source,
817 self.EmitVLoadAPostIncrement(load_no, load_type, destinations, source,
820 def EmitVLoadAPostIncrement(self, load_no, load_type, destinations, source,
823 if len(destinations) == 1 and destinations[0].lane is -1:
824 destination = '{%s}' % _AppendType(load_type, destinations[0])
831 destination_list = _RegisterList(load_type, destinations)
840 destinations,
[all...] |
| /external/harfbuzz_ng/test/subset/ |
| subset_test_suite.py | 76 destinations = {
92 if line in destinations:
93 current_destination = destinations[line]
|
| /external/python/cpython3/Lib/test/ |
| test_clinic.py | 62 self.destinations = {}
66 d = self.destinations.get
78 d = self.destinations.get(name)
84 if name in self.destinations:
86 self.destinations[name] = clinic.Destination(name, type, self, *args)
|
| /cts/tests/app/src/android/app/cts/ |
| DownloadManagerTest.java | 380 final String[] destinations = { local
389 for (int i = 0; i < destinations.length; ++i) {
390 final String destination = destinations[i];
|
| /cts/tests/tests/text/src/android/text/cts/ |
| TextUtilsTest.java | 1829 CharSequence destinations[] = new CharSequence[] { "text" }; local
[all...] |
| /external/deqp-deps/SPIRV-Tools/source/opt/ |
| loop_fusion.cpp | 56 // Append all dependences from |sources| to |destinations| to |dependences|.
60 const std::vector<Instruction*>& destinations,
63 for (auto destination : destinations) {
|
| /external/swiftshader/third_party/SPIRV-Tools/source/opt/ |
| loop_fusion.cpp | 56 // Append all dependences from |sources| to |destinations| to |dependences|.
60 const std::vector<Instruction*>& destinations,
63 for (auto destination : destinations) {
|
| /external/python/cpython3/Tools/clinic/ |
| clinic.py | [all...] |
