1 files changed, 102 insertions, 0 deletions
diff --git a/trunk/TAO/performance-tests/CSD_Strategy/TestInf/ServantList_T.cpp b/trunk/TAO/performance-tests/CSD_Strategy/TestInf/ServantList_T.cpp
new file mode 100644
index 00000000000..22133fa9868
--- /dev/null
+++ b/trunk/TAO/performance-tests/CSD_Strategy/TestInf/ServantList_T.cpp
@@ -0,0 +1,102 @@
+// $Id$
+#include "ServantList_T.h"
+#include "AppHelper.h"
+#include "TestAppExceptionC.h"
+
+
+template <typename T>
+ServantList<T>::ServantList()
+{
+}
+
+
+template <typename T>
+ServantList<T>::~ServantList()
+{
+}
+
+
+template <typename T>
+void
+ServantList<T>::create_and_activate(unsigned                num_servants,
+                                    CORBA::ORB_ptr          orb, 
+                                    PortableServer::POA_ptr poa,
+                                    const char*             ior_fname_prefix
+                                    ACE_ENV_ARG_DECL)
+{
+  for (unsigned i = 0; i < num_servants; i++)
+    {
+      char buf[32];
+      ACE_OS::sprintf(buf, "%02d", i + 1);
+      ACE_CString filename = ACE_CString(ior_fname_prefix) + "_" + buf + ".ior";  
+      ServantRecord record;
+      record.servant_ = new T();
+      record.safe_servant_ = record.servant_;
+
+      CORBA::Object_var obj 
+        = AppHelper::activate_servant(poa, 
+                                      record.safe_servant_.in()
+                                      ACE_ENV_ARG_PARAMETER);
+      ACE_CHECK;
+                                     
+      AppHelper::ref_to_file(orb, obj.in(), filename.c_str() ACE_ENV_ARG_PARAMETER); 
+      ACE_CHECK;
+
+      record.obj_ = T_stub::_narrow(obj.in() ACE_ENV_ARG_PARAMETER);
+      ACE_CHECK;
+
+      if (CORBA::is_nil(record.obj_.in()))
+        {
+          ACE_THROW (TestAppException());
+        }
+
+      this->servant_records_.push_back(record);
+    }
+}
+
+
+template <typename T>
+void
+ServantList<T>::create_and_activate(unsigned                num_servants,
+                                    PortableServer::POA_ptr poa
+                                    ACE_ENV_ARG_DECL)
+{
+  for (unsigned i = 0; i < num_servants; i++)
+    {
+      ServantRecord record;
+      record.servant_ = new T();
+      record.safe_servant_ = record.servant_;
+
+      CORBA::Object_var obj 
+        = AppHelper::activate_servant(poa, 
+                                      record.safe_servant_.in()
+                                      ACE_ENV_ARG_PARAMETER);
+      ACE_CHECK;
+                                    
+      record.obj_ = T_stub::_narrow(obj.in() ACE_ENV_ARG_PARAMETER);
+      ACE_CHECK;
+
+      if (CORBA::is_nil(record.obj_.in()))
+        {
+          ACE_THROW (TestAppException());
+        }
+
+      this->servant_records_.push_back(record);
+    }
+}
+
+
+template <typename T>
+typename ServantList<T>::T_stub_ptr
+ServantList<T>::objref(unsigned index)
+{
+  return T_stub::_duplicate(this->servant_records_[index].obj_.in());
+}
+
+
+template <typename T>
+T*
+ServantList<T>::servant(unsigned index)
+{
+  return this->servant_records_[index].servant_;
+}