/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/volley/src/main/java/com/android/volley/ |
D | CacheDispatcher.java | 40 private final BlockingQueue<Request<?>> mCacheQueue; 43 private final BlockingQueue<Request<?>> mNetworkQueue; 67 BlockingQueue<Request<?>> cacheQueue, in CacheDispatcher() 68 BlockingQueue<Request<?>> networkQueue, in CacheDispatcher() 112 // This is needed to avoid keeping previous request references alive for an indeterminate amount 116 // Get a request from the cache triage queue, blocking until in processRequest() 118 final Request<?> request = mCacheQueue.take(); in processRequest() local 119 processRequest(request); in processRequest() 123 void processRequest(final Request<?> request) throws InterruptedException { in processRequest() argument 124 request.addMarker("cache-queue-take"); in processRequest() [all …]
|
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 …]
|
D | NetworkDispatcher.java | 38 private final BlockingQueue<Request<?>> mQueue; 58 BlockingQueue<Request<?>> queue, in NetworkDispatcher() 78 private void addTrafficStatsTag(Request<?> request) { in addTrafficStatsTag() argument 79 // Tag the request (if API >= 14) in addTrafficStatsTag() 81 TrafficStats.setThreadStatsTag(request.getTrafficStatsTag()); in addTrafficStatsTag() 105 // This is needed to avoid keeping previous request references alive for an indeterminate amount 109 // Take a request from the queue. in processRequest() 110 Request<?> request = mQueue.take(); in processRequest() local 111 processRequest(request); in processRequest() 115 void processRequest(Request<?> request) { in processRequest() argument [all …]
|
/external/autotest/scheduler/ |
D | rdb.py | 85 # Request Handlers: Used in conjunction with requests in rdb_utils, these 86 # handlers acquire hosts for a request and record the acquisition in 87 # an response_map dictionary keyed on the request itself, with the host/hosts 100 def update_response_map(self, request, response, append=False): argument 101 """Record a response for a request. 105 against a request. If the rdb hit an exception processing a request, the 108 @param response: A response for the request. 109 @param request: The request that has reserved these hosts. 111 |response| for existing request. 119 'valid responses. Request %s, response %s is invalid.' % [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/tensorflow/tensorflow/compiler/xla/client/ |
D | client.cc | 43 TransferToClientRequest request; in Transfer() local 44 *request.mutable_data() = data.handle(); in Transfer() 46 *request.mutable_shape_with_layout() = shape_with_layout->ToProto(); in Transfer() 50 VLOG(1) << "making transfer request"; in Transfer() 51 VLOG(3) << "TransferToClientRequest: {" << request.DebugString() << "}"; in Transfer() 52 Status s = stub_->TransferToClient(&request, &response); in Transfer() 53 VLOG(1) << "done with request"; in Transfer() 63 "TransferToClient request"); in Transfer() 70 TransferToServerRequest request; in TransferToServer() local 71 *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 …]
|
D | CallTest.java | 113 Request request = new Request.Builder() in get() local 118 executeSynchronously(request) in get() 135 Request request = new Request.Builder() in buildRequestUsingHttpUrl() local 138 assertEquals(httpUrl, request.httpUrl()); in buildRequestUsingHttpUrl() 140 executeSynchronously(request).assertSuccessful(); in buildRequestUsingHttpUrl() 144 Request.Builder requestBuilder = new Request.Builder(); in invalidScheme() 154 Request.Builder requestBuilder = new Request.Builder(); in invalidPort() 166 Request request = new Request.Builder() in getReturns500() local 170 executeSynchronously(request) in getReturns500() 195 Request request = new Request.Builder() in repeatedHeaderNames() local [all …]
|
D | ConnectionReuseTest.java | 44 Request request = new Request.Builder() in connectionsAreReused() local 47 assertConnectionReused(request, request); in connectionsAreReused() 55 Request request = new Request.Builder() in connectionsAreReusedWithHttp2() local 58 assertConnectionReused(request, request); in connectionsAreReusedWithHttp2() 65 Request requestA = new Request.Builder() in connectionsAreNotReusedWithRequestConnectionClose() 69 Request requestB = new Request.Builder() in connectionsAreNotReusedWithRequestConnectionClose() 81 Request requestA = new Request.Builder() in connectionsAreNotReusedWithResponseConnectionClose() 84 Request requestB = new Request.Builder() in connectionsAreNotReusedWithResponseConnectionClose() 97 Request request = new Request.Builder() in connectionsAreNotReusedWithUnknownLengthResponseBody() local 100 assertConnectionNotReused(request, request); in connectionsAreNotReusedWithUnknownLengthResponseBody() [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/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/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/volley/src/test/java/com/android/volley/toolbox/ |
D | HttpClientStackTest.java | 22 import com.android.volley.Request.Method; 42 TestRequest.DeprecatedGet request = new TestRequest.DeprecatedGet(); in createDeprecatedGetRequest() local 43 assertEquals(request.getMethod(), Method.DEPRECATED_GET_OR_POST); in createDeprecatedGetRequest() 45 HttpUriRequest httpRequest = HttpClientStack.createHttpRequest(request, null); in createDeprecatedGetRequest() 51 TestRequest.DeprecatedPost request = new TestRequest.DeprecatedPost(); in createDeprecatedPostRequest() local 52 assertEquals(request.getMethod(), Method.DEPRECATED_GET_OR_POST); in createDeprecatedPostRequest() 54 HttpUriRequest httpRequest = HttpClientStack.createHttpRequest(request, null); in createDeprecatedPostRequest() 60 TestRequest.Get request = new TestRequest.Get(); in createGetRequest() local 61 assertEquals(request.getMethod(), Method.GET); in createGetRequest() 63 HttpUriRequest httpRequest = HttpClientStack.createHttpRequest(request, null); in createGetRequest() [all …]
|
D | RequestTest.java | 23 import com.android.volley.Request; 39 Request.class.getConstructor( in publicMethods() 42 assertNotNull(Request.class.getMethod("getMethod")); in publicMethods() 43 assertNotNull(Request.class.getMethod("setTag", Object.class)); in publicMethods() 44 assertNotNull(Request.class.getMethod("getTag")); in publicMethods() 45 assertNotNull(Request.class.getMethod("getErrorListener")); in publicMethods() 46 assertNotNull(Request.class.getMethod("getTrafficStatsTag")); in publicMethods() 47 assertNotNull(Request.class.getMethod("setRetryPolicy", RetryPolicy.class)); in publicMethods() 48 assertNotNull(Request.class.getMethod("addMarker", String.class)); in publicMethods() 49 assertNotNull(Request.class.getDeclaredMethod("finish", String.class)); in publicMethods() [all …]
|
/external/python/cpython2/Lib/ |
D | SocketServer.py | 15 For request-based servers (including socket-based): 17 - client address verification before further looking at the request 19 at the request before anything else, e.g. logging) 21 - synchronous (one request is handled at a time) 22 - forking (each request is handled by a new process) 23 - threading (each request is handled by a new thread) 65 with your request handler class. 67 The request handler class must be different for datagram or stream 68 services. This can be hidden by using the request handler 83 class will essentially render the service "deaf" while one request is [all …]
|
/external/wayland-protocols/chromium.org/unstable/remote-shell/ |
D | remote-shell-unstable-v1.xml | 88 <request name="destroy" type="destructor"> 96 </request> 98 <request name="get_remote_surface"> 112 </request> 122 <request name="get_notification_surface"> 130 </request> 188 <request name="get_input_method_surface" since="17"> 195 </request> 281 <request name="destroy" type="destructor"> 286 </request> [all …]
|
/external/python/oauth2client/tests/contrib/django_util/ |
D | test_views.py | 49 request = self.factory.get('oauth2/oauth2authorize') 50 request.session = self.session 51 request.user = self.user 52 response = views.oauth2_authorize(request) 56 request = self.factory.get('oauth2/oauth2authorize') 57 request.session = self.session 58 request.user = AnonymousUser() 59 response = views.oauth2_authorize(request) 63 request = self.factory.get('oauth2/oauth2authorize', 65 request.session = self.session [all …]
|
/external/python/apitools/apitools/base/py/ |
D | batch.py | 42 'RequestResponseAndHandler', ['request', 'response', 'handler'])): 44 """Container for data related to completing an HTTP request. 46 This contains an HTTP request, its response, and a callback for handling 50 request: An http_wrapper.Request object representing the HTTP request. 60 """Batches multiple api requests into a single request.""" 64 """Holds request and response information for each request. 67 batch request has been completed. 70 http_request: A client-supplied http_wrapper.Request to be 73 response to the user request, or None if an error occurred. 79 def __init__(self, request, retryable_codes, service, method_config): argument [all …]
|
/external/autotest/frontend/afe/ |
D | views.py | 22 def handle_rpc(request): argument 23 """Handle the RPC request. 25 @param request: the RPC request. 27 return rpc_handler_obj.handle_rpc_request(request) 30 def rpc_documentation(request): argument 33 @param request: the RPC request. 38 def model_documentation(request): argument 41 @param request: the RPC request. 48 def redirect_with_extra_data(request, url, **kwargs): argument 51 @param request: the RPC request. [all …]
|
/external/nos/test/system-test-harness/src/ |
D | keymaster-import-key-tests.cc | 40 void initRSARequest(ImportKeyRequest *request, Algorithm alg) { in initRSARequest() argument 41 KeyParameters *params = request->mutable_params(); in initRSARequest() 47 void initRSARequest(ImportKeyRequest *request, Algorithm alg, int key_size) { in initRSARequest() argument 48 initRSARequest(request, alg); in initRSARequest() 51 KeyParameters *params = request->mutable_params(); in initRSARequest() 58 void initRSARequest(ImportKeyRequest *request, Algorithm alg, int key_size, in initRSARequest() argument 60 initRSARequest(request, alg, key_size); in initRSARequest() 63 KeyParameters *params = request->mutable_params(); in initRSARequest() 70 void initRSARequest(ImportKeyRequest *request, Algorithm alg, int key_size, in initRSARequest() argument 73 initRSARequest(request, alg, key_size, public_exponent_tag); in initRSARequest() [all …]
|
/external/grpc-grpc/test/cpp/codegen/ |
D | compiler_test_golden | 65 …tus MethodA1(::grpc::ClientContext* context, const ::grpc::testing::Request& request, ::grpc::test… 66 …syncMethodA1(::grpc::ClientContext* context, const ::grpc::testing::Request& request, ::grpc::Comp… 67 …tAsyncResponseReaderInterface< ::grpc::testing::Response>>(AsyncMethodA1Raw(context, request, cq)); 69 …syncMethodA1(::grpc::ClientContext* context, const ::grpc::testing::Request& request, ::grpc::Comp… 70 …esponseReaderInterface< ::grpc::testing::Response>>(PrepareAsyncMethodA1Raw(context, request, cq)); 77 …std::unique_ptr< ::grpc::ClientWriterInterface< ::grpc::testing::Request>> MethodA2(::grpc::Client… 78 …return std::unique_ptr< ::grpc::ClientWriterInterface< ::grpc::testing::Request>>(MethodA2Raw(cont… 80 …std::unique_ptr< ::grpc::ClientAsyncWriterInterface< ::grpc::testing::Request>> AsyncMethodA2(::gr… 81 …return std::unique_ptr< ::grpc::ClientAsyncWriterInterface< ::grpc::testing::Request>>(AsyncMethod… 83 …std::unique_ptr< ::grpc::ClientAsyncWriterInterface< ::grpc::testing::Request>> PrepareAsyncMethod… [all …]
|
/external/python/cpython3/Lib/ |
D | socketserver.py | 15 For request-based servers (including socket-based): 17 - client address verification before further looking at the request 19 at the request before anything else, e.g. logging) 21 - synchronous (one request is handled at a time) 22 - forking (each request is handled by a new process) 23 - threading (each request is handled by a new thread) 65 with your request handler class. 67 The request handler class must be different for datagram or stream 68 services. This can be hidden by using the request handler 83 class will essentially render the service "deaf" while one request is [all …]
|