diff options
Diffstat (limited to 'ace/Select_Reactor_T.inl')
-rw-r--r-- | ace/Select_Reactor_T.inl | 82 |
1 files changed, 36 insertions, 46 deletions
diff --git a/ace/Select_Reactor_T.inl b/ace/Select_Reactor_T.inl index 0ad9033f9a0..136d445810a 100644 --- a/ace/Select_Reactor_T.inl +++ b/ace/Select_Reactor_T.inl @@ -1,22 +1,16 @@ -// -*- C++ -*- -// +/* -*- C++ -*- */ // $Id$ #include "ace/Reactor.h" -#include "ace/Signal.h" -ACE_BEGIN_VERSIONED_NAMESPACE_DECL - -template <class ACE_SELECT_REACTOR_TOKEN> -ACE_INLINE int +template <class ACE_SELECT_REACTOR_TOKEN> /* ACE_INLINE */ int ACE_Select_Reactor_T<ACE_SELECT_REACTOR_TOKEN>::resume_handler (ACE_Event_Handler *h) { ACE_TRACE ("ACE_Select_Reactor_T::resume_handler"); return this->resume_handler (h->get_handle ()); } -template <class ACE_SELECT_REACTOR_TOKEN> -ACE_INLINE int +template <class ACE_SELECT_REACTOR_TOKEN> /* ACE_INLINE */ int ACE_Select_Reactor_T<ACE_SELECT_REACTOR_TOKEN>::resume_handler (const ACE_Handle_Set &handles) { ACE_TRACE ("ACE_Select_Reactor_T::resume_handler"); @@ -32,16 +26,14 @@ ACE_Select_Reactor_T<ACE_SELECT_REACTOR_TOKEN>::resume_handler (const ACE_Handle return 0; } -template <class ACE_SELECT_REACTOR_TOKEN> -ACE_INLINE int +template <class ACE_SELECT_REACTOR_TOKEN> /* ACE_INLINE */ int ACE_Select_Reactor_T<ACE_SELECT_REACTOR_TOKEN>::suspend_handler (ACE_Event_Handler *h) { ACE_TRACE ("ACE_Select_Reactor_T::suspend_handler"); return this->suspend_handler (h->get_handle ()); } -template <class ACE_SELECT_REACTOR_TOKEN> -ACE_INLINE int +template <class ACE_SELECT_REACTOR_TOKEN> /* ACE_INLINE */ int ACE_Select_Reactor_T<ACE_SELECT_REACTOR_TOKEN>::suspend_handler (const ACE_Handle_Set &handles) { ACE_TRACE ("ACE_Select_Reactor_T::suspend_handler"); @@ -57,8 +49,7 @@ ACE_Select_Reactor_T<ACE_SELECT_REACTOR_TOKEN>::suspend_handler (const ACE_Handl return 0; } -template <class ACE_SELECT_REACTOR_TOKEN> -ACE_INLINE int +template <class ACE_SELECT_REACTOR_TOKEN> /* ACE_INLINE */ int ACE_Select_Reactor_T<ACE_SELECT_REACTOR_TOKEN>::register_handler (int signum, ACE_Event_Handler *new_sh, ACE_Sig_Action *new_disp, @@ -73,38 +64,40 @@ ACE_Select_Reactor_T<ACE_SELECT_REACTOR_TOKEN>::register_handler (int signum, #if defined (ACE_WIN32) -template <class ACE_SELECT_REACTOR_TOKEN> -ACE_INLINE int -ACE_Select_Reactor_T<ACE_SELECT_REACTOR_TOKEN>::register_handler (ACE_Event_Handler *, - ACE_HANDLE ) +template <class ACE_SELECT_REACTOR_TOKEN> /* ACE_INLINE */ int +ACE_Select_Reactor_T<ACE_SELECT_REACTOR_TOKEN>::register_handler (ACE_Event_Handler *event_handler, + ACE_HANDLE event_handle) { // Don't have an implementation for this yet... + ACE_UNUSED_ARG (event_handler); + ACE_UNUSED_ARG (event_handle); ACE_NOTSUP_RETURN (-1); } #endif /* ACE_WIN32 */ -template <class ACE_SELECT_REACTOR_TOKEN> -ACE_INLINE int -ACE_Select_Reactor_T<ACE_SELECT_REACTOR_TOKEN>::register_handler (ACE_HANDLE , - ACE_HANDLE , - ACE_Event_Handler *, - ACE_Reactor_Mask ) +template <class ACE_SELECT_REACTOR_TOKEN> /* ACE_INLINE */ int +ACE_Select_Reactor_T<ACE_SELECT_REACTOR_TOKEN>::register_handler (ACE_HANDLE event_handle, + ACE_HANDLE io_handle, + ACE_Event_Handler *event_handler, + ACE_Reactor_Mask mask) { // Don't have an implementation for this yet... + ACE_UNUSED_ARG (event_handle); + ACE_UNUSED_ARG (io_handle); + ACE_UNUSED_ARG (event_handler); + ACE_UNUSED_ARG (mask); ACE_NOTSUP_RETURN (-1); } -template <class ACE_SELECT_REACTOR_TOKEN> -ACE_INLINE int +template <class ACE_SELECT_REACTOR_TOKEN> /* ACE_INLINE */ int ACE_Select_Reactor_T<ACE_SELECT_REACTOR_TOKEN>::handler (int signum, ACE_Event_Handler **handler) { ACE_TRACE ("ACE_Select_Reactor_T::handler"); return this->handler_i (signum, handler); } -template <class ACE_SELECT_REACTOR_TOKEN> -ACE_INLINE int +template <class ACE_SELECT_REACTOR_TOKEN> /* ACE_INLINE */ int ACE_Select_Reactor_T<ACE_SELECT_REACTOR_TOKEN>::remove_handler (int signum, ACE_Sig_Action *new_disp, ACE_Sig_Action *old_disp, @@ -114,8 +107,7 @@ ACE_Select_Reactor_T<ACE_SELECT_REACTOR_TOKEN>::remove_handler (int signum, return this->signal_handler_->remove_handler (signum, new_disp, old_disp, sigkey); } -template <class ACE_SELECT_REACTOR_TOKEN> -ACE_INLINE int +template <class ACE_SELECT_REACTOR_TOKEN> /* ACE_INLINE */ int ACE_Select_Reactor_T<ACE_SELECT_REACTOR_TOKEN>::uses_event_associations (void) { // Since the Select_Reactor does not do any event associations, this @@ -128,7 +120,7 @@ ACE_Select_Reactor_T<ACE_SELECT_REACTOR_TOKEN>::uses_event_associations (void) // Performs operations on the "ready" bits. -template <class ACE_SELECT_REACTOR_TOKEN> ACE_INLINE int +template <class ACE_SELECT_REACTOR_TOKEN> /* ACE_INLINE */ int ACE_Select_Reactor_T<ACE_SELECT_REACTOR_TOKEN>::ready_ops (ACE_Event_Handler *handler, ACE_Reactor_Mask mask, int ops) @@ -139,7 +131,7 @@ ACE_Select_Reactor_T<ACE_SELECT_REACTOR_TOKEN>::ready_ops (ACE_Event_Handler *ha // Performs operations on the "dispatch" masks. -template <class ACE_SELECT_REACTOR_TOKEN> ACE_INLINE int +template <class ACE_SELECT_REACTOR_TOKEN> /* ACE_INLINE */ int ACE_Select_Reactor_T<ACE_SELECT_REACTOR_TOKEN>::mask_ops (ACE_Event_Handler *handler, ACE_Reactor_Mask mask, int ops) @@ -148,7 +140,7 @@ ACE_Select_Reactor_T<ACE_SELECT_REACTOR_TOKEN>::mask_ops (ACE_Event_Handler *han return this->mask_ops (handler->get_handle (), mask, ops); } -template <class ACE_SELECT_REACTOR_TOKEN> ACE_INLINE int +template <class ACE_SELECT_REACTOR_TOKEN> /* ACE_INLINE */ int ACE_Select_Reactor_T<ACE_SELECT_REACTOR_TOKEN>::schedule_wakeup (ACE_Event_Handler *eh, ACE_Reactor_Mask mask) { @@ -156,7 +148,7 @@ ACE_Select_Reactor_T<ACE_SELECT_REACTOR_TOKEN>::schedule_wakeup (ACE_Event_Handl return this->mask_ops (eh->get_handle (), mask, ACE_Reactor::ADD_MASK); } -template <class ACE_SELECT_REACTOR_TOKEN> ACE_INLINE int +template <class ACE_SELECT_REACTOR_TOKEN> /* ACE_INLINE */ int ACE_Select_Reactor_T<ACE_SELECT_REACTOR_TOKEN>::cancel_wakeup (ACE_Event_Handler *eh, ACE_Reactor_Mask mask) { @@ -164,7 +156,7 @@ ACE_Select_Reactor_T<ACE_SELECT_REACTOR_TOKEN>::cancel_wakeup (ACE_Event_Handler return this->mask_ops (eh->get_handle (), mask, ACE_Reactor::CLR_MASK); } -template <class ACE_SELECT_REACTOR_TOKEN> ACE_INLINE int +template <class ACE_SELECT_REACTOR_TOKEN> /* ACE_INLINE */ int ACE_Select_Reactor_T<ACE_SELECT_REACTOR_TOKEN>::schedule_wakeup (ACE_HANDLE handle, ACE_Reactor_Mask mask) { @@ -172,7 +164,7 @@ ACE_Select_Reactor_T<ACE_SELECT_REACTOR_TOKEN>::schedule_wakeup (ACE_HANDLE hand return this->mask_ops (handle, mask, ACE_Reactor::ADD_MASK); } -template <class ACE_SELECT_REACTOR_TOKEN> ACE_INLINE int +template <class ACE_SELECT_REACTOR_TOKEN> /* ACE_INLINE */ int ACE_Select_Reactor_T<ACE_SELECT_REACTOR_TOKEN>::cancel_wakeup (ACE_HANDLE handle, ACE_Reactor_Mask mask) { @@ -180,14 +172,14 @@ ACE_Select_Reactor_T<ACE_SELECT_REACTOR_TOKEN>::cancel_wakeup (ACE_HANDLE handle return this->mask_ops (handle, mask, ACE_Reactor::CLR_MASK); } -template <class ACE_SELECT_REACTOR_TOKEN> ACE_INLINE ACE_Lock & +template <class ACE_SELECT_REACTOR_TOKEN> /* ACE_INLINE */ ACE_Lock & ACE_Select_Reactor_T<ACE_SELECT_REACTOR_TOKEN>::lock (void) { ACE_TRACE ("ACE_Select_Reactor_T::lock"); return this->lock_adapter_; } -template <class ACE_SELECT_REACTOR_TOKEN> ACE_INLINE void +template <class ACE_SELECT_REACTOR_TOKEN> /* ACE_INLINE */ void ACE_Select_Reactor_T<ACE_SELECT_REACTOR_TOKEN>::wakeup_all_threads (void) { // Send a notification, but don't block if there's no one to receive @@ -195,25 +187,25 @@ ACE_Select_Reactor_T<ACE_SELECT_REACTOR_TOKEN>::wakeup_all_threads (void) this->notify (0, ACE_Event_Handler::NULL_MASK, (ACE_Time_Value *) &ACE_Time_Value::zero); } -template <class ACE_SELECT_REACTOR_TOKEN> ACE_INLINE int +template <class ACE_SELECT_REACTOR_TOKEN> /* ACE_INLINE */ int ACE_Select_Reactor_T<ACE_SELECT_REACTOR_TOKEN>::alertable_handle_events (ACE_Time_Value *max_wait_time) { return this->handle_events (max_wait_time); } -template <class ACE_SELECT_REACTOR_TOKEN> ACE_INLINE int +template <class ACE_SELECT_REACTOR_TOKEN> /* ACE_INLINE */ int ACE_Select_Reactor_T<ACE_SELECT_REACTOR_TOKEN>::alertable_handle_events (ACE_Time_Value &max_wait_time) { return this->handle_events (max_wait_time); } -template <class ACE_SELECT_REACTOR_TOKEN> ACE_INLINE int +template <class ACE_SELECT_REACTOR_TOKEN> /* ACE_INLINE */ int ACE_Select_Reactor_T<ACE_SELECT_REACTOR_TOKEN>::deactivated (void) { return this->deactivated_; } -template <class ACE_SELECT_REACTOR_TOKEN> ACE_INLINE void +template <class ACE_SELECT_REACTOR_TOKEN> /* ACE_INLINE */ void ACE_Select_Reactor_T<ACE_SELECT_REACTOR_TOKEN>::deactivate (int do_stop) { { @@ -226,10 +218,8 @@ ACE_Select_Reactor_T<ACE_SELECT_REACTOR_TOKEN>::deactivate (int do_stop) this->wakeup_all_threads (); } -template <class ACE_SELECT_REACTOR_TOKEN> ACE_INLINE size_t +template <class ACE_SELECT_REACTOR_TOKEN> /* ACE_INLINE */ size_t ACE_Select_Reactor_T<ACE_SELECT_REACTOR_TOKEN>::size (void) const { return this->handler_rep_.size (); } - -ACE_END_VERSIONED_NAMESPACE_DECL |