Ignore this one, I had some issues on my end with sending it.
On Feb 15, 2013, at 4:01 PM, Kyle Mestery <kmest...@cisco.com>
wrote:
> v3 Changes to main loop from Ethan.
> v2 fixes error handling noticed by Ben.
> ---
> Garbage collect tnl_backers during type_run(). Add new
> tnl_backers if a VXLAN ports UDP port changes.
>
> Signed-off-by: Kyle Mestery <kmest...@cisco.com>
> ---
> ofproto/ofproto-dpif.c | 107 +++++++++++++++++++++++++++----------------------
> 1 file changed, 60 insertions(+), 47 deletions(-)
>
> diff --git a/ofproto/ofproto-dpif.c b/ofproto/ofproto-dpif.c
> index aa17244..66a722f 100644
> --- a/ofproto/ofproto-dpif.c
> +++ b/ofproto/ofproto-dpif.c
> @@ -721,7 +721,6 @@ static struct ofport_dpif *get_odp_port(const struct
> ofproto_dpif *,
> static void ofproto_trace(struct ofproto_dpif *, const struct flow *,
> const struct ofpbuf *, ovs_be16 initial_tci,
> struct ds *);
> -static bool may_dpif_port_del(struct ofport_dpif *);
>
> /* Packet processing. */
> static void update_learning_table(struct ofproto_dpif *,
> @@ -848,7 +847,59 @@ type_run(const char *type)
> || !tag_set_is_empty(&backer->revalidate_set)) {
> struct tag_set revalidate_set = backer->revalidate_set;
> bool need_revalidate = backer->need_revalidate;
> + const struct simap_node **nodes;
> struct ofproto_dpif *ofproto;
> + struct simap_node *node;
> + struct simap tmp_simap;
> +
> + /* Handle tunnel garbage collection. */
> + simap_init(&tmp_simap);
> + simap_swap(&backer->tnl_backers, &tmp_simap);
> +
> + HMAP_FOR_EACH (ofproto, all_ofproto_dpifs_node, &all_ofproto_dpifs) {
> + struct ofport_dpif *iter;
> +
> + if (backer != ofproto->backer) {
> + continue;
> + }
> +
> + HMAP_FOR_EACH (iter, up.hmap_node, &ofproto->up.ports) {
> + const char *dp_port;
> +
> + if (!iter->tnl_port) {
> + continue;
> + }
> +
> + dp_port = netdev_vport_get_dpif_port(iter->up.netdev);
> + node = simap_find(&tmp_simap, dp_port);
> + if (node) {
> + simap_put(&backer->tnl_backers, dp_port, node->data);
> + simap_delete(&tmp_simap, node);
> + } else {
> + node = simap_find(&backer->tnl_backers, dp_port);
> + if (!node) {
> + uint32_t odp_port = UINT32_MAX;
> +
> + if (!dpif_port_add(backer->dpif, iter->up.netdev,
> + &odp_port)) {
> + simap_put(&backer->tnl_backers, dp_port,
> odp_port);
> + node = simap_find(&backer->tnl_backers, dp_port);
> + }
> + }
> + }
> +
> + iter->odp_port = node ? node->data : OVSP_NONE;
> + if (tnl_port_reconfigure(&iter->up, iter->odp_port,
> + &iter->tnl_port)) {
> + backer->need_revalidate = REV_RECONFIGURE;
> + }
> + }
> + }
> +
> + SIMAP_FOR_EACH (node, &tmp_simap) {
> + dpif_port_del(backer->dpif, node->data);
> + }
> + simap_destroy(&tmp_simap);
>
> switch (backer->need_revalidate) {
> case REV_RECONFIGURE: COVERAGE_INC(rev_reconfigure); break;
> @@ -882,6 +933,7 @@ type_run(const char *type)
> }
> }
> }
> +
> }
>
> if (timer_expired(&backer->next_expiration)) {
> @@ -1622,14 +1674,15 @@ port_destruct(struct ofport *port_)
> const char *dp_port_name = netdev_vport_get_dpif_port(port->up.netdev);
> const char *devname = netdev_get_name(port->up.netdev);
>
> - if (dpif_port_exists(ofproto->backer->dpif, dp_port_name)
> - && may_dpif_port_del(port)) {
> + if (dpif_port_exists(ofproto->backer->dpif, dp_port_name)) {
> /* The underlying device is still there, so delete it. This
> * happens when the ofproto is being destroyed, since the caller
> * assumes that removal of attached ports will happen as part of
> * destruction. */
> - dpif_port_del(ofproto->backer->dpif, port->odp_port);
> - simap_find_and_delete(&ofproto->backer->tnl_backers, dp_port_name);
> + if (!port->tnl_port) {
> + dpif_port_del(ofproto->backer->dpif, port->odp_port);
> + }
> + ofproto->backer->need_revalidate = REV_RECONFIGURE;
> }
>
> if (port->odp_port != OVSP_NONE && !port->tnl_port) {
> @@ -3032,43 +3085,6 @@ port_add(struct ofproto *ofproto_, struct netdev
> *netdev)
> return 0;
> }
>
> -/* Returns true if the odp_port backing 'ofport' may be deleted from the
> - * datapath. In most cases, this function simply returns true. However, for
> - * tunnels it's possible that multiple ofports use the same odp_port, in
> which
> - * case we need to keep the odp_port backer around until the last ofport is
> - * deleted. */
> -static bool
> -may_dpif_port_del(struct ofport_dpif *ofport)
> -{
> - struct dpif_backer *backer =
> ofproto_dpif_cast(ofport->up.ofproto)->backer;
> - struct ofproto_dpif *ofproto_iter;
> -
> - if (!ofport->tnl_port) {
> - return true;
> - }
> -
> - HMAP_FOR_EACH (ofproto_iter, all_ofproto_dpifs_node, &all_ofproto_dpifs)
> {
> - struct ofport_dpif *iter;
> -
> - if (backer != ofproto_iter->backer) {
> - continue;
> - }
> -
> - HMAP_FOR_EACH (iter, up.hmap_node, &ofproto_iter->up.ports) {
> - if (ofport == iter) {
> - continue;
> - }
> -
> - if (!strcmp(netdev_vport_get_dpif_port(ofport->up.netdev),
> - netdev_vport_get_dpif_port(iter->up.netdev))) {
> - return false;
> - }
> - }
> - }
> -
> - return true;
> -}
> -
> static int
> port_del(struct ofproto *ofproto_, uint16_t ofp_port)
> {
> @@ -3082,17 +3098,14 @@ port_del(struct ofproto *ofproto_, uint16_t ofp_port)
>
> sset_find_and_delete(&ofproto->ghost_ports,
> netdev_get_name(ofport->up.netdev));
> - if (may_dpif_port_del(ofport)) {
> + ofproto->backer->need_revalidate = REV_RECONFIGURE;
> + if (!ofport->tnl_port) {
> error = dpif_port_del(ofproto->backer->dpif, ofport->odp_port);
> if (!error) {
> - const char *dpif_port;
> -
> /* The caller is going to close ofport->up.netdev. If this is a
> * bonded port, then the bond is using that netdev, so remove it
> * from the bond. The client will need to reconfigure everything
> * after deleting ports, so then the slave will get re-added. */
> - dpif_port = netdev_vport_get_dpif_port(ofport->up.netdev);
> - simap_find_and_delete(&ofproto->backer->tnl_backers, dpif_port);
> bundle_remove(&ofport->up);
> }
> }
> --
> 1.8.1
>
_______________________________________________
dev mailing list
dev@openvswitch.org
http://openvswitch.org/mailman/listinfo/dev
