}
}
-
-
struct msrp_attribute *msrp_lookup(struct msrp_attribute *rattrib)
{
struct msrp_attribute *attrib;
} else {
/* compare on the stream ID */
mac_eq =
- memcmp(attrib->attribute.
- talk_listen.StreamID,
- rattrib->attribute.
- talk_listen.StreamID, 8);
+ memcmp(attrib->attribute.talk_listen.
+ StreamID,
+ rattrib->attribute.talk_listen.
+ StreamID, 8);
if (0 == mac_eq)
return attrib;
}
}
} else {
mac_eq =
- memcmp(attrib->attribute.
- talk_listen.StreamID,
- rattrib->attribute.
- talk_listen.StreamID, 8);
+ memcmp(attrib->attribute.talk_listen.
+ StreamID,
+ rattrib->attribute.talk_listen.
+ StreamID, 8);
if (mac_eq < 0) {
/* possible tail insertion ... */
case MSRP_TALKER_ADV_TYPE:
case MSRP_TALKER_FAILED_TYPE:
attrib->attribute.talk_listen.FailureInformation.FailureCode =
- rattrib->attribute.talk_listen.
- FailureInformation.FailureCode;
- memcpy(attrib->attribute.talk_listen.
- FailureInformation.BridgeID,
- rattrib->attribute.talk_listen.
- FailureInformation.BridgeID, 8);
+ rattrib->attribute.talk_listen.FailureInformation.
+ FailureCode;
+ memcpy(attrib->attribute.talk_listen.FailureInformation.
+ BridgeID,
+ rattrib->attribute.talk_listen.FailureInformation.
+ BridgeID, 8);
#ifdef ENABLE_MERGED_LATENCY
attrib->attribute.talk_listen.AccumulatedLatency =
rattrib->attribute.talk_listen.AccumulatedLatency;
#if LOG_MSRP
mrpd_log_printf("MSRP -> mrp_applicant_fsm\n");
#endif
- mrp_applicant_fsm(&(MSRP_db->mrp_db), &(attrib->applicant), MRP_EVENT_TXLA);
+ mrp_applicant_fsm(&(MSRP_db->mrp_db),
+ &(attrib->applicant), MRP_EVENT_TXLA);
mrp_registrar_fsm(&(attrib->registrar),
&(MSRP_db->mrp_db), MRP_EVENT_TXLA);
attrib = attrib->next;
#if LOG_MSRP
mrpd_log_printf("MSRP -> mrp_applicant_fsm\n");
#endif
- mrp_applicant_fsm(&(MSRP_db->mrp_db), &(attrib->applicant), MRP_EVENT_RLA);
+ mrp_applicant_fsm(&(MSRP_db->mrp_db),
+ &(attrib->applicant), MRP_EVENT_RLA);
mrp_registrar_fsm(&(attrib->registrar),
&(MSRP_db->mrp_db), MRP_EVENT_RLA);
attrib = attrib->next;
#if LOG_MSRP
mrpd_log_printf("MSRP -> mrp_applicant_fsm\n");
#endif
- mrp_applicant_fsm(&(MSRP_db->mrp_db), &(attrib->applicant), MRP_EVENT_TX);
+ mrp_applicant_fsm(&(MSRP_db->mrp_db),
+ &(attrib->applicant), MRP_EVENT_TX);
attrib = attrib->next;
}
#if LOG_MSRP
mrpd_log_printf("MSRP -> mrp_applicant_fsm\n");
#endif
- mrp_applicant_fsm(&(MSRP_db->mrp_db), &(attrib->applicant),
+ mrp_applicant_fsm(&(MSRP_db->mrp_db),
+ &(attrib->applicant),
MRP_EVENT_PERIODIC);
attrib = attrib->next;
}
free(rattrib);
}
- mrp_applicant_fsm(&(MSRP_db->mrp_db), &(attrib->applicant), event);
+ mrp_applicant_fsm(&(MSRP_db->mrp_db), &(attrib->applicant),
+ event);
/* remap local requests into registrar events */
switch (event) {
rc = mrp_registrar_fsm(&(attrib->registrar),
&(MSRP_db->mrp_db), event);
if (-1 == rc) {
- printf("MSRP registrar error on attrib->type = %s (%d)\n",
- msrp_attrib_type_string(attrib->type),
- attrib->type);
+ printf
+ ("MSRP registrar error on attrib->type = %s (%d)\n",
+ msrp_attrib_type_string(attrib->type),
+ attrib->type);
}
break;
}
endmarks = 0;
#if LOG_MSRP
- mrpd_log_printf("MSRP msrp_recv_msg() msg addr 0x%X\n", ((int)mrpdu_msg_ptr) & 0x3);
+ mrpd_log_printf("MSRP msrp_recv_msg() msg addr 0x%X\n",
+ ((int)mrpdu_msg_ptr) & 0x3);
#endif
switch (mrpdu_msg->AttributeType) {
&& (mrpdu_msg_ptr[1] == 0))) {
numvalues =
MRPDU_VECT_NUMVALUES(ntohs
- (mrpdu_vectorptr->VectorHeader));
+ (mrpdu_vectorptr->
+ VectorHeader));
if (0 == numvalues) {
/* skip this null attribute ... some switches generate these ... */
srclassprio_firstval =
mrpdu_vectorptr->FirstValue_VectorEvents[1];
srclassvid_firstval = ((uint16_t)
- mrpdu_vectorptr->FirstValue_VectorEvents
+ mrpdu_vectorptr->
+ FirstValue_VectorEvents
[2]) << 8 |
mrpdu_vectorptr->FirstValue_VectorEvents[3];
vectidx <= (numvectorbytes + 4);
vectidx++) {
vect_3pack =
- mrpdu_vectorptr->FirstValue_VectorEvents
- [vectidx];
+ mrpdu_vectorptr->
+ FirstValue_VectorEvents[vectidx];
vectevt[0] = vect_3pack / 36;
vectevt[1] =
(vect_3pack - vectevt[0] * 36) / 6;
goto out; /* oops - internal error */
attrib->type = MSRP_DOMAIN_TYPE;
- attrib->attribute.
- domain.SRclassID =
+ attrib->attribute.domain.
+ SRclassID =
srclassID_firstval;
- attrib->attribute.
- domain.SRclassPriority =
+ attrib->attribute.domain.
+ SRclassPriority =
srclassprio_firstval;
- attrib->attribute.
- domain.SRclassVID =
+ attrib->attribute.domain.
+ SRclassVID =
srclassvid_firstval;
srclassID_firstval++;
srclassprio_firstval++;
- memcpy(attrib->
- registrar.macaddr,
- eth->srcaddr, 6);
+ memcpy(attrib->registrar.
+ macaddr, eth->srcaddr,
+ 6);
switch (vectevt[vectevt_idx]) {
case MRPDU_NEW:
&& (mrpdu_msg_ptr[1] == 0))) {
numvalues =
MRPDU_VECT_NUMVALUES(ntohs
- (mrpdu_vectorptr->VectorHeader));
+ (mrpdu_vectorptr->
+ VectorHeader));
#if LOG_MSRP
- mrpd_log_printf("MSRP msrp_recv_msg() LISTENER vector addr 0x%X, n = %d, VectorHeader (ntohs) %d, VectorHeader read %d\n",
- ((int)mrpdu_vectorptr) & 0x3, numvalues,
- ntohs(mrpdu_vectorptr->VectorHeader),
- ((uint8_t *)mrpdu_vectorptr)[0] << 8 | ((uint8_t *)mrpdu_vectorptr)[1]);
+ mrpd_log_printf
+ ("MSRP msrp_recv_msg() LISTENER vector addr 0x%X, n = %d, VectorHeader (ntohs) %d, VectorHeader read %d\n",
+ ((int)mrpdu_vectorptr) & 0x3, numvalues,
+ ntohs(mrpdu_vectorptr->VectorHeader),
+ ((uint8_t *) mrpdu_vectorptr)[0] << 8 |
+ ((uint8_t *) mrpdu_vectorptr)[1]);
#endif
-
-
if (0 == numvalues) {
/* 2 byte numvalues + 8 byte FirstValue + (0) vector bytes */
mrpdu_msg_ptr =
for (; vectidx < listener_endbyte; vectidx++) {
vect_4pack =
- mrpdu_vectorptr->FirstValue_VectorEvents
- [vectidx];
+ mrpdu_vectorptr->
+ FirstValue_VectorEvents[vectidx];
vectevt[3] =
vect_4pack -
numvalues =
MRPDU_VECT_NUMVALUES(ntohs
- (mrpdu_vectorptr->VectorHeader));
+ (mrpdu_vectorptr->
+ VectorHeader));
/* if not an even multiple ... */
if (numvalues != ((numvalues / 3) * 3))
vectidx <= (numvectorbytes + 8);
vectidx++) {
vect_3pack =
- mrpdu_vectorptr->FirstValue_VectorEvents
- [vectidx];
+ mrpdu_vectorptr->
+ FirstValue_VectorEvents[vectidx];
vectevt[0] = vect_3pack / 36;
vectevt[1] =
(vect_3pack - vectevt[0] * 36) / 6;
attrib->type =
MSRP_LISTENER_TYPE;
- memcpy(attrib->
- attribute.talk_listen.
- StreamID,
+ memcpy(attrib->attribute.
+ talk_listen.StreamID,
streamid_firstval, 8);
attrib->substate =
listener_vectevt
(streamid_firstval);
listener_vectevt_idx++;
- memcpy(attrib->
- registrar.macaddr,
- eth->srcaddr, 6);
+ memcpy(attrib->registrar.
+ macaddr, eth->srcaddr,
+ 6);
#if LOG_MSRP
- mrpd_log_printf("MSRP msrp_recv_msg() Listener[%d][%d] attrib %d\n",
- vectidx,
- vectevt_idx,
- vectevt[vectevt_idx]);
+ mrpd_log_printf
+ ("MSRP msrp_recv_msg() Listener[%d][%d] attrib %d\n",
+ vectidx, vectevt_idx,
+ vectevt[vectevt_idx]);
#endif
switch (vectevt[vectevt_idx]) {
numvalues =
MRPDU_VECT_NUMVALUES(ntohs
- (mrpdu_vectorptr->VectorHeader));
+ (mrpdu_vectorptr->
+ VectorHeader));
if (numvalues != ((numvalues / 4) * 4))
numvectorbytes += (numvalues / 4) + 1;
else
&& (mrpdu_msg_ptr[1] == 0))) {
numvalues =
MRPDU_VECT_NUMVALUES(ntohs
- (mrpdu_vectorptr->VectorHeader));
+ (mrpdu_vectorptr->
+ VectorHeader));
if (0 == numvalues) {
/* 2 byte numvalues + 25 byte FirstValue + (0) vector bytes */
vectidx <= (numvectorbytes + 25);
vectidx++) {
vect_3pack =
- mrpdu_vectorptr->FirstValue_VectorEvents
- [vectidx];
+ mrpdu_vectorptr->
+ FirstValue_VectorEvents[vectidx];
vectevt[0] = vect_3pack / 36;
vectevt[1] =
(vect_3pack - vectevt[0] * 36) / 6;
attrib->direction =
MSRP_DIRECTION_LISTENER;
- memcpy(attrib->
- attribute.talk_listen.
- StreamID,
+ memcpy(attrib->attribute.
+ talk_listen.StreamID,
streamid_firstval, 8);
- memcpy(attrib->
- attribute.talk_listen.DataFrameParameters.Dest_Addr,
+ memcpy(attrib->attribute.
+ talk_listen.
+ DataFrameParameters.
+ Dest_Addr,
destmac_firstval, 6);
msrp_increment_streamid
mmrp_increment_macaddr
(destmac_firstval);
- attrib->attribute.
- talk_listen.DataFrameParameters.Vlan_ID
- =
- mrpdu_vectorptr->FirstValue_VectorEvents
- [14];
- attrib->attribute.
- talk_listen.DataFrameParameters.Vlan_ID
- <<= 8;
- attrib->attribute.
- talk_listen.DataFrameParameters.Vlan_ID
- |=
- mrpdu_vectorptr->FirstValue_VectorEvents
- [15];
-
- attrib->attribute.
- talk_listen.TSpec.
- MaxFrameSize =
- mrpdu_vectorptr->FirstValue_VectorEvents
- [16];
- attrib->attribute.
- talk_listen.TSpec.
- MaxFrameSize <<= 8;
- attrib->attribute.
- talk_listen.TSpec.
- MaxFrameSize |=
- mrpdu_vectorptr->FirstValue_VectorEvents
- [17];
-
- attrib->attribute.
- talk_listen.TSpec.
- MaxIntervalFrames =
- mrpdu_vectorptr->FirstValue_VectorEvents
- [18];
- attrib->attribute.
- talk_listen.TSpec.MaxIntervalFrames
- <<= 8;
- attrib->attribute.
- talk_listen.TSpec.
- MaxIntervalFrames |=
- mrpdu_vectorptr->FirstValue_VectorEvents
- [19];
-
- attrib->attribute.
- talk_listen.PriorityAndRank
- =
- mrpdu_vectorptr->FirstValue_VectorEvents
- [20];
-
- attrib->attribute.
- talk_listen.AccumulatedLatency
- =
- mrpdu_vectorptr->FirstValue_VectorEvents
- [21];
- attrib->attribute.
- talk_listen.AccumulatedLatency
- <<= 8;
- attrib->attribute.
- talk_listen.AccumulatedLatency
- |=
- mrpdu_vectorptr->FirstValue_VectorEvents
- [22];
- attrib->attribute.
- talk_listen.AccumulatedLatency
- <<= 8;
- attrib->attribute.
- talk_listen.AccumulatedLatency
- |=
- mrpdu_vectorptr->FirstValue_VectorEvents
- [23];
- attrib->attribute.
- talk_listen.AccumulatedLatency
- <<= 8;
- attrib->attribute.
- talk_listen.AccumulatedLatency
- |=
- mrpdu_vectorptr->FirstValue_VectorEvents
- [24];
-
- memcpy(attrib->
- registrar.macaddr,
- eth->srcaddr, 6);
+ attrib->attribute.talk_listen.
+ DataFrameParameters.
+ Vlan_ID =
+ mrpdu_vectorptr->
+ FirstValue_VectorEvents[14];
+ attrib->attribute.talk_listen.
+ DataFrameParameters.
+ Vlan_ID <<= 8;
+ attrib->attribute.talk_listen.
+ DataFrameParameters.
+ Vlan_ID |=
+ mrpdu_vectorptr->
+ FirstValue_VectorEvents[15];
+
+ attrib->attribute.talk_listen.
+ TSpec.MaxFrameSize =
+ mrpdu_vectorptr->
+ FirstValue_VectorEvents[16];
+ attrib->attribute.talk_listen.
+ TSpec.MaxFrameSize <<= 8;
+ attrib->attribute.talk_listen.
+ TSpec.MaxFrameSize |=
+ mrpdu_vectorptr->
+ FirstValue_VectorEvents[17];
+
+ attrib->attribute.talk_listen.
+ TSpec.MaxIntervalFrames =
+ mrpdu_vectorptr->
+ FirstValue_VectorEvents[18];
+ attrib->attribute.talk_listen.
+ TSpec.
+ MaxIntervalFrames <<= 8;
+ attrib->attribute.talk_listen.
+ TSpec.MaxIntervalFrames |=
+ mrpdu_vectorptr->
+ FirstValue_VectorEvents[19];
+
+ attrib->attribute.talk_listen.
+ PriorityAndRank =
+ mrpdu_vectorptr->
+ FirstValue_VectorEvents[20];
+
+ attrib->attribute.talk_listen.
+ AccumulatedLatency =
+ mrpdu_vectorptr->
+ FirstValue_VectorEvents[21];
+ attrib->attribute.talk_listen.
+ AccumulatedLatency <<= 8;
+ attrib->attribute.talk_listen.
+ AccumulatedLatency |=
+ mrpdu_vectorptr->
+ FirstValue_VectorEvents[22];
+ attrib->attribute.talk_listen.
+ AccumulatedLatency <<= 8;
+ attrib->attribute.talk_listen.
+ AccumulatedLatency |=
+ mrpdu_vectorptr->
+ FirstValue_VectorEvents[23];
+ attrib->attribute.talk_listen.
+ AccumulatedLatency <<= 8;
+ attrib->attribute.talk_listen.
+ AccumulatedLatency |=
+ mrpdu_vectorptr->
+ FirstValue_VectorEvents[24];
+
+ memcpy(attrib->registrar.
+ macaddr, eth->srcaddr,
+ 6);
#if LOG_MSRP
- mrpd_log_printf("MSRP msrp_recv_msg() TalkerAdv[%d][%d] attrib %d\n",
- vectidx,
- vectevt_idx,
- vectevt[vectevt_idx]);
+ mrpd_log_printf
+ ("MSRP msrp_recv_msg() TalkerAdv[%d][%d] attrib %d\n",
+ vectidx, vectevt_idx,
+ vectevt[vectevt_idx]);
#endif
switch (vectevt[vectevt_idx]) {
&& (mrpdu_msg_ptr[1] == 0))) {
numvalues =
MRPDU_VECT_NUMVALUES(ntohs
- (mrpdu_vectorptr->VectorHeader));
+ (mrpdu_vectorptr->
+ VectorHeader));
if (0 == numvalues) {
/* 2 byte numvalues + 34 byte FirstValue + (0) vector bytes */
vectidx <= (numvectorbytes + 34);
vectidx++) {
vect_3pack =
- mrpdu_vectorptr->FirstValue_VectorEvents
- [vectidx];
+ mrpdu_vectorptr->
+ FirstValue_VectorEvents[vectidx];
vectevt[0] = vect_3pack / 36;
vectevt[1] =
(vect_3pack - vectevt[0] * 36) / 6;
attrib->direction =
MSRP_DIRECTION_LISTENER;
- memcpy(attrib->
- attribute.talk_listen.
- StreamID,
+ memcpy(attrib->attribute.
+ talk_listen.StreamID,
streamid_firstval, 8);
- memcpy(attrib->
- attribute.talk_listen.DataFrameParameters.Dest_Addr,
+ memcpy(attrib->attribute.
+ talk_listen.
+ DataFrameParameters.
+ Dest_Addr,
destmac_firstval, 6);
msrp_increment_streamid
mmrp_increment_macaddr
(destmac_firstval);
- attrib->attribute.
- talk_listen.DataFrameParameters.Vlan_ID
- =
- mrpdu_vectorptr->FirstValue_VectorEvents
- [14];
- attrib->attribute.
- talk_listen.DataFrameParameters.Vlan_ID
- <<= 8;
- attrib->attribute.
- talk_listen.DataFrameParameters.Vlan_ID
- |=
- mrpdu_vectorptr->FirstValue_VectorEvents
- [15];
-
- attrib->attribute.
- talk_listen.TSpec.
- MaxFrameSize =
- mrpdu_vectorptr->FirstValue_VectorEvents
- [16];
- attrib->attribute.
- talk_listen.TSpec.
- MaxFrameSize <<= 8;
- attrib->attribute.
- talk_listen.TSpec.
- MaxFrameSize |=
- mrpdu_vectorptr->FirstValue_VectorEvents
- [17];
-
- attrib->attribute.
- talk_listen.TSpec.
- MaxIntervalFrames =
- mrpdu_vectorptr->FirstValue_VectorEvents
- [18];
- attrib->attribute.
- talk_listen.TSpec.MaxIntervalFrames
- <<= 8;
- attrib->attribute.
- talk_listen.TSpec.
- MaxIntervalFrames |=
- mrpdu_vectorptr->FirstValue_VectorEvents
- [19];
-
- attrib->attribute.
- talk_listen.PriorityAndRank
- =
- mrpdu_vectorptr->FirstValue_VectorEvents
- [20];
-
- attrib->attribute.
- talk_listen.AccumulatedLatency
- =
- mrpdu_vectorptr->FirstValue_VectorEvents
- [21];
- attrib->attribute.
- talk_listen.AccumulatedLatency
- <<= 8;
- attrib->attribute.
- talk_listen.AccumulatedLatency
- |=
- mrpdu_vectorptr->FirstValue_VectorEvents
- [22];
- attrib->attribute.
- talk_listen.AccumulatedLatency
- <<= 8;
- attrib->attribute.
- talk_listen.AccumulatedLatency
- |=
- mrpdu_vectorptr->FirstValue_VectorEvents
- [23];
- attrib->attribute.
- talk_listen.AccumulatedLatency
- <<= 8;
- attrib->attribute.
- talk_listen.AccumulatedLatency
- |=
- mrpdu_vectorptr->FirstValue_VectorEvents
- [24];
-
- memcpy(attrib->
- attribute.talk_listen.FailureInformation.BridgeID,
- &
- (mrpdu_vectorptr->FirstValue_VectorEvents
- [25]), 8);
-
- attrib->attribute.
- talk_listen.FailureInformation.FailureCode
- =
- mrpdu_vectorptr->FirstValue_VectorEvents
- [33];
-
- memcpy(attrib->
- registrar.macaddr,
- eth->srcaddr, 6);
+ attrib->attribute.talk_listen.
+ DataFrameParameters.
+ Vlan_ID =
+ mrpdu_vectorptr->
+ FirstValue_VectorEvents[14];
+ attrib->attribute.talk_listen.
+ DataFrameParameters.
+ Vlan_ID <<= 8;
+ attrib->attribute.talk_listen.
+ DataFrameParameters.
+ Vlan_ID |=
+ mrpdu_vectorptr->
+ FirstValue_VectorEvents[15];
+
+ attrib->attribute.talk_listen.
+ TSpec.MaxFrameSize =
+ mrpdu_vectorptr->
+ FirstValue_VectorEvents[16];
+ attrib->attribute.talk_listen.
+ TSpec.MaxFrameSize <<= 8;
+ attrib->attribute.talk_listen.
+ TSpec.MaxFrameSize |=
+ mrpdu_vectorptr->
+ FirstValue_VectorEvents[17];
+
+ attrib->attribute.talk_listen.
+ TSpec.MaxIntervalFrames =
+ mrpdu_vectorptr->
+ FirstValue_VectorEvents[18];
+ attrib->attribute.talk_listen.
+ TSpec.
+ MaxIntervalFrames <<= 8;
+ attrib->attribute.talk_listen.
+ TSpec.MaxIntervalFrames |=
+ mrpdu_vectorptr->
+ FirstValue_VectorEvents[19];
+
+ attrib->attribute.talk_listen.
+ PriorityAndRank =
+ mrpdu_vectorptr->
+ FirstValue_VectorEvents[20];
+
+ attrib->attribute.talk_listen.
+ AccumulatedLatency =
+ mrpdu_vectorptr->
+ FirstValue_VectorEvents[21];
+ attrib->attribute.talk_listen.
+ AccumulatedLatency <<= 8;
+ attrib->attribute.talk_listen.
+ AccumulatedLatency |=
+ mrpdu_vectorptr->
+ FirstValue_VectorEvents[22];
+ attrib->attribute.talk_listen.
+ AccumulatedLatency <<= 8;
+ attrib->attribute.talk_listen.
+ AccumulatedLatency |=
+ mrpdu_vectorptr->
+ FirstValue_VectorEvents[23];
+ attrib->attribute.talk_listen.
+ AccumulatedLatency <<= 8;
+ attrib->attribute.talk_listen.
+ AccumulatedLatency |=
+ mrpdu_vectorptr->
+ FirstValue_VectorEvents[24];
+
+ memcpy(attrib->attribute.
+ talk_listen.
+ FailureInformation.
+ BridgeID,
+ &(mrpdu_vectorptr->
+ FirstValue_VectorEvents
+ [25]), 8);
+
+ attrib->attribute.talk_listen.
+ FailureInformation.
+ FailureCode =
+ mrpdu_vectorptr->
+ FirstValue_VectorEvents[33];
+
+ memcpy(attrib->registrar.
+ macaddr, eth->srcaddr,
+ 6);
switch (vectevt[vectevt_idx]) {
case MRPDU_NEW:
* we can seek for an endmark to recover .. but this version
* dumps the entire packet as malformed
*/
- printf("################## unrecognized attribute type (%d)\n",
- mrpdu_msg->AttributeType);
+ printf
+ ("################## unrecognized attribute type (%d)\n",
+ mrpdu_msg->AttributeType);
goto out;
}
}
int
msrp_emit_domainvectors(unsigned char *msgbuf, unsigned char *msgbuf_eof,
- int *bytes_used, int lva)
+ int *bytes_used, int lva)
{
mrpdu_vectorattrib_t *mrpdu_vectorptr;
uint16_t numvalues;
attrib = MSRP_db->attrib_list;
- mrpdu_vectorptr = (mrpdu_vectorattrib_t *)&(mrpdu_msg->Data[2]);
+ mrpdu_vectorptr = (mrpdu_vectorattrib_t *) & (mrpdu_msg->Data[2]);
while ((mrpdu_msg_ptr < (mrpdu_msg_eof - 2)) && (NULL != attrib)) {
srclassprio_firstval = attrib->attribute.domain.SRclassPriority;
srclassvid_firstval = attrib->attribute.domain.SRclassVID;
-
- mrpdu_vectorptr->FirstValue_VectorEvents[0] = srclassID_firstval;
- mrpdu_vectorptr->FirstValue_VectorEvents[1] = srclassprio_firstval;
- mrpdu_vectorptr->FirstValue_VectorEvents[2] = (uint8_t)(srclassvid_firstval >> 8);
- mrpdu_vectorptr->FirstValue_VectorEvents[3] = (uint8_t)srclassvid_firstval;
+ mrpdu_vectorptr->FirstValue_VectorEvents[0] =
+ srclassID_firstval;
+ mrpdu_vectorptr->FirstValue_VectorEvents[1] =
+ srclassprio_firstval;
+ mrpdu_vectorptr->FirstValue_VectorEvents[2] =
+ (uint8_t) (srclassvid_firstval >> 8);
+ mrpdu_vectorptr->FirstValue_VectorEvents[3] =
+ (uint8_t) srclassvid_firstval;
switch (attrib->applicant.sndmsg) {
case MRP_SND_IN:
srclassID_firstval++;
srclassprio_firstval++;
- if (srclassID_firstval != vattrib->attribute.domain.SRclassID)
+ if (srclassID_firstval !=
+ vattrib->attribute.domain.SRclassID)
break;
vattrib->applicant.tx = 0;
vectevt[1],
vectevt[2]);
- mrpdu_vectorptr->
- FirstValue_VectorEvents[vectidx] =
- vect_3pack;
+ mrpdu_vectorptr->FirstValue_VectorEvents
+ [vectidx] = vect_3pack;
vectidx++;
vectevt[0] = 0;
vectevt[1] = 0;
}
- if (mrpdu_vectorptr == (mrpdu_vectorattrib_t *)&(mrpdu_msg->Data[2])) {
+ if (mrpdu_vectorptr == (mrpdu_vectorattrib_t *) & (mrpdu_msg->Data[2])) {
*bytes_used = 0;
return 0;
}
return -1;
}
-
-
-
int
msrp_emit_talkvectors(unsigned char *msgbuf, unsigned char *msgbuf_eof,
int *bytes_used, int lva)
memcpy(streamid_firstval,
attrib->attribute.talk_listen.StreamID, 8);
memcpy(destmac_firstval,
- attrib->attribute.talk_listen.
- DataFrameParameters.Dest_Addr, 6);
+ attrib->attribute.talk_listen.DataFrameParameters.
+ Dest_Addr, 6);
memcpy(mrpdu_vectorptr->FirstValue_VectorEvents,
streamid_firstval, 8);
memcpy(&(mrpdu_vectorptr->FirstValue_VectorEvents[8]),
destmac_firstval, 6);
mrpdu_vectorptr->FirstValue_VectorEvents[14] =
- attrib->attribute.talk_listen.
- DataFrameParameters.Vlan_ID >> 8;
+ attrib->attribute.talk_listen.DataFrameParameters.
+ Vlan_ID >> 8;
mrpdu_vectorptr->FirstValue_VectorEvents[15] =
- (uint8_t) attrib->attribute.talk_listen.DataFrameParameters.
- Vlan_ID;
+ (uint8_t) attrib->attribute.talk_listen.
+ DataFrameParameters.Vlan_ID;
mrpdu_vectorptr->FirstValue_VectorEvents[16] =
attrib->attribute.talk_listen.TSpec.MaxFrameSize >> 8;
mrpdu_vectorptr->FirstValue_VectorEvents[18] =
attrib->attribute.talk_listen.TSpec.MaxIntervalFrames >> 8;
mrpdu_vectorptr->FirstValue_VectorEvents[19] =
- (uint8_t) attrib->attribute.talk_listen.TSpec.
- MaxIntervalFrames;
+ (uint8_t) attrib->attribute.talk_listen.
+ TSpec.MaxIntervalFrames;
mrpdu_vectorptr->FirstValue_VectorEvents[20] =
attrib->attribute.talk_listen.PriorityAndRank;
* so mark all as ready.
*/
attrib = MSRP_db->attrib_list;
- while(attrib) {
+ while (attrib) {
if (MSRP_LISTENER_TYPE == attrib->type) {
attrib->applicant.tx = 1;
}
goto oops;
vect_4pack =
- MRPDU_4PACK_ENCODE(listen_declare
- [listen_declare_idx],
- listen_declare
- [listen_declare_idx + 1],
- listen_declare
- [listen_declare_idx + 2],
- listen_declare
- [listen_declare_idx +
- 3]);
+ MRPDU_4PACK_ENCODE(listen_declare
+ [listen_declare_idx],
+ listen_declare
+ [listen_declare_idx + 1],
+ listen_declare
+ [listen_declare_idx + 2],
+ listen_declare
+ [listen_declare_idx + 3]);
mrpdu_vectorptr->FirstValue_VectorEvents
- [vectidx] = vect_4pack;
+ [vectidx] = vect_4pack;
vectidx++;
if (&(mrpdu_vectorptr->FirstValue_VectorEvents[vectidx])
attrib->attribute.talk_listen.StreamID[5],
attrib->attribute.talk_listen.StreamID[6],
attrib->attribute.talk_listen.StreamID[7],
- attrib->attribute.talk_listen.
- DataFrameParameters.Dest_Addr[0],
- attrib->attribute.talk_listen.
- DataFrameParameters.Dest_Addr[1],
- attrib->attribute.talk_listen.
- DataFrameParameters.Dest_Addr[2],
- attrib->attribute.talk_listen.
- DataFrameParameters.Dest_Addr[3],
- attrib->attribute.talk_listen.
- DataFrameParameters.Dest_Addr[4],
- attrib->attribute.talk_listen.
- DataFrameParameters.Dest_Addr[5],
- attrib->attribute.talk_listen.
- DataFrameParameters.Vlan_ID,
+ attrib->attribute.talk_listen.DataFrameParameters.
+ Dest_Addr[0],
+ attrib->attribute.talk_listen.DataFrameParameters.
+ Dest_Addr[1],
+ attrib->attribute.talk_listen.DataFrameParameters.
+ Dest_Addr[2],
+ attrib->attribute.talk_listen.DataFrameParameters.
+ Dest_Addr[3],
+ attrib->attribute.talk_listen.DataFrameParameters.
+ Dest_Addr[4],
+ attrib->attribute.talk_listen.DataFrameParameters.
+ Dest_Addr[5],
+ attrib->attribute.talk_listen.DataFrameParameters.
+ Vlan_ID,
attrib->attribute.talk_listen.TSpec.MaxFrameSize,
attrib->attribute.talk_listen.TSpec.MaxIntervalFrames,
attrib->attribute.talk_listen.PriorityAndRank,
attrib->attribute.talk_listen.AccumulatedLatency,
- attrib->attribute.talk_listen.
- FailureInformation.BridgeID[0],
- attrib->attribute.talk_listen.
- FailureInformation.BridgeID[1],
- attrib->attribute.talk_listen.
- FailureInformation.BridgeID[2],
- attrib->attribute.talk_listen.
- FailureInformation.BridgeID[3],
- attrib->attribute.talk_listen.
- FailureInformation.BridgeID[4],
- attrib->attribute.talk_listen.
- FailureInformation.BridgeID[5],
- attrib->attribute.talk_listen.
- FailureInformation.BridgeID[6],
- attrib->attribute.talk_listen.
- FailureInformation.BridgeID[7],
- attrib->attribute.talk_listen.
- FailureInformation.FailureCode);
+ attrib->attribute.talk_listen.FailureInformation.
+ BridgeID[0],
+ attrib->attribute.talk_listen.FailureInformation.
+ BridgeID[1],
+ attrib->attribute.talk_listen.FailureInformation.
+ BridgeID[2],
+ attrib->attribute.talk_listen.FailureInformation.
+ BridgeID[3],
+ attrib->attribute.talk_listen.FailureInformation.
+ BridgeID[4],
+ attrib->attribute.talk_listen.FailureInformation.
+ BridgeID[5],
+ attrib->attribute.talk_listen.FailureInformation.
+ BridgeID[6],
+ attrib->attribute.talk_listen.FailureInformation.
+ BridgeID[7],
+ attrib->attribute.talk_listen.FailureInformation.
+ FailureCode);
}
sprintf(regsrc, "R=%02x%02x%02x%02x%02x%02x",
attrib->attribute.talk_listen.StreamID[5],
attrib->attribute.talk_listen.StreamID[6],
attrib->attribute.talk_listen.StreamID[7],
- attrib->attribute.
- talk_listen.DataFrameParameters.Dest_Addr[0],
- attrib->attribute.
- talk_listen.DataFrameParameters.Dest_Addr[1],
- attrib->attribute.
- talk_listen.DataFrameParameters.Dest_Addr[2],
- attrib->attribute.
- talk_listen.DataFrameParameters.Dest_Addr[3],
- attrib->attribute.
- talk_listen.DataFrameParameters.Dest_Addr[4],
- attrib->attribute.
- talk_listen.DataFrameParameters.Dest_Addr[5],
- attrib->attribute.
- talk_listen.DataFrameParameters.Vlan_ID,
attrib->attribute.talk_listen.
- TSpec.MaxFrameSize,
+ DataFrameParameters.Dest_Addr[0],
+ attrib->attribute.talk_listen.
+ DataFrameParameters.Dest_Addr[1],
attrib->attribute.talk_listen.
- TSpec.MaxIntervalFrames,
+ DataFrameParameters.Dest_Addr[2],
+ attrib->attribute.talk_listen.
+ DataFrameParameters.Dest_Addr[3],
+ attrib->attribute.talk_listen.
+ DataFrameParameters.Dest_Addr[4],
+ attrib->attribute.talk_listen.
+ DataFrameParameters.Dest_Addr[5],
+ attrib->attribute.talk_listen.
+ DataFrameParameters.Vlan_ID,
+ attrib->attribute.talk_listen.TSpec.
+ MaxFrameSize,
+ attrib->attribute.talk_listen.TSpec.
+ MaxIntervalFrames,
attrib->attribute.talk_listen.PriorityAndRank,
- attrib->attribute.
- talk_listen.AccumulatedLatency,
- attrib->attribute.
- talk_listen.FailureInformation.BridgeID[0],
- attrib->attribute.
- talk_listen.FailureInformation.BridgeID[1],
- attrib->attribute.
- talk_listen.FailureInformation.BridgeID[2],
- attrib->attribute.
- talk_listen.FailureInformation.BridgeID[3],
- attrib->attribute.
- talk_listen.FailureInformation.BridgeID[4],
- attrib->attribute.
- talk_listen.FailureInformation.BridgeID[5],
- attrib->attribute.
- talk_listen.FailureInformation.BridgeID[6],
- attrib->attribute.
- talk_listen.FailureInformation.BridgeID[7],
- attrib->attribute.
- talk_listen.FailureInformation.FailureCode);
+ attrib->attribute.talk_listen.
+ AccumulatedLatency,
+ attrib->attribute.talk_listen.
+ FailureInformation.BridgeID[0],
+ attrib->attribute.talk_listen.
+ FailureInformation.BridgeID[1],
+ attrib->attribute.talk_listen.
+ FailureInformation.BridgeID[2],
+ attrib->attribute.talk_listen.
+ FailureInformation.BridgeID[3],
+ attrib->attribute.talk_listen.
+ FailureInformation.BridgeID[4],
+ attrib->attribute.talk_listen.
+ FailureInformation.BridgeID[5],
+ attrib->attribute.talk_listen.
+ FailureInformation.BridgeID[6],
+ attrib->attribute.talk_listen.
+ FailureInformation.BridgeID[7],
+ attrib->attribute.talk_listen.
+ FailureInformation.FailureCode);
}
mrp_decode_state(&attrib->registrar, &attrib->applicant,
/* S+? - (re)JOIN a stream */
/* S++ - NEW a stream */
static int msrp_cmd_parse_join_or_new_stream(char *buf, int buflen,
- struct msrpdu_talker_fail *talker_ad,
- int *err_index)
+ struct msrpdu_talker_fail
+ *talker_ad, int *err_index)
{
struct parse_param specs[] = {
{"S" PARSE_ASSIGN, parse_c64, talker_ad->StreamID},
*
*/
-static int msrp_cmd_join_or_new_stream(struct msrpdu_talker_fail *talker_ad, int mrp_event)
+static int msrp_cmd_join_or_new_stream(struct msrpdu_talker_fail *talker_ad,
+ int mrp_event)
{
struct msrp_attribute *attrib;
/* S-- - LV a stream */
static int msrp_cmd_parse_leave_stream(char *buf, int buflen,
- struct msrpdu_talker_fail *talker_ad,
- int *err_index)
+ struct msrpdu_talker_fail *talker_ad,
+ int *err_index)
{
struct parse_param specs[] = {
{"S" PARSE_ASSIGN, parse_c64, talker_ad->StreamID},
/* S+L Report a listener status */
static int msrp_cmd_parse_report_listener_status(char *buf, int buflen,
- struct msrpdu_talker_fail *talker_ad,
- uint32_t * substate, int *err_index)
+ struct msrpdu_talker_fail
+ *talker_ad,
+ uint32_t * substate,
+ int *err_index)
{
struct parse_param specs[] = {
{"L" PARSE_ASSIGN, parse_c64, talker_ad->StreamID},
}
static int msrp_cmd_report_listener_status(struct msrpdu_talker_fail *talker_ad,
- uint32_t substate)
+ uint32_t substate)
{
struct msrp_attribute *attrib;
}
/* S-L Withdraw a listener status */
-static int msrp_cmd_parse_withdraw_listener_status(char *buf, int buflen,
- struct msrpdu_talker_fail
- *talker_ad, int *err_index)
+static int msrp_cmd_parse_withdraw_listener_status(char *buf, int buflen, struct msrpdu_talker_fail
+ *talker_ad, int *err_index)
{
struct parse_param specs[] = {
{"L" PARSE_ASSIGN, parse_c64, talker_ad->StreamID},
return parse(buf + 4, buflen - 4, specs, err_index);
}
-static int msrp_cmd_withdraw_listener_status(struct msrpdu_talker_fail *talker_ad)
+static int msrp_cmd_withdraw_listener_status(struct msrpdu_talker_fail
+ *talker_ad)
{
struct msrp_attribute *attrib;
/* S+D Report a domain status */
/* S-D Withdraw a domain status */
static int msrp_cmd_parse_domain_status(char *buf, int buflen,
- struct msrpdu_domain *domain, int *err_index)
+ struct msrpdu_domain *domain,
+ int *err_index)
{
struct parse_param specs[] = {
{"C" PARSE_ASSIGN, parse_u8, &domain->SRclassID},
return parse(buf + 4, buflen - 4, specs, err_index);
}
-static int msrp_cmd_report_domain_status(struct msrpdu_domain *domain, int report)
+static int msrp_cmd_report_domain_status(struct msrpdu_domain *domain,
+ int report)
{
struct msrp_attribute *attrib;