Home
last modified time | relevance | path

Searched defs:task_name (Results 1 – 25 of 27) sorted by relevance

12

/external/autotest/server/hosts/
Dcros_label.py65 def update_for_task(self, task_name): argument
122 def update_for_task(self, task_name): argument
152 def update_for_task(self, task_name): argument
200 def update_for_task(self, task_name): argument
217 def update_for_task(self, task_name): argument
298 def update_for_task(self, task_name): argument
338 def update_for_task(self, task_name): argument
Dbase_label.py105 def update_for_task(self, task_name): argument
196 def _populate_known_labels(self, label_list, task_name): argument
231 def get_labels_for_update(self, host, task_name): argument
300 def update_labels(self, host, task_name='', keep_pool=False): argument
/external/cronet/base/
Dcritical_closure.h82 inline OnceClosure MakeCriticalClosure(StringPiece task_name, in MakeCriticalClosure()
109 inline OnceClosure MakeCriticalClosure(StringPiece task_name, in MakeCriticalClosure()
/external/tensorflow/tensorflow/core/distributed_runtime/coordination/
Dcoordination_service.cc66 CoordinatedTask GetTaskFromName(absl::string_view task_name) { in GetTaskFromName()
370 const std::string& task_name = GetTaskName(job.name(), task.first); local
512 const std::string& task_name = GetTaskName(task); in RegisterTask() local
590 const std::string task_name = GetTaskName(task); in DisconnectTask() local
627 const std::string& task_name = GetTaskName(task); in ReportTaskError() local
647 const std::string& task_name = GetTaskName(task); in RecordHeartbeat() local
704 const std::string task_name = GetTaskName(destination_task); in ReportServiceErrorToTaskAsync() local
905 absl::string_view task_name, Status error) { in SetTaskError()
936 absl::string_view task_name = task_state.first; in BarrierAsync() local
943 const std::string task_name = GetTaskName(task); in BarrierAsync() local
[all …]
/external/tensorflow/tensorflow/core/distributed_runtime/
Dcollective_param_resolver_distributed_test.cc64 string task_name; in GetDeviceLocalityAsync() local
168 string task_name = strings::StrCat("/job:worker/replica:0/task:", wi); in DefineCollectiveParams() local
207 string task_name = strings::StrCat("/job:worker/replica:0/task:", wi); in IssueRequests() local
215 void IssueRequest(const string& task_name, const string& device_name, in IssueRequest()
249 string task_name = strings::StrCat("/job:worker/replica:0/task:", wi); in ValidateCollectiveParams() local
347 const string task_name = "/job:worker/replica:0/task:1"; in TEST_F() local
Dcollective_rma_distributed.h32 WorkerCacheInterface* worker_cache, int64_t step_id, string task_name) in CollectiveRemoteAccessDistributed()
Drpc_collective_executor_mgr_test.cc41 string task_name = "/job:localhost/replica:0/task:0"; in RpcCollectiveExecutorMgrTest() local
Drpc_collective_executor_mgr.cc33 WorkerCacheInterface* worker_cache, const string& task_name) in RpcCollectiveExecutorMgr()
Dsession_mgr.cc275 std::string task_name; in UpdateSession() local
Dcollective_param_resolver_distributed.cc93 WorkerCacheInterface* worker_cache, const string& task_name) in CollectiveParamResolverDistributed()
Dcollective_rma_distributed_test.cc183 string task_name; in GetDeviceLocalityAsync() local
/external/cronet/net/base/
Dprioritized_task_runner_unittest.cc37 void PushName(const std::string& task_name) { in PushName()
42 std::string PushNameWithResult(const std::string& task_name) { in PushNameWithResult()
/external/tensorflow/tensorflow/core/common_runtime/
Ddevice_resolver_local_test.cc34 string task_name = "/job:localhost/replica:0/task:0"; in DeviceResolverLocalTest() local
Dcollective_executor_mgr_test.cc46 string task_name = "/job:localhost/replica:0/task:0"; in CollectiveExecutorMgrTest() local
Dcollective_param_resolver_local.cc48 NcclCommunicatorInterface* nccl_communicator, const string& task_name) in CollectiveParamResolverLocal()
89 string task_name; in TaskNameFromDeviceName() local
Dhierarchical_tree_broadcaster_test.cc360 string task_name = strings::StrCat("/job:worker/replica:0/task:", ti); in TEST_F() local
Dcollective_test_util.cc218 string task_name = strings::StrCat("/job:worker/replica:0/task:", wi); in CreateCollectiveParams() local
Dbase_collective_executor.cc482 const string& task_name = in UnblockDependencies() local
/external/webrtc/modules/audio_device/win/
Dcore_audio_utility_win.h86 explicit ScopedMMCSSRegistration(const wchar_t* task_name) { in ScopedMMCSSRegistration()
/external/tensorflow/tensorflow/core/distributed_runtime/preemption/
Dpreemption_sync_manager.cc114 const std::string task_name = in Initialize() local
/external/autotest/server/
Dsite_utils.py469 def get_special_task_exec_path(hostname, task_id, task_name, time_requested): argument
/external/tensorflow/tensorflow/compiler/mlir/tfrt/transforms/
Dcorert_converter.cc254 mlir::Operation *op, StringRef task_name, in GetTaskHandle()
/external/tensorflow/tensorflow/core/common_runtime/eager/
Dcontext_distributed_manager.cc313 string task_name; in UpdateRemoteContexts() local
Dcontext.cc1234 Status GetTaskName(Device* d, string* task_name) { in GetTaskName()
/external/tensorflow/tensorflow/core/kernels/
Dcollective_nccl_test.cc142 const string task_name = "/job:worker/replica:0/task:0"; in Init() local

12