diff options
author | nobody <nobody@ae88bc3d-4319-0410-8dbf-d08b4c9d3795> | 1997-11-25 22:18:58 +0000 |
---|---|---|
committer | nobody <nobody@ae88bc3d-4319-0410-8dbf-d08b4c9d3795> | 1997-11-25 22:18:58 +0000 |
commit | 7a5fe8ce23ac50450b804cf0183c773565ae7cef (patch) | |
tree | 220a38a6627619d1386897d42757a140b9de448f /ace/Proactor.cpp | |
parent | 87b0987cad99cf45cd5d9e03cd1cefbaaec4ef2a (diff) | |
download | ATCD-ACE-4_4.tar.gz |
This commit was manufactured by cvs2svn to create branch 'ACE-4_4'.ACE-4_4
Diffstat (limited to 'ace/Proactor.cpp')
-rw-r--r-- | ace/Proactor.cpp | 31 |
1 files changed, 4 insertions, 27 deletions
diff --git a/ace/Proactor.cpp b/ace/Proactor.cpp index 77d923194f4..a7f1f3c199b 100644 --- a/ace/Proactor.cpp +++ b/ace/Proactor.cpp @@ -49,10 +49,6 @@ class ACE_Export ACE_Proactor_Timer_Handler : public ACE_Task <ACE_NULL_SYNCH> public: ACE_Proactor_Timer_Handler (ACE_Proactor &proactor); - // Constructor - - ~ACE_Proactor_Timer_Handler (void); - // Destructor protected: virtual int svc (void); @@ -65,40 +61,21 @@ protected: ACE_Proactor &proactor_; // Proactor - - int shutting_down_; - // Flag used to indicate when we are shutting down. }; ACE_Proactor_Timer_Handler::ACE_Proactor_Timer_Handler (ACE_Proactor &proactor) - : ACE_Task <ACE_NULL_SYNCH> (&proactor.thr_mgr_), - proactor_ (proactor), - shutting_down_ (0) + : proactor_ (proactor), + ACE_Task <ACE_NULL_SYNCH> (&proactor.thr_mgr_) { } -ACE_Proactor_Timer_Handler::~ACE_Proactor_Timer_Handler (void) -{ - // Mark for closing down - this->shutting_down_ = 1; - - // Signal timer event - this->timer_event_.signal (); - - // Don't bother to wait (since the thread may have already - // gone). But make sure to close up the descriptor. This may not be - // necessary in the future when THR_DETACHED is correctly - // implemented. - this->thr_mgr ()->close (0); -} - int ACE_Proactor_Timer_Handler::svc (void) { u_long time; ACE_Time_Value absolute_time; - for (; !this->shutting_down_;) + for (;;) { // default value time = INFINITE; @@ -249,7 +226,7 @@ ACE_Proactor::ACE_Proactor (size_t number_of_threads, ACE_NEW (this->timer_handler_, ACE_Proactor_Timer_Handler (*this)); // activate <timer_handler> - if (this->timer_handler_->activate (THR_NEW_LWP | THR_DETACHED) == -1) + if (this->timer_handler_->activate () == -1) ACE_ERROR ((LM_ERROR, "%p Could not create thread\n", "Task::activate")); } |