cregit-Linux how code gets into the kernel

Release 4.11 drivers/media/v4l2-core/v4l2-async.c

/*
 * V4L2 asynchronous subdevice registration API
 *
 * Copyright (C) 2012-2013, Guennadi Liakhovetski <g.liakhovetski@gmx.de>
 *
 * This program is free software; you can redistribute it and/or modify
 * it under the terms of the GNU General Public License version 2 as
 * published by the Free Software Foundation.
 */

#include <linux/device.h>
#include <linux/err.h>
#include <linux/i2c.h>
#include <linux/list.h>
#include <linux/module.h>
#include <linux/mutex.h>
#include <linux/platform_device.h>
#include <linux/slab.h>
#include <linux/types.h>

#include <media/v4l2-async.h>
#include <media/v4l2-device.h>
#include <media/v4l2-subdev.h>


static bool match_i2c(struct v4l2_subdev *sd, struct v4l2_async_subdev *asd) { #if IS_ENABLED(CONFIG_I2C) struct i2c_client *client = i2c_verify_client(sd->dev); return client && asd->match.i2c.adapter_id == client->adapter->nr && asd->match.i2c.address == client->addr; #else return false; #endif }

Contributors

PersonTokensPropCommitsCommitProp
Guennadi Liakhovetski6694.29%266.67%
Sakari Ailus45.71%133.33%
Total70100.00%3100.00%


static bool match_devname(struct v4l2_subdev *sd, struct v4l2_async_subdev *asd) { return !strcmp(asd->match.device_name.name, dev_name(sd->dev)); }

Contributors

PersonTokensPropCommitsCommitProp
Guennadi Liakhovetski3083.33%133.33%
Sakari Ailus411.11%133.33%
Sylwester Nawrocki25.56%133.33%
Total36100.00%3100.00%


static bool match_of(struct v4l2_subdev *sd, struct v4l2_async_subdev *asd) { return !of_node_cmp(of_node_full_name(sd->of_node), of_node_full_name(asd->match.of.node)); }

Contributors

PersonTokensPropCommitsCommitProp
Sylwester Nawrocki2564.10%133.33%
Javi Merino1128.21%133.33%
Sakari Ailus37.69%133.33%
Total39100.00%3100.00%


static bool match_custom(struct v4l2_subdev *sd, struct v4l2_async_subdev *asd) { if (!asd->match.custom.match) /* Match always */ return true; return asd->match.custom.match(sd->dev, asd); }

Contributors

PersonTokensPropCommitsCommitProp
Sakari Ailus47100.00%1100.00%
Total47100.00%1100.00%

static LIST_HEAD(subdev_list); static LIST_HEAD(notifier_list); static DEFINE_MUTEX(list_lock);
static struct v4l2_async_subdev *v4l2_async_belongs(struct v4l2_async_notifier *notifier, struct v4l2_subdev *sd) { bool (*match)(struct v4l2_subdev *, struct v4l2_async_subdev *); struct v4l2_async_subdev *asd; list_for_each_entry(asd, &notifier->waiting, list) { /* bus_type has been verified valid before */ switch (asd->match_type) { case V4L2_ASYNC_MATCH_CUSTOM: match = match_custom; break; case V4L2_ASYNC_MATCH_DEVNAME: match = match_devname; break; case V4L2_ASYNC_MATCH_I2C: match = match_i2c; break; case V4L2_ASYNC_MATCH_OF: match = match_of; break; default: /* Cannot happen, unless someone breaks us */ WARN_ON(true); return NULL; } /* match cannot be NULL here */ if (match(sd, asd)) return asd; } return NULL; }

Contributors

PersonTokensPropCommitsCommitProp
Guennadi Liakhovetski9380.87%120.00%
Sylwester Nawrocki1513.04%360.00%
Sakari Ailus76.09%120.00%
Total115100.00%5100.00%


static int v4l2_async_test_notify(struct v4l2_async_notifier *notifier, struct v4l2_subdev *sd, struct v4l2_async_subdev *asd) { int ret; if (notifier->bound) { ret = notifier->bound(notifier, sd, asd); if (ret < 0) return ret; } ret = v4l2_device_register_subdev(notifier->v4l2_dev, sd); if (ret < 0) { if (notifier->unbind) notifier->unbind(notifier, sd, asd); return ret; } /* Remove from the waiting list */ list_del(&asd->list); sd->asd = asd; sd->notifier = notifier; /* Move from the global subdevice list to notifier's done */ list_move(&sd->async_list, &notifier->done); if (list_empty(&notifier->waiting) && notifier->complete) return notifier->complete(notifier); return 0; }

Contributors

PersonTokensPropCommitsCommitProp
Guennadi Liakhovetski11675.82%133.33%
Tuukka Toivonen3522.88%133.33%
Sylwester Nawrocki21.31%133.33%
Total153100.00%3100.00%


static void v4l2_async_cleanup(struct v4l2_subdev *sd) { v4l2_device_unregister_subdev(sd); /* Subdevice driver will reprobe and put the subdev back onto the list */ list_del_init(&sd->async_list); sd->asd = NULL; sd->dev = NULL; }

Contributors

PersonTokensPropCommitsCommitProp
Guennadi Liakhovetski3183.78%150.00%
Sylwester Nawrocki616.22%150.00%
Total37100.00%2100.00%


int v4l2_async_notifier_register(struct v4l2_device *v4l2_dev, struct v4l2_async_notifier *notifier) { struct v4l2_subdev *sd, *tmp; struct v4l2_async_subdev *asd; int i; if (!notifier->num_subdevs || notifier->num_subdevs > V4L2_MAX_SUBDEVS) return -EINVAL; notifier->v4l2_dev = v4l2_dev; INIT_LIST_HEAD(&notifier->waiting); INIT_LIST_HEAD(&notifier->done); for (i = 0; i < notifier->num_subdevs; i++) { asd = notifier->subdevs[i]; switch (asd->match_type) { case V4L2_ASYNC_MATCH_CUSTOM: case V4L2_ASYNC_MATCH_DEVNAME: case V4L2_ASYNC_MATCH_I2C: case V4L2_ASYNC_MATCH_OF: break; default: dev_err(notifier->v4l2_dev ? notifier->v4l2_dev->dev : NULL, "Invalid match type %u on %p\n", asd->match_type, asd); return -EINVAL; } list_add_tail(&asd->list, &notifier->waiting); } mutex_lock(&list_lock); list_for_each_entry_safe(sd, tmp, &subdev_list, async_list) { int ret; asd = v4l2_async_belongs(notifier, sd); if (!asd) continue; ret = v4l2_async_test_notify(notifier, sd, asd); if (ret < 0) { mutex_unlock(&list_lock); return ret; } } /* Keep also completed notifiers on the list */ list_add(&notifier->list, &notifier_list); mutex_unlock(&list_lock); return 0; }

Contributors

PersonTokensPropCommitsCommitProp
Guennadi Liakhovetski21588.48%116.67%
Sylwester Nawrocki166.58%466.67%
Tuukka Toivonen124.94%116.67%
Total243100.00%6100.00%

EXPORT_SYMBOL(v4l2_async_notifier_register);
void v4l2_async_notifier_unregister(struct v4l2_async_notifier *notifier) { struct v4l2_subdev *sd, *tmp; unsigned int notif_n_subdev = notifier->num_subdevs; unsigned int n_subdev = min(notif_n_subdev, V4L2_MAX_SUBDEVS); struct device **dev; int i = 0; if (!notifier->v4l2_dev) return; dev = kmalloc_array(n_subdev, sizeof(*dev), GFP_KERNEL); if (!dev) { dev_err(notifier->v4l2_dev->dev, "Failed to allocate device cache!\n"); } mutex_lock(&list_lock); list_del(&notifier->list); list_for_each_entry_safe(sd, tmp, &notifier->done, async_list) { struct device *d; d = get_device(sd->dev); v4l2_async_cleanup(sd); /* If we handled USB devices, we'd have to lock the parent too */ device_release_driver(d); if (notifier->unbind) notifier->unbind(notifier, sd, sd->asd); /* * Store device at the device cache, in order to call * put_device() on the final step */ if (dev) dev[i++] = d; else put_device(d); } mutex_unlock(&list_lock); /* * Call device_attach() to reprobe devices * * NOTE: If dev allocation fails, i is 0, and the whole loop won't be * executed. */ while (i--) { struct device *d = dev[i]; if (d && device_attach(d) < 0) { const char *name = "(none)"; int lock = device_trylock(d); if (lock && d->driver) name = d->driver->name; dev_err(d, "Failed to re-probe to %s\n", name); if (lock) device_unlock(d); } put_device(d); } kfree(dev); notifier->v4l2_dev = NULL; /* * Don't care about the waiting list, it is initialised and populated * upon notifier registration. */ }

Contributors

PersonTokensPropCommitsCommitProp
Guennadi Liakhovetski19669.75%116.67%
Mauro Carvalho Chehab6422.78%116.67%
Laurent Pinchart144.98%116.67%
Sylwester Nawrocki51.78%233.33%
SF Markus Elfring20.71%116.67%
Total281100.00%6100.00%

EXPORT_SYMBOL(v4l2_async_notifier_unregister);
int v4l2_async_register_subdev(struct v4l2_subdev *sd) { struct v4l2_async_notifier *notifier; /* * No reference taken. The reference is held by the device * (struct v4l2_subdev.dev), and async sub-device does not * exist independently of the device at any point of time. */ if (!sd->of_node && sd->dev) sd->of_node = sd->dev->of_node; mutex_lock(&list_lock); INIT_LIST_HEAD(&sd->async_list); list_for_each_entry(notifier, &notifier_list, list) { struct v4l2_async_subdev *asd = v4l2_async_belongs(notifier, sd); if (asd) { int ret = v4l2_async_test_notify(notifier, sd, asd); mutex_unlock(&list_lock); return ret; } } /* None matched, wait for hot-plugging */ list_add(&sd->async_list, &subdev_list); mutex_unlock(&list_lock); return 0; }

Contributors

PersonTokensPropCommitsCommitProp
Guennadi Liakhovetski9376.86%133.33%
Sakari Ailus2218.18%133.33%
Sylwester Nawrocki64.96%133.33%
Total121100.00%3100.00%

EXPORT_SYMBOL(v4l2_async_register_subdev);
void v4l2_async_unregister_subdev(struct v4l2_subdev *sd) { struct v4l2_async_notifier *notifier = sd->notifier; if (!sd->asd) { if (!list_empty(&sd->async_list)) v4l2_async_cleanup(sd); return; } mutex_lock(&list_lock); list_add(&sd->asd->list, &notifier->waiting); v4l2_async_cleanup(sd); if (notifier->unbind) notifier->unbind(notifier, sd, sd->asd); mutex_unlock(&list_lock); }

Contributors

PersonTokensPropCommitsCommitProp
Guennadi Liakhovetski8992.71%150.00%
Sylwester Nawrocki77.29%150.00%
Total96100.00%2100.00%

EXPORT_SYMBOL(v4l2_async_unregister_subdev);

Overall Contributors

PersonTokensPropCommitsCommitProp
Guennadi Liakhovetski100476.47%215.38%
Sakari Ailus876.63%17.69%
Sylwester Nawrocki846.40%538.46%
Mauro Carvalho Chehab644.87%17.69%
Tuukka Toivonen473.58%17.69%
Laurent Pinchart141.07%17.69%
Javi Merino110.84%17.69%
SF Markus Elfring20.15%17.69%
Total1313100.00%13100.00%
Information contained on this website is for historical information purposes only and does not indicate or represent copyright ownership.
Created with cregit.