Home
last modified time | relevance | path

Searched refs:resp (Results 1 – 25 of 623) sorted by relevance

12345678910>>...25

/external/python/cpython2/Lib/
Dnntplib.py156 resp = self.shortcmd('authinfo user '+user)
157 if resp[:3] == '381':
159 raise NNTPReplyError(resp)
161 resp = self.shortcmd(
163 if resp[:3] != '281':
164 raise NNTPPermanentError(resp)
223 resp = self.getline()
224 if self.debugging: print '*resp*', repr(resp)
225 c = resp[:1]
227 raise NNTPTemporaryError(resp)
[all …]
Dftplib.py217 resp = self.getmultiline()
218 if self.debugging: print '*resp*', self.sanitize(resp)
219 self.lastresp = resp[:3]
220 c = resp[:1]
222 return resp
224 raise error_temp, resp
226 raise error_perm, resp
227 raise error_proto, resp
231 resp = self.getresp()
232 if resp[:1] != '2':
[all …]
/external/python/cpython3/Lib/
Dftplib.py236 resp = self.getmultiline()
238 print('*resp*', self.sanitize(resp))
239 self.lastresp = resp[:3]
240 c = resp[:1]
242 return resp
244 raise error_temp(resp)
246 raise error_perm(resp)
247 raise error_proto(resp)
251 resp = self.getresp()
252 if resp[:1] != '2':
[all …]
Dnntplib.py390 resp, caps = self.capabilities()
449 resp = self._getline()
450 if self.debugging: print('*resp*', repr(resp))
451 resp = resp.decode(self.encoding, self.errors)
452 c = resp[:1]
454 raise NNTPTemporaryError(resp)
456 raise NNTPPermanentError(resp)
458 raise NNTPProtocolError(resp)
459 return resp
476 resp = self._getresp()
[all …]
/external/python/cpython3/Lib/test/
Dtest_httplib.py281 resp = client.HTTPResponse(sock)
282 resp.begin()
284 self.assertEqual(resp.getheader('First'), 'val')
285 self.assertEqual(resp.getheader('Second'), 'val')
301 resp = client.HTTPResponse(sock)
302 resp.begin()
303 self.assertEqual(resp.getheader('Content-Length'), '0')
304 self.assertEqual(resp.msg['Content-Length'], '0')
305 self.assertEqual(resp.getheader("!#$%&'*+-.^_`|~"), 'value')
306 self.assertEqual(resp.msg["!#$%&'*+-.^_`|~"], 'value')
[all …]
Dtest_nntplib.py37 resp, lines = self.server.help()
38 self.assertTrue(resp.startswith("100 "), resp)
43 resp, groups = self.server.list()
49 resp, groups = self.server.list(self.GROUP_PAT)
57 resp = cm.exception.response
58 self.assertTrue(resp.startswith("500 "), resp)
64 resp, groups = self.server.newgroups(dt)
86 resp, descs = self.server.descriptions(self.GROUP_PAT)
89 resp.startswith("215 ") or resp.startswith("282 "), resp)
97 resp, count, first, last, group = result
[all …]
/external/python/cpython2/Lib/test/
Dtest_httplib.py238 resp = httplib.HTTPResponse(sock)
239 resp.begin()
241 self.assertEqual(resp.getheader('First'), 'val')
242 self.assertEqual(resp.getheader('Second'), 'val')
247 resp = (
256 resp = httplib.HTTPResponse(FakeSocket(resp))
257 resp.begin()
258 self.assertIsNotNone(resp.getheader('Public-Key-Pins'))
259 self.assertEqual(resp.getheader('Transfer-Encoding'), 'chunked')
260 self.assertEqual(resp.read(), b'body')
[all …]
/external/wpa_supplicant_8/wpa_supplicant/
Dp2p_supplicant_sd.c183 static void wpas_sd_add_empty(struct wpabuf *resp, u8 srv_proto, in wpas_sd_add_empty() argument
188 if (wpabuf_tailroom(resp) < 5) in wpas_sd_add_empty()
192 len_pos = wpabuf_put(resp, 2); in wpas_sd_add_empty()
193 wpabuf_put_u8(resp, srv_proto); in wpas_sd_add_empty()
194 wpabuf_put_u8(resp, srv_trans_id); in wpas_sd_add_empty()
196 wpabuf_put_u8(resp, status); in wpas_sd_add_empty()
198 WPA_PUT_LE16(len_pos, (u8 *) wpabuf_put(resp, 0) - len_pos - 2); in wpas_sd_add_empty()
202 static void wpas_sd_add_proto_not_avail(struct wpabuf *resp, u8 srv_proto, in wpas_sd_add_proto_not_avail() argument
205 wpas_sd_add_empty(resp, srv_proto, srv_trans_id, in wpas_sd_add_proto_not_avail()
210 static void wpas_sd_add_bad_request(struct wpabuf *resp, u8 srv_proto, in wpas_sd_add_bad_request() argument
[all …]
/external/grpc-grpc/test/core/tsi/alts/handshaker/
Dalts_handshaker_service_api_test_lib.cc70 grpc_gcp_handshaker_resp* resp, const char* application_protocol) { in grpc_gcp_handshaker_resp_set_application_protocol() argument
71 if (resp == nullptr || application_protocol == nullptr) { in grpc_gcp_handshaker_resp_set_application_protocol()
77 resp->has_result = true; in grpc_gcp_handshaker_resp_set_application_protocol()
80 resp->result.application_protocol.arg = slice; in grpc_gcp_handshaker_resp_set_application_protocol()
81 resp->result.application_protocol.funcs.encode = encode_string_or_bytes_cb; in grpc_gcp_handshaker_resp_set_application_protocol()
86 grpc_gcp_handshaker_resp* resp, const char* record_protocol) { in grpc_gcp_handshaker_resp_set_record_protocol() argument
87 if (resp == nullptr || record_protocol == nullptr) { in grpc_gcp_handshaker_resp_set_record_protocol()
93 resp->has_result = true; in grpc_gcp_handshaker_resp_set_record_protocol()
95 resp->result.record_protocol.arg = slice; in grpc_gcp_handshaker_resp_set_record_protocol()
96 resp->result.record_protocol.funcs.encode = encode_string_or_bytes_cb; in grpc_gcp_handshaker_resp_set_record_protocol()
[all …]
Dalts_handshaker_service_api_test_lib.h45 bool grpc_gcp_handshaker_resp_encode(grpc_gcp_handshaker_resp* resp,
50 grpc_gcp_handshaker_resp* resp, const char* application_protocol);
54 grpc_gcp_handshaker_resp* resp, const char* record_protocol);
57 bool grpc_gcp_handshaker_resp_set_key_data(grpc_gcp_handshaker_resp* resp,
62 grpc_gcp_handshaker_resp* resp, const char* hostname);
69 grpc_gcp_handshaker_resp* resp, const char* service_account);
73 grpc_gcp_handshaker_resp* resp, const char* hostname);
80 grpc_gcp_handshaker_resp* resp, const char* service_account);
83 bool grpc_gcp_handshaker_resp_set_channel_open(grpc_gcp_handshaker_resp* resp,
87 bool grpc_gcp_handshaker_resp_set_code(grpc_gcp_handshaker_resp* resp,
[all …]
/external/bouncycastle/bcpkix/src/main/java/org/bouncycastle/cert/ocsp/
DOCSPResp.java26 private OCSPResponse resp; field in OCSPResp
29 OCSPResponse resp) in OCSPResp() argument
31 this.resp = resp; in OCSPResp()
35 byte[] resp) in OCSPResp() argument
38 this(new ByteArrayInputStream(resp)); in OCSPResp()
42 InputStream resp) in OCSPResp() argument
45 this(new ASN1InputStream(resp)); in OCSPResp()
54 this.resp = OCSPResponse.getInstance(aIn.readObject()); in OCSPResp()
69 if (resp == null) in OCSPResp()
77 return this.resp.getResponseStatus().getValue().intValue(); in getStatus()
[all …]
DBasicOCSPResp.java36 private BasicOCSPResponse resp; field in BasicOCSPResp
41 BasicOCSPResponse resp) in BasicOCSPResp() argument
43 this.resp = resp; in BasicOCSPResp()
44 this.data = resp.getTbsResponseData(); in BasicOCSPResp()
45 this.extensions = Extensions.getInstance(resp.getTbsResponseData().getResponseExtensions()); in BasicOCSPResp()
56 return resp.getTbsResponseData().getEncoded(ASN1Encoding.DER); in getTBSResponseData()
71 return resp.getSignatureAlgorithm(); in getSignatureAlgorithmID()
135 return resp.getSignatureAlgorithm().getAlgorithm(); in getSignatureAlgOID()
140 return resp.getSignature().getOctets(); in getSignature()
148 if (resp.getCerts() != null) in getCerts()
[all …]
/external/u-boot/drivers/misc/
Dcros_ec_sandbox.c294 struct ec_response_hello *resp = resp_data; in process_cmd() local
296 resp->out_data = req->in_data + 0x01020304; in process_cmd()
297 len = sizeof(*resp); in process_cmd()
301 struct ec_response_get_version *resp = resp_data; in process_cmd() local
303 strcpy(resp->version_string_ro, "sandbox_ro"); in process_cmd()
304 strcpy(resp->version_string_rw, "sandbox_rw"); in process_cmd()
305 resp->current_image = ec->current_image; in process_cmd()
306 debug("Current image %d\n", resp->current_image); in process_cmd()
307 len = sizeof(*resp); in process_cmd()
312 struct ec_response_vbnvcontext *resp = resp_data; in process_cmd() local
[all …]
Datsha204a-i2c.c175 struct atsha204a_resp *resp) in atsha204a_recv_resp() argument
179 u8 *p = (u8 *) resp; in atsha204a_recv_resp()
185 if (resp->length > 4) { in atsha204a_recv_resp()
186 if (resp->length > sizeof(*resp)) in atsha204a_recv_resp()
189 res = atsha204a_recv(dev, p + 4, resp->length - 4); in atsha204a_recv_resp()
194 resp_crc = (u16) p[resp->length - 2] in atsha204a_recv_resp()
195 | (((u16) p[resp->length - 1]) << 8); in atsha204a_recv_resp()
196 computed_crc = atsha204a_crc16(p, resp->length - 2); in atsha204a_recv_resp()
209 struct atsha204a_resp resp; in atsha204a_wakeup() local
226 res = atsha204a_recv_resp(dev, &resp); in atsha204a_wakeup()
[all …]
/external/wpa_supplicant_8/src/common/
Dgas_server.c28 void (*status_cb)(void *ctx, struct wpabuf *resp, int ok);
37 struct wpabuf *resp; member
47 void (*tx)(void *ctx, int freq, const u8 *da, struct wpabuf *resp,
64 (unsigned long) wpabuf_len(response->resp)); in gas_server_response_timeout()
66 response->resp, 0); in gas_server_response_timeout()
67 response->resp = NULL; in gas_server_response_timeout()
79 wpabuf_free(response->resp); in gas_server_free_response()
92 struct wpabuf *resp; in gas_server_send_resp() local
119 resp = gas_build_initial_resp(dialog_token, WLAN_STATUS_SUCCESS, in gas_server_send_resp()
123 if (!resp) { in gas_server_send_resp()
[all …]
/external/grpc-grpc-java/alts/src/test/java/io/grpc/alts/internal/
DMockAltsHandshakerResp.java75 HandshakerResp.Builder resp = HandshakerResp.newBuilder(); in getErrorResponse() local
76 resp.setStatus( in getErrorResponse()
81 return resp.build(); in getErrorResponse()
86 HandshakerResp.Builder resp = HandshakerResp.newBuilder(); in getOkResponse() local
87 resp.setOutFrames(getOutFrame()); in getOkResponse()
88 resp.setBytesConsumed(bytesConsumed); in getOkResponse()
89 resp.setStatus(HandshakerStatus.newBuilder().setCode(Status.Code.OK.value()).build()); in getOkResponse()
90 return resp.build(); in getOkResponse()
95 HandshakerResp.Builder resp = HandshakerResp.newBuilder(); in getEmptyOutFrameResponse() local
96 resp.setBytesConsumed(bytesConsumed); in getEmptyOutFrameResponse()
[all …]
/external/volley/src/test/java/com/android/volley/toolbox/
DBaseHttpStackTest.java49 org.apache.http.HttpResponse resp = stack.performRequest(REQUEST, ADDITIONAL_HEADERS); in legacyRequestWithoutBody() local
50 assertEquals(12345, resp.getStatusLine().getStatusCode()); in legacyRequestWithoutBody()
51 assertEquals(0, resp.getAllHeaders().length); in legacyRequestWithoutBody()
52 assertNull(resp.getEntity()); in legacyRequestWithoutBody()
69 org.apache.http.HttpResponse resp = stack.performRequest(REQUEST, ADDITIONAL_HEADERS); in legacyResponseWithBody() local
70 assertEquals(12345, resp.getStatusLine().getStatusCode()); in legacyResponseWithBody()
71 assertEquals(0, resp.getAllHeaders().length); in legacyResponseWithBody()
72 assertEquals(555L, resp.getEntity().getContentLength()); in legacyResponseWithBody()
73 assertSame(mContent, resp.getEntity().getContent()); in legacyResponseWithBody()
93 org.apache.http.HttpResponse resp = stack.performRequest(REQUEST, ADDITIONAL_HEADERS); in legacyResponseHeaders() local
[all …]
/external/u-boot/drivers/usb/gadget/
Drndis.c156 rndis_query_cmplt_type *resp; in gen_ndis_query_resp() local
161 resp = (rndis_query_cmplt_type *) r->buf; in gen_ndis_query_resp()
163 if (!resp) in gen_ndis_query_resp()
180 outbuf = (__le32 *) &resp[1]; in gen_ndis_query_resp()
181 resp->InformationBufferOffset = __constant_cpu_to_le32(16); in gen_ndis_query_resp()
645 resp->InformationBufferLength = cpu_to_le32(length); in gen_ndis_query_resp()
646 r->length = length + sizeof *resp; in gen_ndis_query_resp()
647 resp->MessageLength = cpu_to_le32(r->length); in gen_ndis_query_resp()
654 rndis_set_cmplt_type *resp; in gen_ndis_set_resp() local
663 resp = (rndis_set_cmplt_type *) r->buf; in gen_ndis_set_resp()
[all …]
/external/openssh/openbsd-compat/
Dgetrrsetbyname.c385 struct dns_response *resp; in parse_dns_response() local
389 resp = calloc(1, sizeof(*resp)); in parse_dns_response()
390 if (resp == NULL) in parse_dns_response()
397 memcpy(&resp->header, cp, HFIXEDSZ); in parse_dns_response()
401 resp->header.qdcount = ntohs(resp->header.qdcount); in parse_dns_response()
402 resp->header.ancount = ntohs(resp->header.ancount); in parse_dns_response()
403 resp->header.nscount = ntohs(resp->header.nscount); in parse_dns_response()
404 resp->header.arcount = ntohs(resp->header.arcount); in parse_dns_response()
407 if (resp->header.qdcount < 1) { in parse_dns_response()
408 free_dns_response(resp); in parse_dns_response()
[all …]
/external/syzkaller/dashboard/dashapi/
Ddashapi.go104 resp := new(BuilderPollResp)
105 err := dash.Query("builder_poll", req, resp)
106 return resp, err
146 resp := new(JobPollResp)
147 err := dash.Query("job_poll", req, resp)
148 return resp, err
183 resp := new(ReportCrashResp)
184 err := dash.Query("report_crash", crash, resp)
185 return resp, err
201 resp := new(NeedReproResp)
[all …]
/external/syzkaller/syz-ci/
Djobs.go90 resp := jp.process(job)
92 resp.ID, resp.Build.KernelCommit, resp.CrashTitle, resp.Error)
93 if err := jp.dash.JobDone(resp); err != nil {
101 resp *dashapi.JobDoneReq member
119 job.resp = &dashapi.JobDoneReq{
136 job.resp.Error = []byte(req.name + " is empty")
137 jp.Errorf("%s", job.resp.Error)
138 return job.resp
148 job.resp.Error = []byte(fmt.Sprintf("testing is not yet supported for %v machine type.", typ))
149 jp.Errorf("%s", job.resp.Error)
[all …]
/external/python/google-api-python-client/googleapiclient/
Dhttp.py150 resp = None
159 resp.status if resp else exception)
164 resp, content = http.request(uri, method, *args, **kwargs)
187 if not _should_retry_response(resp.status, content):
190 return resp, content
684 resp, content = _retry_request(
688 if resp.status in [200, 206]:
689 if 'content-location' in resp and resp['content-location'] != self._uri:
690 self._uri = resp['content-location']
694 if 'content-range' in resp:
[all …]
/external/python/google-api-python-client/tests/
Dtest_json_model.py151 resp = httplib2.Response({'status': '401'})
152 resp.reason = 'Unauthorized'
156 content = model.response(resp, content)
161 resp['content-type'] = 'application/json'
164 content = model.response(resp, content)
171 resp = httplib2.Response({'status': '200'})
172 resp.reason = 'OK'
175 content = model.response(resp, content)
180 resp = httplib2.Response({'status': '200'})
181 resp.reason = 'OK'
[all …]
/external/syzkaller/dashboard/app/
Drepro_test.go24 resp, _ := c.client.ReportCrash(crash1)
25 c.expectEQ(resp.NeedRepro, true)
32 resp, _ = c.client.ReportCrash(crash1)
33 c.expectEQ(resp.NeedRepro, true)
41 resp, _ = c.client.ReportCrash(crash2)
42 c.expectEQ(resp.NeedRepro, true)
47 resp, _ = c.client.ReportCrash(crash2)
48 c.expectEQ(resp.NeedRepro, false)
52 resp, _ = c.client.ReportCrash(crash2)
53 c.expectEQ(resp.NeedRepro, false)
[all …]
/external/tensorflow/tensorflow/core/distributed_runtime/rpc/
Dgrpc_session.cc124 CreateSessionResponse resp; in CreateImpl() local
125 Status s = master_->CreateSession(call_options, &req, &resp); in CreateImpl()
127 SetHandleAndGraphVersion(resp.session_handle(), resp.graph_version()); in CreateImpl()
161 ExtendSessionResponse resp; in ExtendImpl() local
162 Status s = master_->ExtendSession(call_options, &req, &resp); in ExtendImpl()
164 current_graph_version_ = resp.new_graph_version(); in ExtendImpl()
191 std::unique_ptr<MutableRunStepResponseWrapper> resp( in RunHelper() local
227 TF_RETURN_IF_ERROR(RunProto(&call_options, req.get(), resp.get())); in RunHelper()
230 if (resp->status_code() != error::Code::OK) { in RunHelper()
231 return Status(resp->status_code(), resp->status_error_message()); in RunHelper()
[all …]

12345678910>>...25