ACE/protocols/ace/INet/String_IOStream.cpp

   1 #ifndef ACE_IOS_STRING_IOSTREAM_CPP
   2 #define ACE_IOS_STRING_IOSTREAM_CPP
   3
   4 #include "ace/INet/String_IOStream.h"
   5 #include "ace/INet/IOS_util.h"
   6 #include "ace/Truncate.h"
   7
   8 ACE_BEGIN_VERSIONED_NAMESPACE_DECL
   9
  10 namespace ACE
  11 {
  12   namespace IOS
  13   {
  14     template <class ACE_CHAR_T, class TR>
  15     String_StreamBufferBase<ACE_CHAR_T, TR>::String_StreamBufferBase (openmode mode)
  16       : BasicBufferedStreamBuffer<ACE_CHAR_T, TR> (BUFFER_SIZE, mode),
  17         string_ref_ (&string_),
  18         rd_ptr_ (0)
  19       {
  20       }
  21
  22     template <class ACE_CHAR_T, class TR>
  23     String_StreamBufferBase<ACE_CHAR_T, TR>::String_StreamBufferBase (string_type& string, openmode mode)
  24       : BasicBufferedStreamBuffer<ACE_CHAR_T, TR> (BUFFER_SIZE, mode),
  25         string_ref_ (&string),
  26         rd_ptr_ (0)
  27       {
  28       }
  29
  30     template <class ACE_CHAR_T, class TR>
  31     String_StreamBufferBase<ACE_CHAR_T, TR>::~String_StreamBufferBase ()
  32       {
  33       }
  34
  35     template <class ACE_CHAR_T, class TR>
  36     typename String_StreamBufferBase<ACE_CHAR_T, TR>::pos_type
  37     String_StreamBufferBase<ACE_CHAR_T, TR>::seekoff (
  38         off_type off,
  39         seekdir way,
  40         openmode which)
  41       {
  42         if (which != this->get_mode () || which == std::ios::out)
  43           return pos_type (-1);
  44
  45         size_type spos = 0;
  46         if (way == std::ios::cur)
  47           spos = this->rd_ptr_;
  48         else if (way == std::ios::end)
  49           spos = this->string_ref_->length ();
  50         spos += off;
  51         if (spos < this->string_ref_->length ())
  52           this->rd_ptr_ = spos;
  53         else
  54           this->rd_ptr_ = this->string_ref_->length ();
  55
  56         this->setg (this->eback (), this->eback (), this->eback ());
  57         return pos_type (this->rd_ptr_);
  58       }
  59
  60     template <class ACE_CHAR_T, class TR>
  61     typename String_StreamBufferBase<ACE_CHAR_T, TR>::pos_type
  62     String_StreamBufferBase<ACE_CHAR_T, TR>::seekpos (
  63         pos_type pos,
  64         openmode which)
  65       {
  66         return this->seekoff (pos_type (pos), std::ios::beg, which);
  67       }
  68
  69     template <class ACE_CHAR_T, class TR>
  70     const typename String_StreamBufferBase<ACE_CHAR_T, TR>::string_type&
  71     String_StreamBufferBase<ACE_CHAR_T, TR>::str () const
  72       {
  73         const_cast<String_StreamBufferBase<ACE_CHAR_T, TR>*> (this)->sync ();
  74         return *this->string_ref_;
  75       }
  76
  77     template <class ACE_CHAR_T, class TR>
  78     void String_StreamBufferBase<ACE_CHAR_T, TR>::close_string ()
  79       {
  80         this->sync ();
  81         this->string_ref_ = 0;
  82       }
  83
  84     template <class ACE_CHAR_T, class TR>
  85     void String_StreamBufferBase<ACE_CHAR_T, TR>::clear_string ()
  86       {
  87         this->sync ();
  88         this->string_ref_->clear ();
  89       }
  90
  91     template <class ACE_CHAR_T, class TR>
  92     int String_StreamBufferBase<ACE_CHAR_T, TR>::read_from_stream (char_type* buffer, std::streamsize length)
  93       {
  94         int n = 0;
  95         if (this->string_ref_)
  96           {
  97             if ((this->rd_ptr_ + length) > this->string_ref_->length ())
  98               {
  99                 length = this->string_ref_->length () - this->rd_ptr_;
 100               }
 101             ACE_OS::memmove (buffer, &(*this->string_ref_)[this->rd_ptr_], length * sizeof (char_type));
 102             this->rd_ptr_ += length;
 103             n = ACE_Utils::truncate_cast<int> (length);
 104           }
 105         return n;
 106       }
 107
 108     template <class ACE_CHAR_T, class TR>
 109     int String_StreamBufferBase<ACE_CHAR_T, TR>::write_to_stream (const char_type* buffer, std::streamsize length)
 110       {
 111         int n = 0;
 112         if (this->string_ref_)
 113           {
 114             this->string_ref_->append (buffer, length);
 115             n = ACE_Utils::truncate_cast<int> (length);
 116           }
 117         return n;
 118       }
 119
 120     template <class ACE_CHAR_T, class TR>
 121     String_IOSBase<ACE_CHAR_T, TR>::String_IOSBase (openmode mode)
 122       : streambuf_ (mode)
 123       {
 124         ace_ios_init (&this->streambuf_);
 125       }
 126
 127     template <class ACE_CHAR_T, class TR>
 128     String_IOSBase<ACE_CHAR_T, TR>::String_IOSBase (string_type& string, openmode mode)
 129       : streambuf_ (string, mode)
 130       {
 131         ace_ios_init (&this->streambuf_);
 132       }
 133
 134     template <class ACE_CHAR_T, class TR>
 135     String_IOSBase<ACE_CHAR_T, TR>::~String_IOSBase ()
 136       {
 137         this->close ();
 138       }
 139
 140     template <class ACE_CHAR_T, class TR>
 141     typename String_IOSBase<ACE_CHAR_T, TR>::buffer_type*
 142     String_IOSBase<ACE_CHAR_T, TR>::rdbuf ()
 143       {
 144         return &this->streambuf_;
 145       }
 146
 147     template <class ACE_CHAR_T, class TR>
 148     void String_IOSBase<ACE_CHAR_T, TR>::close ()
 149       {
 150         this->streambuf_.close_string ();
 151       }
 152
 153     template <class ACE_CHAR_T, class TR>
 154     const typename String_IOSBase<ACE_CHAR_T, TR>::buffer_type&
 155     String_IOSBase<ACE_CHAR_T, TR>::stream () const
 156       {
 157         return this->streambuf_;
 158       }
 159
 160     template <class ACE_CHAR_T, class TR>
 161     String_OStreamBase<ACE_CHAR_T, TR>::String_OStreamBase()
 162       : String_IOSBase<ACE_CHAR_T, TR> (std::ios::out),
 163         std::basic_ostream<ACE_CHAR_T, TR> (String_IOSBase<ACE_CHAR_T, TR>::rdbuf ())
 164       {
 165       }
 166
 167     template <class ACE_CHAR_T, class TR>
 168     String_OStreamBase<ACE_CHAR_T, TR>::String_OStreamBase(string_type& string)
 169       : String_IOSBase<ACE_CHAR_T, TR> (string, std::ios::out),
 170         std::basic_ostream<ACE_CHAR_T, TR> (String_IOSBase<ACE_CHAR_T, TR>::rdbuf ())
 171       {
 172       }
 173
 174     template <class ACE_CHAR_T, class TR>
 175     String_OStreamBase<ACE_CHAR_T, TR>::~String_OStreamBase()
 176       {
 177       }
 178
 179     template <class ACE_CHAR_T, class TR>
 180     const typename String_OStreamBase<ACE_CHAR_T, TR>::string_type&
 181     String_OStreamBase<ACE_CHAR_T, TR>::str () const
 182       {
 183         return this->stream ().str ();
 184       }
 185
 186     template <class ACE_CHAR_T, class TR>
 187     void String_OStreamBase<ACE_CHAR_T, TR>::clear ()
 188       {
 189         return this->rdbuf ()->clear_string ();
 190       }
 191
 192     template <class ACE_CHAR_T, class TR>
 193     String_IStreamBase<ACE_CHAR_T, TR>::String_IStreamBase()
 194       : String_IOSBase<ACE_CHAR_T, TR> (std::ios::in),
 195         std::basic_istream<ACE_CHAR_T, TR> (String_IOSBase<ACE_CHAR_T, TR>::rdbuf ())
 196       {
 197       }
 198
 199     template <class ACE_CHAR_T, class TR>
 200     String_IStreamBase<ACE_CHAR_T, TR>::String_IStreamBase(const string_type& string)
 201       : String_IOSBase<ACE_CHAR_T, TR> (const_cast<string_type&> (string),
 202                                         std::ios::in),
 203         std::basic_istream<ACE_CHAR_T, TR> (String_IOSBase<ACE_CHAR_T, TR>::rdbuf ())
 204       {
 205       }
 206
 207     template <class ACE_CHAR_T, class TR>
 208     String_IStreamBase<ACE_CHAR_T, TR>::~String_IStreamBase()
 209       {
 210       }
 211
 212     template <class ACE_CHAR_T, class TR>
 213     String_IStreamBase<ACE_CHAR_T, TR>&
 214     String_IStreamBase<ACE_CHAR_T, TR>::rewind ()
 215       {
 216         this->rdbuf ()->pubseekpos (0, std::ios::in);
 217         this->clear ();
 218         return *this;
 219       }
 220   }
 221 }
 222
 223 ACE_END_VERSIONED_NAMESPACE_DECL
 224
 225 #endif /* ACE_IOS_STRING_IOSTREAM_CPP */