2 files changed, 1312 insertions, 0 deletions

diff --git a/CIAO/examples/RT1H/Env_Detector_Impl_svnt.cpp b/CIAO/examples/RT1H/Env_Detector_Impl_svnt.cpp
new file mode 100644
index 00000000000..9382b925a9e
--- /dev/null
+++ b/CIAO/examples/RT1H/Env_Detector_Impl_svnt.cpp
@@ -0,0 +1,912 @@
+// $Id$
+//
+// ****              Code generated by the                 ****
+// ****  Component Integrated ACE ORB (CIAO) CIDL Compiler ****
+// CIAO has been developed by:
+//       Center for Distributed Object Computing
+//       Washington University
+//       St. Louis, MO
+//       USA
+//       http://www.cs.wustl.edu/~schmidt/doc-center.html
+// CIDL Compiler has been developed by:
+//       Institute for Software Integrated Systems
+//       Vanderbilt University
+//       Nashville, TN
+//       USA
+//       http://www.isis.vanderbilt.edu/
+//
+// Information about CIAO is available at:
+//    http://www.dre.vanderbilt.edu/CIAO
+
+#include "Env_Detector_Impl_svnt.h"
+#include "Cookies.h"
+#include "ciao/Servant_Activator.h"
+#include "ciao/Port_Activator_T.h"
+#include "ace/SString.h"
+
+namespace CIDL_MonolithicImplementation
+{
+  Env_Detector_Context::Env_Detector_Context (
+    ::Components::CCMHome_ptr h,
+    ::CIAO::Session_Container *c,
+    Env_Detector_Servant *sv)
+    : ::CIAO::Context_Impl_Base (h, c), 
+      ::CIAO::Context_Impl<
+          ::TSCE::CCM_Env_Detector_Context,
+          Env_Detector_Servant,
+          ::TSCE::Env_Detector,
+          ::TSCE::Env_Detector_var
+        > (h, c, sv)
+  {
+  }
+
+  Env_Detector_Context::~Env_Detector_Context (void)
+  {
+  }
+
+  // Operations for Env_Detector receptacles and event sources,
+  // defined in ::TSCE::CCM_Env_Detector_Context.
+
+  void
+  Env_Detector_Context::push_track (
+    ::TSCE::Track_Event *ev
+    ACE_ENV_ARG_DECL)
+  ACE_THROW_SPEC (( ::CORBA::SystemException))
+  {
+    for (ACE_Active_Map_Manager< 
+           ::TSCE::Track_EventConsumer_var>::iterator iter =
+             this->ciao_publishes_track_map_.begin ();
+         iter != this->ciao_publishes_track_map_.end ();
+         ++iter)
+    {
+      (*iter).int_id_->push_Track_Event (
+        ev
+        ACE_ENV_ARG_PARAMETER);
+      ACE_CHECK;
+    }
+
+    for (ACE_Active_Map_Manager< 
+           ::Components::EventConsumerBase_var>::iterator giter =
+             this->ciao_publishes_track_generic_map_.begin ();
+         giter != this->ciao_publishes_track_generic_map_.end ();
+         ++giter)
+    {
+      (*giter).int_id_->push_event (
+        ev
+        ACE_ENV_ARG_PARAMETER);
+      ACE_CHECK;
+    }
+  }
+
+  ::Components::Cookie *
+  Env_Detector_Context::subscribe_track (
+    ::TSCE::Track_EventConsumer_ptr c
+    ACE_ENV_ARG_DECL)
+  ACE_THROW_SPEC (( ::CORBA::SystemException,
+                   ::Components::ExceededConnectionLimit))
+  {
+    if ( ::CORBA::is_nil (c))
+    {
+      ACE_THROW_RETURN ( ::CORBA::BAD_PARAM (), 0);
+    }
+
+    ::TSCE::Track_EventConsumer_var sub =
+      ::TSCE::Track_EventConsumer::_duplicate (c);
+
+    ACE_Active_Map_Manager_Key key;
+    this->ciao_publishes_track_map_.bind (sub.in (), key);
+    sub._retn ();
+
+    ::Components::Cookie * retv = 0;
+    ACE_NEW_THROW_EX (retv,
+                      ::CIAO::Map_Key_Cookie (key),
+                      ::CORBA::NO_MEMORY ());
+
+    return retv;
+  }
+
+  ::Components::Cookie *
+  Env_Detector_Context::subscribe_track_generic (
+    ::Components::EventConsumerBase_ptr c
+    ACE_ENV_ARG_DECL)
+  ACE_THROW_SPEC (( ::CORBA::SystemException,
+                   ::Components::ExceededConnectionLimit))
+  {
+    if ( ::CORBA::is_nil (c))
+    {
+      ACE_THROW_RETURN ( ::CORBA::BAD_PARAM (), 0);
+    }
+
+    ::Components::EventConsumerBase_var sub =
+      ::Components::EventConsumerBase::_duplicate (c);
+
+    ACE_Active_Map_Manager_Key key;
+    this->ciao_publishes_track_generic_map_.bind (sub.in (), key);
+    sub._retn ();
+
+    ::Components::Cookie * retv = 0;
+    ACE_NEW_THROW_EX (retv,
+                      ::CIAO::Map_Key_Cookie (key),
+                      ::CORBA::NO_MEMORY ());
+
+    return retv;
+  }
+
+  ::TSCE::Track_EventConsumer_ptr
+  Env_Detector_Context::unsubscribe_track (
+    ::Components::Cookie *ck
+    ACE_ENV_ARG_DECL)
+  ACE_THROW_SPEC (( ::CORBA::SystemException,
+                   ::Components::InvalidConnection))
+  {
+    ACE_Active_Map_Manager_Key key;
+
+    if (ck == 0 || ::CIAO::Map_Key_Cookie::extract (ck, key) == false)
+    {
+      ACE_THROW_RETURN ( ::Components::InvalidConnection (),
+                        ::TSCE::Track_EventConsumer::_nil ());
+    }
+
+    ::TSCE::Track_EventConsumer_var retv;
+    if (this->ciao_publishes_track_map_.unbind (key, retv) == 0)
+    {
+      return retv._retn ();
+    }
+
+    ::Components::EventConsumerBase_var ecb;
+
+    if (this->ciao_publishes_track_generic_map_.unbind (key, ecb) != 0)
+    {
+      ACE_THROW_RETURN ( ::Components::InvalidConnection (),
+                        ::TSCE::Track_EventConsumer::_nil ());
+    }
+
+    return ::TSCE::Track_EventConsumer::_nil ();
+  }
+
+  ::CUTS::Testing_Service_ptr
+  Env_Detector_Context::get_connection_cuts_testing_service (
+    ACE_ENV_SINGLE_ARG_DECL_NOT_USED)
+  ACE_THROW_SPEC (( ::CORBA::SystemException))
+  {
+    return ::CUTS::Testing_Service::_duplicate (
+      this->ciao_uses_cuts_testing_service_.in ());
+  }
+
+  void
+  Env_Detector_Context::connect_cuts_testing_service (
+    ::CUTS::Testing_Service_ptr c
+    ACE_ENV_ARG_DECL)
+  ACE_THROW_SPEC (( ::CORBA::SystemException,
+                   ::Components::AlreadyConnected,
+                   ::Components::InvalidConnection))
+  {
+    if (! ::CORBA::is_nil (this->ciao_uses_cuts_testing_service_.in ()))
+    {
+      ACE_THROW ( ::Components::AlreadyConnected ());
+    }
+
+    if ( ::CORBA::is_nil (c))
+    {
+      ACE_THROW ( ::Components::InvalidConnection ());
+    }
+
+    this->ciao_uses_cuts_testing_service_ =
+      ::CUTS::Testing_Service::_duplicate (c);
+  }
+
+  ::CUTS::Testing_Service_ptr
+  Env_Detector_Context::disconnect_cuts_testing_service (
+    ACE_ENV_SINGLE_ARG_DECL)
+  ACE_THROW_SPEC (( ::CORBA::SystemException,
+                   ::Components::NoConnection))
+  {
+    if ( ::CORBA::is_nil (this->ciao_uses_cuts_testing_service_.in ()))
+    {
+      ACE_THROW_RETURN ( ::Components::NoConnection (),
+                        ::CUTS::Testing_Service::_nil ());
+    }
+
+    return this->ciao_uses_cuts_testing_service_._retn ();
+  }
+
+  // CIAO-specific.
+
+  Env_Detector_Context *
+  Env_Detector_Context::_narrow (
+    ::Components::SessionContext_ptr p
+    ACE_ENV_ARG_DECL_NOT_USED)
+  {
+    return dynamic_cast<Env_Detector_Context *> (p);
+  }
+
+  Env_Detector_Servant::Env_Detector_Servant (
+    ::TSCE::CCM_Env_Detector_ptr exe,
+    ::Components::CCMHome_ptr h,
+    const char *ins_name,
+    ::CIAO::Home_Servant_Impl_Base *hs,
+    ::CIAO::Session_Container *c,
+    ::CIAO::REC_POL_MAP &rec_pol_map)
+    : ::CIAO::Servant_Impl_Base (h, hs, c, rec_pol_map),
+      ::CIAO::Servant_Impl<
+          ::POA_TSCE::Env_Detector,
+          ::TSCE::CCM_Env_Detector,
+          Env_Detector_Context
+        > (exe, h, hs, c, rec_pol_map),
+      ins_name_ (ins_name)
+  {
+    ACE_NEW (this->context_,
+             Env_Detector_Context (h, c, this));
+
+    // Set the instance id of the component on the context
+
+    this->context_->_ciao_instance_id (this->ins_name_);
+
+    CIAO_REGISTER_OBV_FACTORY (
+      ::TSCE::Command_Event_init,
+      ::TSCE::Command_Event);
+
+    ACE_TRY_NEW_ENV
+    {
+      ::Components::SessionComponent_var scom =
+        ::Components::SessionComponent::_narrow (
+          exe
+          ACE_ENV_ARG_PARAMETER);
+      ACE_TRY_CHECK;
+
+      if (! ::CORBA::is_nil (scom.in ()))
+      {
+        scom->set_session_context (
+          this->context_
+          ACE_ENV_ARG_PARAMETER);
+        ACE_TRY_CHECK;
+      }
+
+      this->populate_port_tables (
+        ACE_ENV_SINGLE_ARG_PARAMETER);
+      ACE_TRY_CHECK;
+    }
+
+    ACE_CATCHANY
+    {
+    }
+
+    ACE_ENDTRY;
+  }
+
+  Env_Detector_Servant::~Env_Detector_Servant (void)
+  {
+  }
+
+  void
+  Env_Detector_Servant::set_attributes (
+    const ::Components::ConfigValues &descr
+    ACE_ENV_ARG_DECL)
+  {
+    ACE_ENV_EMIT_CODE (ACE_UNUSED_ARG (ACE_TRY_ENV));
+
+    for ( ::CORBA::ULong i = 0; i < descr.length (); ++i)
+    {
+      const char *descr_name = descr[i]->name ();
+      ::CORBA::Any &descr_value = descr[i]->value ();
+
+      ACE_UNUSED_ARG (descr_name);
+      ACE_UNUSED_ARG (descr_value);
+    }
+  }
+
+  ::Components::Cookie *
+  Env_Detector_Servant::subscribe_track (
+    ::TSCE::Track_EventConsumer_ptr c
+    ACE_ENV_ARG_DECL)
+  ACE_THROW_SPEC (( ::CORBA::SystemException,
+                   ::Components::ExceededConnectionLimit))
+  {
+    return this->context_->subscribe_track (
+      c
+      ACE_ENV_ARG_PARAMETER);
+  }
+
+  ::Components::Cookie *
+  Env_Detector_Servant::subscribe_track_generic (
+    ::Components::EventConsumerBase_ptr c
+    ACE_ENV_ARG_DECL)
+  ACE_THROW_SPEC (( ::CORBA::SystemException,
+                   ::Components::ExceededConnectionLimit))
+  {
+    return this->context_->subscribe_track_generic (
+      c
+      ACE_ENV_ARG_PARAMETER);
+  }
+
+  ::TSCE::Track_EventConsumer_ptr
+  Env_Detector_Servant::unsubscribe_track (
+    ::Components::Cookie *ck
+    ACE_ENV_ARG_DECL)
+  ACE_THROW_SPEC (( ::CORBA::SystemException,
+                   ::Components::InvalidConnection))
+  {
+    return this->context_->unsubscribe_track (
+      ck
+      ACE_ENV_ARG_PARAMETER);
+  }
+
+  Env_Detector_Servant::Command_EventConsumer_command_Servant::Command_EventConsumer_command_Servant (
+    ::TSCE::CCM_Env_Detector_ptr executor,
+    ::TSCE::CCM_Env_Detector_Context_ptr c)
+    : executor_ ( ::TSCE::CCM_Env_Detector::_duplicate (executor)),
+      ctx_ ( ::TSCE::CCM_Env_Detector_Context::_duplicate (c))
+  {
+  }
+
+  Env_Detector_Servant::Command_EventConsumer_command_Servant::~Command_EventConsumer_command_Servant (void)
+  {
+  }
+
+  ::CORBA::Object_ptr
+  Env_Detector_Servant::Command_EventConsumer_command_Servant::_get_component (
+    ACE_ENV_SINGLE_ARG_DECL)
+  ACE_THROW_SPEC (( ::CORBA::SystemException))
+  {
+    return this->ctx_->get_CCM_object (ACE_ENV_SINGLE_ARG_PARAMETER);
+  }
+
+  void
+  Env_Detector_Servant::Command_EventConsumer_command_Servant::push_Command_Event (
+    ::TSCE::Command_Event *evt
+    ACE_ENV_ARG_DECL)
+  ACE_THROW_SPEC (( ::CORBA::SystemException))
+  {
+    this->executor_->push_command (
+      evt
+      ACE_ENV_ARG_PARAMETER);
+  }
+
+  // Inherited from ::Components::EventConsumerBase.
+  void
+  Env_Detector_Servant::Command_EventConsumer_command_Servant::push_event (
+    ::Components::EventBase *ev
+    ACE_ENV_ARG_DECL)
+  ACE_THROW_SPEC (( ::CORBA::SystemException,
+                   ::Components::BadEventType))
+  {
+    ::TSCE::Command_Event_var ev_type =
+      ::TSCE::Command_Event::_downcast (ev);
+
+    if (ev_type.in () != 0)
+    {
+      this->push_Command_Event (
+        ev_type.in ()
+        ACE_ENV_ARG_PARAMETER);
+
+      return;
+    }
+
+    ACE_THROW ( ::Components::BadEventType ());
+  }
+
+  CORBA::Boolean
+  Env_Detector_Servant::Command_EventConsumer_command_Servant::ciao_is_substitutable (
+    const char * event_repo_id
+    ACE_ENV_ARG_DECL)
+  ACE_THROW_SPEC (( ::CORBA::SystemException))
+  {
+    if (event_repo_id == 0)
+    {
+      ACE_THROW_RETURN ( ::CORBA::BAD_PARAM (), false);
+    }
+
+    Env_Detector_Context *ctx =
+      Env_Detector_Context::_narrow (
+        this->ctx_.in ()
+        ACE_ENV_ARG_PARAMETER);
+    ACE_CHECK_RETURN (false);
+
+    CORBA::ORB_ptr orb = ctx->_ciao_the_Container ()->the_ORB ();
+
+    CORBA::ValueFactory f =
+      orb->lookup_value_factory (
+        event_repo_id
+        ACE_ENV_ARG_PARAMETER);
+    ACE_CHECK_RETURN (false);
+
+    if (f == 0)
+    {
+      return false;
+    }
+
+    CORBA::ValueBase_var v =
+      f->create_for_unmarshal (ACE_ENV_SINGLE_ARG_PARAMETER);
+    ACE_CHECK_RETURN (false);
+
+    f->_remove_ref ();
+
+    if (v.in () == 0)
+    {
+      return false;
+    }
+
+    return dynamic_cast< ::TSCE::Command_Event *> (v.in ()) != 0;
+  }
+
+
+  ::TSCE::Command_EventConsumer_ptr
+  Env_Detector_Servant::get_consumer_command (
+    ACE_ENV_SINGLE_ARG_DECL)
+  ACE_THROW_SPEC (( ::CORBA::SystemException))
+  {
+    if (! ::CORBA::is_nil (this->consumes_command_.in ()))
+    {
+      return ::TSCE::Command_EventConsumer::_duplicate (this->consumes_command_.in ());
+    }
+
+    ::Components::EventConsumerBase_var obj =
+      this->get_consumer_command_i (
+        ACE_ENV_SINGLE_ARG_PARAMETER);
+    ACE_CHECK_RETURN ( ::TSCE::Command_EventConsumer::_nil ());
+
+    ::TSCE::Command_EventConsumer_var eco =
+      ::TSCE::Command_EventConsumer::_narrow (
+        obj.in ()
+        ACE_ENV_ARG_PARAMETER);
+    ACE_CHECK_RETURN ( ::TSCE::Command_EventConsumer::_nil ());
+
+    this->consumes_command_ = eco;
+    return ::TSCE::Command_EventConsumer::_duplicate (this->consumes_command_.in ());
+  }
+
+  ::Components::EventConsumerBase_ptr
+  Env_Detector_Servant::get_consumer_command_i (
+    ACE_ENV_SINGLE_ARG_DECL)
+  ACE_THROW_SPEC (( ::CORBA::SystemException))
+  {
+    ::Components::EventConsumerBase_ptr ret =
+      this->lookup_consumer ("command");
+
+    if (! ::CORBA::is_nil (ret))
+    {
+      return ret;
+    }
+
+    ::CIAO::Port_Activator_T<
+    Env_Detector_Servant::Command_EventConsumer_command_Servant,
+    ::TSCE::CCM_Env_Detector,
+    ::TSCE::CCM_Env_Detector_Context,
+    Env_Detector_Servant > *tmp = 0;
+
+    typedef  CIAO::Port_Activator_T<
+        Env_Detector_Servant::Command_EventConsumer_command_Servant,
+        ::TSCE::CCM_Env_Detector,
+        ::TSCE::CCM_Env_Detector_Context, 
+        Env_Detector_Servant
+      >
+    MACRO_MADNESS_TYPEDEF;
+
+    ACE_CString obj_id (this->ins_name_);
+    obj_id += "_command";
+
+    ACE_NEW_THROW_EX (
+      tmp,
+      MACRO_MADNESS_TYPEDEF (obj_id.c_str (),
+                             "command",
+                             ::CIAO::Port_Activator::Sink,
+                             this->executor_.in (),
+                             this->context_,
+                             this),
+      ::CORBA::NO_MEMORY ());
+
+    ::CIAO::Servant_Activator *sa =
+      this->container_->ports_servant_activator ();
+
+    if (!sa->register_port_activator (tmp))
+    {
+      return ::TSCE::Command_EventConsumer::_nil ();
+    }
+
+    ::CORBA::Object_var obj =
+      this->container_->generate_reference (
+        obj_id.c_str (),
+        "IDL:TSCE/Command_EventConsumer:1.0",
+        ::CIAO::Container::Facet_Consumer
+        ACE_ENV_ARG_PARAMETER);
+    ACE_CHECK_RETURN ( ::TSCE::Command_EventConsumer::_nil ());
+
+    ::Components::EventConsumerBase_var ecb =
+      ::Components::EventConsumerBase::_narrow (
+        obj.in ()
+        ACE_ENV_ARG_PARAMETER);
+    ACE_CHECK_RETURN ( ::TSCE::Command_EventConsumer::_nil ());
+
+    this->add_consumer ("command",
+                        ecb.in ()
+                        ACE_ENV_ARG_PARAMETER);
+    ACE_CHECK_RETURN ( ::TSCE::Command_EventConsumer::_nil ());
+
+    return ecb._retn ();
+  }
+
+  ::Components::Cookie *
+  Env_Detector_Servant::connect (
+    const char *name,
+    ::CORBA::Object_ptr connection
+    ACE_ENV_ARG_DECL)
+  ACE_THROW_SPEC (( ::CORBA::SystemException,
+                   ::Components::InvalidName,
+                   ::Components::InvalidConnection,
+                   ::Components::AlreadyConnected,
+                   ::Components::ExceededConnectionLimit))
+  {
+    // If the component has no receptacles, this will be unused.
+    ACE_UNUSED_ARG (connection);
+
+    if (name == 0)
+    {
+      ACE_THROW_RETURN ( ::Components::InvalidName (), 0);
+    }
+
+    if (ACE_OS::strcmp (name, "cuts_testing_service") == 0)
+    {
+      ::CUTS::Testing_Service_var _ciao_conn =
+      ::CUTS::Testing_Service::_narrow (
+        connection
+        ACE_ENV_ARG_PARAMETER);
+      ACE_CHECK_RETURN (0);
+
+      if ( ::CORBA::is_nil (_ciao_conn.in ()))
+      {
+        ACE_THROW_RETURN ( ::Components::InvalidConnection (), 0);
+      }
+
+      // Simplex connect.
+      this->connect_cuts_testing_service (
+        _ciao_conn.in ()
+        ACE_ENV_ARG_PARAMETER);
+      ACE_CHECK_RETURN (0);
+
+      return 0;
+    }
+
+    ACE_THROW_RETURN ( ::Components::InvalidName (), 0);
+  }
+
+  ::CORBA::Object_ptr
+  Env_Detector_Servant::disconnect (
+    const char *name,
+    ::Components::Cookie * ck
+    ACE_ENV_ARG_DECL)
+  ACE_THROW_SPEC (( ::CORBA::SystemException,
+                   ::Components::InvalidName,
+                   ::Components::InvalidConnection,
+                   ::Components::CookieRequired,
+                   ::Components::NoConnection))
+  {
+    ACE_UNUSED_ARG (ck);
+
+    if (name == 0)
+    {
+      ACE_THROW_RETURN ( ::CORBA::BAD_PARAM (),
+                        ::CORBA::Object::_nil ());
+    }
+
+    if (ACE_OS::strcmp (name, "cuts_testing_service") == 0)
+    {
+      // Simplex disconnect.
+      return this->disconnect_cuts_testing_service (ACE_ENV_SINGLE_ARG_PARAMETER);
+    }
+
+    ACE_THROW_RETURN ( ::Components::InvalidName (),
+                      ::CORBA::Object::_nil ());
+  }
+
+  ::Components::ReceptacleDescriptions *
+  Env_Detector_Servant::get_all_receptacles (
+    ACE_ENV_SINGLE_ARG_DECL)
+  ACE_THROW_SPEC (( ::CORBA::SystemException))
+  {
+    ::Components::ReceptacleDescriptions *retval = 0;
+    ACE_NEW_RETURN (retval,
+                    ::Components::ReceptacleDescriptions,
+                    0);
+    ::Components::ReceptacleDescriptions_var safe_retval = retval;
+    safe_retval->length (1UL);
+
+    ::CIAO::Servant_Impl_Base::describe_simplex_receptacle<
+        ::CUTS::Testing_Service_var
+      > ("cuts_testing_service",
+         "IDL:CUTS/Testing_Service:1.0",
+         this->context_->ciao_uses_cuts_testing_service_,
+         safe_retval,
+         0UL);
+
+    return safe_retval._retn ();
+  }
+
+  void
+  Env_Detector_Servant::connect_cuts_testing_service (
+    ::CUTS::Testing_Service_ptr c
+    ACE_ENV_ARG_DECL)
+  ACE_THROW_SPEC (( ::CORBA::SystemException,
+                   ::Components::AlreadyConnected,
+                   ::Components::InvalidConnection))
+  {
+    this->context_->connect_cuts_testing_service (
+      c
+      ACE_ENV_ARG_PARAMETER);
+
+    this->add_receptacle ("cuts_testing_service", c, 0);
+  }
+
+  ::CUTS::Testing_Service_ptr
+  Env_Detector_Servant::disconnect_cuts_testing_service (
+    ACE_ENV_SINGLE_ARG_DECL)
+  ACE_THROW_SPEC (( ::CORBA::SystemException,
+                   ::Components::NoConnection))
+  {
+    return this->context_->disconnect_cuts_testing_service (
+      ACE_ENV_SINGLE_ARG_PARAMETER);
+  }
+
+  ::CUTS::Testing_Service_ptr
+  Env_Detector_Servant::get_connection_cuts_testing_service (
+    ACE_ENV_SINGLE_ARG_DECL)
+  ACE_THROW_SPEC (( ::CORBA::SystemException))
+  {
+    return this->context_->get_connection_cuts_testing_service (
+      ACE_ENV_SINGLE_ARG_PARAMETER);
+  }
+
+  void
+  Env_Detector_Servant::connect_consumer (
+    const char * emitter_name,
+    ::Components::EventConsumerBase_ptr consumer
+    ACE_ENV_ARG_DECL)
+  ACE_THROW_SPEC (( ::CORBA::SystemException,
+                   ::Components::InvalidName,
+                   ::Components::AlreadyConnected,
+                   ::Components::InvalidConnection))
+  {
+    if (emitter_name == 0)
+    {
+      ACE_THROW ( ::CORBA::BAD_PARAM ());
+    }
+
+    ACE_UNUSED_ARG (consumer);
+    ACE_THROW ( ::Components::InvalidName ());
+  }
+
+  ::Components::EventConsumerBase_ptr
+  Env_Detector_Servant::disconnect_consumer (
+    const char *source_name
+    ACE_ENV_ARG_DECL)
+  ACE_THROW_SPEC (( ::CORBA::SystemException,
+                   ::Components::InvalidName,
+                   ::Components::NoConnection))
+  {
+    if (source_name == 0)
+    {
+      ACE_THROW_RETURN ( ::CORBA::BAD_PARAM (),
+                        ::Components::EventConsumerBase::_nil ());
+    }
+
+    ACE_THROW_RETURN ( ::Components::InvalidName (),
+                      ::Components::EventConsumerBase::_nil ());
+  }
+
+  ::Components::PublisherDescriptions *
+  Env_Detector_Servant::get_all_publishers (
+    ACE_ENV_SINGLE_ARG_DECL)
+  ACE_THROW_SPEC (( ::CORBA::SystemException))
+  {
+    ::Components::PublisherDescriptions *retval = 0;
+    ACE_NEW_RETURN (retval,
+                    ::Components::PublisherDescriptions,
+                    0);
+    ::Components::PublisherDescriptions_var safe_retval = retval;
+    safe_retval->length (1UL);
+
+    ::CIAO::Servant_Impl_Base::describe_pub_event_source<
+        ::TSCE::Track_EventConsumer_var
+      > ("track",
+         "IDL:TSCE/Track_Event:1.0",
+         this->context_->ciao_publishes_track_map_,
+         safe_retval,
+         0UL);
+
+    return safe_retval._retn ();
+  }
+
+  ::Components::EmitterDescriptions *
+  Env_Detector_Servant::get_all_emitters (
+    ACE_ENV_SINGLE_ARG_DECL)
+  ACE_THROW_SPEC (( ::CORBA::SystemException))
+  {
+    ::Components::EmitterDescriptions *retval = 0;
+    ACE_NEW_RETURN (retval,
+                    ::Components::EmitterDescriptions,
+                    0);
+    ::Components::EmitterDescriptions_var safe_retval = retval;
+    safe_retval->length (0UL);
+
+    return safe_retval._retn ();
+  }
+
+  ::Components::Cookie *
+  Env_Detector_Servant::subscribe (
+    const char *publisher_name,
+    ::Components::EventConsumerBase_ptr subscribe
+    ACE_ENV_ARG_DECL)
+  ACE_THROW_SPEC (( ::CORBA::SystemException,
+                   ::Components::InvalidName,
+                   ::Components::InvalidConnection,
+                   ::Components::ExceededConnectionLimit))
+  {
+    // Just in case there are no if blocks
+    ACE_UNUSED_ARG (subscribe);
+
+    if (publisher_name == 0)
+    {
+      ACE_THROW_RETURN ( ::Components::InvalidName (), 0);
+    }
+
+    if (ACE_OS::strcmp (publisher_name, "track") == 0)
+    {
+      ::TSCE::Track_EventConsumer_var sub =
+        ::TSCE::Track_EventConsumer::_narrow (
+        subscribe
+        ACE_ENV_ARG_PARAMETER);
+      ACE_CHECK_RETURN (0);
+
+      if ( ::CORBA::is_nil (sub.in ()))
+      {
+        ::CORBA::Boolean substitutable =
+          subscribe->ciao_is_substitutable (
+            ::TSCE::Track_Event::_tao_obv_static_repository_id ()
+            ACE_ENV_ARG_PARAMETER);
+        ACE_CHECK_RETURN (0);
+
+        if (substitutable)
+        {
+          return this->subscribe_track_generic (
+            subscribe
+            ACE_ENV_ARG_PARAMETER);
+        }
+
+        else
+        {
+          ACE_THROW_RETURN ( ::Components::InvalidConnection (), 0);
+        }
+      }
+
+      else
+      {
+        return this->subscribe_track (
+          sub.in ()
+          ACE_ENV_ARG_PARAMETER);
+      }
+    }
+
+    ACE_THROW_RETURN ( ::Components::InvalidName (), 0);
+  }
+
+  ::Components::EventConsumerBase_ptr
+  Env_Detector_Servant::unsubscribe (
+    const char *publisher_name,
+    ::Components::Cookie *ck
+    ACE_ENV_ARG_DECL)
+  ACE_THROW_SPEC (( ::CORBA::SystemException,
+                   ::Components::InvalidName,
+                   ::Components::InvalidConnection))
+  {
+    // Just in case there are no if blocks
+    ACE_UNUSED_ARG (ck);
+
+    if (publisher_name == 0)
+    {
+      ACE_THROW_RETURN ( ::Components::InvalidName (),
+                        ::Components::EventConsumerBase::_nil ());
+    }
+
+    if (ACE_OS::strcmp (publisher_name, "track") == 0)
+    {
+      return this->unsubscribe_track (
+        ck
+        ACE_ENV_ARG_PARAMETER);
+    }
+
+    ACE_THROW_RETURN ( ::Components::InvalidName (),
+                      ::Components::EventConsumerBase::_nil ());
+  }
+
+  ::CORBA::Object_ptr
+  Env_Detector_Servant::get_facet_executor (
+    const char *name
+    ACE_ENV_ARG_DECL)
+  ACE_THROW_SPEC (( ::CORBA::SystemException))
+  {
+    if (name == 0)
+    {
+      ACE_THROW_RETURN ( ::CORBA::BAD_PARAM (),
+                        ::CORBA::Object::_nil ());
+    }
+
+    return ::CORBA::Object::_nil ();
+  }
+
+  // Supported operations.
+
+  // Component attribute operations.
+
+  // Private method to populate the port tables.
+  void
+  Env_Detector_Servant::populate_port_tables (
+    ACE_ENV_SINGLE_ARG_DECL)
+  ACE_THROW_SPEC (( ::CORBA::SystemException))
+  {
+    ACE_ENV_ARG_NOT_USED;
+    ::CORBA::Object_var obj_var;
+    ::Components::EventConsumerBase_var ecb_var;
+
+    ecb_var =
+      this->get_consumer_command_i (
+        ACE_ENV_SINGLE_ARG_PARAMETER);
+    ACE_CHECK;
+  }
+
+  Env_Detector_Factory_Servant::Env_Detector_Factory_Servant (
+    ::TSCE::CCM_Env_Detector_Factory_ptr exe,
+    const char *ins_name,
+    ::CIAO::Session_Container *c,
+    ::CIAO::REC_POL_MAP &rec_pol_map)
+    : ::CIAO::Home_Servant_Impl_Base (c),
+      ::CIAO::Home_Servant_Impl<
+            ::POA_TSCE::Env_Detector_Factory,
+            ::TSCE::CCM_Env_Detector_Factory,
+            Env_Detector_Servant
+          > (exe, c, ins_name, rec_pol_map)
+  {
+  }
+
+  Env_Detector_Factory_Servant::~Env_Detector_Factory_Servant (void)
+  {
+  }
+
+  // Home operations.
+
+  // Home supported interface operations.
+
+  // Home factory and finder operations.
+
+  // Home attribute operations.
+
+  extern "C" ENV_DETECTOR_IMPL_SVNT_Export ::PortableServer::Servant
+  create_TSCE_Env_Detector_Factory_Servant (
+    ::Components::HomeExecutorBase_ptr p,
+    ::CIAO::Session_Container *c,
+    const char *ins_name,
+    ::CIAO::REC_POL_MAP &rec_pol_map
+    ACE_ENV_ARG_DECL)
+  {
+    if (p == 0)
+    {
+      return 0;
+    }
+
+    ::TSCE::CCM_Env_Detector_Factory_var x =
+    ::TSCE::CCM_Env_Detector_Factory::_narrow (
+      p
+      ACE_ENV_ARG_PARAMETER);
+    ACE_CHECK_RETURN (0);
+
+    if (::CORBA::is_nil (x.in ()))
+    {
+      return 0;
+    }
+
+    return new
+    Env_Detector_Factory_Servant (
+      x.in (),
+      ins_name,
+      c, rec_pol_map);
+  }
+}
+
diff --git a/CIAO/examples/RT1H/Env_Detector_Impl_svnt.h b/CIAO/examples/RT1H/Env_Detector_Impl_svnt.h
new file mode 100644
index 00000000000..f185935fe5a
--- /dev/null
+++ b/CIAO/examples/RT1H/Env_Detector_Impl_svnt.h
@@ -0,0 +1,400 @@
+// $Id$
+//
+// ****              Code generated by the                 ****
+// ****  Component Integrated ACE ORB (CIAO) CIDL Compiler ****
+// CIAO has been developed by:
+//       Center for Distributed Object Computing
+//       Washington University
+//       St. Louis, MO
+//       USA
+//       http://www.cs.wustl.edu/~schmidt/doc-center.html
+// CIDL Compiler has been developed by:
+//       Institute for Software Integrated Systems
+//       Vanderbilt University
+//       Nashville, TN
+//       USA
+//       http://www.isis.vanderbilt.edu/
+//
+// Information about CIAO is available at:
+//    http://www.dre.vanderbilt.edu/CIAO
+
+#ifndef CIAO_GLUE_SESSION_ENV_DETECTOR_IMPL_SVNT_H
+#define CIAO_GLUE_SESSION_ENV_DETECTOR_IMPL_SVNT_H
+
+#include /**/ "ace/pre.h"
+
+#include "Env_Detector_ImplEC.h"
+
+#if !defined (ACE_LACKS_PRAGMA_ONCE)
+# pragma once
+#endif /* ACE_LACKS_PRAGMA_ONCE */
+
+#include "ciao/Container_Base.h"
+#include "ciao/Context_Impl_T.h"
+#include "ciao/Servant_Impl_T.h"
+#include "ciao/Home_Servant_Impl_T.h"
+
+#include "Env_DetectorS.h"
+
+namespace CIDL_MonolithicImplementation
+{
+  class Env_Detector_Servant;
+
+  class ENV_DETECTOR_IMPL_SVNT_Export Env_Detector_Context
+    : public virtual CIAO::Context_Impl<
+        ::TSCE::CCM_Env_Detector_Context,
+        Env_Detector_Servant,
+        ::TSCE::Env_Detector,
+        ::TSCE::Env_Detector_var
+      >
+  {
+    public:
+    // We will allow the servant glue code we generate to access our state.
+    friend class Env_Detector_Servant;
+
+    Env_Detector_Context (
+      ::Components::CCMHome_ptr h,
+      ::CIAO::Session_Container *c,
+      Env_Detector_Servant *sv);
+
+    virtual ~Env_Detector_Context (void);
+
+    // Operations for Env_Detector receptacles and event sources,
+    // defined in ::TSCE::CCM_Env_Detector_Context.
+
+    virtual void
+    push_track (
+      ::TSCE::Track_Event *ev
+      ACE_ENV_ARG_DECL_WITH_DEFAULTS)
+    ACE_THROW_SPEC (( ::CORBA::SystemException));
+
+    virtual ::CUTS::Testing_Service_ptr
+    get_connection_cuts_testing_service (
+      ACE_ENV_SINGLE_ARG_DECL_WITH_DEFAULTS)
+    ACE_THROW_SPEC (( ::CORBA::SystemException));
+
+    // CIAO-specific.
+
+    static Env_Detector_Context *
+    _narrow (
+      ::Components::SessionContext_ptr p
+      ACE_ENV_ARG_DECL_WITH_DEFAULTS);
+
+    protected:
+    // Methods that manage this component's connections and consumers.
+
+    virtual ::Components::Cookie *
+    subscribe_track (
+      ::TSCE::Track_EventConsumer_ptr c
+      ACE_ENV_ARG_DECL_WITH_DEFAULTS)
+    ACE_THROW_SPEC (( ::CORBA::SystemException,
+                     ::Components::ExceededConnectionLimit));
+
+    // CIAO-specific.
+    ::Components::Cookie *
+    subscribe_track_generic (
+      ::Components::EventConsumerBase_ptr c
+      ACE_ENV_ARG_DECL_WITH_DEFAULTS)
+    ACE_THROW_SPEC (( ::CORBA::SystemException,
+                     ::Components::ExceededConnectionLimit));
+
+    virtual ::TSCE::Track_EventConsumer_ptr
+    unsubscribe_track (
+      ::Components::Cookie *ck
+      ACE_ENV_ARG_DECL_WITH_DEFAULTS)
+    ACE_THROW_SPEC (( ::CORBA::SystemException,
+                     ::Components::InvalidConnection));
+
+    virtual void
+    connect_cuts_testing_service (
+      ::CUTS::Testing_Service_ptr
+      ACE_ENV_ARG_DECL_WITH_DEFAULTS)
+    ACE_THROW_SPEC (( ::CORBA::SystemException,
+                     ::Components::AlreadyConnected,
+                     ::Components::InvalidConnection));
+
+    virtual ::CUTS::Testing_Service_ptr
+    disconnect_cuts_testing_service (
+      ACE_ENV_SINGLE_ARG_DECL_WITH_DEFAULTS)
+    ACE_THROW_SPEC (( ::CORBA::SystemException,
+                     ::Components::NoConnection));
+
+    protected:
+    ACE_Active_Map_Manager<
+    ::TSCE::Track_EventConsumer_var>
+    ciao_publishes_track_map_;
+
+    ACE_Active_Map_Manager<
+    ::Components::EventConsumerBase_var>
+    ciao_publishes_track_generic_map_;
+
+    // Simplex cuts_testing_service connection.
+    ::CUTS::Testing_Service_var
+    ciao_uses_cuts_testing_service_;
+  };
+
+  class ENV_DETECTOR_IMPL_SVNT_Export Env_Detector_Servant
+    : public virtual CIAO::Servant_Impl<
+        POA_TSCE::Env_Detector,
+        ::TSCE::CCM_Env_Detector,
+        Env_Detector_Context
+      >
+  {
+    public:
+
+    typedef ::TSCE::CCM_Env_Detector _exec_type;
+
+    Env_Detector_Servant (
+      ::TSCE::CCM_Env_Detector_ptr executor,
+      ::Components::CCMHome_ptr h,
+      const char *ins_name,
+      ::CIAO::Home_Servant_Impl_Base *hs,
+      ::CIAO::Session_Container *c,
+      ::CIAO::REC_POL_MAP &rec_pol_map);
+
+    virtual ~Env_Detector_Servant (void);
+
+    virtual void
+    set_attributes (
+      const ::Components::ConfigValues &descr
+      ACE_ENV_ARG_DECL);
+
+    // Supported operations.
+
+    // Public port operations.
+
+    // Servant class for the command consumer.
+    class ENV_DETECTOR_IMPL_SVNT_Export Command_EventConsumer_command_Servant
+    : public virtual POA_TSCE::Command_EventConsumer
+    {
+      public:
+      Command_EventConsumer_command_Servant (
+        ::TSCE::CCM_Env_Detector_ptr executor,
+        ::TSCE::CCM_Env_Detector_Context_ptr c);
+
+      virtual ~Command_EventConsumer_command_Servant (void);
+
+      virtual void
+      push_Command_Event (
+        ::TSCE::Command_Event *evt
+        ACE_ENV_ARG_DECL_WITH_DEFAULTS)
+      ACE_THROW_SPEC (( ::CORBA::SystemException));
+
+      // Inherited from ::Components::EventConsumerBase.
+      virtual void
+      push_event ( ::Components::EventBase *ev
+                  ACE_ENV_ARG_DECL_WITH_DEFAULTS)
+      ACE_THROW_SPEC (( ::CORBA::SystemException,
+                       ::Components::BadEventType));
+
+      // CIAO-specific in ::Components::EventConsumerBase.
+      virtual CORBA::Boolean
+      ciao_is_substitutable (
+        const char *event_repo_id
+        ACE_ENV_ARG_DECL_WITH_DEFAULTS)
+      ACE_THROW_SPEC (( ::CORBA::SystemException));
+
+      // Get component implementation.
+      virtual CORBA::Object_ptr
+      _get_component (
+        ACE_ENV_SINGLE_ARG_DECL_WITH_DEFAULTS)
+      ACE_THROW_SPEC (( ::CORBA::SystemException));
+
+      protected:
+      ::TSCE::CCM_Env_Detector_var
+      executor_;
+
+      ::TSCE::CCM_Env_Detector_Context_var
+      ctx_;
+    };
+
+    virtual ::TSCE::Command_EventConsumer_ptr
+    get_consumer_command (
+      ACE_ENV_SINGLE_ARG_DECL_WITH_DEFAULTS)
+    ACE_THROW_SPEC (( ::CORBA::SystemException));
+
+    virtual ::Components::Cookie *
+    subscribe_track (
+      ::TSCE::Track_EventConsumer_ptr c
+      ACE_ENV_ARG_DECL_WITH_DEFAULTS)
+    ACE_THROW_SPEC (( ::CORBA::SystemException,
+                     ::Components::ExceededConnectionLimit));
+
+    // CIAO-specific.
+    ::Components::Cookie *
+    subscribe_track_generic (
+      ::Components::EventConsumerBase_ptr c
+      ACE_ENV_ARG_DECL_WITH_DEFAULTS)
+    ACE_THROW_SPEC (( ::CORBA::SystemException,
+                     ::Components::ExceededConnectionLimit));
+
+    virtual ::TSCE::Track_EventConsumer_ptr
+    unsubscribe_track (
+      ::Components::Cookie *ck
+      ACE_ENV_ARG_DECL_WITH_DEFAULTS)
+    ACE_THROW_SPEC (( ::CORBA::SystemException,
+                     ::Components::InvalidConnection));
+
+    virtual void
+    connect_cuts_testing_service (
+      ::CUTS::Testing_Service_ptr c
+      ACE_ENV_ARG_DECL_WITH_DEFAULTS)
+    ACE_THROW_SPEC (( ::CORBA::SystemException,
+                     ::Components::AlreadyConnected,
+                     ::Components::InvalidConnection));
+
+    virtual ::CUTS::Testing_Service_ptr
+    disconnect_cuts_testing_service (
+      ACE_ENV_SINGLE_ARG_DECL_WITH_DEFAULTS)
+    ACE_THROW_SPEC (( ::CORBA::SystemException,
+                     ::Components::NoConnection));
+
+    virtual ::CUTS::Testing_Service_ptr
+    get_connection_cuts_testing_service (
+      ACE_ENV_SINGLE_ARG_DECL_WITH_DEFAULTS)
+    ACE_THROW_SPEC (( ::CORBA::SystemException));
+
+    // Component attribute operations.
+
+    // Operations for Receptacles interface.
+
+    virtual ::Components::Cookie *
+    connect (
+      const char *name,
+      CORBA::Object_ptr connection
+      ACE_ENV_ARG_DECL_WITH_DEFAULTS)
+    ACE_THROW_SPEC (( ::CORBA::SystemException,
+                     ::Components::InvalidName,
+                     ::Components::InvalidConnection,
+                     ::Components::AlreadyConnected,
+                     ::Components::ExceededConnectionLimit));
+
+    virtual CORBA::Object_ptr
+    disconnect (
+      const char *name,
+      ::Components::Cookie *ck
+      ACE_ENV_ARG_DECL_WITH_DEFAULTS)
+    ACE_THROW_SPEC (( ::CORBA::SystemException,
+                     ::Components::InvalidName,
+                     ::Components::InvalidConnection,
+                     ::Components::CookieRequired,
+                     ::Components::NoConnection));
+
+    virtual ::Components::ReceptacleDescriptions *
+    get_all_receptacles (
+      ACE_ENV_SINGLE_ARG_DECL_WITH_DEFAULTS)
+    ACE_THROW_SPEC (( ::CORBA::SystemException));
+
+    // Operations for Events interface.
+
+    virtual ::Components::Cookie *
+    subscribe (
+      const char *publisher_name,
+      ::Components::EventConsumerBase_ptr subscriber
+      ACE_ENV_ARG_DECL_WITH_DEFAULTS)
+    ACE_THROW_SPEC (( ::CORBA::SystemException,
+                     ::Components::InvalidName,
+                     ::Components::InvalidConnection,
+                     ::Components::ExceededConnectionLimit));
+
+    virtual ::Components::EventConsumerBase_ptr
+    unsubscribe (
+      const char *publisher_name,
+      ::Components::Cookie *ck
+      ACE_ENV_ARG_DECL_WITH_DEFAULTS)
+    ACE_THROW_SPEC (( ::CORBA::SystemException,
+                     ::Components::InvalidName,
+                     ::Components::InvalidConnection));
+
+    virtual void
+    connect_consumer (
+      const char *emitter_name,
+      ::Components::EventConsumerBase_ptr consumer
+      ACE_ENV_ARG_DECL_WITH_DEFAULTS)
+    ACE_THROW_SPEC (( ::CORBA::SystemException,
+                     ::Components::InvalidName,
+                     ::Components::AlreadyConnected,
+                     ::Components::InvalidConnection));
+
+    virtual ::Components::EventConsumerBase_ptr
+    disconnect_consumer (
+      const char *source_name
+      ACE_ENV_ARG_DECL_WITH_DEFAULTS)
+    ACE_THROW_SPEC (( ::CORBA::SystemException,
+                     ::Components::InvalidName,
+                     ::Components::NoConnection));
+
+    virtual ::Components::PublisherDescriptions *
+    get_all_publishers (
+      ACE_ENV_SINGLE_ARG_DECL_WITH_DEFAULTS)
+    ACE_THROW_SPEC (( ::CORBA::SystemException));
+
+    virtual ::Components::EmitterDescriptions *
+    get_all_emitters (
+      ACE_ENV_SINGLE_ARG_DECL_WITH_DEFAULTS)
+    ACE_THROW_SPEC (( ::CORBA::SystemException));
+
+    // CIAO specific operations on the servant. 
+    CORBA::Object_ptr
+    get_facet_executor (
+      const char *name
+      ACE_ENV_ARG_DECL_WITH_DEFAULTS)
+    ACE_THROW_SPEC (( ::CORBA::SystemException));
+
+    private:
+
+    ::TSCE::Command_EventConsumer_var
+    consumes_command_;
+
+    const char *ins_name_;
+
+    private:
+
+    void
+    populate_port_tables (
+      ACE_ENV_SINGLE_ARG_DECL_WITH_DEFAULTS)
+    ACE_THROW_SPEC (( ::CORBA::SystemException));
+
+    ::Components::EventConsumerBase_ptr
+    get_consumer_command_i (
+      ACE_ENV_SINGLE_ARG_DECL_WITH_DEFAULTS)
+    ACE_THROW_SPEC (( ::CORBA::SystemException));
+  };
+
+  class ENV_DETECTOR_IMPL_SVNT_Export Env_Detector_Factory_Servant
+    : public virtual
+        ::CIAO::Home_Servant_Impl<
+            ::POA_TSCE::Env_Detector_Factory,
+            ::TSCE::CCM_Env_Detector_Factory,
+            Env_Detector_Servant
+          >
+  {
+    public:
+
+    Env_Detector_Factory_Servant (
+      ::TSCE::CCM_Env_Detector_Factory_ptr exe,
+      const char *ins_name,
+      ::CIAO::Session_Container *c,
+      ::CIAO::REC_POL_MAP &rec_pol_map);
+
+    virtual ~Env_Detector_Factory_Servant (void);
+
+    // Home operations.
+    // Home factory and finder operations.
+
+    // Attribute operations.
+  };
+
+  extern "C" ENV_DETECTOR_IMPL_SVNT_Export ::PortableServer::Servant
+  create_TSCE_Env_Detector_Factory_Servant (
+    ::Components::HomeExecutorBase_ptr p,
+    CIAO::Session_Container *c,
+    const char *ins_name,
+    ::CIAO::REC_POL_MAP &rec_pol_map
+    ACE_ENV_ARG_DECL_WITH_DEFAULTS);
+}
+
+#include /**/ "ace/post.h"
+
+#endif /* CIAO_GLUE_SESSION_ENV_DETECTOR_IMPL_SVNT_H */
+