diff options
author | Adam Mitz <mitza-oci@users.noreply.github.com> | 2007-02-01 23:15:16 +0000 |
---|---|---|
committer | Adam Mitz <mitza-oci@users.noreply.github.com> | 2007-02-01 23:15:16 +0000 |
commit | 90e6bf59320e26594892053700cccf80511ed642 (patch) | |
tree | 608f63eeaed485e2510e783d35efcfce0eba95ec | |
parent | 4a12960df16eddb53ec59de893600ce3e3cd283e (diff) | |
download | ATCD-90e6bf59320e26594892053700cccf80511ed642.tar.gz |
Thu Feb 1 22:47:04 UTC 2007 Adam Mitz <mitza@ociweb.com>
-rw-r--r-- | TAO/ChangeLog | 10 | ||||
-rw-r--r-- | TAO/orbsvcs/orbsvcs/AV/RTCP_Packet.cpp | 94 | ||||
-rw-r--r-- | TAO/orbsvcs/orbsvcs/Event/ECG_CDR_Message_Receiver.cpp | 2 | ||||
-rw-r--r-- | TAO/orbsvcs/orbsvcs/Event/ECG_CDR_Message_Sender.cpp | 2 |
4 files changed, 59 insertions, 49 deletions
diff --git a/TAO/ChangeLog b/TAO/ChangeLog index 49999991ea6..89fe0e89281 100644 --- a/TAO/ChangeLog +++ b/TAO/ChangeLog @@ -1,3 +1,13 @@ +Thu Feb 1 22:47:04 UTC 2007 Adam Mitz <mitza@ociweb.com> + + * orbsvcs/orbsvcs/AV/RTCP_Packet.cpp: + * orbsvcs/orbsvcs/Event/ECG_CDR_Message_Receiver.cpp: + * orbsvcs/orbsvcs/Event/ECG_CDR_Message_Sender.cpp: + + Replaced htonl, htons, ntohl, and ntohs with the appropriate + ACE_XTOYZ macro (ACE_HTONL, for example). QNX doesn't have htonl and + friends without adding extra #includes. + Thu Feb 1 18:08:03 UTC 2007 Jeff Parsons <j.parsons@vanderbilt.edu> * TAO_IDL/include/ast_typedef.h: diff --git a/TAO/orbsvcs/orbsvcs/AV/RTCP_Packet.cpp b/TAO/orbsvcs/orbsvcs/AV/RTCP_Packet.cpp index 8ef82e30bb3..6bcfea4031d 100644 --- a/TAO/orbsvcs/orbsvcs/AV/RTCP_Packet.cpp +++ b/TAO/orbsvcs/orbsvcs/AV/RTCP_Packet.cpp @@ -25,7 +25,7 @@ RTCP_Packet::RTCP_Packet(char* buffer) this->chd_.pad_ = (buffer[0] & 0x20) >> 5; this->chd_.count_ = buffer[0] & 0x1F; this->chd_.pt_ = buffer[1]; - this->chd_.length_ = ntohs(*(ACE_UINT16*)&buffer[2]); + this->chd_.length_ = ACE_NTOHS(*(ACE_UINT16*)&buffer[2]); this->packet_data_ = 0; } @@ -130,7 +130,7 @@ RTCP_BYE_Packet::RTCP_BYE_Packet(char* buffer, int *len) // Store the source ids of the sources leaving the session for (j=0; j<this->chd_.count_; j++) { - this->ssrc_list_[j] = ntohl(*(ACE_UINT32*)&buffer[index]); + this->ssrc_list_[j] = ACE_NTOHL(*(ACE_UINT32*)&buffer[index]); index+=4; } @@ -223,12 +223,12 @@ RTCP_BYE_Packet::build_packet(void) index++; this->packet_data_[index] = this->chd_.pt_; index++; - *((ACE_UINT16*)&this->packet_data_[index]) = htons(this->chd_.length_); + *((ACE_UINT16*)&this->packet_data_[index]) = ACE_HTONS(this->chd_.length_); index+=2; for (i=0; i<this->chd_.count_; i++) { - *((ACE_UINT32*)&this->packet_data_[index]) = htonl(this->ssrc_list_[i]); + *((ACE_UINT32*)&this->packet_data_[index]) = ACE_HTONL(this->ssrc_list_[i]); index+=4; } @@ -302,7 +302,7 @@ RTCP_RR_Packet::RTCP_RR_Packet (char* buffer, // The common part of the header is initialized in the parent. i=4; - this->ssrc_ = ntohl(*(ACE_UINT32*)&buffer[i]); + this->ssrc_ = ACE_NTOHL(*(ACE_UINT32*)&buffer[i]); i+=4; for (unsigned int j=0; j<this->chd_.count_; j++) { @@ -320,19 +320,19 @@ RTCP_RR_Packet::RTCP_RR_Packet (char* buffer, } local_block_ptr->next_ = 0; - local_block_ptr->ssrc_ = ntohl(*(ACE_UINT32*)&buffer[i]); + local_block_ptr->ssrc_ = ACE_NTOHL(*(ACE_UINT32*)&buffer[i]); i+=4; - ACE_UINT32 temp = ntohl(*(ACE_UINT32*)&buffer[i]); + ACE_UINT32 temp = ACE_NTOHL(*(ACE_UINT32*)&buffer[i]); local_block_ptr->fraction_ = (temp&0xff000000) >> 24; local_block_ptr->lost_ = temp & 0x00ffffff; i+=4; - local_block_ptr->last_seq_ = ntohl(*(ACE_UINT32*)&buffer[i]); + local_block_ptr->last_seq_ = ACE_NTOHL(*(ACE_UINT32*)&buffer[i]); i+=4; - local_block_ptr->jitter_ = ntohl(*(ACE_UINT32*)&buffer[i]); + local_block_ptr->jitter_ = ACE_NTOHL(*(ACE_UINT32*)&buffer[i]); i+=4; - local_block_ptr->lsr_ = ntohl(*(ACE_UINT32*)&buffer[i]); + local_block_ptr->lsr_ = ACE_NTOHL(*(ACE_UINT32*)&buffer[i]); i+=4; - local_block_ptr->dlsr_ = ntohl(*(ACE_UINT32*)&buffer[i]); + local_block_ptr->dlsr_ = ACE_NTOHL(*(ACE_UINT32*)&buffer[i]); i+=4; } @@ -391,27 +391,27 @@ RTCP_RR_Packet::build_packet(void) index++; this->packet_data_[index] = chd_.pt_; index++; - *((ACE_UINT16*)&this->packet_data_[index]) = htons(chd_.length_); + *((ACE_UINT16*)&this->packet_data_[index]) = ACE_HTONS(chd_.length_); index+=2; - *((ACE_UINT32*)&this->packet_data_[index]) = htonl(this->ssrc_); + *((ACE_UINT32*)&this->packet_data_[index]) = ACE_HTONL(this->ssrc_); index+=4; local_block_ptr = this->rr_; while (local_block_ptr) { - *((ACE_UINT32*)&this->packet_data_[index]) = htonl(local_block_ptr->ssrc_); + *((ACE_UINT32*)&this->packet_data_[index]) = ACE_HTONL(local_block_ptr->ssrc_); index+=4; - ACE_UINT32 temp = htonl((local_block_ptr->fraction_&0xff) << 24) & + ACE_UINT32 temp = ACE_HTONL((local_block_ptr->fraction_&0xff) << 24) & local_block_ptr->lost_; *((ACE_UINT32*)&this->packet_data_[index]) = temp; index+=4; - *((ACE_UINT32*)&this->packet_data_[index]) = htonl(local_block_ptr->last_seq_); + *((ACE_UINT32*)&this->packet_data_[index]) = ACE_HTONL(local_block_ptr->last_seq_); index+=4; - *((ACE_UINT32*)&this->packet_data_[index]) = htonl(local_block_ptr->jitter_); + *((ACE_UINT32*)&this->packet_data_[index]) = ACE_HTONL(local_block_ptr->jitter_); index+=4; - *((ACE_UINT32*)&this->packet_data_[index]) = htonl(local_block_ptr->lsr_); + *((ACE_UINT32*)&this->packet_data_[index]) = ACE_HTONL(local_block_ptr->lsr_); index+=4; - *((ACE_UINT32*)&this->packet_data_[index]) = htonl(local_block_ptr->dlsr_); + *((ACE_UINT32*)&this->packet_data_[index]) = ACE_HTONL(local_block_ptr->dlsr_); index+=4; local_block_ptr = local_block_ptr->next_; } @@ -492,7 +492,7 @@ RTCP_SDES_Packet::RTCP_SDES_Packet(char* buffer, int *len): } cp->next_ = 0; cp->item_ = 0; - cp->ssrc_ = ntohl(*(ACE_UINT32*)&buffer[i]); + cp->ssrc_ = ACE_NTOHL(*(ACE_UINT32*)&buffer[i]); i+=4; while (buffer[i]!=RTCP_SDES_END) @@ -835,13 +835,13 @@ RTCP_SDES_Packet::build_packet(void) index++; this->packet_data_[index] = chd_.pt_; index++; - *((ACE_UINT16*)&this->packet_data_[index]) = htons(chd_.length_); + *((ACE_UINT16*)&this->packet_data_[index]) = ACE_HTONS(chd_.length_); index+=2; cp = this->chunk_; while (cp) { - *((ACE_UINT32*)&this->packet_data_[index]) = htonl(cp->ssrc_); + *((ACE_UINT32*)&this->packet_data_[index]) = ACE_HTONL(cp->ssrc_); index+=4; ip = cp->item_; @@ -1035,17 +1035,17 @@ RTCP_SR_Packet::RTCP_SR_Packet (char* buffer, // The common part of the header is initialized in the parent. i=4; - this->ssrc_ = ntohl(*(ACE_UINT32*)&buffer[i]); + this->ssrc_ = ACE_NTOHL(*(ACE_UINT32*)&buffer[i]); i+=4; - this->ntp_ts_msw_ = ntohl(*(ACE_UINT32*)&buffer[i]); + this->ntp_ts_msw_ = ACE_NTOHL(*(ACE_UINT32*)&buffer[i]); i+=4; - this->ntp_ts_lsw_ = ntohl(*(ACE_UINT32*)&buffer[i]); + this->ntp_ts_lsw_ = ACE_NTOHL(*(ACE_UINT32*)&buffer[i]); i+=4; - this->rtp_ts_ = ntohl(*(ACE_UINT32*)&buffer[i]); + this->rtp_ts_ = ACE_NTOHL(*(ACE_UINT32*)&buffer[i]); i+=4; - this->psent_ = ntohl(*(ACE_UINT32*)&buffer[i]); + this->psent_ = ACE_NTOHL(*(ACE_UINT32*)&buffer[i]); i+=4; - this->osent_ = ntohl(*(ACE_UINT32*)&buffer[i]); + this->osent_ = ACE_NTOHL(*(ACE_UINT32*)&buffer[i]); i+=4; for (unsigned int j=0; j<this->chd_.count_; j++) { @@ -1063,19 +1063,19 @@ RTCP_SR_Packet::RTCP_SR_Packet (char* buffer, } local_block_ptr->next_ = 0; - local_block_ptr->ssrc_ = ntohl(*(ACE_UINT32*)&buffer[i]); + local_block_ptr->ssrc_ = ACE_NTOHL(*(ACE_UINT32*)&buffer[i]); i+=4; - ACE_UINT32 temp = ntohl(*(ACE_UINT32*)&buffer[i]); + ACE_UINT32 temp = ACE_NTOHL(*(ACE_UINT32*)&buffer[i]); local_block_ptr->fraction_ = (temp&0xff000000) >> 24; local_block_ptr->lost_ = temp & 0x00ffffff; i+=4; - local_block_ptr->last_seq_ = ntohl(*(ACE_UINT32*)&buffer[i]); + local_block_ptr->last_seq_ = ACE_NTOHL(*(ACE_UINT32*)&buffer[i]); i+=4; - local_block_ptr->jitter_ = ntohl(*(ACE_UINT32*)&buffer[i]); + local_block_ptr->jitter_ = ACE_NTOHL(*(ACE_UINT32*)&buffer[i]); i+=4; - local_block_ptr->lsr_ = ntohl(*(ACE_UINT32*)&buffer[i]); + local_block_ptr->lsr_ = ACE_NTOHL(*(ACE_UINT32*)&buffer[i]); i+=4; - local_block_ptr->dlsr_ = ntohl(*(ACE_UINT32*)&buffer[i]); + local_block_ptr->dlsr_ = ACE_NTOHL(*(ACE_UINT32*)&buffer[i]); i+=4; } @@ -1133,37 +1133,37 @@ void RTCP_SR_Packet::build_packet(void) index++; this->packet_data_[index] = this->chd_.pt_; index++; - *((ACE_UINT16*)&this->packet_data_[index]) = htons(this->chd_.length_); + *((ACE_UINT16*)&this->packet_data_[index]) = ACE_HTONS(this->chd_.length_); index+=2; - *((ACE_UINT32*)&this->packet_data_[index]) = htonl(this->ssrc_); + *((ACE_UINT32*)&this->packet_data_[index]) = ACE_HTONL(this->ssrc_); index+=4; - *((ACE_UINT32*)&this->packet_data_[index]) = htonl(this->ntp_ts_msw_); + *((ACE_UINT32*)&this->packet_data_[index]) = ACE_HTONL(this->ntp_ts_msw_); index+=4; - *((ACE_UINT32*)&this->packet_data_[index]) = htonl(this->ntp_ts_lsw_); + *((ACE_UINT32*)&this->packet_data_[index]) = ACE_HTONL(this->ntp_ts_lsw_); index+=4; - *((ACE_UINT32*)&this->packet_data_[index]) = htonl(this->rtp_ts_); + *((ACE_UINT32*)&this->packet_data_[index]) = ACE_HTONL(this->rtp_ts_); index+=4; - *((ACE_UINT32*)&this->packet_data_[index]) = htonl(this->psent_); + *((ACE_UINT32*)&this->packet_data_[index]) = ACE_HTONL(this->psent_); index+=4; - *((ACE_UINT32*)&this->packet_data_[index]) = htonl(this->osent_); + *((ACE_UINT32*)&this->packet_data_[index]) = ACE_HTONL(this->osent_); index+=4; local_block_ptr = this->rr_; while (local_block_ptr) { - *((ACE_UINT32*)&this->packet_data_[index]) = htonl(local_block_ptr->ssrc_); + *((ACE_UINT32*)&this->packet_data_[index]) = ACE_HTONL(local_block_ptr->ssrc_); index+=4; - ACE_UINT32 temp = htonl((local_block_ptr->fraction_&0xff) << 24) & + ACE_UINT32 temp = ACE_HTONL((local_block_ptr->fraction_&0xff) << 24) & local_block_ptr->lost_; *((ACE_UINT32*)&this->packet_data_[index]) = temp; index+=4; - *((ACE_UINT32*)&this->packet_data_[index]) = htonl(local_block_ptr->last_seq_); + *((ACE_UINT32*)&this->packet_data_[index]) = ACE_HTONL(local_block_ptr->last_seq_); index+=4; - *((ACE_UINT32*)&this->packet_data_[index]) = htonl(local_block_ptr->jitter_); + *((ACE_UINT32*)&this->packet_data_[index]) = ACE_HTONL(local_block_ptr->jitter_); index+=4; - *((ACE_UINT32*)&this->packet_data_[index]) = htonl(local_block_ptr->lsr_); + *((ACE_UINT32*)&this->packet_data_[index]) = ACE_HTONL(local_block_ptr->lsr_); index+=4; - *((ACE_UINT32*)&this->packet_data_[index]) = htonl(local_block_ptr->dlsr_); + *((ACE_UINT32*)&this->packet_data_[index]) = ACE_HTONL(local_block_ptr->dlsr_); index+=4; local_block_ptr = local_block_ptr->next_; } diff --git a/TAO/orbsvcs/orbsvcs/Event/ECG_CDR_Message_Receiver.cpp b/TAO/orbsvcs/orbsvcs/Event/ECG_CDR_Message_Receiver.cpp index 03c5ff717fc..9da65cee9b4 100644 --- a/TAO/orbsvcs/orbsvcs/Event/ECG_CDR_Message_Receiver.cpp +++ b/TAO/orbsvcs/orbsvcs/Event/ECG_CDR_Message_Receiver.cpp @@ -581,7 +581,7 @@ TAO_ECG_CDR_Message_Receiver::Mcast_Header::read (char *header, crcparts[cnt] = padding[cnt]; } - this->crc = ntohl (this->crc); + this->crc = ACE_NTOHL (this->crc); } // Validate. diff --git a/TAO/orbsvcs/orbsvcs/Event/ECG_CDR_Message_Sender.cpp b/TAO/orbsvcs/orbsvcs/Event/ECG_CDR_Message_Sender.cpp index 6a9b79ce970..9fec02fdf71 100644 --- a/TAO/orbsvcs/orbsvcs/Event/ECG_CDR_Message_Sender.cpp +++ b/TAO/orbsvcs/orbsvcs/Event/ECG_CDR_Message_Sender.cpp @@ -218,7 +218,7 @@ TAO_ECG_CDR_Message_Sender::send_fragment (const ACE_INET_Addr &addr, if (iovcnt > 1) { crc = ACE::crc32 (iov, iovcnt); - crc = htonl (crc); + crc = ACE_HTONL (crc); } for (int cnt=0; cnt<4; ++cnt) { |