summaryrefslogtreecommitdiff
path: root/TAO/orbsvcs/orbsvcs/Event/ECG_CDR_Message_Sender.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'TAO/orbsvcs/orbsvcs/Event/ECG_CDR_Message_Sender.cpp')
-rw-r--r--TAO/orbsvcs/orbsvcs/Event/ECG_CDR_Message_Sender.cpp13
1 files changed, 7 insertions, 6 deletions
diff --git a/TAO/orbsvcs/orbsvcs/Event/ECG_CDR_Message_Sender.cpp b/TAO/orbsvcs/orbsvcs/Event/ECG_CDR_Message_Sender.cpp
index 7d725174738..ea0ad2cdb97 100644
--- a/TAO/orbsvcs/orbsvcs/Event/ECG_CDR_Message_Sender.cpp
+++ b/TAO/orbsvcs/orbsvcs/Event/ECG_CDR_Message_Sender.cpp
@@ -1,5 +1,6 @@
// $Id$
+#include "orbsvcs/Log_Macros.h"
#include "orbsvcs/Event/ECG_CDR_Message_Sender.h"
#include "tao/CDR.h"
#include "ace/SOCK_Dgram.h"
@@ -21,7 +22,7 @@ TAO_ECG_CDR_Message_Sender::init (
if (endpoint_rptr.get () == 0
|| endpoint_rptr->dgram ().get_handle () == ACE_INVALID_HANDLE)
{
- ACE_ERROR ((LM_ERROR, "TAO_ECG_CDR_Message_Sender::init(): "
+ ORBSVCS_ERROR ((LM_ERROR, "TAO_ECG_CDR_Message_Sender::init(): "
"nil or unitialized endpoint argument.\n"));
throw CORBA::INTERNAL ();
}
@@ -35,7 +36,7 @@ TAO_ECG_CDR_Message_Sender::send_message (const TAO_OutputCDR &cdr,
{
if (this->endpoint_rptr_.get () == 0)
{
- ACE_ERROR ((LM_ERROR, "Attempt to invoke send_message() "
+ ORBSVCS_ERROR ((LM_ERROR, "Attempt to invoke send_message() "
"on non-initialized sender object.\n"));
throw CORBA::INTERNAL ();
}
@@ -244,7 +245,7 @@ TAO_ECG_CDR_Message_Sender::send_fragment (const ACE_INET_Addr &addr,
expected_n += iov[i].iov_len;
if (n > 0 && size_t(n) != expected_n)
{
- ACE_ERROR ((LM_ERROR, ("Sent only %d out of %d bytes "
+ ORBSVCS_ERROR ((LM_ERROR, ("Sent only %d out of %d bytes "
"for mcast fragment.\n"),
n,
expected_n));
@@ -254,18 +255,18 @@ TAO_ECG_CDR_Message_Sender::send_fragment (const ACE_INET_Addr &addr,
{
if (errno == EWOULDBLOCK)
{
- ACE_ERROR ((LM_ERROR, "Send of mcast fragment failed (%m).\n"));
+ ORBSVCS_ERROR ((LM_ERROR, "Send of mcast fragment failed (%m).\n"));
// @@ TODO Use a Event Channel specific exception
throw CORBA::COMM_FAILURE ();
}
else
{
- ACE_DEBUG ((LM_WARNING, "Send of mcast fragment blocked (%m).\n"));
+ ORBSVCS_DEBUG ((LM_WARNING, "Send of mcast fragment blocked (%m).\n"));
}
}
else if (n == 0)
{
- ACE_DEBUG ((LM_WARNING, "EOF on send of mcast fragment (%m).\n"));
+ ORBSVCS_DEBUG ((LM_WARNING, "EOF on send of mcast fragment (%m).\n"));
}
}