TAO/tao/Tagged_Profile.cpp

   1 #include "tao/Tagged_Profile.h"
   2 #include "tao/ORB_Core.h"
   3 #include "tao/Acceptor_Registry.h"
   4 #include "tao/Transport_Acceptor.h"
   5 #include "tao/Thread_Lane_Resources.h"
   6 #include "tao/debug.h"
   7 #include "tao/target_specification.h"
   8 #include "tao/CDR.h"
   9
  10 #if !defined (__ACE_INLINE__)
  11 # include "tao/Tagged_Profile.inl"
  12 #endif /* ! __ACE_INLINE__ */
  13
  14 TAO_BEGIN_VERSIONED_NAMESPACE_DECL
  15
  16 CORBA::Boolean
  17 TAO_Tagged_Profile::extract_object_key (IOP::TaggedProfile &profile)
  18 {
  19   // Get our Acceptor registry
  20   TAO_Acceptor_Registry &acceptor_registry =
  21     this->orb_core_->lane_resources ().acceptor_registry ();
  22
  23   // Get the right acceptor for the tag in the TaggedProfile
  24   TAO_Acceptor *acceptor = acceptor_registry.get_acceptor (profile.tag);
  25
  26   if (acceptor)
  27     {
  28       // Get the object key
  29       if (acceptor->object_key (profile, this->object_key_) == -1)
  30         {
  31           return false;
  32         }
  33     }
  34   else
  35     {
  36       if (TAO_debug_level)
  37         {
  38           TAOLIB_ERROR ((LM_ERROR,
  39                       ACE_TEXT ("(%P|%t)TAO_Tagged_Profile\n")));
  40         }
  41
  42       return false;
  43     }
  44
  45   return true;
  46 }
  47
  48 CORBA::Boolean
  49 TAO_Tagged_Profile::unmarshall_target_address (TAO_InputCDR &cdr)
  50 {
  51   CORBA::Boolean hdr_status = cdr.read_short (this->discriminator_);
  52
  53   if (hdr_status)
  54     {
  55       switch (this->discriminator_)
  56         {
  57         case TAO_Target_Specification::Key_Addr:
  58           hdr_status = this->unmarshall_object_key_i (cdr);
  59           break;
  60
  61         case TAO_Target_Specification::Profile_Addr:
  62           hdr_status = this->unmarshall_iop_profile_i (cdr);
  63           break;
  64
  65         case TAO_Target_Specification::Reference_Addr:
  66           hdr_status = this->unmarshall_ref_addr_i (cdr);
  67           break;
  68
  69         default:
  70           hdr_status = false;
  71           break;
  72         }
  73     }
  74
  75   return hdr_status;
  76 }
  77
  78 CORBA::Boolean
  79 TAO_Tagged_Profile::unmarshall_object_key (TAO_InputCDR &input)
  80 {
  81   this->discriminator_ = TAO_Target_Specification::Key_Addr;
  82
  83   return this->unmarshall_object_key_i (input);
  84 }
  85
  86
  87 CORBA::Boolean
  88 TAO_Tagged_Profile::unmarshall_object_key_i (TAO_InputCDR &input)
  89 {
  90   CORBA::Boolean hdr_status = (CORBA::Boolean) input.good_bit ();
  91
  92   CORBA::Long key_length = 0;
  93   hdr_status = hdr_status && input.read_long (key_length);
  94
  95   if (hdr_status)
  96     {
  97       this->object_key_.replace (key_length,
  98                                  key_length,
  99                                  (CORBA::Octet*)input.rd_ptr (),
 100                                  0);
 101       input.skip_bytes (key_length);
 102
 103       this->object_key_extracted_ = true;
 104     }
 105
 106   return hdr_status;
 107 }
 108
 109
 110 CORBA::Boolean
 111 TAO_Tagged_Profile::unmarshall_iop_profile_i (TAO_InputCDR &input)
 112 {
 113   CORBA::Boolean hdr_status = (CORBA::Boolean) input.good_bit ();
 114
 115   // Extract into the IOP::Tagged profile.
 116   hdr_status &= input >> this->profile_;
 117
 118   return hdr_status;
 119 }
 120
 121 CORBA::Boolean
 122 TAO_Tagged_Profile::unmarshall_ref_addr_i (TAO_InputCDR &input)
 123 {
 124   CORBA::Boolean hdr_status = (CORBA::Boolean) input.good_bit ();
 125
 126   /*
 127    * The GIOP::IORAddressingInfo is defined as follows
 128    *   struct IORAddressingInfo
 129    *     {
 130    *       unsigned long selected_profile_index;
 131    *       IOP::IOR ior;
 132    *     };
 133    *
 134    * and the IOP::IOR is defined to be
 135    *   struct IOR
 136    *      {
 137    *        string type_id;
 138    *        sequence<TaggedProfile>   profiles;
 139    *      };
 140    */
 141
 142   // First read the profile index
 143   CORBA::ULong prof_index =  0;
 144
 145   hdr_status = hdr_status && input.read_ulong (prof_index);
 146
 147   // Set the value in TAO_Tagged_Profile
 148   if (hdr_status)
 149     {
 150       this->profile_index_ = prof_index;
 151     }
 152
 153   // Get the length of the type_id
 154   CORBA::Long id_length = 0;
 155   hdr_status = hdr_status && input.read_long (id_length);
 156
 157   if (hdr_status)
 158     {
 159       // Set the type_id (it is not owned by this object)
 160       this->type_id_ = input.rd_ptr ();
 161
 162       input.skip_bytes (id_length);
 163     }
 164
 165   // Unmarshall the sequence of TaggedProfiles
 166   IOP::TaggedProfileSeq ior_profiles;
 167
 168   hdr_status &= input >> ior_profiles;
 169
 170   // Get the right TaggedProfile from the <ior_profiles>
 171   if (hdr_status)
 172     {
 173       this->profile_ = ior_profiles [prof_index];
 174     }
 175
 176   return hdr_status;
 177 }
 178
 179 TAO_END_VERSIONED_NAMESPACE_DECL