/* *receivepackethandler
*/ void smt_received_pack(struct s_smc *smc, SMbuf *mb, int fs) /* int fs; frame status */
{ struct smt_header *sm ; int local ;
int illegal = 0 ;
switch (m_fc(mb)) { case FC_SMT_INFO : case FC_SMT_LAN_LOC : case FC_SMT_LOC : case FC_SMT_NSA : break ; default :
smt_free_mbuf(smc,mb) ; return ;
}
smc->mib.m[MAC0].fddiMACSMTCopied_Ct++ ;
sm = smtod(mb,struct smt_header *) ;
local = ((fs & L_INDICATOR) != 0) ;
hwm_conv_can(smc,(char *)sm,12) ;
/* check destination address */ if (is_individual(&sm->smt_dest) && !is_my_addr(smc,&sm->smt_dest)) {
smt_free_mbuf(smc,mb) ; return ;
} #if0/* for DUP recognition, do NOT filter them */ /* ignore loop back packets */ if (is_my_addr(smc,&sm->smt_source) && !local) {
smt_free_mbuf(smc,mb) ; return ;
} #endif
smt_swap_para(sm,(int) mb->sm_len,1) ;
DB_SMT("SMT : received packet [%s] at 0x%p",
smt_type_name[m_fc(mb) & 0xf], sm);
DB_SMT("SMT : version %d, class %s",
sm->smt_version,
smt_class_name[sm->smt_class > LAST_CLASS ? 0 : sm->smt_class]);
/* *checkSMTversion
*/ switch (sm->smt_class) { case SMT_NIF : case SMT_SIF_CONFIG : case SMT_SIF_OPER : case SMT_ECF : if (sm->smt_version != SMT_VID)
illegal = 1; break ; default : if (sm->smt_version != SMT_VID_2)
illegal = 1; break ;
} if (illegal) {
DB_SMT("SMT : version = %d, dest = %pM",
sm->smt_version, &sm->smt_source);
smt_send_rdf(smc,mb,m_fc(mb),SMT_RDF_VERSION,local) ;
smt_free_mbuf(smc,mb) ; return ;
} if ((sm->smt_len > mb->sm_len - sizeof(struct smt_header)) ||
((sm->smt_len & 3) && (sm->smt_class != SMT_ECF))) {
DB_SMT("SMT: info length error, len = %d", sm->smt_len);
smt_send_rdf(smc,mb,m_fc(mb),SMT_RDF_LENGTH,local) ;
smt_free_mbuf(smc,mb) ; return ;
} switch (sm->smt_class) { case SMT_NIF : if (smt_check_para(smc,sm,plist_nif)) {
DB_SMT("SMT: NIF with para problem, ignoring"); break ;
} switch (sm->smt_type) { case SMT_ANNOUNCE : case SMT_REQUEST : if (!(fs & C_INDICATOR) && m_fc(mb) == FC_SMT_NSA
&& is_broadcast(&sm->smt_dest)) { struct smt_p_state *st ;
/* set my UNA */ if (!is_equal(
&smc->mib.m[MAC0].fddiMACUpstreamNbr,
&sm->smt_source)) {
DB_SMT("SMT : updated my UNA = %pM",
&sm->smt_source); if (!is_equal(&smc->mib.m[MAC0].
fddiMACUpstreamNbr,&SMT_Unknown)){ /* Do not update unknown address */
smc->mib.m[MAC0].fddiMACOldUpstreamNbr=
smc->mib.m[MAC0].fddiMACUpstreamNbr ;
}
smc->mib.m[MAC0].fddiMACUpstreamNbr =
sm->smt_source ;
smt_srf_event(smc,
SMT_EVENT_MAC_NEIGHBOR_CHANGE,
INDEX_MAC,0) ;
smt_echo_test(smc,0) ;
}
smc->sm.smt_tvu = smt_get_time() ;
st = (struct smt_p_state *)
sm_to_para(smc,sm,SMT_P_STATE) ; if (st) {
smc->mib.m[MAC0].fddiMACUNDA_Flag =
(st->st_dupl_addr & SMT_ST_MY_DUPA) ? TRUE : FALSE ;
update_dac(smc,1) ;
}
} if ((sm->smt_type == SMT_REQUEST) &&
is_individual(&sm->smt_source) &&
((!(fs & A_INDICATOR) && m_fc(mb) == FC_SMT_NSA) ||
(m_fc(mb) != FC_SMT_NSA))) {
DB_SMT("SMT : replying to NIF request %pM",
&sm->smt_source);
smt_send_nif(smc,&sm->smt_source,
FC_SMT_INFO,
sm->smt_tid,
SMT_REPLY,local) ;
} break ; case SMT_REPLY :
DB_SMT("SMT : received NIF response from %pM",
&sm->smt_source); if (fs & A_INDICATOR) {
smc->sm.pend[SMT_TID_NIF] = 0 ;
DB_SMT("SMT : duplicate address");
smc->mib.m[MAC0].fddiMACDupAddressTest =
DA_FAILED ;
smc->r.dup_addr_test = DA_FAILED ;
queue_event(smc,EVENT_RMT,RM_DUP_ADDR) ;
smc->mib.m[MAC0].fddiMACDA_Flag = TRUE ;
update_dac(smc,1) ; break ;
} if (sm->smt_tid == smc->sm.pend[SMT_TID_NIF]) {
smc->sm.pend[SMT_TID_NIF] = 0 ; /* set my DNA */ if (!is_equal(
&smc->mib.m[MAC0].fddiMACDownstreamNbr,
&sm->smt_source)) {
DB_SMT("SMT : updated my DNA"); if (!is_equal(&smc->mib.m[MAC0].
fddiMACDownstreamNbr, &SMT_Unknown)){ /* Do not update unknown address */
smc->mib.m[MAC0].fddiMACOldDownstreamNbr =
smc->mib.m[MAC0].fddiMACDownstreamNbr ;
}
smc->mib.m[MAC0].fddiMACDownstreamNbr =
sm->smt_source ;
smt_srf_event(smc,
SMT_EVENT_MAC_NEIGHBOR_CHANGE,
INDEX_MAC,0) ;
smt_echo_test(smc,1) ;
}
smc->mib.m[MAC0].fddiMACDA_Flag = FALSE ;
update_dac(smc,1) ;
smc->sm.smt_tvd = smt_get_time() ;
smc->mib.m[MAC0].fddiMACDupAddressTest =
DA_PASSED ; if (smc->r.dup_addr_test != DA_PASSED) {
smc->r.dup_addr_test = DA_PASSED ;
queue_event(smc,EVENT_RMT,RM_DUP_ADDR) ;
}
} elseif (sm->smt_tid ==
smc->sm.pend[SMT_TID_NIF_TEST]) {
DB_SMT("SMT : NIF test TID ok");
} else {
DB_SMT("SMT : expected TID %lx, got %x",
smc->sm.pend[SMT_TID_NIF], sm->smt_tid);
} break ; default :
illegal = 2 ; break ;
} break ; case SMT_SIF_CONFIG : /* station information */ if (sm->smt_type != SMT_REQUEST) break ;
DB_SMT("SMT : replying to SIF Config request from %pM",
&sm->smt_source);
smt_send_sif_config(smc,&sm->smt_source,sm->smt_tid,local) ; break ; case SMT_SIF_OPER : /* station information */ if (sm->smt_type != SMT_REQUEST) break ;
DB_SMT("SMT : replying to SIF Operation request from %pM",
&sm->smt_source);
smt_send_sif_operation(smc,&sm->smt_source,sm->smt_tid,local) ; break ; case SMT_ECF : /* echo frame */ switch (sm->smt_type) { case SMT_REPLY :
smc->mib.priv.fddiPRIVECF_Reply_Rx++ ;
DB_SMT("SMT: received ECF reply from %pM",
&sm->smt_source); if (sm_to_para(smc,sm,SMT_P_ECHODATA) == NULL) {
DB_SMT("SMT: ECHODATA missing"); break ;
} if (sm->smt_tid == smc->sm.pend[SMT_TID_ECF]) {
DB_SMT("SMT : ECF test TID ok");
} elseif (sm->smt_tid == smc->sm.pend[SMT_TID_ECF_UNA]) {
DB_SMT("SMT : ECF test UNA ok");
} elseif (sm->smt_tid == smc->sm.pend[SMT_TID_ECF_DNA]) {
DB_SMT("SMT : ECF test DNA ok");
} else {
DB_SMT("SMT : expected TID %lx, got %x",
smc->sm.pend[SMT_TID_ECF],
sm->smt_tid);
} break ; case SMT_REQUEST :
smc->mib.priv.fddiPRIVECF_Req_Rx++ ;
{ if (sm->smt_len && !sm_to_para(smc,sm,SMT_P_ECHODATA)) {
DB_SMT("SMT: ECF with para problem,sending RDF");
smt_send_rdf(smc,mb,m_fc(mb),SMT_RDF_LENGTH,
local) ; break ;
}
DB_SMT("SMT - sending ECF reply to %pM",
&sm->smt_source);
if (!(mb=smt_build_frame(smc,SMT_RDF,SMT_REPLY,sizeof(struct smt_rdf)))) return ;
rdf = smtod(mb,struct smt_rdf *) ;
rdf->smt.smt_tid = sm->smt_tid ; /* use TID from sm */
rdf->smt.smt_dest = sm->smt_source ; /* set dest = source */
smt_fill_echo(smc,&ecf->ec_echo,tid,len) ; /* set ECHO */
ecf->smt.smt_dest = *dest ; /* destination address */
ecf->smt.smt_tid = tid ; /* transaction ID */
smc->mib.priv.fddiPRIVECF_Req_Tx++ ;
smt_send_frame(smc,mb,fc,0) ;
}
/* *generateandsendSIFconfigresponse
*/
staticvoid smt_send_sif_config(struct s_smc *smc, struct fddi_addr *dest,
u_long tid, int local) /* struct fddi_addr *dest; dest address */ /* u_long tid; transaction id */
{ struct smt_sif_config *sif ;
SMbuf *mb ; int len ; if (!(mb = smt_build_frame(smc,SMT_SIF_CONFIG,SMT_REPLY,
SIZEOF_SMT_SIF_CONFIG))) return ;
sif = smtod(mb, struct smt_sif_config *) ;
smt_fill_timestamp(smc,&sif->ts) ; /* set time stamp */
smt_fill_sde(smc,&sif->sde) ; /* set station descriptor */
smt_fill_version(smc,&sif->version) ; /* set version information */
smt_fill_state(smc,&sif->state) ; /* set state information */
smt_fill_policy(smc,&sif->policy) ; /* set station policy */
smt_fill_latency(smc,&sif->latency); /* set station latency */
smt_fill_neighbor(smc,&sif->neighbor); /* set station neighbor */
smt_fill_setcount(smc,&sif->setcount) ; /* set count */
len = smt_fill_path(smc,&sif->path); /* set station path descriptor*/
sif->smt.smt_dest = *dest ; /* destination address */
sif->smt.smt_tid = tid ; /* transaction ID */
smt_add_frame_len(mb,len) ; /* adjust length fields */
dump_smt(smc,(struct smt_header *)sif,"SIF Configuration Reply") ;
smt_send_frame(smc,mb,FC_SMT_INFO,local) ;
}
/* *generateandsendSIFoperationresponse
*/
staticvoid smt_send_sif_operation(struct s_smc *smc, struct fddi_addr *dest,
u_long tid, int local) /* struct fddi_addr *dest; dest address */ /* u_long tid; transaction id */
{ struct smt_sif_operation *sif ;
SMbuf *mb ; int ports ; int i ;
if (!(mb = smt_build_frame(smc,SMT_SIF_OPER,SMT_REPLY,
struct_size(sif, lem, ports)))) return ;
sif = smtod(mb, typeof(sif));
smt_fill_timestamp(smc,&sif->ts) ; /* set time stamp */
smt_fill_mac_status(smc,&sif->status) ; /* set mac status */
smt_fill_mac_counter(smc,&sif->mc) ; /* set mac counter field */
smt_fill_mac_fnc(smc,&sif->fnc) ; /* set frame not copied counter */
smt_fill_manufacturer(smc,&sif->man) ; /* set manufacturer field */
smt_fill_user(smc,&sif->user) ; /* set user field */
smt_fill_setcount(smc,&sif->setcount) ; /* set count */ /* *setlinkerrormoninformation
*/ if (ports == 1) {
smt_fill_lem(smc,sif->lem,PS) ;
} else { for (i = 0 ; i < ports ; i++) {
smt_fill_lem(smc,&sif->lem[i],i) ;
}
}
out = 0 ;
in = smc->mib.fddiSMTConnectionPolicy ; for (i = 0, map = ansi_weirdness ; i < 16 ; i++) { if (in & 1)
out |= (1<<*map) ;
in >>= 1 ;
map++ ;
}
policy->pl_config = smc->mib.fddiSMTConfigPolicy ;
policy->pl_connect = out ;
}
void smt_swap_para(struct smt_header *sm, int len, int direction) /* int direction; 0 encode 1 decode */
{ struct smt_para *pa ; conststruct smt_pdef *pd ; char *p ; int plen ; int type ; int i ;
/* printf("smt_swap_para sm %x len %d dir %d\n", sm,len,direction);
*/
smt_string_swap((char *)sm,SWAP_SMTHEADER,len) ;
/* swap args */
len -= sizeof(struct smt_header) ;
p = (char *) (sm + 1) ; while (len > 0) {
pa = (struct smt_para *) p ;
plen = pa->p_len ;
type = pa->p_type ;
pa->p_type = smt_swap_short(pa->p_type) ;
pa->p_len = smt_swap_short(pa->p_len) ; if (direction) {
plen = pa->p_len ;
type = pa->p_type ;
} /* *note:parascanhave0length!
*/ if (plen < 0) break ;
plen += PARA_LEN ; for (i = N_SMT_PLEN, pd = smt_pdef; i ; i--,pd++) { if (pd->ptype == type) break ;
} if (i && pd->pswap) {
smt_string_swap(p+PARA_LEN,pd->pswap,len) ;
}
len -= plen ;
p += plen ;
}
}
/* *PMFactions
*/ int smt_action(struct s_smc *smc, intclass, int code, int index)
{ int event ; int port ;
DB_SMT("SMT: action %d code %d", class, code); switch(class) { case SMT_STATION_ACTION : switch(code) { case SMT_STATION_ACTION_CONNECT :
smc->mib.fddiSMTRemoteDisconnectFlag = FALSE ;
queue_event(smc,EVENT_ECM,EC_CONNECT) ; break ; case SMT_STATION_ACTION_DISCONNECT :
queue_event(smc,EVENT_ECM,EC_DISCONNECT) ;
smc->mib.fddiSMTRemoteDisconnectFlag = TRUE ;
RS_SET(smc,RS_DISCONNECT) ;
AIX_EVENT(smc, (u_long) FDDI_RING_STATUS, (u_long)
FDDI_SMT_EVENT, (u_long) FDDI_REMOTE_DISCONNECT,
smt_get_event_word(smc)); break ; case SMT_STATION_ACTION_PATHTEST :
AIX_EVENT(smc, (u_long) FDDI_RING_STATUS, (u_long)
FDDI_SMT_EVENT, (u_long) FDDI_PATH_TEST,
smt_get_event_word(smc)); break ; case SMT_STATION_ACTION_SELFTEST :
AIX_EVENT(smc, (u_long) FDDI_RING_STATUS, (u_long)
FDDI_SMT_EVENT, (u_long) FDDI_REMOTE_SELF_TEST,
smt_get_event_word(smc)); break ; case SMT_STATION_ACTION_DISABLE_A : if (smc->y[PA].pc_mode == PM_PEER) {
RS_SET(smc,RS_EVENT) ;
queue_event(smc,EVENT_PCM+PA,PC_DISABLE) ;
} break ; case SMT_STATION_ACTION_DISABLE_B : if (smc->y[PB].pc_mode == PM_PEER) {
RS_SET(smc,RS_EVENT) ;
queue_event(smc,EVENT_PCM+PB,PC_DISABLE) ;
} break ; case SMT_STATION_ACTION_DISABLE_M : for (port = 0 ; port < NUMPHYS ; port++) { if (smc->mib.p[port].fddiPORTMy_Type != TM) continue ;
RS_SET(smc,RS_EVENT) ;
queue_event(smc,EVENT_PCM+port,PC_DISABLE) ;
} break ; default : return1;
} break ; case SMT_PORT_ACTION : switch(code) { case SMT_PORT_ACTION_ENABLE :
event = PC_ENABLE ; break ; case SMT_PORT_ACTION_DISABLE :
event = PC_DISABLE ; break ; case SMT_PORT_ACTION_MAINT :
event = PC_MAINT ; break ; case SMT_PORT_ACTION_START :
event = PC_START ; break ; case SMT_PORT_ACTION_STOP :
event = PC_STOP ; break ; default : return1;
}
queue_event(smc,EVENT_PCM+index,event) ; break ; default : return1;
} return0;
}
/* *canonicalconversionof<len>bytesbeginningform*data
*/ #ifdef USE_CAN_ADDR staticvoid hwm_conv_can(struct s_smc *smc, char *data, int len)
{ int i ;
SK_UNUSED(smc) ;
for (i = len; i ; i--, data++)
*data = bitrev8(*data);
} #endif
#endif/* no SLIM_SMT */
Messung V0.5 in Prozent
¤ Diese beiden folgenden Angebotsgruppen bietet das Unternehmen0.24Angebot
(Wie Sie bei der Firma Beratungs- und Dienstleistungen beauftragen können 2026-10-11)
¤
Die Informationen auf dieser Webseite wurden
nach bestem Wissen sorgfältig zusammengestellt. Es wird jedoch weder Vollständigkeit, noch Richtigkeit,
noch Qualität der bereit gestellten Informationen zugesichert.
Bemerkung:
Die farbliche Syntaxdarstellung und die Messung sind noch experimentell.