TAO/tao/TransportCurrent/Current_Impl.cpp

   1 /* -*- C++ -*- */
   2
   3 /**
   4  * @file Current_Impl.cpp
   5  *
   6  * @author Iliyan Jeliazkov <iliyan@ociweb.com>
   7  */
   8
   9 #include "tao/Transport.h"
  10
  11 #if TAO_HAS_TRANSPORT_CURRENT == 1
  12
  13 #include "tao/Transport_Selection_Guard.h"
  14 #include "tao/TransportCurrent/Current_Loader.h"
  15 #include "tao/TransportCurrent/Current_Impl.h"
  16
  17 TAO_BEGIN_VERSIONED_NAMESPACE_DECL
  18
  19 namespace TAO
  20 {
  21   namespace Transport
  22   {
  23     /// ctor
  24     Current_Impl::Current_Impl (TAO_ORB_Core* core, size_t tss_slot_id)
  25       : core_ (core)
  26       , tss_slot_id_ (tss_slot_id)
  27     {
  28     }
  29
  30     /// dtor
  31     Current_Impl::~Current_Impl ()
  32     {
  33     }
  34
  35     /// Obtains the current transport. Throws a NoContext exception
  36     /// if, there was no "current" transport selected on the current
  37     /// thread.
  38     const TAO_Transport*
  39     Current_Impl::transport () const
  40     {
  41       Transport_Selection_Guard* topguard =
  42         Transport_Selection_Guard::current (this->core_, this->tss_slot_id_);
  43
  44       if (topguard == 0)
  45         throw NoContext();
  46
  47       return topguard->get ();
  48     }
  49
  50     static const TAO::Transport::Stats dummy_transport_stats;
  51
  52     /// Obtains the current transport's stats
  53     const TAO::Transport::Stats*
  54     Current_Impl::transport_stats () const
  55     {
  56       static const TAO::Transport::Stats dummy;
  57
  58       const TAO_Transport* t = this->transport ();
  59
  60       return (t==0 || t->stats () == 0) ? &dummy_transport_stats : t->stats ();
  61     }
  62
  63     CORBA::Long Current_Impl::id ()
  64     {
  65       const TAO_Transport* t = this->transport ();
  66
  67       return (t==0) ? 0 : static_cast<CORBA::Long> (t->id ());
  68     }
  69
  70     CounterT Current_Impl::bytes_sent ()
  71     {
  72       return transport_stats ()->bytes_sent ();
  73     }
  74
  75     CounterT Current_Impl::bytes_received ()
  76     {
  77       return transport_stats ()->bytes_received ();
  78     }
  79
  80     CounterT Current_Impl::messages_sent ()
  81     {
  82       return transport_stats ()->messages_sent ();
  83     }
  84
  85     CounterT Current_Impl::messages_received ()
  86     {
  87       return transport_stats ()->messages_received ();
  88     }
  89
  90     TimeBase::TimeT Current_Impl::open_since ()
  91     {
  92       TimeBase::TimeT msecs = 0;
  93       transport_stats ()->opened_since ().msec (msecs);
  94       return msecs;
  95     }
  96
  97   }
  98
  99 }
 100
 101 TAO_END_VERSIONED_NAMESPACE_DECL
 102
 103 #endif /* TAO_HAS_TRANSPORT_CURRENT == 1 */
 104