mirrors/linux
1
0
Fork 0
mirror of https://git.kernel.org/pub/scm/linux/kernel/git/torvalds/linux.git synced 2026-05-05 19:24:01 -04:00
Code Issues Packages Projects Releases Wiki Activity

staging: vc04_services: Simplify block bulk transfer code paths

Browse Source 
Blocking bulk transfer functions tend to open-code every function
parameter needed to initiate the bulk transfer. Instead of doing
that, simply pass a populated struct vchiq_bulk down the function
chain.

Signed-off-by: Umang Jain <umang.jain@ideasonboard.com>
Link: https://lore.kernel.org/r/20241017133629.216672-4-umang.jain@ideasonboard.com
Signed-off-by: Greg Kroah-Hartman <gregkh@linuxfoundation.org>
This commit is contained in:
Umang Jain
2024-10-17 19:06:26 +05:30
committed by Greg Kroah-Hartman
parent 53cc1e2549
commit 72406c8a7a
4 changed files with 37 additions and 23 deletions
Download Patch File Download Diff File Expand all files Collapse all files

34
drivers/staging/vc04_services/interface/vchiq_arm/vchiq_arm.c
View File

@@ -107,8 +107,8 @@ struct vchiq_arm_state {
};
static int
vchiq_blocking_bulk_transfer(struct vchiq_instance *instance, unsigned int handle, void *data,
unsigned int size, enum vchiq_bulk_dir dir);
vchiq_blocking_bulk_transfer(struct vchiq_instance *instance, unsigned int handle,
struct vchiq_bulk *bulk_params);
static irqreturn_t
vchiq_doorbell_irq(int irq, void *dev_id)
@@ -491,6 +491,7 @@ int
vchiq_bulk_transmit(struct vchiq_instance *instance, unsigned int handle, const void *data,
unsigned int size, void *userdata, enum vchiq_bulk_mode mode)
{
struct vchiq_bulk bulk_params = {};
int ret;
switch (mode) {
@@ -501,8 +502,12 @@ vchiq_bulk_transmit(struct vchiq_instance *instance, unsigned int handle, const
VCHIQ_BULK_TRANSMIT);
break;
case VCHIQ_BULK_MODE_BLOCKING:
ret = vchiq_blocking_bulk_transfer(instance, handle, (void *)data, size,
VCHIQ_BULK_TRANSMIT);
bulk_params.offset = (void *)data;
bulk_params.mode = mode;
bulk_params.size = size;
bulk_params.dir = VCHIQ_BULK_TRANSMIT;
ret = vchiq_blocking_bulk_transfer(instance, handle, &bulk_params);
break;
default:
return -EINVAL;
@@ -516,6 +521,7 @@ int vchiq_bulk_receive(struct vchiq_instance *instance, unsigned int handle,
void *data, unsigned int size, void *userdata,
enum vchiq_bulk_mode mode)
{
struct vchiq_bulk bulk_params = {};
int ret;
switch (mode) {
@@ -525,8 +531,12 @@ int vchiq_bulk_receive(struct vchiq_instance *instance, unsigned int handle,
size, mode, userdata, VCHIQ_BULK_RECEIVE);
break;
case VCHIQ_BULK_MODE_BLOCKING:
ret = vchiq_blocking_bulk_transfer(instance, handle, (void *)data, size,
VCHIQ_BULK_RECEIVE);
bulk_params.offset = (void *)data;
bulk_params.mode = mode;
bulk_params.size = size;
bulk_params.dir = VCHIQ_BULK_RECEIVE;
ret = vchiq_blocking_bulk_transfer(instance, handle, &bulk_params);
break;
default:
return -EINVAL;
@@ -537,8 +547,8 @@ int vchiq_bulk_receive(struct vchiq_instance *instance, unsigned int handle,
EXPORT_SYMBOL(vchiq_bulk_receive);
static int
vchiq_blocking_bulk_transfer(struct vchiq_instance *instance, unsigned int handle, void *data,
unsigned int size, enum vchiq_bulk_dir dir)
vchiq_blocking_bulk_transfer(struct vchiq_instance *instance, unsigned int handle,
struct vchiq_bulk *bulk_params)
{
struct vchiq_service *service;
struct bulk_waiter_node *waiter = NULL, *iter;
@@ -566,7 +576,8 @@ vchiq_blocking_bulk_transfer(struct vchiq_instance *instance, unsigned int handl
if (bulk) {
/* This thread has an outstanding bulk transfer. */
/* FIXME: why compare a dma address to a pointer? */
if ((bulk->data != (dma_addr_t)(uintptr_t)data) || (bulk->size != size)) {
if ((bulk->data != (dma_addr_t)(uintptr_t)bulk_params->data) ||
(bulk->size != bulk_params->size)) {
/*
* This is not a retry of the previous one.
* Cancel the signal when the transfer completes.
@@ -582,8 +593,9 @@ vchiq_blocking_bulk_transfer(struct vchiq_instance *instance, unsigned int handl
return -ENOMEM;
}
ret = vchiq_bulk_xfer_blocking(instance, handle, data, NULL, size,
&waiter->bulk_waiter, dir);
bulk_params->userdata = &waiter->bulk_waiter;
ret = vchiq_bulk_xfer_blocking(instance, handle, bulk_params);
if ((ret != -EAGAIN) || fatal_signal_pending(current) || !waiter->bulk_waiter.bulk) {
struct vchiq_bulk *bulk = waiter->bulk_waiter.bulk;

12
drivers/staging/vc04_services/interface/vchiq_arm/vchiq_core.c
View File

@@ -3471,11 +3471,9 @@ vchiq_remove_service(struct vchiq_instance *instance, unsigned int handle)
int
vchiq_bulk_xfer_blocking(struct vchiq_instance *instance, unsigned int handle,
void *offset, void __user *uoffset, int size,
void __user *userdata, enum vchiq_bulk_dir dir)
struct vchiq_bulk *bulk_params)
{
struct vchiq_service *service = find_service_by_handle(instance, handle);
enum vchiq_bulk_mode mode = VCHIQ_BULK_MODE_BLOCKING;
int status = -EINVAL;
if (!service)
@@ -3484,15 +3482,17 @@ vchiq_bulk_xfer_blocking(struct vchiq_instance *instance, unsigned int handle,
if (service->srvstate != VCHIQ_SRVSTATE_OPEN)
goto error_exit;
if (!offset && !uoffset)
if (!bulk_params->offset && !bulk_params->uoffset)
goto error_exit;
if (vchiq_check_service(service))
goto error_exit;
status = vchiq_bulk_xfer_queue_msg_killable(service, offset, uoffset, size,
userdata, mode, dir);
status = vchiq_bulk_xfer_queue_msg_killable(service, bulk_params->offset,
bulk_params->uoffset, bulk_params->size,
bulk_params->userdata, bulk_params->mode,
bulk_params->dir);
error_exit:
vchiq_service_put(service);

3
drivers/staging/vc04_services/interface/vchiq_arm/vchiq_core.h
View File

@@ -501,8 +501,7 @@ vchiq_bulk_xfer_waiting(struct vchiq_instance *instance, unsigned int handle,
extern int
vchiq_bulk_xfer_blocking(struct vchiq_instance *instance, unsigned int handle,
void *offset, void __user *uoffset, int size,
void __user *userdata, enum vchiq_bulk_dir dir);
struct vchiq_bulk *bulk);
extern int
vchiq_bulk_xfer_callback(struct vchiq_instance *instance, unsigned int handle,

11
drivers/staging/vc04_services/interface/vchiq_arm/vchiq_dev.c
View File

@@ -288,6 +288,7 @@ static int vchiq_irq_queue_bulk_tx_rx(struct vchiq_instance *instance,
{
struct vchiq_service *service;
struct bulk_waiter_node *waiter = NULL, *iter;
struct vchiq_bulk bulk_params = {};
void *userdata;
int status = 0;
int ret;
@@ -303,12 +304,14 @@ static int vchiq_irq_queue_bulk_tx_rx(struct vchiq_instance *instance,
goto out;
}
userdata = &waiter->bulk_waiter;
bulk_params.uoffset = args->data;
bulk_params.mode = args->mode;
bulk_params.size = args->size;
bulk_params.dir = dir;
bulk_params.userdata = &waiter->bulk_waiter;
status = vchiq_bulk_xfer_blocking(instance, args->handle,
NULL, args->data, args->size,
userdata, dir);
&bulk_params);
} else if (args->mode == VCHIQ_BULK_MODE_WAITING) {
mutex_lock(&instance->bulk_waiter_list_mutex);
list_for_each_entry(iter, &instance->bulk_waiter_list,