| /components/drivers/ipc/ |
| A D | workqueue.c | 21 rt_inline rt_err_t _workqueue_work_completion(struct rt_workqueue *queue) in _workqueue_work_completion()
54 struct rt_workqueue *queue; in _workqueue_thread_entry() local
115 static rt_err_t _workqueue_submit_work(struct rt_workqueue *queue, in _workqueue_submit_work()
168 static rt_err_t _workqueue_cancel_work(struct rt_workqueue *queue, struct rt_work *work) in _workqueue_cancel_work()
219 struct rt_workqueue *queue = RT_NULL; in rt_workqueue_create() local
254 rt_err_t rt_workqueue_destroy(struct rt_workqueue *queue) in rt_workqueue_destroy()
275 rt_err_t rt_workqueue_dowork(struct rt_workqueue *queue, struct rt_work *work) in rt_workqueue_dowork()
315 rt_err_t rt_workqueue_urgent_work(struct rt_workqueue *queue, struct rt_work *work) in rt_workqueue_urgent_work()
343 rt_err_t rt_workqueue_cancel_work(struct rt_workqueue *queue, struct rt_work *work) in rt_workqueue_cancel_work()
360 rt_err_t rt_workqueue_cancel_work_sync(struct rt_workqueue *queue, struct rt_work *work) in rt_workqueue_cancel_work_sync()
[all …]
|
| A D | dataqueue.c | 43 rt_data_queue_init(struct rt_data_queue *queue, in rt_data_queue_init()
46 void (*evt_notify)(struct rt_data_queue *queue, rt_uint32_t event)) in rt_data_queue_init()
92 rt_err_t rt_data_queue_push(struct rt_data_queue *queue, in rt_data_queue_push()
209 rt_err_t rt_data_queue_pop(struct rt_data_queue *queue, in rt_data_queue_pop()
330 rt_err_t rt_data_queue_peek(struct rt_data_queue *queue, in rt_data_queue_peek()
363 void rt_data_queue_reset(struct rt_data_queue *queue) in rt_data_queue_reset()
403 rt_err_t rt_data_queue_deinit(struct rt_data_queue *queue) in rt_data_queue_deinit()
430 rt_uint16_t rt_data_queue_len(struct rt_data_queue *queue) in rt_data_queue_len()
|
| A D | waitqueue.c | 29 void rt_wqueue_add(rt_wqueue_t *queue, struct rt_wqueue_node *node) in rt_wqueue_add()
80 void rt_wqueue_wakeup(rt_wqueue_t *queue, void *key) in rt_wqueue_wakeup()
136 void rt_wqueue_wakeup_all(rt_wqueue_t *queue, void *key) in rt_wqueue_wakeup_all()
199 static int _rt_wqueue_wait(rt_wqueue_t *queue, int condition, int msec, int suspend_flag) in _rt_wqueue_wait()
267 int rt_wqueue_wait(rt_wqueue_t *queue, int condition, int msec) in rt_wqueue_wait()
272 int rt_wqueue_wait_killable(rt_wqueue_t *queue, int condition, int msec) in rt_wqueue_wait_killable()
277 int rt_wqueue_wait_interruptible(rt_wqueue_t *queue, int condition, int msec) in rt_wqueue_wait_interruptible()
|
| A D | condvar.c | 37 static int _waitq_inqueue(rt_wqueue_t *queue, struct rt_wqueue_node *node, in _waitq_inqueue()
|
| /components/drivers/virtio/ |
| A D | virtio.c | 95 struct virtq *queue; in virtio_queue_init() local
153 struct virtq *queue; in virtio_queue_destroy() local
186 struct virtq *queue; in virtio_submit_chain() local
205 struct virtq *queue; in virtio_alloc_desc() local
234 struct virtq *queue; in virtio_free_desc() local
|
| A D | virtio_blk.c | 147 struct virtq *queue = &virtio_dev->queues[VIRTIO_BLK_QUEUE]; in virtio_blk_isr() local
|
| A D | virtio_console.h | 29 #define VIRTIO_CONSOLE_PORT_QUEUE_INDEX(id, queue) ((id) * 2 + (!!(id)) * 2 + (queue)) argument
|
| /components/drivers/nvme/ |
| A D | nvme.c | 103 static rt_err_t nvme_submit_cmd(struct rt_nvme_queue *queue, in nvme_submit_cmd()
653 struct rt_nvme_queue *queue = param; in nvme_queue_isr() local
728 static rt_err_t nvme_attach_queue(struct rt_nvme_queue *queue, rt_uint8_t opcode) in nvme_attach_queue()
763 rt_inline rt_err_t nvme_attach_queue_sq(struct rt_nvme_queue *queue) in nvme_attach_queue_sq()
768 rt_inline rt_err_t nvme_attach_queue_cq(struct rt_nvme_queue *queue) in nvme_attach_queue_cq()
773 static rt_err_t nvme_detach_queue(struct rt_nvme_queue *queue, in nvme_detach_queue()
791 static void nvme_free_queue(struct rt_nvme_queue *queue) in nvme_free_queue()
826 struct rt_nvme_queue *queue = &nvme->queue[qid]; in nvme_alloc_queue() local
959 struct rt_nvme_queue *queue; in nvme_setup_io_queues() local
1012 struct rt_nvme_queue *queue; in nvme_remove_io_queues() local
|
| /components/drivers/include/ipc/ |
| A D | waitqueue.h | 37 rt_inline void rt_wqueue_init(rt_wqueue_t *queue) in rt_wqueue_init()
|
| A D | dataqueue.h | 35 struct rt_data_item *queue; member
|
| /components/libc/posix/io/termios/ |
| A D | termios.c | 197 int tcflush(int fd, int queue) in tcflush()
|
| /components/drivers/serial/ |
| A D | dev_serial.c | 998 static void _tc_flush(struct rt_serial_device *serial, int queue) in _tc_flush()
1232 int queue = (int)(rt_ubase_t)args; in rt_serial_control() local
|
| A D | dev_serial_v2.c | 1355 static void _tc_flush(struct rt_serial_device *serial, int queue) in _tc_flush()
1658 int queue = (int)args; in rt_serial_control() local
|
| /components/drivers/include/drivers/ |
| A D | dev_audio.h | 233 struct rt_data_queue queue; /**< Replay data queue */ member
|
| A D | nvme.h | 860 struct rt_nvme_queue queue[RT_USING_NVME_QUEUE]; member
|
| /components/net/lwip/lwip-1.4.1/src/core/ |
| A D | tcp_out.c | 357 struct tcp_seg *last_unsent = NULL, *seg = NULL, *prev_seg = NULL, *queue = NULL; in tcp_write() local
|
| /components/net/lwip/lwip-2.0.3/src/core/ |
| A D | tcp_out.c | 371 struct tcp_seg *last_unsent = NULL, *seg = NULL, *prev_seg = NULL, *queue = NULL; in tcp_write() local
|
| /components/net/lwip/lwip-2.1.2/src/core/ |
| A D | tcp_out.c | 393 struct tcp_seg *last_unsent = NULL, *seg = NULL, *prev_seg = NULL, *queue = NULL; in tcp_write() local
|