#include <connection.h>

Inheritance diagram for http::base::Connection< IOLayer >:

Public Types
using	This = Connection< IOLayer >

using	ConnectionStatusCallbacks = http::base::ConnectionStatusCallbacks< This >

using	Methods = base::method::Bitset

using	Headers = http::base::Headers

using	owned_buffer = http::base::details::owned_buffer

using	ref_buffers = http::base::details::ref_buffers< std::list< owned_buffer > >

using	IO = IOLayer

Public Types inherited from http::base::ConnectionInterface
using	IOBuffer = http::base::IOBuffer

using	Headers = http::base::Headers

Public Member Functions
	Connection (IOLayer s, base::method::Bitset allowed_method, ConnectionStatusCallbacks connection_handler, CNO_CONNECTION_KIND kind, CNO_HTTP_VERSION version)

	~Connection () override

bool	send (const uint32_t *stream_id_ptr, const int status_code, const std::string &method, const std::string &path, const Headers &headers, const IOBuffer &data) override

std::string	get_peer_address () const override

uint16_t	get_peer_port () const override

IOLayer &	get_socket ()

void	start () override

Public Member Functions inherited from http::base::ConnectionInterface
virtual	~ConnectionInterface ()

Public Member Functions inherited from http::cno::CnoInterface
virtual	~CnoInterface ()

virtual int	on_cno_message_head (const uint32_t session_id, const cno_message_t *message)=0

virtual int	on_cno_message_body (const uint32_t session_id, const char *data, const size_t size)=0

virtual int	on_cno_stream_end (const uint32_t id)=0

virtual int	on_settings ()=0

Protected Member Functions
void	do_net_send ()

void	do_net_recv ()

Pending	on_net_receive (const std::error_code &ec, std::size_t bytes_transferred)

Pending	on_net_send (const std::error_code &ec, size_t size)

void	resume ()

void	suspend ()

bool	stop_running ()
	Mark the connection that it should stop running. More...

virtual void	on_output_buffer_empty ()

int	on_cno_writev (const cno_buffer_t *buffer, size_t count) override

int	on_cno_message_tail (const uint32_t session_id, const cno_tail_t *tail) override

int	on_cno_stream_start (const uint32_t id) override

int	on_cno_close () override

Protected Attributes
bool	keep_alive_ {true}

IOLayer	socket_

Methods *	allowed_method_

cno_connection_t	cno_

uint8_t	input_buffer_ [512]

net::mutable_buffer	input_mutable_buffer_ {net::buffer(input_buffer_)}

std::mutex	output_buffer_mutex_

std::list< owned_buffer >	output_buffers_

std::atomic< bool >	processed_request_ {false}

std::atomic< bool >	output_pending_ {false}

std::atomic< bool >	running_ {true}

std::atomic< bool >	suspend_ {false}

ConnectionStatusCallbacks *	connection_handler_

Member Typedef Documentation

◆ ConnectionStatusCallbacks

template<typename IOLayer >

using http::base::Connection< IOLayer >::ConnectionStatusCallbacks = http::base::ConnectionStatusCallbacks<This>

◆ Headers

template<typename IOLayer >

using http::base::Connection< IOLayer >::Headers = http::base::Headers

◆ IO

template<typename IOLayer >

using http::base::Connection< IOLayer >::IO = IOLayer

◆ Methods

template<typename IOLayer >

using http::base::Connection< IOLayer >::Methods = base::method::Bitset

◆ owned_buffer

template<typename IOLayer >

using http::base::Connection< IOLayer >::owned_buffer = http::base::details::owned_buffer

◆ ref_buffers

template<typename IOLayer >

using http::base::Connection< IOLayer >::ref_buffers = http::base::details::ref_buffers<std::list<owned_buffer> >

◆ This

template<typename IOLayer >

using http::base::Connection< IOLayer >::This = Connection<IOLayer>

Constructor & Destructor Documentation

◆ Connection()

template<typename IOLayer >

http::base::Connection< IOLayer >::Connection	(	IOLayer	s,
		base::method::Bitset *	allowed_method,
		ConnectionStatusCallbacks *	connection_handler,
		CNO_CONNECTION_KIND	kind,
		CNO_HTTP_VERSION	version
	)

inline

◆ ~Connection()

template<typename IOLayer >

http::base::Connection< IOLayer >::~Connection ( )

inlineoverride

Member Function Documentation

◆ do_net_recv()

template<typename IOLayer >

void http::base::Connection< IOLayer >::do_net_recv ( )

inlineprotected

◆ do_net_send()

template<typename IOLayer >

void http::base::Connection< IOLayer >::do_net_send ( )

inlineprotected

◆ get_peer_address()

template<typename IOLayer >

std::string http::base::Connection< IOLayer >::get_peer_address ( ) const

inlineoverridevirtual

Implements http::base::ConnectionInterface.

◆ get_peer_port()

template<typename IOLayer >

uint16_t http::base::Connection< IOLayer >::get_peer_port ( ) const

inlineoverridevirtual

Implements http::base::ConnectionInterface.

◆ get_socket()

template<typename IOLayer >

IOLayer & http::base::Connection< IOLayer >::get_socket ( )

inline

◆ on_cno_close()

template<typename IOLayer >

int http::base::Connection< IOLayer >::on_cno_close ( )

inlineoverrideprotectedvirtual

Implements http::cno::CnoInterface.

◆ on_cno_message_tail()

template<typename IOLayer >

int http::base::Connection< IOLayer >::on_cno_message_tail	(	const uint32_t	session_id,
		const cno_tail_t *	tail
	)

inlineoverrideprotectedvirtual

Implements http::cno::CnoInterface.

Reimplemented in http::client::Connection< IOLayer >.

◆ on_cno_stream_start()

template<typename IOLayer >

int http::base::Connection< IOLayer >::on_cno_stream_start ( const uint32_t id )

inlineoverrideprotectedvirtual

Implements http::cno::CnoInterface.

◆ on_cno_writev()

template<typename IOLayer >

int http::base::Connection< IOLayer >::on_cno_writev	(	const cno_buffer_t *	buffer,
		size_t	count
	)

inlineoverrideprotectedvirtual

Implements http::cno::CnoInterface.

◆ on_net_receive()

template<typename IOLayer >

Pending http::base::Connection< IOLayer >::on_net_receive	(	const std::error_code &	ec,
		std::size_t	bytes_transferred
	)

inlineprotected

◆ on_net_send()

template<typename IOLayer >

Pending http::base::Connection< IOLayer >::on_net_send	(	const std::error_code &	ec,
		size_t	size
	)

inlineprotected

◆ on_output_buffer_empty()

template<typename IOLayer >

virtual void http::base::Connection< IOLayer >::on_output_buffer_empty ( )

inlineprotectedvirtual

Reimplemented in http::client::Connection< IOLayer >.

◆ resume()

template<typename IOLayer >

void http::base::Connection< IOLayer >::resume ( )

inlineprotected

◆ send()

template<typename IOLayer >

bool http::base::Connection< IOLayer >::send	(	const uint32_t *	stream_id_ptr,
		const int	status_code,
		const std::string &	method,
		const std::string &	path,
		const Headers &	headers,
		const IOBuffer &	data
	)

inlineoverridevirtual

Implements http::base::ConnectionInterface.

Reimplemented in http::client::Connection< IOLayer >.

◆ start()

template<typename IOLayer >

void http::base::Connection< IOLayer >::start ( )

inlineoverridevirtual

Implements http::base::ConnectionInterface.

Reimplemented in http::client::Connection< IOLayer >.

◆ stop_running()

template<typename IOLayer >

bool http::base::Connection< IOLayer >::stop_running ( )

inlineprotected

Mark the connection that it should stop running.

Returns: information if the object may be delete

Return values

'false'	Connection object can be removed immediately
'true'	Connection object must wait until IO is finished.

◆ suspend()

template<typename IOLayer >

void http::base::Connection< IOLayer >::suspend ( )

inlineprotected

Member Data Documentation

◆ allowed_method_

template<typename IOLayer >

Methods* http::base::Connection< IOLayer >::allowed_method_

protected

◆ cno_

template<typename IOLayer >

cno_connection_t http::base::Connection< IOLayer >::cno_

protected

◆ connection_handler_

template<typename IOLayer >

ConnectionStatusCallbacks* http::base::Connection< IOLayer >::connection_handler_

protected

◆ input_buffer_

template<typename IOLayer >

uint8_t http::base::Connection< IOLayer >::input_buffer_[512]

protected

◆ input_mutable_buffer_

template<typename IOLayer >

net::mutable_buffer http::base::Connection< IOLayer >::input_mutable_buffer_ {net::buffer(input_buffer_)}

protected

◆ keep_alive_

template<typename IOLayer >

bool http::base::Connection< IOLayer >::keep_alive_ {true}

protected

◆ output_buffer_mutex_

template<typename IOLayer >

std::mutex http::base::Connection< IOLayer >::output_buffer_mutex_

protected

◆ output_buffers_

template<typename IOLayer >

std::list<owned_buffer> http::base::Connection< IOLayer >::output_buffers_

protected

◆ output_pending_

template<typename IOLayer >

std::atomic<bool> http::base::Connection< IOLayer >::output_pending_ {false}

protected

◆ processed_request_

template<typename IOLayer >

std::atomic<bool> http::base::Connection< IOLayer >::processed_request_ {false}

protected

◆ running_

template<typename IOLayer >

std::atomic<bool> http::base::Connection< IOLayer >::running_ {true}

protected

◆ socket_

template<typename IOLayer >

IOLayer http::base::Connection< IOLayer >::socket_

protected

◆ suspend_

template<typename IOLayer >

std::atomic<bool> http::base::Connection< IOLayer >::suspend_ {false}

protected

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

router/src/http/include/http/base/connection.h

Public Types

Public Member Functions

Protected Member Functions

Protected Attributes

Member Typedef Documentation

◆ ConnectionStatusCallbacks

◆ Headers

◆ IO

◆ Methods

◆ owned_buffer

◆ ref_buffers

◆ This

Constructor & Destructor Documentation

◆ Connection()

◆ ~Connection()

Member Function Documentation

◆ do_net_recv()

◆ do_net_send()

◆ get_peer_address()

◆ get_peer_port()

◆ get_socket()

◆ on_cno_close()

◆ on_cno_message_tail()

◆ on_cno_stream_start()

◆ on_cno_writev()

◆ on_net_receive()

◆ on_net_send()

◆ on_output_buffer_empty()

◆ resume()

◆ send()

◆ start()

◆ stop_running()

◆ suspend()

Member Data Documentation

◆ allowed_method_

◆ cno_

◆ connection_handler_

◆ input_buffer_

◆ input_mutable_buffer_

◆ keep_alive_

◆ output_buffer_mutex_

◆ output_buffers_

◆ output_pending_

◆ processed_request_

◆ running_

◆ socket_

◆ suspend_