| /external/tensorflow/tensorflow/core/data/service/ |
| D | dispatcher_state_test.cc | 62 CreateJobUpdate* create_job = update.mutable_create_job(); in CreateAnonymousJob() local
63 create_job->set_job_id(job_id); in CreateAnonymousJob()
64 create_job->set_dataset_id(dataset_id); in CreateAnonymousJob()
65 create_job->set_processing_mode(ProcessingModeDef::PARALLEL_EPOCHS); in CreateAnonymousJob()
73 CreateJobUpdate* create_job = update.mutable_create_job(); in CreateNamedJob() local
74 create_job->set_job_id(job_id); in CreateNamedJob()
75 create_job->set_dataset_id(dataset_id); in CreateNamedJob()
76 create_job->set_processing_mode(ProcessingModeDef::PARALLEL_EPOCHS); in CreateNamedJob()
77 NamedJobKeyDef* key = create_job->mutable_named_job_key(); in CreateNamedJob()
250 CreateJobUpdate* create_job = update.mutable_create_job(); in TEST() local
[all …]
|
| D | dispatcher_state.cc | 37 CreateJob(update.create_job()); in Apply()
89 void DispatcherState::CreateJob(const CreateJobUpdate& create_job) { in CreateJob() argument
90 int64 job_id = create_job.job_id(); in CreateJob()
92 if (create_job.has_named_job_key()) { in CreateJob()
93 named_job_key.emplace(create_job.named_job_key().name(), in CreateJob()
94 create_job.named_job_key().index()); in CreateJob()
97 if (create_job.optional_num_consumers_case() == in CreateJob()
99 num_consumers = create_job.num_consumers(); in CreateJob()
101 auto job = std::make_shared<Job>(job_id, create_job.dataset_id(), in CreateJob()
102 ProcessingMode(create_job.processing_mode()), in CreateJob()
|
| D | journal_test.cc | 42 CreateJobUpdate* create_job = update.mutable_create_job(); in MakeCreateJobUpdate() local
43 create_job->set_dataset_id(3); in MakeCreateJobUpdate()
44 create_job->set_job_id(8); in MakeCreateJobUpdate()
45 create_job->set_processing_mode(ProcessingModeDef::PARALLEL_EPOCHS); in MakeCreateJobUpdate()
|
| D | dispatcher_impl.cc | 524 CreateJobUpdate* create_job = update.mutable_create_job(); in CreateJob() local
525 create_job->set_job_id(job_id); in CreateJob()
526 create_job->set_dataset_id(dataset_id); in CreateJob()
527 create_job->set_processing_mode(ProcessingModeDef(processing_mode)); in CreateJob()
529 NamedJobKeyDef* key = create_job->mutable_named_job_key(); in CreateJob()
534 create_job->set_num_consumers(num_consumers.value()); in CreateJob()
|
| D | journal.proto | 14 CreateJobUpdate create_job = 2; field
|
| D | dispatcher_state.h | 215 void CreateJob(const CreateJobUpdate& create_job);
|
| /external/autotest/frontend/afe/ |
| D | direct_afe_unittest.py | 24 afe.create_job('job_name', hosts=['a_host'])
|
| D | rpc_interface_unittest.py | 91 job_id = rpc_interface.create_job(name='dummy', priority=self._PRIORITY,
789 job_id = rpc_interface.create_job(name='test',
883 return rpc_interface.create_job(name='test',
1341 job_id = rpc_interface.create_job(name='test',
1355 job_id = rpc_interface.create_job(name='test',
1370 job_id = rpc_interface.create_job(name='test',
1385 job_id = rpc_interface.create_job(name='test',
1658 job_id = rpc_interface.create_job(
|
| D | rpc_interface.py | 960 return create_job(name, priority, control_file, control_type, image=image,
965 def create_job( function
|
| /external/libcups/backend/ |
| D | ipp.c | 59 create_job, /* Support Create-Job? */ member
255 int create_job = 0, /* Does printer support Create-Job? */ in main() local
1212 create_job = 1; in main()
1219 if (create_job && !send_document) in main()
1223 create_job = 0; in main()
1432 create_job = send_document = 0; in main()
1445 monitor.create_job = create_job; in main()
1454 if (create_job) in main()
1586 request = new_request((num_files > 1 || create_job) ? IPP_OP_CREATE_JOB : in main()
1597 if (num_files > 1 || create_job) in main()
[all …]
|
| /external/autotest/site_utils/ |
| D | test_runner_utils_unittest.py | 202 job_id = afe.create_job(control_file, hosts=self._hosts)
218 job_id = afe.create_job(control_file, hosts=self._hosts)
|
| /external/autotest/cli/ |
| D | job.py | 349 def create_job(self): member in job_create_or_clone
519 return self.create_job()
592 return self.create_job()
|
| /external/autotest/server/ |
| D | sequence.py | 156 afe.create_job(
|
| D | frontend.py | 648 def create_job(self, control_file, name=' ', member in AFE
|
| /external/autotest/server/cros/dynamic_suite/ |
| D | suite_unittest.py | 335 job_mock = self.afe.create_job(
733 suite._job_creator.create_job(
788 self.suite._job_creator.create_job(
850 self.suite._job_creator.create_job(
|
| D | suite.py | 375 def create_job(self, test, retry_for=None): member in _SuiteChildJobCreator
398 test_obj = self._afe.create_job(
1015 job = self._job_creator.create_job(test, retry_for=retry_for)
|
| /external/oss-fuzz/infra/build/functions/ |
| D | project_sync_test.py | 76 def create_job(self, parent, job): member in CloudSchedulerClient
|
| D | project_sync.py | 64 cloud_scheduler_client.create_job(parent, job)
|
| /external/libcups/scheduler/ |
| D | cups-lpd.c | 56 static int create_job(http_t *http, const char *dest, const char *title, const char *user, int num_…
325 create_job(http_t *http, /* I - HTTP connection */ in create_job() function
1123 if ((id = create_job(http, dest, title, user, num_options, options)) < 0) in recv_print_job()
|
| D | ipp.c | 74 static void create_job(cupsd_client_t *con, ipp_attribute_t *uri);
437 create_job(con, uri); in cupsdProcessIPPRequest()
5148 create_job(cupsd_client_t *con, /* I - Client connection */ in create_job() function
|
| /external/libcups/tools/ |
| D | ippeveprinter.c | 262 static ippeve_job_t *create_job(ippeve_client_t *client);
1106 create_job(ippeve_client_t *client) /* I - Client */ in create_job() function
3217 if ((job = create_job(client)) == NULL) in ipp_create_job()
3598 if ((job = create_job(client)) == NULL) in ipp_print_job()
3636 if ((job = create_job(client)) == NULL) in ipp_print_uri()
|