/external/tensorflow/tensorflow/python/training/ |
D | server_lib.py | 30 def _make_server_def(server_or_cluster_def, job_name, task_index, protocol, argument 61 if job_name is not None: 62 server_def.job_name = job_name 75 if job_name is None: 77 job_name = cluster_spec.jobs[0] 81 task_indices = cluster_spec.task_indices(job_name) 91 job_name=job_name, task_index=task_index, protocol=protocol) 112 job_name=None, argument 147 job_name, task_index, protocol, config) 286 for job_name, tasks in cluster.items(): [all …]
|
/external/tensorflow/tensorflow/core/distributed_runtime/rpc/ |
D | grpc_tensorflow_server.cc | 41 Status FillServerDef(const string& cluster_spec, const string& job_name, in FillServerDef() argument 44 options->set_job_name(job_name); in FillServerDef() 56 const string& job_name = job_pieces[0]; in FillServerDef() local 57 job_def->set_name(job_name); in FillServerDef() 66 if (job_name == options->job_name()) { in FillServerDef() 69 LOG(INFO) << "Peer " << job_name << " " << num_tasks << " {" in FillServerDef() 73 return errors::InvalidArgument("Job name \"", options->job_name(), in FillServerDef() 78 " is invalid (job \"", options->job_name(), in FillServerDef() 100 tensorflow::string job_name; in main() local 104 tensorflow::Flag("job_name", &job_name, "job name"), in main() [all …]
|
D | grpc_testlib_server.cc | 38 Status FillServerDef(const string& job_spec, const string& job_name, in FillServerDef() argument 42 options->set_job_name(job_name); in FillServerDef() 60 if (job_def->name() == options->job_name()) { in FillServerDef() 81 tensorflow::string job_name; in main() local 87 tensorflow::Flag("tf_job", &job_name, "job name"), in main() 100 tensorflow::Status s = tensorflow::FillServerDef(job_spec, job_name, num_cpus, in main()
|
D | grpc_server_lib.cc | 127 if (job.name() == server_def_.job_name()) { in Init() 132 server_def_.job_name(), "\""); in Init() 145 return errors::Internal("Job \"", server_def_.job_name(), in Init() 155 strings::StrCat("/job:", server_def_.job_name(), "/replica:0", in Init() 294 if (job.name() == *options.job_name && task.first == options.task_index) { in ParseChannelSpec() 307 if (options.job_name == nullptr || options.job_name->empty()) { in WorkerCacheFactory() 322 string name_prefix = strings::StrCat("/job:", *options.job_name, "/replica:0", in WorkerCacheFactory()
|
D | grpc_channel.cc | 194 void ListWorkersInJob(const string& job_name, in ListWorkersInJob() argument 197 cache->ListWorkersInJob(job_name, workers); in ListWorkersInJob() 261 void ListWorkersInJob(const string& job_name, in ListWorkersInJob() argument 263 if (job_name == job_id_) { in ListWorkersInJob()
|
/external/autotest/tko/ |
D | site_parse_unittest.py | 61 job_name='x86-alex-r16-R16-1166.0.0-a1-b1118_bvt', argument 65 board, rev, version = self._stack_trace._parse_job_name(job_name) 75 return job_name, symbols_dir, chroot_symbols_dir 79 job_name = 'x86-alex-r16-R16-1166.0.0-a1-b1118_regression' 81 f.write('label=%s' % job_name) 83 self.assertEqual(self._stack_trace._get_job_name(), job_name) 87 job_name = 'x86-alex-r16-R16-1166.0.0-a1-b1118_regression' 88 board, rev, version = self._stack_trace._parse_job_name(job_name) 95 job_name = 'x86-mario-r15-0.15.1011.74-a1-b61_bvt' 96 board, rev, version = self._stack_trace._parse_job_name(job_name) [all …]
|
D | site_parse.py | 115 def _parse_job_name(self, job_name): argument 128 version = job_name.rsplit('-', 3)[1].split('_')[-1] 129 arch, board, rev = job_name.split('-', 3)[:3]
|
/external/grpc-grpc/tools/failures/sql/ |
D | new_failures_24h.sql | 6 job_name, 12 job_name, 20 AND NOT REGEXP_CONTAINS(job_name, 28 job_name, 35 job_name, 43 AND NOT REGEXP_CONTAINS(job_name, 50 reporting.job_name,
|
/external/tensorflow/tensorflow/python/debug/lib/ |
D | grpc_tensorflow_server.py | 69 job_name = job_string.split("|")[0] 71 if not job_name: 74 job_def.name = job_name 77 logging.info("Added job named \"%s\"", job_name) 88 job_tasks[i], job_name) 99 if not FLAGS.job_name: 101 server_def.job_name = FLAGS.job_name
|
/external/tensorflow/tensorflow/core/protobuf/ |
D | cluster.proto | 37 // cluster { $CLUSTER } job_name: 'local' task_index: 0 46 // cluster { $CLUSTER } job_name: 'local' task_index: 0 47 // cluster { $CLUSTER } job_name: 'local' task_index: 1 60 // cluster { $CLUSTER } job_name: 'worker' task_index: 0 61 // cluster { $CLUSTER } job_name: 'worker' task_index: 1 62 // cluster { $CLUSTER } job_name: 'worker' task_index: 2 63 // cluster { $CLUSTER } job_name: 'ps' task_index: 0 64 // cluster { $CLUSTER } job_name: 'ps' task_index: 1
|
/external/tensorflow/tensorflow/python/distribute/cluster_resolver/ |
D | cluster_resolver.py | 361 for job_name, tasks in cluster_dict.items(): 362 if job_name in merged_cluster: 365 merged_cluster[job_name] = {} 369 merged_cluster[job_name] = [] 371 merged_cluster[job_name] = {} 378 for job_name, tasks in cluster_dict.items(): 379 if isinstance(merged_cluster[job_name], list): 381 merged_cluster[job_name].extend(tasks) 392 merged_keys = set(merged_cluster[job_name].keys()) 399 merged_cluster[job_name].update(task_dict)
|
/external/tensorflow/tensorflow/python/eager/ |
D | remote.py | 30 def connect_to_remote_host(remote_host=None, job_name="worker"): argument 68 job_def.name = job_name 74 job_name=job_name,
|
/external/tensorflow/tensorflow/core/distributed_runtime/ |
D | master_env.h | 39 const string* job_name = nullptr; member 49 if (server_def.has_cluster() && !server_def.job_name().empty()) { in WorkerCacheFactoryOptions() 51 job_name = &server_def.job_name(); in WorkerCacheFactoryOptions()
|
D | worker_cache_wrapper.h | 35 virtual void ListWorkersInJob(const string& job_name, in ListWorkersInJob() argument 37 return wrapped_->ListWorkersInJob(job_name, workers); in ListWorkersInJob()
|
/external/tensorflow/tensorflow/tools/api/golden/v1/ |
D | tensorflow.train.-cluster-spec.pbtxt | 23 argspec: "args=[\'self\', \'job_name\'], varargs=None, keywords=None, defaults=None" 27 argspec: "args=[\'self\', \'job_name\'], varargs=None, keywords=None, defaults=None" 31 …argspec: "args=[\'self\', \'job_name\', \'task_index\'], varargs=None, keywords=None, defaults=Non… 35 argspec: "args=[\'self\', \'job_name\'], varargs=None, keywords=None, defaults=None"
|
/external/tensorflow/tensorflow/tools/api/golden/v2/ |
D | tensorflow.train.-cluster-spec.pbtxt | 23 argspec: "args=[\'self\', \'job_name\'], varargs=None, keywords=None, defaults=None" 27 argspec: "args=[\'self\', \'job_name\'], varargs=None, keywords=None, defaults=None" 31 …argspec: "args=[\'self\', \'job_name\', \'task_index\'], varargs=None, keywords=None, defaults=Non… 35 argspec: "args=[\'self\', \'job_name\'], varargs=None, keywords=None, defaults=None"
|
/external/grpc-grpc/tools/failures/ |
D | detect_new_failures.py | 74 def build_kokoro_url(job_name, build_id): argument 75 job_path = '{}/{}'.format('/job/'.join(job_name.split('/')), build_id) 81 poll_strategy, job_name, build_id, timestamp = results_row 85 url = build_kokoro_url(job_name, build_id) 118 poll_strategy, job_name, build_id, timestamp = results_row 119 full_kokoro_url = build_kokoro_url(job_name, build_id) 153 job_name=row['f'][2]['v'],
|
/external/libcups/cups/ |
D | notify.c | 39 *job_name, /* job-name */ in cupsNotifySubject() local 59 job_name = ippFindAttribute(event, "job-name", IPP_TAG_NAME); in cupsNotifySubject() 108 job_name ? job_name->values[0].string.text : in cupsNotifySubject()
|
/external/autotest/site_utils/admin/scripts/ |
D | check_db_queries.sql | 88 …ct count(*) as values_per_board, left(job_name,instr(job_name,'-0')-1) as board from tko_perf_view…
|
/external/grpc-grpc/tools/run_tests/python_utils/ |
D | upload_test_results.py | 77 job_name = os.getenv('KOKORO_JOB_NAME') 83 if job_name: 84 test_results['job_name'] = job_name
|
/external/tensorflow/tensorflow/core/grappler/costs/ |
D | virtual_placer_test.cc | 115 for (const string& job_name : {"localhost", "worker", "worker_train"}) { in TEST() 119 devices[strings::StrCat("/job:", job_name, "/replica:0/task:0/cpu:0")] = in TEST() 123 devices[strings::StrCat("/job:", job_name, in TEST() 131 EXPECT_EQ(strings::StrCat("/job:", job_name, "/replica:0/task:0/cpu:0"), in TEST() 135 strings::StrCat("/job:", job_name, "/replica:0/task:0/device:GPU:0"), in TEST()
|
/external/autotest/client/common_lib/cros/ |
D | arc.py | 310 def get_job_pid(job_name): argument 312 status = utils.system_output('status %s' % job_name) 313 match = re.match(r'^%s start/running, process (\d+)$' % job_name, 338 def _get_mount_passthrough_pid_internal(job_name): argument 340 job_pid = get_job_pid(job_name) 353 for job_name in JOB_NAMES: 355 pid = _get_mount_passthrough_pid_internal(job_name) 358 logging.warning('Failed to find PID for %s : %s', job_name, e)
|
/external/tensorflow/tensorflow/contrib/eager/python/ |
D | remote_test.py | 60 def get_server_def(job_name, local_server_port, remote_server_addresses, argument 65 job_def.name = job_name 73 job_name=job_name,
|
/external/grpc-grpc/tools/run_tests/performance/ |
D | bq_upload_result.py | 137 job_name = os.getenv('KOKORO_JOB_NAME') 150 if job_name: 151 metadata['jobName'] = job_name
|
/external/autotest/server/cros/dynamic_suite/ |
D | job_status_unittest.py | 105 job_name = 'broken_infra_job' 112 status.entry['job'] = {'name': job_name} 119 expected_name = '%s_%s' % (job_name, job.statuses[i].test_name)
|