Lines Matching refs:rpc_interface
19 from autotest_lib.frontend.afe import rpc_interface
49 self.assertRaises(model_logic.ValidationError, rpc_interface.add_label,
52 self.assertRaises(model_logic.ValidationError, rpc_interface.add_host,
59 rpc_interface. label_add_hosts, id='platform2',
62 rpc_interface.host_add_labels,
65 platforms = rpc_interface.get_labels(
77 hosts = rpc_interface.get_hosts()
80 hosts = rpc_interface.get_hosts(hostname='host1')
90 hosts = rpc_interface.get_hosts(
98 hosts = rpc_interface.get_hosts(hostname__in=['host1', 'host2'],
105 job_id = rpc_interface.create_job(name='test',
111 jobs = rpc_interface.get_jobs(id=job_id)
117 job_id = rpc_interface.create_job(name='flake',
123 jobs = rpc_interface.get_jobs(id=job_id)
138 self.god.stub_function_to_return(rpc_interface.tko_rpc_interface,
142 job_summaries = rpc_interface.get_jobs_summary(id=job.id)
184 self._check_job_ids(rpc_interface.get_jobs(not_yet_run=True), [queued])
185 self._check_job_ids(rpc_interface.get_jobs(running=True),
188 self._check_job_ids(rpc_interface.get_jobs(finished=True), [complete])
192 self.assertRaises(AssertionError, rpc_interface.get_jobs,
194 self.assertRaises(AssertionError, rpc_interface.get_jobs,
196 self.assertRaises(AssertionError, rpc_interface.get_jobs,
204 self._check_job_ids(rpc_interface.get_jobs(suite=True), [parent_job])
205 self._check_job_ids(rpc_interface.get_jobs(sub=True), [child_jobs])
206 self._check_job_ids(rpc_interface.get_jobs(standalone=True),
211 return rpc_interface.create_job(name='test',
272 tasks = rpc_interface.get_special_tasks(host__hostname='host1',
286 tasks = rpc_interface.get_special_tasks(
304 rpc_interface.get_host_queue_entries_and_special_tasks(host))
332 self.assertEquals(1, rpc_interface.get_num_hosts(hostname='host1',
334 data = rpc_interface.get_hosts(hostname='host1', valid_only=False)
337 self.assertEquals(1, rpc_interface.get_num_host_queue_entries(
339 data = rpc_interface.get_host_queue_entries(host__hostname='host1')
342 count = rpc_interface.get_num_host_queue_entries_and_special_tasks(
345 data = rpc_interface.get_host_queue_entries_and_special_tasks(
351 hostname_list = rpc_interface.reverify_hosts(id__in=[1, 2])
353 tasks = rpc_interface.get_special_tasks()
364 hostname_list = rpc_interface.repair_hosts(id__in=[1, 2])
366 tasks = rpc_interface.get_special_tasks()
413 rpc_interface.modify_host(id=host.id, locked=True,
484 rpc_interface.modify_hosts(
513 rpc_interface.delete_host(id=host1.id)
539 rpc_interface.modify_label(label1.id, invalid=1)
562 rpc_interface.delete_label(id=label1.id)
571 job_id = rpc_interface.create_job(name='test',
579 image = rpc_interface._get_image_for_job(job, True)
585 job_id = rpc_interface.create_job(name='test',
593 image = rpc_interface._get_image_for_job(job, True)
600 job_id = rpc_interface.create_job(name='test',
608 image = rpc_interface._get_image_for_job(job, True)
615 job_id = rpc_interface.create_job(name='test',
623 image = rpc_interface._get_image_for_job(job, True)
646 self._SUITE_NAME = rpc_interface.canonicalize_suite_name(
711 rpc_interface.create_suite_job,
730 rpc_interface.create_suite_job,
749 rpc_interface.create_suite_job,
759 rpc_interface.create_suite_job,
766 rpc_interface.create_suite_job,
773 rpc_interface.create_suite_job,
797 rpc_interface.create_suite_job(name=self._NAME,
819 rpc_interface.create_suite_job(name=self._NAME,
842 rpc_interface.create_suite_job(name=self._NAME,
864 rpc_interface.create_suite_job(name=self._NAME,
885 rpc_interface.create_suite_job(name='%s/%s' % (self._NAME,
936 retval = rpc_interface.shard_heartbeat(
976 job_id = rpc_interface.create_job(
1068 job_id = rpc_interface.create_job(name='dummy', priority=self._PRIORITY,
1183 rpc_interface.delete_shard(hostname=shard1.hostname)
1211 shard_id = rpc_interface.add_shard(
1214 rpc_interface.add_shard,
1217 rpc_interface.add_shard,
1224 self.assertEqual(rpc_interface.get_shards(),
1235 shard_id = rpc_interface.add_board_to_shard(
1239 rpc_interface.add_board_to_shard,
1243 rpc_interface.add_board_to_shard,
1250 self.assertEqual(rpc_interface.get_shards(),