OpenCores
URL https://opencores.org/ocsvn/test_project/test_project/trunk

Subversion Repositories test_project

[/] [test_project/] [trunk/] [linux_sd_driver/] [drivers/] [net/] [skfp/] [srf.c] - Blame information for rev 62

Details | Compare with Previous | View Log

Line No. Rev Author Line
1 62 marcus.erl
/******************************************************************************
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
 

powered by: WebSVN 2.1.0

© copyright 1999-2025 OpenCores.org, equivalent to Oliscience, all rights reserved. OpenCores®, registered trademark.