*** empty log message ***

12 files changed, 941 insertions, 0 deletions

diff --git a/TAO/orbsvcs/FTRT_Event_Service/Event_Service/FTRT_Event_Service.mpc b/TAO/orbsvcs/FTRT_Event_Service/Event_Service/FTRT_Event_Service.mpc
new file mode 100644
index 00000000000..3498b83f115
--- /dev/null
+++ b/TAO/orbsvcs/FTRT_Event_Service/Event_Service/FTRT_Event_Service.mpc
@@ -0,0 +1,9 @@
+project(FTRT_Event_Service) : orbsvcsexe,  rtschedevent, ftrtevent, ftorbutils {
+  exename = ftrt_eventservice
+  includes += $(TAO_ROOT)/orbsvcs $(TAO_ROOT)/orbsvcs/FtRtEvent/Utils $(TAO_ROOT)/orbsvcs/FtRtEvent/EventChannel
+  after += FTRT_EventChannel
+  libs += TAO_Utils TAO_FTRT_EventChannel
+  specific(gnuace) {
+   lit_libs += TAO_Strategies
+  }
+} 
\ No newline at end of file
diff --git a/TAO/orbsvcs/FTRT_Event_Service/Event_Service/FT_EventService.cpp b/TAO/orbsvcs/FTRT_Event_Service/Event_Service/FT_EventService.cpp
new file mode 100644
index 00000000000..d355b524b9a
--- /dev/null
+++ b/TAO/orbsvcs/FTRT_Event_Service/Event_Service/FT_EventService.cpp
@@ -0,0 +1,286 @@
+// $Id$
+
+#include "FT_EventService.h"
+#include "ace/Argv_Type_Converter.h"
+#include "ace/Thread_Manager.h"
+#include "ace/Get_Opt.h"
+#include "ace/INET_Addr.h"
+#include "ace/SOCK_Connector.h"
+#include "ace/SOCK_Stream.h"
+#include "orbsvcs/Sched/Config_Scheduler.h" 
+#include "orbsvcs/Scheduler_Factory.h"
+#include "orbsvcs/FtRtEvent/EventChannel/FTRTEC_ServiceActivate.h"
+
+ACE_RCSID (FTRT_Event_Service,
+           FT_EventService.cpp,
+           "$Id$")
+
+
+int ACE_TMAIN (int argc, ACE_TCHAR* argv[])
+{
+  FT_EventService event_service;
+  return event_service.run (argc, argv);
+}
+ 
+FT_EventService::FT_EventService()
+: global_scheduler_(0)
+, sched_impl_(0)
+, membership_(TAO_FTEC_Event_Channel::NONE)
+, num_threads_(1)
+{
+}
+
+FT_EventService::~FT_EventService()
+{
+  delete sched_impl_;
+}
+
+int
+FT_EventService::run(int argc, ACE_TCHAR* argv[])
+{
+  ACE_TRY_NEW_ENV
+  {
+    // Make a copy of command line parameter.
+    ACE_Argv_Type_Converter command(argc, argv);
+
+    // Initialize ORB.
+    CORBA::ORB_var orb =
+      CORBA::ORB_init (command.get_argc(), command.get_ASCII_argv(), "" ACE_ENV_ARG_PARAMETER);
+    ACE_TRY_CHECK;
+
+    if (this->parse_args (command.get_argc(), command.get_TCHAR_argv()) == -1)
+      return 1;
+
+    CORBA::Object_var root_poa_object =
+      orb->resolve_initial_references("RootPOA"
+      ACE_ENV_ARG_PARAMETER);
+    ACE_TRY_CHECK;
+    if (CORBA::is_nil (root_poa_object.in ()))
+      ACE_ERROR_RETURN ((LM_ERROR,
+      " (%P|%t) Unable to initialize the root POA.\n"),
+      1);
+
+    PortableServer::POA_var root_poa =
+      PortableServer::POA::_narrow (root_poa_object.in () ACE_ENV_ARG_PARAMETER);
+    ACE_TRY_CHECK;
+
+    PortableServer::POAManager_var poa_manager =
+      root_poa->the_POAManager (ACE_ENV_SINGLE_ARG_PARAMETER);
+    ACE_TRY_CHECK;
+
+    poa_manager->activate (ACE_ENV_SINGLE_ARG_PARAMETER);
+    ACE_TRY_CHECK;
+
+    CORBA::Object_var naming_obj =
+      orb->resolve_initial_references ("NameService" ACE_ENV_ARG_PARAMETER);
+    ACE_TRY_CHECK;
+    if (CORBA::is_nil (naming_obj.in ()))
+      ACE_ERROR_RETURN ((LM_ERROR,
+      " (%P|%t) Unable to initialize the Naming Service.\n"),
+      1);
+
+    CosNaming::NamingContext_var naming_context =
+      CosNaming::NamingContext::_narrow (naming_obj.in () ACE_ENV_ARG_PARAMETER);
+    ACE_TRY_CHECK;
+
+    setup_scheduler(naming_context.in() ACE_ENV_ARG_PARAMETER);
+    ACE_CHECK_RETURN(-1);
+
+
+    poa_manager->activate(ACE_ENV_SINGLE_ARG_PARAMETER);
+    ACE_TRY_CHECK;
+
+    // Activate the Event channel implementation
+
+    TAO_FTEC_Event_Channel ec(orb, root_poa);
+
+    FtRtecEventChannelAdmin::EventChannel_var ec_ior =
+      ec.activate(membership_ 
+        ACE_ENV_SINGLE_ARG_PARAMETER);
+    ACE_TRY_CHECK;
+
+    if (report_factory(orb.in(), ec_ior.in())==-1)
+      return -1;
+
+    orb->run(ACE_ENV_SINGLE_ARG_PARAMETER);
+  }
+  ACE_CATCHANY
+  {
+    ACE_PRINT_EXCEPTION(ACE_ANY_EXCEPTION, "A CORBA Exception occurred.");
+  }
+  ACE_ENDTRY;
+
+  ACE_CHECK_RETURN(-1);
+
+  ACE_Thread_Manager::instance()->wait();
+  return 0;
+}
+
+int
+FT_EventService::parse_args (int argc, ACE_TCHAR* argv [])
+{
+  char* member = ACE_OS::getenv("FTEC_MEMBERSHIP");
+
+  membership_ = TAO_FTEC_Event_Channel::NONE;
+
+  if (member) {
+    if (ACE_OS::strcasecmp(member, "PRIMARY")==0) {
+      membership_ = TAO_FTEC_Event_Channel::PRIMARY;
+    }
+    else if (ACE_OS::strcasecmp(member, "BACKUP")==0) {
+      membership_ = TAO_FTEC_Event_Channel::BACKUP;
+    }
+  }
+
+  char* n_threads = ACE_OS::getenv("FTEC_NUM_THREAD");
+
+  this->num_threads_ = 1;
+  if (n_threads) 
+    this->num_threads_ = ACE_OS::atoi(n_threads); 
+
+  ACE_Get_Opt get_opt (argc, argv, ACE_LIB_TEXT("jn:ps:"));
+	int opt;
+
+	while ((opt = get_opt ()) != EOF)
+	{
+		switch (opt)
+		{
+		case 'j':
+      this->membership_ = TAO_FTEC_Event_Channel::BACKUP;
+			break;
+    case 'n':
+      this->num_threads_ = ACE_OS::atoi(get_opt.opt_arg ()); 
+      break;
+		case 'p':
+			this->membership_ = TAO_FTEC_Event_Channel::PRIMARY;
+			break;
+		case 's':
+			// It could be just a flag (i.e. no "global" or "local"
+			// argument, but this is consistent with the EC_Multiple
+			// test and also allows for a runtime scheduling service.
+
+			if (ACE_OS::strcasecmp (get_opt.opt_arg (), ACE_LIB_TEXT("global")) == 0)
+			{
+				this->global_scheduler_ = 1;
+			}
+			else if (ACE_OS::strcasecmp (get_opt.opt_arg (), ACE_LIB_TEXT("local")) == 0)
+			{
+				this->global_scheduler_ = 0;
+			}
+			else
+			{
+				ACE_DEBUG ((LM_DEBUG,
+					ACE_LIB_TEXT("Unknown scheduling type <%s> ")
+					ACE_LIB_TEXT("defaulting to local\n"),
+					get_opt.opt_arg ()));
+				this->global_scheduler_ = 0;
+			}
+			break;
+
+		case '?':
+		default:
+			ACE_DEBUG ((LM_DEBUG,
+				ACE_LIB_TEXT("Usage: %s \n")
+				ACE_LIB_TEXT("  -j join the object group\n")
+				ACE_LIB_TEXT("  -p set as primary\n")
+				ACE_LIB_TEXT("  -s <global|local> \n")
+				ACE_LIB_TEXT("\n"),
+				argv[0]));
+			return -1;
+		}
+	}
+
+  if (this->num_threads_ < 1) 
+    ACE_ERROR_RETURN((LM_ERROR, "Invalid number of threads specified\n"), -1);
+
+	return 0;
+}
+
+void
+FT_EventService::setup_scheduler(CosNaming::NamingContext_ptr naming_context
+                                        ACE_ENV_ARG_DECL_WITH_DEFAULTS)
+{
+    RtecScheduler::Scheduler_var scheduler;
+    if (CORBA::is_nil(naming_context)) {
+        ACE_NEW_THROW_EX (this->sched_impl_,
+            ACE_Config_Scheduler,
+            CORBA::NO_MEMORY());
+        
+        scheduler = this->sched_impl_->_this (ACE_ENV_SINGLE_ARG_PARAMETER);
+        ACE_TRY_CHECK;
+        
+        if (ACE_Scheduler_Factory::server(scheduler.in()) == -1)
+            ACE_ERROR((LM_ERROR,"Unable to install scheduler\n"));
+    }
+    else {
+        // This is the name we (potentially) register the Scheduling
+        // Service in the Naming Service.
+        CosNaming::Name schedule_name (1);
+        schedule_name.length (1);
+        schedule_name[0].id = CORBA::string_dup ("ScheduleService");
+        
+        
+        if (1) 
+        {
+            // We must find the scheduler object reference...
+            
+            if (this->global_scheduler_ == 0)
+            {
+                ACE_NEW_THROW_EX (this->sched_impl_,
+                    ACE_Config_Scheduler,
+                    CORBA::NO_MEMORY());
+                
+                scheduler = this->sched_impl_->_this (ACE_ENV_SINGLE_ARG_PARAMETER);
+                ACE_CHECK;
+                
+                // Register the servant with the Naming Context....
+                naming_context->rebind (schedule_name, scheduler.in ()
+                    ACE_ENV_ARG_PARAMETER);
+                ACE_CHECK;
+            }
+            else
+            {
+                CORBA::Object_var tmp =
+                    naming_context->resolve (schedule_name ACE_ENV_ARG_PARAMETER);
+                ACE_CHECK;
+                
+                scheduler = RtecScheduler::Scheduler::_narrow (tmp.in ()
+                    ACE_ENV_ARG_PARAMETER);
+                ACE_CHECK;
+            }
+        }
+    }
+}
+
+int 
+FT_EventService::report_factory(CORBA::ORB_ptr orb,
+                   FtRtecEventChannelAdmin::EventChannel_ptr ec)
+{
+    char* addr = ACE_OS::getenv("EventChannelFactoryAddr");
+
+		if (addr != NULL) {
+      // instaniated by object factory, report my ior back to the factory           
+      ACE_INET_Addr factory_addr(addr);
+      ACE_SOCK_Connector connector;
+      ACE_SOCK_Stream stream;
+
+      ACE_DEBUG((LM_DEBUG,"connecting to %s\n",addr));
+      if (connector.connect(stream, factory_addr) == -1)
+        ACE_ERROR_RETURN((LM_ERROR, "(%P|%t) Invalid Factory Address\n"), -1);
+
+      ACE_DEBUG((LM_DEBUG,"Factory connected\n"));
+      CORBA::String_var my_ior_string = orb->object_to_string(ec 
+        ACE_ENV_ARG_PARAMETER);
+
+      ACE_TRY_CHECK;
+      int len = strlen(my_ior_string.in()) ;
+
+      if (stream.send_n(my_ior_string.in(), len) != len)
+        ACE_ERROR_RETURN((LM_ERROR, "(%P|%t) IOR Transmission Error\n"), -1);
+
+      stream.close();
+    }
+    return 0;
+}
+
+
diff --git a/TAO/orbsvcs/FTRT_Event_Service/Event_Service/FT_EventService.h b/TAO/orbsvcs/FTRT_Event_Service/Event_Service/FT_EventService.h
new file mode 100644
index 00000000000..3982c19aa88
--- /dev/null
+++ b/TAO/orbsvcs/FTRT_Event_Service/Event_Service/FT_EventService.h
@@ -0,0 +1,45 @@
+// -*- C++ -*-
+
+//=============================================================================
+/**
+ *  @file   FT_EventService.h
+ *
+ *  $Id$
+ *
+ *  @author Huang-Ming Huang <hh1@cse.wustl.edu>
+ */
+//=============================================================================#ifndef FT_EVENTSERVICE_H
+#define FT_EVENTSERVICE_H
+
+#include "orbsvcs/CosNamingC.h"
+#include "orbsvcs/FtRtecEventChannelAdminC.h"
+#include "orbsvcs/FtRtEvent/EventChannel/FTEC_Event_Channel.h"
+
+namespace POA_RtecScheduler
+{ 
+    class Scheduler;
+};
+
+class FT_EventService 
+{
+public:
+  FT_EventService();
+  ~FT_EventService();
+
+  int run(int argc, ACE_TCHAR* argv[]);
+
+  int parse_args (int argc, ACE_TCHAR* argv []);
+  void setup_scheduler(CosNaming::NamingContext_ptr naming_context
+                                        ACE_ENV_ARG_DECL_WITH_DEFAULTS);
+  int report_factory(CORBA::ORB_ptr orb,
+                   FtRtecEventChannelAdmin::EventChannel_ptr ec);
+private:
+  int global_scheduler_;
+	// Should we use a global scheduler or a local one? 
+	POA_RtecScheduler::Scheduler *sched_impl_;
+	// The Scheduler implementation.
+  TAO_FTEC_Event_Channel::MEMBERSHIP membership_;
+  int num_threads_;
+};
+
+#endif
diff --git a/TAO/orbsvcs/FTRT_Event_Service/Event_Service/svc.conf b/TAO/orbsvcs/FTRT_Event_Service/Event_Service/svc.conf
new file mode 100644
index 00000000000..d23c985de19
--- /dev/null
+++ b/TAO/orbsvcs/FTRT_Event_Service/Event_Service/svc.conf
@@ -0,0 +1,20 @@
+## $Id$
+
+## The value of FTEC_DETECTOR_TRANSPORT_PROTOCL should be either "sctp" or "tcp".
+## The FTEC_HEART_BEAT is only meanful for stcp. It represents the heart beat in
+## seconds for the connections between replicas.
+
+static FTRTEC_Fault_Detector "$FTEC_DETECTOR_TRANSPORT_PROTOCL -HeartBeat $FTEC_HEART_BEAT"
+
+
+## If FTEC_REPLICATION_STRATEGY is set to AMI, then use AMI for replicating operations;
+##  otherwise, two-way CORBA call is used for replication.
+
+static FTRTEC_Replication "$FTEC_REPLICATION_STRATEGY"
+
+## FTEC_EVENT_SERVICE_NAME is used for the event channnel to register to the naming service.
+## FTEC_OBJECT_ID should be a globally unique identifier defined in
+## draft-leach-uuids-guids-01.txt. This value should be the same
+## for the entire object group.
+
+static FTRTEC_Identification "-Name $FTEC_EVENT_SERVICE_NAME -Object_ID $FTEC_OBJECT_ID"
\ No newline at end of file
diff --git a/TAO/orbsvcs/FTRT_Event_Service/Factory_Service/EventChannelFactory_i.cpp b/TAO/orbsvcs/FTRT_Event_Service/Factory_Service/EventChannelFactory_i.cpp
new file mode 100644
index 00000000000..b6b016130bf
--- /dev/null
+++ b/TAO/orbsvcs/FTRT_Event_Service/Factory_Service/EventChannelFactory_i.cpp
@@ -0,0 +1,201 @@
+// $Id$
+
+#include "EventChannelFactory_i.h"
+#include "ace/Process.h"
+#include "ace/Read_Buffer.h"
+#include "ace/SOCK_Acceptor.h"
+#include "ace/SOCK_Stream.h"
+#include "orbsvcs/FtRtEvent/Utils/ScopeGuard.h"
+#include "orbsvcs/FtRtEvent/Utils/UUID.h"
+
+ACE_RCSID (FTRTEC_Factory_Service,
+           EventChannelFactory_i.cpp,
+           "$Id$")
+
+
+const int WAIT_FOR_REGISTRATION_TIME = 10; //sec
+const int MAX_ID_STRING = 10;
+
+EventChannelFactory_i::EventChannelFactory_i(const char* conf_filename, CORBA::ORB_ptr orb_ptr)
+: conf_file(conf_filename), id(0), orb(orb_ptr)
+{
+}
+
+CORBA::Object_ptr EventChannelFactory_i::create_object (
+  const char * type_id,
+  const FT::Criteria & the_criteria,
+  FT::GenericFactory::FactoryCreationId_out factory_creation_id
+  ACE_ENV_ARG_DECL_WITH_DEFAULTS
+  )
+  ACE_THROW_SPEC ((
+  CORBA::SystemException
+  , FT::NoFactory
+  , FT::ObjectNotCreated
+  , FT::InvalidCriteria
+  , FT::InvalidProperty
+  , FT::CannotMeetCriteria
+  )) 
+{
+
+  ACE_DEBUG((LM_DEBUG,"EventChannelFactory_i::create_object\n"));
+
+  FILE* file = fopen(conf_file, "r");
+  if (file == NULL)
+    ACE_THROW_RETURN(FT::NoFactory(), CORBA::Object::_nil());
+
+  ScopeGuard file_guard = MakeGuard(fclose, file);
+  ACE_UNUSED_ARG(file_guard);
+
+  char *id=0, *prog=0;
+  ACE_Read_Buffer read_buf(file);
+  ScopeGuard id_guard = MakeObjGuard(* ACE_Allocator::instance(), 
+    &ACE_Allocator::free, id);
+  ACE_UNUSED_ARG(id_guard);
+
+  ScopeGuard prog_guard = MakeObjGuard(* ACE_Allocator::instance(), 
+    &ACE_Allocator::free, prog);
+  ACE_UNUSED_ARG(prog_guard);
+
+  while ((id = read_buf.read(' ')) != NULL &&
+    (prog = read_buf.read('\n')) != NULL) {
+      id[strlen(id)-1] = '\0';
+      if (strcmp(id, type_id) == 0) {
+        return create_process(prog, the_criteria, factory_creation_id);
+      }
+    }
+
+    ACE_THROW_RETURN(FT::ObjectNotCreated(), CORBA::Object::_nil());
+}
+
+void EventChannelFactory_i::delete_object (
+  const FT::GenericFactory::FactoryCreationId & factory_creation_id
+  ACE_ENV_ARG_DECL_WITH_DEFAULTS
+  )
+  ACE_THROW_SPEC ((
+  CORBA::SystemException
+  , FT::ObjectNotFound
+  )) 
+{
+  ACE_TRACE("EventChannelFactory_i::delete_object");
+  CORBA::ULong object_id;
+  factory_creation_id >>= object_id;
+  CORBA::Object_var obj;
+  if (objects.find(object_id, obj) == 0) {
+    objects.unbind(object_id);
+    //obj->shutdown(ACE_ENV_SINGLE_ARG_PARAMETER);
+  }
+}
+
+CORBA::Object_ptr EventChannelFactory_i::create_process (
+  char * process_str,
+  const FT::Criteria & the_criteria,
+  FT::GenericFactory::FactoryCreationId_out factory_creation_id)
+{
+  ACE_TRACE("EventChannelFactory_i::create_prcess");
+
+  CORBA::Object_ptr result = CORBA::Object::_nil();
+
+  // fill the factory_creation_id
+
+  ACE_NEW_RETURN(factory_creation_id, 
+    FT::GenericFactory::FactoryCreationId, 
+    CORBA::Object::_nil());
+  *factory_creation_id <<= (CORBA::ULong) ++id;
+
+  // create an acceptor and get the listen address
+
+  ACE_SOCK_Acceptor acceptor;
+  ACE_INET_Addr server_addr;
+  acceptor.open(server_addr);
+  acceptor.get_local_addr(server_addr);
+
+  ACE_Process_Options options;
+  ACE_CString str;
+
+  char* pos = ACE_OS::strrchr(process_str, '/');
+  if (pos !=0) { //
+    *pos = '\0';
+    options.working_directory(process_str);
+    *pos = '/';
+  }
+  str = process_str;
+
+  const int ENV_BUF_LEN = 512;
+  char buf[ENV_BUF_LEN];
+  server_addr.addr_to_string(buf,ENV_BUF_LEN,0);
+  options.setenv("EventChannelFactoryAddr", buf);
+
+  // extract the object ID from the criteria
+  for (size_t i = 0; i < the_criteria.length(); ++i)
+  {
+    const CosNaming::Name& name = the_criteria[i].nam;
+    if (name.length() > 0) {
+      const char* val;
+      const char* id = name[0].id.in();
+      the_criteria[i].val >>= val;
+      if (id[0] != '-') // environment variable
+        options.setenv(id, "%s", val);
+      else {// command line option
+        ACE_OS::sprintf(buf, " %s %s", id, val);
+        str += buf;
+      }
+    }
+  }
+
+  ACE_DEBUG((LM_DEBUG, "Command Line : %s\n", str.c_str()));
+
+  options.command_line(str.c_str());
+
+  // Try to create a new process running date.
+  ACE_Process new_process;
+
+  ACE_Time_Value timeout(WAIT_FOR_REGISTRATION_TIME);
+  timeout += ACE_OS::gettimeofday();
+  if (new_process.spawn (options) == -1)
+  {
+    int error = ACE_OS::last_error ();
+    ACE_ERROR ((LM_ERROR,
+      "%p errno = %d.\n",
+      str.c_str(),
+      error));
+    return result;
+  }
+
+  ACE_INET_Addr client_addr;
+  ACE_SOCK_Stream stream;
+
+  ACE_DEBUG((LM_DEBUG, "accepting connection from event channel\n"));
+  if (acceptor.accept(stream, &client_addr, &timeout) != -1)
+  {
+    ACE_DEBUG((LM_DEBUG, "Factory Connect established with %s:%d\n", 
+      client_addr.get_host_name(), client_addr.get_port_number() ));
+
+    // receive the ior string from the created object
+
+    char ior[5000] = {'0'};
+    int n = 0;
+    int byteRead=0;
+    while ((n = stream.recv(ior+byteRead, 5000-byteRead)))  {
+      byteRead += n;
+    }
+
+    if (strlen(ior)  ==0) 
+      return result;
+
+
+    CORBA::Object_var result = orb->string_to_object(ior 
+      ACE_ENV_ARG_PARAMETER);
+
+    ACE_CHECK_RETURN(result);
+
+    if (objects.bind(id, result) ==0){
+      return result._retn(); 
+    }
+  }
+  else {
+    ACE_DEBUG((LM_DEBUG,"accept fail\n"));
+  }
+
+  return result;
+}
+
diff --git a/TAO/orbsvcs/FTRT_Event_Service/Factory_Service/EventChannelFactory_i.h b/TAO/orbsvcs/FTRT_Event_Service/Factory_Service/EventChannelFactory_i.h
new file mode 100644
index 00000000000..8d487cca187
--- /dev/null
+++ b/TAO/orbsvcs/FTRT_Event_Service/Factory_Service/EventChannelFactory_i.h
@@ -0,0 +1,65 @@
+// -*- C++ -*-
+
+//=============================================================================
+/**
+ *  @file   EventChannelFactory_i.h
+ *
+ *  $Id$
+ *
+ *  @author Huang-Ming Huang <hh1@cse.wustl.edu>
+ */
+//=============================================================================#ifndef FT_EVENTSERVICE_H
+
+#ifndef EVENTCHANNELFACTORY_I_H
+#define EVENTCHANNELFACTORY_I_H
+
+#include "orbsvcs/FT_CORBAS.h"
+#include "ace/Synch.h"
+#include "ace/Hash_Map_Manager_T.h"
+
+#if !defined (ACE_LACKS_PRAGMA_ONCE)
+# pragma once
+#endif /* ACE_LACKS_PRAGMA_ONCE */ 
+
+class EventChannelFactory_i : public POA_FT::GenericFactory {
+public:
+	EventChannelFactory_i(const char* conf_filename, CORBA::ORB_ptr);
+
+	virtual CORBA::Object_ptr create_object (
+		const char * type_id,
+		const FT::Criteria & the_criteria,
+		FT::GenericFactory::FactoryCreationId_out factory_creation_id
+		ACE_ENV_ARG_DECL_WITH_DEFAULTS
+		)
+		ACE_THROW_SPEC ((
+		CORBA::SystemException
+		, FT::NoFactory
+		, FT::ObjectNotCreated
+		, FT::InvalidCriteria
+		, FT::InvalidProperty
+		, FT::CannotMeetCriteria
+		)) ;
+
+	virtual void delete_object (
+		const FT::GenericFactory::FactoryCreationId & factory_creation_id
+		ACE_ENV_ARG_DECL_WITH_DEFAULTS
+		)
+		ACE_THROW_SPEC ((
+		CORBA::SystemException
+		, FT::ObjectNotFound
+		));
+
+private:
+  CORBA::Object_ptr create_process (
+		char * process,
+		const FT::Criteria & the_criteria,
+		FT::GenericFactory::FactoryCreationId_out factory_creation_id);
+
+	const char* conf_file;
+	int id;
+	CORBA::ORB_ptr orb;
+	typedef ACE_Hash_Map_Manager<int, CORBA::Object_var, ACE_Null_Mutex> Objects;
+	Objects objects;
+};
+#endif
+
diff --git a/TAO/orbsvcs/FTRT_Event_Service/Factory_Service/FTRTEC_Factory_Service.cpp b/TAO/orbsvcs/FTRT_Event_Service/Factory_Service/FTRTEC_Factory_Service.cpp
new file mode 100644
index 00000000000..2a8694d5639
--- /dev/null
+++ b/TAO/orbsvcs/FTRT_Event_Service/Factory_Service/FTRTEC_Factory_Service.cpp
@@ -0,0 +1,157 @@
+// $Id$
+
+#include "EventChannelFactory_i.h"
+#include "ace/Task.h"
+#include "ace/SString.h"
+#include "ace/Get_Opt.h"
+
+ACE_RCSID (FTRTEC_Factory_Service,
+           FTRTEC_Factory_Service.cpp,
+           "$Id$")
+
+namespace {
+  ACE_CString id, kind, output;
+}
+
+int parse_args(int argc, char* argv[])
+{
+  ACE_Get_Opt get_opt (argc, argv, ACE_LIB_TEXT("i:k:o:"));
+  int opt;
+
+  int result = 0;
+  while ((opt = get_opt ()) != EOF)
+  {
+    switch (opt)
+    {
+    case 'i':
+      id = get_opt.opt_arg ();
+      break;
+    case 'k':
+      kind = get_opt.opt_arg (); 
+      break;
+    case 'o':
+      output = get_opt.opt_arg ();
+      break;
+    default:
+      result = -1;
+      break;
+    }
+  }
+
+  if (result == -1 || (id.length() == 0 && output.length() == 0))
+  {
+    ACE_DEBUG ((LM_DEBUG,
+      ACE_LIB_TEXT("Usage: %s \n")
+      ACE_LIB_TEXT("  [-i id]  set the id that is used to register to the naming service\n")
+      ACE_LIB_TEXT("  [-k kind] set the kind that is used to register to the naming service\n")
+      ACE_LIB_TEXT("  [-o filename] set the output file name for the IOR\n")
+      ACE_LIB_TEXT("\n"),
+      argv[0]));
+    return -1;
+  }
+  return 0;
+}
+
+int main(int argc, ACE_TCHAR* argv[])
+{
+
+	ACE_DECLARE_NEW_CORBA_ENV;
+	ACE_TRY {
+		CORBA::ORB_var orb = CORBA::ORB_init(argc, argv 
+			                                       ACE_ENV_ARG_PARAMETER);
+        ACE_TRY_CHECK;
+
+	
+    if (parse_args(argc, argv) == -1)
+      return -1;
+
+		CORBA::Object_var obj = 
+			orb->resolve_initial_references("RootPOA"  
+			ACE_ENV_ARG_PARAMETER);
+        ACE_TRY_CHECK;
+
+		PortableServer::POA_var poa = 
+			PortableServer::POA::_narrow(obj.in()  
+			                             ACE_ENV_ARG_PARAMETER);
+		ACE_TRY_CHECK;
+		
+		PortableServer::POAManager_var mgr = poa->the_POAManager(ACE_ENV_SINGLE_ARG_PARAMETER);
+		ACE_TRY_CHECK;
+
+		mgr->activate(ACE_ENV_SINGLE_ARG_PARAMETER);
+		ACE_TRY_CHECK;
+		
+		EventChannelFactory_i servant("factory.cfg", orb.in());
+
+		FT::GenericFactory_var event_channel_factory = 
+			servant._this(ACE_ENV_SINGLE_ARG_PARAMETER);
+		ACE_TRY_CHECK;
+
+		// register to the Event Service
+
+    if (id.length()) {
+      CORBA::Object_var namng_contex_object =
+        orb->resolve_initial_references("NameService"
+        ACE_ENV_ARG_PARAMETER);
+      ACE_TRY_CHECK;
+
+      CosNaming::NamingContext_var naming_context = 
+        CosNaming::NamingContext::_narrow(namng_contex_object.in()
+        ACE_ENV_ARG_PARAMETER);
+      ACE_TRY_CHECK;
+
+      // register to naming service
+      CosNaming::Name name(1);
+      name.length(1);
+      name[0].id = CORBA::string_dup(id.c_str());
+      if (kind.length())
+        name[0].kind = CORBA::string_dup(kind.c_str());
+
+      naming_context->bind(name, event_channel_factory.in()
+        ACE_ENV_ARG_PARAMETER);
+      ACE_TRY_CHECK;
+
+      ACE_DEBUG((LM_DEBUG, "Register to naming service with %s", id.c_str()));
+      if (kind.length())
+        ACE_DEBUG((LM_DEBUG, ", %s", kind.c_str()));
+      ACE_DEBUG((LM_DEBUG,"\n"));
+    }
+
+    if (output.length()) {
+      // get the IOR of factory
+      CORBA::String_var str = orb->object_to_string(event_channel_factory.in()
+        ACE_ENV_ARG_PARAMETER);
+      ACE_TRY_CHECK;
+
+      if (ACE_OS::strcmp(output.c_str(), "") != 0)
+      {
+        FILE *output_file=
+          ACE_OS::fopen (ACE_TEXT_CHAR_TO_TCHAR(output.c_str()),
+          ACE_LIB_TEXT("w"));
+        if (output_file == 0)
+          ACE_ERROR_RETURN ((LM_ERROR,
+          "Cannot open output file for writing IOR: %s",
+          output.c_str()),
+          1);
+        ACE_OS::fprintf (output_file, "%s", str.in ());
+        ACE_OS::fclose (output_file);
+      } 
+    }
+
+    ACE_TRY_CHECK;
+
+    orb->run(ACE_ENV_SINGLE_ARG_PARAMETER);
+
+  }
+	ACE_CATCHANY
+	{
+		ACE_PRINT_EXCEPTION(ACE_ANY_EXCEPTION, "A CORBA Exception occurred.");
+	}
+	ACE_ENDTRY;
+
+	
+	ACE_CHECK_RETURN(1);
+ 
+	return 0;
+}
+
diff --git a/TAO/orbsvcs/FTRT_Event_Service/Factory_Service/FTRTEC_Factory_Service.mpc b/TAO/orbsvcs/FTRT_Event_Service/Factory_Service/FTRTEC_Factory_Service.mpc
new file mode 100644
index 00000000000..1208347b2e3
--- /dev/null
+++ b/TAO/orbsvcs/FTRT_Event_Service/Factory_Service/FTRTEC_Factory_Service.mpc
@@ -0,0 +1,10 @@
+project(FTRTEC_Factory_Service): orbsvcsexe, ftorbutils, notify {
+  exename   = ftrtec_factory_service
+  includes += $(TAO_ROOT)/orbsvcs
+  libs += TAO_FaultTolerance
+
+  specific(gnuace) {
+   lit_libs += TAO_Strategies
+  }
+}
+
diff --git a/TAO/orbsvcs/FTRT_Event_Service/Factory_Service/factory.cfg b/TAO/orbsvcs/FTRT_Event_Service/Factory_Service/factory.cfg
new file mode 100644
index 00000000000..021110f6781
--- /dev/null
+++ b/TAO/orbsvcs/FTRT_Event_Service/Factory_Service/factory.cfg
@@ -0,0 +1,2 @@
+IDL:FtRtecEventChannelAdmin/EventChannel:1.0 ../FTRT_Event_Service/ftrt_eventservice
+IDL:RtecEventChannelAdmin/EventChannel:1.0 ../FTRT_Event_Service/ftrt_eventservice
\ No newline at end of file
diff --git a/TAO/orbsvcs/FTRT_Event_Service/Gateway_Service/FTRTEC_Gateway_Service.cpp b/TAO/orbsvcs/FTRT_Event_Service/Gateway_Service/FTRTEC_Gateway_Service.cpp
new file mode 100644
index 00000000000..493c5fefbf8
--- /dev/null
+++ b/TAO/orbsvcs/FTRT_Event_Service/Gateway_Service/FTRTEC_Gateway_Service.cpp
@@ -0,0 +1,134 @@
+// $Id$
+
+#include "ace/Get_Opt.h"
+#include "orbsvcs/FtRtEvent/Utils/FTEC_Gateway.h"
+#include "orbsvcs/FtRtEvent/Utils/resolve_init.h"
+/// include this file to statically linked with FT ORB
+#include "orbsvcs/FaultTolerance/FT_ClientService_Activate.h"
+
+/// include this file to statically linked with Transaction Depth
+#include "orbsvcs/FtRtEvent/ClientORB/FTRT_ClientORB_Loader.h"
+
+ACE_RCSID (FTRTEC_Gateway_Service,
+           FTRTEC_Gateway_Service.cpp,
+           "$Id$")
+
+
+namespace {
+  CORBA::ORB_var orb;
+  FtRtecEventChannelAdmin::EventChannel_var ftec;
+  ACE_CString ior_file_name;
+}
+
+int parse_args(int argc, ACE_TCHAR** argv)
+{
+  ACE_TRY_NEW_ENV {
+    ACE_Get_Opt get_opt (argc, argv, ACE_LIB_TEXT("i:n:o:"));
+    int opt;
+    CosNaming::Name name(1);
+    name.length(1);
+    name[0].id = CORBA::string_dup("FT_EventService");
+
+    while ((opt = get_opt ()) != EOF)
+    {
+      switch (opt)
+      {
+      case 'i': 
+        {
+          CORBA::Object_var obj = orb->string_to_object(get_opt.opt_arg () 
+                                                        ACE_ENV_ARG_PARAMETER);
+          ACE_TRY_CHECK;
+          ftec = FtRtecEventChannelAdmin::EventChannel::_narrow(obj.in() 
+                                                                ACE_ENV_ARG_PARAMETER);
+          ACE_TRY_CHECK;
+        }
+        break;
+      case 'n':
+        name[0].id = CORBA::string_dup(get_opt.opt_arg ());
+        break;
+      case 'o':
+        ior_file_name = get_opt.opt_arg (); 
+        break;
+      }
+    }
+
+    if (CORBA::is_nil(ftec.in())) {
+      /// we should get the ftec from Naming Service
+
+      CosNaming::NamingContext_var naming_context =
+        resolve_init<CosNaming::NamingContext>(orb.in(), "NameService"
+        ACE_ENV_ARG_PARAMETER);
+      ACE_TRY_CHECK;
+
+      ftec = resolve<FtRtecEventChannelAdmin::EventChannel>(naming_context.in(),
+        name
+        ACE_ENV_ARG_PARAMETER);
+      ACE_TRY_CHECK;
+
+      if (CORBA::is_nil(ftec.in()))
+        ACE_ERROR_RETURN((LM_ERROR, "Cannot Find FT_EventService\n"), -1);
+    }
+  }
+  ACE_CATCHANY {
+    ACE_ERROR_RETURN((LM_ERROR, "Cannot Find FT_EventService\n"), -1);
+  }
+  ACE_ENDTRY;  
+  return 0;
+}
+
+int main(int argc,  ACE_TCHAR** argv)
+{
+  ACE_TRY_NEW_ENV 
+  {
+    orb = CORBA::ORB_init (argc, argv ACE_ENV_ARG_PARAMETER);
+    ACE_TRY_CHECK;
+
+    if (parse_args(argc, argv)==-1)
+      return 1;
+
+    PortableServer::POA_var
+      root_poa =  resolve_init<PortableServer::POA>(orb.in(), "RootPOA"  
+      ACE_ENV_ARG_PARAMETER);
+    ACE_TRY_CHECK;
+
+    // create POAManager
+    PortableServer::POAManager_var 
+      mgr = root_poa->the_POAManager(ACE_ENV_SINGLE_ARG_PARAMETER);
+    ACE_TRY_CHECK;
+
+
+    mgr->activate(ACE_ENV_SINGLE_ARG_PARAMETER);
+    ACE_TRY_CHECK;
+
+    TAO_FTRTEC::FTEC_Gateway gateway_servant(orb.in(), ftec.in());
+
+    RtecEventChannelAdmin::EventChannel_var gateway = 
+      gateway_servant.activate(root_poa.in() ACE_ENV_ARG_PARAMETER);
+    ACE_TRY_CHECK;
+
+    if (ior_file_name.length()) 
+    {
+      CORBA::String_var str = orb->object_to_string(gateway.in()
+        ACE_ENV_ARG_PARAMETER);
+      ACE_TRY_CHECK;
+
+      FILE *output_file=
+        ACE_OS::fopen (ACE_TEXT_CHAR_TO_TCHAR(ior_file_name.c_str()),
+        ACE_LIB_TEXT("w"));
+      if (output_file == 0)
+        ACE_ERROR_RETURN ((LM_ERROR,
+        "Cannot open output file for writing IOR: %s",
+        ior_file_name.c_str()),
+        1);
+      ACE_OS::fprintf (output_file, "%s", str.in ());
+      ACE_OS::fclose (output_file); 
+    }
+
+    orb->run(ACE_ENV_SINGLE_ARG_PARAMETER);
+  }
+  ACE_CATCHANY {
+    return 1;
+  }
+  ACE_ENDTRY;
+  return 0;
+}
diff --git a/TAO/orbsvcs/FTRT_Event_Service/Gateway_Service/FTRTEC_Gateway_Service.mpc b/TAO/orbsvcs/FTRT_Event_Service/Gateway_Service/FTRTEC_Gateway_Service.mpc
new file mode 100644
index 00000000000..7c21a4791f3
--- /dev/null
+++ b/TAO/orbsvcs/FTRT_Event_Service/Gateway_Service/FTRTEC_Gateway_Service.mpc
@@ -0,0 +1,9 @@
+  project(FTRTEC_Gateway_Service): orbsvcsexe, ftrteventclient {
+  exename   = ftrtec_gateway_service
+  includes += $(TAO_ROOT)/orbsvcs $(TAO_ROOT)/orbsvcs/FtRtEvent/Utils
+
+  specific(gnuace) {
+   lit_libs += TAO_Strategies
+  }
+}
+
diff --git a/TAO/orbsvcs/FTRT_Event_Service/Gateway_Service/svc.conf b/TAO/orbsvcs/FTRT_Event_Service/Gateway_Service/svc.conf
new file mode 100644
index 00000000000..49c3a8a3d04
--- /dev/null
+++ b/TAO/orbsvcs/FTRT_Event_Service/Gateway_Service/svc.conf
@@ -0,0 +1,3 @@
+## $Id$
+
+static FTRT_ClientORB_Service "-ORBTransactionDepth $FTEC_TransactionDepth"
\ No newline at end of file