| /external/python/cpython2/Modules/_ctypes/libffi/testsuite/libffi.call/ |
| closure_fn6.c | 12 closure_test_fn0(ffi_cif* cif __UNUSED__, void* resp, void** args,
15 *(ffi_arg*)resp =
39 (int)(intptr_t)userdata, (int)*(ffi_arg *)resp);
|
| /external/python/google-api-python-client/samples/storage_serviceaccount_appengine/ |
| main.py | 70 resp, content = http.request(URI + bucket, "GET")
71 if resp.status != 200:
73 err = 'Error: ' + str(resp.status) + ', bucket: ' + bucket + \
|
| /external/robolectric-shadows/shadows/httpclient/src/test/java/org/robolectric/shadows/httpclient/ |
| AndroidHttpClientTest.java | 36 HttpResponse resp = client.execute(new HttpGet("/foo")); local
37 assertThat(resp.getStatusLine().getStatusCode()).isEqualTo(200);
38 assertThat(CharStreams.toString(new InputStreamReader(resp.getEntity().getContent(), UTF_8)))
|
| /external/tensorflow/tensorflow/core/distributed_runtime/ |
| worker_cache_partial.cc | 76 GetStatusResponse resp; local
77 s = rwi->GetStatus(&req, &resp);
80 for (auto& dev_attr : resp.device_attributes()) {
|
| cluster_function_library_runtime.cc | 153 RegisterGraphResponse resp; local
154 TF_RETURN_IF_ERROR(wi->RegisterGraph(&req, &resp));
158 function_data_.push_back(FunctionData(resp.graph_handle(), options.target, wi,
203 RunGraphResponse* resp = new RunGraphResponse(); local
206 call_options, req, resp,
207 [call_options, req, resp, rets, recv_keys, done](const Status& status) {
212 delete resp;
216 for (auto& recv : *resp->mutable_recv()) {
226 delete resp;
237 delete resp;
[all...] |
| rpc_collective_executor_mgr.cc | 85 GetStepSequenceResponse* resp = new GetStepSequenceResponse; local
88 req, resp, [this, req, resp, done](const Status& s) {
95 done(UpdateStepSequences(*resp));
98 delete resp;
130 const GetStepSequenceResponse& resp) {
132 for (const StepSequence& ss : resp.step_sequence()) {
|
| master_session.h | 78 // is "resp->new_graph_version".
81 Status Extend(const ExtendSessionRequest* req, ExtendSessionResponse* resp);
85 PartialRunSetupResponse* resp);
89 MutableRunStepResponseWrapper* resp);
91 Status ListDevices(ListDevicesResponse* resp) const;
94 MakeCallableResponse* resp);
97 RunCallableResponse* resp);
100 ReleaseCallableResponse* resp);
236 MutableRunStepResponseWrapper* resp);
238 MutableRunStepResponseWrapper* resp);
[all...] |
| /external/wpa_supplicant_8/src/eap_peer/ |
| eap_tnc.c | 91 struct wpabuf *resp; local
113 resp = eap_msg_alloc(EAP_VENDOR_IETF, EAP_TYPE_TNC, plen,
115 if (resp == NULL)
118 wpabuf_put_u8(resp, flags); /* Flags */
120 wpabuf_put_be32(resp, wpabuf_len(data->out_buf));
122 wpabuf_put_data(resp, wpabuf_head_u8(data->out_buf) + data->out_used,
144 return resp;
206 struct wpabuf *resp; local
354 resp = eap_msg_alloc(EAP_VENDOR_IETF, EAP_TYPE_TNC, 1,
356 if (resp == NULL
[all...] |
| eap_pax.c | 96 struct wpabuf *resp; local
99 resp = eap_msg_alloc(EAP_VENDOR_IETF, EAP_TYPE_PAX,
101 if (resp == NULL)
104 pax = wpabuf_put(resp, sizeof(*pax));
111 return resp;
120 struct wpabuf *resp; local
191 resp = eap_pax_alloc_resp(req, id, EAP_PAX_OP_STD_2, plen);
192 if (resp == NULL)
195 wpabuf_put_be16(resp, EAP_PAX_RAND_LEN);
196 wpabuf_put_data(resp, data->rand.r.y, EAP_PAX_RAND_LEN)
236 struct wpabuf *resp; local
338 struct wpabuf *resp; local
[all...] |
| eap_leap.c | 64 struct wpabuf *resp; local
109 resp = eap_msg_alloc(EAP_VENDOR_IETF, EAP_TYPE_LEAP,
112 if (resp == NULL)
114 wpabuf_put_u8(resp, LEAP_VERSION);
115 wpabuf_put_u8(resp, 0); /* unused */
116 wpabuf_put_u8(resp, LEAP_RESPONSE_LEN);
117 rpos = wpabuf_put(resp, LEAP_RESPONSE_LEN);
123 wpabuf_free(resp);
129 wpabuf_put_data(resp, identity, identity_len);
133 return resp;
142 struct wpabuf *resp; local
[all...] |
| eap_mschapv2.c | 149 struct wpabuf *resp; local
166 resp = eap_msg_alloc(EAP_VENDOR_IETF, EAP_TYPE_MSCHAPV2, ms_len,
168 if (resp == NULL)
171 ms = wpabuf_put(resp, sizeof(*ms));
185 wpabuf_put_u8(resp, sizeof(*r)); /* Value-Size */
188 r = wpabuf_put(resp, sizeof(*r));
196 wpabuf_free(resp);
211 wpabuf_free(resp);
219 wpabuf_put_data(resp, identity, identity_len);
222 return resp;
348 struct wpabuf *resp; local
655 struct wpabuf *resp; local
[all...] |
| eap_gpsk.c | 280 struct wpabuf *resp; local
301 resp = eap_gpsk_send_gpsk_2(data, identifier,
303 if (resp == NULL)
308 return resp;
317 struct wpabuf *resp; local
329 resp = eap_msg_alloc(EAP_VENDOR_IETF, EAP_TYPE_GPSK, len,
331 if (resp == NULL)
334 wpabuf_put_u8(resp, EAP_GPSK_OPCODE_GPSK_2);
335 start = wpabuf_put(resp, 0);
339 wpabuf_put_be16(resp, data->id_peer_len)
587 struct wpabuf *resp; local
630 struct wpabuf *resp; local
667 struct wpabuf *resp; local
[all...] |
| /external/ltp/testcases/kernel/syscalls/fanotify/ |
| fanotify07.c | 132 struct fanotify_response resp; local
152 resp.fd = event.fd;
153 resp.response = FAN_ALLOW;
154 SAFE_WRITE(1, fd_notify, &resp, sizeof(resp));
|
| /external/skia/tools/lua/ |
| trigger_ct_lua | 39 resp, content = httplib2.Http().request(
41 if resp['status'] != '200':
44 resp['status'], content))
80 resp, content = httplib2.Http().request(CT_GET_SKP_REPOS_URL, "GET")
81 if resp['status'] != '200':
|
| /external/skqp/tools/lua/ |
| trigger_ct_lua | 39 resp, content = httplib2.Http().request(
41 if resp['status'] != '200':
44 resp['status'], content))
80 resp, content = httplib2.Http().request(CT_GET_SKP_REPOS_URL, "GET")
81 if resp['status'] != '200':
|
| /external/syzkaller/vendor/google.golang.org/grpc/ |
| proxy.go | 90 resp, err := http.ReadResponse(r, req)
94 defer resp.Body.Close()
95 if resp.StatusCode != http.StatusOK {
96 dump, err := httputil.DumpResponse(resp, true)
98 return nil, fmt.Errorf("failed to do connect handshake, status code: %s", resp.Status)
|
| /development/samples/SampleSyncAdapter/src/com/example/android/samplesync/client/ |
| NetworkUtilities.java | 106 final HttpResponse resp; local
122 resp = getHttpClient().execute(post);
124 if (resp.getStatusLine().getStatusCode() == HttpStatus.SC_OK) {
125 InputStream istream = (resp.getEntity() != null) ? resp.getEntity().getContent()
136 Log.e(TAG, "Error authenticating" + resp.getStatusLine());
192 final HttpResponse resp = getHttpClient().execute(post); local
193 final String response = EntityUtils.toString(resp.getEntity());
194 if (resp.getStatusLine().getStatusCode() == HttpStatus.SC_OK) {
208 if (resp.getStatusLine().getStatusCode() == HttpStatus.SC_UNAUTHORIZED)
[all...] |
| /external/wpa_supplicant_8/src/utils/ |
| pcsc_funcs.c | 812 unsigned char resp[3]; local
839 len = sizeof(resp);
840 ret = scard_transmit(scard, cmd, cmdlen, resp, &len);
848 wpa_printf(MSG_WARNING, "SCARD: unexpected resp len "
853 if (resp[0] == 0x98 && resp[1] == 0x04) {
860 if (resp[0] == 0x6e) {
865 if (resp[0] != 0x6c && resp[0] != 0x9f && resp[0] != 0x61)
1024 unsigned char resp[3]; local
1056 unsigned char resp[3]; local
1247 unsigned char resp[3], buf[12 + 3 + 2]; local
1348 unsigned char resp[3], buf[64], *pos, *end; local
[all...] |
| /external/python/cpython2/Lib/ |
| smtplib.py | 357 resp = []
374 resp.append(line[4:].strip())
387 errmsg = "\n".join(resp)
427 resp = self.ehlo_resp.split('\n')
428 del resp[0]
429 for each in resp:
544 (code, resp) = self.helo()
546 raise SMTPHeloError(code, resp)
604 (code, resp) = self.docmd("AUTH", AUTH_CRAM_MD5)
607 return (code, resp)
[all...] |
| /external/syzkaller/dashboard/dashapi/ |
| dashapi.go | 104 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/vendor/google.golang.org/api/gensupport/ |
| retry.go | 30 resp, err := f()
33 if resp != nil {
34 status = resp.StatusCode
40 return resp, err
44 if resp != nil && resp.Body != nil {
45 resp.Body.Close()
|
| resumable.go | 92 func statusResumeIncomplete(resp *http.Response) bool {
95 return resp != nil && resp.Header.Get("X-Http-Status-Code-Override") == "308"
158 // Exactly one of resp or err will be nil. If resp is non-nil, the caller must call resp.Body.Close.
159 func (rx *ResumableUpload) Upload(ctx context.Context) (resp *http.Response, err error) {
177 resp, err = rx.transferChunk(ctx)
180 if resp != nil {
181 status = resp.StatusCod
[all...] |
| /device/linaro/bootloader/edk2/AppPkg/Applications/Python/Python-2.7.2/Lib/ |
| smtplib.py | 342 resp = []
355 resp.append(line[4:].strip())
368 errmsg = "\n".join(resp)
408 resp = self.ehlo_resp.split('\n')
409 del resp[0]
410 for each in resp:
525 (code, resp) = self.helo()
527 raise SMTPHeloError(code, resp)
585 (code, resp) = self.docmd("AUTH", AUTH_CRAM_MD5)
588 return (code, resp)
[all...] |
| poplib.py | 124 resp, o = self._getline()
125 if self._debugging > 1: print '*resp*', repr(resp)
126 c = resp[:1]
128 raise error_proto(resp)
129 return resp
135 resp = self._getresp()
145 return resp, list, octets
251 resp = self._shortcmd('QUIT')
253 resp = val
[all...] |
| /external/syzkaller/vendor/google.golang.org/appengine/internal/ |
| metadata.go | 52 resp, err := http.DefaultClient.Do(req)
56 defer resp.Body.Close()
57 if resp.StatusCode != 200 {
58 return nil, fmt.Errorf("metadata server returned HTTP %d", resp.StatusCode)
60 return ioutil.ReadAll(resp.Body)
|
