Home
last modified time | relevance | path

Searched refs:req (Results 1 – 25 of 65) sorted by relevance

123

/subsys/fs/fuse_client/
A Dfuse_client.c72 req->read_in.fh = fh; in fuse_create_read_req()
103 &req->in_header, sizeof(req->in_header) + sizeof(req->create_in) + fname_len, in fuse_create_create_req()
116 &req->in_header, sizeof(req->in_header) + sizeof(req->write_in) + size, FUSE_WRITE, in fuse_create_write_req()
131 &req->in_header, sizeof(req->in_header) + sizeof(req->lseek_in), FUSE_LSEEK, inode in fuse_create_lseek_req()
149 &req->in_header, sizeof(req->in_header) + sizeof(req->fsync_in), FUSE_FSYNC, in fuse_create_fsync_req()
160 &req->in_header, sizeof(req->in_header) + sizeof(req->mkdir_in) + dirname_len, in fuse_create_mkdir_req()
172 &req->in_header, sizeof(req->in_header) + fname_len, in fuse_create_unlink_req()
182 &req->in_header, in fuse_create_rename_req()
183 sizeof(req->in_header) + sizeof(req->rename_in) + old_len + new_len, in fuse_create_rename_req()
326 req->open_out.fh, in fuse_dump_open_req_out()
[all …]
A Dfuse_client.h130 void fuse_create_init_req(struct fuse_init_req *req);
131 void fuse_create_open_req(struct fuse_open_req *req, uint64_t inode, uint32_t flags,
139 void fuse_create_destroy_req(struct fuse_destroy_req *req);
141 struct fuse_create_req *req, uint64_t inode, uint32_t fname_len, uint32_t flags,
147 void fuse_create_setattr_req(struct fuse_setattr_req *req, uint64_t inode);
150 struct fuse_mkdir_req *req, uint64_t inode, uint32_t dirname_len, uint32_t mode);
152 struct fuse_unlink_req *req, uint32_t fname_len, enum fuse_object_type type);
154 struct fuse_rename_req *req, uint64_t old_dir_nodeid, uint32_t old_len,
159 void fuse_dump_init_req_out(struct fuse_init_req *req);
161 void fuse_dump_open_req_out(struct fuse_open_req *req);
[all …]
/subsys/fs/virtiofs/
A Dvirtiofs.c146 { .addr = &req.in_header, .len = sizeof(req.in_header) + sizeof(req.init_in) }, in virtiofs_init()
147 { .addr = &req.out_header, .len = sizeof(req.out_header) + sizeof(req.init_out) } in virtiofs_init()
302 { .addr = &req.out_header, .len = sizeof(req.out_header) + sizeof(req.open_out) } in virtiofs_open()
423 { .addr = &req.in_header, .len = sizeof(req.in_header) + sizeof(req.create_in) }, in virtiofs_create()
425 { .addr = &req.out_header, .len = sizeof(req.out_header) + sizeof(req.create_out) } in virtiofs_create()
463 { .addr = &req.in_header, .len = sizeof(req.in_header) + sizeof(req.write_in) }, in virtiofs_write()
465 { .addr = &req.out_header, .len = sizeof(req.out_header) + sizeof(req.write_out) } in virtiofs_write()
502 { .addr = &req.out_header, .len = sizeof(req.out_header) + sizeof(req.lseek_out) } in virtiofs_lseek()
599 { .addr = &req.in_header, .len = sizeof(req.in_header) + sizeof(req.mkdir_in) }, in virtiofs_mkdir()
664 { .addr = &req.in_header, .len = sizeof(req.in_header) + sizeof(req.rename_in) }, in virtiofs_rename()
[all …]
/subsys/net/lib/http/
A Dhttp_client.c463 (void)req->internal.response.cb(&req->internal.response, in http_report_complete()
644 if (sock < 0 || req == NULL || req->response == NULL || in http_client_req()
645 req->recv_buf == NULL || req->recv_buf_len == 0) { in http_client_req()
651 req->internal.response.http_cb = req->http_cb; in http_client_req()
652 req->internal.response.cb = req->response; in http_client_req()
653 req->internal.response.recv_buf = req->recv_buf; in http_client_req()
654 req->internal.response.recv_buf_len = req->recv_buf_len; in http_client_req()
662 " ", req->url, " ", req->protocol, in http_client_req()
701 ret = req->optional_headers_cb(sock, req, user_data); in http_client_req()
743 if (req->payload || req->payload_cb) { in http_client_req()
[all …]
/subsys/bluetooth/host/classic/
A Davdtp.c144 req->func(req, NULL); in bt_avdtp_media_l2cap_connected()
174 req->func(req, NULL); in bt_avdtp_media_l2cap_disconnected()
328 req->func(req, buf); in avdtp_discover_rsp()
420 req->func(req, buf); in avdtp_get_capabilities_rsp()
538 req->func(req, NULL); in avdtp_process_configuration_rsp()
639 req->func(req, NULL); in avdtp_open_rsp()
732 req->func(req, NULL); in avdtp_start_rsp()
810 req->func(req, NULL); in avdtp_close_rsp()
887 req->func(req, NULL); in avdtp_suspend_rsp()
977 req->func(req, NULL); in avdtp_abort_rsp()
[all …]
A Da2dp.c521 a2dp_cb->config_rsp(stream, req->status); in bt_a2dp_set_config_cb()
544 LOG_DBG("GET CAPABILITIES result:%d", req->status); in bt_a2dp_get_capabilities_cb()
545 if (req->status) { in bt_a2dp_get_capabilities_cb()
637 LOG_DBG("DISCOVER result:%d", req->status); in bt_a2dp_discover_cb()
644 if (!(req->status)) { in bt_a2dp_discover_cb()
731 a2dp->set_config_param.req.func = cb; in bt_a2dp_stream_config_set_param()
773 struct bt_a2dp *a2dp = CTRL_PARAM(CTRL_REQ(req)); in bt_a2dp_ctrl_cb()
788 LOG_DBG("ctrl result:%d", req->status); in bt_a2dp_ctrl_cb()
791 rsp_cb(stream, req->status); in bt_a2dp_ctrl_cb()
794 if ((!req->status) && (done_cb != NULL)) { in bt_a2dp_ctrl_cb()
[all …]
A Davdtp_internal.h114 typedef int (*bt_avdtp_func_t)(struct bt_avdtp_req *req, struct net_buf *buf);
150 struct bt_avdtp_req req; member
154 struct bt_avdtp_req req; member
159 struct bt_avdtp_req req; member
171 struct bt_avdtp_req req; member
211 struct bt_avdtp_req *req; member
/subsys/rtio/
A Drtio_workq.c23 struct rtio_work_req *req; in rtio_work_req_alloc() local
31 return req; in rtio_work_req_alloc()
34 void rtio_work_req_submit(struct rtio_work_req *req, in rtio_work_req_submit() argument
38 if (!req) { in rtio_work_req_submit()
43 k_mem_slab_free(&rtio_work_items_slab, req); in rtio_work_req_submit()
47 req->iodev_sqe = iodev_sqe; in rtio_work_req_submit()
48 req->handler = handler; in rtio_work_req_submit()
54 k_queue_append(&rtio_workq, req); in rtio_work_req_submit()
71 if (req != NULL) { in rtio_workq_thread_fn()
72 req->handler(req->iodev_sqe); in rtio_workq_thread_fn()
[all …]
/subsys/pm/policy/
A Dpolicy_latency.c29 struct pm_policy_latency_request *req; in update_max_latency() local
31 SYS_SLIST_FOR_EACH_CONTAINER(&latency_reqs, req, node) { in update_max_latency()
33 ((int32_t)req->value_us < new_max_latency_us)) { in update_max_latency()
34 new_max_latency_us = (int32_t)req->value_us; in update_max_latency()
58 req->value_us = value_us; in pm_policy_latency_request_add()
62 sys_slist_append(&latency_reqs, &req->node); in pm_policy_latency_request_add()
73 req->value_us = value_us; in pm_policy_latency_request_update()
83 (void)sys_slist_find_and_remove(&latency_reqs, &req->node); in pm_policy_latency_request_remove()
94 req->cb = cb; in pm_policy_latency_changed_subscribe()
95 sys_slist_append(&latency_subs, &req->node); in pm_policy_latency_changed_subscribe()
[all …]
/subsys/bluetooth/controller/ll_sw/
A Dull_peripheral_iso.c198 cig->cig_id = req->cig_id; in ull_peripheral_iso_acquire()
249 cis->cis_id = req->cis_id; in ull_peripheral_iso_acquire()
256 req->c_max_sdu_packed[0]; in ull_peripheral_iso_acquire()
258 req->p_max_sdu[0]; in ull_peripheral_iso_acquire()
269 cis->lll.nse = req->nse; in ull_peripheral_iso_acquire()
271 cis->lll.rx.phy = req->c_phy; in ull_peripheral_iso_acquire()
273 cis->lll.rx.bn = req->c_bn; in ull_peripheral_iso_acquire()
274 cis->lll.rx.ft = req->c_ft; in ull_peripheral_iso_acquire()
277 cis->lll.tx.phy = req->p_phy; in ull_peripheral_iso_acquire()
279 cis->lll.tx.bn = req->p_bn; in ull_peripheral_iso_acquire()
[all …]
/subsys/mgmt/mcumgr/grp/img_mgmt/src/
A Dzephyr_img_mgmt.c565 if (req->off == SIZE_MAX) { in img_mgmt_upload_inspect()
572 if (req->off == 0) { in img_mgmt_upload_inspect()
599 if (req->size == SIZE_MAX) { in img_mgmt_upload_inspect()
606 action->size = req->size; in img_mgmt_upload_inspect()
629 req->data_sha.len)) { in img_mgmt_upload_inspect()
651 if (req->size > fa->fa_size) { in img_mgmt_upload_inspect()
719 req->size > max_image_size) { in img_mgmt_upload_inspect()
724 req->size, max_image_size); in img_mgmt_upload_inspect()
744 if (req->upgrade) { in img_mgmt_upload_inspect()
790 if ((req->off + req->img_data.len) > action->size) { in img_mgmt_upload_inspect()
[all …]
A Dimg_mgmt.c728 struct img_mgmt_upload_req req = { in img_mgmt_upload() local
775 .req = &req, in img_mgmt_upload()
791 rc = img_mgmt_upload_inspect(&req, &action); in img_mgmt_upload()
839 if (req.off == 0) { in img_mgmt_upload()
864 g_img_mgmt_state.data_sha_len = req.data_sha.len; in img_mgmt_upload()
865 memcpy(g_img_mgmt_state.data_sha, req.data_sha.value, req.data_sha.len); in img_mgmt_upload()
866 memset(&g_img_mgmt_state.data_sha[req.data_sha.len], 0, in img_mgmt_upload()
867 IMG_MGMT_DATA_SHA_LEN - req.data_sha.len); in img_mgmt_upload()
900 rc = img_mgmt_erase_image_data(0, req.size); in img_mgmt_upload()
916 if (req.img_data.len != 0) { in img_mgmt_upload()
[all …]
/subsys/bluetooth/mesh/
A Ddfu_cli.c42 enum req { enum
144 cli->req.addr = addr; in req_setup()
145 cli->req.params = params; in req_setup()
146 cli->req.type = type; in req_setup()
253 cli->req.img_cb = NULL; in blob_end()
715 if (cli->req.type == REQ_STATUS && cli->req.addr == ctx->addr) { in handle_status()
837 (cli->req.type == REQ_IMG && cli->req.addr != ctx->addr)) { in handle_info_status()
855 while (buf->len && cli->req.img_cb && idx < cli->req.img_cnt) { in handle_info_status()
937 if (cli->req.type != REQ_METADATA || ctx->addr != cli->req.addr || in handle_metadata_status()
995 cli->req.img_cnt = 0; in dfu_cli_reset()
[all …]
/subsys/bluetooth/host/
A Datt.c552 chan->req = req; in bt_att_chan_req_send()
1299 req = net_buf_pull_mem(buf, sizeof(*req)); in att_find_type_req()
1558 req = net_buf_pull_mem(buf, sizeof(*req)); in att_read_type_req()
2007 req = net_buf_pull_mem(buf, sizeof(*req)); in att_read_group_req()
2137 data.req = req; in att_write_rsp()
2304 req = net_buf_pull_mem(buf, sizeof(*req)); in att_prepare_write_req()
3257 struct bt_att_req *req = att_chan->req; in att_req_retry() local
3272 if (req->encode(buf, req->len, req->user_data)) { in att_req_retry()
3306 if (att_chan->req && att_chan->req->retrying) { in bt_att_encrypt_change()
3966 memset(req, 0, sizeof(*req)); in bt_att_req_alloc()
[all …]
A Diso.c1700 req = net_buf_add(buf, sizeof(*req)); in hci_le_remove_cig()
1702 memset(req, 0, sizeof(*req)); in hci_le_remove_cig()
1723 req = net_buf_add(buf, sizeof(*req)); in hci_le_set_cig_params()
1725 memset(req, 0, sizeof(*req)); in hci_le_set_cig_params()
1811 req = net_buf_add(buf, sizeof(*req)); in hci_le_set_cig_test_params()
1813 memset(req, 0, sizeof(*req)); in hci_le_set_cig_test_params()
2459 req = net_buf_add(buf, sizeof(*req)); in hci_le_create_cis()
2461 memset(req, 0, sizeof(*req)); in hci_le_create_cis()
2898 req->big_handle, req->adv_handle, req->num_bis, param->interval, in hci_le_create_big_test()
2899 param->iso_interval, req->nse, req->max_sdu, req->max_pdu, req->phy, req->packing, in hci_le_create_big_test()
[all …]
A Dsmp.c1319 req->io_capability, req->oob_flag, req->auth_req, in smp_br_pairing_req()
1320 req->max_key_size, req->init_key_dist, req->resp_key_dist); in smp_br_pairing_req()
2198 req = net_buf_add(buf, sizeof(*req)); in smp_send_pairing_confirm()
2547 req = net_buf_add(buf, sizeof(*req)); in legacy_send_pairing_confirm()
3157 req->io_capability, req->oob_flag, req->auth_req, in smp_pairing_req()
3158 req->max_key_size, req->init_key_dist, req->resp_key_dist); in smp_pairing_req()
3406 req->io_capability, req->oob_flag, req->auth_req, in smp_send_pairing_req()
3407 req->max_key_size, req->init_key_dist, req->resp_key_dist); in smp_send_pairing_req()
3596 req = net_buf_add(buf, sizeof(*req)); in sc_smp_send_dhkey_check()
3597 memcpy(req->e, e, sizeof(req->e)); in sc_smp_send_dhkey_check()
[all …]
A Dl2cap.c547 req = net_buf_add(buf, sizeof(*req)); in l2cap_le_conn_req()
577 sizeof(*req) + in l2cap_ecred_conn_req()
584 req = net_buf_add(buf, sizeof(*req)); in l2cap_ecred_conn_req()
1595 req = net_buf_pull_mem(buf, sizeof(*req)); in le_ecred_conn_req()
1719 req = net_buf_pull_mem(buf, sizeof(*req)); in le_ecred_reconf_req()
1882 data.scid = req->scid; in le_disconn_req()
1883 data.dcid = req->dcid; in le_disconn_req()
2880 req = net_buf_add(buf, sizeof(*req)); in bt_l2cap_update_conn_param()
3126 req = net_buf_add(buf, sizeof(*req)); in bt_l2cap_ecred_chan_reconfigure()
3217 req = net_buf_add(buf, sizeof(*req)); in bt_l2cap_ecred_chan_reconfigure_explicit()
[all …]
A Dgatt.c3788 req = net_buf_add(buf, sizeof(*req)); in gatt_exchange_mtu_encode()
3916 req = net_buf_add(buf, sizeof(*req)); in gatt_find_type_encode()
4023 req = net_buf_add(buf, sizeof(*req)); in read_included_uuid_encode()
4376 req = net_buf_add(buf, sizeof(*req)); in gatt_read_type_encode()
4526 req = net_buf_add(buf, sizeof(*req)); in gatt_read_group_encode()
4679 req = net_buf_add(buf, sizeof(*req)); in gatt_find_info_encode()
4864 req = net_buf_add(buf, sizeof(*req)); in gatt_read_blob_encode()
4888 req = net_buf_add(buf, sizeof(*req)); in gatt_read_uuid_encode()
5043 req = net_buf_add(buf, sizeof(*req)); in gatt_read_encode()
5146 req = net_buf_add(buf, sizeof(*req)); in gatt_exec_encode()
[all …]
/subsys/mgmt/mcumgr/smp/src/
A Dsmp.c348 rsp = req; in smp_on_err()
349 req = NULL; in smp_on_err()
363 smp_free_buf(req, streamer->smpt); in smp_on_err()
391 struct net_buf *req = vreq; in smp_process_request_packet() local
405 while (req->len > 0) { in smp_process_request_packet()
410 rc = smp_read_hdr(req, &req_hdr); in smp_process_request_packet()
418 net_buf_pull(req, sizeof(struct smp_hdr)); in smp_process_request_packet()
420 if (req->len < req_hdr.nh_len) { in smp_process_request_packet()
426 rsp = smp_alloc_rsp(req, streamer->smpt); in smp_process_request_packet()
464 net_buf_pull(req, req_hdr.nh_len); in smp_process_request_packet()
[all …]
/subsys/net/lib/coap/
A Dcoap_client.c88 struct coap_client_request *req, in coap_client_schedule_poll() argument
198 struct coap_client_request *req, in coap_client_init_request() argument
234 if (req->payload) { in coap_client_init_request()
236 COAP_OPTION_CONTENT_FORMAT, req->fmt); in coap_client_init_request()
257 for (i = 0; i < req->num_options; i++) { in coap_client_init_request()
267 req->options[i].value, req->options[i].len); in coap_client_init_request()
275 if (req->payload) { in coap_client_init_request()
281 (req->len > CONFIG_COAP_CLIENT_MESSAGE_SIZE)) { in coap_client_init_request()
286 req->len); in coap_client_init_request()
328 payload_len = req->len; in coap_client_init_request()
[all …]
/subsys/net/lib/latmon/
A Dlatmon.c461 if (len != sizeof(*req)) { in get_latmus_conf()
465 if (ntohl(req->period_usecs) == 0) { in get_latmus_conf()
470 if (ntohl(req->period_usecs) > MAX_SAMPLING_PERIOD_USEC) { in get_latmus_conf()
472 ntohl(req->period_usecs)); in get_latmus_conf()
476 if (ntohl(req->histogram_cells) > HISTOGRAM_CELLS_MAX) { in get_latmus_conf()
478 ntohl(req->histogram_cells), HISTOGRAM_CELLS_MAX); in get_latmus_conf()
482 conf->period = ntohl(req->period_usecs); in get_latmus_conf()
483 conf->cells = ntohl(req->histogram_cells); in get_latmus_conf()
517 struct latmon_net_request req; in handle_connection() local
528 len = zsock_recv(msg->latmus, &req, sizeof(req), 0); in handle_connection()
[all …]
/subsys/net/l2/ieee802154/
A Dieee802154_mgmt.c442 struct ieee802154_req_params *req; in ieee802154_associate() local
452 req = (struct ieee802154_req_params *)data; in ieee802154_associate()
460 params.dst.pan_id = req->pan_id; in ieee802154_associate()
469 if (req->len == IEEE802154_SHORT_ADDR_LENGTH) { in ieee802154_associate()
477 params.dst.short_addr = req->short_addr; in ieee802154_associate()
485 params.dst.len = req->len; in ieee802154_associate()
539 ctx->pan_id = req->pan_id; in ieee802154_associate()
547 if (req->len == IEEE802154_SHORT_ADDR_LENGTH) { in ieee802154_associate()
548 ctx->coord_short_addr = req->short_addr; in ieee802154_associate()
589 if (req->len == IEEE802154_SHORT_ADDR_LENGTH && in ieee802154_associate()
[all …]
/subsys/net/lib/lwm2m/
A Dlwm2m_obj_firmware_pull.c55 static struct requesting_object req = { variable
72 req.write_cb = lwm2m_firmware_get_write_cb(); in lwm2m_firmware_start_transfer()
75 error_code = lwm2m_pull_context_start_transfer(package_uri, req, K_NO_WAIT); in lwm2m_firmware_start_transfer()
A Dlwm2m_pull_context.c420 int lwm2m_pull_context_start_transfer(char *uri, struct requesting_object req, k_timeout_t timeout) in lwm2m_pull_context_start_transfer() argument
424 if (!req.write_cb || !req.result_cb) { in lwm2m_pull_context_start_transfer()
438 context.result_cb(req.obj_inst_id, -EALREADY); in lwm2m_pull_context_start_transfer()
443 context.obj_inst_id = req.obj_inst_id; in lwm2m_pull_context_start_transfer()
445 context.is_firmware_uri = req.is_firmware_uri; in lwm2m_pull_context_start_transfer()
446 context.result_cb = req.result_cb; in lwm2m_pull_context_start_transfer()
447 context.write_cb = req.write_cb; in lwm2m_pull_context_start_transfer()
/subsys/net/lib/websocket/
A Dwebsocket.c242 struct http_request req; in websocket_connect() local
310 memset(&req, 0, sizeof(req)); in websocket_connect()
312 req.method = HTTP_GET; in websocket_connect()
313 req.url = wreq->url; in websocket_connect()
314 req.host = wreq->host; in websocket_connect()
315 req.protocol = "HTTP/1.1"; in websocket_connect()
319 req.response = response_cb; in websocket_connect()
320 req.http_cb = &http_parser_settings; in websocket_connect()
321 req.recv_buf = wreq->tmp_buf; in websocket_connect()
322 req.recv_buf_len = wreq->tmp_buf_len; in websocket_connect()
[all …]

Completed in 134 milliseconds

123