TAO/tao/Queued_Data.inl

   1 // -*- C++ -*-
   2 //
   3 TAO_BEGIN_VERSIONED_NAMESPACE_DECL
   4
   5 /*static*/
   6 ACE_INLINE void
   7 TAO_Queued_Data::replace_data_block (ACE_Message_Block &mb)
   8 {
   9   size_t const newsize = ACE_CDR::total_length (&mb, 0) + ACE_CDR::MAX_ALIGNMENT;
  10
  11   ACE_Data_Block *db = mb.data_block ()->clone_nocopy ();
  12
  13   if (db->size (newsize) == -1)
  14     return;
  15
  16   ACE_Message_Block tmp (db);
  17   ACE_CDR::mb_align (&tmp);
  18
  19   tmp.copy (mb.rd_ptr (), mb.length());
  20   mb.data_block (tmp.data_block ()->duplicate ());
  21
  22   mb.rd_ptr (tmp.rd_ptr ());
  23   mb.wr_ptr (tmp.wr_ptr ());
  24
  25   // Remove the DONT_DELETE flags from mb
  26   mb.clr_self_flags (ACE_Message_Block::DONT_DELETE);
  27 }
  28
  29 ACE_INLINE
  30 TAO_Queued_Data::TAO_Queued_Data (ACE_Allocator *alloc)
  31   : state_ (),
  32     allocator_ (alloc)
  33 {
  34 }
  35
  36 ACE_INLINE
  37 TAO_Queued_Data::TAO_Queued_Data (ACE_Message_Block *mb,
  38                                   ACE_Allocator *alloc)
  39   : msg_block_ (mb),
  40     state_ (),
  41     allocator_ (alloc)
  42 {
  43 }
  44
  45 ACE_INLINE
  46 TAO_Queued_Data::TAO_Queued_Data (const TAO_Queued_Data &qd)
  47   : msg_block_ (qd.msg_block_->duplicate ()),
  48     missing_data_ (qd.missing_data_),
  49     state_ (qd.state_),
  50     allocator_ (qd.allocator_)
  51 {
  52 }
  53
  54 ACE_INLINE size_t
  55 TAO_Queued_Data::missing_data () const
  56 {
  57   return this->missing_data_;
  58 }
  59
  60 ACE_INLINE void
  61 TAO_Queued_Data::missing_data (size_t data)
  62 {
  63   this->missing_data_ = data;
  64 }
  65
  66 ACE_INLINE TAO_GIOP_Message_Version const &
  67 TAO_Queued_Data::giop_version () const
  68 {
  69   return this->state_.giop_version ();
  70 }
  71
  72 ACE_INLINE CORBA::Octet
  73 TAO_Queued_Data::byte_order () const
  74 {
  75   return this->state_.byte_order ();
  76 }
  77
  78 ACE_INLINE CORBA::Boolean
  79 TAO_Queued_Data::more_fragments () const
  80 {
  81   return this->state_.more_fragments ();
  82 }
  83
  84 ACE_INLINE GIOP::MsgType
  85 TAO_Queued_Data::msg_type () const
  86 {
  87   return this->state_.message_type ();
  88 }
  89
  90 ACE_INLINE TAO_Queued_Data *
  91 TAO_Queued_Data::next () const
  92 {
  93   return this->next_;
  94 }
  95
  96 ACE_INLINE void
  97 TAO_Queued_Data::next (TAO_Queued_Data* qd)
  98 {
  99   this->next_ = qd;
 100 }
 101
 102 ACE_INLINE ACE_Message_Block *
 103 TAO_Queued_Data::msg_block () const
 104 {
 105   return this->msg_block_;
 106 }
 107
 108 ACE_INLINE void
 109 TAO_Queued_Data::msg_block (ACE_Message_Block *mb)
 110 {
 111   this->msg_block_ = mb;
 112 }
 113
 114 ACE_INLINE void
 115 TAO_Queued_Data::state (const TAO_GIOP_Message_State& state)
 116 {
 117   this->state_ = state;
 118 }
 119
 120 ACE_INLINE const TAO_GIOP_Message_State&
 121 TAO_Queued_Data::state () const
 122 {
 123   return this->state_;
 124 }
 125
 126 TAO_END_VERSIONED_NAMESPACE_DECL