ACE/ace/TP_Reactor.inl

   1 // -*- C++ -*-
   2 ACE_BEGIN_VERSIONED_NAMESPACE_DECL
   3
   4 /************************************************************************/
   5 // Methods for ACE_EH_Dispatch_Info
   6 /************************************************************************/
   7
   8 ACE_INLINE
   9 ACE_EH_Dispatch_Info::ACE_EH_Dispatch_Info () :
  10   handle_ (ACE_INVALID_HANDLE),
  11   event_handler_ (0),
  12   mask_ (ACE_Event_Handler::NULL_MASK),
  13   callback_ (0),
  14   resume_flag_ (ACE_Event_Handler::ACE_REACTOR_RESUMES_HANDLER),
  15   reference_counting_required_ (false),
  16   dispatch_ (false)
  17 {
  18 }
  19
  20 ACE_INLINE void
  21 ACE_EH_Dispatch_Info::set (ACE_HANDLE handle,
  22                            ACE_Event_Handler *event_handler,
  23                            ACE_Reactor_Mask mask,
  24                            ACE_EH_PTMF callback)
  25 {
  26   this->dispatch_ = true;
  27
  28   this->handle_ = handle;
  29   this->event_handler_ = event_handler;
  30   this->mask_ = mask;
  31   this->callback_ = callback;
  32   if (event_handler_)
  33     {
  34       this->resume_flag_ = event_handler->resume_handler ();
  35       this->reference_counting_required_ =
  36         (event_handler_->reference_counting_policy ().value () ==
  37          ACE_Event_Handler::Reference_Counting_Policy::ENABLED);
  38     }
  39   else
  40     this->dispatch_ = false;
  41 }
  42
  43 ACE_INLINE bool
  44 ACE_EH_Dispatch_Info::dispatch () const
  45 {
  46   return this->dispatch_;
  47 }
  48
  49 /************************************************************************/
  50 // Methods for ACE_TP_Token_Guard
  51 /************************************************************************/
  52
  53 ACE_INLINE
  54 ACE_TP_Token_Guard::ACE_TP_Token_Guard (ACE_Select_Reactor_Token &token)
  55   : token_ (token),
  56     owner_ (false)
  57 {
  58 }
  59
  60 ACE_INLINE
  61 ACE_TP_Token_Guard::~ACE_TP_Token_Guard ()
  62 {
  63   if (this->owner_)
  64     {
  65       ACE_MT (this->token_.release ());
  66       this->owner_ = false;
  67     }
  68 }
  69
  70 ACE_INLINE void
  71 ACE_TP_Token_Guard::release_token ()
  72 {
  73   if (this->owner_)
  74     {
  75       ACE_MT (this->token_.release ());
  76
  77       // We are not the owner anymore..
  78       this->owner_ = false;
  79     }
  80 }
  81
  82 ACE_INLINE bool
  83 ACE_TP_Token_Guard::is_owner ()
  84 {
  85   return this->owner_;
  86 }
  87
  88
  89 /************************************************************************/
  90 // Methods for ACE_TP_Reactor
  91 /************************************************************************/
  92
  93 ACE_INLINE void
  94 ACE_TP_Reactor::no_op_sleep_hook (void *)
  95 {
  96 }
  97
  98 ACE_INLINE void
  99 ACE_TP_Reactor::clear_handle_read_set (ACE_HANDLE handle)
 100 {
 101   this->ready_set_.wr_mask_.clr_bit (handle);
 102   this->ready_set_.ex_mask_.clr_bit (handle);
 103   this->ready_set_.rd_mask_.clr_bit (handle);
 104 }
 105
 106 ACE_INLINE void
 107 ACE_TP_Reactor::clear_dispatch_mask (ACE_HANDLE ,
 108                                      ACE_Reactor_Mask )
 109 {
 110   this->ready_set_.rd_mask_.reset ();
 111   this->ready_set_.wr_mask_.reset ();
 112   this->ready_set_.ex_mask_.reset ();
 113 }
 114
 115 ACE_END_VERSIONED_NAMESPACE_DECL