src/rstp/port.c

   1 /************************************************************************
   2  * RSTP library - Rapid Spanning Tree (802.1t, 802.1w)
   3  * Copyright (C) 2001-2003 Optical Access
   4  * Author: Alex Rozin
   5  *
   6  * This file is part of RSTP library.
   7  *
   8  * RSTP library is free software; you can redistribute it and/or modify it
   9  * under the terms of the GNU Lesser General Public License as published by the
  10  * Free Software Foundation; version 2.1
  11  *
  12  * RSTP library is distributed in the hope that it will be useful, but
  13  * WITHOUT ANY WARRANTY; without even the implied warranty of
  14  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU Lesser
  15  * General Public License for more details.
  16  *
  17  * You should have received a copy of the GNU Lesser General Public License
  18  * along with RSTP library; see the file COPYING.  If not, write to the Free
  19  * Software Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA
  20  * 02111-1307, USA.
  21  **********************************************************************/
  22
  23 /* STP PORT instance : 17.18, 17.15 */
  24
  25 #include "base.h"
  26 #include "stpm.h"
  27 #include "stp_in.h"
  28
  29 #include "rolesel.h"
  30 #include "portinfo.h"
  31 #include "roletrns.h"
  32 #include "sttrans.h"
  33 #include "topoch.h"
  34 #include "migrate.h"
  35 #include "transmit.h"
  36 #include "p2p.h"
  37 #include "pcost.h"
  38 #include "edge.h"
  39 #include "portrec.h"
  40 #include "brdec.h"
  41
  42 #include "stp_to.h" /* for STP_OUT_get_port_name & STP_OUT_get_port_link_status */
  43 #include "rstp_bridge.h"
  44
  45 Bool portEnabled(PORT_T *self)
  46 {
  47   if (self->adminEnable && self->macOperational)
  48     return True;
  49   else
  50     return False;
  51 }
  52
  53 PORT_T * STP_port_create (STPM_T* stpm, int port_index)
  54 {
  55   PORT_T*        self;
  56   UID_STP_PORT_CFG_T port_cfg;
  57   register int   iii;
  58   unsigned short port_prio;
  59
  60   /* check, if the port has just been added */
  61   for (self = stpm->ports; self; self = self->next) {
  62     if (self->port_index == port_index) {
  63       return NULL;
  64     }
  65   }
  66
  67   STP_NEW_IN_LIST(self, PORT_T, stpm->ports, "port create");
  68
  69   self->owner = stpm;
  70   self->machines = NULL;
  71   self->port_index = port_index;
  72   self->port_name = strdup (STP_OUT_get_port_name (self->owner->rstp, port_index));
  73   self->uptime = 0;
  74 #ifdef USELUA
  75   STP_OUT_get_init_port_cfg (stpm->rstp, stpm->vlan_id, port_index, &port_cfg);
  76 #else
  77   STP_OUT_get_init_port_cfg (stpm->vlan_id, port_index, &port_cfg);
  78 #endif
  79   port_prio =                  port_cfg.port_priority;
  80   self->admin_non_stp =        port_cfg.admin_non_stp;
  81   self->adminEdge =            port_cfg.admin_edge;
  82 #if 0
  83   self->autoEdge =               port_cfg.auto_edge;
  84 #endif
  85   self->adminPCost =           port_cfg.admin_port_path_cost;
  86   self->adminPointToPointMac = port_cfg.admin_point2point;
  87
  88   self->LinkDelay = DEF_LINK_DELAY;
  89   self->port_id = (port_prio << 8) + port_index;
  90
  91   iii = 0;
  92   self->timers[iii++] = &self->fdWhile;
  93   self->timers[iii++] = &self->helloWhen;
  94   self->timers[iii++] = &self->mdelayWhile;
  95   self->timers[iii++] = &self->rbWhile;
  96   self->timers[iii++] = &self->rcvdInfoWhile;
  97   self->timers[iii++] = &self->rrWhile;
  98   self->timers[iii++] = &self->tcWhile;
  99   self->timers[iii++] = &self->txCount;
 100   self->timers[iii++] = &self->lnkWhile;
 101
 102   /* create and bind port state machines */
 103   STP_STATE_MACH_IN_LIST(topoch);
 104
 105   STP_STATE_MACH_IN_LIST(migrate);
 106
 107   STP_STATE_MACH_IN_LIST(p2p);
 108
 109 #if 0 /* leu: replaced by brdec */
 110   STP_STATE_MACH_IN_LIST(edge);
 111 #endif
 112
 113   STP_STATE_MACH_IN_LIST(pcost)
 114
 115   STP_STATE_MACH_IN_LIST(info);
 116
 117   STP_STATE_MACH_IN_LIST(roletrns);
 118
 119   STP_STATE_MACH_IN_LIST(sttrans);
 120
 121   STP_STATE_MACH_IN_LIST(transmit);
 122
 123   STP_STATE_MACH_IN_LIST(portrec);  /* kd: new */
 124
 125   STP_STATE_MACH_IN_LIST(brdec);    /* kd: new */
 126
 127 #ifdef STP_DBG
 128 #if 0
 129   self->roletrns->ignoreHop2State = 14; /* DESIGNATED_PORT; */
 130   self->info->ignoreHop2State =      3; /* CURRENT */
 131   self->transmit->ignoreHop2State =  3; /* IDLE */
 132   self->edge->ignoreHop2State =      0; /* DISABLED; */
 133 #endif
 134
 135 #ifdef STP_DBG_ALL
 136   self->info->debug = 1;
 137   self->pcost->debug = 1;
 138   self->p2p->debug = 1;
 139   self->edge->debug = 1;
 140   self->migrate->debug = 1;
 141   self->sttrans->debug = 1;
 142   self->topoch->debug = 1;
 143   self->roletrns->debug = 1;
 144   self->portrec->debug = 1;
 145   self->brdec->debug = 1;
 146   self->sttrans->debug = 1;
 147 #endif
 148
 149 #endif
 150   return self;
 151 }
 152
 153 void STP_port_init (PORT_T* self, STPM_T* stpm, Bool check_link)
 154 {
 155   if (check_link) {
 156     self->adminEnable = STP_OUT_get_port_link_status (stpm->rstp, self->port_index);
 157     STP_VECT_create (&self->designPrio,
 158                      &stpm->BrId,
 159                      0,
 160                      &stpm->BrId,
 161                      self->port_id,
 162                      self->port_id);
 163     STP_copy_times (&self->designTimes, &stpm->rootTimes);
 164   }
 165
 166   /* reset timers */
 167   self->fdWhile =
 168   self->helloWhen =
 169   self->mdelayWhile =
 170   self->rbWhile =
 171   self->rcvdInfoWhile =
 172   self->rrWhile =
 173   self->tcWhile =
 174   self->txCount = 0;
 175
 176   self->msgPortRole = RSTP_PORT_ROLE_UNKN;
 177   self->selectedRole = DisabledPort;
 178   self->sendRSTP = True;
 179   self->operSpeed = STP_OUT_get_port_oper_speed (self->owner->rstp, self->port_index);
 180   self->p2p_recompute = True;
 181 }
 182
 183 void STP_port_delete (PORT_T* self)
 184 {
 185   STPM_T*                   stpm;
 186   register PORT_T*          prev;
 187   register PORT_T*          tmp;
 188   register STATE_MACH_T*    stater;
 189   register void*            pv;
 190
 191   stpm = self->owner;
 192
 193   free (self->port_name);
 194   for (stater = self->machines; stater; ) {
 195     pv = (void*) stater->next;
 196     STP_state_mach_delete (stater);
 197     stater = (STATE_MACH_T*) pv;
 198   }
 199
 200   prev = NULL;
 201   for (tmp = stpm->ports; tmp; tmp = tmp->next) {
 202     if (tmp->port_index == self->port_index) {
 203       if (prev) {
 204         prev->next = self->next;
 205       } else {
 206         stpm->ports = self->next;
 207       }
 208       STP_FREE(self, "stp instance");
 209       break;
 210     }
 211     prev = tmp;
 212   }
 213 }
 214
 215 int STP_port_rx_bpdu (PORT_T* self, BPDU_T* bpdu, size_t len)
 216 {
 217   STP_info_rx_bpdu (self, bpdu, len);
 218   return 0;
 219 }
 220
 221 #ifdef STP_DBG
 222 int STP_port_trace_state_machine (PORT_T* self, char* mach_name, int enadis, int vlan_id)
 223 {
 224   register struct state_mach_t* stater;
 225
 226   for (stater = self->machines; stater; stater = stater->next) {
 227     if (! strcmp (mach_name, "all") || ! strcmp (mach_name, stater->name)) {
 228       if (self->debug)
 229         stp_trace ("port %s on %s trace %-8s (was %s) now %s",
 230                    self->port_name, self->owner->name,
 231                    stater->name,
 232                    stater->debug ? " enabled" :"disabled",
 233                    enadis        ? " enabled" :"disabled");
 234       stater->debug = enadis;
 235     }
 236   }
 237   return 0;
 238 }
 239
 240 void STP_port_trace_flags (char* title, PORT_T* self)
 241 {
 242 /* it may be opened for more deep debugging */
 243 #ifdef STP_DBG_FLAGS
 244   unsigned long flag = 0L;
 245
 246   if (self->reRoot)   flag |= 0x000001L;
 247   if (self->sync)     flag |= 0x000002L;
 248   if (self->synced)   flag |= 0x000004L;
 249
 250   if (self->proposed)  flag |= 0x000010L;
 251   if (self->proposing) flag |= 0x000020L;
 252   if (self->agreed)    flag |= 0x000040L;
 253   if (self->updtInfo)  flag |= 0x000080L;
 254
 255   if (self->operEdge)   flag |= 0x000100L;
 256   stp_trace ("         %-12s: flags=0x%04lx port=%s", title, flag, self->port_name);
 257 #endif
 258 }
 259
 260 #endif