00001
00002
00003
00004 #include "ace/Reactor.h"
00005
00006 ACE_INLINE
00007 ACE_Event_Tuple::~ACE_Event_Tuple (void)
00008 {
00009 }
00010
00011 ACE_INLINE
00012 ACE_Select_Reactor_Notify::~ACE_Select_Reactor_Notify (void)
00013 {
00014 }
00015
00016 ACE_INLINE
00017 ACE_Select_Reactor_Handler_Repository::~ACE_Select_Reactor_Handler_Repository (void)
00018 {
00019 }
00020
00021 ACE_INLINE
00022 ACE_Select_Reactor_Handler_Repository_Iterator::~ACE_Select_Reactor_Handler_Repository_Iterator (void)
00023 {
00024 }
00025
00026 ACE_INLINE size_t
00027 ACE_Select_Reactor_Handler_Repository::size (void) const
00028 {
00029 return this->max_size_;
00030 }
00031
00032 ACE_INLINE
00033 ACE_Event_Tuple::ACE_Event_Tuple (void)
00034 : handle_ (ACE_INVALID_HANDLE),
00035 event_handler_ (0)
00036 {
00037 }
00038
00039 ACE_INLINE
00040 ACE_Event_Tuple::ACE_Event_Tuple (ACE_Event_Handler* eh,
00041 ACE_HANDLE h)
00042 : handle_ (h),
00043 event_handler_ (eh)
00044 {
00045 }
00046
00047 ACE_INLINE int
00048 ACE_Event_Tuple::operator== (const ACE_Event_Tuple &rhs) const
00049 {
00050 return this->handle_ == rhs.handle_;
00051 }
00052
00053 ACE_INLINE int
00054 ACE_Event_Tuple::operator!= (const ACE_Event_Tuple &rhs) const
00055 {
00056 return !(*this == rhs);
00057 }
00058
00059 ACE_INLINE
00060 ACE_Select_Reactor_Impl::ACE_Select_Reactor_Impl ()
00061 : handler_rep_ (*this),
00062 timer_queue_ (0),
00063 delete_timer_queue_ (0),
00064 delete_signal_handler_ (0),
00065 delete_notify_handler_ (0),
00066 requeue_position_ (-1),
00067 initialized_ (0),
00068 state_changed_ (0),
00069 supress_renew_ (0)
00070 {
00071 }
00072
00073 ACE_INLINE int
00074 ACE_Select_Reactor_Impl::purge_pending_notifications (ACE_Event_Handler *eh,
00075 ACE_Reactor_Mask mask)
00076 {
00077 if (this->notify_handler_ == 0)
00078 return 0;
00079 else
00080 return this->notify_handler_->purge_pending_notifications (eh, mask);
00081 }
00082
00083 ACE_INLINE int
00084 ACE_Select_Reactor_Impl::supress_notify_renew (void)
00085 {
00086 return this->supress_renew_;
00087 }
00088
00089 ACE_INLINE void
00090 ACE_Select_Reactor_Impl::supress_notify_renew (int sr)
00091 {
00092 this->supress_renew_ = sr;
00093 }