123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258 |
- #ifndef BOOST_ASIO_BUFFERED_STREAM_HPP
- #define BOOST_ASIO_BUFFERED_STREAM_HPP
- #if defined(_MSC_VER) && (_MSC_VER >= 1200)
- # pragma once
- #endif
- #include <boost/asio/detail/push_options.hpp>
- #include <boost/asio/detail/push_options.hpp>
- #include <cstddef>
- #include <boost/config.hpp>
- #include <boost/asio/detail/pop_options.hpp>
- #include <boost/asio/buffered_read_stream.hpp>
- #include <boost/asio/buffered_write_stream.hpp>
- #include <boost/asio/buffered_stream_fwd.hpp>
- #include <boost/asio/error.hpp>
- #include <boost/asio/io_service.hpp>
- #include <boost/asio/detail/noncopyable.hpp>
- namespace boost {
- namespace asio {
- template <typename Stream>
- class buffered_stream
- : private noncopyable
- {
- public:
-
- typedef typename boost::remove_reference<Stream>::type next_layer_type;
-
- typedef typename next_layer_type::lowest_layer_type lowest_layer_type;
-
- template <typename Arg>
- explicit buffered_stream(Arg& a)
- : inner_stream_impl_(a),
- stream_impl_(inner_stream_impl_)
- {
- }
-
- template <typename Arg>
- explicit buffered_stream(Arg& a, std::size_t read_buffer_size,
- std::size_t write_buffer_size)
- : inner_stream_impl_(a, write_buffer_size),
- stream_impl_(inner_stream_impl_, read_buffer_size)
- {
- }
-
- next_layer_type& next_layer()
- {
- return stream_impl_.next_layer().next_layer();
- }
-
- lowest_layer_type& lowest_layer()
- {
- return stream_impl_.lowest_layer();
- }
-
- const lowest_layer_type& lowest_layer() const
- {
- return stream_impl_.lowest_layer();
- }
-
-
- boost::asio::io_service& io_service()
- {
- return stream_impl_.get_io_service();
- }
-
- boost::asio::io_service& get_io_service()
- {
- return stream_impl_.get_io_service();
- }
-
- void close()
- {
- stream_impl_.close();
- }
-
- boost::system::error_code close(boost::system::error_code& ec)
- {
- return stream_impl_.close(ec);
- }
-
-
-
- std::size_t flush()
- {
- return stream_impl_.next_layer().flush();
- }
-
-
-
- std::size_t flush(boost::system::error_code& ec)
- {
- return stream_impl_.next_layer().flush(ec);
- }
-
- template <typename WriteHandler>
- void async_flush(WriteHandler handler)
- {
- return stream_impl_.next_layer().async_flush(handler);
- }
-
-
- template <typename ConstBufferSequence>
- std::size_t write_some(const ConstBufferSequence& buffers)
- {
- return stream_impl_.write_some(buffers);
- }
-
-
- template <typename ConstBufferSequence>
- std::size_t write_some(const ConstBufferSequence& buffers,
- boost::system::error_code& ec)
- {
- return stream_impl_.write_some(buffers, ec);
- }
-
-
- template <typename ConstBufferSequence, typename WriteHandler>
- void async_write_some(const ConstBufferSequence& buffers,
- WriteHandler handler)
- {
- stream_impl_.async_write_some(buffers, handler);
- }
-
-
- std::size_t fill()
- {
- return stream_impl_.fill();
- }
-
-
- std::size_t fill(boost::system::error_code& ec)
- {
- return stream_impl_.fill(ec);
- }
-
- template <typename ReadHandler>
- void async_fill(ReadHandler handler)
- {
- stream_impl_.async_fill(handler);
- }
-
-
- template <typename MutableBufferSequence>
- std::size_t read_some(const MutableBufferSequence& buffers)
- {
- return stream_impl_.read_some(buffers);
- }
-
-
- template <typename MutableBufferSequence>
- std::size_t read_some(const MutableBufferSequence& buffers,
- boost::system::error_code& ec)
- {
- return stream_impl_.read_some(buffers, ec);
- }
-
-
- template <typename MutableBufferSequence, typename ReadHandler>
- void async_read_some(const MutableBufferSequence& buffers,
- ReadHandler handler)
- {
- stream_impl_.async_read_some(buffers, handler);
- }
-
-
- template <typename MutableBufferSequence>
- std::size_t peek(const MutableBufferSequence& buffers)
- {
- return stream_impl_.peek(buffers);
- }
-
-
- template <typename MutableBufferSequence>
- std::size_t peek(const MutableBufferSequence& buffers,
- boost::system::error_code& ec)
- {
- return stream_impl_.peek(buffers, ec);
- }
-
- std::size_t in_avail()
- {
- return stream_impl_.in_avail();
- }
-
- std::size_t in_avail(boost::system::error_code& ec)
- {
- return stream_impl_.in_avail(ec);
- }
- private:
-
- typedef buffered_write_stream<Stream> write_stream_type;
- write_stream_type inner_stream_impl_;
-
- typedef buffered_read_stream<write_stream_type&> read_stream_type;
- read_stream_type stream_impl_;
- };
- }
- }
- #include <boost/asio/detail/pop_options.hpp>
- #endif
|