Botan::TLS::detail::AsyncReadOperation< Handler, Stream, MutableBufferSequence, Allocator > Class Template Reference

#include <asio_async_ops.h>

Inheritance diagram for Botan::TLS::detail::AsyncReadOperation< Handler, Stream, MutableBufferSequence, Allocator >:

Public Types
using	allocator_type = boost::asio::associated_allocator_t< Handler, Allocator >
using	executor_type = boost::asio::associated_executor_t< Handler, Stream::executor_type >

Public Member Functions
template<class HandlerT >
	AsyncReadOperation (HandlerT &&handler, Stream &stream, const MutableBufferSequence &buffers, const boost::system::error_code &ec={})
	AsyncReadOperation (AsyncReadOperation &&)=default
allocator_type	get_allocator () const noexcept
executor_type	get_executor () const noexcept
void	operator() (boost::system::error_code ec, std::size_t bytes_transferred, bool isContinuation=true)

Protected Member Functions
void	complete_now (Args &&...args)

Protected Attributes
Handler	m_handler
boost::asio::executor_work_guard< Stream::executor_type >	m_work_guard_1

Detailed Description

template<class Handler, class Stream, class MutableBufferSequence, class Allocator = std::allocator<void>>
class Botan::TLS::detail::AsyncReadOperation< Handler, Stream, MutableBufferSequence, Allocator >

Definition at line 111 of file asio_async_ops.h.

Member Typedef Documentation

using Botan::TLS::detail::AsyncBase< Handler, Stream::executor_type , Allocator >::allocator_type = boost::asio::associated_allocator_t<Handler, Allocator>

inherited

Definition at line 71 of file asio_async_ops.h.

using Botan::TLS::detail::AsyncBase< Handler, Stream::executor_type , Allocator >::executor_type = boost::asio::associated_executor_t<Handler, Stream::executor_type >

inherited

Definition at line 72 of file asio_async_ops.h.

Constructor & Destructor Documentation

template<class Handler, class Stream, class MutableBufferSequence, class Allocator = std::allocator<void>>

template<class HandlerT >

Botan::TLS::detail::AsyncReadOperation< Handler, Stream, MutableBufferSequence, Allocator >::AsyncReadOperation ( HandlerT &&  handler, Stream &  stream, const MutableBufferSequence &  buffers, const boost::system::error_code &  ec = {}  )

inline

Construct and invoke an AsyncReadOperation.

Parameters

handler	Handler function to be called upon completion.
stream	The stream from which the data will be read
buffers	The buffers into which the data will be read.
ec	Optional error code; used to report an error to the handler function.

Definition at line 123 of file asio_async_ops.h.

                                                           {})
         : AsyncBase<Handler, typename Stream::executor_type, Allocator>(
              std::forward<HandlerT>(handler),
              stream.get_executor())
         , m_stream(stream)
         , m_buffers(buffers)
         , m_decodedBytes(0)
         {
         this->operator()(ec, std::size_t(0), false);
         }

template<class Handler, class Stream, class MutableBufferSequence, class Allocator = std::allocator<void>>

Botan::TLS::detail::AsyncReadOperation< Handler, Stream, MutableBufferSequence, Allocator >::AsyncReadOperation ( AsyncReadOperation< Handler, Stream, MutableBufferSequence, Allocator > &&  )

default

Member Function Documentation

void Botan::TLS::detail::AsyncBase< Handler, Stream::executor_type , Allocator >::complete_now ( Args &&...  args )

inlineprotectedinherited

Call the completion handler.

This function should only be called after an intermediate initiating function has been called.

Parameters

args	Arguments forwarded to the completion handler function.

Definition at line 100 of file asio_async_ops.h.

References Botan::TLS::detail::AsyncBase< Handler, Executor1, Allocator >::m_handler, and Botan::TLS::detail::AsyncBase< Handler, Executor1, Allocator >::m_work_guard_1.

Referenced by Botan::TLS::detail::AsyncReadOperation< Handler, Stream, MutableBufferSequence, Allocator >::operator()(), Botan::TLS::detail::AsyncWriteOperation< Handler, Stream, Allocator >::operator()(), and Botan::TLS::detail::AsyncHandshakeOperation< Handler, Stream, Allocator >::operator()().

         {
         m_work_guard_1.reset();
         m_handler(std::forward<Args>(args)...);
         }

allocator_type Botan::TLS::detail::AsyncBase< Handler, Stream::executor_type , Allocator >::get_allocator ( ) const

inlinenoexceptinherited

Definition at line 74 of file asio_async_ops.h.

References Botan::TLS::detail::AsyncBase< Handler, Executor1, Allocator >::m_handler.

         {
         return boost::asio::get_associated_allocator(m_handler);
         }

executor_type Botan::TLS::detail::AsyncBase< Handler, Stream::executor_type , Allocator >::get_executor ( ) const

inlinenoexceptinherited

Definition at line 79 of file asio_async_ops.h.

References Botan::TLS::detail::AsyncBase< Handler, Executor1, Allocator >::m_handler, and Botan::TLS::detail::AsyncBase< Handler, Executor1, Allocator >::m_work_guard_1.

         {
         return boost::asio::get_associated_executor(m_handler, m_work_guard_1.get_executor());
         }

template<class Handler, class Stream, class MutableBufferSequence, class Allocator = std::allocator<void>>

void Botan::TLS::detail::AsyncReadOperation< Handler, Stream, MutableBufferSequence, Allocator >::operator() ( boost::system::error_code  ec, std::size_t  bytes_transferred, bool  isContinuation = true  )

inline

Definition at line 139 of file asio_async_ops.h.

References Botan::TLS::detail::AsyncBase< Handler, Stream::executor_type, Allocator >::complete_now(), Botan::TLS::Stream< StreamLayer, ChannelT >::copy_received_data(), Botan::Exception::error_type(), Botan::TLS::Stream< StreamLayer, ChannelT >::has_received_data(), Botan::TLS::Stream< StreamLayer, ChannelT >::input_buffer(), Botan::TLS::Stream< StreamLayer, ChannelT >::native_handle(), Botan::TLS::Stream< StreamLayer, ChannelT >::next_layer(), Botan::TLS::TLS_Exception::type(), and Botan::Unknown.

         {
         reenter(this)
            {
            if(bytes_transferred > 0 && !ec)
               {
               // We have received encrypted data from the network, now hand it to TLS::Channel for decryption.
               boost::asio::const_buffer read_buffer{m_stream.input_buffer().data(), bytes_transferred};
               try
                  {
                  m_stream.native_handle()->received_data(
                     static_cast<const uint8_t*>(read_buffer.data()), read_buffer.size()
                  );
                  }
               catch(const TLS_Exception& e)
                  {
                  ec = e.type();
                  }
               catch(const Botan::Exception& e)
                  {
                  ec = e.error_type();
                  }
               catch(...)
                  {
                  ec = Botan::ErrorType::Unknown;
                  }
               }

            if(!m_stream.has_received_data() && !ec && boost::asio::buffer_size(m_buffers) > 0)
               {
               // The channel did not decrypt a complete record yet, we need more data from the socket.
               m_stream.next_layer().async_read_some(m_stream.input_buffer(), std::move(*this));
               return;
               }

            if(m_stream.has_received_data() && !ec)
               {
               // The channel has decrypted a TLS record, now copy it to the output buffers.
               m_decodedBytes = m_stream.copy_received_data(m_buffers);
               }

            if(!isContinuation)
               {
               // Make sure the handler is not called without an intermediate initiating function.
               // "Reading" into a zero-byte buffer will complete immediately.
               m_ec = ec;
               yield m_stream.next_layer().async_read_some(boost::asio::mutable_buffer(), std::move(*this));
               ec = m_ec;
               }

            this->complete_now(ec, m_decodedBytes);
            }
         }

Member Data Documentation

Handler Botan::TLS::detail::AsyncBase< Handler, Stream::executor_type , Allocator >::m_handler

protectedinherited

Definition at line 106 of file asio_async_ops.h.

boost::asio::executor_work_guard<Stream::executor_type > Botan::TLS::detail::AsyncBase< Handler, Stream::executor_type , Allocator >::m_work_guard_1

protectedinherited

Definition at line 107 of file asio_async_ops.h.

---

The documentation for this class was generated from the following file:

• src/lib/tls/asio/asio_async_ops.h