TAO/tao/Transport.inl

   1 // -*- C++ -*-
   2 TAO_BEGIN_VERSIONED_NAMESPACE_DECL
   3
   4 ACE_INLINE bool
   5 TAO_Transport::queue_is_empty_i () const
   6 {
   7   return (this->head_ == 0);
   8 }
   9
  10 ACE_INLINE CORBA::ULong
  11 TAO_Transport::tag () const
  12 {
  13   return this->tag_;
  14 }
  15
  16 ACE_INLINE TAO_ORB_Core *
  17 TAO_Transport::orb_core () const
  18 {
  19   return this->orb_core_;
  20 }
  21
  22 ACE_INLINE TAO_Transport_Mux_Strategy *
  23 TAO_Transport::tms () const
  24 {
  25   return tms_;
  26 }
  27
  28 // Return the Wait strategy used by the Transport.
  29 ACE_INLINE TAO_Wait_Strategy *
  30 TAO_Transport::wait_strategy () const
  31 {
  32   return this->ws_;
  33 }
  34
  35 ACE_INLINE int
  36 TAO_Transport::bidirectional_flag () const
  37 {
  38   return this->bidirectional_flag_;
  39 }
  40
  41 ACE_INLINE void
  42 TAO_Transport::bidirectional_flag (int flag)
  43 {
  44   this->bidirectional_flag_ = flag;
  45 }
  46
  47 ACE_INLINE TAO::Connection_Role
  48 TAO_Transport::opened_as () const
  49 {
  50   return this->opening_connection_role_;
  51 }
  52
  53 ACE_INLINE void
  54 TAO_Transport::opened_as (TAO::Connection_Role role)
  55 {
  56   this->opening_connection_role_ = role;
  57 }
  58
  59 ACE_INLINE TAO::Transport_Cache_Manager::HASH_MAP_ENTRY *
  60 TAO_Transport::cache_map_entry ()
  61 {
  62   return this->cache_map_entry_;
  63 }
  64
  65 ACE_INLINE void
  66 TAO_Transport::cache_map_entry (
  67     TAO::Transport_Cache_Manager::HASH_MAP_ENTRY *entry)
  68 {
  69   // Sync with TAO_Transport::purge_entry()
  70   ACE_GUARD (ACE_Lock, ace_mon, *this->handler_lock_);
  71   this->cache_map_entry_ = entry;
  72 }
  73
  74 ACE_INLINE unsigned long
  75 TAO_Transport::purging_order () const
  76 {
  77   return this->purging_order_;
  78 }
  79
  80 ACE_INLINE void
  81 TAO_Transport::purging_order (unsigned long value)
  82 {
  83   // This should only be called by the Transport Cache Manager when
  84   // it is holding it's lock.
  85   // The transport should still be here since the cache manager still
  86   // has a reference to it.
  87   this->purging_order_ = value;
  88 }
  89
  90 ACE_INLINE size_t
  91 TAO_Transport::id () const
  92 {
  93   return this->id_;
  94 }
  95
  96 ACE_INLINE void
  97 TAO_Transport::id (size_t id)
  98 {
  99   this->id_ = id;
 100 }
 101
 102 ACE_INLINE bool
 103 TAO_Transport::queue_is_empty ()
 104 {
 105   ACE_GUARD_RETURN (ACE_Lock,
 106                     ace_mon,
 107                     *this->handler_lock_,
 108                     false);
 109   return this->queue_is_empty_i ();
 110 }
 111
 112 ACE_INLINE int
 113 TAO_Transport::flush_timer_pending () const
 114 {
 115   return this->flush_timer_id_ != -1;
 116 }
 117
 118 ACE_INLINE void
 119 TAO_Transport::reset_flush_timer ()
 120 {
 121   this->flush_timer_id_ = -1;
 122   this->current_deadline_ = ACE_Time_Value::zero;
 123 }
 124
 125 ACE_INLINE TAO_GIOP_Message_Base *
 126 TAO_Transport::messaging_object ()
 127 {
 128   return this->messaging_object_;
 129 }
 130
 131 //********************************************************************
 132 // codeset related methods
 133
 134
 135 ACE_INLINE TAO_Codeset_Translator_Base *
 136 TAO_Transport::char_translator () const
 137 {
 138   return this->char_translator_;
 139 }
 140
 141 ACE_INLINE TAO_Codeset_Translator_Base *
 142 TAO_Transport::wchar_translator () const
 143 {
 144   return this->wchar_translator_;
 145 }
 146
 147 ACE_INLINE void
 148 TAO_Transport::char_translator (TAO_Codeset_Translator_Base *tf)
 149 {
 150   this->char_translator_ = tf;
 151   this->tcs_set_ = 1;
 152 }
 153
 154 ACE_INLINE void
 155 TAO_Transport::wchar_translator (TAO_Codeset_Translator_Base *tf)
 156 {
 157   this->wchar_translator_ = tf;
 158   this->tcs_set_ = 1;
 159 }
 160
 161 /// CodeSet negotiation
 162 ACE_INLINE CORBA::Boolean
 163 TAO_Transport::is_tcs_set() const
 164 {
 165   return tcs_set_;
 166 }
 167
 168 ACE_INLINE void
 169 TAO_Transport::first_request_sent (bool flag)
 170 {
 171   this->first_request_ = flag;
 172 }
 173
 174 ACE_INLINE bool
 175 TAO_Transport::first_request () const
 176 {
 177   return this->first_request_;
 178 }
 179
 180 ACE_INLINE bool
 181 TAO_Transport::is_connected () const
 182 {
 183   ACE_GUARD_RETURN (ACE_Lock, ace_mon, *this->handler_lock_, false);
 184   return this->is_connected_;
 185 }
 186
 187 ACE_INLINE TAO_Connection_Handler *
 188 TAO_Transport::connection_handler ()
 189 {
 190   return this->connection_handler_i();
 191 }
 192
 193 ACE_INLINE size_t
 194 TAO_Transport::recv_buffer_size () const
 195 {
 196   return this->recv_buffer_size_;
 197 }
 198
 199 ACE_INLINE size_t
 200 TAO_Transport::sent_byte_count () const
 201 {
 202   return this->sent_byte_count_;
 203 }
 204
 205 #if TAO_HAS_TRANSPORT_CURRENT == 1
 206
 207 ACE_INLINE TAO::Transport::Stats*
 208 TAO_Transport::stats () const
 209 {
 210   return this->stats_;
 211 }
 212
 213 ACE_INLINE
 214 TAO::Transport::Stats::Stats ()
 215   : messages_rcvd_ (0)
 216   , messages_sent_ (0)
 217   , bytes_rcvd_()
 218   , bytes_sent_ ()
 219   , opened_since_ ()
 220 {
 221 }
 222
 223 ACE_INLINE void
 224 TAO::Transport::Stats::messages_sent (size_t message_length)
 225 {
 226   ACE_GUARD (TAO_SYNCH_MUTEX, ace_mon, this->stat_mutex_);
 227
 228   ++this->messages_sent_;
 229   this->bytes_sent_.sample (message_length);
 230 }
 231
 232 ACE_INLINE CORBA::LongLong
 233 TAO::Transport::Stats::messages_sent () const
 234 {
 235   ACE_GUARD_RETURN (TAO_SYNCH_MUTEX, ace_mon, this->stat_mutex_, 0);
 236
 237   return this->messages_sent_;
 238 }
 239
 240 ACE_INLINE CORBA::LongLong
 241 TAO::Transport::Stats::bytes_sent () const
 242 {
 243   ACE_GUARD_RETURN (TAO_SYNCH_MUTEX, ace_mon, this->stat_mutex_, 0);
 244
 245   return this->bytes_sent_.sum_;
 246 }
 247
 248 ACE_INLINE void
 249 TAO::Transport::Stats::messages_received (size_t message_length)
 250 {
 251   ACE_GUARD (TAO_SYNCH_MUTEX, ace_mon, this->stat_mutex_);
 252
 253   ++this->messages_rcvd_;
 254   this->bytes_rcvd_.sample (message_length);
 255 }
 256
 257 ACE_INLINE CORBA::LongLong
 258 TAO::Transport::Stats::messages_received () const
 259 {
 260   ACE_GUARD_RETURN (TAO_SYNCH_MUTEX, ace_mon, this->stat_mutex_, 0);
 261
 262   return this->messages_rcvd_;
 263 }
 264
 265 ACE_INLINE CORBA::LongLong
 266 TAO::Transport::Stats::bytes_received () const
 267 {
 268   ACE_GUARD_RETURN (TAO_SYNCH_MUTEX, ace_mon, this->stat_mutex_, 0);
 269
 270   return this->bytes_rcvd_.sum_;
 271 }
 272
 273 ACE_INLINE void
 274 TAO::Transport::Stats::opened_since (const ACE_Time_Value& tv)
 275 {
 276   ACE_GUARD (TAO_SYNCH_MUTEX, ace_mon, this->stat_mutex_);
 277
 278   this->opened_since_ = tv;
 279 }
 280
 281 ACE_INLINE const ACE_Time_Value&
 282 TAO::Transport::Stats::opened_since () const
 283 {
 284   ACE_GUARD_RETURN (TAO_SYNCH_MUTEX, ace_mon, this->stat_mutex_, ACE_Time_Value::zero);
 285
 286   return this->opened_since_;
 287 }
 288
 289 #endif /* TAO_HAS_TRANSPORT_CURRENT == 1 */
 290
 291 ACE_INLINE int
 292 TAO_Transport::notify_reactor ()
 293 {
 294   if (!this->ws_->is_registered ())
 295     {
 296       return 0;
 297     }
 298
 299   return this->notify_reactor_now ();
 300 }
 301
 302 TAO_END_VERSIONED_NAMESPACE_DECL