Home
last modified time | relevance | path

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

/bsp/allwinner/libraries/sunxi-hal/hal/source/sdmmc/osal/os/RT-Thread/
A Dos_queue.c51 if (queue->handle == NULL) { in OS_QueueCreate()
55 queue->itemSize = itemSize; in OS_QueueCreate()
68 OS_HANDLE_ASSERT(OS_QueueIsValid(queue), queue->handle); in OS_QueueDelete()
71 ret = rt_mq_delete(queue->handle); in OS_QueueDelete()
76 OS_QueueSetInvalid(queue); in OS_QueueDelete()
97 OS_HANDLE_ASSERT(OS_QueueIsValid(queue), queue->handle); in OS_QueueSend()
100 ret = rt_mq_send(queue->handle, item, queue->itemSize); in OS_QueueSend()
106 ret = rt_mq_send(queue->handle, item, queue->itemSize); in OS_QueueSend()
119 ret = rt_mq_send(queue->handle, item, queue->itemSize); in OS_QueueSend()
150 OS_HANDLE_ASSERT(OS_QueueIsValid(queue), queue->handle); in OS_QueueReceive()
[all …]
/bsp/allwinner/libraries/sunxi-hal/hal/source/sdmmc/osal/os/FreeRTOS/
A Dos_queue.c52 queue->handle = xQueueCreate(queueLen, itemSize); in OS_QueueCreate()
53 if (queue->handle == NULL) { in OS_QueueCreate()
54 OS_ERR("err %"OS_HANDLE_F"\n", queue->handle); in OS_QueueCreate()
66 OS_Status OS_QueueDelete(OS_Queue_t *queue) in OS_QueueDelete() argument
70 OS_HANDLE_ASSERT(OS_QueueIsValid(queue), queue->handle); in OS_QueueDelete()
72 ret = uxQueueMessagesWaiting(queue->handle); in OS_QueueDelete()
78 vQueueDelete(queue->handle); in OS_QueueDelete()
79 OS_QueueSetInvalid(queue); in OS_QueueDelete()
101 OS_HANDLE_ASSERT(OS_QueueIsValid(queue), queue->handle); in OS_QueueSend()
105 ret = xQueueSendFromISR(queue->handle, item, &taskWoken); in OS_QueueSend()
[all …]
/bsp/allwinner/libraries/sunxi-hal/include/hal/sdmmc/osal/RT-Thread/
A D_os_queue.h48 OS_Status OS_QueueDelete(OS_Queue_t *queue);
50 OS_Status OS_QueueReceive(OS_Queue_t *queue, void *item, OS_Time_t waitMS);
57 static inline int OS_QueueIsValid(OS_Queue_t *queue) in OS_QueueIsValid() argument
59 return (queue->handle != OS_INVALID_HANDLE); in OS_QueueIsValid()
67 static inline void OS_QueueSetInvalid(OS_Queue_t *queue) in OS_QueueSetInvalid() argument
69 queue->handle = OS_INVALID_HANDLE; in OS_QueueSetInvalid()
83 return OS_QueueCreate(queue, queueLen, sizeof(void *)); in OS_MsgQueueCreate()
91 static inline OS_Status OS_MsgQueueDelete(OS_Queue_t *queue) in OS_MsgQueueDelete() argument
93 return OS_QueueDelete(queue); in OS_MsgQueueDelete()
108 return OS_QueueSend(queue, &msg, waitMS); in OS_MsgQueueSend()
[all …]
/bsp/allwinner/libraries/sunxi-hal/include/hal/sdmmc/osal/FreeRTOS/
A D_os_queue.h53 OS_Status OS_QueueDelete(OS_Queue_t *queue);
55 OS_Status OS_QueueReceive(OS_Queue_t *queue, void *item, OS_Time_t waitMS);
62 static __always_inline int OS_QueueIsValid(OS_Queue_t *queue) in OS_QueueIsValid() argument
64 return (queue->handle != OS_INVALID_HANDLE); in OS_QueueIsValid()
72 static __always_inline void OS_QueueSetInvalid(OS_Queue_t *queue) in OS_QueueSetInvalid() argument
74 queue->handle = OS_INVALID_HANDLE; in OS_QueueSetInvalid()
88 return OS_QueueCreate(queue, queueLen, sizeof(void *)); in OS_MsgQueueCreate()
96 static __always_inline OS_Status OS_MsgQueueDelete(OS_Queue_t *queue) in OS_MsgQueueDelete() argument
98 return OS_QueueDelete(queue); in OS_MsgQueueDelete()
113 return OS_QueueSend(queue, &msg, waitMS); in OS_MsgQueueSend()
[all …]
/bsp/allwinner/libraries/sunxi-hal/hal/source/msgbox/msgbox_sx/
A Dmsgbox_sx.c17 static int msg_queue_t_set(struct messagebox *mb, int queue) in msg_queue_t_set() argument
21 int offset_bit_t = 4 + ((queue % 4) * 8 ); in msg_queue_t_set()
22 int offset_bit_r = ((queue % 4) * 8 ); in msg_queue_t_set()
26 if (queue >= MSGBOX_MAX_QUEUE || user >= MSGBOX_MAX_USER) in msg_queue_t_set()
40 static int msg_queue_r_set(struct messagebox *mb, int queue) in msg_queue_r_set() argument
44 int offset_bit_t = 4 + ((queue % 4) * 8 ); in msg_queue_r_set()
45 int offset_bit_r = ((queue % 4) * 8 ); in msg_queue_r_set()
67 int offset_bit = 1 + (queue << 1); in msg_queue_irq_t()
84 int offset_bit = (queue << 1); in msg_queue_irq_r()
113 if (queue >= MSGBOX_MAX_QUEUE) in msg_queue_is_full()
[all …]
A Dmsgbox_sx.h28 int (*cb_of_msg_queue)(int queue, void *data);
/bsp/allwinner/libraries/sunxi-hal/osal/src/
A Dhal_queue.c128 ret = rt_workqueue_dowork(queue, work); in hal_workqueue_dowork()
137 int hal_queue_delete(hal_queue_t queue) in hal_queue_delete() argument
139 if (queue == NULL) in hal_queue_delete()
145 rt_mq_delete(queue); in hal_queue_delete()
154 if (queue == NULL) in hal_queue_send_wait()
160 ret = rt_mq_send_wait(queue, buffer, queue->msg_size, timeout); in hal_queue_send_wait()
171 return hal_queue_send_wait(queue, buffer, 0); in hal_queue_send()
178 if (queue == NULL) in hal_queue_recv()
184 ret = rt_mq_recv(queue, buffer, queue->msg_size, timeout); in hal_queue_recv()
194 int hal_is_queue_empty(hal_queue_t queue) in hal_is_queue_empty() argument
[all …]
/bsp/xuantie/libraries/xuantie_libraries/csi/csi2/include/drv/
A Dlist.h52 static inline void dlist_add(dlist_t *node, dlist_t *queue) in dlist_add() argument
54 __dlist_add(node, queue, queue->next); in dlist_add()
59 __dlist_add(node, queue->prev, queue); in dlist_add_tail()
132 #define dlist_for_each_entry(queue, node, type, member) \ argument
134 &node->member != (queue); \
148 n = (queue)->next ? (queue)->next->next : NULL; \
181 int dlist_entry_number(dlist_t *queue);
273 for (node = (queue)->next? aos_container_of((queue)->next, type, member) : NULL; \
287 for (node = (queue)->next? aos_container_of((queue)->next, type, member) : NULL, \
288 tmp = (queue)->next ? (queue)->next->next : NULL; \
[all …]
/bsp/n32/libraries/N32WB452_Firmware_Library/n32wb452_ble_driver/inc/
A Dke_queue.h53 __INLINE void ke_queue_push(struct co_list *const queue, struct co_list_hdr *const element) in ke_queue_push() argument
55 co_list_push_back(queue, element); in ke_queue_push()
67 __INLINE struct co_list_hdr *ke_queue_pop(struct co_list *const queue) in ke_queue_pop() argument
69 return co_list_pop_front(queue); in ke_queue_pop()
83 struct co_list_hdr *ke_queue_extract(struct co_list * const queue,
102 void ke_queue_insert(struct co_list * const queue, struct co_list_hdr * const element,
/bsp/allwinner/libraries/sunxi-hal/include/osal/
A Dhal_queue.h28 int hal_workqueue_dowork(hal_workqueue *queue, hal_work *work);
47 int hal_queue_delete(hal_queue_t queue);
48 int hal_queue_send(hal_queue_t queue, void *buffer);
49 int hal_queue_send_wait(hal_queue_t queue, void *buffer, int timeout);
50 int hal_queue_recv(hal_queue_t queue, void *buffer, int timeout);
51 int hal_is_queue_empty(hal_queue_t queue);
/bsp/simulator/pcap/Include/
A DWin32-Extensions.h87 void pcap_sendqueue_destroy(pcap_send_queue* queue);
89 int pcap_sendqueue_queue(pcap_send_queue* queue, const struct pcap_pkthdr *pkt_header, const u_char…
91 u_int pcap_sendqueue_transmit(pcap_t *p, pcap_send_queue* queue, int sync);
/bsp/apollo2/libraries/drivers/hal/
A Dam_hal_queue.h95 #define am_hal_queue_from_array(queue, array) \ argument
96 am_hal_queue_init((queue), (array), sizeof((array)[0]), sizeof(array))
/bsp/hpmicro/libraries/hpm_sdk/drivers/src/
A Dhpm_adc12_drv.c297 if (ADC12_IS_CHANNEL_INVALID(config->queue[i].ch)) { in adc12_set_seq_config()
301 ptr->SEQ_QUE[i] = ADC12_SEQ_QUE_SEQ_INT_EN_SET(config->queue[i].seq_int_en) in adc12_set_seq_config()
302 | ADC12_SEQ_QUE_CHAN_NUM_4_0_SET(config->queue[i].ch); in adc12_set_seq_config()
A Dhpm_adc16_drv.c352 if (ADC16_IS_CHANNEL_INVALID(config->queue[i].ch)) { in adc16_set_seq_config()
356 ptr->SEQ_QUE[i] = ADC16_SEQ_QUE_SEQ_INT_EN_SET(config->queue[i].seq_int_en) in adc16_set_seq_config()
357 | ADC16_SEQ_QUE_CHAN_NUM_4_0_SET(config->queue[i].ch); in adc16_set_seq_config()
/bsp/stm32/stm32f429-st-disco/board/CubeMX_Config/
A D.mxproject8 …queue.h;Middlewares/Third_Party/FreeRTOS/Source/include/semphr.h;Middlewares/Third_Party/FreeRTOS/…
11 …queue.c;../Middlewares/Third_Party/FreeRTOS/Source/stream_buffer.c;../Middlewares/Third_Party/Free…
/bsp/hpmicro/libraries/hpm_sdk/drivers/inc/
A Dhpm_tsw_drv.h43 uint32_t queue : 3; /**< the priority queue for TSW TX */ member
A Dhpm_adc12_drv.h196 adc12_seq_queue_config_t queue[ADC_SOC_SEQ_MAX_LEN]; member
A Dhpm_adc16_drv.h209 adc16_seq_queue_config_t queue[ADC_SOC_SEQ_MAX_LEN]; member
/bsp/allwinner/libraries/sunxi-hal/hal/source/usb/uvc/Class/
A Duvc_video.c1208 if (!uvc_queue_streaming(&stream->queue)) in uvc_video_suspend()
1239 uvc_queue_enable(&stream->queue, 0); in uvc_video_resume()
1243 if (!uvc_queue_streaming(&stream->queue)) in uvc_video_resume()
1248 uvc_queue_enable(&stream->queue, 0); in uvc_video_resume()
/bsp/sparkfun-redv/
A DREADME.md133 list_msgqueue - list message queue in system

Completed in 40 milliseconds