Home
last modified time | relevance | path

Searched defs:queue (Results 1 – 25 of 41) sorted by relevance

12

/AliOS-Things-master/kernel/rhino/
A Dk_queue.c14 static kstat_t queue_create(kqueue_t *queue, const name_t *name, void **start, in queue_create()
60 kstat_t krhino_queue_create(kqueue_t *queue, const name_t *name, void **start, in krhino_queue_create()
66 kstat_t krhino_queue_del(kqueue_t *queue) in krhino_queue_del()
108 kstat_t krhino_queue_dyn_create(kqueue_t **queue, const name_t *name, in krhino_queue_dyn_create()
141 kstat_t krhino_queue_dyn_del(kqueue_t *queue) in krhino_queue_dyn_del()
238 kstat_t krhino_queue_back_send(kqueue_t *queue, void *msg) in krhino_queue_back_send()
243 kstat_t krhino_queue_all_send(kqueue_t *queue, void *msg) in krhino_queue_all_send()
248 kstat_t krhino_queue_recv(kqueue_t *queue, tick_t ticks, void **msg) in krhino_queue_recv()
322 kstat_t krhino_queue_is_full(kqueue_t *queue) in krhino_queue_is_full()
347 kstat_t krhino_queue_flush(kqueue_t *queue) in krhino_queue_flush()
[all …]
A Dk_buf_queue.c59 kstat_t krhino_buf_queue_create(kbuf_queue_t *queue, const name_t *name, in krhino_buf_queue_create()
65 kstat_t krhino_fix_buf_queue_create(kbuf_queue_t *queue, const name_t *name, in krhino_fix_buf_queue_create()
71 kstat_t krhino_buf_queue_del(kbuf_queue_t *queue) in krhino_buf_queue_del()
113 static kstat_t buf_queue_dyn_create(kbuf_queue_t **queue, const name_t *name, in buf_queue_dyn_create()
154 kstat_t krhino_buf_queue_dyn_create(kbuf_queue_t **queue, const name_t *name, in krhino_buf_queue_dyn_create()
160 kstat_t krhino_fix_buf_queue_dyn_create(kbuf_queue_t **queue, const name_t *name, in krhino_fix_buf_queue_dyn_create()
166 kstat_t krhino_buf_queue_dyn_del(kbuf_queue_t *queue) in krhino_buf_queue_dyn_del()
209 static kstat_t buf_queue_send(kbuf_queue_t *queue, void *msg, size_t msg_size) in buf_queue_send()
283 kstat_t krhino_buf_queue_send(kbuf_queue_t *queue, void *msg, size_t size) in krhino_buf_queue_send()
363 kstat_t krhino_buf_queue_flush(kbuf_queue_t *queue) in krhino_buf_queue_flush()
[all …]
A Dk_workqueue.c33 kworkqueue_t *queue = (kworkqueue_t *)arg; in worker_task() local
/AliOS-Things-master/components/linkkit/external/nghttp2/
A Dnghttp2_queue.c48 void nghttp2_queue_init(nghttp2_queue *queue) in nghttp2_queue_init()
53 void nghttp2_queue_free(nghttp2_queue *queue) in nghttp2_queue_free()
67 int nghttp2_queue_push(nghttp2_queue *queue, void *data) in nghttp2_queue_push()
86 void nghttp2_queue_pop(nghttp2_queue *queue) in nghttp2_queue_pop()
97 void *nghttp2_queue_front(nghttp2_queue *queue) in nghttp2_queue_front()
103 void *nghttp2_queue_back(nghttp2_queue *queue) in nghttp2_queue_back()
109 int nghttp2_queue_empty(nghttp2_queue *queue) in nghttp2_queue_empty()
/AliOS-Things-master/components/osal_aos/rhino/
A Daos_queue.c20 aos_status_t aos_queue_new(aos_queue_t *queue, void *buf, size_t size, size_t max_msg) in aos_queue_new()
49 aos_status_t aos_queue_create(aos_queue_t *queue, size_t size, size_t max_msg, uint32_t options) in aos_queue_create()
79 void aos_queue_free(aos_queue_t *queue) in aos_queue_free()
92 aos_status_t aos_queue_send(aos_queue_t *queue, void *msg, size_t size) in aos_queue_send()
102 aos_status_t aos_queue_recv(aos_queue_t *queue, uint32_t ms, void *msg, in aos_queue_recv()
116 bool aos_queue_is_valid(aos_queue_t *queue) in aos_queue_is_valid()
137 void *aos_queue_buf_ptr(aos_queue_t *queue) in aos_queue_buf_ptr()
146 aos_status_t aos_queue_get_count(aos_queue_t *queue) in aos_queue_get_count()
/AliOS-Things-master/components/SDL2/src/
A DSDL_dataqueue.c60 SDL_DataQueue *queue = (SDL_DataQueue *) SDL_malloc(sizeof (SDL_DataQueue)); in SDL_NewDataQueue() local
88 SDL_FreeDataQueue(SDL_DataQueue *queue) in SDL_FreeDataQueue()
98 SDL_ClearDataQueue(SDL_DataQueue *queue, const size_t slack) in SDL_ClearDataQueue()
141 AllocateDataQueuePacket(SDL_DataQueue *queue) in AllocateDataQueuePacket()
175 SDL_WriteToDataQueue(SDL_DataQueue *queue, const void *_data, const size_t _len) in SDL_WriteToDataQueue()
229 SDL_PeekIntoDataQueue(SDL_DataQueue *queue, void *_buf, const size_t _len) in SDL_PeekIntoDataQueue()
254 SDL_ReadFromDataQueue(SDL_DataQueue *queue, void *_buf, const size_t _len) in SDL_ReadFromDataQueue()
294 SDL_CountDataQueue(SDL_DataQueue *queue) in SDL_CountDataQueue()
300 SDL_ReserveSpaceInDataQueue(SDL_DataQueue *queue, const size_t len) in SDL_ReserveSpaceInDataQueue()
/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()
53 static inline void handle_poll_events(struct k_queue *queue, bt_u32_t state) in handle_poll_events()
58 void k_queue_cancel_wait(struct k_queue *queue) in k_queue_cancel_wait()
64 void k_queue_insert(struct k_queue *queue, void *prev, void *node) in k_queue_insert()
80 void k_queue_append(struct k_queue *queue, void *data) in k_queue_append()
85 void k_queue_prepend(struct k_queue *queue, void *data) in k_queue_prepend()
90 void k_queue_append_list(struct k_queue *queue, void *head, void *tail) in k_queue_append_list()
102 void *k_queue_get(struct k_queue *queue, int32_t timeout) in k_queue_get()
127 int k_queue_is_empty(struct k_queue *queue) in k_queue_is_empty()
132 int k_queue_count(struct k_queue *queue) in k_queue_count()
/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()
52 __STATIC __INLINE struct co_list_hdr *ke_queue_pop(struct co_list *const queue) in ke_queue_pop()
/AliOS-Things-master/components/SDL2/test/
A Dtestatomic.c297 static void InitEventQueue(SDL_EventQueue *queue) in InitEventQueue()
314 static SDL_bool EnqueueEvent_LockFree(SDL_EventQueue *queue, const SDL_Event *event) in EnqueueEvent_LockFree()
361 static SDL_bool DequeueEvent_LockFree(SDL_EventQueue *queue, SDL_Event *event) in DequeueEvent_LockFree()
408 static SDL_bool EnqueueEvent_Mutex(SDL_EventQueue *queue, const SDL_Event *event) in EnqueueEvent_Mutex()
441 static SDL_bool DequeueEvent_Mutex(SDL_EventQueue *queue, SDL_Event *event) in DequeueEvent_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
575 SDL_EventQueue *queue = (SDL_EventQueue *)_data; in FIFO_Watcher() local
[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()
86 static inline void dlist_add_tail(dlist_t *node, dlist_t *queue) in dlist_add_tail()
180 #define dlist_for_each_entry(queue, node, type, member) \ argument
194 #define dlist_for_each_entry_safe(queue, n, node, type, member) \ argument
228 static inline int dlist_entry_number(dlist_t *queue) in dlist_entry_number()
334 #define slist_for_each_entry(queue, node, type, member) \ argument
348 #define slist_for_each_entry_safe(queue, tmp, node, type, member) \ argument
394 static inline int slist_entry_number(slist_t *queue) in slist_entry_number()
/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()
85 static inline void dlist_add_tail(dlist_t *node, dlist_t *queue) in dlist_add_tail()
181 #define dlist_for_each_entry(queue, node, type, member) \ argument
194 #define dlist_for_each_entry_safe(queue, n, node, type, member) \ argument
225 static inline int dlist_entry_number(dlist_t *queue) in dlist_entry_number()
334 #define slist_for_each_entry(queue, node, type, member) \ argument
348 #define slist_for_each_entry_safe(queue, tmp, node, type, member) \ argument
396 static inline int slist_entry_number(slist_t *queue) in slist_entry_number()
/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()
86 static inline void dlist_add_tail(dlist_t *node, dlist_t *queue) in dlist_add_tail()
180 #define dlist_for_each_entry(queue, node, type, member) \ argument
194 #define dlist_for_each_entry_safe(queue, n, node, type, member) \ argument
228 static inline int dlist_entry_number(dlist_t *queue) in dlist_entry_number()
334 #define slist_for_each_entry(queue, node, type, member) \ argument
348 #define slist_for_each_entry_safe(queue, tmp, node, type, member) \ argument
394 static inline int slist_entry_number(slist_t *queue) in slist_entry_number()
/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()
62 static inline void dlist_add_tail(dlist_t *node, dlist_t *queue) in dlist_add_tail()
140 #define dlist_for_each_entry(queue, node, type, member) \ argument
154 #define dlist_for_each_entry_safe(queue, n, node, type, member) \ argument
185 static inline int __dlist_entry_number(dlist_t *queue) in __dlist_entry_number()
269 #define slist_for_each_entry(queue, node, type, member) \ argument
283 #define slist_for_each_entry_safe(queue, tmp, node, type, member) \ argument
330 static inline int slist_entry_number(slist_t *queue) in slist_entry_number()
/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()
69 static inline void dlist_add_tail(dlist_t *node, dlist_t *queue) in dlist_add_tail()
144 #define dlist_for_each_entry(queue, node, type, member) \ argument
158 #define dlist_for_each_entry_safe(queue, n, node, type, member) \ argument
289 #define slist_for_each_entry(queue, node, type, member) \ argument
303 #define slist_for_each_entry_safe(queue, tmp, node, type, member) \ argument
/AliOS-Things-master/components/amp_adapter/platform/linux/
A Daos_system.c226 struct queue { struct
233 aos_status_t aos_queue_new(aos_queue_t *queue, void *buf, size_t size, size_t max_msg) in aos_queue_new()
244 void aos_queue_free(aos_queue_t *queue) in aos_queue_free()
252 aos_status_t aos_queue_send(aos_queue_t *queue, void *msg, size_t size) in aos_queue_send()
259 aos_status_t aos_queue_recv(aos_queue_t *queue, uint32_t ms, void *msg, size_t *size) in aos_queue_recv()
277 bool aos_queue_is_valid(aos_queue_t *queue) in aos_queue_is_valid()
A Daos_ota.c43 int ota_register_module_store(ota_service_t *ctx, ota_store_module_info_t *queue, int queue_len) in ota_register_module_store()
/AliOS-Things-master/components/ble_host/ble_profiles/
A Duart_client.c156 static bool is_dev_data_queue_empty(dev_data_queue *queue) in is_dev_data_queue_empty()
161 static bool is_dev_data_queue_full(dev_data_queue *queue) in is_dev_data_queue_full()
170 static report_dev *get_dev_data(dev_data_queue *queue) in get_dev_data()
182 static int put_dev_data(dev_data_queue *queue, dev_addr_t *dev) in put_dev_data()
/AliOS-Things-master/components/mbedtls/include/mbedtls/
A Dpoly1305.h66 uint8_t queue[16]; /** The current partial block of data. */ member
/AliOS-Things-master/solutions/tflite_micro_speech_demo/micro_speech/
A Drecognize_commands_test.cc26 PreviousResultsQueue queue(&micro_error_reporter); in TF_LITE_MICRO_TEST() local
57 PreviousResultsQueue queue(&micro_error_reporter); in TF_LITE_MICRO_TEST() local
/AliOS-Things-master/components/ble_host/include/
A Dwork.h16 struct k_queue queue; member
A Dble_os_port.h107 struct k_queue *queue; member
338 static inline bool k_queue_remove(struct k_queue *queue, void *data) in k_queue_remove()
343 static inline void *k_queue_first_entry(struct k_queue *queue) in k_queue_first_entry()
/AliOS-Things-master/components/py_engine/external/amp_task/
A Damp_task.c26 static void queue_deinit(aos_queue_t *queue) in queue_deinit()
/AliOS-Things-master/components/ble_mesh/bt_mesh/mesh_node/
A Dmesh_node.c462 static bool is_rssi_data_queue_empty(rssi_data_queue *queue) in is_rssi_data_queue_empty()
467 static bool is_rssi_data_queue_full(rssi_data_queue *queue) in is_rssi_data_queue_full()
476 static beacon_rssi_data *get_rssi_data(rssi_data_queue *queue) in get_rssi_data()
487 static int put_rssi_data(rssi_data_queue *queue, const uint8_t *mac, int8_t rssi, int8_t rssi_calib… in put_rssi_data()
/AliOS-Things-master/components/uvoice/internal/
A Duvoice_linux.h231 static inline int os_queue_send(os_queue_t *queue, void *msg, unsigned int size) in os_queue_send()
236 static inline int os_queue_recv(os_queue_t *queue, unsigned int ms, void *msg, in os_queue_recv()
242 static inline int os_queue_new(os_queue_t *queue, void *buffer, unsigned int size, int msg_size) in os_queue_new()
247 static inline void os_queue_free(os_queue_t *queue) in os_queue_free()
/AliOS-Things-master/hardware/chip/rtl872xd/aos/
A Daos_osdep.c296 static int _aos_init_xqueue( _xqueue* queue, const char* name, u32 message_size, u32 number_of_mess… in _aos_init_xqueue()
303 static int _aos_push_to_xqueue( _xqueue* queue, void* message, u32 timeout_ms ) in _aos_push_to_xqueue()
310 static int _aos_pop_from_xqueue( _xqueue* queue, void* message, u32 timeout_ms ) in _aos_pop_from_xqueue()
318 static int _aos_deinit_xqueue( _xqueue* queue ) in _aos_deinit_xqueue()

Completed in 36 milliseconds

12