summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorPhil Mesnier <mesnier_p@ociweb.com>2013-01-09 19:13:01 +0000
committerPhil Mesnier <mesnier_p@ociweb.com>2013-01-09 19:13:01 +0000
commit79fce1fa280e31413a44863adc63d363a47279ce (patch)
treeadae04156e67e750893c93de673f38b2bed31381
parenta18c7e39c0c7fc7005abfd320785706e3af6d70f (diff)
downloadATCD-79fce1fa280e31413a44863adc63d363a47279ce.tar.gz
Wed Jan 9 19:09:43 UTC 2013 Phil Mesnier <mesnier_p@ociweb.com>
* tao/Dynamic_TP/DTP_Config.h: * tao/Dynamic_TP/DTP_Config.cpp: * tao/Dynamic_TP/DTP_ORBInitializer.h: * tao/Dynamic_TP/DTP_ORBInitializer.cpp: * tao/Dynamic_TP/DTP_ORB_Loader.h: * tao/Dynamic_TP/DTP_ORB_Loader.cpp: * tao/Dynamic_TP/DTP_POA_Loader.h: * tao/Dynamic_TP/DTP_POA_Loader.cpp: * tao/Dynamic_TP/DTP_POA_Strategy.h: * tao/Dynamic_TP/DTP_POA_Strategy.inl: * tao/Dynamic_TP/DTP_POA_Strategy.cpp: * tao/Dynamic_TP/DTP_Task.h: * tao/Dynamic_TP/DTP_Task.inl: * tao/Dynamic_TP/DTP_Task.cpp: * tao/Dynamic_TP/DTP_Thread_Pool.h: Added these files. * tests/Dynamic_TP/Config_Loader/Test.cpp: * tests/Dynamic_TP/Config_Loader/svc.conf: * tests/Dynamic_TP/POA_Loader/Dynamic_TP_POA_Test_Dynamic/run_test.pl: * tests/Dynamic_TP/POA_Loader/Dynamic_TP_POA_Test_Dynamic/server.cpp: * tests/Dynamic_TP/POA_Loader/Dynamic_TP_POA_Test_Dynamic/svc1.conf: * tests/Dynamic_TP/POA_Loader/Dynamic_TP_POA_Test_Dynamic/svc2.conf: * tests/Dynamic_TP/POA_Loader/Dynamic_TP_POA_Test_Dynamic/svc3.conf: * tests/Dynamic_TP/POA_Loader/Dynamic_TP_POA_Test_Dynamic/svc4.conf: * tests/Dynamic_TP/POA_Loader/Dynamic_TP_POA_Test_Static/run_test.pl: * tests/Dynamic_TP/POA_Loader/Dynamic_TP_POA_Test_Static/server.cpp: * tests/Dynamic_TP/POA_Loader/Test.cpp: * tests/Dynamic_TP/POA_Loader/svc.conf: Modified these files. * tao/Dynamic_TP/Dynamic_TP_Config.h: * tao/Dynamic_TP/Dynamic_TP_Config.cpp: * tao/Dynamic_TP/Dynamic_TP_ORBInitializer.h: * tao/Dynamic_TP/Dynamic_TP_ORBInitializer.cpp: * tao/Dynamic_TP/Dynamic_TP_ORB_Loader.h: * tao/Dynamic_TP/Dynamic_TP_ORB_Loader.cpp: * tao/Dynamic_TP/Dynamic_TP_POA_Loader.h: * tao/Dynamic_TP/Dynamic_TP_POA_Loader.cpp: * tao/Dynamic_TP/Dynamic_TP_POA_Strategy.h: * tao/Dynamic_TP/Dynamic_TP_POA_Strategy.inl: * tao/Dynamic_TP/Dynamic_TP_POA_Strategy.cpp: * tao/Dynamic_TP/Dynamic_TP_Task.h: * tao/Dynamic_TP/Dynamic_TP_Task.inl: * tao/Dynamic_TP/Dynamic_TP_Task.cpp: Removed these files. Unified the naming convension for the Dynamic_TP library. All class names and svc.conf objects are prefixed with DTP_ or TAO_DTP_ as appropriate.
-rw-r--r--TAO/OCI_RE_ChangeLog58
-rw-r--r--TAO/tao/Dynamic_TP/DTP_Config.cpp (renamed from TAO/tao/Dynamic_TP/Dynamic_TP_Config.cpp)81
-rw-r--r--TAO/tao/Dynamic_TP/DTP_Config.h (renamed from TAO/tao/Dynamic_TP/Dynamic_TP_Config.h)26
-rw-r--r--TAO/tao/Dynamic_TP/DTP_ORBInitializer.cpp (renamed from TAO/tao/Dynamic_TP/Dynamic_TP_ORBInitializer.cpp)36
-rw-r--r--TAO/tao/Dynamic_TP/DTP_ORBInitializer.h (renamed from TAO/tao/Dynamic_TP/Dynamic_TP_ORBInitializer.h)6
-rw-r--r--TAO/tao/Dynamic_TP/DTP_ORB_Loader.cpp (renamed from TAO/tao/Dynamic_TP/Dynamic_TP_ORB_Loader.cpp)26
-rw-r--r--TAO/tao/Dynamic_TP/DTP_ORB_Loader.h (renamed from TAO/tao/Dynamic_TP/Dynamic_TP_ORB_Loader.h)12
-rw-r--r--TAO/tao/Dynamic_TP/DTP_POA_Loader.cpp (renamed from TAO/tao/Dynamic_TP/Dynamic_TP_POA_Loader.cpp)40
-rw-r--r--TAO/tao/Dynamic_TP/DTP_POA_Loader.h (renamed from TAO/tao/Dynamic_TP/Dynamic_TP_POA_Loader.h)14
-rw-r--r--TAO/tao/Dynamic_TP/DTP_POA_Strategy.cpp (renamed from TAO/tao/Dynamic_TP/Dynamic_TP_POA_Strategy.cpp)56
-rw-r--r--TAO/tao/Dynamic_TP/DTP_POA_Strategy.h (renamed from TAO/tao/Dynamic_TP/Dynamic_TP_POA_Strategy.h)28
-rw-r--r--TAO/tao/Dynamic_TP/DTP_POA_Strategy.inl (renamed from TAO/tao/Dynamic_TP/Dynamic_TP_POA_Strategy.inl)6
-rw-r--r--TAO/tao/Dynamic_TP/DTP_Task.cpp (renamed from TAO/tao/Dynamic_TP/Dynamic_TP_Task.cpp)114
-rw-r--r--TAO/tao/Dynamic_TP/DTP_Task.h (renamed from TAO/tao/Dynamic_TP/Dynamic_TP_Task.h)14
-rw-r--r--TAO/tao/Dynamic_TP/DTP_Task.inl (renamed from TAO/tao/Dynamic_TP/Dynamic_TP_Task.inl)0
-rw-r--r--TAO/tao/Dynamic_TP/DTP_Thread_Pool.h2
-rw-r--r--TAO/tests/Dynamic_TP/Config_Loader/Test.cpp8
-rw-r--r--TAO/tests/Dynamic_TP/Config_Loader/svc.conf26
-rwxr-xr-xTAO/tests/Dynamic_TP/POA_Loader/Dynamic_TP_POA_Test_Dynamic/run_test.pl20
-rw-r--r--TAO/tests/Dynamic_TP/POA_Loader/Dynamic_TP_POA_Test_Dynamic/server.cpp2
-rw-r--r--TAO/tests/Dynamic_TP/POA_Loader/Dynamic_TP_POA_Test_Dynamic/svc1.conf4
-rw-r--r--TAO/tests/Dynamic_TP/POA_Loader/Dynamic_TP_POA_Test_Dynamic/svc2.conf4
-rw-r--r--TAO/tests/Dynamic_TP/POA_Loader/Dynamic_TP_POA_Test_Dynamic/svc3.conf4
-rw-r--r--TAO/tests/Dynamic_TP/POA_Loader/Dynamic_TP_POA_Test_Dynamic/svc4.conf4
-rwxr-xr-xTAO/tests/Dynamic_TP/POA_Loader/Dynamic_TP_POA_Test_Static/run_test.pl20
-rw-r--r--TAO/tests/Dynamic_TP/POA_Loader/Dynamic_TP_POA_Test_Static/server.cpp6
-rw-r--r--TAO/tests/Dynamic_TP/POA_Loader/Test.cpp12
-rw-r--r--TAO/tests/Dynamic_TP/POA_Loader/svc.conf28
28 files changed, 364 insertions, 293 deletions
diff --git a/TAO/OCI_RE_ChangeLog b/TAO/OCI_RE_ChangeLog
index 0b97c9c9365..74b8861dda9 100644
--- a/TAO/OCI_RE_ChangeLog
+++ b/TAO/OCI_RE_ChangeLog
@@ -1,3 +1,61 @@
+Wed Jan 9 19:09:43 UTC 2013 Phil Mesnier <mesnier_p@ociweb.com>
+
+ * tao/Dynamic_TP/DTP_Config.h:
+ * tao/Dynamic_TP/DTP_Config.cpp:
+ * tao/Dynamic_TP/DTP_ORBInitializer.h:
+ * tao/Dynamic_TP/DTP_ORBInitializer.cpp:
+ * tao/Dynamic_TP/DTP_ORB_Loader.h:
+ * tao/Dynamic_TP/DTP_ORB_Loader.cpp:
+ * tao/Dynamic_TP/DTP_POA_Loader.h:
+ * tao/Dynamic_TP/DTP_POA_Loader.cpp:
+ * tao/Dynamic_TP/DTP_POA_Strategy.h:
+ * tao/Dynamic_TP/DTP_POA_Strategy.inl:
+ * tao/Dynamic_TP/DTP_POA_Strategy.cpp:
+ * tao/Dynamic_TP/DTP_Task.h:
+ * tao/Dynamic_TP/DTP_Task.inl:
+ * tao/Dynamic_TP/DTP_Task.cpp:
+ * tao/Dynamic_TP/DTP_Thread_Pool.h:
+
+ Added these files.
+
+ * tests/Dynamic_TP/Config_Loader/Test.cpp:
+ * tests/Dynamic_TP/Config_Loader/svc.conf:
+
+ * tests/Dynamic_TP/POA_Loader/Dynamic_TP_POA_Test_Dynamic/run_test.pl:
+ * tests/Dynamic_TP/POA_Loader/Dynamic_TP_POA_Test_Dynamic/server.cpp:
+ * tests/Dynamic_TP/POA_Loader/Dynamic_TP_POA_Test_Dynamic/svc1.conf:
+ * tests/Dynamic_TP/POA_Loader/Dynamic_TP_POA_Test_Dynamic/svc2.conf:
+ * tests/Dynamic_TP/POA_Loader/Dynamic_TP_POA_Test_Dynamic/svc3.conf:
+ * tests/Dynamic_TP/POA_Loader/Dynamic_TP_POA_Test_Dynamic/svc4.conf:
+
+ * tests/Dynamic_TP/POA_Loader/Dynamic_TP_POA_Test_Static/run_test.pl:
+ * tests/Dynamic_TP/POA_Loader/Dynamic_TP_POA_Test_Static/server.cpp:
+
+ * tests/Dynamic_TP/POA_Loader/Test.cpp:
+ * tests/Dynamic_TP/POA_Loader/svc.conf:
+
+ Modified these files.
+
+ * tao/Dynamic_TP/Dynamic_TP_Config.h:
+ * tao/Dynamic_TP/Dynamic_TP_Config.cpp:
+ * tao/Dynamic_TP/Dynamic_TP_ORBInitializer.h:
+ * tao/Dynamic_TP/Dynamic_TP_ORBInitializer.cpp:
+ * tao/Dynamic_TP/Dynamic_TP_ORB_Loader.h:
+ * tao/Dynamic_TP/Dynamic_TP_ORB_Loader.cpp:
+ * tao/Dynamic_TP/Dynamic_TP_POA_Loader.h:
+ * tao/Dynamic_TP/Dynamic_TP_POA_Loader.cpp:
+ * tao/Dynamic_TP/Dynamic_TP_POA_Strategy.h:
+ * tao/Dynamic_TP/Dynamic_TP_POA_Strategy.inl:
+ * tao/Dynamic_TP/Dynamic_TP_POA_Strategy.cpp:
+ * tao/Dynamic_TP/Dynamic_TP_Task.h:
+ * tao/Dynamic_TP/Dynamic_TP_Task.inl:
+ * tao/Dynamic_TP/Dynamic_TP_Task.cpp:
+
+ Removed these files.
+
+ Unified the naming convension for the Dynamic_TP library. All class names and
+ svc.conf objects are prefixed with DTP_ or TAO_DTP_ as appropriate.
+
Wed Jan 9 16:46:56 UTC 2013 Byron Harris <harrisb@ociweb.com>
* orbsvcs/tests/FT_Naming/FaultTolerant/client.cpp:
diff --git a/TAO/tao/Dynamic_TP/Dynamic_TP_Config.cpp b/TAO/tao/Dynamic_TP/DTP_Config.cpp
index feef01396c1..85e37764dc2 100644
--- a/TAO/tao/Dynamic_TP/Dynamic_TP_Config.cpp
+++ b/TAO/tao/Dynamic_TP/DTP_Config.cpp
@@ -1,10 +1,10 @@
// $Id$
-#include "tao/Dynamic_TP/Dynamic_TP_Config.h"
+#include "tao/Dynamic_TP/DTP_Config.h"
#if defined (TAO_HAS_CORBA_MESSAGING) && TAO_HAS_CORBA_MESSAGING != 0
-#include "tao/Dynamic_TP/Dynamic_TP_ORBInitializer.h"
+#include "tao/Dynamic_TP/DTP_ORBInitializer.h"
#include "tao/debug.h"
#include "ace/Dynamic_Service.h"
@@ -12,56 +12,56 @@
TAO_BEGIN_VERSIONED_NAMESPACE_DECL
-TAO_Dynamic_TP_Config_Registry_Installer::TAO_Dynamic_TP_Config_Registry_Installer (void)
+TAO_DTP_Config_Registry_Installer::TAO_DTP_Config_Registry_Installer (void)
{
- ACE_Service_Config::process_directive (ace_svc_desc_TAO_Dynamic_TP_Config_Registry);
+ ACE_Service_Config::process_directive (ace_svc_desc_TAO_DTP_Config_Registry);
}
-TAO_Dynamic_TP_Config_Registry::TAO_Dynamic_TP_Config_Registry (void)
+TAO_DTP_Config_Registry::TAO_DTP_Config_Registry (void)
{
}
-TAO_Dynamic_TP_Config_Registry::~TAO_Dynamic_TP_Config_Registry (void)
+TAO_DTP_Config_Registry::~TAO_DTP_Config_Registry (void)
{
}
int
-TAO_Dynamic_TP_Config_Registry::init (int , ACE_TCHAR* [] )
+TAO_DTP_Config_Registry::init (int , ACE_TCHAR* [] )
{
return 0;
}
bool
-TAO_Dynamic_TP_Config_Registry::find (const ACE_CString& name, TAO_DTP_Definition &entry)
+TAO_DTP_Config_Registry::find (const ACE_CString& name, TAO_DTP_Definition &entry)
{
return registry_.find (name, entry) == 0;
}
int
-TAO_Dynamic_TP_Config_Registry::bind (const ACE_CString& name, TAO_DTP_Definition &entry)
+TAO_DTP_Config_Registry::bind (const ACE_CString& name, TAO_DTP_Definition &entry)
{
return registry_.bind (name, entry);
}
int
-TAO_Dynamic_TP_Config_Registry::rebind (const ACE_CString& name, TAO_DTP_Definition &entry)
+TAO_DTP_Config_Registry::rebind (const ACE_CString& name, TAO_DTP_Definition &entry)
{
return registry_.rebind (name, entry);
}
//--------------------------------------------------------------------------------------
-TAO_Dynamic_TP_Config::TAO_Dynamic_TP_Config (void)
+TAO_DTP_Config::TAO_DTP_Config (void)
{
}
-TAO_Dynamic_TP_Config::~TAO_Dynamic_TP_Config (void)
+TAO_DTP_Config::~TAO_DTP_Config (void)
{
}
int
-TAO_Dynamic_TP_Config::init (int argc, ACE_TCHAR* argv[])
+TAO_DTP_Config::init (int argc, ACE_TCHAR* argv[])
{
// TAO_DTP_Definition entry = {-1,5,-1,0,60,0};
TAO_DTP_Definition entry;
@@ -150,30 +150,43 @@ TAO_Dynamic_TP_Config::init (int argc, ACE_TCHAR* argv[])
if (TAO_debug_level > 0)
{
ACE_DEBUG ((LM_DEBUG,
- ACE_TEXT ("TAO (%P|%t) - Dynamic_TP_Config - Unrecognized argv[%d], %C\n"),
+ ACE_TEXT ("TAO (%P|%t) - DTP_Config - Unrecognized argv[%d], %C\n"),
curarg, argv[curarg]));
}
return -1;
}
}
+ if ((entry.max_threads_ != -1 && entry.max_threads_ < entry.init_threads_) ||
+ (entry.min_threads_ > entry.init_threads_))
+ {
+ if (TAO_debug_level > 0)
+ {
+ ACE_DEBUG ((LM_DEBUG,
+ ACE_TEXT ("TAO (%P|%t) - DTP_Config - thread count constraint ")
+ ACE_TEXT ("violated, min: %d <= init: %d <= max: %d or max = -1\n"),
+ entry.min_threads_, entry.init_threads_, entry.max_threads_));
+ }
+ return 0;
+ }
+
ACE_CString name_str = name;
ACE_Service_Gestalt *current = ACE_Service_Config::current();
- TAO_Dynamic_TP_Config_Registry* registry =
- ACE_Dynamic_Service<TAO_Dynamic_TP_Config_Registry>::instance
- (current, "Dynamic_TP_Config_Registry", true);
+ TAO_DTP_Config_Registry* registry =
+ ACE_Dynamic_Service<TAO_DTP_Config_Registry>::instance
+ (current, "DTP_Config_Registry", true);
if (registry == 0)
{
- current->process_directive (ace_svc_desc_TAO_Dynamic_TP_Config_Registry);
- registry = ACE_Dynamic_Service<TAO_Dynamic_TP_Config_Registry>::instance
- (current, "Dynamic_TP_Config_Registry", true);
+ current->process_directive (ace_svc_desc_TAO_DTP_Config_Registry);
+ registry = ACE_Dynamic_Service<TAO_DTP_Config_Registry>::instance
+ (current, "DTP_Config_Registry", true);
if (registry == 0)
{
if (TAO_debug_level > 0)
{
ACE_DEBUG((LM_DEBUG,
- ACE_TEXT ("TAO (%P|%t) - Dynamic_TP_Config - cannot initialize registry\n")));
+ ACE_TEXT ("TAO (%P|%t) - DTP_Config - cannot initialize registry\n")));
}
return -1;
}
@@ -191,7 +204,7 @@ TAO_Dynamic_TP_Config::init (int argc, ACE_TCHAR* argv[])
}
int
-TAO_Dynamic_TP_Config::parse_long (int &curarg,
+TAO_DTP_Config::parse_long (int &curarg,
int argc, ACE_TCHAR *argv[],
const ACE_TCHAR *match, long &value)
{
@@ -211,7 +224,7 @@ TAO_Dynamic_TP_Config::parse_long (int &curarg,
}
int
-TAO_Dynamic_TP_Config::parse_bool (int &curarg,
+TAO_DTP_Config::parse_bool (int &curarg,
int argc, ACE_TCHAR *argv[],
const ACE_TCHAR *match, bool &value)
{
@@ -226,7 +239,7 @@ TAO_Dynamic_TP_Config::parse_bool (int &curarg,
}
int
-TAO_Dynamic_TP_Config::parse_string (int &curarg,
+TAO_DTP_Config::parse_string (int &curarg,
int argc, ACE_TCHAR *argv[],
const ACE_TCHAR *match, ACE_TCHAR *&value)
{
@@ -246,13 +259,13 @@ TAO_Dynamic_TP_Config::parse_string (int &curarg,
void
-TAO_Dynamic_TP_Config::report_option_value_error (const ACE_TCHAR* option_name,
+TAO_DTP_Config::report_option_value_error (const ACE_TCHAR* option_name,
const ACE_TCHAR* option_value)
{
if (TAO_debug_level > 0)
{
ACE_DEBUG((LM_DEBUG,
- ACE_TEXT ("TAO (%P|%t) - Dynamic_TP_Config - unknown ")
+ ACE_TEXT ("TAO (%P|%t) - DTP_Config - unknown ")
ACE_TEXT ("argument <%s> for <%s>\n"),
option_value, option_name));
}
@@ -261,19 +274,19 @@ TAO_Dynamic_TP_Config::report_option_value_error (const ACE_TCHAR* option_name,
/////////////////////////////////////////////////////////////////////
-ACE_FACTORY_DEFINE (TAO_Dynamic_TP, TAO_Dynamic_TP_Config_Registry)
-ACE_STATIC_SVC_DEFINE (TAO_Dynamic_TP_Config_Registry,
- ACE_TEXT ("Dynamic_TP_Config_Registry"),
+ACE_FACTORY_DEFINE (TAO_Dynamic_TP, TAO_DTP_Config_Registry)
+ACE_STATIC_SVC_DEFINE (TAO_DTP_Config_Registry,
+ ACE_TEXT ("DTP_Config_Registry"),
ACE_SVC_OBJ_T,
- &ACE_SVC_NAME (TAO_Dynamic_TP_Config_Registry),
+ &ACE_SVC_NAME (TAO_DTP_Config_Registry),
ACE_Service_Type::DELETE_THIS
| ACE_Service_Type::DELETE_OBJ,
0)
-ACE_FACTORY_DEFINE (TAO_Dynamic_TP, TAO_Dynamic_TP_Config)
-ACE_STATIC_SVC_DEFINE (TAO_Dynamic_TP_Config,
- ACE_TEXT ("Dynamic_TP_Config"),
+ACE_FACTORY_DEFINE (TAO_Dynamic_TP, TAO_DTP_Config)
+ACE_STATIC_SVC_DEFINE (TAO_DTP_Config,
+ ACE_TEXT ("DTP_Config"),
ACE_SVC_OBJ_T,
- &ACE_SVC_NAME (TAO_Dynamic_TP_Config),
+ &ACE_SVC_NAME (TAO_DTP_Config),
ACE_Service_Type::DELETE_THIS
| ACE_Service_Type::DELETE_OBJ,
0)
diff --git a/TAO/tao/Dynamic_TP/Dynamic_TP_Config.h b/TAO/tao/Dynamic_TP/DTP_Config.h
index 4ae17614764..6deddf381de 100644
--- a/TAO/tao/Dynamic_TP/Dynamic_TP_Config.h
+++ b/TAO/tao/Dynamic_TP/DTP_Config.h
@@ -53,17 +53,17 @@ struct TAO_Dynamic_TP_Export TAO_DTP_Definition
};
-class TAO_Dynamic_TP_Export TAO_Dynamic_TP_Config_Registry_Installer
+class TAO_Dynamic_TP_Export TAO_DTP_Config_Registry_Installer
{
public:
- TAO_Dynamic_TP_Config_Registry_Installer (void);
+ TAO_DTP_Config_Registry_Installer (void);
};
-class TAO_Dynamic_TP_Export TAO_Dynamic_TP_Config_Registry : public ACE_Service_Object
+class TAO_Dynamic_TP_Export TAO_DTP_Config_Registry : public ACE_Service_Object
{
public:
- TAO_Dynamic_TP_Config_Registry (void);
- virtual ~TAO_Dynamic_TP_Config_Registry (void);
+ TAO_DTP_Config_Registry (void);
+ virtual ~TAO_DTP_Config_Registry (void);
virtual int init (int argc, ACE_TCHAR* []);
@@ -78,14 +78,14 @@ public:
Registry registry_;
};
-class TAO_Dynamic_TP_Export TAO_Dynamic_TP_Config : public ACE_Service_Object
+class TAO_Dynamic_TP_Export TAO_DTP_Config : public ACE_Service_Object
{
public:
/// Constructor.
- TAO_Dynamic_TP_Config (void);
+ TAO_DTP_Config (void);
/// Destructor.
- virtual ~TAO_Dynamic_TP_Config (void);
+ virtual ~TAO_DTP_Config (void);
/// Read a definition parameter set from the supplied args.
/// There must be a -TPName argument, which, if replicated will cause the set to be ignored, unless -TPOverwrite is also set
@@ -107,14 +107,14 @@ private:
};
-static TAO_Dynamic_TP_Config_Registry_Installer config_installer;
+static TAO_DTP_Config_Registry_Installer config_installer;
-ACE_STATIC_SVC_DECLARE_EXPORT (TAO_Dynamic_TP, TAO_Dynamic_TP_Config_Registry)
-ACE_FACTORY_DECLARE (TAO_Dynamic_TP, TAO_Dynamic_TP_Config_Registry)
+ACE_STATIC_SVC_DECLARE_EXPORT (TAO_Dynamic_TP, TAO_DTP_Config_Registry)
+ACE_FACTORY_DECLARE (TAO_Dynamic_TP, TAO_DTP_Config_Registry)
-ACE_STATIC_SVC_DECLARE_EXPORT (TAO_Dynamic_TP, TAO_Dynamic_TP_Config)
-ACE_FACTORY_DECLARE (TAO_Dynamic_TP, TAO_Dynamic_TP_Config)
+ACE_STATIC_SVC_DECLARE_EXPORT (TAO_Dynamic_TP, TAO_DTP_Config)
+ACE_FACTORY_DECLARE (TAO_Dynamic_TP, TAO_DTP_Config)
TAO_END_VERSIONED_NAMESPACE_DECL
diff --git a/TAO/tao/Dynamic_TP/Dynamic_TP_ORBInitializer.cpp b/TAO/tao/Dynamic_TP/DTP_ORBInitializer.cpp
index 48732e1554b..81dac29403e 100644
--- a/TAO/tao/Dynamic_TP/Dynamic_TP_ORBInitializer.cpp
+++ b/TAO/tao/Dynamic_TP/DTP_ORBInitializer.cpp
@@ -1,6 +1,6 @@
// $Id$
-#include "tao/Dynamic_TP/Dynamic_TP_ORBInitializer.h"
+#include "tao/Dynamic_TP/DTP_ORBInitializer.h"
#if defined (TAO_HAS_CORBA_MESSAGING) && TAO_HAS_CORBA_MESSAGING != 0
@@ -27,7 +27,7 @@
#include "tao/RTCORBA/RT_Service_Context_Handler.h"
#endif
-#include "tao/Dynamic_TP/Dynamic_TP_Config.h"
+#include "tao/Dynamic_TP/DTP_Config.h"
#include "tao/Dynamic_TP/DTP_Thread_Lane_Resources_Manager.h"
#include "tao/Dynamic_TP/DTP_Thread_Pool.h"
#include "tao/Exception.h"
@@ -40,24 +40,24 @@
#include "ace/Sched_Params.h"
#if 0
-static const char rt_poa_factory_name[] = "TAO_Dynamic_TP_Object_Adapter_Factory";
+static const char rt_poa_factory_name[] = "TAO_DTP_Object_Adapter_Factory";
static const ACE_TCHAR rt_poa_factory_directive[] =
ACE_DYNAMIC_SERVICE_DIRECTIVE(
- "TAO_Dynamic_TP_Object_Adapter_Factory",
+ "TAO_DTP_Object_Adapter_Factory",
"TAO_RTPortableServer",
- "_make_TAO_Dynamic_TP_Object_Adapter_Factory",
+ "_make_TAO_DTP_Object_Adapter_Factory",
"");
#endif
TAO_BEGIN_VERSIONED_NAMESPACE_DECL
-TAO_Dynamic_TP_ORBInitializer::TAO_Dynamic_TP_ORBInitializer (/*const ACE_CString &tplist*/)
+TAO_DTP_ORBInitializer::TAO_DTP_ORBInitializer (/*const ACE_CString &tplist*/)
{
}
void
-TAO_Dynamic_TP_ORBInitializer::pre_init (PortableInterceptor::ORBInitInfo_ptr info)
+TAO_DTP_ORBInitializer::pre_init (PortableInterceptor::ORBInitInfo_ptr info)
{
TAO_ORBInitInfo_var tao_info = TAO_ORBInitInfo::_narrow (info);
@@ -65,7 +65,7 @@ TAO_Dynamic_TP_ORBInitializer::pre_init (PortableInterceptor::ORBInitInfo_ptr in
{
if (TAO_debug_level > 0)
ACE_ERROR ((LM_ERROR,
- "(%P|%t) TAO_Dynamic_TP_ORBInitializer::pre_init:\n"
+ "(%P|%t) TAO_DTP_ORBInitializer::pre_init:\n"
"(%P|%t) Unable to narrow "
"\"PortableInterceptor::ORBInitInfo_ptr\" to\n"
"(%P|%t) \"TAO_ORBInitInfo *.\"\n"));
@@ -79,7 +79,7 @@ TAO_Dynamic_TP_ORBInitializer::pre_init (PortableInterceptor::ORBInitInfo_ptr in
ACE_Service_Object * const config_obj =
ACE_Dynamic_Service<ACE_Service_Object>::instance (
gestalt,
- "Dynamic_TP_Config",
+ "DTP_Config",
true);
if (config_obj == 0)
{
@@ -87,13 +87,13 @@ TAO_Dynamic_TP_ORBInitializer::pre_init (PortableInterceptor::ORBInitInfo_ptr in
return;
}
- TAO_Dynamic_TP_Config *config_mgr = dynamic_cast<TAO_Dynamic_TP_Config *>(config_obj);
+ TAO_DTP_Config *config_mgr = dynamic_cast<TAO_DTP_Config *>(config_obj);
if (config_mgr == 0)
{
if (TAO_debug_level > 0)
ACE_ERROR ((LM_ERROR,
- ACE_TEXT ("(%P|%t) TAO_Dynamic_TP_ORBInitializer::pre_init:\n")
- ACE_TEXT ("(%P|%t) Unable to resolve Dynamic_TP_Config object\n")));
+ ACE_TEXT ("(%P|%t) TAO_DTP_ORBInitializer::pre_init:\n")
+ ACE_TEXT ("(%P|%t) Unable to resolve DTP_Config object\n")));
throw ::CORBA::INTERNAL ();
}
@@ -105,7 +105,7 @@ TAO_Dynamic_TP_ORBInitializer::pre_init (PortableInterceptor::ORBInitInfo_ptr in
}
void
-TAO_Dynamic_TP_ORBInitializer::post_init (PortableInterceptor::ORBInitInfo_ptr info)
+TAO_DTP_ORBInitializer::post_init (PortableInterceptor::ORBInitInfo_ptr info)
{
TAO_ORBInitInfo_var tao_info = TAO_ORBInitInfo::_narrow (info);
@@ -119,10 +119,10 @@ TAO_Dynamic_TP_ORBInitializer::post_init (PortableInterceptor::ORBInitInfo_ptr i
if (dtp_name != 0 && dtp_name[0] != 0)
{
- TAO_Dynamic_TP_Config_Registry *config_registry =
- dynamic_cast<TAO_Dynamic_TP_Config_Registry *>
+ TAO_DTP_Config_Registry *config_registry =
+ dynamic_cast<TAO_DTP_Config_Registry *>
(ACE_Dynamic_Service<ACE_Service_Object>::instance
- (gestalt, "Dynamic_TP_Config_Registry", true));
+ (gestalt, "DTP_Config_Registry", true));
TAO_DTP_Definition def;
@@ -130,8 +130,8 @@ TAO_Dynamic_TP_ORBInitializer::post_init (PortableInterceptor::ORBInitInfo_ptr i
{
if (TAO_debug_level > 0)
ACE_ERROR ((LM_ERROR,
- ACE_TEXT ("(%P|%t) TAO_Dynamic_TP_ORBInitializer::pre_init:\n")
- ACE_TEXT ("(%P|%t) Unable to resolve Dynamic_TP_Config object\n")));
+ ACE_TEXT ("(%P|%t) TAO_DTP_ORBInitializer::pre_init:\n")
+ ACE_TEXT ("(%P|%t) Unable to resolve DTP_Config object\n")));
throw ::CORBA::INTERNAL ();
}
diff --git a/TAO/tao/Dynamic_TP/Dynamic_TP_ORBInitializer.h b/TAO/tao/Dynamic_TP/DTP_ORBInitializer.h
index c362b418ead..770ac31b50d 100644
--- a/TAO/tao/Dynamic_TP/Dynamic_TP_ORBInitializer.h
+++ b/TAO/tao/Dynamic_TP/DTP_ORBInitializer.h
@@ -2,7 +2,7 @@
//=============================================================================
/**
- * @file Dynamic_TP_ORBInitializer.h
+ * @file DTP_ORBInitializer.h
*
* $Id$
*
@@ -39,13 +39,13 @@
TAO_BEGIN_VERSIONED_NAMESPACE_DECL
/// Dynamic_TP ORB initializer.
-class TAO_Dynamic_TP_ORBInitializer
+class TAO_DTP_ORBInitializer
: public virtual PortableInterceptor::ORBInitializer
, public virtual ::CORBA::LocalObject
{
public:
- TAO_Dynamic_TP_ORBInitializer (void);
+ TAO_DTP_ORBInitializer (void);
virtual void pre_init (PortableInterceptor::ORBInitInfo_ptr info);
diff --git a/TAO/tao/Dynamic_TP/Dynamic_TP_ORB_Loader.cpp b/TAO/tao/Dynamic_TP/DTP_ORB_Loader.cpp
index 89cc8f63309..984abc5d438 100644
--- a/TAO/tao/Dynamic_TP/Dynamic_TP_ORB_Loader.cpp
+++ b/TAO/tao/Dynamic_TP/DTP_ORB_Loader.cpp
@@ -1,10 +1,10 @@
// $Id$
-#include "tao/Dynamic_TP/Dynamic_TP_ORB_Loader.h"
+#include "tao/Dynamic_TP/DTP_ORB_Loader.h"
#if defined (TAO_HAS_CORBA_MESSAGING) && TAO_HAS_CORBA_MESSAGING != 0
-#include "tao/Dynamic_TP/Dynamic_TP_ORBInitializer.h"
+#include "tao/Dynamic_TP/DTP_ORBInitializer.h"
#include "tao/debug.h"
#include "tao/ORB_Constants.h"
@@ -16,19 +16,19 @@
TAO_BEGIN_VERSIONED_NAMESPACE_DECL
-TAO_Dynamic_TP_ORB_Loader::TAO_Dynamic_TP_ORB_Loader (void)
+TAO_DTP_ORB_Loader::TAO_DTP_ORB_Loader (void)
: initialized_ (false)
{
}
-TAO_Dynamic_TP_ORB_Loader::~TAO_Dynamic_TP_ORB_Loader (void)
+TAO_DTP_ORB_Loader::~TAO_DTP_ORB_Loader (void)
{
}
int
-TAO_Dynamic_TP_ORB_Loader::init (int argc, ACE_TCHAR* argv[])
+TAO_DTP_ORB_Loader::init (int argc, ACE_TCHAR* argv[])
{
- ACE_TRACE ("TAO_Dynamic_TP_ORB_Loader::init");
+ ACE_TRACE ("TAO_DTP_ORB_Loader::init");
// Only allow initialization once.
if (this->initialized_)
@@ -46,7 +46,7 @@ TAO_Dynamic_TP_ORB_Loader::init (int argc, ACE_TCHAR* argv[])
if (TAO_debug_level > 0)
{
ACE_DEBUG ((LM_DEBUG,
- ACE_TEXT ("TAO (%P|%t) - Dynamic_TP_ORB_Loader - ")
+ ACE_TEXT ("TAO (%P|%t) - DTP_ORB_Loader - ")
ACE_TEXT ("DTPORB arbument missing value\n")));
}
return -1;
@@ -57,7 +57,7 @@ TAO_Dynamic_TP_ORB_Loader::init (int argc, ACE_TCHAR* argv[])
if (TAO_debug_level > 0)
{
ACE_DEBUG ((LM_DEBUG,
- ACE_TEXT ("TAO (%P|%t) - Dynamic_TP_ORB_Loader -")
+ ACE_TEXT ("TAO (%P|%t) - DTP_ORB_Loader -")
ACE_TEXT (" Unrecognized argv[%d], %C\n"),
curarg, argv[curarg]));
}
@@ -73,7 +73,7 @@ TAO_Dynamic_TP_ORB_Loader::init (int argc, ACE_TCHAR* argv[])
/// Register the DynamicTP ORBInitializer.
ACE_NEW_THROW_EX (temp_orb_initializer,
- TAO_Dynamic_TP_ORBInitializer (),
+ TAO_DTP_ORBInitializer (),
CORBA::NO_MEMORY (
CORBA::SystemException::_tao_minor_code (
TAO::VMCID,
@@ -99,11 +99,11 @@ TAO_Dynamic_TP_ORB_Loader::init (int argc, ACE_TCHAR* argv[])
/////////////////////////////////////////////////////////////////////
-ACE_FACTORY_DEFINE (TAO_Dynamic_TP, TAO_Dynamic_TP_ORB_Loader)
-ACE_STATIC_SVC_DEFINE (TAO_Dynamic_TP_ORB_Loader,
- ACE_TEXT ("Dynamic_TP_ORB_Loader"),
+ACE_FACTORY_DEFINE (TAO_Dynamic_TP, TAO_DTP_ORB_Loader)
+ACE_STATIC_SVC_DEFINE (TAO_DTP_ORB_Loader,
+ ACE_TEXT ("DTP_ORB_Loader"),
ACE_SVC_OBJ_T,
- &ACE_SVC_NAME (TAO_Dynamic_TP_ORB_Loader),
+ &ACE_SVC_NAME (TAO_DTP_ORB_Loader),
ACE_Service_Type::DELETE_THIS
| ACE_Service_Type::DELETE_OBJ,
0)
diff --git a/TAO/tao/Dynamic_TP/Dynamic_TP_ORB_Loader.h b/TAO/tao/Dynamic_TP/DTP_ORB_Loader.h
index 476c7e2b156..ffef32befd2 100644
--- a/TAO/tao/Dynamic_TP/Dynamic_TP_ORB_Loader.h
+++ b/TAO/tao/Dynamic_TP/DTP_ORB_Loader.h
@@ -2,7 +2,7 @@
//=============================================================================
/**
- * @file Dynamic_TP_ORB_Loader.h
+ * @file DTP_ORB_Loader.h
*
* $Id$
*
@@ -33,15 +33,15 @@ TAO_BEGIN_VERSIONED_NAMESPACE_DECL
class TAO_ORB_Core;
-class TAO_Dynamic_TP_Export TAO_Dynamic_TP_ORB_Loader : public ACE_Service_Object
+class TAO_Dynamic_TP_Export TAO_DTP_ORB_Loader : public ACE_Service_Object
{
public:
/// Constructor.
- TAO_Dynamic_TP_ORB_Loader (void);
+ TAO_DTP_ORB_Loader (void);
/// Destructor.
- virtual ~TAO_Dynamic_TP_ORB_Loader (void);
+ virtual ~TAO_DTP_ORB_Loader (void);
/// Initialize the DynamicTP loader hooks.
virtual int init (int argc, ACE_TCHAR* []);
@@ -52,8 +52,8 @@ private:
};
-ACE_STATIC_SVC_DECLARE_EXPORT (TAO_Dynamic_TP, TAO_Dynamic_TP_ORB_Loader)
-ACE_FACTORY_DECLARE (TAO_Dynamic_TP, TAO_Dynamic_TP_ORB_Loader)
+ACE_STATIC_SVC_DECLARE_EXPORT (TAO_Dynamic_TP, TAO_DTP_ORB_Loader)
+ACE_FACTORY_DECLARE (TAO_Dynamic_TP, TAO_DTP_ORB_Loader)
TAO_END_VERSIONED_NAMESPACE_DECL
diff --git a/TAO/tao/Dynamic_TP/Dynamic_TP_POA_Loader.cpp b/TAO/tao/Dynamic_TP/DTP_POA_Loader.cpp
index c00266f37b0..cf5320e6a15 100644
--- a/TAO/tao/Dynamic_TP/Dynamic_TP_POA_Loader.cpp
+++ b/TAO/tao/Dynamic_TP/DTP_POA_Loader.cpp
@@ -1,13 +1,13 @@
// $Id$
-#include "tao/Dynamic_TP/Dynamic_TP_POA_Loader.h"
+#include "tao/Dynamic_TP/DTP_POA_Loader.h"
#if defined (TAO_HAS_CORBA_MESSAGING) && TAO_HAS_CORBA_MESSAGING != 0
#include "tao/debug.h"
#include "tao/CSD_Framework/CSD_Framework_Loader.h"
-#include "tao/Dynamic_TP/Dynamic_TP_Config.h"
-#include "tao/Dynamic_TP/Dynamic_TP_POA_Strategy.h"
+#include "tao/Dynamic_TP/DTP_Config.h"
+#include "tao/Dynamic_TP/DTP_POA_Strategy.h"
#include "ace/OS_NS_strings.h"
#include "tao/CSD_Framework/CSD_ORBInitializer.h"
#include "tao/PI/DLL_Resident_ORB_Initializer.h"
@@ -17,20 +17,20 @@
TAO_BEGIN_VERSIONED_NAMESPACE_DECL
-TAO_Dynamic_TP_POA_Loader::TAO_Dynamic_TP_POA_Loader (void)
+TAO_DTP_POA_Loader::TAO_DTP_POA_Loader (void)
{
}
-TAO_Dynamic_TP_POA_Loader::~TAO_Dynamic_TP_POA_Loader (void)
+TAO_DTP_POA_Loader::~TAO_DTP_POA_Loader (void)
{
}
int
-TAO_Dynamic_TP_POA_Loader::init (int argc, ACE_TCHAR* argv[])
+TAO_DTP_POA_Loader::init (int argc, ACE_TCHAR* argv[])
{
//TAO_debug_level = 5;
- ACE_TRACE ("TAO_Dynamic_TP_POA_Loader::init");
+ ACE_TRACE ("TAO_DTP_POA_Loader::init");
// Only allow initialization once.
static bool initialized = false;
@@ -59,7 +59,7 @@ TAO_Dynamic_TP_POA_Loader::init (int argc, ACE_TCHAR* argv[])
if (TAO_debug_level > 0)
{
ACE_DEBUG((LM_DEBUG,
- ACE_TEXT ("TAO (%P|%t) - Dynamic_TP_POA_Loader - ")
+ ACE_TEXT ("TAO (%P|%t) - DTP_POA_Loader - ")
ACE_TEXT ("cannot initialize strategy repo\n")));
}
return -1;
@@ -73,7 +73,7 @@ TAO_Dynamic_TP_POA_Loader::init (int argc, ACE_TCHAR* argv[])
if (TAO_debug_level > 0)
{
ACE_DEBUG((LM_DEBUG,
- ACE_TEXT ("TAO (%P|%t) - Dynamic_TP_POA_Loader - parsing args\n")));
+ ACE_TEXT ("TAO (%P|%t) - DTP_POA_Loader - parsing args\n")));
}
if (ACE_OS::strcasecmp (argv[curarg], ACE_TEXT ("-DTPPOAConfigMap")) == 0)
@@ -100,7 +100,7 @@ TAO_Dynamic_TP_POA_Loader::init (int argc, ACE_TCHAR* argv[])
if (TAO_debug_level > 0)
{
ACE_ERROR ((LM_ERROR,
- ACE_TEXT ("Dynamic_TP_POA_Loader: Missing option\n")
+ ACE_TEXT ("DTP_POA_Loader: Missing option\n")
ACE_TEXT ("Usage: -DTPPOAConfigMap <comma-separated ")
ACE_TEXT ("list of POAs>:<POA Config Name>\n")
ACE_TEXT ("<%s>.\n"),
@@ -115,13 +115,13 @@ TAO_Dynamic_TP_POA_Loader::init (int argc, ACE_TCHAR* argv[])
int
-TAO_Dynamic_TP_POA_Loader::load_poa_map (ACE_TCHAR *map,
+TAO_DTP_POA_Loader::load_poa_map (ACE_TCHAR *map,
TAO_CSD_Strategy_Repository *repo)
{
ACE_CString poa_name;
ACE_CString config_name;
- TAO_Dynamic_TP_POA_Strategy * strategy_container = 0;
+ TAO_DTP_POA_Strategy * strategy_container = 0;
ACE_TCHAR *sep = ACE_OS::strchr (map, ':');
@@ -130,7 +130,7 @@ TAO_Dynamic_TP_POA_Loader::load_poa_map (ACE_TCHAR *map,
if (TAO_debug_level > 0)
{
ACE_ERROR ((LM_ERROR,
- ACE_TEXT ("Dynamic_TP_POA_Loader: Missing option\n")
+ ACE_TEXT ("DTP_POA_Loader: Missing option\n")
ACE_TEXT ("Usage: -DTPPOAConfigMap <comma-separated ")
ACE_TEXT ("list of POAs>:<POA Config Name>\n<%s>.\n"),
map));
@@ -146,7 +146,7 @@ TAO_Dynamic_TP_POA_Loader::load_poa_map (ACE_TCHAR *map,
// strategy configuration container.
ACE_NEW_RETURN(strategy_container,
- TAO_Dynamic_TP_POA_Strategy(config_name,
+ TAO_DTP_POA_Strategy(config_name,
false), -1);
sep = ACE_OS::strchr (map, ',');
@@ -165,13 +165,13 @@ TAO_Dynamic_TP_POA_Loader::load_poa_map (ACE_TCHAR *map,
}
void
-TAO_Dynamic_TP_POA_Loader::report_option_value_error (const ACE_TCHAR* name,
+TAO_DTP_POA_Loader::report_option_value_error (const ACE_TCHAR* name,
const ACE_TCHAR* value)
{
if (TAO_debug_level > 0)
{
ACE_DEBUG((LM_DEBUG,
- ACE_TEXT ("TAO (%P|%t) - Dynamic_TP_POA_Loader - unknown ")
+ ACE_TEXT ("TAO (%P|%t) - DTP_POA_Loader - unknown ")
ACE_TEXT ("argument <%s> for <%s>\n"),
value, name));
}
@@ -181,11 +181,11 @@ TAO_Dynamic_TP_POA_Loader::report_option_value_error (const ACE_TCHAR* name,
/////////////////////////////////////////////////////////////////////
-ACE_FACTORY_DEFINE (TAO_Dynamic_TP, TAO_Dynamic_TP_POA_Loader)
-ACE_STATIC_SVC_DEFINE (TAO_Dynamic_TP_POA_Loader,
- ACE_TEXT ("Dynamic_TP_POA_Loader"),
+ACE_FACTORY_DEFINE (TAO_Dynamic_TP, TAO_DTP_POA_Loader)
+ACE_STATIC_SVC_DEFINE (TAO_DTP_POA_Loader,
+ ACE_TEXT ("DTP_POA_Loader"),
ACE_SVC_OBJ_T,
- &ACE_SVC_NAME (TAO_Dynamic_TP_POA_Loader),
+ &ACE_SVC_NAME (TAO_DTP_POA_Loader),
ACE_Service_Type::DELETE_THIS
| ACE_Service_Type::DELETE_OBJ,
0)
diff --git a/TAO/tao/Dynamic_TP/Dynamic_TP_POA_Loader.h b/TAO/tao/Dynamic_TP/DTP_POA_Loader.h
index 567370f8675..9fba1917330 100644
--- a/TAO/tao/Dynamic_TP/Dynamic_TP_POA_Loader.h
+++ b/TAO/tao/Dynamic_TP/DTP_POA_Loader.h
@@ -2,7 +2,7 @@
//=============================================================================
/**
- * @file Dynamic_TP_POA_Loader.h
+ * @file DTP_POA_Loader.h
*
* $Id$
*
@@ -18,7 +18,7 @@
#include /**/ "ace/pre.h"
#include "tao/orbconf.h"
#include "tao/Dynamic_TP/dynamic_tp_export.h"
-#include "tao/Dynamic_TP/Dynamic_TP_Config.h"
+#include "tao/Dynamic_TP/DTP_Config.h"
#include "tao/CSD_Framework/CSD_Strategy_Repository.h"
#include "ace/Synch.h"
#include "ace/Service_Object.h"
@@ -33,15 +33,15 @@ TAO_BEGIN_VERSIONED_NAMESPACE_DECL
class TAO_POA_Core; //TODO: Do we still need this?
-class TAO_Dynamic_TP_Export TAO_Dynamic_TP_POA_Loader : public ACE_Service_Object
+class TAO_Dynamic_TP_Export TAO_DTP_POA_Loader : public ACE_Service_Object
{
public:
/// Constructor.
- TAO_Dynamic_TP_POA_Loader (void);
+ TAO_DTP_POA_Loader (void);
/// Destructor.
- virtual ~TAO_Dynamic_TP_POA_Loader (void);
+ virtual ~TAO_DTP_POA_Loader (void);
/// Initialize the DynamicTP loader hooks.
virtual int init (int argc, ACE_TCHAR* []);
@@ -55,8 +55,8 @@ private:
const ACE_TCHAR* option_value);
};
-ACE_STATIC_SVC_DECLARE_EXPORT (TAO_Dynamic_TP, TAO_Dynamic_TP_POA_Loader)
-ACE_FACTORY_DECLARE (TAO_Dynamic_TP, TAO_Dynamic_TP_POA_Loader)
+ACE_STATIC_SVC_DECLARE_EXPORT (TAO_Dynamic_TP, TAO_DTP_POA_Loader)
+ACE_FACTORY_DECLARE (TAO_Dynamic_TP, TAO_DTP_POA_Loader)
TAO_END_VERSIONED_NAMESPACE_DECL
diff --git a/TAO/tao/Dynamic_TP/Dynamic_TP_POA_Strategy.cpp b/TAO/tao/Dynamic_TP/DTP_POA_Strategy.cpp
index 8d3ec1a48c5..ddc9d44f7d8 100644
--- a/TAO/tao/Dynamic_TP/Dynamic_TP_POA_Strategy.cpp
+++ b/TAO/tao/Dynamic_TP/DTP_POA_Strategy.cpp
@@ -1,6 +1,6 @@
// $Id$
-#include "tao/Dynamic_TP/Dynamic_TP_POA_Strategy.h"
+#include "tao/Dynamic_TP/DTP_POA_Strategy.h"
#include "tao/CSD_ThreadPool/CSD_TP_Remote_Request.h"
#include "tao/CSD_ThreadPool/CSD_TP_Collocated_Synch_Request.h"
#include "tao/CSD_ThreadPool/CSD_TP_Collocated_Asynch_Request.h"
@@ -13,18 +13,18 @@
#if !defined (__ACE_INLINE__)
-#include "tao/Dynamic_TP/Dynamic_TP_POA_Strategy.inl"
+#include "tao/Dynamic_TP/DTP_POA_Strategy.inl"
#endif /* ! __ACE_INLINE__ */
TAO_BEGIN_VERSIONED_NAMESPACE_DECL
-TAO_Dynamic_TP_POA_Strategy::~TAO_Dynamic_TP_POA_Strategy()
+TAO_DTP_POA_Strategy::~TAO_DTP_POA_Strategy()
{
}
-TAO_Dynamic_TP_POA_Strategy::CustomRequestOutcome
-TAO_Dynamic_TP_POA_Strategy::custom_synch_request(TAO::CSD::TP_Custom_Request_Operation* op)
+TAO_DTP_POA_Strategy::CustomRequestOutcome
+TAO_DTP_POA_Strategy::custom_synch_request(TAO::CSD::TP_Custom_Request_Operation* op)
{
TAO::CSD::TP_Servant_State::HandleType servant_state =
@@ -43,8 +43,8 @@ TAO_Dynamic_TP_POA_Strategy::custom_synch_request(TAO::CSD::TP_Custom_Request_Op
return (request->wait()) ? REQUEST_EXECUTED : REQUEST_CANCELLED;
}
-TAO_Dynamic_TP_POA_Strategy::CustomRequestOutcome
-TAO_Dynamic_TP_POA_Strategy::custom_asynch_request(TAO::CSD::TP_Custom_Request_Operation* op)
+TAO_DTP_POA_Strategy::CustomRequestOutcome
+TAO_DTP_POA_Strategy::custom_asynch_request(TAO::CSD::TP_Custom_Request_Operation* op)
{
TAO::CSD::TP_Servant_State::HandleType servant_state =
@@ -58,7 +58,7 @@ TAO_Dynamic_TP_POA_Strategy::custom_asynch_request(TAO::CSD::TP_Custom_Request_O
}
bool
-TAO_Dynamic_TP_POA_Strategy::poa_activated_event_i(TAO_ORB_Core& orb_core)
+TAO_DTP_POA_Strategy::poa_activated_event_i(TAO_ORB_Core& orb_core)
{
this->dtp_task_.thr_mgr(orb_core.thr_mgr());
@@ -67,16 +67,16 @@ TAO_Dynamic_TP_POA_Strategy::poa_activated_event_i(TAO_ORB_Core& orb_core)
if (!this->config_initialized_)
{
- TAO_Dynamic_TP_Config_Registry * config_repo =
- ACE_Dynamic_Service<TAO_Dynamic_TP_Config_Registry>::instance
- ("Dynamic_TP_Config_Registry");
+ TAO_DTP_Config_Registry * config_repo =
+ ACE_Dynamic_Service<TAO_DTP_Config_Registry>::instance
+ ("DTP_Config_Registry");
if (config_repo == 0)
{
if (TAO_debug_level > 0)
{
ACE_DEBUG((LM_DEBUG,
- ACE_TEXT ("TAO (%P|%t) - Dynamic_TP_POA_Strategy - ")
+ ACE_TEXT ("TAO (%P|%t) - DTP_POA_Strategy - ")
ACE_TEXT ("cannot retrieve configuration repo\n")));
}
return false;
@@ -87,7 +87,7 @@ TAO_Dynamic_TP_POA_Strategy::poa_activated_event_i(TAO_ORB_Core& orb_core)
if (!config_repo->find(this->dynamic_tp_config_name_, config_entry))
{
ACE_DEBUG((LM_DEBUG,
- ACE_TEXT ("TAO (%P|%t) - Dynamic_TP_POA_Strategy - ")
+ ACE_TEXT ("TAO (%P|%t) - DTP_POA_Strategy - ")
ACE_TEXT ("warning: config not found...using defaults!\n")));
}
@@ -108,7 +108,7 @@ TAO_Dynamic_TP_POA_Strategy::poa_activated_event_i(TAO_ORB_Core& orb_core)
}
void
-TAO_Dynamic_TP_POA_Strategy::poa_deactivated_event_i()
+TAO_DTP_POA_Strategy::poa_deactivated_event_i()
{
// Passing in a value of 1 means that we want to shutdown the task, which
// equates to causing all worker threads to shutdown. The worker threads
@@ -119,7 +119,7 @@ TAO_Dynamic_TP_POA_Strategy::poa_deactivated_event_i()
}
TAO::CSD::Strategy_Base::DispatchResult
-TAO_Dynamic_TP_POA_Strategy::dispatch_remote_request_i
+TAO_DTP_POA_Strategy::dispatch_remote_request_i
(TAO_ServerRequest& server_request,
const PortableServer::ObjectId& object_id,
PortableServer::POA_ptr poa,
@@ -156,7 +156,7 @@ TAO_Dynamic_TP_POA_Strategy::dispatch_remote_request_i
}
TAO::CSD::Strategy_Base::DispatchResult
-TAO_Dynamic_TP_POA_Strategy::dispatch_collocated_request_i
+TAO_DTP_POA_Strategy::dispatch_collocated_request_i
(TAO_ServerRequest& server_request,
const PortableServer::ObjectId& object_id,
PortableServer::POA_ptr poa,
@@ -250,7 +250,7 @@ TAO_Dynamic_TP_POA_Strategy::dispatch_collocated_request_i
}
void
-TAO_Dynamic_TP_POA_Strategy::servant_activated_event_i
+TAO_DTP_POA_Strategy::servant_activated_event_i
(PortableServer::Servant servant,
const PortableServer::ObjectId&)
{
@@ -262,7 +262,7 @@ TAO_Dynamic_TP_POA_Strategy::servant_activated_event_i
}
void
-TAO_Dynamic_TP_POA_Strategy::servant_deactivated_event_i
+TAO_DTP_POA_Strategy::servant_deactivated_event_i
(PortableServer::Servant servant,
const PortableServer::ObjectId&)
{
@@ -277,14 +277,14 @@ TAO_Dynamic_TP_POA_Strategy::servant_deactivated_event_i
}
void
-TAO_Dynamic_TP_POA_Strategy::cancel_requests(PortableServer::Servant servant)
+TAO_DTP_POA_Strategy::cancel_requests(PortableServer::Servant servant)
{
// Cancel all requests stuck in the queue for the specified servant.
this->dtp_task_.cancel_servant(servant);
}
TAO::CSD::TP_Servant_State::HandleType
-TAO_Dynamic_TP_POA_Strategy::get_servant_state(PortableServer::Servant servant)
+TAO_DTP_POA_Strategy::get_servant_state(PortableServer::Servant servant)
{
TAO::CSD::TP_Servant_State::HandleType servant_state;
@@ -297,7 +297,7 @@ TAO_Dynamic_TP_POA_Strategy::get_servant_state(PortableServer::Servant servant)
}
void
-TAO_Dynamic_TP_POA_Strategy::set_dtp_config(TAO_DTP_Definition &tp_config)
+TAO_DTP_POA_Strategy::set_dtp_config(TAO_DTP_Definition &tp_config)
{
if (tp_config.min_threads_ <= 0)
@@ -363,14 +363,14 @@ TAO_Dynamic_TP_POA_Strategy::set_dtp_config(TAO_DTP_Definition &tp_config)
if (TAO_debug_level > 4)
{
ACE_DEBUG ((LM_DEBUG,
- ACE_TEXT ("TAO (%P|%t) - Dynamic_TP_POA_Strategy: ")
+ ACE_TEXT ("TAO (%P|%t) - DTP_POA_Strategy: ")
ACE_TEXT ("Initialized with:\n")
- ACE_TEXT ("TAO (%P|%t) - Dynamic_TP_POA_Strategy initial_pool_threads_=[%d]\n")
- ACE_TEXT ("TAO (%P|%t) - Dynamic_TP_POA_Strategy min_pool_threads_=[%d]\n")
- ACE_TEXT ("TAO (%P|%t) - Dynamic_TP_POA_Strategy max_pool_threads_=[%d]\n")
- ACE_TEXT ("TAO (%P|%t) - Dynamic_TP_POA_Strategy max_request_queue_depth_=[%d]\n")
- ACE_TEXT ("TAO (%P|%t) - Dynamic_TP_POA_Strategy thread_stack_size_=[%d]\n")
- ACE_TEXT ("TAO (%P|%t) - Dynamic_TP_POA_Strategy thread_idle_time_=[%d]\n"),
+ ACE_TEXT ("TAO (%P|%t) - DTP_POA_Strategy initial_pool_threads_=[%d]\n")
+ ACE_TEXT ("TAO (%P|%t) - DTP_POA_Strategy min_pool_threads_=[%d]\n")
+ ACE_TEXT ("TAO (%P|%t) - DTP_POA_Strategy max_pool_threads_=[%d]\n")
+ ACE_TEXT ("TAO (%P|%t) - DTP_POA_Strategy max_request_queue_depth_=[%d]\n")
+ ACE_TEXT ("TAO (%P|%t) - DTP_POA_Strategy thread_stack_size_=[%d]\n")
+ ACE_TEXT ("TAO (%P|%t) - DTP_POA_Strategy thread_idle_time_=[%d]\n"),
this->dtp_task_.get_init_pool_threads(),
this->dtp_task_.get_min_pool_threads(),
this->dtp_task_.get_max_pool_threads(),
diff --git a/TAO/tao/Dynamic_TP/Dynamic_TP_POA_Strategy.h b/TAO/tao/Dynamic_TP/DTP_POA_Strategy.h
index 5e96fc98f81..51533e334b1 100644
--- a/TAO/tao/Dynamic_TP/Dynamic_TP_POA_Strategy.h
+++ b/TAO/tao/Dynamic_TP/DTP_POA_Strategy.h
@@ -2,7 +2,7 @@
//=============================================================================
/**
- * @file Dynamic_TP_POA_Strategy.h
+ * @file DTP_POA_Strategy.h
*
* $Id$
*
@@ -15,8 +15,8 @@
#include /**/ "ace/pre.h"
#include "tao/Dynamic_TP/dynamic_tp_export.h"
-#include "tao/Dynamic_TP/Dynamic_TP_Config.h"
-#include "tao/Dynamic_TP/Dynamic_TP_Task.h"
+#include "tao/Dynamic_TP/DTP_Config.h"
+#include "tao/Dynamic_TP/DTP_Task.h"
#include "tao/CSD_ThreadPool/CSD_TP_Servant_State_Map.h"
#include "tao/CSD_ThreadPool/CSD_TP_Custom_Request_Operation.h"
#include "tao/CSD_ThreadPool/CSD_TP_Strategy.h"
@@ -33,9 +33,9 @@
TAO_BEGIN_VERSIONED_NAMESPACE_DECL
-class TAO_Dynamic_TP_POA_Strategy;
-typedef TAO_Intrusive_Ref_Count_Handle<TAO_Dynamic_TP_POA_Strategy>
- TAO_Dynamic_TP_POA_Strategy_Handle;
+class TAO_DTP_POA_Strategy;
+typedef TAO_Intrusive_Ref_Count_Handle<TAO_DTP_POA_Strategy>
+ TAO_DTP_POA_Strategy_Handle;
namespace TAO
{
@@ -47,12 +47,12 @@ namespace TAO
/**
- * @class TAO_Dynamic_TP_POA_Strategy
+ * @class TAO_DTP_POA_Strategy
*
* @brief
*
*/
-class TAO_Dynamic_TP_Export TAO_Dynamic_TP_POA_Strategy:
+class TAO_Dynamic_TP_Export TAO_DTP_POA_Strategy:
public TAO::CSD::Strategy_Base
{
public:
@@ -62,17 +62,17 @@ class TAO_Dynamic_TP_Export TAO_Dynamic_TP_POA_Strategy:
/// of a thread pool for POAs is initiated from a svc.conf file.
/// A configuration name is passed in such that the object can
/// lookup a configuration in a pre-populated repository.
- TAO_Dynamic_TP_POA_Strategy(ACE_CString tp_config_name,
+ TAO_DTP_POA_Strategy(ACE_CString tp_config_name,
bool serialize_servants = true);
/// This constructor supports situations where explicit instantiation
/// of a thread pool for POAs is initiated from an application, such as
/// the use of the apply_to() method.
- TAO_Dynamic_TP_POA_Strategy(TAO_DTP_Definition * tp_config,
+ TAO_DTP_POA_Strategy(TAO_DTP_Definition * tp_config,
bool serialize_servants = true);
/// Virtual Destructor.
- virtual ~TAO_Dynamic_TP_POA_Strategy();
+ virtual ~TAO_DTP_POA_Strategy();
/// Turn on/off serialization of servants.
void set_servant_serialization(bool serialize_servants);
@@ -183,7 +183,7 @@ class TAO_Dynamic_TP_Export TAO_Dynamic_TP_POA_Strategy:
TAO::CSD::TP_Servant_State_Map servant_state_map_;
/// This holds the name of a configuration that have been loaded
- /// into a Dynamic_TP_Config_Registry. This is the key to the RB
+ /// into a DTP_Config_Registry. This is the key to the RB
/// Tree entry.
ACE_CString dynamic_tp_config_name_;
@@ -193,7 +193,7 @@ class TAO_Dynamic_TP_Export TAO_Dynamic_TP_POA_Strategy:
/// The strategy object puts requests into the task's request
/// queue, and the worker threads service the queued requests
/// by performing the actual servant request dispatching logic.
- TAO_Dynamic_TP_Task dtp_task_;
+ TAO_DTP_Task dtp_task_;
/// This boolean is used to determine if the configuration has
@@ -212,7 +212,7 @@ class TAO_Dynamic_TP_Export TAO_Dynamic_TP_POA_Strategy:
TAO_END_VERSIONED_NAMESPACE_DECL
#if defined (__ACE_INLINE__)
-#include "tao/Dynamic_TP/Dynamic_TP_POA_Strategy.inl"
+#include "tao/Dynamic_TP/DTP_POA_Strategy.inl"
#endif /* __ACE_INLINE__ */
#include /**/ "ace/post.h"
diff --git a/TAO/tao/Dynamic_TP/Dynamic_TP_POA_Strategy.inl b/TAO/tao/Dynamic_TP/DTP_POA_Strategy.inl
index aec25abe33e..bd6171bf599 100644
--- a/TAO/tao/Dynamic_TP/Dynamic_TP_POA_Strategy.inl
+++ b/TAO/tao/Dynamic_TP/DTP_POA_Strategy.inl
@@ -6,7 +6,7 @@ TAO_BEGIN_VERSIONED_NAMESPACE_DECL
ACE_INLINE
/// Constructor.
-TAO_Dynamic_TP_POA_Strategy::TAO_Dynamic_TP_POA_Strategy
+TAO_DTP_POA_Strategy::TAO_DTP_POA_Strategy
(ACE_CString tp_config_name,
bool ss)
: serialize_servants_ (ss),
@@ -16,7 +16,7 @@ TAO_Dynamic_TP_POA_Strategy::TAO_Dynamic_TP_POA_Strategy
}
ACE_INLINE
-TAO_Dynamic_TP_POA_Strategy::TAO_Dynamic_TP_POA_Strategy
+TAO_DTP_POA_Strategy::TAO_DTP_POA_Strategy
(TAO_DTP_Definition * tp_config,
bool ss)
: serialize_servants_ (ss),
@@ -29,7 +29,7 @@ TAO_Dynamic_TP_POA_Strategy::TAO_Dynamic_TP_POA_Strategy
ACE_INLINE
void
-TAO_Dynamic_TP_POA_Strategy::set_servant_serialization(bool serialize_servants)
+TAO_DTP_POA_Strategy::set_servant_serialization(bool serialize_servants)
{
// Simple Mutator.
this->serialize_servants_ = serialize_servants;
diff --git a/TAO/tao/Dynamic_TP/Dynamic_TP_Task.cpp b/TAO/tao/Dynamic_TP/DTP_Task.cpp
index 89f8fde099c..377f5c70779 100644
--- a/TAO/tao/Dynamic_TP/Dynamic_TP_Task.cpp
+++ b/TAO/tao/Dynamic_TP/DTP_Task.cpp
@@ -1,17 +1,17 @@
// $Id$
-#include "tao/Dynamic_TP/Dynamic_TP_Task.h"
+#include "tao/Dynamic_TP/DTP_Task.h"
#include "tao/CSD_ThreadPool/CSD_TP_Request.h"
#include "tao/CSD_ThreadPool/CSD_TP_Dispatchable_Visitor.h"
#include "tao/CSD_ThreadPool/CSD_TP_Cancel_Visitor.h"
#if !defined (__ACE_INLINE__)
-# include "tao/Dynamic_TP/Dynamic_TP_Task.inl"
+# include "tao/Dynamic_TP/DTP_Task.inl"
#endif /* ! __ACE_INLINE__ */
TAO_BEGIN_VERSIONED_NAMESPACE_DECL
-TAO_Dynamic_TP_Task::TAO_Dynamic_TP_Task()
+TAO_DTP_Task::TAO_DTP_Task()
: aw_lock_(),
queue_lock_(),
work_lock_(),
@@ -24,12 +24,12 @@ TAO_Dynamic_TP_Task::TAO_Dynamic_TP_Task()
{
}
-TAO_Dynamic_TP_Task::~TAO_Dynamic_TP_Task()
+TAO_DTP_Task::~TAO_DTP_Task()
{
}
bool
-TAO_Dynamic_TP_Task::add_request(TAO::CSD::TP_Request* request)
+TAO_DTP_Task::add_request(TAO::CSD::TP_Request* request)
{
{
ACE_GUARD_RETURN (TAO_SYNCH_MUTEX, guard, this->queue_lock_, false);
@@ -45,9 +45,9 @@ TAO_Dynamic_TP_Task::add_request(TAO::CSD::TP_Request* request)
if (TAO_debug_level > 4)
{
ACE_DEBUG ((LM_DEBUG,
- ACE_TEXT ("TAO (%P|%t) - Dynamic_TP_Task::add_request() not accepting requests.\n")
- ACE_TEXT ("TAO (%P|%t) - Dynamic_TP_Task::add_request() num_queue_requests_ : [%d]\n")
- ACE_TEXT ("TAO (%P|%t) - Dynamic_TP_Task::add_request() max_request_queue_depth_ : [%d]\n"),
+ ACE_TEXT ("TAO (%P|%t) - DTP_Task::add_request() not accepting requests.\n")
+ ACE_TEXT ("TAO (%P|%t) - DTP_Task::add_request() num_queue_requests_ : [%d]\n")
+ ACE_TEXT ("TAO (%P|%t) - DTP_Task::add_request() max_request_queue_depth_ : [%d]\n"),
this->num_queue_requests_,
this->max_request_queue_depth_));
}
@@ -71,7 +71,7 @@ TAO_Dynamic_TP_Task::add_request(TAO::CSD::TP_Request* request)
this->work_available_.signal();
if (TAO_debug_level > 4 )
{
- ACE_DEBUG((LM_DEBUG,"TAO (%P|%t) - Dynamic_TP_Task::add_request() - "
+ ACE_DEBUG((LM_DEBUG,"TAO (%P|%t) - DTP_Task::add_request() - "
"work available\n"));
}
}
@@ -79,43 +79,43 @@ TAO_Dynamic_TP_Task::add_request(TAO::CSD::TP_Request* request)
return true;
}
-size_t
-TAO_Dynamic_TP_Task::get_init_pool_threads()
+size_t
+TAO_DTP_Task::get_init_pool_threads()
{
return(this->init_pool_threads_);
}
-size_t
-TAO_Dynamic_TP_Task::get_min_pool_threads()
+size_t
+TAO_DTP_Task::get_min_pool_threads()
{
return(this->min_pool_threads_);
}
-size_t TAO_Dynamic_TP_Task::get_max_pool_threads()
+size_t TAO_DTP_Task::get_max_pool_threads()
{
return(this->max_pool_threads_);
}
-size_t
-TAO_Dynamic_TP_Task::get_max_request_queue_depth()
+size_t
+TAO_DTP_Task::get_max_request_queue_depth()
{
return(this->max_request_queue_depth_);
}
-size_t
-TAO_Dynamic_TP_Task::get_thread_stack_size()
+size_t
+TAO_DTP_Task::get_thread_stack_size()
{
return(this->thread_stack_size_);
}
-time_t
-TAO_Dynamic_TP_Task::get_thread_idle_time()
+time_t
+TAO_DTP_Task::get_thread_idle_time()
{
return(this->thread_idle_time_.sec());
}
int
-TAO_Dynamic_TP_Task::open()//void* args)
+TAO_DTP_Task::open(void* /* args */)
{
size_t num = 1;
@@ -125,7 +125,7 @@ TAO_Dynamic_TP_Task::open()//void* args)
// {
// //FUZZ: disable check_for_lack_ACE_OS
// ACE_ERROR_RETURN ((LM_ERROR,
- // ACE_TEXT ("(%P|%t) Dynamic_TP_Task::open() failed to open. ")
+ // ACE_TEXT ("(%P|%t) DTP_Task::open() failed to open. ")
// ACE_TEXT ("Invalid argument type passed to open().\n")),
// -1);
// //FUZZ: enable check_for_lack_ACE_OS
@@ -137,18 +137,18 @@ TAO_Dynamic_TP_Task::open()//void* args)
// now. When they startup they will decrement themselves
// as they go into a wait state.
- this->busy_threads_ = 0;
+ this->busy_threads_ = 0;
if (TAO_debug_level > 4)
{
ACE_DEBUG((LM_DEBUG,
- ACE_TEXT ("TAO (%P|%t) - Dynamic_TP_Task::open() initialized with:\n")
- ACE_TEXT ("TAO (%P|%t) - Dynamic_TP_Task::open() init_threads_ \t\t: [%d]\n")
- ACE_TEXT ("TAO (%P|%t) - Dynamic_TP_Task::open() min_pool_threads_ \t\t: [%d]\n")
- ACE_TEXT ("TAO (%P|%t) - Dynamic_TP_Task::open() max_pool_threads_ \t\t: [%d]\n")
- ACE_TEXT ("TAO (%P|%t) - Dynamic_TP_Task::open() max_request_queue_depth_ \t: [%d]\n")
- ACE_TEXT ("TAO (%P|%t) - Dynamic_TP_Task::open() thread_stack_size_ \t\t: [%d]\n")
- ACE_TEXT ("TAO (%P|%t) - Dynamic_TP_Task::open() thread_idle_time_ \t\t: [%d]\n"),
+ ACE_TEXT ("TAO (%P|%t) - DTP_Task::open() initialized with:\n")
+ ACE_TEXT ("TAO (%P|%t) - DTP_Task::open() init_threads_ \t\t: [%d]\n")
+ ACE_TEXT ("TAO (%P|%t) - DTP_Task::open() min_pool_threads_ \t\t: [%d]\n")
+ ACE_TEXT ("TAO (%P|%t) - DTP_Task::open() max_pool_threads_ \t\t: [%d]\n")
+ ACE_TEXT ("TAO (%P|%t) - DTP_Task::open() max_request_queue_depth_ \t: [%d]\n")
+ ACE_TEXT ("TAO (%P|%t) - DTP_Task::open() thread_stack_size_ \t\t: [%d]\n")
+ ACE_TEXT ("TAO (%P|%t) - DTP_Task::open() thread_idle_time_ \t\t: [%d]\n"),
this->init_pool_threads_,
this->min_pool_threads_,
this->max_pool_threads_,
@@ -162,7 +162,7 @@ TAO_Dynamic_TP_Task::open()//void* args)
if (num < 1)
{
ACE_ERROR_RETURN ((LM_ERROR,
- ACE_TEXT ("TAO (%P|%t) Dynamic_TP_Task::open() failed to open. ")
+ ACE_TEXT ("TAO (%P|%t) DTP_Task::open() failed to open. ")
ACE_TEXT ("num_threads (%u) is less-than 1.\n"),
num),
-1);
@@ -177,7 +177,7 @@ TAO_Dynamic_TP_Task::open()//void* args)
{
//FUZZ: disable check_for_lack_ACE_OS
ACE_ERROR_RETURN ((LM_ERROR,
- ACE_TEXT ("TAO (%P|%t) Dynamic_TP_Task::open() failed to open. ")
+ ACE_TEXT ("TAO (%P|%t) DTP_Task::open() failed to open. ")
ACE_TEXT ("Task has previously been open()'ed.\n")),
-1);
//FUZZ: enable check_for_lack_ACE_OS
@@ -190,7 +190,7 @@ TAO_Dynamic_TP_Task::open()//void* args)
if (this->activate(THR_NEW_LWP | THR_DETACHED, num, 1) != 0)
{
ACE_ERROR_RETURN ((LM_ERROR,
- ACE_TEXT ("(%P|%t) Dynamic_TP_Task::open() failed to activate ")
+ ACE_TEXT ("(%P|%t) DTP_Task::open() failed to activate ")
ACE_TEXT ("(%d) worker threads.\n"),
num),
-1);
@@ -215,7 +215,7 @@ TAO_Dynamic_TP_Task::open()//void* args)
stack_sz_arr) != 0)
{
ACE_ERROR_RETURN ((LM_ERROR,
- ACE_TEXT ("(%P|%t) Dynamic_TP_Task::open() failed to activate ")
+ ACE_TEXT ("(%P|%t) DTP_Task::open() failed to activate ")
ACE_TEXT ("(%d) worker threads.\n"),
num),
-1);
@@ -230,7 +230,7 @@ TAO_Dynamic_TP_Task::open()//void* args)
}
bool
-TAO_Dynamic_TP_Task::request_ready (TAO::CSD::TP_Dispatchable_Visitor &v,
+TAO_DTP_Task::request_ready (TAO::CSD::TP_Dispatchable_Visitor &v,
TAO::CSD::TP_Request_Handle &r)
{
ACE_GUARD_RETURN (TAO_SYNCH_MUTEX, guard, this->queue_lock_, false);
@@ -244,7 +244,7 @@ TAO_Dynamic_TP_Task::request_ready (TAO::CSD::TP_Dispatchable_Visitor &v,
}
void
-TAO_Dynamic_TP_Task::clear_request (TAO::CSD::TP_Request_Handle &r)
+TAO_DTP_Task::clear_request (TAO::CSD::TP_Request_Handle &r)
{
ACE_GUARD (TAO_SYNCH_MUTEX, guard, this->queue_lock_);
--this->num_queue_requests_;
@@ -256,7 +256,7 @@ TAO_Dynamic_TP_Task::clear_request (TAO::CSD::TP_Request_Handle &r)
if (TAO_debug_level > 4 )
{
ACE_DEBUG ((LM_DEBUG,
- ACE_TEXT ("TAO (%P|%t) - Dynamic_TP_Task::svc() ")
+ ACE_TEXT ("TAO (%P|%t) - DTP_Task::svc() ")
ACE_TEXT ("Decrementing num_queue_requests.")
ACE_TEXT ("New queue depth:%d\n"),
this->num_queue_requests_));
@@ -266,13 +266,13 @@ TAO_Dynamic_TP_Task::clear_request (TAO::CSD::TP_Request_Handle &r)
}
int
-TAO_Dynamic_TP_Task::svc()
+TAO_DTP_Task::svc()
{
++this->busy_threads_;
if (TAO_debug_level > 4)
{
ACE_DEBUG ((LM_DEBUG,
- ACE_TEXT ("TAO (%P|%t) - Dynamic_TP_Task::svc() ")
+ ACE_TEXT ("TAO (%P|%t) - DTP_Task::svc() ")
ACE_TEXT ("New thread created.\n")));
}
@@ -290,7 +290,7 @@ TAO_Dynamic_TP_Task::svc()
if (TAO_debug_level > 4)
{
ACE_DEBUG ((LM_DEBUG,
- ACE_TEXT ("TAO (%P|%t) - Dynamic_TP_Task::svc() ")
+ ACE_TEXT ("TAO (%P|%t) - DTP_Task::svc() ")
ACE_TEXT ("Decrementing busy_threads_. ")
ACE_TEXT ("Busy thread count:%d\n"),
this->busy_threads_.value()));
@@ -300,7 +300,7 @@ TAO_Dynamic_TP_Task::svc()
{
ACE_GUARD_RETURN (TAO_SYNCH_MUTEX, guard, this->work_lock_, false);
- int wait_state = this->thread_idle_time_.sec() == 0
+ int wait_state = this->thread_idle_time_.sec() == 0
? this->work_available_.wait()
: this->work_available_.wait(&tmp_sec);
@@ -316,7 +316,7 @@ TAO_Dynamic_TP_Task::svc()
if (TAO_debug_level > 4)
{
ACE_DEBUG ((LM_DEBUG,
- ACE_TEXT ("TAO (%P|%t) - Dynamic_TP_Task::svc() ")
+ ACE_TEXT ("TAO (%P|%t) - DTP_Task::svc() ")
ACE_TEXT ("Existing thread expiring.\n")));
}
return 0;
@@ -328,7 +328,7 @@ TAO_Dynamic_TP_Task::svc()
if (TAO_debug_level > 4)
{
ACE_DEBUG ((LM_DEBUG,
- ACE_TEXT ("TAO (%P|%t) - Dynamic_TP_Task::svc() ")
+ ACE_TEXT ("TAO (%P|%t) - DTP_Task::svc() ")
ACE_TEXT ("Incrementing busy_threads_. ")
ACE_TEXT ("Busy thread count:%d\n"),
this->busy_threads_.value()));
@@ -353,15 +353,15 @@ TAO_Dynamic_TP_Task::svc()
&this->thread_stack_size_) != 0)
{
ACE_ERROR ((LM_ERROR,
- ACE_TEXT ("(%P|%t) Dynamic_TP_Task::svc() failed to grow ")
+ ACE_TEXT ("(%P|%t) DTP_Task::svc() failed to grow ")
ACE_TEXT ("to %d worker threads.\n"), count));
}
else
{
if (TAO_debug_level > 4)
- {
+ {
ACE_DEBUG ((LM_DEBUG,
- ACE_TEXT ("TAO (%P|%t) - Dynamic_TP_Task::svc() ")
+ ACE_TEXT ("TAO (%P|%t) - DTP_Task::svc() ")
ACE_TEXT ("Growing threadcount. ")
ACE_TEXT ("New thread count:%d\n"),
this->thr_count()));
@@ -378,7 +378,7 @@ TAO_Dynamic_TP_Task::svc()
int
-TAO_Dynamic_TP_Task::close(u_long flag)
+TAO_DTP_Task::close(u_long flag)
{
{
ACE_GUARD_RETURN (TAO_SYNCH_MUTEX, guard, this->aw_lock_, 0);
@@ -406,7 +406,7 @@ TAO_Dynamic_TP_Task::close(u_long flag)
if (TAO_debug_level > 4)
{
ACE_DEBUG ((LM_DEBUG,
- ACE_TEXT ("TAO (%P|%t) - Dynamic_TP_Task::close() ")
+ ACE_TEXT ("TAO (%P|%t) - DTP_Task::close() ")
ACE_TEXT ("shutting down. in_task = %d, Count = %d \n"),
in_task, this->thr_count()));
}
@@ -426,44 +426,44 @@ TAO_Dynamic_TP_Task::close(u_long flag)
}
-void
-TAO_Dynamic_TP_Task::set_init_pool_threads(size_t thr_count)
+void
+TAO_DTP_Task::set_init_pool_threads(size_t thr_count)
{
this->init_pool_threads_ = thr_count;
}
-void
-TAO_Dynamic_TP_Task::set_min_pool_threads(size_t thr_count)
+void
+TAO_DTP_Task::set_min_pool_threads(size_t thr_count)
{
this->min_pool_threads_ = thr_count;
}
void
-TAO_Dynamic_TP_Task::set_max_pool_threads(size_t thr_count)
+TAO_DTP_Task::set_max_pool_threads(size_t thr_count)
{
this->max_pool_threads_ = thr_count;
}
void
-TAO_Dynamic_TP_Task::set_thread_stack_size(size_t stack_sz)
+TAO_DTP_Task::set_thread_stack_size(size_t stack_sz)
{
this->thread_stack_size_ = stack_sz;
}
void
-TAO_Dynamic_TP_Task::set_thread_idle_time(ACE_Time_Value thr_timeout)
+TAO_DTP_Task::set_thread_idle_time(ACE_Time_Value thr_timeout)
{
this->thread_idle_time_ = thr_timeout;
}
void
-TAO_Dynamic_TP_Task::set_max_request_queue_depth(size_t queue_depth)
+TAO_DTP_Task::set_max_request_queue_depth(size_t queue_depth)
{
this->max_request_queue_depth_ = queue_depth;
}
void
-TAO_Dynamic_TP_Task::cancel_servant (PortableServer::Servant servant)
+TAO_DTP_Task::cancel_servant (PortableServer::Servant servant)
{
ACE_GUARD (TAO_SYNCH_MUTEX, guard, this->queue_lock_);
diff --git a/TAO/tao/Dynamic_TP/Dynamic_TP_Task.h b/TAO/tao/Dynamic_TP/DTP_Task.h
index 6476eb9aa3e..0b18950e75d 100644
--- a/TAO/tao/Dynamic_TP/Dynamic_TP_Task.h
+++ b/TAO/tao/Dynamic_TP/DTP_Task.h
@@ -2,7 +2,7 @@
//=============================================================================
/**
- * @file Dynamic_TP_Task.h
+ * @file DTP_Task.h
*
* $Id$
*/
@@ -14,7 +14,7 @@
#include /**/ "ace/pre.h"
#include "tao/Dynamic_TP/dynamic_tp_export.h"
-#include "tao/Dynamic_TP/Dynamic_TP_Config.h"
+#include "tao/Dynamic_TP/DTP_Config.h"
#include "tao/CSD_ThreadPool/CSD_TP_Queue.h"
#include "tao/CSD_ThreadPool/CSD_TP_Request.h"
#include "tao/CSD_ThreadPool/CSD_TP_Dispatchable_Visitor.h"
@@ -56,15 +56,15 @@ TAO_BEGIN_VERSIONED_NAMESPACE_DECL
* worker thread will invoke this task's close() method (with the
* flag argument equal to 0).
*/
- class TAO_Dynamic_TP_Export TAO_Dynamic_TP_Task : public ACE_Task_Base
+ class TAO_Dynamic_TP_Export TAO_DTP_Task : public ACE_Task_Base
{
public:
/// Default Constructor.
- TAO_Dynamic_TP_Task();
+ TAO_DTP_Task();
/// Virtual Destructor.
- virtual ~TAO_Dynamic_TP_Task();
+ virtual ~TAO_DTP_Task();
struct Open_Args {
TAO_DTP_Definition task_thread_config;
@@ -76,7 +76,7 @@ TAO_BEGIN_VERSIONED_NAMESPACE_DECL
bool add_request(TAO::CSD::TP_Request* request);
/// Activate the worker threads
- virtual int open();//void* args = 0);
+ virtual int open(void* args = 0);
/// The "mainline" executed by each worker thread.
virtual int svc();
@@ -191,7 +191,7 @@ TAO_BEGIN_VERSIONED_NAMESPACE_DECL
TAO_END_VERSIONED_NAMESPACE_DECL
#if defined (__ACE_INLINE__)
-# include "tao/Dynamic_TP/Dynamic_TP_Task.inl"
+# include "tao/Dynamic_TP/DTP_Task.inl"
#endif /* __ACE_INLINE__ */
#include /**/ "ace/post.h"
diff --git a/TAO/tao/Dynamic_TP/Dynamic_TP_Task.inl b/TAO/tao/Dynamic_TP/DTP_Task.inl
index 5b9eaafbd7d..5b9eaafbd7d 100644
--- a/TAO/tao/Dynamic_TP/Dynamic_TP_Task.inl
+++ b/TAO/tao/Dynamic_TP/DTP_Task.inl
diff --git a/TAO/tao/Dynamic_TP/DTP_Thread_Pool.h b/TAO/tao/Dynamic_TP/DTP_Thread_Pool.h
index 72d4aa9a277..b51541bb745 100644
--- a/TAO/tao/Dynamic_TP/DTP_Thread_Pool.h
+++ b/TAO/tao/Dynamic_TP/DTP_Thread_Pool.h
@@ -27,7 +27,7 @@
#include "ace/Hash_Map_Manager.h"
#include "tao/Thread_Lane_Resources.h"
#include "tao/Dynamic_TP/dynamic_tp_export.h"
-#include "tao/Dynamic_TP/Dynamic_TP_Config.h"
+#include "tao/Dynamic_TP/DTP_Config.h"
#include "tao/New_Leader_Generator.h"
#include "ace/Task.h"
#include "ace/Null_Mutex.h"
diff --git a/TAO/tests/Dynamic_TP/Config_Loader/Test.cpp b/TAO/tests/Dynamic_TP/Config_Loader/Test.cpp
index dcce5806a08..f6d274e8080 100644
--- a/TAO/tests/Dynamic_TP/Config_Loader/Test.cpp
+++ b/TAO/tests/Dynamic_TP/Config_Loader/Test.cpp
@@ -1,6 +1,6 @@
// $Id$
-#include "tao/Dynamic_TP/Dynamic_TP_Config.h"
+#include "tao/Dynamic_TP/DTP_Config.h"
#include "ace/OS_NS_stdio.h"
#include "ace/Service_Config.h"
#include "ace/Dynamic_Service.h"
@@ -24,9 +24,9 @@ ACE_TMAIN(int argc, ACE_TCHAR *argv[])
ACE_Service_Config::open (argc, argv);
ACE_Service_Gestalt *current = ACE_Service_Config::current();
- TAO_Dynamic_TP_Config_Registry* registry =
- ACE_Dynamic_Service<TAO_Dynamic_TP_Config_Registry>::instance
- (current, "Dynamic_TP_Config_Registry", true);
+ TAO_DTP_Config_Registry* registry =
+ ACE_Dynamic_Service<TAO_DTP_Config_Registry>::instance
+ (current, "DTP_Config_Registry", true);
if (registry == 0)
{
diff --git a/TAO/tests/Dynamic_TP/Config_Loader/svc.conf b/TAO/tests/Dynamic_TP/Config_Loader/svc.conf
index 10417277b38..4b3231a7a8b 100644
--- a/TAO/tests/Dynamic_TP/Config_Loader/svc.conf
+++ b/TAO/tests/Dynamic_TP/Config_Loader/svc.conf
@@ -1,16 +1,16 @@
# $Id$
-dynamic Dynamice_TP_Config Service_Object * TAO_Dynamic_TP:_make_TAO_Dynamic_TP_Config()
+dynamic DTP_Config Service_Object * TAO_Dynamic_TP:_make_TAO_DTP_Config()
"-DTPName ORB -DTPMin 5 -DTPInit 6 -DTPMax 10 -DTPTimeout 240 -DTPStack 10240 -DTPQueue 20"
-dynamic Dynamice_TP_Config Service_Object * TAO_Dynamic_TP:_make_TAO_Dynamic_TP_Config() "-DTPName POA1 -DTPMin 2 -DTPInit 4 -DTPMax 10 -DTPQueue 10"
-dynamic Dynamice_TP_Config Service_Object * TAO_Dynamic_TP:_make_TAO_Dynamic_TP_Config() "-DTPName POA1 -DTPOverwrite 1 -DTPMin 7 -DTPMax 14 "
-dynamic Dynamice_TP_Config Service_Object * TAO_Dynamic_TP:_make_TAO_Dynamic_TP_Config() "-DTPName POA1 -DTPMin 7 -DTPMax 11 -DPQueue 14"
-dynamic Dynamice_TP_Config Service_Object * TAO_Dynamic_TP:_make_TAO_Dynamic_TP_Config() "-DTPName defaults"
-dynamic Dynamice_TP_Config Service_Object * TAO_Dynamic_TP:_make_TAO_Dynamic_TP_Config() "-DTPName m1 -DTPMin 3"
-dynamic Dynamice_TP_Config Service_Object * TAO_Dynamic_TP:_make_TAO_Dynamic_TP_Config() "-DTPName m2 -DTPMax 10"
-dynamic Dynamice_TP_Config Service_Object * TAO_Dynamic_TP:_make_TAO_Dynamic_TP_Config() "-DTPName m3 -DTPTimeout 120"
-dynamic Dynamice_TP_Config Service_Object * TAO_Dynamic_TP:_make_TAO_Dynamic_TP_Config() "-DTPName m4 -DTPMin 3 -DTPInit 7 -DTPMax 10 -DTPTimeout 120"
-dynamic Dynamice_TP_Config Service_Object * TAO_Dynamic_TP:_make_TAO_Dynamic_TP_Config() "-DTPName m5 -DTPMin 3 -DTPInit 10 -DTPTimeout 30"
-dynamic Dynamice_TP_Config Service_Object * TAO_Dynamic_TP:_make_TAO_Dynamic_TP_Config() "-DTPName m6 -DTPInit 6 -DTPMax -1"
-dynamic Dynamice_TP_Config Service_Object * TAO_Dynamic_TP:_make_TAO_Dynamic_TP_Config() "-DTPName m7 -DTPInit 7"
-dynamic Dynamice_TP_Config Service_Object * TAO_Dynamic_TP:_make_TAO_Dynamic_TP_Config() "-DTPName bogus -DTPMin 6 -DTPInit 3"
+dynamic DTP_Config Service_Object * TAO_Dynamic_TP:_make_TAO_DTP_Config() "-DTPName POA1 -DTPMin 2 -DTPInit 4 -DTPMax 10 -DTPQueue 10"
+dynamic DTP_Config Service_Object * TAO_Dynamic_TP:_make_TAO_DTP_Config() "-DTPName POA1 -DTPOverwrite 1 -DTPMin 7 -DTPMax 14 "
+dynamic DTP_Config Service_Object * TAO_Dynamic_TP:_make_TAO_DTP_Config() "-DTPName POA1 -DTPMin 7 -DTPMax 11 -DPQueue 14"
+dynamic DTP_Config Service_Object * TAO_Dynamic_TP:_make_TAO_DTP_Config() "-DTPName defaults"
+dynamic DTP_Config Service_Object * TAO_Dynamic_TP:_make_TAO_DTP_Config() "-DTPName m1 -DTPMin 3"
+dynamic DTP_Config Service_Object * TAO_Dynamic_TP:_make_TAO_DTP_Config() "-DTPName m2 -DTPMax 10"
+dynamic DTP_Config Service_Object * TAO_Dynamic_TP:_make_TAO_DTP_Config() "-DTPName m3 -DTPTimeout 120"
+dynamic DTP_Config Service_Object * TAO_Dynamic_TP:_make_TAO_DTP_Config() "-DTPName m4 -DTPMin 3 -DTPInit 7 -DTPMax 10 -DTPTimeout 120"
+dynamic DTP_Config Service_Object * TAO_Dynamic_TP:_make_TAO_DTP_Config() "-DTPName m5 -DTPMin 3 -DTPInit 10 -DTPTimeout 30"
+dynamic DTP_Config Service_Object * TAO_Dynamic_TP:_make_TAO_DTP_Config() "-DTPName m6 -DTPInit 6 -DTPMax -1"
+dynamic DTP_Config Service_Object * TAO_Dynamic_TP:_make_TAO_DTP_Config() "-DTPName m7 -DTPInit 7"
+dynamic DTP_Config Service_Object * TAO_Dynamic_TP:_make_TAO_DTP_Config() "-DTPName bogus -DTPMin 6 -DTPInit 3"
diff --git a/TAO/tests/Dynamic_TP/POA_Loader/Dynamic_TP_POA_Test_Dynamic/run_test.pl b/TAO/tests/Dynamic_TP/POA_Loader/Dynamic_TP_POA_Test_Dynamic/run_test.pl
index 74936e686f1..ff8141814bb 100755
--- a/TAO/tests/Dynamic_TP/POA_Loader/Dynamic_TP_POA_Test_Dynamic/run_test.pl
+++ b/TAO/tests/Dynamic_TP/POA_Loader/Dynamic_TP_POA_Test_Dynamic/run_test.pl
@@ -37,7 +37,7 @@ sub test_1
my $iorbase = shift;
my $deletelogs = shift;
my $status = 0;
-
+
print "\nRunning Test 1....\n";
$test_num=1;
@@ -74,7 +74,7 @@ sub test_1
# Now find the spawned threads in the log file.
- $find_this="Dynamic_TP_Task::svc() New thread created.";
+ $find_this="DTP_Task::svc() New thread created.";
$found_cnt=0;
my($found_cnt) = count_strings($server_logfile,$find_this);
@@ -115,8 +115,8 @@ sub test_2
my $iorbase = shift;
my $deletelogs = shift;
my $status = 0;
-
-
+
+
print "\nRunning Test 2....\n";
$test_num=2;
my $lfname = "server_test" . $test_num . ".log";
@@ -155,7 +155,7 @@ sub test_2
}
# Now find the spawned threads in the log file.
- $find_this="Dynamic_TP_Task::svc() Existing thread expiring.";
+ $find_this="DTP_Task::svc() Existing thread expiring.";
$found_cnt=0;
my($found_cnt) = count_strings($server_logfile,$find_this);
@@ -174,10 +174,10 @@ sub test_2
print STDERR "ERROR: server returned $server_status\n";
$status = 1;
}
-
+
$server->DeleteFile($iorbase);
$client->DeleteFile($iorbase);
-
+
return($status);
}
@@ -195,7 +195,7 @@ sub test_3
my $iorbase = shift;
my $deletelogs = shift;
my $status = 0;
-
+
print "\nRunning Test 3....\n";
$test_num=3;
$num_clients=15;
@@ -267,7 +267,7 @@ sub test_3
$server->DeleteFile($iorbase);
$client->DeleteFile($iorbase);
-
+
return($status);
}
@@ -281,7 +281,7 @@ sub test_4
# will issue calls from 10 clients. There should be 5 CORBA exceptions found
# in the log after the run.
#
-
+
my $server = shift;
my $client = shift;
my $iorbase = shift;
diff --git a/TAO/tests/Dynamic_TP/POA_Loader/Dynamic_TP_POA_Test_Dynamic/server.cpp b/TAO/tests/Dynamic_TP/POA_Loader/Dynamic_TP_POA_Test_Dynamic/server.cpp
index 8de18ed608e..fcdfee2efe0 100644
--- a/TAO/tests/Dynamic_TP/POA_Loader/Dynamic_TP_POA_Test_Dynamic/server.cpp
+++ b/TAO/tests/Dynamic_TP/POA_Loader/Dynamic_TP_POA_Test_Dynamic/server.cpp
@@ -1,7 +1,7 @@
// $Id$
#include "Hello.h"
-#include "tao/Dynamic_TP/Dynamic_TP_POA_Strategy.h"
+#include "tao/Dynamic_TP/DTP_POA_Strategy.h"
#include "ace/Get_Opt.h"
#include "ace/OS_NS_stdio.h"
#include "ace/Thread_Manager.h"
diff --git a/TAO/tests/Dynamic_TP/POA_Loader/Dynamic_TP_POA_Test_Dynamic/svc1.conf b/TAO/tests/Dynamic_TP/POA_Loader/Dynamic_TP_POA_Test_Dynamic/svc1.conf
index b7e33603656..98c7ce1492f 100644
--- a/TAO/tests/Dynamic_TP/POA_Loader/Dynamic_TP_POA_Test_Dynamic/svc1.conf
+++ b/TAO/tests/Dynamic_TP/POA_Loader/Dynamic_TP_POA_Test_Dynamic/svc1.conf
@@ -1,4 +1,4 @@
# $Id$
-dynamic Dynamic_TP_Config Service_Object * TAO_Dynamic_TP:_make_TAO_Dynamic_TP_Config() "-DTPName POA1 -DTPMin -1 -DTPInit 5 -DTPMax -1 -DTPTimeout 60 -DTPStack 0 -DTPQueue 0"
-dynamic Dynamic_TP_POA_Loader Service_Object * TAO_Dynamic_TP:_make_TAO_Dynamic_TP_POA_Loader() "-DTPPOAConfigMap RootPOA,MyPOA2,MyPOA3:POA1"
+dynamic DTP_Config Service_Object * TAO_Dynamic_TP:_make_TAO_DTP_Config() "-DTPName POA1 -DTPMin -1 -DTPInit 5 -DTPMax -1 -DTPTimeout 60 -DTPStack 0 -DTPQueue 0"
+dynamic DTP_POA_Loader Service_Object * TAO_Dynamic_TP:_make_TAO_DTP_POA_Loader() "-DTPPOAConfigMap RootPOA,MyPOA2,MyPOA3:POA1"
diff --git a/TAO/tests/Dynamic_TP/POA_Loader/Dynamic_TP_POA_Test_Dynamic/svc2.conf b/TAO/tests/Dynamic_TP/POA_Loader/Dynamic_TP_POA_Test_Dynamic/svc2.conf
index 934c07da21c..a0c90c7be1d 100644
--- a/TAO/tests/Dynamic_TP/POA_Loader/Dynamic_TP_POA_Test_Dynamic/svc2.conf
+++ b/TAO/tests/Dynamic_TP/POA_Loader/Dynamic_TP_POA_Test_Dynamic/svc2.conf
@@ -1,4 +1,4 @@
# $Id$
-dynamic Dynamic_TP_Config Service_Object * TAO_Dynamic_TP:_make_TAO_Dynamic_TP_Config() "-DTPName POA1 -DTPMin 5 -DTPInit 10 -DTPMax -1 -DTPTimeout 10 -DTPStack 0 -DTPQueue 0"
-dynamic Dynamic_TP_POA_Loader Service_Object * TAO_Dynamic_TP:_make_TAO_Dynamic_TP_POA_Loader() "-DTPPOAConfigMap RootPOA,MyPOA2,MyPOA3:POA1"
+dynamic DTP_Config Service_Object * TAO_Dynamic_TP:_make_TAO_DTP_Config() "-DTPName POA1 -DTPMin 5 -DTPInit 10 -DTPMax -1 -DTPTimeout 10 -DTPStack 0 -DTPQueue 0"
+dynamic DTP_POA_Loader Service_Object * TAO_Dynamic_TP:_make_TAO_DTP_POA_Loader() "-DTPPOAConfigMap RootPOA,MyPOA2,MyPOA3:POA1"
diff --git a/TAO/tests/Dynamic_TP/POA_Loader/Dynamic_TP_POA_Test_Dynamic/svc3.conf b/TAO/tests/Dynamic_TP/POA_Loader/Dynamic_TP_POA_Test_Dynamic/svc3.conf
index 7d2143ce252..1e56b9c2599 100644
--- a/TAO/tests/Dynamic_TP/POA_Loader/Dynamic_TP_POA_Test_Dynamic/svc3.conf
+++ b/TAO/tests/Dynamic_TP/POA_Loader/Dynamic_TP_POA_Test_Dynamic/svc3.conf
@@ -1,4 +1,4 @@
# $Id$
-dynamic Dynamic_TP_Config Service_Object * TAO_Dynamic_TP:_make_TAO_Dynamic_TP_Config() "-DTPName POA1 -DTPMin -1 -DTPInit 15 -DTPMax -1 -DTPTimeout 10 -DTPStack 0 -DTPQueue 10"
-dynamic Dynamic_TP_POA_Loader Service_Object * TAO_Dynamic_TP:_make_TAO_Dynamic_TP_POA_Loader() "-DTPPOAConfigMap RootPOA,MyPOA2,MyPOA3:POA1"
+dynamic DTP_Config Service_Object * TAO_Dynamic_TP:_make_TAO_DTP_Config() "-DTPName POA1 -DTPMin -1 -DTPInit 15 -DTPMax -1 -DTPTimeout 10 -DTPStack 0 -DTPQueue 10"
+dynamic DTP_POA_Loader Service_Object * TAO_Dynamic_TP:_make_TAO_DTP_POA_Loader() "-DTPPOAConfigMap RootPOA,MyPOA2,MyPOA3:POA1"
diff --git a/TAO/tests/Dynamic_TP/POA_Loader/Dynamic_TP_POA_Test_Dynamic/svc4.conf b/TAO/tests/Dynamic_TP/POA_Loader/Dynamic_TP_POA_Test_Dynamic/svc4.conf
index 9daef8d1c41..7b8f2807899 100644
--- a/TAO/tests/Dynamic_TP/POA_Loader/Dynamic_TP_POA_Test_Dynamic/svc4.conf
+++ b/TAO/tests/Dynamic_TP/POA_Loader/Dynamic_TP_POA_Test_Dynamic/svc4.conf
@@ -1,4 +1,4 @@
# $Id$
-dynamic Dynamic_TP_Config Service_Object * TAO_Dynamic_TP:_make_TAO_Dynamic_TP_Config() "-DTPName POA1 -DTPMin -1 -DTPInit 1 -DTPMax 5 -DTPTimeout 60 -DTPStack 0 -DTPQueue 10"
-dynamic Dynamic_TP_POA_Loader Service_Object * TAO_Dynamic_TP:_make_TAO_Dynamic_TP_POA_Loader() "-DTPPOAConfigMap RootPOA,MyPOA2,MyPOA3:POA1"
+dynamic DTP_Config Service_Object * TAO_Dynamic_TP:_make_TAO_DTP_Config() "-DTPName POA1 -DTPMin -1 -DTPInit 1 -DTPMax 5 -DTPTimeout 60 -DTPStack 0 -DTPQueue 10"
+dynamic DTP_POA_Loader Service_Object * TAO_Dynamic_TP:_make_TAO_DTP_POA_Loader() "-DTPPOAConfigMap RootPOA,MyPOA2,MyPOA3:POA1"
diff --git a/TAO/tests/Dynamic_TP/POA_Loader/Dynamic_TP_POA_Test_Static/run_test.pl b/TAO/tests/Dynamic_TP/POA_Loader/Dynamic_TP_POA_Test_Static/run_test.pl
index 062fc791234..bc66e52623f 100755
--- a/TAO/tests/Dynamic_TP/POA_Loader/Dynamic_TP_POA_Test_Static/run_test.pl
+++ b/TAO/tests/Dynamic_TP/POA_Loader/Dynamic_TP_POA_Test_Static/run_test.pl
@@ -37,7 +37,7 @@ sub test_1
my $iorbase = shift;
my $deletelogs = shift;
my $status = 0;
-
+
print "\nRunning Test 1....\n";
$test_num=1;
@@ -74,7 +74,7 @@ sub test_1
# Now find the spawned threads in the log file.
- $find_this="Dynamic_TP_Task::svc() New thread created.";
+ $find_this="DTP_Task::svc() New thread created.";
$found_cnt=0;
my($found_cnt) = count_strings($server_logfile,$find_this);
@@ -115,8 +115,8 @@ sub test_2
my $iorbase = shift;
my $deletelogs = shift;
my $status = 0;
-
-
+
+
print "\nRunning Test 2....\n";
$test_num=2;
my $lfname = "server_test" . $test_num . ".log";
@@ -155,7 +155,7 @@ sub test_2
}
# Now find the spawned threads in the log file.
- $find_this="Dynamic_TP_Task::svc() Existing thread expiring.";
+ $find_this="DTP_Task::svc() Existing thread expiring.";
$found_cnt=0;
my($found_cnt) = count_strings($server_logfile,$find_this);
@@ -174,10 +174,10 @@ sub test_2
print STDERR "ERROR: server returned $server_status\n";
$status = 1;
}
-
+
$server->DeleteFile($iorbase);
$client->DeleteFile($iorbase);
-
+
return($status);
}
@@ -195,7 +195,7 @@ sub test_3
my $iorbase = shift;
my $deletelogs = shift;
my $status = 0;
-
+
print "\nRunning Test 3....\n";
$test_num=3;
$num_clients=15;
@@ -267,7 +267,7 @@ sub test_3
$server->DeleteFile($iorbase);
$client->DeleteFile($iorbase);
-
+
return($status);
}
@@ -281,7 +281,7 @@ sub test_4
# will issue calls from 10 clients. There should be 5 CORBA exceptions found
# in the log after the run.
#
-
+
my $server = shift;
my $client = shift;
my $iorbase = shift;
diff --git a/TAO/tests/Dynamic_TP/POA_Loader/Dynamic_TP_POA_Test_Static/server.cpp b/TAO/tests/Dynamic_TP/POA_Loader/Dynamic_TP_POA_Test_Static/server.cpp
index 42a8ba9c6a7..0e6b309f82b 100644
--- a/TAO/tests/Dynamic_TP/POA_Loader/Dynamic_TP_POA_Test_Static/server.cpp
+++ b/TAO/tests/Dynamic_TP/POA_Loader/Dynamic_TP_POA_Test_Static/server.cpp
@@ -1,7 +1,7 @@
// $Id$
#include "Hello.h"
-#include "tao/Dynamic_TP/Dynamic_TP_POA_Strategy.h"
+#include "tao/Dynamic_TP/DTP_POA_Strategy.h"
#include "ace/Get_Opt.h"
#include "ace/OS_NS_stdio.h"
#include "ace/Thread_Manager.h"
@@ -126,8 +126,8 @@ ACE_TMAIN (int argc, ACE_TCHAR *argv[])
// Create the thread pool servant dispatching strategy object, and
// hold it in a (local) smart pointer variable.
- TAO_Intrusive_Ref_Count_Handle<TAO_Dynamic_TP_POA_Strategy> csd_strategy =
- new TAO_Dynamic_TP_POA_Strategy(&dtp_config, false);
+ TAO_Intrusive_Ref_Count_Handle<TAO_DTP_POA_Strategy> csd_strategy =
+ new TAO_DTP_POA_Strategy(&dtp_config, false);
// Tell the strategy to apply itself to the child poa.
if (csd_strategy->apply_to(root_poa.in()) == false)
diff --git a/TAO/tests/Dynamic_TP/POA_Loader/Test.cpp b/TAO/tests/Dynamic_TP/POA_Loader/Test.cpp
index ed119d30cea..538f19b126e 100644
--- a/TAO/tests/Dynamic_TP/POA_Loader/Test.cpp
+++ b/TAO/tests/Dynamic_TP/POA_Loader/Test.cpp
@@ -1,6 +1,6 @@
// $Id$
-#include "tao/Dynamic_TP/Dynamic_TP_POA_Strategy.h"
+#include "tao/Dynamic_TP/DTP_POA_Strategy.h"
#include "tao/CSD_Framework/CSD_Strategy_Repository.h"
#include "ace/OS_NS_stdio.h"
@@ -23,7 +23,7 @@ show_tp_config (const ACE_CString &name, const TAO_DTP_Definition &entry)
}
//void
-//show_poa_config (const ACE_CString &name, TAO_Dynamic_TP_POA_Strategy * strat)
+//show_poa_config (const ACE_CString &name, TAO_DTP_POA_Strategy * strat)
//{
//ACE_DEBUG ((LM_INFO, ACE_TEXT ("POA [%C] has the configuration key [%C]\n"), name.c_str(),strat->get_tp_config().c_str()));
//ACE_DEBUG ((LM_DEBUG, ACE_TEXT (" Initial threads: %d:\n"), entry.init_threads_));
@@ -68,19 +68,19 @@ ACE_TMAIN(int argc, ACE_TCHAR *argv[])
0
};
- TAO_Dynamic_TP_POA_Strategy * mapped_strategy;
+ TAO_DTP_POA_Strategy * mapped_strategy;
for (int i = 0; poa_list[i] != 0; i++)
{
mapped_strategy = 0;
ACE_DEBUG ((LM_INFO, ACE_TEXT("Config definition for %C\n"), poa_list[i]));
- mapped_strategy = dynamic_cast <TAO_Dynamic_TP_POA_Strategy*> (dtp_poa_strat_repo->find (poa_list[i]));
- if ((mapped_strategy == 0) && (i != 1))
+ mapped_strategy = dynamic_cast <TAO_DTP_POA_Strategy*> (dtp_poa_strat_repo->find (poa_list[i]));
+ if ((mapped_strategy == 0) && (i != 1) && (i != 3))
{
ACE_DEBUG ((LM_DEBUG, ACE_TEXT("Cannot find TP Config definition for %C\n"), poa_list[i]));
continue;
}
- if (i == 1)
+ if (i == 1 || i == 3)
{
if (mapped_strategy)
{
diff --git a/TAO/tests/Dynamic_TP/POA_Loader/svc.conf b/TAO/tests/Dynamic_TP/POA_Loader/svc.conf
index 750b31c3b0d..664f8220087 100644
--- a/TAO/tests/Dynamic_TP/POA_Loader/svc.conf
+++ b/TAO/tests/Dynamic_TP/POA_Loader/svc.conf
@@ -1,15 +1,15 @@
# $Id$
-dynamic Dynamice_TP_Config Service_Object * TAO_Dynamic_TP:_make_TAO_Dynamic_TP_Config() "-DTPName ORB -DTPMin 5 -DTPInit 6 -DTPMax 10 -DTPTimeout 240 -DTPStack 10240 -DTPQueue 20"
-dynamic Dynamice_TP_Config Service_Object * TAO_Dynamic_TP:_make_TAO_Dynamic_TP_Config() "-DTPName POA1 -DTPMin 2 -DTPInit 4 -DTPMax 10 -DTPQueue 10"
-dynamic Dynamice_TP_Config Service_Object * TAO_Dynamic_TP:_make_TAO_Dynamic_TP_Config() "-DTPName POA1 -DTPOverwrite 1 -DTPMin 7 -DTPMax 14 "
-dynamic Dynamice_TP_Config Service_Object * TAO_Dynamic_TP:_make_TAO_Dynamic_TP_Config() "-DTPName POA1 -DTPMin 7 -DTPMax 11 -DPQueue 14"
-dynamic Dynamice_TP_Config Service_Object * TAO_Dynamic_TP:_make_TAO_Dynamic_TP_Config() "-DTPName defaults"
-dynamic Dynamice_TP_Config Service_Object * TAO_Dynamic_TP:_make_TAO_Dynamic_TP_Config() "-DTPName m1 -DTPMin 3"
-dynamic Dynamice_TP_Config Service_Object * TAO_Dynamic_TP:_make_TAO_Dynamic_TP_Config() "-DTPName m2 -DTPMax 10"
-dynamic Dynamice_TP_Config Service_Object * TAO_Dynamic_TP:_make_TAO_Dynamic_TP_Config() "-DTPName m3 -DTPTimeout 120"
-dynamic Dynamice_TP_Config Service_Object * TAO_Dynamic_TP:_make_TAO_Dynamic_TP_Config() "-DTPName m4 -DTPMin 3 -DTPInit 7 -DTPMax 10 -DTPTimeout 120"
-dynamic Dynamice_TP_Config Service_Object * TAO_Dynamic_TP:_make_TAO_Dynamic_TP_Config() "-DTPName m5 -DTPMin 3 -DTPInit 10 -DTPTimeout 30"
-dynamic Dynamice_TP_Config Service_Object * TAO_Dynamic_TP:_make_TAO_Dynamic_TP_Config() "-DTPName m6 -DTPInit 6 -DTPMax -1"
-dynamic Dynamice_TP_Config Service_Object * TAO_Dynamic_TP:_make_TAO_Dynamic_TP_Config() "-DTPName m7 -DTPInit 7"
-dynamic Dynamice_TP_Config Service_Object * TAO_Dynamic_TP:_make_TAO_Dynamic_TP_Config() "-DTPName bogus -DTPMin 6 -DTPInit 3"
-dynamic Dynamic_TP_POA_Loader Service_Object * TAO_Dynamic_TP:_make_TAO_Dynamic_TP_POA_Loader() "-DTPPOAConfigMap MyPOA,MyPOA2,MyPOA3:POA1"
+dynamic DTP_Config Service_Object * TAO_Dynamic_TP:_make_TAO_DTP_Config() "-DTPName ORB -DTPMin 5 -DTPInit 6 -DTPMax 10 -DTPTimeout 240 -DTPStack 10240 -DTPQueue 20"
+dynamic DTP_Config Service_Object * TAO_Dynamic_TP:_make_TAO_DTP_Config() "-DTPName POA1 -DTPMin 2 -DTPInit 4 -DTPMax 10 -DTPQueue 10"
+dynamic DTP_Config Service_Object * TAO_Dynamic_TP:_make_TAO_DTP_Config() "-DTPName POA1 -DTPOverwrite 1 -DTPMin 7 -DTPMax 14 "
+dynamic DTP_Config Service_Object * TAO_Dynamic_TP:_make_TAO_DTP_Config() "-DTPName POA1 -DTPMin 7 -DTPMax 11 -DPQueue 14"
+dynamic DTP_Config Service_Object * TAO_Dynamic_TP:_make_TAO_DTP_Config() "-DTPName defaults"
+dynamic DTP_Config Service_Object * TAO_Dynamic_TP:_make_TAO_DTP_Config() "-DTPName m1 -DTPMin 3"
+dynamic DTP_Config Service_Object * TAO_Dynamic_TP:_make_TAO_DTP_Config() "-DTPName m2 -DTPMax 10"
+dynamic DTP_Config Service_Object * TAO_Dynamic_TP:_make_TAO_DTP_Config() "-DTPName m3 -DTPTimeout 120"
+dynamic DTP_Config Service_Object * TAO_Dynamic_TP:_make_TAO_DTP_Config() "-DTPName m4 -DTPMin 3 -DTPInit 7 -DTPMax 10 -DTPTimeout 120"
+dynamic DTP_Config Service_Object * TAO_Dynamic_TP:_make_TAO_DTP_Config() "-DTPName m5 -DTPMin 3 -DTPInit 10 -DTPTimeout 30"
+dynamic DTP_Config Service_Object * TAO_Dynamic_TP:_make_TAO_DTP_Config() "-DTPName m6 -DTPInit 6 -DTPMax -1"
+dynamic DTP_Config Service_Object * TAO_Dynamic_TP:_make_TAO_DTP_Config() "-DTPName m7 -DTPInit 7"
+dynamic DTP_Config Service_Object * TAO_Dynamic_TP:_make_TAO_DTP_Config() "-DTPName bogus -DTPMin 6 -DTPInit 3"
+dynamic DTP_POA_Loader Service_Object * TAO_Dynamic_TP:_make_TAO_DTP_POA_Loader() "-DTPPOAConfigMap MyPOA,MyPOA2,MyPOA3:POA1"