TAO/tao/Service_Context.cpp

   1 // -*- C++ -*-
   2 #include "tao/Service_Context.h"
   3 #include "tao/CDR.h"
   4
   5 #if !defined (__ACE_INLINE__)
   6 # include "tao/Service_Context.inl"
   7 #endif /* ! __ACE_INLINE__ */
   8
   9 #include "ace/OS_NS_string.h"
  10
  11 TAO_BEGIN_VERSIONED_NAMESPACE_DECL
  12
  13 void
  14 TAO_Service_Context::set_context_i (IOP::ServiceId id, TAO_OutputCDR &cdr)
  15 {
  16   IOP::ServiceContext context;
  17   context.context_id = id;
  18
  19   // Make a *copy* of the CDR stream...
  20   size_t const length = cdr.total_length ();
  21   context.context_data.length (static_cast<CORBA::ULong> (length));
  22   CORBA::Octet *buf = context.context_data.get_buffer ();
  23
  24   for (const ACE_Message_Block *i = cdr.begin ();
  25        i != nullptr;
  26        i = i->cont ())
  27     {
  28       ACE_OS::memcpy (buf, i->rd_ptr (), i->length ());
  29       buf += i->length ();
  30     }
  31
  32   this->set_context_i (context);
  33 }
  34
  35 void
  36 TAO_Service_Context::set_context_i (IOP::ServiceContext &context,
  37                                     TAO_OutputCDR &cdr)
  38 {
  39   // Make a *copy* of the CDR stream...
  40   size_t const length = cdr.total_length ();
  41   context.context_data.length (static_cast<CORBA::ULong> (length));
  42   CORBA::Octet *buf = context.context_data.get_buffer ();
  43
  44   for (const ACE_Message_Block *i = cdr.begin ();
  45        i != nullptr;
  46        i = i->cont ())
  47     {
  48       ACE_OS::memcpy (buf, i->rd_ptr (), i->length ());
  49       buf += i->length ();
  50     }
  51 }
  52
  53 void
  54 TAO_Service_Context::set_context (const IOP::ServiceContext &context)
  55 {
  56   this->add_context_i (context);
  57 }
  58
  59 int
  60 TAO_Service_Context::set_context (const IOP::ServiceContext &context,
  61                                   CORBA::Boolean replace)
  62 {
  63   for (CORBA::ULong i = 0; i != this->service_context_.length (); ++i)
  64     {
  65       if (context.context_id == this->service_context_[i].context_id)
  66         {
  67           if (replace)
  68             {
  69               this->service_context_[i] = context;
  70               return 1;
  71             }
  72           else
  73             {
  74               return 0;
  75             }
  76         }
  77     }
  78
  79   this->add_context_i (context);
  80   return 1;
  81 }
  82
  83 void
  84 TAO_Service_Context::set_context_i (const IOP::ServiceContext& context)
  85 {
  86   // @@ TODO Some contexts can show up multiple times, others
  87   //    can't find out and take appropriate action.
  88   for (CORBA::ULong i = 0; i != this->service_context_.length (); ++i)
  89     {
  90       if (context.context_id == this->service_context_[i].context_id)
  91         {
  92           this->service_context_[i] = context;
  93           return;
  94         }
  95     }
  96
  97   this->add_context_i (context);
  98 }
  99
 100 void
 101 TAO_Service_Context::set_context_i (IOP::ServiceContext& context)
 102 {
 103   for (CORBA::ULong i = 0; i != this->service_context_.length (); ++i)
 104     {
 105       if (context.context_id == this->service_context_[i].context_id)
 106         {
 107           CORBA::ULong const max = context.context_data.maximum ();
 108           CORBA::ULong const len = context.context_data.length ();
 109           CORBA::Octet * const buf = context.context_data.get_buffer (1);
 110           this->service_context_[i].context_data.replace (max, len, buf, 1);
 111           return;
 112         }
 113     }
 114
 115   this->add_context_i (context);
 116 }
 117
 118 void
 119 TAO_Service_Context::add_context_i (IOP::ServiceContext& context)
 120 {
 121   // @@ TODO Some contexts can show up multiple times, others
 122   //    can't find out and take appropriate action.
 123   CORBA::ULong const l = this->service_context_.length ();
 124   this->service_context_.length (l + 1);
 125   this->service_context_[l].context_id = context.context_id;
 126   CORBA::ULong const max = context.context_data.maximum ();
 127   CORBA::ULong const len = context.context_data.length ();
 128   CORBA::Octet* const buf = context.context_data.get_buffer (1);
 129   this->service_context_[l].context_data.replace (max, len, buf, 1);
 130 }
 131
 132 void
 133 TAO_Service_Context::add_context_i (const IOP::ServiceContext& context)
 134 {
 135   // @@ TODO Some contexts can show up multiple times, others
 136   //    can't find out and take appropriate action.
 137   CORBA::ULong const l = this->service_context_.length ();
 138   this->service_context_.length (l + 1);
 139   this->service_context_[l] = context;
 140 }
 141
 142 int
 143 TAO_Service_Context::get_context (IOP::ServiceContext& context) const
 144 {
 145   for (CORBA::ULong i = 0; i != this->service_context_.length (); ++i)
 146     {
 147       if (context.context_id == this->service_context_[i].context_id)
 148         {
 149           context = this->service_context_[i];
 150           return 1;
 151         }
 152     }
 153
 154   return 0;
 155 }
 156
 157 int
 158 TAO_Service_Context::get_context (IOP::ServiceId id,
 159                                   const IOP::ServiceContext **context) const
 160 {
 161   for (CORBA::ULong i = 0; i != this->service_context_.length (); ++i)
 162     {
 163       if (id == this->service_context_[i].context_id)
 164         {
 165           *context = &this->service_context_[i];
 166           return 1;
 167         }
 168     }
 169
 170   return 0;
 171 }
 172
 173 int
 174 TAO_Service_Context::get_context (IOP::ServiceId id,
 175                                   IOP::ServiceContext_out context)
 176 {
 177   CORBA::ULong const len = this->service_context_.length ();
 178
 179   for (CORBA::ULong i = 0; i < len; ++i)
 180     {
 181       if (id == this->service_context_[i].context_id)
 182         {
 183           ACE_NEW_RETURN (context, IOP::ServiceContext, 0);
 184
 185           *(context.ptr ()) = this->service_context_[i];
 186
 187           return 1;
 188         }
 189     }
 190
 191   return 0;
 192 }
 193
 194 int
 195 TAO_Service_Context::encode (TAO_OutputCDR& cdr) const
 196 {
 197   return (cdr << this->service_context_);
 198 }
 199
 200 int
 201 TAO_Service_Context::decode (TAO_InputCDR& cdr)
 202 {
 203   if (!(cdr >> this->service_context_))
 204     {
 205       return 0;
 206     }
 207
 208   return 1;
 209 }
 210
 211 TAO_END_VERSIONED_NAMESPACE_DECL