Lines Matching refs:rpc_interface
9 from autotest_lib.frontend.afe import models, rpc_interface, frontend_test_utils
43 rpc_interface.add_atomic_group, name='foo',
46 self.assertRaises(model_logic.ValidationError, rpc_interface.add_label,
49 self.assertRaises(model_logic.ValidationError, rpc_interface.add_host,
56 rpc_interface. label_add_hosts, id='platform2',
59 rpc_interface.host_add_labels,
62 platforms = rpc_interface.get_labels(
74 hosts = rpc_interface.get_hosts()
77 hosts = rpc_interface.get_hosts(hostname='host1')
88 hosts = rpc_interface.get_hosts(
96 hosts = rpc_interface.get_hosts(hostname__in=['host1', 'host2'],
102 hosts = rpc_interface.get_hosts(
111 hosts = rpc_interface.get_hosts(
120 job_id = rpc_interface.create_job(name='test', priority='Medium',
125 jobs = rpc_interface.get_jobs(id=job_id)
131 job_id = rpc_interface.create_job(name='flake', priority='Medium',
136 jobs = rpc_interface.get_jobs(id=job_id)
151 self.god.stub_function_to_return(rpc_interface.tko_rpc_interface,
155 job_summaries = rpc_interface.get_jobs_summary(id=job.id)
197 self._check_job_ids(rpc_interface.get_jobs(not_yet_run=True), [queued])
198 self._check_job_ids(rpc_interface.get_jobs(running=True),
201 self._check_job_ids(rpc_interface.get_jobs(finished=True), [complete])
205 self.assertRaises(AssertionError, rpc_interface.get_jobs,
207 self.assertRaises(AssertionError, rpc_interface.get_jobs,
209 self.assertRaises(AssertionError, rpc_interface.get_jobs,
217 self._check_job_ids(rpc_interface.get_jobs(suite=True), [parent_job])
218 self._check_job_ids(rpc_interface.get_jobs(sub=True), [child_jobs])
219 self._check_job_ids(rpc_interface.get_jobs(standalone=True),
224 return rpc_interface.create_job(name='test', priority='Medium',
285 tasks = rpc_interface.get_special_tasks(host__hostname='host1',
299 tasks = rpc_interface.get_special_tasks(
317 rpc_interface.get_host_queue_entries_and_special_tasks(host))
345 self.assertEquals(1, rpc_interface.get_num_hosts(hostname='host1',
347 data = rpc_interface.get_hosts(hostname='host1', valid_only=False)
350 self.assertEquals(1, rpc_interface.get_num_host_queue_entries(
352 data = rpc_interface.get_host_queue_entries(host__hostname='host1')
355 count = rpc_interface.get_num_host_queue_entries_and_special_tasks(
358 data = rpc_interface.get_host_queue_entries_and_special_tasks(
364 hostname_list = rpc_interface.reverify_hosts(id__in=[1, 2])
366 tasks = rpc_interface.get_special_tasks()
377 hostname_list = rpc_interface.repair_hosts(id__in=[1, 2])
379 tasks = rpc_interface.get_special_tasks()
405 job_id = rpc_interface.create_parameterized_job(
476 rpc_interface.modify_host(id=host.id, locked=True,
547 rpc_interface.modify_hosts(
576 rpc_interface.delete_host(id=host1.id)
602 rpc_interface.modify_label(label1.id, invalid=1)
625 rpc_interface.delete_label(id=label1.id)
