Home
last modified time | relevance | path

Searched refs:coordinator (Results 1 – 25 of 70) sorted by relevance

123

/external/tensorflow/tensorflow/python/distribute/coordinator/
Dcluster_coordinator_test.py37 from tensorflow.python.distribute.coordinator import cluster_coordinator as coordinator_lib
38 from tensorflow.python.distribute.coordinator import values as values_lib
55 from tensorflow.python.training import coordinator
86 coord = coordinator.Coordinator(clean_stop_exception_types=[])
134 coord = coordinator.Coordinator(clean_stop_exception_types=[])
154 coord = coordinator.Coordinator(clean_stop_exception_types=[])
173 coord = coordinator.Coordinator(clean_stop_exception_types=[])
195 coord = coordinator.Coordinator(clean_stop_exception_types=[])
504 cls.coordinator = make_coordinator(num_workers=5, num_ps=2)
505 cls.strategy = cls.coordinator.strategy
[all …]
Dvalues.py320 def __init__(self, dataset_fn, coordinator): argument
339 self._coordinator = coordinator
411 def __init__(self, dataset, coordinator): argument
444 super(PerWorkerDatasetFromDataset, self).__init__(dataset_fn, coordinator)
447 def get_per_worker_dataset(dataset_or_dataset_fn, coordinator): argument
451 coordinator)
453 return PerWorkerDatasetFromDataset(dataset_or_dataset_fn, coordinator)
Dmetric_utils_test.py21 from tensorflow.python.distribute.coordinator import cluster_coordinator as coordinator_lib
22 from tensorflow.python.distribute.coordinator import metric_utils
/external/glide/library/src/main/java/com/bumptech/glide/request/
DThumbnailRequestCoordinator.java10 private RequestCoordinator coordinator; field in ThumbnailRequestCoordinator
16 public ThumbnailRequestCoordinator(RequestCoordinator coordinator) { in ThumbnailRequestCoordinator() argument
17 this.coordinator = coordinator; in ThumbnailRequestCoordinator()
38 return coordinator == null || coordinator.canSetImage(this); in parentCanSetImage()
53 return coordinator == null || coordinator.canNotifyStatusChanged(this); in parentCanNotifyStatusChanged()
62 return coordinator != null && coordinator.isAnyResourceSet(); in parentIsAnyResourceSet()
/external/tensorflow/tensorflow/python/training/
Dcoordinator_test.py23 from tensorflow.python.training import coordinator
71 coord = coordinator.Coordinator()
79 coord = coordinator.Coordinator()
95 coord = coordinator.Coordinator()
108 coord = coordinator.Coordinator()
122 coord = coordinator.Coordinator()
139 coord = coordinator.Coordinator()
161 coord = coordinator.Coordinator()
177 coord = coordinator.Coordinator()
197 coord = coordinator.Coordinator()
[all …]
Dqueue_runner_test.py30 from tensorflow.python.training import coordinator
139 coord = coordinator.Coordinator()
156 coord = coordinator.Coordinator()
171 coord = coordinator.Coordinator()
189 coord = coordinator.Coordinator()
204 coord = coordinator.Coordinator()
Dsupervisor.py31 from tensorflow.python.training import coordinator
322 self._coord = coordinator.Coordinator()
797 looper = coordinator.LooperThread(
1024 class SVSummaryThread(coordinator.LooperThread):
1050 class SVStepCounterThread(coordinator.LooperThread):
1098 class SVTimerCheckpointThread(coordinator.LooperThread):
/external/cronet/components/nacl/renderer/plugin/
Dpnacl_coordinator.cc31 PnaclCoordinator* coordinator = static_cast<PnaclCoordinator*>(user_data); in DidCacheHit() local
32 coordinator->BitcodeStreamCacheHit(nexe_file_handle); in DidCacheHit()
37 PnaclCoordinator* coordinator = static_cast<PnaclCoordinator*>(user_data); in DidCacheMiss() local
38 coordinator->BitcodeStreamCacheMiss(expected_pexe_size, in DidCacheMiss()
43 PnaclCoordinator* coordinator = static_cast<PnaclCoordinator*>(user_data); in DidStreamData() local
44 coordinator->BitcodeStreamGotData(stream_data, length); in DidStreamData()
48 PnaclCoordinator* coordinator = static_cast<PnaclCoordinator*>(user_data); in DidFinishStream() local
49 coordinator->BitcodeStreamDidFinish(pp_error); in DidFinishStream()
62 PnaclCoordinator* coordinator = in BitcodeToNative() local
69 coordinator->num_threads_ = std::clamp(cpus, 1, 4); in BitcodeToNative()
[all …]
/external/tensorflow/tensorflow/python/distribute/
Ddistributed_table_test.py30 from tensorflow.python.distribute.coordinator import cluster_coordinator as coordinator_lib
31 from tensorflow.python.distribute.coordinator import coordinator_context
149 coordinator = coordinator_lib.ClusterCoordinator(strategy=strategy)
169 per_worker_dataset = coordinator.create_per_worker_dataset(
180 coordinator.schedule(worker_fn, args=(per_worker_iterator,)))
192 coordinator = coordinator_lib.ClusterCoordinator(strategy=strategy)
212 per_worker_dataset = coordinator.create_per_worker_dataset(
223 coordinator.schedule(worker_fn, args=(per_worker_iterator,)))
236 coordinator = coordinator_lib.ClusterCoordinator(strategy=strategy)
253 per_worker_dataset = coordinator.create_per_worker_dataset(
[all …]
/external/libchrome/base/memory/
Dmemory_coordinator_proxy.cc26 MemoryCoordinator* coordinator) { in SetMemoryCoordinator() argument
27 DCHECK(!g_memory_coordinator || !coordinator); in SetMemoryCoordinator()
28 g_memory_coordinator = coordinator; in SetMemoryCoordinator()
Dmemory_coordinator_proxy.h33 static void SetMemoryCoordinator(MemoryCoordinator* coordinator);
/external/glide/library/src/main/java/com/bumptech/glide/
DGenericRequestBuilder.java737 … ThumbnailRequestCoordinator coordinator = new ThumbnailRequestCoordinator(parentCoordinator); in buildRequestRecursive() local
738 Request fullRequest = obtainRequest(target, sizeMultiplier, priority, coordinator); in buildRequestRecursive()
740 … Request thumbRequest = thumbnailRequestBuilder.buildRequestRecursive(target, coordinator); in buildRequestRecursive()
741 coordinator.setRequests(fullRequest, thumbRequest); in buildRequestRecursive()
742 return coordinator; in buildRequestRecursive()
745 … ThumbnailRequestCoordinator coordinator = new ThumbnailRequestCoordinator(parentCoordinator); in buildRequestRecursive() local
746 Request fullRequest = obtainRequest(target, sizeMultiplier, priority, coordinator); in buildRequestRecursive()
747 …thumbnailRequest = obtainRequest(target, thumbSizeMultiplier, getThumbnailPriority(), coordinator); in buildRequestRecursive()
748 coordinator.setRequests(fullRequest, thumbnailRequest); in buildRequestRecursive()
749 return coordinator; in buildRequestRecursive()
/external/tensorflow/tensorflow/tools/api/golden/v2/
Dtensorflow.distribute.coordinator.-per-worker-value.pbtxt1 path: "tensorflow.distribute.coordinator.PerWorkerValue"
3 is_instance: "<class \'tensorflow.python.distribute.coordinator.values.PerWorkerValues\'>"
Dtensorflow.distribute.experimental.coordinator.-per-worker-values.pbtxt1 path: "tensorflow.distribute.experimental.coordinator.PerWorkerValues"
3 is_instance: "<class \'tensorflow.python.distribute.coordinator.values.PerWorkerValues\'>"
Dtensorflow.distribute.coordinator.-remote-value.pbtxt1 path: "tensorflow.distribute.coordinator.RemoteValue"
3 is_instance: "<class \'tensorflow.python.distribute.coordinator.values.RemoteValue\'>"
Dtensorflow.distribute.experimental.coordinator.-remote-value.pbtxt1 path: "tensorflow.distribute.experimental.coordinator.RemoteValue"
3 is_instance: "<class \'tensorflow.python.distribute.coordinator.values.RemoteValue\'>"
Dtensorflow.distribute.coordinator.-cluster-coordinator.pbtxt1 path: "tensorflow.distribute.coordinator.ClusterCoordinator"
3 …is_instance: "<class \'tensorflow.python.distribute.coordinator.cluster_coordinator.ClusterCoordin…
Dtensorflow.distribute.experimental.coordinator.-cluster-coordinator.pbtxt1 path: "tensorflow.distribute.experimental.coordinator.ClusterCoordinator"
3 …is_instance: "<class \'tensorflow.python.distribute.coordinator.cluster_coordinator.ClusterCoordin…
Dtensorflow.distribute.coordinator.pbtxt1 path: "tensorflow.distribute.coordinator"
Dtensorflow.distribute.experimental.coordinator.pbtxt1 path: "tensorflow.distribute.experimental.coordinator"
/external/cronet/net/proxy_resolution/
Dmulti_threaded_proxy_resolver.cc58 Executor(Coordinator* coordinator, int thread_number);
81 void set_coordinator(Coordinator* coordinator) { in set_coordinator() argument
82 DCHECK(coordinator); in set_coordinator()
84 coordinator_ = coordinator; in set_coordinator()
354 Executor::Executor(Executor::Coordinator* coordinator, int thread_number) in Executor() argument
355 : coordinator_(coordinator), thread_number_(thread_number) { in Executor()
356 DCHECK(coordinator); in Executor()
/external/tensorflow/tensorflow/compiler/xla/pjrt/distributed/
Dprotocol.proto42 // passed to EnumerateDevices(). In other words, the coordinator node
123 // Connects a node to the distributed coordinator node. Blocks until all tasks
134 // Health-checking RPC. Workers send heartbeats to the coordinator at regular
135 // intervals. If the worker does not hear from the coordinator or the
136 // coordinator does not hear from the tasks, the tasks abort.
/external/tensorflow/tensorflow/cc/
DBUILD52 "training/coordinator.h",
884 ":coordinator",
897 "coordinator",
914 name = "coordinator",
915 srcs = ["training/coordinator.cc"],
916 hdrs = ["training/coordinator.h"],
929 ":coordinator",
950 ":coordinator",
/external/tensorflow/tensorflow/core/api_def/base_api/
Dapi_def_WorkerHeartbeat.pbtxt18 Heartbeats may be sent periodically to indicate the coordinator is still active,
/external/tensorflow/tensorflow/python/eager/
Dremote_cluster_test.py37 from tensorflow.python.training import coordinator
325 self._coord = coordinator.Coordinator()
427 self._coord = coordinator.Coordinator()
558 self._coord = coordinator.Coordinator()
608 self._coord = coordinator.Coordinator()

123