cregit-Linux how code gets into the kernel

Release 4.11 drivers/net/fddi/skfp/cfm.c

/******************************************************************************
 *
 *      (C)Copyright 1998,1999 SysKonnect,
 *      a business unit of Schneider & Koch & Co. Datensysteme GmbH.
 *
 *      See the file "skfddi.c" for further information.
 *
 *      This program is free software; you can redistribute it and/or modify
 *      it under the terms of the GNU General Public License as published by
 *      the Free Software Foundation; either version 2 of the License, or
 *      (at your option) any later version.
 *
 *      The information in this file is provided "AS IS" without warranty.
 *
 ******************************************************************************/

/*
        SMT CFM
        Configuration Management
        DAS with single MAC
*/

/*
 *      Hardware independent state machine implemantation
 *      The following external SMT functions are referenced :
 *
 *              queue_event()
 *
 *      The following external HW dependent functions are referenced :
 *              config_mux()
 *
 *      The following HW dependent events are required :
 *              NONE 
 */

#include "h/types.h"
#include "h/fddi.h"
#include "h/smc.h"


#define KERNEL
#include "h/smtstate.h"

#ifndef	lint

static const char ID_sccs[] = "@(#)cfm.c      2.18 98/10/06 (C) SK " ;
#endif

/*
 * FSM Macros
 */

#define AFLAG	0x10

#define GO_STATE(x)	(smc->mib.fddiSMTCF_State = (x)|AFLAG)

#define ACTIONS_DONE()	(smc->mib.fddiSMTCF_State &= ~AFLAG)

#define ACTIONS(x)	(x|AFLAG)

/*
 * symbolic state names
 */

static const char * const cfm_states[] = {
	"SC0_ISOLATED","CF1","CF2","CF3","CF4",
	"SC1_WRAP_A","SC2_WRAP_B","SC5_TRHU_B","SC7_WRAP_S",
	"SC9_C_WRAP_A","SC10_C_WRAP_B","SC11_C_WRAP_S","SC4_THRU_A"
} ;

/*
 * symbolic event names
 */

static const char * const cfm_events[] = {
	"NONE","CF_LOOP_A","CF_LOOP_B","CF_JOIN_A","CF_JOIN_B"
} ;

/*
 * map from state to downstream port type
 */

static const unsigned char cf_to_ptype[] = {
	TNONE,TNONE,TNONE,TNONE,TNONE,
	TNONE,TB,TB,TS,
	TA,TB,TS,TB
} ;

/*
 * CEM port states
 */

#define	CEM_PST_DOWN	0

#define	CEM_PST_UP	1

#define	CEM_PST_HOLD	2
/* define portstate array only for A and B port */
/* Do this within the smc structure (use in multiple cards) */

/*
 * all Globals  are defined in smc.h
 * struct s_cfm
 */

/*
 * function declarations
 */
static void cfm_fsm(struct s_smc *smc, int cmd);

/*
        init CFM state machine
        clear all CFM vars and flags
*/

void cfm_init(struct s_smc *smc) { smc->mib.fddiSMTCF_State = ACTIONS(SC0_ISOLATED) ; smc->r.rm_join = 0 ; smc->r.rm_loop = 0 ; smc->y[PA].scrub = 0 ; smc->y[PB].scrub = 0 ; smc->y[PA].cem_pst = CEM_PST_DOWN ; smc->y[PB].cem_pst = CEM_PST_DOWN ; }

Contributors

PersonTokensPropCommitsCommitProp
Linus Torvalds (pre-git)8098.77%150.00%
Stephen Hemminger11.23%150.00%
Total81100.00%2100.00%

/* Some terms conditions used by the selection criteria */ #define THRU_ENABLED(smc) (smc->y[PA].pc_mode != PM_TREE && \ smc->y[PB].pc_mode != PM_TREE) /* Selection criteria for the ports */
static void selection_criteria (struct s_smc *smc, struct s_phy *phy) { switch (phy->mib->fddiPORTMy_Type) { case TA: if ( !THRU_ENABLED(smc) && smc->y[PB].cf_join ) { phy->wc_flag = TRUE ; } else { phy->wc_flag = FALSE ; } break; case TB: /* take precedence over PA */ phy->wc_flag = FALSE ; break; case TS: phy->wc_flag = FALSE ; break; case TM: phy->wc_flag = FALSE ; break; } }

Contributors

PersonTokensPropCommitsCommitProp
Linus Torvalds (pre-git)9397.89%150.00%
Stephen Hemminger22.11%150.00%
Total95100.00%2100.00%


void all_selection_criteria(struct s_smc *smc) { struct s_phy *phy ; int p ; for ( p = 0,phy = smc->y ; p < NUMPHYS; p++, phy++ ) { /* Do the selection criteria */ selection_criteria (smc,phy); } }

Contributors

PersonTokensPropCommitsCommitProp
Linus Torvalds (pre-git)4998.00%150.00%
Stephen Hemminger12.00%150.00%
Total50100.00%2100.00%


static void cem_priv_state(struct s_smc *smc, int event) /* State machine for private PORT states: used to optimize dual homing */ { int np; /* Number of the port */ int i; /* Do this only in a DAS */ if (smc->s.sas != SMT_DAS ) return ; np = event - CF_JOIN; if (np != PA && np != PB) { return ; } /* Change the port state according to the event (portnumber) */ if (smc->y[np].cf_join) { smc->y[np].cem_pst = CEM_PST_UP ; } else if (!smc->y[np].wc_flag) { /* set the port to done only if it is not withheld */ smc->y[np].cem_pst = CEM_PST_DOWN ; } /* Don't set an hold port to down */ /* Check all ports of restart conditions */ for (i = 0 ; i < 2 ; i ++ ) { /* Check all port for PORT is on hold and no withhold is done */ if ( smc->y[i].cem_pst == CEM_PST_HOLD && !smc->y[i].wc_flag ) { smc->y[i].cem_pst = CEM_PST_DOWN; queue_event(smc,(int)(EVENT_PCM+i),PC_START) ; } if ( smc->y[i].cem_pst == CEM_PST_UP && smc->y[i].wc_flag ) { smc->y[i].cem_pst = CEM_PST_HOLD; queue_event(smc,(int)(EVENT_PCM+i),PC_START) ; } if ( smc->y[i].cem_pst == CEM_PST_DOWN && smc->y[i].wc_flag ) { /* * The port must be restarted when the wc_flag * will be reset. So set the port on hold. */ smc->y[i].cem_pst = CEM_PST_HOLD; } } return ; }

Contributors

PersonTokensPropCommitsCommitProp
Linus Torvalds (pre-git)26199.24%150.00%
Stephen Hemminger20.76%150.00%
Total263100.00%2100.00%

/* CFM state machine called by dispatcher do display state change process event until SM is stable */
void cfm(struct s_smc *smc, int event) { int state ; /* remember last state */ int cond ; int oldstate ; /* We will do the following: */ /* - compute the variable WC_Flag for every port (This is where */ /* we can extend the requested path checking !!) */ /* - do the old (SMT 6.2 like) state machine */ /* - do the resulting station states */ all_selection_criteria (smc); /* We will check now whether a state transition is allowed or not */ /* - change the portstates */ cem_priv_state (smc, event); oldstate = smc->mib.fddiSMTCF_State ; do { DB_CFM("CFM : state %s%s event %s", smc->mib.fddiSMTCF_State & AFLAG ? "ACTIONS " : "", cfm_states[smc->mib.fddiSMTCF_State & ~AFLAG], cfm_events[event]); state = smc->mib.fddiSMTCF_State ; cfm_fsm(smc,event) ; event = 0 ; } while (state != smc->mib.fddiSMTCF_State) ; #ifndef SLIM_SMT /* * check peer wrap condition */ cond = FALSE ; if ( (smc->mib.fddiSMTCF_State == SC9_C_WRAP_A && smc->y[PA].pc_mode == PM_PEER) || (smc->mib.fddiSMTCF_State == SC10_C_WRAP_B && smc->y[PB].pc_mode == PM_PEER) || (smc->mib.fddiSMTCF_State == SC11_C_WRAP_S && smc->y[PS].pc_mode == PM_PEER && smc->y[PS].mib->fddiPORTNeighborType != TS ) ) { cond = TRUE ; } if (cond != smc->mib.fddiSMTPeerWrapFlag) smt_srf_event(smc,SMT_COND_SMT_PEER_WRAP,0,cond) ; #if 0 /* * Don't send ever MAC_PATH_CHANGE events. Our MAC is hard-wired * to the primary path. */ /* * path change */ if (smc->mib.fddiSMTCF_State != oldstate) { smt_srf_event(smc,SMT_EVENT_MAC_PATH_CHANGE,INDEX_MAC,0) ; } #endif #endif /* no SLIM_SMT */ /* * set MAC port type */ smc->mib.m[MAC0].fddiMACDownstreamPORTType = cf_to_ptype[smc->mib.fddiSMTCF_State] ; cfm_state_change(smc,(int)smc->mib.fddiSMTCF_State) ; }

Contributors

PersonTokensPropCommitsCommitProp
Linus Torvalds (pre-git)27398.91%133.33%
Stephen Hemminger20.72%133.33%
Joe Perches10.36%133.33%
Total276100.00%3100.00%

/* process CFM event */ /*ARGSUSED1*/
static void cfm_fsm(struct s_smc *smc, int cmd) { switch(smc->mib.fddiSMTCF_State) { case ACTIONS(SC0_ISOLATED) : smc->mib.p[PA].fddiPORTCurrentPath = MIB_PATH_ISOLATED ; smc->mib.p[PB].fddiPORTCurrentPath = MIB_PATH_ISOLATED ; smc->mib.p[PA].fddiPORTMACPlacement = 0 ; smc->mib.p[PB].fddiPORTMACPlacement = 0 ; smc->mib.fddiSMTStationStatus = MIB_SMT_STASTA_SEPA ; config_mux(smc,MUX_ISOLATE) ; /* configure PHY Mux */ smc->r.rm_loop = FALSE ; smc->r.rm_join = FALSE ; queue_event(smc,EVENT_RMT,RM_JOIN) ;/* signal RMT */ /* Don't do the WC-Flag changing here */ ACTIONS_DONE() ; DB_CFMN(1, "CFM : %s", cfm_states[smc->mib.fddiSMTCF_State]); break; case SC0_ISOLATED : /*SC07*/ /*SAS port can be PA or PB ! */ if (smc->s.sas && (smc->y[PA].cf_join || smc->y[PA].cf_loop || smc->y[PB].cf_join || smc->y[PB].cf_loop)) { GO_STATE(SC11_C_WRAP_S) ; break ; } /*SC01*/ if ((smc->y[PA].cem_pst == CEM_PST_UP && smc->y[PA].cf_join && !smc->y[PA].wc_flag) || smc->y[PA].cf_loop) { GO_STATE(SC9_C_WRAP_A) ; break ; } /*SC02*/ if ((smc->y[PB].cem_pst == CEM_PST_UP && smc->y[PB].cf_join && !smc->y[PB].wc_flag) || smc->y[PB].cf_loop) { GO_STATE(SC10_C_WRAP_B) ; break ; } break ; case ACTIONS(SC9_C_WRAP_A) : smc->mib.p[PA].fddiPORTCurrentPath = MIB_PATH_CONCATENATED ; smc->mib.p[PB].fddiPORTCurrentPath = MIB_PATH_ISOLATED ; smc->mib.p[PA].fddiPORTMACPlacement = INDEX_MAC ; smc->mib.p[PB].fddiPORTMACPlacement = 0 ; smc->mib.fddiSMTStationStatus = MIB_SMT_STASTA_CON ; config_mux(smc,MUX_WRAPA) ; /* configure PHY mux */ if (smc->y[PA].cf_loop) { smc->r.rm_join = FALSE ; smc->r.rm_loop = TRUE ; queue_event(smc,EVENT_RMT,RM_LOOP) ;/* signal RMT */ } if (smc->y[PA].cf_join) { smc->r.rm_loop = FALSE ; smc->r.rm_join = TRUE ; queue_event(smc,EVENT_RMT,RM_JOIN) ;/* signal RMT */ } ACTIONS_DONE() ; DB_CFMN(1, "CFM : %s", cfm_states[smc->mib.fddiSMTCF_State]); break ; case SC9_C_WRAP_A : /*SC10*/ if ( (smc->y[PA].wc_flag || !smc->y[PA].cf_join) && !smc->y[PA].cf_loop ) { GO_STATE(SC0_ISOLATED) ; break ; } /*SC12*/ else if ( (smc->y[PB].cf_loop && smc->y[PA].cf_join && smc->y[PA].cem_pst == CEM_PST_UP) || ((smc->y[PB].cf_loop || (smc->y[PB].cf_join && smc->y[PB].cem_pst == CEM_PST_UP)) && (smc->y[PA].pc_mode == PM_TREE || smc->y[PB].pc_mode == PM_TREE))) { smc->y[PA].scrub = TRUE ; GO_STATE(SC10_C_WRAP_B) ; break ; } /*SC14*/ else if (!smc->s.attach_s && smc->y[PA].cf_join && smc->y[PA].cem_pst == CEM_PST_UP && smc->y[PA].pc_mode == PM_PEER && smc->y[PB].cf_join && smc->y[PB].cem_pst == CEM_PST_UP && smc->y[PB].pc_mode == PM_PEER) { smc->y[PA].scrub = TRUE ; smc->y[PB].scrub = TRUE ; GO_STATE(SC4_THRU_A) ; break ; } /*SC15*/ else if ( smc->s.attach_s && smc->y[PA].cf_join && smc->y[PA].cem_pst == CEM_PST_UP && smc->y[PA].pc_mode == PM_PEER && smc->y[PB].cf_join && smc->y[PB].cem_pst == CEM_PST_UP && smc->y[PB].pc_mode == PM_PEER) { smc->y[PA].scrub = TRUE ; smc->y[PB].scrub = TRUE ; GO_STATE(SC5_THRU_B) ; break ; } break ; case ACTIONS(SC10_C_WRAP_B) : smc->mib.p[PA].fddiPORTCurrentPath = MIB_PATH_ISOLATED ; smc->mib.p[PB].fddiPORTCurrentPath = MIB_PATH_CONCATENATED ; smc->mib.p[PA].fddiPORTMACPlacement = 0 ; smc->mib.p[PB].fddiPORTMACPlacement = INDEX_MAC ; smc->mib.fddiSMTStationStatus = MIB_SMT_STASTA_CON ; config_mux(smc,MUX_WRAPB) ; /* configure PHY mux */ if (smc->y[PB].cf_loop) { smc->r.rm_join = FALSE ; smc->r.rm_loop = TRUE ; queue_event(smc,EVENT_RMT,RM_LOOP) ;/* signal RMT */ } if (smc->y[PB].cf_join) { smc->r.rm_loop = FALSE ; smc->r.rm_join = TRUE ; queue_event(smc,EVENT_RMT,RM_JOIN) ;/* signal RMT */ } ACTIONS_DONE() ; DB_CFMN(1, "CFM : %s", cfm_states[smc->mib.fddiSMTCF_State]); break ; case SC10_C_WRAP_B : /*SC20*/ if ( !smc->y[PB].cf_join && !smc->y[PB].cf_loop ) { GO_STATE(SC0_ISOLATED) ; break ; } /*SC21*/ else if ( smc->y[PA].cf_loop && smc->y[PA].pc_mode == PM_PEER && smc->y[PB].cf_join && smc->y[PB].pc_mode == PM_PEER) { smc->y[PB].scrub = TRUE ; GO_STATE(SC9_C_WRAP_A) ; break ; } /*SC24*/ else if (!smc->s.attach_s && smc->y[PA].cf_join && smc->y[PA].pc_mode == PM_PEER && smc->y[PB].cf_join && smc->y[PB].pc_mode == PM_PEER) { smc->y[PA].scrub = TRUE ; smc->y[PB].scrub = TRUE ; GO_STATE(SC4_THRU_A) ; break ; } /*SC25*/ else if ( smc->s.attach_s && smc->y[PA].cf_join && smc->y[PA].pc_mode == PM_PEER && smc->y[PB].cf_join && smc->y[PB].pc_mode == PM_PEER) { smc->y[PA].scrub = TRUE ; smc->y[PB].scrub = TRUE ; GO_STATE(SC5_THRU_B) ; break ; } break ; case ACTIONS(SC4_THRU_A) : smc->mib.p[PA].fddiPORTCurrentPath = MIB_PATH_THRU ; smc->mib.p[PB].fddiPORTCurrentPath = MIB_PATH_THRU ; smc->mib.p[PA].fddiPORTMACPlacement = 0 ; smc->mib.p[PB].fddiPORTMACPlacement = INDEX_MAC ; smc->mib.fddiSMTStationStatus = MIB_SMT_STASTA_THRU ; config_mux(smc,MUX_THRUA) ; /* configure PHY mux */ smc->r.rm_loop = FALSE ; smc->r.rm_join = TRUE ; queue_event(smc,EVENT_RMT,RM_JOIN) ;/* signal RMT */ ACTIONS_DONE() ; DB_CFMN(1, "CFM : %s", cfm_states[smc->mib.fddiSMTCF_State]); break ; case SC4_THRU_A : /*SC41*/ if (smc->y[PB].wc_flag || !smc->y[PB].cf_join) { smc->y[PA].scrub = TRUE ; GO_STATE(SC9_C_WRAP_A) ; break ; } /*SC42*/ else if (!smc->y[PA].cf_join || smc->y[PA].wc_flag) { smc->y[PB].scrub = TRUE ; GO_STATE(SC10_C_WRAP_B) ; break ; } /*SC45*/ else if (smc->s.attach_s) { smc->y[PB].scrub = TRUE ; GO_STATE(SC5_THRU_B) ; break ; } break ; case ACTIONS(SC5_THRU_B) : smc->mib.p[PA].fddiPORTCurrentPath = MIB_PATH_THRU ; smc->mib.p[PB].fddiPORTCurrentPath = MIB_PATH_THRU ; smc->mib.p[PA].fddiPORTMACPlacement = INDEX_MAC ; smc->mib.p[PB].fddiPORTMACPlacement = 0 ; smc->mib.fddiSMTStationStatus = MIB_SMT_STASTA_THRU ; config_mux(smc,MUX_THRUB) ; /* configure PHY mux */ smc->r.rm_loop = FALSE ; smc->r.rm_join = TRUE ; queue_event(smc,EVENT_RMT,RM_JOIN) ;/* signal RMT */ ACTIONS_DONE() ; DB_CFMN(1, "CFM : %s", cfm_states[smc->mib.fddiSMTCF_State]); break ; case SC5_THRU_B : /*SC51*/ if (!smc->y[PB].cf_join || smc->y[PB].wc_flag) { smc->y[PA].scrub = TRUE ; GO_STATE(SC9_C_WRAP_A) ; break ; } /*SC52*/ else if (!smc->y[PA].cf_join || smc->y[PA].wc_flag) { smc->y[PB].scrub = TRUE ; GO_STATE(SC10_C_WRAP_B) ; break ; } /*SC54*/ else if (!smc->s.attach_s) { smc->y[PA].scrub = TRUE ; GO_STATE(SC4_THRU_A) ; break ; } break ; case ACTIONS(SC11_C_WRAP_S) : smc->mib.p[PS].fddiPORTCurrentPath = MIB_PATH_CONCATENATED ; smc->mib.p[PS].fddiPORTMACPlacement = INDEX_MAC ; smc->mib.fddiSMTStationStatus = MIB_SMT_STASTA_CON ; config_mux(smc,MUX_WRAPS) ; /* configure PHY mux */ if (smc->y[PA].cf_loop || smc->y[PB].cf_loop) { smc->r.rm_join = FALSE ; smc->r.rm_loop = TRUE ; queue_event(smc,EVENT_RMT,RM_LOOP) ;/* signal RMT */ } if (smc->y[PA].cf_join || smc->y[PB].cf_join) { smc->r.rm_loop = FALSE ; smc->r.rm_join = TRUE ; queue_event(smc,EVENT_RMT,RM_JOIN) ;/* signal RMT */ } ACTIONS_DONE() ; DB_CFMN(1, "CFM : %s", cfm_states[smc->mib.fddiSMTCF_State]); break ; case SC11_C_WRAP_S : /*SC70*/ if ( !smc->y[PA].cf_join && !smc->y[PA].cf_loop && !smc->y[PB].cf_join && !smc->y[PB].cf_loop) { GO_STATE(SC0_ISOLATED) ; break ; } break ; default: SMT_PANIC(smc,SMT_E0106, SMT_E0106_MSG) ; break; } }

Contributors

PersonTokensPropCommitsCommitProp
Linus Torvalds (pre-git)197199.60%133.33%
Joe Perches60.30%133.33%
Stephen Hemminger20.10%133.33%
Total1979100.00%3100.00%

/* * get MAC's input Port * return : * PA or PB */
int cfm_get_mac_input(struct s_smc *smc) { return (smc->mib.fddiSMTCF_State == SC10_C_WRAP_B || smc->mib.fddiSMTCF_State == SC5_THRU_B) ? PB : PA; }

Contributors

PersonTokensPropCommitsCommitProp
Linus Torvalds (pre-git)3296.97%150.00%
Stephen Hemminger13.03%150.00%
Total33100.00%2100.00%

/* * get MAC's output Port * return : * PA or PB */
int cfm_get_mac_output(struct s_smc *smc) { return (smc->mib.fddiSMTCF_State == SC10_C_WRAP_B || smc->mib.fddiSMTCF_State == SC4_THRU_A) ? PB : PA; }

Contributors

PersonTokensPropCommitsCommitProp
Linus Torvalds (pre-git)3296.97%150.00%
Stephen Hemminger13.03%150.00%
Total33100.00%2100.00%

static char path_iso[] = { 0,0, 0,RES_PORT, 0,PA + INDEX_PORT, 0,PATH_ISO, 0,0, 0,RES_MAC, 0,INDEX_MAC, 0,PATH_ISO, 0,0, 0,RES_PORT, 0,PB + INDEX_PORT, 0,PATH_ISO } ; static char path_wrap_a[] = { 0,0, 0,RES_PORT, 0,PA + INDEX_PORT, 0,PATH_PRIM, 0,0, 0,RES_MAC, 0,INDEX_MAC, 0,PATH_PRIM, 0,0, 0,RES_PORT, 0,PB + INDEX_PORT, 0,PATH_ISO } ; static char path_wrap_b[] = { 0,0, 0,RES_PORT, 0,PB + INDEX_PORT, 0,PATH_PRIM, 0,0, 0,RES_MAC, 0,INDEX_MAC, 0,PATH_PRIM, 0,0, 0,RES_PORT, 0,PA + INDEX_PORT, 0,PATH_ISO } ; static char path_thru[] = { 0,0, 0,RES_PORT, 0,PA + INDEX_PORT, 0,PATH_PRIM, 0,0, 0,RES_MAC, 0,INDEX_MAC, 0,PATH_PRIM, 0,0, 0,RES_PORT, 0,PB + INDEX_PORT, 0,PATH_PRIM } ; static char path_wrap_s[] = { 0,0, 0,RES_PORT, 0,PS + INDEX_PORT, 0,PATH_PRIM, 0,0, 0,RES_MAC, 0,INDEX_MAC, 0,PATH_PRIM, } ; static char path_iso_s[] = { 0,0, 0,RES_PORT, 0,PS + INDEX_PORT, 0,PATH_ISO, 0,0, 0,RES_MAC, 0,INDEX_MAC, 0,PATH_ISO, } ;
int cem_build_path(struct s_smc *smc, char *to, int path_index) { char *path ; int len ; switch (smc->mib.fddiSMTCF_State) { default : case SC0_ISOLATED : path = smc->s.sas ? path_iso_s : path_iso ; len = smc->s.sas ? sizeof(path_iso_s) : sizeof(path_iso) ; break ; case SC9_C_WRAP_A : path = path_wrap_a ; len = sizeof(path_wrap_a) ; break ; case SC10_C_WRAP_B : path = path_wrap_b ; len = sizeof(path_wrap_b) ; break ; case SC4_THRU_A : path = path_thru ; len = sizeof(path_thru) ; break ; case SC11_C_WRAP_S : path = path_wrap_s ; len = sizeof(path_wrap_s) ; break ; } memcpy(to,path,len) ; LINT_USE(path_index); return len; }

Contributors

PersonTokensPropCommitsCommitProp
Linus Torvalds (pre-git)14397.95%150.00%
Stephen Hemminger32.05%150.00%
Total146100.00%2100.00%


Overall Contributors

PersonTokensPropCommitsCommitProp
Linus Torvalds (pre-git)343499.02%120.00%
Stephen Hemminger240.69%120.00%
Joe Perches70.20%120.00%
Alan Cox20.06%120.00%
Steven Cole10.03%120.00%
Total3468100.00%5100.00%
Information contained on this website is for historical information purposes only and does not indicate or represent copyright ownership.
Created with cregit.