Lines Matching refs:write_ptr
51 msgq->write_ptr = buffer; in k_msgq_init()
156 __ASSERT_NO_MSG(msgq->write_ptr >= msgq->buffer_start && in put_msg_in_queue()
157 msgq->write_ptr < msgq->buffer_end); in put_msg_in_queue()
163 (void)memcpy(msgq->write_ptr, (char *)data, msgq->msg_size); in put_msg_in_queue()
164 msgq->write_ptr += msgq->msg_size; in put_msg_in_queue()
165 if (msgq->write_ptr == msgq->buffer_end) { in put_msg_in_queue()
166 msgq->write_ptr = msgq->buffer_start; in put_msg_in_queue()
302 __ASSERT_NO_MSG(msgq->write_ptr >= msgq->buffer_start && in z_impl_k_msgq_get()
303 msgq->write_ptr < msgq->buffer_end); in z_impl_k_msgq_get()
304 (void)memcpy(msgq->write_ptr, (char *)pending_thread->base.swap_data, in z_impl_k_msgq_get()
306 msgq->write_ptr += msgq->msg_size; in z_impl_k_msgq_get()
307 if (msgq->write_ptr == msgq->buffer_end) { in z_impl_k_msgq_get()
308 msgq->write_ptr = msgq->buffer_start; in z_impl_k_msgq_get()
455 msgq->read_ptr = msgq->write_ptr; in z_impl_k_msgq_purge()