summaryrefslogtreecommitdiff
path: root/ace/WIN32_Proactor.cpp
diff options
context:
space:
mode:
authorJohnny Willemsen <jwillemsen@remedy.nl>2002-05-27 06:13:52 +0000
committerJohnny Willemsen <jwillemsen@remedy.nl>2002-05-27 06:13:52 +0000
commit8b011a0913b34ea9cfda2dff5f8070a0d47111e2 (patch)
tree24f8060f1bfb6a3330d590eccb658e81adce8fc8 /ace/WIN32_Proactor.cpp
parent4806b74282a2de20eea69b327b10bbfd03f56360 (diff)
downloadATCD-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.cpp30
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()