Adding file containing inlined functions

1 files changed, 79 insertions, 0 deletions

diff --git a/ACE/ace/MT_Priority_Reactor.inl b/ACE/ace/MT_Priority_Reactor.inl
new file mode 100644
index 00000000000..9dafdcdc7a8
--- /dev/null
+++ b/ACE/ace/MT_Priority_Reactor.inl
@@ -0,0 +1,79 @@
+// -*- C++ -*-
+//
+// $Id$
+
+ACE_BEGIN_VERSIONED_NAMESPACE_DECL
+
+/************************************************************************/
+// Methods for ACE_Handle_Dispatch_Info
+/************************************************************************/
+
+ACE_INLINE
+ACE_Handle_Dispatch_Info::ACE_Handle_Dispatch_Info (void) :
+  handle_ (ACE_INVALID_HANDLE),
+  event_handler_ (0),
+  mask_ (ACE_Event_Handler::NULL_MASK),
+  callback_ (0),
+  resume_flag_ (ACE_Event_Handler::ACE_REACTOR_RESUMES_HANDLER),
+  reference_counting_required_ (false),
+  dispatch_ (false)
+{
+}
+
+ACE_INLINE void
+ACE_Handle_Dispatch_Info::set (ACE_HANDLE handle,
+                           ACE_Event_Handler *event_handler,
+                           ACE_Reactor_Mask mask,
+                           ACE_EH_PTMF callback)
+{
+  this->dispatch_ = true;
+
+  this->handle_ = handle;
+  this->event_handler_ = event_handler;
+  this->mask_ = mask;
+  this->callback_ = callback;
+  if (event_handler_)
+    {
+      this->resume_flag_ = event_handler->resume_handler ();
+      this->reference_counting_required_ =
+        (event_handler_->reference_counting_policy ().value () ==
+         ACE_Event_Handler::Reference_Counting_Policy::ENABLED);
+    }
+  else
+    this->dispatch_ = false;
+}
+
+ACE_INLINE bool
+ACE_Handle_Dispatch_Info::dispatch (void) const
+{
+  return this->dispatch_;
+}
+
+
+/************************************************************************/
+// Methods for ACE_MT_Priority_Reactor
+/************************************************************************/
+
+ACE_INLINE void
+ACE_MT_Priority_Reactor::no_op_sleep_hook (void *)
+{
+}
+
+ACE_INLINE void
+ACE_MT_Priority_Reactor::clear_read_set (ACE_HANDLE handle)
+{
+  this->ready_set_.wr_mask_.clr_bit (handle);
+  this->ready_set_.ex_mask_.clr_bit (handle);
+  this->ready_set_.rd_mask_.clr_bit (handle);
+}
+
+ACE_INLINE void
+ACE_MT_Priority_Reactor::clear_dispatch_mask (ACE_HANDLE ,
+                                     ACE_Reactor_Mask )
+{
+  this->ready_set_.rd_mask_.reset ();
+  this->ready_set_.wr_mask_.reset ();
+  this->ready_set_.ex_mask_.reset ();
+}
+
+ACE_END_VERSIONED_NAMESPACE_DECL