stream_service.hpp 5.7 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186
  1. //
  2. // ssl/old/stream_service.hpp
  3. // ~~~~~~~~~~~~~~~~~~~~~~~~~~
  4. //
  5. // Copyright (c) 2005 Voipster / Indrek dot Juhani at voipster dot com
  6. // Copyright (c) 2005-2013 Christopher M. Kohlhoff (chris at kohlhoff dot com)
  7. //
  8. // Distributed under the Boost Software License, Version 1.0. (See accompanying
  9. // file LICENSE_1_0.txt or copy at http://www.boost.org/LICENSE_1_0.txt)
  10. //
  11. #ifndef BOOST_ASIO_SSL_OLD_STREAM_SERVICE_HPP
  12. #define BOOST_ASIO_SSL_OLD_STREAM_SERVICE_HPP
  13. #if defined(_MSC_VER) && (_MSC_VER >= 1200)
  14. # pragma once
  15. #endif // defined(_MSC_VER) && (_MSC_VER >= 1200)
  16. #include <boost/asio/detail/config.hpp>
  17. #include <cstddef>
  18. #include <boost/noncopyable.hpp>
  19. #include <boost/asio/io_service.hpp>
  20. #include <boost/asio/ssl/basic_context.hpp>
  21. #include <boost/asio/ssl/old/detail/openssl_stream_service.hpp>
  22. #include <boost/asio/ssl/stream_base.hpp>
  23. #include <boost/asio/detail/push_options.hpp>
  24. namespace boost {
  25. namespace asio {
  26. namespace ssl {
  27. namespace old {
  28. /// Default service implementation for an SSL stream.
  29. class stream_service
  30. #if defined(GENERATING_DOCUMENTATION)
  31. : public boost::asio::io_service::service
  32. #else
  33. : public boost::asio::detail::service_base<stream_service>
  34. #endif
  35. {
  36. private:
  37. // The type of the platform-specific implementation.
  38. typedef old::detail::openssl_stream_service service_impl_type;
  39. public:
  40. #if defined(GENERATING_DOCUMENTATION)
  41. /// The unique service identifier.
  42. static boost::asio::io_service::id id;
  43. #endif
  44. /// The type of a stream implementation.
  45. #if defined(GENERATING_DOCUMENTATION)
  46. typedef implementation_defined impl_type;
  47. #else
  48. typedef service_impl_type::impl_type impl_type;
  49. #endif
  50. /// Construct a new stream service for the specified io_service.
  51. explicit stream_service(boost::asio::io_service& io_service)
  52. : boost::asio::detail::service_base<stream_service>(io_service),
  53. service_impl_(boost::asio::use_service<service_impl_type>(io_service))
  54. {
  55. }
  56. /// Return a null stream implementation.
  57. impl_type null() const
  58. {
  59. return service_impl_.null();
  60. }
  61. /// Create a new stream implementation.
  62. template <typename Stream, typename Context_Service>
  63. void create(impl_type& impl, Stream& next_layer,
  64. basic_context<Context_Service>& context)
  65. {
  66. service_impl_.create(impl, next_layer, context);
  67. }
  68. /// Destroy a stream implementation.
  69. template <typename Stream>
  70. void destroy(impl_type& impl, Stream& next_layer)
  71. {
  72. service_impl_.destroy(impl, next_layer);
  73. }
  74. /// Perform SSL handshaking.
  75. template <typename Stream>
  76. boost::system::error_code handshake(impl_type& impl, Stream& next_layer,
  77. stream_base::handshake_type type, boost::system::error_code& ec)
  78. {
  79. return service_impl_.handshake(impl, next_layer, type, ec);
  80. }
  81. /// Start an asynchronous SSL handshake.
  82. template <typename Stream, typename HandshakeHandler>
  83. void async_handshake(impl_type& impl, Stream& next_layer,
  84. stream_base::handshake_type type, HandshakeHandler handler)
  85. {
  86. service_impl_.async_handshake(impl, next_layer, type, handler);
  87. }
  88. /// Shut down SSL on the stream.
  89. template <typename Stream>
  90. boost::system::error_code shutdown(impl_type& impl, Stream& next_layer,
  91. boost::system::error_code& ec)
  92. {
  93. return service_impl_.shutdown(impl, next_layer, ec);
  94. }
  95. /// Asynchronously shut down SSL on the stream.
  96. template <typename Stream, typename ShutdownHandler>
  97. void async_shutdown(impl_type& impl, Stream& next_layer,
  98. ShutdownHandler handler)
  99. {
  100. service_impl_.async_shutdown(impl, next_layer, handler);
  101. }
  102. /// Write some data to the stream.
  103. template <typename Stream, typename ConstBufferSequence>
  104. std::size_t write_some(impl_type& impl, Stream& next_layer,
  105. const ConstBufferSequence& buffers, boost::system::error_code& ec)
  106. {
  107. return service_impl_.write_some(impl, next_layer, buffers, ec);
  108. }
  109. /// Start an asynchronous write.
  110. template <typename Stream, typename ConstBufferSequence,
  111. typename WriteHandler>
  112. void async_write_some(impl_type& impl, Stream& next_layer,
  113. const ConstBufferSequence& buffers, WriteHandler handler)
  114. {
  115. service_impl_.async_write_some(impl, next_layer, buffers, handler);
  116. }
  117. /// Read some data from the stream.
  118. template <typename Stream, typename MutableBufferSequence>
  119. std::size_t read_some(impl_type& impl, Stream& next_layer,
  120. const MutableBufferSequence& buffers, boost::system::error_code& ec)
  121. {
  122. return service_impl_.read_some(impl, next_layer, buffers, ec);
  123. }
  124. /// Start an asynchronous read.
  125. template <typename Stream, typename MutableBufferSequence,
  126. typename ReadHandler>
  127. void async_read_some(impl_type& impl, Stream& next_layer,
  128. const MutableBufferSequence& buffers, ReadHandler handler)
  129. {
  130. service_impl_.async_read_some(impl, next_layer, buffers, handler);
  131. }
  132. /// Peek at the incoming data on the stream.
  133. template <typename Stream, typename MutableBufferSequence>
  134. std::size_t peek(impl_type& impl, Stream& next_layer,
  135. const MutableBufferSequence& buffers, boost::system::error_code& ec)
  136. {
  137. return service_impl_.peek(impl, next_layer, buffers, ec);
  138. }
  139. /// Determine the amount of data that may be read without blocking.
  140. template <typename Stream>
  141. std::size_t in_avail(impl_type& impl, Stream& next_layer,
  142. boost::system::error_code& ec)
  143. {
  144. return service_impl_.in_avail(impl, next_layer, ec);
  145. }
  146. private:
  147. // Destroy all user-defined handler objects owned by the service.
  148. void shutdown_service()
  149. {
  150. }
  151. // The service that provides the platform-specific implementation.
  152. service_impl_type& service_impl_;
  153. };
  154. } // namespace old
  155. } // namespace ssl
  156. } // namespace asio
  157. } // namespace boost
  158. #include <boost/asio/detail/pop_options.hpp>
  159. #endif // BOOST_ASIO_SSL_OLD_STREAM_SERVICE_HPP