Home
last modified time | relevance | path

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

1234

/AliOS-Things-master/kernel/rhino/
A Dk_buf_queue.c16 NULL_PARA_CHK(queue); in buf_queue_create()
53 queue->min_free_buf_size = queue->ringbuf.freesize; in buf_queue_create()
76 NULL_PARA_CHK(queue); in krhino_buf_queue_del()
119 NULL_PARA_CHK(queue); in buf_queue_dyn_create()
149 *queue = queue_obj; in buf_queue_dyn_create()
255 if (queue->peak_num < queue->cur_num) { in buf_queue_send()
256 queue->peak_num = queue->cur_num; in buf_queue_send()
259 if (queue->min_free_buf_size > queue->ringbuf.freesize) { in buf_queue_send()
260 queue->min_free_buf_size = queue->ringbuf.freesize; in buf_queue_send()
381 queue->min_free_buf_size = queue->ringbuf.freesize; in krhino_buf_queue_flush()
[all …]
A Dk_queue.c21 NULL_PARA_CHK(queue); in queue_create()
71 NULL_PARA_CHK(queue); in krhino_queue_del()
115 NULL_PARA_CHK(queue); in krhino_queue_dyn_create()
136 *queue = queue_obj; in krhino_queue_dyn_create()
146 NULL_PARA_CHK(queue); in krhino_queue_dyn_del()
180 krhino_mm_free(queue); in krhino_queue_dyn_del()
254 NULL_PARA_CHK(queue); in krhino_queue_recv()
327 NULL_PARA_CHK(queue); in krhino_queue_is_full()
336 if (queue->msg_q.cur_num >= queue->msg_q.size) { in krhino_queue_is_full()
351 NULL_PARA_CHK(queue); in krhino_queue_flush()
[all …]
/AliOS-Things-master/components/SDL2/src/
A DSDL_dataqueue.c62 if (!queue) { in SDL_NewDataQueue()
84 return queue; in SDL_NewDataQueue()
90 if (queue) { in SDL_FreeDataQueue()
100 const size_t packet_size = queue ? queue->packet_size : 1; in SDL_ClearDataQueue()
106 if (!queue) { in SDL_ClearDataQueue()
114 queue->tail->next = queue->pool; in SDL_ClearDataQueue()
179 const size_t packet_size = queue ? queue->packet_size : 0; in SDL_WriteToDataQueue()
185 if (!queue) { in SDL_WriteToDataQueue()
236 if (!queue) { in SDL_PeekIntoDataQueue()
261 if (!queue) { in SDL_ReadFromDataQueue()
[all …]
A DSDL_dataqueue.h30 void SDL_FreeDataQueue(SDL_DataQueue *queue);
31 void SDL_ClearDataQueue(SDL_DataQueue *queue, const size_t slack);
32 int SDL_WriteToDataQueue(SDL_DataQueue *queue, const void *data, const size_t len);
33 size_t SDL_ReadFromDataQueue(SDL_DataQueue *queue, void *buf, const size_t len);
34 size_t SDL_PeekIntoDataQueue(SDL_DataQueue *queue, void *buf, const size_t len);
35 size_t SDL_CountDataQueue(SDL_DataQueue *queue);
50 void *SDL_ReserveSpaceInDataQueue(SDL_DataQueue *queue, const size_t len);
/AliOS-Things-master/components/linkkit/external/nghttp2/
A Dnghttp2_queue.c50 queue->front = queue->back = NULL; in nghttp2_queue_init()
55 if (!queue) { in nghttp2_queue_free()
76 if (queue->back) { in nghttp2_queue_push()
78 queue->back = new_cell; in nghttp2_queue_push()
81 queue->front = queue->back = new_cell; in nghttp2_queue_push()
90 queue->front = front->next; in nghttp2_queue_pop()
92 queue->back = NULL; in nghttp2_queue_pop()
99 assert(queue->front); in nghttp2_queue_front()
100 return queue->front->data; in nghttp2_queue_front()
105 assert(queue->back); in nghttp2_queue_back()
[all …]
A Dnghttp2_queue.h43 void nghttp2_queue_init(nghttp2_queue *queue);
44 void nghttp2_queue_free(nghttp2_queue *queue);
45 int nghttp2_queue_push(nghttp2_queue *queue, void *data);
46 void nghttp2_queue_pop(nghttp2_queue *queue);
47 void *nghttp2_queue_front(nghttp2_queue *queue);
48 void *nghttp2_queue_back(nghttp2_queue *queue);
49 int nghttp2_queue_empty(nghttp2_queue *queue);
/AliOS-Things-master/components/osal_aos/rhino/
A Daos_queue.c27 if (queue == NULL || size == 0) { in aos_queue_new()
44 *queue = q; in aos_queue_new()
57 if (queue == NULL || size == 0) { in aos_queue_create()
74 *queue = q; in aos_queue_create()
81 if (queue == NULL || *queue == NULL) { in aos_queue_free()
87 aos_free(*queue); in aos_queue_free()
89 *queue = NULL; in aos_queue_free()
96 CHECK_HANDLE(queue); in aos_queue_send()
107 CHECK_HANDLE(queue); in aos_queue_recv()
120 if (queue == NULL) { in aos_queue_is_valid()
[all …]
/AliOS-Things-master/components/SDL2/test/
A Dtestatomic.c307 queue->lock = 0; in InitEventQueue()
416 SDL_LockMutex(queue->mutex); in EnqueueEvent_Mutex()
481 SDL_EventQueue *queue; member
491 SDL_EventQueue *queue; member
501 SDL_EventQueue *queue = data->queue; in FIFO_Writer() local
536 SDL_EventQueue *queue = data->queue; in FIFO_Reader() local
596 SDL_EventQueue queue; in RunFIFOTest() local
611 SDL_memset(&queue, 0xff, sizeof(queue)); in RunFIFOTest()
613 InitEventQueue(&queue); in RunFIFOTest()
634 readerData[i].queue = &queue; in RunFIFOTest()
[all …]
/AliOS-Things-master/solutions/tflite_micro_speech_demo/micro_speech/
A Drecognize_commands_test.cc27 TF_LITE_MICRO_EXPECT_EQ(0, queue.size()); in TF_LITE_MICRO_TEST()
30 queue.push_back({0, scores_a}); in TF_LITE_MICRO_TEST()
31 TF_LITE_MICRO_EXPECT_EQ(1, queue.size()); in TF_LITE_MICRO_TEST()
36 queue.push_back({1, scores_b}); in TF_LITE_MICRO_TEST()
37 TF_LITE_MICRO_EXPECT_EQ(2, queue.size()); in TF_LITE_MICRO_TEST()
43 TF_LITE_MICRO_EXPECT_EQ(1, queue.size()); in TF_LITE_MICRO_TEST()
48 queue.push_back({2, scores_c}); in TF_LITE_MICRO_TEST()
49 TF_LITE_MICRO_EXPECT_EQ(2, queue.size()); in TF_LITE_MICRO_TEST()
58 TF_LITE_MICRO_EXPECT_EQ(0, queue.size()); in TF_LITE_MICRO_TEST()
62 queue.push_back({i, scores}); in TF_LITE_MICRO_TEST()
[all …]
/AliOS-Things-master/components/ble_host/bt_host/port/aos/
A Daos_port.c39 void k_queue_init(struct k_queue *queue) in k_queue_init() argument
49 sys_slist_init(&queue->queue_list); in k_queue_init()
50 sys_dlist_init(&queue->poll_events); in k_queue_init()
60 krhino_sem_give(&queue->sem); in k_queue_cancel_wait()
71 krhino_sem_give(&queue->sem); in k_queue_insert()
82 k_queue_insert(queue, NULL, data); in k_queue_append()
87 k_queue_insert(queue, NULL, data); in k_queue_prepend()
96 k_queue_append(queue, buf_tail); in k_queue_append_list()
127 int k_queue_is_empty(struct k_queue *queue) in k_queue_is_empty() argument
132 int k_queue_count(struct k_queue *queue) in k_queue_count() argument
[all …]
A Devent_scheduler.c24 if (k_queue_is_empty(&g_work_queue.queue) == 0) { in scheduler_loop()
25 work = k_queue_first_entry(&g_work_queue.queue); in scheduler_loop()
48 if (k_queue_is_empty(&g_work_queue.queue) == 0) { in scheduler_loop()
49 work = k_queue_first_entry(&g_work_queue.queue); in scheduler_loop()
53 k_queue_remove(&g_work_queue.queue, work); in scheduler_loop()
/AliOS-Things-master/components/minilibc/include/
A Dmm_queue.h106 void sq_addlast(sq_entry_t *node, sq_queue_t *queue);
107 void dq_addlast(dq_entry_t *node, dq_queue_t *queue);
109 sq_queue_t *queue);
111 dq_queue_t *queue);
113 dq_queue_t *queue);
116 void sq_rem(sq_entry_t *node, sq_queue_t *queue);
117 void dq_rem(dq_entry_t *node, dq_queue_t *queue);
118 sq_entry_t *sq_remlast(sq_queue_t *queue);
119 dq_entry_t *dq_remlast(dq_queue_t *queue);
120 sq_entry_t *sq_remfirst(sq_queue_t *queue);
[all …]
/AliOS-Things-master/components/amp/utils/list/
A Damp_list.h75 static inline void dlist_add(dlist_t *node, dlist_t *queue) in dlist_add() argument
77 __dlist_add(node, queue, queue->next); in dlist_add()
86 static inline void dlist_add_tail(dlist_t *node, dlist_t *queue) in dlist_add_tail() argument
88 __dlist_add(node, queue->prev, queue); in dlist_add_tail()
196 n = (queue)->next ? (queue)->next->next : NULL; \
228 static inline int dlist_entry_number(dlist_t *queue) in dlist_entry_number() argument
232 dlist_t *cur = queue; in dlist_entry_number()
234 for (num = 0; cur->next != queue; cur = cur->next, num++) in dlist_entry_number()
350 tmp = (queue)->next ? (queue)->next->next : NULL; \
394 static inline int slist_entry_number(slist_t *queue) in slist_entry_number() argument
[all …]
/AliOS-Things-master/components/py_engine/external/amp_utils/
A Damp_list.h73 static inline void dlist_add(dlist_t *node, dlist_t *queue) in dlist_add() argument
75 __dlist_add(node, queue, queue->next); in dlist_add()
87 __dlist_add(node, queue->prev, queue); in dlist_add_tail()
181 #define dlist_for_each_entry(queue, node, type, member) \ argument
182 for (node = amp_container_of((queue)->next, type, member); &node->member != (queue); \
195 …for (node = amp_container_of((queue)->next, type, member), n = (queue)->next ? (queue)->next->next…
225 static inline int dlist_entry_number(dlist_t *queue) in dlist_entry_number() argument
229 dlist_t *cur = queue; in dlist_entry_number()
350 tmp = (queue)->next ? (queue)->next->next : NULL; \
396 static inline int slist_entry_number(slist_t *queue) in slist_entry_number() argument
[all …]
/AliOS-Things-master/components/osal_aos/include/aos/
A Dlist.h75 static inline void dlist_add(dlist_t *node, dlist_t *queue) in dlist_add() argument
77 __dlist_add(node, queue, queue->next); in dlist_add()
86 static inline void dlist_add_tail(dlist_t *node, dlist_t *queue) in dlist_add_tail() argument
88 __dlist_add(node, queue->prev, queue); in dlist_add_tail()
196 n = (queue)->next ? (queue)->next->next : NULL; \
228 static inline int dlist_entry_number(dlist_t *queue) in dlist_entry_number() argument
232 dlist_t *cur = queue; in dlist_entry_number()
234 for (num = 0; cur->next != queue; cur = cur->next, num++) in dlist_entry_number()
350 tmp = (queue)->next ? (queue)->next->next : NULL; \
394 static inline int slist_entry_number(slist_t *queue) in slist_entry_number() argument
[all …]
/AliOS-Things-master/kernel/rhino/include/
A Dk_queue.h62 kstat_t krhino_queue_create(kqueue_t *queue, const name_t *name, void **start, size_t msg_num);
71 kstat_t krhino_queue_del(kqueue_t *queue);
83 kstat_t krhino_queue_dyn_create(kqueue_t **queue, const name_t *name, size_t msg_num);
92 kstat_t krhino_queue_dyn_del(kqueue_t *queue);
103 kstat_t krhino_queue_back_send(kqueue_t *queue, void *msg);
113 kstat_t krhino_queue_all_send(kqueue_t *queue, void *msg);
124 kstat_t krhino_queue_recv(kqueue_t *queue, tick_t ticks, void **msg);
133 kstat_t krhino_queue_is_full(kqueue_t *queue);
142 kstat_t krhino_queue_flush(kqueue_t *queue);
152 kstat_t krhino_queue_info_get(kqueue_t *queue, msg_info_t *info);
A Dk_buf_queue.h64 kstat_t krhino_buf_queue_create(kbuf_queue_t *queue, const name_t *name,
78 kstat_t krhino_fix_buf_queue_create(kbuf_queue_t *queue, const name_t *name,
88 kstat_t krhino_buf_queue_del(kbuf_queue_t *queue);
103 kstat_t krhino_buf_queue_dyn_create(kbuf_queue_t **queue, const name_t *name,
117 kstat_t krhino_fix_buf_queue_dyn_create(kbuf_queue_t **queue, const name_t *name,
127 kstat_t krhino_buf_queue_dyn_del(kbuf_queue_t *queue);
140 kstat_t krhino_buf_queue_send(kbuf_queue_t *queue, void *msg, size_t size);
153 kstat_t krhino_buf_queue_recv(kbuf_queue_t *queue, tick_t ticks, void *msg, size_t *size);
162 kstat_t krhino_buf_queue_flush(kbuf_queue_t *queue);
172 kstat_t krhino_buf_queue_info_get(kbuf_queue_t *queue, kbuf_queue_info_t *info);
/AliOS-Things-master/components/linkkit/include/linkkit/infra/
A Dinfra_list.h57 static inline void dlist_add(dlist_t *node, dlist_t *queue) in dlist_add() argument
59 __dlist_add(node, queue, queue->next); in dlist_add()
62 static inline void dlist_add_tail(dlist_t *node, dlist_t *queue) in dlist_add_tail() argument
64 __dlist_add(node, queue->prev, queue); in dlist_add_tail()
156 n = (queue)->next ? (queue)->next->next : NULL; \
185 static inline int __dlist_entry_number(dlist_t *queue) in __dlist_entry_number() argument
188 dlist_t *cur = queue; in __dlist_entry_number()
189 for (num = 0; cur->next != queue; cur = cur->next, num++) in __dlist_entry_number()
285 tmp = (queue)->next ? (queue)->next->next : NULL; \
330 static inline int slist_entry_number(slist_t *queue) in slist_entry_number() argument
[all …]
/AliOS-Things-master/components/csi/csi2/include/drv/
A Dlist.h64 static inline void dlist_add(dlist_t *node, dlist_t *queue) in dlist_add() argument
66 __dlist_add(node, queue, queue->next); in dlist_add()
69 static inline void dlist_add_tail(dlist_t *node, dlist_t *queue) in dlist_add_tail() argument
71 __dlist_add(node, queue->prev, queue); in dlist_add_tail()
144 #define dlist_for_each_entry(queue, node, type, member) \ argument
145 for (node = aos_container_of((queue)->next, type, member); \
146 &node->member != (queue); \
160 n = (queue)->next ? (queue)->next->next : NULL; \
193 int dlist_entry_number(dlist_t *queue);
305 tmp = (queue)->next ? (queue)->next->next : NULL; \
[all …]
/AliOS-Things-master/hardware/chip/haas1000/drivers/services/ble_stack/ke/src/
A Dke_queue.h38 __STATIC __INLINE void ke_queue_push(struct co_list *const queue, struct co_list_hdr *const element) in ke_queue_push() argument
40 co_list_push_back(queue, element); in ke_queue_push()
52 __STATIC __INLINE struct co_list_hdr *ke_queue_pop(struct co_list *const queue) in ke_queue_pop() argument
54 return co_list_pop_front(queue); in ke_queue_pop()
68 struct co_list_hdr *ke_queue_extract(struct co_list * const queue,
87 void ke_queue_insert(struct co_list * const queue, struct co_list_hdr * const element,
/AliOS-Things-master/components/ble_host/ble_profiles/
A Duart_client.c158 return queue->front == queue->rear; in is_dev_data_queue_empty()
163 if ((queue->rear + 1) % 10 == queue->front) { in is_dev_data_queue_full()
172 if (is_dev_data_queue_empty(queue)) { in get_dev_data()
175 report_dev *data = &queue->dev[queue->front]; in get_dev_data()
176 queue->front = (queue->front + 1) % 10; in get_dev_data()
184 if (!queue || !dev) { in put_dev_data()
188 if (is_dev_data_queue_full(queue)) { in put_dev_data()
192 for (int i = queue->front; i < queue->rear ; i++) { in put_dev_data()
198 memcpy(&queue->dev[queue->rear].addr, dev, sizeof(dev_addr_t)); in put_dev_data()
199 queue->dev[queue->rear].time_found = aos_now_ms(); in put_dev_data()
[all …]
/AliOS-Things-master/components/py_engine/adapter/haas/
A Dmodipc.c18 kbuf_queue_t* queue;
34 mp_printf(print, "queue(%u)", self->queue);
39 kbuf_queue_t *queue;
57 mp_int_t ret = krhino_buf_queue_dyn_create(&queue, pname, size, max_msg);
63 ipc_obj->queue = queue;
77 mp_int_t ret = krhino_buf_queue_send(ipc_obj->queue, msg, size);
97 mp_int_t ret = krhino_buf_queue_recv(ipc_obj->queue, tick , msg, psize);
/AliOS-Things-master/components/py_engine/adapter/haas510/
A Dmodipc.c18 kbuf_queue_t* queue;
34 mp_printf(print, "queue(%u)", self->queue);
39 kbuf_queue_t *queue;
57 mp_int_t ret = krhino_buf_queue_dyn_create(&queue, pname, size, max_msg);
63 ipc_obj->queue = queue;
77 mp_int_t ret = krhino_buf_queue_send(ipc_obj->queue, msg, size);
97 mp_int_t ret = krhino_buf_queue_recv(ipc_obj->queue, tick , msg, psize);
/AliOS-Things-master/components/py_engine/adapter/haas600/
A Dmodipc.c18 kbuf_queue_t* queue;
34 mp_printf(print, "queue(%u)", self->queue);
39 kbuf_queue_t *queue;
57 mp_int_t ret = krhino_buf_queue_dyn_create(&queue, pname, size, max_msg);
63 ipc_obj->queue = queue;
77 mp_int_t ret = krhino_buf_queue_send(ipc_obj->queue, msg, size);
97 mp_int_t ret = krhino_buf_queue_recv(ipc_obj->queue, tick , msg, psize);
/AliOS-Things-master/components/ble_host/include/
A Dble_os_port.h107 struct k_queue *queue; member
327 extern void k_queue_init(struct k_queue *queue);
328 extern void k_queue_uninit(struct k_queue *queue);
329 extern void k_queue_cancel_wait(struct k_queue *queue);
330 extern void k_queue_append(struct k_queue *queue, void *data);
331 extern void k_queue_prepend(struct k_queue *queue, void *data);
334 extern void *k_queue_get(struct k_queue *queue, int32_t timeout);
335 extern int k_queue_is_empty(struct k_queue *queue);
336 extern int k_queue_count(struct k_queue *queue);
343 static inline void *k_queue_first_entry(struct k_queue *queue) in k_queue_first_entry() argument
[all …]

Completed in 31 milliseconds

1234