Lines Matching refs:rpc_interface
17 models, rpc_interface, rpc_utils)
46 retval = rpc_interface.shard_heartbeat(
88 job_id = rpc_interface.create_job(name='stub', priority=self._PRIORITY,
126 side_effect=lambda: rpc_interface.remove_board_from_shard(
224 rpc_interface.delete_shard(hostname=shard1.hostname)
256 self.old_respect_static_config = rpc_interface.RESPECT_STATIC_ATTRIBUTES
257 rpc_interface.RESPECT_STATIC_ATTRIBUTES = True
264 rpc_interface.RESPECT_STATIC_ATTRIBUTES = self.old_respect_static_config
280 hosts = rpc_interface.get_hosts(hostname=host1.hostname)
299 attributes = rpc_interface.get_host_attribute(
316 hosts = rpc_interface.get_hosts_by_attribute(
337 hosts = rpc_interface.get_hosts_by_attribute(
361 self.old_respect_static_config = rpc_interface.RESPECT_STATIC_LABELS
362 rpc_interface.RESPECT_STATIC_LABELS = True
369 rpc_interface.RESPECT_STATIC_LABELS = self.old_respect_static_config
391 hosts = rpc_interface.get_hosts(hostname=host1.hostname)
405 hosts = rpc_interface.get_hosts(
422 rpc_interface.delete_label, label1.id)
438 rpc_interface.modify_label,
459 rpc_interface.label_add_hosts, id='platform2',
462 rpc_interface.host_add_labels,
465 platforms = rpc_interface.get_labels(
485 rpc_interface.label_add_hosts,
489 rpc_interface.host_add_labels,
492 platforms = rpc_interface.get_labels(
508 rpc_interface.label_remove_hosts,
526 rpc_interface.host_remove_labels(
528 labels = rpc_interface.get_labels(host__hostname__in=['test_host'])
548 rpc_interface.remove_board_from_shard(shard.hostname, label.name)
691 self.assertRaises(model_logic.ValidationError, rpc_interface.add_label,
694 self.assertRaises(model_logic.ValidationError, rpc_interface.add_host,
701 rpc_interface. label_add_hosts, id='platform2',
704 rpc_interface.host_add_labels,
707 platforms = rpc_interface.get_labels(
719 self.assertEquals(rpc_interface.ping_db(), [True])
728 hosts = rpc_interface.get_hosts_by_attribute(
740 attributes = rpc_interface.get_host_attribute(
751 hosts = rpc_interface.get_hosts()
754 hosts = rpc_interface.get_hosts(hostname='host1')
764 hosts = rpc_interface.get_hosts(
771 job_id = rpc_interface.create_job(name='test',
777 jobs = rpc_interface.get_jobs(id=job_id)
792 with patch.object(rpc_interface.tko_rpc_interface,
795 job_summaries = rpc_interface.get_jobs_summary(id=job.id)
839 self._check_job_ids(rpc_interface.get_jobs(not_yet_run=True), [queued])
840 self._check_job_ids(rpc_interface.get_jobs(running=True),
843 self._check_job_ids(rpc_interface.get_jobs(finished=True), [complete])
847 self.assertRaises(AssertionError, rpc_interface.get_jobs,
849 self.assertRaises(AssertionError, rpc_interface.get_jobs,
851 self.assertRaises(AssertionError, rpc_interface.get_jobs,
859 self._check_job_ids(rpc_interface.get_jobs(suite=True), [parent_job])
860 self._check_job_ids(rpc_interface.get_jobs(sub=True), [child_jobs])
861 self._check_job_ids(rpc_interface.get_jobs(standalone=True),
866 return rpc_interface.create_job(name='test',
927 tasks = rpc_interface.get_special_tasks(host__hostname='host1',
941 tasks = rpc_interface.get_special_tasks(
959 rpc_interface.get_host_queue_entries_and_special_tasks(host))
1006 hqes = rpc_interface.get_host_queue_entries_by_insert_time(
1010 hqes = rpc_interface.get_host_queue_entries_by_insert_time(
1014 hqes = rpc_interface.get_host_queue_entries_by_insert_time(
1018 hqes = rpc_interface.get_host_queue_entries_by_insert_time(
1022 hqes = rpc_interface.get_host_queue_entries_by_insert_time(
1026 hqes = rpc_interface.get_host_queue_entries_by_insert_time(
1038 hqes = rpc_interface.get_host_queue_entries_by_insert_time(
1044 hqes = rpc_interface.get_host_queue_entries_by_insert_time(
1053 hqes = rpc_interface.get_host_queue_entries_by_insert_time(
1059 hqes = rpc_interface.get_host_queue_entries_by_insert_time(
1070 self.assertEquals(1, rpc_interface.get_num_hosts(hostname='host1',
1072 data = rpc_interface.get_hosts(hostname='host1', valid_only=False)
1075 self.assertEquals(1, rpc_interface.get_num_host_queue_entries(
1077 data = rpc_interface.get_host_queue_entries(host__hostname='host1')
1080 count = rpc_interface.get_num_host_queue_entries_and_special_tasks(
1083 data = rpc_interface.get_host_queue_entries_and_special_tasks(
1089 hostname_list = rpc_interface.reverify_hosts(id__in=[1, 2])
1091 tasks = rpc_interface.get_special_tasks()
1102 hostname_list = rpc_interface.repair_hosts(id__in=[1, 2])
1104 tasks = rpc_interface.get_special_tasks()
1131 rpc_interface.modify_host(id=host.id,
1205 rpc_interface.modify_hosts(host_filter_data={'status': 'Ready'},
1248 rpc_interface.delete_host(id=host1.id)
1264 rpc_interface.delete_shard(hostname=shard1.hostname)
1285 rpc_interface.modify_label(label1.id, invalid=1)
1306 rpc_interface.delete_label(id=label1.id)
1316 job_id = rpc_interface.create_job(name='test',
1324 image = rpc_interface._get_image_for_job(job, True)
1330 job_id = rpc_interface.create_job(name='test',
1338 image = rpc_interface._get_image_for_job(job, True)
1345 job_id = rpc_interface.create_job(name='test',
1353 image = rpc_interface._get_image_for_job(job, True)
1360 job_id = rpc_interface.create_job(name='test',
1368 image = rpc_interface._get_image_for_job(job, True)
1445 rpc_interface.create_suite_job,
1463 rpc_interface.create_suite_job,
1484 rpc_interface.create_suite_job,
1506 rpc_interface.create_suite_job(name=self._NAME,
1528 rpc_interface.create_suite_job(name=self._NAME,
1551 rpc_interface.create_suite_job(name=self._NAME,
1572 rpc_interface.create_suite_job(name='%s/%s' % (self._NAME,
1620 job_id = rpc_interface.create_job(
1748 rpc_interface.remove_board_from_shard(
1758 rpc_interface.remove_board_from_shard(
1774 shard_id = rpc_interface.add_shard(
1777 rpc_interface.add_shard,
1780 rpc_interface.add_shard,
1787 self.assertEqual(rpc_interface.get_shards(),
1798 shard_id = rpc_interface.add_board_to_shard(
1802 rpc_interface.add_board_to_shard,
1806 rpc_interface.add_board_to_shard,
1813 self.assertEqual(rpc_interface.get_shards(),