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