datapath: Encapsulate parameters for new vports in new struct vport_parms.

Upcoming commits will keep needing to pass more information to the vport
'create' member function.  It's annoying to have to modify a dozen pieces
of code every time just to do this, so this commit encapsulates all of the
parameters in a new struct and passes that instead.

Acked-by: Jesse Gross <jesse@nicira.com>

diff --git a/datapath/datapath.c b/datapath/datapath.c
index bed48039b63a2e0d9a8b1b0870b53f96a1bbe7e4..529d496913ec3c418f611530d729f5e24a7aeed3 100644 (file)
--- a/datapath/datapath.c
+++ b/datapath/datapath.c
@@ -356,13 +356,14 @@ static int new_dp_port(struct datapath *dp, struct odp_port *odp_port, int port_
 
        vport = vport_locate(odp_port->devname);
        if (!vport) {
-               vport_lock();
+               struct vport_parms parms;
 
-               if (odp_port->flags & ODP_PORT_INTERNAL)
-                       vport = vport_add(odp_port->devname, "internal", NULL);
-               else
-                       vport = vport_add(odp_port->devname, "netdev", NULL);
+               parms.name = odp_port->devname;
+               parms.type = odp_port->flags & ODP_PORT_INTERNAL ? "internal" : "netdev";
+               parms.config = NULL;
 
+               vport_lock();
+               vport = vport_add(&parms);
                vport_unlock();
 
                if (IS_ERR(vport))

diff --git a/datapath/tunnel.c b/datapath/tunnel.c
index d3625d35b654eaedd7f3843a6e48a15e1c2851bc..cdbb4f45609ffa5bce8616bc4357e4c091f7cd45 100644 (file)
--- a/datapath/tunnel.c
+++ b/datapath/tunnel.c
@@ -1344,7 +1344,7 @@ static int set_config(const void __user *uconfig, const struct tnl_ops *tnl_ops,
        return 0;
 }
 
-struct vport *tnl_create(const char *name, const void __user *config,
+struct vport *tnl_create(const struct vport_parms *parms,
                         const struct vport_ops *vport_ops,
                         const struct tnl_ops *tnl_ops)
 {
@@ -1361,7 +1361,7 @@ struct vport *tnl_create(const char *name, const void __user *config,
 
        tnl_vport = tnl_vport_priv(vport);
 
-       strcpy(tnl_vport->name, name);
+       strcpy(tnl_vport->name, parms->name);
        tnl_vport->tnl_ops = tnl_ops;
 
        tnl_vport->mutable = kzalloc(sizeof(struct tnl_mutable_config), GFP_KERNEL);
@@ -1376,7 +1376,7 @@ struct vport *tnl_create(const char *name, const void __user *config,
        get_random_bytes(&initial_frag_id, sizeof(int));
        atomic_set(&tnl_vport->frag_id, initial_frag_id);
 
-       err = set_config(config, tnl_ops, NULL, tnl_vport->mutable);
+       err = set_config(parms->config, tnl_ops, NULL, tnl_vport->mutable);
        if (err)
                goto error_free_mutable;
 

diff --git a/datapath/tunnel.h b/datapath/tunnel.h
index 8ffb7bf544446f9b108b683f1ba3aa154ff693d9..63f7dd42c0c5a2b334b5edcf3e172c771cfdccbd 100644 (file)
--- a/datapath/tunnel.h
+++ b/datapath/tunnel.h
@@ -184,8 +184,7 @@ struct tnl_vport {
 #endif
 };
 
-struct vport *tnl_create(const char *name, const void __user *config,
-                        const struct vport_ops *,
+struct vport *tnl_create(const struct vport_parms *, const struct vport_ops *,
                         const struct tnl_ops *);
 int tnl_modify(struct vport *, const void __user *config);
 int tnl_destroy(struct vport *);

diff --git a/datapath/vport-capwap.c b/datapath/vport-capwap.c
index 1c2d41b257f8a8e16152b2bb451b463a5310b9f4..3f6f941fd610b841091b289a25afdf194b31c503 100644 (file)
--- a/datapath/vport-capwap.c
+++ b/datapath/vport-capwap.c
@@ -220,9 +220,9 @@ static const struct tnl_ops capwap_tnl_ops = {
        .update_header  = capwap_update_header,
 };
 
-static struct vport *capwap_create(const char *name, const void __user *config)
+static struct vport *capwap_create(const struct vport_parms *parms)
 {
-       return tnl_create(name, config, &capwap_vport_ops, &capwap_tnl_ops);
+       return tnl_create(parms, &capwap_vport_ops, &capwap_tnl_ops);
 }
 
 /* Random value.  Irrelevant as long as it's not 0 since we set the handler. */

diff --git a/datapath/vport-gre.c b/datapath/vport-gre.c
index 10ee63fecef9777039ad21844a57283a18d4fe16..f6996ed4004e4e2b32eb4669989a7ab9a018cb35 100644 (file)
--- a/datapath/vport-gre.c
+++ b/datapath/vport-gre.c
@@ -340,9 +340,9 @@ static const struct tnl_ops gre_tnl_ops = {
        .update_header  = gre_update_header,
 };
 
-static struct vport *gre_create(const char *name, const void __user *config)
+static struct vport *gre_create(const struct vport_parms *parms)
 {
-       return tnl_create(name, config, &gre_vport_ops, &gre_tnl_ops);
+       return tnl_create(parms, &gre_vport_ops, &gre_tnl_ops);
 }
 
 static const struct net_protocol gre_protocol_handlers = {

diff --git a/datapath/vport-internal_dev.c b/datapath/vport-internal_dev.c
index f5a531f39863cb91342568f016f2121abed707cc..c4de2be66eaf0b55a2a4c795c8cfdb016537f3ac 100644 (file)
--- a/datapath/vport-internal_dev.c
+++ b/datapath/vport-internal_dev.c
@@ -187,8 +187,7 @@ static void do_setup(struct net_device *netdev)
        vport_gen_rand_ether_addr(netdev->dev_addr);
 }
 
-static struct vport *internal_dev_create(const char *name,
-                                        const void __user *config)
+static struct vport *internal_dev_create(const struct vport_parms *parms)
 {
        struct vport *vport;
        struct netdev_vport *netdev_vport;
@@ -203,7 +202,7 @@ static struct vport *internal_dev_create(const char *name,
 
        netdev_vport = netdev_vport_priv(vport);
 
-       netdev_vport->dev = alloc_netdev(sizeof(struct internal_dev), name, do_setup);
+       netdev_vport->dev = alloc_netdev(sizeof(struct internal_dev), parms->name, do_setup);
        if (!netdev_vport->dev) {
                err = -ENOMEM;
                goto error_free_vport;

diff --git a/datapath/vport-netdev.c b/datapath/vport-netdev.c
index 11421bf7a13542a4c5e9e6efdfa305425ef70f53..33fe9a513773e0fcc55983ec3043c06862855b1c 100644 (file)
--- a/datapath/vport-netdev.c
+++ b/datapath/vport-netdev.c
@@ -88,7 +88,7 @@ static void netdev_exit(void)
 }
 #endif
 
-static struct vport *netdev_create(const char *name, const void __user *config)
+static struct vport *netdev_create(const struct vport_parms *parms)
 {
        struct vport *vport;
        struct netdev_vport *netdev_vport;
@@ -102,7 +102,7 @@ static struct vport *netdev_create(const char *name, const void __user *config)
 
        netdev_vport = netdev_vport_priv(vport);
 
-       netdev_vport->dev = dev_get_by_name(&init_net, name);
+       netdev_vport->dev = dev_get_by_name(&init_net, parms->name);
        if (!netdev_vport->dev) {
                err = -ENODEV;
                goto error_free_vport;

diff --git a/datapath/vport-patch.c b/datapath/vport-patch.c
index 81fa61b118cabd285ab6d59cdaa47266192abd06..eb3915805baf69d3d2d11983cde23d1a727d501b 100644 (file)
--- a/datapath/vport-patch.c
+++ b/datapath/vport-patch.c
@@ -109,7 +109,7 @@ static int set_config(struct vport *vport, const void __user *uconfig)
        return 0;
 }
 
-static struct vport *patch_create(const char *name, const void __user *config)
+static struct vport *patch_create(const struct vport_parms *parms)
 {
        struct vport *vport;
        struct patch_vport *patch_vport;
@@ -123,9 +123,9 @@ static struct vport *patch_create(const char *name, const void __user *config)
 
        patch_vport = patch_vport_priv(vport);
 
-       strcpy(patch_vport->name, name);
+       strcpy(patch_vport->name, parms->name);
 
-       err = set_config(vport, config);
+       err = set_config(vport, parms->config);
        if (err)
                goto error_free_vport;
 

diff --git a/datapath/vport.c b/datapath/vport.c
index fdbf522e8d73d4e92ca6b1b22cfe63c0edd1335c..ffdd5216bf75383969eca6d9512c03866be5e807 100644 (file)
--- a/datapath/vport.c
+++ b/datapath/vport.c
@@ -179,6 +179,7 @@ void vport_exit(void)
 
 static int do_vport_add(struct odp_vport_add *vport_config)
 {
+       struct vport_parms parms;
        struct vport *vport;
        int err = 0;
 
@@ -193,9 +194,12 @@ static int do_vport_add(struct odp_vport_add *vport_config)
                goto out;
        }
 
+       parms.name = vport_config->devname;
+       parms.type = vport_config->port_type;
+       parms.config = vport_config->config;
+
        vport_lock();
-       vport = vport_add(vport_config->devname, vport_config->port_type,
-                         vport_config->config);
+       vport = vport_add(&parms);
        vport_unlock();
 
        if (IS_ERR(vport))
@@ -703,15 +707,12 @@ void vport_free(struct vport *vport)
 /**
  *     vport_add - add vport device (for kernel callers)
  *
- * @name: Name of new device.
- * @type: Type of new device (to be matched against types in registered vport
- * ops).
- * @config: Device type specific configuration.  Userspace pointer.
+ * @parms: Information about new vport.
  *
  * Creates a new vport with the specified configuration (which is dependent
  * on device type).  Both RTNL and vport locks must be held.
  */
-struct vport *vport_add(const char *name, const char *type, const void __user *config)
+struct vport *vport_add(const struct vport_parms *parms)
 {
        struct vport *vport;
        int err = 0;
@@ -721,8 +722,8 @@ struct vport *vport_add(const char *name, const char *type, const void __user *c
        ASSERT_VPORT();
 
        for (i = 0; i < n_vport_types; i++) {
-               if (!strcmp(vport_ops_list[i]->type, type)) {
-                       vport = vport_ops_list[i]->create(name, config);
+               if (!strcmp(vport_ops_list[i]->type, parms->type)) {
+                       vport = vport_ops_list[i]->create(parms);
                        if (IS_ERR(vport)) {
                                err = PTR_ERR(vport);
                                goto out;

diff --git a/datapath/vport.h b/datapath/vport.h
index bacefa842e87953715cb9ce26f83e09892996830..5f3c7e9f1378beb15909e7fb392fb3d4ca8af732 100644 (file)
--- a/datapath/vport.h
+++ b/datapath/vport.h
@@ -19,6 +19,7 @@
 #include "odp-compat.h"
 
 struct vport;
+struct vport_parms;
 struct dp_port;
 
 /* The following definitions are for users of the vport subsytem: */
@@ -45,7 +46,7 @@ void vport_unlock(void);
 int vport_init(void);
 void vport_exit(void);
 
-struct vport *vport_add(const char *name, const char *type, const void __user *config);
+struct vport *vport_add(const struct vport_parms *);
 int vport_mod(struct vport *, const void __user *config);
 int vport_del(struct vport *);
 
@@ -111,6 +112,20 @@ struct vport {
 #define VPORT_F_FLOW           (1 << 2) /* Sets OVS_CB(skb)->flow. */
 #define VPORT_F_TUN_ID         (1 << 3) /* Sets OVS_CB(skb)->tun_id. */
 
+/**
+ * struct vport_parms - parameters for creating a new vport
+ *
+ * @name: New vport's name.
+ * @type: New vport's type.
+ * @config: New vport's configuration, as %NULL or a userspace pointer to an
+ * arbitrary type-specific structure.
+ */
+struct vport_parms {
+       const char *name;
+       const char *type;
+       const void __user *config;
+};
+
 /**
  * struct vport_ops - definition of a type of virtual port
  *
@@ -122,9 +137,8 @@ struct vport {
  * failure of this function will cause the module to not load.  If the flag is
  * not set and initialzation fails then no vports of this type can be created.
  * @exit: Called at module unload.
- * @create: Create a new vport called 'name' with vport type specific
- * configuration 'config' (which must be copied from userspace before use).  On
- * success must allocate a new vport using vport_alloc().
+ * @create: Create a new vport configured as specified.  On success returns
+ * a new vport allocated with vport_alloc(), otherwise an ERR_PTR() value.
  * @modify: Modify the configuration of an existing vport.  May be null if
  * modification is not supported.
  * @destroy: Destroy and free a vport using vport_free().  Prior to destruction
@@ -164,7 +178,7 @@ struct vport_ops {
        void (*exit)(void);
 
        /* Called with RTNL lock. */
-       struct vport *(*create)(const char *name, const void __user *config);
+       struct vport *(*create)(const struct vport_parms *);
        int (*modify)(struct vport *, const void __user *config);
        int (*destroy)(struct vport *);