summaryrefslogtreecommitdiff
path: root/CIAO/examples/Display/RateGen/RateGen_exec.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'CIAO/examples/Display/RateGen/RateGen_exec.cpp')
-rw-r--r--CIAO/examples/Display/RateGen/RateGen_exec.cpp341
1 files changed, 0 insertions, 341 deletions
diff --git a/CIAO/examples/Display/RateGen/RateGen_exec.cpp b/CIAO/examples/Display/RateGen/RateGen_exec.cpp
deleted file mode 100644
index a5a27833490..00000000000
--- a/CIAO/examples/Display/RateGen/RateGen_exec.cpp
+++ /dev/null
@@ -1,341 +0,0 @@
-// $Id$
-
-#include "RateGen_exec.h"
-#include "CIAO_common.h"
-#include "ace/Timer_Queue.h"
-#include "ace/Reactor.h"
-
-//=================================================================
-
-MyImpl::Pulse_Handler::Pulse_Handler (MyImpl::RateGen_exec_i *cb)
- : active_ (0),
- done_ (0),
- tid_ (0),
- pulse_callback_ (cb)
-{
- // Nothing
- this->reactor (new ACE_Reactor);
-}
-
-MyImpl::Pulse_Handler::~Pulse_Handler ()
-{
- delete this->reactor ();
- this->reactor (0);
-}
-
-int
-MyImpl::Pulse_Handler::open_h ()
-{
- return this->activate ();
-}
-
-int
-MyImpl::Pulse_Handler::close_h ()
-{
- this->done_ = 1;
- this->reactor ()->notify ();
-
- if (CIAO::debug_level () > 0)
- {
- ACE_DEBUG ((LM_DEBUG, "Waiting\n"));
- }
-
- return this->wait ();
-}
-
-int
-MyImpl::Pulse_Handler::start (CORBA::Long hertz)
-{
- if (hertz == 0 || this->active_ != 0) // Not valid
- {
- return -1;
- }
-
- long usec = 1000000 / hertz;
-
- this->tid_ = this->reactor ()->schedule_timer (this,
- 0,
- ACE_Time_Value (0, usec),
- ACE_Time_Value (0, usec));
-
- this->active_ = 1;
- return 0;
-}
-
-int
-MyImpl::Pulse_Handler::stop (void)
-{
- if (this->active_ == 0) // Not valid.
- {
- return -1;
- }
-
- this->reactor ()->cancel_timer (this);
-
- this->active_ = 0;
- return 0;
-}
-
-int
-MyImpl::Pulse_Handler::active (void)
-{
- return this->active_;
-}
-
-int
-MyImpl::Pulse_Handler::handle_close (ACE_HANDLE handle,
- ACE_Reactor_Mask close_mask)
-{
- if (CIAO::debug_level () > 0)
- {
- ACE_DEBUG ((LM_DEBUG,
- ACE_TEXT ("[%x] handle = %d, close_mask = %d\n"),
- this,
- handle,
- close_mask));
- }
-
- return 0;
-}
-
-int
-MyImpl::Pulse_Handler::handle_timeout (const ACE_Time_Value &,
- const void *)
-{
- this->pulse_callback_->pulse ();
-
-// ACE_DEBUG ((LM_DEBUG,
-// ACE_TEXT ("[%x] with count #%05d timed out at %d.%d!\n"),
-// this,
-// tv.sec (),
-// tv.usec ()));
-
- return 0;
-}
-
-int
-MyImpl::Pulse_Handler::svc (void)
-{
- this->reactor ()->owner (ACE_OS::thr_self ());
-
- while (!this->done_)
- {
- this->reactor ()->handle_events ();
- }
-
- return 0;
-}
-
-//=================================================================
-
-MyImpl::RateGen_exec_i::RateGen_exec_i ()
- : hertz_ (0),
- pulser_ (this)
-{
-
-}
-
-MyImpl::RateGen_exec_i::RateGen_exec_i (CORBA::Long hz)
- : hertz_ (hz),
- pulser_ (this)
-{
-}
-
-MyImpl::RateGen_exec_i::~RateGen_exec_i ()
-{
-}
-
-CORBA::Long
-MyImpl::RateGen_exec_i::hertz (ACE_ENV_SINGLE_ARG_DECL_NOT_USED)
- ACE_THROW_SPEC ((CORBA::SystemException))
-{
- return this->hertz_;
-}
-
-void
-MyImpl::RateGen_exec_i::hertz (CORBA::Long hertz
- ACE_ENV_ARG_DECL_NOT_USED)
- ACE_THROW_SPEC ((CORBA::SystemException))
-{
- this->hertz_ = hertz;
-}
-
-// Operations from supported interface(s)
-
-void
-MyImpl::RateGen_exec_i::start (ACE_ENV_SINGLE_ARG_DECL)
- ACE_THROW_SPEC ((CORBA::SystemException))
-{
- if (this->hertz_ == 0 || this->pulser_.active())
- {
- ACE_THROW (CORBA::BAD_INV_ORDER ());
- }
-
- // @@ Start the rate generator
- this->pulser_.start (this->hertz_);
-}
-
-void
-MyImpl::RateGen_exec_i::stop (ACE_ENV_SINGLE_ARG_DECL)
- ACE_THROW_SPEC ((CORBA::SystemException))
-{
- if (! this->pulser_.active ())
- {
- ACE_THROW (CORBA::BAD_INV_ORDER ());
- }
-
- // @@ stop the rate generator
- this->pulser_.stop ();
-}
-
-CORBA::Boolean
-MyImpl::RateGen_exec_i::active (ACE_ENV_SINGLE_ARG_DECL_NOT_USED)
- ACE_THROW_SPEC ((CORBA::SystemException))
-{
- return this->pulser_.active ();
-}
-
-// Operations from Components::SessionComponent
-
-void
-MyImpl::RateGen_exec_i::set_session_context (
- Components::SessionContext_ptr ctx
- ACE_ENV_ARG_DECL
- )
- ACE_THROW_SPEC ((CORBA::SystemException,
- Components::CCMException))
-{
- if (CIAO::debug_level () > 0)
- {
- ACE_DEBUG ((LM_DEBUG,
- "MyImpl::RateGen_exec_i::set_session_context\n"));
- }
-
- this->context_ =
- HUDisplay::CCM_RateGen_Context::_narrow (ctx
- ACE_ENV_ARG_PARAMETER);
- ACE_CHECK;
-
- if (CORBA::is_nil (this->context_.in ()))
- {
- ACE_THROW (CORBA::INTERNAL ());
- }
- // Urm, we actually discard exceptions thown from this operation.
-
-}
-
-void
-MyImpl::RateGen_exec_i::ciao_preactivate (ACE_ENV_SINGLE_ARG_DECL_NOT_USED)
- ACE_THROW_SPEC ((CORBA::SystemException,
- Components::CCMException))
-{
-}
-
-void
-MyImpl::RateGen_exec_i::ccm_activate (ACE_ENV_SINGLE_ARG_DECL_NOT_USED)
- ACE_THROW_SPEC ((CORBA::SystemException,
- Components::CCMException))
-{
- if (CIAO::debug_level () > 0)
- {
- ACE_DEBUG ((LM_DEBUG,
- "MyImpl::RateGen_exec_i::ccm_activate\n"));
- }
-
- this->pulser_.open_h ();
-}
-
-void
-MyImpl::RateGen_exec_i::ciao_postactivate (ACE_ENV_SINGLE_ARG_DECL_NOT_USED)
- ACE_THROW_SPEC ((CORBA::SystemException,
- Components::CCMException))
-{
-}
-
-void
-MyImpl::RateGen_exec_i::ccm_passivate (ACE_ENV_SINGLE_ARG_DECL_NOT_USED)
- ACE_THROW_SPEC ((CORBA::SystemException,
- Components::CCMException))
-{
- if (CIAO::debug_level () > 0)
- {
- ACE_DEBUG ((LM_DEBUG,
- "MyImpl::RateGen_exec_i::ccm_passivate\n"));
- }
-
- this->pulser_.close_h ();
-}
-
-void
-MyImpl::RateGen_exec_i::ccm_remove (ACE_ENV_SINGLE_ARG_DECL_NOT_USED)
- ACE_THROW_SPEC ((CORBA::SystemException,
- Components::CCMException))
-{
- if (CIAO::debug_level () > 0)
- {
- ACE_DEBUG ((LM_DEBUG,
- "MyImpl::RateGen_exec_i::ccm_remove\n"));
- }
-}
-
-void
-MyImpl::RateGen_exec_i::pulse (void)
-{
- ACE_TRY_NEW_ENV
- {
-// if (CIAO::debug_level () > 0)
-// {
-// ACE_DEBUG ((LM_DEBUG,
-// ACE_TEXT ("Pushing HUDisplay::tick event!\n")));
-// }
-
- HUDisplay::tick_var ev = new OBV_HUDisplay::tick ();
-
- this->context_->push_Pulse (ev.in ()
- ACE_ENV_ARG_PARAMETER);
- ACE_TRY_CHECK;
- }
- ACE_CATCHANY
- {
- // @@ do nothing?
- }
- ACE_ENDTRY;
-
-}
-
-MyImpl::RateGenHome_exec_i::RateGenHome_exec_i ()
-{
-}
-
-MyImpl::RateGenHome_exec_i::~RateGenHome_exec_i ()
-{
-}
-
-::Components::EnterpriseComponent_ptr
-MyImpl::RateGenHome_exec_i::new_RateGen (CORBA::Long /* hertz */
- ACE_ENV_ARG_DECL)
- ACE_THROW_SPEC ((CORBA::SystemException))
-{
- Components::EnterpriseComponent_ptr tmp = 0;
- ACE_NEW_THROW_EX (tmp,
- MyImpl::RateGen_exec_i,
- CORBA::NO_MEMORY ());
- ACE_CHECK_RETURN (tmp);
-
- return tmp;
-}
-
-::Components::EnterpriseComponent_ptr
-MyImpl::RateGenHome_exec_i::create (ACE_ENV_SINGLE_ARG_DECL_NOT_USED)
- ACE_THROW_SPEC ((CORBA::SystemException,
- Components::CCMException))
-{
- return new MyImpl::RateGen_exec_i ();
-}
-
-
-extern "C" RATEGEN_EXEC_Export ::Components::HomeExecutorBase_ptr
-createRateGenHome_Impl (void)
-{
- return new MyImpl::RateGenHome_exec_i ();
-}
View Lorry Controller Status