| /tools/test/connectivity/acts_tests/tests/google/net/ |
| D | DhcpServerTest.py | 57 resp = self._get_response(self._make_discover(hwaddr))
58 asserts.assert_false(None == resp,
60 self.server_addr = getopt(resp, 'server_id')
61 self.dut_hwaddr = resp.getlayer(Ether).src
158 resp = self._get_response(self._make_discover(self.hwaddr))
159 asserts.assert_false(None == resp, "Device did not reply to discover")
160 asserts.assert_true(get_yiaddr(resp).startswith(NETADDR_PREFIX),
165 resp = self._get_response(
167 self._assert_offer(resp)
168 self._assert_broadcast(resp)
[all …]
|
| D | UsbTetheringTest.py | 72 resp = sr1(icmp, timeout=2, iface=self.iface)
73 resp_msg = resp.show(dump=True) if resp else "null"
75 resp and resp.haslayer(ICMP), "Failed to send ICMP: " + resp_msg)
87 resp = sr1(icmpv6, timeout=2, iface=self.iface)
88 resp_msg = resp.show(dump=True) if resp else "null"
90 resp and resp.haslayer(IPv6), "Failed to send ICMPv6: " + resp_msg)
104 resp = sr1(dnsqr, timeout=2, iface=self.iface)
105 resp_msg = resp.show(dump=True) if resp else "null"
107 resp and resp.haslayer(DNS), "Failed to send DNS query: " + resp_msg)
119 resp = sr1(tcp, timeout=2, iface=self.iface)
[all …]
|
| /tools/test/connectivity/acts/framework/acts/controllers/ |
| D | abstract_inst.py | 138 resp = ''
144 resp += resp_tmp
164 resp = resp.rstrip(self._escseq)
166 self._logger.debug('Received %r from %r:%r.', resp, self._ip_addr,
169 return resp
200 resp = self._recv()
201 return resp
236 resp = resp_raw.text
238 resp = resp.replace(char_del, '')
241 resp)
[all …]
|
| /tools/netsim/rust/proto/src/ |
| D | frontend_grpc.rs | 510 .add_unary_handler(&METHOD_FRONTEND_SERVICE_GET_VERSION, move |ctx, req, resp| { in create_frontend_service()
511 instance.get_version(ctx, req, resp) in create_frontend_service()
515 .add_unary_handler(&METHOD_FRONTEND_SERVICE_CREATE_DEVICE, move |ctx, req, resp| { in create_frontend_service()
516 instance.create_device(ctx, req, resp) in create_frontend_service()
520 .add_unary_handler(&METHOD_FRONTEND_SERVICE_DELETE_CHIP, move |ctx, req, resp| { in create_frontend_service()
521 instance.delete_chip(ctx, req, resp) in create_frontend_service()
525 .add_unary_handler(&METHOD_FRONTEND_SERVICE_PATCH_DEVICE, move |ctx, req, resp| { in create_frontend_service()
526 instance.patch_device(ctx, req, resp) in create_frontend_service()
529 builder = builder.add_unary_handler(&METHOD_FRONTEND_SERVICE_RESET, move |ctx, req, resp| { in create_frontend_service()
530 instance.reset(ctx, req, resp) in create_frontend_service()
[all …]
|
| D | packet_streamer_grpc.rs | 82 move |ctx, req, resp| instance.stream_packets(ctx, req, resp), in create_packet_streamer()
|
| /tools/test/connectivity/acts/framework/acts/controllers/rohdeschwarz_lib/ |
| D | smbv100.py | 120 resp = self._query(':SOUR:FREQ:CW?')
122 freq = float(resp.split(';')[0])
156 resp = self._query(':SOUR:POW:LEV:IMM:AMPL?')
158 level = float(resp.split(';')[0])
|
| /tools/test/connectivity/acts/framework/tests/controllers/sl4a_lib/ |
| D | rpc_connection_test.py | 27 def __init__(self, resp): argument
28 self.resp = resp
35 return self.resp
|
| /tools/test/connectivity/acts/framework/acts/controllers/sl4a_lib/ |
| D | rpc_connection.py | 85 resp = self._cmd(start_command)
89 if not resp:
92 result = json.loads(str(resp, encoding='utf8'))
|
| /tools/tradefederation/core/src/com/android/tradefed/util/sl4a/ |
| D | Sl4aClient.java | 252 JSONObject resp = new JSONObject(response); in sendThroughSocket() local
253 if (!resp.isNull("error")) { in sendThroughSocket()
254 throw new IOException(String.format("RPC error: %s", resp.get("error"))); in sendThroughSocket()
256 if (resp.isNull("result")) { in sendThroughSocket()
260 return resp.get("result"); in sendThroughSocket()
|
| /tools/test/connectivity/acts/framework/acts/controllers/spirent_lib/ |
| D | gss6450.py | 53 resp = self._query(put_cmd)
55 return resp
69 resp = self._query(get_cmd)
71 return resp
|
| D | gss7000.py | 69 resp = self._recv()
70 return resp
|
| /tools/tradefederation/core/src/com/android/tradefed/invoker/shard/ |
| D | DynamicShardHelper.java | 184 FeatureResponse resp = null; in getClient() local
186 resp = in getClient()
190 if (resp.hasMultiPartResponse()) { in getClient()
193 resp.getMultiPartResponse()); in getClient()
|
| /tools/security/fuzzing/orphans/libffi/ |
| D | fuzz_ffi.cc | 28 void* resp, void** args, void* userdata) {} in closure_fn() argument
30 void* resp, ffi_raw* args, void* userdata) {} in raw_closure_fn() argument
32 void* resp, ffi_java_raw* args, void* userdata) {} in java_raw_closure_fn() argument
|
| /tools/treble/fetcher/ |
| D | fetcher_lib.py | 85 if e.resp.status in masked_errors:
87 elif e.resp.status in retried_errors:
|
| /tools/test/connectivity/acts/framework/acts/controllers/fuchsia_lib/ |
| D | package_server.py | 80 resp = subprocess.run(f"ip -json route get {dest_ip}".split(),
83 routes = json.loads(resp.stdout)
|
| /tools/test/connectivity/acts_tests/acts_contrib/test_utils/cellular/ |
| D | keysight_chamber.py | 167 resp = inst.query(scpi)
168 return list(map(float, resp.split(',')))
|
| /tools/tradefederation/core/src/com/android/tradefed/config/ |
| D | ConfigurationXmlParser.java | 321 String resp = mConfigDef.addExpectedDevice(deviceName, isFake); in addObject() local
322 if (resp != null) { in addObject()
323 throwException(resp); in addObject()
|
| /tools/acloud/ |
| D | errors.py | 60 return HttpError(http_error.resp.status, str(http_error))
|
| /tools/test/mobly_extensions/tools/results_uploader/src/ |
| D | results_uploader.py | 251 resp = input(
254 if resp.lower() in ('y', 'yes'):
|