ACE/protocols/ace/INet/FTP_IOStream.h

   1 /**
   2  * @file FTP_IOStream.h
   3  *
   4  * @author Martin Corino <mcorino@remedy.nl>
   5  */
   6
   7 #ifndef ACE_FTP_IOSTREAM_H
   8 #define ACE_FTP_IOSTREAM_H
   9
  10 #include /**/ "ace/pre.h"
  11
  12 #include /**/ "ace/config-all.h"
  13
  14 #if !defined (ACE_LACKS_PRAGMA_ONCE)
  15 # pragma once
  16 #endif /* ACE_LACKS_PRAGMA_ONCE */
  17
  18 #include "ace/INet/INet_Export.h"
  19 #include "ace/INet/BufferedStreamBuffer.h"
  20 #include <ostream>
  21 #include <istream>
  22
  23 ACE_BEGIN_VERSIONED_NAMESPACE_DECL
  24
  25 namespace ACE
  26   {
  27     namespace FTP
  28       {
  29         /**
  30         * @class ACE_FTP_StreamBuffer
  31         *
  32         * @brief
  33         *
  34         */
  35         class ACE_INET_Export StreamBuffer
  36           : public ACE::IOS::BufferedStreamBuffer
  37           {
  38             public:
  39               StreamBuffer (std::iostream * stream);
  40               virtual ~StreamBuffer ();
  41
  42               virtual int sync ();
  43
  44               std::iostream* set_stream (std::iostream * stream);
  45
  46             protected:
  47               enum
  48                 {
  49                   BUFFER_SIZE = 4096
  50                 };
  51
  52               virtual int read_from_stream (char* buffer, std::streamsize length);
  53
  54               virtual int write_to_stream (const char* buffer, std::streamsize length);
  55
  56             private:
  57               std::iostream * stream_;
  58           };
  59
  60
  61         /**
  62         * @class ACE_FTP_IOS
  63         *
  64         * @brief
  65         *
  66         */
  67         class ACE_INET_Export IOS
  68           : public virtual std::ios
  69           {
  70             public:
  71               IOS (std::iostream* stream);
  72               ~IOS ();
  73
  74               StreamBuffer* rdbuf ();
  75
  76               std::iostream* set_stream (std::iostream* stream);
  77
  78             protected:
  79               StreamBuffer streambuf_;
  80           };
  81
  82         /**
  83         * @class ACE_FTP_OStream
  84         *
  85         * @brief
  86         *
  87         */
  88         class ACE_INET_Export OStream
  89           : public IOS, public std::ostream
  90           {
  91             public:
  92               explicit OStream(std::iostream* stream);
  93               ~OStream();
  94
  95               void set_interceptor (StreamBuffer::interceptor_type& interceptor);
  96           };
  97
  98         /**
  99         * @class ACE_FTP_IStream
 100         *
 101         * @brief
 102         *
 103         */
 104         class ACE_INET_Export IStream
 105           : public IOS, public std::istream
 106           {
 107             public:
 108               explicit IStream(std::iostream* stream);
 109               ~IStream();
 110
 111               void set_interceptor (StreamBuffer::interceptor_type& interceptor);
 112           };
 113       }
 114   }
 115
 116 ACE_END_VERSIONED_NAMESPACE_DECL
 117
 118 #if defined (__ACE_INLINE__)
 119 #include "ace/INet/FTP_IOStream.inl"
 120 #endif
 121
 122 #include /**/ "ace/post.h"
 123 #endif /* ACE_FTP_IOSTREAM_H */