1/****************************************************************************** 2 * 3 * (C)Copyright 1998,1999 SysKonnect, 4 * a business unit of Schneider & Koch & Co. Datensysteme GmbH. 5 * 6 * See the file "skfddi.c" for further information. 7 * 8 * This program is free software; you can redistribute it and/or modify 9 * it under the terms of the GNU General Public License as published by 10 * the Free Software Foundation; either version 2 of the License, or 11 * (at your option) any later version. 12 * 13 * The information in this file is provided "AS IS" without warranty. 14 * 15 ******************************************************************************/ 16 17/* 18 SMT Event Queue Management 19*/ 20 21#include "h/types.h" 22#include "h/fddi.h" 23#include "h/smc.h" 24 25#ifndef lint 26static const char ID_sccs[] = "@(#)queue.c 2.9 97/08/04 (C) SK " ; 27#endif 28 29#define PRINTF(a,b,c) 30 31/* 32 * init event queue management 33 */ 34void ev_init(struct s_smc *smc) 35{ 36 smc->q.ev_put = smc->q.ev_get = smc->q.ev_queue ; 37} 38 39/* 40 * add event to queue 41 */ 42void queue_event(struct s_smc *smc, int class, int event) 43{ 44 PRINTF("queue class %d event %d\n",class,event) ; 45 smc->q.ev_put->class = class ; 46 smc->q.ev_put->event = event ; 47 if (++smc->q.ev_put == &smc->q.ev_queue[MAX_EVENT]) 48 smc->q.ev_put = smc->q.ev_queue ; 49 50 if (smc->q.ev_put == smc->q.ev_get) { 51 SMT_ERR_LOG(smc,SMT_E0137, SMT_E0137_MSG) ; 52 } 53} 54 55/* 56 * timer_event is called from HW timer package. 57 */ 58void timer_event(struct s_smc *smc, u_long token) 59{ 60 PRINTF("timer event class %d token %d\n", 61 EV_T_CLASS(token), 62 EV_T_EVENT(token)) ; 63 queue_event(smc,EV_T_CLASS(token),EV_T_EVENT(token)); 64} 65 66/* 67 * event dispatcher 68 * while event queue is not empty 69 * get event from queue 70 * send command to state machine 71 * end 72 */ 73void ev_dispatcher(struct s_smc *smc) 74{ 75 struct event_queue *ev ; /* pointer into queue */ 76 int class ; 77 78 ev = smc->q.ev_get ; 79 PRINTF("dispatch get %x put %x\n",ev,smc->q.ev_put) ; 80 while (ev != smc->q.ev_put) { 81 PRINTF("dispatch class %d event %d\n",ev->class,ev->event) ; 82 switch(class = ev->class) { 83 case EVENT_ECM : /* Entity Corordination Man. */ 84 ecm(smc,(int)ev->event) ; 85 break ; 86 case EVENT_CFM : /* Configuration Man. */ 87 cfm(smc,(int)ev->event) ; 88 break ; 89 case EVENT_RMT : /* Ring Man. */ 90 rmt(smc,(int)ev->event) ; 91 break ; 92 case EVENT_SMT : 93 smt_event(smc,(int)ev->event) ; 94 break ; 95#ifdef CONCENTRATOR 96 case 99 : 97 timer_test_event(smc,(int)ev->event) ; 98 break ; 99#endif 100 case EVENT_PCMA : /* PHY A */ 101 case EVENT_PCMB : /* PHY B */ 102 default : 103 if (class >= EVENT_PCMA && 104 class < EVENT_PCMA + NUMPHYS) { 105 pcm(smc,class - EVENT_PCMA,(int)ev->event) ; 106 break ; 107 } 108 SMT_PANIC(smc,SMT_E0121, SMT_E0121_MSG) ; 109 return ; 110 } 111 112 if (++ev == &smc->q.ev_queue[MAX_EVENT]) 113 ev = smc->q.ev_queue ; 114 115 /* Renew get: it is used in queue_events to detect overruns */ 116 smc->q.ev_get = ev; 117 } 118} 119 120/* 121 * smt_online connects to or disconnects from the ring 122 * MUST be called to initiate connection establishment 123 * 124 * on 0 disconnect 125 * on 1 connect 126 */ 127u_short smt_online(struct s_smc *smc, int on) 128{ 129 queue_event(smc,EVENT_ECM,on ? EC_CONNECT : EC_DISCONNECT) ; 130 ev_dispatcher(smc) ; 131 return smc->mib.fddiSMTCF_State; 132} 133 134/* 135 * set SMT flag to value 136 * flag flag name 137 * value flag value 138 * dump current flag setting 139 */ 140#ifdef CONCENTRATOR 141void do_smt_flag(struct s_smc *smc, char *flag, int value) 142{ 143#ifdef DEBUG 144 struct smt_debug *deb; 145 146 SK_UNUSED(smc) ; 147 148#ifdef DEBUG_BRD 149 deb = &smc->debug; 150#else 151 deb = &debug; 152#endif 153 if (!strcmp(flag,"smt")) 154 deb->d_smt = value ; 155 else if (!strcmp(flag,"smtf")) 156 deb->d_smtf = value ; 157 else if (!strcmp(flag,"pcm")) 158 deb->d_pcm = value ; 159 else if (!strcmp(flag,"rmt")) 160 deb->d_rmt = value ; 161 else if (!strcmp(flag,"cfm")) 162 deb->d_cfm = value ; 163 else if (!strcmp(flag,"ecm")) 164 deb->d_ecm = value ; 165 printf("smt %d\n",deb->d_smt) ; 166 printf("smtf %d\n",deb->d_smtf) ; 167 printf("pcm %d\n",deb->d_pcm) ; 168 printf("rmt %d\n",deb->d_rmt) ; 169 printf("cfm %d\n",deb->d_cfm) ; 170 printf("ecm %d\n",deb->d_ecm) ; 171#endif /* DEBUG */ 172} 173#endif 174