Home
last modified time | relevance | path

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

123

/components/net/lwip/lwip-2.1.2/src/apps/http/
A Dhttp_client.c172 req = NULL; in httpc_free_state()
291 (req->hdr_content_len != req->rx_content_len)) { in httpc_tcp_recv()
298 return httpc_close(req, result, req->rx_status, ERR_OK); in httpc_tcp_recv()
323 …err = req->conn_settings->headers_done_fn(req, req->callback_arg, req->rx_hdrs, total_header_len, … in httpc_tcp_recv()
342 return req->recv_fn(req->callback_arg, pcb, p, r); in httpc_tcp_recv()
402 r = altcp_write(req->pcb, req->request->payload, req->request->len - 1, TCP_WRITE_FLAG_COPY); in httpc_tcp_connected()
427 err = altcp_connect(req->pcb, &req->remote_addr, req->remote_port, httpc_tcp_connected); in httpc_get_internal_addr()
479 err = httpc_get_internal_addr(req, &req->remote_addr); in httpc_get_internal_dns()
555 req->server_name = (char*)(req + 1); in httpc_init_connection_common()
559 req->uri = req->server_name + server_name_len + 1; in httpc_init_connection_common()
[all …]
A Dhttpd.c251 struct pbuf *req; member
503 if (hs->req) { in http_state_eof()
504 pbuf_free(hs->req); in http_state_eof()
505 hs->req = NULL; in http_state_eof()
1983 if (hs->req == NULL) {
1985 hs->req = p;
1988 pbuf_cat(hs->req, p);
1994 if (hs->req->next != NULL) {
2108 clen = pbuf_clen(hs->req);
2570 pbuf_free(hs->req);
[all …]
/components/drivers/virtio/
A Dvirtio_gpu.c207 rt_memset(&req, 0, sizeof(req)); in virtio_gpu_unref_resource()
230 } req; in virtio_gpu_attach_backing_resource() local
232 rt_memset(&req, 0, sizeof(req)); in virtio_gpu_attach_backing_resource()
235 req.req.resource_id = resource_id; in virtio_gpu_attach_backing_resource()
236 req.req.nr_entries = 1; in virtio_gpu_attach_backing_resource()
257 rt_memset(&req, 0, sizeof(req)); in virtio_gpu_set_scanout()
283 rt_memset(&req, 0, sizeof(req)); in virtio_gpu_flush_resource()
308 rt_memset(&req, 0, sizeof(req)); in virtio_gpu_transfer_to_host_2d()
346 rt_memset(&req, 0, sizeof(req)); in virtio_gpu_update_cursor()
364 rt_memset(&req, 0, sizeof(req)); in virtio_gpu_cursor_move()
[all …]
A Dvirtio_blk.c47 virtio_blk_dev->info[idx[0]].req.type = flags; in virtio_blk_rw()
48 virtio_blk_dev->info[idx[0]].req.ioprio = 0; in virtio_blk_rw()
49 virtio_blk_dev->info[idx[0]].req.sector = pos * (virtio_blk_dev->config->blk_size / 512); in virtio_blk_rw()
54 …VIRTIO_VA2PA(&virtio_blk_dev->info[idx[0]].req), sizeof(struct virtio_blk_req), VIRTQ_DESC_F_NEXT,… in virtio_blk_rw()
/components/drivers/sdio/sdhci/
A Dfit-mmc.c20 rt_uint32_t flags = req->cmd->flags; in rt_plat_request()
52 if (req->data) in rt_plat_request()
56 void *dma_buffer = rt_malloc(req->data->blks * req->data->blksize); in rt_plat_request()
61 rt_memcpy(dma_buffer, req->data->buf, req->data->blks * req->data->blksize); in rt_plat_request()
70 req->cmd->flags |= flags; in rt_plat_request()
71 mmc->ops->request(mmc, req); in rt_plat_request()
77 rt_memcpy(req_buf, dma_buffer, req->data->blksize * req->data->blks); in rt_plat_request()
88 req->cmd->flags |= flags; in rt_plat_request()
89 mmc->ops->request(mmc, req); in rt_plat_request()
94 req->cmd->flags |= flags; in rt_plat_request()
[all …]
/components/drivers/sdio/
A Ddev_mmcsd_core.c66 req->cmd->mrq = req; in mmcsd_send_request()
67 if (req->data) in mmcsd_send_request()
69 req->cmd->data = req->data; in mmcsd_send_request()
71 req->data->mrq = req; in mmcsd_send_request()
74 req->data->stop = req->stop; in mmcsd_send_request()
76 req->stop->mrq = req; in mmcsd_send_request()
84 while (req->cmd->err && (req->cmd->retries > 0)); in mmcsd_send_request()
99 req.cmd = cmd; in mmcsd_send_cmd()
215 req.cmd = &cmd; in mmcsd_get_cid()
216 req.data = &data; in mmcsd_get_cid()
[all …]
A Ddev_sd.c156 struct rt_mmcsd_req req; in mmcsd_switch() local
191 req.cmd = &cmd; in mmcsd_switch()
192 req.data = &data; in mmcsd_switch()
239 req.cmd = &cmd; in mmcsd_switch()
240 req.data = &data; in mmcsd_switch()
353 struct rt_mmcsd_req req; in mmcsd_send_app_cmd() local
383 req.cmd = cmd; in mmcsd_send_app_cmd()
553 req.cmd = &cmd; in mmcsd_get_scr()
554 req.data = &data; in mmcsd_get_scr()
595 req.cmd = &cmd; in mmcsd_read_sd_status()
[all …]
A Ddev_block.c109 struct rt_mmcsd_req req; in mmcsd_num_wr_blocks() local
152 rt_memset(&req, 0, sizeof(struct rt_mmcsd_req)); in mmcsd_num_wr_blocks()
154 req.cmd = &cmd; in mmcsd_num_wr_blocks()
155 req.data = &data; in mmcsd_num_wr_blocks()
157 mmcsd_send_request(card->host, &req); in mmcsd_num_wr_blocks()
173 struct rt_mmcsd_req req; in rt_mmcsd_req_blk() local
182 req.cmd = &cmd; in rt_mmcsd_req_blk()
183 req.data = &data; in rt_mmcsd_req_blk()
199 req.stop = &stop; in rt_mmcsd_req_blk()
209 req.stop = RT_NULL; in rt_mmcsd_req_blk()
[all …]
/components/libc/posix/io/poll/
A Dpoll.c36 rt_pollreq_t req; /**< Poll request. */ member
93 static void _poll_add(rt_wqueue_t *wq, rt_pollreq_t *req) in _poll_add() argument
102 pt = rt_container_of(req, struct rt_poll_table, req); in _poll_add()
104 node->wqn.key = req->_key; in _poll_add()
124 pt->req._proc = _poll_add; in poll_table_init()
225 mask = f->vnode->fops->poll(f, req); in do_pollfd()
268 pt->req._proc = RT_NULL; in poll_do()
280 ret = do_pollfd(pf, &pt->req); in poll_do()
284 pt->req._proc = RT_NULL; in poll_do()
290 pt->req._proc = RT_NULL; in poll_do()
[all …]
/components/drivers/include/ipc/
A Dpoll.h30 rt_inline void rt_poll_add(rt_wqueue_t *wq, rt_pollreq_t *req) in rt_poll_add() argument
32 if (req && req->_proc && wq) in rt_poll_add()
34 req->_proc(wq, req); in rt_poll_add()
/components/drivers/smp_call/
A Dsmp_call.c30 static void _call_req_take(struct rt_smp_call_req *req) in _call_req_take() argument
40 static void _call_req_release(struct rt_smp_call_req *req) in _call_req_release() argument
45 void rt_smp_request_wait_freed(struct rt_smp_call_req *req) in rt_smp_request_wait_freed() argument
51 usage_tracer = rt_atomic_load(&req->event.typed.usage_tracer); in rt_smp_request_wait_freed()
86 static void _do_request(struct rt_smp_call_req *req) in _do_request() argument
90 event = &req->event; in _do_request()
94 _call_req_release(req); in _do_request()
100 switch (req->event.event_id) in _smp_call_handler()
105 _do_glob_request(req, &req_local); in _smp_call_handler()
112 _do_glob_request(req, &req_local); in _smp_call_handler()
[all …]
/components/libc/posix/io/epoll/
A Depoll.c46 rt_pollreq_t req; /**< Poll request structure */ member
63 rt_pollreq_t req; /**< Poll request structure */ member
169 ep->req._key = req->_key; in epoll_poll()
172 rt_poll_add(&ep->epoll_read, req); in epoll_poll()
246 fdlist = rt_container_of(req, struct rt_fd_list, req); in epoll_wqueue_add_callback()
249 fdlist->wqn.key = req->_key; in epoll_wqueue_add_callback()
271 fdlist->req._key = fdlist->revents; in epoll_ctl_install()
273 mask = epoll_get_event(fdlist, &fdlist->req); in epoll_ctl_install()
305 ep->req._key = 0; in epoll_member_init()
462 fdlist->req._proc = epoll_wqueue_add_callback; in epoll_ctl_add()
[all …]
/components/vbus/
A Dvbus.c654 struct rt_vbus_request *req; member
712 rt_vbus_set_recv_wm(chnr, _sess[i].req->recv_wm.low, _sess[i].req->recv_wm.high); in _chn0_actor()
713 rt_vbus_set_post_wm(chnr, _sess[i].req->post_wm.low, _sess[i].req->post_wm.high); in _chn0_actor()
755 rt_vbus_set_recv_wm(chnr, _sess[i].req->recv_wm.low, _sess[i].req->recv_wm.high); in _chn0_actor()
756 rt_vbus_set_post_wm(chnr, _sess[i].req->post_wm.low, _sess[i].req->post_wm.high); in _chn0_actor()
915 _sess[i].req = req; in rt_vbus_request_chn()
917 if (req->is_server) in rt_vbus_request_chn()
940 rt_memcpy(pbuf+1, req->name, plen-1); in rt_vbus_request_chn()
969 _sess[i].req = RT_NULL; in rt_vbus_request_chn()
1151 _sess[i].req = RT_NULL; in rt_vbus_init()
[all …]
A Dvbus_chnx.c42 chnr = rt_vbus_request_chn(&vdev->req, RT_WAITING_FOREVER); in _open()
139 err = rt_vbus_post(vdev->chnr, vdev->req.prio, in _write()
145 err = rt_vbus_post(vdev->chnr, vdev->req.prio, in _write()
255 i < ARRAY_SIZE(_devx) && p->req.name; in rt_vbus_chnx_init()
265 rt_device_register(&_devx[i], p->req.name, RT_DEVICE_FLAG_RDWR); in rt_vbus_chnx_init()
A Dvbus.h68 int rt_vbus_request_chn(struct rt_vbus_request *req, int timeout);
125 struct rt_vbus_request req; member
/components/net/sal/dfs_net/
A Ddfs_net.c100 static int dfs_net_poll(struct dfs_file *file, struct rt_pollreq *req) in dfs_net_poll() argument
102 extern int sal_poll(struct dfs_file *file, struct rt_pollreq *req); in dfs_net_poll()
104 return sal_poll(file, req); in dfs_net_poll()
/components/net/sal/impl/
A Daf_inet_at.c28 static int at_poll(struct dfs_file *file, struct rt_pollreq *req) in at_poll() argument
45 rt_poll_add(&sock->wait_head, req); in at_poll()
/components/drivers/usb/cherryusb/class/dfu/
A Dusbd_dfu.c107 struct usb_setup_packet *req = setup; in dfu_request_upload() local
111 if (req->wLength > 0U) { in dfu_request_upload()
114 g_usbd_dfu.wblock_num = req->wValue; in dfu_request_upload()
115 g_usbd_dfu.wlength = MIN(req->wLength, USBD_DFU_XFER_SIZE); in dfu_request_upload()
187 struct usb_setup_packet *req = setup; in dfu_request_dnload() local
188 if (req->wLength > 0U) { in dfu_request_dnload()
191 g_usbd_dfu.wblock_num = req->wValue; in dfu_request_dnload()
192 g_usbd_dfu.wlength = MIN(req->wLength, USBD_DFU_XFER_SIZE); in dfu_request_dnload()
/components/net/lwip/lwip-2.1.2/src/apps/smtp/
A Dsmtp.c697 struct smtp_send_request *req = (struct smtp_send_request*)arg; in smtp_send_mail_int() local
703 if (req->static_data) { in smtp_send_mail_int()
704 err = smtp_send_mail_static(req->from, req->to, req->subject, req->body, in smtp_send_mail_int()
705 req->callback_fn, req->callback_arg); in smtp_send_mail_int()
707 err = smtp_send_mail(req->from, req->to, req->subject, req->body, in smtp_send_mail_int()
708 req->callback_fn, req->callback_arg); in smtp_send_mail_int()
710 if ((err != ERR_OK) && (req->callback_fn != NULL)) { in smtp_send_mail_int()
711 req->callback_fn(req->callback_arg, SMTP_RESULT_ERR_UNKNOWN, 0, err); in smtp_send_mail_int()
/components/libc/posix/io/eventfd/
A Deventfd.c44 static int eventfd_poll(struct dfs_file *file, struct rt_pollreq *req);
49 static int eventfd_poll(struct dfs_file *file, struct rt_pollreq *req);
86 static int eventfd_poll(struct dfs_file *file, struct rt_pollreq *req) in eventfd_poll() argument
94 rt_poll_add(&ctx->reader_queue, req); in eventfd_poll()
/components/net/lwip/lwip-2.0.3/src/apps/sntp/
A Dsntp.c240 sntp_initialize_request(struct sntp_msg *req) in sntp_initialize_request() argument
242 memset(req, 0, SNTP_MSG_LEN); in sntp_initialize_request()
243 req->li_vn_mode = SNTP_LI_NO_WARNING | SNTP_VERSION | SNTP_MODE_CLIENT; in sntp_initialize_request()
251 req->transmit_timestamp[0] = sntp_last_timestamp_sent[0]; in sntp_initialize_request()
254 req->transmit_timestamp[1] = sntp_last_timestamp_sent[1]; in sntp_initialize_request()
/components/libc/posix/io/signalfd/
A Dsignalfd.c39 static int signalfd_poll(struct dfs_file *file, struct rt_pollreq *req);
83 static int signalfd_poll(struct dfs_file *file, struct rt_pollreq *req) in signalfd_poll() argument
92 rt_poll_add(&sfd->signalfd_queue, req); in signalfd_poll()
/components/net/lwip/lwip-2.1.2/src/apps/sntp/
A Dsntp.c336 sntp_initialize_request(struct sntp_msg *req) in sntp_initialize_request() argument
338 memset(req, 0, SNTP_MSG_LEN); in sntp_initialize_request()
339 req->li_vn_mode = SNTP_LI_NO_WARNING | SNTP_VERSION | SNTP_MODE_CLIENT; in sntp_initialize_request()
354 req->transmit_timestamp[0] = sec; in sntp_initialize_request()
355 req->transmit_timestamp[1] = frac; in sntp_initialize_request()
/components/net/lwip/lwip-2.0.3/src/apps/httpd/
A Dhttpd.c240 struct pbuf *req; member
489 if (hs->req) { in http_state_eof()
490 pbuf_free(hs->req); in http_state_eof()
491 hs->req = NULL; in http_state_eof()
1930 if (hs->req == NULL) {
1932 hs->req = p;
1935 pbuf_cat(hs->req, p);
1941 if (hs->req->next != NULL) {
2055 clen = pbuf_clen(hs->req);
2485 pbuf_free(hs->req);
[all …]
/components/net/lwip/lwip-2.0.3/src/core/
A Ddns.c1338 struct dns_req_entry* req; in dns_enqueue() local
1404 req = NULL; in dns_enqueue()
1407 req = &dns_requests[r]; in dns_enqueue()
1411 if (req == NULL) { in dns_enqueue()
1416 req->dns_table_idx = i; in dns_enqueue()
1419 req = &dns_requests[i]; in dns_enqueue()
1429 LWIP_DNS_SET_ADDRTYPE(req->reqaddrtype, dns_addrtype); in dns_enqueue()
1430 req->found = found; in dns_enqueue()
1431 req->arg = callback_arg; in dns_enqueue()
1442 req->found = NULL; in dns_enqueue()

Completed in 91 milliseconds

123