ACE/ace/Task.inl

   1 // -*- C++ -*-
   2 ACE_BEGIN_VERSIONED_NAMESPACE_DECL
   3
   4 // Get the current group id.
   5 ACE_INLINE int
   6 ACE_Task_Base::grp_id () const
   7 {
   8   ACE_TRACE ("ACE_Task_Base::grp_id");
   9   return this->grp_id_;
  10 }
  11
  12 // Set the current group id.
  13
  14 ACE_INLINE void
  15 ACE_Task_Base::grp_id (int identifier)
  16 {
  17   ACE_TRACE ("ACE_Task_Base::grp_id");
  18   ACE_MT (ACE_GUARD (ACE_Thread_Mutex, ace_mon, this->lock_));
  19
  20   // Cache the group id in the task and then set it in the
  21   // Thread_Manager, if there is one.
  22   this->grp_id_ = identifier;
  23   if (this->thr_mgr ())
  24     this->thr_mgr ()->set_grp (this, identifier);
  25 }
  26
  27 ACE_INLINE ACE_Thread_Manager *
  28 ACE_Task_Base::thr_mgr () const
  29 {
  30   ACE_TRACE ("ACE_Task_Base::thr_mgr");
  31   return this->thr_mgr_;
  32 }
  33
  34 ACE_INLINE void
  35 ACE_Task_Base::thr_mgr (ACE_Thread_Manager *thr_mgr)
  36 {
  37   ACE_TRACE ("ACE_Task_Base::thr_mgr");
  38   this->thr_mgr_ = thr_mgr;
  39 }
  40
  41 ACE_INLINE int
  42 ACE_Task_Base::is_reader () const
  43 {
  44   ACE_TRACE ("ACE_Task_Base::is_reader");
  45   return (ACE_BIT_ENABLED (this->flags_, ACE_Task_Flags::ACE_READER));
  46 }
  47
  48 ACE_INLINE int
  49 ACE_Task_Base::is_writer () const
  50 {
  51   ACE_TRACE ("ACE_Task_Base::is_writer");
  52   return (ACE_BIT_DISABLED (this->flags_, ACE_Task_Flags::ACE_READER));
  53 }
  54
  55 // Return the count of the current number of threads.
  56 ACE_INLINE size_t
  57 ACE_Task_Base::thr_count () const
  58 {
  59   ACE_TRACE ("ACE_Task_Base::thr_count");
  60   ACE_MT (ACE_GUARD_RETURN (ACE_Thread_Mutex, ace_mon, this->lock_, 0));
  61
  62   return this->thr_count_;
  63 }
  64
  65 // Return the thread ID of the last thread to exit svc().
  66 ACE_INLINE ACE_thread_t
  67 ACE_Task_Base::last_thread () const
  68 {
  69   ACE_TRACE ("ACE_Task_Base::last_thread");
  70   return this->last_thread_id_;
  71 }
  72
  73 ACE_END_VERSIONED_NAMESPACE_DECL