Lines Matching refs:msg_q
36 queue->msg_q.queue_start = start; in queue_create()
41 queue->msg_q.size = msg_num; in queue_create()
42 queue->msg_q.cur_num = 0u; in queue_create()
43 queue->msg_q.peak_num = 0u; in queue_create()
179 krhino_mm_free(queue->msg_q.queue_start); in krhino_queue_dyn_del()
200 if (p_q->msg_q.cur_num >= p_q->msg_q.size) { in msg_send()
209 p_q->msg_q.cur_num++; in msg_send()
212 if (p_q->msg_q.cur_num > p_q->msg_q.peak_num) { in msg_send()
213 p_q->msg_q.peak_num = p_q->msg_q.cur_num; in msg_send()
273 if (queue->msg_q.cur_num > 0u) { in krhino_queue_recv()
277 queue->msg_q.cur_num--; in krhino_queue_recv()
336 if (queue->msg_q.cur_num >= queue->msg_q.size) { in krhino_queue_is_full()
362 queue->msg_q.cur_num = 0u; in krhino_queue_flush()
395 info->msg_q.peak_num = queue->msg_q.peak_num; in krhino_queue_info_get()
396 info->msg_q.cur_num = queue->msg_q.cur_num; in krhino_queue_info_get()
397 info->msg_q.queue_start = queue->msg_q.queue_start; in krhino_queue_info_get()
398 info->msg_q.size = queue->msg_q.size; in krhino_queue_info_get()