Lines Matching refs:rpc_interface
19 from autotest_lib.frontend.afe import rpc_interface
49 retval = rpc_interface.shard_heartbeat(
91 job_id = rpc_interface.create_job(name='dummy', priority=self._PRIORITY,
128 rpc_interface.remove_board_from_shard(shard1.hostname, label1.name)
228 rpc_interface.delete_shard(hostname=shard1.hostname)
260 self.old_respect_static_config = rpc_interface.RESPECT_STATIC_ATTRIBUTES
261 rpc_interface.RESPECT_STATIC_ATTRIBUTES = True
269 rpc_interface.RESPECT_STATIC_ATTRIBUTES = self.old_respect_static_config
285 hosts = rpc_interface.get_hosts(hostname=host1.hostname)
304 attributes = rpc_interface.get_host_attribute(
321 hosts = rpc_interface.get_hosts_by_attribute(
342 hosts = rpc_interface.get_hosts_by_attribute(
367 self.old_respect_static_config = rpc_interface.RESPECT_STATIC_LABELS
368 rpc_interface.RESPECT_STATIC_LABELS = True
376 rpc_interface.RESPECT_STATIC_LABELS = self.old_respect_static_config
398 hosts = rpc_interface.get_hosts(hostname=host1.hostname)
412 hosts = rpc_interface.get_hosts(
432 rpc_interface.delete_label,
453 rpc_interface.modify_label,
475 rpc_interface.label_add_hosts, id='platform2',
478 rpc_interface.host_add_labels,
481 platforms = rpc_interface.get_labels(
501 rpc_interface.label_add_hosts,
505 rpc_interface.host_add_labels,
508 platforms = rpc_interface.get_labels(
524 rpc_interface.label_remove_hosts,
542 rpc_interface.host_remove_labels(
544 labels = rpc_interface.get_labels(host__hostname__in=['test_host'])
564 rpc_interface.remove_board_from_shard(shard.hostname, label.name)
709 self.assertRaises(model_logic.ValidationError, rpc_interface.add_label,
712 self.assertRaises(model_logic.ValidationError, rpc_interface.add_host,
719 rpc_interface. label_add_hosts, id='platform2',
722 rpc_interface.host_add_labels,
725 platforms = rpc_interface.get_labels(
737 self.assertEquals(rpc_interface.ping_db(), [True])
746 hosts = rpc_interface.get_hosts_by_attribute(
758 attributes = rpc_interface.get_host_attribute(
769 hosts = rpc_interface.get_hosts()
772 hosts = rpc_interface.get_hosts(hostname='host1')
782 hosts = rpc_interface.get_hosts(
789 job_id = rpc_interface.create_job(name='test',
795 jobs = rpc_interface.get_jobs(id=job_id)
810 self.god.stub_function_to_return(rpc_interface.tko_rpc_interface,
814 job_summaries = rpc_interface.get_jobs_summary(id=job.id)
856 self._check_job_ids(rpc_interface.get_jobs(not_yet_run=True), [queued])
857 self._check_job_ids(rpc_interface.get_jobs(running=True),
860 self._check_job_ids(rpc_interface.get_jobs(finished=True), [complete])
864 self.assertRaises(AssertionError, rpc_interface.get_jobs,
866 self.assertRaises(AssertionError, rpc_interface.get_jobs,
868 self.assertRaises(AssertionError, rpc_interface.get_jobs,
876 self._check_job_ids(rpc_interface.get_jobs(suite=True), [parent_job])
877 self._check_job_ids(rpc_interface.get_jobs(sub=True), [child_jobs])
878 self._check_job_ids(rpc_interface.get_jobs(standalone=True),
883 return rpc_interface.create_job(name='test',
944 tasks = rpc_interface.get_special_tasks(host__hostname='host1',
958 tasks = rpc_interface.get_special_tasks(
976 rpc_interface.get_host_queue_entries_and_special_tasks(host))
1023 hqes = rpc_interface.get_host_queue_entries_by_insert_time(
1027 hqes = rpc_interface.get_host_queue_entries_by_insert_time(
1031 hqes = rpc_interface.get_host_queue_entries_by_insert_time(
1035 hqes = rpc_interface.get_host_queue_entries_by_insert_time(
1039 hqes = rpc_interface.get_host_queue_entries_by_insert_time(
1043 hqes = rpc_interface.get_host_queue_entries_by_insert_time(
1055 hqes = rpc_interface.get_host_queue_entries_by_insert_time(
1061 hqes = rpc_interface.get_host_queue_entries_by_insert_time(
1070 hqes = rpc_interface.get_host_queue_entries_by_insert_time(
1076 hqes = rpc_interface.get_host_queue_entries_by_insert_time(
1087 self.assertEquals(1, rpc_interface.get_num_hosts(hostname='host1',
1089 data = rpc_interface.get_hosts(hostname='host1', valid_only=False)
1092 self.assertEquals(1, rpc_interface.get_num_host_queue_entries(
1094 data = rpc_interface.get_host_queue_entries(host__hostname='host1')
1097 count = rpc_interface.get_num_host_queue_entries_and_special_tasks(
1100 data = rpc_interface.get_host_queue_entries_and_special_tasks(
1106 hostname_list = rpc_interface.reverify_hosts(id__in=[1, 2])
1108 tasks = rpc_interface.get_special_tasks()
1119 hostname_list = rpc_interface.repair_hosts(id__in=[1, 2])
1121 tasks = rpc_interface.get_special_tasks()
1168 rpc_interface.modify_host(id=host.id, locked=True,
1239 rpc_interface.modify_hosts(
1268 rpc_interface.delete_host(id=host1.id)
1283 rpc_interface.delete_shard(hostname=shard1.hostname)
1309 rpc_interface.modify_label(label1.id, invalid=1)
1332 rpc_interface.delete_label(id=label1.id)
1341 job_id = rpc_interface.create_job(name='test',
1349 image = rpc_interface._get_image_for_job(job, True)
1355 job_id = rpc_interface.create_job(name='test',
1363 image = rpc_interface._get_image_for_job(job, True)
1370 job_id = rpc_interface.create_job(name='test',
1378 image = rpc_interface._get_image_for_job(job, True)
1385 job_id = rpc_interface.create_job(name='test',
1393 image = rpc_interface._get_image_for_job(job, True)
1481 rpc_interface.create_suite_job,
1500 rpc_interface.create_suite_job,
1519 rpc_interface.create_suite_job,
1541 rpc_interface.create_suite_job(name=self._NAME,
1563 rpc_interface.create_suite_job(name=self._NAME,
1586 rpc_interface.create_suite_job(name=self._NAME,
1605 rpc_interface.create_suite_job(name='%s/%s' % (self._NAME,
1651 job_id = rpc_interface.create_job(
1779 rpc_interface.remove_board_from_shard(
1789 rpc_interface.remove_board_from_shard(
1806 shard_id = rpc_interface.add_shard(
1809 rpc_interface.add_shard,
1812 rpc_interface.add_shard,
1819 self.assertEqual(rpc_interface.get_shards(),
1830 shard_id = rpc_interface.add_board_to_shard(
1834 rpc_interface.add_board_to_shard,
1838 rpc_interface.add_board_to_shard,
1845 self.assertEqual(rpc_interface.get_shards(),