summaryrefslogtreecommitdiff
path: root/ace/ReactorEx.i
diff options
context:
space:
mode:
Diffstat (limited to 'ace/ReactorEx.i')
-rw-r--r--ace/ReactorEx.i118
1 files changed, 0 insertions, 118 deletions
diff --git a/ace/ReactorEx.i b/ace/ReactorEx.i
deleted file mode 100644
index 1178c0b40ec..00000000000
--- a/ace/ReactorEx.i
+++ /dev/null
@@ -1,118 +0,0 @@
-/* -*- C++ -*- */
-// $Id$
-
-#if defined (ACE_WIN32)
-
-ACE_INLINE int
-ACE_ReactorEx::cancel_timer (ACE_Event_Handler *handler)
-{
- ACE_TRACE ("ACE_ReactorEx::cancel_timer");
- return this->timer_queue_->cancel (handler);
-}
-
-ACE_INLINE int
-ACE_ReactorEx::cancel_timer (int timer_id,
- const void **arg)
-{
- ACE_TRACE ("ACE_ReactorEx::cancel_timer");
- return this->timer_queue_->cancel (timer_id, arg);
-}
-
-ACE_INLINE int
-ACE_ReactorEx::handle_events (ACE_Time_Value &how_long,
- int alertable)
-{
- return this->handle_events (&how_long, alertable);
-}
-
-ACE_INLINE ACE_HANDLE *
-ACE_ReactorEx_Handler_Repository::handles (void) const
-{
- // This code is probably too subtle to be useful in the long run...
- // The basic idea is that all threads wait on all user handles plus
- // the <wakeup_all_threads_> handle. The owner thread additional
- // waits on the <notify_> handle. This is to ensure that only the
- // <owner_> thread get to expire timers and handle event on the
- // notify pipe.
- if (ACE_Thread::self () == this->reactorEx_.owner ())
- return this->current_handles_;
- else
- return this->current_handles_ + 1;
-}
-
-ACE_INLINE ACE_Event_Handler **
-ACE_ReactorEx_Handler_Repository::event_handlers (void) const
-{
- if (ACE_Thread::self () == this->reactorEx_.owner ())
- return this->current_event_handlers_;
- else
- return this->current_event_handlers_ + 1;
-}
-
-ACE_INLINE size_t
-ACE_ReactorEx_Handler_Repository::max_handlep1 (void) const
-{
- if (ACE_Thread::self () == this->reactorEx_.owner ())
- return this->max_handlep1_;
- else
- return this->max_handlep1_ - 1;
-}
-
-ACE_INLINE int
-ACE_ReactorEx_Handler_Repository::scheduled_for_deletion (int index) const
-{
- if (ACE_Thread::self () == this->reactorEx_.owner ())
- return this->to_be_deleted_set_[index] == 1;
- else
- return this->to_be_deleted_set_[index + 1] == 1;
-}
-
-ACE_INLINE int
-ACE_ReactorEx_Handler_Repository::invalid_handle (ACE_HANDLE handle) const
-{
- ACE_TRACE ("ACE_ReactorEx_Handler_Repository::invalid_handle");
- // It's too expensive to perform more exhaustive validity checks on
- // Win32 due to the way that they implement SOCKET HANDLEs.
- if (handle == ACE_INVALID_HANDLE)
- {
- errno = EINVAL;
- return 1;
- }
- else
- return 0;
-}
-
-ACE_INLINE ACE_thread_t
-ACE_ReactorEx::owner (void)
-{
- ACE_GUARD_RETURN (ACE_Process_Mutex, ace_mon, this->lock_, ACE_thread_t (0));
- return this->owner_;
-}
-
-ACE_INLINE void
-ACE_ReactorEx::owner (ACE_thread_t new_owner)
-{
- {
- ACE_GUARD (ACE_Process_Mutex, monitor, this->lock_);
- this->new_owner_ = new_owner;
- }
- // Wake up all threads in WaitForMultipleObjects so that they can
- // reconsult the new owner responsibilities
- this->wakeup_all_threads ();
-}
-
-ACE_INLINE int
-ACE_ReactorEx::new_owner (void)
-{
- return this->new_owner_ != ACE_thread_t (0);
-}
-
-ACE_INLINE int
-ACE_ReactorEx::change_owner (void)
-{
- this->owner_ = this->new_owner_;
- this->new_owner_ = ACE_thread_t (0);
- return 0;
-}
-
-#endif /* ACE_WIN32 */