*** empty log message ***

12 files changed, 0 insertions, 941 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
deleted file mode 100644
index 3498b83f115..00000000000
--- a/TAO/orbsvcs/FTRT_Event_Service/Event_Service/FTRT_Event_Service.mpc
+++ /dev/null
@@ -1,9 +0,0 @@
-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
deleted file mode 100644
index d355b524b9a..00000000000
--- a/TAO/orbsvcs/FTRT_Event_Service/Event_Service/FT_EventService.cpp
+++ /dev/null
@@ -1,286 +0,0 @@
-// $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
deleted file mode 100644
index 3982c19aa88..00000000000
--- a/TAO/orbsvcs/FTRT_Event_Service/Event_Service/FT_EventService.h
+++ /dev/null
@@ -1,45 +0,0 @@
-// -*- 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
deleted file mode 100644
index d23c985de19..00000000000
--- a/TAO/orbsvcs/FTRT_Event_Service/Event_Service/svc.conf
+++ /dev/null
@@ -1,20 +0,0 @@
-## $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
deleted file mode 100644
index d5ae2571be4..00000000000
--- a/TAO/orbsvcs/FTRT_Event_Service/Factory_Service/EventChannelFactory_i.cpp
+++ /dev/null
@@ -1,201 +0,0 @@
-// $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_process");
-
-  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
deleted file mode 100644
index 8d487cca187..00000000000
--- a/TAO/orbsvcs/FTRT_Event_Service/Factory_Service/EventChannelFactory_i.h
+++ /dev/null
@@ -1,65 +0,0 @@
-// -*- 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
deleted file mode 100644
index 2a8694d5639..00000000000
--- a/TAO/orbsvcs/FTRT_Event_Service/Factory_Service/FTRTEC_Factory_Service.cpp
+++ /dev/null
@@ -1,157 +0,0 @@
-// $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
deleted file mode 100644
index 1208347b2e3..00000000000
--- a/TAO/orbsvcs/FTRT_Event_Service/Factory_Service/FTRTEC_Factory_Service.mpc
+++ /dev/null
@@ -1,10 +0,0 @@
-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
deleted file mode 100644
index 021110f6781..00000000000
--- a/TAO/orbsvcs/FTRT_Event_Service/Factory_Service/factory.cfg
+++ /dev/null
@@ -1,2 +0,0 @@
-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
deleted file mode 100644
index 493c5fefbf8..00000000000
--- a/TAO/orbsvcs/FTRT_Event_Service/Gateway_Service/FTRTEC_Gateway_Service.cpp
+++ /dev/null
@@ -1,134 +0,0 @@
-// $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
deleted file mode 100644
index 7c21a4791f3..00000000000
--- a/TAO/orbsvcs/FTRT_Event_Service/Gateway_Service/FTRTEC_Gateway_Service.mpc
+++ /dev/null
@@ -1,9 +0,0 @@
-  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
deleted file mode 100644
index 49c3a8a3d04..00000000000
--- a/TAO/orbsvcs/FTRT_Event_Service/Gateway_Service/svc.conf
+++ /dev/null
@@ -1,3 +0,0 @@
-## $Id$
-
-static FTRT_ClientORB_Service "-ORBTransactionDepth $FTEC_TransactionDepth"
\ No newline at end of file