#include <userver/engine/io/tls_wrapper.hpp>

Detailed Description

Class for TLS communications over a Socket.

Not thread safe. E.g. you MAY NOT read and write concurrently from multiple coroutines.

Usage example:

  TcpListener tcp_listener;
  auto [server, client] = tcp_listener.MakeSocketPair(deadline);
 
  auto server_task = utils::Async(
      "tls-server",
      [deadline](auto&& server) {
        auto tls_server = io::TlsWrapper::StartTlsServer(
            std::forward<decltype(server)>(server),
            crypto::Certificate::LoadFromString(cert),
            crypto::PrivateKey::LoadFromString(key), deadline);
        if (tls_server.SendAll(kData.data(), kData.size(), deadline) !=
            kData.size()) {
          throw std::runtime_error("Couldn't send data");
        }
      },
      std::move(server));
 
  auto tls_client =
      io::TlsWrapper::StartTlsClient(std::move(client), {}, deadline);
  std::vector<char> buffer(kData.size());
  const auto bytes_rcvd =
      tls_client.RecvAll(buffer.data(), buffer.size(), deadline);

Definition at line 27 of file tls_wrapper.hpp.

Inheritance diagram for engine::io::TlsWrapper:

Public Member Functions
	TlsWrapper (const TlsWrapper &)=delete

	TlsWrapper (TlsWrapper &&) noexcept

	operator bool () const
	Whether the socket is valid.

bool	IsValid () const override
	Whether the socket is valid.

bool	WaitReadable (Deadline) override
	Suspends current task until the socket has data available.

bool	WaitWriteable (Deadline) override
	Suspends current task until the socket can accept more data.

size_t	RecvSome (void *buf, size_t len, Deadline deadline)
	Receives at least one byte from the socket.

size_t	RecvAll (void *buf, size_t len, Deadline deadline)
	Receives exactly len bytes from the socket.

size_t	SendAll (const void *buf, size_t len, Deadline deadline)
	Sends exactly len bytes to the socket.

Socket	StopTls (Deadline deadline)
	Finishes TLS session and returns the socket.

size_t	ReadSome (void *buf, size_t len, Deadline deadline) override
	Receives at least one byte from the socket.

size_t	ReadAll (void *buf, size_t len, Deadline deadline) override
	Receives exactly len bytes from the socket.

size_t	WriteAll (const void *buf, size_t len, Deadline deadline) override
	Writes exactly len bytes to the socket.

size_t	WriteAll (std::initializer_list< IoData > list, Deadline deadline) override

int	GetRawFd ()

ReadableBase &	GetReadableBase ()

WritableBase &	GetWritableBase ()

impl::ContextAccessor *	TryGetContextAccessor ()
	For internal use only.

impl::ContextAccessor *	TryGetContextAccessor ()
	For internal use only.

Static Public Member Functions
static TlsWrapper	StartTlsClient (Socket &&socket, const std::string &server_name, Deadline deadline)
	Starts a TLS client on an opened socket.

static TlsWrapper	StartTlsClient (Socket &&socket, const std::string &server_name, const crypto::Certificate &cert, const crypto::PrivateKey &key, Deadline deadline, const std::vector< crypto::Certificate > &extra_cert_authorities={})
	Starts a TLS client with client cert on an opened socket.

static TlsWrapper	StartTlsServer (Socket &&socket, const crypto::Certificate &cert, const crypto::PrivateKey &key, Deadline deadline, const std::vector< crypto::Certificate > &extra_cert_authorities={})
	Starts a TLS server on an opened socket.

Protected Member Functions
void	SetReadableContextAccessor (impl::ContextAccessor *ca)

void	SetWritableContextAccessor (impl::ContextAccessor *ca)

Member Function Documentation

◆ GetReadableBase()

ReadableBase & engine::io::RwBase::GetReadableBase ( )

inlineinherited

Definition at line 102 of file common.hpp.

◆ GetWritableBase()

WritableBase & engine::io::RwBase::GetWritableBase ( )

inlineinherited

Definition at line 104 of file common.hpp.

◆ IsValid()

bool engine::io::TlsWrapper::IsValid ( ) const

overridevirtual

Whether the socket is valid.

Implements engine::io::ReadableBase.

◆ operator bool()

engine::io::TlsWrapper::operator bool ( ) const

inlineexplicit

Whether the socket is valid.

Definition at line 53 of file tls_wrapper.hpp.

◆ ReadAll()

size_t engine::io::TlsWrapper::ReadAll	(	void *	buf,
		size_t	len,
		Deadline	deadline )

inlineoverridevirtual

Receives exactly len bytes from the socket.

Note: Can return less than len if socket is closed by peer.

Implements engine::io::ReadableBase.

Definition at line 92 of file tls_wrapper.hpp.

◆ ReadSome()

size_t engine::io::TlsWrapper::ReadSome	(	void *	buf,
		size_t	len,
		Deadline	deadline )

inlineoverridevirtual

Receives at least one byte from the socket.

Returns: 0 if connection is closed on one side and no data could be received any more, received bytes count otherwise.

Implements engine::io::ReadableBase.

Definition at line 85 of file tls_wrapper.hpp.

◆ RecvAll()

size_t engine::io::TlsWrapper::RecvAll	(	void *	buf,
		size_t	len,
		Deadline	deadline )

Receives exactly len bytes from the socket.

Note: Can return less than len if socket is closed by peer.

◆ RecvSome()

size_t engine::io::TlsWrapper::RecvSome	(	void *	buf,
		size_t	len,
		Deadline	deadline )

Receives at least one byte from the socket.

Returns: 0 if connection is closed on one side and no data could be received any more, received bytes count otherwise.

◆ SendAll()

size_t engine::io::TlsWrapper::SendAll	(	const void *	buf,
		size_t	len,
		Deadline	deadline )

Sends exactly len bytes to the socket.

Note: Can return less than len if socket is closed by peer.

◆ SetReadableContextAccessor()

void engine::io::ReadableBase::SetReadableContextAccessor ( impl::ContextAccessor * ca )

inlineprotectedinherited

Definition at line 48 of file common.hpp.

◆ SetWritableContextAccessor()

void engine::io::WritableBase::SetWritableContextAccessor ( impl::ContextAccessor * ca )

inlineprotectedinherited

Definition at line 88 of file common.hpp.

◆ StopTls()

Socket engine::io::TlsWrapper::StopTls ( Deadline deadline )

Finishes TLS session and returns the socket.

Warning: Wrapper becomes invalid on entry and can only be used to retry socket extraction if interrupted.

◆ TryGetContextAccessor() [1/2]

impl::ContextAccessor * engine::io::ReadableBase::TryGetContextAccessor ( )

inlineinherited

For internal use only.

Definition at line 45 of file common.hpp.

◆ TryGetContextAccessor() [2/2]

impl::ContextAccessor * engine::io::WritableBase::TryGetContextAccessor ( )

inlineinherited

For internal use only.

Definition at line 85 of file common.hpp.

◆ WaitReadable()

bool engine::io::TlsWrapper::WaitReadable ( Deadline )

overridevirtual

Suspends current task until the socket has data available.

Implements engine::io::ReadableBase.

◆ WaitWriteable()

bool engine::io::TlsWrapper::WaitWriteable ( Deadline )

overridevirtual

Suspends current task until the socket can accept more data.

Implements engine::io::WritableBase.

◆ WriteAll() [1/2]

size_t engine::io::TlsWrapper::WriteAll	(	const void *	buf,
		size_t	len,
		Deadline	deadline )

inlineoverridevirtual

Writes exactly len bytes to the socket.

Note: Can return less than len if socket is closed by peer.

Implements engine::io::WritableBase.

Definition at line 99 of file tls_wrapper.hpp.

◆ WriteAll() [2/2]

size_t engine::io::TlsWrapper::WriteAll	(	std::initializer_list< IoData >	list,
		Deadline	deadline )

overridevirtual

Reimplemented from engine::io::WritableBase.

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

userver/engine/io/tls_wrapper.hpp

Detailed Description

Public Member Functions

Static Public Member Functions

Protected Member Functions

Member Function Documentation

◆ GetReadableBase()

◆ GetWritableBase()

◆ IsValid()

◆ operator bool()

◆ ReadAll()

◆ ReadSome()

◆ RecvAll()

◆ RecvSome()

◆ SendAll()

◆ SetReadableContextAccessor()

◆ SetWritableContextAccessor()

◆ StopTls()

◆ TryGetContextAccessor() [1/2]

◆ TryGetContextAccessor() [2/2]

◆ WaitReadable()

◆ WaitWriteable()

◆ WriteAll() [1/2]

◆ WriteAll() [2/2]