| /external/erofs-utils/lib/ |
| D | decompress.c | 16 static int z_erofs_decompress_lz4(struct z_erofs_decompress_req *rq) in z_erofs_decompress_lz4() argument
19 char *dest = rq->out; in z_erofs_decompress_lz4()
20 char *src = rq->in; in z_erofs_decompress_lz4()
32 if (inputmargin >= rq->inputsize) in z_erofs_decompress_lz4()
36 if (rq->decodedskip) { in z_erofs_decompress_lz4()
37 buff = malloc(rq->decodedlength); in z_erofs_decompress_lz4()
43 if (rq->partial_decoding || !support_0padding) in z_erofs_decompress_lz4()
45 rq->inputsize - inputmargin, in z_erofs_decompress_lz4()
46 rq->decodedlength, rq->decodedlength); in z_erofs_decompress_lz4()
49 rq->inputsize - inputmargin, in z_erofs_decompress_lz4()
[all …]
|
| /external/grpc-grpc/test/cpp/thread_manager/ |
| D | thread_manager_test.cc | 49 ThreadManagerTest(const char* name, grpc_resource_quota* rq, in ThreadManagerTest() argument
51 : ThreadManager(name, rq, settings.min_pollers, settings.max_pollers), in ThreadManagerTest()
122 grpc_resource_quota* rq = grpc_resource_quota_create("Test-poll-and-work"); in TestPollAndWork() local
127 grpc::ThreadManagerTest test_thread_mgr("TestThreadManager", rq, settings); in TestPollAndWork()
128 grpc_resource_quota_unref(rq); in TestPollAndWork()
143 grpc_resource_quota* rq = grpc_resource_quota_create("Test-thread-quota"); in TestThreadQuota() local
144 grpc_resource_quota_set_max_threads(rq, kMaxNumThreads); in TestThreadQuota()
156 grpc::ThreadManagerTest test_thread_mgr_1("TestThreadManager-1", rq, in TestThreadQuota()
158 grpc::ThreadManagerTest test_thread_mgr_2("TestThreadManager-2", rq, in TestThreadQuota()
161 grpc_resource_quota_unref(rq); in TestThreadQuota()
|
| /external/bcc/tests/python/ |
| D | test_trace3.c | 5 struct Request { u64 rq; }; member
31 struct Request rq = {.rq = PT_REGS_PARM1(ctx)}; in probe_blk_start_request() local
33 requests.update(&rq, &tm); in probe_blk_start_request()
38 struct Request rq = {.rq = PT_REGS_PARM1(ctx)}; in probe_blk_update_request() local
39 struct Time *tm = requests.lookup(&rq); in probe_blk_update_request()
42 requests.delete(&rq); in probe_blk_update_request()
|
| /external/ltp/testcases/kernel/syscalls/mq_timedsend/ |
| D | mq_timedsend01.c | 98 .rq = &(struct timespec) {.tv_sec = -1, .tv_nsec = 0},
106 .rq = &(struct timespec) {.tv_sec = 0, .tv_nsec = -1},
114 .rq = &(struct timespec) {.tv_sec = 0, .tv_nsec = 1000000000},
122 .rq = &ts,
133 .rq = &ts,
149 pid = set_sig(tc->rq); in do_test()
152 set_timeout(tc->rq); in do_test()
159 TEST(mq_timedsend(*tc->fd, smsg, tc->len, tc->prio, tc->rq)); in do_test()
178 TEST(mq_timedreceive(*tc->fd, rmsg, len, &prio, tc->rq)); in do_test()
|
| /external/deqp-deps/glslang/Test/baseResults/ |
| D | rayQuery-global.rgen.out | 18 Name 9 "rq"
20 Name 12 "rq"
61 9(rq): 7(ptr) FunctionParameter
63 16: 15(bool) RayQueryProceedKHR 9(rq)
68 12(rq): 7(ptr) FunctionParameter
70 19: 15(bool) RayQueryProceedKHR 12(rq)
72 21: 2 FunctionCall 10(otherWrapper(rq1;) 12(rq)
|
| /external/ltp/testcases/kernel/syscalls/clock_nanosleep/ |
| D | clock_nanosleep01.c | 33 struct timespec rq; member
49 .rq = (struct timespec) {.tv_sec = 0, .tv_nsec = -1},
57 .rq = (struct timespec) {.tv_sec = 0, .tv_nsec = 1000000000},
65 .rq = (struct timespec) {.tv_sec = 0, .tv_nsec = 500000000},
73 .rq = (struct timespec) {.tv_sec = 10, .tv_nsec = 0},
95 TEST(clock_nanosleep(tc->clk_id, tc->flags, &tc->rq, &rm)); in do_test()
103 long long expect_ms = tst_timespec_to_ms(tc->rq); in do_test()
|
| /external/ltp/testcases/kernel/syscalls/mq_timedreceive/ |
| D | mq_timedreceive01.c | 98 .rq = &(struct timespec) {.tv_sec = -1, .tv_nsec = 0},
105 .rq = &(struct timespec) {.tv_sec = 0, .tv_nsec = -1},
112 .rq = &(struct timespec) {.tv_sec = 0, .tv_nsec = 1000000000},
121 .rq = &ts,
128 .rq = &ts,
144 pid = set_sig(tc->rq); in do_test()
147 set_timeout(tc->rq); in do_test()
155 TEST(mq_timedreceive(*tc->fd, rmsg, len, &prio, tc->rq)); in do_test()
|
| /external/deqp-deps/glslang/Test/ |
| D | rayQuery-global.rgen | 9 void otherWrapper(rayQueryEXT rq) {
10 rayQueryProceedEXT(rq);
14 void wrapper(rayQueryEXT rq) {
16 rayQueryProceedEXT(rq);
18 otherWrapper(rq);
|
| /external/ltp/testcases/kernel/syscalls/mq_open/ |
| D | mq_open01.c | 34 struct mq_attr *rq; member
55 .rq = &(struct mq_attr){.mq_maxmsg = 20, .mq_msgsize = 16384},
231 TEST(fd = mq_open(qname, tc->oflag, S_IRWXU, tc->rq)); in do_test()
233 if (fd > 0 && tc->rq) { in do_test()
239 if (oldattr.mq_maxmsg != tc->rq->mq_maxmsg in do_test()
240 || oldattr.mq_msgsize != tc->rq->mq_msgsize) { in do_test()
244 tc->rq->mq_maxmsg, oldattr.mq_maxmsg, tc->rq->mq_msgsize, in do_test()
|
| /external/ltp/testcases/kernel/device-drivers/tbio/tbio_kernel/ |
| D | ltp_tbio.c | 81 struct request *rq; in send_request() local
82 rq = blk_make_request(q, bio, GFP_KERNEL); in send_request()
83 if (!rq) { in send_request()
88 if ((!inter->cmd_len) || (inter->cmd_len > rq->cmd_len)) { in send_request()
93 rq->cmd_len = inter->cmd_len; in send_request()
95 if (copy_from_user(rq->cmd, inter->cmd, inter->cmd_len)) in send_request()
98 if (*(rq->cmd + rq->cmd_len - 1)) { in send_request()
103 rq->__sector = bio->bi_sector; in send_request()
105 if (blk_execute_rq(q, bdev->bd_disk, rq, 0)) in send_request()
108 blk_put_request(rq); in send_request()
[all …]
|
| /external/libcxx/test/std/thread/thread.mutex/thread.once/thread.once.callonce/ |
| D | call_once.pass.cpp | 250 RefQual rq; in main() local
251 std::call_once(f1, rq); in main()
252 assert(rq.lv_called == 1); in main()
253 std::call_once(f2, std::move(rq)); in main()
254 assert(rq.rv_called == 1); in main()
|
| /external/llvm-project/libcxx/test/std/thread/thread.mutex/thread.once/thread.once.callonce/ |
| D | call_once.pass.cpp | 250 RefQual rq; in main() local
251 std::call_once(f1, rq); in main()
252 assert(rq.lv_called == 1); in main()
253 std::call_once(f2, std::move(rq)); in main()
254 assert(rq.rv_called == 1); in main()
|
| /external/grpc-grpc/src/core/lib/iomgr/ |
| D | resource_quota.cc | 272 static void rq_step(void* rq, grpc_error* error) { in rq_step() argument
273 grpc_resource_quota* resource_quota = static_cast<grpc_resource_quota*>(rq); in rq_step()
606 static void rq_reclamation_done(void* rq, grpc_error* error) { in rq_reclamation_done() argument
607 grpc_resource_quota* resource_quota = static_cast<grpc_resource_quota*>(rq); in rq_reclamation_done()
730 static void* rq_copy(void* rq) { in rq_copy() argument
731 grpc_resource_quota_ref(static_cast<grpc_resource_quota*>(rq)); in rq_copy()
732 return rq; in rq_copy()
735 static void rq_destroy(void* rq) { in rq_destroy() argument
736 grpc_resource_quota_unref_internal(static_cast<grpc_resource_quota*>(rq)); in rq_destroy()
837 grpc_resource_quota* rq = resource_user->resource_quota; in grpc_resource_user_allocate_threads() local
[all …]
|
| /external/rust/crates/grpcio-sys/grpc/src/core/lib/iomgr/ |
| D | resource_quota.cc | 279 static void rq_step(void* rq, grpc_error* /*error*/) { in rq_step() argument
280 grpc_resource_quota* resource_quota = static_cast<grpc_resource_quota*>(rq); in rq_step()
633 static void rq_reclamation_done(void* rq, grpc_error* /*error*/) { in rq_reclamation_done() argument
634 grpc_resource_quota* resource_quota = static_cast<grpc_resource_quota*>(rq); in rq_reclamation_done()
756 static void* rq_copy(void* rq) { in rq_copy() argument
757 grpc_resource_quota_ref(static_cast<grpc_resource_quota*>(rq)); in rq_copy()
758 return rq; in rq_copy()
761 static void rq_destroy(void* rq) { in rq_destroy() argument
762 grpc_resource_quota_unref_internal(static_cast<grpc_resource_quota*>(rq)); in rq_destroy()
857 grpc_resource_quota* rq = resource_user->resource_quota; in grpc_resource_user_allocate_threads() local
[all …]
|
| /external/libwebsockets/minimal-examples/crypto/minimal-crypto-jwk/ |
| D | CMakeLists.txt | 18 set (rq 1) variable
20 set (rq 0) variable
23 set(rq 0) variable
26 if (${_val} EQUAL ${rq})
|
| /external/libwebsockets/minimal-examples/api-tests/api-test-lws_struct-json/ |
| D | CMakeLists.txt | 18 set (rq 1) variable
20 set (rq 0) variable
23 set(rq 0) variable
26 if (${_val} EQUAL ${rq})
|
| /external/libwebsockets/minimal-examples/raw/minimal-raw-file/ |
| D | CMakeLists.txt | 18 set (rq 1) variable
20 set (rq 0) variable
23 set(rq 0) variable
26 if (${_val} EQUAL ${rq})
|
| /external/libwebsockets/minimal-examples/mqtt-client/minimal-mqtt-client/ |
| D | CMakeLists.txt | 17 set (rq 1) variable
19 set (rq 0) variable
22 set(rq 0) variable
25 if (${_val} EQUAL ${rq})
|
| /external/libwebsockets/minimal-examples/raw/minimal-raw-serial/ |
| D | CMakeLists.txt | 18 set (rq 1) variable
20 set (rq 0) variable
23 set(rq 0) variable
26 if (${_val} EQUAL ${rq})
|
| /external/libwebsockets/minimal-examples/raw/minimal-raw-vhost/ |
| D | CMakeLists.txt | 18 set (rq 1) variable
20 set (rq 0) variable
23 set(rq 0) variable
26 if (${_val} EQUAL ${rq})
|
| /external/libwebsockets/minimal-examples/api-tests/api-test-lwsac/ |
| D | CMakeLists.txt | 18 set (rq 1) variable
20 set (rq 0) variable
23 set(rq 0) variable
26 if (${_val} EQUAL ${rq})
|
| /external/libwebsockets/minimal-examples/crypto/minimal-crypto-jwe/ |
| D | CMakeLists.txt | 18 set (rq 1) variable
20 set (rq 0) variable
23 set(rq 0) variable
26 if (${_val} EQUAL ${rq})
|
| /external/libwebsockets/minimal-examples/raw/minimal-raw-netcat/ |
| D | CMakeLists.txt | 18 set (rq 1) variable
20 set (rq 0) variable
23 set(rq 0) variable
26 if (${_val} EQUAL ${rq})
|
| /external/libwebsockets/minimal-examples/api-tests/api-test-fts/ |
| D | CMakeLists.txt | 18 set (rq 1) variable
20 set (rq 0) variable
23 set(rq 0) variable
26 if (${_val} EQUAL ${rq})
|
| /external/libwebsockets/minimal-examples/api-tests/api-test-dhcpc/ |
| D | CMakeLists.txt | 18 set (rq 1) variable
20 set (rq 0) variable
23 set(rq 0) variable
26 if (${_val} EQUAL ${rq})
|