/third_party/node/test/parallel/ |
H A D | test-http-client-default-headers-exist.js | 41 const server = http.createServer(common.mustCall((req, res) => { 44 assert(Object.hasOwn(expectedHeaders, req.method), 45 `${req.method} was an unexpected method`); 47 const requestHeaders = Object.keys(req.headers); 50 expectedHeaders[req.method].includes(header.toLowerCase()), 51 `${header} should not exist for method ${req.method}` 57 expectedHeaders[req.method].length, 58 `some headers were missing for method: ${req.method}`
|
H A D | test-http-keepalive-request.js | 30 const server = http.createServer(function(req, res) { 33 assert.strictEqual(req.socket, serverSocket); 35 serverSocket = req.socket; 38 res.end(req.url); 59 const req = http.request({ 65 req.end(); 67 req.on('socket', function(sock) { 75 req.on('response', function(res) {
|
H A D | test-http-keepalive-client.js | 30 const server = http.createServer(function(req, res) { 33 assert.strictEqual(req.socket, serverSocket); 35 serverSocket = req.socket; 38 res.end(req.url); 59 const req = http.request({ 65 req.end(); 67 req.on('socket', function(sock) { 75 req.on('response', function(res) {
|
H A D | test-http2-trailers.js | 51 const req = client.request({ ':path': '/', ':method': 'POST' }, 53 req.on('wantTrailers', () => { 54 req.sendTrailers({ [trailerKey]: trailerValue }); 56 req.on('data', common.mustCall()); 57 req.on('trailers', common.mustCall((headers) => { 60 req.on('close', common.mustCall(() => { 62 () => req.sendTrailers({}), 71 req.end('data');
|
H A D | test-http-outgoing-properties.js | 19 const server = http.createServer(common.mustCall(function(req, res) { 20 const hwm = req.socket.writableHighWaterMark; 56 const server = http.createServer((req, res) => { 64 const req = http.request({ 70 assert.strictEqual(req.path, '/'); 71 assert.strictEqual(req.method, 'GET'); 72 assert.strictEqual(req.host, 'localhost'); 73 assert.strictEqual(req.protocol, 'http:'); 74 req.end();
|
H A D | test-http2-options-max-headers-exceeds-nghttp2.js | 31 const req = client.request({ 35 req.on('response', common.mustNotCall()); 37 req.on('close', common.mustCall(() => { 42 req.on('error', common.expectsError({ 47 req.end(); 93 const req = client.request(); 94 req.on('response', common.mustNotCall()); 95 req.on('error', common.mustNotCall()); 96 req.end();
|
/foundation/distributedhardware/device_manager/interfaces/inner_kits/native_cpp/src/ipc/lite/ |
H A D | ipc_client_manager.cpp | 41 std::shared_ptr<IpcRegisterListenerReq> req = std::make_shared<IpcRegisterListenerReq>(); in Init() local 43 req->SetPkgName(pkgName); in Init() 44 req->SetSvcIdentity(IpcClientStub::GetInstance().GetSvcIdentity()); in Init() 45 int32_t ret = serverProxy_.SendCmd(REGISTER_DEVICE_MANAGER_LISTENER, req, rsp); in Init() 66 std::shared_ptr<IpcReq> req = std::make_shared<IpcReq>(); in UnInit() local 68 req->SetPkgName(pkgName); in UnInit() 69 int32_t ret = serverProxy_.SendCmd(UNREGISTER_DEVICE_MANAGER_LISTENER, req, rsp); in UnInit() 85 int32_t IpcClientManager::SendRequest(int32_t cmdCode, std::shared_ptr<IpcReq> req, std::shared_ptr<IpcRsp> rsp) in SendRequest() argument 87 CHECK_NULL_RETURN(req, ERR_DM_POINT_NULL); in SendRequest() 89 std::string pkgName = req in SendRequest() [all...] |
/kernel/linux/linux-5.10/block/ |
H A D | blk-crypto-internal.h | 31 static inline bool bio_crypt_ctx_back_mergeable(struct request *req, in bio_crypt_ctx_back_mergeable() argument 34 return bio_crypt_ctx_mergeable(req->crypt_ctx, blk_rq_bytes(req), in bio_crypt_ctx_back_mergeable() 38 static inline bool bio_crypt_ctx_front_mergeable(struct request *req, in bio_crypt_ctx_front_mergeable() argument 42 bio->bi_iter.bi_size, req->crypt_ctx); in bio_crypt_ctx_front_mergeable() 45 static inline bool bio_crypt_ctx_merge_rq(struct request *req, in bio_crypt_ctx_merge_rq() argument 48 return bio_crypt_ctx_mergeable(req->crypt_ctx, blk_rq_bytes(req), in bio_crypt_ctx_merge_rq() 76 static inline bool bio_crypt_ctx_front_mergeable(struct request *req, in bio_crypt_ctx_front_mergeable() argument 82 static inline bool bio_crypt_ctx_back_mergeable(struct request *req, in bio_crypt_ctx_back_mergeable() argument 88 bio_crypt_ctx_merge_rq(struct request *req, struct request *next) bio_crypt_ctx_merge_rq() argument [all...] |
/kernel/linux/linux-5.10/drivers/crypto/nx/ |
H A D | nx-aes-ecb.c | 53 static int ecb_aes_nx_crypt(struct skcipher_request *req, in ecb_aes_nx_crypt() argument 56 struct crypto_skcipher *tfm = crypto_skcipher_reqtfm(req); in ecb_aes_nx_crypt() 71 to_process = req->cryptlen - processed; in ecb_aes_nx_crypt() 73 rc = nx_build_sg_lists(nx_ctx, NULL, req->dst, req->src, in ecb_aes_nx_crypt() 84 req->base.flags & CRYPTO_TFM_REQ_MAY_SLEEP); in ecb_aes_nx_crypt() 93 } while (processed < req->cryptlen); in ecb_aes_nx_crypt() 100 static int ecb_aes_nx_encrypt(struct skcipher_request *req) in ecb_aes_nx_encrypt() argument 102 return ecb_aes_nx_crypt(req, 1); in ecb_aes_nx_encrypt() 105 static int ecb_aes_nx_decrypt(struct skcipher_request *req) in ecb_aes_nx_decrypt() argument [all...] |
/kernel/linux/linux-5.10/drivers/net/ethernet/hisilicon/hns3/hns3pf/ |
H A D | hclge_trace.h | 19 struct hclge_mbx_vf_to_pf_cmd *req), 20 TP_ARGS(hdev, req), 32 __entry->vfid = req->mbx_src_vfid; 33 __entry->code = req->msg.code; 34 __entry->subcode = req->msg.subcode; 37 memcpy(__entry->mbx_data, req, 52 struct hclge_mbx_pf_to_vf_cmd *req), 53 TP_ARGS(hdev, req), 64 __entry->vfid = req->dest_vfid; 65 __entry->code = req [all...] |
/kernel/linux/linux-5.10/drivers/net/ethernet/hisilicon/hns3/hns3vf/ |
H A D | hclgevf_trace.h | 19 struct hclge_mbx_pf_to_vf_cmd *req), 20 TP_ARGS(hdev, req), 31 __entry->vfid = req->dest_vfid; 32 __entry->code = req->msg.code; 35 memcpy(__entry->mbx_data, req, 50 struct hclge_mbx_vf_to_pf_cmd *req), 51 TP_ARGS(hdev, req), 63 __entry->vfid = req->mbx_src_vfid; 64 __entry->code = req->msg.code; 65 __entry->subcode = req [all...] |
/kernel/linux/linux-6.6/drivers/net/ethernet/hisilicon/hns3/hns3pf/ |
H A D | hclge_trace.h | 19 struct hclge_mbx_vf_to_pf_cmd *req), 20 TP_ARGS(hdev, req), 32 __entry->vfid = req->mbx_src_vfid; 33 __entry->code = req->msg.code; 34 __entry->subcode = req->msg.subcode; 37 memcpy(__entry->mbx_data, req, 52 struct hclge_mbx_pf_to_vf_cmd *req), 53 TP_ARGS(hdev, req), 64 __entry->vfid = req->dest_vfid; 65 __entry->code = le16_to_cpu(req [all...] |
/kernel/linux/linux-6.6/drivers/net/ethernet/hisilicon/hns3/hns3vf/ |
H A D | hclgevf_trace.h | 19 struct hclge_mbx_pf_to_vf_cmd *req), 20 TP_ARGS(hdev, req), 31 __entry->vfid = req->dest_vfid; 32 __entry->code = le16_to_cpu(req->msg.code); 35 memcpy(__entry->mbx_data, req, 50 struct hclge_mbx_vf_to_pf_cmd *req), 51 TP_ARGS(hdev, req), 63 __entry->vfid = req->mbx_src_vfid; 64 __entry->code = req->msg.code; 65 __entry->subcode = req [all...] |
/kernel/linux/linux-6.6/drivers/crypto/nx/ |
H A D | nx-aes-ecb.c | 53 static int ecb_aes_nx_crypt(struct skcipher_request *req, in ecb_aes_nx_crypt() argument 56 struct crypto_skcipher *tfm = crypto_skcipher_reqtfm(req); in ecb_aes_nx_crypt() 71 to_process = req->cryptlen - processed; in ecb_aes_nx_crypt() 73 rc = nx_build_sg_lists(nx_ctx, NULL, req->dst, req->src, in ecb_aes_nx_crypt() 84 req->base.flags & CRYPTO_TFM_REQ_MAY_SLEEP); in ecb_aes_nx_crypt() 93 } while (processed < req->cryptlen); in ecb_aes_nx_crypt() 100 static int ecb_aes_nx_encrypt(struct skcipher_request *req) in ecb_aes_nx_encrypt() argument 102 return ecb_aes_nx_crypt(req, 1); in ecb_aes_nx_encrypt() 105 static int ecb_aes_nx_decrypt(struct skcipher_request *req) in ecb_aes_nx_decrypt() argument [all...] |
/third_party/FreeBSD/sys/dev/usb/ |
H A D | usb_util.c | 200 usb_check_request(struct usb_device *udev, struct usb_device_request *req) in usb_check_request() argument 208 if (((req->bmRequestType == UT_WRITE_DEVICE) && in usb_check_request() 209 (req->bRequest == UR_SET_ADDRESS)) || in usb_check_request() 210 ((req->bmRequestType == UT_WRITE_DEVICE) && in usb_check_request() 211 (req->bRequest == UR_SET_CONFIG)) || in usb_check_request() 212 ((req->bmRequestType == UT_WRITE_INTERFACE) && in usb_check_request() 213 (req->bRequest == UR_SET_INTERFACE))) { in usb_check_request() 225 if (req->bmRequestType == UT_WRITE_ENDPOINT) { in usb_check_request() 226 ep = usbd_get_ep_by_addr(udev, req->wIndex[0]); in usb_check_request() 229 if ((req in usb_check_request() [all...] |
/third_party/libuv/docs/code/pipe-echo-server/ |
H A D | main.c | 15 uv_write_t req; member 19 void free_write_req(uv_write_t *req) { in free_write_req() argument 20 write_req_t *wr = (write_req_t*) req; in free_write_req() 30 void echo_write(uv_write_t *req, int status) { in echo_write() argument 34 free_write_req(req); in echo_write() 39 write_req_t *req = (write_req_t*) malloc(sizeof(write_req_t)); in echo_read() local 40 req->buf = uv_buf_init(buf->base, nread); in echo_read() 41 uv_write((uv_write_t*) req, client, &req->buf, 1, echo_write); in echo_read() 71 uv_fs_t req; in remove_sock() local [all...] |
/third_party/musl/src/network/ |
H A D | netlink.c | 16 } req; in __netlink_enumerate() member 21 memset(&u.req, 0, sizeof(u.req)); in __netlink_enumerate() 22 u.req.nlh.nlmsg_len = sizeof(u.req); in __netlink_enumerate() 23 u.req.nlh.nlmsg_type = type; in __netlink_enumerate() 24 u.req.nlh.nlmsg_flags = NLM_F_DUMP | NLM_F_REQUEST; in __netlink_enumerate() 25 u.req.nlh.nlmsg_seq = seq; in __netlink_enumerate() 26 u.req.g.rtgen_family = af; in __netlink_enumerate() 27 r = send(fd, &u.req, sizeo in __netlink_enumerate() [all...] |
/kernel/linux/linux-5.10/drivers/video/fbdev/omap/ |
H A D | hwa742.c | 80 int (*handler)(struct hwa742_request *req); 230 struct hwa742_request *req; in alloc_req() local 240 req = list_entry(hwa742.free_req_list.next, in alloc_req() 242 list_del(&req->entry); in alloc_req() 245 INIT_LIST_HEAD(&req->entry); in alloc_req() 246 req->flags = req_flags; in alloc_req() 248 return req; in alloc_req() 251 static inline void free_req(struct hwa742_request *req) in free_req() argument 257 list_move(&req->entry, &hwa742.free_req_list); in free_req() 258 if (!(req in free_req() 271 struct hwa742_request *req; process_pending_requests() local 312 struct hwa742_request *req = (struct hwa742_request *)data; request_complete() local 327 send_frame_handler(struct hwa742_request *req) send_frame_handler() argument 418 struct hwa742_request *req; create_req_list() local 535 sync_handler(struct hwa742_request *req) sync_handler() argument 544 struct hwa742_request *req; hwa742_sync() local [all...] |
/kernel/linux/linux-5.10/drivers/regulator/ |
H A D | qcom_rpm-regulator.c | 190 const struct request_member *req, in rpm_reg_write() 193 if (WARN_ON((value << req->shift) & ~req->mask)) in rpm_reg_write() 196 vreg->val[req->word] &= ~req->mask; in rpm_reg_write() 197 vreg->val[req->word] |= value << req->shift; in rpm_reg_write() 211 const struct request_member *req = &parts->mV; in rpm_reg_set_mV_sel() local 215 if (req->mask == 0) in rpm_reg_set_mV_sel() 224 ret = rpm_reg_write(vreg, req, u in rpm_reg_set_mV_sel() 189 rpm_reg_write(struct qcom_rpm_reg *vreg, const struct request_member *req, const int value) rpm_reg_write() argument 238 const struct request_member *req = &parts->uV; rpm_reg_set_uV_sel() local 271 const struct request_member *req = &parts->mV; rpm_reg_mV_enable() local 290 const struct request_member *req = &parts->uV; rpm_reg_uV_enable() local 309 const struct request_member *req = &parts->enable_state; rpm_reg_switch_enable() local 328 const struct request_member *req = &parts->mV; rpm_reg_mV_disable() local 347 const struct request_member *req = &parts->uV; rpm_reg_uV_disable() local 366 const struct request_member *req = &parts->enable_state; rpm_reg_switch_disable() local 392 const struct request_member *req = &parts->ia; rpm_reg_set_load() local 630 rpm_reg_set(struct qcom_rpm_reg *vreg, const struct request_member *req, const int value) rpm_reg_set() argument [all...] |
/kernel/linux/linux-6.6/drivers/regulator/ |
H A D | qcom_rpm-regulator.c | 190 const struct request_member *req, in rpm_reg_write() 193 if (WARN_ON((value << req->shift) & ~req->mask)) in rpm_reg_write() 196 vreg->val[req->word] &= ~req->mask; in rpm_reg_write() 197 vreg->val[req->word] |= value << req->shift; in rpm_reg_write() 211 const struct request_member *req = &parts->mV; in rpm_reg_set_mV_sel() local 215 if (req->mask == 0) in rpm_reg_set_mV_sel() 224 ret = rpm_reg_write(vreg, req, u in rpm_reg_set_mV_sel() 189 rpm_reg_write(struct qcom_rpm_reg *vreg, const struct request_member *req, const int value) rpm_reg_write() argument 238 const struct request_member *req = &parts->uV; rpm_reg_set_uV_sel() local 271 const struct request_member *req = &parts->mV; rpm_reg_mV_enable() local 290 const struct request_member *req = &parts->uV; rpm_reg_uV_enable() local 309 const struct request_member *req = &parts->enable_state; rpm_reg_switch_enable() local 328 const struct request_member *req = &parts->mV; rpm_reg_mV_disable() local 347 const struct request_member *req = &parts->uV; rpm_reg_uV_disable() local 366 const struct request_member *req = &parts->enable_state; rpm_reg_switch_disable() local 392 const struct request_member *req = &parts->ia; rpm_reg_set_load() local 630 rpm_reg_set(struct qcom_rpm_reg *vreg, const struct request_member *req, const int value) rpm_reg_set() argument [all...] |
/third_party/node/deps/uv/src/win/ |
H A D | udp.c | 29 #include "req-inl.h" 268 uv_req_t* req; in uv__udp_queue_recv() local 276 req = &handle->recv_req; in uv__udp_queue_recv() 277 memset(&req->u.io.overlapped, 0, sizeof(req->u.io.overlapped)); in uv__udp_queue_recv() 306 &req->u.io.overlapped, in uv__udp_queue_recv() 310 /* Process the req without IOCP. */ in uv__udp_queue_recv() 312 req->u.io.overlapped.InternalHigh = bytes; in uv__udp_queue_recv() 314 uv__insert_pending_req(loop, req); in uv__udp_queue_recv() 316 /* The req wil in uv__udp_queue_recv() 404 uv__send(uv_udp_send_t* req, uv_udp_t* handle, const uv_buf_t bufs[], unsigned int nbufs, const struct sockaddr* addr, unsigned int addrlen, uv_udp_send_cb cb) uv__send() argument 453 uv__process_udp_recv_req(uv_loop_t* loop, uv_udp_t* handle, uv_req_t* req) uv__process_udp_recv_req() argument 564 uv__process_udp_send_req(uv_loop_t* loop, uv_udp_t* handle, uv_udp_send_t* req) uv__process_udp_send_req() argument 1102 uv__udp_send(uv_udp_send_t* req, uv_udp_t* handle, const uv_buf_t bufs[], unsigned int nbufs, const struct sockaddr* addr, unsigned int addrlen, uv_udp_send_cb send_cb) uv__udp_send() argument [all...] |
/kernel/linux/linux-5.10/drivers/crypto/ |
H A D | omap-sham.c | 194 void (*copy_hash)(struct ahash_request *req, int out); 232 struct ahash_request *req; member 249 static int omap_sham_enqueue(struct ahash_request *req, unsigned int op); 250 static void omap_sham_finish_req(struct ahash_request *req, int err); 286 static void omap_sham_copy_hash_omap2(struct ahash_request *req, int out) in omap_sham_copy_hash_omap2() argument 288 struct omap_sham_reqctx *ctx = ahash_request_ctx(req); in omap_sham_copy_hash_omap2() 301 static void omap_sham_copy_hash_omap4(struct ahash_request *req, int out) in omap_sham_copy_hash_omap4() argument 303 struct omap_sham_reqctx *ctx = ahash_request_ctx(req); in omap_sham_copy_hash_omap4() 308 struct crypto_ahash *tfm = crypto_ahash_reqtfm(dd->req); in omap_sham_copy_hash_omap4() 323 omap_sham_copy_hash_omap2(req, ou in omap_sham_copy_hash_omap4() 326 omap_sham_copy_ready_hash(struct ahash_request *req) omap_sham_copy_ready_hash() argument 866 struct ahash_request *req = container_of(areq, struct ahash_request, omap_sham_prepare_request() local 961 omap_sham_init(struct ahash_request *req) omap_sham_init() argument 1030 struct ahash_request *req = dd->req; omap_sham_update_req() local 1056 struct ahash_request *req = dd->req; omap_sham_final_req() local 1084 struct ahash_request *req = container_of(areq, struct ahash_request, omap_sham_hash_one_req() local 1115 omap_sham_finish_hmac(struct ahash_request *req) omap_sham_finish_hmac() argument 1130 omap_sham_finish(struct ahash_request *req) omap_sham_finish() argument 1148 omap_sham_finish_req(struct ahash_request *req, int err) omap_sham_finish_req() argument 1194 omap_sham_handle_queue(struct omap_sham_dev *dd, struct ahash_request *req) omap_sham_handle_queue() argument 1200 omap_sham_enqueue(struct ahash_request *req, unsigned int op) omap_sham_enqueue() argument 1210 omap_sham_update(struct ahash_request *req) omap_sham_update() argument 1231 omap_sham_final_shash(struct ahash_request *req) omap_sham_final_shash() argument 1250 omap_sham_final(struct ahash_request *req) omap_sham_final() argument 1275 omap_sham_finup(struct ahash_request *req) omap_sham_finup() argument 1294 omap_sham_digest(struct ahash_request *req) omap_sham_digest() argument 1422 omap_sham_export(struct ahash_request *req, void *out) omap_sham_export() argument 1431 omap_sham_import(struct ahash_request *req, const void *in) omap_sham_import() argument [all...] |
/kernel/linux/linux-6.6/drivers/crypto/ |
H A D | omap-sham.c | 189 void (*copy_hash)(struct ahash_request *req, int out); 227 struct ahash_request *req; member 244 static int omap_sham_enqueue(struct ahash_request *req, unsigned int op); 245 static void omap_sham_finish_req(struct ahash_request *req, int err); 281 static void omap_sham_copy_hash_omap2(struct ahash_request *req, int out) in omap_sham_copy_hash_omap2() argument 283 struct omap_sham_reqctx *ctx = ahash_request_ctx(req); in omap_sham_copy_hash_omap2() 296 static void omap_sham_copy_hash_omap4(struct ahash_request *req, int out) in omap_sham_copy_hash_omap4() argument 298 struct omap_sham_reqctx *ctx = ahash_request_ctx(req); in omap_sham_copy_hash_omap4() 303 struct crypto_ahash *tfm = crypto_ahash_reqtfm(dd->req); in omap_sham_copy_hash_omap4() 318 omap_sham_copy_hash_omap2(req, ou in omap_sham_copy_hash_omap4() 321 omap_sham_copy_ready_hash(struct ahash_request *req) omap_sham_copy_ready_hash() argument 843 struct ahash_request *req = container_of(areq, struct ahash_request, omap_sham_prepare_request() local 938 omap_sham_init(struct ahash_request *req) omap_sham_init() argument 1007 struct ahash_request *req = dd->req; omap_sham_update_req() local 1033 struct ahash_request *req = dd->req; omap_sham_final_req() local 1061 struct ahash_request *req = container_of(areq, struct ahash_request, omap_sham_hash_one_req() local 1099 omap_sham_finish_hmac(struct ahash_request *req) omap_sham_finish_hmac() argument 1114 omap_sham_finish(struct ahash_request *req) omap_sham_finish() argument 1132 omap_sham_finish_req(struct ahash_request *req, int err) omap_sham_finish_req() argument 1178 omap_sham_handle_queue(struct omap_sham_dev *dd, struct ahash_request *req) omap_sham_handle_queue() argument 1184 omap_sham_enqueue(struct ahash_request *req, unsigned int op) omap_sham_enqueue() argument 1194 omap_sham_update(struct ahash_request *req) omap_sham_update() argument 1215 omap_sham_final_shash(struct ahash_request *req) omap_sham_final_shash() argument 1234 omap_sham_final(struct ahash_request *req) omap_sham_final() argument 1259 omap_sham_finup(struct ahash_request *req) omap_sham_finup() argument 1278 omap_sham_digest(struct ahash_request *req) omap_sham_digest() argument 1402 omap_sham_export(struct ahash_request *req, void *out) omap_sham_export() argument 1411 omap_sham_import(struct ahash_request *req, const void *in) omap_sham_import() argument [all...] |
/third_party/libuv/docs/code/tcp-echo-server/ |
H A D | main.c | 13 uv_write_t req; member 17 void free_write_req(uv_write_t *req) { in free_write_req() argument 18 write_req_t *wr = (write_req_t*) req; in free_write_req() 32 void echo_write(uv_write_t *req, int status) { in echo_write() argument 36 free_write_req(req); in echo_write() 41 write_req_t *req = (write_req_t*) malloc(sizeof(write_req_t)); in echo_read() local 42 req->buf = uv_buf_init(buf->base, nread); in echo_read() 43 uv_write((uv_write_t*) req, client, &req->buf, 1, echo_write); in echo_read()
|
/kernel/linux/linux-5.10/drivers/usb/gadget/udc/aspeed-vhub/ |
H A D | core.c | 35 void ast_vhub_done(struct ast_vhub_ep *ep, struct ast_vhub_req *req, in ast_vhub_done() argument 38 bool internal = req->internal; in ast_vhub_done() 41 EPVDBG(ep, "completing request @%p, status %d\n", req, status); in ast_vhub_done() 43 list_del_init(&req->queue); in ast_vhub_done() 45 if (req->req.status == -EINPROGRESS) in ast_vhub_done() 46 req->req.status = status; in ast_vhub_done() 48 if (req->req in ast_vhub_done() 68 struct ast_vhub_req *req; ast_vhub_nuke() local 84 struct ast_vhub_req *req; ast_vhub_alloc_request() local 94 struct ast_vhub_req *req = to_ast_req(u_req); ast_vhub_free_request() local [all...] |