[linux-2.6-block.git] / net / core / sock_diag.c

/* License: GPL */

#include <linux/filter.h>
#include <linux/mutex.h>
#include <linux/socket.h>
#include <linux/skbuff.h>
#include <net/netlink.h>
#include <net/net_namespace.h>
#include <linux/module.h>
#include <net/sock.h>
#include <linux/kernel.h>
#include <linux/tcp.h>
#include <linux/workqueue.h>
#include <linux/nospec.h>
#include <linux/cookie.h>
#include <linux/inet_diag.h>
#include <linux/sock_diag.h>

static const struct sock_diag_handler *sock_diag_handlers[AF_MAX];
static int (*inet_rcv_compat)(struct sk_buff *skb, struct nlmsghdr *nlh);
static DEFINE_MUTEX(sock_diag_table_mutex);
static struct workqueue_struct *broadcast_wq;

DEFINE_COOKIE(sock_cookie);

u64 __sock_gen_cookie(struct sock *sk)
{
	u64 res = atomic64_read(&sk->sk_cookie);

	if (!res) {
		u64 new = gen_cookie_next(&sock_cookie);

		atomic64_cmpxchg(&sk->sk_cookie, res, new);

		/* Another thread might have changed sk_cookie before us. */
		res = atomic64_read(&sk->sk_cookie);
	}
	return res;
}

int sock_diag_check_cookie(struct sock *sk, const __u32 *cookie)
{
	u64 res;

	if (cookie[0] == INET_DIAG_NOCOOKIE && cookie[1] == INET_DIAG_NOCOOKIE)
		return 0;

	res = sock_gen_cookie(sk);
	if ((u32)res != cookie[0] || (u32)(res >> 32) != cookie[1])
		return -ESTALE;

	return 0;
}
EXPORT_SYMBOL_GPL(sock_diag_check_cookie);

void sock_diag_save_cookie(struct sock *sk, __u32 *cookie)
{
	u64 res = sock_gen_cookie(sk);

	cookie[0] = (u32)res;
	cookie[1] = (u32)(res >> 32);
}
EXPORT_SYMBOL_GPL(sock_diag_save_cookie);

int sock_diag_put_meminfo(struct sock *sk, struct sk_buff *skb, int attrtype)
{
	u32 mem[SK_MEMINFO_VARS];

	sk_get_meminfo(sk, mem);

	return nla_put(skb, attrtype, sizeof(mem), &mem);
}
EXPORT_SYMBOL_GPL(sock_diag_put_meminfo);

int sock_diag_put_filterinfo(bool may_report_filterinfo, struct sock *sk,
			     struct sk_buff *skb, int attrtype)
{
	struct sock_fprog_kern *fprog;
	struct sk_filter *filter;
	struct nlattr *attr;
	unsigned int flen;
	int err = 0;

	if (!may_report_filterinfo) {
		nla_reserve(skb, attrtype, 0);
		return 0;
	}

	rcu_read_lock();
	filter = rcu_dereference(sk->sk_filter);
	if (!filter)
		goto out;

	fprog = filter->prog->orig_prog;
	if (!fprog)
		goto out;

	flen = bpf_classic_proglen(fprog);

	attr = nla_reserve(skb, attrtype, flen);
	if (attr == NULL) {
		err = -EMSGSIZE;
		goto out;
	}

	memcpy(nla_data(attr), fprog->filter, flen);
out:
	rcu_read_unlock();
	return err;
}
EXPORT_SYMBOL(sock_diag_put_filterinfo);

struct broadcast_sk {
	struct sock *sk;
	struct work_struct work;
};

static size_t sock_diag_nlmsg_size(void)
{
	return NLMSG_ALIGN(sizeof(struct inet_diag_msg)
	       + nla_total_size(sizeof(u8)) /* INET_DIAG_PROTOCOL */
	       + nla_total_size_64bit(sizeof(struct tcp_info))); /* INET_DIAG_INFO */
}

static void sock_diag_broadcast_destroy_work(struct work_struct *work)
{
	struct broadcast_sk *bsk =
		container_of(work, struct broadcast_sk, work);
	struct sock *sk = bsk->sk;
	const struct sock_diag_handler *hndl;
	struct sk_buff *skb;
	const enum sknetlink_groups group = sock_diag_destroy_group(sk);
	int err = -1;

	WARN_ON(group == SKNLGRP_NONE);

	skb = nlmsg_new(sock_diag_nlmsg_size(), GFP_KERNEL);
	if (!skb)
		goto out;

	mutex_lock(&sock_diag_table_mutex);
	hndl = sock_diag_handlers[sk->sk_family];
	if (hndl && hndl->get_info)
		err = hndl->get_info(skb, sk);
	mutex_unlock(&sock_diag_table_mutex);

	if (!err)
		nlmsg_multicast(sock_net(sk)->diag_nlsk, skb, 0, group,
				GFP_KERNEL);
	else
		kfree_skb(skb);
out:
	sk_destruct(sk);
	kfree(bsk);
}

void sock_diag_broadcast_destroy(struct sock *sk)
{
	/* Note, this function is often called from an interrupt context. */
	struct broadcast_sk *bsk =
		kmalloc(sizeof(struct broadcast_sk), GFP_ATOMIC);
	if (!bsk)
		return sk_destruct(sk);
	bsk->sk = sk;
	INIT_WORK(&bsk->work, sock_diag_broadcast_destroy_work);
	queue_work(broadcast_wq, &bsk->work);
}

void sock_diag_register_inet_compat(int (*fn)(struct sk_buff *skb, struct nlmsghdr *nlh))
{
	mutex_lock(&sock_diag_table_mutex);
	inet_rcv_compat = fn;
	mutex_unlock(&sock_diag_table_mutex);
}
EXPORT_SYMBOL_GPL(sock_diag_register_inet_compat);

void sock_diag_unregister_inet_compat(int (*fn)(struct sk_buff *skb, struct nlmsghdr *nlh))
{
	mutex_lock(&sock_diag_table_mutex);
	inet_rcv_compat = NULL;
	mutex_unlock(&sock_diag_table_mutex);
}
EXPORT_SYMBOL_GPL(sock_diag_unregister_inet_compat);

int sock_diag_register(const struct sock_diag_handler *hndl)
{
	int err = 0;

	if (hndl->family >= AF_MAX)
		return -EINVAL;

	mutex_lock(&sock_diag_table_mutex);
	if (sock_diag_handlers[hndl->family])
		err = -EBUSY;
	else
		sock_diag_handlers[hndl->family] = hndl;
	mutex_unlock(&sock_diag_table_mutex);

	return err;
}
EXPORT_SYMBOL_GPL(sock_diag_register);

void sock_diag_unregister(const struct sock_diag_handler *hnld)
{
	int family = hnld->family;

	if (family >= AF_MAX)
		return;

	mutex_lock(&sock_diag_table_mutex);
	BUG_ON(sock_diag_handlers[family] != hnld);
	sock_diag_handlers[family] = NULL;
	mutex_unlock(&sock_diag_table_mutex);
}
EXPORT_SYMBOL_GPL(sock_diag_unregister);

static int __sock_diag_cmd(struct sk_buff *skb, struct nlmsghdr *nlh)
{
	int err;
	struct sock_diag_req *req = nlmsg_data(nlh);
	const struct sock_diag_handler *hndl;

	if (nlmsg_len(nlh) < sizeof(*req))
		return -EINVAL;

	if (req->sdiag_family >= AF_MAX)
		return -EINVAL;
	req->sdiag_family = array_index_nospec(req->sdiag_family, AF_MAX);

	if (sock_diag_handlers[req->sdiag_family] == NULL)
		sock_load_diag_module(req->sdiag_family, 0);

	mutex_lock(&sock_diag_table_mutex);
	hndl = sock_diag_handlers[req->sdiag_family];
	if (hndl == NULL)
		err = -ENOENT;
	else if (nlh->nlmsg_type == SOCK_DIAG_BY_FAMILY)
		err = hndl->dump(skb, nlh);
	else if (nlh->nlmsg_type == SOCK_DESTROY && hndl->destroy)
		err = hndl->destroy(skb, nlh);
	else
		err = -EOPNOTSUPP;
	mutex_unlock(&sock_diag_table_mutex);

	return err;
}

static int sock_diag_rcv_msg(struct sk_buff *skb, struct nlmsghdr *nlh,
			     struct netlink_ext_ack *extack)
{
	int ret;

	switch (nlh->nlmsg_type) {
	case TCPDIAG_GETSOCK:
	case DCCPDIAG_GETSOCK:
		if (inet_rcv_compat == NULL)
			sock_load_diag_module(AF_INET, 0);

		mutex_lock(&sock_diag_table_mutex);
		if (inet_rcv_compat != NULL)
			ret = inet_rcv_compat(skb, nlh);
		else
			ret = -EOPNOTSUPP;
		mutex_unlock(&sock_diag_table_mutex);

		return ret;
	case SOCK_DIAG_BY_FAMILY:
	case SOCK_DESTROY:
		return __sock_diag_cmd(skb, nlh);
	default:
		return -EINVAL;
	}
}

static DEFINE_MUTEX(sock_diag_mutex);

static void sock_diag_rcv(struct sk_buff *skb)
{
	mutex_lock(&sock_diag_mutex);
	netlink_rcv_skb(skb, &sock_diag_rcv_msg);
	mutex_unlock(&sock_diag_mutex);
}

static int sock_diag_bind(struct net *net, int group)
{
	switch (group) {
	case SKNLGRP_INET_TCP_DESTROY:
	case SKNLGRP_INET_UDP_DESTROY:
		if (!sock_diag_handlers[AF_INET])
			sock_load_diag_module(AF_INET, 0);
		break;
	case SKNLGRP_INET6_TCP_DESTROY:
	case SKNLGRP_INET6_UDP_DESTROY:
		if (!sock_diag_handlers[AF_INET6])
			sock_load_diag_module(AF_INET6, 0);
		break;
	}
	return 0;
}

int sock_diag_destroy(struct sock *sk, int err)
{
	if (!ns_capable(sock_net(sk)->user_ns, CAP_NET_ADMIN))
		return -EPERM;

	if (!sk->sk_prot->diag_destroy)
		return -EOPNOTSUPP;

	return sk->sk_prot->diag_destroy(sk, err);
}
EXPORT_SYMBOL_GPL(sock_diag_destroy);

static int __net_init diag_net_init(struct net *net)
{
	struct netlink_kernel_cfg cfg = {
		.groups	= SKNLGRP_MAX,
		.input	= sock_diag_rcv,
		.bind	= sock_diag_bind,
		.flags	= NL_CFG_F_NONROOT_RECV,
	};

	net->diag_nlsk = netlink_kernel_create(net, NETLINK_SOCK_DIAG, &cfg);
	return net->diag_nlsk == NULL ? -ENOMEM : 0;
}

static void __net_exit diag_net_exit(struct net *net)
{
	netlink_kernel_release(net->diag_nlsk);
	net->diag_nlsk = NULL;
}

static struct pernet_operations diag_net_ops = {
	.init = diag_net_init,
	.exit = diag_net_exit,
};

static int __init sock_diag_init(void)
{
	broadcast_wq = alloc_workqueue("sock_diag_events", 0, 0);
	BUG_ON(!broadcast_wq);
	return register_pernet_subsys(&diag_net_ops);
}
device_initcall(sock_diag_init);
Commit	Line	Data
b6191aee PG	1	/* License: GPL */
b6191aee PG	2
b6459415	3	#include <linux/filter.h>
8ef874bf PE	4	#include <linux/mutex.h>
	5	#include <linux/socket.h>
	6	#include <linux/skbuff.h>
	7	#include <net/netlink.h>
	8	#include <net/net_namespace.h>
	9	#include <linux/module.h>
5d2e5f27	10	#include <net/sock.h>
eb4cb008 CG	11	#include <linux/kernel.h>
	12	#include <linux/tcp.h>
	13	#include <linux/workqueue.h>
66b51b0a	14	#include <linux/nospec.h>
92acdc58	15	#include <linux/cookie.h>
8ef874bf PE	16	#include <linux/inet_diag.h>
	17	#include <linux/sock_diag.h>
	18
8dcf01fc	19	static const struct sock_diag_handler *sock_diag_handlers[AF_MAX];
8ef874bf PE	20	static int (inet_rcv_compat)(struct sk_buff skb, struct nlmsghdr *nlh);
8ef874bf PE	21	static DEFINE_MUTEX(sock_diag_table_mutex);
eb4cb008	22	static struct workqueue_struct *broadcast_wq;
8ef874bf	23
92acdc58 DB	24	DEFINE_COOKIE(sock_cookie);
	25
	26	u64 __sock_gen_cookie(struct sock *sk)
f65c1b53	27	{
4ebf802c	28	u64 res = atomic64_read(&sk->sk_cookie);
33cf7c90	29
4ebf802c ED	30	if (!res) {
	31	u64 new = gen_cookie_next(&sock_cookie);
	32
32634819 ED	33	atomic64_cmpxchg(&sk->sk_cookie, res, new);
	34
	35	/* Another thread might have changed sk_cookie before us. */
	36	res = atomic64_read(&sk->sk_cookie);
33cf7c90	37	}
4ebf802c	38	return res;
33cf7c90 ED	39	}
	40
	41	int sock_diag_check_cookie(struct sock sk, const __u32 cookie)
	42	{
	43	u64 res;
	44
	45	if (cookie[0] == INET_DIAG_NOCOOKIE && cookie[1] == INET_DIAG_NOCOOKIE)
f65c1b53	46	return 0;
33cf7c90 ED	47
	48	res = sock_gen_cookie(sk);
	49	if ((u32)res != cookie[0] \|\| (u32)(res >> 32) != cookie[1])
	50	return -ESTALE;
	51
	52	return 0;
f65c1b53 PE	53	}
	54	EXPORT_SYMBOL_GPL(sock_diag_check_cookie);
	55
33cf7c90	56	void sock_diag_save_cookie(struct sock sk, __u32 cookie)
f65c1b53	57	{
33cf7c90 ED	58	u64 res = sock_gen_cookie(sk);
	59
	60	cookie[0] = (u32)res;
	61	cookie[1] = (u32)(res >> 32);
f65c1b53 PE	62	}
	63	EXPORT_SYMBOL_GPL(sock_diag_save_cookie);
	64
5d2e5f27 PE	65	int sock_diag_put_meminfo(struct sock sk, struct sk_buff skb, int attrtype)
5d2e5f27 PE	66	{
7b46866d	67	u32 mem[SK_MEMINFO_VARS];
5d2e5f27	68
a2d133b1	69	sk_get_meminfo(sk, mem);
5d2e5f27	70
7b46866d	71	return nla_put(skb, attrtype, sizeof(mem), &mem);
5d2e5f27 PE	72	}
	73	EXPORT_SYMBOL_GPL(sock_diag_put_meminfo);
	74
a53b72c8	75	int sock_diag_put_filterinfo(bool may_report_filterinfo, struct sock *sk,
e8d9612c ND	76	struct sk_buff *skb, int attrtype)
e8d9612c ND	77	{
a3ea269b	78	struct sock_fprog_kern *fprog;
e8d9612c	79	struct sk_filter *filter;
a3ea269b DB	80	struct nlattr *attr;
a3ea269b DB	81	unsigned int flen;
e8d9612c ND	82	int err = 0;
e8d9612c ND	83
a53b72c8	84	if (!may_report_filterinfo) {
e8d9612c ND	85	nla_reserve(skb, attrtype, 0);
	86	return 0;
	87	}
	88
	89	rcu_read_lock();
e8d9612c	90	filter = rcu_dereference(sk->sk_filter);
a3ea269b DB	91	if (!filter)
a3ea269b DB	92	goto out;
e8d9612c	93
7ae457c1	94	fprog = filter->prog->orig_prog;
b382c086 DB	95	if (!fprog)
	96	goto out;
	97
009937e7	98	flen = bpf_classic_proglen(fprog);
a3ea269b DB	99
a3ea269b DB	100	attr = nla_reserve(skb, attrtype, flen);
e8d9612c ND	101	if (attr == NULL) {
	102	err = -EMSGSIZE;
	103	goto out;
	104	}
	105
a3ea269b	106	memcpy(nla_data(attr), fprog->filter, flen);
e8d9612c ND	107	out:
	108	rcu_read_unlock();
	109	return err;
	110	}
	111	EXPORT_SYMBOL(sock_diag_put_filterinfo);
	112
eb4cb008 CG	113	struct broadcast_sk {
	114	struct sock *sk;
	115	struct work_struct work;
	116	};
	117
	118	static size_t sock_diag_nlmsg_size(void)
	119	{
	120	return NLMSG_ALIGN(sizeof(struct inet_diag_msg)
	121	+ nla_total_size(sizeof(u8)) /* INET_DIAG_PROTOCOL */
6ed46d12	122	+ nla_total_size_64bit(sizeof(struct tcp_info))); /* INET_DIAG_INFO */
eb4cb008 CG	123	}
	124
	125	static void sock_diag_broadcast_destroy_work(struct work_struct *work)
	126	{
	127	struct broadcast_sk *bsk =
	128	container_of(work, struct broadcast_sk, work);
	129	struct sock *sk = bsk->sk;
	130	const struct sock_diag_handler *hndl;
	131	struct sk_buff *skb;
	132	const enum sknetlink_groups group = sock_diag_destroy_group(sk);
	133	int err = -1;
	134
	135	WARN_ON(group == SKNLGRP_NONE);
	136
	137	skb = nlmsg_new(sock_diag_nlmsg_size(), GFP_KERNEL);
	138	if (!skb)
	139	goto out;
	140
	141	mutex_lock(&sock_diag_table_mutex);
	142	hndl = sock_diag_handlers[sk->sk_family];
	143	if (hndl && hndl->get_info)
	144	err = hndl->get_info(skb, sk);
	145	mutex_unlock(&sock_diag_table_mutex);
	146
	147	if (!err)
	148	nlmsg_multicast(sock_net(sk)->diag_nlsk, skb, 0, group,
	149	GFP_KERNEL);
	150	else
	151	kfree_skb(skb);
	152	out:
	153	sk_destruct(sk);
	154	kfree(bsk);
	155	}
	156
	157	void sock_diag_broadcast_destroy(struct sock *sk)
	158	{
	159	/* Note, this function is often called from an interrupt context. */
	160	struct broadcast_sk *bsk =
	161	kmalloc(sizeof(struct broadcast_sk), GFP_ATOMIC);
	162	if (!bsk)
	163	return sk_destruct(sk);
	164	bsk->sk = sk;
	165	INIT_WORK(&bsk->work, sock_diag_broadcast_destroy_work);
	166	queue_work(broadcast_wq, &bsk->work);
	167	}
	168
8ef874bf PE	169	void sock_diag_register_inet_compat(int (fn)(struct sk_buff skb, struct nlmsghdr *nlh))
	170	{
	171	mutex_lock(&sock_diag_table_mutex);
	172	inet_rcv_compat = fn;
	173	mutex_unlock(&sock_diag_table_mutex);
	174	}
	175	EXPORT_SYMBOL_GPL(sock_diag_register_inet_compat);
	176
	177	void sock_diag_unregister_inet_compat(int (fn)(struct sk_buff skb, struct nlmsghdr *nlh))
	178	{
	179	mutex_lock(&sock_diag_table_mutex);
	180	inet_rcv_compat = NULL;
	181	mutex_unlock(&sock_diag_table_mutex);
	182	}
	183	EXPORT_SYMBOL_GPL(sock_diag_unregister_inet_compat);
	184
8dcf01fc	185	int sock_diag_register(const struct sock_diag_handler *hndl)
8ef874bf PE	186	{
	187	int err = 0;
	188
6f8e4ad0	189	if (hndl->family >= AF_MAX)
8ef874bf PE	190	return -EINVAL;
	191
	192	mutex_lock(&sock_diag_table_mutex);
	193	if (sock_diag_handlers[hndl->family])
	194	err = -EBUSY;
	195	else
	196	sock_diag_handlers[hndl->family] = hndl;
	197	mutex_unlock(&sock_diag_table_mutex);
	198
	199	return err;
	200	}
	201	EXPORT_SYMBOL_GPL(sock_diag_register);
	202
8dcf01fc	203	void sock_diag_unregister(const struct sock_diag_handler *hnld)
8ef874bf PE	204	{
	205	int family = hnld->family;
	206
6f8e4ad0	207	if (family >= AF_MAX)
8ef874bf PE	208	return;
	209
	210	mutex_lock(&sock_diag_table_mutex);
	211	BUG_ON(sock_diag_handlers[family] != hnld);
	212	sock_diag_handlers[family] = NULL;
	213	mutex_unlock(&sock_diag_table_mutex);
	214	}
	215	EXPORT_SYMBOL_GPL(sock_diag_unregister);
	216
64be0aed	217	static int __sock_diag_cmd(struct sk_buff skb, struct nlmsghdr nlh)
8ef874bf PE	218	{
8ef874bf PE	219	int err;
7b46866d	220	struct sock_diag_req *req = nlmsg_data(nlh);
8dcf01fc	221	const struct sock_diag_handler *hndl;
8ef874bf PE	222
	223	if (nlmsg_len(nlh) < sizeof(*req))
	224	return -EINVAL;
	225
6e601a53 MK	226	if (req->sdiag_family >= AF_MAX)
6e601a53 MK	227	return -EINVAL;
66b51b0a	228	req->sdiag_family = array_index_nospec(req->sdiag_family, AF_MAX);
6e601a53	229
8e904550	230	if (sock_diag_handlers[req->sdiag_family] == NULL)
bf2ae2e4	231	sock_load_diag_module(req->sdiag_family, 0);
8e904550 MK	232
	233	mutex_lock(&sock_diag_table_mutex);
	234	hndl = sock_diag_handlers[req->sdiag_family];
8ef874bf PE	235	if (hndl == NULL)
8ef874bf PE	236	err = -ENOENT;
64be0aed	237	else if (nlh->nlmsg_type == SOCK_DIAG_BY_FAMILY)
8ef874bf	238	err = hndl->dump(skb, nlh);
64be0aed LC	239	else if (nlh->nlmsg_type == SOCK_DESTROY && hndl->destroy)
	240	err = hndl->destroy(skb, nlh);
	241	else
	242	err = -EOPNOTSUPP;
8e904550	243	mutex_unlock(&sock_diag_table_mutex);
8ef874bf PE	244
	245	return err;
	246	}
	247
2d4bc933 JB	248	static int sock_diag_rcv_msg(struct sk_buff skb, struct nlmsghdr nlh,
2d4bc933 JB	249	struct netlink_ext_ack *extack)
8ef874bf PE	250	{
	251	int ret;
	252
	253	switch (nlh->nlmsg_type) {
	254	case TCPDIAG_GETSOCK:
	255	case DCCPDIAG_GETSOCK:
	256	if (inet_rcv_compat == NULL)
bf2ae2e4	257	sock_load_diag_module(AF_INET, 0);
8ef874bf PE	258
	259	mutex_lock(&sock_diag_table_mutex);
	260	if (inet_rcv_compat != NULL)
	261	ret = inet_rcv_compat(skb, nlh);
	262	else
	263	ret = -EOPNOTSUPP;
	264	mutex_unlock(&sock_diag_table_mutex);
	265
	266	return ret;
	267	case SOCK_DIAG_BY_FAMILY:
64be0aed LC	268	case SOCK_DESTROY:
64be0aed LC	269	return __sock_diag_cmd(skb, nlh);
8ef874bf PE	270	default:
	271	return -EINVAL;
	272	}
	273	}
	274
	275	static DEFINE_MUTEX(sock_diag_mutex);
	276
	277	static void sock_diag_rcv(struct sk_buff *skb)
	278	{
	279	mutex_lock(&sock_diag_mutex);
	280	netlink_rcv_skb(skb, &sock_diag_rcv_msg);
	281	mutex_unlock(&sock_diag_mutex);
	282	}
	283
eb4cb008 CG	284	static int sock_diag_bind(struct net *net, int group)
	285	{
	286	switch (group) {
	287	case SKNLGRP_INET_TCP_DESTROY:
	288	case SKNLGRP_INET_UDP_DESTROY:
	289	if (!sock_diag_handlers[AF_INET])
bf2ae2e4	290	sock_load_diag_module(AF_INET, 0);
eb4cb008 CG	291	break;
	292	case SKNLGRP_INET6_TCP_DESTROY:
	293	case SKNLGRP_INET6_UDP_DESTROY:
	294	if (!sock_diag_handlers[AF_INET6])
bf2ae2e4	295	sock_load_diag_module(AF_INET6, 0);
eb4cb008 CG	296	break;
	297	}
	298	return 0;
	299	}
	300
64be0aed LC	301	int sock_diag_destroy(struct sock *sk, int err)
	302	{
	303	if (!ns_capable(sock_net(sk)->user_ns, CAP_NET_ADMIN))
	304	return -EPERM;
	305
	306	if (!sk->sk_prot->diag_destroy)
	307	return -EOPNOTSUPP;
	308
	309	return sk->sk_prot->diag_destroy(sk, err);
	310	}
	311	EXPORT_SYMBOL_GPL(sock_diag_destroy);
	312
51d7cccf	313	static int __net_init diag_net_init(struct net *net)
8ef874bf	314	{
a31f2d17	315	struct netlink_kernel_cfg cfg = {
eb4cb008	316	.groups = SKNLGRP_MAX,
a31f2d17	317	.input = sock_diag_rcv,
eb4cb008 CG	318	.bind = sock_diag_bind,
eb4cb008 CG	319	.flags = NL_CFG_F_NONROOT_RECV,
a31f2d17 PNA	320	};
a31f2d17 PNA	321
9f00d977	322	net->diag_nlsk = netlink_kernel_create(net, NETLINK_SOCK_DIAG, &cfg);
51d7cccf AV	323	return net->diag_nlsk == NULL ? -ENOMEM : 0;
	324	}
	325
	326	static void __net_exit diag_net_exit(struct net *net)
	327	{
	328	netlink_kernel_release(net->diag_nlsk);
	329	net->diag_nlsk = NULL;
	330	}
	331
	332	static struct pernet_operations diag_net_ops = {
	333	.init = diag_net_init,
	334	.exit = diag_net_exit,
	335	};
	336
	337	static int __init sock_diag_init(void)
	338	{
eb4cb008 CG	339	broadcast_wq = alloc_workqueue("sock_diag_events", 0, 0);
eb4cb008 CG	340	BUG_ON(!broadcast_wq);
51d7cccf	341	return register_pernet_subsys(&diag_net_ops);
8ef874bf	342	}
b6191aee	343	device_initcall(sock_diag_init);