TAO_UIOP_Profile Class Reference

This class defines the protocol specific attributes required for locating ORBs over local IPC. More...

#include <UIOP_Profile.h>

Inheritance diagram for TAO_UIOP_Profile:

[legend]Collaboration diagram for TAO_UIOP_Profile:

[legend]List of all members.

Public Member Functions
virtual char	object_key_delimiter (void) const
	TAO_UIOP_Profile (const ACE_UNIX_Addr &addr, const TAO::ObjectKey &object_key, const TAO_GIOP_Message_Version &version, TAO_ORB_Core *orb_core)
	TAO_UIOP_Profile (const char *rendezvous_point, const TAO::ObjectKey &object_key, const ACE_UNIX_Addr &addr, const TAO_GIOP_Message_Version &version, TAO_ORB_Core *orb_core)
	Profile constructor.
	TAO_UIOP_Profile (TAO_ORB_Core *orb_core)
	Profile constructor, default.
	~TAO_UIOP_Profile (void)
	Destructor is to be called only through <_decr_refcnt>.
virtual char *	to_string (void)
	Template methods. Please see Profile.h for documentation.
virtual int	encode_endpoints (void)
virtual TAO_Endpoint *	endpoint (void)
virtual CORBA::ULong	endpoint_count (void) const
virtual CORBA::ULong	hash (CORBA::ULong max)
void	add_endpoint (TAO_UIOP_Endpoint *endp)
Static Public Member Functions
static const char *	prefix (void)
	Return the char string prefix.
Static Public Attributes
static const char	object_key_delimiter_ = '|'
	The object key delimiter that UIOP uses or expects.
Protected Member Functions
virtual int	decode_profile (TAO_InputCDR &cdr)
virtual void	parse_string_i (const char *string)
virtual void	create_profile_body (TAO_OutputCDR &cdr) const
virtual int	decode_endpoints (void)
virtual CORBA::Boolean	do_is_equivalent (const TAO_Profile *other_profile)
Private Attributes
TAO_UIOP_Endpoint	endpoint_
CORBA::ULong	count_
	Number of endpoints in the list headed by <endpoint_>.

---

Detailed Description

This class defines the protocol specific attributes required for locating ORBs over local IPC.

This class defines the UIOP profile.

Definition at line 47 of file UIOP_Profile.h.

---

Constructor & Destructor Documentation

TAO_UIOP_Profile::TAO_UIOP_Profile	(	const ACE_UNIX_Addr &	addr,
		const TAO::ObjectKey &	object_key,
		const TAO_GIOP_Message_Version &	version,
		TAO_ORB_Core *	orb_core
	)

Profile constructor, same as above except the object_key has already been marshaled. (actually, no marshalling for this protocol)

Definition at line 33 of file UIOP_Profile.cpp.

  : TAO_Profile (TAO_TAG_UIOP_PROFILE,
                 orb_core,
                 object_key,
                 version),
    endpoint_ (addr),
    count_ (1)
{
}

TAO_UIOP_Profile::TAO_UIOP_Profile	(	const char *	rendezvous_point,
		const TAO::ObjectKey &	object_key,
		const ACE_UNIX_Addr &	addr,
		const TAO_GIOP_Message_Version &	version,
		TAO_ORB_Core *	orb_core
	)

Profile constructor.

Definition at line 46 of file UIOP_Profile.cpp.

  : TAO_Profile (TAO_TAG_UIOP_PROFILE,
                 orb_core,
                 object_key,
                 version),
    endpoint_ (addr),
    count_ (1)
{
}

TAO_UIOP_Profile::TAO_UIOP_Profile

(

TAO_ORB_Core *

orb_core

)

Profile constructor, default.

Definition at line 60 of file UIOP_Profile.cpp.

  : TAO_Profile (TAO_TAG_UIOP_PROFILE,
                 orb_core,
                 TAO_GIOP_Message_Version (TAO_DEF_GIOP_MAJOR,
                                           TAO_DEF_GIOP_MINOR)),
    endpoint_ (),
    count_ (1)
{
}

TAO_UIOP_Profile::~TAO_UIOP_Profile

(

void

)

Destructor is to be called only through <_decr_refcnt>.

Definition at line 70 of file UIOP_Profile.cpp.

References TAO_Endpoint::next().

{
  // Clean up the list of endpoints since we own it.
  // Skip the head, since it is not dynamically allocated.
  TAO_Endpoint *tmp = 0;

  for (TAO_Endpoint *next = this->endpoint ()->next ();
       next != 0;
       next = tmp)
    {
      tmp = next->next ();
      delete next;
    }
}

---

Member Function Documentation

void TAO_UIOP_Profile::add_endpoint

(

TAO_UIOP_Endpoint *

endp

)

Add <endp> to this profile's list of endpoints (it is inserted next to the head of the list). This profiles takes ownership of <endp>.

Definition at line 234 of file UIOP_Profile.cpp.

References count_, endpoint_, and TAO_UIOP_Endpoint::next_.

Referenced by TAO_UIOP_Acceptor::create_shared_profile(), and decode_endpoints().

{
  endp->next_ = this->endpoint_.next_;
  this->endpoint_.next_ = endp;

  this->count_++;
}

void TAO_UIOP_Profile::create_profile_body

(

TAO_OutputCDR &

cdr

)

const [protected, virtual]

Implements TAO_Profile.

Definition at line 318 of file UIOP_Profile.cpp.

References ACE_ERROR, TAO_Tagged_Components::encode(), LM_ERROR, TAO_Profile::ref_object_key_, TAO_Profile::tagged_components(), TAO_ENCAP_BYTE_ORDER, ACE_OutputCDR::write_octet(), and ACE_OutputCDR::write_string().

{
  // CHAR describing byte order, starting the encapsulation
  encap.write_octet (TAO_ENCAP_BYTE_ORDER);

  // The GIOP version
  encap.write_octet (this->version_.major);
  encap.write_octet (this->version_.minor);

  // STRING rendezvous_pointname from profile
  encap.write_string (this->endpoint_.rendezvous_point ());

  // OCTET SEQUENCE for object key
  if (this->ref_object_key_)
    encap << this->ref_object_key_->object_key ();
  else
    {
      ACE_ERROR ((LM_ERROR,
                  "(%P|%t) TAO - UIOP_Profile::create_profile_body "
                  "no object key marshalled \n"));
    }

  if (this->version_.major > 1
      || this->version_.minor > 0)
    this->tagged_components ().encode (encap);
}

int TAO_UIOP_Profile::decode_endpoints

(

void

)

[protected, virtual]

Implements TAO_Profile.

Definition at line 381 of file UIOP_Profile.cpp.

References ACE_DEBUG, ACE_NEW_RETURN, ACE_TEXT, add_endpoint(), endpoint(), endpoint_, LM_DEBUG, TAO_Endpoint::priority(), TAO_debug_level, and TAO_TAG_ENDPOINTS.

{
  IOP::TaggedComponent tagged_component;
  tagged_component.tag = TAO_TAG_ENDPOINTS;

  if (this->tagged_components_.get_component (tagged_component))
    {
      const CORBA::Octet *buf =
        tagged_component.component_data.get_buffer ();

      TAO_InputCDR in_cdr (reinterpret_cast <const char*>(buf),
                           tagged_component.component_data.length ());

      // Extract the Byte Order.
      CORBA::Boolean byte_order;
      if ((in_cdr >> ACE_InputCDR::to_boolean (byte_order)) == 0)
        return -1;
      in_cdr.reset_byte_order (static_cast<int>(byte_order));

      // Extract endpoints sequence.
      TAO_UIOPEndpointSequence endpoints;

      if ((in_cdr >> endpoints) == 0)
        return -1;

      // Get the priority of the first endpoint (head of the list.
      // It's other data is extracted as part of the standard profile
      // decoding.
      this->endpoint_.priority (endpoints[0].priority);

      // Use information extracted from the tagged component to
      // populate the profile.  Skip the first endpoint, since it is
      // always extracted through standard profile body.  Also, begin
      // from the end of the sequence to preserve endpoint order,
      // since <add_endpoint> method reverses the order of endpoints
      // in the list.
      for (CORBA::ULong i = endpoints.length () - 1;
           i > 0;
           --i)
        {
          TAO_UIOP_Endpoint *endpoint = 0;
          ACE_NEW_RETURN (endpoint,
                          TAO_UIOP_Endpoint,
                          -1);
          this->add_endpoint (endpoint);
          if (endpoint->object_addr_.set
              (endpoints[i].rendezvous_point)
              == -1)
            {
              // In the case of an ACE_UNIX_Addr, this should call should
              // never fail!
              // If the call fails, allow the profile to be created, and rely
              // on TAO's connection handling to throw the appropriate
              // exception.
              if (TAO_debug_level > 0)
                {
                  ACE_DEBUG ((LM_DEBUG,
                              ACE_TEXT ("TAO (%P|%t) UIOP_Profile::decode_endpoints - ")
                              ACE_TEXT ("ACE_UNIX_Addr::set() failed\n")));
                }

            }
          endpoint->priority (endpoints[i].priority);
        }
    }

  return 0;
}

int TAO_UIOP_Profile::decode_profile

(

TAO_InputCDR &

cdr

)

[protected, virtual]

Protected template methods. Please see documentation in Profile.h for details.

Implements TAO_Profile.

Definition at line 284 of file UIOP_Profile.cpp.

References ACE_DEBUG, ACE_TEXT, LM_DEBUG, ACE_InputCDR::read_string(), and TAO_debug_level.

{
  char *rendezvous = 0;

  // Get rendezvous_point
  if (cdr.read_string (rendezvous) == 0)
    {
      ACE_DEBUG ((LM_DEBUG, "error decoding UIOP rendezvous_point"));
      return -1;
    }

  if (this->endpoint_.object_addr_.set (rendezvous) == -1)
    {
      // In the case of an ACE_UNIX_Addr, this should call should
      // never fail!
      //
      // If the call fails, allow the profile to be created, and rely
      // on TAO's connection handling to throw the appropriate
      // exception.
      if (TAO_debug_level > 0)
        {
          ACE_DEBUG ((LM_DEBUG,
                      ACE_TEXT ("TAO (%P|%t) UIOP_Profile::decode - ")
                      ACE_TEXT ("ACE_UNIX_Addr::set() failed\n")));
        }
    }

  // Clean up
  delete [] rendezvous;

  return 1;
}

CORBA::Boolean TAO_UIOP_Profile::do_is_equivalent

(

const TAO_Profile *

other_profile

)

[protected, virtual]

Implements TAO_Profile.

Definition at line 181 of file UIOP_Profile.cpp.

References endpoint_, and TAO_UIOP_Endpoint::next_.

{
  const TAO_UIOP_Profile *op =
    dynamic_cast <const TAO_UIOP_Profile *> (other_profile);

  if (op == 0)
    return false;

  // Check endpoints equivalence.
  const TAO_UIOP_Endpoint *other_endp = &op->endpoint_;
  for (TAO_UIOP_Endpoint *endp = &this->endpoint_;
       endp != 0;
       endp = endp->next_)
    {
      if (endp->is_equivalent (other_endp))
        other_endp = other_endp->next_;
      else
        return false;
    }

  return true;
}

int TAO_UIOP_Profile::encode_endpoints

(

void

)

[virtual]

Implements TAO_Profile.

Definition at line 346 of file UIOP_Profile.cpp.

References count_, endpoint(), endpoint_, TAO_Endpoint::priority(), TAO_Profile::set_tagged_components(), and TAO_ENCAP_BYTE_ORDER.

{
  // Create a data structure and fill it with endpoint info for wire
  // transfer.
  // We include information for the head of the list
  // together with other endpoints because even though its addressing
  // info is transmitted using standard ProfileBody components, its
  // priority is not!
  TAO_UIOPEndpointSequence endpoints;
  endpoints.length (this->count_);

  TAO_UIOP_Endpoint *endpoint = &this->endpoint_;
  for (size_t i = 0;
       i < this->count_;
       ++i)
    {
      endpoints[i].rendezvous_point = endpoint->rendezvous_point ();
      endpoints[i].priority = endpoint->priority ();

      endpoint = endpoint->next_;
    }

  // Encode the data structure.
  TAO_OutputCDR out_cdr;
  if ((out_cdr << ACE_OutputCDR::from_boolean (TAO_ENCAP_BYTE_ORDER)
       == 0)
      || (out_cdr << endpoints) == 0)
    return -1;

  this->set_tagged_components (out_cdr);

  return  0;
}

TAO_Endpoint * TAO_UIOP_Profile::endpoint

(

void

)

[virtual]

Implements TAO_Profile.

Definition at line 86 of file UIOP_Profile.cpp.

References endpoint_.

Referenced by TAO_UIOP_Acceptor::create_new_profile(), decode_endpoints(), and encode_endpoints().

{
  return &this->endpoint_;
}

CORBA::ULong TAO_UIOP_Profile::endpoint_count

(

void

)

const [virtual]

Implements TAO_Profile.

Definition at line 92 of file UIOP_Profile.cpp.

References count_.

{
  return this->count_;
}

CORBA::ULong TAO_UIOP_Profile::hash

(

CORBA::ULong

max

)

[virtual]

Implements TAO_Profile.

Definition at line 205 of file UIOP_Profile.cpp.

References TAO_Profile::hash_service_i(), TAO_GIOP_Message_Version::minor, TAO_Profile::ref_object_key_, TAO_Profile::tag(), and TAO_Profile::version_.

{
  // Get the hashvalue for all endpoints.
  CORBA::ULong hashval = 0;
  for (TAO_UIOP_Endpoint *endp = &this->endpoint_;
       endp != 0;
       endp = endp->next_)
    {
      hashval += endp->hash ();
    }

  hashval += this->version_.minor;
  hashval += this->tag ();

  const TAO::ObjectKey &ok =
    this->ref_object_key_->object_key ();

  if (ok.length () >= 4)
    {
      hashval += ok[1];
      hashval += ok[3];
    }

  hashval += this->hash_service_i (max);

  return hashval % max;
}

char TAO_UIOP_Profile::object_key_delimiter

(

void

)

const [virtual]

Implements TAO_Profile.

Definition at line 28 of file UIOP_Profile.cpp.

References object_key_delimiter_.

{
  return TAO_UIOP_Profile::object_key_delimiter_;
}

void TAO_UIOP_Profile::parse_string_i

(

const char *

string

)

[protected, virtual]

Implements TAO_Profile.

Definition at line 98 of file UIOP_Profile.cpp.

References CORBA::SystemException::_tao_minor_code(), ACE_OS::ace_isdigit(), CORBA::COMPLETED_NO, TAO_GIOP_Message_Version::set_version(), ACE_OS::strchr(), CORBA::string_alloc(), ACE_OS::strncpy(), TAO_DEF_GIOP_MAJOR, TAO_DEF_GIOP_MINOR, TAO_Profile::version_, and TAO::VMCID.

{
  if (!string || !*string)
    {
      throw ::CORBA::INV_OBJREF (
                   CORBA::SystemException::_tao_minor_code (
                     0,
                     EINVAL),
                   CORBA::COMPLETED_NO);
    }

  // Remove the "N.n@" version prefix, if it exists, and verify the
  // version is one that we accept.

  // Check for version
  if (ACE_OS::ace_isdigit (string [0]) &&
      string[1] == '.' &&
      ACE_OS::ace_isdigit (string [2]) &&
      string[3] == '@')
    {
      // @@ This may fail for non-ascii character sets [but take that
      // with a grain of salt]
      this->version_.set_version ((char) (string [0] - '0'),
                                  (char) (string [2] - '0'));
      string += 4;
      // Skip over the "N.n@"
    }

  if (this->version_.major != TAO_DEF_GIOP_MAJOR ||
      this->version_.minor  > TAO_DEF_GIOP_MINOR)
    {
      throw ::CORBA::INV_OBJREF (
                   CORBA::SystemException::_tao_minor_code (
                     0,
                     EINVAL),
                   CORBA::COMPLETED_NO);
    }


  // Pull off the "rendezvous point" part of the objref
  // Copy the string because we are going to modify it...
  CORBA::String_var copy (string);

  char *start = copy.inout ();
  char *cp = ACE_OS::strchr (start, this->object_key_delimiter_);

  if (cp == 0)
    {
      throw ::CORBA::INV_OBJREF (
                   CORBA::SystemException::_tao_minor_code (
                     TAO::VMCID,
                     EINVAL),
                   CORBA::COMPLETED_NO);
      // No rendezvous point specified
    }

  CORBA::ULong length = cp - start;

  CORBA::String_var rendezvous = CORBA::string_alloc (length);

  ACE_OS::strncpy (rendezvous.inout (), start, length);
  rendezvous[length] = '\0';

  if (this->endpoint_.object_addr_.set (rendezvous.in ()) != 0)
    {
      throw ::CORBA::INV_OBJREF (
                   CORBA::SystemException::_tao_minor_code (
                     TAO::VMCID,
                     EINVAL),
                   CORBA::COMPLETED_NO);
    }

  start = ++cp;  // increment past the object key separator

  TAO::ObjectKey ok;
  TAO::ObjectKey::decode_string_to_sequence (ok,
                                             start);

  (void) this->orb_core ()->object_key_table ().bind (ok,
                                                      this->ref_object_key_);
}

const char * TAO_UIOP_Profile::prefix

(

void

)

[static]

Return the char string prefix.

Definition at line 278 of file UIOP_Profile.cpp.

References prefix_.

{
  return ::prefix_;
}

char * TAO_UIOP_Profile::to_string

(

void

)

[virtual]

Template methods. Please see Profile.h for documentation.

Implements TAO_Profile.

Definition at line 244 of file UIOP_Profile.cpp.

References object_key_delimiter_, prefix_, TAO_Profile::ref_object_key_, ACE_OS::sprintf(), CORBA::string_alloc(), and ACE_OS::strlen().

{
  CORBA::String_var key;
  TAO::ObjectKey::encode_sequence_to_string (key.inout(),
                                            this->ref_object_key_->object_key ());

  u_int buflen = (8 /* "corbaloc" */ +
                  1 /* colon separator */ +
                  ACE_OS::strlen (::prefix_) +
                  1 /* colon separator */ +
                  1 /* major version */ +
                  1 /* decimal point */ +
                  1 /* minor version */ +
                  1 /* `@' character */ +
                  ACE_OS::strlen (this->endpoint_.rendezvous_point ()) +
                  1 /* object key separator */ +
                  ACE_OS::strlen (key.in ()));

  char * buf = CORBA::string_alloc (buflen);

  static const char digits [] = "0123456789";

  ACE_OS::sprintf (buf,
                   "corbaloc:%s:%c.%c@%s%c%s",
                   ::prefix_,
                   digits [this->version_.major],
                   digits [this->version_.minor],
                   this->endpoint_.rendezvous_point (),
                   this->object_key_delimiter_,
                   key.in ());
  return buf;
}

---

Member Data Documentation

CORBA::ULong TAO_UIOP_Profile::count_ [private]

Number of endpoints in the list headed by <endpoint_>.

Definition at line 119 of file UIOP_Profile.h.

Referenced by add_endpoint(), encode_endpoints(), and endpoint_count().

TAO_UIOP_Endpoint TAO_UIOP_Profile::endpoint_ [private]

Head of this profile's list of endpoints. This endpoint is not dynamically allocated because a profile always contains at least one endpoint.

Currently, a profile contains more than one endpoint, i.e., list contains more than just the head, only when RTCORBA is enabled. However, in the near future, this will be used in nonRT mode as well, e.g., to support a la TAG_ALTERNATE_IIOP_ADDRESS feature. Addressing info of the default endpoint, i.e., head of the list, is transmitted using standard UIOP ProfileBody components. See <encode_endpoints> method documentation above for how the rest of the endpoint list is transmitted.

Definition at line 116 of file UIOP_Profile.h.

Referenced by add_endpoint(), decode_endpoints(), do_is_equivalent(), encode_endpoints(), and endpoint().

TAO_BEGIN_VERSIONED_NAMESPACE_DECL const char TAO_UIOP_Profile::object_key_delimiter_ = '|' [static]

The object key delimiter that UIOP uses or expects.

Definition at line 51 of file UIOP_Profile.h.

Referenced by object_key_delimiter(), TAO_UIOP_Connector::object_key_delimiter(), and to_string().

---

The documentation for this class was generated from the following files:

• UIOP_Profile.h
• UIOP_Profile.cpp

---