diff options
author | Johnny Willemsen <jwillemsen@remedy.nl> | 2002-05-27 06:13:52 +0000 |
---|---|---|
committer | Johnny Willemsen <jwillemsen@remedy.nl> | 2002-05-27 06:13:52 +0000 |
commit | 8b011a0913b34ea9cfda2dff5f8070a0d47111e2 (patch) | |
tree | 24f8060f1bfb6a3330d590eccb658e81adce8fc8 /ace/WIN32_Proactor.cpp | |
parent | 4806b74282a2de20eea69b327b10bbfd03f56360 (diff) | |
download | ATCD-8b011a0913b34ea9cfda2dff5f8070a0d47111e2.tar.gz |
ChangeLogTag: Mon May 27 07:53:12 2002 Johnny Willemsen <jwillemsen@remedy.nl>
Diffstat (limited to 'ace/WIN32_Proactor.cpp')
-rw-r--r-- | ace/WIN32_Proactor.cpp | 30 |
1 files changed, 16 insertions, 14 deletions
diff --git a/ace/WIN32_Proactor.cpp b/ace/WIN32_Proactor.cpp index a26c164430b..fd043bda4de 100644 --- a/ace/WIN32_Proactor.cpp +++ b/ace/WIN32_Proactor.cpp @@ -10,30 +10,32 @@ #include "ace/Log_Msg.h" #include "ace/Object_Manager.h" +/** + * @class ACE_WIN32_Wakeup_Completion + * + * This is result object is used by the <end_event_loop> of the + * ACE_Proactor interface to wake up all the threads blocking + * for completions. + */ class ACE_Export ACE_WIN32_Wakeup_Completion : public ACE_WIN32_Asynch_Result { - // = TITLE - // This is result object is used by the <end_event_loop> of the - // ACE_Proactor interface to wake up all the threads blocking - // for completions. public: + /// Constructor. ACE_WIN32_Wakeup_Completion (ACE_Handler &handler, const void *act = 0, ACE_HANDLE event = ACE_INVALID_HANDLE, int priority = 0, int signal_number = ACE_SIGRTMIN); - // Constructor. + /// Destructor. virtual ~ACE_WIN32_Wakeup_Completion (void); - // Destructor. - + /// This method calls the <handler>'s <handle_wakeup> method. virtual void complete (u_long bytes_transferred = 0, int success = 1, const void *completion_key = 0, u_long error = 0); - // This method calls the <handler>'s <handle_wakeup> method. }; ACE_WIN32_Proactor::ACE_WIN32_Proactor (size_t number_of_threads, @@ -596,15 +598,15 @@ ACE_WIN32_Proactor::handle_events (unsigned long milli_seconds) // during shared_read/shared_write. // The real error code is already stored in "errno", // so copy "errno" value to the "result_err" - // and pass this "result_err" code + // and pass this "result_err" code // to the application_specific_code () - // else + // else // "result_err" non zero // it means we have "post_completed" result - // so pass this "result_err" code + // so pass this "result_err" code // to the application_specific_code () - if ( result_err == 0 ) + if ( result_err == 0 ) result_err = errno ; this->application_specific_code (asynch_result, @@ -649,9 +651,9 @@ ACE_WIN32_Proactor::post_completion (ACE_WIN32_Asynch_Result *result) handle != 0) ACE_OS::event_signal (&handle); - // pass + // pass // bytes_transferred - // completion_key + // completion_key // to the ::PostQueuedCompletionStatus() // error will be extracted later in handle_events() |