| /external/oj-libjdwp/src/share/back/ |
| D | invoker.c | 102 createGlobalRefs(JNIEnv *env, InvokeRequest *request) in createGlobalRefs() argument
115 if ( request->argumentCount > 0 ) { in createGlobalRefs()
117 argRefs = jvmtiAllocate((jint)(request->argumentCount*sizeof(jobject))); in createGlobalRefs()
122 (void)memset(argRefs, 0, request->argumentCount*sizeof(jobject)); in createGlobalRefs()
127 saveGlobalRef(env, request->clazz, &clazz); in createGlobalRefs()
133 if ( error == JVMTI_ERROR_NONE && request->instance != NULL ) { in createGlobalRefs()
134 saveGlobalRef(env, request->instance, &instance); in createGlobalRefs()
142 argumentTag = firstArgumentTypeTag(request->methodSignature, &cursor); in createGlobalRefs()
143 argument = request->arguments; in createGlobalRefs()
145 if ( argIndex > request->argumentCount ) { in createGlobalRefs()
[all …]
|
| /external/e2fsprogs/debugfs/ |
| D | debug_cmds.ct | 7 request do_show_debugfs_params, "Show debugfs parameters",
10 request do_open_filesys, "Open a filesystem",
13 request do_close_filesys, "Close the filesystem",
16 request do_freefrag, "Report free space fragmentation",
19 request do_features, "Set/print superblock features",
22 request do_dirty_filesys, "Mark the filesystem as dirty",
25 request do_init_filesys, "Initialize a filesystem (DESTROYS DATA)",
28 request do_show_super_stats, "Show superblock statistics",
31 request do_ncheck, "Do inode->name translation",
34 request do_icheck, "Do block->inode translation",
[all …]
|
| D | ro_debug_cmds.ct | 9 request do_show_debugfs_params, "Show debugfs parameters",
12 request do_open_filesys, "Open a filesystem",
15 request do_close_filesys, "Close the filesystem",
18 request do_freefrag, "Report free space fragmentation",
21 request do_show_super_stats, "Show superblock statistics",
24 request do_ncheck, "Do inode->name translation",
27 request do_icheck, "Do block->inode translation",
30 request do_chroot, "Change root directory",
33 request do_change_working_dir, "Change working directory",
36 request do_list_dir, "List directory",
[all …]
|
| /external/sdk-platform-java/gapic-generator-java/src/test/java/com/google/api/generator/gapic/composer/grpc/goldens/ |
| D | GrpcRoutingHeadersStub.golden | 12 import com.google.explicit.dynamic.routing.header.Request;
32 private static final MethodDescriptor<Request, Empty> example1TestMethodDescriptor =
33 MethodDescriptor.<Request, Empty>newBuilder()
37 .setRequestMarshaller(ProtoUtils.marshaller(Request.getDefaultInstance()))
41 private static final MethodDescriptor<Request, Empty> example2TestMethodDescriptor =
42 MethodDescriptor.<Request, Empty>newBuilder()
46 .setRequestMarshaller(ProtoUtils.marshaller(Request.getDefaultInstance()))
50 private static final MethodDescriptor<Request, Empty> example3TestMethodDescriptor =
51 MethodDescriptor.<Request, Empty>newBuilder()
55 .setRequestMarshaller(ProtoUtils.marshaller(Request.getDefaultInstance()))
[all …]
|
| /external/libdrm/amdgpu/ |
| D | amdgpu_gpu_info.c | 36 struct drm_amdgpu_info request; in amdgpu_query_info() local
38 memset(&request, 0, sizeof(request)); in amdgpu_query_info()
39 request.return_pointer = (uintptr_t)value; in amdgpu_query_info()
40 request.return_size = size; in amdgpu_query_info()
41 request.query = info_id; in amdgpu_query_info()
43 return drmCommandWrite(dev->fd, DRM_AMDGPU_INFO, &request, in amdgpu_query_info()
50 struct drm_amdgpu_info request; in amdgpu_query_crtc_from_id() local
52 memset(&request, 0, sizeof(request)); in amdgpu_query_crtc_from_id()
53 request.return_pointer = (uintptr_t)result; in amdgpu_query_crtc_from_id()
54 request.return_size = sizeof(*result); in amdgpu_query_crtc_from_id()
[all …]
|
| /external/glide/library/src/main/java/com/bumptech/glide/manager/ |
| D | RequestTracker.java | 3 import com.bumptech.glide.request.Request;
15 …// though the user still would like the request to finish. Weak references are therefore only real…
19 …private final Set<Request> requests = Collections.newSetFromMap(new WeakHashMap<Request, Boolean>(…
23 * Starts tracking the given request.
25 public void runRequest(Request request) { in runRequest() argument
26 requests.add(request); in runRequest()
28 request.begin(); in runRequest()
33 void addRequest(Request request) { in addRequest() argument
34 requests.add(request); in addRequest()
38 * Stops tracking the given request.
[all …]
|
| /external/python/google-auth-library-python/tests/compute_engine/ |
| D | test__metadata.py | 39 request = mock.create_autospec(transport.Request)
41 request.side_effect = [exceptions.TransportError(), response]
43 request.return_value = response
45 return request
49 request = make_request("", headers=_metadata._METADATA_HEADERS)
51 assert _metadata.ping(request)
53 request.assert_called_once_with(
62 request = make_request("", headers=_metadata._METADATA_HEADERS, retry=True)
64 assert _metadata.ping(request)
66 request.assert_called_with(
[all …]
|
| /external/volley/core/src/main/java/com/android/volley/ |
| D | RequestQueue.java | 32 * A request dispatch queue with a thread pool of dispatchers.
34 * <p>Calling {@link #add(Request)} will enqueue the given Request for dispatch, resolving from
41 // TODO: This should not be a generic class, because the request type can't be determined at
46 /** Called when a request has finished processing. */
47 void onRequestFinished(Request<T> request); in onRequestFinished() argument
50 /** Request event types the listeners {@link RequestEventListener} will be notified about. */
61 /** The request was added to the queue. */
63 /** Cache lookup started for the request. */
66 * Cache lookup finished for the request and cached response is delivered or request is
70 /** Network dispatch started for the request. */
[all …]
|
| /external/aws-sdk-java-v2/core/http-auth-aws/src/test/java/software/amazon/awssdk/http/auth/aws/internal/signer/ |
| D | DefaultAwsV4HttpSignerTest.java | 58 SignRequest<? extends AwsCredentialsIdentity> request = generateBasicRequest( in sign_WithNoAdditonalProperties_DelegatesToHeaderSigner() local
66 SignedRequest signedRequest = signer.sign(request); in sign_WithNoAdditonalProperties_DelegatesToHeaderSigner()
68 assertThat(signedRequest.request().firstMatchingHeader("Authorization")).isPresent(); in sign_WithNoAdditonalProperties_DelegatesToHeaderSigner()
73 AsyncSignRequest<? extends AwsCredentialsIdentity> request = generateBasicAsyncRequest( in signAsync_WithNoAdditonalProperties_DelegatesToHeaderSigner() local
81 AsyncSignedRequest signedRequest = signer.signAsync(request).join(); in signAsync_WithNoAdditonalProperties_DelegatesToHeaderSigner()
83 assertThat(signedRequest.request().firstMatchingHeader("Authorization")).isPresent(); in signAsync_WithNoAdditonalProperties_DelegatesToHeaderSigner()
88 SignRequest<? extends AwsCredentialsIdentity> request = generateBasicRequest( in sign_WithQueryAuthLocation_DelegatesToQuerySigner() local
95 SignedRequest signedRequest = signer.sign(request); in sign_WithQueryAuthLocation_DelegatesToQuerySigner()
97 … assertThat(signedRequest.request().firstMatchingRawQueryParameter("X-Amz-Signature")).isPresent(); in sign_WithQueryAuthLocation_DelegatesToQuerySigner()
102 AsyncSignRequest<? extends AwsCredentialsIdentity> request = generateBasicAsyncRequest( in signAsync_WithQueryAuthLocation_DelegatesToQuerySigner() local
[all …]
|
| /external/mtools/ |
| D | devices.h | 47 UNUSED(static __inline__ void RR_INIT(struct floppy_raw_cmd *request)) in UNUSED() argument
49 request->data = 0; in UNUSED()
50 request->length = 0; in UNUSED()
51 request->cmd_count = 9; in UNUSED()
52 request->flags = FD_RAW_INTR | FD_RAW_NEED_SEEK | FD_RAW_NEED_DISK in UNUSED()
57 request->cmd[1] = 0; in UNUSED()
58 request->cmd[6] = 0; in UNUSED()
59 request->cmd[7] = 0x1b; in UNUSED()
60 request->cmd[8] = 0xff; in UNUSED()
61 request->reply_count = 0; in UNUSED()
[all …]
|
| /external/rust/android-crates-io/extra_versions/crates/http/src/ |
| D | request.rs | 1 //! HTTP request types.
4 //! `Request` type itself as well as a builder to create requests. Typically
5 //! you'll import the `http::Request` type rather than reaching into this
10 //! Creating a `Request` to send
13 //! use http::{Request, Response};
15 //! let mut request = Request::builder()
20 //! request = request.header("Awesome", "yes");
23 //! let response = send(request.body(()).unwrap());
29 //! fn send(req: Request<()>) -> Response<()> {
35 //! Inspecting a request to see what was sent.
[all …]
|
| /external/rust/android-crates-io/crates/http/src/ |
| D | request.rs | 1 //! HTTP request types.
4 //! `Request` type itself as well as a builder to create requests. Typically
5 //! you'll import the `http::Request` type rather than reaching into this
10 //! Creating a `Request` to send
13 //! use http::{Request, Response};
15 //! let mut request = Request::builder()
20 //! request = request.header("Awesome", "yes");
23 //! let response = send(request.body(()).unwrap());
29 //! fn send(req: Request<()>) -> Response<()> {
35 //! Inspecting a request to see what was sent.
[all …]
|
| /external/aws-sdk-java-v2/core/http-auth-aws/src/main/java/software/amazon/awssdk/http/auth/aws/internal/signer/ |
| D | DefaultAwsV4HttpSigner.java | 51 * request and payload (if applicable) accordingly.
60 public SignedRequest sign(SignRequest<? extends AwsCredentialsIdentity> request) { in sign() argument
61 Checksummer checksummer = checksummer(request, null); in sign()
62 V4Properties v4Properties = v4Properties(request); in sign()
63 V4RequestSigner v4RequestSigner = v4RequestSigner(request, v4Properties); in sign()
64 V4PayloadSigner payloadSigner = v4PayloadSigner(request, v4Properties); in sign()
66 return doSign(request, checksummer, v4RequestSigner, payloadSigner); in sign()
70 …eFuture<AsyncSignedRequest> signAsync(AsyncSignRequest<? extends AwsCredentialsIdentity> request) { in signAsync() argument
71 Checksummer checksummer = asyncChecksummer(request); in signAsync()
72 V4Properties v4Properties = v4Properties(request); in signAsync()
[all …]
|
| /external/tensorflow/tensorflow/compiler/xla/rpc/ |
| D | grpc_stub.cc | 30 Status GRPCStub::TransferToClient(const TransferToClientRequest* request, in TransferToClient() argument
32 return MakeRPC([this, request, response](::grpc::ClientContext* context) { in TransferToClient()
33 return grpc_stub_->TransferToClient(context, *request, response); in TransferToClient()
37 Status GRPCStub::TransferToServer(const TransferToServerRequest* request, in TransferToServer() argument
39 return MakeRPC([this, request, response](::grpc::ClientContext* context) { in TransferToServer()
40 return grpc_stub_->TransferToServer(context, *request, response); in TransferToServer()
44 Status GRPCStub::TransferToInfeed(const TransferToInfeedRequest* request, in TransferToInfeed() argument
46 return MakeRPC([this, request, response](::grpc::ClientContext* context) { in TransferToInfeed()
47 return grpc_stub_->TransferToInfeed(context, *request, response); in TransferToInfeed()
51 Status GRPCStub::TransferFromOutfeed(const TransferFromOutfeedRequest* request, in TransferFromOutfeed() argument
[all …]
|
| /external/tensorflow/tensorflow/compiler/xla/client/ |
| D | client.cc | 42 TransferToClientRequest request; in Transfer() local
43 *request.mutable_data() = data.handle(); in Transfer()
45 *request.mutable_shape_with_layout() = shape_with_layout->ToProto(); in Transfer()
49 VLOG(1) << "making transfer request"; in Transfer()
50 VLOG(3) << "TransferToClientRequest: {" << request.DebugString() << "}"; in Transfer()
51 Status s = stub_->TransferToClient(&request, &response); in Transfer()
52 VLOG(1) << "done with request"; in Transfer()
62 "TransferToClient request"); in Transfer()
69 TransferToServerRequest request; in TransferToServer() local
70 *request.mutable_literal() = literal.ToProto(); in TransferToServer()
[all …]
|
| /external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/ |
| D | InterceptorTest.java | 56 Request request = new Request.Builder() in applicationInterceptorsCanShortCircuitResponses() local
61 .request(request) in applicationInterceptorsCanShortCircuitResponses()
74 Response response = client.newCall(request).execute(); in applicationInterceptorsCanShortCircuitResponses()
84 .request(chain.request()) in networkInterceptorsCannotShortCircuitResponses()
94 Request request = new Request.Builder() in networkInterceptorsCannotShortCircuitResponses() local
99 client.newCall(request).execute(); in networkInterceptorsCannotShortCircuitResponses()
113 chain.proceed(chain.request()); in networkInterceptorsCannotCallProceedMultipleTimes()
114 return chain.proceed(chain.request()); in networkInterceptorsCannotCallProceedMultipleTimes()
119 Request request = new Request.Builder() in networkInterceptorsCannotCallProceedMultipleTimes() local
124 client.newCall(request).execute(); in networkInterceptorsCannotCallProceedMultipleTimes()
[all …]
|
| /external/cronet/stable/net/test/embedded_test_server/ |
| D | http_request_unittest.cc | 16 // Process request in chunks to check if the parser deals with border cases. in TEST()
31 // Content data and another request in the same chunk (possible in http/1.1). in TEST()
35 // Fetch the first request and validate it. in TEST()
37 std::unique_ptr<HttpRequest> request = parser.GetRequest(); in TEST() local
38 EXPECT_EQ("/foobar.html", request->relative_url); in TEST()
39 EXPECT_EQ("POST", request->method_string); in TEST()
40 EXPECT_EQ(METHOD_POST, request->method); in TEST()
41 EXPECT_EQ("1234567890", request->content); in TEST()
42 ASSERT_EQ(3u, request->headers.size()); in TEST()
44 EXPECT_EQ(1u, request->headers.count("Host")); in TEST()
[all …]
|
| /external/cronet/tot/net/test/embedded_test_server/ |
| D | http_request_unittest.cc | 16 // Process request in chunks to check if the parser deals with border cases. in TEST()
31 // Content data and another request in the same chunk (possible in http/1.1). in TEST()
35 // Fetch the first request and validate it. in TEST()
37 std::unique_ptr<HttpRequest> request = parser.GetRequest(); in TEST() local
38 EXPECT_EQ("/foobar.html", request->relative_url); in TEST()
39 EXPECT_EQ("POST", request->method_string); in TEST()
40 EXPECT_EQ(METHOD_POST, request->method); in TEST()
41 EXPECT_EQ("1234567890", request->content); in TEST()
42 ASSERT_EQ(3u, request->headers.size()); in TEST()
44 EXPECT_EQ(1u, request->headers.count("Host")); in TEST()
[all …]
|
| /external/googleapis/google/cloud/visionai/v1/ |
| D | streams_service.proto | 368 // Optional. An optional request ID to identify requests. Specify a unique
369 // request ID so that if you must retry your request, the server will know to
370 // ignore the request if it has already been completed. The server will
371 // guarantee that for at least 60 minutes since the first request.
373 // For example, consider a situation where you make an initial request and the
374 // request times out. If you make the request again with the same request ID,
375 // the server can check if original operation with the same request ID was
376 // received, and if so, will ignore the second request. This prevents clients
379 // The request ID must be a valid UUID with the exception that zero UUID is
389 // the full request. A field will be overwritten if it is in the mask. If the
[all …]
|
| /external/opencensus-java/contrib/http_util/src/main/java/io/opencensus/contrib/http/ |
| D | HttpExtractor.java | 23 * An adaptor to extract information from request and response.
31 * @param <Q> the HTTP request entity.
39 * Returns the request route.
41 * @param request the HTTP request.
42 * @return the request route.
46 public abstract String getRoute(Q request); in getRoute() argument
49 * Returns the request URL.
51 * @param request the HTTP request.
52 * @return the request URL.
56 public abstract String getUrl(Q request); in getUrl() argument
[all …]
|
| /external/googleapis/google/cloud/visionai/v1alpha1/ |
| D | streams_service.proto | 347 // Optional. An optional request ID to identify requests. Specify a unique request ID
348 // so that if you must retry your request, the server will know to ignore
349 // the request if it has already been completed. The server will guarantee
350 // that for at least 60 minutes since the first request.
352 // For example, consider a situation where you make an initial request and the
353 // request times out. If you make the request again with the same request ID,
354 // the server can check if original operation with the same request ID was
355 // received, and if so, will ignore the second request. This prevents clients
358 // The request ID must be a valid UUID with the exception that zero UUID is
368 // the full request. A field will be overwritten if it is in the mask. If the
[all …]
|
| /external/googleapis/google/cloud/alloydb/v1/ |
| D | service.proto | 195 // instance exists in the cluster as well as this request, then API will
198 // created. If the primary instance is a part of the request payload, then
484 // Optional. An optional request ID to identify requests. Specify a unique
485 // request ID so that if you must retry your request, the server will know to
486 // ignore the request if it has already been completed. The server will
487 // guarantee that for at least 60 minutes since the first request.
489 // For example, consider a situation where you make an initial request and
490 // the request times out. If you make the request again with the same request
491 // ID, the server can check if original operation with the same request ID
492 // was received, and if so, will ignore the second request. This prevents
[all …]
|
| /external/okhttp/okcurl/src/test/java/com/squareup/okhttp/curl/ |
| D | MainTest.java | 18 import com.squareup.okhttp.Request;
30 Request request = fromArgs("http://example.com").createRequest(); in simple() local
31 assertEquals("GET", request.method()); in simple()
32 assertEquals("http://example.com/", request.urlString()); in simple()
33 assertNull(request.body()); in simple()
37 Request request = fromArgs("-X", "PUT", "-d", "foo", "http://example.com").createRequest(); in put() local
38 assertEquals("PUT", request.method()); in put()
39 assertEquals("http://example.com/", request.urlString()); in put()
40 assertEquals(3, request.body().contentLength()); in put()
44 Request request = fromArgs("-d", "foo", "http://example.com").createRequest(); in dataPost() local
[all …]
|
| /external/googleapis/google/cloud/video/livestream/v1/ |
| D | service.proto | 114 // only when the StartChannel request is received by the server.
128 // when the StopChannel request is received by the server.
292 // Request message for "LivestreamService.CreateAsset".
311 // A request ID to identify requests. Specify a unique request ID
312 // so that if you must retry your request, the server will know to ignore
313 // the request if it has already been completed. The server will guarantee
314 // that for at least 60 minutes since the first request.
316 // For example, consider a situation where you make an initial request and the
317 // request times out. If you make the request again with the same request ID,
318 // the server can check if original operation with the same request ID was
[all …]
|
| /external/google-cloud-java/java-compute/google-cloud-compute/src/main/java/com/google/cloud/compute/v1/stub/ |
| D | HttpJsonInstancesStub.java | 128 request -> {
132 serializer.putPathParam(fields, "instance", request.getInstance());
133 serializer.putPathParam(fields, "project", request.getProject());
134 serializer.putPathParam(fields, "zone", request.getZone());
138 request -> {
143 fields, "networkInterface", request.getNetworkInterface());
144 if (request.hasRequestId()) {
145 serializer.putQueryParam(fields, "requestId", request.getRequestId());
150 request ->
154 request.getAccessConfigResource(),
[all …]
|