// -*- C++ -*- // $Id$ // **************************************************************** ACE_INLINE void ACE_CDR::swap_2 (const char *orig, char* target) { target[1] = *orig++; target[0] = *orig++; } ACE_INLINE void ACE_CDR::swap_4 (const char *orig, char* target) { target [3] = *orig++; target [2] = *orig++; target [1] = *orig++; target [0] = *orig++; } ACE_INLINE void ACE_CDR::swap_8 (const char *orig, char* target) { target [7] = *orig++; target [6] = *orig++; target [5] = *orig++; target [4] = *orig++; target [3] = *orig++; target [2] = *orig++; target [1] = *orig++; target [0] = *orig++; } ACE_INLINE void ACE_CDR::swap_16 (const char *orig, char* target) { target [15] = *orig++; target [14] = *orig++; target [13] = *orig++; target [12] = *orig++; target [11] = *orig++; target [10] = *orig++; target [9] = *orig++; target [8] = *orig++; target [7] = *orig++; target [6] = *orig++; target [5] = *orig++; target [4] = *orig++; target [3] = *orig++; target [2] = *orig++; target [1] = *orig++; target [0] = *orig++; } ACE_INLINE void ACE_CDR::mb_align (ACE_Message_Block *mb) { char *start = ACE_ptr_align_binary (mb->base (), ACE_CDR::MAX_ALIGNMENT); mb->rd_ptr (start); mb->wr_ptr (start); #if defined (ACE_HAS_PURIFY) // This is a good place to zero the buffer; this is not needed // by IIOP, but makes Purify happy. if (mb->base () != 0) { (void) ACE_OS::memset (mb->base (), 0, mb->size ()); } #endif /* ACE_HAS_PURIFY */ } ACE_INLINE size_t ACE_CDR::first_size (size_t minsize) { if (minsize == 0) return ACE_CDR::DEFAULT_BUFSIZE; size_t newsize = ACE_CDR::DEFAULT_BUFSIZE; while (newsize < minsize) { if (newsize < ACE_CDR::EXP_GROWTH_MAX) { // We grow exponentially at the beginning, this is fast and // reduces the number of allocations. newsize *= 2; } else { // but continuing with exponential growth can result in over // allocations and easily yield an allocation failure. // So we grow linearly when the buffer is too big. newsize += ACE_CDR::LINEAR_GROWTH_CHUNK; } } return newsize; } ACE_INLINE size_t ACE_CDR::next_size (size_t minsize) { size_t newsize = ACE_CDR::first_size (minsize); if (newsize == minsize) { // If necessary increment the size if (newsize < ACE_CDR::EXP_GROWTH_MAX) newsize *= 2; else newsize += ACE_CDR::LINEAR_GROWTH_CHUNK; } return newsize; } // **************************************************************** // implementing the special types ACE_INLINE ACE_OutputCDR::from_boolean::from_boolean (ACE_CDR::Boolean b) : val_ (b) { } ACE_INLINE ACE_InputCDR::to_boolean::to_boolean (ACE_CDR::Boolean &b) : ref_ (b) { } ACE_INLINE ACE_OutputCDR::from_octet::from_octet (ACE_CDR::Octet o) : val_ (o) { } ACE_INLINE ACE_InputCDR::to_octet::to_octet (ACE_CDR::Octet &o) : ref_ (o) { } ACE_INLINE ACE_OutputCDR::from_char::from_char (ACE_CDR::Char c) : val_ (c) { } ACE_INLINE ACE_InputCDR::to_char::to_char (ACE_CDR::Char &c) : ref_ (c) { } ACE_INLINE ACE_OutputCDR::from_wchar::from_wchar (ACE_CDR::WChar wc) : val_ (wc) { } ACE_INLINE ACE_InputCDR::to_wchar::to_wchar (ACE_CDR::WChar &wc) : ref_ (wc) { } ACE_INLINE ACE_OutputCDR::from_string::from_string (ACE_CDR::Char *s, ACE_CDR::ULong b, ACE_CDR::Boolean nocopy) : val_ (s), bound_ (b), nocopy_ (nocopy) { } ACE_INLINE ACE_InputCDR::to_string::to_string (ACE_CDR::Char *&s, ACE_CDR::ULong b) : val_ (s), bound_ (b) { } ACE_INLINE ACE_OutputCDR::from_wstring::from_wstring (ACE_CDR::WChar *ws, ACE_CDR::ULong b, ACE_CDR::Boolean nocopy) : val_ (ws), bound_ (b), nocopy_ (nocopy) { } ACE_INLINE ACE_InputCDR::to_wstring::to_wstring (ACE_CDR::WChar *&ws, ACE_CDR::ULong b) : val_ (ws), bound_ (b) { } ACE_INLINE ACE_InputCDR::Transfer_Contents::Transfer_Contents (ACE_InputCDR &rhs) : rhs_ (rhs) { } // **************************************************************** ACE_INLINE ACE_OutputCDR::~ACE_OutputCDR (void) { if (this->start_.cont () != 0) { ACE_Message_Block::release (this->start_.cont ()); this->start_.cont (0); } this->current_ = 0; } ACE_INLINE void ACE_OutputCDR::reset (void) { this->current_ = &this->start_; this->current_is_writable_ = 1; ACE_CDR::mb_align (&this->start_); this->current_alignment_ = 0; // It is tempting not to remove the memory, but we need to do so to // release any potential user buffers chained in the continuation // field. ACE_Message_Block *cont = this->start_.cont (); if (cont != 0) { ACE_Message_Block::release (cont); this->start_.cont (0); } } // Decode the CDR stream. ACE_INLINE ACE_CDR::Boolean ACE_OutputCDR::write_octet (ACE_CDR::Octet x) { return this->write_1 (ACE_reinterpret_cast (const ACE_CDR::Octet*,&x)); } ACE_INLINE ACE_CDR::Boolean ACE_OutputCDR::write_boolean (ACE_CDR::Boolean x) { return (ACE_CDR::Boolean) this->write_octet (x ? 1 : 0); } ACE_INLINE ACE_CDR::Boolean ACE_OutputCDR::write_char (ACE_CDR::Char x) { if (this->char_translator_ == 0) return this->write_1 (ACE_reinterpret_cast (const ACE_CDR::Octet*, &x)); return this->char_translator_->write_char (*this, x); } ACE_INLINE ACE_CDR::Boolean ACE_OutputCDR::write_wchar (ACE_CDR::WChar x) { if (this->wchar_translator_ == 0) return this->write_2 (ACE_reinterpret_cast (const ACE_CDR::UShort*, &x)); return this->wchar_translator_->write_wchar (*this, x); } ACE_INLINE ACE_CDR::Boolean ACE_OutputCDR::write_short (ACE_CDR::Short x) { return this->write_2 (ACE_reinterpret_cast (const ACE_CDR::UShort*, &x)); } ACE_INLINE ACE_CDR::Boolean ACE_OutputCDR::write_ushort (ACE_CDR::UShort x) { return this->write_2 (ACE_reinterpret_cast (const ACE_CDR::UShort*, &x)); } ACE_INLINE ACE_CDR::Boolean ACE_OutputCDR::write_long (ACE_CDR::Long x) { return this->write_4 (ACE_reinterpret_cast (const ACE_CDR::ULong*, &x)); } ACE_INLINE ACE_CDR::Boolean ACE_OutputCDR::write_ulong (ACE_CDR::ULong x) { return this->write_4 (ACE_reinterpret_cast (const ACE_CDR::ULong*, &x)); } ACE_INLINE ACE_CDR::Boolean ACE_OutputCDR::write_longlong (const ACE_CDR::LongLong &x) { return this->write_8 (ACE_reinterpret_cast (const ACE_CDR::ULongLong*, &x)); } ACE_INLINE ACE_CDR::Boolean ACE_OutputCDR::write_ulonglong (const ACE_CDR::ULongLong &x) { return this->write_8 (ACE_reinterpret_cast (const ACE_CDR::ULongLong*,&x)); } ACE_INLINE ACE_CDR::Boolean ACE_OutputCDR::write_float (ACE_CDR::Float x) { return this->write_4 (ACE_reinterpret_cast (const ACE_CDR::ULong*, &x)); } ACE_INLINE ACE_CDR::Boolean ACE_OutputCDR::write_double (const ACE_CDR::Double &x) { return this->write_8 (ACE_reinterpret_cast (const ACE_CDR::ULongLong*, &x)); } ACE_INLINE ACE_CDR::Boolean ACE_OutputCDR::write_longdouble (const ACE_CDR::LongDouble &x) { return this->write_16 (ACE_reinterpret_cast (const ACE_CDR::LongDouble*,&x)); } ACE_INLINE ACE_CDR::Boolean ACE_OutputCDR::write_string (const ACE_CDR::Char *x) { if (x != 0) return this->write_string (ACE_OS::strlen(x), x); return this->write_string (0, 0); } ACE_INLINE ACE_CDR::Boolean ACE_OutputCDR::write_string (const ACE_CString &x) { return this->write_string (x.length(), x.c_str()); } ACE_INLINE ACE_CDR::Boolean ACE_OutputCDR::write_wstring (const ACE_CDR::WChar *x) { if (x != 0) return this->write_wstring (ACE_OS::wslen (x), x); return this->write_wstring (0, 0); } ACE_INLINE ACE_CDR::Boolean ACE_OutputCDR::write_char_array (const ACE_CDR::Char *x, ACE_CDR::ULong length) { if (this->char_translator_ == 0) return this->write_array (x, ACE_CDR::OCTET_SIZE, ACE_CDR::OCTET_ALIGN, length); return this->char_translator_->write_char_array (*this, x, length); } ACE_INLINE ACE_CDR::Boolean ACE_OutputCDR::write_wchar_array (const ACE_CDR::WChar* x, ACE_CDR::ULong length) { if (this->wchar_translator_ == 0) return this->write_array (x, ACE_CDR::SHORT_SIZE, ACE_CDR::SHORT_ALIGN, length); return this->wchar_translator_->write_wchar_array (*this, x, length); } ACE_INLINE ACE_CDR::Boolean ACE_OutputCDR::write_octet_array (const ACE_CDR::Octet* x, ACE_CDR::ULong length) { return this->write_array (x, ACE_CDR::OCTET_SIZE, ACE_CDR::OCTET_ALIGN, length); } ACE_INLINE ACE_CDR::Boolean ACE_OutputCDR::write_short_array (const ACE_CDR::Short *x, ACE_CDR::ULong length) { return this->write_array (x, ACE_CDR::SHORT_SIZE, ACE_CDR::SHORT_ALIGN, length); } ACE_INLINE ACE_CDR::Boolean ACE_OutputCDR::write_ushort_array (const ACE_CDR::UShort *x, ACE_CDR::ULong length) { return this->write_array (x, ACE_CDR::SHORT_SIZE, ACE_CDR::SHORT_ALIGN, length); } ACE_INLINE ACE_CDR::Boolean ACE_OutputCDR::write_long_array (const ACE_CDR::Long *x, ACE_CDR::ULong length) { return this->write_array (x, ACE_CDR::LONG_SIZE, ACE_CDR::LONG_ALIGN, length); } ACE_INLINE ACE_CDR::Boolean ACE_OutputCDR::write_ulong_array (const ACE_CDR::ULong *x, ACE_CDR::ULong length) { return this->write_array (x, ACE_CDR::LONG_SIZE, ACE_CDR::LONG_ALIGN, length); } ACE_INLINE ACE_CDR::Boolean ACE_OutputCDR::write_longlong_array (const ACE_CDR::LongLong *x, ACE_CDR::ULong length) { return this->write_array (x, ACE_CDR::LONGLONG_SIZE, ACE_CDR::LONGLONG_ALIGN, length); } ACE_INLINE ACE_CDR::Boolean ACE_OutputCDR::write_ulonglong_array (const ACE_CDR::ULongLong *x, ACE_CDR::ULong length) { return this->write_array (x, ACE_CDR::LONGLONG_SIZE, ACE_CDR::LONGLONG_ALIGN, length); } ACE_INLINE ACE_CDR::Boolean ACE_OutputCDR::write_float_array (const ACE_CDR::Float *x, ACE_CDR::ULong length) { return this->write_array (x, ACE_CDR::LONG_SIZE, ACE_CDR::LONG_ALIGN, length); } ACE_INLINE ACE_CDR::Boolean ACE_OutputCDR::write_double_array (const ACE_CDR::Double *x, ACE_CDR::ULong length) { return this->write_array (x, ACE_CDR::LONGLONG_SIZE, ACE_CDR::LONGLONG_ALIGN, length); } ACE_INLINE ACE_CDR::Boolean ACE_OutputCDR::write_longdouble_array (const ACE_CDR::LongDouble* x, ACE_CDR::ULong length) { return this->write_array (x, ACE_CDR::LONGDOUBLE_SIZE, ACE_CDR::LONGDOUBLE_ALIGN, length); } ACE_INLINE int ACE_OutputCDR::good_bit (void) const { return this->good_bit_; } ACE_INLINE int ACE_OutputCDR::adjust (size_t size, size_t align, char*& buf) { if (!this->current_is_writable_) return this->grow_and_adjust (size, align, buf); size_t offset = ACE_align_binary (this->current_alignment_, align) - this->current_alignment_; buf = this->current_->wr_ptr () + offset; char *end = buf + size; if (end <= this->current_->end ()) { this->current_alignment_ += offset + size; this->current_->wr_ptr (end); return 0; } return this->grow_and_adjust (size, align, buf); } ACE_INLINE int ACE_OutputCDR::adjust (size_t size, char*& buf) { return this->adjust (size, size, buf); } ACE_INLINE const ACE_Message_Block* ACE_OutputCDR::begin (void) const { return &this->start_; } ACE_INLINE const ACE_Message_Block* ACE_OutputCDR::end (void) const { return this->current_->cont (); } ACE_INLINE const ACE_Message_Block* ACE_OutputCDR::current (void) const { return this->current_; } ACE_INLINE size_t ACE_OutputCDR::total_length (void) const { return ACE_CDR::total_length (this->begin (), this->end ()); } ACE_INLINE const char* ACE_OutputCDR::buffer (void) const { return this->start_.rd_ptr (); } ACE_INLINE size_t ACE_OutputCDR::length (void) const { return this->start_.length (); } ACE_INLINE int ACE_OutputCDR::do_byte_swap (void) const { return this->do_byte_swap_; } ACE_INLINE size_t ACE_OutputCDR::current_alignment (void) const { return this->current_alignment_; } ACE_INLINE int ACE_OutputCDR::align_write_ptr (size_t alignment) { char *buf = ACE_ptr_align_binary (this->current_->wr_ptr (), alignment); if (buf <= this->current_->end ()) { this->current_->wr_ptr (buf); return 0; } return this->grow_and_adjust (0, alignment, buf); } ACE_INLINE ACE_Char_Codeset_Translator * ACE_OutputCDR::char_translator (void) const { return this->char_translator_; } ACE_INLINE ACE_WChar_Codeset_Translator * ACE_OutputCDR::wchar_translator (void) const { return this->wchar_translator_; } // **************************************************************** ACE_INLINE ACE_InputCDR::~ACE_InputCDR (void) { } ACE_INLINE ACE_CDR::Boolean ACE_InputCDR::read_octet (ACE_CDR::Octet& x) { return this->read_1 (&x); } ACE_INLINE ACE_CDR::Boolean ACE_InputCDR::read_boolean (ACE_CDR::Boolean& x) { ACE_CDR::Octet tmp; this->read_octet (tmp); x = tmp ? 1 : 0; return (ACE_CDR::Boolean) this->good_bit_; } ACE_INLINE ACE_CDR::Boolean ACE_InputCDR::read_char (ACE_CDR::Char &x) { if (this->char_translator_ == 0) return this->read_1 (ACE_reinterpret_cast (ACE_CDR::Octet*, &x)); return this->char_translator_->read_char (*this, x); } ACE_INLINE ACE_CDR::Boolean ACE_InputCDR::read_wchar (ACE_CDR::WChar& x) { if (this->wchar_translator_ == 0) return this->read_2 (ACE_reinterpret_cast (ACE_CDR::UShort*,&x)); return this->wchar_translator_->read_wchar (*this, x); } ACE_INLINE ACE_CDR::Boolean ACE_InputCDR::read_short (ACE_CDR::Short &x) { return this->read_2 (ACE_reinterpret_cast (ACE_CDR::UShort*, &x)); } ACE_INLINE ACE_CDR::Boolean ACE_InputCDR::read_ushort (ACE_CDR::UShort &x) { return this->read_2 (ACE_reinterpret_cast (ACE_CDR::UShort*, &x)); } ACE_INLINE ACE_CDR::Boolean ACE_InputCDR::read_long (ACE_CDR::Long &x) { return this->read_4 (ACE_reinterpret_cast (ACE_CDR::ULong*, &x)); } ACE_INLINE ACE_CDR::Boolean ACE_InputCDR::read_ulong (ACE_CDR::ULong &x) { return this->read_4 (ACE_reinterpret_cast (ACE_CDR::ULong*, &x)); } ACE_INLINE ACE_CDR::Boolean ACE_InputCDR::read_longlong (ACE_CDR::LongLong &x) { return this->read_8 (ACE_reinterpret_cast (ACE_CDR::ULongLong*, &x)); } ACE_INLINE ACE_CDR::Boolean ACE_InputCDR::read_ulonglong (ACE_CDR::ULongLong &x) { return this->read_8 (ACE_reinterpret_cast (ACE_CDR::ULongLong*,&x)); } ACE_INLINE ACE_CDR::Boolean ACE_InputCDR::read_float (ACE_CDR::Float &x) { return this->read_4 (ACE_reinterpret_cast (ACE_CDR::ULong*, &x)); } ACE_INLINE ACE_CDR::Boolean ACE_InputCDR::read_double (ACE_CDR::Double &x) { return this->read_8 (ACE_reinterpret_cast (ACE_CDR::ULongLong*, &x)); } ACE_INLINE ACE_CDR::Boolean ACE_InputCDR::read_longdouble (ACE_CDR::LongDouble &x) { return this->read_16 (ACE_reinterpret_cast (ACE_CDR::LongDouble*,&x)); } ACE_INLINE ACE_CDR::Boolean ACE_InputCDR::read_char_array (ACE_CDR::Char* x, ACE_CDR::ULong length) { if (this->char_translator_ == 0) return this->read_array (x, ACE_CDR::OCTET_SIZE, ACE_CDR::OCTET_ALIGN, length); return this->char_translator_->read_char_array (*this, x, length); } ACE_INLINE ACE_CDR::Boolean ACE_InputCDR::read_wchar_array (ACE_CDR::WChar* x, ACE_CDR::ULong length) { if (this->wchar_translator_ == 0) return this->read_array (x, ACE_CDR::SHORT_SIZE, ACE_CDR::SHORT_ALIGN, length); return this->wchar_translator_->read_wchar_array (*this, x, length); } ACE_INLINE ACE_CDR::Boolean ACE_InputCDR::read_octet_array (ACE_CDR::Octet* x, ACE_CDR::ULong length) { return this->read_array (x, ACE_CDR::OCTET_SIZE, ACE_CDR::OCTET_ALIGN, length); } ACE_INLINE ACE_CDR::Boolean ACE_InputCDR::read_short_array (ACE_CDR::Short *x, ACE_CDR::ULong length) { return this->read_array (x, ACE_CDR::SHORT_SIZE, ACE_CDR::SHORT_ALIGN, length); } ACE_INLINE ACE_CDR::Boolean ACE_InputCDR::read_ushort_array (ACE_CDR::UShort *x, ACE_CDR::ULong length) { return this->read_array (x, ACE_CDR::SHORT_SIZE, ACE_CDR::SHORT_ALIGN, length); } ACE_INLINE ACE_CDR::Boolean ACE_InputCDR::read_long_array (ACE_CDR::Long *x, ACE_CDR::ULong length) { return this->read_array (x, ACE_CDR::LONG_SIZE, ACE_CDR::LONG_ALIGN, length); } ACE_INLINE ACE_CDR::Boolean ACE_InputCDR::read_ulong_array (ACE_CDR::ULong *x, ACE_CDR::ULong length) { return this->read_array (x, ACE_CDR::LONG_SIZE, ACE_CDR::LONG_ALIGN, length); } ACE_INLINE ACE_CDR::Boolean ACE_InputCDR::read_longlong_array (ACE_CDR::LongLong *x, ACE_CDR::ULong length) { return this->read_array (x, ACE_CDR::LONGLONG_SIZE, ACE_CDR::LONGLONG_ALIGN, length); } ACE_INLINE ACE_CDR::Boolean ACE_InputCDR::read_ulonglong_array (ACE_CDR::ULongLong *x, ACE_CDR::ULong length) { return this->read_array (x, ACE_CDR::LONGLONG_SIZE, ACE_CDR::LONGLONG_ALIGN, length); } ACE_INLINE ACE_CDR::Boolean ACE_InputCDR::read_float_array (ACE_CDR::Float *x, ACE_CDR::ULong length) { return this->read_array (x, ACE_CDR::LONG_SIZE, ACE_CDR::LONG_ALIGN, length); } ACE_INLINE ACE_CDR::Boolean ACE_InputCDR::read_double_array (ACE_CDR::Double *x, ACE_CDR::ULong length) { return this->read_array (x, ACE_CDR::LONGLONG_SIZE, ACE_CDR::LONGLONG_ALIGN, length); } ACE_INLINE ACE_CDR::Boolean ACE_InputCDR::read_longdouble_array (ACE_CDR::LongDouble* x, ACE_CDR::ULong length) { return this->read_array (x, ACE_CDR::LONGDOUBLE_SIZE, ACE_CDR::LONGDOUBLE_ALIGN, length); } ACE_INLINE ACE_CDR::Boolean ACE_InputCDR::skip_char (void) { ACE_CDR::Char x; return this->read_1 (ACE_reinterpret_cast (ACE_CDR::Octet*,&x)); } ACE_INLINE ACE_CDR::Boolean ACE_InputCDR::skip_wchar (void) { ACE_CDR::WChar x; return this->read_2 (ACE_reinterpret_cast (ACE_CDR::UShort*,&x)); } ACE_INLINE ACE_CDR::Boolean ACE_InputCDR::skip_octet (void) { ACE_CDR::Octet x; return this->read_1 (&x); } ACE_INLINE ACE_CDR::Boolean ACE_InputCDR::skip_boolean (void) { ACE_CDR::Octet tmp; this->read_octet (tmp); return this->good_bit_; } ACE_INLINE ACE_CDR::Boolean ACE_InputCDR::skip_short (void) { ACE_CDR::Short x; return this->read_2 (ACE_reinterpret_cast (ACE_CDR::UShort*,&x)); } ACE_INLINE ACE_CDR::Boolean ACE_InputCDR::skip_ushort (void) { ACE_CDR::UShort x; return this->read_2 (ACE_reinterpret_cast (ACE_CDR::UShort*,&x)); } ACE_INLINE ACE_CDR::Boolean ACE_InputCDR::skip_long (void) { ACE_CDR::Long x; return this->read_4 (ACE_reinterpret_cast (ACE_CDR::ULong*,&x)); } ACE_INLINE ACE_CDR::Boolean ACE_InputCDR::skip_ulong (void) { ACE_CDR::ULong x; return this->read_4 (ACE_reinterpret_cast (ACE_CDR::ULong*,&x)); } ACE_INLINE ACE_CDR::Boolean ACE_InputCDR::skip_longlong (void) { ACE_CDR::LongLong x; return this->read_8 (ACE_reinterpret_cast (ACE_CDR::ULongLong*,&x)); } ACE_INLINE ACE_CDR::Boolean ACE_InputCDR::skip_ulonglong (void) { ACE_CDR::ULongLong x; return this->read_8 (ACE_reinterpret_cast (ACE_CDR::ULongLong*,&x)); } ACE_INLINE ACE_CDR::Boolean ACE_InputCDR::skip_float (void) { float x; return this->read_4 (ACE_reinterpret_cast (ACE_CDR::ULong*,&x)); } ACE_INLINE ACE_CDR::Boolean ACE_InputCDR::skip_double (void) { double x; return this->read_8 (ACE_reinterpret_cast (ACE_CDR::ULongLong*,&x)); } ACE_INLINE ACE_CDR::Boolean ACE_InputCDR::skip_longdouble (void) { ACE_CDR::LongDouble x; return this->read_16 (ACE_reinterpret_cast (ACE_CDR::LongDouble*,&x)); } ACE_INLINE char* ACE_InputCDR::end (void) { return this->start_.end (); } ACE_INLINE void ACE_InputCDR::rd_ptr (size_t offset) { this->start_.rd_ptr (offset); } ACE_INLINE char* ACE_InputCDR::rd_ptr (void) { return this->start_.rd_ptr (); } ACE_INLINE int ACE_InputCDR::adjust (size_t size, size_t align, char*& buf) { buf = ACE_ptr_align_binary (this->rd_ptr (), align); char *end = buf + size; if (end <= this->end ()) { this->start_.rd_ptr (end); return 0; } this->good_bit_ = 0; return -1; } ACE_INLINE int ACE_InputCDR::adjust (size_t size, char*& buf) { return this->adjust (size, size, buf); } ACE_INLINE size_t ACE_InputCDR::length (void) const { return this->start_.length (); } ACE_INLINE const ACE_Message_Block* ACE_InputCDR::start (void) const { return &this->start_; } ACE_INLINE int ACE_InputCDR::good_bit (void) const { return this->good_bit_; } // **************************************************************** ACE_INLINE ACE_CDR::Boolean operator<< (ACE_OutputCDR &os, ACE_CDR::Char x) { os.write_char (x); return os.good_bit (); } ACE_INLINE ACE_CDR::Boolean operator<< (ACE_OutputCDR &os, ACE_CDR::Short x) { os.write_short (x); return os.good_bit (); } ACE_INLINE ACE_CDR::Boolean operator<< (ACE_OutputCDR &os, ACE_CDR::UShort x) { os.write_ushort (x); return os.good_bit (); } ACE_INLINE ACE_CDR::Boolean operator<< (ACE_OutputCDR &os, ACE_CDR::Long x) { os.write_long (x); return os.good_bit (); } ACE_INLINE ACE_CDR::Boolean operator<< (ACE_OutputCDR &os, ACE_CDR::ULong x) { os.write_ulong (x); return os.good_bit (); } ACE_INLINE ACE_CDR::Boolean operator<< (ACE_OutputCDR &os, ACE_CDR::LongLong x) { os.write_longlong (x); return os.good_bit (); } ACE_INLINE ACE_CDR::Boolean operator<< (ACE_OutputCDR &os, ACE_CDR::ULongLong x) { os.write_ulonglong (x); return os.good_bit (); } ACE_INLINE ACE_CDR::Boolean operator<< (ACE_OutputCDR &os, ACE_CDR::LongDouble x) { os.write_longdouble (x); return os.good_bit (); } ACE_INLINE ACE_CDR::Boolean operator<< (ACE_OutputCDR &os, ACE_CDR::Float x) { os.write_float (x); return os.good_bit (); } ACE_INLINE ACE_CDR::Boolean operator<< (ACE_OutputCDR &os, ACE_CDR::Double x) { os.write_double (x); return os.good_bit (); } ACE_INLINE ACE_CDR::Boolean operator<< (ACE_OutputCDR &os, const ACE_CDR::Char *x) { os.write_string (x); return os.good_bit (); } ACE_INLINE ACE_CDR::Boolean operator<< (ACE_OutputCDR &os, const ACE_CDR::WChar *x) { os.write_wstring (x); return os.good_bit (); } ACE_INLINE ACE_CDR::Boolean operator<< (ACE_OutputCDR &os, const ACE_CString &x) { os.write_string (x); return os.good_bit (); } // The following use the helper classes ACE_INLINE ACE_CDR::Boolean operator<< (ACE_OutputCDR &os, ACE_OutputCDR::from_boolean x) { os.write_boolean (x.val_); return os.good_bit (); } ACE_INLINE ACE_CDR::Boolean operator<< (ACE_OutputCDR &os, ACE_OutputCDR::from_char x) { os.write_char (x.val_); return os.good_bit (); } ACE_INLINE ACE_CDR::Boolean operator<< (ACE_OutputCDR &os, ACE_OutputCDR::from_wchar x) { os.write_wchar (x.val_); return os.good_bit (); } ACE_INLINE ACE_CDR::Boolean operator<< (ACE_OutputCDR &os, ACE_OutputCDR::from_octet x) { os.write_octet (x.val_); return os.good_bit (); } ACE_INLINE ACE_CDR::Boolean operator<< (ACE_OutputCDR &os, ACE_OutputCDR::from_string x) { ACE_CDR::ULong len = 0; if (x.val_ != 0) len = ACE_OS::strlen (x.val_); os.write_string (len, x.val_); return os.good_bit () && (len <= x.bound_); } ACE_INLINE ACE_CDR::Boolean operator<< (ACE_OutputCDR &os, ACE_OutputCDR::from_wstring x) { ACE_CDR::ULong len = 0;; if (x.val_ != 0) len = ACE_OS::wslen (x.val_); os.write_wstring (len, x.val_); return os.good_bit () && (len <= x.bound_); } // **************************************************************** ACE_INLINE ACE_CDR::Boolean operator>> (ACE_InputCDR &is, ACE_CDR::Char &x) { is.read_char (x); return is.good_bit (); } ACE_INLINE ACE_CDR::Boolean operator>> (ACE_InputCDR &is, ACE_CDR::Short &x) { is.read_short (x); return is.good_bit (); } ACE_INLINE ACE_CDR::Boolean operator>> (ACE_InputCDR &is, ACE_CDR::UShort &x) { is.read_ushort (x); return is.good_bit (); } ACE_INLINE ACE_CDR::Boolean operator>>(ACE_InputCDR &is, ACE_CDR::Long &x) { is.read_long (x); return is.good_bit (); } ACE_INLINE ACE_CDR::Boolean operator>> (ACE_InputCDR &is, ACE_CDR::ULong &x) { is.read_ulong (x); return is.good_bit (); } ACE_INLINE ACE_CDR::Boolean operator>> (ACE_InputCDR& is, ACE_CDR::LongLong &x) { is.read_longlong (x); return is.good_bit (); } ACE_INLINE ACE_CDR::Boolean operator>> (ACE_InputCDR& is, ACE_CDR::ULongLong &x) { is.read_ulonglong (x); return is.good_bit (); } ACE_INLINE ACE_CDR::Boolean operator>> (ACE_InputCDR& is, ACE_CDR::LongDouble &x) { is.read_longdouble (x); return is.good_bit (); } ACE_INLINE ACE_CDR::Boolean operator>> (ACE_InputCDR &is, ACE_CDR::Float &x) { is.read_float (x); return is.good_bit (); } ACE_INLINE ACE_CDR::Boolean operator>> (ACE_InputCDR &is, ACE_CDR::Double &x) { is.read_double (x); return is.good_bit (); } ACE_INLINE ACE_CDR::Boolean operator>> (ACE_InputCDR &is, ACE_CDR::Char *&x) { is.read_string (x); return is.good_bit (); } ACE_INLINE ACE_CDR::Boolean operator>> (ACE_InputCDR &is, ACE_CDR::WChar *&x) { is.read_wstring (x); return is.good_bit (); } ACE_INLINE ACE_CDR::Boolean operator>> (ACE_InputCDR &is, ACE_CString &x) { is.read_string (x); return is.good_bit (); } // The following use the helper classes ACE_INLINE ACE_CDR::Boolean operator>> (ACE_InputCDR &is, ACE_InputCDR::to_boolean x) { is.read_boolean (x.ref_); return is.good_bit (); } ACE_INLINE ACE_CDR::Boolean operator>> (ACE_InputCDR &is, ACE_InputCDR::to_char x) { is.read_char (x.ref_); return is.good_bit (); } ACE_INLINE ACE_CDR::Boolean operator>> (ACE_InputCDR &is, ACE_InputCDR::to_wchar x) { is.read_wchar (x.ref_); return is.good_bit (); } ACE_INLINE ACE_CDR::Boolean operator>> (ACE_InputCDR &is, ACE_InputCDR::to_octet x) { is.read_octet (x.ref_); return is.good_bit (); } ACE_INLINE ACE_CDR::Boolean operator>> (ACE_InputCDR &is, ACE_InputCDR::to_string x) { is.read_string (x.val_); // check if the bounds are satisfied return (is.good_bit () && (ACE_OS::strlen (x.val_) <= x.bound_)); } ACE_INLINE ACE_CDR::Boolean operator>> (ACE_InputCDR &is, ACE_InputCDR::to_wstring x) { is.read_wstring (x.val_); // check if the bounds are satisfied return (is.good_bit () && (ACE_OS::wslen (x.val_) <= x.bound_)); } // *************************************************************************** // We must define these methods here because they use the "read_*" inlined // methods of the ACE_InputCDR class // *************************************************************************** ACE_INLINE ACE_CDR::Boolean ACE_OutputCDR::append_boolean (ACE_InputCDR &stream) { ACE_CDR::Boolean x; return (stream.read_boolean (x) ? this->write_boolean (x) : 0); } ACE_INLINE ACE_CDR::Boolean ACE_OutputCDR::append_char (ACE_InputCDR &stream) { ACE_CDR::Char x; return (stream.read_char (x) ? this->write_char (x) : 0); } ACE_INLINE ACE_CDR::Boolean ACE_OutputCDR::append_wchar (ACE_InputCDR &stream) { ACE_CDR::WChar x; return (stream.read_wchar (x) ? this->write_wchar (x) : 0); } ACE_INLINE ACE_CDR::Boolean ACE_OutputCDR::append_octet (ACE_InputCDR &stream) { ACE_CDR::Octet x; return (stream.read_octet (x) ? this->write_octet (x) : 0); } ACE_INLINE ACE_CDR::Boolean ACE_OutputCDR::append_short (ACE_InputCDR &stream) { ACE_CDR::Short x; return (stream.read_short (x) ? this->write_short (x) : 0); } ACE_INLINE ACE_CDR::Boolean ACE_OutputCDR::append_ushort (ACE_InputCDR &stream) { ACE_CDR::UShort x; return (stream.read_ushort (x) ? this->write_ushort (x) : 0); } ACE_INLINE ACE_CDR::Boolean ACE_OutputCDR::append_long (ACE_InputCDR &stream) { ACE_CDR::Long x; return (stream.read_long (x) ? this->write_long (x) : 0); } ACE_INLINE ACE_CDR::Boolean ACE_OutputCDR::append_ulong (ACE_InputCDR &stream) { ACE_CDR::ULong x; return (stream.read_ulong (x) ? this->write_ulong (x) : 0); } ACE_INLINE ACE_CDR::Boolean ACE_OutputCDR::append_longlong (ACE_InputCDR &stream) { ACE_CDR::LongLong x; return (stream.read_longlong (x) ? this->write_longlong (x) : 0); } ACE_INLINE ACE_CDR::Boolean ACE_OutputCDR::append_ulonglong (ACE_InputCDR &stream) { ACE_CDR::ULongLong x; return (stream.read_ulonglong (x) ? this->write_ulonglong (x) : 0); } ACE_INLINE ACE_CDR::Boolean ACE_OutputCDR::append_float (ACE_InputCDR &stream) { ACE_CDR::Float x; return (stream.read_float (x) ? this->write_float (x) : 0); } ACE_INLINE ACE_CDR::Boolean ACE_OutputCDR::append_double (ACE_InputCDR &stream) { ACE_CDR::Double x; return (stream.read_double (x) ? this->write_double (x) : 0); } ACE_INLINE ACE_CDR::Boolean ACE_OutputCDR::append_longdouble (ACE_InputCDR &stream) { ACE_CDR::LongDouble x; return (stream.read_longdouble (x) ? this->write_longdouble (x) : 0); } ACE_INLINE ACE_CDR::Boolean ACE_OutputCDR::append_string (ACE_InputCDR &stream) { ACE_CDR::Char *x; ACE_CDR::Boolean flag = (stream.read_string (x) ? this->write_string (x) : 0); delete [] x; return flag; } ACE_INLINE ACE_CDR::Boolean ACE_OutputCDR::append_wstring (ACE_InputCDR &stream) { ACE_CDR::WChar *x; ACE_CDR::Boolean flag = (stream.read_wstring (x) ? this->write_wstring (x) : 0); delete [] x; return flag; } ACE_INLINE void ACE_InputCDR::reset_byte_order (int byte_order) { this->do_byte_swap_ = (byte_order != ACE_CDR_BYTE_ORDER); } ACE_INLINE int ACE_InputCDR::do_byte_swap (void) const { return this->do_byte_swap_; } ACE_INLINE int ACE_InputCDR::byte_order (void) const { if (this->do_byte_swap ()) return !ACE_CDR_BYTE_ORDER; else return ACE_CDR_BYTE_ORDER; } ACE_INLINE int ACE_InputCDR::align_read_ptr (size_t alignment) { char *buf = ACE_ptr_align_binary (this->rd_ptr (), alignment); if (buf <= this->end ()) { this->start_.rd_ptr (buf); return 0; } this->good_bit_ = 0; return -1; } ACE_INLINE ACE_Char_Codeset_Translator * ACE_InputCDR::char_translator (void) const { return this->char_translator_; } ACE_INLINE ACE_WChar_Codeset_Translator * ACE_InputCDR::wchar_translator (void) const { return this->wchar_translator_; } // **************************************************************** ACE_INLINE ACE_CDR::Boolean ACE_Char_Codeset_Translator::read_1 (ACE_InputCDR& input, ACE_CDR::Octet *x) { return input.read_1 (x); } ACE_INLINE ACE_CDR::Boolean ACE_Char_Codeset_Translator::write_1 (ACE_OutputCDR& output, const ACE_CDR::Octet *x) { return output.write_1 (x); } ACE_INLINE ACE_CDR::Boolean ACE_Char_Codeset_Translator::read_array (ACE_InputCDR& in, void* x, size_t size, size_t align, ACE_CDR::ULong length) { return in.read_array (x, size, align, length); } ACE_INLINE ACE_CDR::Boolean ACE_Char_Codeset_Translator::write_array (ACE_OutputCDR& out, const void *x, size_t size, size_t align, ACE_CDR::ULong length) { return out.write_array(x, size, align, length); } ACE_INLINE int ACE_Char_Codeset_Translator::adjust (ACE_OutputCDR& out, size_t size, size_t align, char *&buf) { return out.adjust(size, align, buf); } ACE_INLINE void ACE_Char_Codeset_Translator::good_bit (ACE_OutputCDR& out, int bit) { out.good_bit_ = bit; } // **************************************************************** ACE_INLINE ACE_CDR::Boolean ACE_WChar_Codeset_Translator::read_1 (ACE_InputCDR& input, ACE_CDR::Octet *x) { return input.read_1 (x); } ACE_INLINE ACE_CDR::Boolean ACE_WChar_Codeset_Translator::read_2 (ACE_InputCDR& input, ACE_CDR::UShort *x) { return input.read_2 (x); } ACE_INLINE ACE_CDR::Boolean ACE_WChar_Codeset_Translator::read_4 (ACE_InputCDR& input, ACE_CDR::ULong *x) { return input.read_4 (x); } ACE_INLINE ACE_CDR::Boolean ACE_WChar_Codeset_Translator::write_1 (ACE_OutputCDR& output, const ACE_CDR::Octet *x) { return output.write_1 (x); } ACE_INLINE ACE_CDR::Boolean ACE_WChar_Codeset_Translator::write_2 (ACE_OutputCDR& output, const ACE_CDR::UShort *x) { return output.write_2 (x); } ACE_INLINE ACE_CDR::Boolean ACE_WChar_Codeset_Translator::write_4 (ACE_OutputCDR& output, const ACE_CDR::ULong *x) { return output.write_4 (x); } ACE_INLINE ACE_CDR::Boolean ACE_WChar_Codeset_Translator::read_array (ACE_InputCDR& in, void* x, size_t size, size_t align, ACE_CDR::ULong length) { return in.read_array (x, size, align, length); } ACE_INLINE ACE_CDR::Boolean ACE_WChar_Codeset_Translator::write_array (ACE_OutputCDR& out, const void *x, size_t size, size_t align, ACE_CDR::ULong length) { return out.write_array(x, size, align, length); } ACE_INLINE int ACE_WChar_Codeset_Translator::adjust (ACE_OutputCDR& out, size_t size, size_t align, char *&buf) { return out.adjust(size, align, buf); } ACE_INLINE void ACE_WChar_Codeset_Translator::good_bit (ACE_OutputCDR& out, int bit) { out.good_bit_ = bit; }