Linux Kernel  3.7.1
 All Data Structures Namespaces Files Functions Variables Typedefs Enumerations Enumerator Macros Groups Pages
srf.c
Go to the documentation of this file.
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 7.2 Status Response Frame Implementation
19  SRF state machine and frame generation
20 */
21 
22 #include "h/types.h"
23 #include "h/fddi.h"
24 #include "h/smc.h"
25 #include "h/smt_p.h"
26 
27 #define KERNEL
28 #include "h/smtstate.h"
29 
30 #ifndef SLIM_SMT
31 #ifndef BOOT
32 
33 #ifndef lint
34 static const char ID_sccs[] = "@(#)srf.c 1.18 97/08/04 (C) SK " ;
35 #endif
36 
37 
38 /*
39  * function declarations
40  */
41 static void clear_all_rep(struct s_smc *smc);
42 static void clear_reported(struct s_smc *smc);
43 static void smt_send_srf(struct s_smc *smc);
44 static struct s_srf_evc *smt_get_evc(struct s_smc *smc, int code, int index);
45 
46 #define MAX_EVCS ARRAY_SIZE(smc->evcs)
47 
48 struct evc_init {
49  u_char code ;
50  u_char index ;
51  u_char n ;
52  u_short para ;
53 } ;
54 
55 static const struct evc_init evc_inits[] = {
56  { SMT_COND_SMT_PEER_WRAP, 0,1,SMT_P1048 } ,
57 
58  { SMT_COND_MAC_DUP_ADDR, INDEX_MAC, NUMMACS,SMT_P208C } ,
59  { SMT_COND_MAC_FRAME_ERROR, INDEX_MAC, NUMMACS,SMT_P208D } ,
60  { SMT_COND_MAC_NOT_COPIED, INDEX_MAC, NUMMACS,SMT_P208E } ,
61  { SMT_EVENT_MAC_NEIGHBOR_CHANGE, INDEX_MAC, NUMMACS,SMT_P208F } ,
62  { SMT_EVENT_MAC_PATH_CHANGE, INDEX_MAC, NUMMACS,SMT_P2090 } ,
63 
64  { SMT_COND_PORT_LER, INDEX_PORT,NUMPHYS,SMT_P4050 } ,
65  { SMT_COND_PORT_EB_ERROR, INDEX_PORT,NUMPHYS,SMT_P4052 } ,
66  { SMT_EVENT_PORT_CONNECTION, INDEX_PORT,NUMPHYS,SMT_P4051 } ,
67  { SMT_EVENT_PORT_PATH_CHANGE, INDEX_PORT,NUMPHYS,SMT_P4053 } ,
68 } ;
69 
70 #define MAX_INIT_EVC ARRAY_SIZE(evc_inits)
71 
72 void smt_init_evc(struct s_smc *smc)
73 {
74  struct s_srf_evc *evc ;
75  const struct evc_init *init ;
76  int i ;
77  int index ;
78  int offset ;
79 
80  static u_char fail_safe = FALSE ;
81 
82  memset((char *)smc->evcs,0,sizeof(smc->evcs)) ;
83 
84  evc = smc->evcs ;
85  init = evc_inits ;
86 
87  for (i = 0 ; (unsigned) i < MAX_INIT_EVC ; i++) {
88  for (index = 0 ; index < init->n ; index++) {
89  evc->evc_code = init->code ;
90  evc->evc_para = init->para ;
91  evc->evc_index = init->index + index ;
92 #ifndef DEBUG
93  evc->evc_multiple = &fail_safe ;
94  evc->evc_cond_state = &fail_safe ;
95 #endif
96  evc++ ;
97  }
98  init++ ;
99  }
100 
101  if ((unsigned) (evc - smc->evcs) > MAX_EVCS) {
102  SMT_PANIC(smc,SMT_E0127, SMT_E0127_MSG) ;
103  }
104 
105  /*
106  * conditions
107  */
108  smc->evcs[0].evc_cond_state = &smc->mib.fddiSMTPeerWrapFlag ;
109  smc->evcs[1].evc_cond_state =
110  &smc->mib.m[MAC0].fddiMACDuplicateAddressCond ;
111  smc->evcs[2].evc_cond_state =
112  &smc->mib.m[MAC0].fddiMACFrameErrorFlag ;
113  smc->evcs[3].evc_cond_state =
114  &smc->mib.m[MAC0].fddiMACNotCopiedFlag ;
115 
116  /*
117  * events
118  */
119  smc->evcs[4].evc_multiple = &smc->mib.m[MAC0].fddiMACMultiple_N ;
120  smc->evcs[5].evc_multiple = &smc->mib.m[MAC0].fddiMACMultiple_P ;
121 
122  offset = 6 ;
123  for (i = 0 ; i < NUMPHYS ; i++) {
124  /*
125  * conditions
126  */
127  smc->evcs[offset + 0*NUMPHYS].evc_cond_state =
128  &smc->mib.p[i].fddiPORTLerFlag ;
129  smc->evcs[offset + 1*NUMPHYS].evc_cond_state =
130  &smc->mib.p[i].fddiPORTEB_Condition ;
131 
132  /*
133  * events
134  */
135  smc->evcs[offset + 2*NUMPHYS].evc_multiple =
136  &smc->mib.p[i].fddiPORTMultiple_U ;
137  smc->evcs[offset + 3*NUMPHYS].evc_multiple =
138  &smc->mib.p[i].fddiPORTMultiple_P ;
139  offset++ ;
140  }
141 #ifdef DEBUG
142  for (i = 0, evc = smc->evcs ; (unsigned) i < MAX_EVCS ; i++, evc++) {
143  if (SMT_IS_CONDITION(evc->evc_code)) {
144  if (!evc->evc_cond_state) {
145  SMT_PANIC(smc,SMT_E0128, SMT_E0128_MSG) ;
146  }
147  evc->evc_multiple = &fail_safe ;
148  }
149  else {
150  if (!evc->evc_multiple) {
151  SMT_PANIC(smc,SMT_E0129, SMT_E0129_MSG) ;
152  }
153  evc->evc_cond_state = &fail_safe ;
154  }
155  }
156 #endif
157  smc->srf.TSR = smt_get_time() ;
158  smc->srf.sr_state = SR0_WAIT ;
159 }
160 
161 static struct s_srf_evc *smt_get_evc(struct s_smc *smc, int code, int index)
162 {
163  int i ;
164  struct s_srf_evc *evc ;
165 
166  for (i = 0, evc = smc->evcs ; (unsigned) i < MAX_EVCS ; i++, evc++) {
167  if (evc->evc_code == code && evc->evc_index == index)
168  return evc;
169  }
170  return NULL;
171 }
172 
173 #define THRESHOLD_2 (2*TICKS_PER_SECOND)
174 #define THRESHOLD_32 (32*TICKS_PER_SECOND)
175 
176 #ifdef DEBUG
177 static const char * const srf_names[] = {
178  "None","MACPathChangeEvent", "MACNeighborChangeEvent",
179  "PORTPathChangeEvent", "PORTUndesiredConnectionAttemptEvent",
180  "SMTPeerWrapCondition", "SMTHoldCondition",
181  "MACFrameErrorCondition", "MACDuplicateAddressCondition",
182  "MACNotCopiedCondition", "PORTEBErrorCondition",
183  "PORTLerCondition"
184 } ;
185 #endif
186 
187 void smt_srf_event(struct s_smc *smc, int code, int index, int cond)
188 {
189  struct s_srf_evc *evc ;
190  int cond_asserted = 0 ;
191  int cond_deasserted = 0 ;
192  int event_occurred = 0 ;
193  int tsr ;
194  int T_Limit = 2*TICKS_PER_SECOND ;
195 
196  if (code == SMT_COND_MAC_DUP_ADDR && cond) {
197  RS_SET(smc,RS_DUPADDR) ;
198  }
199 
200  if (code) {
201  DB_SMT("SRF: %s index %d\n",srf_names[code],index) ;
202 
203  if (!(evc = smt_get_evc(smc,code,index))) {
204  DB_SMT("SRF : smt_get_evc() failed\n",0,0) ;
205  return ;
206  }
207  /*
208  * ignore condition if no change
209  */
210  if (SMT_IS_CONDITION(code)) {
211  if (*evc->evc_cond_state == cond)
212  return ;
213  }
214 
215  /*
216  * set transition time stamp
217  */
218  smt_set_timestamp(smc,smc->mib.fddiSMTTransitionTimeStamp) ;
219  if (SMT_IS_CONDITION(code)) {
220  DB_SMT("SRF: condition is %s\n",cond ? "ON":"OFF",0) ;
221  if (cond) {
222  *evc->evc_cond_state = TRUE ;
223  evc->evc_rep_required = TRUE ;
224  smc->srf.any_report = TRUE ;
225  cond_asserted = TRUE ;
226  }
227  else {
228  *evc->evc_cond_state = FALSE ;
229  cond_deasserted = TRUE ;
230  }
231  }
232  else {
233  if (evc->evc_rep_required) {
234  *evc->evc_multiple = TRUE ;
235  }
236  else {
237  evc->evc_rep_required = TRUE ;
238  *evc->evc_multiple = FALSE ;
239  }
240  smc->srf.any_report = TRUE ;
241  event_occurred = TRUE ;
242  }
243 #ifdef FDDI_MIB
244  snmp_srf_event(smc,evc) ;
245 #endif /* FDDI_MIB */
246  }
247  tsr = smt_get_time() - smc->srf.TSR ;
248 
249  switch (smc->srf.sr_state) {
250  case SR0_WAIT :
251  /* SR01a */
252  if (cond_asserted && tsr < T_Limit) {
253  smc->srf.SRThreshold = THRESHOLD_2 ;
254  smc->srf.sr_state = SR1_HOLDOFF ;
255  break ;
256  }
257  /* SR01b */
258  if (cond_deasserted && tsr < T_Limit) {
259  smc->srf.sr_state = SR1_HOLDOFF ;
260  break ;
261  }
262  /* SR01c */
263  if (event_occurred && tsr < T_Limit) {
264  smc->srf.sr_state = SR1_HOLDOFF ;
265  break ;
266  }
267  /* SR00b */
268  if (cond_asserted && tsr >= T_Limit) {
269  smc->srf.SRThreshold = THRESHOLD_2 ;
270  smc->srf.TSR = smt_get_time() ;
271  smt_send_srf(smc) ;
272  break ;
273  }
274  /* SR00c */
275  if (cond_deasserted && tsr >= T_Limit) {
276  smc->srf.TSR = smt_get_time() ;
277  smt_send_srf(smc) ;
278  break ;
279  }
280  /* SR00d */
281  if (event_occurred && tsr >= T_Limit) {
282  smc->srf.TSR = smt_get_time() ;
283  smt_send_srf(smc) ;
284  break ;
285  }
286  /* SR00e */
287  if (smc->srf.any_report && (u_long) tsr >=
288  smc->srf.SRThreshold) {
289  smc->srf.SRThreshold *= 2 ;
290  if (smc->srf.SRThreshold > THRESHOLD_32)
291  smc->srf.SRThreshold = THRESHOLD_32 ;
292  smc->srf.TSR = smt_get_time() ;
293  smt_send_srf(smc) ;
294  break ;
295  }
296  /* SR02 */
297  if (!smc->mib.fddiSMTStatRptPolicy) {
298  smc->srf.sr_state = SR2_DISABLED ;
299  break ;
300  }
301  break ;
302  case SR1_HOLDOFF :
303  /* SR10b */
304  if (tsr >= T_Limit) {
305  smc->srf.sr_state = SR0_WAIT ;
306  smc->srf.TSR = smt_get_time() ;
307  smt_send_srf(smc) ;
308  break ;
309  }
310  /* SR11a */
311  if (cond_asserted) {
312  smc->srf.SRThreshold = THRESHOLD_2 ;
313  }
314  /* SR11b */
315  /* SR11c */
316  /* handled above */
317  /* SR12 */
318  if (!smc->mib.fddiSMTStatRptPolicy) {
319  smc->srf.sr_state = SR2_DISABLED ;
320  break ;
321  }
322  break ;
323  case SR2_DISABLED :
324  if (smc->mib.fddiSMTStatRptPolicy) {
325  smc->srf.sr_state = SR0_WAIT ;
326  smc->srf.TSR = smt_get_time() ;
327  smc->srf.SRThreshold = THRESHOLD_2 ;
328  clear_all_rep(smc) ;
329  break ;
330  }
331  break ;
332  }
333 }
334 
335 static void clear_all_rep(struct s_smc *smc)
336 {
337  struct s_srf_evc *evc ;
338  int i ;
339 
340  for (i = 0, evc = smc->evcs ; (unsigned) i < MAX_EVCS ; i++, evc++) {
341  evc->evc_rep_required = FALSE ;
342  if (SMT_IS_CONDITION(evc->evc_code))
343  *evc->evc_cond_state = FALSE ;
344  }
345  smc->srf.any_report = FALSE ;
346 }
347 
348 static void clear_reported(struct s_smc *smc)
349 {
350  struct s_srf_evc *evc ;
351  int i ;
352 
353  smc->srf.any_report = FALSE ;
354  for (i = 0, evc = smc->evcs ; (unsigned) i < MAX_EVCS ; i++, evc++) {
355  if (SMT_IS_CONDITION(evc->evc_code)) {
356  if (*evc->evc_cond_state == FALSE)
357  evc->evc_rep_required = FALSE ;
358  else
359  smc->srf.any_report = TRUE ;
360  }
361  else {
362  evc->evc_rep_required = FALSE ;
363  *evc->evc_multiple = FALSE ;
364  }
365  }
366 }
367 
368 /*
369  * build and send SMT SRF frame
370  */
371 static void smt_send_srf(struct s_smc *smc)
372 {
373 
374  struct smt_header *smt ;
375  struct s_srf_evc *evc ;
376  SK_LOC_DECL(struct s_pcon,pcon) ;
377  SMbuf *mb ;
378  int i ;
379 
380  static const struct fddi_addr SMT_SRF_DA = {
381  { 0x80, 0x01, 0x43, 0x00, 0x80, 0x08 }
382  } ;
383 
384  /*
385  * build SMT header
386  */
387  if (!smc->r.sm_ma_avail)
388  return ;
389  if (!(mb = smt_build_frame(smc,SMT_SRF,SMT_ANNOUNCE,0)))
390  return ;
391 
392  RS_SET(smc,RS_SOFTERROR) ;
393 
394  smt = smtod(mb, struct smt_header *) ;
395  smt->smt_dest = SMT_SRF_DA ; /* DA == SRF multicast */
396 
397  /*
398  * setup parameter status
399  */
400  pcon.pc_len = SMT_MAX_INFO_LEN ; /* max para length */
401  pcon.pc_err = 0 ; /* no error */
402  pcon.pc_badset = 0 ; /* no bad set count */
403  pcon.pc_p = (void *) (smt + 1) ; /* paras start here */
404 
405  smt_add_para(smc,&pcon,(u_short) SMT_P1033,0,0) ;
406  smt_add_para(smc,&pcon,(u_short) SMT_P1034,0,0) ;
407 
408  for (i = 0, evc = smc->evcs ; (unsigned) i < MAX_EVCS ; i++, evc++) {
409  if (evc->evc_rep_required) {
410  smt_add_para(smc,&pcon,evc->evc_para,
411  (int)evc->evc_index,0) ;
412  }
413  }
414  smt->smt_len = SMT_MAX_INFO_LEN - pcon.pc_len ;
415  mb->sm_len = smt->smt_len + sizeof(struct smt_header) ;
416 
417  DB_SMT("SRF: sending SRF at %x, len %d\n",smt,mb->sm_len) ;
418  DB_SMT("SRF: state SR%d Threshold %d\n",
419  smc->srf.sr_state,smc->srf.SRThreshold/TICKS_PER_SECOND) ;
420 #ifdef DEBUG
421  dump_smt(smc,smt,"SRF Send") ;
422 #endif
423  smt_send_frame(smc,mb,FC_SMT_INFO,0) ;
424  clear_reported(smc) ;
425 }
426 
427 #endif /* no BOOT */
428 #endif /* no SLIM_SMT */
429 
Generated on Thu Jan 10 2013 14:06:25 for Linux Kernel by   doxygen 1.8.2