Chris@16: //
Chris@16: // basic_socket_streambuf.hpp
Chris@16: // ~~~~~~~~~~~~~~~~~~~~~~~~~~
Chris@16: //
Chris@101: // Copyright (c) 2003-2015 Christopher M. Kohlhoff (chris at kohlhoff dot com)
Chris@16: //
Chris@16: // Distributed under the Boost Software License, Version 1.0. (See accompanying
Chris@16: // file LICENSE_1_0.txt or copy at http://www.boost.org/LICENSE_1_0.txt)
Chris@16: //
Chris@16: 
Chris@16: #ifndef BOOST_ASIO_BASIC_SOCKET_STREAMBUF_HPP
Chris@16: #define BOOST_ASIO_BASIC_SOCKET_STREAMBUF_HPP
Chris@16: 
Chris@16: #if defined(_MSC_VER) && (_MSC_VER >= 1200)
Chris@16: # pragma once
Chris@16: #endif // defined(_MSC_VER) && (_MSC_VER >= 1200)
Chris@16: 
Chris@16: #include <boost/asio/detail/config.hpp>
Chris@16: 
Chris@16: #if !defined(BOOST_ASIO_NO_IOSTREAM)
Chris@16: 
Chris@16: #include <streambuf>
Chris@16: #include <boost/asio/basic_socket.hpp>
Chris@16: #include <boost/asio/deadline_timer_service.hpp>
Chris@16: #include <boost/asio/detail/array.hpp>
Chris@16: #include <boost/asio/detail/throw_error.hpp>
Chris@16: #include <boost/asio/io_service.hpp>
Chris@16: #include <boost/asio/stream_socket_service.hpp>
Chris@16: 
Chris@16: #if defined(BOOST_ASIO_HAS_BOOST_DATE_TIME)
Chris@16: # include <boost/asio/deadline_timer.hpp>
Chris@16: #else
Chris@16: # include <boost/asio/steady_timer.hpp>
Chris@16: #endif
Chris@16: 
Chris@16: #if !defined(BOOST_ASIO_HAS_VARIADIC_TEMPLATES)
Chris@16: 
Chris@16: # include <boost/asio/detail/variadic_templates.hpp>
Chris@16: 
Chris@16: // A macro that should expand to:
Chris@16: //   template <typename T1, ..., typename Tn>
Chris@16: //   basic_socket_streambuf<Protocol, StreamSocketService,
Chris@16: //     Time, TimeTraits, TimerService>* connect(
Chris@16: //       T1 x1, ..., Tn xn)
Chris@16: //   {
Chris@16: //     init_buffers();
Chris@16: //     this->basic_socket<Protocol, StreamSocketService>::close(ec_);
Chris@16: //     typedef typename Protocol::resolver resolver_type;
Chris@16: //     typedef typename resolver_type::query resolver_query;
Chris@16: //     resolver_query query(x1, ..., xn);
Chris@16: //     resolve_and_connect(query);
Chris@16: //     return !ec_ ? this : 0;
Chris@16: //   }
Chris@16: // This macro should only persist within this file.
Chris@16: 
Chris@16: # define BOOST_ASIO_PRIVATE_CONNECT_DEF(n) \
Chris@16:   template <BOOST_ASIO_VARIADIC_TPARAMS(n)> \
Chris@16:   basic_socket_streambuf<Protocol, StreamSocketService, \
Chris@16:     Time, TimeTraits, TimerService>* connect(BOOST_ASIO_VARIADIC_PARAMS(n)) \
Chris@16:   { \
Chris@16:     init_buffers(); \
Chris@16:     this->basic_socket<Protocol, StreamSocketService>::close(ec_); \
Chris@16:     typedef typename Protocol::resolver resolver_type; \
Chris@16:     typedef typename resolver_type::query resolver_query; \
Chris@16:     resolver_query query(BOOST_ASIO_VARIADIC_ARGS(n)); \
Chris@16:     resolve_and_connect(query); \
Chris@16:     return !ec_ ? this : 0; \
Chris@16:   } \
Chris@16:   /**/
Chris@16: 
Chris@16: #endif // !defined(BOOST_ASIO_HAS_VARIADIC_TEMPLATES)
Chris@16: 
Chris@16: #include <boost/asio/detail/push_options.hpp>
Chris@16: 
Chris@16: namespace boost {
Chris@16: namespace asio {
Chris@16: namespace detail {
Chris@16: 
Chris@16: // A separate base class is used to ensure that the io_service is initialised
Chris@16: // prior to the basic_socket_streambuf's basic_socket base class.
Chris@16: class socket_streambuf_base
Chris@16: {
Chris@16: protected:
Chris@16:   io_service io_service_;
Chris@16: };
Chris@16: 
Chris@16: } // namespace detail
Chris@16: 
Chris@16: /// Iostream streambuf for a socket.
Chris@16: template <typename Protocol,
Chris@16:     typename StreamSocketService = stream_socket_service<Protocol>,
Chris@16: #if defined(BOOST_ASIO_HAS_BOOST_DATE_TIME) \
Chris@16:   || defined(GENERATING_DOCUMENTATION)
Chris@16:     typename Time = boost::posix_time::ptime,
Chris@16:     typename TimeTraits = boost::asio::time_traits<Time>,
Chris@16:     typename TimerService = deadline_timer_service<Time, TimeTraits> >
Chris@16: #else
Chris@16:     typename Time = steady_timer::clock_type,
Chris@16:     typename TimeTraits = steady_timer::traits_type,
Chris@16:     typename TimerService = steady_timer::service_type>
Chris@16: #endif
Chris@16: class basic_socket_streambuf
Chris@16:   : public std::streambuf,
Chris@16:     private detail::socket_streambuf_base,
Chris@16:     public basic_socket<Protocol, StreamSocketService>
Chris@16: {
Chris@16: private:
Chris@16:   // These typedefs are intended keep this class's implementation independent
Chris@16:   // of whether it's using Boost.DateTime, Boost.Chrono or std::chrono.
Chris@16: #if defined(BOOST_ASIO_HAS_BOOST_DATE_TIME)
Chris@16:   typedef TimeTraits traits_helper;
Chris@16: #else
Chris@16:   typedef detail::chrono_time_traits<Time, TimeTraits> traits_helper;
Chris@16: #endif
Chris@16: 
Chris@16: public:
Chris@16:   /// The endpoint type.
Chris@16:   typedef typename Protocol::endpoint endpoint_type;
Chris@16: 
Chris@16: #if defined(GENERATING_DOCUMENTATION)
Chris@16:   /// The time type.
Chris@16:   typedef typename TimeTraits::time_type time_type;
Chris@16: 
Chris@16:   /// The duration type.
Chris@16:   typedef typename TimeTraits::duration_type duration_type;
Chris@16: #else
Chris@16:   typedef typename traits_helper::time_type time_type;
Chris@16:   typedef typename traits_helper::duration_type duration_type;
Chris@16: #endif
Chris@16: 
Chris@16:   /// Construct a basic_socket_streambuf without establishing a connection.
Chris@16:   basic_socket_streambuf()
Chris@16:     : basic_socket<Protocol, StreamSocketService>(
Chris@16:         this->detail::socket_streambuf_base::io_service_),
Chris@16:       unbuffered_(false),
Chris@16:       timer_service_(0),
Chris@16:       timer_state_(no_timer)
Chris@16:   {
Chris@16:     init_buffers();
Chris@16:   }
Chris@16: 
Chris@16:   /// Destructor flushes buffered data.
Chris@16:   virtual ~basic_socket_streambuf()
Chris@16:   {
Chris@16:     if (pptr() != pbase())
Chris@16:       overflow(traits_type::eof());
Chris@16: 
Chris@16:     destroy_timer();
Chris@16:   }
Chris@16: 
Chris@16:   /// Establish a connection.
Chris@16:   /**
Chris@16:    * This function establishes a connection to the specified endpoint.
Chris@16:    *
Chris@16:    * @return \c this if a connection was successfully established, a null
Chris@16:    * pointer otherwise.
Chris@16:    */
Chris@16:   basic_socket_streambuf<Protocol, StreamSocketService,
Chris@16:     Time, TimeTraits, TimerService>* connect(
Chris@16:       const endpoint_type& endpoint)
Chris@16:   {
Chris@16:     init_buffers();
Chris@16: 
Chris@16:     this->basic_socket<Protocol, StreamSocketService>::close(ec_);
Chris@16: 
Chris@16:     if (timer_state_ == timer_has_expired)
Chris@16:     {
Chris@16:       ec_ = boost::asio::error::operation_aborted;
Chris@16:       return 0;
Chris@16:     }
Chris@16: 
Chris@16:     io_handler handler = { this };
Chris@16:     this->basic_socket<Protocol, StreamSocketService>::async_connect(
Chris@16:         endpoint, handler);
Chris@16: 
Chris@16:     ec_ = boost::asio::error::would_block;
Chris@16:     this->get_service().get_io_service().reset();
Chris@16:     do this->get_service().get_io_service().run_one();
Chris@16:     while (ec_ == boost::asio::error::would_block);
Chris@16: 
Chris@16:     return !ec_ ? this : 0;
Chris@16:   }
Chris@16: 
Chris@16: #if defined(GENERATING_DOCUMENTATION)
Chris@16:   /// Establish a connection.
Chris@16:   /**
Chris@16:    * This function automatically establishes a connection based on the supplied
Chris@16:    * resolver query parameters. The arguments are used to construct a resolver
Chris@16:    * query object.
Chris@16:    *
Chris@16:    * @return \c this if a connection was successfully established, a null
Chris@16:    * pointer otherwise.
Chris@16:    */
Chris@16:   template <typename T1, ..., typename TN>
Chris@16:   basic_socket_streambuf<Protocol, StreamSocketService>* connect(
Chris@16:       T1 t1, ..., TN tn);
Chris@16: #elif defined(BOOST_ASIO_HAS_VARIADIC_TEMPLATES)
Chris@16:   template <typename... T>
Chris@16:   basic_socket_streambuf<Protocol, StreamSocketService,
Chris@16:     Time, TimeTraits, TimerService>* connect(T... x)
Chris@16:   {
Chris@16:     init_buffers();
Chris@16:     this->basic_socket<Protocol, StreamSocketService>::close(ec_);
Chris@16:     typedef typename Protocol::resolver resolver_type;
Chris@16:     typedef typename resolver_type::query resolver_query;
Chris@16:     resolver_query query(x...);
Chris@16:     resolve_and_connect(query);
Chris@16:     return !ec_ ? this : 0;
Chris@16:   }
Chris@16: #else
Chris@16:   BOOST_ASIO_VARIADIC_GENERATE(BOOST_ASIO_PRIVATE_CONNECT_DEF)
Chris@16: #endif
Chris@16: 
Chris@16:   /// Close the connection.
Chris@16:   /**
Chris@16:    * @return \c this if a connection was successfully established, a null
Chris@16:    * pointer otherwise.
Chris@16:    */
Chris@16:   basic_socket_streambuf<Protocol, StreamSocketService,
Chris@16:     Time, TimeTraits, TimerService>* close()
Chris@16:   {
Chris@16:     sync();
Chris@16:     this->basic_socket<Protocol, StreamSocketService>::close(ec_);
Chris@16:     if (!ec_)
Chris@16:       init_buffers();
Chris@16:     return !ec_ ? this : 0;
Chris@16:   }
Chris@16: 
Chris@16:   /// Get the last error associated with the stream buffer.
Chris@16:   /**
Chris@16:    * @return An \c error_code corresponding to the last error from the stream
Chris@16:    * buffer.
Chris@16:    */
Chris@16:   const boost::system::error_code& puberror() const
Chris@16:   {
Chris@16:     return error();
Chris@16:   }
Chris@16: 
Chris@16:   /// Get the stream buffer's expiry time as an absolute time.
Chris@16:   /**
Chris@16:    * @return An absolute time value representing the stream buffer's expiry
Chris@16:    * time.
Chris@16:    */
Chris@16:   time_type expires_at() const
Chris@16:   {
Chris@16:     return timer_service_
Chris@16:       ? timer_service_->expires_at(timer_implementation_)
Chris@16:       : time_type();
Chris@16:   }
Chris@16: 
Chris@16:   /// Set the stream buffer's expiry time as an absolute time.
Chris@16:   /**
Chris@16:    * This function sets the expiry time associated with the stream. Stream
Chris@16:    * operations performed after this time (where the operations cannot be
Chris@16:    * completed using the internal buffers) will fail with the error
Chris@16:    * boost::asio::error::operation_aborted.
Chris@16:    *
Chris@16:    * @param expiry_time The expiry time to be used for the stream.
Chris@16:    */
Chris@16:   void expires_at(const time_type& expiry_time)
Chris@16:   {
Chris@16:     construct_timer();
Chris@16: 
Chris@16:     boost::system::error_code ec;
Chris@16:     timer_service_->expires_at(timer_implementation_, expiry_time, ec);
Chris@16:     boost::asio::detail::throw_error(ec, "expires_at");
Chris@16: 
Chris@16:     start_timer();
Chris@16:   }
Chris@16: 
Chris@16:   /// Get the stream buffer's expiry time relative to now.
Chris@16:   /**
Chris@16:    * @return A relative time value representing the stream buffer's expiry time.
Chris@16:    */
Chris@16:   duration_type expires_from_now() const
Chris@16:   {
Chris@16:     return traits_helper::subtract(expires_at(), traits_helper::now());
Chris@16:   }
Chris@16: 
Chris@16:   /// Set the stream buffer's expiry time relative to now.
Chris@16:   /**
Chris@16:    * This function sets the expiry time associated with the stream. Stream
Chris@16:    * operations performed after this time (where the operations cannot be
Chris@16:    * completed using the internal buffers) will fail with the error
Chris@16:    * boost::asio::error::operation_aborted.
Chris@16:    *
Chris@16:    * @param expiry_time The expiry time to be used for the timer.
Chris@16:    */
Chris@16:   void expires_from_now(const duration_type& expiry_time)
Chris@16:   {
Chris@16:     construct_timer();
Chris@16: 
Chris@16:     boost::system::error_code ec;
Chris@16:     timer_service_->expires_from_now(timer_implementation_, expiry_time, ec);
Chris@16:     boost::asio::detail::throw_error(ec, "expires_from_now");
Chris@16: 
Chris@16:     start_timer();
Chris@16:   }
Chris@16: 
Chris@16: protected:
Chris@16:   int_type underflow()
Chris@16:   {
Chris@16:     if (gptr() == egptr())
Chris@16:     {
Chris@16:       if (timer_state_ == timer_has_expired)
Chris@16:       {
Chris@16:         ec_ = boost::asio::error::operation_aborted;
Chris@16:         return traits_type::eof();
Chris@16:       }
Chris@16: 
Chris@16:       io_handler handler = { this };
Chris@16:       this->get_service().async_receive(this->get_implementation(),
Chris@16:           boost::asio::buffer(boost::asio::buffer(get_buffer_) + putback_max),
Chris@16:           0, handler);
Chris@16: 
Chris@16:       ec_ = boost::asio::error::would_block;
Chris@16:       this->get_service().get_io_service().reset();
Chris@16:       do this->get_service().get_io_service().run_one();
Chris@16:       while (ec_ == boost::asio::error::would_block);
Chris@16:       if (ec_)
Chris@16:         return traits_type::eof();
Chris@16: 
Chris@16:       setg(&get_buffer_[0], &get_buffer_[0] + putback_max,
Chris@16:           &get_buffer_[0] + putback_max + bytes_transferred_);
Chris@16:       return traits_type::to_int_type(*gptr());
Chris@16:     }
Chris@16:     else
Chris@16:     {
Chris@16:       return traits_type::eof();
Chris@16:     }
Chris@16:   }
Chris@16: 
Chris@16:   int_type overflow(int_type c)
Chris@16:   {
Chris@16:     if (unbuffered_)
Chris@16:     {
Chris@16:       if (traits_type::eq_int_type(c, traits_type::eof()))
Chris@16:       {
Chris@16:         // Nothing to do.
Chris@16:         return traits_type::not_eof(c);
Chris@16:       }
Chris@16:       else
Chris@16:       {
Chris@16:         if (timer_state_ == timer_has_expired)
Chris@16:         {
Chris@16:           ec_ = boost::asio::error::operation_aborted;
Chris@16:           return traits_type::eof();
Chris@16:         }
Chris@16: 
Chris@16:         // Send the single character immediately.
Chris@16:         char_type ch = traits_type::to_char_type(c);
Chris@16:         io_handler handler = { this };
Chris@16:         this->get_service().async_send(this->get_implementation(),
Chris@16:             boost::asio::buffer(&ch, sizeof(char_type)), 0, handler);
Chris@16: 
Chris@16:         ec_ = boost::asio::error::would_block;
Chris@16:         this->get_service().get_io_service().reset();
Chris@16:         do this->get_service().get_io_service().run_one();
Chris@16:         while (ec_ == boost::asio::error::would_block);
Chris@16:         if (ec_)
Chris@16:           return traits_type::eof();
Chris@16: 
Chris@16:         return c;
Chris@16:       }
Chris@16:     }
Chris@16:     else
Chris@16:     {
Chris@16:       // Send all data in the output buffer.
Chris@16:       boost::asio::const_buffer buffer =
Chris@16:         boost::asio::buffer(pbase(), pptr() - pbase());
Chris@16:       while (boost::asio::buffer_size(buffer) > 0)
Chris@16:       {
Chris@16:         if (timer_state_ == timer_has_expired)
Chris@16:         {
Chris@16:           ec_ = boost::asio::error::operation_aborted;
Chris@16:           return traits_type::eof();
Chris@16:         }
Chris@16: 
Chris@16:         io_handler handler = { this };
Chris@16:         this->get_service().async_send(this->get_implementation(),
Chris@16:             boost::asio::buffer(buffer), 0, handler);
Chris@16: 
Chris@16:         ec_ = boost::asio::error::would_block;
Chris@16:         this->get_service().get_io_service().reset();
Chris@16:         do this->get_service().get_io_service().run_one();
Chris@16:         while (ec_ == boost::asio::error::would_block);
Chris@16:         if (ec_)
Chris@16:           return traits_type::eof();
Chris@16: 
Chris@16:         buffer = buffer + bytes_transferred_;
Chris@16:       }
Chris@16:       setp(&put_buffer_[0], &put_buffer_[0] + put_buffer_.size());
Chris@16: 
Chris@16:       // If the new character is eof then our work here is done.
Chris@16:       if (traits_type::eq_int_type(c, traits_type::eof()))
Chris@16:         return traits_type::not_eof(c);
Chris@16: 
Chris@16:       // Add the new character to the output buffer.
Chris@16:       *pptr() = traits_type::to_char_type(c);
Chris@16:       pbump(1);
Chris@16:       return c;
Chris@16:     }
Chris@16:   }
Chris@16: 
Chris@16:   int sync()
Chris@16:   {
Chris@16:     return overflow(traits_type::eof());
Chris@16:   }
Chris@16: 
Chris@16:   std::streambuf* setbuf(char_type* s, std::streamsize n)
Chris@16:   {
Chris@16:     if (pptr() == pbase() && s == 0 && n == 0)
Chris@16:     {
Chris@16:       unbuffered_ = true;
Chris@16:       setp(0, 0);
Chris@16:       return this;
Chris@16:     }
Chris@16: 
Chris@16:     return 0;
Chris@16:   }
Chris@16: 
Chris@16:   /// Get the last error associated with the stream buffer.
Chris@16:   /**
Chris@16:    * @return An \c error_code corresponding to the last error from the stream
Chris@16:    * buffer.
Chris@16:    */
Chris@16:   virtual const boost::system::error_code& error() const
Chris@16:   {
Chris@16:     return ec_;
Chris@16:   }
Chris@16: 
Chris@16: private:
Chris@16:   void init_buffers()
Chris@16:   {
Chris@16:     setg(&get_buffer_[0],
Chris@16:         &get_buffer_[0] + putback_max,
Chris@16:         &get_buffer_[0] + putback_max);
Chris@16:     if (unbuffered_)
Chris@16:       setp(0, 0);
Chris@16:     else
Chris@16:       setp(&put_buffer_[0], &put_buffer_[0] + put_buffer_.size());
Chris@16:   }
Chris@16: 
Chris@16:   template <typename ResolverQuery>
Chris@16:   void resolve_and_connect(const ResolverQuery& query)
Chris@16:   {
Chris@16:     typedef typename Protocol::resolver resolver_type;
Chris@16:     typedef typename resolver_type::iterator iterator_type;
Chris@16:     resolver_type resolver(detail::socket_streambuf_base::io_service_);
Chris@16:     iterator_type i = resolver.resolve(query, ec_);
Chris@16:     if (!ec_)
Chris@16:     {
Chris@16:       iterator_type end;
Chris@16:       ec_ = boost::asio::error::host_not_found;
Chris@16:       while (ec_ && i != end)
Chris@16:       {
Chris@16:         this->basic_socket<Protocol, StreamSocketService>::close(ec_);
Chris@16: 
Chris@16:         if (timer_state_ == timer_has_expired)
Chris@16:         {
Chris@16:           ec_ = boost::asio::error::operation_aborted;
Chris@16:           return;
Chris@16:         }
Chris@16: 
Chris@16:         io_handler handler = { this };
Chris@16:         this->basic_socket<Protocol, StreamSocketService>::async_connect(
Chris@16:             *i, handler);
Chris@16: 
Chris@16:         ec_ = boost::asio::error::would_block;
Chris@16:         this->get_service().get_io_service().reset();
Chris@16:         do this->get_service().get_io_service().run_one();
Chris@16:         while (ec_ == boost::asio::error::would_block);
Chris@16: 
Chris@16:         ++i;
Chris@16:       }
Chris@16:     }
Chris@16:   }
Chris@16: 
Chris@16:   struct io_handler;
Chris@16:   friend struct io_handler;
Chris@16:   struct io_handler
Chris@16:   {
Chris@16:     basic_socket_streambuf* this_;
Chris@16: 
Chris@16:     void operator()(const boost::system::error_code& ec,
Chris@16:         std::size_t bytes_transferred = 0)
Chris@16:     {
Chris@16:       this_->ec_ = ec;
Chris@16:       this_->bytes_transferred_ = bytes_transferred;
Chris@16:     }
Chris@16:   };
Chris@16: 
Chris@16:   struct timer_handler;
Chris@16:   friend struct timer_handler;
Chris@16:   struct timer_handler
Chris@16:   {
Chris@16:     basic_socket_streambuf* this_;
Chris@16: 
Chris@16:     void operator()(const boost::system::error_code&)
Chris@16:     {
Chris@16:       time_type now = traits_helper::now();
Chris@16: 
Chris@16:       time_type expiry_time = this_->timer_service_->expires_at(
Chris@16:             this_->timer_implementation_);
Chris@16: 
Chris@16:       if (traits_helper::less_than(now, expiry_time))
Chris@16:       {
Chris@16:         this_->timer_state_ = timer_is_pending;
Chris@16:         this_->timer_service_->async_wait(this_->timer_implementation_, *this);
Chris@16:       }
Chris@16:       else
Chris@16:       {
Chris@16:         this_->timer_state_ = timer_has_expired;
Chris@16:         boost::system::error_code ec;
Chris@16:         this_->basic_socket<Protocol, StreamSocketService>::close(ec);
Chris@16:       }
Chris@16:     }
Chris@16:   };
Chris@16: 
Chris@16:   void construct_timer()
Chris@16:   {
Chris@16:     if (timer_service_ == 0)
Chris@16:     {
Chris@16:       TimerService& timer_service = use_service<TimerService>(
Chris@16:           detail::socket_streambuf_base::io_service_);
Chris@16:       timer_service.construct(timer_implementation_);
Chris@16:       timer_service_ = &timer_service;
Chris@16:     }
Chris@16:   }
Chris@16: 
Chris@16:   void destroy_timer()
Chris@16:   {
Chris@16:     if (timer_service_)
Chris@16:       timer_service_->destroy(timer_implementation_);
Chris@16:   }
Chris@16: 
Chris@16:   void start_timer()
Chris@16:   {
Chris@16:     if (timer_state_ != timer_is_pending)
Chris@16:     {
Chris@16:       timer_handler handler = { this };
Chris@16:       handler(boost::system::error_code());
Chris@16:     }
Chris@16:   }
Chris@16: 
Chris@16:   enum { putback_max = 8 };
Chris@16:   enum { buffer_size = 512 };
Chris@16:   boost::asio::detail::array<char, buffer_size> get_buffer_;
Chris@16:   boost::asio::detail::array<char, buffer_size> put_buffer_;
Chris@16:   bool unbuffered_;
Chris@16:   boost::system::error_code ec_;
Chris@16:   std::size_t bytes_transferred_;
Chris@16:   TimerService* timer_service_;
Chris@16:   typename TimerService::implementation_type timer_implementation_;
Chris@16:   enum state { no_timer, timer_is_pending, timer_has_expired } timer_state_;
Chris@16: };
Chris@16: 
Chris@16: } // namespace asio
Chris@16: } // namespace boost
Chris@16: 
Chris@16: #include <boost/asio/detail/pop_options.hpp>
Chris@16: 
Chris@16: #if !defined(BOOST_ASIO_HAS_VARIADIC_TEMPLATES)
Chris@16: # undef BOOST_ASIO_PRIVATE_CONNECT_DEF
Chris@16: #endif // !defined(BOOST_ASIO_HAS_VARIADIC_TEMPLATES)
Chris@16: 
Chris@16: #endif // !defined(BOOST_ASIO_NO_IOSTREAM)
Chris@16: 
Chris@16: #endif // BOOST_ASIO_BASIC_SOCKET_STREAMBUF_HPP