ACE/ace/Task_T.inl

   1 // -*- C++ -*-
   2 ACE_BEGIN_VERSIONED_NAMESPACE_DECL
   3
   4 template <ACE_SYNCH_DECL, class TIME_POLICY> ACE_INLINE void
   5 ACE_Task<ACE_SYNCH_USE, TIME_POLICY>::water_marks (ACE_IO_Cntl_Msg::ACE_IO_Cntl_Cmds cmd,
   6                                       size_t wm_size)
   7 {
   8   ACE_TRACE ("ACE_Task<ACE_SYNCH_USE, TIME_POLICY>::water_marks");
   9   if (cmd == ACE_IO_Cntl_Msg::SET_LWM)
  10     this->msg_queue_->low_water_mark (wm_size);
  11   else /* cmd == ACE_IO_Cntl_Msg::SET_HWM */
  12     this->msg_queue_->high_water_mark (wm_size);
  13 }
  14
  15 template <ACE_SYNCH_DECL, class TIME_POLICY> ACE_INLINE int
  16 ACE_Task<ACE_SYNCH_USE, TIME_POLICY>::getq (ACE_Message_Block *&mb, ACE_Time_Value *tv)
  17 {
  18   ACE_TRACE ("ACE_Task<ACE_SYNCH_USE, TIME_POLICY>::getq");
  19   return this->msg_queue_->dequeue_head (mb, tv);
  20 }
  21
  22 template <ACE_SYNCH_DECL, class TIME_POLICY> ACE_INLINE int
  23 ACE_Task<ACE_SYNCH_USE, TIME_POLICY>::putq (ACE_Message_Block *mb, ACE_Time_Value *tv)
  24 {
  25   ACE_TRACE ("ACE_Task<ACE_SYNCH_USE, TIME_POLICY>::putq");
  26   return this->msg_queue_->enqueue_tail (mb, tv);
  27 }
  28
  29 template <ACE_SYNCH_DECL, class TIME_POLICY> ACE_INLINE int
  30 ACE_Task<ACE_SYNCH_USE, TIME_POLICY>::ungetq (ACE_Message_Block *mb, ACE_Time_Value *tv)
  31 {
  32   ACE_TRACE ("ACE_Task<ACE_SYNCH_USE, TIME_POLICY>::ungetq");
  33   return this->msg_queue_->enqueue_head (mb, tv);
  34 }
  35
  36 template <ACE_SYNCH_DECL, class TIME_POLICY> ACE_INLINE int
  37 ACE_Task<ACE_SYNCH_USE, TIME_POLICY>::flush (u_long f)
  38 {
  39   ACE_TRACE ("ACE_Task<ACE_SYNCH_USE, TIME_POLICY>::flush");
  40   if (ACE_BIT_ENABLED (f, ACE_Task_Flags::ACE_FLUSHALL))
  41     return this->msg_queue_ != 0 && this->msg_queue_->close ();
  42   else
  43     return -1;   // Note, need to be more careful about what we free...
  44 }
  45
  46 template <ACE_SYNCH_DECL, class TIME_POLICY> ACE_INLINE void
  47 ACE_Task<ACE_SYNCH_USE, TIME_POLICY>::msg_queue (ACE_Message_Queue<ACE_SYNCH_USE, TIME_POLICY> *mq)
  48 {
  49   ACE_TRACE ("ACE_Task<ACE_SYNCH_USE, TIME_POLICY>::msg_queue");
  50   if (this->delete_msg_queue_)
  51     {
  52       delete this->msg_queue_;
  53       this->delete_msg_queue_ = false;
  54     }
  55   this->msg_queue_ = mq;
  56 }
  57
  58 template <ACE_SYNCH_DECL, class TIME_POLICY> ACE_Message_Queue<ACE_SYNCH_USE, TIME_POLICY> *
  59 ACE_Task<ACE_SYNCH_USE, TIME_POLICY>::msg_queue (void)
  60 {
  61   ACE_TRACE ("ACE_Task<ACE_SYNCH_USE, TIME_POLICY>::msg_queue");
  62   return this->msg_queue_;
  63 }
  64
  65 template <ACE_SYNCH_DECL, class TIME_POLICY>
  66 ACE_Time_Value_T<TIME_POLICY>
  67 ACE_Task<ACE_SYNCH_USE, TIME_POLICY>::gettimeofday (void) const
  68 {
  69   if (this->msg_queue_ != 0)
  70     return this->msg_queue_->gettimeofday ();
  71
  72   return ACE_Time_Value_T<TIME_POLICY> (ACE_Time_Value::zero);
  73 }
  74
  75 template <ACE_SYNCH_DECL, class TIME_POLICY>
  76 void
  77 ACE_Task<ACE_SYNCH_USE, TIME_POLICY>::set_time_policy (TIME_POLICY const & rhs)
  78 {
  79   if (this->msg_queue_ != 0)
  80     this->msg_queue_->set_time_policy (rhs);
  81 }
  82
  83 template <ACE_SYNCH_DECL, class TIME_POLICY> ACE_INLINE int
  84 ACE_Task<ACE_SYNCH_USE, TIME_POLICY>::reply (ACE_Message_Block *mb, ACE_Time_Value *tv)
  85 {
  86   ACE_TRACE ("ACE_Task<ACE_SYNCH_USE, TIME_POLICY>::reply");
  87   return this->sibling ()->put_next (mb, tv);
  88 }
  89
  90 template <ACE_SYNCH_DECL, class TIME_POLICY> ACE_INLINE ACE_Task<ACE_SYNCH_USE, TIME_POLICY> *
  91 ACE_Task<ACE_SYNCH_USE, TIME_POLICY>::next (void)
  92 {
  93   ACE_TRACE ("ACE_Task<ACE_SYNCH_USE, TIME_POLICY>::next");
  94   return this->next_;
  95 }
  96
  97 template <ACE_SYNCH_DECL, class TIME_POLICY> ACE_INLINE void
  98 ACE_Task<ACE_SYNCH_USE, TIME_POLICY>::next (ACE_Task<ACE_SYNCH_USE, TIME_POLICY> *q)
  99 {
 100   ACE_TRACE ("ACE_Task<ACE_SYNCH_USE, TIME_POLICY>::next");
 101   this->next_ = q;
 102 }
 103
 104 // Transfer msg to the next ACE_Task.
 105
 106 template <ACE_SYNCH_DECL, class TIME_POLICY> ACE_INLINE int
 107 ACE_Task<ACE_SYNCH_USE, TIME_POLICY>::put_next (ACE_Message_Block *msg, ACE_Time_Value *tv)
 108 {
 109   ACE_TRACE ("ACE_Task<ACE_SYNCH_USE, TIME_POLICY>::put_next");
 110   return this->next_ == 0 ? -1 : this->next_->put (msg, tv);
 111 }
 112
 113 ACE_END_VERSIONED_NAMESPACE_DECL