Lines Matching refs:rpc_interface
19 from autotest_lib.frontend.afe import rpc_interface
46 retval = rpc_interface.shard_heartbeat(
88 job_id = rpc_interface.create_job(name='dummy', priority=self._PRIORITY,
125 rpc_interface.remove_board_from_shard(shard1.hostname, label1.name)
225 rpc_interface.delete_shard(hostname=shard1.hostname)
257 self.old_respect_static_config = rpc_interface.RESPECT_STATIC_ATTRIBUTES
258 rpc_interface.RESPECT_STATIC_ATTRIBUTES = True
266 rpc_interface.RESPECT_STATIC_ATTRIBUTES = self.old_respect_static_config
282 hosts = rpc_interface.get_hosts(hostname=host1.hostname)
301 attributes = rpc_interface.get_host_attribute(
318 hosts = rpc_interface.get_hosts_by_attribute(
339 hosts = rpc_interface.get_hosts_by_attribute(
364 self.old_respect_static_config = rpc_interface.RESPECT_STATIC_LABELS
365 rpc_interface.RESPECT_STATIC_LABELS = True
373 rpc_interface.RESPECT_STATIC_LABELS = self.old_respect_static_config
395 hosts = rpc_interface.get_hosts(hostname=host1.hostname)
409 hosts = rpc_interface.get_hosts(
429 rpc_interface.delete_label,
450 rpc_interface.modify_label,
472 rpc_interface.label_add_hosts, id='platform2',
475 rpc_interface.host_add_labels,
478 platforms = rpc_interface.get_labels(
498 rpc_interface.label_add_hosts,
502 rpc_interface.host_add_labels,
505 platforms = rpc_interface.get_labels(
521 rpc_interface.label_remove_hosts,
539 rpc_interface.host_remove_labels(
541 labels = rpc_interface.get_labels(host__hostname__in=['test_host'])
561 rpc_interface.remove_board_from_shard(shard.hostname, label.name)
706 self.assertRaises(model_logic.ValidationError, rpc_interface.add_label,
709 self.assertRaises(model_logic.ValidationError, rpc_interface.add_host,
716 rpc_interface. label_add_hosts, id='platform2',
719 rpc_interface.host_add_labels,
722 platforms = rpc_interface.get_labels(
734 self.assertEquals(rpc_interface.ping_db(), [True])
743 hosts = rpc_interface.get_hosts_by_attribute(
755 attributes = rpc_interface.get_host_attribute(
766 hosts = rpc_interface.get_hosts()
769 hosts = rpc_interface.get_hosts(hostname='host1')
779 hosts = rpc_interface.get_hosts(
786 job_id = rpc_interface.create_job(name='test',
792 jobs = rpc_interface.get_jobs(id=job_id)
798 job_id = rpc_interface.create_job(name='flake',
804 jobs = rpc_interface.get_jobs(id=job_id)
819 self.god.stub_function_to_return(rpc_interface.tko_rpc_interface,
823 job_summaries = rpc_interface.get_jobs_summary(id=job.id)
865 self._check_job_ids(rpc_interface.get_jobs(not_yet_run=True), [queued])
866 self._check_job_ids(rpc_interface.get_jobs(running=True),
869 self._check_job_ids(rpc_interface.get_jobs(finished=True), [complete])
873 self.assertRaises(AssertionError, rpc_interface.get_jobs,
875 self.assertRaises(AssertionError, rpc_interface.get_jobs,
877 self.assertRaises(AssertionError, rpc_interface.get_jobs,
885 self._check_job_ids(rpc_interface.get_jobs(suite=True), [parent_job])
886 self._check_job_ids(rpc_interface.get_jobs(sub=True), [child_jobs])
887 self._check_job_ids(rpc_interface.get_jobs(standalone=True),
892 return rpc_interface.create_job(name='test',
953 tasks = rpc_interface.get_special_tasks(host__hostname='host1',
967 tasks = rpc_interface.get_special_tasks(
985 rpc_interface.get_host_queue_entries_and_special_tasks(host))
1032 hqes = rpc_interface.get_host_queue_entries_by_insert_time(
1036 hqes = rpc_interface.get_host_queue_entries_by_insert_time(
1040 hqes = rpc_interface.get_host_queue_entries_by_insert_time(
1044 hqes = rpc_interface.get_host_queue_entries_by_insert_time(
1048 hqes = rpc_interface.get_host_queue_entries_by_insert_time(
1052 hqes = rpc_interface.get_host_queue_entries_by_insert_time(
1064 hqes = rpc_interface.get_host_queue_entries_by_insert_time(
1070 hqes = rpc_interface.get_host_queue_entries_by_insert_time(
1079 hqes = rpc_interface.get_host_queue_entries_by_insert_time(
1085 hqes = rpc_interface.get_host_queue_entries_by_insert_time(
1096 self.assertEquals(1, rpc_interface.get_num_hosts(hostname='host1',
1098 data = rpc_interface.get_hosts(hostname='host1', valid_only=False)
1101 self.assertEquals(1, rpc_interface.get_num_host_queue_entries(
1103 data = rpc_interface.get_host_queue_entries(host__hostname='host1')
1106 count = rpc_interface.get_num_host_queue_entries_and_special_tasks(
1109 data = rpc_interface.get_host_queue_entries_and_special_tasks(
1115 hostname_list = rpc_interface.reverify_hosts(id__in=[1, 2])
1117 tasks = rpc_interface.get_special_tasks()
1128 hostname_list = rpc_interface.repair_hosts(id__in=[1, 2])
1130 tasks = rpc_interface.get_special_tasks()
1177 rpc_interface
1248 rpc_interface.modify_hosts(
1277 rpc_interface.delete_host(id=host1.id)
1303 rpc_interface.modify_label(label1.id, invalid=1)
1326 rpc_interface.delete_label(id=label1.id)
1335 job_id = rpc_interface.create_job(name='test',
1343 image = rpc_interface._get_image_for_job(job, True)
1349 job_id = rpc_interface.create_job(name='test',
1357 image = rpc_interface._get_image_for_job(job, True)
1364 job_id = rpc_interface.create_job(name='test',
1372 image = rpc_interface._get_image_for_job(job, True)
1379 job_id = rpc_interface.create_job(name='test',
1387 image = rpc_interface._get_image_for_job(job, True)
1410 self._SUITE_NAME = rpc_interface.canonicalize_suite_name(
1475 rpc_interface.create_suite_job,
1494 rpc_interface.create_suite_job,
1513 rpc_interface.create_suite_job,
1535 rpc_interface.create_suite_job(name=self._NAME,
1557 rpc_interface.create_suite_job(name=self._NAME,
1580 rpc_interface.create_suite_job(name=self._NAME,
1599 rpc_interface.create_suite_job(name='%s/%s' % (self._NAME,
1645 job_id = rpc_interface.create_job(
1773 rpc_interface.remove_board_from_shard(
1783 rpc_interface.remove_board_from_shard(
1800 shard_id = rpc_interface.add_shard(
1803 rpc_interface.add_shard,
1806 rpc_interface.add_shard,
1813 self.assertEqual(rpc_interface.get_shards(),
1824 shard_id = rpc_interface.add_board_to_shard(
1828 rpc_interface.add_board_to_shard,
1832 rpc_interface.add_board_to_shard,
1839 self.assertEqual(rpc_interface.get_shards(),
