This source file includes following definitions.
- cfm_init
- selection_criteria
- all_selection_criteria
- cem_priv_state
- cfm
- cfm_fsm
- cfm_get_mac_input
- cfm_get_mac_output
- cem_build_path
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32 #include "h/types.h"
33 #include "h/fddi.h"
34 #include "h/smc.h"
35
36 #define KERNEL
37 #include "h/smtstate.h"
38
39 #ifndef lint
40 static const char ID_sccs[] = "@(#)cfm.c 2.18 98/10/06 (C) SK " ;
41 #endif
42
43
44
45
46 #define AFLAG 0x10
47 #define GO_STATE(x) (smc->mib.fddiSMTCF_State = (x)|AFLAG)
48 #define ACTIONS_DONE() (smc->mib.fddiSMTCF_State &= ~AFLAG)
49 #define ACTIONS(x) (x|AFLAG)
50
51
52
53
54 static const char * const cfm_states[] = {
55 "SC0_ISOLATED","CF1","CF2","CF3","CF4",
56 "SC1_WRAP_A","SC2_WRAP_B","SC5_TRHU_B","SC7_WRAP_S",
57 "SC9_C_WRAP_A","SC10_C_WRAP_B","SC11_C_WRAP_S","SC4_THRU_A"
58 } ;
59
60
61
62
63 static const char * const cfm_events[] = {
64 "NONE","CF_LOOP_A","CF_LOOP_B","CF_JOIN_A","CF_JOIN_B"
65 } ;
66
67
68
69
70 static const unsigned char cf_to_ptype[] = {
71 TNONE,TNONE,TNONE,TNONE,TNONE,
72 TNONE,TB,TB,TS,
73 TA,TB,TS,TB
74 } ;
75
76
77
78
79 #define CEM_PST_DOWN 0
80 #define CEM_PST_UP 1
81 #define CEM_PST_HOLD 2
82
83
84
85
86
87
88
89
90
91
92
93 static void cfm_fsm(struct s_smc *smc, int cmd);
94
95
96
97
98
99 void cfm_init(struct s_smc *smc)
100 {
101 smc->mib.fddiSMTCF_State = ACTIONS(SC0_ISOLATED) ;
102 smc->r.rm_join = 0 ;
103 smc->r.rm_loop = 0 ;
104 smc->y[PA].scrub = 0 ;
105 smc->y[PB].scrub = 0 ;
106 smc->y[PA].cem_pst = CEM_PST_DOWN ;
107 smc->y[PB].cem_pst = CEM_PST_DOWN ;
108 }
109
110
111 #define THRU_ENABLED(smc) (smc->y[PA].pc_mode != PM_TREE && \
112 smc->y[PB].pc_mode != PM_TREE)
113
114 static void selection_criteria (struct s_smc *smc, struct s_phy *phy)
115 {
116
117 switch (phy->mib->fddiPORTMy_Type) {
118 case TA:
119 if ( !THRU_ENABLED(smc) && smc->y[PB].cf_join ) {
120 phy->wc_flag = TRUE ;
121 } else {
122 phy->wc_flag = FALSE ;
123 }
124
125 break;
126 case TB:
127
128 phy->wc_flag = FALSE ;
129 break;
130 case TS:
131 phy->wc_flag = FALSE ;
132 break;
133 case TM:
134 phy->wc_flag = FALSE ;
135 break;
136 }
137
138 }
139
140 void all_selection_criteria(struct s_smc *smc)
141 {
142 struct s_phy *phy ;
143 int p ;
144
145 for ( p = 0,phy = smc->y ; p < NUMPHYS; p++, phy++ ) {
146
147 selection_criteria (smc,phy);
148 }
149 }
150
151 static void cem_priv_state(struct s_smc *smc, int event)
152
153 {
154 int np;
155 int i;
156
157
158 if (smc->s.sas != SMT_DAS )
159 return ;
160
161 np = event - CF_JOIN;
162
163 if (np != PA && np != PB) {
164 return ;
165 }
166
167 if (smc->y[np].cf_join) {
168 smc->y[np].cem_pst = CEM_PST_UP ;
169 } else if (!smc->y[np].wc_flag) {
170
171 smc->y[np].cem_pst = CEM_PST_DOWN ;
172 }
173
174
175
176
177 for (i = 0 ; i < 2 ; i ++ ) {
178
179 if ( smc->y[i].cem_pst == CEM_PST_HOLD && !smc->y[i].wc_flag ) {
180 smc->y[i].cem_pst = CEM_PST_DOWN;
181 queue_event(smc,(int)(EVENT_PCM+i),PC_START) ;
182 }
183 if ( smc->y[i].cem_pst == CEM_PST_UP && smc->y[i].wc_flag ) {
184 smc->y[i].cem_pst = CEM_PST_HOLD;
185 queue_event(smc,(int)(EVENT_PCM+i),PC_START) ;
186 }
187 if ( smc->y[i].cem_pst == CEM_PST_DOWN && smc->y[i].wc_flag ) {
188
189
190
191
192 smc->y[i].cem_pst = CEM_PST_HOLD;
193 }
194 }
195 return ;
196 }
197
198
199
200
201
202
203
204
205
206
207 void cfm(struct s_smc *smc, int event)
208 {
209 int state ;
210 int cond ;
211 int oldstate ;
212
213
214
215
216
217
218
219 all_selection_criteria (smc);
220
221
222
223 cem_priv_state (smc, event);
224
225 oldstate = smc->mib.fddiSMTCF_State ;
226 do {
227 DB_CFM("CFM : state %s%s event %s",
228 smc->mib.fddiSMTCF_State & AFLAG ? "ACTIONS " : "",
229 cfm_states[smc->mib.fddiSMTCF_State & ~AFLAG],
230 cfm_events[event]);
231 state = smc->mib.fddiSMTCF_State ;
232 cfm_fsm(smc,event) ;
233 event = 0 ;
234 } while (state != smc->mib.fddiSMTCF_State) ;
235
236 #ifndef SLIM_SMT
237
238
239
240 cond = FALSE ;
241 if ( (smc->mib.fddiSMTCF_State == SC9_C_WRAP_A &&
242 smc->y[PA].pc_mode == PM_PEER) ||
243 (smc->mib.fddiSMTCF_State == SC10_C_WRAP_B &&
244 smc->y[PB].pc_mode == PM_PEER) ||
245 (smc->mib.fddiSMTCF_State == SC11_C_WRAP_S &&
246 smc->y[PS].pc_mode == PM_PEER &&
247 smc->y[PS].mib->fddiPORTNeighborType != TS ) ) {
248 cond = TRUE ;
249 }
250 if (cond != smc->mib.fddiSMTPeerWrapFlag)
251 smt_srf_event(smc,SMT_COND_SMT_PEER_WRAP,0,cond) ;
252
253 #if 0
254
255
256
257
258
259
260
261 if (smc->mib.fddiSMTCF_State != oldstate) {
262 smt_srf_event(smc,SMT_EVENT_MAC_PATH_CHANGE,INDEX_MAC,0) ;
263 }
264 #endif
265 #endif
266
267
268
269
270 smc->mib.m[MAC0].fddiMACDownstreamPORTType =
271 cf_to_ptype[smc->mib.fddiSMTCF_State] ;
272 cfm_state_change(smc,(int)smc->mib.fddiSMTCF_State) ;
273 }
274
275
276
277
278
279 static void cfm_fsm(struct s_smc *smc, int cmd)
280 {
281 switch(smc->mib.fddiSMTCF_State) {
282 case ACTIONS(SC0_ISOLATED) :
283 smc->mib.p[PA].fddiPORTCurrentPath = MIB_PATH_ISOLATED ;
284 smc->mib.p[PB].fddiPORTCurrentPath = MIB_PATH_ISOLATED ;
285 smc->mib.p[PA].fddiPORTMACPlacement = 0 ;
286 smc->mib.p[PB].fddiPORTMACPlacement = 0 ;
287 smc->mib.fddiSMTStationStatus = MIB_SMT_STASTA_SEPA ;
288 config_mux(smc,MUX_ISOLATE) ;
289 smc->r.rm_loop = FALSE ;
290 smc->r.rm_join = FALSE ;
291 queue_event(smc,EVENT_RMT,RM_JOIN) ;
292
293 ACTIONS_DONE() ;
294 DB_CFMN(1, "CFM : %s", cfm_states[smc->mib.fddiSMTCF_State]);
295 break;
296 case SC0_ISOLATED :
297
298
299 if (smc->s.sas && (smc->y[PA].cf_join || smc->y[PA].cf_loop ||
300 smc->y[PB].cf_join || smc->y[PB].cf_loop)) {
301 GO_STATE(SC11_C_WRAP_S) ;
302 break ;
303 }
304
305 if ((smc->y[PA].cem_pst == CEM_PST_UP && smc->y[PA].cf_join &&
306 !smc->y[PA].wc_flag) || smc->y[PA].cf_loop) {
307 GO_STATE(SC9_C_WRAP_A) ;
308 break ;
309 }
310
311 if ((smc->y[PB].cem_pst == CEM_PST_UP && smc->y[PB].cf_join &&
312 !smc->y[PB].wc_flag) || smc->y[PB].cf_loop) {
313 GO_STATE(SC10_C_WRAP_B) ;
314 break ;
315 }
316 break ;
317 case ACTIONS(SC9_C_WRAP_A) :
318 smc->mib.p[PA].fddiPORTCurrentPath = MIB_PATH_CONCATENATED ;
319 smc->mib.p[PB].fddiPORTCurrentPath = MIB_PATH_ISOLATED ;
320 smc->mib.p[PA].fddiPORTMACPlacement = INDEX_MAC ;
321 smc->mib.p[PB].fddiPORTMACPlacement = 0 ;
322 smc->mib.fddiSMTStationStatus = MIB_SMT_STASTA_CON ;
323 config_mux(smc,MUX_WRAPA) ;
324 if (smc->y[PA].cf_loop) {
325 smc->r.rm_join = FALSE ;
326 smc->r.rm_loop = TRUE ;
327 queue_event(smc,EVENT_RMT,RM_LOOP) ;
328 }
329 if (smc->y[PA].cf_join) {
330 smc->r.rm_loop = FALSE ;
331 smc->r.rm_join = TRUE ;
332 queue_event(smc,EVENT_RMT,RM_JOIN) ;
333 }
334 ACTIONS_DONE() ;
335 DB_CFMN(1, "CFM : %s", cfm_states[smc->mib.fddiSMTCF_State]);
336 break ;
337 case SC9_C_WRAP_A :
338
339 if ( (smc->y[PA].wc_flag || !smc->y[PA].cf_join) &&
340 !smc->y[PA].cf_loop ) {
341 GO_STATE(SC0_ISOLATED) ;
342 break ;
343 }
344
345 else if ( (smc->y[PB].cf_loop && smc->y[PA].cf_join &&
346 smc->y[PA].cem_pst == CEM_PST_UP) ||
347 ((smc->y[PB].cf_loop ||
348 (smc->y[PB].cf_join &&
349 smc->y[PB].cem_pst == CEM_PST_UP)) &&
350 (smc->y[PA].pc_mode == PM_TREE ||
351 smc->y[PB].pc_mode == PM_TREE))) {
352 smc->y[PA].scrub = TRUE ;
353 GO_STATE(SC10_C_WRAP_B) ;
354 break ;
355 }
356
357 else if (!smc->s.attach_s &&
358 smc->y[PA].cf_join &&
359 smc->y[PA].cem_pst == CEM_PST_UP &&
360 smc->y[PA].pc_mode == PM_PEER && smc->y[PB].cf_join &&
361 smc->y[PB].cem_pst == CEM_PST_UP &&
362 smc->y[PB].pc_mode == PM_PEER) {
363 smc->y[PA].scrub = TRUE ;
364 smc->y[PB].scrub = TRUE ;
365 GO_STATE(SC4_THRU_A) ;
366 break ;
367 }
368
369 else if ( smc->s.attach_s &&
370 smc->y[PA].cf_join &&
371 smc->y[PA].cem_pst == CEM_PST_UP &&
372 smc->y[PA].pc_mode == PM_PEER &&
373 smc->y[PB].cf_join &&
374 smc->y[PB].cem_pst == CEM_PST_UP &&
375 smc->y[PB].pc_mode == PM_PEER) {
376 smc->y[PA].scrub = TRUE ;
377 smc->y[PB].scrub = TRUE ;
378 GO_STATE(SC5_THRU_B) ;
379 break ;
380 }
381 break ;
382 case ACTIONS(SC10_C_WRAP_B) :
383 smc->mib.p[PA].fddiPORTCurrentPath = MIB_PATH_ISOLATED ;
384 smc->mib.p[PB].fddiPORTCurrentPath = MIB_PATH_CONCATENATED ;
385 smc->mib.p[PA].fddiPORTMACPlacement = 0 ;
386 smc->mib.p[PB].fddiPORTMACPlacement = INDEX_MAC ;
387 smc->mib.fddiSMTStationStatus = MIB_SMT_STASTA_CON ;
388 config_mux(smc,MUX_WRAPB) ;
389 if (smc->y[PB].cf_loop) {
390 smc->r.rm_join = FALSE ;
391 smc->r.rm_loop = TRUE ;
392 queue_event(smc,EVENT_RMT,RM_LOOP) ;
393 }
394 if (smc->y[PB].cf_join) {
395 smc->r.rm_loop = FALSE ;
396 smc->r.rm_join = TRUE ;
397 queue_event(smc,EVENT_RMT,RM_JOIN) ;
398 }
399 ACTIONS_DONE() ;
400 DB_CFMN(1, "CFM : %s", cfm_states[smc->mib.fddiSMTCF_State]);
401 break ;
402 case SC10_C_WRAP_B :
403
404 if ( !smc->y[PB].cf_join && !smc->y[PB].cf_loop ) {
405 GO_STATE(SC0_ISOLATED) ;
406 break ;
407 }
408
409 else if ( smc->y[PA].cf_loop && smc->y[PA].pc_mode == PM_PEER &&
410 smc->y[PB].cf_join && smc->y[PB].pc_mode == PM_PEER) {
411 smc->y[PB].scrub = TRUE ;
412 GO_STATE(SC9_C_WRAP_A) ;
413 break ;
414 }
415
416 else if (!smc->s.attach_s &&
417 smc->y[PA].cf_join && smc->y[PA].pc_mode == PM_PEER &&
418 smc->y[PB].cf_join && smc->y[PB].pc_mode == PM_PEER) {
419 smc->y[PA].scrub = TRUE ;
420 smc->y[PB].scrub = TRUE ;
421 GO_STATE(SC4_THRU_A) ;
422 break ;
423 }
424
425 else if ( smc->s.attach_s &&
426 smc->y[PA].cf_join && smc->y[PA].pc_mode == PM_PEER &&
427 smc->y[PB].cf_join && smc->y[PB].pc_mode == PM_PEER) {
428 smc->y[PA].scrub = TRUE ;
429 smc->y[PB].scrub = TRUE ;
430 GO_STATE(SC5_THRU_B) ;
431 break ;
432 }
433 break ;
434 case ACTIONS(SC4_THRU_A) :
435 smc->mib.p[PA].fddiPORTCurrentPath = MIB_PATH_THRU ;
436 smc->mib.p[PB].fddiPORTCurrentPath = MIB_PATH_THRU ;
437 smc->mib.p[PA].fddiPORTMACPlacement = 0 ;
438 smc->mib.p[PB].fddiPORTMACPlacement = INDEX_MAC ;
439 smc->mib.fddiSMTStationStatus = MIB_SMT_STASTA_THRU ;
440 config_mux(smc,MUX_THRUA) ;
441 smc->r.rm_loop = FALSE ;
442 smc->r.rm_join = TRUE ;
443 queue_event(smc,EVENT_RMT,RM_JOIN) ;
444 ACTIONS_DONE() ;
445 DB_CFMN(1, "CFM : %s", cfm_states[smc->mib.fddiSMTCF_State]);
446 break ;
447 case SC4_THRU_A :
448
449 if (smc->y[PB].wc_flag || !smc->y[PB].cf_join) {
450 smc->y[PA].scrub = TRUE ;
451 GO_STATE(SC9_C_WRAP_A) ;
452 break ;
453 }
454
455 else if (!smc->y[PA].cf_join || smc->y[PA].wc_flag) {
456 smc->y[PB].scrub = TRUE ;
457 GO_STATE(SC10_C_WRAP_B) ;
458 break ;
459 }
460
461 else if (smc->s.attach_s) {
462 smc->y[PB].scrub = TRUE ;
463 GO_STATE(SC5_THRU_B) ;
464 break ;
465 }
466 break ;
467 case ACTIONS(SC5_THRU_B) :
468 smc->mib.p[PA].fddiPORTCurrentPath = MIB_PATH_THRU ;
469 smc->mib.p[PB].fddiPORTCurrentPath = MIB_PATH_THRU ;
470 smc->mib.p[PA].fddiPORTMACPlacement = INDEX_MAC ;
471 smc->mib.p[PB].fddiPORTMACPlacement = 0 ;
472 smc->mib.fddiSMTStationStatus = MIB_SMT_STASTA_THRU ;
473 config_mux(smc,MUX_THRUB) ;
474 smc->r.rm_loop = FALSE ;
475 smc->r.rm_join = TRUE ;
476 queue_event(smc,EVENT_RMT,RM_JOIN) ;
477 ACTIONS_DONE() ;
478 DB_CFMN(1, "CFM : %s", cfm_states[smc->mib.fddiSMTCF_State]);
479 break ;
480 case SC5_THRU_B :
481
482 if (!smc->y[PB].cf_join || smc->y[PB].wc_flag) {
483 smc->y[PA].scrub = TRUE ;
484 GO_STATE(SC9_C_WRAP_A) ;
485 break ;
486 }
487
488 else if (!smc->y[PA].cf_join || smc->y[PA].wc_flag) {
489 smc->y[PB].scrub = TRUE ;
490 GO_STATE(SC10_C_WRAP_B) ;
491 break ;
492 }
493
494 else if (!smc->s.attach_s) {
495 smc->y[PA].scrub = TRUE ;
496 GO_STATE(SC4_THRU_A) ;
497 break ;
498 }
499 break ;
500 case ACTIONS(SC11_C_WRAP_S) :
501 smc->mib.p[PS].fddiPORTCurrentPath = MIB_PATH_CONCATENATED ;
502 smc->mib.p[PS].fddiPORTMACPlacement = INDEX_MAC ;
503 smc->mib.fddiSMTStationStatus = MIB_SMT_STASTA_CON ;
504 config_mux(smc,MUX_WRAPS) ;
505 if (smc->y[PA].cf_loop || smc->y[PB].cf_loop) {
506 smc->r.rm_join = FALSE ;
507 smc->r.rm_loop = TRUE ;
508 queue_event(smc,EVENT_RMT,RM_LOOP) ;
509 }
510 if (smc->y[PA].cf_join || smc->y[PB].cf_join) {
511 smc->r.rm_loop = FALSE ;
512 smc->r.rm_join = TRUE ;
513 queue_event(smc,EVENT_RMT,RM_JOIN) ;
514 }
515 ACTIONS_DONE() ;
516 DB_CFMN(1, "CFM : %s", cfm_states[smc->mib.fddiSMTCF_State]);
517 break ;
518 case SC11_C_WRAP_S :
519
520 if ( !smc->y[PA].cf_join && !smc->y[PA].cf_loop &&
521 !smc->y[PB].cf_join && !smc->y[PB].cf_loop) {
522 GO_STATE(SC0_ISOLATED) ;
523 break ;
524 }
525 break ;
526 default:
527 SMT_PANIC(smc,SMT_E0106, SMT_E0106_MSG) ;
528 break;
529 }
530 }
531
532
533
534
535
536
537 int cfm_get_mac_input(struct s_smc *smc)
538 {
539 return (smc->mib.fddiSMTCF_State == SC10_C_WRAP_B ||
540 smc->mib.fddiSMTCF_State == SC5_THRU_B) ? PB : PA;
541 }
542
543
544
545
546
547
548 int cfm_get_mac_output(struct s_smc *smc)
549 {
550 return (smc->mib.fddiSMTCF_State == SC10_C_WRAP_B ||
551 smc->mib.fddiSMTCF_State == SC4_THRU_A) ? PB : PA;
552 }
553
554 static char path_iso[] = {
555 0,0, 0,RES_PORT, 0,PA + INDEX_PORT, 0,PATH_ISO,
556 0,0, 0,RES_MAC, 0,INDEX_MAC, 0,PATH_ISO,
557 0,0, 0,RES_PORT, 0,PB + INDEX_PORT, 0,PATH_ISO
558 } ;
559
560 static char path_wrap_a[] = {
561 0,0, 0,RES_PORT, 0,PA + INDEX_PORT, 0,PATH_PRIM,
562 0,0, 0,RES_MAC, 0,INDEX_MAC, 0,PATH_PRIM,
563 0,0, 0,RES_PORT, 0,PB + INDEX_PORT, 0,PATH_ISO
564 } ;
565
566 static char path_wrap_b[] = {
567 0,0, 0,RES_PORT, 0,PB + INDEX_PORT, 0,PATH_PRIM,
568 0,0, 0,RES_MAC, 0,INDEX_MAC, 0,PATH_PRIM,
569 0,0, 0,RES_PORT, 0,PA + INDEX_PORT, 0,PATH_ISO
570 } ;
571
572 static char path_thru[] = {
573 0,0, 0,RES_PORT, 0,PA + INDEX_PORT, 0,PATH_PRIM,
574 0,0, 0,RES_MAC, 0,INDEX_MAC, 0,PATH_PRIM,
575 0,0, 0,RES_PORT, 0,PB + INDEX_PORT, 0,PATH_PRIM
576 } ;
577
578 static char path_wrap_s[] = {
579 0,0, 0,RES_PORT, 0,PS + INDEX_PORT, 0,PATH_PRIM,
580 0,0, 0,RES_MAC, 0,INDEX_MAC, 0,PATH_PRIM,
581 } ;
582
583 static char path_iso_s[] = {
584 0,0, 0,RES_PORT, 0,PS + INDEX_PORT, 0,PATH_ISO,
585 0,0, 0,RES_MAC, 0,INDEX_MAC, 0,PATH_ISO,
586 } ;
587
588 int cem_build_path(struct s_smc *smc, char *to, int path_index)
589 {
590 char *path ;
591 int len ;
592
593 switch (smc->mib.fddiSMTCF_State) {
594 default :
595 case SC0_ISOLATED :
596 path = smc->s.sas ? path_iso_s : path_iso ;
597 len = smc->s.sas ? sizeof(path_iso_s) : sizeof(path_iso) ;
598 break ;
599 case SC9_C_WRAP_A :
600 path = path_wrap_a ;
601 len = sizeof(path_wrap_a) ;
602 break ;
603 case SC10_C_WRAP_B :
604 path = path_wrap_b ;
605 len = sizeof(path_wrap_b) ;
606 break ;
607 case SC4_THRU_A :
608 path = path_thru ;
609 len = sizeof(path_thru) ;
610 break ;
611 case SC11_C_WRAP_S :
612 path = path_wrap_s ;
613 len = sizeof(path_wrap_s) ;
614 break ;
615 }
616 memcpy(to,path,len) ;
617
618 LINT_USE(path_index);
619
620 return len;
621 }