diff options
author | elliott_c <ocielliottc@users.noreply.github.com> | 2004-12-13 18:02:36 +0000 |
---|---|---|
committer | elliott_c <ocielliottc@users.noreply.github.com> | 2004-12-13 18:02:36 +0000 |
commit | a73e87e7fd915f467382866c7323cccf8b768ce7 (patch) | |
tree | bca5417dc6c42534290ca4ad408819176668ff98 /TAO/orbsvcs/orbsvcs/Event/ECG_CDR_Message_Receiver.cpp | |
parent | 7ee856dabf7d55a301ea7a1a7be0f3bd2f589375 (diff) | |
download | ATCD-a73e87e7fd915f467382866c7323cccf8b768ce7.tar.gz |
ChangeLogTag: Mon Dec 13 11:58:49 2004 Chad Elliott <elliott_c@ociweb.com>
Diffstat (limited to 'TAO/orbsvcs/orbsvcs/Event/ECG_CDR_Message_Receiver.cpp')
-rw-r--r-- | TAO/orbsvcs/orbsvcs/Event/ECG_CDR_Message_Receiver.cpp | 30 |
1 files changed, 15 insertions, 15 deletions
diff --git a/TAO/orbsvcs/orbsvcs/Event/ECG_CDR_Message_Receiver.cpp b/TAO/orbsvcs/orbsvcs/Event/ECG_CDR_Message_Receiver.cpp index b75bd1e1333..3225218ea60 100644 --- a/TAO/orbsvcs/orbsvcs/Event/ECG_CDR_Message_Receiver.cpp +++ b/TAO/orbsvcs/orbsvcs/Event/ECG_CDR_Message_Receiver.cpp @@ -267,21 +267,21 @@ TAO_ECG_CDR_Message_Receiver::handle_input ( if (errno == EWOULDBLOCK) return 0; - ACE_ERROR_RETURN ((LM_ERROR, "Error reading mcast fragment (%m)."), + ACE_ERROR_RETURN ((LM_ERROR, "Error reading mcast fragment (%m).\n"), -1); } if (n == 0) { ACE_ERROR_RETURN ((LM_ERROR, "Trying to read mcast fragment: " - "read 0 bytes from socket."), + "read 0 bytes from socket.\n"), 0); } if (n < TAO_ECG_CDR_Message_Sender::ECG_HEADER_SIZE) { ACE_ERROR_RETURN ((LM_ERROR, "Trying to read mcast fragment: " - "# of bytes read < mcast header size."), + "# of bytes read < mcast header size.\n"), -1); } @@ -379,19 +379,19 @@ TAO_ECG_CDR_Message_Receiver::mark_received (const ACE_INET_Addr &from, if (request == 0) { ACE_DEBUG ((LM_WARNING, "Received mcast request with sequence" - "below currently expected range.")); + "below currently expected range.\n")); return 0; } if (*request == &Request_Completed_) { ACE_DEBUG ((LM_INFO, "Received duplicate mcast fragment. " - "(Request already complete).")); + "(Request already complete).\n")); return 0; } if (*request != 0) { ACE_ERROR_RETURN ((LM_ERROR, "Inconsistent fragments for " - "mcast request."), + "mcast request.\n"), -1); } @@ -418,13 +418,13 @@ TAO_ECG_CDR_Message_Receiver::process_fragment ( if (request == 0) { ACE_DEBUG ((LM_WARNING, "Received mcast request with sequence " - "below currently expected range.")); + "below currently expected range.\n")); return 0; } if (*request == &Request_Completed_) { ACE_DEBUG ((LM_INFO, "Received duplicate mcast fragment. " - "(Request already complete).")); + "(Request already complete).\n")); return 0; } if (*request == 0) @@ -447,14 +447,14 @@ TAO_ECG_CDR_Message_Receiver::process_fragment ( header.fragment_count) == 0) { ACE_ERROR_RETURN ((LM_ERROR, - "Received invalid mcast fragment."), + "Received invalid mcast fragment.\n"), -1); } // Check whether this fragment was already received. if ((*request)->test_received (header.fragment_id) == 1) { - ACE_DEBUG ((LM_INFO, "Received duplicate mcast fragment.")); + ACE_DEBUG ((LM_INFO, "Received duplicate mcast fragment.\n")); return 0; } @@ -502,7 +502,7 @@ TAO_ECG_CDR_Message_Receiver::get_source_entry (const ACE_INET_Addr &from) || this->request_map_.bind (from, requests, entry) == -1) { ACE_ERROR_RETURN ((LM_ERROR, "Unable to create hash map " - "entry for a new request."), + "entry for a new request.\n"), 0); } requests_aptr.release (); @@ -521,7 +521,7 @@ TAO_ECG_CDR_Message_Receiver::Mcast_Header::read (char *header, if(this->byte_order != 0 && this->byte_order != 1) { ACE_ERROR_RETURN ((LM_ERROR, "Reading mcast packet header: byte " - "order is neither 0 nor 1, it is %d.", + "order is neither 0 nor 1, it is %d.\n", this->byte_order), -1); } @@ -538,7 +538,7 @@ TAO_ECG_CDR_Message_Receiver::Mcast_Header::read (char *header, || a != 'A' || b != 'B' || c != 'C') { ACE_ERROR_RETURN ((LM_ERROR, "Error reading magic bytes " - "in mcast packet header."), + "in mcast packet header.\n"), -1); } @@ -550,7 +550,7 @@ TAO_ECG_CDR_Message_Receiver::Mcast_Header::read (char *header, || !header_cdr.read_ulong (this->fragment_count)) { ACE_ERROR_RETURN ((LM_ERROR, - "Error decoding mcast packet header."), + "Error decoding mcast packet header.\n"), -1); } @@ -582,7 +582,7 @@ TAO_ECG_CDR_Message_Receiver::Mcast_Header::read (char *header, { ACE_ERROR_RETURN ((LM_ERROR, "Invalid mcast fragment: " - "inconsistent header fields."), + "inconsistent header fields.\n"), -1); } |