*** empty log message ***

8 files changed, 4415 insertions, 0 deletions

diff --git a/TAO/CIAO/DAnCE/examples/BasicSP/BMClosedED/BMClosedED_svnt.cpp b/TAO/CIAO/DAnCE/examples/BasicSP/BMClosedED/BMClosedED_svnt.cpp
new file mode 100644
index 00000000000..d37f153e129
--- /dev/null
+++ b/TAO/CIAO/DAnCE/examples/BasicSP/BMClosedED/BMClosedED_svnt.cpp
@@ -0,0 +1,903 @@
+// $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 "BMClosedED_svnt.h"
+#include "Cookies.h"
+#include "ciao/Servant_Activator.h"
+#include "ciao/Port_Activator_T.h"
+
+namespace BMClosedED_Impl
+{
+  namespace CIAO_GLUE_BasicSP
+  {
+    template <typename T>
+    ReadData_Servant_T<T>::ReadData_Servant_T (
+    ::BasicSP::CCM_ReadData_ptr executor,
+    ::Components::CCMContext_ptr c)
+    : executor_ (::BasicSP::CCM_ReadData::_duplicate (executor)),
+    ctx_ (::Components::CCMContext::_duplicate (c))
+    {
+    }
+
+    template <typename T>
+    ReadData_Servant_T<T>::~ReadData_Servant_T (void)
+    {
+    }
+
+    template <typename T>
+    char *
+    ReadData_Servant_T<T>::get_data (
+    ACE_ENV_SINGLE_ARG_DECL)
+    ACE_THROW_SPEC ((CORBA::SystemException))
+    {
+      return this->executor_->get_data (
+      ACE_ENV_SINGLE_ARG_PARAMETER);
+    }
+
+    template <typename T>
+    CORBA::Object_ptr
+    ReadData_Servant_T<T>::_get_component (
+    ACE_ENV_SINGLE_ARG_DECL)
+    ACE_THROW_SPEC ((CORBA::SystemException))
+    {
+      ::Components::SessionContext_var sc =
+      ::Components::SessionContext::_narrow (
+      this->ctx_.in ()
+      ACE_ENV_ARG_PARAMETER);
+      ACE_CHECK_RETURN (CORBA::Object::_nil ());
+
+      if (! CORBA::is_nil (sc.in ()))
+      {
+        return sc->get_CCM_object (
+        ACE_ENV_SINGLE_ARG_PARAMETER);
+      }
+
+      ::Components::EntityContext_var ec =
+      ::Components::EntityContext::_narrow (
+      this->ctx_.in ()
+      ACE_ENV_ARG_PARAMETER);
+      ACE_CHECK_RETURN (CORBA::Object::_nil ());
+
+      if (! CORBA::is_nil (ec.in ()))
+      {
+        return ec->get_CCM_object (
+        ACE_ENV_SINGLE_ARG_PARAMETER);
+      }
+
+      ACE_THROW_RETURN (CORBA::INTERNAL (), 0);
+    }
+  }
+
+  namespace CIAO_GLUE_BasicSP
+  {
+    BMClosedED_Context::BMClosedED_Context (
+    ::Components::CCMHome_ptr home,
+    ::CIAO::Session_Container *c,
+    BMClosedED_Servant *sv)
+      : Context_Impl_Base (home, c),
+        ctx_svnt_base (home, c, sv)
+    {
+    }
+
+    BMClosedED_Context::~BMClosedED_Context (void)
+    {
+    }
+
+    // Operations for BMClosedED receptacles and event sources,
+    // defined in ::BasicSP::CCM_BMClosedED_Context.
+
+    ::BasicSP::ReadData_ptr
+    BMClosedED_Context::get_connection_datain (
+    ACE_ENV_SINGLE_ARG_DECL_NOT_USED)
+    ACE_THROW_SPEC ((CORBA::SystemException))
+    {
+      return ::BasicSP::ReadData::_duplicate (
+      this->ciao_uses_datain_.in ());
+    }
+
+    void
+    BMClosedED_Context::connect_datain (
+    ::BasicSP::ReadData_ptr c
+    ACE_ENV_ARG_DECL)
+    ACE_THROW_SPEC ((
+    ::CORBA::SystemException,
+    ::Components::AlreadyConnected,
+    ::Components::InvalidConnection))
+    {
+      if (!CORBA::is_nil (this->ciao_uses_datain_.in ()))
+      {
+        ACE_THROW (::Components::AlreadyConnected ());
+      }
+
+      if (CORBA::is_nil (c))
+      {
+        ACE_THROW (::Components::InvalidConnection ());
+      }
+
+      this->ciao_uses_datain_ =
+      ::BasicSP::ReadData::_duplicate (c);
+    }
+
+    ::BasicSP::ReadData_ptr
+    BMClosedED_Context::disconnect_datain (
+    ACE_ENV_SINGLE_ARG_DECL)
+    ACE_THROW_SPEC ((
+    ::CORBA::SystemException,
+    ::Components::NoConnection))
+    {
+      if (CORBA::is_nil (this->ciao_uses_datain_.in ()))
+      {
+        ACE_THROW_RETURN (
+        ::Components::NoConnection (),
+        ::BasicSP::ReadData::_nil ());
+      }
+
+      return this->ciao_uses_datain_._retn ();
+    }
+
+    void
+    BMClosedED_Context::push_out_avail (
+    ::BasicSP::DataAvailable *ev
+    ACE_ENV_ARG_DECL)
+    ACE_THROW_SPEC ((CORBA::SystemException))
+    {
+
+      ACE_CString my_uuid = this->servant_->component_UUID (ACE_ENV_SINGLE_ARG_PARAMETER);
+      ACE_CHECK;
+      my_uuid += "_prepare_capture_publisher";
+
+      this->container_->push_event (ev,
+                                    my_uuid.c_str ()
+                                    ACE_ENV_ARG_PARAMETER);
+      ACE_CHECK;
+      /*
+      ACE_Active_Map_Manager< 
+      ::BasicSP::DataAvailableConsumer_var>::iterator end =
+      this->ciao_publishes_out_avail_map_.end ();
+
+      for (ACE_Active_Map_Manager< 
+      ::BasicSP::DataAvailableConsumer_var>::iterator iter =
+      this->ciao_publishes_out_avail_map_.begin ();
+      iter != end;
+      ++iter)
+      {
+        ACE_Active_Map_Manager< 
+        ::BasicSP::DataAvailableConsumer_var>::ENTRY &entry = *iter;
+
+        ::BasicSP::DataAvailableConsumer_var c =
+        ::BasicSP::DataAvailableConsumer::_narrow (
+        entry.int_id_.in ()
+        ACE_ENV_ARG_PARAMETER);
+        ACE_CHECK;
+
+        entry.int_id_->push_DataAvailable (
+        ev
+        ACE_ENV_ARG_PARAMETER);
+        ACE_CHECK;
+      }
+      */
+    }
+
+    ::Components::Cookie *
+    BMClosedED_Context::subscribe_out_avail (
+    ::BasicSP::DataAvailableConsumer_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);
+      }
+
+      ::BasicSP::DataAvailableConsumer_var sub =
+      ::BasicSP::DataAvailableConsumer::_duplicate (c);
+
+      ACE_Active_Map_Manager_Key key;
+      this->ciao_publishes_out_avail_map_.bind (sub.in (), key);
+      sub._retn ();
+
+      ::Components::Cookie_var retv = new ::CIAO::Map_Key_Cookie (key);
+      return retv._retn ();
+    }
+
+    ::BasicSP::DataAvailableConsumer_ptr
+    BMClosedED_Context::unsubscribe_out_avail (
+    ::Components::Cookie *ck
+    ACE_ENV_ARG_DECL)
+    ACE_THROW_SPEC ((
+    ::CORBA::SystemException,
+    ::Components::InvalidConnection))
+    {
+      ::BasicSP::DataAvailableConsumer_var retv;
+      ACE_Active_Map_Manager_Key key;
+
+      if (ck == 0 || ::CIAO::Map_Key_Cookie::extract (ck, key) == false)
+      {
+        ACE_THROW_RETURN (
+        ::Components::InvalidConnection (),
+        ::BasicSP::DataAvailableConsumer::_nil ());
+      }
+
+      if (this->ciao_publishes_out_avail_map_.unbind (key, retv) != 0)
+      {
+        ACE_THROW_RETURN (
+        ::Components::InvalidConnection (),
+        ::BasicSP::DataAvailableConsumer::_nil ());
+      }
+
+      return retv._retn ();
+    }
+
+    // CIAO-specific.
+
+    BMClosedED_Context *
+    BMClosedED_Context::_narrow (
+    ::Components::SessionContext_ptr p
+    ACE_ENV_ARG_DECL_NOT_USED)
+    {
+      return dynamic_cast<BMClosedED_Context *> (p);
+    }
+  }
+
+  namespace CIAO_GLUE_BasicSP
+  {
+    void
+    BMClosedED_Servant::component_UUID (
+    const char * new_component_UUID
+    ACE_ENV_ARG_DECL_WITH_DEFAULTS)
+    ACE_THROW_SPEC ((CORBA::SystemException))
+    {
+      this->component_UUID_ = new_component_UUID;
+    }
+
+    CIAO::CONNECTION_ID
+    BMClosedED_Servant::component_UUID (
+    ACE_ENV_SINGLE_ARG_DECL_WITH_DEFAULTS)
+    ACE_THROW_SPEC ((CORBA::SystemException))
+    {
+      return CORBA::string_dup (this->component_UUID_.c_str ());
+    }
+
+ 
+    BMClosedED_Servant::BMClosedED_Servant (
+    ::BasicSP::CCM_BMClosedED_ptr exe,
+    ::Components::CCMHome_ptr h,
+    ::CIAO::Session_Container *c)
+      : Servant_Impl_Base (c),
+        comp_svnt_base (exe, c)
+    {
+      this->context_ = new BMClosedED_Context (h, c, this);
+
+      CIAO_REGISTER_OBV_FACTORY (
+      ::BasicSP::DataAvailable_init,
+      ::BasicSP::DataAvailable);
+
+      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;
+    }
+
+    BMClosedED_Servant::~BMClosedED_Servant (void)
+    {
+    }
+
+    void
+    BMClosedED_Servant::set_attributes (
+    const ::Components::ConfigValues &descr
+    ACE_ENV_ARG_DECL_NOT_USED)
+    {
+      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);
+      }
+    }
+
+    ::BasicSP::ReadData_ptr
+    BMClosedED_Servant::provide_dataout (
+    ACE_ENV_SINGLE_ARG_DECL)
+    ACE_THROW_SPEC ((CORBA::SystemException))
+    {
+      if (! ::CORBA::is_nil (this->provide_dataout_.in ()))
+      {
+        return ::BasicSP::ReadData::_duplicate (this->provide_dataout_.in ());
+      }
+
+      ::CORBA::Object_var obj =
+      this->provide_dataout_i (ACE_ENV_SINGLE_ARG_PARAMETER);
+      ACE_CHECK_RETURN (::BasicSP::ReadData::_nil ());
+
+      ::BasicSP::ReadData_var fo =
+      ::BasicSP::ReadData::_narrow (
+      obj.in ()
+      ACE_ENV_ARG_PARAMETER);
+      ACE_CHECK_RETURN (::BasicSP::ReadData::_nil ());
+
+      this->provide_dataout_ = fo;
+      return ::BasicSP::ReadData::_duplicate (this->provide_dataout_.in ());
+    }
+
+    ::CORBA::Object_ptr
+    BMClosedED_Servant::provide_dataout_i (
+    ACE_ENV_SINGLE_ARG_DECL)
+    ACE_THROW_SPEC ((CORBA::SystemException))
+    {
+      ::CORBA::Object_ptr ret =
+      this->lookup_facet ("dataout");
+
+      if (! ::CORBA::is_nil (ret))
+      {
+        return ret;
+      }
+
+      CIAO::Port_Activator_T<
+          CIAO_GLUE_BasicSP::ReadData_Servant,
+          ::BasicSP::CCM_ReadData,
+          ::Components::CCMContext,
+          BMClosedED_Servant
+        > *tmp = 0;
+
+      typedef CIAO::Port_Activator_T<
+          CIAO_GLUE_BasicSP::ReadData_Servant,
+          ::BasicSP::CCM_ReadData,
+          ::Components::CCMContext,
+          BMClosedED_Servant
+        >
+      MACRO_MADNESS_TYPEDEF;
+
+      ACE_NEW_THROW_EX ( 
+      tmp,
+      MACRO_MADNESS_TYPEDEF (
+      "BasicSP_BMClosedED_dataout",
+      "dataout",
+      CIAO::Port_Activator::Facet,
+      0,
+      this->context_,
+      this),
+      CORBA::NO_MEMORY ());
+
+      CIAO::Servant_Activator *sa = 
+      this->container_->ports_servant_activator ();
+
+      if (!sa->register_port_activator (tmp))
+      {
+        return 0;
+      }
+
+      ::CORBA::Object_var obj =
+      this->container_->generate_reference (
+      "BasicSP_BMClosedED_dataout",
+      "IDL:BasicSP/ReadData:1.0",
+      CIAO::Container::Facet_Consumer
+      ACE_ENV_ARG_PARAMETER);
+      ACE_CHECK_RETURN (::BasicSP::ReadData::_nil ());
+
+      this->add_facet (
+      "dataout",
+      obj.in ());
+
+      return obj._retn ();
+    }
+
+    ::Components::Cookie *
+    BMClosedED_Servant::subscribe_out_avail (
+    ::BasicSP::DataAvailableConsumer_ptr c
+    ACE_ENV_ARG_DECL)
+    ACE_THROW_SPEC ((
+    ::CORBA::SystemException,
+    ::Components::ExceededConnectionLimit))
+    {
+      return this->context_->subscribe_out_avail (
+      c
+      ACE_ENV_ARG_PARAMETER);
+    }
+
+    ::BasicSP::DataAvailableConsumer_ptr
+    BMClosedED_Servant::unsubscribe_out_avail (
+    ::Components::Cookie *ck
+    ACE_ENV_ARG_DECL)
+    ACE_THROW_SPEC ((
+    ::CORBA::SystemException,
+    ::Components::InvalidConnection))
+    {
+      return this->context_->unsubscribe_out_avail (
+      ck
+      ACE_ENV_ARG_PARAMETER);
+    }
+
+    BMClosedED_Servant::DataAvailableConsumer_in_avail_Servant::DataAvailableConsumer_in_avail_Servant (
+    ::BasicSP::CCM_BMClosedED_ptr executor,
+    ::BasicSP::CCM_BMClosedED_Context_ptr c)
+    : executor_ (::BasicSP::CCM_BMClosedED::_duplicate (executor)),
+    ctx_ (::BasicSP::CCM_BMClosedED_Context::_duplicate (c))
+    {
+    }
+
+    BMClosedED_Servant::DataAvailableConsumer_in_avail_Servant::~DataAvailableConsumer_in_avail_Servant (void)
+    {
+    }
+
+    CORBA::Object_ptr
+    BMClosedED_Servant::DataAvailableConsumer_in_avail_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
+    BMClosedED_Servant::DataAvailableConsumer_in_avail_Servant::push_DataAvailable (
+    ::BasicSP::DataAvailable *evt
+    ACE_ENV_ARG_DECL)
+    ACE_THROW_SPEC ((CORBA::SystemException))
+    {
+      this->executor_->push_in_avail (
+      evt
+      ACE_ENV_ARG_PARAMETER);
+    }
+
+    // Inherited from ::Components::EventConsumerBase.
+    void
+    BMClosedED_Servant::DataAvailableConsumer_in_avail_Servant::push_event (
+    ::Components::EventBase *ev
+    ACE_ENV_ARG_DECL)
+    ACE_THROW_SPEC ((
+    ::CORBA::SystemException,
+    ::Components::BadEventType))
+    {
+      ::BasicSP::DataAvailable_var ev_type =
+      ::BasicSP::DataAvailable::_downcast (ev);
+
+      if (ev_type != 0)
+      {
+        this->push_DataAvailable (
+        ev_type.in ()
+        ACE_ENV_ARG_PARAMETER);
+
+        return;
+      }
+
+      ACE_THROW (::Components::BadEventType ());
+    }
+
+    ::BasicSP::DataAvailableConsumer_ptr
+    BMClosedED_Servant::get_consumer_in_avail (
+    ACE_ENV_SINGLE_ARG_DECL)
+    ACE_THROW_SPEC ((CORBA::SystemException))
+    {
+      if (! ::CORBA::is_nil (this->consumes_in_avail_.in ()))
+      {
+        return ::BasicSP::DataAvailableConsumer::_duplicate (this->consumes_in_avail_.in ());
+      }
+
+      ::Components::EventConsumerBase_var obj =
+      this->get_consumer_in_avail_i (
+      ACE_ENV_SINGLE_ARG_PARAMETER);
+      ACE_CHECK_RETURN (::BasicSP::DataAvailableConsumer::_nil ());
+
+      ::BasicSP::DataAvailableConsumer_var eco =
+      ::BasicSP::DataAvailableConsumer::_narrow (
+      obj.in ()
+      ACE_ENV_ARG_PARAMETER);
+      ACE_CHECK_RETURN (::BasicSP::DataAvailableConsumer::_nil ());
+
+      this->consumes_in_avail_ = eco;
+      return ::BasicSP::DataAvailableConsumer::_duplicate (this->consumes_in_avail_.in ());
+    }
+
+    ::Components::EventConsumerBase_ptr
+    BMClosedED_Servant::get_consumer_in_avail_i (
+    ACE_ENV_SINGLE_ARG_DECL)
+    ACE_THROW_SPEC ((CORBA::SystemException))
+    {
+      ::Components::EventConsumerBase_ptr ret =
+      this->lookup_consumer ("in_avail");
+
+      if (! ::CORBA::is_nil (ret))
+      {
+        return ret;
+      }
+
+      CIAO::Port_Activator_T<
+      BMClosedED_Servant::DataAvailableConsumer_in_avail_Servant,
+      ::BasicSP::CCM_BMClosedED,
+      ::BasicSP::CCM_BMClosedED_Context,
+      BMClosedED_Servant > *tmp = 0;
+
+      typedef  CIAO::Port_Activator_T<
+      BMClosedED_Servant::DataAvailableConsumer_in_avail_Servant,
+      ::BasicSP::CCM_BMClosedED,
+      ::BasicSP::CCM_BMClosedED_Context, 
+      BMClosedED_Servant > 
+       MACRO_MADNESS_TYPEDEF;
+
+
+      ACE_NEW_THROW_EX ( 
+        tmp,
+        MACRO_MADNESS_TYPEDEF (
+      "BasicSP_BMClosedED_in_avail",
+      "in_avail",
+      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 0;
+      }
+
+      ::CORBA::Object_var obj =
+      this->container_->generate_reference (
+      "BasicSP_BMClosedED_in_avail",
+      "IDL:BasicSP/DataAvailableConsumer:1.0",
+      CIAO::Container::Facet_Consumer
+      ACE_ENV_ARG_PARAMETER);
+      ACE_CHECK_RETURN (::BasicSP::DataAvailableConsumer::_nil ());
+
+      ::Components::EventConsumerBase_var ecb =
+      ::Components::EventConsumerBase::_narrow (
+      obj.in ()
+      ACE_ENV_ARG_PARAMETER);
+      ACE_CHECK_RETURN (::BasicSP::DataAvailableConsumer::_nil ());
+
+      this->add_consumer (
+      "in_avail",
+      ecb.in ());
+
+      return ecb._retn ();
+    }
+
+    ::Components::Cookie *
+    BMClosedED_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, "datain") == 0)
+      {
+        ::BasicSP::ReadData_var _ciao_conn =
+        ::BasicSP::ReadData::_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_datain (
+        _ciao_conn.in ()
+        ACE_ENV_ARG_PARAMETER);
+        ACE_CHECK_RETURN (0);
+
+        return 0;
+      }
+
+      ACE_THROW_RETURN (::Components::InvalidName (), 0);
+    }
+
+    CORBA::Object_ptr
+    BMClosedED_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))
+    {
+      if (name == 0)
+      {
+        ACE_THROW_RETURN (
+        ::Components::InvalidName (),
+        ::CORBA::Object::_nil ());
+      }
+
+      if (ACE_OS::strcmp (name, "datain") == 0)
+      {
+        // Simplex disconnect.
+        return this->disconnect_datain (ACE_ENV_SINGLE_ARG_PARAMETER);
+      }
+
+      ACE_THROW_RETURN (
+      ::Components::InvalidName (),
+      ::CORBA::Object::_nil ());
+
+      ACE_UNUSED_ARG (ck);
+    }
+
+    void
+    BMClosedED_Servant::connect_datain (
+    ::BasicSP::ReadData_ptr c
+    ACE_ENV_ARG_DECL)
+    ACE_THROW_SPEC ((
+    ::CORBA::SystemException,
+    ::Components::AlreadyConnected,
+    ::Components::InvalidConnection))
+    {
+      this->context_->connect_datain (
+      c
+      ACE_ENV_ARG_PARAMETER);
+    }
+
+    ::BasicSP::ReadData_ptr
+    BMClosedED_Servant::disconnect_datain (
+    ACE_ENV_SINGLE_ARG_DECL)
+    ACE_THROW_SPEC ((
+    ::CORBA::SystemException,
+    ::Components::NoConnection))
+    {
+      return this->context_->disconnect_datain (
+      ACE_ENV_SINGLE_ARG_PARAMETER);
+    }
+
+    ::BasicSP::ReadData_ptr
+    BMClosedED_Servant::get_connection_datain (
+    ACE_ENV_SINGLE_ARG_DECL)
+    ACE_THROW_SPEC ((CORBA::SystemException))
+    {
+      return this->context_->get_connection_datain (
+      ACE_ENV_SINGLE_ARG_PARAMETER);
+    }
+
+    void
+    BMClosedED_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::Cookie *
+    BMClosedED_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, "out_avail") == 0)
+      {
+        ::BasicSP::DataAvailableConsumer_var _ciao_consumer =
+        ::BasicSP::DataAvailableConsumer::_narrow (
+        subscribe
+        ACE_ENV_ARG_PARAMETER);
+        ACE_CHECK_RETURN (0);
+
+        if (::CORBA::is_nil (_ciao_consumer.in ()))
+        {
+          ACE_THROW_RETURN (::Components::InvalidConnection (), 0);
+        }
+
+        return this->subscribe_out_avail (
+        _ciao_consumer.in ()
+        ACE_ENV_ARG_PARAMETER);
+      }
+
+      ACE_THROW_RETURN (::Components::InvalidName (), 0);
+    }
+
+    ::Components::EventConsumerBase_ptr
+    BMClosedED_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, "out_avail") == 0)
+      {
+        return this->unsubscribe_out_avail (
+        ck
+        ACE_ENV_ARG_PARAMETER);
+      }
+
+      ACE_THROW_RETURN (
+      ::Components::InvalidName (),
+      ::Components::EventConsumerBase::_nil ());
+    }
+
+    CORBA::Object_ptr
+    BMClosedED_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 ());
+      }
+
+      if (ACE_OS::strcmp (name, "dataout") == 0)
+      {
+        return this->executor_->get_dataout (ACE_ENV_SINGLE_ARG_PARAMETER);
+      }
+
+       return CORBA::Object::_nil ();
+    }
+
+    // Supported operations.
+
+    // Component attribute operations.
+
+    // Private method to populate the port tables.
+    void
+    BMClosedED_Servant::populate_port_tables (
+    ACE_ENV_SINGLE_ARG_DECL)
+    ACE_THROW_SPEC ((CORBA::SystemException))
+    {
+      ::CORBA::Object_var obj_var;
+      ::Components::EventConsumerBase_var ecb_var;
+
+      obj_var =
+      this->provide_dataout_i (
+      ACE_ENV_SINGLE_ARG_PARAMETER);
+      ACE_CHECK;
+
+      ecb_var =
+      this->get_consumer_in_avail_i (
+      ACE_ENV_SINGLE_ARG_PARAMETER);
+      ACE_CHECK;
+    }
+  }
+
+  namespace CIAO_GLUE_BasicSP
+  {
+    BMClosedEDHome_Servant::BMClosedEDHome_Servant (
+    ::BasicSP::CCM_BMClosedEDHome_ptr exe,
+    ::CIAO::Session_Container *c)
+      : CIAO::Home_Servant_Impl_Base (c),
+        home_svnt_base (exe, c)
+    {
+    }
+
+    BMClosedEDHome_Servant::~BMClosedEDHome_Servant (void)
+    {
+    }
+
+    // Home operations.
+
+    // Home supported interface operations.
+
+    // Home factory and finder operations.
+
+    // Home attribute operations.
+  }
+
+  extern "C" BMCLOSEDED_SVNT_Export ::PortableServer::Servant
+  createBMClosedEDHome_Servant (
+  ::Components::HomeExecutorBase_ptr p,
+  CIAO::Session_Container *c
+  ACE_ENV_ARG_DECL)
+  {
+    if (p == 0)
+    {
+      return 0;
+    }
+
+    ::BasicSP::CCM_BMClosedEDHome_var x =
+    ::BasicSP::CCM_BMClosedEDHome::_narrow (
+    p
+    ACE_ENV_ARG_PARAMETER);
+    ACE_CHECK_RETURN (0);
+
+    if (::CORBA::is_nil (x.in ()))
+    {
+      return 0;
+    }
+
+    return new
+    CIAO_GLUE_BasicSP::BMClosedEDHome_Servant (
+    x.in (),
+    c);
+  }
+}
+
diff --git a/TAO/CIAO/DAnCE/examples/BasicSP/BMClosedED/BMClosedED_svnt.h b/TAO/CIAO/DAnCE/examples/BasicSP/BMClosedED/BMClosedED_svnt.h
new file mode 100644
index 00000000000..335a8e51632
--- /dev/null
+++ b/TAO/CIAO/DAnCE/examples/BasicSP/BMClosedED/BMClosedED_svnt.h
@@ -0,0 +1,459 @@
+// $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_BMCLOSEDED_SVNT_H
+#define CIAO_GLUE_SESSION_BMCLOSEDED_SVNT_H
+
+#include /**/ "ace/pre.h"
+
+#include "BMClosedEDEC.h"
+
+#if !defined (ACE_LACKS_PRAGMA_ONCE)
+# pragma once
+#endif /* ACE_LACKS_PRAGMA_ONCE */
+
+#include "ciao/Container_Base.h"
+#include "ciao/Servant_Impl_T.h"
+#include "ciao/Context_Impl_T.h"
+#include "ciao/Home_Servant_Impl_T.h"
+#include "ace/Active_Map_Manager_T.h"
+
+#include "../BasicSPS.h"
+#include "BMClosedEDS.h"
+
+namespace BMClosedED_Impl
+{
+  namespace CIAO_GLUE_BasicSP
+  {
+    template <typename T>
+    class ReadData_Servant_T
+    : public virtual POA_BasicSP::ReadData,
+    public virtual PortableServer::RefCountServantBase
+    {
+      public:
+      ReadData_Servant_T (
+      ::BasicSP::CCM_ReadData_ptr executor,
+      ::Components::CCMContext_ptr ctx);
+
+      virtual ~ReadData_Servant_T (void);
+
+      virtual char *
+      get_data (
+      ACE_ENV_SINGLE_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:
+      // Facet executor.
+      ::BasicSP::CCM_ReadData_var executor_;
+
+      // Context object.
+      ::Components::CCMContext_var ctx_;
+    };
+
+    typedef BMCLOSEDED_SVNT_Export ReadData_Servant_T<int> ReadData_Servant;
+  }
+
+  namespace CIAO_GLUE_BasicSP
+  {
+    class BMClosedED_Servant;
+
+    class BMCLOSEDED_SVNT_Export BMClosedED_Context
+      : public virtual CIAO::Context_Impl<
+          ::BasicSP::CCM_BMClosedED_Context,
+          BMClosedED_Servant,
+          ::BasicSP::BMClosedED,
+          ::BasicSP::BMClosedED_var
+        >
+    {
+      public:
+      // We will allow the servant glue code we generate to access our state.
+      friend class BMClosedED_Servant;
+
+      /// Hack for VC6.
+      typedef CIAO::Context_Impl<
+          ::BasicSP::CCM_BMClosedED_Context,
+          BMClosedED_Servant,
+          ::BasicSP::BMClosedED,
+          ::BasicSP::BMClosedED_var
+        > ctx_svnt_base;
+
+      BMClosedED_Context (
+      ::Components::CCMHome_ptr home,
+      ::CIAO::Session_Container *c,
+      BMClosedED_Servant *sv);
+
+      virtual ~BMClosedED_Context (void);
+
+      // Operations for BMClosedED receptacles and event sources,
+      // defined in ::BasicSP::CCM_BMClosedED_Context.
+
+      virtual ::BasicSP::ReadData_ptr
+      get_connection_datain (
+      ACE_ENV_SINGLE_ARG_DECL_WITH_DEFAULTS)
+      ACE_THROW_SPEC ((CORBA::SystemException));
+
+      virtual void
+      push_out_avail (
+      ::BasicSP::DataAvailable *ev
+      ACE_ENV_ARG_DECL_WITH_DEFAULTS)
+      ACE_THROW_SPEC ((CORBA::SystemException));
+
+      // CIAO-specific.
+
+      static BMClosedED_Context *
+      _narrow (
+      ::Components::SessionContext_ptr p
+      ACE_ENV_ARG_DECL_WITH_DEFAULTS);
+
+      protected:
+      // Methods that manage this component's connections and consumers.
+
+      virtual void
+      connect_datain (
+      ::BasicSP::ReadData_ptr
+      ACE_ENV_ARG_DECL_WITH_DEFAULTS)
+      ACE_THROW_SPEC ((
+      ::CORBA::SystemException,
+      ::Components::AlreadyConnected,
+      ::Components::InvalidConnection));
+
+      virtual ::BasicSP::ReadData_ptr
+      disconnect_datain (
+      ACE_ENV_SINGLE_ARG_DECL_WITH_DEFAULTS)
+      ACE_THROW_SPEC ((
+      ::CORBA::SystemException,
+      ::Components::NoConnection));
+
+      virtual ::Components::Cookie *
+      subscribe_out_avail (
+      ::BasicSP::DataAvailableConsumer_ptr c
+      ACE_ENV_ARG_DECL_WITH_DEFAULTS)
+      ACE_THROW_SPEC ((
+      ::CORBA::SystemException,
+      ::Components::ExceededConnectionLimit));
+
+      virtual ::BasicSP::DataAvailableConsumer_ptr
+      unsubscribe_out_avail (
+      ::Components::Cookie *ck
+      ACE_ENV_ARG_DECL_WITH_DEFAULTS)
+      ACE_THROW_SPEC ((
+      ::CORBA::SystemException,
+      ::Components::InvalidConnection));
+
+      protected:
+      // Simplex datain connection.
+      ::BasicSP::ReadData_var
+      ciao_uses_datain_;
+
+      ACE_Active_Map_Manager<
+      ::BasicSP::DataAvailableConsumer_var>
+      ciao_publishes_out_avail_map_;
+    };
+  }
+
+  namespace CIAO_GLUE_BasicSP
+  {
+    class BMCLOSEDED_SVNT_Export BMClosedED_Servant
+      : public virtual CIAO::Servant_Impl<
+          POA_BasicSP::BMClosedED,
+          ::BasicSP::CCM_BMClosedED,
+          ::BasicSP::CCM_BMClosedED_var,
+          BMClosedED_Context
+        >
+    {
+      public:
+      /// Hack for VC6.
+      typedef CIAO::Servant_Impl<
+          POA_BasicSP::BMClosedED,
+          ::BasicSP::CCM_BMClosedED,
+          ::BasicSP::CCM_BMClosedED_var,
+          BMClosedED_Context
+        > comp_svnt_base;
+
+      BMClosedED_Servant (
+      ::BasicSP::CCM_BMClosedED_ptr executor,
+      ::Components::CCMHome_ptr home,
+      ::CIAO::Session_Container *c);
+
+      virtual ~BMClosedED_Servant (void);
+
+      virtual void
+      set_attributes (
+      const ::Components::ConfigValues &descr
+      ACE_ENV_ARG_DECL);
+
+      // Supported operations.
+      virtual void
+      component_UUID (
+      const char * new_component_UUID
+      ACE_ENV_ARG_DECL_WITH_DEFAULTS)
+      ACE_THROW_SPEC ((CORBA::SystemException));
+
+      virtual CIAO::CONNECTION_ID
+      component_UUID (
+      ACE_ENV_SINGLE_ARG_DECL_WITH_DEFAULTS)
+      ACE_THROW_SPEC ((CORBA::SystemException));
+
+      // Public port operations.
+
+      virtual ::BasicSP::ReadData_ptr
+      provide_dataout (
+      ACE_ENV_SINGLE_ARG_DECL_WITH_DEFAULTS)
+      ACE_THROW_SPEC ((CORBA::SystemException));
+
+      virtual void
+      connect_datain (
+      ::BasicSP::ReadData_ptr c
+      ACE_ENV_ARG_DECL_WITH_DEFAULTS)
+      ACE_THROW_SPEC ((
+      ::CORBA::SystemException,
+      ::Components::AlreadyConnected,
+      ::Components::InvalidConnection));
+
+      virtual ::BasicSP::ReadData_ptr
+      disconnect_datain (
+      ACE_ENV_SINGLE_ARG_DECL_WITH_DEFAULTS)
+      ACE_THROW_SPEC ((
+      ::CORBA::SystemException,
+      ::Components::NoConnection));
+
+      virtual ::BasicSP::ReadData_ptr
+      get_connection_datain (
+      ACE_ENV_SINGLE_ARG_DECL_WITH_DEFAULTS)
+      ACE_THROW_SPEC ((CORBA::SystemException));
+
+      virtual ::Components::Cookie *
+      subscribe_out_avail (
+      ::BasicSP::DataAvailableConsumer_ptr c
+      ACE_ENV_ARG_DECL_WITH_DEFAULTS)
+      ACE_THROW_SPEC ((
+      ::CORBA::SystemException,
+      ::Components::ExceededConnectionLimit));
+
+      virtual ::BasicSP::DataAvailableConsumer_ptr
+      unsubscribe_out_avail (
+      ::Components::Cookie *ck
+      ACE_ENV_ARG_DECL_WITH_DEFAULTS)
+      ACE_THROW_SPEC ((
+      ::CORBA::SystemException,
+      ::Components::InvalidConnection));
+
+      // Servant class for the in_avail consumer.
+      class BMCLOSEDED_SVNT_Export DataAvailableConsumer_in_avail_Servant
+      : public virtual POA_BasicSP::DataAvailableConsumer,
+      public virtual PortableServer::RefCountServantBase
+      {
+        public:
+        DataAvailableConsumer_in_avail_Servant (
+        ::BasicSP::CCM_BMClosedED_ptr executor,
+        ::BasicSP::CCM_BMClosedED_Context_ptr c);
+
+        virtual ~DataAvailableConsumer_in_avail_Servant (void);
+
+        virtual void
+        push_DataAvailable (
+        ::BasicSP::DataAvailable *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));
+
+        // Get component implementation.
+        virtual CORBA::Object_ptr
+        _get_component (
+        ACE_ENV_SINGLE_ARG_DECL_WITH_DEFAULTS)
+        ACE_THROW_SPEC ((CORBA::SystemException));
+
+        protected:
+        ::BasicSP::CCM_BMClosedED_var
+        executor_;
+
+        ::BasicSP::CCM_BMClosedED_Context_var
+        ctx_;
+      };
+
+      virtual ::BasicSP::DataAvailableConsumer_ptr
+      get_consumer_in_avail (
+      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));
+
+      // 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));
+
+      // 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:
+
+      ::BasicSP::ReadData_var
+      provide_dataout_;
+
+      ::BasicSP::DataAvailableConsumer_var
+      consumes_in_avail_;
+
+      ACE_CString component_UUID_;
+
+      private:
+
+      void
+      populate_port_tables (
+      ACE_ENV_SINGLE_ARG_DECL_WITH_DEFAULTS)
+      ACE_THROW_SPEC ((CORBA::SystemException));
+
+      ::CORBA::Object_ptr
+      provide_dataout_i (
+      ACE_ENV_SINGLE_ARG_DECL_WITH_DEFAULTS)
+      ACE_THROW_SPEC ((CORBA::SystemException));
+
+      ::Components::EventConsumerBase_ptr
+      get_consumer_in_avail_i (
+      ACE_ENV_SINGLE_ARG_DECL_WITH_DEFAULTS)
+      ACE_THROW_SPEC ((CORBA::SystemException));
+    };
+  }
+
+  namespace CIAO_GLUE_BasicSP
+  {
+    class BMCLOSEDED_SVNT_Export BMClosedEDHome_Servant
+      : public virtual CIAO::Home_Servant_Impl<
+          POA_BasicSP::BMClosedEDHome,
+          ::BasicSP::CCM_BMClosedEDHome,
+          ::BasicSP::CCM_BMClosedEDHome_var,
+          ::BasicSP::BMClosedED,
+          ::BasicSP::BMClosedED_var,
+          ::BasicSP::CCM_BMClosedED,
+          ::BasicSP::CCM_BMClosedED_var,
+          BMClosedED_Servant
+        >
+    {
+      public:
+      /// Hack for VC6.
+      typedef CIAO::Home_Servant_Impl<
+          POA_BasicSP::BMClosedEDHome,
+          ::BasicSP::CCM_BMClosedEDHome,
+          ::BasicSP::CCM_BMClosedEDHome_var,
+          ::BasicSP::BMClosedED,
+          ::BasicSP::BMClosedED_var,
+          ::BasicSP::CCM_BMClosedED,
+          ::BasicSP::CCM_BMClosedED_var,
+          BMClosedED_Servant
+        > home_svnt_base;
+
+      BMClosedEDHome_Servant (
+      ::BasicSP::CCM_BMClosedEDHome_ptr exe,
+      ::CIAO::Session_Container *c);
+
+      virtual ~BMClosedEDHome_Servant (void);
+
+      // Home operations.
+
+      // Home factory and finder operations.
+
+      // Attribute operations.
+    };
+
+    extern "C" BMCLOSEDED_SVNT_Export ::PortableServer::Servant
+    createBMClosedEDHome_Servant (
+    ::Components::HomeExecutorBase_ptr p,
+    CIAO::Session_Container *c
+    ACE_ENV_ARG_DECL_WITH_DEFAULTS);
+  }
+}
+
+#include /**/ "ace/post.h"
+
+#endif /* CIAO_GLUE_SESSION_BMCLOSEDED_SVNT_H */
+
diff --git a/TAO/CIAO/DAnCE/examples/BasicSP/BMDevice/BMDevice_svnt.cpp b/TAO/CIAO/DAnCE/examples/BasicSP/BMDevice/BMDevice_svnt.cpp
new file mode 100644
index 00000000000..5392a96a84b
--- /dev/null
+++ b/TAO/CIAO/DAnCE/examples/BasicSP/BMDevice/BMDevice_svnt.cpp
@@ -0,0 +1,791 @@
+// $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 "BMDevice_svnt.h"
+#include "Cookies.h"
+#include "ciao/Servant_Activator.h"
+#include "ciao/Port_Activator_T.h"
+
+namespace BMDevice_Impl
+{
+  namespace CIAO_GLUE_BasicSP
+  {
+    template <typename T>
+    ReadData_Servant_T<T>::ReadData_Servant_T (
+    ::BasicSP::CCM_ReadData_ptr executor,
+    ::Components::CCMContext_ptr c)
+    : executor_ (::BasicSP::CCM_ReadData::_duplicate (executor)),
+    ctx_ (::Components::CCMContext::_duplicate (c))
+    {
+    }
+
+    template <typename T>
+    ReadData_Servant_T<T>::~ReadData_Servant_T (void)
+    {
+    }
+
+    template <typename T>
+    char *
+    ReadData_Servant_T<T>::get_data (
+    ACE_ENV_SINGLE_ARG_DECL)
+    ACE_THROW_SPEC ((CORBA::SystemException))
+    {
+      return this->executor_->get_data (
+      ACE_ENV_SINGLE_ARG_PARAMETER);
+    }
+
+    template <typename T>
+    CORBA::Object_ptr
+    ReadData_Servant_T<T>::_get_component (
+    ACE_ENV_SINGLE_ARG_DECL)
+    ACE_THROW_SPEC ((CORBA::SystemException))
+    {
+      ::Components::SessionContext_var sc =
+      ::Components::SessionContext::_narrow (
+      this->ctx_.in ()
+      ACE_ENV_ARG_PARAMETER);
+      ACE_CHECK_RETURN (CORBA::Object::_nil ());
+
+      if (! CORBA::is_nil (sc.in ()))
+      {
+        return sc->get_CCM_object (
+        ACE_ENV_SINGLE_ARG_PARAMETER);
+      }
+
+      ::Components::EntityContext_var ec =
+      ::Components::EntityContext::_narrow (
+      this->ctx_.in ()
+      ACE_ENV_ARG_PARAMETER);
+      ACE_CHECK_RETURN (CORBA::Object::_nil ());
+
+      if (! CORBA::is_nil (ec.in ()))
+      {
+        return ec->get_CCM_object (
+        ACE_ENV_SINGLE_ARG_PARAMETER);
+      }
+
+      ACE_THROW_RETURN (CORBA::INTERNAL (), 0);
+    }
+  }
+
+  namespace CIAO_GLUE_BasicSP
+  {
+    BMDevice_Context::BMDevice_Context (
+    ::Components::CCMHome_ptr home,
+    ::CIAO::Session_Container *c,
+    BMDevice_Servant *sv)
+      : Context_Impl_Base (home, c),
+        ctx_svnt_base (home, c, sv)
+    {
+    }
+
+    BMDevice_Context::~BMDevice_Context (void)
+    {
+    }
+
+    // Operations for BMDevice receptacles and event sources,
+    // defined in ::BasicSP::CCM_BMDevice_Context.
+
+    void
+    BMDevice_Context::push_data_available (
+    ::BasicSP::DataAvailable *ev
+    ACE_ENV_ARG_DECL)
+    ACE_THROW_SPEC ((CORBA::SystemException))
+    {
+
+      ACE_CString my_uuid = this->servant_->component_UUID (ACE_ENV_SINGLE_ARG_PARAMETER);
+      ACE_CHECK;
+      my_uuid += "_prepare_capture_publisher";
+
+      this->container_->push_event (ev,
+                                    my_uuid.c_str ()
+                                    ACE_ENV_ARG_PARAMETER);
+      ACE_CHECK;
+      /*
+      ACE_Active_Map_Manager< 
+      ::BasicSP::DataAvailableConsumer_var>::iterator end =
+      this->ciao_publishes_data_available_map_.end ();
+
+      for (ACE_Active_Map_Manager< 
+      ::BasicSP::DataAvailableConsumer_var>::iterator iter =
+      this->ciao_publishes_data_available_map_.begin ();
+      iter != end;
+      ++iter)
+      {
+        ACE_Active_Map_Manager< 
+        ::BasicSP::DataAvailableConsumer_var>::ENTRY &entry = *iter;
+
+        ::BasicSP::DataAvailableConsumer_var c =
+        ::BasicSP::DataAvailableConsumer::_narrow (
+        entry.int_id_.in ()
+        ACE_ENV_ARG_PARAMETER);
+        ACE_CHECK;
+
+        entry.int_id_->push_DataAvailable (
+        ev
+        ACE_ENV_ARG_PARAMETER);
+        ACE_CHECK;
+      }
+      */
+    }
+
+    ::Components::Cookie *
+    BMDevice_Context::subscribe_data_available (
+    ::BasicSP::DataAvailableConsumer_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);
+      }
+
+      ::BasicSP::DataAvailableConsumer_var sub =
+      ::BasicSP::DataAvailableConsumer::_duplicate (c);
+
+      ACE_Active_Map_Manager_Key key;
+      this->ciao_publishes_data_available_map_.bind (sub.in (), key);
+      sub._retn ();
+
+      ::Components::Cookie_var retv = new ::CIAO::Map_Key_Cookie (key);
+      return retv._retn ();
+    }
+
+    ::BasicSP::DataAvailableConsumer_ptr
+    BMDevice_Context::unsubscribe_data_available (
+    ::Components::Cookie *ck
+    ACE_ENV_ARG_DECL)
+    ACE_THROW_SPEC ((
+    ::CORBA::SystemException,
+    ::Components::InvalidConnection))
+    {
+      ::BasicSP::DataAvailableConsumer_var retv;
+      ACE_Active_Map_Manager_Key key;
+
+      if (ck == 0 || ::CIAO::Map_Key_Cookie::extract (ck, key) == false)
+      {
+        ACE_THROW_RETURN (
+        ::Components::InvalidConnection (),
+        ::BasicSP::DataAvailableConsumer::_nil ());
+      }
+
+      if (this->ciao_publishes_data_available_map_.unbind (key, retv) != 0)
+      {
+        ACE_THROW_RETURN (
+        ::Components::InvalidConnection (),
+        ::BasicSP::DataAvailableConsumer::_nil ());
+      }
+
+      return retv._retn ();
+    }
+
+    // CIAO-specific.
+
+    BMDevice_Context *
+    BMDevice_Context::_narrow (
+    ::Components::SessionContext_ptr p
+    ACE_ENV_ARG_DECL_NOT_USED)
+    {
+      return dynamic_cast<BMDevice_Context *> (p);
+    }
+  }
+
+  namespace CIAO_GLUE_BasicSP
+  {
+    void
+    BMDevice_Servant::component_UUID (
+    const char * new_component_UUID
+    ACE_ENV_ARG_DECL_WITH_DEFAULTS)
+    ACE_THROW_SPEC ((CORBA::SystemException))
+    {
+      this->component_UUID_ = new_component_UUID;
+    }
+
+    CIAO::CONNECTION_ID
+    BMDevice_Servant::component_UUID (
+    ACE_ENV_SINGLE_ARG_DECL_WITH_DEFAULTS)
+    ACE_THROW_SPEC ((CORBA::SystemException))
+    {
+      return CORBA::string_dup (this->component_UUID_.c_str ());
+    }
+
+    BMDevice_Servant::BMDevice_Servant (
+    ::BasicSP::CCM_BMDevice_ptr exe,
+    ::Components::CCMHome_ptr h,
+    ::CIAO::Session_Container *c)
+      : Servant_Impl_Base (c),
+        comp_svnt_base (exe, c)
+    {
+      this->context_ = new BMDevice_Context (h, c, this);
+
+      CIAO_REGISTER_OBV_FACTORY (
+      ::BasicSP::TimeOut_init,
+      ::BasicSP::TimeOut);
+
+      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;
+    }
+
+    BMDevice_Servant::~BMDevice_Servant (void)
+    {
+    }
+
+    void
+    BMDevice_Servant::set_attributes (
+    const ::Components::ConfigValues &descr
+    ACE_ENV_ARG_DECL_NOT_USED)
+    {
+      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);
+      }
+    }
+
+    ::BasicSP::ReadData_ptr
+    BMDevice_Servant::provide_data_read (
+    ACE_ENV_SINGLE_ARG_DECL)
+    ACE_THROW_SPEC ((CORBA::SystemException))
+    {
+      if (! ::CORBA::is_nil (this->provide_data_read_.in ()))
+      {
+        return ::BasicSP::ReadData::_duplicate (this->provide_data_read_.in ());
+      }
+
+      ::CORBA::Object_var obj =
+      this->provide_data_read_i (ACE_ENV_SINGLE_ARG_PARAMETER);
+      ACE_CHECK_RETURN (::BasicSP::ReadData::_nil ());
+
+      ::BasicSP::ReadData_var fo =
+      ::BasicSP::ReadData::_narrow (
+      obj.in ()
+      ACE_ENV_ARG_PARAMETER);
+      ACE_CHECK_RETURN (::BasicSP::ReadData::_nil ());
+
+      this->provide_data_read_ = fo;
+      return ::BasicSP::ReadData::_duplicate (this->provide_data_read_.in ());
+    }
+
+    ::CORBA::Object_ptr
+    BMDevice_Servant::provide_data_read_i (
+    ACE_ENV_SINGLE_ARG_DECL)
+    ACE_THROW_SPEC ((CORBA::SystemException))
+    {
+      ::CORBA::Object_ptr ret =
+      this->lookup_facet ("data_read");
+
+      if (! ::CORBA::is_nil (ret))
+      {
+        return ret;
+      }
+
+      CIAO::Port_Activator_T<
+          CIAO_GLUE_BasicSP::ReadData_Servant,
+          ::BasicSP::CCM_ReadData,
+          ::Components::CCMContext,
+          BMDevice_Servant
+        > *tmp = 0;
+
+      typedef CIAO::Port_Activator_T<
+          CIAO_GLUE_BasicSP::ReadData_Servant,
+          ::BasicSP::CCM_ReadData,
+          ::Components::CCMContext,
+          BMDevice_Servant
+        >
+      MACRO_MADNESS_TYPEDEF;
+
+      ACE_NEW_THROW_EX ( 
+      tmp,
+      MACRO_MADNESS_TYPEDEF (
+      "BasicSP_BMDevice_data_read",
+      "data_read",
+      CIAO::Port_Activator::Facet,
+      0,
+      this->context_,
+      this),
+      CORBA::NO_MEMORY ());
+
+      CIAO::Servant_Activator *sa = 
+      this->container_->ports_servant_activator ();
+
+      if (!sa->register_port_activator (tmp))
+      {
+        return 0;
+      }
+
+      ::CORBA::Object_var obj =
+      this->container_->generate_reference (
+      "BasicSP_BMDevice_data_read",
+      "IDL:BasicSP/ReadData:1.0",
+      CIAO::Container::Facet_Consumer
+      ACE_ENV_ARG_PARAMETER);
+      ACE_CHECK_RETURN (::BasicSP::ReadData::_nil ());
+
+      this->add_facet (
+      "data_read",
+      obj.in ());
+
+      return obj._retn ();
+    }
+
+    ::Components::Cookie *
+    BMDevice_Servant::subscribe_data_available (
+    ::BasicSP::DataAvailableConsumer_ptr c
+    ACE_ENV_ARG_DECL)
+    ACE_THROW_SPEC ((
+    ::CORBA::SystemException,
+    ::Components::ExceededConnectionLimit))
+    {
+      return this->context_->subscribe_data_available (
+      c
+      ACE_ENV_ARG_PARAMETER);
+    }
+
+    ::BasicSP::DataAvailableConsumer_ptr
+    BMDevice_Servant::unsubscribe_data_available (
+    ::Components::Cookie *ck
+    ACE_ENV_ARG_DECL)
+    ACE_THROW_SPEC ((
+    ::CORBA::SystemException,
+    ::Components::InvalidConnection))
+    {
+      return this->context_->unsubscribe_data_available (
+      ck
+      ACE_ENV_ARG_PARAMETER);
+    }
+
+    BMDevice_Servant::TimeOutConsumer_timeout_Servant::TimeOutConsumer_timeout_Servant (
+    ::BasicSP::CCM_BMDevice_ptr executor,
+    ::BasicSP::CCM_BMDevice_Context_ptr c)
+    : executor_ (::BasicSP::CCM_BMDevice::_duplicate (executor)),
+    ctx_ (::BasicSP::CCM_BMDevice_Context::_duplicate (c))
+    {
+    }
+
+    BMDevice_Servant::TimeOutConsumer_timeout_Servant::~TimeOutConsumer_timeout_Servant (void)
+    {
+    }
+
+    CORBA::Object_ptr
+    BMDevice_Servant::TimeOutConsumer_timeout_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
+    BMDevice_Servant::TimeOutConsumer_timeout_Servant::push_TimeOut (
+    ::BasicSP::TimeOut *evt
+    ACE_ENV_ARG_DECL)
+    ACE_THROW_SPEC ((CORBA::SystemException))
+    {
+      this->executor_->push_timeout (
+      evt
+      ACE_ENV_ARG_PARAMETER);
+    }
+
+    // Inherited from ::Components::EventConsumerBase.
+    void
+    BMDevice_Servant::TimeOutConsumer_timeout_Servant::push_event (
+    ::Components::EventBase *ev
+    ACE_ENV_ARG_DECL)
+    ACE_THROW_SPEC ((
+    ::CORBA::SystemException,
+    ::Components::BadEventType))
+    {
+      ::BasicSP::TimeOut_var ev_type =
+      ::BasicSP::TimeOut::_downcast (ev);
+
+      if (ev_type != 0)
+      {
+        this->push_TimeOut (
+        ev_type.in ()
+        ACE_ENV_ARG_PARAMETER);
+
+        return;
+      }
+
+      ACE_THROW (::Components::BadEventType ());
+    }
+
+    ::BasicSP::TimeOutConsumer_ptr
+    BMDevice_Servant::get_consumer_timeout (
+    ACE_ENV_SINGLE_ARG_DECL)
+    ACE_THROW_SPEC ((CORBA::SystemException))
+    {
+      if (! ::CORBA::is_nil (this->consumes_timeout_.in ()))
+      {
+        return ::BasicSP::TimeOutConsumer::_duplicate (this->consumes_timeout_.in ());
+      }
+
+      ::Components::EventConsumerBase_var obj =
+      this->get_consumer_timeout_i (
+      ACE_ENV_SINGLE_ARG_PARAMETER);
+      ACE_CHECK_RETURN (::BasicSP::TimeOutConsumer::_nil ());
+
+      ::BasicSP::TimeOutConsumer_var eco =
+      ::BasicSP::TimeOutConsumer::_narrow (
+      obj.in ()
+      ACE_ENV_ARG_PARAMETER);
+      ACE_CHECK_RETURN (::BasicSP::TimeOutConsumer::_nil ());
+
+      this->consumes_timeout_ = eco;
+      return ::BasicSP::TimeOutConsumer::_duplicate (this->consumes_timeout_.in ());
+    }
+
+    ::Components::EventConsumerBase_ptr
+    BMDevice_Servant::get_consumer_timeout_i (
+    ACE_ENV_SINGLE_ARG_DECL)
+    ACE_THROW_SPEC ((CORBA::SystemException))
+    {
+      ::Components::EventConsumerBase_ptr ret =
+      this->lookup_consumer ("timeout");
+
+      if (! ::CORBA::is_nil (ret))
+      {
+        return ret;
+      }
+
+      CIAO::Port_Activator_T<
+      BMDevice_Servant::TimeOutConsumer_timeout_Servant,
+      ::BasicSP::CCM_BMDevice,
+      ::BasicSP::CCM_BMDevice_Context,
+      BMDevice_Servant > *tmp = 0;
+
+      typedef  CIAO::Port_Activator_T<
+      BMDevice_Servant::TimeOutConsumer_timeout_Servant,
+      ::BasicSP::CCM_BMDevice,
+      ::BasicSP::CCM_BMDevice_Context, 
+      BMDevice_Servant > 
+       MACRO_MADNESS_TYPEDEF;
+
+
+      ACE_NEW_THROW_EX ( 
+        tmp,
+        MACRO_MADNESS_TYPEDEF (
+      "BasicSP_BMDevice_timeout",
+      "timeout",
+      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 0;
+      }
+
+      ::CORBA::Object_var obj =
+      this->container_->generate_reference (
+      "BasicSP_BMDevice_timeout",
+      "IDL:BasicSP/TimeOutConsumer:1.0",
+      CIAO::Container::Facet_Consumer
+      ACE_ENV_ARG_PARAMETER);
+      ACE_CHECK_RETURN (::BasicSP::TimeOutConsumer::_nil ());
+
+      ::Components::EventConsumerBase_var ecb =
+      ::Components::EventConsumerBase::_narrow (
+      obj.in ()
+      ACE_ENV_ARG_PARAMETER);
+      ACE_CHECK_RETURN (::BasicSP::TimeOutConsumer::_nil ());
+
+      this->add_consumer (
+      "timeout",
+      ecb.in ());
+
+      return ecb._retn ();
+    }
+
+    ::Components::Cookie *
+    BMDevice_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);
+      }
+
+      ACE_THROW_RETURN (::Components::InvalidName (), 0);
+    }
+
+    CORBA::Object_ptr
+    BMDevice_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))
+    {
+      if (name == 0)
+      {
+        ACE_THROW_RETURN (
+        ::Components::InvalidName (),
+        ::CORBA::Object::_nil ());
+      }
+
+      ACE_THROW_RETURN (
+      ::Components::InvalidName (),
+      ::CORBA::Object::_nil ());
+
+      ACE_UNUSED_ARG (ck);
+    }
+
+    void
+    BMDevice_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::Cookie *
+    BMDevice_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, "data_available") == 0)
+      {
+        ::BasicSP::DataAvailableConsumer_var _ciao_consumer =
+        ::BasicSP::DataAvailableConsumer::_narrow (
+        subscribe
+        ACE_ENV_ARG_PARAMETER);
+        ACE_CHECK_RETURN (0);
+
+        if (::CORBA::is_nil (_ciao_consumer.in ()))
+        {
+          ACE_THROW_RETURN (::Components::InvalidConnection (), 0);
+        }
+
+        return this->subscribe_data_available (
+        _ciao_consumer.in ()
+        ACE_ENV_ARG_PARAMETER);
+      }
+
+      ACE_THROW_RETURN (::Components::InvalidName (), 0);
+    }
+
+    ::Components::EventConsumerBase_ptr
+    BMDevice_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, "data_available") == 0)
+      {
+        return this->unsubscribe_data_available (
+        ck
+        ACE_ENV_ARG_PARAMETER);
+      }
+
+      ACE_THROW_RETURN (
+      ::Components::InvalidName (),
+      ::Components::EventConsumerBase::_nil ());
+    }
+
+    CORBA::Object_ptr
+    BMDevice_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 ());
+      }
+
+      if (ACE_OS::strcmp (name, "data_read") == 0)
+      {
+        return this->executor_->get_data_read (ACE_ENV_SINGLE_ARG_PARAMETER);
+      }
+
+       return CORBA::Object::_nil ();
+    }
+
+    // Supported operations.
+
+    // Component attribute operations.
+
+    // Private method to populate the port tables.
+    void
+    BMDevice_Servant::populate_port_tables (
+    ACE_ENV_SINGLE_ARG_DECL)
+    ACE_THROW_SPEC ((CORBA::SystemException))
+    {
+      ::CORBA::Object_var obj_var;
+      ::Components::EventConsumerBase_var ecb_var;
+
+      obj_var =
+      this->provide_data_read_i (
+      ACE_ENV_SINGLE_ARG_PARAMETER);
+      ACE_CHECK;
+
+      ecb_var =
+      this->get_consumer_timeout_i (
+      ACE_ENV_SINGLE_ARG_PARAMETER);
+      ACE_CHECK;
+    }
+  }
+
+  namespace CIAO_GLUE_BasicSP
+  {
+    BMDeviceHome_Servant::BMDeviceHome_Servant (
+    ::BasicSP::CCM_BMDeviceHome_ptr exe,
+    ::CIAO::Session_Container *c)
+      : CIAO::Home_Servant_Impl_Base (c),
+        home_svnt_base (exe, c)
+    {
+    }
+
+    BMDeviceHome_Servant::~BMDeviceHome_Servant (void)
+    {
+    }
+
+    // Home operations.
+
+    // Home supported interface operations.
+
+    // Home factory and finder operations.
+
+    // Home attribute operations.
+  }
+
+  extern "C" BMDEVICE_SVNT_Export ::PortableServer::Servant
+  createBMDeviceHome_Servant (
+  ::Components::HomeExecutorBase_ptr p,
+  CIAO::Session_Container *c
+  ACE_ENV_ARG_DECL)
+  {
+    if (p == 0)
+    {
+      return 0;
+    }
+
+    ::BasicSP::CCM_BMDeviceHome_var x =
+    ::BasicSP::CCM_BMDeviceHome::_narrow (
+    p
+    ACE_ENV_ARG_PARAMETER);
+    ACE_CHECK_RETURN (0);
+
+    if (::CORBA::is_nil (x.in ()))
+    {
+      return 0;
+    }
+
+    return new
+    CIAO_GLUE_BasicSP::BMDeviceHome_Servant (
+    x.in (),
+    c);
+  }
+}
+
diff --git a/TAO/CIAO/DAnCE/examples/BasicSP/BMDevice/BMDevice_svnt.h b/TAO/CIAO/DAnCE/examples/BasicSP/BMDevice/BMDevice_svnt.h
new file mode 100644
index 00000000000..d7b2702ea5f
--- /dev/null
+++ b/TAO/CIAO/DAnCE/examples/BasicSP/BMDevice/BMDevice_svnt.h
@@ -0,0 +1,413 @@
+// $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_BMDEVICE_SVNT_H
+#define CIAO_GLUE_SESSION_BMDEVICE_SVNT_H
+
+#include /**/ "ace/pre.h"
+
+#include "BMDeviceEC.h"
+
+#if !defined (ACE_LACKS_PRAGMA_ONCE)
+# pragma once
+#endif /* ACE_LACKS_PRAGMA_ONCE */
+
+#include "ciao/Container_Base.h"
+#include "ciao/Servant_Impl_T.h"
+#include "ciao/Context_Impl_T.h"
+#include "ciao/Home_Servant_Impl_T.h"
+#include "ace/Active_Map_Manager_T.h"
+
+#include "../BasicSPS.h"
+#include "BMDeviceS.h"
+
+namespace BMDevice_Impl
+{
+  namespace CIAO_GLUE_BasicSP
+  {
+    template <typename T>
+    class ReadData_Servant_T
+    : public virtual POA_BasicSP::ReadData,
+    public virtual PortableServer::RefCountServantBase
+    {
+      public:
+      ReadData_Servant_T (
+      ::BasicSP::CCM_ReadData_ptr executor,
+      ::Components::CCMContext_ptr ctx);
+
+      virtual ~ReadData_Servant_T (void);
+
+      virtual char *
+      get_data (
+      ACE_ENV_SINGLE_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:
+      // Facet executor.
+      ::BasicSP::CCM_ReadData_var executor_;
+
+      // Context object.
+      ::Components::CCMContext_var ctx_;
+    };
+
+    typedef BMDEVICE_SVNT_Export ReadData_Servant_T<int> ReadData_Servant;
+  }
+
+  namespace CIAO_GLUE_BasicSP
+  {
+    class BMDevice_Servant;
+
+    class BMDEVICE_SVNT_Export BMDevice_Context
+      : public virtual CIAO::Context_Impl<
+          ::BasicSP::CCM_BMDevice_Context,
+          BMDevice_Servant,
+          ::BasicSP::BMDevice,
+          ::BasicSP::BMDevice_var
+        >
+    {
+      public:
+      // We will allow the servant glue code we generate to access our state.
+      friend class BMDevice_Servant;
+
+      /// Hack for VC6.
+      typedef CIAO::Context_Impl<
+          ::BasicSP::CCM_BMDevice_Context,
+          BMDevice_Servant,
+          ::BasicSP::BMDevice,
+          ::BasicSP::BMDevice_var
+        > ctx_svnt_base;
+
+      BMDevice_Context (
+      ::Components::CCMHome_ptr home,
+      ::CIAO::Session_Container *c,
+      BMDevice_Servant *sv);
+
+      virtual ~BMDevice_Context (void);
+
+      // Operations for BMDevice receptacles and event sources,
+      // defined in ::BasicSP::CCM_BMDevice_Context.
+
+      virtual void
+      push_data_available (
+      ::BasicSP::DataAvailable *ev
+      ACE_ENV_ARG_DECL_WITH_DEFAULTS)
+      ACE_THROW_SPEC ((CORBA::SystemException));
+
+      // CIAO-specific.
+
+      static BMDevice_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_data_available (
+      ::BasicSP::DataAvailableConsumer_ptr c
+      ACE_ENV_ARG_DECL_WITH_DEFAULTS)
+      ACE_THROW_SPEC ((
+      ::CORBA::SystemException,
+      ::Components::ExceededConnectionLimit));
+
+      virtual ::BasicSP::DataAvailableConsumer_ptr
+      unsubscribe_data_available (
+      ::Components::Cookie *ck
+      ACE_ENV_ARG_DECL_WITH_DEFAULTS)
+      ACE_THROW_SPEC ((
+      ::CORBA::SystemException,
+      ::Components::InvalidConnection));
+
+      protected:
+      ACE_Active_Map_Manager<
+      ::BasicSP::DataAvailableConsumer_var>
+      ciao_publishes_data_available_map_;
+    };
+  }
+
+  namespace CIAO_GLUE_BasicSP
+  {
+    class BMDEVICE_SVNT_Export BMDevice_Servant
+      : public virtual CIAO::Servant_Impl<
+          POA_BasicSP::BMDevice,
+          ::BasicSP::CCM_BMDevice,
+          ::BasicSP::CCM_BMDevice_var,
+          BMDevice_Context
+        >
+    {
+      public:
+      /// Hack for VC6.
+      typedef CIAO::Servant_Impl<
+          POA_BasicSP::BMDevice,
+          ::BasicSP::CCM_BMDevice,
+          ::BasicSP::CCM_BMDevice_var,
+          BMDevice_Context
+        > comp_svnt_base;
+
+      BMDevice_Servant (
+      ::BasicSP::CCM_BMDevice_ptr executor,
+      ::Components::CCMHome_ptr home,
+      ::CIAO::Session_Container *c);
+
+      virtual ~BMDevice_Servant (void);
+
+      virtual void
+      set_attributes (
+      const ::Components::ConfigValues &descr
+      ACE_ENV_ARG_DECL);
+
+      // Supported operations.
+      virtual void
+      component_UUID (
+      const char * new_component_UUID
+      ACE_ENV_ARG_DECL_WITH_DEFAULTS)
+      ACE_THROW_SPEC ((CORBA::SystemException));
+
+      virtual CIAO::CONNECTION_ID
+      component_UUID (
+      ACE_ENV_SINGLE_ARG_DECL_WITH_DEFAULTS)
+      ACE_THROW_SPEC ((CORBA::SystemException));
+
+      // Public port operations.
+
+      virtual ::BasicSP::ReadData_ptr
+      provide_data_read (
+      ACE_ENV_SINGLE_ARG_DECL_WITH_DEFAULTS)
+      ACE_THROW_SPEC ((CORBA::SystemException));
+
+      virtual ::Components::Cookie *
+      subscribe_data_available (
+      ::BasicSP::DataAvailableConsumer_ptr c
+      ACE_ENV_ARG_DECL_WITH_DEFAULTS)
+      ACE_THROW_SPEC ((
+      ::CORBA::SystemException,
+      ::Components::ExceededConnectionLimit));
+
+      virtual ::BasicSP::DataAvailableConsumer_ptr
+      unsubscribe_data_available (
+      ::Components::Cookie *ck
+      ACE_ENV_ARG_DECL_WITH_DEFAULTS)
+      ACE_THROW_SPEC ((
+      ::CORBA::SystemException,
+      ::Components::InvalidConnection));
+
+      // Servant class for the timeout consumer.
+      class BMDEVICE_SVNT_Export TimeOutConsumer_timeout_Servant
+      : public virtual POA_BasicSP::TimeOutConsumer,
+      public virtual PortableServer::RefCountServantBase
+      {
+        public:
+        TimeOutConsumer_timeout_Servant (
+        ::BasicSP::CCM_BMDevice_ptr executor,
+        ::BasicSP::CCM_BMDevice_Context_ptr c);
+
+        virtual ~TimeOutConsumer_timeout_Servant (void);
+
+        virtual void
+        push_TimeOut (
+        ::BasicSP::TimeOut *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));
+
+        // Get component implementation.
+        virtual CORBA::Object_ptr
+        _get_component (
+        ACE_ENV_SINGLE_ARG_DECL_WITH_DEFAULTS)
+        ACE_THROW_SPEC ((CORBA::SystemException));
+
+        protected:
+        ::BasicSP::CCM_BMDevice_var
+        executor_;
+
+        ::BasicSP::CCM_BMDevice_Context_var
+        ctx_;
+      };
+
+      virtual ::BasicSP::TimeOutConsumer_ptr
+      get_consumer_timeout (
+      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));
+
+      // 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));
+
+      // 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:
+
+      ::BasicSP::ReadData_var
+      provide_data_read_;
+
+      ::BasicSP::TimeOutConsumer_var
+      consumes_timeout_;
+
+      ACE_CString component_UUID_;
+
+      private:
+
+      void
+      populate_port_tables (
+      ACE_ENV_SINGLE_ARG_DECL_WITH_DEFAULTS)
+      ACE_THROW_SPEC ((CORBA::SystemException));
+
+      ::CORBA::Object_ptr
+      provide_data_read_i (
+      ACE_ENV_SINGLE_ARG_DECL_WITH_DEFAULTS)
+      ACE_THROW_SPEC ((CORBA::SystemException));
+
+      ::Components::EventConsumerBase_ptr
+      get_consumer_timeout_i (
+      ACE_ENV_SINGLE_ARG_DECL_WITH_DEFAULTS)
+      ACE_THROW_SPEC ((CORBA::SystemException));
+    };
+  }
+
+  namespace CIAO_GLUE_BasicSP
+  {
+    class BMDEVICE_SVNT_Export BMDeviceHome_Servant
+      : public virtual CIAO::Home_Servant_Impl<
+          POA_BasicSP::BMDeviceHome,
+          ::BasicSP::CCM_BMDeviceHome,
+          ::BasicSP::CCM_BMDeviceHome_var,
+          ::BasicSP::BMDevice,
+          ::BasicSP::BMDevice_var,
+          ::BasicSP::CCM_BMDevice,
+          ::BasicSP::CCM_BMDevice_var,
+          BMDevice_Servant
+        >
+    {
+      public:
+      /// Hack for VC6.
+      typedef CIAO::Home_Servant_Impl<
+          POA_BasicSP::BMDeviceHome,
+          ::BasicSP::CCM_BMDeviceHome,
+          ::BasicSP::CCM_BMDeviceHome_var,
+          ::BasicSP::BMDevice,
+          ::BasicSP::BMDevice_var,
+          ::BasicSP::CCM_BMDevice,
+          ::BasicSP::CCM_BMDevice_var,
+          BMDevice_Servant
+        > home_svnt_base;
+
+      BMDeviceHome_Servant (
+      ::BasicSP::CCM_BMDeviceHome_ptr exe,
+      ::CIAO::Session_Container *c);
+
+      virtual ~BMDeviceHome_Servant (void);
+
+      // Home operations.
+
+      // Home factory and finder operations.
+
+      // Attribute operations.
+    };
+
+    extern "C" BMDEVICE_SVNT_Export ::PortableServer::Servant
+    createBMDeviceHome_Servant (
+    ::Components::HomeExecutorBase_ptr p,
+    CIAO::Session_Container *c
+    ACE_ENV_ARG_DECL_WITH_DEFAULTS);
+  }
+}
+
+#include /**/ "ace/post.h"
+
+#endif /* CIAO_GLUE_SESSION_BMDEVICE_SVNT_H */
+
diff --git a/TAO/CIAO/DAnCE/examples/BasicSP/BMDisplay/BMDisplay_svnt.cpp b/TAO/CIAO/DAnCE/examples/BasicSP/BMDisplay/BMDisplay_svnt.cpp
new file mode 100644
index 00000000000..a7929e736b4
--- /dev/null
+++ b/TAO/CIAO/DAnCE/examples/BasicSP/BMDisplay/BMDisplay_svnt.cpp
@@ -0,0 +1,601 @@
+// $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 "BMDisplay_svnt.h"
+#include "Cookies.h"
+#include "ciao/Servant_Activator.h"
+#include "ciao/Port_Activator_T.h"
+
+namespace BMDisplay_Impl
+{
+  namespace CIAO_GLUE_BasicSP
+  {
+    BMDisplay_Context::BMDisplay_Context (
+    ::Components::CCMHome_ptr home,
+    ::CIAO::Session_Container *c,
+    BMDisplay_Servant *sv)
+      : Context_Impl_Base (home, c),
+        ctx_svnt_base (home, c, sv)
+    {
+    }
+
+    BMDisplay_Context::~BMDisplay_Context (void)
+    {
+    }
+
+    // Operations for BMDisplay receptacles and event sources,
+    // defined in ::BasicSP::CCM_BMDisplay_Context.
+
+    ::BasicSP::ReadData_ptr
+    BMDisplay_Context::get_connection_comp_data (
+    ACE_ENV_SINGLE_ARG_DECL_NOT_USED)
+    ACE_THROW_SPEC ((CORBA::SystemException))
+    {
+      return ::BasicSP::ReadData::_duplicate (
+      this->ciao_uses_comp_data_.in ());
+    }
+
+    void
+    BMDisplay_Context::connect_comp_data (
+    ::BasicSP::ReadData_ptr c
+    ACE_ENV_ARG_DECL)
+    ACE_THROW_SPEC ((
+    ::CORBA::SystemException,
+    ::Components::AlreadyConnected,
+    ::Components::InvalidConnection))
+    {
+      if (!CORBA::is_nil (this->ciao_uses_comp_data_.in ()))
+      {
+        ACE_THROW (::Components::AlreadyConnected ());
+      }
+
+      if (CORBA::is_nil (c))
+      {
+        ACE_THROW (::Components::InvalidConnection ());
+      }
+
+      this->ciao_uses_comp_data_ =
+      ::BasicSP::ReadData::_duplicate (c);
+    }
+
+    ::BasicSP::ReadData_ptr
+    BMDisplay_Context::disconnect_comp_data (
+    ACE_ENV_SINGLE_ARG_DECL)
+    ACE_THROW_SPEC ((
+    ::CORBA::SystemException,
+    ::Components::NoConnection))
+    {
+      if (CORBA::is_nil (this->ciao_uses_comp_data_.in ()))
+      {
+        ACE_THROW_RETURN (
+        ::Components::NoConnection (),
+        ::BasicSP::ReadData::_nil ());
+      }
+
+      return this->ciao_uses_comp_data_._retn ();
+    }
+
+    // CIAO-specific.
+
+    BMDisplay_Context *
+    BMDisplay_Context::_narrow (
+    ::Components::SessionContext_ptr p
+    ACE_ENV_ARG_DECL_NOT_USED)
+    {
+      return dynamic_cast<BMDisplay_Context *> (p);
+    }
+  }
+
+  namespace CIAO_GLUE_BasicSP
+  {
+    void
+    BMDisplay_Servant::component_UUID (
+    const char * new_component_UUID
+    ACE_ENV_ARG_DECL_WITH_DEFAULTS)
+    ACE_THROW_SPEC ((CORBA::SystemException))
+    {
+      this->component_UUID_ = new_component_UUID;
+    }
+
+    CIAO::CONNECTION_ID
+    BMDisplay_Servant::component_UUID (
+    ACE_ENV_SINGLE_ARG_DECL_WITH_DEFAULTS)
+    ACE_THROW_SPEC ((CORBA::SystemException))
+    {
+      return CORBA::string_dup (this->component_UUID_.c_str ());
+    }
+
+ 
+    BMDisplay_Servant::BMDisplay_Servant (
+    ::BasicSP::CCM_BMDisplay_ptr exe,
+    ::Components::CCMHome_ptr h,
+    ::CIAO::Session_Container *c)
+      : Servant_Impl_Base (c),
+        comp_svnt_base (exe, c)
+    {
+      this->context_ = new BMDisplay_Context (h, c, this);
+
+      CIAO_REGISTER_OBV_FACTORY (
+      ::BasicSP::DataAvailable_init,
+      ::BasicSP::DataAvailable);
+
+      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;
+    }
+
+    BMDisplay_Servant::~BMDisplay_Servant (void)
+    {
+    }
+
+    void
+    BMDisplay_Servant::set_attributes (
+    const ::Components::ConfigValues &descr
+    ACE_ENV_ARG_DECL_NOT_USED)
+    {
+      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);
+      }
+    }
+
+    BMDisplay_Servant::DataAvailableConsumer_data_ready_Servant::DataAvailableConsumer_data_ready_Servant (
+    ::BasicSP::CCM_BMDisplay_ptr executor,
+    ::BasicSP::CCM_BMDisplay_Context_ptr c)
+    : executor_ (::BasicSP::CCM_BMDisplay::_duplicate (executor)),
+    ctx_ (::BasicSP::CCM_BMDisplay_Context::_duplicate (c))
+    {
+    }
+
+    BMDisplay_Servant::DataAvailableConsumer_data_ready_Servant::~DataAvailableConsumer_data_ready_Servant (void)
+    {
+    }
+
+    CORBA::Object_ptr
+    BMDisplay_Servant::DataAvailableConsumer_data_ready_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
+    BMDisplay_Servant::DataAvailableConsumer_data_ready_Servant::push_DataAvailable (
+    ::BasicSP::DataAvailable *evt
+    ACE_ENV_ARG_DECL)
+    ACE_THROW_SPEC ((CORBA::SystemException))
+    {
+      this->executor_->push_data_ready (
+      evt
+      ACE_ENV_ARG_PARAMETER);
+    }
+
+    // Inherited from ::Components::EventConsumerBase.
+    void
+    BMDisplay_Servant::DataAvailableConsumer_data_ready_Servant::push_event (
+    ::Components::EventBase *ev
+    ACE_ENV_ARG_DECL)
+    ACE_THROW_SPEC ((
+    ::CORBA::SystemException,
+    ::Components::BadEventType))
+    {
+      ::BasicSP::DataAvailable_var ev_type =
+      ::BasicSP::DataAvailable::_downcast (ev);
+
+      if (ev_type != 0)
+      {
+        this->push_DataAvailable (
+        ev_type.in ()
+        ACE_ENV_ARG_PARAMETER);
+
+        return;
+      }
+
+      ACE_THROW (::Components::BadEventType ());
+    }
+
+    ::BasicSP::DataAvailableConsumer_ptr
+    BMDisplay_Servant::get_consumer_data_ready (
+    ACE_ENV_SINGLE_ARG_DECL)
+    ACE_THROW_SPEC ((CORBA::SystemException))
+    {
+      if (! ::CORBA::is_nil (this->consumes_data_ready_.in ()))
+      {
+        return ::BasicSP::DataAvailableConsumer::_duplicate (this->consumes_data_ready_.in ());
+      }
+
+      ::Components::EventConsumerBase_var obj =
+      this->get_consumer_data_ready_i (
+      ACE_ENV_SINGLE_ARG_PARAMETER);
+      ACE_CHECK_RETURN (::BasicSP::DataAvailableConsumer::_nil ());
+
+      ::BasicSP::DataAvailableConsumer_var eco =
+      ::BasicSP::DataAvailableConsumer::_narrow (
+      obj.in ()
+      ACE_ENV_ARG_PARAMETER);
+      ACE_CHECK_RETURN (::BasicSP::DataAvailableConsumer::_nil ());
+
+      this->consumes_data_ready_ = eco;
+      return ::BasicSP::DataAvailableConsumer::_duplicate (this->consumes_data_ready_.in ());
+    }
+
+    ::Components::EventConsumerBase_ptr
+    BMDisplay_Servant::get_consumer_data_ready_i (
+    ACE_ENV_SINGLE_ARG_DECL)
+    ACE_THROW_SPEC ((CORBA::SystemException))
+    {
+      ::Components::EventConsumerBase_ptr ret =
+      this->lookup_consumer ("data_ready");
+
+      if (! ::CORBA::is_nil (ret))
+      {
+        return ret;
+      }
+
+      CIAO::Port_Activator_T<
+      BMDisplay_Servant::DataAvailableConsumer_data_ready_Servant,
+      ::BasicSP::CCM_BMDisplay,
+      ::BasicSP::CCM_BMDisplay_Context,
+      BMDisplay_Servant > *tmp = 0;
+
+      typedef  CIAO::Port_Activator_T<
+      BMDisplay_Servant::DataAvailableConsumer_data_ready_Servant,
+      ::BasicSP::CCM_BMDisplay,
+      ::BasicSP::CCM_BMDisplay_Context, 
+      BMDisplay_Servant > 
+       MACRO_MADNESS_TYPEDEF;
+
+
+      ACE_NEW_THROW_EX ( 
+        tmp,
+        MACRO_MADNESS_TYPEDEF (
+      "BasicSP_BMDisplay_data_ready",
+      "data_ready",
+      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 0;
+      }
+
+      ::CORBA::Object_var obj =
+      this->container_->generate_reference (
+      "BasicSP_BMDisplay_data_ready",
+      "IDL:BasicSP/DataAvailableConsumer:1.0",
+      CIAO::Container::Facet_Consumer
+      ACE_ENV_ARG_PARAMETER);
+      ACE_CHECK_RETURN (::BasicSP::DataAvailableConsumer::_nil ());
+
+      ::Components::EventConsumerBase_var ecb =
+      ::Components::EventConsumerBase::_narrow (
+      obj.in ()
+      ACE_ENV_ARG_PARAMETER);
+      ACE_CHECK_RETURN (::BasicSP::DataAvailableConsumer::_nil ());
+
+      this->add_consumer (
+      "data_ready",
+      ecb.in ());
+
+      return ecb._retn ();
+    }
+
+    ::Components::Cookie *
+    BMDisplay_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, "comp_data") == 0)
+      {
+        ::BasicSP::ReadData_var _ciao_conn =
+        ::BasicSP::ReadData::_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_comp_data (
+        _ciao_conn.in ()
+        ACE_ENV_ARG_PARAMETER);
+        ACE_CHECK_RETURN (0);
+
+        return 0;
+      }
+
+      ACE_THROW_RETURN (::Components::InvalidName (), 0);
+    }
+
+    CORBA::Object_ptr
+    BMDisplay_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))
+    {
+      if (name == 0)
+      {
+        ACE_THROW_RETURN (
+        ::Components::InvalidName (),
+        ::CORBA::Object::_nil ());
+      }
+
+      if (ACE_OS::strcmp (name, "comp_data") == 0)
+      {
+        // Simplex disconnect.
+        return this->disconnect_comp_data (ACE_ENV_SINGLE_ARG_PARAMETER);
+      }
+
+      ACE_THROW_RETURN (
+      ::Components::InvalidName (),
+      ::CORBA::Object::_nil ());
+
+      ACE_UNUSED_ARG (ck);
+    }
+
+    void
+    BMDisplay_Servant::connect_comp_data (
+    ::BasicSP::ReadData_ptr c
+    ACE_ENV_ARG_DECL)
+    ACE_THROW_SPEC ((
+    ::CORBA::SystemException,
+    ::Components::AlreadyConnected,
+    ::Components::InvalidConnection))
+    {
+      this->context_->connect_comp_data (
+      c
+      ACE_ENV_ARG_PARAMETER);
+    }
+
+    ::BasicSP::ReadData_ptr
+    BMDisplay_Servant::disconnect_comp_data (
+    ACE_ENV_SINGLE_ARG_DECL)
+    ACE_THROW_SPEC ((
+    ::CORBA::SystemException,
+    ::Components::NoConnection))
+    {
+      return this->context_->disconnect_comp_data (
+      ACE_ENV_SINGLE_ARG_PARAMETER);
+    }
+
+    ::BasicSP::ReadData_ptr
+    BMDisplay_Servant::get_connection_comp_data (
+    ACE_ENV_SINGLE_ARG_DECL)
+    ACE_THROW_SPEC ((CORBA::SystemException))
+    {
+      return this->context_->get_connection_comp_data (
+      ACE_ENV_SINGLE_ARG_PARAMETER);
+    }
+
+    void
+    BMDisplay_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::Cookie *
+    BMDisplay_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);
+      }
+
+      ACE_THROW_RETURN (::Components::InvalidName (), 0);
+    }
+
+    ::Components::EventConsumerBase_ptr
+    BMDisplay_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 ());
+      }
+
+      ACE_THROW_RETURN (
+      ::Components::InvalidName (),
+      ::Components::EventConsumerBase::_nil ());
+    }
+
+    CORBA::Object_ptr
+    BMDisplay_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
+    BMDisplay_Servant::populate_port_tables (
+    ACE_ENV_SINGLE_ARG_DECL)
+    ACE_THROW_SPEC ((CORBA::SystemException))
+    {
+      ::CORBA::Object_var obj_var;
+      ::Components::EventConsumerBase_var ecb_var;
+
+      ecb_var =
+      this->get_consumer_data_ready_i (
+      ACE_ENV_SINGLE_ARG_PARAMETER);
+      ACE_CHECK;
+    }
+  }
+
+  namespace CIAO_GLUE_BasicSP
+  {
+    BMDisplayHome_Servant::BMDisplayHome_Servant (
+    ::BasicSP::CCM_BMDisplayHome_ptr exe,
+    ::CIAO::Session_Container *c)
+      : CIAO::Home_Servant_Impl_Base (c),
+        home_svnt_base (exe, c)
+    {
+    }
+
+    BMDisplayHome_Servant::~BMDisplayHome_Servant (void)
+    {
+    }
+
+    // Home operations.
+
+    // Home supported interface operations.
+
+    // Home factory and finder operations.
+
+    // Home attribute operations.
+  }
+
+  extern "C" BMDISPLAY_SVNT_Export ::PortableServer::Servant
+  createBMDisplayHome_Servant (
+  ::Components::HomeExecutorBase_ptr p,
+  CIAO::Session_Container *c
+  ACE_ENV_ARG_DECL)
+  {
+    if (p == 0)
+    {
+      return 0;
+    }
+
+    ::BasicSP::CCM_BMDisplayHome_var x =
+    ::BasicSP::CCM_BMDisplayHome::_narrow (
+    p
+    ACE_ENV_ARG_PARAMETER);
+    ACE_CHECK_RETURN (0);
+
+    if (::CORBA::is_nil (x.in ()))
+    {
+      return 0;
+    }
+
+    return new
+    CIAO_GLUE_BasicSP::BMDisplayHome_Servant (
+    x.in (),
+    c);
+  }
+}
+
diff --git a/TAO/CIAO/DAnCE/examples/BasicSP/BMDisplay/BMDisplay_svnt.h b/TAO/CIAO/DAnCE/examples/BasicSP/BMDisplay/BMDisplay_svnt.h
new file mode 100644
index 00000000000..16b3c2dfe2f
--- /dev/null
+++ b/TAO/CIAO/DAnCE/examples/BasicSP/BMDisplay/BMDisplay_svnt.h
@@ -0,0 +1,366 @@
+// $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_BMDISPLAY_SVNT_H
+#define CIAO_GLUE_SESSION_BMDISPLAY_SVNT_H
+
+#include /**/ "ace/pre.h"
+
+#include "BMDisplayEC.h"
+
+#if !defined (ACE_LACKS_PRAGMA_ONCE)
+# pragma once
+#endif /* ACE_LACKS_PRAGMA_ONCE */
+
+#include "ciao/Container_Base.h"
+#include "ciao/Servant_Impl_T.h"
+#include "ciao/Context_Impl_T.h"
+#include "ciao/Home_Servant_Impl_T.h"
+#include "ace/Active_Map_Manager_T.h"
+
+#include "BMDisplayS.h"
+
+namespace BMDisplay_Impl
+{
+  namespace CIAO_GLUE_BasicSP
+  {
+    class BMDisplay_Servant;
+
+    class BMDISPLAY_SVNT_Export BMDisplay_Context
+      : public virtual CIAO::Context_Impl<
+          ::BasicSP::CCM_BMDisplay_Context,
+          BMDisplay_Servant,
+          ::BasicSP::BMDisplay,
+          ::BasicSP::BMDisplay_var
+        >
+    {
+      public:
+      // We will allow the servant glue code we generate to access our state.
+      friend class BMDisplay_Servant;
+
+      /// Hack for VC6.
+      typedef CIAO::Context_Impl<
+          ::BasicSP::CCM_BMDisplay_Context,
+          BMDisplay_Servant,
+          ::BasicSP::BMDisplay,
+          ::BasicSP::BMDisplay_var
+        > ctx_svnt_base;
+
+      BMDisplay_Context (
+      ::Components::CCMHome_ptr home,
+      ::CIAO::Session_Container *c,
+      BMDisplay_Servant *sv);
+
+      virtual ~BMDisplay_Context (void);
+
+      // Operations for BMDisplay receptacles and event sources,
+      // defined in ::BasicSP::CCM_BMDisplay_Context.
+
+      virtual ::BasicSP::ReadData_ptr
+      get_connection_comp_data (
+      ACE_ENV_SINGLE_ARG_DECL_WITH_DEFAULTS)
+      ACE_THROW_SPEC ((CORBA::SystemException));
+
+      // CIAO-specific.
+
+      static BMDisplay_Context *
+      _narrow (
+      ::Components::SessionContext_ptr p
+      ACE_ENV_ARG_DECL_WITH_DEFAULTS);
+
+      protected:
+      // Methods that manage this component's connections and consumers.
+
+      virtual void
+      connect_comp_data (
+      ::BasicSP::ReadData_ptr
+      ACE_ENV_ARG_DECL_WITH_DEFAULTS)
+      ACE_THROW_SPEC ((
+      ::CORBA::SystemException,
+      ::Components::AlreadyConnected,
+      ::Components::InvalidConnection));
+
+      virtual ::BasicSP::ReadData_ptr
+      disconnect_comp_data (
+      ACE_ENV_SINGLE_ARG_DECL_WITH_DEFAULTS)
+      ACE_THROW_SPEC ((
+      ::CORBA::SystemException,
+      ::Components::NoConnection));
+
+      protected:
+      // Simplex comp_data connection.
+      ::BasicSP::ReadData_var
+      ciao_uses_comp_data_;
+    };
+  }
+
+  namespace CIAO_GLUE_BasicSP
+  {
+    class BMDISPLAY_SVNT_Export BMDisplay_Servant
+      : public virtual CIAO::Servant_Impl<
+          POA_BasicSP::BMDisplay,
+          ::BasicSP::CCM_BMDisplay,
+          ::BasicSP::CCM_BMDisplay_var,
+          BMDisplay_Context
+        >
+    {
+      public:
+      /// Hack for VC6.
+      typedef CIAO::Servant_Impl<
+          POA_BasicSP::BMDisplay,
+          ::BasicSP::CCM_BMDisplay,
+          ::BasicSP::CCM_BMDisplay_var,
+          BMDisplay_Context
+        > comp_svnt_base;
+
+      BMDisplay_Servant (
+      ::BasicSP::CCM_BMDisplay_ptr executor,
+      ::Components::CCMHome_ptr home,
+      ::CIAO::Session_Container *c);
+
+      virtual ~BMDisplay_Servant (void);
+
+      virtual void
+      set_attributes (
+      const ::Components::ConfigValues &descr
+      ACE_ENV_ARG_DECL);
+
+      // Supported operations.
+      virtual void
+      component_UUID (
+      const char * new_component_UUID
+      ACE_ENV_ARG_DECL_WITH_DEFAULTS)
+      ACE_THROW_SPEC ((CORBA::SystemException));
+
+      virtual CIAO::CONNECTION_ID
+      component_UUID (
+      ACE_ENV_SINGLE_ARG_DECL_WITH_DEFAULTS)
+      ACE_THROW_SPEC ((CORBA::SystemException));
+
+      // Public port operations.
+
+      // Servant class for the data_ready consumer.
+      class BMDISPLAY_SVNT_Export DataAvailableConsumer_data_ready_Servant
+      : public virtual POA_BasicSP::DataAvailableConsumer,
+      public virtual PortableServer::RefCountServantBase
+      {
+        public:
+        DataAvailableConsumer_data_ready_Servant (
+        ::BasicSP::CCM_BMDisplay_ptr executor,
+        ::BasicSP::CCM_BMDisplay_Context_ptr c);
+
+        virtual ~DataAvailableConsumer_data_ready_Servant (void);
+
+        virtual void
+        push_DataAvailable (
+        ::BasicSP::DataAvailable *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));
+
+        // Get component implementation.
+        virtual CORBA::Object_ptr
+        _get_component (
+        ACE_ENV_SINGLE_ARG_DECL_WITH_DEFAULTS)
+        ACE_THROW_SPEC ((CORBA::SystemException));
+
+        protected:
+        ::BasicSP::CCM_BMDisplay_var
+        executor_;
+
+        ::BasicSP::CCM_BMDisplay_Context_var
+        ctx_;
+      };
+
+      virtual ::BasicSP::DataAvailableConsumer_ptr
+      get_consumer_data_ready (
+      ACE_ENV_SINGLE_ARG_DECL_WITH_DEFAULTS)
+      ACE_THROW_SPEC ((CORBA::SystemException));
+
+      virtual void
+      connect_comp_data (
+      ::BasicSP::ReadData_ptr c
+      ACE_ENV_ARG_DECL_WITH_DEFAULTS)
+      ACE_THROW_SPEC ((
+      ::CORBA::SystemException,
+      ::Components::AlreadyConnected,
+      ::Components::InvalidConnection));
+
+      virtual ::BasicSP::ReadData_ptr
+      disconnect_comp_data (
+      ACE_ENV_SINGLE_ARG_DECL_WITH_DEFAULTS)
+      ACE_THROW_SPEC ((
+      ::CORBA::SystemException,
+      ::Components::NoConnection));
+
+      virtual ::BasicSP::ReadData_ptr
+      get_connection_comp_data (
+      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));
+
+      // 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));
+
+      // 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:
+
+      ::BasicSP::DataAvailableConsumer_var
+      consumes_data_ready_;
+
+      ACE_CString component_UUID_;
+
+      private:
+
+      void
+      populate_port_tables (
+      ACE_ENV_SINGLE_ARG_DECL_WITH_DEFAULTS)
+      ACE_THROW_SPEC ((CORBA::SystemException));
+
+      ::Components::EventConsumerBase_ptr
+      get_consumer_data_ready_i (
+      ACE_ENV_SINGLE_ARG_DECL_WITH_DEFAULTS)
+      ACE_THROW_SPEC ((CORBA::SystemException));
+    };
+  }
+
+  namespace CIAO_GLUE_BasicSP
+  {
+    class BMDISPLAY_SVNT_Export BMDisplayHome_Servant
+      : public virtual CIAO::Home_Servant_Impl<
+          POA_BasicSP::BMDisplayHome,
+          ::BasicSP::CCM_BMDisplayHome,
+          ::BasicSP::CCM_BMDisplayHome_var,
+          ::BasicSP::BMDisplay,
+          ::BasicSP::BMDisplay_var,
+          ::BasicSP::CCM_BMDisplay,
+          ::BasicSP::CCM_BMDisplay_var,
+          BMDisplay_Servant
+        >
+    {
+      public:
+      /// Hack for VC6.
+      typedef CIAO::Home_Servant_Impl<
+          POA_BasicSP::BMDisplayHome,
+          ::BasicSP::CCM_BMDisplayHome,
+          ::BasicSP::CCM_BMDisplayHome_var,
+          ::BasicSP::BMDisplay,
+          ::BasicSP::BMDisplay_var,
+          ::BasicSP::CCM_BMDisplay,
+          ::BasicSP::CCM_BMDisplay_var,
+          BMDisplay_Servant
+        > home_svnt_base;
+
+      BMDisplayHome_Servant (
+      ::BasicSP::CCM_BMDisplayHome_ptr exe,
+      ::CIAO::Session_Container *c);
+
+      virtual ~BMDisplayHome_Servant (void);
+
+      // Home operations.
+
+      // Home factory and finder operations.
+
+      // Attribute operations.
+    };
+
+    extern "C" BMDISPLAY_SVNT_Export ::PortableServer::Servant
+    createBMDisplayHome_Servant (
+    ::Components::HomeExecutorBase_ptr p,
+    CIAO::Session_Container *c
+    ACE_ENV_ARG_DECL_WITH_DEFAULTS);
+  }
+}
+
+#include /**/ "ace/post.h"
+
+#endif /* CIAO_GLUE_SESSION_BMDISPLAY_SVNT_H */
+
diff --git a/TAO/CIAO/DAnCE/examples/BasicSP/EC/EC_svnt.cpp b/TAO/CIAO/DAnCE/examples/BasicSP/EC/EC_svnt.cpp
new file mode 100644
index 00000000000..e78f7f1157e
--- /dev/null
+++ b/TAO/CIAO/DAnCE/examples/BasicSP/EC/EC_svnt.cpp
@@ -0,0 +1,549 @@
+// $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 "EC_svnt.h"
+#include "Cookies.h"
+#include "ciao/Servant_Activator.h"
+#include "ciao/Port_Activator_T.h"
+
+namespace EC_Impl
+{
+  namespace CIAO_GLUE_BasicSP
+  {
+    EC_Context::EC_Context (
+    ::Components::CCMHome_ptr home,
+    ::CIAO::Session_Container *c,
+    EC_Servant *sv)
+      : Context_Impl_Base (home, c),
+        ctx_svnt_base (home, c, sv)
+    {
+    }
+
+    EC_Context::~EC_Context (void)
+    {
+    }
+
+    // Operations for EC receptacles and event sources,
+    // defined in ::BasicSP::CCM_EC_Context.
+
+    void
+    EC_Context::push_timeout (
+    ::BasicSP::TimeOut *ev
+    ACE_ENV_ARG_DECL)
+    ACE_THROW_SPEC ((CORBA::SystemException))
+    {
+
+      ACE_CString my_uuid = this->servant_->component_UUID (ACE_ENV_SINGLE_ARG_PARAMETER);
+      ACE_CHECK;
+      my_uuid += "_prepare_capture_publisher";
+
+      this->container_->push_event (ev,
+                                    my_uuid.c_str ()
+                                    ACE_ENV_ARG_PARAMETER);
+      ACE_CHECK;
+      /*
+      ACE_Active_Map_Manager< 
+      ::BasicSP::TimeOutConsumer_var>::iterator end =
+      this->ciao_publishes_timeout_map_.end ();
+
+      for (ACE_Active_Map_Manager< 
+      ::BasicSP::TimeOutConsumer_var>::iterator iter =
+      this->ciao_publishes_timeout_map_.begin ();
+      iter != end;
+      ++iter)
+      {
+        ACE_Active_Map_Manager< 
+        ::BasicSP::TimeOutConsumer_var>::ENTRY &entry = *iter;
+
+        ::BasicSP::TimeOutConsumer_var c =
+        ::BasicSP::TimeOutConsumer::_narrow (
+        entry.int_id_.in ()
+        ACE_ENV_ARG_PARAMETER);
+        ACE_CHECK;
+
+        entry.int_id_->push_TimeOut (
+        ev
+        ACE_ENV_ARG_PARAMETER);
+        ACE_CHECK;
+      }
+      */
+    }
+
+    ::Components::Cookie *
+    EC_Context::subscribe_timeout (
+    ::BasicSP::TimeOutConsumer_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);
+      }
+
+      ::BasicSP::TimeOutConsumer_var sub =
+      ::BasicSP::TimeOutConsumer::_duplicate (c);
+
+      ACE_Active_Map_Manager_Key key;
+      this->ciao_publishes_timeout_map_.bind (sub.in (), key);
+      sub._retn ();
+
+      ::Components::Cookie_var retv = new ::CIAO::Map_Key_Cookie (key);
+      return retv._retn ();
+    }
+
+    ::BasicSP::TimeOutConsumer_ptr
+    EC_Context::unsubscribe_timeout (
+    ::Components::Cookie *ck
+    ACE_ENV_ARG_DECL)
+    ACE_THROW_SPEC ((
+    ::CORBA::SystemException,
+    ::Components::InvalidConnection))
+    {
+      ::BasicSP::TimeOutConsumer_var retv;
+      ACE_Active_Map_Manager_Key key;
+
+      if (ck == 0 || ::CIAO::Map_Key_Cookie::extract (ck, key) == false)
+      {
+        ACE_THROW_RETURN (
+        ::Components::InvalidConnection (),
+        ::BasicSP::TimeOutConsumer::_nil ());
+      }
+
+      if (this->ciao_publishes_timeout_map_.unbind (key, retv) != 0)
+      {
+        ACE_THROW_RETURN (
+        ::Components::InvalidConnection (),
+        ::BasicSP::TimeOutConsumer::_nil ());
+      }
+
+      return retv._retn ();
+    }
+
+    // CIAO-specific.
+
+    EC_Context *
+    EC_Context::_narrow (
+    ::Components::SessionContext_ptr p
+    ACE_ENV_ARG_DECL_NOT_USED)
+    {
+      return dynamic_cast<EC_Context *> (p);
+    }
+  }
+
+  namespace CIAO_GLUE_BasicSP
+  {
+    void
+    EC_Servant::component_UUID (
+    const char * new_component_UUID
+    ACE_ENV_ARG_DECL_WITH_DEFAULTS)
+    ACE_THROW_SPEC ((CORBA::SystemException))
+    {
+      this->component_UUID_ = new_component_UUID;
+    }
+
+    CIAO::CONNECTION_ID
+    EC_Servant::component_UUID (
+    ACE_ENV_SINGLE_ARG_DECL_WITH_DEFAULTS)
+    ACE_THROW_SPEC ((CORBA::SystemException))
+    {
+      return CORBA::string_dup (this->component_UUID_.c_str ());
+    }
+
+ 
+    EC_Servant::EC_Servant (
+    ::BasicSP::CCM_EC_ptr exe,
+    ::Components::CCMHome_ptr h,
+    ::CIAO::Session_Container *c)
+      : Servant_Impl_Base (c),
+        comp_svnt_base (exe, c)
+    {
+      this->context_ = new EC_Context (h, c, this);
+
+      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;
+    }
+
+    EC_Servant::~EC_Servant (void)
+    {
+    }
+
+    void
+    EC_Servant::set_attributes (
+    const ::Components::ConfigValues &descr
+    ACE_ENV_ARG_DECL_NOT_USED)
+    {
+      for (CORBA::ULong i = 0;
+       i < descr.length ();
+       ++i)
+      {
+        const char *descr_name = descr[i]->name ();
+        ::CORBA::Any &descr_value = descr[i]->value ();
+
+        if (ACE_OS::strcmp (descr_name, "hertz") == 0)
+        {
+          ::CORBA::Long _ciao_extract_val = 0;
+          descr_value >>= _ciao_extract_val;
+          this->hertz (_ciao_extract_val);
+          continue;
+        }
+
+        ACE_UNUSED_ARG (descr_name);
+        ACE_UNUSED_ARG (descr_value);
+      }
+    }
+
+    ::Components::Cookie *
+    EC_Servant::subscribe_timeout (
+    ::BasicSP::TimeOutConsumer_ptr c
+    ACE_ENV_ARG_DECL)
+    ACE_THROW_SPEC ((
+    ::CORBA::SystemException,
+    ::Components::ExceededConnectionLimit))
+    {
+      return this->context_->subscribe_timeout (
+      c
+      ACE_ENV_ARG_PARAMETER);
+    }
+
+    ::BasicSP::TimeOutConsumer_ptr
+    EC_Servant::unsubscribe_timeout (
+    ::Components::Cookie *ck
+    ACE_ENV_ARG_DECL)
+    ACE_THROW_SPEC ((
+    ::CORBA::SystemException,
+    ::Components::InvalidConnection))
+    {
+      return this->context_->unsubscribe_timeout (
+      ck
+      ACE_ENV_ARG_PARAMETER);
+    }
+
+    ::Components::Cookie *
+    EC_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);
+      }
+
+      ACE_THROW_RETURN (::Components::InvalidName (), 0);
+    }
+
+    CORBA::Object_ptr
+    EC_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))
+    {
+      if (name == 0)
+      {
+        ACE_THROW_RETURN (
+        ::Components::InvalidName (),
+        ::CORBA::Object::_nil ());
+      }
+
+      ACE_THROW_RETURN (
+      ::Components::InvalidName (),
+      ::CORBA::Object::_nil ());
+
+      ACE_UNUSED_ARG (ck);
+    }
+
+    void
+    EC_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::Cookie *
+    EC_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, "timeout") == 0)
+      {
+        ::BasicSP::TimeOutConsumer_var _ciao_consumer =
+        ::BasicSP::TimeOutConsumer::_narrow (
+        subscribe
+        ACE_ENV_ARG_PARAMETER);
+        ACE_CHECK_RETURN (0);
+
+        if (::CORBA::is_nil (_ciao_consumer.in ()))
+        {
+          ACE_THROW_RETURN (::Components::InvalidConnection (), 0);
+        }
+
+        return this->subscribe_timeout (
+        _ciao_consumer.in ()
+        ACE_ENV_ARG_PARAMETER);
+      }
+
+      ACE_THROW_RETURN (::Components::InvalidName (), 0);
+    }
+
+    ::Components::EventConsumerBase_ptr
+    EC_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, "timeout") == 0)
+      {
+        return this->unsubscribe_timeout (
+        ck
+        ACE_ENV_ARG_PARAMETER);
+      }
+
+      ACE_THROW_RETURN (
+      ::Components::InvalidName (),
+      ::Components::EventConsumerBase::_nil ());
+    }
+
+    CORBA::Object_ptr
+    EC_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.
+
+    void
+    EC_Servant::start (
+    ACE_ENV_SINGLE_ARG_DECL)
+    ACE_THROW_SPEC ((CORBA::SystemException))
+    {
+      this->executor_->start (
+      ACE_ENV_SINGLE_ARG_PARAMETER);
+    }
+
+    void
+    EC_Servant::stop (
+    ACE_ENV_SINGLE_ARG_DECL)
+    ACE_THROW_SPEC ((CORBA::SystemException))
+    {
+      this->executor_->stop (
+      ACE_ENV_SINGLE_ARG_PARAMETER);
+    }
+
+    // Component attribute operations.
+
+    ::CORBA::Long
+    EC_Servant::hertz (
+    ACE_ENV_SINGLE_ARG_DECL)
+    ACE_THROW_SPEC ((CORBA::SystemException))
+    {
+      return this->executor_->hertz (
+      ACE_ENV_SINGLE_ARG_PARAMETER);
+    }
+
+    void
+    EC_Servant::hertz (
+    ::CORBA::Long hertz
+    ACE_ENV_ARG_DECL)
+    ACE_THROW_SPEC ((CORBA::SystemException))
+    {
+      this->executor_->hertz (
+      hertz
+      ACE_ENV_ARG_PARAMETER);
+    }
+
+    // Private method to populate the port tables.
+    void
+    EC_Servant::populate_port_tables (
+    ACE_ENV_SINGLE_ARG_DECL)
+    ACE_THROW_SPEC ((CORBA::SystemException))
+    {
+      ::CORBA::Object_var obj_var;
+      ::Components::EventConsumerBase_var ecb_var;
+    }
+  }
+
+  namespace CIAO_GLUE_BasicSP
+  {
+    ECHome_Servant::ECHome_Servant (
+    ::BasicSP::CCM_ECHome_ptr exe,
+    ::CIAO::Session_Container *c)
+      : CIAO::Home_Servant_Impl_Base (c),
+        home_svnt_base (exe, c)
+    {
+    }
+
+    ECHome_Servant::~ECHome_Servant (void)
+    {
+    }
+
+    // Home operations.
+
+    // Home supported interface operations.
+
+    // Home factory and finder operations.
+
+    ::BasicSP::EC_ptr
+    ECHome_Servant::new_EC (
+    ::CORBA::Long hertz
+    ACE_ENV_ARG_DECL)
+    ACE_THROW_SPEC ((CORBA::SystemException))
+    {
+      ::Components::EnterpriseComponent_var _ciao_ec =
+      this->executor_->new_EC (
+      hertz
+      ACE_ENV_ARG_PARAMETER);
+      ACE_CHECK_RETURN (::BasicSP::EC_ptr::_nil ());
+
+      ::BasicSP::CCM_EC_var _ciao_comp =
+      ::BasicSP::CCM_EC::_narrow (
+      _ciao_ec.in ()
+      ACE_ENV_ARG_PARAMETER);
+
+      ACE_CHECK_RETURN (::BasicSP::EC_ptr::_nil ());
+
+      return this->_ciao_activate_component (
+      _ciao_comp.in ()
+      ACE_ENV_ARG_PARAMETER);
+    }
+
+    // Home attribute operations.
+  }
+
+  extern "C" EC_SVNT_Export ::PortableServer::Servant
+  createECHome_Servant (
+  ::Components::HomeExecutorBase_ptr p,
+  CIAO::Session_Container *c
+  ACE_ENV_ARG_DECL)
+  {
+    if (p == 0)
+    {
+      return 0;
+    }
+
+    ::BasicSP::CCM_ECHome_var x =
+    ::BasicSP::CCM_ECHome::_narrow (
+    p
+    ACE_ENV_ARG_PARAMETER);
+    ACE_CHECK_RETURN (0);
+
+    if (::CORBA::is_nil (x.in ()))
+    {
+      return 0;
+    }
+
+    return new
+    CIAO_GLUE_BasicSP::ECHome_Servant (
+    x.in (),
+    c);
+  }
+}
+
diff --git a/TAO/CIAO/DAnCE/examples/BasicSP/EC/EC_svnt.h b/TAO/CIAO/DAnCE/examples/BasicSP/EC/EC_svnt.h
new file mode 100644
index 00000000000..3db4ddf95fa
--- /dev/null
+++ b/TAO/CIAO/DAnCE/examples/BasicSP/EC/EC_svnt.h
@@ -0,0 +1,333 @@
+// $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_EC_SVNT_H
+#define CIAO_GLUE_SESSION_EC_SVNT_H
+
+#include /**/ "ace/pre.h"
+
+#include "ECEC.h"
+
+#if !defined (ACE_LACKS_PRAGMA_ONCE)
+# pragma once
+#endif /* ACE_LACKS_PRAGMA_ONCE */
+
+#include "ciao/Container_Base.h"
+#include "ciao/Servant_Impl_T.h"
+#include "ciao/Context_Impl_T.h"
+#include "ciao/Home_Servant_Impl_T.h"
+#include "ace/Active_Map_Manager_T.h"
+
+#include "ECS.h"
+
+namespace EC_Impl
+{
+  namespace CIAO_GLUE_BasicSP
+  {
+    class EC_Servant;
+
+    class EC_SVNT_Export EC_Context
+      : public virtual CIAO::Context_Impl<
+          ::BasicSP::CCM_EC_Context,
+          EC_Servant,
+          ::BasicSP::EC,
+          ::BasicSP::EC_var
+        >
+    {
+      public:
+      // We will allow the servant glue code we generate to access our state.
+      friend class EC_Servant;
+
+      /// Hack for VC6.
+      typedef CIAO::Context_Impl<
+          ::BasicSP::CCM_EC_Context,
+          EC_Servant,
+          ::BasicSP::EC,
+          ::BasicSP::EC_var
+        > ctx_svnt_base;
+
+      EC_Context (
+      ::Components::CCMHome_ptr home,
+      ::CIAO::Session_Container *c,
+      EC_Servant *sv);
+
+      virtual ~EC_Context (void);
+
+      // Operations for EC receptacles and event sources,
+      // defined in ::BasicSP::CCM_EC_Context.
+
+      virtual void
+      push_timeout (
+      ::BasicSP::TimeOut *ev
+      ACE_ENV_ARG_DECL_WITH_DEFAULTS)
+      ACE_THROW_SPEC ((CORBA::SystemException));
+
+      // CIAO-specific.
+
+      static EC_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_timeout (
+      ::BasicSP::TimeOutConsumer_ptr c
+      ACE_ENV_ARG_DECL_WITH_DEFAULTS)
+      ACE_THROW_SPEC ((
+      ::CORBA::SystemException,
+      ::Components::ExceededConnectionLimit));
+
+      virtual ::BasicSP::TimeOutConsumer_ptr
+      unsubscribe_timeout (
+      ::Components::Cookie *ck
+      ACE_ENV_ARG_DECL_WITH_DEFAULTS)
+      ACE_THROW_SPEC ((
+      ::CORBA::SystemException,
+      ::Components::InvalidConnection));
+
+      protected:
+      ACE_Active_Map_Manager<
+      ::BasicSP::TimeOutConsumer_var>
+      ciao_publishes_timeout_map_;
+    };
+  }
+
+  namespace CIAO_GLUE_BasicSP
+  {
+    class EC_SVNT_Export EC_Servant
+      : public virtual CIAO::Servant_Impl<
+          POA_BasicSP::EC,
+          ::BasicSP::CCM_EC,
+          ::BasicSP::CCM_EC_var,
+          EC_Context
+        >
+    {
+      public:
+      /// Hack for VC6.
+      typedef CIAO::Servant_Impl<
+          POA_BasicSP::EC,
+          ::BasicSP::CCM_EC,
+          ::BasicSP::CCM_EC_var,
+          EC_Context
+        > comp_svnt_base;
+
+      EC_Servant (
+      ::BasicSP::CCM_EC_ptr executor,
+      ::Components::CCMHome_ptr home,
+      ::CIAO::Session_Container *c);
+
+      virtual ~EC_Servant (void);
+
+      virtual void
+      set_attributes (
+      const ::Components::ConfigValues &descr
+      ACE_ENV_ARG_DECL);
+
+      // Supported operations.
+      virtual void
+      component_UUID (
+      const char * new_component_UUID
+      ACE_ENV_ARG_DECL_WITH_DEFAULTS)
+      ACE_THROW_SPEC ((CORBA::SystemException));
+
+      virtual CIAO::CONNECTION_ID
+      component_UUID (
+      ACE_ENV_SINGLE_ARG_DECL_WITH_DEFAULTS)
+      ACE_THROW_SPEC ((CORBA::SystemException));
+
+      virtual void
+      start (
+      ACE_ENV_SINGLE_ARG_DECL_WITH_DEFAULTS)
+      ACE_THROW_SPEC ((CORBA::SystemException));
+      virtual void
+      stop (
+      ACE_ENV_SINGLE_ARG_DECL_WITH_DEFAULTS)
+      ACE_THROW_SPEC ((CORBA::SystemException));
+      // Public port operations.
+
+      virtual ::Components::Cookie *
+      subscribe_timeout (
+      ::BasicSP::TimeOutConsumer_ptr c
+      ACE_ENV_ARG_DECL_WITH_DEFAULTS)
+      ACE_THROW_SPEC ((
+      ::CORBA::SystemException,
+      ::Components::ExceededConnectionLimit));
+
+      virtual ::BasicSP::TimeOutConsumer_ptr
+      unsubscribe_timeout (
+      ::Components::Cookie *ck
+      ACE_ENV_ARG_DECL_WITH_DEFAULTS)
+      ACE_THROW_SPEC ((
+      ::CORBA::SystemException,
+      ::Components::InvalidConnection));
+
+      // Component attribute operations.
+
+      virtual ::CORBA::Long
+      hertz (
+      ACE_ENV_SINGLE_ARG_DECL_WITH_DEFAULTS)
+      ACE_THROW_SPEC ((CORBA::SystemException));
+
+      virtual void
+      hertz (
+      ::CORBA::Long
+      ACE_ENV_ARG_DECL_WITH_DEFAULTS)
+      ACE_THROW_SPEC ((CORBA::SystemException));
+
+      // 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));
+
+      // 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));
+
+      // 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:
+      ACE_CString component_UUID_;
+
+      private:
+
+      void
+      populate_port_tables (
+      ACE_ENV_SINGLE_ARG_DECL_WITH_DEFAULTS)
+      ACE_THROW_SPEC ((CORBA::SystemException));
+    };
+  }
+
+  namespace CIAO_GLUE_BasicSP
+  {
+    class EC_SVNT_Export ECHome_Servant
+      : public virtual CIAO::Home_Servant_Impl<
+          POA_BasicSP::ECHome,
+          ::BasicSP::CCM_ECHome,
+          ::BasicSP::CCM_ECHome_var,
+          ::BasicSP::EC,
+          ::BasicSP::EC_var,
+          ::BasicSP::CCM_EC,
+          ::BasicSP::CCM_EC_var,
+          EC_Servant
+        >
+    {
+      public:
+      /// Hack for VC6.
+      typedef CIAO::Home_Servant_Impl<
+          POA_BasicSP::ECHome,
+          ::BasicSP::CCM_ECHome,
+          ::BasicSP::CCM_ECHome_var,
+          ::BasicSP::EC,
+          ::BasicSP::EC_var,
+          ::BasicSP::CCM_EC,
+          ::BasicSP::CCM_EC_var,
+          EC_Servant
+        > home_svnt_base;
+
+      ECHome_Servant (
+      ::BasicSP::CCM_ECHome_ptr exe,
+      ::CIAO::Session_Container *c);
+
+      virtual ~ECHome_Servant (void);
+
+      // Home operations.
+
+      // Home factory and finder operations.
+
+      virtual ::BasicSP::EC_ptr
+      new_EC (
+      ::CORBA::Long hertz
+      ACE_ENV_ARG_DECL_WITH_DEFAULTS)
+      ACE_THROW_SPEC ((CORBA::SystemException));
+
+      // Attribute operations.
+    };
+
+    extern "C" EC_SVNT_Export ::PortableServer::Servant
+    createECHome_Servant (
+    ::Components::HomeExecutorBase_ptr p,
+    CIAO::Session_Container *c
+    ACE_ENV_ARG_DECL_WITH_DEFAULTS);
+  }
+}
+
+#include /**/ "ace/post.h"
+
+#endif /* CIAO_GLUE_SESSION_EC_SVNT_H */
+