Release 4.11 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
107
74.31%
2
28.57%
Patrick McHardy
29
20.14%
1
14.29%
Philipp Reisner
4
2.78%
1
14.29%
Mike Frysinger
2
1.39%
1
14.29%
Joe Perches
1
0.69%
1
14.29%
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
21
56.76%
1
50.00%
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
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
157
91.81%
2
28.57%
Philipp Reisner
4
2.34%
1
14.29%
Li Zefan
4
2.34%
1
14.29%
Patrick McHardy
3
1.75%
1
14.29%
Mike Frysinger
2
1.17%
1
14.29%
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
93
98.94%
2
66.67%
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
90
93.75%
1
25.00%
Frédéric Weisbecker
4
4.17%
1
25.00%
Tejun Heo
1
1.04%
1
25.00%
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
94
98.95%
1
50.00%
Valentin Ilie
1
1.05%
1
50.00%
Total
95
100.00%
2
100.00%

Overall Contributors
Person
Tokens
Prop
Commits
CommitProp
Evgeniy Polyakov
630
89.24%
2
20.00%
Patrick McHardy
49
6.94%
1
10.00%
Philipp Reisner
8
1.13%
1
10.00%
Li Zefan
4
0.57%
1
10.00%
Mike Frysinger
4
0.57%
1
10.00%
Frédéric Weisbecker
4
0.57%
1
10.00%
Joe Perches
3
0.42%
1
10.00%
Valentin Ilie
3
0.42%
1
10.00%
Tejun Heo
1
0.14%
1
10.00%
Total
706
100.00%
10
100.00%
Directory: drivers/connector

Information contained on this website is for historical information purposes only and does not indicate or represent copyright ownership.