Lines Matching refs:data
219 static int ept_cb(struct rpmsg_endpoint *ep, void *data, size_t len, uint32_t src, void *priv) in ept_cb() argument
246 ept->cb->received(data, len, ept->priv); in ept_cb()
308 struct backend_data_t *data; in mbox_callback_process() local
311 data = CONTAINER_OF(item, struct backend_data_t, mbox_work); in mbox_callback_process()
312 vq_id = (data->role == ROLE_HOST) ? VIRTQUEUE_ID_HOST : VIRTQUEUE_ID_REMOTE; in mbox_callback_process()
314 virtqueue_notification(data->vr.vq[vq_id]); in mbox_callback_process()
320 struct backend_data_t *data = user_data; in mbox_callback() local
322 k_work_submit_to_queue(&data->mbox_wq, &data->mbox_work); in mbox_callback()
328 struct backend_data_t *data = instance->data; in mbox_init() local
335 k_work_queue_init(&data->mbox_wq); in mbox_init()
336 k_work_queue_start(&data->mbox_wq, mbox_stack[conf->id], WQ_STACK_SIZE, prio, &wq_cfg); in mbox_init()
342 k_thread_name_set(&data->mbox_wq.thread, name); in mbox_init()
345 k_work_init(&data->mbox_work, mbox_callback_process); in mbox_init()
347 err = mbox_register_callback_dt(&conf->mbox_rx, mbox_callback, data); in mbox_init()
358 struct backend_data_t *data = instance->data; in mbox_deinit() local
367 k_work_queue_drain(&data->mbox_wq, 1); in mbox_deinit()
369 wq_thread = k_work_queue_thread_get(&data->mbox_wq); in mbox_deinit()
444 struct backend_data_t *data = instance->data; in register_ept() local
449 if (atomic_get(&data->state) != STATE_INITED) { in register_ept()
458 rpmsg_inst = &data->rpmsg_inst; in register_ept()
460 rpmsg_ept = (data->role == ROLE_HOST) ? in register_ept()
474 struct backend_data_t *data = instance->data; in deregister_ept() local
479 if (atomic_get(&data->state) != STATE_INITED) { in deregister_ept()
495 k_work_flush(&data->mbox_work, &sync); in deregister_ept()
507 struct backend_data_t *data = instance->data; in send() local
512 if (atomic_get(&data->state) != STATE_INITED) { in send()
541 struct backend_data_t *data = instance->data; in send_nocopy() local
545 if (atomic_get(&data->state) != STATE_INITED) { in send_nocopy()
567 struct backend_data_t *data = instance->data; in open() local
572 if (!atomic_cas(&data->state, STATE_READY, STATE_BUSY)) { in open()
576 err = vr_shm_configure(&data->vr, conf); in open()
581 data->vr.notify_cb = virtio_notify_cb; in open()
582 data->vr.priv = (void *) conf; in open()
584 err = ipc_static_vrings_init(&data->vr, conf->role); in open()
594 rpmsg_inst = &data->rpmsg_inst; in open()
599 err = ipc_rpmsg_init(rpmsg_inst, data->role, conf->buffer_size, in open()
600 &data->vr.shm_io, &data->vr.vdev, in open()
601 (void *)data->vr.shm_addr, in open()
602 data->vr.shm_size, ns_bind_cb); in open()
609 data->tx_buffer_size = rpmsg_virtio_get_buffer_size(rdev); in open()
610 if (data->tx_buffer_size < 0) { in open()
615 atomic_set(&data->state, STATE_INITED); in open()
620 atomic_set(&data->state, STATE_READY); in open()
628 struct backend_data_t *data = instance->data; in close() local
632 if (!atomic_cas(&data->state, STATE_INITED, STATE_BUSY)) { in close()
636 rpmsg_inst = &data->rpmsg_inst; in close()
642 err = ipc_rpmsg_deinit(rpmsg_inst, data->role); in close()
652 err = ipc_static_vrings_deinit(&data->vr, conf->role); in close()
657 memset(&data->vr, 0, sizeof(struct ipc_static_vrings)); in close()
660 atomic_set(&data->state, STATE_READY); in close()
665 atomic_set(&data->state, STATE_INITED); in close()
671 struct backend_data_t *data = instance->data; in get_tx_buffer_size() local
673 return data->tx_buffer_size; in get_tx_buffer_size()
679 struct backend_data_t *data = instance->data; in get_tx_buffer() local
700 if ((*size) && (*size > data->tx_buffer_size)) { in get_tx_buffer()
702 *size = data->tx_buffer_size; in get_tx_buffer()
726 void *data) in hold_rx_buffer() argument
737 rpmsg_hold_rx_buffer(&rpmsg_ept->ep, data); in hold_rx_buffer()
743 void *data) in release_rx_buffer() argument
754 rpmsg_release_rx_buffer(&rpmsg_ept->ep, data); in release_rx_buffer()
760 const void *data) in drop_tx_buffer() argument
783 struct backend_data_t *data = instance->data; in backend_init() local
785 data->role = conf->role; in backend_init()
796 k_mutex_init(&data->rpmsg_inst.mtx); in backend_init()
797 atomic_set(&data->state, STATE_READY); in backend_init()