ACE/protocols/ace/INet/Sock_IOStream.cpp

   1 #ifndef ACE_IOS_SOCK_IOSTREAM_CPP
   2 #define ACE_IOS_SOCK_IOSTREAM_CPP
   3
   4 #include "ace/INet/Sock_IOStream.h"
   5 #include "ace/INet/IOS_util.h"
   6
   7 ACE_BEGIN_VERSIONED_NAMESPACE_DECL
   8
   9 namespace ACE
  10 {
  11   namespace IOS
  12   {
  13     template <ACE_SYNCH_DECL>
  14     Sock_StreamBufferBase<ACE_SYNCH_USE>::Sock_StreamBufferBase (stream_type* stream)
  15       : BidirStreamBuffer<StreamHandler<ACE_SOCK_STREAM, ACE_SYNCH_USE> > (
  16             stream,
  17             BUFFER_SIZE,
  18             std::ios::in | std::ios::out)
  19       {
  20       }
  21
  22     template <ACE_SYNCH_DECL>
  23     Sock_StreamBufferBase<ACE_SYNCH_USE>::~Sock_StreamBufferBase ()
  24       {
  25       }
  26
  27     template <ACE_SYNCH_DECL>
  28     Sock_IOSBase<ACE_SYNCH_USE>::Sock_IOSBase (stream_type* stream)
  29       : streambuf_ (stream)
  30       {
  31         ace_ios_init (&this->streambuf_);
  32       }
  33
  34     template <ACE_SYNCH_DECL>
  35     Sock_IOSBase<ACE_SYNCH_USE>::~Sock_IOSBase ()
  36       {
  37         try
  38           {
  39             this->streambuf_.sync();
  40           }
  41         catch (...)
  42           {
  43           }
  44       }
  45
  46     template <ACE_SYNCH_DECL>
  47     typename Sock_IOSBase<ACE_SYNCH_USE>::buffer_type*
  48     Sock_IOSBase<ACE_SYNCH_USE>::rdbuf ()
  49       {
  50         return &this->streambuf_;
  51       }
  52
  53     template <ACE_SYNCH_DECL>
  54     void Sock_IOSBase<ACE_SYNCH_USE>::close ()
  55       {
  56         this->streambuf_.sync ();
  57         this->streambuf_.close_stream ();
  58       }
  59
  60     template <ACE_SYNCH_DECL>
  61     const typename Sock_IOSBase<ACE_SYNCH_USE>::stream_type&
  62     Sock_IOSBase<ACE_SYNCH_USE>::stream () const
  63       {
  64         return this->streambuf_.stream ();
  65       }
  66
  67
  68     template <ACE_SYNCH_DECL>
  69     Sock_OStreamBase<ACE_SYNCH_USE>::Sock_OStreamBase(stream_type* stream)
  70       : Sock_IOSBase<ACE_SYNCH_USE> (stream), std::ostream (Sock_IOSBase<ACE_SYNCH_USE>::rdbuf ())
  71       {
  72       }
  73
  74     template <ACE_SYNCH_DECL>
  75     Sock_OStreamBase<ACE_SYNCH_USE>::~Sock_OStreamBase()
  76       {
  77       }
  78
  79     template <ACE_SYNCH_DECL>
  80     void Sock_OStreamBase<ACE_SYNCH_USE>::set_interceptor (
  81           typename buffer_type::interceptor_type& interceptor)
  82       {
  83         this->rdbuf ()->set_interceptor (interceptor);
  84       }
  85
  86     template <ACE_SYNCH_DECL>
  87     Sock_IStreamBase<ACE_SYNCH_USE>::Sock_IStreamBase(stream_type* stream)
  88       : Sock_IOSBase<ACE_SYNCH_USE> (stream), std::istream (Sock_IOSBase<ACE_SYNCH_USE>::rdbuf ())
  89       {
  90       }
  91
  92     template <ACE_SYNCH_DECL>
  93     Sock_IStreamBase<ACE_SYNCH_USE>::~Sock_IStreamBase ()
  94       {
  95       }
  96
  97     template <ACE_SYNCH_DECL>
  98     void Sock_IStreamBase<ACE_SYNCH_USE>::set_interceptor (
  99           typename buffer_type::interceptor_type& interceptor)
 100       {
 101         this->rdbuf ()->set_interceptor (interceptor);
 102       }
 103
 104     template <ACE_SYNCH_DECL>
 105     Sock_IOStreamBase<ACE_SYNCH_USE>::Sock_IOStreamBase(stream_type* stream)
 106       : Sock_IOSBase<ACE_SYNCH_USE> (stream), std::iostream (Sock_IOSBase<ACE_SYNCH_USE>::rdbuf ())
 107       {
 108       }
 109
 110     template <ACE_SYNCH_DECL>
 111     Sock_IOStreamBase<ACE_SYNCH_USE>::~Sock_IOStreamBase ()
 112       {
 113       }
 114
 115     template <ACE_SYNCH_DECL>
 116     void Sock_IOStreamBase<ACE_SYNCH_USE>::set_interceptor (
 117           typename buffer_type::interceptor_type& interceptor)
 118       {
 119         this->rdbuf ()->set_interceptor (interceptor);
 120       }
 121
 122   }
 123 }
 124
 125 ACE_END_VERSIONED_NAMESPACE_DECL
 126
 127 #endif /* ACE_IOS_SOCK_IOSTREAM_CPP */