| /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/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/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/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/tensorflow/tensorflow/core/distributed_runtime/ |
| D | message_wrappers_test.cc | 40 void BuildRunStepRequest(MutableRunStepRequestWrapper* request) { in BuildRunStepRequest() argument
41 request->set_session_handle("handle"); in BuildRunStepRequest()
42 request->set_partial_run_handle("partial_handle"); in BuildRunStepRequest()
43 request->add_feed("feed_a:0", TensorA()); in BuildRunStepRequest()
44 request->add_feed("feed_b:0", TensorB()); in BuildRunStepRequest()
45 request->add_fetch("fetch_x:0"); in BuildRunStepRequest()
46 request->add_fetch("fetch_y:0"); in BuildRunStepRequest()
47 request->add_target("target_i"); in BuildRunStepRequest()
48 request->add_target("target_j"); in BuildRunStepRequest()
49 request->mutable_options()->set_timeout_in_ms(37); in BuildRunStepRequest()
[all …]
|
| D | worker_interface.h | 39 virtual void GetStatusAsync(const GetStatusRequest* request,
44 const CreateWorkerSessionRequest* request,
48 CallOptions* opts, const DeleteWorkerSessionRequest* request,
51 virtual void RegisterGraphAsync(const RegisterGraphRequest* request,
55 virtual void DeregisterGraphAsync(const DeregisterGraphRequest* request,
59 virtual void RunGraphAsync(CallOptions* opts, RunGraphRequestWrapper* request,
63 virtual void RunGraphAsync(CallOptions* opts, const RunGraphRequest* request, in RunGraphAsync() argument
67 RunGraphRequestWrapper* wrapped_request = new ProtoRunGraphRequest(request); in RunGraphAsync()
96 virtual void CleanupGraphAsync(const CleanupGraphRequest* request,
100 virtual void CleanupAllAsync(const CleanupAllRequest* request,
[all …]
|
| /external/okhttp/okcurl/src/test/java/com/squareup/okhttp/curl/ |
| D | MainTest.java | 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
45 RequestBody body = request.body(); in dataPost()
[all …]
|
| /external/mdnsresponder/mDNSShared/ |
| D | uds_daemon.c | 93 typedef void (*req_termination_fn)(request_state *request);
100 request_state *request; member
112 request_state *request; member
358 … reply_state *create_reply(const reply_op_t op, const size_t datalen, request_state *const request) in create_reply() argument
379 reply->mhdr->client_context = request->hdr.client_context; in create_reply()
400 …request_state *const request, reply_state **const rep, reply_op_t op, DNSServiceFlags flags, mStat… in GenerateNTDResponse() argument
428 *rep = create_reply(op, len, request); in GenerateNTDResponse()
446 …request_state *const request, reply_state **const rep, reply_op_t op, DNSServiceFlags flags, mStat… in GenerateBonjourBrowserResponse() argument
471 *rep = create_reply(op, len, request); in GenerateBonjourBrowserResponse()
486 mDNSlocal AuthRecord *read_rr_from_ipc_msg(request_state *request, int GetTTL, int validate_flags) in read_rr_from_ipc_msg() argument
[all …]
|
| /external/grpc-grpc/test/core/security/ |
| D | oauth2_utils.cc | 43 oauth2_request* request = static_cast<oauth2_request*>(arg); in on_oauth2_response() local
49 GPR_ASSERT(request->md_array.size == 1); in on_oauth2_response()
50 token_slice = GRPC_MDVALUE(request->md_array.md[0]); in on_oauth2_response()
56 grpc_credentials_mdelem_array_destroy(&request->md_array); in on_oauth2_response()
57 gpr_mu_lock(request->mu); in on_oauth2_response()
58 request->is_done = true; in on_oauth2_response()
59 request->token = token; in on_oauth2_response()
62 grpc_pollset_kick(grpc_polling_entity_pollset(&request->pops), nullptr)); in on_oauth2_response()
63 gpr_mu_unlock(request->mu); in on_oauth2_response()
70 oauth2_request request; in grpc_test_fetch_oauth2_token_with_credentials() local
[all …]
|
| /external/volley/src/main/java/com/android/volley/ |
| D | NetworkDispatcher.java | 78 private void addTrafficStatsTag(Request<?> request) { in addTrafficStatsTag() argument
81 TrafficStats.setThreadStatsTag(request.getTrafficStatsTag()); in addTrafficStatsTag()
110 Request<?> request = mQueue.take(); in processRequest() local
111 processRequest(request); in processRequest()
115 void processRequest(Request<?> request) { in processRequest() argument
117 request.sendEvent(RequestQueue.RequestEvent.REQUEST_NETWORK_DISPATCH_STARTED); in processRequest()
119 request.addMarker("network-queue-take"); in processRequest()
123 if (request.isCanceled()) { in processRequest()
124 request.finish("network-discard-cancelled"); in processRequest()
125 request.notifyListenerResponseNotUsable(); in processRequest()
[all …]
|
| D | CacheDispatcher.java | 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()
125 request.sendEvent(RequestQueue.RequestEvent.REQUEST_CACHE_LOOKUP_STARTED); in processRequest()
129 if (request.isCanceled()) { in processRequest()
130 request.finish("cache-discard-canceled"); in processRequest()
135 Cache.Entry entry = mCache.get(request.getCacheKey()); in processRequest()
137 request.addMarker("cache-miss"); in processRequest()
139 if (!mWaitingRequestManager.maybeAddToWaitingRequests(request)) { in processRequest()
[all …]
|
| /external/autotest/scheduler/ |
| D | rdb.py | 100 def update_response_map(self, request, response, append=False): argument
120 (request, response))
121 exist_response = self.response_map.setdefault(request, [])
126 (request, response))
140 for request, response in self.response_map.iteritems():
148 (response, request, self.response_map))
153 def _record_exceptions(self, request, exceptions): argument
160 self.update_response_map(request, rdb_exceptions)
171 for request, response in self.response_map.iteritems():
172 self.response_map[request] = [reply.wire_format()
[all …]
|
| /external/volley/src/test/java/com/android/volley/toolbox/ |
| D | HttpClientStackTest.java | 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()
69 TestRequest.Post request = new TestRequest.Post(); in createPostRequest() local
[all …]
|
| /external/glide/library/src/main/java/com/bumptech/glide/manager/ |
| D | RequestTracker.java | 3 import com.bumptech.glide.request.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()
40 public void removeRequest(Request request) { in removeRequest() argument
41 requests.remove(request); in removeRequest()
56 for (Request request : requests) { in pauseRequests()
57 if (request.isRunning()) { in pauseRequests()
[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 …]
|
| D | test_decorators.py | 50 request = self.factory.get('/test')
51 request.session = self.session
54 def test_view(request): argument
57 response = test_view(request)
59 self.assertIsNotNone(request.oauth)
60 self.assertFalse(request.oauth.has_credentials())
61 self.assertIsNone(request.oauth.http)
65 request = self.factory.get('/test')
66 request.session = mock.MagicMock()
76 def test_view(request): argument
[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 …]
|
| D | keymaster-provision-tests.cc | 39 virtual void PopulateDefaultRequest(ProvisionDeviceIdsRequest *request);
65 ProvisionDeviceIdsRequest *request) { in PopulateDefaultRequest() argument
66 request->set_product_brand("Pixel"); in PopulateDefaultRequest()
67 request->set_product_device("3"); in PopulateDefaultRequest()
68 request->set_product_name("Pixel"); in PopulateDefaultRequest()
69 request->set_serialno("12345678"); in PopulateDefaultRequest()
70 request->set_product_manufacturer("Google"); in PopulateDefaultRequest()
71 request->set_product_model("3"); in PopulateDefaultRequest()
72 request->set_imei("12345678"); in PopulateDefaultRequest()
73 request->set_meid("12345678"); in PopulateDefaultRequest()
[all …]
|
| /external/grpc-grpc/test/cpp/end2end/ |
| D | end2end_test.cc | 174 Status Echo(ServerContext* server_context, const EchoRequest* request, in Echo() argument
178 return stub_->Echo(client_context.get(), *request, response); in Echo()
188 Status Echo(ServerContext* context, const EchoRequest* request, in Echo() argument
342 EchoRequest request; in SendRpc() local
344 request.set_message("Hello hello hello hello"); in SendRpc()
354 Status s = stub->Echo(&context, request, &response); in SendRpc()
355 EXPECT_EQ(response.message(), request.message()); in SendRpc()
380 EchoRequest request; in TestRequestStreamServerCancel() local
392 request.set_message("hello"); in TestRequestStreamServerCancel()
393 if (!stream->Write(request)) { in TestRequestStreamServerCancel()
[all …]
|
| D | test_service_impl.cc | 41 void MaybeEchoDeadline(ServerContext* context, const EchoRequest* request, in MaybeEchoDeadline() argument
43 if (request->has_param() && request->param().echo_deadline()) { in MaybeEchoDeadline()
74 Status TestServiceImpl::Echo(ServerContext* context, const EchoRequest* request, in Echo() argument
77 if (request->has_param() && request->param().server_sleep_us() > 0) { in Echo()
80 gpr_time_from_micros(request->param().server_sleep_us(), in Echo()
84 if (request->has_param() && request->param().server_die()) { in Echo()
88 if (request->has_param() && request->param().has_expected_error()) { in Echo()
89 const auto& error = request->param().expected_error(); in Echo()
104 response->set_message(request->message()); in Echo()
105 MaybeEchoDeadline(context, request, response); in Echo()
[all …]
|
| /external/libcups/cups/ |
| D | dest-job.c | 44 ipp_t *request; /* Cancel-Job request */ in cupsCancelDestJob() local
46 request = ippNewRequest(IPP_OP_CANCEL_JOB); in cupsCancelDestJob()
48 ippSetVersion(request, info->version / 10, info->version % 10); in cupsCancelDestJob()
50 ippAddString(request, IPP_TAG_OPERATION, IPP_TAG_URI, "printer-uri", NULL, info->uri); in cupsCancelDestJob()
51 ippAddInteger(request, IPP_TAG_OPERATION, IPP_TAG_INTEGER, "job-id", job_id); in cupsCancelDestJob()
52 … ippAddString(request, IPP_TAG_OPERATION, IPP_TAG_NAME, "requesting-user-name", NULL, cupsUser()); in cupsCancelDestJob()
54 ippDelete(cupsDoRequest(http, request, info->resource)); in cupsCancelDestJob()
80 ipp_t *request = NULL;/* Close-Job/Send-Document request */ in cupsCloseDestJob() local
114 request = ippNewRequest(IPP_OP_CLOSE_JOB); in cupsCloseDestJob()
119 if (!request) in cupsCloseDestJob()
[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()
51 VLOG(3) << "TransferToClientRequest: {" << request.DebugString() << "}"; in Transfer()
52 Status s = stub_->TransferToClient(&request, &response); in Transfer()
70 TransferToServerRequest request; in TransferToServer() local
71 *request.mutable_literal() = literal.ToProto(); in TransferToServer()
73 *request.mutable_device_handle() = *device_handle; in TransferToServer()
78 VLOG(3) << "TransferToServerRequest: {" << request.DebugString() << "}"; in TransferToServer()
79 Status s = stub_->TransferToServer(&request, &response); in TransferToServer()
[all …]
|
| /external/python/apitools/samples/storage_sample/storage_v1/ |
| D | storage_v1.py | 185 request = messages.StorageBucketAccessControlsDeleteRequest(
190 request, global_params=global_params)
213 request = messages.StorageBucketAccessControlsGetRequest(
218 request, global_params=global_params)
318 request = messages.BucketAccessControl(
322 request.domain = FLAGS.domain.decode('utf8')
324 request.email = FLAGS.email.decode('utf8')
326 request.entity = FLAGS.entity.decode('utf8')
328 request.entityId = FLAGS.entityId.decode('utf8')
330 request.etag = FLAGS.etag.decode('utf8')
[all …]
|
| /external/u-boot/drivers/usb/musb-new/ |
| D | musb_gadget.c | 80 static inline void map_dma_buffer(struct musb_request *request, in map_dma_buffer() argument
86 request->map_state = UN_MAPPED; in map_dma_buffer()
97 musb_ep->packet_sz, request->request.buf, in map_dma_buffer()
98 request->request.length); in map_dma_buffer()
102 if (request->request.dma == DMA_ADDR_INVALID) { in map_dma_buffer()
103 request->request.dma = dma_map_single( in map_dma_buffer()
105 request->request.buf, in map_dma_buffer()
106 request->request.length, in map_dma_buffer()
107 request->tx in map_dma_buffer()
110 request->map_state = MUSB_MAPPED; in map_dma_buffer()
[all …]
|