Commit b4b51029 authored by Eric W. Biederman's avatar Eric W. Biederman Committed by David S. Miller

[NET]: Support multiple network namespaces with netlink

Each netlink socket will live in exactly one network namespace,
this includes the controlling kernel sockets.

This patch updates all of the existing netlink protocols
to only support the initial network namespace.  Request
by clients in other namespaces will get -ECONREFUSED.
As they would if the kernel did not have the support for
that netlink protocol compiled in.

As each netlink protocol is updated to be multiple network
namespace safe it can register multiple kernel sockets
to acquire a presence in the rest of the network namespaces.

The implementation in af_netlink is a simple filter implementation
at hash table insertion and hash table look up time.
Signed-off-by: default avatarEric W. Biederman <ebiederm@xmission.com>
Signed-off-by: default avatarDavid S. Miller <davem@davemloft.net>
parent e9dc8653
...@@ -446,7 +446,7 @@ static int __devinit cn_init(void) ...@@ -446,7 +446,7 @@ static int __devinit cn_init(void)
dev->id.idx = cn_idx; dev->id.idx = cn_idx;
dev->id.val = cn_val; dev->id.val = cn_val;
dev->nls = netlink_kernel_create(NETLINK_CONNECTOR, dev->nls = netlink_kernel_create(&init_net, NETLINK_CONNECTOR,
CN_NETLINK_USERS + 0xf, CN_NETLINK_USERS + 0xf,
dev->input, NULL, THIS_MODULE); dev->input, NULL, THIS_MODULE);
if (!dev->nls) if (!dev->nls)
......
...@@ -167,7 +167,7 @@ scsi_netlink_init(void) ...@@ -167,7 +167,7 @@ scsi_netlink_init(void)
return; return;
} }
scsi_nl_sock = netlink_kernel_create(NETLINK_SCSITRANSPORT, scsi_nl_sock = netlink_kernel_create(&init_net, NETLINK_SCSITRANSPORT,
SCSI_NL_GRP_CNT, scsi_nl_rcv, NULL, SCSI_NL_GRP_CNT, scsi_nl_rcv, NULL,
THIS_MODULE); THIS_MODULE);
if (!scsi_nl_sock) { if (!scsi_nl_sock) {
......
...@@ -1523,7 +1523,7 @@ static __init int iscsi_transport_init(void) ...@@ -1523,7 +1523,7 @@ static __init int iscsi_transport_init(void)
if (err) if (err)
goto unregister_conn_class; goto unregister_conn_class;
nls = netlink_kernel_create(NETLINK_ISCSI, 1, iscsi_if_rx, NULL, nls = netlink_kernel_create(&init_net, NETLINK_ISCSI, 1, iscsi_if_rx, NULL,
THIS_MODULE); THIS_MODULE);
if (!nls) { if (!nls) {
err = -ENOBUFS; err = -ENOBUFS;
......
...@@ -227,7 +227,7 @@ int ecryptfs_init_netlink(void) ...@@ -227,7 +227,7 @@ int ecryptfs_init_netlink(void)
{ {
int rc; int rc;
ecryptfs_nl_sock = netlink_kernel_create(NETLINK_ECRYPTFS, 0, ecryptfs_nl_sock = netlink_kernel_create(&init_net, NETLINK_ECRYPTFS, 0,
ecryptfs_receive_nl_message, ecryptfs_receive_nl_message,
NULL, THIS_MODULE); NULL, THIS_MODULE);
if (!ecryptfs_nl_sock) { if (!ecryptfs_nl_sock) {
......
...@@ -27,6 +27,8 @@ ...@@ -27,6 +27,8 @@
#define MAX_LINKS 32 #define MAX_LINKS 32
struct net;
struct sockaddr_nl struct sockaddr_nl
{ {
sa_family_t nl_family; /* AF_NETLINK */ sa_family_t nl_family; /* AF_NETLINK */
...@@ -157,7 +159,8 @@ struct netlink_skb_parms ...@@ -157,7 +159,8 @@ struct netlink_skb_parms
#define NETLINK_CREDS(skb) (&NETLINK_CB((skb)).creds) #define NETLINK_CREDS(skb) (&NETLINK_CB((skb)).creds)
extern struct sock *netlink_kernel_create(int unit, unsigned int groups, extern struct sock *netlink_kernel_create(struct net *net,
int unit,unsigned int groups,
void (*input)(struct sock *sk, int len), void (*input)(struct sock *sk, int len),
struct mutex *cb_mutex, struct mutex *cb_mutex,
struct module *module); struct module *module);
...@@ -206,6 +209,7 @@ struct netlink_callback ...@@ -206,6 +209,7 @@ struct netlink_callback
struct netlink_notify struct netlink_notify
{ {
struct net *net;
int pid; int pid;
int protocol; int protocol;
}; };
......
...@@ -876,8 +876,8 @@ static int __init audit_init(void) ...@@ -876,8 +876,8 @@ static int __init audit_init(void)
printk(KERN_INFO "audit: initializing netlink socket (%s)\n", printk(KERN_INFO "audit: initializing netlink socket (%s)\n",
audit_default ? "enabled" : "disabled"); audit_default ? "enabled" : "disabled");
audit_sock = netlink_kernel_create(NETLINK_AUDIT, 0, audit_receive, audit_sock = netlink_kernel_create(&init_net, NETLINK_AUDIT, 0,
NULL, THIS_MODULE); audit_receive, NULL, THIS_MODULE);
if (!audit_sock) if (!audit_sock)
audit_panic("cannot initialize netlink socket"); audit_panic("cannot initialize netlink socket");
else else
......
...@@ -280,9 +280,8 @@ EXPORT_SYMBOL_GPL(add_uevent_var); ...@@ -280,9 +280,8 @@ EXPORT_SYMBOL_GPL(add_uevent_var);
#if defined(CONFIG_NET) #if defined(CONFIG_NET)
static int __init kobject_uevent_init(void) static int __init kobject_uevent_init(void)
{ {
uevent_sock = netlink_kernel_create(NETLINK_KOBJECT_UEVENT, 1, NULL, uevent_sock = netlink_kernel_create(&init_net, NETLINK_KOBJECT_UEVENT,
NULL, THIS_MODULE); 1, NULL, NULL, THIS_MODULE);
if (!uevent_sock) { if (!uevent_sock) {
printk(KERN_ERR printk(KERN_ERR
"kobject_uevent: unable to create netlink socket!\n"); "kobject_uevent: unable to create netlink socket!\n");
......
...@@ -300,8 +300,9 @@ static int __init ebt_ulog_init(void) ...@@ -300,8 +300,9 @@ static int __init ebt_ulog_init(void)
spin_lock_init(&ulog_buffers[i].lock); spin_lock_init(&ulog_buffers[i].lock);
} }
ebtulognl = netlink_kernel_create(NETLINK_NFLOG, EBT_ULOG_MAXNLGROUPS, ebtulognl = netlink_kernel_create(&init_net, NETLINK_NFLOG,
NULL, NULL, THIS_MODULE); EBT_ULOG_MAXNLGROUPS, NULL, NULL,
THIS_MODULE);
if (!ebtulognl) if (!ebtulognl)
ret = -ENOMEM; ret = -ENOMEM;
else if ((ret = ebt_register_watcher(&ulog))) else if ((ret = ebt_register_watcher(&ulog)))
......
...@@ -1327,8 +1327,8 @@ void __init rtnetlink_init(void) ...@@ -1327,8 +1327,8 @@ void __init rtnetlink_init(void)
if (!rta_buf) if (!rta_buf)
panic("rtnetlink_init: cannot allocate rta_buf\n"); panic("rtnetlink_init: cannot allocate rta_buf\n");
rtnl = netlink_kernel_create(NETLINK_ROUTE, RTNLGRP_MAX, rtnetlink_rcv, rtnl = netlink_kernel_create(&init_net, NETLINK_ROUTE, RTNLGRP_MAX,
&rtnl_mutex, THIS_MODULE); rtnetlink_rcv, &rtnl_mutex, THIS_MODULE);
if (rtnl == NULL) if (rtnl == NULL)
panic("rtnetlink_init: cannot initialize rtnetlink\n"); panic("rtnetlink_init: cannot initialize rtnetlink\n");
netlink_set_nonroot(NETLINK_ROUTE, NL_NONROOT_RECV); netlink_set_nonroot(NETLINK_ROUTE, NL_NONROOT_RECV);
......
...@@ -137,7 +137,8 @@ static int __init dn_rtmsg_init(void) ...@@ -137,7 +137,8 @@ static int __init dn_rtmsg_init(void)
{ {
int rv = 0; int rv = 0;
dnrmg = netlink_kernel_create(NETLINK_DNRTMSG, DNRNG_NLGRP_MAX, dnrmg = netlink_kernel_create(&init_net,
NETLINK_DNRTMSG, DNRNG_NLGRP_MAX,
dnrmg_receive_user_sk, NULL, THIS_MODULE); dnrmg_receive_user_sk, NULL, THIS_MODULE);
if (dnrmg == NULL) { if (dnrmg == NULL) {
printk(KERN_ERR "dn_rtmsg: Cannot create netlink socket"); printk(KERN_ERR "dn_rtmsg: Cannot create netlink socket");
......
...@@ -816,8 +816,8 @@ static void nl_fib_input(struct sock *sk, int len) ...@@ -816,8 +816,8 @@ static void nl_fib_input(struct sock *sk, int len)
static void nl_fib_lookup_init(void) static void nl_fib_lookup_init(void)
{ {
netlink_kernel_create(NETLINK_FIB_LOOKUP, 0, nl_fib_input, NULL, netlink_kernel_create(&init_net, NETLINK_FIB_LOOKUP, 0, nl_fib_input,
THIS_MODULE); NULL, THIS_MODULE);
} }
static void fib_disable_ip(struct net_device *dev, int force) static void fib_disable_ip(struct net_device *dev, int force)
......
...@@ -897,8 +897,8 @@ static int __init inet_diag_init(void) ...@@ -897,8 +897,8 @@ static int __init inet_diag_init(void)
if (!inet_diag_table) if (!inet_diag_table)
goto out; goto out;
idiagnl = netlink_kernel_create(NETLINK_INET_DIAG, 0, inet_diag_rcv, idiagnl = netlink_kernel_create(&init_net, NETLINK_INET_DIAG, 0,
NULL, THIS_MODULE); inet_diag_rcv, NULL, THIS_MODULE);
if (idiagnl == NULL) if (idiagnl == NULL)
goto out_free_table; goto out_free_table;
err = 0; err = 0;
......
...@@ -579,7 +579,7 @@ ipq_rcv_nl_event(struct notifier_block *this, ...@@ -579,7 +579,7 @@ ipq_rcv_nl_event(struct notifier_block *this,
if (event == NETLINK_URELEASE && if (event == NETLINK_URELEASE &&
n->protocol == NETLINK_FIREWALL && n->pid) { n->protocol == NETLINK_FIREWALL && n->pid) {
write_lock_bh(&queue_lock); write_lock_bh(&queue_lock);
if (n->pid == peer_pid) if ((n->net == &init_net) && (n->pid == peer_pid))
__ipq_reset(); __ipq_reset();
write_unlock_bh(&queue_lock); write_unlock_bh(&queue_lock);
} }
...@@ -671,8 +671,8 @@ static int __init ip_queue_init(void) ...@@ -671,8 +671,8 @@ static int __init ip_queue_init(void)
struct proc_dir_entry *proc; struct proc_dir_entry *proc;
netlink_register_notifier(&ipq_nl_notifier); netlink_register_notifier(&ipq_nl_notifier);
ipqnl = netlink_kernel_create(NETLINK_FIREWALL, 0, ipq_rcv_sk, ipqnl = netlink_kernel_create(&init_net, NETLINK_FIREWALL, 0,
NULL, THIS_MODULE); ipq_rcv_sk, NULL, THIS_MODULE);
if (ipqnl == NULL) { if (ipqnl == NULL) {
printk(KERN_ERR "ip_queue: failed to create netlink socket\n"); printk(KERN_ERR "ip_queue: failed to create netlink socket\n");
goto cleanup_netlink_notifier; goto cleanup_netlink_notifier;
......
...@@ -409,7 +409,8 @@ static int __init ipt_ulog_init(void) ...@@ -409,7 +409,8 @@ static int __init ipt_ulog_init(void)
for (i = 0; i < ULOG_MAXNLGROUPS; i++) for (i = 0; i < ULOG_MAXNLGROUPS; i++)
setup_timer(&ulog_buffers[i].timer, ulog_timer, i); setup_timer(&ulog_buffers[i].timer, ulog_timer, i);
nflognl = netlink_kernel_create(NETLINK_NFLOG, ULOG_MAXNLGROUPS, NULL, nflognl = netlink_kernel_create(&init_net,
NETLINK_NFLOG, ULOG_MAXNLGROUPS, NULL,
NULL, THIS_MODULE); NULL, THIS_MODULE);
if (!nflognl) if (!nflognl)
return -ENOMEM; return -ENOMEM;
......
...@@ -569,7 +569,7 @@ ipq_rcv_nl_event(struct notifier_block *this, ...@@ -569,7 +569,7 @@ ipq_rcv_nl_event(struct notifier_block *this,
if (event == NETLINK_URELEASE && if (event == NETLINK_URELEASE &&
n->protocol == NETLINK_IP6_FW && n->pid) { n->protocol == NETLINK_IP6_FW && n->pid) {
write_lock_bh(&queue_lock); write_lock_bh(&queue_lock);
if (n->pid == peer_pid) if ((n->net == &init_net) && (n->pid == peer_pid))
__ipq_reset(); __ipq_reset();
write_unlock_bh(&queue_lock); write_unlock_bh(&queue_lock);
} }
...@@ -661,8 +661,8 @@ static int __init ip6_queue_init(void) ...@@ -661,8 +661,8 @@ static int __init ip6_queue_init(void)
struct proc_dir_entry *proc; struct proc_dir_entry *proc;
netlink_register_notifier(&ipq_nl_notifier); netlink_register_notifier(&ipq_nl_notifier);
ipqnl = netlink_kernel_create(NETLINK_IP6_FW, 0, ipq_rcv_sk, NULL, ipqnl = netlink_kernel_create(&init_net, NETLINK_IP6_FW, 0, ipq_rcv_sk,
THIS_MODULE); NULL, THIS_MODULE);
if (ipqnl == NULL) { if (ipqnl == NULL) {
printk(KERN_ERR "ip6_queue: failed to create netlink socket\n"); printk(KERN_ERR "ip6_queue: failed to create netlink socket\n");
goto cleanup_netlink_notifier; goto cleanup_netlink_notifier;
......
...@@ -264,7 +264,7 @@ static int __init nfnetlink_init(void) ...@@ -264,7 +264,7 @@ static int __init nfnetlink_init(void)
{ {
printk("Netfilter messages via NETLINK v%s.\n", nfversion); printk("Netfilter messages via NETLINK v%s.\n", nfversion);
nfnl = netlink_kernel_create(NETLINK_NETFILTER, NFNLGRP_MAX, nfnl = netlink_kernel_create(&init_net, NETLINK_NETFILTER, NFNLGRP_MAX,
nfnetlink_rcv, NULL, THIS_MODULE); nfnetlink_rcv, NULL, THIS_MODULE);
if (!nfnl) { if (!nfnl) {
printk(KERN_ERR "cannot initialize nfnetlink!\n"); printk(KERN_ERR "cannot initialize nfnetlink!\n");
......
...@@ -706,7 +706,8 @@ nfulnl_rcv_nl_event(struct notifier_block *this, ...@@ -706,7 +706,8 @@ nfulnl_rcv_nl_event(struct notifier_block *this,
hlist_for_each_entry_safe(inst, tmp, t2, head, hlist) { hlist_for_each_entry_safe(inst, tmp, t2, head, hlist) {
UDEBUG("node = %p\n", inst); UDEBUG("node = %p\n", inst);
if (n->pid == inst->peer_pid) if ((n->net == &init_net) &&
(n->pid == inst->peer_pid))
__instance_destroy(inst); __instance_destroy(inst);
} }
} }
......
...@@ -765,7 +765,8 @@ nfqnl_rcv_nl_event(struct notifier_block *this, ...@@ -765,7 +765,8 @@ nfqnl_rcv_nl_event(struct notifier_block *this,
struct hlist_head *head = &instance_table[i]; struct hlist_head *head = &instance_table[i];
hlist_for_each_entry_safe(inst, tmp, t2, head, hlist) { hlist_for_each_entry_safe(inst, tmp, t2, head, hlist) {
if (n->pid == inst->peer_pid) if ((n->net == &init_net) &&
(n->pid == inst->peer_pid))
__instance_destroy(inst); __instance_destroy(inst);
} }
} }
......
...@@ -211,7 +211,7 @@ netlink_unlock_table(void) ...@@ -211,7 +211,7 @@ netlink_unlock_table(void)
wake_up(&nl_table_wait); wake_up(&nl_table_wait);
} }
static __inline__ struct sock *netlink_lookup(int protocol, u32 pid) static __inline__ struct sock *netlink_lookup(struct net *net, int protocol, u32 pid)
{ {
struct nl_pid_hash *hash = &nl_table[protocol].hash; struct nl_pid_hash *hash = &nl_table[protocol].hash;
struct hlist_head *head; struct hlist_head *head;
...@@ -221,7 +221,7 @@ static __inline__ struct sock *netlink_lookup(int protocol, u32 pid) ...@@ -221,7 +221,7 @@ static __inline__ struct sock *netlink_lookup(int protocol, u32 pid)
read_lock(&nl_table_lock); read_lock(&nl_table_lock);
head = nl_pid_hashfn(hash, pid); head = nl_pid_hashfn(hash, pid);
sk_for_each(sk, node, head) { sk_for_each(sk, node, head) {
if (nlk_sk(sk)->pid == pid) { if ((sk->sk_net == net) && (nlk_sk(sk)->pid == pid)) {
sock_hold(sk); sock_hold(sk);
goto found; goto found;
} }
...@@ -328,7 +328,7 @@ netlink_update_listeners(struct sock *sk) ...@@ -328,7 +328,7 @@ netlink_update_listeners(struct sock *sk)
* makes sure updates are visible before bind or setsockopt return. */ * makes sure updates are visible before bind or setsockopt return. */
} }
static int netlink_insert(struct sock *sk, u32 pid) static int netlink_insert(struct sock *sk, struct net *net, u32 pid)
{ {
struct nl_pid_hash *hash = &nl_table[sk->sk_protocol].hash; struct nl_pid_hash *hash = &nl_table[sk->sk_protocol].hash;
struct hlist_head *head; struct hlist_head *head;
...@@ -341,7 +341,7 @@ static int netlink_insert(struct sock *sk, u32 pid) ...@@ -341,7 +341,7 @@ static int netlink_insert(struct sock *sk, u32 pid)
head = nl_pid_hashfn(hash, pid); head = nl_pid_hashfn(hash, pid);
len = 0; len = 0;
sk_for_each(osk, node, head) { sk_for_each(osk, node, head) {
if (nlk_sk(osk)->pid == pid) if ((osk->sk_net == net) && (nlk_sk(osk)->pid == pid))
break; break;
len++; len++;
} }
...@@ -419,9 +419,6 @@ static int netlink_create(struct net *net, struct socket *sock, int protocol) ...@@ -419,9 +419,6 @@ static int netlink_create(struct net *net, struct socket *sock, int protocol)
struct netlink_sock *nlk; struct netlink_sock *nlk;
int err = 0; int err = 0;
if (net != &init_net)
return -EAFNOSUPPORT;
sock->state = SS_UNCONNECTED; sock->state = SS_UNCONNECTED;
if (sock->type != SOCK_RAW && sock->type != SOCK_DGRAM) if (sock->type != SOCK_RAW && sock->type != SOCK_DGRAM)
...@@ -481,6 +478,7 @@ static int netlink_release(struct socket *sock) ...@@ -481,6 +478,7 @@ static int netlink_release(struct socket *sock)
if (nlk->pid && !nlk->subscriptions) { if (nlk->pid && !nlk->subscriptions) {
struct netlink_notify n = { struct netlink_notify n = {
.net = sk->sk_net,
.protocol = sk->sk_protocol, .protocol = sk->sk_protocol,
.pid = nlk->pid, .pid = nlk->pid,
}; };
...@@ -509,6 +507,7 @@ static int netlink_release(struct socket *sock) ...@@ -509,6 +507,7 @@ static int netlink_release(struct socket *sock)
static int netlink_autobind(struct socket *sock) static int netlink_autobind(struct socket *sock)
{ {
struct sock *sk = sock->sk; struct sock *sk = sock->sk;
struct net *net = sk->sk_net;
struct nl_pid_hash *hash = &nl_table[sk->sk_protocol].hash; struct nl_pid_hash *hash = &nl_table[sk->sk_protocol].hash;
struct hlist_head *head; struct hlist_head *head;
struct sock *osk; struct sock *osk;
...@@ -522,6 +521,8 @@ static int netlink_autobind(struct socket *sock) ...@@ -522,6 +521,8 @@ static int netlink_autobind(struct socket *sock)
netlink_table_grab(); netlink_table_grab();
head = nl_pid_hashfn(hash, pid); head = nl_pid_hashfn(hash, pid);
sk_for_each(osk, node, head) { sk_for_each(osk, node, head) {
if ((osk->sk_net != net))
continue;
if (nlk_sk(osk)->pid == pid) { if (nlk_sk(osk)->pid == pid) {
/* Bind collision, search negative pid values. */ /* Bind collision, search negative pid values. */
pid = rover--; pid = rover--;
...@@ -533,7 +534,7 @@ static int netlink_autobind(struct socket *sock) ...@@ -533,7 +534,7 @@ static int netlink_autobind(struct socket *sock)
} }
netlink_table_ungrab(); netlink_table_ungrab();
err = netlink_insert(sk, pid); err = netlink_insert(sk, net, pid);
if (err == -EADDRINUSE) if (err == -EADDRINUSE)
goto retry; goto retry;
...@@ -598,6 +599,7 @@ static int netlink_realloc_groups(struct sock *sk) ...@@ -598,6 +599,7 @@ static int netlink_realloc_groups(struct sock *sk)
static int netlink_bind(struct socket *sock, struct sockaddr *addr, int addr_len) static int netlink_bind(struct socket *sock, struct sockaddr *addr, int addr_len)
{ {
struct sock *sk = sock->sk; struct sock *sk = sock->sk;
struct net *net = sk->sk_net;
struct netlink_sock *nlk = nlk_sk(sk); struct netlink_sock *nlk = nlk_sk(sk);
struct sockaddr_nl *nladdr = (struct sockaddr_nl *)addr; struct sockaddr_nl *nladdr = (struct sockaddr_nl *)addr;
int err; int err;
...@@ -619,7 +621,7 @@ static int netlink_bind(struct socket *sock, struct sockaddr *addr, int addr_len ...@@ -619,7 +621,7 @@ static int netlink_bind(struct socket *sock, struct sockaddr *addr, int addr_len
return -EINVAL; return -EINVAL;
} else { } else {
err = nladdr->nl_pid ? err = nladdr->nl_pid ?
netlink_insert(sk, nladdr->nl_pid) : netlink_insert(sk, net, nladdr->nl_pid) :
netlink_autobind(sock); netlink_autobind(sock);
if (err) if (err)
return err; return err;
...@@ -703,10 +705,12 @@ static void netlink_overrun(struct sock *sk) ...@@ -703,10 +705,12 @@ static void netlink_overrun(struct sock *sk)
static struct sock *netlink_getsockbypid(struct sock *ssk, u32 pid) static struct sock *netlink_getsockbypid(struct sock *ssk, u32 pid)
{ {
int protocol = ssk->sk_protocol; int protocol = ssk->sk_protocol;
struct net *net;
struct sock *sock; struct sock *sock;
struct netlink_sock *nlk; struct netlink_sock *nlk;
sock = netlink_lookup(protocol, pid); net = ssk->sk_net;
sock = netlink_lookup(net, protocol, pid);
if (!sock) if (!sock)
return ERR_PTR(-ECONNREFUSED); return ERR_PTR(-ECONNREFUSED);
...@@ -887,6 +891,7 @@ static __inline__ int netlink_broadcast_deliver(struct sock *sk, struct sk_buff ...@@ -887,6 +891,7 @@ static __inline__ int netlink_broadcast_deliver(struct sock *sk, struct sk_buff
struct netlink_broadcast_data { struct netlink_broadcast_data {
struct sock *exclude_sk; struct sock *exclude_sk;
struct net *net;
u32 pid; u32 pid;
u32 group; u32 group;
int failure; int failure;
...@@ -909,6 +914,9 @@ static inline int do_one_broadcast(struct sock *sk, ...@@ -909,6 +914,9 @@ static inline int do_one_broadcast(struct sock *sk,
!test_bit(p->group - 1, nlk->groups)) !test_bit(p->group - 1, nlk->groups))
goto out; goto out;
if ((sk->sk_net != p->net))
goto out;
if (p->failure) { if (p->failure) {
netlink_overrun(sk); netlink_overrun(sk);
goto out; goto out;
...@@ -947,6 +955,7 @@ static inline int do_one_broadcast(struct sock *sk, ...@@ -947,6 +955,7 @@ static inline int do_one_broadcast(struct sock *sk,
int netlink_broadcast(struct sock *ssk, struct sk_buff *skb, u32 pid, int netlink_broadcast(struct sock *ssk, struct sk_buff *skb, u32 pid,
u32 group, gfp_t allocation) u32 group, gfp_t allocation)
{ {
struct net *net = ssk->sk_net;
struct netlink_broadcast_data info; struct netlink_broadcast_data info;
struct hlist_node *node; struct hlist_node *node;
struct sock *sk; struct sock *sk;
...@@ -954,6 +963,7 @@ int netlink_broadcast(struct sock *ssk, struct sk_buff *skb, u32 pid, ...@@ -954,6 +963,7 @@ int netlink_broadcast(struct sock *ssk, struct sk_buff *skb, u32 pid,
skb = netlink_trim(skb, allocation); skb = netlink_trim(skb, allocation);
info.exclude_sk = ssk; info.exclude_sk = ssk;
info.net = net;
info.pid = pid; info.pid = pid;
info.group = group; info.group = group;
info.failure = 0; info.failure = 0;
...@@ -1002,6 +1012,9 @@ static inline int do_one_set_err(struct sock *sk, ...@@ -1002,6 +1012,9 @@ static inline int do_one_set_err(struct sock *sk,
if (sk == p->exclude_sk) if (sk == p->exclude_sk)
goto out; goto out;
if (sk->sk_net != p->exclude_sk->sk_net)
goto out;
if (nlk->pid == p->pid || p->group - 1 >= nlk->ngroups || if (nlk->pid == p->pid || p->group - 1 >= nlk->ngroups ||
!test_bit(p->group - 1, nlk->groups)) !test_bit(p->group - 1, nlk->groups))
goto out; goto out;
...@@ -1304,7 +1317,7 @@ static void netlink_data_ready(struct sock *sk, int len) ...@@ -1304,7 +1317,7 @@ static void netlink_data_ready(struct sock *sk, int len)
*/ */
struct sock * struct sock *
netlink_kernel_create(int unit, unsigned int groups, netlink_kernel_create(struct net *net, int unit, unsigned int groups,
void (*input)(struct sock *sk, int len), void (*input)(struct sock *sk, int len),
struct mutex *cb_mutex, struct module *module) struct mutex *cb_mutex, struct module *module)
{ {
...@@ -1321,7 +1334,7 @@ netlink_kernel_create(int unit, unsigned int groups, ...@@ -1321,7 +1334,7 @@ netlink_kernel_create(int unit, unsigned int groups,
if (sock_create_lite(PF_NETLINK, SOCK_DGRAM, unit, &sock)) if (sock_create_lite(PF_NETLINK, SOCK_DGRAM, unit, &sock))
return NULL; return NULL;
if (__netlink_create(&init_net, sock, cb_mutex, unit) < 0) if (__netlink_create(net, sock, cb_mutex, unit) < 0)
goto out_sock_release; goto out_sock_release;
if (groups < 32) if (groups < 32)
...@@ -1336,18 +1349,20 @@ netlink_kernel_create(int unit, unsigned int groups, ...@@ -1336,18 +1349,20 @@ netlink_kernel_create(int unit, unsigned int groups,
if (input) if (input)
nlk_sk(sk)->data_ready = input; nlk_sk(sk)->data_ready = input;
if (netlink_insert(sk, 0)) if (netlink_insert(sk, net, 0))
goto out_sock_release; goto out_sock_release;
nlk = nlk_sk(sk); nlk = nlk_sk(sk);
nlk->flags |= NETLINK_KERNEL_SOCKET; nlk->flags |= NETLINK_KERNEL_SOCKET;
netlink_table_grab(); netlink_table_grab();
nl_table[unit].groups = groups; if (!nl_table[unit].registered) {
nl_table[unit].listeners = listeners; nl_table[unit].groups = groups;
nl_table[unit].cb_mutex = cb_mutex; nl_table[unit].listeners = listeners;
nl_table[unit].module = module; nl_table[unit].cb_mutex = cb_mutex;
nl_table[unit].registered = 1; nl_table[unit].module = module;
nl_table[unit].registered = 1;
}
netlink_table_ungrab(); netlink_table_ungrab();
return sk; return sk;
...@@ -1513,7 +1528,7 @@ int netlink_dump_start(struct sock *ssk, struct sk_buff *skb, ...@@ -1513,7 +1528,7 @@ int netlink_dump_start(struct sock *ssk, struct sk_buff *skb,
atomic_inc(&skb->users); atomic_inc(&skb->users);
cb->skb = skb; cb->skb = skb;
sk = netlink_lookup(ssk->sk_protocol, NETLINK_CB(skb).pid); sk = netlink_lookup(ssk->sk_net, ssk->sk_protocol, NETLINK_CB(skb).pid);
if (sk == NULL) { if (sk == NULL) {
netlink_destroy_callback(cb); netlink_destroy_callback(cb);
return -ECONNREFUSED; return -ECONNREFUSED;
...@@ -1555,7 +1570,8 @@ void netlink_ack(struct sk_buff *in_skb, struct nlmsghdr *nlh, int err) ...@@ -1555,7 +1570,8 @@ void netlink_ack(struct sk_buff *in_skb, struct nlmsghdr *nlh, int err)
if (!skb) { if (!skb) {
struct sock *sk; struct sock *sk;
sk = netlink_lookup(in_skb->sk->sk_protocol, sk = netlink_lookup(in_skb->sk->sk_net,
in_skb->sk->sk_protocol,
NETLINK_CB(in_skb).pid); NETLINK_CB(in_skb).pid);
if (sk) { if (sk) {
sk->sk_err = ENOBUFS; sk->sk_err = ENOBUFS;
...@@ -1706,6 +1722,7 @@ int nlmsg_notify(struct sock *sk, struct sk_buff *skb, u32 pid, ...@@ -1706,6 +1722,7 @@ int nlmsg_notify(struct sock *sk, struct sk_buff *skb, u32 pid,
#ifdef CONFIG_PROC_FS #ifdef CONFIG_PROC_FS
struct nl_seq_iter { struct nl_seq_iter {
struct net *net;
int link; int link;
int hash_idx; int hash_idx;
}; };
...@@ -1723,6 +1740,8 @@ static struct sock *netlink_seq_socket_idx(struct seq_file *seq, loff_t pos) ...@@ -1723,6 +1740,8 @@ static struct sock *netlink_seq_socket_idx(struct seq_file *seq, loff_t pos)
for (j = 0; j <= hash->mask; j++) { for (j = 0; j <= hash->mask; j++) {
sk_for_each(s, node, &hash->table[j]) { sk_for_each(s, node, &hash->table[j]) {
if (iter->net != s->sk_net)
continue;
if (off == pos) { if (off == pos) {
iter->link = i; iter->link = i;
iter->hash_idx = j; iter->hash_idx = j;
...@@ -1752,11 +1771,14 @@ static void *netlink_seq_next(struct seq_file *seq, void *v, loff_t *pos) ...@@ -1752,11 +1771,14 @@ static void *netlink_seq_next(struct seq_file *seq, void *v, loff_t *pos)
if (v == SEQ_START_TOKEN) if (v == SEQ_START_TOKEN)
return netlink_seq_socket_idx(seq, 0); return netlink_seq_socket_idx(seq, 0);
s = sk_next(v); iter = seq->private;
s = v;
do {
s = sk_next(s);
} while (s && (iter->net != s->sk_net));
if (s) if (s)
return s; return s;
iter = seq->private;
i = iter->link; i = iter->link;
j = iter->hash_idx + 1; j = iter->hash_idx + 1;
...@@ -1765,6 +1787,8 @@ static void *netlink_seq_next(struct seq_file *seq, void *v, loff_t *pos) ...@@ -1765,6 +1787,8 @@ static void *netlink_seq_next(struct seq_file *seq, void *v, loff_t *pos)
for (; j <= hash->mask; j++) { for (; j <= hash->mask; j++) {
s = sk_head(&hash->table[j]); s = sk_head(&hash->table[j]);
while (s && (iter->net != s->sk_net))
s = sk_next(s);
if (s) { if (s) {
iter->link = i; iter->link = i;
iter->hash_idx = j; iter->hash_idx = j;
...@@ -1835,15 +1859,24 @@ static int netlink_seq_open(struct inode *inode, struct file *file) ...@@ -1835,15 +1859,24 @@ static int netlink_seq_open(struct inode *inode, struct file *file)
seq = file->private_data; seq = file->private_data;
seq->private = iter; seq->private = iter;
iter->net = get_net(PROC_NET(inode));
return 0; return 0;
} }
static int netlink_seq_release(struct inode *inode, struct file *file)
{
struct seq_file *seq = file->private_data;
struct nl_seq_iter *iter = seq->private;
put_net(iter->net);
return seq_release_private(inode, file);
}
static const struct file_operations netlink_seq_fops = { static const struct file_operations netlink_seq_fops = {
.owner = THIS_MODULE, .owner = THIS_MODULE,
.open = netlink_seq_open, .open = netlink_seq_open,
.read = seq_read, .read = seq_read,
.llseek = seq_lseek, .llseek = seq_lseek,
.release = seq_release_private, .release = netlink_seq_release,
}; };
#endif #endif
...@@ -1885,6 +1918,27 @@ static struct net_proto_family netlink_family_ops = { ...@@ -1885,6 +1918,27 @@ static struct net_proto_family netlink_family_ops = {
.owner = THIS_MODULE, /* for consistency 8) */ .owner = THIS_MODULE, /* for consistency 8) */
}; };
static int netlink_net_init(struct net *net)
{
#ifdef CONFIG_PROC_FS
if (!proc_net_fops_create(net, "netlink", 0, &netlink_seq_fops))
return -ENOMEM;
#endif
return 0;
}
static void netlink_net_exit(struct net *net)
{
#ifdef CONFIG_PROC_FS
proc_net_remove(net, "netlink");
#endif
}
static struct pernet_operations netlink_net_ops = {
.init = netlink_net_init,
.exit = netlink_net_exit,
};
static int __init netlink_proto_init(void) static int __init netlink_proto_init(void)
{ {
struct sk_buff *dummy_skb; struct sk_buff *dummy_skb;
...@@ -1930,9 +1984,7 @@ static int __init netlink_proto_init(void) ...@@ -1930,9 +1984,7 @@ static int __init netlink_proto_init(void)
} }
sock_register(&netlink_family_ops); sock_register(&netlink_family_ops);
#ifdef CONFIG_PROC_FS register_pernet_subsys(&netlink_net_ops);
proc_net_fops_create(&init_net, "netlink", 0, &netlink_seq_fops);
#endif
/* The netlink device handler may be needed early. */ /* The netlink device handler may be needed early. */
rtnetlink_init(); rtnetlink_init();
out: out:
......
...@@ -782,8 +782,8 @@ static int __init genl_init(void) ...@@ -782,8 +782,8 @@ static int __init genl_init(void)
netlink_set_nonroot(NETLINK_GENERIC, NL_NONROOT_RECV); netlink_set_nonroot(NETLINK_GENERIC, NL_NONROOT_RECV);
/* we'll bump the group number right afterwards */ /* we'll bump the group number right afterwards */
genl_sock = netlink_kernel_create(NETLINK_GENERIC, 0, genl_rcv, genl_sock = netlink_kernel_create(&init_net, NETLINK_GENERIC, 0,
NULL, THIS_MODULE); genl_rcv, NULL, THIS_MODULE);
if (genl_sock == NULL) if (genl_sock == NULL)
panic("GENL: Cannot initialize generic netlink\n"); panic("GENL: Cannot initialize generic netlink\n");
......
...@@ -2399,7 +2399,7 @@ static int __init xfrm_user_init(void) ...@@ -2399,7 +2399,7 @@ static int __init xfrm_user_init(void)
printk(KERN_INFO "Initializing XFRM netlink socket\n"); printk(KERN_INFO "Initializing XFRM netlink socket\n");
nlsk = netlink_kernel_create(NETLINK_XFRM, XFRMNLGRP_MAX, nlsk = netlink_kernel_create(&init_net, NETLINK_XFRM, XFRMNLGRP_MAX,
xfrm_netlink_rcv, NULL, THIS_MODULE); xfrm_netlink_rcv, NULL, THIS_MODULE);
if (nlsk == NULL) if (nlsk == NULL)
return -ENOMEM; return -ENOMEM;
......
...@@ -17,6 +17,7 @@ ...@@ -17,6 +17,7 @@
#include <linux/skbuff.h> #include <linux/skbuff.h>
#include <linux/netlink.h> #include <linux/netlink.h>
#include <linux/selinux_netlink.h> #include <linux/selinux_netlink.h>
#include <net/net_namespace.h>
static struct sock *selnl; static struct sock *selnl;
...@@ -104,8 +105,8 @@ void selnl_notify_policyload(u32 seqno) ...@@ -104,8 +105,8 @@ void selnl_notify_policyload(u32 seqno)
static int __init selnl_init(void) static int __init selnl_init(void)
{ {
selnl = netlink_kernel_create(NETLINK_SELINUX, SELNLGRP_MAX, NULL, NULL, selnl = netlink_kernel_create(&init_net, NETLINK_SELINUX,
THIS_MODULE); SELNLGRP_MAX, NULL, NULL, THIS_MODULE);
if (selnl == NULL) if (selnl == NULL)
panic("SELinux: Cannot create netlink socket."); panic("SELinux: Cannot create netlink socket.");
netlink_set_nonroot(NETLINK_SELINUX, NL_NONROOT_RECV); netlink_set_nonroot(NETLINK_SELINUX, NL_NONROOT_RECV);
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment