Commit 56df512e authored by Stefan Wahren's avatar Stefan Wahren Committed by Greg Kroah-Hartman
Browse files

staging: vchiq_arm: Unify return code variable



The file vchiq_arm uses a wild mixture of variable names for
return codes. Unify them by using the common name "ret".

Signed-off-by: default avatarStefan Wahren <wahrenst@gmx.net>
Reviewed-by: default avatarLaurent Pinchart <laurent.pinchart@ideasonboard.com>
Link: https://lore.kernel.org/r/20240621131958.98208-2-wahrenst@gmx.net


Signed-off-by: default avatarGreg Kroah-Hartman <gregkh@linuxfoundation.org>
parent 13cc0956
Loading
Loading
Loading
Loading
+69 −72
Original line number Diff line number Diff line
@@ -758,8 +758,8 @@ void free_bulk_waiter(struct vchiq_instance *instance)

int vchiq_shutdown(struct vchiq_instance *instance)
{
	int status = 0;
	struct vchiq_state *state = instance->state;
	int ret = 0;

	if (mutex_lock_killable(&state->mutex))
		return -EAGAIN;
@@ -769,12 +769,12 @@ int vchiq_shutdown(struct vchiq_instance *instance)

	mutex_unlock(&state->mutex);

	dev_dbg(state->dev, "core: (%p): returning %d\n", instance, status);
	dev_dbg(state->dev, "core: (%p): returning %d\n", instance, ret);

	free_bulk_waiter(instance);
	kfree(instance);

	return status;
	return ret;
}
EXPORT_SYMBOL(vchiq_shutdown);

@@ -785,26 +785,26 @@ static int vchiq_is_connected(struct vchiq_instance *instance)

int vchiq_connect(struct vchiq_instance *instance)
{
	int status;
	struct vchiq_state *state = instance->state;
	int ret;

	if (mutex_lock_killable(&state->mutex)) {
		dev_dbg(state->dev,
			"core: call to mutex_lock failed\n");
		status = -EAGAIN;
		ret = -EAGAIN;
		goto failed;
	}
	status = vchiq_connect_internal(state, instance);
	ret = vchiq_connect_internal(state, instance);

	if (!status)
	if (!ret)
		instance->connected = 1;

	mutex_unlock(&state->mutex);

failed:
	dev_dbg(state->dev, "core: (%p): returning %d\n", instance, status);
	dev_dbg(state->dev, "core: (%p): returning %d\n", instance, ret);

	return status;
	return ret;
}
EXPORT_SYMBOL(vchiq_connect);

@@ -813,10 +813,9 @@ vchiq_add_service(struct vchiq_instance *instance,
		  const struct vchiq_service_params_kernel *params,
		  unsigned int *phandle)
{
	int status;
	struct vchiq_state *state = instance->state;
	struct vchiq_service *service = NULL;
	int srvstate;
	int srvstate, ret;

	*phandle = VCHIQ_SERVICE_HANDLE_INVALID;

@@ -828,14 +827,14 @@ vchiq_add_service(struct vchiq_instance *instance,

	if (service) {
		*phandle = service->handle;
		status = 0;
		ret = 0;
	} else {
		status = -EINVAL;
		ret = -EINVAL;
	}

	dev_dbg(state->dev, "core: (%p): returning %d\n", instance, status);
	dev_dbg(state->dev, "core: (%p): returning %d\n", instance, ret);

	return status;
	return ret;
}

int
@@ -843,9 +842,9 @@ vchiq_open_service(struct vchiq_instance *instance,
		   const struct vchiq_service_params_kernel *params,
		   unsigned int *phandle)
{
	int status = -EINVAL;
	struct vchiq_state   *state = instance->state;
	struct vchiq_service *service = NULL;
	int ret = -EINVAL;

	*phandle = VCHIQ_SERVICE_HANDLE_INVALID;

@@ -856,17 +855,17 @@ vchiq_open_service(struct vchiq_instance *instance,

	if (service) {
		*phandle = service->handle;
		status = vchiq_open_service_internal(service, current->pid);
		if (status) {
		ret = vchiq_open_service_internal(service, current->pid);
		if (ret) {
			vchiq_remove_service(instance, service->handle);
			*phandle = VCHIQ_SERVICE_HANDLE_INVALID;
		}
	}

failed:
	dev_dbg(state->dev, "core: (%p): returning %d\n", instance, status);
	dev_dbg(state->dev, "core: (%p): returning %d\n", instance, ret);

	return status;
	return ret;
}
EXPORT_SYMBOL(vchiq_open_service);

@@ -874,19 +873,19 @@ int
vchiq_bulk_transmit(struct vchiq_instance *instance, unsigned int handle, const void *data,
		    unsigned int size, void *userdata, enum vchiq_bulk_mode mode)
{
	int status;
	int ret;

	while (1) {
		switch (mode) {
		case VCHIQ_BULK_MODE_NOCALLBACK:
		case VCHIQ_BULK_MODE_CALLBACK:
			status = vchiq_bulk_transfer(instance, handle,
			ret = vchiq_bulk_transfer(instance, handle,
						  (void *)data, NULL,
						  size, userdata, mode,
						  VCHIQ_BULK_TRANSMIT);
			break;
		case VCHIQ_BULK_MODE_BLOCKING:
			status = vchiq_blocking_bulk_transfer(instance, handle, (void *)data, size,
			ret = vchiq_blocking_bulk_transfer(instance, handle, (void *)data, size,
							   VCHIQ_BULK_TRANSMIT);
			break;
		default:
@@ -898,13 +897,13 @@ vchiq_bulk_transmit(struct vchiq_instance *instance, unsigned int handle, const
		 * to implement a retry mechanism since this function is
		 * supposed to block until queued
		 */
		if (status != -EAGAIN)
		if (ret != -EAGAIN)
			break;

		msleep(1);
	}

	return status;
	return ret;
}
EXPORT_SYMBOL(vchiq_bulk_transmit);

@@ -912,18 +911,18 @@ int vchiq_bulk_receive(struct vchiq_instance *instance, unsigned int handle,
		       void *data, unsigned int size, void *userdata,
		       enum vchiq_bulk_mode mode)
{
	int status;
	int ret;

	while (1) {
		switch (mode) {
		case VCHIQ_BULK_MODE_NOCALLBACK:
		case VCHIQ_BULK_MODE_CALLBACK:
			status = vchiq_bulk_transfer(instance, handle, data, NULL,
			ret = vchiq_bulk_transfer(instance, handle, data, NULL,
						  size, userdata,
						  mode, VCHIQ_BULK_RECEIVE);
			break;
		case VCHIQ_BULK_MODE_BLOCKING:
			status = vchiq_blocking_bulk_transfer(instance, handle, (void *)data, size,
			ret = vchiq_blocking_bulk_transfer(instance, handle, (void *)data, size,
							   VCHIQ_BULK_RECEIVE);
			break;
		default:
@@ -935,13 +934,13 @@ int vchiq_bulk_receive(struct vchiq_instance *instance, unsigned int handle,
		 * to implement a retry mechanism since this function is
		 * supposed to block until queued
		 */
		if (status != -EAGAIN)
		if (ret != -EAGAIN)
			break;

		msleep(1);
	}

	return status;
	return ret;
}
EXPORT_SYMBOL(vchiq_bulk_receive);

@@ -950,8 +949,8 @@ vchiq_blocking_bulk_transfer(struct vchiq_instance *instance, unsigned int handl
			     unsigned int size, enum vchiq_bulk_dir dir)
{
	struct vchiq_service *service;
	int status;
	struct bulk_waiter_node *waiter = NULL, *iter;
	int ret;

	service = find_service_by_handle(instance, handle);
	if (!service)
@@ -991,10 +990,10 @@ vchiq_blocking_bulk_transfer(struct vchiq_instance *instance, unsigned int handl
			return -ENOMEM;
	}

	status = vchiq_bulk_transfer(instance, handle, data, NULL, size,
	ret = vchiq_bulk_transfer(instance, handle, data, NULL, size,
				  &waiter->bulk_waiter,
				  VCHIQ_BULK_MODE_BLOCKING, dir);
	if ((status != -EAGAIN) || fatal_signal_pending(current) || !waiter->bulk_waiter.bulk) {
	if ((ret != -EAGAIN) || fatal_signal_pending(current) || !waiter->bulk_waiter.bulk) {
		struct vchiq_bulk *bulk = waiter->bulk_waiter.bulk;

		if (bulk) {
@@ -1013,7 +1012,7 @@ vchiq_blocking_bulk_transfer(struct vchiq_instance *instance, unsigned int handl
			waiter, current->pid);
	}

	return status;
	return ret;
}

static int
@@ -1137,17 +1136,17 @@ service_callback(struct vchiq_instance *instance, enum vchiq_reason reason,
			 */
			if ((user_service->message_available_pos -
				instance->completion_remove) < 0) {
				int status;
				int ret;

				dev_dbg(instance->state->dev,
					"arm: Inserting extra MESSAGE_AVAILABLE\n");
				DEBUG_TRACE(SERVICE_CALLBACK_LINE);
				status = add_completion(instance, reason, NULL, user_service,
				ret = add_completion(instance, reason, NULL, user_service,
						     bulk_userdata);
				if (status) {
				if (ret) {
					DEBUG_TRACE(SERVICE_CALLBACK_LINE);
					vchiq_service_put(service);
					return status;
					return ret;
				}
			}

@@ -1294,8 +1293,6 @@ vchiq_keepalive_thread_func(void *v)
{
	struct vchiq_state *state = (struct vchiq_state *)v;
	struct vchiq_arm_state *arm_state = vchiq_platform_get_arm_state(state);

	int status;
	struct vchiq_instance *instance;
	unsigned int ka_handle;
	int ret;
@@ -1313,16 +1310,16 @@ vchiq_keepalive_thread_func(void *v)
		goto exit;
	}

	status = vchiq_connect(instance);
	if (status) {
		dev_err(state->dev, "suspend: %s: vchiq_connect failed %d\n", __func__, status);
	ret = vchiq_connect(instance);
	if (ret) {
		dev_err(state->dev, "suspend: %s: vchiq_connect failed %d\n", __func__, ret);
		goto shutdown;
	}

	status = vchiq_add_service(instance, &params, &ka_handle);
	if (status) {
	ret = vchiq_add_service(instance, &params, &ka_handle);
	if (ret) {
		dev_err(state->dev, "suspend: %s: vchiq_open_service failed %d\n",
			__func__, status);
			__func__, ret);
		goto shutdown;
	}

@@ -1348,17 +1345,17 @@ vchiq_keepalive_thread_func(void *v)
		 */
		while (uc--) {
			atomic_inc(&arm_state->ka_use_ack_count);
			status = vchiq_use_service(instance, ka_handle);
			if (status) {
			ret = vchiq_use_service(instance, ka_handle);
			if (ret) {
				dev_err(state->dev, "suspend: %s: vchiq_use_service error %d\n",
					__func__, status);
					__func__, ret);
			}
		}
		while (rc--) {
			status = vchiq_release_service(instance, ka_handle);
			if (status) {
			ret = vchiq_release_service(instance, ka_handle);
			if (ret) {
				dev_err(state->dev, "suspend: %s: vchiq_release_service error %d\n",
					__func__, status);
					__func__, ret);
			}
		}
	}
@@ -1408,13 +1405,13 @@ vchiq_use_internal(struct vchiq_state *state, struct vchiq_service *service,
	write_unlock_bh(&arm_state->susp_res_lock);

	if (!ret) {
		int status = 0;
		int ret = 0;
		long ack_cnt = atomic_xchg(&arm_state->ka_use_ack_count, 0);

		while (ack_cnt && !status) {
		while (ack_cnt && !ret) {
			/* Send the use notify to videocore */
			status = vchiq_send_remote_use_active(state);
			if (!status)
			ret = vchiq_send_remote_use_active(state);
			if (!ret)
				ack_cnt--;
			else
				atomic_add(ack_cnt, &arm_state->ka_use_ack_count);
@@ -1730,7 +1727,7 @@ static int vchiq_probe(struct platform_device *pdev)
	struct device_node *fw_node;
	const struct vchiq_platform_info *info;
	struct vchiq_drv_mgmt *mgmt;
	int err;
	int ret;

	info = of_device_get_match_data(&pdev->dev);
	if (!info)
@@ -1755,8 +1752,8 @@ static int vchiq_probe(struct platform_device *pdev)
	mgmt->info = info;
	platform_set_drvdata(pdev, mgmt);

	err = vchiq_platform_init(pdev, &mgmt->state);
	if (err)
	ret = vchiq_platform_init(pdev, &mgmt->state);
	if (ret)
		goto failed_platform_init;

	vchiq_debugfs_init(&mgmt->state);
@@ -1768,8 +1765,8 @@ static int vchiq_probe(struct platform_device *pdev)
	 * Simply exit on error since the function handles cleanup in
	 * cases of failure.
	 */
	err = vchiq_register_chrdev(&pdev->dev);
	if (err) {
	ret = vchiq_register_chrdev(&pdev->dev);
	if (ret) {
		dev_err(&pdev->dev, "arm: Failed to initialize vchiq cdev\n");
		goto error_exit;
	}
@@ -1782,7 +1779,7 @@ static int vchiq_probe(struct platform_device *pdev)
failed_platform_init:
	dev_err(&pdev->dev, "arm: Could not initialize vchiq platform\n");
error_exit:
	return err;
	return ret;
}

static void vchiq_remove(struct platform_device *pdev)