| /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/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/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/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/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/rust/crates/grpcio-sys/grpc/test/core/security/ |
| D | oauth2_utils.cc | 44 oauth2_request* request = static_cast<oauth2_request*>(arg); in on_oauth2_response() local
50 GPR_ASSERT(request->md_array.size == 1); in on_oauth2_response()
51 token_slice = GRPC_MDVALUE(request->md_array.md[0]); in on_oauth2_response()
57 grpc_credentials_mdelem_array_destroy(&request->md_array); in on_oauth2_response()
58 gpr_mu_lock(request->mu); in on_oauth2_response()
59 request->is_done = true; in on_oauth2_response()
60 request->token = token; in on_oauth2_response()
63 grpc_pollset_kick(grpc_polling_entity_pollset(&request->pops), nullptr)); in on_oauth2_response()
64 gpr_mu_unlock(request->mu); in on_oauth2_response()
71 oauth2_request request; in grpc_test_fetch_oauth2_token_with_credentials() local
[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/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/volley/src/main/java/com/android/volley/ |
| D | CacheDispatcher.java | 114 final Request<?> request = mCacheQueue.take(); in processRequest() local
115 processRequest(request); in processRequest()
119 void processRequest(final Request<?> request) throws InterruptedException { in processRequest() argument
120 request.addMarker("cache-queue-take"); in processRequest()
121 request.sendEvent(RequestQueue.RequestEvent.REQUEST_CACHE_LOOKUP_STARTED); in processRequest()
125 if (request.isCanceled()) { in processRequest()
126 request.finish("cache-discard-canceled"); in processRequest()
131 Cache.Entry entry = mCache.get(request.getCacheKey()); in processRequest()
133 request.addMarker("cache-miss"); in processRequest()
135 if (!mWaitingRequestManager.maybeAddToWaitingRequests(request)) { in processRequest()
[all …]
|
| 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 …]
|
| /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 | 40 const GetStatusRequest* request,
45 const CreateWorkerSessionRequest* request,
49 CallOptions* opts, const DeleteWorkerSessionRequest* request,
52 virtual void RegisterGraphAsync(const RegisterGraphRequest* request,
56 virtual void DeregisterGraphAsync(const DeregisterGraphRequest* request,
60 virtual void RunGraphAsync(CallOptions* opts, RunGraphRequestWrapper* request,
64 virtual void RunGraphAsync(CallOptions* opts, const RunGraphRequest* request, in RunGraphAsync() argument
66 RunGraphRequestWrapper* wrapped_request = new ProtoRunGraphRequest(request); in RunGraphAsync()
96 virtual void CleanupGraphAsync(const CleanupGraphRequest* request,
100 virtual void CleanupAllAsync(const CleanupAllRequest* request,
[all …]
|
| D | worker.cc | 38 void Worker::GetStatusAsync(CallOptions* opts, const GetStatusRequest* request, in GetStatusAsync() argument
51 void Worker::CreateWorkerSessionAsync(const CreateWorkerSessionRequest* request, in CreateWorkerSessionAsync() argument
55 request->session_handle(), request->server_def(), in CreateWorkerSessionAsync()
56 request->cluster_device_attributes(), request->isolate_session_state(), in CreateWorkerSessionAsync()
57 request->master_task(), request->master_incarnation()); in CreateWorkerSessionAsync()
62 const DeleteWorkerSessionRequest* request, in DeleteWorkerSessionAsync() argument
65 Status s = env_->session_mgr->DeleteSession(request->session_handle()); in DeleteWorkerSessionAsync()
69 void Worker::RegisterGraphAsync(const RegisterGraphRequest* request, in RegisterGraphAsync() argument
74 if (request->create_worker_session_called()) { in RegisterGraphAsync()
75 s = env_->session_mgr->WorkerSessionForSession(request->session_handle(), in RegisterGraphAsync()
[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 …]
|
| D | HurlStackTest.java | 74 Request<?> request, HttpURLConnection connection) { in setUp()
76 super.createInputStream(request, connection)); in setUp()
81 Request<?> request, HttpURLConnection connection, int length) in setUp()
83 if (request instanceof MonitoredRequest) { in setUp()
85 super.createOutputStream(request, connection, length), in setUp()
86 (MonitoredRequest) request, in setUp()
89 return super.createOutputStream(request, connection, length); in setUp()
96 TestRequest.DeprecatedGet request = new TestRequest.DeprecatedGet(); in connectionForDeprecatedGetRequest() local
97 assertEquals(request.getMethod(), Method.DEPRECATED_GET_OR_POST); in connectionForDeprecatedGetRequest()
99 mHurlStack.setConnectionParametersForRequest(mMockConnection, request); in connectionForDeprecatedGetRequest()
[all …]
|
| /external/icu/icu4c/source/python/icutools/databuilder/renderers/ |
| D | makefile.py | 37 for request in requests:
38 make_rules += get_gnumake_rules_helper(request, **kwargs)
86 def get_gnumake_rules_helper(request, common_vars, **kwargs):
88 if isinstance(request, PrintFileRequest):
89 var_name = "%s_CONTENT" % request.name.upper()
93 content = request.content
96 name = request.name,
99 output_file = request.output_file,
103 MAKEFILENAME = files_to_makefile([request.output_file], common_vars),
111 if isinstance(request, CopyRequest):
[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/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/llvm-project/lldb/unittests/Utility/ |
| D | CompletionRequestTest.cpp | 21 CompletionRequest request(command, cursor_pos, result); in TEST() local
24 EXPECT_EQ(request.GetRawLine(), "a b"); in TEST()
25 EXPECT_EQ(request.GetRawLineWithUnusedSuffix(), command); in TEST()
26 EXPECT_EQ(request.GetRawCursorPos(), cursor_pos); in TEST()
27 EXPECT_EQ(request.GetCursorIndex(), arg_index); in TEST()
29 EXPECT_EQ(request.GetParsedLine().GetArgumentCount(), 2u); in TEST()
30 EXPECT_EQ(request.GetCursorArgumentPrefix().str(), "b"); in TEST()
40 CompletionRequest request(command, cursor_pos, result); in TEST() local
42 EXPECT_EQ(request.GetRawLine(), command); in TEST()
43 EXPECT_EQ(request.GetRawLineWithUnusedSuffix(), command); in TEST()
[all …]
|
| /external/libcups/cups/ |
| D | dest-job.c | 39 ipp_t *request; /* Cancel-Job request */ in cupsCancelDestJob() local
41 request = ippNewRequest(IPP_OP_CANCEL_JOB); in cupsCancelDestJob()
43 ippSetVersion(request, info->version / 10, info->version % 10); in cupsCancelDestJob()
45 ippAddString(request, IPP_TAG_OPERATION, IPP_TAG_URI, "printer-uri", NULL, info->uri); in cupsCancelDestJob()
46 ippAddInteger(request, IPP_TAG_OPERATION, IPP_TAG_INTEGER, "job-id", job_id); in cupsCancelDestJob()
47 … ippAddString(request, IPP_TAG_OPERATION, IPP_TAG_NAME, "requesting-user-name", NULL, cupsUser()); in cupsCancelDestJob()
49 ippDelete(cupsDoRequest(http, request, info->resource)); in cupsCancelDestJob()
75 ipp_t *request = NULL;/* Close-Job/Send-Document request */ in cupsCloseDestJob() local
109 request = ippNewRequest(IPP_OP_CLOSE_JOB); in cupsCloseDestJob()
114 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/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 …]
|