Home
last modified time | relevance | path

Searched refs:queue (Results 1 – 25 of 36) sorted by relevance

12

/components/drivers/ipc/
A Ddataqueue.c68 if (queue->queue == RT_NULL) in rt_data_queue_init()
154 queue->queue[queue->put_index].data_ptr = data_ptr; in rt_data_queue_push()
155 queue->queue[queue->put_index].data_size = data_size; in rt_data_queue_push()
157 if (queue->put_index == queue->size) in rt_data_queue_push()
271 *data_ptr = queue->queue[queue->get_index].data_ptr; in rt_data_queue_pop()
272 *size = queue->queue[queue->get_index].data_size; in rt_data_queue_pop()
274 if (queue->get_index == queue->size) in rt_data_queue_pop()
346 *data_ptr = queue->queue[queue->get_index].data_ptr; in rt_data_queue_peek()
347 *size = queue->queue[queue->get_index].data_size; in rt_data_queue_peek()
417 rt_free(queue->queue); in rt_data_queue_deinit()
[all …]
A Dworkqueue.c54 struct rt_workqueue *queue; in _workqueue_thread_entry() local
61 RT_ASSERT(queue != RT_NULL); in _workqueue_thread_entry()
132 work->workqueue = queue; in _workqueue_submit_work()
222 if (queue != RT_NULL) in rt_workqueue_create()
244 return queue; in rt_workqueue_create()
256 RT_ASSERT(queue != RT_NULL); in rt_workqueue_destroy()
261 RT_KERNEL_FREE(queue); in rt_workqueue_destroy()
277 RT_ASSERT(queue != RT_NULL); in rt_workqueue_dowork()
299 RT_ASSERT(queue != RT_NULL); in rt_workqueue_submit_work()
319 RT_ASSERT(queue != RT_NULL); in rt_workqueue_urgent_work()
[all …]
A Dwaitqueue.c33 level = rt_spin_lock_irqsave(&(queue->spinlock)); in rt_wqueue_add()
34 node->wqueue = queue; in rt_wqueue_add()
80 void rt_wqueue_wakeup(rt_wqueue_t *queue, void *key) in rt_wqueue_wakeup() argument
89 queue_list = &(queue->waiting_list); in rt_wqueue_wakeup()
91 level = rt_spin_lock_irqsave(&(queue->spinlock)); in rt_wqueue_wakeup()
93 queue->flag = RT_WQ_FLAG_WAKEUP; in rt_wqueue_wakeup()
145 queue_list = &(queue->waiting_list); in rt_wqueue_wakeup_all()
149 queue->flag = RT_WQ_FLAG_WAKEUP; in rt_wqueue_wakeup_all()
219 __wait.wqueue = queue; in _rt_wqueue_wait()
227 if (queue->flag == RT_WQ_FLAG_WAKEUP) in _rt_wqueue_wait()
[all …]
A Dcondvar.c37 static int _waitq_inqueue(rt_wqueue_t *queue, struct rt_wqueue_node *node, in _waitq_inqueue() argument
44 if (queue->flag != RT_WQ_FLAG_WAKEUP) in _waitq_inqueue()
49 rt_wqueue_add(queue, node); in _waitq_inqueue()
/components/drivers/virtio/
A Dvirtio.c95 struct virtq *queue; in virtio_queue_init() local
138 queue->used_idx = 0; in virtio_queue_init()
153 struct virtq *queue; in virtio_queue_destroy() local
164 rt_free(queue->free); in virtio_queue_destroy()
170 queue->num = 0; in virtio_queue_destroy()
186 struct virtq *queue; in virtio_submit_chain() local
194 queue->avail->ring[queue->avail->idx % ring_size] = desc_index; in virtio_submit_chain()
198 queue->avail->idx++; in virtio_submit_chain()
205 struct virtq *queue; in virtio_alloc_desc() local
234 struct virtq *queue; in virtio_free_desc() local
[all …]
A Dvirtio_blk.c147 struct virtq *queue = &virtio_dev->queues[VIRTIO_BLK_QUEUE]; in virtio_blk_isr() local
157 while (queue->used_idx != queue->used->idx) in virtio_blk_isr()
160 id = queue->used->ring[queue->used_idx % queue->num].id; in virtio_blk_isr()
167 queue->used_idx++; in virtio_blk_isr()
A Dvirtio_console.h29 #define VIRTIO_CONSOLE_PORT_QUEUE_INDEX(id, queue) ((id) * 2 + (!!(id)) * 2 + (queue)) argument
/components/drivers/nvme/
A Dnvme.c145 queue->cmd = cmd; in nvme_submit_cmd()
146 queue->err = RT_EOK; in nvme_submit_cmd()
673 nvme->ops->complete_cmd(queue, queue->cmd); in nvme_queue_isr()
810 rt_dma_free(nvme->dev, sizeof(*queue->sq_cmds) * queue->depth, in nvme_free_queue()
811 queue->sq_cmds, queue->sq_cmds_phy, dma_flags); in nvme_free_queue()
816 rt_dma_free(nvme->dev, sizeof(*queue->cq_entry) * queue->depth, in nvme_free_queue()
817 queue->cq_entry, queue->cq_entry_phy, dma_flags); in nvme_free_queue()
826 struct rt_nvme_queue *queue = &nvme->queue[qid]; in nvme_alloc_queue() local
828 rt_memset(queue, 0, sizeof(*queue)); in nvme_alloc_queue()
874 return queue; in nvme_alloc_queue()
[all …]
A DKconfig9 int "Number of I/O Command queue"
/components/drivers/include/ipc/
A Dwaitqueue.h37 rt_inline void rt_wqueue_init(rt_wqueue_t *queue) in rt_wqueue_init() argument
39 RT_ASSERT(queue != RT_NULL); in rt_wqueue_init()
41 queue->flag = RT_WQ_FLAG_CLEAN; in rt_wqueue_init()
42 rt_list_init(&(queue->waiting_list)); in rt_wqueue_init()
43 rt_spin_lock_init(&(queue->spinlock)); in rt_wqueue_init()
46 void rt_wqueue_add(rt_wqueue_t *queue, struct rt_wqueue_node *node);
48 int rt_wqueue_wait(rt_wqueue_t *queue, int condition, int timeout);
49 int rt_wqueue_wait_killable(rt_wqueue_t *queue, int condition, int timeout);
50 int rt_wqueue_wait_interruptible(rt_wqueue_t *queue, int condition, int timeout);
51 void rt_wqueue_wakeup(rt_wqueue_t *queue, void *key);
[all …]
A Ddataqueue.h35 struct rt_data_item *queue; member
42 void (*evt_notify)(struct rt_data_queue *queue, rt_uint32_t event);
48 rt_err_t rt_data_queue_init(struct rt_data_queue *queue,
51 void (*evt_notify)(struct rt_data_queue *queue, rt_uint32_t event));
52 rt_err_t rt_data_queue_push(struct rt_data_queue *queue,
56 rt_err_t rt_data_queue_pop(struct rt_data_queue *queue,
60 rt_err_t rt_data_queue_peek(struct rt_data_queue *queue,
63 void rt_data_queue_reset(struct rt_data_queue *queue);
64 rt_err_t rt_data_queue_deinit(struct rt_data_queue *queue);
65 rt_uint16_t rt_data_queue_len(struct rt_data_queue *queue);
A Dworkqueue.h67 rt_err_t rt_workqueue_destroy(struct rt_workqueue *queue);
68 rt_err_t rt_workqueue_dowork(struct rt_workqueue *queue, struct rt_work *work);
69 rt_err_t rt_workqueue_submit_work(struct rt_workqueue *queue, struct rt_work *work, rt_tick_t ticks…
70 rt_err_t rt_workqueue_cancel_work(struct rt_workqueue *queue, struct rt_work *work);
71 rt_err_t rt_workqueue_cancel_work_sync(struct rt_workqueue *queue, struct rt_work *work);
72 rt_err_t rt_workqueue_cancel_all_work(struct rt_workqueue *queue);
73 rt_err_t rt_workqueue_urgent_work(struct rt_workqueue *queue, struct rt_work *work);
/components/drivers/wlan/
A DKconfig108 bool "WLAN work queue thread Enable"
113 string "WLAN work queue thread name"
117 int "WLAN work queue thread size"
121 int "WLAN work queue thread priority"
/components/libc/posix/io/termios/
A Dtermios.c197 int tcflush(int fd, int queue) in tcflush() argument
199 return ioctl(fd, TCFLSH, (void*)(rt_ubase_t)queue); in tcflush()
/components/net/lwip/lwip-2.0.3/doc/
A DNO_SYS_SampleCode.c14 if(!queue_try_put(&queue, p)) { in eth_mac_irq()
97 struct pbuf* p = queue_try_get(&queue); in main()
/components/net/lwip/lwip-2.1.2/doc/
A DNO_SYS_SampleCode.c14 if(!queue_try_put(&queue, p)) { in eth_mac_irq()
97 struct pbuf* p = queue_try_get(&queue); in main()
/components/drivers/audio/
A Ddev_audio.c69 if (rt_data_queue_peek(&audio->replay->queue, (const void **)&data, &src_size) != RT_EOK) in _audio_send_replay_frame()
88 result = rt_data_queue_peek(&audio->replay->queue, (const void **)&data, &src_size); in _audio_send_replay_frame()
113 … rt_data_queue_pop(&audio->replay->queue, (const void **)&data, &src_size, RT_WAITING_NO); in _audio_send_replay_frame()
145 result = rt_data_queue_push(&audio->replay->queue, in _audio_flush_replay_frame()
317 rt_data_queue_init(&replay->queue, CFG_AUDIO_REPLAY_QUEUE_COUNT, 0, RT_NULL); in _audio_dev_init()
528 rt_data_queue_push(&audio->replay->queue, in _audio_dev_write()
/components/drivers/include/drivers/
A Dnvme.h860 struct rt_nvme_queue queue[RT_USING_NVME_QUEUE]; member
887 rt_err_t (*setup_queue)(struct rt_nvme_queue *queue);
889 rt_err_t (*cleanup_queue)(struct rt_nvme_queue *queue);
891 rt_err_t (*submit_cmd)(struct rt_nvme_queue *queue, struct rt_nvme_command *cmd);
893 void (*complete_cmd)(struct rt_nvme_queue *queue, struct rt_nvme_command *cmd);
A Ddev_audio.h233 struct rt_data_queue queue; /**< Replay data queue */ member
/components/net/lwip/lwip-1.4.1/
A DREADME.md9 - sockets.c: custom 'select' function implementation in RT-Thread by the wait queue mode.
/components/libc/posix/ipc/
A DKconfig26 bool "Enable posix message queue <mqueue.h>"
/components/net/lwip/lwip-1.4.1/src/core/
A Dtcp_out.c357 struct tcp_seg *last_unsent = NULL, *seg = NULL, *prev_seg = NULL, *queue = NULL; in tcp_write() local
535 …loc(PBUF_TRANSPORT, seglen + optlen, mss_local, &oversize, pcb, apiflags, queue == NULL)) == NULL)… in tcp_write()
599 if (queue == NULL) { in tcp_write()
600 queue = seg; in tcp_write()
668 pcb->unsent = queue; in tcp_write()
670 last_unsent->next = queue; in tcp_write()
700 if (queue != NULL) { in tcp_write()
701 tcp_segs_free(queue); in tcp_write()
/components/net/lwip/lwip-2.0.3/src/core/
A Dtcp_out.c371 struct tcp_seg *last_unsent = NULL, *seg = NULL, *prev_seg = NULL, *queue = NULL; in tcp_write() local
572 …loc(PBUF_TRANSPORT, seglen + optlen, mss_local, &oversize, pcb, apiflags, queue == NULL)) == NULL)… in tcp_write()
641 if (queue == NULL) { in tcp_write()
642 queue = seg; in tcp_write()
733 pcb->unsent = queue; in tcp_write()
735 last_unsent->next = queue; in tcp_write()
765 if (queue != NULL) { in tcp_write()
766 tcp_segs_free(queue); in tcp_write()
/components/net/lwip/lwip-2.0.3/
A DREADME.md16 - sockets.c: custom 'select' function implementation in RT-Thread by the wait queue mode.
/components/net/lwip/lwip-2.1.2/src/core/
A Dtcp_out.c393 struct tcp_seg *last_unsent = NULL, *seg = NULL, *prev_seg = NULL, *queue = NULL; in tcp_write() local
610 …loc(PBUF_TRANSPORT, seglen + optlen, mss_local, &oversize, pcb, apiflags, queue == NULL)) == NULL)… in tcp_write()
679 if (queue == NULL) { in tcp_write()
680 queue = seg; in tcp_write()
771 pcb->unsent = queue; in tcp_write()
773 last_unsent->next = queue; in tcp_write()
803 if (queue != NULL) { in tcp_write()
804 tcp_segs_free(queue); in tcp_write()

Completed in 47 milliseconds

12