lib/rstp: Better debug messages, style fixes.

Remove unused struct rstp_priority_vector4 definition, fix coding
style, fix sparse warnings.

Signed-off-by: Jarno Rajahalme <jrajahalme@nicira.com>
Acked-by: Daniele Venturino <daniele.venturino@m3s.it>

diff --git a/lib/rstp-common.h b/lib/rstp-common.h
index 6bc04eb..0c43446 100644 (file)
--- a/lib/rstp-common.h
+++ b/lib/rstp-common.h
@@ -205,18 +205,11 @@ struct rstp_priority_vector {
     uint16_t bridge_port_id;
 };
 
-struct rstp_priority_vector4 {
-    rstp_identifier root_bridge_id;
-    uint32_t root_path_cost;
-    rstp_identifier designated_bridge_id;
-    uint16_t designated_port_id;
-};
-
 enum rstp_bpdu_type {
     CONFIGURATION_BPDU = 0x0,
     TOPOLOGY_CHANGE_NOTIFICATION_BPDU = 0x80,
     RAPID_SPANNING_TREE_BPDU = 0x2
-} bpdu_type_t;
+};
 
 enum rstp_bpdu_flag {
     BPDU_FLAG_TOPCHANGE = 0x01,
@@ -225,7 +218,7 @@ enum rstp_bpdu_flag {
     BPDU_FLAG_FORWARDING = 0x20,
     BPDU_FLAG_AGREEMENT = 0x40,
     BPDU_FLAG_TOPCHANGEACK = 0x80
-} bpdu_flag;
+};
 
 /* Rapid Spanning Tree BPDU [9.3.3] */
 OVS_PACKED(

diff --git a/lib/rstp-state-machines.c b/lib/rstp-state-machines.c
index 4aea49d..a0fe3d9 100644 (file)
--- a/lib/rstp-state-machines.c
+++ b/lib/rstp-state-machines.c
@@ -110,7 +110,8 @@ process_received_bpdu(struct rstp_port *p, const void *bpdu, size_t bpdu_size)
         rstp->changes = true;
         move_rstp(rstp);
     } else {
-        VLOG_DBG("Bad BPDU received");
+        VLOG_DBG("%s, port %u: Bad BPDU received", p->rstp->name,
+                 p->port_number);
         p->error_count++;
     }
 }
@@ -296,7 +297,7 @@ updt_roles_tree(struct rstp *r)
     }
     r->root_priority = best_vector;
     r->root_port_id = best_vector.bridge_port_id;
-    VLOG_DBG("%s: new Root is "RSTP_ID_FMT"", r->name,
+    VLOG_DBG("%s: new Root is "RSTP_ID_FMT, r->name,
              RSTP_ID_ARGS(r->root_priority.root_bridge_id));
     /* Letters d) e) */
     if (r->ports_count > 0) {
@@ -423,8 +424,8 @@ port_role_selection_sm(struct rstp *r)
     }
     if (old_state != r->port_role_selection_sm_state) {
         r->changes = true;
-        VLOG_DBG("Port_role_selection_sm %d -> %d", old_state,
-            r->port_role_selection_sm_state);
+        VLOG_DBG("%s: Port_role_selection_sm %d -> %d", r->name,
+                 old_state, r->port_role_selection_sm_state);
     }
     return 0;
 }
@@ -823,10 +824,9 @@ tx_rstp(struct rstp_port *p)
         bpdu.flags = PORT_ALT_BACK << ROLE_FLAG_SHIFT;
         break;
     case ROLE_DISABLED:
-        /* should not happen! */
+        /* Should not happen! */
         VLOG_ERR("%s transmitting bpdu in disabled role on port "
-                 ""RSTP_PORT_ID_FMT"", p->rstp->name, p->port_id);
-        OVS_NOT_REACHED();
+                 RSTP_PORT_ID_FMT, p->rstp->name, p->port_id);
         break;
     }
     if (p->agree) {
@@ -899,6 +899,8 @@ port_transmit_sm(struct rstp_port *p)
         /* no break */
     case PORT_TRANSMIT_SM_IDLE:
         if (p->role == ROLE_DISABLED) {
+            VLOG_DBG("%s, port %u: port_transmit_sm ROLE == DISABLED.",
+                     p->rstp->name, p->port_number);
             break;
         }
         else if (p->send_rstp && p->new_info &&
@@ -1085,9 +1087,8 @@ port_information_sm(struct rstp_port *p)
     case PORT_INFORMATION_SM_DISABLED:
         if (p->port_enabled) {
             p->port_information_sm_state = PORT_INFORMATION_SM_AGED_EXEC;
-        }
-        else if (p->rcvd_msg) {
-        p->port_information_sm_state = PORT_INFORMATION_SM_DISABLED_EXEC;
+        } else if (p->rcvd_msg) {
+            p->port_information_sm_state = PORT_INFORMATION_SM_DISABLED_EXEC;
         }
         break;
     case PORT_INFORMATION_SM_AGED_EXEC:
@@ -1225,8 +1226,8 @@ port_information_sm(struct rstp_port *p)
     }
     if (old_state != p->port_information_sm_state) {
         r->changes = true;
-        VLOG_DBG("Port_information_sm %d -> %d", old_state,
-                 p->port_information_sm_state);
+        VLOG_DBG("%s, port %u: Port_information_sm %d -> %d", p->rstp->name,
+                 p->port_number, old_state, p->port_information_sm_state);
     }
     return 0;
 }
@@ -1945,8 +1946,8 @@ topology_change_sm(struct rstp_port *p)
     }
     if (old_state != p->topology_change_sm_state) {
         r->changes = true;
-        VLOG_DBG("Topology_change_sm %d -> %d",old_state,
-                 p->topology_change_sm_state);
+        VLOG_DBG("%s, port %u: Topology_change_sm %d -> %d", p->rstp->name,
+                 p->port_number, old_state, p->topology_change_sm_state);
     }
     return 0;
 }

diff --git a/lib/rstp.c b/lib/rstp.c
index b0ad613..17830d9 100644 (file)
--- a/lib/rstp.c
+++ b/lib/rstp.c
@@ -27,6 +27,7 @@
  */
 
 #include <config.h>
+
 #include "rstp.h"
 #include "rstp-common.h"
 #include "rstp-state-machines.h"
@@ -58,7 +59,7 @@ static void set_bridge_priority__(struct rstp *);
 static void reinitialize_rstp__(struct rstp *);
 static bool is_port_number_taken__(struct rstp *, int, struct rstp_port *);
 static uint16_t rstp_first_free_number__(struct rstp *, struct rstp_port *);
-static void rstp_initialize_port(struct rstp_port *p);
+static void rstp_initialize_port__(struct rstp_port *);
 
 const char *
 rstp_state_name(enum rstp_state state)
@@ -96,12 +97,11 @@ rstp_port_role_name(enum rstp_port_role role)
     }
 }
 
+/* Caller has to hold a reference to prevent 'rstp' from being deleted
+ * while we are taking a new reference. */
 struct rstp *
-rstp_ref(struct rstp *rstp_)
+rstp_ref(struct rstp *rstp)
 {
-    struct rstp *rstp;
-
-    rstp = rstp_;
     if (rstp) {
         ovs_refcount_ref(&rstp->ref_cnt);
     }
@@ -112,11 +112,11 @@ rstp_ref(struct rstp *rstp_)
 void
 rstp_unref(struct rstp *rstp)
 {
-    struct rstp_port *p;
-
     if (rstp && ovs_refcount_unref(&rstp->ref_cnt) == 1) {
         ovs_mutex_lock(&mutex);
         if (rstp->ports_count > 0) {
+            struct rstp_port *p;
+
             LIST_FOR_EACH (p, node, &rstp->ports) {
                 rstp_delete_port(p);
             }
@@ -128,7 +128,9 @@ rstp_unref(struct rstp *rstp)
     }
 }
 
-/* Returns the port number. */
+/* Returns the port number.  Mutex is needed to guard against
+ * concurrent reinitialization (which can temporarily clear the
+ * port_number). */
 int
 rstp_port_number(const struct rstp_port *p)
 {
@@ -164,15 +166,15 @@ rstp_received_bpdu(struct rstp_port *p, const void *bpdu, size_t bpdu_size)
 void
 rstp_init(void)
 {
-     unixctl_command_register("rstp/tcn", "[bridge]", 0, 1, rstp_unixctl_tcn,
-                                     NULL);
+    unixctl_command_register("rstp/tcn", "[bridge]", 0, 1, rstp_unixctl_tcn,
+                             NULL);
 }
 
 /* Creates and returns a new RSTP instance that initially has no ports. */
 struct rstp *
 rstp_create(const char *name, rstp_identifier bridge_address,
-        void (*send_bpdu)(struct ofpbuf *bpdu, int port_no, void *aux),
-        void *aux)
+            void (*send_bpdu)(struct ofpbuf *bpdu, int port_no, void *aux),
+            void *aux)
 {
     static struct ovsthread_once once = OVSTHREAD_ONCE_INITIALIZER;
     struct rstp *rstp;
@@ -205,12 +207,14 @@ rstp_create(const char *name, rstp_identifier bridge_address,
     rstp->changes = false;
     rstp->begin = true;
 
-    ovs_mutex_lock(&mutex);
     /* Initialize the ports list. */
     list_init(&rstp->ports);
     ovs_refcount_init(&rstp->ref_cnt);
+
+    ovs_mutex_lock(&mutex);
     list_push_back(all_rstps, &rstp->node);
     ovs_mutex_unlock(&mutex);
+
     VLOG_DBG("RSTP instance creation done");
     return rstp;
 }
@@ -236,6 +240,7 @@ rstp_set_bridge_address(struct rstp *rstp, rstp_identifier bridge_address)
 
     VLOG_DBG("%s: set bridge address to: "RSTP_ID_FMT"", rstp->name,
              RSTP_ID_ARGS(bridge_address));
+
     ovs_mutex_lock(&mutex);
     rstp->address = bridge_address;
     rstp->bridge_identifier = bridge_address;
@@ -246,8 +251,8 @@ rstp_set_bridge_address(struct rstp *rstp, rstp_identifier bridge_address)
      */
     if (rstp->ports_count > 0) {
         LIST_FOR_EACH (p, node, &rstp->ports) {
-            p->selected = 0;
-            p->reselect = 1;
+            p->selected = false;
+            p->reselect = true;
         }
     }
     rstp->changes = true;
@@ -289,7 +294,7 @@ rstp_set_bridge_priority(struct rstp *rstp, int new_priority)
                  (new_priority / 4096) * 4096);
         ovs_mutex_lock(&mutex);
         rstp->priority = (new_priority / 4096) * 4096;
-        rstp->bridge_identifier &= 0xffffffffffffULL;
+        rstp->bridge_identifier &= 0x0000ffffffffffffULL;
         rstp->bridge_identifier |=
                               (uint64_t) ((new_priority / 4096) * 4096) << 48;
         set_bridge_priority__(rstp);
@@ -297,8 +302,8 @@ rstp_set_bridge_priority(struct rstp *rstp, int new_priority)
         /* [17.13] */
         if (rstp->ports_count > 0){
             LIST_FOR_EACH (p, node, &rstp->ports) {
-                p->selected = 0;
-                p->reselect = 1;
+                p->selected = false;
+                p->reselect = true;
             }
         }
         rstp->changes = true;
@@ -311,9 +316,10 @@ rstp_set_bridge_priority(struct rstp *rstp, int new_priority)
 void
 rstp_set_bridge_ageing_time(struct rstp *rstp, int new_ageing_time)
 {
-    if (new_ageing_time >= RSTP_MIN_AGEING_TIME &&
-            new_ageing_time <= RSTP_MAX_AGEING_TIME) {
+    if (new_ageing_time >= RSTP_MIN_AGEING_TIME
+        && new_ageing_time <= RSTP_MAX_AGEING_TIME) {
         VLOG_DBG("%s: set ageing time to %d", rstp->name, new_ageing_time);
+
         ovs_mutex_lock(&mutex);
         rstp->ageing_time = new_ageing_time;
         ovs_mutex_unlock(&mutex);
@@ -325,14 +331,15 @@ rstp_set_bridge_ageing_time(struct rstp *rstp, int new_ageing_time)
  */
 static void
 reinitialize_rstp__(struct rstp *rstp)
+    OVS_REQUIRES(mutex)
 {
     struct rstp temp;
-    struct rstp_port *p, temp_port;
     static struct list ports;
 
     /* Copy rstp in temp */
     temp = *rstp;
     ports = rstp->ports;
+
     /* stop and clear rstp */
     memset(rstp, 0, sizeof(struct rstp));
 
@@ -360,7 +367,10 @@ reinitialize_rstp__(struct rstp *rstp)
     rstp->begin = true;
     rstp->ports = ports;
     rstp->ports_count = temp.ports_count;
-    if (rstp->ports_count > 0){
+
+    if (rstp->ports_count > 0) {
+        struct rstp_port *p, temp_port;
+
         LIST_FOR_EACH (p, node, &rstp->ports) {
             temp_port = *p;
             memset(p, 0, sizeof(struct rstp_port));
@@ -442,8 +452,8 @@ rstp_set_bridge_max_age(struct rstp *rstp, int new_max_age)
     if (new_max_age >= RSTP_MIN_BRIDGE_MAX_AGE &&
         new_max_age <= RSTP_MAX_BRIDGE_MAX_AGE) {
         /* [17.13] */
-        if ((2*(rstp->bridge_forward_delay - 1) >= new_max_age) &&
-            (new_max_age >= 2*rstp->bridge_hello_time)) {
+        if ((2 * (rstp->bridge_forward_delay - 1) >= new_max_age)
+            && (new_max_age >= 2 * rstp->bridge_hello_time)) {
             VLOG_DBG("%s: set RSTP bridge Max Age to %d", rstp->name,
                      new_max_age);
             ovs_mutex_lock(&mutex);
@@ -458,8 +468,8 @@ rstp_set_bridge_max_age(struct rstp *rstp, int new_max_age)
 void
 rstp_set_bridge_forward_delay(struct rstp *rstp, int new_forward_delay)
 {
-    if (new_forward_delay >= RSTP_MIN_BRIDGE_FORWARD_DELAY &&
-            new_forward_delay <= RSTP_MAX_BRIDGE_FORWARD_DELAY) {
+    if (new_forward_delay >= RSTP_MIN_BRIDGE_FORWARD_DELAY
+        && new_forward_delay <= RSTP_MAX_BRIDGE_FORWARD_DELAY) {
         if (2 * (new_forward_delay - 1) >= rstp->bridge_max_age) {
             VLOG_DBG("%s: set RSTP Forward Delay to %d", rstp->name,
                      new_forward_delay);
@@ -478,16 +488,16 @@ rstp_set_bridge_transmit_hold_count(struct rstp *rstp,
 {
     struct rstp_port *p;
 
-    if (new_transmit_hold_count >= RSTP_MIN_TRANSMIT_HOLD_COUNT &&
-            new_transmit_hold_count <= RSTP_MAX_TRANSMIT_HOLD_COUNT) {
+    if (new_transmit_hold_count >= RSTP_MIN_TRANSMIT_HOLD_COUNT
+        && new_transmit_hold_count <= RSTP_MAX_TRANSMIT_HOLD_COUNT) {
         VLOG_DBG("%s: set RSTP Transmit Hold Count to %d", rstp->name,
                  new_transmit_hold_count);
         /* Resetting txCount on all ports [17.13]. */
         ovs_mutex_lock(&mutex);
         rstp->transmit_hold_count = new_transmit_hold_count;
-        if (rstp->ports_count > 0){
+        if (rstp->ports_count > 0) {
             LIST_FOR_EACH (p, node, &rstp->ports) {
-                p->tx_count=0;
+                p->tx_count = 0;
             }
         }
         ovs_mutex_unlock(&mutex);
@@ -514,14 +524,17 @@ rstp_set_bridge_times(struct rstp *rstp, int new_forward_delay,
 {
     VLOG_DBG("%s: set RSTP times to (%d, %d, %d, %d)", rstp->name,
              new_forward_delay, new_hello_time, new_max_age, new_message_age);
-    if (new_forward_delay >= RSTP_MIN_BRIDGE_FORWARD_DELAY &&
-            new_forward_delay <= RSTP_MAX_BRIDGE_FORWARD_DELAY)
+    if (new_forward_delay >= RSTP_MIN_BRIDGE_FORWARD_DELAY
+        && new_forward_delay <= RSTP_MAX_BRIDGE_FORWARD_DELAY) {
         rstp->bridge_times.forward_delay = new_forward_delay;
-    if (new_hello_time == RSTP_BRIDGE_HELLO_TIME)
+    }
+    if (new_hello_time == RSTP_BRIDGE_HELLO_TIME) {
         rstp->bridge_times.hello_time = new_hello_time;
-    if (new_max_age >= RSTP_MIN_BRIDGE_MAX_AGE &&
-            new_max_age <= RSTP_MAX_BRIDGE_MAX_AGE)
+    }
+    if (new_max_age >= RSTP_MIN_BRIDGE_MAX_AGE
+        && new_max_age <= RSTP_MAX_BRIDGE_MAX_AGE) {
         rstp->bridge_times.max_age = new_max_age;
+    }
     rstp->bridge_times.message_age = new_message_age;
 }
 
@@ -547,16 +560,16 @@ rstp_port_set_priority(struct rstp_port *rstp_port, int new_port_priority)
     struct rstp *rstp;
 
     rstp = rstp_port->rstp;
-    if (new_port_priority >= RSTP_MIN_PORT_PRIORITY &&
-            new_port_priority  <= RSTP_MAX_PORT_PRIORITY) {
+    if (new_port_priority >= RSTP_MIN_PORT_PRIORITY
+        && new_port_priority <= RSTP_MAX_PORT_PRIORITY) {
         VLOG_DBG("%s, port %u: set RSTP port priority to %d", rstp->name,
                  rstp_port->port_number, new_port_priority);
         ovs_mutex_lock(&mutex);
         new_port_priority -= new_port_priority % RSTP_STEP_PORT_PRIORITY;
         rstp_port->priority = new_port_priority;
         set_port_id__(rstp_port);
-        rstp_port->selected = 0;
-        rstp_port->reselect = 1;
+        rstp_port->selected = false;
+        rstp_port->reselect = true;
         ovs_mutex_unlock(&mutex);
     }
 }
@@ -623,10 +636,9 @@ rstp_port_set_port_number(struct rstp_port *rstp_port,
 
     set_port_id__(rstp_port);
     /* [17.13] is not clear. I suppose that a port number change
-     * should trigger reselection like a port priority change.
-     */
-    rstp_port->selected = 0;
-    rstp_port->reselect = 1;
+     * should trigger reselection like a port priority change. */
+    rstp_port->selected = false;
+    rstp_port->reselect = true;
     ovs_mutex_unlock(&mutex);
     VLOG_DBG("%s: set new RSTP port number %d", rstp->name,
              rstp_port->port_number);
@@ -656,17 +668,17 @@ void
 rstp_port_set_path_cost(struct rstp_port *rstp_port,
                         uint32_t new_port_path_cost)
 {
-    struct rstp *rstp;
-
-    rstp = rstp_port->rstp;
     if (new_port_path_cost >= RSTP_MIN_PORT_PATH_COST &&
             new_port_path_cost <= RSTP_MAX_PORT_PATH_COST) {
+        struct rstp *rstp;
+
+        ovs_mutex_lock(&mutex);
+        rstp = rstp_port->rstp;
         VLOG_DBG("%s, port %u, set RSTP port path cost to %d", rstp->name,
                  rstp_port->port_number, new_port_path_cost);
-        ovs_mutex_lock(&mutex);
         rstp_port->port_path_cost = new_port_path_cost;
-        rstp_port->selected = 0;
-        rstp_port->reselect = 1;
+        rstp_port->selected = false;
+        rstp_port->reselect = true;
         ovs_mutex_unlock(&mutex);
     }
 }
@@ -712,17 +724,21 @@ rstp_check_and_reset_fdb_flush(struct rstp *rstp)
 
 /* Finds a port whose state has changed.  If successful, stores the port whose
  * state changed in '*portp' and returns true.  If no port has changed, stores
- * NULL in '*portp' and returns false. */
+ * NULL in '*portp' and returns false.
+ *
+ * XXX: This function is only called by the main thread, which is also the one
+ * that creates and deletes ports.  Otherwise this function is not thread safe,
+ * as the returned '*portp' could become stale before it is referenced by the
+ * caller. */
 bool
 rstp_get_changed_port(struct rstp *rstp, struct rstp_port **portp)
 {
-    struct rstp_port *p;
-    bool changed;
-
-    changed = false;
+    bool changed = false;
 
     ovs_mutex_lock(&mutex);
-    if (rstp->ports_count > 0){
+    if (rstp->ports_count > 0) {
+        struct rstp_port *p;
+
         LIST_FOR_EACH (p, node, &rstp->ports) {
             if (p->state_changed) {
                 p->state_changed = false;
@@ -822,8 +838,8 @@ rstp_port_set_oper_point_to_point_mac(struct rstp_port *p,
 
 /* Initializes a port with the defaults values for its parameters. */
 static void
-rstp_initialize_port(struct rstp_port *p)
-OVS_REQUIRES(mutex)
+rstp_initialize_port__(struct rstp_port *p)
+    OVS_REQUIRES(mutex)
 {
     struct rstp *rstp;
 
@@ -916,7 +932,7 @@ rstp_add_port(struct rstp *rstp) {
 
     ovs_mutex_lock(&mutex);
     p->rstp = rstp;
-    rstp_initialize_port(p);
+    rstp_initialize_port__(p);
     rstp_port_set_state(p, RSTP_DISCARDING);
     list_push_back(&rstp->ports, &p->node);
     rstp->ports_count++;

diff --git a/lib/rstp.h b/lib/rstp.h
index 916521a..5d7c7f4 100644 (file)
--- a/lib/rstp.h
+++ b/lib/rstp.h
@@ -127,8 +127,10 @@ const char *rstp_port_role_name(enum rstp_port_role);
 void rstp_init(void);
 
 struct rstp * rstp_create(const char *, rstp_identifier bridge_id,
-        void (*send_bpdu)(struct ofpbuf *, int port_no, void *),
-                void *);
+                          void (*send_bpdu)(struct ofpbuf *, int port_no,
+                                            void *aux),
+                          void *aux);
+
 struct rstp *rstp_ref(struct rstp *);
 void rstp_unref(struct rstp *);
 
@@ -140,7 +142,7 @@ void rstp_received_bpdu(struct rstp_port *, const void *, size_t);
 bool rstp_check_and_reset_fdb_flush(struct rstp *);
 bool rstp_get_changed_port(struct rstp *, struct rstp_port **);
 void rstp_port_set_mac_operational(struct rstp_port *,
-                                   bool  new_mac_operational);
+                                   bool new_mac_operational);
 bool rstp_port_get_mac_operational(struct rstp_port *);
 
 /* Bridge setters */
@@ -148,12 +150,12 @@ void rstp_set_bridge_address(struct rstp *, rstp_identifier bridge_address);
 void rstp_set_bridge_priority(struct rstp *, int new_priority);
 void rstp_set_bridge_ageing_time(struct rstp *, int new_ageing_time);
 void rstp_set_bridge_force_protocol_version(struct rstp *,
-                enum rstp_force_protocol_version new_force_protocol_version);
+                                            enum rstp_force_protocol_version);
 void rstp_set_bridge_hello_time(struct rstp *);
 void rstp_set_bridge_max_age(struct rstp *, int new_max_age);
 void rstp_set_bridge_forward_delay(struct rstp *, int new_forward_delay);
 void rstp_set_bridge_transmit_hold_count(struct rstp *,
-                                        int new_transmit_hold_count);
+                                         int new_transmit_hold_count);
 void rstp_set_bridge_migrate_time(struct rstp *);
 void rstp_set_bridge_times(struct rstp *, int new_forward_delay,
                            int new_hello_time, int new_max_age,

diff --git a/ofproto/ofproto-dpif.c b/ofproto/ofproto-dpif.c
index aeff00d..34ecc51 100644 (file)
--- a/ofproto/ofproto-dpif.c
+++ b/ofproto/ofproto-dpif.c
@@ -1917,15 +1917,16 @@ rstp_send_bpdu_cb(struct ofpbuf *pkt, int port_num, void *ofproto_)
 
     ofport = rstp_port_get_aux(rp);
     if (!ofport) {
-        VLOG_WARN_RL(&rl, "%s: cannot send BPDU on unknown port %d",
-                ofproto->up.name, port_num);
+        VLOG_WARN_RL(&rl, "%s: cannot send BPDU on unknown RSTP port %d",
+                     ofproto->up.name, port_num);
     } else {
         struct eth_header *eth = ofpbuf_l2(pkt);
 
         netdev_get_etheraddr(ofport->up.netdev, eth->eth_src);
         if (eth_addr_is_zero(eth->eth_src)) {
-            VLOG_WARN_RL(&rl, "%s: cannot send BPDU on port %d "
-                    "with unknown MAC", ofproto->up.name, port_num);
+            VLOG_WARN_RL(&rl, "%s port %d: cannot send BPDU on RSTP port %d "
+                         "with unknown MAC", ofproto->up.name,
+                         ofp_to_u16(ofport->up.ofp_port), port_num);
         } else {
             ofproto_dpif_send_packet(ofport, pkt);
         }
@@ -1972,7 +1973,7 @@ set_rstp(struct ofproto *ofproto_, const struct ofproto_rstp_settings *s)
     if (s) {
         if (!ofproto->rstp) {
             ofproto->rstp = rstp_create(ofproto_->name, s->address,
-              rstp_send_bpdu_cb, ofproto);
+                                        rstp_send_bpdu_cb, ofproto);
             ofproto->rstp_last_tick = time_msec();
         }
         rstp_set_bridge_address(ofproto->rstp, s->address);

diff --git a/vswitchd/bridge.c b/vswitchd/bridge.c
index ba2eb79..8f99d7d 100644 (file)
--- a/vswitchd/bridge.c
+++ b/vswitchd/bridge.c
@@ -1358,16 +1358,14 @@ port_configure_rstp(const struct ofproto *ofproto, struct port *port,
             return;
         }
         port_s->port_num = port_num;
-    }
-    else {
+    } else {
         if (*port_num_counter >= RSTP_MAX_PORTS) {
             VLOG_ERR("port %s: too many RSTP ports, disabling", port->name);
             port_s->enable = false;
             return;
         }
-        /* If rstp-port-num is not specified, use 0. rstp_port_set_port_number
-         * will look for the first free one.
-         */
+        /* If rstp-port-num is not specified, use 0.
+         * rstp_port_set_port_number() will look for the first free one. */
         port_s->port_num = 0;
     }
 
@@ -1403,6 +1401,7 @@ static void
 bridge_configure_stp(struct bridge *br)
 {
     struct ofproto_rstp_status rstp_status;
+
     ofproto_get_rstp_status(br->ofproto, &rstp_status);
     if (!br->cfg->stp_enable) {
         ofproto_set_stp(br->ofproto, NULL);
@@ -1504,6 +1503,7 @@ static void
 bridge_configure_rstp(struct bridge *br)
 {
     struct ofproto_stp_status stp_status;
+
     ofproto_get_stp_status(br->ofproto, &stp_status);
     if (!br->cfg->rstp_enable) {
         ofproto_set_rstp(br->ofproto, NULL);