summaryrefslogtreecommitdiff
path: root/ace
diff options
context:
space:
mode:
authorJohnny Willemsen <jwillemsen@remedy.nl>2006-04-19 12:34:24 +0000
committerJohnny Willemsen <jwillemsen@remedy.nl>2006-04-19 12:34:24 +0000
commita350edeacb31a0a1af3110048c494f938d93436e (patch)
tree90eda563e9191882521746db29df6701bc3f6a5d /ace
parentbb45149f24cac5f0bddae7112855652108458fe6 (diff)
downloadATCD-a350edeacb31a0a1af3110048c494f938d93436e.tar.gz
ChangeLogTag: Wed Apr 19 11:39:12 UTC 2006 Johnny Willemsen <jwillemsen@remedy.nl>
Diffstat (limited to 'ace')
-rw-r--r--ace/Proactor.h110
-rw-r--r--ace/Thread_Manager.h23
-rw-r--r--ace/Thread_Mutex.h14
3 files changed, 74 insertions, 73 deletions
diff --git a/ace/Proactor.h b/ace/Proactor.h
index ad88b4ee36b..2b5f6f750d1 100644
--- a/ace/Proactor.h
+++ b/ace/Proactor.h
@@ -51,7 +51,7 @@ class ACE_Proactor_Timer_Handler;
* This class implements the functor required by the Timer
* Queue to call <handle_timeout> on ACE_Handlers.
*/
-class ACE_Export ACE_Proactor_Handle_Timeout_Upcall
+class ACE_Proactor_Handle_Timeout_Upcall
{
/// Type def for the timer queue.
@@ -187,8 +187,8 @@ public:
int delete_implementation = 0,
TIMER_QUEUE *tq = 0);
- /// Virtual destruction.
- virtual ~ACE_Proactor (void);
+ /// Destruction.
+ ~ACE_Proactor (void);
/// Get pointer to a process-wide <ACE_Proactor>. <threads> should
/// be part of another method.
@@ -254,7 +254,7 @@ public:
* If @arg delete_implementation was specified to the @c open() method,
* the implementation object is also deleted.
*/
- virtual int close (void);
+ int close (void);
/**
* You can add a hook to various run_event methods and the hook will
@@ -271,7 +271,7 @@ public:
* <ACE_Proactor::handle_events>
* method returns -1 or the <end_proactor_event_loop> method is invoked.
*/
- virtual int proactor_run_event_loop (PROACTOR_EVENT_HOOK = 0);
+ int proactor_run_event_loop (PROACTOR_EVENT_HOOK = 0);
/**
* Run the event loop until the <ACE_Proactor::handle_events>
@@ -280,28 +280,28 @@ public:
* or the <ACE_Time_Value>
* expires, in which case a 0 is returned.
*/
- virtual int proactor_run_event_loop (ACE_Time_Value &tv,
- PROACTOR_EVENT_HOOK = 0);
+ int proactor_run_event_loop (ACE_Time_Value &tv,
+ PROACTOR_EVENT_HOOK = 0);
/**
* Instruct the ACE_Proactor to terminate its event loop
* and notifies the ACE_Proactor so that it can wake up
* and close down gracefully.
*/
- virtual int proactor_end_event_loop (void);
+ int proactor_end_event_loop (void);
/// Report if the ACE_Proactor event loop is finished.
- virtual int proactor_event_loop_done (void);
+ int proactor_event_loop_done (void);
/// Resets the <ACE_Proactor::end_event_loop_> static so that the
/// <run_event_loop> method can be restarted.
- virtual int proactor_reset_event_loop (void);
+ int proactor_reset_event_loop (void);
/// This method adds the <handle> to the I/O completion port. This
/// function is a no-op function for Unix systems and returns 0;
- virtual int register_handle (ACE_HANDLE handle,
- const void *completion_key);
+ int register_handle (ACE_HANDLE handle,
+ const void *completion_key);
// = Timer management.
/**
@@ -315,28 +315,28 @@ public:
* with accidentally deleting the wrong timer. Returns -1 on
* failure (which is guaranteed never to be a valid <timer_id>).
*/
- virtual long schedule_timer (ACE_Handler &handler,
- const void *act,
- const ACE_Time_Value &time);
+ long schedule_timer (ACE_Handler &handler,
+ const void *act,
+ const ACE_Time_Value &time);
- virtual long schedule_repeating_timer (ACE_Handler &handler,
- const void *act,
- const ACE_Time_Value &interval);
+ long schedule_repeating_timer (ACE_Handler &handler,
+ const void *act,
+ const ACE_Time_Value &interval);
// Same as above except <interval> it is used to reschedule the
// <handler> automatically.
/// This combines the above two methods into one. Mostly for backward
/// compatibility.
- virtual long schedule_timer (ACE_Handler &handler,
- const void *act,
- const ACE_Time_Value &time,
- const ACE_Time_Value &interval);
+ long schedule_timer (ACE_Handler &handler,
+ const void *act,
+ const ACE_Time_Value &time,
+ const ACE_Time_Value &interval);
/// Cancel all timers associated with this <handler>. Returns number
/// of timers cancelled.
- virtual int cancel_timer (ACE_Handler &handler,
- int dont_call_handle_close = 1);
+ int cancel_timer (ACE_Handler &handler,
+ int dont_call_handle_close = 1);
/**
* Cancel the single <ACE_Handler> that matches the <timer_id> value
@@ -347,9 +347,9 @@ public:
* Returns 1 if cancellation succeeded and 0 if the <timer_id>
* wasn't found.
*/
- virtual int cancel_timer (long timer_id,
- const void **act = 0,
- int dont_call_handle_close = 1);
+ int cancel_timer (long timer_id,
+ const void **act = 0,
+ int dont_call_handle_close = 1);
/**
* Dispatch a single set of events, waiting up to a specified time limit
@@ -361,14 +361,14 @@ public:
* Returns 1 when a completion is dispatched. On error, returns -1
* and sets errno accordingly.
*/
- virtual int handle_events (ACE_Time_Value &wait_time);
+ int handle_events (ACE_Time_Value &wait_time);
/**
* Block indefinitely until at least one event is dispatched.
* @return Returns 1 when a completion is dispatched. On error, returns -1
* and sets errno accordingly.
*/
- virtual int handle_events (void);
+ int handle_events (void);
/// Add wakeup dispatch threads (reinit).
int wake_up_dispatch_threads (void);
@@ -393,10 +393,10 @@ public:
* It is a no-op in POSIX platforms and it returns
* ACE_INVALID_HANDLE.
*/
- virtual ACE_HANDLE get_handle (void) const;
+ ACE_HANDLE get_handle (void) const;
/// Get the implementation class.
- virtual ACE_Proactor_Impl *implementation (void) const;
+ ACE_Proactor_Impl *implementation (void) const;
// = Factory methods for the operations
@@ -405,37 +405,37 @@ public:
/// Create the correct implementation class for doing
/// Asynch_Read_Stream.
- virtual ACE_Asynch_Read_Stream_Impl *create_asynch_read_stream (void);
+ ACE_Asynch_Read_Stream_Impl *create_asynch_read_stream (void);
/// Create the correct implementation class for doing
/// Asynch_Write_Stream.
- virtual ACE_Asynch_Write_Stream_Impl *create_asynch_write_stream (void);
+ ACE_Asynch_Write_Stream_Impl *create_asynch_write_stream (void);
/// Create the correct implementation class for doing
/// Asynch_Read_File.
- virtual ACE_Asynch_Read_File_Impl *create_asynch_read_file (void);
+ ACE_Asynch_Read_File_Impl *create_asynch_read_file (void);
/// Create the correct implementation class for doing
/// Asynch_Write_File.
- virtual ACE_Asynch_Write_File_Impl *create_asynch_write_file (void);
+ ACE_Asynch_Write_File_Impl *create_asynch_write_file (void);
/// Create the correct implementation class for doing Asynch_Accept.
- virtual ACE_Asynch_Accept_Impl *create_asynch_accept (void);
+ ACE_Asynch_Accept_Impl *create_asynch_accept (void);
/// Create the correct implementation class for doing Asynch_Connect.
- virtual ACE_Asynch_Connect_Impl *create_asynch_connect (void);
+ ACE_Asynch_Connect_Impl *create_asynch_connect (void);
/// Create the correct implementation class for doing
/// Asynch_Transmit_File.
- virtual ACE_Asynch_Transmit_File_Impl *create_asynch_transmit_file (void);
+ ACE_Asynch_Transmit_File_Impl *create_asynch_transmit_file (void);
/// Create the correct implementation class for doing
/// Asynch_Read_Dgram.
- virtual ACE_Asynch_Read_Dgram_Impl *create_asynch_read_dgram (void);
+ ACE_Asynch_Read_Dgram_Impl *create_asynch_read_dgram (void);
/// Create the correct implementation class for doing
/// Asynch_Write_Dgram.
- virtual ACE_Asynch_Write_Dgram_Impl *create_asynch_write_dgram (void);
+ ACE_Asynch_Write_Dgram_Impl *create_asynch_write_dgram (void);
// = Factory methods for the results
@@ -444,7 +444,7 @@ public:
/// Create the correct implementation class for
/// ACE_Asynch_Read_Stream::Result class.
- virtual ACE_Asynch_Read_Stream_Result_Impl *
+ ACE_Asynch_Read_Stream_Result_Impl *
create_asynch_read_stream_result (ACE_Handler::Proxy_Ptr &handler_proxy,
ACE_HANDLE handle,
ACE_Message_Block &message_block,
@@ -456,7 +456,7 @@ public:
/// Create the correct implementation class for
/// ACE_Asynch_Write_Stream::Result.
- virtual ACE_Asynch_Write_Stream_Result_Impl *
+ ACE_Asynch_Write_Stream_Result_Impl *
create_asynch_write_stream_result (ACE_Handler::Proxy_Ptr &handler_proxy,
ACE_HANDLE handle,
ACE_Message_Block &message_block,
@@ -468,7 +468,7 @@ public:
/// Create the correct implementation class for
/// ACE_Asynch_Read_File::Result.
- virtual ACE_Asynch_Read_File_Result_Impl *
+ ACE_Asynch_Read_File_Result_Impl *
create_asynch_read_file_result (ACE_Handler::Proxy_Ptr &handler_proxy,
ACE_HANDLE handle,
ACE_Message_Block &message_block,
@@ -482,7 +482,7 @@ public:
/// Create the correct implementation class for
/// ACE_Asynch_Write_File::Result.
- virtual ACE_Asynch_Write_File_Result_Impl *
+ ACE_Asynch_Write_File_Result_Impl *
create_asynch_write_file_result (ACE_Handler::Proxy_Ptr &handler_proxy,
ACE_HANDLE handle,
ACE_Message_Block &message_block,
@@ -496,7 +496,7 @@ public:
/// Create the correct implementation class for
/// ACE_Asynch_Read_Dgram::Result.
- virtual ACE_Asynch_Read_Dgram_Result_Impl *
+ ACE_Asynch_Read_Dgram_Result_Impl *
create_asynch_read_dgram_result (ACE_Handler::Proxy_Ptr &handler_proxy,
ACE_HANDLE handle,
ACE_Message_Block *message_block,
@@ -510,7 +510,7 @@ public:
/// Create the correct implementation class for
/// ACE_Asynch_Write_Dgram::Result.
- virtual ACE_Asynch_Write_Dgram_Result_Impl *
+ ACE_Asynch_Write_Dgram_Result_Impl *
create_asynch_write_dgram_result (ACE_Handler::Proxy_Ptr &handler_proxy,
ACE_HANDLE handle,
ACE_Message_Block *message_block,
@@ -522,7 +522,7 @@ public:
int signal_number = ACE_SIGRTMIN);
/// Create the correct implementation class for ACE_Asynch_Accept::Result.
- virtual ACE_Asynch_Accept_Result_Impl *
+ ACE_Asynch_Accept_Result_Impl *
create_asynch_accept_result (ACE_Handler::Proxy_Ptr &handler_proxy,
ACE_HANDLE listen_handle,
ACE_HANDLE accept_handle,
@@ -534,7 +534,7 @@ public:
int signal_number = ACE_SIGRTMIN);
/// Create the correct implementation class for ACE_Asynch_Connect::Result
- virtual ACE_Asynch_Connect_Result_Impl *
+ ACE_Asynch_Connect_Result_Impl *
create_asynch_connect_result (ACE_Handler::Proxy_Ptr &handler_proxy,
ACE_HANDLE connect_handle,
const void* act,
@@ -544,7 +544,7 @@ public:
/// Create the correct implementation class for
/// ACE_Asynch_Transmit_File::Result.
- virtual ACE_Asynch_Transmit_File_Result_Impl *
+ ACE_Asynch_Transmit_File_Result_Impl *
create_asynch_transmit_file_result (ACE_Handler::Proxy_Ptr &handler_proxy,
ACE_HANDLE socket,
ACE_HANDLE file,
@@ -566,7 +566,7 @@ public:
* Timer object with a meaningful signal number, choosing the
* largest signal number from the signal mask of the Proactor.
*/
- virtual ACE_Asynch_Result_Impl *
+ ACE_Asynch_Result_Impl *
create_asynch_timer (ACE_Handler::Proxy_Ptr &handler_proxy,
const void *act,
const ACE_Time_Value &tv,
@@ -588,10 +588,10 @@ protected:
* threads can wake up. This is used in conjunction with the
* <proactor_run_event_loop>.
*/
- virtual int proactor_post_wakeup_completions (int how_many);
+ int proactor_post_wakeup_completions (int how_many);
/// Set the implementation class.
- virtual void implementation (ACE_Proactor_Impl *implementation);
+ void implementation (ACE_Proactor_Impl *implementation);
/// Delegation/implementation class that all methods will be
/// forwarded to.
@@ -656,9 +656,9 @@ public:
class Timer_Queue {};
ACE_Proactor (size_t /* number_of_threads */ = 0,
Timer_Queue * /* tq */ = 0) {}
- virtual ~ACE_Proactor (void) {}
- virtual int handle_events (void) { return -1; }
- virtual int handle_events (ACE_Time_Value &) { return -1; }
+ ~ACE_Proactor (void) {}
+ int handle_events (void) { return -1; }
+ int handle_events (ACE_Time_Value &) { return -1; }
/// Placeholder to enable compilation on non-Win32 platforms
static ACE_Proactor *instance (size_t threads = 0);
diff --git a/ace/Thread_Manager.h b/ace/Thread_Manager.h
index 1e08642c58b..c42f7959f25 100644
--- a/ace/Thread_Manager.h
+++ b/ace/Thread_Manager.h
@@ -450,7 +450,7 @@ public:
size_t lwm = ACE_DEFAULT_THREAD_MANAGER_LWM,
size_t inc = ACE_DEFAULT_THREAD_MANAGER_INC,
size_t hwm = ACE_DEFAULT_THREAD_MANAGER_HWM);
- virtual ~ACE_Thread_Manager (void);
+ ~ACE_Thread_Manager (void);
#if ! defined (ACE_THREAD_MANAGER_LACKS_STATICS)
/// Get pointer to a process-wide <ACE_Thread_Manager>.
@@ -981,16 +981,17 @@ protected:
ACE_Thread_Descriptor *hthread_descriptor (ACE_hthread_t);
/// Create a new thread (must be called with locks held).
- virtual int spawn_i (ACE_THR_FUNC func,
- void *arg,
- long flags,
- ACE_thread_t * = 0,
- ACE_hthread_t *t_handle = 0,
- long priority = ACE_DEFAULT_THREAD_PRIORITY,
- int grp_id = -1,
- void *stack = 0,
- size_t stack_size = 0,
- ACE_Task_Base *task = 0);
+ int spawn_i (ACE_THR_FUNC func,
+ void *arg,
+ long flags,
+ ACE_thread_t * = 0,
+ ACE_hthread_t *t_handle = 0,
+ long priority = ACE_DEFAULT_THREAD_PRIORITY,
+ int grp_id = -1,
+ void *stack = 0,
+ size_t stack_size = 0,
+ ACE_Task_Base *task = 0);
+
/// Run the registered hooks when the thread exits.
void run_thread_exit_hooks (int i);
diff --git a/ace/Thread_Mutex.h b/ace/Thread_Mutex.h
index 5b1877fb82c..4da040a3296 100644
--- a/ace/Thread_Mutex.h
+++ b/ace/Thread_Mutex.h
@@ -78,7 +78,7 @@ public:
int acquire (ACE_Time_Value &tv);
/**
- * If <tv> == 0 the call <acquire()> directly. Otherwise, Block the
+ * If @a tv == 0 the call <acquire()> directly. Otherwise, Block the
* thread until we acquire the mutex or until <tv> times out, in
* which case -1 is returned with <errno> == <ETIME>. Note that
* <*tv> is assumed to be in "absolute" rather than "relative" time.
@@ -99,21 +99,21 @@ public:
/**
* Acquire mutex ownership. This calls <acquire> and is only here
- * to make the <ACE_Thread_Mutex> interface consistent with the
+ * to make the ACE_Thread_Mutex interface consistent with the
* other synchronization APIs.
*/
int acquire_read (void);
/**
* Acquire mutex ownership. This calls <acquire> and is only here
- * to make the <ACE_Thread_Mutex> interface consistent with the
+ * to make the ACE_Thread_Mutex interface consistent with the
* other synchronization APIs.
*/
int acquire_write (void);
/**
* Conditionally acquire mutex (i.e., won't block). This calls
- * <tryacquire> and is only here to make the <ACE_Thread_Mutex>
+ * <tryacquire> and is only here to make the ACE_Thread_Mutex
* interface consistent with the other synchronization APIs.
* Returns -1 on failure. If we "failed" because someone else
* already had the lock, <errno> is set to <EBUSY>.
@@ -122,7 +122,7 @@ public:
/**
* Conditionally acquire mutex (i.e., won't block). This calls
- * <tryacquire> and is only here to make the <ACE_Thread_Mutex>
+ * <tryacquire> and is only here to make the ACE_Thread_Mutex
* interface consistent with the other synchronization APIs.
* Returns -1 on failure. If we "failed" because someone else
* already had the lock, <errno> is set to <EBUSY>.
@@ -130,7 +130,7 @@ public:
int tryacquire_write (void);
/**
- * This is only here to make the <ACE_Thread_Mutex>
+ * This is only here to make the ACE_Thread_Mutex
* interface consistent with the other synchronization APIs.
* Assumes the caller has already acquired the mutex using one of
* the above calls, and returns 0 (success) always.
@@ -169,7 +169,7 @@ private:
*
* @brief This data structure is meant to be used within a method or
* function... It performs automatic aquisition and release of
- * an <ACE_Thread_Mutex>.
+ * an ACE_Thread_Mutex.
*
* This class is obsolete and should be replaced by
* ACE_Guard<ACE_Thread_Mutex>.