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
26 static 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  */
ev_init(struct s_smc * smc)34 void 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  */
queue_event(struct s_smc * smc,int class,int event)42 void 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  */
timer_event(struct s_smc * smc,u_long token)58 void 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  */
ev_dispatcher(struct s_smc * smc)73 void 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  */
smt_online(struct s_smc * smc,int on)127 u_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
do_smt_flag(struct s_smc * smc,char * flag,int value)141 void 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