diff options
Diffstat (limited to 'CIAO/examples/BasicSP/EC/EC_exec.cpp')
| -rw-r--r-- | CIAO/examples/BasicSP/EC/EC_exec.cpp | 296 |
1 files changed, 0 insertions, 296 deletions
diff --git a/CIAO/examples/BasicSP/EC/EC_exec.cpp b/CIAO/examples/BasicSP/EC/EC_exec.cpp deleted file mode 100644 index 52929f35378..00000000000 --- a/CIAO/examples/BasicSP/EC/EC_exec.cpp +++ /dev/null @@ -1,296 +0,0 @@ -// $Id$ - -#include "EC_exec.h" -#include "CIAO_common.h" -#include "ace/Timer_Queue.h" -#include "ace/Reactor.h" - -//================================================================= - -MyImpl::timeout_Handler::timeout_Handler (MyImpl::EC_exec_i *cb) - : active_ (0), - done_ (0), - tid_ (0), - pulse_callback_ (cb) -{ - // Nothing - this->reactor (new ACE_Reactor); -} - -MyImpl::timeout_Handler::~timeout_Handler () -{ - delete this->reactor (); - this->reactor (0); -} - -int -MyImpl::timeout_Handler::open_h () -{ - return this->activate (); -} - -int -MyImpl::timeout_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::timeout_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::timeout_Handler::stop (void) -{ - if (this->active_ == 0) // Not valid. - return -1; - - this->reactor ()->cancel_timer (this); - - this->active_ = 0; - return 0; -} - -int -MyImpl::timeout_Handler::active (void) -{ - return this->active_; -} - -int -MyImpl::timeout_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::timeout_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::timeout_Handler::svc (void) -{ - this->reactor ()->owner (ACE_OS::thr_self ()); - - while (!this->done_) - this->reactor ()->handle_events (); - - return 0; -} - -//================================================================= - -MyImpl::EC_exec_i::EC_exec_i () - : hertz_ (0), - pulser_ (this) -{ - -} - -MyImpl::EC_exec_i::EC_exec_i (CORBA::Long hz) - : hertz_ (hz), - pulser_ (this) -{ -} - -MyImpl::EC_exec_i::~EC_exec_i () -{ -} - -CORBA::Long -MyImpl::EC_exec_i::hertz () -{ - return this->hertz_; -} - -void -MyImpl::EC_exec_i::hertz (CORBA::Long hertz) -{ - this->hertz_ = hertz; -} - -// Operations from supported interface(s) - -void -MyImpl::EC_exec_i::start () -{ - if (this->hertz_ == 0 || this->pulser_.active()) - throw CORBA::BAD_INV_ORDER (); - - // @@ Start the rate generator - this->pulser_.start (this->hertz_); -} - -void -MyImpl::EC_exec_i::stop () -{ - if (! this->pulser_.active ()) - throw CORBA::BAD_INV_ORDER (); - - // @@ stop the rate generator - this->pulser_.stop (); -} - -CORBA::Boolean -MyImpl::EC_exec_i::active () -{ - return this->pulser_.active (); -} - -// Operations from Components::SessionComponent - -void -MyImpl::EC_exec_i::set_session_context (Components::SessionContext_ptr ctx) -{ - if (CIAO::debug_level () > 0) - ACE_DEBUG ((LM_DEBUG, "MyImpl::EC_exec_i::set_session_context\n")); - - this->context_ = - BasicSP::CCM_EC_Context::_narrow (ctx); - - if (CORBA::is_nil (this->context_.in ())) - throw CORBA::INTERNAL (); - // Urm, we actually discard exceptions thown from this operation. - -} - -void -MyImpl::EC_exec_i::ciao_preactivate () -{ -} - -void -MyImpl::EC_exec_i::ccm_activate () -{ - if (CIAO::debug_level () > 0) - ACE_DEBUG ((LM_DEBUG, "MyImpl::EC_exec_i::ccm_activate\n")); - - this->pulser_.open_h (); -} - -void -MyImpl::EC_exec_i::ciao_postactivate () -{ -} - -void -MyImpl::EC_exec_i::ccm_passivate () -{ - if (CIAO::debug_level () > 0) - ACE_DEBUG ((LM_DEBUG, "MyImpl::EC_exec_i::ccm_passivate\n")); - this->pulser_.close_h (); -} - -void -MyImpl::EC_exec_i::ccm_remove () -{ - if (CIAO::debug_level () > 0) - ACE_DEBUG ((LM_DEBUG, "MyImpl::EC_exec_i::ccm_remove\n")); -} - -void -MyImpl::EC_exec_i::pulse (void) -{ - try - { - if (CIAO::debug_level () > 0) - ACE_DEBUG ((LM_DEBUG, - ACE_TEXT ("Pushing BasicSP::TimeOut event!\n"))); - - BasicSP::TimeOut_var ev = new OBV_BasicSP::TimeOut (); - - this->context_->push_timeout (ev.in ()); - } - catch (const CORBA::Exception& ex) - { - ex._tao_print_exception ("Caught exception while pushing " - "BasicSP::TimeOut event to BMDevice"); - } -} - -MyImpl::ECHome_exec_i::ECHome_exec_i () -{ -} - -MyImpl::ECHome_exec_i::~ECHome_exec_i () -{ -} - -::Components::EnterpriseComponent_ptr -MyImpl::ECHome_exec_i::new_EC (CORBA::Long hertz) -{ - ::Components::EnterpriseComponent_ptr retval = - ::Components::EnterpriseComponent::_nil (); - - ACE_NEW_THROW_EX ( - retval, - MyImpl::EC_exec_i (hertz), - ::CORBA::NO_MEMORY ()); - - return retval; -} - -::Components::EnterpriseComponent_ptr -MyImpl::ECHome_exec_i::create () -{ - ::Components::EnterpriseComponent_ptr retval = - ::Components::EnterpriseComponent::_nil (); - - ACE_NEW_THROW_EX ( - retval, - MyImpl::EC_exec_i, - ::CORBA::NO_MEMORY ()); - - return retval; -} - -extern "C" EC_EXEC_Export ::Components::HomeExecutorBase_ptr -create_BasicSP_ECHome_Impl (void) -{ - ::Components::HomeExecutorBase_ptr retval = - ::Components::HomeExecutorBase::_nil (); - - ACE_NEW_RETURN ( - retval, - MyImpl::ECHome_exec_i, - ::Components::HomeExecutorBase::_nil ()); - - return retval; -} |