Lines Matching refs:write_ptr
51 msgq->write_ptr = buffer; in k_msgq_init()
154 __ASSERT_NO_MSG(msgq->write_ptr >= msgq->buffer_start && in z_impl_k_msgq_put()
155 msgq->write_ptr < msgq->buffer_end); in z_impl_k_msgq_put()
156 (void)memcpy(msgq->write_ptr, (char *)data, msgq->msg_size); in z_impl_k_msgq_put()
157 msgq->write_ptr += msgq->msg_size; in z_impl_k_msgq_put()
158 if (msgq->write_ptr == msgq->buffer_end) { in z_impl_k_msgq_put()
159 msgq->write_ptr = msgq->buffer_start; in z_impl_k_msgq_put()
248 __ASSERT_NO_MSG(msgq->write_ptr >= msgq->buffer_start && in z_impl_k_msgq_get()
249 msgq->write_ptr < msgq->buffer_end); in z_impl_k_msgq_get()
250 (void)memcpy(msgq->write_ptr, (char *)pending_thread->base.swap_data, in z_impl_k_msgq_get()
252 msgq->write_ptr += msgq->msg_size; in z_impl_k_msgq_get()
253 if (msgq->write_ptr == msgq->buffer_end) { in z_impl_k_msgq_get()
254 msgq->write_ptr = msgq->buffer_start; in z_impl_k_msgq_get()
401 msgq->read_ptr = msgq->write_ptr; in z_impl_k_msgq_purge()