From: Lee Duncan <[email protected]>

Prepare iSCSI netlink to operate in multiple namespaces.

Signed-off-by: Lee Duncan <[email protected]>
Reviewed-by: Hannes Reinecke <[email protected]>
Signed-off-by: Chris Leech <[email protected]>
---
 drivers/scsi/scsi_transport_iscsi.c | 73 +++++++++++++++++++++++++----
 1 file changed, 63 insertions(+), 10 deletions(-)

diff --git a/drivers/scsi/scsi_transport_iscsi.c 
b/drivers/scsi/scsi_transport_iscsi.c
index b9b97300e3b3..be69cea9c6f8 100644
--- a/drivers/scsi/scsi_transport_iscsi.c
+++ b/drivers/scsi/scsi_transport_iscsi.c
@@ -13,6 +13,8 @@
 #include <linux/bsg-lib.h>
 #include <linux/idr.h>
 #include <net/tcp.h>
+#include <net/net_namespace.h>
+#include <net/netns/generic.h>
 #include <scsi/scsi.h>
 #include <scsi/scsi_host.h>
 #include <scsi/scsi_device.h>
@@ -1597,7 +1599,11 @@ static DECLARE_TRANSPORT_CLASS(iscsi_connection_class,
                               NULL,
                               NULL);
 
-static struct sock *nls;
+struct iscsi_net {
+       struct sock *nls;
+};
+
+static int iscsi_net_id __read_mostly;
 static DEFINE_MUTEX(rx_queue_mutex);
 
 static LIST_HEAD(sesslist);
@@ -2552,14 +2558,32 @@ iscsi_if_transport_lookup(struct iscsi_transport *tt)
 }
 
 static int
-iscsi_multicast_skb(struct sk_buff *skb, uint32_t group, gfp_t gfp)
+iscsi_multicast_netns(struct net *net, struct sk_buff *skb,
+                     uint32_t group, gfp_t gfp)
 {
+       struct sock *nls;
+       struct iscsi_net *isn;
+
+       isn = net_generic(net, iscsi_net_id);
+       nls = isn->nls;
        return nlmsg_multicast(nls, skb, 0, group, gfp);
 }
 
+static int
+iscsi_multicast_skb(struct sk_buff *skb, uint32_t group, gfp_t gfp)
+{
+       return iscsi_multicast_netns(&init_net, skb, group, gfp);
+}
+
 static int
 iscsi_unicast_skb(struct sk_buff *skb, u32 portid)
 {
+       struct sock *nls;
+       struct iscsi_net *isn;
+       struct net *net = &init_net;
+
+       isn = net_generic(net, iscsi_net_id);
+       nls = isn->nls;
        return nlmsg_unicast(nls, skb, portid);
 }
 
@@ -4937,13 +4961,42 @@ void iscsi_dbg_trace(void (*trace)(struct device *dev, 
struct va_format *),
 }
 EXPORT_SYMBOL_GPL(iscsi_dbg_trace);
 
-static __init int iscsi_transport_init(void)
+static int __net_init iscsi_net_init(struct net *net)
 {
-       int err;
+       struct sock *nls;
+       struct iscsi_net *isn;
        struct netlink_kernel_cfg cfg = {
                .groups = 1,
                .input  = iscsi_if_rx,
        };
+
+       nls = netlink_kernel_create(net, NETLINK_ISCSI, &cfg);
+       if (!nls)
+               return -ENOMEM;
+       isn = net_generic(net, iscsi_net_id);
+       isn->nls = nls;
+       return 0;
+}
+
+static void __net_exit iscsi_net_exit(struct net *net)
+{
+       struct iscsi_net *isn;
+
+       isn = net_generic(net, iscsi_net_id);
+       netlink_kernel_release(isn->nls);
+       isn->nls = NULL;
+}
+
+static struct pernet_operations iscsi_net_ops = {
+       .init = iscsi_net_init,
+       .exit = iscsi_net_exit,
+       .id   = &iscsi_net_id,
+       .size = sizeof(struct iscsi_net),
+};
+
+static __init int iscsi_transport_init(void)
+{
+       int err;
        printk(KERN_INFO "Loading iSCSI transport class v%s.\n",
                ISCSI_TRANSPORT_VERSION);
 
@@ -4977,8 +5030,8 @@ static __init int iscsi_transport_init(void)
        if (err)
                goto unregister_session_class;
 
-       nls = netlink_kernel_create(&init_net, NETLINK_ISCSI, &cfg);
-       if (!nls) {
+       err = register_pernet_subsys(&iscsi_net_ops);
+       if (err) {
                err = -ENOBUFS;
                goto unregister_flashnode_bus;
        }
@@ -4988,13 +5041,13 @@ static __init int iscsi_transport_init(void)
                        "iscsi_conn_cleanup");
        if (!iscsi_conn_cleanup_workq) {
                err = -ENOMEM;
-               goto release_nls;
+               goto unregister_pernet_subsys;
        }
 
        return 0;
 
-release_nls:
-       netlink_kernel_release(nls);
+unregister_pernet_subsys:
+       unregister_pernet_subsys(&iscsi_net_ops);
 unregister_flashnode_bus:
        bus_unregister(&iscsi_flashnode_bus);
 unregister_session_class:
@@ -5015,7 +5068,7 @@ static __init int iscsi_transport_init(void)
 static void __exit iscsi_transport_exit(void)
 {
        destroy_workqueue(iscsi_conn_cleanup_workq);
-       netlink_kernel_release(nls);
+       unregister_pernet_subsys(&iscsi_net_ops);
        bus_unregister(&iscsi_flashnode_bus);
        transport_class_unregister(&iscsi_connection_class);
        transport_class_unregister(&iscsi_session_class);
-- 
2.39.2

-- 
You received this message because you are subscribed to the Google Groups 
"open-iscsi" group.
To unsubscribe from this group and stop receiving emails from it, send an email 
to [email protected].
To view this discussion on the web visit 
https://groups.google.com/d/msgid/open-iscsi/20230506232930.195451-2-cleech%40redhat.com.

Reply via email to