On 23/08/17 01:26, Niklas Söderlund wrote:
> In media controller mode all VIN instances needs to be part of the same
> media graph. There is also a need to each VIN instance to know and in
> some cases be able to communicate with other VIN instances.
> 
> Add a allocator framework where the first VIN instance to be probed

Add a -> Add an

> creates a shared data structure and creates a media device.
> 
> Signed-off-by: Niklas Söderlund <niklas.soderlund+rene...@ragnatech.se>


Reviewed-by: Hans Verkuil <hans.verk...@cisco.com>

Note the small typo below.

Regards,

        Hans


> ---
>  drivers/media/platform/rcar-vin/rcar-core.c | 179 
> +++++++++++++++++++++++++++-
>  drivers/media/platform/rcar-vin/rcar-vin.h  |  38 ++++++
>  2 files changed, 216 insertions(+), 1 deletion(-)
> 
> diff --git a/drivers/media/platform/rcar-vin/rcar-core.c 
> b/drivers/media/platform/rcar-vin/rcar-core.c
> index dd0525f2ba336bc2..4218a73eb6885486 100644
> --- a/drivers/media/platform/rcar-vin/rcar-core.c
> +++ b/drivers/media/platform/rcar-vin/rcar-core.c
> @@ -20,11 +20,170 @@
>  #include <linux/of_graph.h>
>  #include <linux/platform_device.h>
>  #include <linux/pm_runtime.h>
> +#include <linux/slab.h>
>  
>  #include <media/v4l2-fwnode.h>
>  
>  #include "rcar-vin.h"
>  
> +/* 
> -----------------------------------------------------------------------------
> + * Gen3 CSI2 Group Allocator
> + */
> +
> +static int rvin_group_read_id(struct rvin_dev *vin, struct device_node *np)
> +{
> +     u32 val;
> +     int ret;
> +
> +     ret = of_property_read_u32(np, "renesas,id", &val);
> +     if (ret) {
> +             vin_err(vin, "%s: No renesas,id property found\n",
> +                     of_node_full_name(np));
> +             return -EINVAL;
> +     }
> +
> +     if (val >= RCAR_VIN_NUM) {
> +             vin_err(vin, "%s: Invalid renesas,id '%u'\n",
> +                     of_node_full_name(np), val);
> +             return -EINVAL;
> +     }
> +
> +     return val;
> +}
> +
> +static DEFINE_MUTEX(rvin_group_lock);
> +static struct rvin_group *rvin_group_data;
> +
> +static void rvin_group_release(struct kref *kref)
> +{
> +     struct rvin_group *group =
> +             container_of(kref, struct rvin_group, refcount);
> +
> +     mutex_lock(&rvin_group_lock);
> +
> +     media_device_unregister(&group->mdev);
> +     media_device_cleanup(&group->mdev);
> +
> +     rvin_group_data = NULL;
> +
> +     mutex_unlock(&rvin_group_lock);
> +
> +     kfree(group);
> +}
> +
> +static struct rvin_group *__rvin_group_allocate(struct rvin_dev *vin)
> +{
> +     struct rvin_group *group;
> +
> +     if (rvin_group_data) {
> +             group = rvin_group_data;
> +             kref_get(&group->refcount);
> +             vin_dbg(vin, "%s: get group=%p\n", __func__, group);
> +             return group;
> +     }
> +
> +     group = kzalloc(sizeof(*group), GFP_KERNEL);
> +     if (!group)
> +             return NULL;
> +
> +     kref_init(&group->refcount);
> +     rvin_group_data = group;
> +
> +     vin_dbg(vin, "%s: alloc group=%p\n", __func__, group);
> +     return group;
> +}
> +
> +static int rvin_group_add_vin(struct rvin_dev *vin)
> +{
> +     int ret;
> +
> +     ret = rvin_group_read_id(vin, vin->dev->of_node);
> +     if (ret < 0)
> +             return ret;
> +
> +     mutex_lock(&vin->group->lock);
> +
> +     if (vin->group->vin[ret]) {
> +             mutex_unlock(&vin->group->lock);
> +             vin_err(vin, "VIN number %d already occupied\n", ret);
> +             return -EINVAL;
> +     }
> +
> +     vin->group->vin[ret] = vin;
> +
> +     mutex_unlock(&vin->group->lock);
> +
> +     vin_dbg(vin, "I'm VIN number %d", ret);
> +
> +     return 0;
> +}
> +
> +static int rvin_group_allocate(struct rvin_dev *vin)
> +{
> +     struct rvin_group *group;
> +     struct media_device *mdev;
> +     int ret;
> +
> +     mutex_lock(&rvin_group_lock);
> +
> +     group = __rvin_group_allocate(vin);
> +     if (!group) {
> +             mutex_unlock(&rvin_group_lock);
> +             return -ENOMEM;
> +     }
> +
> +     /* Init group data if its not already initialized */

its -> it is

> +     mdev = &group->mdev;
> +     if (!mdev->dev) {
> +             mutex_init(&group->lock);
> +             mdev->dev = vin->dev;
> +
> +             strlcpy(mdev->driver_name, "Renesas VIN",
> +                     sizeof(mdev->driver_name));
> +             strlcpy(mdev->model, vin->dev->of_node->name,
> +                     sizeof(mdev->model));
> +             strlcpy(mdev->bus_info, of_node_full_name(vin->dev->of_node),
> +                     sizeof(mdev->bus_info));
> +             media_device_init(mdev);
> +
> +             ret = media_device_register(mdev);
> +             if (ret) {
> +                     vin_err(vin, "Failed to register media device\n");
> +                     kref_put(&group->refcount, rvin_group_release);
> +                     mutex_unlock(&rvin_group_lock);
> +                     return ret;
> +             }
> +     }
> +
> +     vin->group = group;
> +     vin->v4l2_dev.mdev = mdev;
> +
> +     ret = rvin_group_add_vin(vin);
> +     if (ret) {
> +             kref_put(&group->refcount, rvin_group_release);
> +             mutex_unlock(&rvin_group_lock);
> +             return ret;
> +     }
> +
> +     mutex_unlock(&rvin_group_lock);
> +
> +     return 0;
> +}
> +
> +static void rvin_group_delete(struct rvin_dev *vin)
> +{
> +     unsigned int i;
> +
> +     mutex_lock(&vin->group->lock);
> +     for (i = 0; i < RCAR_VIN_NUM; i++)
> +             if (vin->group->vin[i] == vin)
> +                     vin->group->vin[i] = NULL;
> +     mutex_unlock(&vin->group->lock);
> +
> +     vin_dbg(vin, "%s: group=%p\n", __func__, &vin->group);
> +     kref_put(&vin->group->refcount, rvin_group_release);
> +}
> +
>  /* 
> -----------------------------------------------------------------------------
>   * Async notifier
>   */
> @@ -283,12 +442,27 @@ static int rvin_digital_graph_init(struct rvin_dev *vin)
>  
>  static int rvin_group_init(struct rvin_dev *vin)
>  {
> +     int ret;
> +
> +     ret = rvin_group_allocate(vin);
> +     if (ret)
> +             return ret;
> +
>       /* All our sources are CSI-2 */
>       vin->mbus_cfg.type = V4L2_MBUS_CSI2;
>       vin->mbus_cfg.flags = 0;
>  
>       vin->pad.flags = MEDIA_PAD_FL_SINK;
> -     return media_entity_pads_init(&vin->vdev.entity, 1, &vin->pad);
> +     ret = media_entity_pads_init(&vin->vdev.entity, 1, &vin->pad);
> +     if (ret)
> +             goto error_group;
> +
> +     return 0;
> +
> +error_group:
> +     rvin_group_delete(vin);
> +
> +     return ret;
>  }
>  
>  /* 
> -----------------------------------------------------------------------------
> @@ -416,6 +590,9 @@ static int rcar_vin_remove(struct platform_device *pdev)
>  
>       rvin_v4l2_remove(vin);
>  
> +     if (vin->info->use_mc)
> +             rvin_group_delete(vin);
> +
>       rvin_dma_remove(vin);
>  
>       return 0;
> diff --git a/drivers/media/platform/rcar-vin/rcar-vin.h 
> b/drivers/media/platform/rcar-vin/rcar-vin.h
> index 9c47669669c0469c..88683aaee3b6acd5 100644
> --- a/drivers/media/platform/rcar-vin/rcar-vin.h
> +++ b/drivers/media/platform/rcar-vin/rcar-vin.h
> @@ -17,6 +17,8 @@
>  #ifndef __RCAR_VIN__
>  #define __RCAR_VIN__
>  
> +#include <linux/kref.h>
> +
>  #include <media/v4l2-async.h>
>  #include <media/v4l2-ctrls.h>
>  #include <media/v4l2-dev.h>
> @@ -30,6 +32,9 @@
>  /* Address alignment mask for HW buffers */
>  #define HW_BUFFER_MASK 0x7f
>  
> +/* Max number on VIN instances that can be in a system */
> +#define RCAR_VIN_NUM 8
> +
>  enum chip_id {
>       RCAR_H1,
>       RCAR_M1,
> @@ -37,6 +42,15 @@ enum chip_id {
>       RCAR_GEN3,
>  };
>  
> +enum rvin_csi_id {
> +     RVIN_CSI20,
> +     RVIN_CSI21,
> +     RVIN_CSI40,
> +     RVIN_CSI41,
> +     RVIN_CSI_MAX,
> +     RVIN_NC, /* Not Connected */
> +};
> +
>  /**
>   * STOPPED  - No operation in progress
>   * RUNNING  - Operation in progress have buffers
> @@ -75,6 +89,8 @@ struct rvin_graph_entity {
>       unsigned int sink_pad;
>  };
>  
> +struct rvin_group;
> +
>  /**
>   * struct rvin_info - Information about the particular VIN implementation
>   * @chip:            type of VIN chip
> @@ -103,6 +119,7 @@ struct rvin_info {
>   * @notifier:                V4L2 asynchronous subdevs notifier
>   * @digital:         entity in the DT for local digital subdevice
>   *
> + * @group:           Gen3 CSI group
>   * @pad:             pad for media controller
>   *
>   * @lock:            protects @queue
> @@ -134,6 +151,7 @@ struct rvin_dev {
>       struct v4l2_async_notifier notifier;
>       struct rvin_graph_entity digital;
>  
> +     struct rvin_group *group;
>       struct media_pad pad;
>  
>       struct mutex lock;
> @@ -162,6 +180,26 @@ struct rvin_dev {
>  #define vin_warn(d, fmt, arg...)     dev_warn(d->dev, fmt, ##arg)
>  #define vin_err(d, fmt, arg...)              dev_err(d->dev, fmt, ##arg)
>  
> +/**
> + * struct rvin_group - VIN CSI2 group information
> + * @refcount:                number of VIN instances using the group
> + *
> + * @mdev:            media device which represents the group
> + *
> + * @lock:            protects the vin and csi members
> + * @vin:             VIN instances which are part of the group
> + * @csi:             CSI-2 entities that are part of the group
> + */
> +struct rvin_group {
> +     struct kref refcount;
> +
> +     struct media_device mdev;
> +
> +     struct mutex lock;
> +     struct rvin_dev *vin[RCAR_VIN_NUM];
> +     struct rvin_graph_entity csi[RVIN_CSI_MAX];
> +};
> +
>  int rvin_dma_probe(struct rvin_dev *vin, int irq);
>  void rvin_dma_remove(struct rvin_dev *vin);
>  
> 

Reply via email to