1 files changed, 157 insertions, 0 deletions
diff --git a/TAO/CIAO/DAnCE/spec_RepositoryManager/RepositoryManager.cpp b/TAO/CIAO/DAnCE/spec_RepositoryManager/RepositoryManager.cpp
new file mode 100644
index 00000000000..ebe07839060
--- /dev/null
+++ b/TAO/CIAO/DAnCE/spec_RepositoryManager/RepositoryManager.cpp
@@ -0,0 +1,157 @@
+// $Id$
+
+/***
+ * file RepositoryManager.cpp
+ *
+ * author Stoyan Paunov <spaunov@isis.vanderbilt.edu>
+ **/
+
+
+#include "RepositoryManager_Impl.h"
+#include "ace/OS_NS_stdio.h"
+#include "ace/streams.h"
+#include "ace/Auto_Ptr.h"
+#include "ace/Task.h"
+using namespace std;
+
+namespace
+{
+///name of the file holding the IOR of the RM
+const char * rm_ior = "RepositoryManagerDeamon.ior";
+
+///default number of worker threads to run in the multi-threaded RM
+const unsigned int nthreads = 3;
+}
+
+
+///Class that implements the service routine of the worker threads
+///of the repository manager
+
+class Worker : public ACE_Task_Base
+{
+  // = TITLE
+  //   Run a server thread
+  //
+  // = DESCRIPTION
+  //   Use the ACE_Task_Base class to run server threads
+  //
+public:
+  Worker (CORBA::ORB_ptr orb);
+  // ctor
+
+  virtual int svc (void);
+  // The thread entry point.
+
+private:
+  CORBA::ORB_var orb_;
+  // The orb
+};
+
+
+///Main function
+
+int
+ACE_TMAIN (int argc, ACE_TCHAR *argv[])
+{
+	try
+	{
+		//init the ORB
+		CORBA::ORB_var orb = CORBA::ORB_init(argc, argv);
+
+		//Get the root POA object
+		CORBA::Object_var obj = orb->resolve_initial_references ("RootPOA");
+		
+		//downcast to POA type
+		PortableServer::POA_var root_poa = PortableServer::POA::_narrow (obj.in ());
+
+		//activate the POA manager
+		PortableServer::POAManager_var mgr = root_poa->the_POAManager ();
+		mgr->activate ();
+
+		//create a servant
+		CIAO_RepositoryManagerDaemon_i* repo = new CIAO_RepositoryManagerDaemon_i (orb.in ());
+
+		//trasfer ownership to the POA
+		PortableServer::ServantBase_var distributor_owner_transfer(repo);
+
+		//register and implicitly activate servant
+		CIAO::RepositoryManagerDaemon_var RepositoryManagerDeamon = repo->_this ();
+		
+		//convert the IOR to string
+		CORBA::String_var ior = orb->object_to_string (RepositoryManagerDeamon.in ());
+
+		//output the IOR to a file
+		FILE* ior_out = ACE_OS::fopen (rm_ior, "w");
+		
+		if (ior_out == 0)
+        ACE_ERROR_RETURN ((LM_ERROR,
+                           "Cannot open output file for writing IOR: %s",
+                           rm_ior),
+                              1);
+		
+		ACE_OS::fprintf (ior_out, "%s", ior.in ());
+		ACE_OS::fclose (ior_out);
+
+		Worker worker (orb.in ());
+		if (worker.activate (THR_NEW_LWP | THR_JOINABLE,
+			                   nthreads) != 0)
+			ACE_ERROR_RETURN ((LM_ERROR,
+			                   "Cannot activate client threads\n"),
+							   1);
+
+	    worker.thr_mgr ()->wait ();
+
+	    ACE_DEBUG ((LM_DEBUG, "event loop finished\n"));
+
+		//done
+		return 0; 
+
+		//Start accepting requests
+		orb->run ();
+
+		//allow objects registered with the POA ot get cleaned-up
+		root_poa->destroy (1, 1);
+
+		//shutdown the orb
+		orb->shutdown (1);
+
+		return 0;
+	}
+	catch (CORBA::Exception &ex) {
+		cerr << "CORBA Exception: " << ex << endl;
+
+		return 1;
+	}
+
+
+  return 0;
+}
+
+
+
+// ****************************************************************
+
+///Constuctor for the worker class
+Worker::Worker (CORBA::ORB_ptr orb)
+  :  orb_ (CORBA::ORB::_duplicate (orb))
+{
+}
+
+///implementation of the service routine inherited from ACE::Task_Base
+
+int Worker::svc (void)
+{
+  ACE_DECLARE_NEW_CORBA_ENV;
+  ACE_TRY
+    {
+      this->orb_->run (ACE_ENV_SINGLE_ARG_PARAMETER);
+      ACE_TRY_CHECK;
+    }
+  ACE_CATCHANY
+    {
+    }
+  ACE_ENDTRY;
+  return 0;
+}
+
+