Release 4.7 drivers/connector/cn_queue.c
/*
* cn_queue.c
*
* 2004+ Copyright (c) Evgeniy Polyakov <zbr@ioremap.net>
* All rights reserved.
*
* This program is free software; you can redistribute it and/or modify
* it under the terms of the GNU General Public License as published by
* the Free Software Foundation; either version 2 of the License, or
* (at your option) any later version.
*
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU General Public License for more details.
*
* You should have received a copy of the GNU General Public License
* along with this program; if not, write to the Free Software
* Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
*
*/
#include <linux/kernel.h>
#include <linux/module.h>
#include <linux/list.h>
#include <linux/workqueue.h>
#include <linux/spinlock.h>
#include <linux/slab.h>
#include <linux/skbuff.h>
#include <linux/suspend.h>
#include <linux/connector.h>
#include <linux/delay.h>
static struct cn_callback_entry *
cn_queue_alloc_callback_entry(struct cn_queue_dev *dev, const char *name,
struct cb_id *id,
void (*callback)(struct cn_msg *,
struct netlink_skb_parms *))
{
struct cn_callback_entry *cbq;
cbq = kzalloc(sizeof(*cbq), GFP_KERNEL);
if (!cbq) {
pr_err("Failed to create new callback queue.\n");
return NULL;
}
atomic_set(&cbq->refcnt, 1);
atomic_inc(&dev->refcnt);
cbq->pdev = dev;
snprintf(cbq->id.name, sizeof(cbq->id.name), "%s", name);
memcpy(&cbq->id.id, id, sizeof(struct cb_id));
cbq->callback = callback;
return cbq;
}
Contributors
| Person | Tokens | Prop | Commits | CommitProp |
| evgeniy polyakov | evgeniy polyakov | 107 | 74.31% | 2 | 28.57% |
| patrick mchardy | patrick mchardy | 29 | 20.14% | 1 | 14.29% |
| philipp reisner | philipp reisner | 4 | 2.78% | 1 | 14.29% |
| mike frysinger | mike frysinger | 2 | 1.39% | 1 | 14.29% |
| joe perches | joe perches | 1 | 0.69% | 1 | 14.29% |
| valentin ilie | valentin ilie | 1 | 0.69% | 1 | 14.29% |
| Total | 144 | 100.00% | 7 | 100.00% |
void cn_queue_release_callback(struct cn_callback_entry *cbq)
{
if (!atomic_dec_and_test(&cbq->refcnt))
return;
atomic_dec(&cbq->pdev->refcnt);
kfree(cbq);
}
Contributors
| Person | Tokens | Prop | Commits | CommitProp |
| evgeniy polyakov | evgeniy polyakov | 21 | 56.76% | 1 | 50.00% |
| patrick mchardy | patrick mchardy | 16 | 43.24% | 1 | 50.00% |
| Total | 37 | 100.00% | 2 | 100.00% |
int cn_cb_equal(struct cb_id *i1, struct cb_id *i2)
{
return ((i1->idx == i2->idx) && (i1->val == i2->val));
}
Contributors
| Person | Tokens | Prop | Commits | CommitProp |
| evgeniy polyakov | evgeniy polyakov | 38 | 100.00% | 1 | 100.00% |
| Total | 38 | 100.00% | 1 | 100.00% |
int cn_queue_add_callback(struct cn_queue_dev *dev, const char *name,
struct cb_id *id,
void (*callback)(struct cn_msg *,
struct netlink_skb_parms *))
{
struct cn_callback_entry *cbq, *__cbq;
int found = 0;
cbq = cn_queue_alloc_callback_entry(dev, name, id, callback);
if (!cbq)
return -ENOMEM;
spin_lock_bh(&dev->queue_lock);
list_for_each_entry(__cbq, &dev->queue_list, callback_entry) {
if (cn_cb_equal(&__cbq->id.id, id)) {
found = 1;
break;
}
}
if (!found)
list_add_tail(&cbq->callback_entry, &dev->queue_list);
spin_unlock_bh(&dev->queue_lock);
if (found) {
cn_queue_release_callback(cbq);
return -EINVAL;
}
cbq->seq = 0;
cbq->group = cbq->id.id.idx;
return 0;
}
Contributors
| Person | Tokens | Prop | Commits | CommitProp |
| evgeniy polyakov | evgeniy polyakov | 157 | 91.81% | 2 | 28.57% |
| li zefan | li zefan | 4 | 2.34% | 1 | 14.29% |
| philipp reisner | philipp reisner | 4 | 2.34% | 1 | 14.29% |
| patrick mchardy | patrick mchardy | 3 | 1.75% | 1 | 14.29% |
| mike frysinger | mike frysinger | 2 | 1.17% | 1 | 14.29% |
| joe perches | joe perches | 1 | 0.58% | 1 | 14.29% |
| Total | 171 | 100.00% | 7 | 100.00% |
void cn_queue_del_callback(struct cn_queue_dev *dev, struct cb_id *id)
{
struct cn_callback_entry *cbq, *n;
int found = 0;
spin_lock_bh(&dev->queue_lock);
list_for_each_entry_safe(cbq, n, &dev->queue_list, callback_entry) {
if (cn_cb_equal(&cbq->id.id, id)) {
list_del(&cbq->callback_entry);
found = 1;
break;
}
}
spin_unlock_bh(&dev->queue_lock);
if (found)
cn_queue_release_callback(cbq);
}
Contributors
| Person | Tokens | Prop | Commits | CommitProp |
| evgeniy polyakov | evgeniy polyakov | 93 | 98.94% | 2 | 66.67% |
| patrick mchardy | patrick mchardy | 1 | 1.06% | 1 | 33.33% |
| Total | 94 | 100.00% | 3 | 100.00% |
struct cn_queue_dev *cn_queue_alloc_dev(const char *name, struct sock *nls)
{
struct cn_queue_dev *dev;
dev = kzalloc(sizeof(*dev), GFP_KERNEL);
if (!dev)
return NULL;
snprintf(dev->name, sizeof(dev->name), "%s", name);
atomic_set(&dev->refcnt, 0);
INIT_LIST_HEAD(&dev->queue_list);
spin_lock_init(&dev->queue_lock);
dev->nls = nls;
return dev;
}
Contributors
| Person | Tokens | Prop | Commits | CommitProp |
| evgeniy polyakov | evgeniy polyakov | 90 | 93.75% | 1 | 25.00% |
| frederic weisbecker | frederic weisbecker | 4 | 4.17% | 1 | 25.00% |
| tejun heo | tejun heo | 1 | 1.04% | 1 | 25.00% |
| joe perches | joe perches | 1 | 1.04% | 1 | 25.00% |
| Total | 96 | 100.00% | 4 | 100.00% |
void cn_queue_free_dev(struct cn_queue_dev *dev)
{
struct cn_callback_entry *cbq, *n;
spin_lock_bh(&dev->queue_lock);
list_for_each_entry_safe(cbq, n, &dev->queue_list, callback_entry)
list_del(&cbq->callback_entry);
spin_unlock_bh(&dev->queue_lock);
while (atomic_read(&dev->refcnt)) {
pr_info("Waiting for %s to become free: refcnt=%d.\n",
dev->name, atomic_read(&dev->refcnt));
msleep(1000);
}
kfree(dev);
dev = NULL;
}
Contributors
| Person | Tokens | Prop | Commits | CommitProp |
| evgeniy polyakov | evgeniy polyakov | 94 | 98.95% | 1 | 50.00% |
| valentin ilie | valentin ilie | 1 | 1.05% | 1 | 50.00% |
| Total | 95 | 100.00% | 2 | 100.00% |
Overall Contributors
| Person | Tokens | Prop | Commits | CommitProp |
| evgeniy polyakov | evgeniy polyakov | 630 | 89.24% | 2 | 20.00% |
| patrick mchardy | patrick mchardy | 49 | 6.94% | 1 | 10.00% |
| philipp reisner | philipp reisner | 8 | 1.13% | 1 | 10.00% |
| li zefan | li zefan | 4 | 0.57% | 1 | 10.00% |
| frederic weisbecker | frederic weisbecker | 4 | 0.57% | 1 | 10.00% |
| mike frysinger | mike frysinger | 4 | 0.57% | 1 | 10.00% |
| valentin ilie | valentin ilie | 3 | 0.42% | 1 | 10.00% |
| joe perches | joe perches | 3 | 0.42% | 1 | 10.00% |
| tejun heo | tejun heo | 1 | 0.14% | 1 | 10.00% |
| Total | 706 | 100.00% | 10 | 100.00% |
Information contained on this website is for historical information purposes only and does not indicate or represent copyright ownership.