1*55fea89dSDan Cross /************************************************************************
2*55fea89dSDan Cross * RSTP library - Rapid Spanning Tree (802.1t, 802.1w)
3*55fea89dSDan Cross * Copyright (C) 2001-2003 Optical Access
4*55fea89dSDan Cross * Author: Alex Rozin
5*55fea89dSDan Cross *
6*55fea89dSDan Cross * This file is part of RSTP library.
7*55fea89dSDan Cross *
8*55fea89dSDan Cross * RSTP library is free software; you can redistribute it and/or modify it
9*55fea89dSDan Cross * under the terms of the GNU Lesser General Public License as published by the
10*55fea89dSDan Cross * Free Software Foundation; version 2.1
11*55fea89dSDan Cross *
12*55fea89dSDan Cross * RSTP library is distributed in the hope that it will be useful, but
13*55fea89dSDan Cross * WITHOUT ANY WARRANTY; without even the implied warranty of
14*55fea89dSDan Cross * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU Lesser
15*55fea89dSDan Cross * General Public License for more details.
16*55fea89dSDan Cross *
17*55fea89dSDan Cross * You should have received a copy of the GNU Lesser General Public License
18*55fea89dSDan Cross * along with RSTP library; see the file COPYING. If not, write to the Free
19*55fea89dSDan Cross * Software Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA
20*55fea89dSDan Cross * 02111-1307, USA.
214eaa4710SRishi Srivatsavai **********************************************************************/
224eaa4710SRishi Srivatsavai
234eaa4710SRishi Srivatsavai /* STP PORT instance : 17.18, 17.15 */
24*55fea89dSDan Cross
254eaa4710SRishi Srivatsavai #include "base.h"
264eaa4710SRishi Srivatsavai #include "stpm.h"
274eaa4710SRishi Srivatsavai #include "stp_in.h"
284eaa4710SRishi Srivatsavai
294eaa4710SRishi Srivatsavai /* #include "rolesel.h" */
304eaa4710SRishi Srivatsavai #include "portinfo.h"
314eaa4710SRishi Srivatsavai #include "roletrns.h"
324eaa4710SRishi Srivatsavai #include "sttrans.h"
334eaa4710SRishi Srivatsavai #include "topoch.h"
344eaa4710SRishi Srivatsavai #include "migrate.h"
354eaa4710SRishi Srivatsavai #include "transmit.h"
364eaa4710SRishi Srivatsavai #include "p2p.h"
374eaa4710SRishi Srivatsavai #include "pcost.h"
384eaa4710SRishi Srivatsavai #include "edge.h"
394eaa4710SRishi Srivatsavai
404eaa4710SRishi Srivatsavai #include "stp_to.h" /* for STP_OUT_get_port_name & STP_OUT_get_port_link_status */
414eaa4710SRishi Srivatsavai
424eaa4710SRishi Srivatsavai int port_trace_flags;
434eaa4710SRishi Srivatsavai
444eaa4710SRishi Srivatsavai PORT_T *
STP_port_create(STPM_T * stpm,int port_index)454eaa4710SRishi Srivatsavai STP_port_create (STPM_T* stpm, int port_index)
464eaa4710SRishi Srivatsavai {
474eaa4710SRishi Srivatsavai PORT_T* this;
484eaa4710SRishi Srivatsavai UID_STP_PORT_CFG_T port_cfg;
494eaa4710SRishi Srivatsavai register int iii;
504eaa4710SRishi Srivatsavai unsigned short port_prio;
514eaa4710SRishi Srivatsavai
524eaa4710SRishi Srivatsavai /* check, if the port has just been added */
534eaa4710SRishi Srivatsavai for (this = stpm->ports; this; this = this->next) {
544eaa4710SRishi Srivatsavai if (this->port_index == port_index) {
554eaa4710SRishi Srivatsavai return NULL;
564eaa4710SRishi Srivatsavai }
574eaa4710SRishi Srivatsavai }
584eaa4710SRishi Srivatsavai
594eaa4710SRishi Srivatsavai STP_NEW_IN_LIST(this, PORT_T, stpm->ports, "port create");
604eaa4710SRishi Srivatsavai
614eaa4710SRishi Srivatsavai this->owner = stpm;
624eaa4710SRishi Srivatsavai this->machines = NULL;
634eaa4710SRishi Srivatsavai this->port_index = port_index;
644eaa4710SRishi Srivatsavai this->port_name = strdup (STP_OUT_get_port_name (port_index));
654eaa4710SRishi Srivatsavai this->uptime = 0;
664eaa4710SRishi Srivatsavai
674eaa4710SRishi Srivatsavai STP_OUT_get_init_port_cfg (stpm->vlan_id, port_index, &port_cfg);
684eaa4710SRishi Srivatsavai port_prio = port_cfg.port_priority;
694eaa4710SRishi Srivatsavai this->admin_non_stp = port_cfg.admin_non_stp;
704eaa4710SRishi Srivatsavai this->adminEdge = port_cfg.admin_edge;
714eaa4710SRishi Srivatsavai this->adminPCost = port_cfg.admin_port_path_cost;
724eaa4710SRishi Srivatsavai this->adminPointToPointMac = port_cfg.admin_point2point;
73*55fea89dSDan Cross
744eaa4710SRishi Srivatsavai this->LinkDelay = DEF_LINK_DELAY;
754eaa4710SRishi Srivatsavai this->port_id = (port_prio << 8) + port_index;
764eaa4710SRishi Srivatsavai
774eaa4710SRishi Srivatsavai iii = 0;
784eaa4710SRishi Srivatsavai this->timers[iii++] = &this->fdWhile;
794eaa4710SRishi Srivatsavai this->timers[iii++] = &this->helloWhen;
804eaa4710SRishi Srivatsavai this->timers[iii++] = &this->mdelayWhile;
814eaa4710SRishi Srivatsavai this->timers[iii++] = &this->rbWhile;
824eaa4710SRishi Srivatsavai this->timers[iii++] = &this->rcvdInfoWhile;
834eaa4710SRishi Srivatsavai this->timers[iii++] = &this->rrWhile;
844eaa4710SRishi Srivatsavai this->timers[iii++] = &this->tcWhile;
854eaa4710SRishi Srivatsavai this->timers[iii++] = &this->txCount;
864eaa4710SRishi Srivatsavai this->timers[iii++] = &this->lnkWhile;
874eaa4710SRishi Srivatsavai
884eaa4710SRishi Srivatsavai /* create and bind port state machines */
894eaa4710SRishi Srivatsavai STP_STATE_MACH_IN_LIST(topoch);
904eaa4710SRishi Srivatsavai
914eaa4710SRishi Srivatsavai STP_STATE_MACH_IN_LIST(migrate);
924eaa4710SRishi Srivatsavai
934eaa4710SRishi Srivatsavai STP_STATE_MACH_IN_LIST(p2p);
944eaa4710SRishi Srivatsavai
954eaa4710SRishi Srivatsavai STP_STATE_MACH_IN_LIST(edge);
96*55fea89dSDan Cross
974eaa4710SRishi Srivatsavai STP_STATE_MACH_IN_LIST(pcost)
984eaa4710SRishi Srivatsavai
994eaa4710SRishi Srivatsavai STP_STATE_MACH_IN_LIST(info);
100*55fea89dSDan Cross
1014eaa4710SRishi Srivatsavai STP_STATE_MACH_IN_LIST(roletrns);
1024eaa4710SRishi Srivatsavai
1034eaa4710SRishi Srivatsavai STP_STATE_MACH_IN_LIST(sttrans);
1044eaa4710SRishi Srivatsavai
1054eaa4710SRishi Srivatsavai STP_STATE_MACH_IN_LIST(transmit);
106*55fea89dSDan Cross
1074eaa4710SRishi Srivatsavai #ifdef STP_DBG
1084eaa4710SRishi Srivatsavai
1094eaa4710SRishi Srivatsavai #if 0
1104eaa4710SRishi Srivatsavai this->roletrns->ignoreHop2State = 14; /* DESIGNATED_PORT; */
1114eaa4710SRishi Srivatsavai this->info->ignoreHop2State = 3; /* CURRENT */
1124eaa4710SRishi Srivatsavai this->transmit->ignoreHop2State = 3; /* IDLE */
1134eaa4710SRishi Srivatsavai this->edge->ignoreHop2State = 0; /* DISABLED; */
1144eaa4710SRishi Srivatsavai #endif
1154eaa4710SRishi Srivatsavai
1164eaa4710SRishi Srivatsavai #if 0
1174eaa4710SRishi Srivatsavai this->info->debug = 1;
1184eaa4710SRishi Srivatsavai this->pcost->debug = 1;
1194eaa4710SRishi Srivatsavai this->p2p->debug = 1;
1204eaa4710SRishi Srivatsavai this->edge->debug = 1;
1214eaa4710SRishi Srivatsavai this->migrate->debug = 1;
1224eaa4710SRishi Srivatsavai this->sttrans->debug = 1;
1234eaa4710SRishi Srivatsavai this->topoch->debug = 1;
1244eaa4710SRishi Srivatsavai this->roletrns->debug = 1;
1254eaa4710SRishi Srivatsavai #endif
1264eaa4710SRishi Srivatsavai this->sttrans->debug = 1;
1274eaa4710SRishi Srivatsavai
1284eaa4710SRishi Srivatsavai #endif
1294eaa4710SRishi Srivatsavai return this;
1304eaa4710SRishi Srivatsavai }
1314eaa4710SRishi Srivatsavai
132*55fea89dSDan Cross void
STP_port_init(PORT_T * this,STPM_T * stpm,Bool check_link)1334eaa4710SRishi Srivatsavai STP_port_init (PORT_T* this, STPM_T* stpm, Bool check_link)
1344eaa4710SRishi Srivatsavai {
1354eaa4710SRishi Srivatsavai if (check_link) {
1364eaa4710SRishi Srivatsavai this->adminEnable = STP_OUT_get_port_link_status (this->port_index);
1374eaa4710SRishi Srivatsavai STP_VECT_create (&this->designPrio,
1384eaa4710SRishi Srivatsavai &stpm->BrId,
1394eaa4710SRishi Srivatsavai 0,
1404eaa4710SRishi Srivatsavai &stpm->BrId,
1414eaa4710SRishi Srivatsavai this->port_id,
1424eaa4710SRishi Srivatsavai this->port_id);
1434eaa4710SRishi Srivatsavai STP_copy_times (&this->designTimes, &stpm->rootTimes);
1444eaa4710SRishi Srivatsavai }
1454eaa4710SRishi Srivatsavai
1464eaa4710SRishi Srivatsavai /* reset timers */
1474eaa4710SRishi Srivatsavai this->fdWhile =
1484eaa4710SRishi Srivatsavai this->helloWhen =
1494eaa4710SRishi Srivatsavai this->mdelayWhile =
1504eaa4710SRishi Srivatsavai this->rbWhile =
1514eaa4710SRishi Srivatsavai this->rcvdInfoWhile =
1524eaa4710SRishi Srivatsavai this->rrWhile =
1534eaa4710SRishi Srivatsavai this->tcWhile =
1544eaa4710SRishi Srivatsavai this->txCount = 0;
1554eaa4710SRishi Srivatsavai
1564eaa4710SRishi Srivatsavai this->msgPortRole = RSTP_PORT_ROLE_UNKN;
1574eaa4710SRishi Srivatsavai this->selectedRole = DisabledPort;
1584eaa4710SRishi Srivatsavai this->sendRSTP = True;
1594eaa4710SRishi Srivatsavai this->operSpeed = STP_OUT_get_port_oper_speed (this->port_index);
1604eaa4710SRishi Srivatsavai this->p2p_recompute = True;
1614eaa4710SRishi Srivatsavai }
1624eaa4710SRishi Srivatsavai
1634eaa4710SRishi Srivatsavai void
STP_port_delete(PORT_T * this)1644eaa4710SRishi Srivatsavai STP_port_delete (PORT_T* this)
1654eaa4710SRishi Srivatsavai {
1664eaa4710SRishi Srivatsavai STPM_T* stpm;
1674eaa4710SRishi Srivatsavai register PORT_T* prev;
1684eaa4710SRishi Srivatsavai register PORT_T* tmp;
1694eaa4710SRishi Srivatsavai register STATE_MACH_T* stater;
1704eaa4710SRishi Srivatsavai register void* pv;
1714eaa4710SRishi Srivatsavai
1724eaa4710SRishi Srivatsavai stpm = this->owner;
1734eaa4710SRishi Srivatsavai
1744eaa4710SRishi Srivatsavai free (this->port_name);
1754eaa4710SRishi Srivatsavai for (stater = this->machines; stater; ) {
1764eaa4710SRishi Srivatsavai pv = (void*) stater->next;
1774eaa4710SRishi Srivatsavai STP_state_mach_delete (stater);
1784eaa4710SRishi Srivatsavai stater = (STATE_MACH_T*) pv;
1794eaa4710SRishi Srivatsavai }
180*55fea89dSDan Cross
1814eaa4710SRishi Srivatsavai prev = NULL;
1824eaa4710SRishi Srivatsavai for (tmp = stpm->ports; tmp; tmp = tmp->next) {
1834eaa4710SRishi Srivatsavai if (tmp->port_index == this->port_index) {
1844eaa4710SRishi Srivatsavai if (prev) {
1854eaa4710SRishi Srivatsavai prev->next = this->next;
1864eaa4710SRishi Srivatsavai } else {
1874eaa4710SRishi Srivatsavai stpm->ports = this->next;
1884eaa4710SRishi Srivatsavai }
1894eaa4710SRishi Srivatsavai STP_FREE(this, "stp instance");
1904eaa4710SRishi Srivatsavai break;
1914eaa4710SRishi Srivatsavai }
1924eaa4710SRishi Srivatsavai prev = tmp;
1934eaa4710SRishi Srivatsavai }
1944eaa4710SRishi Srivatsavai }
1954eaa4710SRishi Srivatsavai
1964eaa4710SRishi Srivatsavai int
STP_port_rx_bpdu(PORT_T * this,BPDU_T * bpdu,size_t len)1974eaa4710SRishi Srivatsavai STP_port_rx_bpdu (PORT_T* this, BPDU_T* bpdu, size_t len)
1984eaa4710SRishi Srivatsavai {
1994eaa4710SRishi Srivatsavai STP_info_rx_bpdu (this, bpdu, len);
2004eaa4710SRishi Srivatsavai
2014eaa4710SRishi Srivatsavai return 0;
2024eaa4710SRishi Srivatsavai }
2034eaa4710SRishi Srivatsavai
2044eaa4710SRishi Srivatsavai #ifdef STP_DBG
STP_port_trace_state_machine(PORT_T * this,char * mach_name,int enadis)2054eaa4710SRishi Srivatsavai int STP_port_trace_state_machine (PORT_T* this, char* mach_name, int enadis)
2064eaa4710SRishi Srivatsavai {
2074eaa4710SRishi Srivatsavai STATE_MACH_T *stater;
2084eaa4710SRishi Srivatsavai int nmatch = 0;
2094eaa4710SRishi Srivatsavai
2104eaa4710SRishi Srivatsavai for (stater = this->machines; stater; stater = stater->next) {
2114eaa4710SRishi Srivatsavai if (! strcmp (mach_name, "all") || ! strcmp (mach_name, stater->name)) {
2124eaa4710SRishi Srivatsavai if (stater->debug != enadis)
2134eaa4710SRishi Srivatsavai {
2144eaa4710SRishi Srivatsavai stp_trace ("port %s on %s trace %-8s (was %s) now %s",
2154eaa4710SRishi Srivatsavai this->port_name, this->owner->name,
2164eaa4710SRishi Srivatsavai stater->name,
2174eaa4710SRishi Srivatsavai stater->debug ? " enabled" :"disabled",
2184eaa4710SRishi Srivatsavai enadis ? " enabled" :"disabled");
2194eaa4710SRishi Srivatsavai }
2204eaa4710SRishi Srivatsavai stater->debug = enadis;
2214eaa4710SRishi Srivatsavai nmatch++;
2224eaa4710SRishi Srivatsavai }
2234eaa4710SRishi Srivatsavai }
2244eaa4710SRishi Srivatsavai
2254eaa4710SRishi Srivatsavai if (nmatch == 0) {
2264eaa4710SRishi Srivatsavai stp_trace("port %s no such state machine as '%s'", this->port_name,
2274eaa4710SRishi Srivatsavai mach_name);
2284eaa4710SRishi Srivatsavai return STP_No_Such_State_Machine;
2294eaa4710SRishi Srivatsavai }
2304eaa4710SRishi Srivatsavai
2314eaa4710SRishi Srivatsavai return 0;
2324eaa4710SRishi Srivatsavai }
2334eaa4710SRishi Srivatsavai
STP_port_trace_flags(char * title,PORT_T * this)2344eaa4710SRishi Srivatsavai void STP_port_trace_flags (char* title, PORT_T* this)
2354eaa4710SRishi Srivatsavai {
2364eaa4710SRishi Srivatsavai unsigned long flag = 0L;
2374eaa4710SRishi Srivatsavai
2384eaa4710SRishi Srivatsavai if (!port_trace_flags) return;
2394eaa4710SRishi Srivatsavai
2404eaa4710SRishi Srivatsavai if (this->reRoot) flag |= 0x000001L;
2414eaa4710SRishi Srivatsavai if (this->sync) flag |= 0x000002L;
2424eaa4710SRishi Srivatsavai if (this->synced) flag |= 0x000004L;
2434eaa4710SRishi Srivatsavai
2444eaa4710SRishi Srivatsavai if (this->proposed) flag |= 0x000010L;
2454eaa4710SRishi Srivatsavai if (this->proposing) flag |= 0x000020L;
2464eaa4710SRishi Srivatsavai if (this->agreed) flag |= 0x000040L;
2474eaa4710SRishi Srivatsavai if (this->updtInfo) flag |= 0x000080L;
2484eaa4710SRishi Srivatsavai
2494eaa4710SRishi Srivatsavai if (this->operEdge) flag |= 0x000100L;
2504eaa4710SRishi Srivatsavai stp_trace (" %-12s: flags=0x%04lx fdWhile=%d port=%s", title, flag, this->fdWhile, this->port_name);
2514eaa4710SRishi Srivatsavai }
2524eaa4710SRishi Srivatsavai
2534eaa4710SRishi Srivatsavai #endif
254