1 files changed, 150 insertions, 0 deletions
diff --git a/TAO/orbsvcs/examples/ImR/Combined_Service/dynserver.cpp b/TAO/orbsvcs/examples/ImR/Combined_Service/dynserver.cpp
new file mode 100644
index 00000000000..1a4b617f2f7
--- /dev/null
+++ b/TAO/orbsvcs/examples/ImR/Combined_Service/dynserver.cpp
@@ -0,0 +1,150 @@
+// $Id$
+#include "dynserver.h"
+
+#include <tao/IORTable/IORTable.h>
+
+#include <ace/Dynamic_Service.h>
+#include <ace/Task.h>
+
+using namespace CORBA;
+using namespace PortableServer;
+
+DynServer::DynServer()
+: n_(0)
+{
+}
+
+DynServer::~DynServer() {
+}
+
+Long DynServer::get() ACE_THROW_SPEC ((SystemException)) {
+  ACE_DEBUG((LM_DEBUG, "dynserver: get() %d\n", ++n_));
+  return n_;
+}
+
+namespace {
+  POA_ptr createPersistPOA(const char* name, POA_ptr root_poa, POAManager_ptr poaman) {
+    PolicyList policies (2);
+    policies.length (2);
+    policies[0] = root_poa->create_id_assignment_policy(USER_ID);
+    policies[1] = root_poa->create_lifespan_policy(PERSISTENT);
+    POA_var poa = root_poa->create_POA(name, poaman, policies);
+    policies[0]->destroy();
+    policies[1]->destroy();
+    return poa._retn();
+  }
+}
+
+class DynServer_ORB_Runner : public ACE_Task_Base
+{
+  ORB_var orb_;
+public:
+  DynServer_ORB_Runner(ORB_ptr orb)
+    : orb_(ORB::_duplicate(orb))
+  {
+  }
+  void end() {
+    if (! is_nil(orb_.in())) {
+      orb_->shutdown(1);
+      wait();
+    }
+  }
+  virtual int svc()
+  {
+    orb_->run();
+    orb_ = ORB::_nil();
+    return 0;
+  }
+};
+
+DynServer_Loader::DynServer_Loader(void)
+{
+}
+
+int
+DynServer_Loader::init (int argc, ACE_TCHAR* argv[] ACE_ENV_ARG_DECL)
+{
+  try {
+
+    orb_ = ORB_init(argc, argv, "DynServer");
+
+    Object_var obj = orb_->resolve_initial_references("RootPOA");
+    root_poa_ = POA::_narrow(obj.in());
+    POAManager_var poaman = root_poa_->the_POAManager();
+    obj = this->orb_->resolve_initial_references ("IORTable");
+    IORTable::Table_var ior_table = IORTable::Table::_narrow (obj.in());
+    ACE_ASSERT(! is_nil(ior_table.in()));
+
+    ACE_DEBUG((LM_DEBUG, "dynserver: creating poas. (Registers with ImR)\n"));
+
+    POA_var poa1 = createPersistPOA("DynObject1", root_poa_.in(), poaman.in());
+    POA_var poa2 = createPersistPOA("DynObject2", root_poa_.in(), poaman.in());
+
+    ACE_DEBUG((LM_DEBUG, "dynserver: activating objects.\n"));
+
+    DynServer* svt1 = new DynServer;
+    ServantBase_var scoped_svt1(svt1);
+    DynServer* svt2 = new DynServer;
+    ServantBase_var scoped_svt2(svt2);
+
+    ObjectId_var id = string_to_ObjectId("myobject");
+
+    poa1->activate_object_with_id(id.in(), svt1);
+    poa2->activate_object_with_id(id.in(), svt2);
+
+    obj = poa1->id_to_reference(id.in());
+    String_var ior = orb_->object_to_string(obj.in());
+    ior_table->bind ("DynObject1", ior.in());
+    obj = poa2->id_to_reference(id.in());
+    ior = orb_->object_to_string(obj.in());
+    ior_table->bind ("DynObject2", ior.in());
+
+    poaman->activate();
+
+    runner_.reset(new DynServer_ORB_Runner(orb_.in()));
+    runner_->activate();
+
+    ACE_DEBUG((LM_DEBUG, "dynserver: running.\n"));
+
+  } catch (Exception& e) {
+    ACE_PRINT_EXCEPTION(e, "DynServer::init()");
+  }
+  return 0;
+}
+
+int
+DynServer_Loader::fini (void)
+{
+  ACE_ASSERT(runner_.get() != 0);
+  try {
+
+    ACE_DEBUG((LM_DEBUG, "dynserver: shutting down.\n"));
+
+    runner_->end();
+    runner_.reset(0);
+
+    root_poa_->destroy(1, 1);
+    orb_->destroy();
+
+    ACE_DEBUG((LM_DEBUG, "dynserver: shut down successfully.\n"));
+
+    return 0;
+
+  } catch (Exception& e) {
+    ACE_PRINT_EXCEPTION(e, "DynServer::fini()");
+  }
+  return -1;
+}
+
+Object_ptr
+DynServer_Loader::create_object (ORB_ptr,
+                                 int,
+                                 ACE_TCHAR **
+                                 ACE_ENV_ARG_DECL)
+                                 ACE_THROW_SPEC ((SystemException))
+{
+  ACE_THROW_RETURN(NO_IMPLEMENT(), Object::_nil());
+}
+
+ACE_FACTORY_DEFINE (DynServer, DynServer_Loader)
+