| /AliOS-Things-master/components/osal_aos/rhino/ |
| A D | aos_queue.c | 23 kbuf_queue_t *q; in aos_queue_new()
31 malloc_len = sizeof(kbuf_queue_t) + ((buf == NULL) ? size : 0); in aos_queue_new()
32 q = (kbuf_queue_t *)aos_malloc(malloc_len); in aos_queue_new()
52 kbuf_queue_t *q; in aos_queue_create()
61 malloc_len = sizeof(kbuf_queue_t) + size; in aos_queue_create()
62 q = (kbuf_queue_t *)aos_malloc(malloc_len); in aos_queue_create()
66 real_buf = (void *)q + sizeof(kbuf_queue_t); in aos_queue_create()
85 krhino_buf_queue_del((kbuf_queue_t *)*queue); in aos_queue_free()
118 kbuf_queue_t *k_queue; in aos_queue_is_valid()
124 k_queue = (kbuf_queue_t *)*queue; in aos_queue_is_valid()
[all …]
|
| /AliOS-Things-master/kernel/rhino/include/ |
| A D | k_buf_queue.h | 39 } kbuf_queue_t; typedef
64 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);
[all …]
|
| A D | k_trace.h | 150 void trace_buf_queue_create(ktask_t *task, kbuf_queue_t *buf_queue);
151 void trace_buf_queue_max(ktask_t *task, kbuf_queue_t *buf_queue, void *msg, size_t msg_size);
152 void trace_buf_queue_post(ktask_t *task, kbuf_queue_t *buf_queue, void *msg, size_t msg_size);
153 void trace_buf_queue_task_wake(ktask_t *task, ktask_t *task_waked_up, kbuf_queue_t *buf_queue);
154 void trace_buf_queue_get_blk(ktask_t *task, kbuf_queue_t *buf_queue, tick_t wait_option);
|
| A D | k_internal.h | 56 extern kbuf_queue_t g_timer_queue;
|
| /AliOS-Things-master/kernel/rhino/ |
| A D | k_buf_queue.c | 28 memset(queue, 0, sizeof(kbuf_queue_t)); in buf_queue_create()
59 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()
117 kbuf_queue_t *queue_obj; in buf_queue_dyn_create()
125 queue_obj = krhino_mm_alloc(sizeof(kbuf_queue_t)); 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()
166 kstat_t krhino_buf_queue_dyn_del(kbuf_queue_t *queue) in krhino_buf_queue_dyn_del()
283 kstat_t krhino_buf_queue_send(kbuf_queue_t *queue, void *msg, size_t size) in krhino_buf_queue_send()
[all …]
|
| A D | k_obj.c | 44 kbuf_queue_t g_timer_queue;
|
| /AliOS-Things-master/components/posix/src/ |
| A D | mqueue.c | 12 kbuf_queue_t *mq; in mq_open()
46 ret = krhino_buf_queue_send((kbuf_queue_t *)mqdes, (void *)msg_ptr, msg_len); in mq_send()
91 ret = krhino_buf_queue_send((kbuf_queue_t *)mqdes, (void *)msg_ptr, msg_len); in mq_timedsend()
|
| /AliOS-Things-master/components/cplusplus/include/ |
| A D | cpp_queue.h | 79 kbuf_queue_t *self(void);
85 kbuf_queue_t _buf_queue_def;
|
| /AliOS-Things-master/components/trace/ |
| A D | k_trace.c | 213 void trace_buf_queue_create(ktask_t *task, kbuf_queue_t *buf_queue) in trace_buf_queue_create()
218 void trace_buf_queue_max(ktask_t *task, kbuf_queue_t *buf_queue, void *msg, size_t msg_size) in trace_buf_queue_max()
223 void trace_buf_queue_post(ktask_t *task, kbuf_queue_t *buf_queue, void *msg, size_t msg_size) in trace_buf_queue_post()
228 void trace_buf_queue_task_wake(ktask_t *task, ktask_t *task_waked_up, kbuf_queue_t *buf_queue) in trace_buf_queue_task_wake()
233 void trace_buf_queue_get_blk(ktask_t *task, kbuf_queue_t *buf_queue, tick_t wait_option) in trace_buf_queue_get_blk()
|
| /AliOS-Things-master/components/py_engine/adapter/haas/ |
| A D | modipc.c | 18 kbuf_queue_t* queue;
39 kbuf_queue_t *queue;
|
| /AliOS-Things-master/components/py_engine/adapter/haas510/ |
| A D | modipc.c | 18 kbuf_queue_t* queue;
39 kbuf_queue_t *queue;
|
| /AliOS-Things-master/components/py_engine/adapter/haas600/ |
| A D | modipc.c | 18 kbuf_queue_t* queue;
39 kbuf_queue_t *queue;
|
| /AliOS-Things-master/components/cplusplus/ |
| A D | queue.cpp | 91 kbuf_queue_t *Queue::self(void) in self()
|
| /AliOS-Things-master/hardware/chip/smarth_rv64/hal/ |
| A D | uart.c | 11 kbuf_queue_t g_buf_queue_uart;
|
| /AliOS-Things-master/hardware/chip/rtl872xd/aos/ |
| A D | aos_osdep.h | 98 typedef kbuf_queue_t _xqueue;
|
| /AliOS-Things-master/hardware/chip/haas1000/drivers/rtos/rhino/cmsis/ |
| A D | cmsis_os.h | 194 typedef kbuf_queue_t *osMessageQId;
253 kbuf_queue_t *queue;
|
| /AliOS-Things-master/components/debug/src/ |
| A D | debug_overview.c | 196 kbuf_queue_t *buf_queue; in debug_buf_queue_overview()
210 buf_queue = krhino_list_entry(listnode, kbuf_queue_t, buf_queue_item); in debug_buf_queue_overview()
|
| /AliOS-Things-master/components/ble_host/include/ |
| A D | ble_os_port.h | 289 typedef kbuf_queue_t _queue_t;
|
| /AliOS-Things-master/hardware/chip/smarth_rv64/smarth_rv64/ |
| A D | ck_usart.c | 342 extern kbuf_queue_t g_buf_queue_uart;
|
| /AliOS-Things-master/components/netmgr/src/ |
| A D | netmgr_wifi.c | 2656 kbuf_queue_t *send_queue = NULL; in wifi_msg_cb()
2657 kbuf_queue_t *recv_queue = NULL; in wifi_msg_cb()
3291 kbuf_queue_t *send_queue = NULL;
3292 kbuf_queue_t *recv_queue = NULL;
|
| /AliOS-Things-master/hardware/board/c906/adapter/ |
| A D | csi_rhino.c | 1091 kbuf_queue_t *buf_q;
|