ACE/ace/Local_Tokens.inl

   1 // -*- C++ -*-
   2 #if defined (ACE_HAS_TOKENS_LIBRARY)
   3
   4 ACE_BEGIN_VERSIONED_NAMESPACE_DECL
   5
   6 // ************************************************************
   7
   8 ACE_INLINE int
   9 ACE_Token_Proxy_Queue::size ()
  10 {
  11   ACE_TRACE ("ACE_Token_Proxy_Queue::size");
  12   return this->size_;
  13 }
  14
  15 // ************************************************************
  16
  17 ACE_INLINE int
  18 ACE_TPQ_Entry::waiting () const
  19 {
  20   ACE_TRACE ("ACE_TPQ_Entry::waiting");
  21   return waiting_;
  22 }
  23
  24 ACE_INLINE void
  25 ACE_TPQ_Entry::waiting (int v)
  26 {
  27   ACE_TRACE ("ACE_TPQ_Entry::waiting");
  28   waiting_ = v;
  29 }
  30
  31 ACE_INLINE const ACE_TCHAR *
  32 ACE_TPQ_Entry::client_id () const
  33 {
  34   ACE_TRACE ("ACE_TPQ_Entry::client_id");
  35   return this->client_id_;
  36 }
  37
  38 ACE_INLINE ACE_Token_Proxy *
  39 ACE_TPQ_Entry::proxy () const
  40 {
  41   ACE_TRACE ("ACE_TPQ_Entry::proxy");
  42   return this->proxy_;
  43 }
  44
  45 ACE_INLINE void
  46 ACE_TPQ_Entry::proxy (ACE_Token_Proxy *proxy)
  47 {
  48   ACE_TRACE ("ACE_TPQ_Entry::proxy");
  49   this->proxy_ = proxy;
  50 }
  51
  52 ACE_INLINE void
  53 ACE_Tokens::remove (ACE_TPQ_Entry *caller)
  54 {
  55   this->waiters_.remove (caller);
  56 }
  57
  58 ACE_INLINE int
  59 ACE_Tokens::dec_reference ()
  60 {
  61   ACE_TRACE ("ACE_Tokens::dec_reference");
  62   if (this->reference_count_ == 0)
  63     {
  64       ACELIB_DEBUG ((LM_DEBUG,  ACE_TEXT ("dec_reference already zero")));
  65       return 0;
  66     }
  67
  68   return --this->reference_count_;
  69 }
  70
  71 ACE_INLINE void
  72 ACE_Tokens::inc_reference ()
  73 {
  74   ACE_TRACE ("ACE_Tokens::inc_reference");
  75   ++this->reference_count_;
  76 }
  77
  78 ACE_INLINE const ACE_TPQ_Entry *
  79 ACE_Token_Proxy_Queue::head ()
  80 {
  81   ACE_TRACE ("ACE_Token_Proxy_Queue::head");
  82   if (this->head_ == 0)
  83     return 0;
  84   else
  85     return this->head_;
  86 }
  87
  88 // **************************************************
  89
  90 ACE_INLINE void
  91 ACE_Tokens::visit (int v)
  92 {
  93   ACE_TRACE ("ACE_Tokens::visit");
  94   visited_ = v;
  95 }
  96
  97 ACE_INLINE int
  98 ACE_Tokens::visited ()
  99 {
 100   ACE_TRACE ("ACE_Tokens::visited");
 101   return visited_;
 102 }
 103
 104 ACE_INLINE ACE_TPQ_Entry *
 105 ACE_Tokens::owner ()
 106 {
 107   ACE_TRACE ("ACE_Tokens::owner");
 108   return (ACE_TPQ_Entry *) this->waiters_.head ();
 109 }
 110
 111 ACE_INLINE const ACE_TCHAR*
 112 ACE_Tokens::owner_id ()
 113 {
 114   ACE_TRACE ("ACE_Tokens::owner_id");
 115   if (this->owner () == 0)
 116     return ACE_TEXT ("no owner");
 117   else
 118     return this->owner ()->client_id ();
 119 }
 120
 121 ACE_INLINE const ACE_TCHAR*
 122 ACE_Tokens::name ()
 123 {
 124   ACE_TRACE ("ACE_Tokens::name");
 125   return this->token_name_;
 126 }
 127
 128 // ************************************************************
 129
 130 ACE_INLINE int
 131 ACE_TPQ_Entry::nesting_level () const
 132 {
 133   ACE_TRACE ("ACE_TPQ_Entry::nesting_level");
 134   return this->nesting_level_;
 135 }
 136
 137 ACE_INLINE void
 138 ACE_TPQ_Entry::nesting_level (int delta)
 139 {
 140   ACE_TRACE ("ACE_TPQ_Entry::nesting_level");
 141   this->nesting_level_ += delta;
 142 }
 143
 144 ACE_INLINE ACE_TPQ_Entry::PTVF
 145 ACE_TPQ_Entry::sleep_hook () const
 146 {
 147   ACE_TRACE ("ACE_TPQ_Entry::sleep_hook");
 148   return this->sleep_hook_;
 149 }
 150
 151 ACE_INLINE void
 152 ACE_TPQ_Entry::sleep_hook (void (*sh)(void *))
 153 {
 154   ACE_TRACE ("ACE_TPQ_Entry::sleep_hook");
 155   this->sleep_hook_ = sh;
 156 }
 157
 158 ACE_INLINE void
 159 ACE_TPQ_Entry::call_sleep_hook ()
 160 {
 161   ACE_TRACE ("ACE_TPQ_Entry::call_sleep_hook");
 162
 163   // if a function has been registered, call it.
 164   if (this->sleep_hook () != 0)
 165     this->sleep_hook () ((void *) this->proxy ());
 166   else
 167     // otherwise, call back the sleep_hook method
 168     this->proxy ()->sleep_hook ();
 169 }
 170
 171 ACE_INLINE int
 172 ACE_TPQ_Entry::equal_client_id (const ACE_TCHAR *id)
 173 {
 174   ACE_TRACE ("ACE_TPQ_Entry::equal_client_id");
 175   return (ACE_OS::strcmp (this->client_id (), id) == 0);
 176 }
 177
 178 // ************************************************************
 179
 180 ACE_INLINE
 181 ACE_Local_Mutex::ACE_Local_Mutex (const ACE_TCHAR *token_name,
 182                                   int ignore_deadlock,
 183                                   int debug)
 184 {
 185   ACE_TRACE ("ACE_Local_Mutex::ACE_Local_Mutex");
 186   this->open (token_name, ignore_deadlock, debug);
 187 }
 188
 189 ACE_INLINE void
 190 ACE_Token_Name::name (const ACE_TCHAR *new_name)
 191 {
 192   ACE_TRACE ("ACE_Token_Name::name");
 193
 194   if (new_name == 0)
 195     new_name = ACE_TEXT ("no name");
 196
 197   size_t n = ACE_OS::strlen (new_name) + 1;
 198
 199   if (n >= ACE_MAXTOKENNAMELEN)
 200     n = ACE_MAXTOKENNAMELEN - 1;
 201
 202   ACE_OS::strsncpy (this->token_name_, (ACE_TCHAR *) new_name, n);
 203 }
 204
 205 ACE_INLINE const ACE_TCHAR*
 206 ACE_Token_Name::name () const
 207 {
 208   ACE_TRACE ("ACE_Token_Name::name");
 209   return this->token_name_;
 210 }
 211
 212 // ************************************************************
 213
 214 ACE_INLINE
 215 ACE_Local_RLock::ACE_Local_RLock (const ACE_TCHAR *token_name,
 216                                   int ignore_deadlock,
 217                                   int debug)
 218 {
 219   ACE_TRACE ("ACE_Local_RLock::ACE_Local_RLock");
 220   this->open (token_name, ignore_deadlock, debug);
 221 }
 222
 223 // ************************************************************
 224
 225 ACE_INLINE
 226 ACE_Local_WLock::ACE_Local_WLock (const ACE_TCHAR *token_name,
 227                                   int ignore_deadlock,
 228                                   int debug)
 229 {
 230   ACE_TRACE ("ACE_Local_WLock::ACE_Local_WLock");
 231   this->open (token_name, ignore_deadlock, debug);
 232 }
 233
 234 // ************************************************************
 235
 236
 237 ACE_INLINE void
 238 ACE_Token_Name::operator= (const ACE_Token_Name &rhs)
 239 {
 240   ACE_TRACE ("ACE_Token_Name::operator=");
 241   if (&rhs != this)
 242   {
 243     this->name (rhs.name ());
 244   }
 245 }
 246
 247 ACE_INLINE bool
 248 ACE_Token_Name::operator== (const ACE_Token_Name &rhs) const
 249 {
 250   ACE_TRACE ("ACE_Token_Name::operator==");
 251
 252   // the name and type must be the same
 253   return (ACE_OS::strcmp (this->token_name_, rhs.name ()) == 0);
 254 }
 255
 256 ACE_END_VERSIONED_NAMESPACE_DECL
 257
 258 #endif /* ACE_HAS_TOKENS_LIBRARY */