ACE/protocols/ace/INet/HTTP_IOStream.h

   1 /**
   2  * @file HTTP_IOStream.h
   3  *
   4  * @author Martin Corino <mcorino@remedy.nl>
   5  */
   6
   7 #ifndef ACE_HTTP_IOSTREAM_H
   8 #define ACE_HTTP_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 "ace/INet/HTTP_StreamPolicyBase.h"
  21 #include <ostream>
  22 #include <istream>
  23
  24 ACE_BEGIN_VERSIONED_NAMESPACE_DECL
  25
  26 namespace ACE
  27   {
  28     namespace HTTP
  29       {
  30         /**
  31         * @class ACE_HTTP_StreamBuffer
  32         *
  33         * @brief
  34         *
  35         */
  36         class ACE_INET_Export StreamBuffer
  37           : public ACE::IOS::BufferedStreamBuffer
  38           {
  39             public:
  40               typedef StreamPolicyBase<StreamBuffer>  policy_type;
  41
  42               StreamBuffer (std::iostream& stream, policy_type* policy = 0);
  43               virtual ~StreamBuffer ();
  44
  45               virtual int sync ();
  46
  47             protected:
  48               friend class StreamPolicyBase<StreamBuffer>;
  49
  50               enum
  51                 {
  52                   BUFFER_SIZE = 4096
  53                 };
  54
  55               virtual int read_from_stream (char* buffer, std::streamsize length);
  56
  57               virtual int write_to_stream (const char* buffer, std::streamsize length);
  58
  59               virtual int read_from_stream_i (char* buffer, std::streamsize length);
  60
  61               virtual int write_to_stream_i (const char* buffer, std::streamsize length);
  62
  63             private:
  64               std::iostream & stream_;
  65               policy_type * policy_;
  66           };
  67
  68
  69         /**
  70         * @class ACE_HTTP_IOS
  71         *
  72         * @brief
  73         *
  74         */
  75         class ACE_INET_Export IOS
  76           : public virtual std::ios
  77           {
  78             public:
  79               IOS (std::iostream& stream, StreamBuffer::policy_type* policy = 0);
  80               ~IOS ();
  81
  82               StreamBuffer* rdbuf ();
  83
  84             protected:
  85               StreamBuffer streambuf_;
  86           };
  87
  88         /**
  89         * @class ACE_HTTP_OStream
  90         *
  91         * @brief
  92         *
  93         */
  94         class ACE_INET_Export OStream
  95           : public IOS, public std::ostream
  96           {
  97             public:
  98               explicit OStream(std::iostream& stream, StreamBuffer::policy_type* policy = 0);
  99               ~OStream();
 100
 101               void set_interceptor (StreamBuffer::interceptor_type& interceptor);
 102           };
 103
 104         /**
 105         * @class ACE_HTTP_IStream
 106         *
 107         * @brief
 108         *
 109         */
 110         class ACE_INET_Export IStream
 111           : public IOS, public std::istream
 112           {
 113             public:
 114               explicit IStream(std::iostream& stream, StreamBuffer::policy_type* policy = 0);
 115               ~IStream();
 116
 117               void set_interceptor (StreamBuffer::interceptor_type& interceptor);
 118           };
 119       }
 120   }
 121
 122 ACE_END_VERSIONED_NAMESPACE_DECL
 123
 124 #if defined (__ACE_INLINE__)
 125 #include "ace/INet/HTTP_IOStream.inl"
 126 #endif
 127
 128 #include /**/ "ace/post.h"
 129 #endif /* ACE_HTTP_IOSTREAM_H */