summaryrefslogtreecommitdiff
path: root/TAO/orbsvcs/orbsvcs/AV/Endpoint_Strategy.cpp
diff options
context:
space:
mode:
authormitza <mitza@ae88bc3d-4319-0410-8dbf-d08b4c9d3795>2013-04-12 22:47:02 +0000
committermitza <mitza@ae88bc3d-4319-0410-8dbf-d08b4c9d3795>2013-04-12 22:47:02 +0000
commit4763430ca49834f855cb538a5a867ae43a0a403e (patch)
tree51fd3bf65fca69b840033a5a5dd7d086c96a4194 /TAO/orbsvcs/orbsvcs/AV/Endpoint_Strategy.cpp
parent9d5564b342e794dc79bcf4ffe3a1381086b8d960 (diff)
downloadATCD-4763430ca49834f855cb538a5a867ae43a0a403e.tar.gz
ChangeLogTag: Fri Apr 12 22:41:43 UTC 2013 Adam Mitz <mitza@ociweb.com>
Diffstat (limited to 'TAO/orbsvcs/orbsvcs/AV/Endpoint_Strategy.cpp')
-rw-r--r--TAO/orbsvcs/orbsvcs/AV/Endpoint_Strategy.cpp34
1 files changed, 18 insertions, 16 deletions
diff --git a/TAO/orbsvcs/orbsvcs/AV/Endpoint_Strategy.cpp b/TAO/orbsvcs/orbsvcs/AV/Endpoint_Strategy.cpp
index 8793ff67520..2eae2670669 100644
--- a/TAO/orbsvcs/orbsvcs/AV/Endpoint_Strategy.cpp
+++ b/TAO/orbsvcs/orbsvcs/AV/Endpoint_Strategy.cpp
@@ -10,6 +10,8 @@
//=============================================================================
+#include "orbsvcs/Log_Macros.h"
+#include "orbsvcs/Log_Macros.h"
#include "orbsvcs/AV/Endpoint_Strategy.h"
#include "tao/debug.h"
@@ -44,7 +46,7 @@ int
TAO_AV_Endpoint_Strategy::create_A (AVStreams::StreamEndPoint_A_ptr & /* stream_endpoint */,
AVStreams::VDev_ptr & /* vdev */)
{
- ACE_ERROR_RETURN ((LM_ERROR,
+ ORBSVCS_ERROR_RETURN ((LM_ERROR,
"(%P|%t) Error creating A endpoint\n"),
-1);
}
@@ -57,7 +59,7 @@ int
TAO_AV_Endpoint_Strategy::create_B (AVStreams::StreamEndPoint_B_ptr & /* stream_endpoint */,
AVStreams::VDev_ptr & /*vdev */)
{
- ACE_ERROR_RETURN ((LM_ERROR,
+ ORBSVCS_ERROR_RETURN ((LM_ERROR,
"(%P|%t) Error creating B endpoint\n"),
-1);
}
@@ -95,7 +97,7 @@ TAO_AV_Endpoint_Process_Strategy::activate (void)
// Process creation failed
if (this->pid_ == -1)
- ACE_ERROR_RETURN ((LM_ERROR,
+ ORBSVCS_ERROR_RETURN ((LM_ERROR,
"(%P|%t) ACE_Process:: spawn failed: %p\n",
"spawn"),
-1);
@@ -110,7 +112,7 @@ TAO_AV_Endpoint_Process_Strategy::activate (void)
this->host_,
static_cast<long int> (this->pid_));
- ACE_DEBUG ((LM_DEBUG,
+ ORBSVCS_DEBUG ((LM_DEBUG,
"(%P|%t) semaphore is %s\n",
sem_str));
// Create the semaphore
@@ -126,7 +128,7 @@ TAO_AV_Endpoint_Process_Strategy::activate (void)
// See if my child process is still alive -- if not, return an error
if (ACE_OS::kill (this->pid_,
0) == -1)
- ACE_ERROR_RETURN ((LM_ERROR,
+ ORBSVCS_ERROR_RETURN ((LM_ERROR,
"(%P|%t) Process_Strategy: Process being waited on died unexpectedly.\n"),
-1);
// if we were not interrupted due to a EINTR, break
@@ -139,7 +141,7 @@ TAO_AV_Endpoint_Process_Strategy::activate (void)
// The job of the semaphore is done, remove it.
if (semaphore.remove () == -1)
- ACE_ERROR_RETURN ((LM_ERROR,
+ ORBSVCS_ERROR_RETURN ((LM_ERROR,
"(%P|%t) semaphore remove failed: %p\n",
"remove"),
-1);
@@ -177,7 +179,7 @@ TAO_AV_Endpoint_Process_Strategy::bind_to_naming_service (void)
TAO_ORB_Core_instance ()->orb ()->resolve_initial_references ("NameService");
if (CORBA::is_nil (naming_obj.in ()))
- ACE_ERROR_RETURN ((LM_ERROR,
+ ORBSVCS_ERROR_RETURN ((LM_ERROR,
" (%P|%t) Unable to resolve the Name Service.\n"),
-1);
this->naming_context_ =
@@ -205,7 +207,7 @@ TAO_AV_Endpoint_Process_Strategy::get_vdev (void)
this->host_,
(long) this->pid_);
- if (TAO_debug_level > 0) ACE_DEBUG ((LM_DEBUG,"(%P|%t)%s\n",vdev_name));
+ if (TAO_debug_level > 0) ORBSVCS_DEBUG ((LM_DEBUG,"(%P|%t)%s\n",vdev_name));
// Create the name
CosNaming::Name VDev_Name (1);
@@ -222,7 +224,7 @@ TAO_AV_Endpoint_Process_Strategy::get_vdev (void)
// Check if valid
if (CORBA::is_nil (this->vdev_.in() ))
- ACE_ERROR_RETURN ((LM_ERROR,
+ ORBSVCS_ERROR_RETURN ((LM_ERROR,
" could not resolve Stream_Endpoint_B in Naming service <%s>\n"),
-1);
}
@@ -257,7 +259,7 @@ TAO_AV_Endpoint_Process_Strategy_A::create_A (AVStreams::StreamEndPoint_A_ptr &s
{
// use the baseclass activate
if (this->activate () == -1)
- ACE_ERROR_RETURN ((LM_ERROR,
+ ORBSVCS_ERROR_RETURN ((LM_ERROR,
"(%P|%t) TAO_AV_Endpoint_Process_Strategy: Error in activate ()\n"),
-1);
@@ -281,7 +283,7 @@ TAO_AV_Endpoint_Process_Strategy_A::get_stream_endpoint (void)
this->host_,
(long) this->pid_);
- if (TAO_debug_level > 0) ACE_DEBUG ((LM_DEBUG,"(%P|%t)%s\n",stream_endpoint_name));
+ if (TAO_debug_level > 0) ORBSVCS_DEBUG ((LM_DEBUG,"(%P|%t)%s\n",stream_endpoint_name));
// Create the name
CosNaming::Name Stream_Endpoint_A_Name (1);
@@ -299,7 +301,7 @@ TAO_AV_Endpoint_Process_Strategy_A::get_stream_endpoint (void)
// Check for validity
if (CORBA::is_nil (this->stream_endpoint_a_.in() ))
- ACE_ERROR_RETURN ((LM_ERROR,
+ ORBSVCS_ERROR_RETURN ((LM_ERROR,
" could not resolve Stream_Endpoint_A in Naming service <%s>\n"),
-1);
}
@@ -335,11 +337,11 @@ TAO_AV_Endpoint_Process_Strategy_B::create_B (AVStreams::StreamEndPoint_B_ptr &s
try
{
if (this->activate () == -1)
- ACE_ERROR_RETURN ((LM_ERROR,
+ ORBSVCS_ERROR_RETURN ((LM_ERROR,
"(%P|%t) TAO_AV_Endpoint_Process_Strategy: Error in activate ()\n"),
-1);
- if (TAO_debug_level > 0) ACE_DEBUG ((LM_DEBUG,"(%P|%t)TAO_AV_Endpoint_Process_Strategy_B::create_B ()\n: stream_endpoint is:%s\n",
+ if (TAO_debug_level > 0) ORBSVCS_DEBUG ((LM_DEBUG,"(%P|%t)TAO_AV_Endpoint_Process_Strategy_B::create_B ()\n: stream_endpoint is:%s\n",
TAO_ORB_Core_instance ()->orb ()->object_to_string (this->stream_endpoint_b_.in())));
stream_endpoint = AVStreams::StreamEndPoint_B::_duplicate ( this->stream_endpoint_b_.in() );
vdev = AVStreams::VDev::_duplicate( this->vdev_.in() );
@@ -366,7 +368,7 @@ TAO_AV_Endpoint_Process_Strategy_B::get_stream_endpoint (void)
this->host_,
(long) this->pid_);
- if (TAO_debug_level > 0) ACE_DEBUG ((LM_DEBUG,"(%P|%t)%s\n",stream_endpoint_name));
+ if (TAO_debug_level > 0) ORBSVCS_DEBUG ((LM_DEBUG,"(%P|%t)%s\n",stream_endpoint_name));
// Create the name
CosNaming::Name Stream_Endpoint_B_Name (1);
@@ -384,7 +386,7 @@ TAO_AV_Endpoint_Process_Strategy_B::get_stream_endpoint (void)
// Check for validity
if (CORBA::is_nil (this->stream_endpoint_b_.in() ))
- ACE_ERROR_RETURN ((LM_ERROR,
+ ORBSVCS_ERROR_RETURN ((LM_ERROR,
" could not resolve Stream_Endpoint_B in Naming service <%s>\n"),
-1);
}