| /device/linaro/bootloader/edk2/ShellPkg/Include/Library/ |
| ShellLib.h | [all...] |
| /external/nist-sip/java/gov/nist/javax/sip/stack/ |
| TLSMessageChannel.java | 55 import javax.sip.message.Response;
157 // Can drop this after response is sent potentially.
353 // JvB: send a 400 response for requests (except ACK)
407 // For response, this has already been recorded in the outgoing
493 SIPResponse response = sipRequest local
494 .createResponse(Response.SERVICE_UNAVAILABLE);
498 // Be a good citizen and send a decent response code back.
501 response.setHeader(retryAfter);
502 this.sendMessage(response);
517 .logError("Dropping Badly formatted response message >>>
[all...] |
| SIPServerTransaction.java | 61 import javax.sip.message.Response;
81 * send response+-----------+
83 * | | Proceeding| |send response
90 * send response | |send response |
94 * send response+-----------+ send response |
130 * | |send response
132 * |send response |
135 * send response+-----------+send response
[all...] |
| /external/okhttp/okhttp/src/main/java/com/squareup/okhttp/internal/io/ |
| RealConnection.java | 27 import com.squareup.okhttp.Response;
270 Response response = tunnelConnection.readResponse().request(tunnelRequest).build(); local
271 // The response body from a CONNECT should be empty, but if it is not then we should consume
273 long contentLength = OkHeaders.contentLength(response);
281 switch (response.code()) {
294 route.getAddress().getAuthenticator(), response, route.getProxy());
300 "Unexpected response code for CONNECT: " + response.code());
|
| /external/okhttp/repackaged/okhttp/src/main/java/com/android/okhttp/internal/io/ |
| RealConnection.java | 28 import com.android.okhttp.Response;
274 Response response = tunnelConnection.readResponse().request(tunnelRequest).build(); local
275 // The response body from a CONNECT should be empty, but if it is not then we should consume
277 long contentLength = OkHeaders.contentLength(response);
285 switch (response.code()) {
298 route.getAddress().getAuthenticator(), response, route.getProxy());
304 "Unexpected response code for CONNECT: " + response.code());
|
| /external/python/httplib2/python3/httplib2/ |
| __init__.py | 69 "Response",
90 def __init__(self, desc, response, content):
91 self.response = response
202 def _get_end2end_headers(response):
204 hopbyhop.extend([x.strip() for x in response.get("connection", "").split(",")])
205 return [header for header in list(response.keys()) if header not in hopbyhop]
434 def _decompressContent(response, new_content):
437 encoding = response.get("content-encoding", None)
443 response["content-length"] = str(len(content)
570 def response(self, response, content): member in class:Authentication
690 def response(self, response, content): member in class:DigestAuthentication
800 def response(self, response, content): member in class:HmacDigestAuthentication
[all...] |
| /external/syzkaller/vendor/golang.org/x/oauth2/ |
| transport.go | 36 func (t *Transport) RoundTrip(req *http.Request) (*http.Response, error) {
|
| /external/syzkaller/vendor/google.golang.org/api/transport/http/ |
| dial.go | 79 func (t userAgentTransport) RoundTrip(req *http.Request) (*http.Response, error) {
|
| /external/tensorflow/tensorflow/contrib/ignite/kernels/igfs/ |
| igfs_messages.cc | 59 Status Response::Read(ExtendedTCPClient *client) {
314 TF_RETURN_IF_ERROR(Response::Read(client));
|
| /external/volley/src/test/java/com/android/volley/toolbox/ |
| BasicNetworkTest.java | 34 import com.android.volley.Response;
114 NetworkResponse response = httpNetwork.performRequest(request); local
116 // Should have all server headers + cache headers that didn't show up in server response.
124 assertThat(expectedHeaders, containsInAnyOrder(response.allHeaders.toArray(new Header[0])));
148 NetworkResponse response = httpNetwork.performRequest(request); local
150 // Should have all server headers + cache headers that didn't show up in server response.
158 assertThat(expectedHeaders, containsInAnyOrder(response.allHeaders.toArray(new Header[0])));
324 protected Response<String> parseNetworkResponse(NetworkResponse response) {
329 protected void deliverResponse(String response) {}
[all...] |
| /cts/tests/framework/base/windowmanager/util/src/android/server/wm/ |
| CommandSession.java | 54 * can control whether to send an async or sync command with response data.
60 * final Bundle response = session.requestOrientation(
62 * Log.i("Test", "Config: " + CommandSession.getConfigInfo(response));
63 * Log.i("Test", "Callbacks: " + CommandSession.getCallbackHistory(response));
160 * (require response) at a time.
165 private final Response mPendingResponse = new Response();
166 // Only set when requiring response.
321 private static class Response {
340 throw new TimeoutException("No response over " + TIMEOUT_MILLIS + "ms")
[all...] |
| /device/linaro/bootloader/edk2/NetworkPkg/HttpBootDxe/ |
| HttpBootSupport.c | 757 // Create TimeoutEvent for response
896 Synchronously receive a HTTP RESPONSE message from the server.
899 @param[in] RecvMsgHeader TRUE to receive a new HTTP response (from message header).
900 FALSE to continue receive the previous response message.
901 @param[out] ResponseData Point to a wrapper of the received response data.
903 @retval EFI_SUCCESS The HTTP response is received.
933 // Queue the response token to HTTP instances.
937 HttpIo->RspToken.Message->Data.Response = &ResponseData->Response;
939 HttpIo->RspToken.Message->Data.Response = NULL;
[all...] |
| /external/libbrillo/brillo/dbus/ |
| exported_object_manager_unittest.cc | 124 std::unique_ptr<dbus::Response> CallHandleGetManagedObjects() {
154 auto response = CallHandleGetManagedObjects(); local
155 dbus::MessageReader reader(response.get());
168 auto response = CallHandleGetManagedObjects(); local
169 dbus::MessageReader reader(response.get());
|
| /external/pdfium/fpdfsdk/fpdfxfa/ |
| cpdfxfa_context.cpp | 284 WideString CPDFXFA_Context::Response(const WideString& wsQuestion,
|
| /external/python/oauth2client/tests/ |
| test_client.py | 369 response = mock.MagicMock()
371 response.status = http_client.OK
372 response.getheader = mock.MagicMock(
376 response.status = http_client.NOT_FOUND
380 return_value=response)
416 self.assertEqual(response.method_calls, [])
418 response.getheader.assert_called_once_with(
426 self.assertEqual(response.method_calls, [])
427 self.assertEqual(response.getheader.mock_calls, [])
[all...] |
| /external/tensorflow/tensorflow/core/distributed_runtime/rpc/ |
| grpc_master_service.cc | 96 method##Request, method##Response>:: \
155 master_impl_->CreateSession(rewritten_req, &call->response,
166 master_impl_->ExtendSession(&call->request, &call->response,
176 master_impl_->PartialRunSetup(&call->request, &call->response,
195 new NonOwnedProtoRunStepResponse(&call->response);
206 call->response.set_status_code(status.code());
207 call->response.set_status_error_message(status.error_message());
219 master_impl_->CloseSession(&call->request, &call->response,
229 master_impl_->ListDevices(&call->request, &call->response,
238 master_impl_->Reset(&call->request, &call->response,
[all...] |
| grpc_worker_service.cc | 79 method##Request, method##Response>:: \
189 void method##Handler(WorkerCall<method##Request, method##Response>* call) { \
191 Status s = worker_->method(&call->request, &call->response); \
193 VLOG(1) << "Bad response from " << #method << ": " << s; \
216 &call->request, &call->response, [call](const Status& s) {
217 VLOG(1) << "Bad response from GetStepSequence:" << s;
230 new NonOwnedProtoRunGraphResponse(&call->response);
236 VLOG(1) << "Bad response from RunGraph:" << s;
253 cache_->LookupOrCompute(request_key, RPCResponse(&call->response),
272 VLOG(1) << "Bad response from RecvTensor:" << s
[all...] |
| /external/syzkaller/vendor/google.golang.org/api/googleapi/ |
| googleapi.go | 37 // ServerResponse is embedded in each Do response and
40 // HTTPStatusCode is the server's response status code.
43 // Header contains the response header fields from the server.
61 // Error contains an error response from the server.
63 // Code is the HTTP response status code and will always be populated.
65 // Message is the server response message and is only populated when
66 // explicitly referenced by the JSON server response.
68 // Body is the raw response returned by the server.
71 // Header contains the response header fields from the server.
87 return fmt.Sprintf("googleapi: got HTTP response code %d with body: %v", e.Code, e.Body
[all...] |
| /external/v8/src/inspector/ |
| v8-debugger.cc | 385 m_stepIntoAsyncCallback->sendFailure(Response::Error(
406 Response::Error("There is current termination request in progress"));
433 Response V8Debugger::continueToLocation(
452 return Response::OK();
454 return Response::Error("Cannot continue to specified location");
495 Response::Error("No async tasks were scheduled before pause."));
[all...] |
| /device/linaro/bootloader/edk2/MdeModulePkg/Bus/Ufs/UfsBlockIoPei/ |
| UfsHci.h | 456 UINT16 RuL; /* Response UPIU Length */
457 UINT16 RuO; /* Response UPIU Offset */
532 // UFS 2.0 Spec Section 10.5.4 - UTP Response UPIU
551 UINT8 Response; /* Response */
769 // UFS 2.0 Spec Section 10.5.9 - UTP Task Management Response UPIU
786 UINT8 Resp; /* Response */
847 UTP_TM_RESP_UPIU TmResp; /* Task Management Response UPIU */
922 // UFS 2.0 Spec Section 10.5.11 - UTP Query Response UPIU
940 UINT8 QueryResp; /* Query Response */
[all...] |
| /device/linaro/bootloader/edk2/MdeModulePkg/Bus/Ufs/UfsPassThruDxe/ |
| UfsPassThruHci.h | 456 UINT16 RuL; /* Response UPIU Length */
457 UINT16 RuO; /* Response UPIU Offset */
532 // UFS 2.0 Spec Section 10.5.4 - UTP Response UPIU
551 UINT8 Response; /* Response */
769 // UFS 2.0 Spec Section 10.5.9 - UTP Task Management Response UPIU
786 UINT8 Resp; /* Response */
847 UTP_TM_RESP_UPIU TmResp; /* Task Management Response UPIU */
922 // UFS 2.0 Spec Section 10.5.11 - UTP Query Response UPIU
940 UINT8 QueryResp; /* Query Response */
[all...] |
| /external/golang-protobuf/protoc-gen-go/ |
| main.go | 60 // Begin by allocating a generator. The request and response structures are stored there
61 // so we can do error handling easily - the response structure contains the field to
90 data, err = proto.Marshal(g.Response)
|
| /external/grpc-grpc/src/csharp/Grpc.Core/ |
| Method.cs | 29 /// <summary>Single request sent from client, single response received from server.</summary>
32 /// <summary>Stream of request sent from client, single response received from server.</summary>
73 /// <typeparam name="TResponse">Response message type for this method.</typeparam>
90 /// <param name="responseMarshaller">Marshaller used for response messages.</param>
146 /// Gets the marshaller used for response messages.
|
| /external/libbrillo/brillo/http/ |
| http_transport_curl.cc | 462 LOG(INFO) << "Response: " << connection->GetResponseStatusCode() << " ("
466 // Rewind the response data stream to the beginning so the clients can
475 std::unique_ptr<Response> resp{new Response{request_data->connection}};
|
| /external/python/httplib2/python2/httplib2/ |
| __init__.py | 140 "Response",
186 def __init__(self, desc, response, content):
187 self.response = response
288 def _get_end2end_headers(response):
290 hopbyhop.extend([x.strip() for x in response.get("connection", "").split(",")])
291 return [header for header in response.keys() if header not in hopbyhop]
514 def _decompressContent(response, new_content):
517 encoding = response.get("content-encoding", None)
523 response["content-length"] = str(len(content)
623 def response(self, response, content): member in class:Authentication
722 def response(self, response, content): member in class:DigestAuthentication
832 def response(self, response, content): member in class:HmacDigestAuthentication
[all...] |
