ACE/ace/Dev_Poll_Reactor.inl

   1 // -*- C++ -*-
   2 #include "ace/Log_Category.h"
   3
   4 ACE_BEGIN_VERSIONED_NAMESPACE_DECL
   5
   6 ACE_INLINE
   7 ACE_Dev_Poll_Reactor::Event_Tuple::Event_Tuple (ACE_Event_Handler *eh,
   8                                                 ACE_Reactor_Mask m,
   9                                                 bool is_suspended,
  10                                                 bool is_controlled)
  11   : event_handler (eh),
  12     mask (m),
  13     suspended (is_suspended),
  14     controlled (is_controlled)
  15 {
  16 }
  17
  18 // ---------------------------------------------------------------------
  19
  20 ACE_INLINE size_t
  21 ACE_Dev_Poll_Reactor::Handler_Repository::size () const
  22 {
  23   ACE_TRACE ("ACE_Dev_Poll_Reactor::Handler_Repository::size");
  24
  25   return this->size_;
  26 }
  27
  28 ACE_INLINE size_t
  29 ACE_Dev_Poll_Reactor::Handler_Repository::max_size () const
  30 {
  31   ACE_TRACE ("ACE_Dev_Poll_Reactor::Handler_Repository::max_size");
  32
  33   return this->max_size_;
  34 }
  35
  36 // -----------------------------------------------------------------
  37
  38 ACE_INLINE
  39 ACE_Dev_Poll_Handler_Guard::ACE_Dev_Poll_Handler_Guard
  40   (ACE_Event_Handler *eh,
  41    bool do_incr)
  42   : eh_ (eh),
  43     refcounted_ (false)
  44 {
  45   if (eh == 0)
  46     return;
  47
  48   this->refcounted_ =
  49     eh->reference_counting_policy ().value () ==
  50     ACE_Event_Handler::Reference_Counting_Policy::ENABLED;
  51
  52   if (do_incr && this->refcounted_)
  53     eh->add_reference ();
  54 }
  55
  56 ACE_INLINE
  57 ACE_Dev_Poll_Handler_Guard::~ACE_Dev_Poll_Handler_Guard ()
  58 {
  59   if (this->refcounted_ && this->eh_ != 0)
  60     this->eh_->remove_reference ();
  61 }
  62
  63 ACE_INLINE void
  64 ACE_Dev_Poll_Handler_Guard::release ()
  65 {
  66   this->eh_ = 0;
  67 }
  68
  69 // ---------------------------------------------------------------------
  70
  71 ACE_INLINE int
  72 ACE_Dev_Poll_Reactor::upcall (ACE_Event_Handler *event_handler,
  73                               int (ACE_Event_Handler::*callback)(ACE_HANDLE),
  74                               ACE_HANDLE handle)
  75 {
  76   // If the handler returns positive value (requesting a reactor
  77   // callback) just call back as many times as the handler requests
  78   // it.  The handler is suspended internally and other threads are off
  79   // handling other things.
  80   int status = 0;
  81
  82   do
  83     {
  84       status = (event_handler->*callback) (handle);
  85     }
  86   while (status > 0 && event_handler != this->notify_handler_);
  87
  88   return status;
  89 }
  90
  91
  92 /************************************************************************/
  93 // Methods for ACE_Dev_Poll_Reactor::Token_Guard
  94 /************************************************************************/
  95
  96 ACE_INLINE
  97 ACE_Dev_Poll_Reactor::Token_Guard::Token_Guard (ACE_Dev_Poll_Reactor_Token &token)
  98
  99   : token_ (token),
 100     owner_ (false)
 101 {
 102 }
 103
 104 ACE_INLINE
 105 ACE_Dev_Poll_Reactor::Token_Guard::~Token_Guard ()
 106 {
 107   if (this->owner_)
 108     {
 109       ACE_MT (this->token_.release ());
 110       this->owner_ = false;
 111     }
 112 }
 113
 114 ACE_INLINE void
 115 ACE_Dev_Poll_Reactor::Token_Guard::release_token ()
 116 {
 117   if (this->owner_)
 118     {
 119       ACE_MT (this->token_.release ());
 120
 121       // We are not the owner anymore..
 122       this->owner_ = false;
 123     }
 124 }
 125
 126 ACE_INLINE bool
 127 ACE_Dev_Poll_Reactor::Token_Guard::is_owner ()
 128 {
 129   return this->owner_;
 130 }
 131
 132 ACE_END_VERSIONED_NAMESPACE_DECL