| /external/autotest/frontend/afe/ |
| D | frontend_test_utils.py | 19 self.hosts = [models.Host.objects.create(hostname=hostname)
24 acl_group.hosts = self.hosts
25 models.AclGroup.smart_get('Everyone').hosts = []
32 for host in self.hosts:
49 self.hosts[0].labels.add(self.labels[0]) # label1
50 self.hosts[1].labels.add(self.labels[1]) # label2
57 self.hosts[hostnum].labels.add(self.label4) # an atomic group lavel
58 self.hosts[hostnum].labels.add(self.label6) # a normal label
59 self.hosts[6].labels.add(self.label7)
61 self.hosts[hostnum].labels.add(self.label5) # an atomic group lavel
[all …]
|
| D | models_test.py | 30 host1, host2 = self.hosts[1:3]
82 host=self.hosts[0], task=models.SpecialTask.Task.VERIFY,
122 job = self._create_job(hosts=[0])
124 host=self.hosts[0], task=models.SpecialTask.Task.VERIFY,
140 entry = self._create_job(hosts=[1]).hostqueueentry_set.all()[0]
158 self.assertFalse(self.hosts[0].invalid)
159 self.hosts[0].delete()
160 self.assertTrue(self.hosts[0].invalid)
161 self.assertTrue(models.Host.objects.get(id=self.hosts[0].id))
165 for host in self.hosts:
[all …]
|
| D | rpc_interface.py | 92 hosts = []
94 hosts.append(models.Host.smart_get(h.id))
99 rpc_utils.fanout_rpc(hosts, 'delete_label', False, id=id)
132 def add_label_to_hosts(id, hosts): argument
141 host_objs = models.Host.smart_get_bulk(hosts)
148 def label_add_hosts(id, hosts): argument
173 add_label_to_hosts(id, hosts)
175 host_objs = models.Host.smart_get_bulk(hosts)
194 def remove_label_from_hosts(id, hosts): argument
200 host_objs = models.Host.smart_get_bulk(hosts)
[all …]
|
| D | rpc_interface_unittest.py | 57 hosts=['host1', 'host2'])
68 def _check_hostnames(self, hosts, expected_hostnames): argument
69 self.assertEquals(set(host['hostname'] for host in hosts),
74 hosts = rpc_interface.get_hosts()
75 self._check_hostnames(hosts, [host.hostname for host in self.hosts])
77 hosts = rpc_interface.get_hosts(hostname='host1')
78 self._check_hostnames(hosts, ['host1'])
79 host = hosts[0]
88 hosts = rpc_interface.get_hosts(
90 self._check_hostnames(hosts, ['host1'])
[all …]
|
| D | direct_afe_unittest.py | 17 hosts = afe.get_hosts()
18 self.assertEquals(len(hosts), 0)
21 hosts = afe.get_hosts()
22 self.assertEquals(len(hosts), 1)
24 afe.create_job('job_name', hosts=['a_host'])
|
| /external/autotest/scheduler/ |
| D | rdb.py | 197 for payload, hosts in similar_requests.iteritems():
199 response = self.host_query_manager.update_hosts(hosts, **payload)
202 for host in hosts:
251 def lease_hosts(self, hosts): argument
260 unleased_hosts = set(hosts)
301 def _sort_hosts_by_preferred_deps(cls, hosts, preferred_deps): argument
316 hosts = sorted(
317 hosts,
320 return hosts
343 hosts = kwargs.get(rdb_cache_manager.MEMOIZE_KEY, [])
[all …]
|
| D | monitor_db_cleanup_test.py | 30 self.hosts[i].status = models.Host.Status.REPAIR_FAILED
31 self.hosts[i].save()
33 self.hosts[1].locked = True
34 self.hosts[1].save()
36 self.hosts[2].protection = host_protections.Protection.DO_NOT_VERIFY
37 self.hosts[2].save()
56 self.hosts[i].status = models.Host.Status.REPAIR_FAILED
57 self.hosts[i].save()
59 self.hosts[1].locked = True
60 self.hosts[1].save()
[all …]
|
| D | rdb_integration_tests.py | 46 def find_matching_host_for_request(hosts, request): argument
54 if not hosts or not request:
56 for host in hosts:
77 hosts = result.get(request)
79 if hosts and len(hosts) == count:
115 for hosts in result.values():
116 for host in hosts:
135 hosts = list(rdb_lib.acquire_hosts(queue_entries))
136 self.assertTrue(len(hosts) == 1 and hosts[0] is None)
151 hosts = [self.db_helper.create_host('h1', deps=set(['a'])),
[all …]
|
| D | rdb_unittest.py | 109 for request, hosts in self.handler.get_response().iteritems():
110 self.assertTrue(len(hosts) == 1)
111 client_host = rdb_hosts.RDBClientHostWrapper(**hosts[0])
216 hosts = self.all_hosts_query_manager.find_hosts(
219 self.assertTrue(type(hosts) == list and len(hosts) == 1)
220 hosts = self.available_hosts_query_manager.find_hosts(
225 self.assertTrue(len(hosts) == 0)
247 hosts = self.all_hosts_query_manager.get_hosts([db_host.id])
248 self.assertTrue(len(hosts) == 1 and hosts[0].leased)
252 [hosts[0].id], **{'leased': 0})
[all …]
|
| D | monitor_db_cleanup.py | 182 def _choose_subset_of_hosts_to_reverify(self, hosts): argument
185 if (max_at_once > 0 and len(hosts) > max_at_once):
186 return random.sample(hosts, max_at_once)
187 return sorted(hosts)
197 hosts = models.Host.objects.filter(
201 hosts = hosts.exclude(
203 if not hosts:
206 hosts = list(hosts)
207 total_hosts = len(hosts)
208 hosts = self._choose_subset_of_hosts_to_reverify(hosts)
[all …]
|
| D | scheduler_models_unittest.py | 189 hosts = []
192 hosts.append(scheduler_models.Host(row=row, new_record=True))
194 host1 = hosts[expected_order.index('Host1')]
195 host010 = hosts[expected_order.index('HOST010')]
196 host10 = hosts[expected_order.index('host10')]
197 host3 = hosts[expected_order.index('host3')]
198 alice = hosts[expected_order.index('alice')]
212 hosts.sort(cmp=scheduler_models.Host.cmp_for_sort)
213 self.assertEqual(expected_order, [h.hostname for h in hosts])
215 hosts.reverse()
[all …]
|
| D | rdb_cache_manager.py | 113 hosts = func(self, request, count, **kwargs)
114 self.cache.set_line(cache_key, hosts)
115 return hosts
308 def set_line(self, key, hosts): argument
321 if hosts is None:
326 if not hosts or not self.use_cache:
330 self._check_line(hosts, key)
334 self._cache_backend.set(key, set(hosts))
|
| /external/autotest/server/cros/ |
| D | host_lock_manager_unittest.py | 55 def _host_modifier(self, hosts, operation, lock_reason=''): argument
67 self.locked_hosts = self.locked_hosts.union(hosts)
69 self.locked_hosts = self.locked_hosts.difference(hosts)
126 hosts = [self.HOST2]
129 manager.lock(hosts, lock_reason='Locking for test')
135 hosts = [self.HOST1, self.HOST2]
138 manager.lock(hosts, lock_reason='Locking for test')
145 hosts = [self.HOST1, self.HOST2]
146 self.manager.locked_hosts = set(hosts)
147 self.manager.lock(hosts)
[all …]
|
| D | host_lock_manager.py | 47 def locked_hosts(self, hosts): argument
52 self._locked_hosts = hosts
102 def lock(self, hosts, lock_reason='Locked by HostLockManager'): argument
111 new_hosts = set(hosts).difference(self._locked_hosts)
119 def unlock(self, hosts=None): argument
128 if hosts:
129 unknown_hosts = set(hosts).difference(self._locked_hosts)
131 updated_hosts = set(hosts) - unknown_hosts
142 def _host_modifier(self, hosts, operation, lock_reason=None): argument
153 for host in hosts:
|
| /external/autotest/server/ |
| D | profilers.py | 5 from autotest_lib.server import profiler, autotest, standalone_profiler, hosts
67 for host in self.job.hosts:
94 host = hosts.create_host(hostname)
155 def _get_all_failure_logs(self, test, hosts): argument
156 for host, at, autodir in hosts:
175 def _run_clients(self, test, hosts): argument
181 hostnames = [host_info[0].hostname for host_info in hosts]
185 for host, at, autodir in hosts:
206 self._get_all_failure_logs(test, hosts)
218 hosts = self._get_hosts(host)
[all …]
|
| /external/boringssl/src/crypto/x509/ |
| D | x509_vpm.c | 90 if (mode == SET_HOST && id->hosts) in int_x509_param_set_hosts()
92 string_stack_free(id->hosts); in int_x509_param_set_hosts()
93 id->hosts = NULL; in int_x509_param_set_hosts()
102 if (id->hosts == NULL && in int_x509_param_set_hosts()
103 (id->hosts = sk_OPENSSL_STRING_new_null()) == NULL) in int_x509_param_set_hosts()
109 if (!sk_OPENSSL_STRING_push(id->hosts, copy)) in int_x509_param_set_hosts()
112 if (sk_OPENSSL_STRING_num(id->hosts) == 0) in int_x509_param_set_hosts()
114 sk_OPENSSL_STRING_free(id->hosts); in int_x509_param_set_hosts()
115 id->hosts = NULL; in int_x509_param_set_hosts()
141 if (paramid->hosts) in x509_verify_param_zero()
[all …]
|
| /external/autotest/contrib/ |
| D | dhcp_failed_machines.py | 73 hosts = sorted([lookup(h) for h in offenders]) variable
75 pprint.pprint(hosts)
81 (len(hosts), ', '.join(hosts)))
85 (len(hosts), ', '.join(hosts)))
89 (len(hosts), ', '.join(hosts)))
|
| /external/avahi/avahi-daemon/ |
| D | static-hosts.c | 46 AVAHI_LLIST_FIELDS(StaticHost, hosts);
49 static AVAHI_LLIST_HEAD(StaticHost, hosts) = NULL;
92 AVAHI_LLIST_PREPEND(StaticHost, hosts, hosts, s); in static_host_new()
100 AVAHI_LLIST_REMOVE(StaticHost, hosts, hosts, s); in static_host_free()
116 for (h = hosts; h; h = h->hosts_next) in static_host_find()
159 for (h = hosts; h; h = h->hosts_next) in static_hosts_add_to_server()
166 for (h = hosts; h; h = h->hosts_next) in static_hosts_remove_from_server()
260 for (h = hosts; h; h = next) { in static_hosts_load()
276 while(hosts) in static_hosts_free_all()
277 static_host_free(hosts); in static_hosts_free_all()
|
| /external/autotest/cli/ |
| D | site_host.py | 10 from autotest_lib.server import hosts
16 hosts.factory.ssh_user = 'root'
17 hosts.factory.ssh_pass = ''
18 hosts.factory.ssh_port = 22
19 hosts.factory.ssh_verbosity_flag = ''
20 hosts.factory.ssh_options = ''
35 cls, web_server, hosts, platform=None, argument
61 obj.hosts = hosts
108 for host in self.hosts:
112 host_dut = hosts.create_testbed(
[all …]
|
| D | acl.py | 83 hosts = getattr(self, 'hosts')
85 if ((users and (hosts or acls)) or
86 (hosts and acls)):
92 if len(hosts) > 1:
101 self.hosts = hosts[0]
118 if self.hosts:
119 filters['hosts__hostname'] = self.hosts
|
| /external/jetty/src/java/org/eclipse/jetty/server/handler/ |
| D | ContextHandlerCollection.java | 115 Map hosts; in mapContexts() local
118 hosts=(Map)contexts; in mapContexts()
121 hosts=new HashMap(); in mapContexts()
122 hosts.put("*",contexts); in mapContexts()
123 contextMap.put(contextPath, hosts); in mapContexts()
129 contexts=hosts.get(vhost); in mapContexts()
131 hosts.put(vhost,contexts); in mapContexts()
136 Map hosts=(Map)contexts; in mapContexts() local
137 contexts=hosts.get("*"); in mapContexts()
139 hosts.put("*",contexts); in mapContexts()
[all …]
|
| /external/autotest/frontend/afe/doctests/ |
| D | 001_rpc_test.txt | 99 # hosts...
219 ... 'hosts': []}]
227 ... 'hosts': []}]
234 # first, create some hosts and labels to play around with
244 # add hosts to labels
248 # check labels for hosts
281 # add hosts to labels
282 >>> rpc_interface.label_add_hosts(id='label1', hosts=['host1'])
283 >>> rpc_interface.label_add_hosts(id='label2', hosts=['host1', 'host2'])
285 # check labels for hosts
[all …]
|
| /external/autotest/site_utils/ |
| D | host_history.py | 144 def get_results(start_time, end_time, hosts=None, board=None, pool=None, argument
170 hosts=hosts, board=board, pool=pool,
174 def get_history_details(start_time, end_time, hosts=None, board=None, argument
201 results = get_results(start_time=start_time, end_time=end_time, hosts=hosts,
252 results = get_results(hosts=options.hosts,
|
| D | diagnosis_utils.py | 159 hosts = self.rpc_interface.get_hosts(
161 if not hosts:
166 for host in hosts:
196 hosts = self.rpc_interface.get_hosts(
199 if not hosts:
205 if len(hosts) < minimum_duts:
209 ' not enforced.', board, pool, len(hosts),
220 for host in hosts:
226 len(available_hosts), len(hosts), board, pool)
|
| /external/autotest/server/hosts/ |
| D | base_classes.py | 22 from autotest_lib.client.common_lib import hosts
24 from autotest_lib.server.hosts import bootloader
27 class Host(hosts.Host):
62 self.job.hosts.add(self)
80 self.job.hosts.discard(self)
|