ACE/protocols/ace/INet/FTP_IOStream.cpp

   1 #include "ace/INet/FTP_IOStream.h"
   2 #include "ace/INet/IOS_util.h"
   3
   4 #if !defined (__ACE_INLINE__)
   5 #include "ace/INet/FTP_IOStream.inl"
   6 #endif
   7
   8 #include "ace/Truncate.h"
   9
  10
  11 ACE_BEGIN_VERSIONED_NAMESPACE_DECL
  12
  13 namespace ACE
  14 {
  15   namespace FTP
  16   {
  17     StreamBuffer::StreamBuffer (std::iostream * stream)
  18       : ACE::IOS::BufferedStreamBuffer (BUFFER_SIZE,
  19                                         std::ios::in | std::ios::out),
  20         stream_ (stream)
  21       {
  22       }
  23
  24     StreamBuffer::~StreamBuffer ()
  25       {
  26       }
  27
  28     std::iostream* StreamBuffer::set_stream (std::iostream * stream)
  29       {
  30         std::iostream * old_stream = this->stream_;
  31         this->stream_ = stream;
  32         this->reset_buffers ();
  33         return old_stream;
  34       }
  35
  36     int StreamBuffer::read_from_stream (char* buffer, std::streamsize length)
  37       {
  38         if (this->stream_ == 0) return -1;
  39         this->stream_->read (buffer, length);
  40         return ACE_Utils::truncate_cast<int> (this->stream_->gcount ());
  41       }
  42
  43     int StreamBuffer::write_to_stream (const char* buffer, std::streamsize length)
  44       {
  45         if (this->stream_ == 0) return -1;
  46         this->stream_->write (buffer, length);
  47         return this->stream_->good () ? ACE_Utils::truncate_cast<int> (length) : -1;
  48       }
  49
  50     int StreamBuffer::sync ()
  51       {
  52         if (this->stream_ == 0) return -1;
  53         if (ACE::IOS::BufferedStreamBuffer::sync () == -1)
  54           return -1;
  55         return this->stream_->sync ();
  56       }
  57
  58     IOS::IOS (std::iostream * stream)
  59       : streambuf_ (stream)
  60       {
  61         ace_ios_init (&this->streambuf_);
  62       }
  63
  64     IOS::~IOS ()
  65       {
  66         try
  67           {
  68             this->streambuf_.sync();
  69           }
  70         catch (...)
  71           {
  72           }
  73       }
  74
  75     std::iostream* IOS::set_stream (std::iostream* stream)
  76       {
  77         std::iostream* old_stream = this->rdbuf ()->set_stream (stream);
  78         this->clear ();
  79         return old_stream;
  80       }
  81
  82     OStream::OStream(std::iostream * stream)
  83       : IOS (stream), std::ostream (&streambuf_)
  84       {
  85       }
  86
  87     OStream::~OStream()
  88       {
  89       }
  90
  91     IStream::IStream(std::iostream * stream)
  92       : IOS (stream), std::istream (&streambuf_)
  93       {
  94       }
  95
  96     IStream::~IStream()
  97       {
  98       }
  99
 100   }
 101 }
 102
 103 ACE_END_VERSIONED_NAMESPACE_DECL