| /external/syzkaller/vendor/google.golang.org/api/gensupport/ |
| send.go | 19 type Hook func(ctx context.Context, req *http.Request) func(resp *http.Response)
45 post := make([]func(resp *http.Response), len(hooks))
52 resp, err := ctxhttp.Do(ctx, client, req)
57 fn(resp)
60 return resp, err
|
| /external/wpa_supplicant_8/src/ap/ |
| ieee802_11.c | 60 struct sta_info *sta, u16 *resp,
300 u16 auth_alg, u16 auth_transaction, u16 resp,
322 reply->u.auth.status_code = host_to_le16(resp);
328 " auth_alg=%d auth_transaction=%d resp=%d (IE len=%lu) (dbg=%s)",
330 resp, (unsigned long) ies_len, dbg);
981 int resp = WLAN_STATUS_SUCCESS; local
997 auth_transaction, resp, pos, end - pos,
1005 auth_transaction, resp,
1015 resp = -1;
1020 resp = -1
1435 u16 resp = WLAN_STATUS_SUCCESS; local
1909 u16 resp; local
2028 u16 resp = WLAN_STATUS_SUCCESS; local
2798 u16 resp; local
3698 u16 resp = WLAN_STATUS_SUCCESS, reply_res; local
4402 struct ieee80211_mgmt *resp; local
[all...] |
| /external/tensorflow/tensorflow/core/distributed_runtime/ |
| master.cc | 356 CreateSessionResponse* resp, MyClosure done) {
357 SchedClosure([this, req, resp, done]() {
485 resp->set_session_handle(session->handle());
495 ExtendSessionResponse* resp, MyClosure done) {
502 SchedClosure([session, req, resp, done]() {
505 status = session->Extend(req, resp);
513 PartialRunSetupResponse* resp, MyClosure done) {
526 SchedClosure([session, req, resp, done]() {
527 Status s = session->PartialRunSetup(req, resp);
534 MutableRunStepResponseWrapper* resp, MyClosure done)
[all...] |
| master_test.cc | 70 CreateSessionResponse resp; local
71 const Status s = FromGrpcStatus(master_->CreateSession(&ctx, req, &resp));
73 *handle = resp.session_handle();
74 *initial_version = resp.graph_version();
86 ExtendSessionResponse resp; local
87 const Status s = FromGrpcStatus(master_->ExtendSession(&ctx, req, &resp));
89 *new_version = resp.new_graph_version();
111 RunStepResponse resp; local
112 const Status s = FromGrpcStatus(master_->RunStep(&ctx, req, &resp));
114 for (const auto& fetch_resp : resp.tensor())
127 CloseSessionResponse resp; local
134 ResetResponse resp; local
151 ListDevicesResponse resp; local
[all...] |
| collective_param_resolver_distributed.cc | 216 const CompleteGroupResponse& resp) {
217 // Build a new record from resp.
220 gr->group.device_type = DeviceType(resp.device_type());
221 gr->group.group_key = resp.group_key();
222 gr->group.group_size = resp.group_size();
223 gr->group.num_tasks = resp.num_tasks();
224 if (resp.device_name_size() != gr->group.group_size) {
228 for (const string& dn : resp.device_name()) {
232 if (resp.task_name_size() != gr->group.group_size) {
236 for (const string& tn : resp.task_name())
[all...] |
| master_session.cc | 138 LoggingResponse* resp = new LoggingResponse; local
140 p.worker->LoggingAsync(req, resp, [this, req, resp](const Status& s) {
142 delete resp;
167 LoggingResponse* resp = new LoggingResponse; local
169 &req, resp,
170 [step_id, ss, resp, &scoped_mu, &all_done](const Status& s) {
174 for (auto& lss : resp->step()) {
182 delete resp;
203 MutableRunStepResponseWrapper* resp,
461 RegisterGraphResponse resp; member in struct:tensorflow::Call
504 std::unique_ptr<MutableRunGraphResponseWrapper> resp; member in struct:tensorflow::RunManyGraphs::Call
511 auto resp = get(index)->resp.get(); local
573 RunCallableResponse* resp; \/\/ Not owned. member in struct:tensorflow::__anon44917::RunCallableResponseWrapper
1041 DeregisterGraphResponse resp; member in struct:tensorflow::Call
[all...] |
| /external/u-boot/drivers/misc/ |
| cros_ec.c | 277 struct ec_response_get_comms_status *resp = NULL; local
288 (uint8_t **)&resp, sizeof(*resp));
297 } while (resp->flags & EC_COMMS_STATUS_PROCESSING);
569 struct ec_response_host_event_mask *resp; local
576 (uint8_t **)&resp, sizeof(*resp)) < (int)sizeof(*resp))
579 if (resp->mask & EC_HOST_EVENT_MASK(EC_HOST_EVENT_INVALID))
582 *events_ptr = resp->mask
623 struct ec_response_hello *resp; local
678 struct ec_response_hello *resp; local
980 struct ec_response_ldo_get *resp; local
[all...] |
| /external/scapy/scapy/layers/ |
| dhcp6.py | [all...] |
| /external/grpc-grpc/src/core/tsi/alts/handshaker/ |
| alts_tsi_handshaker.cc | 196 static tsi_result create_handshaker_result(grpc_gcp_handshaker_resp* resp,
199 if (self == nullptr || resp == nullptr) {
203 grpc_slice* key = static_cast<grpc_slice*>(resp->result.key_data.arg);
206 static_cast<grpc_slice*>(resp->result.peer_identity.service_account.arg);
222 if (!resp->result.has_peer_rpc_versions) {
226 if (!grpc_gcp_rpc_protocol_versions_encode(&resp->result.peer_rpc_versions,
380 static bool is_handshake_finished_properly(grpc_gcp_handshaker_resp* resp) {
381 GPR_ASSERT(resp != nullptr);
382 if (resp->has_result) {
438 grpc_gcp_handshaker_resp* resp local
[all...] |
| /external/wpa_supplicant_8/hs20/client/ |
| est.c | 123 char *buf, *resp; local
154 resp = os_readfile("Cert/est-cacerts.txt", &resp_len);
155 if (resp == NULL) {
161 pkcs7 = base64_decode((unsigned char *) resp, resp_len, &pkcs7_len);
172 os_memcpy(pkcs7, resp, resp_len);
176 os_free(resp);
631 char *resp; local
636 resp = os_readfile("Cert/est-csrattrs.txt", &resp_len);
637 if (resp == NULL) {
642 attrs = base64_decode((unsigned char *) resp, resp_len
679 char *buf, *resp, *req, *req2; local
[all...] |
| /frameworks/av/media/libaudioclient/ |
| IEffect.cpp | 175 char *resp = NULL; local
182 resp = (char *)calloc(replySize, 1);
183 if (resp == NULL) {
189 status_t status = command(cmdCode, cmdSize, cmd, &replySz, resp);
197 reply->write(resp, replySize);
203 if (resp) {
204 free(resp);
|
| /external/tensorflow/tensorflow/contrib/verbs/ |
| rdma_mgr.cc | 66 GetRemoteAddressResponse resp; local
92 s = client->GetRemoteAddress(&req, &resp);
96 CHECK(worker_name.compare(resp.host_name()) == 0);
98 ra.lid = resp.channel().lid();
99 ra.qpn = resp.channel().qpn();
100 ra.psn = resp.channel().psn();
101 ra.snp = resp.channel().snp();
102 ra.iid = resp.channel().iid();
107 for (const auto& mr : resp.mr()) {
|
| /external/autotest/site_utils/ |
| pubsub_utils.py | 92 resp = pubsub.projects().topics().publish(
96 if resp:
97 msgIds = resp.get('messageIds')
|
| /external/grpc-grpc/src/core/lib/iomgr/ |
| tcp_uv.cc | 343 struct addrinfo* resp; local
348 for (resp = result; resp != nullptr; resp = resp->ai_next) {
353 for (resp = result, i = 0; resp != nullptr; resp = resp->ai_next, i++) {
354 memcpy(&addresses->addrs[i].addr, resp->ai_addr, resp->ai_addrlen)
[all...] |
| /external/u-boot/drivers/mmc/ |
| sandbox_mmc.c | 50 u32 *resp = (u32 *)data->dest; local
51 resp[7] = cpu_to_be32(SD_HIGHSPEED_BUSY);
53 resp[4] = (cmd->cmdarg & 0xF) << 24;
|
| /external/wpa_supplicant_8/src/eap_peer/ |
| eap_tls.c | 154 struct wpabuf *resp, u8 id)
161 if (resp) {
166 return resp;
233 struct wpabuf *resp; local
245 resp = data->pending_resp;
248 return resp;
277 resp = NULL;
280 id, &msg, &resp);
283 return eap_tls_failure(sm, data, ret, res, resp, id);
290 data->pending_resp = resp;
[all...] |
| /external/python/cpython3/Lib/ |
| smtplib.py | 382 resp = []
400 resp.append(line[4:].strip(b' \t\r\n'))
413 errmsg = b"\n".join(resp)
454 resp = self.ehlo_resp.decode("latin-1").split('\n')
455 del resp[0]
456 for each in resp:
601 (code, resp) = self.helo()
603 raise SMTPHeloError(code, resp)
631 (code, resp) = self.docmd("AUTH", mechanism + " " + response)
633 (code, resp) = self.docmd("AUTH", mechanism
[all...] |
| /external/python/google-api-python-client/googleapiclient/ |
| http.py | 148 resp, content - Response from the http request (may be HTTP 5xx).
150 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
[all...] |
| /external/autotest/client/cros/cellular/pseudomodem/ |
| client.py | 260 resp = raw_input('Are you sure? (yes/no): ')
261 if resp == 'yes':
264 if resp != 'no':
265 print '\nDid not understand: ' + resp + '\n'
|
| /external/autotest/frontend/afe/json_rpc/ |
| proxy.py | 139 resp = decoder.JSONDecoder().decode(respdata)
142 if resp['error'] is not None:
143 raise BuildException(resp['error'])
145 return resp['result']
|
| /external/grpc-grpc/src/ruby/lib/grpc/generic/ |
| rpc_desc.rb | 60 resp = mth.call(req, call)
62 resp,
76 resp = mth.call(call)
78 resp,
|
| /external/grpc-grpc-java/alts/src/test/java/io/grpc/alts/internal/ |
| AltsHandshakerStubTest.java | 63 HandshakerResp resp = stub.send(req.build()); local
64 assertEquals(resp.getOutFrames().toStringUtf8(), message);
154 HandshakerResp.Builder resp = HandshakerResp.newBuilder(); local
155 reader.onNext(resp.setOutFrames(req.getNext().getInBytes()).build());
|
| /external/openssh/ |
| auth-pam.c | 355 struct pam_response **resp, void *data)
363 *resp = NULL;
390 reply[i].resp = buffer_get_string(&buffer, NULL);
406 *resp = reply;
411 free(reply[i].resp);
547 struct pam_response **resp, void *data)
557 struct pam_response **resp, void *data)
564 *resp = NULL;
585 *resp = reply;
590 free(reply[i].resp);
[all...] |
| /external/skia/bin/ |
| try.py | 98 resp = raw_input('\nDo you want to trigger these jobs? (y/n or i for '
101 if resp != 'y' and resp != 'i':
103 if resp == 'i':
|
| /external/skqp/bin/ |
| try.py | 98 resp = raw_input('\nDo you want to trigger these jobs? (y/n or i for '
101 if resp != 'y' and resp != 'i':
103 if resp == 'i':
|
