Home
last modified time | relevance | path

Searched refs:task_name (Results 1 – 25 of 32) sorted by relevance

12

/external/tensorflow/tensorflow/core/distributed_runtime/
Dcollective_param_resolver_distributed_test.cc99 string task_name; in GetDeviceLocalityAsync() local
101 if (!DeviceNameUtils::SplitDeviceName(device, &task_name, &dev_part)) { in GetDeviceLocalityAsync()
105 auto it = workers_.find(task_name); in GetDeviceLocalityAsync()
107 done(errors::Internal("failed to find worker ", task_name)); in GetDeviceLocalityAsync()
181 string task_name = strings::StrCat("/job:worker/replica:0/task:", wi); in DefineCollectiveParams() local
184 strings::StrCat(task_name, "/device:", device_type, ":", di); in DefineCollectiveParams()
215 string task_name = strings::StrCat("/job:worker/replica:0/task:", wi); in IssueRequests() local
217 string device_name = strings::StrCat(task_name, "/device:CPU:", di); in IssueRequests()
218 IssueRequest(task_name, device_name, group_size); in IssueRequests()
223 void IssueRequest(const string& task_name, const string& device_name, in IssueRequest() argument
[all …]
Drpc_collective_executor_mgr_test.cc41 string task_name = "/job:localhost/replica:0/task:0"; in RpcCollectiveExecutorMgrTest() local
44 task_name); in RpcCollectiveExecutorMgrTest()
49 TF_CHECK_OK(DeviceFactory::AddDevices(options, task_name, &devices)); in RpcCollectiveExecutorMgrTest()
56 worker_cache, task_name)); in RpcCollectiveExecutorMgrTest()
60 MaybeCreateNcclCommunicator(), worker_cache, task_name)); in RpcCollectiveExecutorMgrTest()
Dcollective_rma_distributed.h32 WorkerCacheInterface* worker_cache, int64 step_id, string task_name) in CollectiveRemoteAccessDistributed() argument
36 task_name_(std::move(task_name)) {} in CollectiveRemoteAccessDistributed()
Drpc_collective_executor_mgr.cc33 WorkerCacheInterface* worker_cache, const string& task_name) in RpcCollectiveExecutorMgr() argument
38 task_name_(task_name) { in RpcCollectiveExecutorMgr()
39 group_leader_ = (task_name == config.experimental().collective_group_leader()) in RpcCollectiveExecutorMgr()
Dcollective_rma_distributed_test.cc152 string task_name; in GetDeviceLocalityAsync() local
154 if (!DeviceNameUtils::SplitDeviceName(device, &task_name, &dev_part)) { in GetDeviceLocalityAsync()
158 auto it = workers_.find(task_name); in GetDeviceLocalityAsync()
160 done(errors::Internal("failed to find worker ", task_name)); in GetDeviceLocalityAsync()
Dcollective_param_resolver_distributed.cc94 const string& task_name) in CollectiveParamResolverDistributed() argument
95 : CollectiveParamResolverLocal(config, dev_mgr, dev_resolver, task_name), in CollectiveParamResolverDistributed()
97 group_leader_(task_name == config.experimental().collective_group_leader() in CollectiveParamResolverDistributed()
100 VLOG(1) << "CompleteParamResolverDistributed ctor task={" << task_name in CollectiveParamResolverDistributed()
Dsession_mgr.cc236 string task_name; in UpdateSession() local
237 DeviceNameUtils::GetTaskName(device->parsed_name(), &task_name); in UpdateSession()
239 task_name) == updated_remote_workers.end()) { in UpdateSession()
Drpc_collective_executor_mgr.h42 WorkerCacheInterface* worker_cache, const string& task_name);
Dcollective_param_resolver_distributed.h35 const string& task_name);
/external/autotest/server/hosts/
Dcros_label.py69 def update_for_task(self, task_name): argument
71 return task_name in (DEPLOY_TASK_NAME, REPAIR_TASK_NAME, '')
126 def update_for_task(self, task_name): argument
129 return task_name in (REPAIR_TASK_NAME, '')
156 def update_for_task(self, task_name): argument
159 return task_name in (REPAIR_TASK_NAME, '')
204 def update_for_task(self, task_name): argument
207 return task_name in (REPAIR_TASK_NAME, '')
221 def update_for_task(self, task_name): argument
224 return task_name in (DEPLOY_TASK_NAME, '')
[all …]
Dbase_label.py105 def update_for_task(self, task_name): argument
196 def _populate_known_labels(self, label_list, task_name): argument
200 if label_instance.update_for_task(task_name):
231 def get_labels_for_update(self, host, task_name): argument
244 if label.update_for_task(task_name):
300 def update_labels(self, host, task_name='', keep_pool=False): argument
308 self._populate_known_labels(self._labels, task_name)
313 new_labels = self.get_labels_for_update(host, task_name)
/external/perfetto/src/traced/probes/ftrace/test/data/android_seed_N2F62_3.10.49/events/exception/user_fault/
Dformat9 field:__data_loc char[] task_name; offset:8; size:4; signed:0;
13 print fmt: "task_name:%s addr:%lu, fsr:%u", __get_str(task_name), REC->addr, REC->fsr
/external/perfetto/src/traced/probes/ftrace/test/data/android_walleye_OPM5.171019.017.A1_4.4.88/events/exception/user_fault/
Dformat9 field:__data_loc char[] task_name; offset:8; size:4; signed:0;
13 print fmt: "task_name:%s addr:%lu, fsr:%u", __get_str(task_name), REC->addr, REC->fsr
/external/perfetto/src/traced/probes/ftrace/test/data/android_hammerhead_MRA59G_3.4.0/events/exception/user_fault/
Dformat10 field:__data_loc char[] task_name; offset:12; size:4; signed:0;
14 print fmt: "task_name:%s addr:%lu, fsr:%u", __get_str(task_name), REC->addr, REC->fsr
/external/tensorflow/tensorflow/core/common_runtime/
Dcollective_param_resolver_local.cc43 DeviceResolverInterface* dev_resolver, const string& task_name) in CollectiveParamResolverLocal() argument
47 task_name_(task_name) {} in CollectiveParamResolverLocal()
81 string task_name; in TaskNameFromDeviceName() local
82 CHECK(DeviceNameUtils::GetTaskName(parsed_device, &task_name)); in TaskNameFromDeviceName()
83 return task_name; in TaskNameFromDeviceName()
435 const string& task_name = gp.task_names[i]; in EstablishGlobalRank() local
436 if (ordered_tasks.find(task_name) != ordered_tasks.end()) { in EstablishGlobalRank()
439 ordered_tasks.insert(task_name); in EstablishGlobalRank()
440 TaskDeviceMap* tdm = &gdm[task_name]; in EstablishGlobalRank()
456 for (const string& task_name : gp->task_names) { in SetDevPerTask() local
[all …]
Dcollective_executor_mgr_test.cc40 string task_name = "/job:localhost/replica:0/task:0"; in CollectiveExecutorMgrTest() local
43 TF_CHECK_OK(DeviceFactory::AddDevices(options, task_name, &devices)); in CollectiveExecutorMgrTest()
49 task_name)); in CollectiveExecutorMgrTest()
Ddevice_resolver_local_test.cc34 string task_name = "/job:localhost/replica:0/task:0"; in DeviceResolverLocalTest() local
38 TF_CHECK_OK(DeviceFactory::AddDevices(options, task_name, &devices)); in DeviceResolverLocalTest()
Dhierarchical_tree_broadcaster_test.cc332 string task_name = strings::StrCat("/job:worker/replica:0/task:", wi); in Init() local
335 dev_name = strings::StrCat(task_name, "/device:GPU:0"); in Init()
337 dev_name = strings::StrCat(task_name, "/device:CPU:", di); in Init()
341 col_params_->group.task_names.push_back(task_name); in Init()
548 string task_name = strings::StrCat("/job:worker/replica:0/task:", ti); in PrepColParamsForSubdivPermsTest() local
550 string dev_name = strings::StrCat(task_name, "/device:GPU:", di); in PrepColParamsForSubdivPermsTest()
551 cp->group.task_names.push_back(task_name); in PrepColParamsForSubdivPermsTest()
801 string task_name = strings::StrCat("/job:worker/replica:0/task:", ti); in TEST_F() local
803 string dev_name = strings::StrCat(task_name, "/device:GPU:", di); in TEST_F()
804 cp->group.task_names.push_back(task_name); in TEST_F()
Dring_reducer_test.cc247 string task_name = strings::StrCat("/job:worker/replica:0/task:", wi); in Init() local
248 col_params_->group.num_devices_per_task[task_name] = num_devices; in Init()
250 string dev_name = strings::StrCat(task_name, "/cpu:", di); in Init()
253 strings::StrCat(task_name, "/gpu:", di % gpu_devices_.size()); in Init()
256 col_params_->group.task_names.push_back(task_name); in Init()
589 string task_name = strings::StrCat("/job:worker/replica:0/task:", task_id); in SetUpCollectiveParams() local
590 string device_name = strings::StrCat(task_name, "/device:GPU:", dev_id); in SetUpCollectiveParams()
591 cp->group.task_names.push_back(task_name); in SetUpCollectiveParams()
Dring_gatherer_test.cc225 string task_name = strings::StrCat("/job:worker/replica:0/task:", wi); in Init() local
226 string dev_name = strings::StrCat(task_name, "/cpu:", di); in Init()
229 strings::StrCat(task_name, "/gpu:", di % gpu_devices_.size()); in Init()
232 col_params_->group.task_names.push_back(task_name); in Init()
557 string task_name = strings::StrCat("/job:worker/replica:0/task:", task_id); in SetUpCollectiveParams() local
558 string device_name = strings::StrCat(task_name, "/device:GPU:", dev_id); in SetUpCollectiveParams()
559 cp->group.task_names.push_back(task_name); in SetUpCollectiveParams()
Dcollective_param_resolver_local.h46 const string& task_name);
175 void CompleteTaskIsLocal(const string& task_name, CollectiveParams* cp);
Dpermuter_test.cc186 string task_name = strings::StrCat("/job:worker/replica:0/task:", wi); in Init() local
189 dev_name = strings::StrCat(task_name, "/device:GPU:0"); in Init()
191 dev_name = strings::StrCat(task_name, "/device:CPU:", di); in Init()
197 col_params_->group.task_names.push_back(task_name); in Init()
/external/webrtc/modules/audio_device/win/
Dcore_audio_utility_win.h85 explicit ScopedMMCSSRegistration(const wchar_t* task_name) { in ScopedMMCSSRegistration() argument
86 RTC_DLOG(INFO) << "ScopedMMCSSRegistration: " << rtc::ToUtf8(task_name); in ScopedMMCSSRegistration()
89 mmcss_handle_ = AvSetMmThreadCharacteristicsW(task_name, &mmcss_task_index); in ScopedMMCSSRegistration()
/external/python/cpython3/Modules/
D_asynciomodule.c85 PyObject *task_name; member
2096 Py_XSETREF(self->task_name, name); in _asyncio_Task___init___impl()
2097 if (self->task_name == NULL) { in _asyncio_Task___init___impl()
2113 Py_CLEAR(task->task_name); in TaskObj_clear()
2123 Py_VISIT(task->task_name); in TaskObj_traverse()
2391 if (self->task_name) { in _asyncio_Task_get_name_impl()
2392 Py_INCREF(self->task_name); in _asyncio_Task_get_name_impl()
2393 return self->task_name; in _asyncio_Task_get_name_impl()
2419 Py_XSETREF(self->task_name, value); in _asyncio_Task_set_name()
/external/tensorflow/tensorflow/core/kernels/
Dcollective_nccl_test.cc141 const string task_name = "/job:worker/replica:0/task:0"; in Init() local
142 col_params_->group.num_devices_per_task[task_name] = num_ranks; in Init()
145 col_params_->group.task_names.push_back(task_name); in Init()

12