| /external/syzkaller/vendor/google.golang.org/api/gensupport/ |
| retry.go | 27 // the HTTP status response indicates the request should be attempted again. ctx may be nil.
28 func Retry(ctx context.Context, f func() (*http.Response, error), backoff BackoffStrategy) (*http.Response, error) {
43 // Ensure the response body is closed, if any.
69 // shouldRetry returns true if the HTTP response / error indicates that the
|
| /developers/build/prebuilts/gradle/AutofillFramework/afservice/src/main/java/com/example/android/autofill/service/data/source/local/ |
| DigitalAssetLinksRepository.java | 34 import retrofit2.Response;
119 @NonNull Response<DalCheck> response) {
120 DalCheck dalCheck = response.body();
131 @NonNull Response<DalCheck> response) {
132 DalCheck dalCheck = response.body();
|
| /developers/samples/android/input/autofill/AutofillFramework/afservice/src/main/java/com/example/android/autofill/service/data/source/local/ |
| DigitalAssetLinksRepository.java | 34 import retrofit2.Response;
119 @NonNull Response<DalCheck> response) {
120 DalCheck dalCheck = response.body();
131 @NonNull Response<DalCheck> response) {
132 DalCheck dalCheck = response.body();
|
| /device/google/contexthub/util/nanotool/ |
| nanomessage.cpp | 68 response.accepted ? "true" : "false");
73 if (buffer.size() != sizeof(Response)) {
78 const Response *source = reinterpret_cast<const Response *>(data);
79 response = *source;
|
| nanomessage.h | 106 * A response to writing an event to the ContextHub.
113 struct Response {
115 } __attribute__((packed)) response; member in class:android::WriteEventResponse
119 * A response to reading an event from the ContextHub.
147 // Event data associated with this response.
|
| /device/linaro/bootloader/edk2/SecurityPkg/Library/SmmTcg2PhysicalPresenceLib/ |
| SmmTcg2PhysicalPresenceLib.c | 39 Return TPM Operation Response to OS Environment.
44 @param[out] Response Response to the most recent operation request.
46 @return Return Code for Return TPM Operation Response to OS Environment.
52 OUT UINT32 *Response
74 *Response = 0;
80 *Response = PpData.PPResponse;
|
| /external/grpc-grpc/src/csharp/Grpc.Core/Internal/ |
| AsyncCallServer.cs | 79 /// Sends a streaming response. Only one pending send action is allowed at any given time.
106 GrpcPreconditions.CheckState(!initialMetadataSent, "Response headers can only be sent once per call.");
107 GrpcPreconditions.CheckState(streamingWritesCounter == 0, "Response headers can only be sent before the first write starts.");
132 byte[] payload = optionalWrite.HasValue ? UnsafeSerialize(optionalWrite.Value.Response) : null;
194 GrpcPreconditions.CheckState(!halfcloseRequested, "Response stream has already been completed.");
253 public ResponseWithFlags(TResponse response, WriteFlags writeFlags)
255 this.Response = response;
259 public TResponse Response { get; }
|
| /external/libbrillo/brillo/dbus/ |
| dbus_method_invoker.h | 12 // CallMethodAndBlock invokes the D-Bus method and returns the Response.
14 // The method call response should be parsed with ExtractMethodCallResults().
89 // timeout. If a timeout occurs, the response object contains an error object
92 // Returns a dbus::Response object on success. On failure, returns nullptr and
95 inline std::unique_ptr<dbus::Response> CallMethodAndBlockWithTimeout(
107 auto response = object->CallMethodAndBlockWithErrorDetails( local
109 if (!response) {
126 return response;
131 inline std::unique_ptr<dbus::Response> CallMethodAndBlock(
249 // A helper function that translates dbus::ErrorResponse response
[all...] |
| /external/libbrillo/brillo/http/ |
| http_request_unittest.cc | 151 std::string resp_data{"FooBar response body"};
161 RequestID request_id, std::unique_ptr<Response> resp) {
187 std::unique_ptr<Response> resp{new Response{connection_}};
|
| /external/okhttp/okhttp-apache/src/main/java/com/squareup/okhttp/apache/ |
| OkApacheClient.java | 8 import com.squareup.okhttp.Response;
79 private static HttpResponse transformResponse(Response response) throws IOException {
80 int code = response.code();
81 String message = response.message();
84 ResponseBody body = response.body();
88 Headers headers = response.headers();
172 Response okResponse = client.newCall(okRequest).execute();
193 HttpResponse response = execute(host, request, context); local
195 return handler.handleResponse(response);
[all...] |
| /external/okhttp/okhttp-logging-interceptor/src/main/java/com/squareup/okhttp/logging/ |
| HttpLoggingInterceptor.java | 26 import com.squareup.okhttp.Response;
37 * An OkHttp interceptor which logs request and response information. Can be applied as an
51 * Logs request and response lines.
62 * Logs request and response lines and their respective headers.
80 * Logs request and response lines and their respective headers and bodies (if present).
137 @Override public Response intercept(Chain chain) throws IOException {
204 Response response = chain.proceed(request); local
207 ResponseBody responseBody = response.body();
208 logger.log("<-- " + protocol(response.protocol()) + ' ' + response.code() + '
[all...] |
| /external/okhttp/okhttp-ws-tests/src/test/java/com/squareup/okhttp/ws/ |
| WebSocketRecorder.java | 19 import com.squareup.okhttp.Response;
47 @Override public void onOpen(WebSocket webSocket, Response response) {
74 @Override public void onFailure(IOException e, Response response) {
|
| /external/tensorflow/tensorflow/contrib/ignite/kernels/igfs/ |
| igfs_messages.h | 65 class Response {
107 class CtrlResponse : public Response {
111 TF_RETURN_IF_ERROR(Response::Read(client));
|
| /external/volley/src/test/java/com/android/volley/ |
| NetworkDispatcherTest.java | 69 ArgumentCaptor<Response> response = ArgumentCaptor.forClass(Response.class); local
70 verify(mDelivery).postResponse(any(Request.class), response.capture());
71 assertTrue(response.getValue().isSuccess());
72 assertEquals(response.getValue().result, new String(CANNED_DATA, StandardCharsets.UTF_8));
105 verify(mDelivery, never()).postResponse(any(Request.class), any(Response.class));
|
| /external/nist-sip/java/gov/nist/javax/sip/ |
| DialogFilter.java | 69 import javax.sip.message.Response;
103 * Send back a Request Pending response.
110 SIPResponse sipResponse = sipRequest.createResponse(Response.REQUEST_PENDING);
125 sipStack.getStackLogger().logError("Problem sending error response", ex);
132 * Send a BAD REQUEST response.
141 SIPResponse sipResponse = sipRequest.createResponse(Response.BAD_REQUEST);
155 sipStack.getStackLogger().logError("Problem sending error response", ex);
163 * Send a CALL OR TRANSACTION DOES NOT EXIST response.
173 .createResponse(Response.CALL_OR_TRANSACTION_DOES_NOT_EXIST);
186 sipStack.getStackLogger().logError("Problem sending error response", ex)
652 SIPResponse response = sipRequest local
747 SIPResponse response = sipRequest local
[all...] |
| /device/linaro/bootloader/edk2/SecurityPkg/Tcg/Tcg2Smm/ |
| Tcg2Smm.c | 121 UINT32 Response;
129 &Response
132 mTcgNvs->PhysicalPresence.Response = Response;
526 ControlArea->Response = PcdGet64 (PcdTpmBaseAddress) + 0x80;
|
| /external/nanohttpd/websocket/src/main/java/fi/iki/elonen/ |
| NanoWSD.java | 79 private final NanoHTTPD.Response handshakeResponse = new NanoHTTPD.Response(NanoHTTPD.Response.Status.SWITCH_PROTOCOL, null, (InputStream) null, 0) {
171 public NanoHTTPD.Response getHandshakeResponse() {
834 public Response serve(final IHTTPSession session) {
838 return newFixedLengthResponse(Response.Status.BAD_REQUEST, NanoHTTPD.MIME_PLAINTEXT,
843 return newFixedLengthResponse(Response.Status.BAD_REQUEST, NanoHTTPD.MIME_PLAINTEXT, "Missing Websocket-Key");
847 Response handshakeResponse = webSocket.getHandshakeResponse();
851 return newFixedLengthResponse(Response.Status.INTERNAL_ERROR, NanoHTTPD.MIME_PLAINTEXT,
[all...] |
| /device/linaro/bootloader/edk2/OvmfPkg/XenPvBlkDxe/ |
| BlockFront.c | 587 blkif_response_t *Response;
600 Response = RING_GET_RESPONSE (&Dev->Ring, ConsumerIndex);
602 IoData = (VOID *) (UINTN) Response->id;
603 Status = Response->status;
605 switch (Response->operation) {
615 Response->operation == BLKIF_OP_READ ? "read" : "write",
641 "XenPvBlk: unrecognized block operation %d response (status %d)\n",
642 Response->operation, Status));
|
| /device/linaro/bootloader/edk2/MdeModulePkg/Universal/Network/UefiPxeBcDxe/ |
| PxeBcDhcp.c | [all...] |
| /cts/libs/testserver/src/android/webkit/cts/ |
| TestWebServer.java | 79 private static class Response {
86 Response(byte[] responseData, List<Pair<String, String>> responseHeaders,
100 private final Map<String, Response> mResponseMap = new HashMap<String, Response>();
184 mResponseMap.put(requestPath, new Response(
195 * This only gets the URL, you still need to set the response if you intend to access it.
205 * Sets a 404 (not found) response to be returned when a particular request path is passed in.
209 * response.
218 * Sets a response to be returned when a particular request path is passed
222 * @param responseString The response body that will be returned
407 Response response = null; local
450 HttpResponse response = new BasicHttpResponse(HttpVersion.HTTP_1_0, status, null); local
592 HttpResponse response = mServer.getResponse(request); local
[all...] |
| /device/linaro/bootloader/edk2/NetworkPkg/UefiPxeBcDxe/ |
| PxeBcDhcp4.c | 1021 @retval EFI_NO_RESPONSE No response to the following request packet.
[all...] |
| /external/grpc-grpc/src/python/grpcio_tests/tests/protoc_plugin/ |
| _split_definitions_test.py | 254 self._messages_pb2.Response
267 _Servicer(self._messages_pb2.Response), server)
272 response = stub.Call(self._messages_pb2.Request())
273 self.assertEqual(self._messages_pb2.Response(), response)
|
| /external/libchrome/dbus/ |
| property.h | 262 Response* response);
273 virtual void OnGetAll(Response* response);
286 Response* response);
|
| /external/nanohttpd/fileupload/src/test/java/fi/iki/elonen/ |
| TestNanoFileUpLoad.java | 72 import fi.iki.elonen.NanoHTTPD.Response.Status;
86 public Response response = newFixedLengthResponse(""); field in class:TestNanoFileUpLoad.TestServer
120 public Response serve(IHTTPSession session) {
155 this.response.setStatus(Status.INTERNAL_ERROR);
162 return this.response;
171 CloseableHttpResponse response = httpclient.execute(httphead); local
172 Assert.assertEquals(200, response.getStatusLine().getStatusCode());
173 response.close();
220 HttpResponse response = httpclient.execute(post) local
[all...] |
| /external/swiftshader/third_party/llvm-7.0/llvm/tools/llvm-mca/ |
| RegisterFile.cpp | 291 unsigned Response = 0;
314 Response |= (1U << I);
317 return Response;
|
