Object Computing Inc.
St.Louis, Missouri
Iliyan Jeliazkov Phil Mesnier and Ciju John
In TAO, it is just too hard to obtain statistical or pretty much any operational information about the network transport which the ORB is using. While this is a direct corollary of the CORBA's design paradigm which mandates hiding all this hairy stuff behind non-transparent abstractions, it also precludes effective ORB and network monitoring.
The Transport::Current feature intends to fill this gap by defining a framework for developing a wide range of solutions to this problem. It also provides a basic implementation for the most common case - the IIOP transport.
By definition, transport-specific information is available in contexts where the ORB has selected a Transport:
The implementation is based on a generic service-oriented framework, implementing the TAO::Transport::Current interface. It is an optional service, which can be dynamically loaded. This service makes the Transport::Current interface available through orb->resolve_initial_references() . The basic idea is that whenever a Transport is chosen by the ORB, the Transport::Current (or a derivative) will have access to that instance and be able to provide some useful information.
Consider the following IDL interface, describing a Factory for producing TAO::Transport::Traits instance, which represents transport-specific data.
#include#include module TAO { /// A type used to represent counters typedef unsigned long long CounterT; module Transport { /// Used to signal that a call was made within improper invocation /// context. Also, this exception is thrown if no Transport has /// been selected for the current thread, for example in a /// collocated invocation. exception NoContext { }; // The primary interface, providing access to Transport // information, available to the current thread. local interface Current { /// Transport ID, unique within the process. readonly attribute long id raises (NoContext); /// Bytes sent/received through the transport. readonly attribute CounterT bytes_sent raises (NoContext); readonly attribute CounterT bytes_received raises (NoContext); /// Messages (requests and replies) sent/received using the current /// protocol. readonly attribute CounterT messages_sent raises (NoContext); readonly attribute CounterT messages_received raises (NoContext); /// The absolute time (miliseconds) since the transport has been /// open. readonly attribute TimeBase::TimeT open_since raises (NoContext); }; }; };
As an example of a specialized Transport::Current is the Transport::IIOP::Current, which derives from Transport::Current and has an interface, described in the following IDL:
#include "TC.idl"
/// Provide a forward reference for the SSLIOP::Current
module SSLIOP
{
interface Current;
};
module TAO
{
module Transport
{
module IIOP
{
// The primary interface, providing access to IIOP-specific
// transport information, if it is indeed an IIOP (-like) transport
// that has been selected.
local interface Current : TAO::Transport::Current
{
/// Remote host
readonly attribute string remote_host raises (NoContext);
/// Remote port Using long (signed) type to better accomodate
/// the Java mapping, which has no support for unsigned values
readonly attribute long remote_port raises (NoContext);
/// Local host
readonly attribute string local_host raises (NoContext);
/// Local port
readonly attribute long local_port raises (NoContext);
/// If this is a "secure" transport, this method will give you
/// the corresponding SSLIOP::Current
readonly attribute ::SSLIOP::Current ssliop_current raises (NoContext);
};
};
};
};
The TAO::Transport::Current can be used as a base interface for a more specialized TAO::Transport::X::Current. It is not required, however that a more specialized Current inherits from it.
Typical, generic usage is shown in the $TAO_ROOT/orbsvcs/tests/Transport_Current/Framework test:
...
// Get the Current object.
::CORBA::Object_var tcobject =
orb->resolve_initial_references ("TAO::Transport::Current"
ACE_ENV_SINGLE_ARG_DECL);
ACE_TRY_CHECK;
::TAO::Transport::Current_var tc =
::TAO::Transport::Current::_narrow (tcobject.in ()
ACE_ENV_SINGLE_ARG_DECL);
ACE_TRY_CHECK;
if (CORBA::is_nil (tc.in ()))
{
ACE_ERROR ((LM_ERROR,
ACE_TEXT ("(%P|%t) client - ERROR: Could not resolve ")
ACE_TEXT ("TAO::Transport::Current object.\n")));
ACE_TRY_THROW (CORBA::INTERNAL ());
}
...
Another example is available from the $TAO_ROOT/orbsvcs/tests/Transport_Current/IIOP test. This fragment shows how to obtain transport-specific information:
...
// Get the specific Current object.
CORBA::Object_var tcobject =
orb->resolve_initial_references (ACE_TEXT_ALWAYS_CHAR ("TAO::Transport::IIOP::Current")
ACE_ENV_ARG_PARAMETER);
ACE_TRY_CHECK;
Transport::IIOP::Current_var tc =
Transport::IIOP::Current::_narrow (tcobject.in ()
ACE_ENV_SINGLE_ARG_DECL);
ACE_TRY_CHECK;
if (CORBA::is_nil (tc.in ()))
ACE_TRY_THROW (CORBA::INTERNAL ());
::CORBA::String_var rhost (tc->remote_host (ACE_ENV_SINGLE_ARG_PARAMETER));
ACE_TRY_CHECK;
::CORBA::String_var lhost (tc->local_host (ACE_ENV_SINGLE_ARG_PARAMETER));
ACE_TRY_CHECK;
::CORBA::Long id = tc->id (ACE_ENV_SINGLE_ARG_PARAMETER);
ACE_TRY_CHECK;
::TAO::CounterT bs = tc->bytes_sent (ACE_ENV_SINGLE_ARG_PARAMETER);
ACE_TRY_CHECK;
::TAO::CounterT br = tc->bytes_received (ACE_ENV_SINGLE_ARG_PARAMETER);
ACE_TRY_CHECK;
::TAO::CounterT rs = tc->messages_sent (ACE_ENV_SINGLE_ARG_PARAMETER);
ACE_TRY_CHECK;
::TAO::CounterT rr = tc->messages_received (ACE_ENV_SINGLE_ARG_PARAMETER);
ACE_TRY_CHECK;
...
To use the Transport Current features the framework must be loaded through the Service Configuration framework. For example, using something like this:
dynamic TAO_Transport_Current_Loader Service_Object * TAO_TC:_make_TAO_Transport_Current_Loader() ""
The Transport_Current_Loader service uses an ORB initializer to register the "TAO::Transport::Current" name in a way that allows it to be resolved via orb->resolve_initial_references(). The implementation is the TAO::Transport::Current_Impl class.
A transport-specific Traits_Factory objects are loaded like this:
... dynamic TAO_Transport_IIOP_Current_Loader Service_Object * TAO_TC_IIOP:_make_TAO_Transport_IIOP_Current_Loader() "" ...
Note that any number of transport-specific Current interfaces may be available at any one time.
Whenever a Transport::Current method is invoked, a pointer to the currently selected Transport instance must be accessible through Thread Specific Storage (TSS). For each thread, this is managed by modifying the TAO classes, instances of which are created on the stack during request/response processing.
The primary implementation is predicated upon usage of thread specific storage (TSS) and the guarantees C++ provides for calling the constructor and the destructor of automatic (stack-based) objects. Some existing objects, used in TAO will have to be modified and the necessary changes, both for client and the server side are detailed below.
The Profile_Transport_Resolver instance contains the reference to the Transport, which is the TAO implementation structure that is needed to extract any protocol-specific information. An instance of Profile_Transport_Resolver lives on the stack, starting inside a call to Invocation_Adapter::invoke_remote_i(), or LocateRequest_Invocation_Adapter::invoke(). In the case of collocated invocations no such object is created.
It is then passed around the calls that follow, except for the calls to the following Invocation_Base methods: send_request_interception(), receive_other_interception(), receive_reply_interception(), handle_any_exception(), handle_all_exception();
Note that these in turn call the client-side interception points and that is where information about the transport will be needed. In order to make the transport information accessible inside those methods, we changed Profile_Transport_Resolver and the TAO_ServerRequest classes to incorporate an additional member:
... TAO::Transport_Selection_Guard transport_; ...
This guard automatically keeps track of the currenty selected Transport from within its constructor and destructor. The rest of the TC framework makes sure this pointer is stored in a thread-specific storage, by adding an additional member to TSS_Resources:
... TAO::Transport_Selection_Guard* tsg_; ...
The idea is to keep a pointer to the last guard on the current thread. Each guard keeps a pointer to the previous, effectively creating a stack of transport selection guards. The stack structure ensures both that the selection/deselection of a Transport will be correctly handled. It also ensures that, in case the current thread temporarily changes the Transport, the previous “current” transport will be preserved, no matter how many times such change occurs. A good example for this is a nested up-call scenario.
Inside an interceptor, one can use the methods from Transport Current to obtain information on the currently selected transport. The implementation simply looks up the TAO_Transport pointer via TSS_Resources::tsg_ and obtains the requested data.
On the server side, the TAO_ServerRequest instance already has a Transport pointer. The TAO_ServerRequest lives on the stack, starting its life inside a call to TAO_GIOP_Message_Base::process_request().
Similarly to the client-side, we changed the TAO_ServerRequest to add a field:
... TAO::Transport_Selection_Guard transport_; ...
Operation is similar to the client-side case. In the collocated case there may not be a transport available, so the TSS slot will be null.
Inside an interceptor then, one can use an RIR-resolved TransportCurrent to create a specialization of TransportInfo, based on the kind of Transport used. Then they would _downcast() it to the specific type.
As the IIOP implementation of the Transport Current functionality requires additional data to be kept about the Transport, we added a new field to TAO_Transport:
... /// Transport statistics TAO::Transport::Stats* stats_ ...
TAO::Transport::Stats is a simple structure, which keeps track of useful statistical information about how a transport is used:
...
class TAO_Export Stats
{
public:
Stats ();
void messages_sent (size_t message_length);
CORBA::LongLong messages_sent (void) const;
CORBA::LongLong bytes_sent (void) const;
void messages_received (size_t message_length);
CORBA::LongLong messages_received (void) const;
CORBA::LongLong bytes_received (void) const;
void opened_since (const ACE_Time_Value& tv);
const ACE_Time_Value& opened_since (void) const;
private:
CORBA::LongLong messages_rcvd_; // 32bits not enough (?)
CORBA::LongLong messages_sent_; // 32bits not enough (?)
ACE_Basic_Stats bytes_rcvd_;
ACE_Basic_Stats bytes_sent_;
ACE_Time_Value opened_since_;
};
...
To gather the statistics the TAO_Transport::send_message_shared() and TAO_Transport::process_parsed_messages() must be modified. These are non-virtual methods and are being called as part of request and reply processing regardless of what the most derived Transport type is. This property ensures that any specific Transport will have access to these statistics.
As the implementation of the Transport Current functionality necessitates some additional processing on the critical path of an invocation, we are expecting a performance impact when the functionality is being used.
It is possible at build time, to disable the functionality, so that applications only incur the penalty if they require the features. The ORB, by default enables the Transport::Current functionality. Adding "transport_current=0" to your default.features file will disable it.
Look at $TAO_ROOT/orbsvcs/tests/Transport_Current for code which illustrates and tests this feature.