2010-05-17 15:04:10 -07:00
|
|
|
|
/*
|
2012-12-26 17:02:08 -08:00
|
|
|
|
* Copyright (c) 2010, 2011, 2012, 2013 Nicira, Inc.
|
2010-05-17 15:04:10 -07:00
|
|
|
|
*
|
|
|
|
|
* Licensed under the Apache License, Version 2.0 (the "License");
|
|
|
|
|
* you may not use this file except in compliance with the License.
|
|
|
|
|
* You may obtain a copy of the License at:
|
|
|
|
|
*
|
|
|
|
|
* http://www.apache.org/licenses/LICENSE-2.0
|
|
|
|
|
*
|
2010-09-24 10:55:57 -07:00
|
|
|
|
* Unless required by applicable law or agreed to in writing, software
|
2010-05-17 15:04:10 -07:00
|
|
|
|
* distributed under the License is distributed on an "AS IS" BASIS,
|
|
|
|
|
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
|
|
|
* See the License for the specific language governing permissions and
|
|
|
|
|
* limitations under the License.
|
|
|
|
|
*/
|
|
|
|
|
|
|
|
|
|
#include <config.h>
|
2010-10-06 15:35:53 -07:00
|
|
|
|
|
|
|
|
|
#include "netdev-vport.h"
|
|
|
|
|
|
2010-05-17 15:04:10 -07:00
|
|
|
|
#include <errno.h>
|
|
|
|
|
#include <fcntl.h>
|
2010-12-21 16:26:21 -08:00
|
|
|
|
#include <sys/socket.h>
|
2010-10-06 15:35:53 -07:00
|
|
|
|
#include <net/if.h>
|
2010-05-17 15:04:10 -07:00
|
|
|
|
#include <sys/ioctl.h>
|
|
|
|
|
|
2010-12-10 10:42:42 -08:00
|
|
|
|
#include "byte-order.h"
|
2011-03-11 15:18:30 -08:00
|
|
|
|
#include "daemon.h"
|
|
|
|
|
#include "dirs.h"
|
2012-12-20 15:32:03 -08:00
|
|
|
|
#include "dpif.h"
|
2010-12-21 16:26:21 -08:00
|
|
|
|
#include "hash.h"
|
|
|
|
|
#include "hmap.h"
|
2010-05-17 15:04:10 -07:00
|
|
|
|
#include "list.h"
|
2010-10-06 15:35:53 -07:00
|
|
|
|
#include "netdev-provider.h"
|
2010-12-21 16:26:21 -08:00
|
|
|
|
#include "ofpbuf.h"
|
2010-10-06 15:35:53 -07:00
|
|
|
|
#include "packets.h"
|
2011-01-12 14:55:18 -08:00
|
|
|
|
#include "route-table.h"
|
2010-05-17 15:04:10 -07:00
|
|
|
|
#include "shash.h"
|
|
|
|
|
#include "socket-util.h"
|
|
|
|
|
#include "vlog.h"
|
|
|
|
|
|
2010-10-19 14:47:01 -07:00
|
|
|
|
VLOG_DEFINE_THIS_MODULE(netdev_vport);
|
2010-07-16 11:02:49 -07:00
|
|
|
|
|
2013-04-26 14:30:24 -04:00
|
|
|
|
#define VXLAN_DST_PORT 4789
|
2013-02-21 21:52:04 -08:00
|
|
|
|
#define LISP_DST_PORT 4341
|
|
|
|
|
|
2013-01-07 16:56:04 -08:00
|
|
|
|
#define DEFAULT_TTL 64
|
|
|
|
|
|
2013-03-15 15:54:36 -07:00
|
|
|
|
struct netdev_vport {
|
|
|
|
|
struct netdev up;
|
2013-08-09 21:34:02 -07:00
|
|
|
|
|
|
|
|
|
/* Protects all members below. */
|
|
|
|
|
struct ovs_mutex mutex;
|
|
|
|
|
|
2012-11-30 11:36:42 -08:00
|
|
|
|
uint8_t etheraddr[ETH_ADDR_LEN];
|
2012-12-14 19:14:54 -08:00
|
|
|
|
struct netdev_stats stats;
|
2012-12-20 15:32:03 -08:00
|
|
|
|
|
|
|
|
|
/* Tunnels. */
|
2013-01-07 16:56:04 -08:00
|
|
|
|
struct netdev_tunnel_config tnl_cfg;
|
2012-12-20 15:32:03 -08:00
|
|
|
|
|
|
|
|
|
/* Patch Ports. */
|
|
|
|
|
char *peer;
|
2010-10-06 15:35:53 -07:00
|
|
|
|
};
|
|
|
|
|
|
|
|
|
|
struct vport_class {
|
2012-12-14 19:14:54 -08:00
|
|
|
|
const char *dpif_port;
|
2010-12-03 14:41:38 -08:00
|
|
|
|
struct netdev_class netdev_class;
|
2010-10-06 15:35:53 -07:00
|
|
|
|
};
|
|
|
|
|
|
2013-08-09 21:21:38 -07:00
|
|
|
|
static int netdev_vport_construct(struct netdev *);
|
2013-08-09 21:34:02 -07:00
|
|
|
|
static int get_patch_config(const struct netdev *netdev, struct smap *args);
|
2013-03-15 15:54:36 -07:00
|
|
|
|
static int get_tunnel_config(const struct netdev *, struct smap *args);
|
2010-10-06 15:35:53 -07:00
|
|
|
|
|
|
|
|
|
static bool
|
|
|
|
|
is_vport_class(const struct netdev_class *class)
|
2010-05-17 15:04:10 -07:00
|
|
|
|
{
|
2013-08-09 21:21:38 -07:00
|
|
|
|
return class->construct == netdev_vport_construct;
|
2010-10-06 15:35:53 -07:00
|
|
|
|
}
|
2010-05-17 15:04:10 -07:00
|
|
|
|
|
2010-10-06 15:35:53 -07:00
|
|
|
|
static const struct vport_class *
|
|
|
|
|
vport_class_cast(const struct netdev_class *class)
|
|
|
|
|
{
|
2012-11-06 13:14:55 -08:00
|
|
|
|
ovs_assert(is_vport_class(class));
|
2010-10-06 15:35:53 -07:00
|
|
|
|
return CONTAINER_OF(class, struct vport_class, netdev_class);
|
|
|
|
|
}
|
|
|
|
|
|
2013-03-15 15:54:36 -07:00
|
|
|
|
static struct netdev_vport *
|
|
|
|
|
netdev_vport_cast(const struct netdev *netdev)
|
2010-10-06 15:35:53 -07:00
|
|
|
|
{
|
2013-03-15 15:54:36 -07:00
|
|
|
|
ovs_assert(is_vport_class(netdev_get_class(netdev)));
|
|
|
|
|
return CONTAINER_OF(netdev, struct netdev_vport, up);
|
2012-12-26 16:33:58 -08:00
|
|
|
|
}
|
|
|
|
|
|
2013-01-07 16:56:04 -08:00
|
|
|
|
static const struct netdev_tunnel_config *
|
2013-03-15 15:54:36 -07:00
|
|
|
|
get_netdev_tunnel_config(const struct netdev *netdev)
|
2013-01-07 16:56:04 -08:00
|
|
|
|
{
|
2013-03-15 15:54:36 -07:00
|
|
|
|
return &netdev_vport_cast(netdev)->tnl_cfg;
|
2013-01-07 16:56:04 -08:00
|
|
|
|
}
|
|
|
|
|
|
2012-12-20 15:32:03 -08:00
|
|
|
|
bool
|
|
|
|
|
netdev_vport_is_patch(const struct netdev *netdev)
|
|
|
|
|
{
|
2013-03-15 15:54:36 -07:00
|
|
|
|
const struct netdev_class *class = netdev_get_class(netdev);
|
2013-01-25 14:17:49 -08:00
|
|
|
|
|
2013-01-25 13:30:40 -08:00
|
|
|
|
return class->get_config == get_patch_config;
|
2012-12-20 15:32:03 -08:00
|
|
|
|
}
|
|
|
|
|
|
2013-11-19 11:06:44 +02:00
|
|
|
|
bool
|
|
|
|
|
netdev_vport_is_layer3(const struct netdev *dev)
|
|
|
|
|
{
|
|
|
|
|
const char *type = netdev_get_type(dev);
|
|
|
|
|
|
|
|
|
|
return (!strcmp("lisp", type));
|
|
|
|
|
}
|
|
|
|
|
|
2013-02-14 09:37:25 -05:00
|
|
|
|
static bool
|
2013-03-15 15:54:36 -07:00
|
|
|
|
netdev_vport_needs_dst_port(const struct netdev *dev)
|
2013-02-14 09:37:25 -05:00
|
|
|
|
{
|
2013-03-15 15:54:36 -07:00
|
|
|
|
const struct netdev_class *class = netdev_get_class(dev);
|
|
|
|
|
const char *type = netdev_get_type(dev);
|
2013-02-14 09:37:25 -05:00
|
|
|
|
|
2013-02-21 21:52:04 -08:00
|
|
|
|
return (class->get_config == get_tunnel_config &&
|
|
|
|
|
(!strcmp("vxlan", type) || !strcmp("lisp", type)));
|
2013-02-14 09:37:25 -05:00
|
|
|
|
}
|
|
|
|
|
|
2013-05-16 14:11:51 -07:00
|
|
|
|
const char *
|
|
|
|
|
netdev_vport_class_get_dpif_port(const struct netdev_class *class)
|
|
|
|
|
{
|
|
|
|
|
return is_vport_class(class) ? vport_class_cast(class)->dpif_port : NULL;
|
|
|
|
|
}
|
|
|
|
|
|
2012-12-16 17:08:50 -08:00
|
|
|
|
const char *
|
2013-05-01 11:05:28 -07:00
|
|
|
|
netdev_vport_get_dpif_port(const struct netdev *netdev,
|
|
|
|
|
char namebuf[], size_t bufsize)
|
2012-12-16 17:08:50 -08:00
|
|
|
|
{
|
2013-03-15 15:54:36 -07:00
|
|
|
|
if (netdev_vport_needs_dst_port(netdev)) {
|
|
|
|
|
const struct netdev_vport *vport = netdev_vport_cast(netdev);
|
|
|
|
|
const char *type = netdev_get_type(netdev);
|
2013-02-14 09:37:25 -05:00
|
|
|
|
|
|
|
|
|
/*
|
|
|
|
|
* Note: IFNAMSIZ is 16 bytes long. The maximum length of a VXLAN
|
2013-02-21 21:52:04 -08:00
|
|
|
|
* or LISP port name below is 15 or 14 bytes respectively. Still,
|
|
|
|
|
* assert here on the size of strlen(type) in case that changes
|
|
|
|
|
* in the future.
|
2013-02-14 09:37:25 -05:00
|
|
|
|
*/
|
2013-05-01 11:05:28 -07:00
|
|
|
|
BUILD_ASSERT(NETDEV_VPORT_NAME_BUFSIZE >= IFNAMSIZ);
|
2013-02-14 09:37:25 -05:00
|
|
|
|
ovs_assert(strlen(type) + 10 < IFNAMSIZ);
|
2013-05-01 11:05:28 -07:00
|
|
|
|
snprintf(namebuf, bufsize, "%s_sys_%d", type,
|
2013-02-14 09:37:25 -05:00
|
|
|
|
ntohs(vport->tnl_cfg.dst_port));
|
2013-05-01 11:05:28 -07:00
|
|
|
|
return namebuf;
|
2013-02-14 09:37:25 -05:00
|
|
|
|
} else {
|
2013-03-15 15:54:36 -07:00
|
|
|
|
const struct netdev_class *class = netdev_get_class(netdev);
|
2013-04-15 15:55:56 -07:00
|
|
|
|
const char *dpif_port = netdev_vport_class_get_dpif_port(class);
|
|
|
|
|
return dpif_port ? dpif_port : netdev_get_name(netdev);
|
2013-02-14 09:37:25 -05:00
|
|
|
|
}
|
2010-10-06 15:35:53 -07:00
|
|
|
|
}
|
2010-05-17 15:04:10 -07:00
|
|
|
|
|
2013-05-01 11:05:28 -07:00
|
|
|
|
char *
|
|
|
|
|
netdev_vport_get_dpif_port_strdup(const struct netdev *netdev)
|
|
|
|
|
{
|
|
|
|
|
char namebuf[NETDEV_VPORT_NAME_BUFSIZE];
|
|
|
|
|
|
|
|
|
|
return xstrdup(netdev_vport_get_dpif_port(netdev, namebuf,
|
|
|
|
|
sizeof namebuf));
|
|
|
|
|
}
|
|
|
|
|
|
2013-08-09 21:21:38 -07:00
|
|
|
|
static struct netdev *
|
|
|
|
|
netdev_vport_alloc(void)
|
|
|
|
|
{
|
|
|
|
|
struct netdev_vport *netdev = xzalloc(sizeof *netdev);
|
|
|
|
|
return &netdev->up;
|
|
|
|
|
}
|
|
|
|
|
|
2010-10-06 15:35:53 -07:00
|
|
|
|
static int
|
2013-08-09 21:21:38 -07:00
|
|
|
|
netdev_vport_construct(struct netdev *netdev_)
|
2010-10-06 15:35:53 -07:00
|
|
|
|
{
|
2013-08-09 21:21:38 -07:00
|
|
|
|
struct netdev_vport *netdev = netdev_vport_cast(netdev_);
|
2010-12-29 16:02:22 -08:00
|
|
|
|
|
Use "error-checking" mutexes in place of other kinds wherever possible.
We've seen a number of deadlocks in the tree since thread safety was
introduced. So far, all of these are self-deadlocks, that is, a single
thread acquiring a lock and then attempting to re-acquire the same lock
recursively. When this has happened, the process simply hung, and it was
somewhat difficult to find the cause.
POSIX "error-checking" mutexes check for this specific problem (and
others). This commit switches from other types of mutexes to
error-checking mutexes everywhere that we can, that is, everywhere that
we're not using recursive mutexes. This ought to help find problems more
quickly in the future.
There might be performance advantages to other kinds of mutexes in some
cases. However, the existing mutex type choices were just guesses, so I'd
rather go for easy detection of errors until we know that other mutex
types actually perform better in specific cases. Also, I did a quick
microbenchmark of glibc mutex types on my host and found that the
error checking mutexes weren't any slower than the other types, at least
when the mutex is uncontended.
Signed-off-by: Ben Pfaff <blp@nicira.com>
Acked-by: Ethan Jackson <ethan@nicira.com>
2013-08-20 13:40:02 -07:00
|
|
|
|
ovs_mutex_init(&netdev->mutex);
|
2013-08-09 21:21:38 -07:00
|
|
|
|
eth_addr_random(netdev->etheraddr);
|
2010-12-29 16:02:22 -08:00
|
|
|
|
|
netdev: Decouple creating and configuring network devices.
Until now, each call to netdev_open() for a particular network device
had to either specify a set of network device arguments that was either
empty or (for devices that already existed) equal to the existing device's
configuration. Unfortunately, the definition of "equality" in the latter
case was mostly done in terms of strict equality of string-to-string maps,
which caused problems in cases where, for example, one set of arguments
specified the default value of an optional argument explicitly and the
other omitted it.
The netdev interface does have provisions for defining equality other ways,
but this had only been done in one case that was especially problematic in
practice. One way to solve this particular problem would be to carefully
define equality in all the problematic cases.
This commit takes another approach based on the realization that there is
really no need to do any comparisons. Instead, it removes configuration
at netdev_open() time entirely, because almost all of netdev_open()'s
callers are not interested in creating and configuring a netdev. Most of
them just want to open a configured device and use it. Therefore, this
commit stops providing any configuration arguments to netdev_open() and the
provider functions that it calls. Instead, a caller that does want to
configure a device does so after it opens it, by calling
netdev_set_config().
This change allows us to simplify the netdev interface a bit. There is no
longer any need to implement argument comparisons. As a result, there is
also no need for "struct netdev_dev" to keep track of configuration at all.
Instead, the network devices that have configuration keep track of it in
their own internal form.
This new interface does mean that it becomes possible to accidentally
create and try to use an unconfigured netdev that requires configuration.
Bug #6677.
Reported-by: Paul Ingram <paul@nicira.com>
2011-08-08 12:49:17 -07:00
|
|
|
|
route_table_register();
|
2010-12-29 16:02:22 -08:00
|
|
|
|
|
netdev: Decouple creating and configuring network devices.
Until now, each call to netdev_open() for a particular network device
had to either specify a set of network device arguments that was either
empty or (for devices that already existed) equal to the existing device's
configuration. Unfortunately, the definition of "equality" in the latter
case was mostly done in terms of strict equality of string-to-string maps,
which caused problems in cases where, for example, one set of arguments
specified the default value of an optional argument explicitly and the
other omitted it.
The netdev interface does have provisions for defining equality other ways,
but this had only been done in one case that was especially problematic in
practice. One way to solve this particular problem would be to carefully
define equality in all the problematic cases.
This commit takes another approach based on the realization that there is
really no need to do any comparisons. Instead, it removes configuration
at netdev_open() time entirely, because almost all of netdev_open()'s
callers are not interested in creating and configuring a netdev. Most of
them just want to open a configured device and use it. Therefore, this
commit stops providing any configuration arguments to netdev_open() and the
provider functions that it calls. Instead, a caller that does want to
configure a device does so after it opens it, by calling
netdev_set_config().
This change allows us to simplify the netdev interface a bit. There is no
longer any need to implement argument comparisons. As a result, there is
also no need for "struct netdev_dev" to keep track of configuration at all.
Instead, the network devices that have configuration keep track of it in
their own internal form.
This new interface does mean that it becomes possible to accidentally
create and try to use an unconfigured netdev that requires configuration.
Bug #6677.
Reported-by: Paul Ingram <paul@nicira.com>
2011-08-08 12:49:17 -07:00
|
|
|
|
return 0;
|
2010-05-17 15:04:10 -07:00
|
|
|
|
}
|
|
|
|
|
|
2010-10-06 15:35:53 -07:00
|
|
|
|
static void
|
2013-08-09 21:21:38 -07:00
|
|
|
|
netdev_vport_destruct(struct netdev *netdev_)
|
2010-10-06 15:35:53 -07:00
|
|
|
|
{
|
2013-03-15 15:54:36 -07:00
|
|
|
|
struct netdev_vport *netdev = netdev_vport_cast(netdev_);
|
2010-10-06 15:35:53 -07:00
|
|
|
|
|
2011-01-12 14:55:18 -08:00
|
|
|
|
route_table_unregister();
|
2013-03-15 15:54:36 -07:00
|
|
|
|
free(netdev->peer);
|
2013-08-09 21:34:02 -07:00
|
|
|
|
ovs_mutex_destroy(&netdev->mutex);
|
2013-08-09 21:21:38 -07:00
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
static void
|
|
|
|
|
netdev_vport_dealloc(struct netdev *netdev_)
|
|
|
|
|
{
|
|
|
|
|
struct netdev_vport *netdev = netdev_vport_cast(netdev_);
|
2010-10-06 15:35:53 -07:00
|
|
|
|
free(netdev);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
static int
|
2013-03-15 15:54:36 -07:00
|
|
|
|
netdev_vport_set_etheraddr(struct netdev *netdev_,
|
2010-05-17 15:04:10 -07:00
|
|
|
|
const uint8_t mac[ETH_ADDR_LEN])
|
|
|
|
|
{
|
2013-03-15 15:54:36 -07:00
|
|
|
|
struct netdev_vport *netdev = netdev_vport_cast(netdev_);
|
2013-08-09 21:34:02 -07:00
|
|
|
|
|
|
|
|
|
ovs_mutex_lock(&netdev->mutex);
|
2013-03-15 15:54:36 -07:00
|
|
|
|
memcpy(netdev->etheraddr, mac, ETH_ADDR_LEN);
|
2013-08-09 21:34:02 -07:00
|
|
|
|
ovs_mutex_unlock(&netdev->mutex);
|
2014-04-03 00:17:34 -07:00
|
|
|
|
netdev_change_seq_changed(netdev_);
|
2013-08-09 21:34:02 -07:00
|
|
|
|
|
2012-11-30 11:36:42 -08:00
|
|
|
|
return 0;
|
2010-05-17 15:04:10 -07:00
|
|
|
|
}
|
|
|
|
|
|
2010-10-06 15:35:53 -07:00
|
|
|
|
static int
|
2013-08-09 21:34:02 -07:00
|
|
|
|
netdev_vport_get_etheraddr(const struct netdev *netdev_,
|
2010-05-17 15:04:10 -07:00
|
|
|
|
uint8_t mac[ETH_ADDR_LEN])
|
|
|
|
|
{
|
2013-08-09 21:34:02 -07:00
|
|
|
|
struct netdev_vport *netdev = netdev_vport_cast(netdev_);
|
|
|
|
|
|
|
|
|
|
ovs_mutex_lock(&netdev->mutex);
|
|
|
|
|
memcpy(mac, netdev->etheraddr, ETH_ADDR_LEN);
|
|
|
|
|
ovs_mutex_unlock(&netdev->mutex);
|
|
|
|
|
|
2012-11-30 11:36:42 -08:00
|
|
|
|
return 0;
|
2010-05-17 15:04:10 -07:00
|
|
|
|
}
|
|
|
|
|
|
2011-01-05 11:51:15 -08:00
|
|
|
|
static int
|
2013-08-09 21:34:02 -07:00
|
|
|
|
tunnel_get_status(const struct netdev *netdev_, struct smap *smap)
|
2011-01-05 11:51:15 -08:00
|
|
|
|
{
|
2013-08-09 21:34:02 -07:00
|
|
|
|
struct netdev_vport *netdev = netdev_vport_cast(netdev_);
|
2013-04-15 15:33:43 -07:00
|
|
|
|
char iface[IFNAMSIZ];
|
2012-12-16 16:42:17 -08:00
|
|
|
|
ovs_be32 route;
|
2011-01-05 11:51:15 -08:00
|
|
|
|
|
2013-08-09 21:34:02 -07:00
|
|
|
|
ovs_mutex_lock(&netdev->mutex);
|
|
|
|
|
route = netdev->tnl_cfg.ip_dst;
|
|
|
|
|
ovs_mutex_unlock(&netdev->mutex);
|
|
|
|
|
|
2012-12-16 16:42:17 -08:00
|
|
|
|
if (route_table_get_name(route, iface)) {
|
2011-01-19 14:50:01 -08:00
|
|
|
|
struct netdev *egress_netdev;
|
|
|
|
|
|
2012-05-22 03:47:36 -07:00
|
|
|
|
smap_add(smap, "tunnel_egress_iface", iface);
|
2011-01-19 14:50:01 -08:00
|
|
|
|
|
2011-08-05 14:18:06 -07:00
|
|
|
|
if (!netdev_open(iface, "system", &egress_netdev)) {
|
2012-05-22 03:47:36 -07:00
|
|
|
|
smap_add(smap, "tunnel_egress_iface_carrier",
|
|
|
|
|
netdev_get_carrier(egress_netdev) ? "up" : "down");
|
2011-01-19 14:50:01 -08:00
|
|
|
|
netdev_close(egress_netdev);
|
|
|
|
|
}
|
2011-01-05 11:51:15 -08:00
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
return 0;
|
|
|
|
|
}
|
|
|
|
|
|
2010-10-06 15:35:53 -07:00
|
|
|
|
static int
|
2013-03-15 15:54:36 -07:00
|
|
|
|
netdev_vport_update_flags(struct netdev *netdev OVS_UNUSED,
|
|
|
|
|
enum netdev_flags off,
|
|
|
|
|
enum netdev_flags on OVS_UNUSED,
|
|
|
|
|
enum netdev_flags *old_flagsp)
|
2010-05-17 15:04:10 -07:00
|
|
|
|
{
|
|
|
|
|
if (off & (NETDEV_UP | NETDEV_PROMISC)) {
|
|
|
|
|
return EOPNOTSUPP;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
*old_flagsp = NETDEV_UP | NETDEV_PROMISC;
|
|
|
|
|
return 0;
|
|
|
|
|
}
|
|
|
|
|
|
2010-12-21 16:26:21 -08:00
|
|
|
|
static void
|
|
|
|
|
netdev_vport_run(void)
|
|
|
|
|
{
|
2011-01-12 14:55:18 -08:00
|
|
|
|
route_table_run();
|
2010-12-21 16:26:21 -08:00
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
static void
|
|
|
|
|
netdev_vport_wait(void)
|
|
|
|
|
{
|
2011-01-12 14:55:18 -08:00
|
|
|
|
route_table_wait();
|
2010-12-21 16:26:21 -08:00
|
|
|
|
}
|
|
|
|
|
|
2012-12-20 15:32:03 -08:00
|
|
|
|
/* Code specific to tunnel types. */
|
2010-10-06 15:35:53 -07:00
|
|
|
|
|
2013-01-07 16:56:04 -08:00
|
|
|
|
static ovs_be64
|
|
|
|
|
parse_key(const struct smap *args, const char *name,
|
|
|
|
|
bool *present, bool *flow)
|
2011-01-26 12:28:59 -08:00
|
|
|
|
{
|
|
|
|
|
const char *s;
|
|
|
|
|
|
2013-01-07 16:56:04 -08:00
|
|
|
|
*present = false;
|
|
|
|
|
*flow = false;
|
|
|
|
|
|
2012-05-22 03:47:36 -07:00
|
|
|
|
s = smap_get(args, name);
|
2011-01-26 12:28:59 -08:00
|
|
|
|
if (!s) {
|
2012-05-22 03:47:36 -07:00
|
|
|
|
s = smap_get(args, "key");
|
2011-01-26 12:28:59 -08:00
|
|
|
|
if (!s) {
|
2013-01-07 16:56:04 -08:00
|
|
|
|
return 0;
|
2011-01-26 12:28:59 -08:00
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
2013-01-07 16:56:04 -08:00
|
|
|
|
*present = true;
|
|
|
|
|
|
2011-01-26 12:28:59 -08:00
|
|
|
|
if (!strcmp(s, "flow")) {
|
2013-01-07 16:56:04 -08:00
|
|
|
|
*flow = true;
|
|
|
|
|
return 0;
|
2011-01-26 12:28:59 -08:00
|
|
|
|
} else {
|
2013-01-07 16:56:04 -08:00
|
|
|
|
return htonll(strtoull(s, NULL, 0));
|
2011-01-26 12:28:59 -08:00
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
2010-10-06 15:35:53 -07:00
|
|
|
|
static int
|
2013-03-15 15:54:36 -07:00
|
|
|
|
set_tunnel_config(struct netdev *dev_, const struct smap *args)
|
2010-10-06 15:35:53 -07:00
|
|
|
|
{
|
2013-03-15 15:54:36 -07:00
|
|
|
|
struct netdev_vport *dev = netdev_vport_cast(dev_);
|
|
|
|
|
const char *name = netdev_get_name(dev_);
|
|
|
|
|
const char *type = netdev_get_type(dev_);
|
2013-01-07 16:56:04 -08:00
|
|
|
|
bool ipsec_mech_set, needs_dst_port, has_csum;
|
|
|
|
|
struct netdev_tunnel_config tnl_cfg;
|
2012-05-22 03:47:36 -07:00
|
|
|
|
struct smap_node *node;
|
2013-01-07 16:56:04 -08:00
|
|
|
|
|
|
|
|
|
has_csum = strstr(type, "gre");
|
|
|
|
|
ipsec_mech_set = false;
|
|
|
|
|
memset(&tnl_cfg, 0, sizeof tnl_cfg);
|
2010-10-06 15:35:53 -07:00
|
|
|
|
|
2013-02-21 21:52:04 -08:00
|
|
|
|
needs_dst_port = netdev_vport_needs_dst_port(dev_);
|
2013-01-07 16:56:04 -08:00
|
|
|
|
tnl_cfg.ipsec = strstr(type, "ipsec");
|
|
|
|
|
tnl_cfg.dont_fragment = true;
|
2010-12-01 17:23:33 -08:00
|
|
|
|
|
2012-05-22 03:47:36 -07:00
|
|
|
|
SMAP_FOR_EACH (node, args) {
|
|
|
|
|
if (!strcmp(node->key, "remote_ip")) {
|
2010-10-06 15:35:53 -07:00
|
|
|
|
struct in_addr in_addr;
|
2013-05-09 15:24:16 +03:00
|
|
|
|
if (!strcmp(node->value, "flow")) {
|
|
|
|
|
tnl_cfg.ip_dst_flow = true;
|
|
|
|
|
tnl_cfg.ip_dst = htonl(0);
|
|
|
|
|
} else if (lookup_ip(node->value, &in_addr)) {
|
2010-12-03 14:41:38 -08:00
|
|
|
|
VLOG_WARN("%s: bad %s 'remote_ip'", name, type);
|
2013-03-04 13:00:25 -08:00
|
|
|
|
} else if (ip_is_multicast(in_addr.s_addr)) {
|
|
|
|
|
VLOG_WARN("%s: multicast remote_ip="IP_FMT" not allowed",
|
|
|
|
|
name, IP_ARGS(in_addr.s_addr));
|
|
|
|
|
return EINVAL;
|
2010-10-06 15:35:53 -07:00
|
|
|
|
} else {
|
2013-01-07 16:56:04 -08:00
|
|
|
|
tnl_cfg.ip_dst = in_addr.s_addr;
|
2010-10-06 15:35:53 -07:00
|
|
|
|
}
|
2012-05-22 03:47:36 -07:00
|
|
|
|
} else if (!strcmp(node->key, "local_ip")) {
|
2010-10-06 15:35:53 -07:00
|
|
|
|
struct in_addr in_addr;
|
2013-05-09 15:24:16 +03:00
|
|
|
|
if (!strcmp(node->value, "flow")) {
|
|
|
|
|
tnl_cfg.ip_src_flow = true;
|
|
|
|
|
tnl_cfg.ip_src = htonl(0);
|
|
|
|
|
} else if (lookup_ip(node->value, &in_addr)) {
|
2010-12-03 14:41:38 -08:00
|
|
|
|
VLOG_WARN("%s: bad %s 'local_ip'", name, type);
|
2010-10-06 15:35:53 -07:00
|
|
|
|
} else {
|
2013-01-07 16:56:04 -08:00
|
|
|
|
tnl_cfg.ip_src = in_addr.s_addr;
|
2010-10-06 15:35:53 -07:00
|
|
|
|
}
|
2012-05-22 03:47:36 -07:00
|
|
|
|
} else if (!strcmp(node->key, "tos")) {
|
|
|
|
|
if (!strcmp(node->value, "inherit")) {
|
2013-01-07 16:56:04 -08:00
|
|
|
|
tnl_cfg.tos_inherit = true;
|
2010-10-06 15:35:53 -07:00
|
|
|
|
} else {
|
2012-05-21 12:18:19 -07:00
|
|
|
|
char *endptr;
|
|
|
|
|
int tos;
|
2012-05-22 03:47:36 -07:00
|
|
|
|
tos = strtol(node->value, &endptr, 0);
|
2012-07-20 10:24:50 -07:00
|
|
|
|
if (*endptr == '\0' && tos == (tos & IP_DSCP_MASK)) {
|
2013-01-07 16:56:04 -08:00
|
|
|
|
tnl_cfg.tos = tos;
|
2012-07-20 10:24:50 -07:00
|
|
|
|
} else {
|
|
|
|
|
VLOG_WARN("%s: invalid TOS %s", name, node->value);
|
2012-05-21 12:18:19 -07:00
|
|
|
|
}
|
2010-10-06 15:35:53 -07:00
|
|
|
|
}
|
2012-05-22 03:47:36 -07:00
|
|
|
|
} else if (!strcmp(node->key, "ttl")) {
|
|
|
|
|
if (!strcmp(node->value, "inherit")) {
|
2013-01-07 16:56:04 -08:00
|
|
|
|
tnl_cfg.ttl_inherit = true;
|
2010-10-06 15:35:53 -07:00
|
|
|
|
} else {
|
2013-01-07 16:56:04 -08:00
|
|
|
|
tnl_cfg.ttl = atoi(node->value);
|
2010-10-06 15:35:53 -07:00
|
|
|
|
}
|
2012-12-05 16:06:46 -05:00
|
|
|
|
} else if (!strcmp(node->key, "dst_port") && needs_dst_port) {
|
2013-01-07 16:56:04 -08:00
|
|
|
|
tnl_cfg.dst_port = htons(atoi(node->value));
|
|
|
|
|
} else if (!strcmp(node->key, "csum") && has_csum) {
|
2012-05-22 03:47:36 -07:00
|
|
|
|
if (!strcmp(node->value, "true")) {
|
2013-01-07 16:56:04 -08:00
|
|
|
|
tnl_cfg.csum = true;
|
2010-10-06 15:35:53 -07:00
|
|
|
|
}
|
2012-05-22 03:47:36 -07:00
|
|
|
|
} else if (!strcmp(node->key, "df_default")) {
|
|
|
|
|
if (!strcmp(node->value, "false")) {
|
2013-01-07 16:56:04 -08:00
|
|
|
|
tnl_cfg.dont_fragment = false;
|
2011-04-29 17:05:58 -07:00
|
|
|
|
}
|
2013-01-07 16:56:04 -08:00
|
|
|
|
} else if (!strcmp(node->key, "peer_cert") && tnl_cfg.ipsec) {
|
2012-05-22 03:47:36 -07:00
|
|
|
|
if (smap_get(args, "certificate")) {
|
2010-12-15 23:44:41 -08:00
|
|
|
|
ipsec_mech_set = true;
|
|
|
|
|
} else {
|
2010-12-27 17:44:33 -08:00
|
|
|
|
const char *use_ssl_cert;
|
|
|
|
|
|
|
|
|
|
/* If the "use_ssl_cert" is true, then "certificate" and
|
|
|
|
|
* "private_key" will be pulled from the SSL table. The
|
|
|
|
|
* use of this option is strongly discouraged, since it
|
|
|
|
|
* will like be removed when multiple SSL configurations
|
|
|
|
|
* are supported by OVS.
|
|
|
|
|
*/
|
2012-05-22 03:47:36 -07:00
|
|
|
|
use_ssl_cert = smap_get(args, "use_ssl_cert");
|
2010-12-27 17:44:33 -08:00
|
|
|
|
if (!use_ssl_cert || strcmp(use_ssl_cert, "true")) {
|
2011-03-14 13:45:43 -07:00
|
|
|
|
VLOG_ERR("%s: 'peer_cert' requires 'certificate' argument",
|
|
|
|
|
name);
|
2012-12-14 19:14:54 -08:00
|
|
|
|
return EINVAL;
|
2010-12-27 17:44:33 -08:00
|
|
|
|
}
|
|
|
|
|
ipsec_mech_set = true;
|
2010-12-15 23:44:41 -08:00
|
|
|
|
}
|
2013-01-07 16:56:04 -08:00
|
|
|
|
} else if (!strcmp(node->key, "psk") && tnl_cfg.ipsec) {
|
2010-10-06 15:35:53 -07:00
|
|
|
|
ipsec_mech_set = true;
|
2013-01-07 16:56:04 -08:00
|
|
|
|
} else if (tnl_cfg.ipsec
|
2012-05-22 03:47:36 -07:00
|
|
|
|
&& (!strcmp(node->key, "certificate")
|
|
|
|
|
|| !strcmp(node->key, "private_key")
|
|
|
|
|
|| !strcmp(node->key, "use_ssl_cert"))) {
|
2010-12-15 23:44:41 -08:00
|
|
|
|
/* Ignore options not used by the netdev. */
|
2012-05-22 03:47:36 -07:00
|
|
|
|
} else if (!strcmp(node->key, "key") ||
|
|
|
|
|
!strcmp(node->key, "in_key") ||
|
|
|
|
|
!strcmp(node->key, "out_key")) {
|
2011-01-26 12:28:59 -08:00
|
|
|
|
/* Handled separately below. */
|
2010-10-06 15:35:53 -07:00
|
|
|
|
} else {
|
2012-05-22 03:47:36 -07:00
|
|
|
|
VLOG_WARN("%s: unknown %s argument '%s'", name, type, node->key);
|
2010-10-06 15:35:53 -07:00
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
2012-12-05 16:06:46 -05:00
|
|
|
|
/* Add a default destination port for VXLAN if none specified. */
|
2013-02-21 21:52:04 -08:00
|
|
|
|
if (!strcmp(type, "vxlan") && !tnl_cfg.dst_port) {
|
2013-01-07 16:56:04 -08:00
|
|
|
|
tnl_cfg.dst_port = htons(VXLAN_DST_PORT);
|
2012-12-05 16:06:46 -05:00
|
|
|
|
}
|
|
|
|
|
|
2013-02-21 21:52:04 -08:00
|
|
|
|
/* Add a default destination port for LISP if none specified. */
|
|
|
|
|
if (!strcmp(type, "lisp") && !tnl_cfg.dst_port) {
|
|
|
|
|
tnl_cfg.dst_port = htons(LISP_DST_PORT);
|
|
|
|
|
}
|
|
|
|
|
|
2013-01-07 16:56:04 -08:00
|
|
|
|
if (tnl_cfg.ipsec) {
|
2013-07-31 14:15:05 -07:00
|
|
|
|
static struct ovs_mutex mutex = OVS_MUTEX_INITIALIZER;
|
2012-07-02 18:30:21 -07:00
|
|
|
|
static pid_t pid = 0;
|
2013-04-26 13:20:30 -07:00
|
|
|
|
|
2014-03-12 10:50:42 -07:00
|
|
|
|
#ifndef _WIN32
|
2013-07-31 14:15:05 -07:00
|
|
|
|
ovs_mutex_lock(&mutex);
|
2012-07-08 13:04:27 -07:00
|
|
|
|
if (pid <= 0) {
|
2012-07-02 18:30:21 -07:00
|
|
|
|
char *file_name = xasprintf("%s/%s", ovs_rundir(),
|
|
|
|
|
"ovs-monitor-ipsec.pid");
|
|
|
|
|
pid = read_pidfile(file_name);
|
|
|
|
|
free(file_name);
|
|
|
|
|
}
|
2013-07-31 14:15:05 -07:00
|
|
|
|
ovs_mutex_unlock(&mutex);
|
2014-03-12 10:50:42 -07:00
|
|
|
|
#endif
|
2012-07-02 18:30:21 -07:00
|
|
|
|
|
2011-03-14 13:15:25 -07:00
|
|
|
|
if (pid < 0) {
|
2011-03-14 13:45:43 -07:00
|
|
|
|
VLOG_ERR("%s: IPsec requires the ovs-monitor-ipsec daemon",
|
|
|
|
|
name);
|
2012-12-14 19:14:54 -08:00
|
|
|
|
return EINVAL;
|
2011-03-14 13:15:25 -07:00
|
|
|
|
}
|
2011-03-11 15:18:30 -08:00
|
|
|
|
|
2012-05-22 03:47:36 -07:00
|
|
|
|
if (smap_get(args, "peer_cert") && smap_get(args, "psk")) {
|
2011-03-14 13:45:43 -07:00
|
|
|
|
VLOG_ERR("%s: cannot define both 'peer_cert' and 'psk'", name);
|
2012-12-14 19:14:54 -08:00
|
|
|
|
return EINVAL;
|
2010-12-15 23:44:41 -08:00
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
if (!ipsec_mech_set) {
|
2011-03-14 13:45:43 -07:00
|
|
|
|
VLOG_ERR("%s: IPsec requires an 'peer_cert' or psk' argument",
|
|
|
|
|
name);
|
2012-12-14 19:14:54 -08:00
|
|
|
|
return EINVAL;
|
2010-12-15 23:44:41 -08:00
|
|
|
|
}
|
2010-10-06 15:35:53 -07:00
|
|
|
|
}
|
|
|
|
|
|
2013-05-09 15:24:16 +03:00
|
|
|
|
if (!tnl_cfg.ip_dst && !tnl_cfg.ip_dst_flow) {
|
2011-03-14 13:45:43 -07:00
|
|
|
|
VLOG_ERR("%s: %s type requires valid 'remote_ip' argument",
|
|
|
|
|
name, type);
|
2012-12-14 19:14:54 -08:00
|
|
|
|
return EINVAL;
|
2010-10-06 15:35:53 -07:00
|
|
|
|
}
|
2013-05-09 15:24:16 +03:00
|
|
|
|
if (tnl_cfg.ip_src_flow && !tnl_cfg.ip_dst_flow) {
|
|
|
|
|
VLOG_ERR("%s: %s type requires 'remote_ip=flow' with 'local_ip=flow'",
|
|
|
|
|
name, type);
|
|
|
|
|
return EINVAL;
|
|
|
|
|
}
|
2013-01-07 16:56:04 -08:00
|
|
|
|
if (!tnl_cfg.ttl) {
|
|
|
|
|
tnl_cfg.ttl = DEFAULT_TTL;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
tnl_cfg.in_key = parse_key(args, "in_key",
|
|
|
|
|
&tnl_cfg.in_key_present,
|
|
|
|
|
&tnl_cfg.in_key_flow);
|
|
|
|
|
|
|
|
|
|
tnl_cfg.out_key = parse_key(args, "out_key",
|
|
|
|
|
&tnl_cfg.out_key_present,
|
|
|
|
|
&tnl_cfg.out_key_flow);
|
2010-10-06 15:35:53 -07:00
|
|
|
|
|
2013-08-09 21:34:02 -07:00
|
|
|
|
ovs_mutex_lock(&dev->mutex);
|
2012-12-20 15:32:03 -08:00
|
|
|
|
dev->tnl_cfg = tnl_cfg;
|
2014-04-03 00:17:34 -07:00
|
|
|
|
netdev_change_seq_changed(dev_);
|
2013-08-09 21:34:02 -07:00
|
|
|
|
ovs_mutex_unlock(&dev->mutex);
|
2013-01-07 16:56:04 -08:00
|
|
|
|
|
2011-01-26 12:28:59 -08:00
|
|
|
|
return 0;
|
|
|
|
|
}
|
|
|
|
|
|
2010-10-06 15:35:53 -07:00
|
|
|
|
static int
|
2013-03-15 15:54:36 -07:00
|
|
|
|
get_tunnel_config(const struct netdev *dev, struct smap *args)
|
2010-12-29 16:02:22 -08:00
|
|
|
|
{
|
2013-08-09 21:34:02 -07:00
|
|
|
|
struct netdev_vport *netdev = netdev_vport_cast(dev);
|
|
|
|
|
struct netdev_tunnel_config tnl_cfg;
|
|
|
|
|
|
|
|
|
|
ovs_mutex_lock(&netdev->mutex);
|
|
|
|
|
tnl_cfg = netdev->tnl_cfg;
|
|
|
|
|
ovs_mutex_unlock(&netdev->mutex);
|
2010-12-29 16:02:22 -08:00
|
|
|
|
|
2013-08-09 21:34:02 -07:00
|
|
|
|
if (tnl_cfg.ip_dst) {
|
|
|
|
|
smap_add_format(args, "remote_ip", IP_FMT, IP_ARGS(tnl_cfg.ip_dst));
|
|
|
|
|
} else if (tnl_cfg.ip_dst_flow) {
|
2013-05-09 15:24:16 +03:00
|
|
|
|
smap_add(args, "remote_ip", "flow");
|
2012-12-20 15:32:03 -08:00
|
|
|
|
}
|
|
|
|
|
|
2013-08-09 21:34:02 -07:00
|
|
|
|
if (tnl_cfg.ip_src) {
|
|
|
|
|
smap_add_format(args, "local_ip", IP_FMT, IP_ARGS(tnl_cfg.ip_src));
|
|
|
|
|
} else if (tnl_cfg.ip_src_flow) {
|
2013-05-09 15:24:16 +03:00
|
|
|
|
smap_add(args, "local_ip", "flow");
|
2012-12-29 08:58:40 +02:00
|
|
|
|
}
|
2011-01-26 12:28:59 -08:00
|
|
|
|
|
2013-08-09 21:34:02 -07:00
|
|
|
|
if (tnl_cfg.in_key_flow && tnl_cfg.out_key_flow) {
|
2010-12-29 16:02:22 -08:00
|
|
|
|
smap_add(args, "key", "flow");
|
2013-08-09 21:34:02 -07:00
|
|
|
|
} else if (tnl_cfg.in_key_present && tnl_cfg.out_key_present
|
|
|
|
|
&& tnl_cfg.in_key == tnl_cfg.out_key) {
|
|
|
|
|
smap_add_format(args, "key", "%"PRIu64, ntohll(tnl_cfg.in_key));
|
2010-12-29 16:02:22 -08:00
|
|
|
|
} else {
|
2013-08-09 21:34:02 -07:00
|
|
|
|
if (tnl_cfg.in_key_flow) {
|
2012-12-14 19:14:54 -08:00
|
|
|
|
smap_add(args, "in_key", "flow");
|
2013-08-09 21:34:02 -07:00
|
|
|
|
} else if (tnl_cfg.in_key_present) {
|
2012-12-14 19:14:54 -08:00
|
|
|
|
smap_add_format(args, "in_key", "%"PRIu64,
|
2013-08-09 21:34:02 -07:00
|
|
|
|
ntohll(tnl_cfg.in_key));
|
2012-12-14 19:14:54 -08:00
|
|
|
|
}
|
2010-12-29 16:02:22 -08:00
|
|
|
|
|
2013-08-09 21:34:02 -07:00
|
|
|
|
if (tnl_cfg.out_key_flow) {
|
2012-12-14 19:14:54 -08:00
|
|
|
|
smap_add(args, "out_key", "flow");
|
2013-08-09 21:34:02 -07:00
|
|
|
|
} else if (tnl_cfg.out_key_present) {
|
2012-12-14 19:14:54 -08:00
|
|
|
|
smap_add_format(args, "out_key", "%"PRIu64,
|
2013-08-09 21:34:02 -07:00
|
|
|
|
ntohll(tnl_cfg.out_key));
|
2010-12-29 16:02:22 -08:00
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
2013-08-09 21:34:02 -07:00
|
|
|
|
if (tnl_cfg.ttl_inherit) {
|
2012-09-25 13:22:08 -07:00
|
|
|
|
smap_add(args, "ttl", "inherit");
|
2013-08-09 21:34:02 -07:00
|
|
|
|
} else if (tnl_cfg.ttl != DEFAULT_TTL) {
|
|
|
|
|
smap_add_format(args, "ttl", "%"PRIu8, tnl_cfg.ttl);
|
2011-01-26 12:28:59 -08:00
|
|
|
|
}
|
|
|
|
|
|
2013-08-09 21:34:02 -07:00
|
|
|
|
if (tnl_cfg.tos_inherit) {
|
2010-12-29 16:02:22 -08:00
|
|
|
|
smap_add(args, "tos", "inherit");
|
2013-08-09 21:34:02 -07:00
|
|
|
|
} else if (tnl_cfg.tos) {
|
|
|
|
|
smap_add_format(args, "tos", "0x%x", tnl_cfg.tos);
|
2010-12-29 16:02:22 -08:00
|
|
|
|
}
|
|
|
|
|
|
2013-08-09 21:34:02 -07:00
|
|
|
|
if (tnl_cfg.dst_port) {
|
|
|
|
|
uint16_t dst_port = ntohs(tnl_cfg.dst_port);
|
2013-03-15 15:54:36 -07:00
|
|
|
|
const char *type = netdev_get_type(dev);
|
2013-02-28 09:30:16 -05:00
|
|
|
|
|
|
|
|
|
if ((!strcmp("vxlan", type) && dst_port != VXLAN_DST_PORT) ||
|
|
|
|
|
(!strcmp("lisp", type) && dst_port != LISP_DST_PORT)) {
|
2012-12-05 16:06:46 -05:00
|
|
|
|
smap_add_format(args, "dst_port", "%d", dst_port);
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
2013-08-09 21:34:02 -07:00
|
|
|
|
if (tnl_cfg.csum) {
|
2010-12-29 16:02:22 -08:00
|
|
|
|
smap_add(args, "csum", "true");
|
|
|
|
|
}
|
2013-01-25 12:38:45 -08:00
|
|
|
|
|
2013-08-09 21:34:02 -07:00
|
|
|
|
if (!tnl_cfg.dont_fragment) {
|
2011-04-29 17:05:58 -07:00
|
|
|
|
smap_add(args, "df_default", "false");
|
|
|
|
|
}
|
2010-12-29 16:02:22 -08:00
|
|
|
|
|
|
|
|
|
return 0;
|
|
|
|
|
}
|
2012-12-20 15:32:03 -08:00
|
|
|
|
|
|
|
|
|
/* Code specific to patch ports. */
|
|
|
|
|
|
2013-07-31 14:09:30 -07:00
|
|
|
|
/* If 'netdev' is a patch port, returns the name of its peer as a malloc()'d
|
|
|
|
|
* string that the caller must free.
|
|
|
|
|
*
|
|
|
|
|
* If 'netdev' is not a patch port, returns NULL. */
|
|
|
|
|
char *
|
|
|
|
|
netdev_vport_patch_peer(const struct netdev *netdev_)
|
2012-12-20 15:32:03 -08:00
|
|
|
|
{
|
2013-07-31 14:09:30 -07:00
|
|
|
|
char *peer = NULL;
|
|
|
|
|
|
|
|
|
|
if (netdev_vport_is_patch(netdev_)) {
|
|
|
|
|
struct netdev_vport *netdev = netdev_vport_cast(netdev_);
|
2013-08-09 21:34:02 -07:00
|
|
|
|
|
|
|
|
|
ovs_mutex_lock(&netdev->mutex);
|
2013-07-31 14:09:30 -07:00
|
|
|
|
if (netdev->peer) {
|
|
|
|
|
peer = xstrdup(netdev->peer);
|
|
|
|
|
}
|
2013-08-09 21:34:02 -07:00
|
|
|
|
ovs_mutex_unlock(&netdev->mutex);
|
2013-07-31 14:09:30 -07:00
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
return peer;
|
2012-12-20 15:32:03 -08:00
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
void
|
2012-12-14 19:14:54 -08:00
|
|
|
|
netdev_vport_inc_rx(const struct netdev *netdev,
|
2013-09-16 17:19:56 -07:00
|
|
|
|
const struct dpif_flow_stats *stats)
|
2012-12-20 15:32:03 -08:00
|
|
|
|
{
|
2013-03-15 15:54:36 -07:00
|
|
|
|
if (is_vport_class(netdev_get_class(netdev))) {
|
|
|
|
|
struct netdev_vport *dev = netdev_vport_cast(netdev);
|
2013-08-09 21:34:02 -07:00
|
|
|
|
|
|
|
|
|
ovs_mutex_lock(&dev->mutex);
|
2012-12-20 15:32:03 -08:00
|
|
|
|
dev->stats.rx_packets += stats->n_packets;
|
|
|
|
|
dev->stats.rx_bytes += stats->n_bytes;
|
2013-08-09 21:34:02 -07:00
|
|
|
|
ovs_mutex_unlock(&dev->mutex);
|
2012-12-20 15:32:03 -08:00
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
void
|
2012-12-14 19:14:54 -08:00
|
|
|
|
netdev_vport_inc_tx(const struct netdev *netdev,
|
|
|
|
|
const struct dpif_flow_stats *stats)
|
2012-12-20 15:32:03 -08:00
|
|
|
|
{
|
2013-03-15 15:54:36 -07:00
|
|
|
|
if (is_vport_class(netdev_get_class(netdev))) {
|
|
|
|
|
struct netdev_vport *dev = netdev_vport_cast(netdev);
|
2013-08-09 21:34:02 -07:00
|
|
|
|
|
|
|
|
|
ovs_mutex_lock(&dev->mutex);
|
2012-12-20 15:32:03 -08:00
|
|
|
|
dev->stats.tx_packets += stats->n_packets;
|
|
|
|
|
dev->stats.tx_bytes += stats->n_bytes;
|
2013-08-09 21:34:02 -07:00
|
|
|
|
ovs_mutex_unlock(&dev->mutex);
|
2012-12-20 15:32:03 -08:00
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
static int
|
2013-03-15 15:54:36 -07:00
|
|
|
|
get_patch_config(const struct netdev *dev_, struct smap *args)
|
2012-12-20 15:32:03 -08:00
|
|
|
|
{
|
2013-03-15 15:54:36 -07:00
|
|
|
|
struct netdev_vport *dev = netdev_vport_cast(dev_);
|
2012-12-20 15:32:03 -08:00
|
|
|
|
|
2013-08-09 21:34:02 -07:00
|
|
|
|
ovs_mutex_lock(&dev->mutex);
|
2012-12-20 15:32:03 -08:00
|
|
|
|
if (dev->peer) {
|
|
|
|
|
smap_add(args, "peer", dev->peer);
|
|
|
|
|
}
|
2013-08-09 21:34:02 -07:00
|
|
|
|
ovs_mutex_unlock(&dev->mutex);
|
|
|
|
|
|
2012-12-20 15:32:03 -08:00
|
|
|
|
return 0;
|
|
|
|
|
}
|
2010-12-29 16:02:22 -08:00
|
|
|
|
|
|
|
|
|
static int
|
2013-03-15 15:54:36 -07:00
|
|
|
|
set_patch_config(struct netdev *dev_, const struct smap *args)
|
2010-10-06 15:35:53 -07:00
|
|
|
|
{
|
2013-03-15 15:54:36 -07:00
|
|
|
|
struct netdev_vport *dev = netdev_vport_cast(dev_);
|
|
|
|
|
const char *name = netdev_get_name(dev_);
|
2010-10-06 15:35:53 -07:00
|
|
|
|
const char *peer;
|
|
|
|
|
|
2012-05-22 03:47:36 -07:00
|
|
|
|
peer = smap_get(args, "peer");
|
2010-10-06 15:35:53 -07:00
|
|
|
|
if (!peer) {
|
2011-03-14 13:45:43 -07:00
|
|
|
|
VLOG_ERR("%s: patch type requires valid 'peer' argument", name);
|
2010-10-06 15:35:53 -07:00
|
|
|
|
return EINVAL;
|
|
|
|
|
}
|
|
|
|
|
|
2012-05-22 03:47:36 -07:00
|
|
|
|
if (smap_count(args) > 1) {
|
2011-03-14 13:45:43 -07:00
|
|
|
|
VLOG_ERR("%s: patch type takes only a 'peer' argument", name);
|
2010-10-06 15:35:53 -07:00
|
|
|
|
return EINVAL;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
if (!strcmp(name, peer)) {
|
2011-03-14 13:45:43 -07:00
|
|
|
|
VLOG_ERR("%s: patch peer must not be self", name);
|
2010-10-06 15:35:53 -07:00
|
|
|
|
return EINVAL;
|
|
|
|
|
}
|
|
|
|
|
|
2013-08-09 21:34:02 -07:00
|
|
|
|
ovs_mutex_lock(&dev->mutex);
|
2012-12-20 15:32:03 -08:00
|
|
|
|
free(dev->peer);
|
|
|
|
|
dev->peer = xstrdup(peer);
|
2014-04-03 00:17:34 -07:00
|
|
|
|
netdev_change_seq_changed(dev_);
|
2013-08-09 21:34:02 -07:00
|
|
|
|
ovs_mutex_unlock(&dev->mutex);
|
|
|
|
|
|
2010-10-06 15:35:53 -07:00
|
|
|
|
return 0;
|
|
|
|
|
}
|
2010-12-29 16:02:22 -08:00
|
|
|
|
|
|
|
|
|
static int
|
2012-12-14 19:14:54 -08:00
|
|
|
|
get_stats(const struct netdev *netdev, struct netdev_stats *stats)
|
2012-12-20 15:32:03 -08:00
|
|
|
|
{
|
2013-03-15 15:54:36 -07:00
|
|
|
|
struct netdev_vport *dev = netdev_vport_cast(netdev);
|
2013-08-09 21:34:02 -07:00
|
|
|
|
|
|
|
|
|
ovs_mutex_lock(&dev->mutex);
|
|
|
|
|
*stats = dev->stats;
|
|
|
|
|
ovs_mutex_unlock(&dev->mutex);
|
|
|
|
|
|
2010-12-29 16:02:22 -08:00
|
|
|
|
return 0;
|
|
|
|
|
}
|
2010-10-06 15:35:53 -07:00
|
|
|
|
|
2012-12-20 15:32:03 -08:00
|
|
|
|
#define VPORT_FUNCTIONS(GET_CONFIG, SET_CONFIG, \
|
2012-12-14 19:14:54 -08:00
|
|
|
|
GET_TUNNEL_CONFIG, GET_STATUS) \
|
2011-01-30 17:52:19 -08:00
|
|
|
|
NULL, \
|
2010-12-21 16:26:21 -08:00
|
|
|
|
netdev_vport_run, \
|
|
|
|
|
netdev_vport_wait, \
|
2010-10-06 15:35:53 -07:00
|
|
|
|
\
|
2013-08-09 21:21:38 -07:00
|
|
|
|
netdev_vport_alloc, \
|
|
|
|
|
netdev_vport_construct, \
|
|
|
|
|
netdev_vport_destruct, \
|
|
|
|
|
netdev_vport_dealloc, \
|
2012-12-20 15:32:03 -08:00
|
|
|
|
GET_CONFIG, \
|
|
|
|
|
SET_CONFIG, \
|
2013-01-07 16:56:04 -08:00
|
|
|
|
GET_TUNNEL_CONFIG, \
|
2010-10-06 15:35:53 -07:00
|
|
|
|
\
|
2012-11-21 16:17:45 -08:00
|
|
|
|
NULL, /* send */ \
|
2010-10-06 15:35:53 -07:00
|
|
|
|
NULL, /* send_wait */ \
|
|
|
|
|
\
|
|
|
|
|
netdev_vport_set_etheraddr, \
|
|
|
|
|
netdev_vport_get_etheraddr, \
|
2011-09-15 10:41:15 -07:00
|
|
|
|
NULL, /* get_mtu */ \
|
|
|
|
|
NULL, /* set_mtu */ \
|
2010-10-06 15:35:53 -07:00
|
|
|
|
NULL, /* get_ifindex */ \
|
2010-10-27 15:29:16 -07:00
|
|
|
|
NULL, /* get_carrier */ \
|
2011-10-14 12:49:57 -07:00
|
|
|
|
NULL, /* get_carrier_resets */ \
|
2011-01-07 16:22:34 -08:00
|
|
|
|
NULL, /* get_miimon */ \
|
2012-12-14 19:14:54 -08:00
|
|
|
|
get_stats, \
|
2012-11-30 16:12:03 -08:00
|
|
|
|
NULL, /* set_stats */ \
|
2010-10-06 15:35:53 -07:00
|
|
|
|
\
|
|
|
|
|
NULL, /* get_features */ \
|
|
|
|
|
NULL, /* set_advertisements */ \
|
|
|
|
|
\
|
|
|
|
|
NULL, /* set_policing */ \
|
|
|
|
|
NULL, /* get_qos_types */ \
|
|
|
|
|
NULL, /* get_qos_capabilities */ \
|
|
|
|
|
NULL, /* get_qos */ \
|
|
|
|
|
NULL, /* set_qos */ \
|
|
|
|
|
NULL, /* get_queue */ \
|
|
|
|
|
NULL, /* set_queue */ \
|
|
|
|
|
NULL, /* delete_queue */ \
|
|
|
|
|
NULL, /* get_queue_stats */ \
|
2013-08-27 17:15:53 -07:00
|
|
|
|
NULL, /* queue_dump_start */ \
|
|
|
|
|
NULL, /* queue_dump_next */ \
|
|
|
|
|
NULL, /* queue_dump_done */ \
|
2010-10-06 15:35:53 -07:00
|
|
|
|
NULL, /* dump_queue_stats */ \
|
|
|
|
|
\
|
|
|
|
|
NULL, /* get_in4 */ \
|
|
|
|
|
NULL, /* set_in4 */ \
|
|
|
|
|
NULL, /* get_in6 */ \
|
|
|
|
|
NULL, /* add_router */ \
|
|
|
|
|
NULL, /* get_next_hop */ \
|
2011-01-05 11:51:15 -08:00
|
|
|
|
GET_STATUS, \
|
2010-10-06 15:35:53 -07:00
|
|
|
|
NULL, /* arp_lookup */ \
|
|
|
|
|
\
|
|
|
|
|
netdev_vport_update_flags, \
|
|
|
|
|
\
|
2013-08-09 21:21:38 -07:00
|
|
|
|
NULL, /* rx_alloc */ \
|
|
|
|
|
NULL, /* rx_construct */ \
|
|
|
|
|
NULL, /* rx_destruct */ \
|
|
|
|
|
NULL, /* rx_dealloc */ \
|
|
|
|
|
NULL, /* rx_recv */ \
|
|
|
|
|
NULL, /* rx_wait */ \
|
|
|
|
|
NULL, /* rx_drain */
|
2010-10-06 15:35:53 -07:00
|
|
|
|
|
2013-01-25 13:30:40 -08:00
|
|
|
|
#define TUNNEL_CLASS(NAME, DPIF_PORT) \
|
|
|
|
|
{ DPIF_PORT, \
|
2012-12-20 15:32:03 -08:00
|
|
|
|
{ NAME, VPORT_FUNCTIONS(get_tunnel_config, \
|
|
|
|
|
set_tunnel_config, \
|
|
|
|
|
get_netdev_tunnel_config, \
|
|
|
|
|
tunnel_get_status) }}
|
2013-01-08 20:01:24 -08:00
|
|
|
|
|
2010-10-06 15:35:53 -07:00
|
|
|
|
void
|
2013-01-25 13:30:40 -08:00
|
|
|
|
netdev_vport_tunnel_register(void)
|
2010-10-06 15:35:53 -07:00
|
|
|
|
{
|
2010-12-03 14:41:38 -08:00
|
|
|
|
static const struct vport_class vport_classes[] = {
|
2013-01-25 13:30:40 -08:00
|
|
|
|
TUNNEL_CLASS("gre", "gre_system"),
|
|
|
|
|
TUNNEL_CLASS("ipsec_gre", "gre_system"),
|
|
|
|
|
TUNNEL_CLASS("gre64", "gre64_system"),
|
|
|
|
|
TUNNEL_CLASS("ipsec_gre64", "gre64_system"),
|
2013-02-21 21:52:04 -08:00
|
|
|
|
TUNNEL_CLASS("vxlan", "vxlan_system"),
|
|
|
|
|
TUNNEL_CLASS("lisp", "lisp_system")
|
2010-12-03 14:41:38 -08:00
|
|
|
|
};
|
2013-08-09 21:34:02 -07:00
|
|
|
|
static struct ovsthread_once once = OVSTHREAD_ONCE_INITIALIZER;
|
2010-12-03 14:41:38 -08:00
|
|
|
|
|
2013-08-09 21:34:02 -07:00
|
|
|
|
if (ovsthread_once_start(&once)) {
|
|
|
|
|
int i;
|
2010-12-03 14:41:38 -08:00
|
|
|
|
|
2013-05-18 08:27:20 -07:00
|
|
|
|
for (i = 0; i < ARRAY_SIZE(vport_classes); i++) {
|
|
|
|
|
netdev_register_provider(&vport_classes[i].netdev_class);
|
|
|
|
|
}
|
2013-08-09 21:34:02 -07:00
|
|
|
|
ovsthread_once_done(&once);
|
2010-12-03 14:41:38 -08:00
|
|
|
|
}
|
2010-10-06 15:35:53 -07:00
|
|
|
|
}
|
2013-01-25 13:30:40 -08:00
|
|
|
|
|
|
|
|
|
void
|
|
|
|
|
netdev_vport_patch_register(void)
|
|
|
|
|
{
|
|
|
|
|
static const struct vport_class patch_class =
|
|
|
|
|
{ NULL,
|
|
|
|
|
{ "patch", VPORT_FUNCTIONS(get_patch_config,
|
|
|
|
|
set_patch_config,
|
|
|
|
|
NULL,
|
|
|
|
|
NULL) }};
|
|
|
|
|
netdev_register_provider(&patch_class.netdev_class);
|
|
|
|
|
}
|