Lines Matching refs:kbuf_queue_t
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()
36 real_buf = (buf == NULL) ? ((void *)q + sizeof(kbuf_queue_t)) : buf; 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()
98 ret = krhino_buf_queue_send((kbuf_queue_t *)*queue, msg, size); in aos_queue_send()
109 ret = krhino_buf_queue_recv((kbuf_queue_t *)*queue, RHINO_WAIT_FOREVER, msg, size); in aos_queue_recv()
111 ret = krhino_buf_queue_recv((kbuf_queue_t *)*queue, MS2TICK(ms), msg, size); in aos_queue_recv()
118 kbuf_queue_t *k_queue; in aos_queue_is_valid()
124 k_queue = (kbuf_queue_t *)*queue; in aos_queue_is_valid()
143 return ((kbuf_queue_t *)*queue)->buf; in aos_queue_buf_ptr()
150 kstat_t ret = krhino_buf_queue_info_get((kbuf_queue_t *)*queue, &info); in aos_queue_get_count()