1da177e4c3
Initial git repository build. I'm not bothering with the full history, even though we have it. We can create a separate "historical" git archive of that later if we want to, and in the meantime it's about 3.2GB when imported into git - space that would just make the early git days unnecessarily complicated, when we don't have a lot of good infrastructure for it. Let it rip!
173 lines
4 KiB
C
173 lines
4 KiB
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 Event Queue Management
|
|
*/
|
|
|
|
#include "h/types.h"
|
|
#include "h/fddi.h"
|
|
#include "h/smc.h"
|
|
|
|
#ifndef lint
|
|
static const char ID_sccs[] = "@(#)queue.c 2.9 97/08/04 (C) SK " ;
|
|
#endif
|
|
|
|
#define PRINTF(a,b,c)
|
|
|
|
/*
|
|
* init event queue management
|
|
*/
|
|
void ev_init(struct s_smc *smc)
|
|
{
|
|
smc->q.ev_put = smc->q.ev_get = smc->q.ev_queue ;
|
|
}
|
|
|
|
/*
|
|
* add event to queue
|
|
*/
|
|
void queue_event(struct s_smc *smc, int class, int event)
|
|
{
|
|
PRINTF("queue class %d event %d\n",class,event) ;
|
|
smc->q.ev_put->class = class ;
|
|
smc->q.ev_put->event = event ;
|
|
if (++smc->q.ev_put == &smc->q.ev_queue[MAX_EVENT])
|
|
smc->q.ev_put = smc->q.ev_queue ;
|
|
|
|
if (smc->q.ev_put == smc->q.ev_get) {
|
|
SMT_ERR_LOG(smc,SMT_E0137, SMT_E0137_MSG) ;
|
|
}
|
|
}
|
|
|
|
/*
|
|
* timer_event is called from HW timer package.
|
|
*/
|
|
void timer_event(struct s_smc *smc, u_long token)
|
|
{
|
|
PRINTF("timer event class %d token %d\n",
|
|
EV_T_CLASS(token),
|
|
EV_T_EVENT(token)) ;
|
|
queue_event(smc,EV_T_CLASS(token),EV_T_EVENT(token));
|
|
}
|
|
|
|
/*
|
|
* event dispatcher
|
|
* while event queue is not empty
|
|
* get event from queue
|
|
* send command to state machine
|
|
* end
|
|
*/
|
|
void ev_dispatcher(struct s_smc *smc)
|
|
{
|
|
struct event_queue *ev ; /* pointer into queue */
|
|
int class ;
|
|
|
|
ev = smc->q.ev_get ;
|
|
PRINTF("dispatch get %x put %x\n",ev,smc->q.ev_put) ;
|
|
while (ev != smc->q.ev_put) {
|
|
PRINTF("dispatch class %d event %d\n",ev->class,ev->event) ;
|
|
switch(class = ev->class) {
|
|
case EVENT_ECM : /* Entity Corordination Man. */
|
|
ecm(smc,(int)ev->event) ;
|
|
break ;
|
|
case EVENT_CFM : /* Configuration Man. */
|
|
cfm(smc,(int)ev->event) ;
|
|
break ;
|
|
case EVENT_RMT : /* Ring Man. */
|
|
rmt(smc,(int)ev->event) ;
|
|
break ;
|
|
case EVENT_SMT :
|
|
smt_event(smc,(int)ev->event) ;
|
|
break ;
|
|
#ifdef CONCENTRATOR
|
|
case 99 :
|
|
timer_test_event(smc,(int)ev->event) ;
|
|
break ;
|
|
#endif
|
|
case EVENT_PCMA : /* PHY A */
|
|
case EVENT_PCMB : /* PHY B */
|
|
default :
|
|
if (class >= EVENT_PCMA &&
|
|
class < EVENT_PCMA + NUMPHYS) {
|
|
pcm(smc,class - EVENT_PCMA,(int)ev->event) ;
|
|
break ;
|
|
}
|
|
SMT_PANIC(smc,SMT_E0121, SMT_E0121_MSG) ;
|
|
return ;
|
|
}
|
|
|
|
if (++ev == &smc->q.ev_queue[MAX_EVENT])
|
|
ev = smc->q.ev_queue ;
|
|
|
|
/* Renew get: it is used in queue_events to detect overruns */
|
|
smc->q.ev_get = ev;
|
|
}
|
|
}
|
|
|
|
/*
|
|
* smt_online connects to or disconnects from the ring
|
|
* MUST be called to initiate connection establishment
|
|
*
|
|
* on 0 disconnect
|
|
* on 1 connect
|
|
*/
|
|
u_short smt_online(struct s_smc *smc, int on)
|
|
{
|
|
queue_event(smc,EVENT_ECM,on ? EC_CONNECT : EC_DISCONNECT) ;
|
|
ev_dispatcher(smc) ;
|
|
return(smc->mib.fddiSMTCF_State) ;
|
|
}
|
|
|
|
/*
|
|
* set SMT flag to value
|
|
* flag flag name
|
|
* value flag value
|
|
* dump current flag setting
|
|
*/
|
|
#ifdef CONCENTRATOR
|
|
void do_smt_flag(struct s_smc *smc, char *flag, int value)
|
|
{
|
|
#ifdef DEBUG
|
|
struct smt_debug *deb;
|
|
|
|
SK_UNUSED(smc) ;
|
|
|
|
#ifdef DEBUG_BRD
|
|
deb = &smc->debug;
|
|
#else
|
|
deb = &debug;
|
|
#endif
|
|
if (!strcmp(flag,"smt"))
|
|
deb->d_smt = value ;
|
|
else if (!strcmp(flag,"smtf"))
|
|
deb->d_smtf = value ;
|
|
else if (!strcmp(flag,"pcm"))
|
|
deb->d_pcm = value ;
|
|
else if (!strcmp(flag,"rmt"))
|
|
deb->d_rmt = value ;
|
|
else if (!strcmp(flag,"cfm"))
|
|
deb->d_cfm = value ;
|
|
else if (!strcmp(flag,"ecm"))
|
|
deb->d_ecm = value ;
|
|
printf("smt %d\n",deb->d_smt) ;
|
|
printf("smtf %d\n",deb->d_smtf) ;
|
|
printf("pcm %d\n",deb->d_pcm) ;
|
|
printf("rmt %d\n",deb->d_rmt) ;
|
|
printf("cfm %d\n",deb->d_cfm) ;
|
|
printf("ecm %d\n",deb->d_ecm) ;
|
|
#endif /* DEBUG */
|
|
}
|
|
#endif
|