sese::internal::service::http::HttpConnectionExImpl Struct Reference

#include <HttpConnectionEx.h>

Inheritance diagram for sese::internal::service::http::HttpConnectionExImpl:

Public Types
using	Ptr = std::shared_ptr<HttpConnectionExImpl>
using	Socket = asio::ip::tcp::socket
using	SharedSocket = std::shared_ptr<Socket>
Public Types inherited from sese::internal::service::http::HttpConnectionEx
using	Ptr = std::shared_ptr<HttpConnectionEx>

Public Member Functions
Ptr	getPtr ()
	HttpConnectionExImpl (const std::shared_ptr< HttpServiceImpl > &service, asio::io_context &context, const sese::net::IPAddress::Ptr &addr, SharedSocket socket)
void	writeBlocks (const std::vector< asio::const_buffer > &buffers, const std::function< void(const asio::error_code &code)> &callback) override
void	writeBlock (const void *buffer, size_t size, const std::function< void(const asio::error_code &code)> &callback) override
void	readBlock (char *buffer, size_t length, const std::function< void(const asio::error_code &code)> &callback) override
void	checkKeepalive () override
Public Member Functions inherited from sese::internal::service::http::HttpConnectionEx
Ptr	getPtr ()
	HttpConnectionEx (const std::shared_ptr< HttpServiceImpl > &service, asio::io_context &io_context, const sese::net::IPAddress::Ptr &addr)
virtual	~HttpConnectionEx ()=default
void	close (uint32_t id)
void	disponse ()
void	readMagic ()
void	readFrameHeader ()
void	handleFrameHeader ()
uint8_t	handleSettingsFrame ()
void	handleWindowUpdate ()
void	handleRstStreamFrame ()
void	handleGoawayFrame ()
void	handleHeadersFrame ()
void	handleDataFrame ()
void	handlePriorityFrame ()
void	handlePingFrame ()
void	handleRequest (const HttpStream::Ptr &stream)
void	handleWrite ()
void	writeSettingsFrame ()
void	writeAckFrame ()
void	writeGoawayFrame (uint32_t latest_stream_id, uint8_t flags, uint32_t error_code, const std::string &msg, bool once=false)
void	writeRstStreamFrame (uint32_t stream_id, uint8_t flags, uint32_t error_code, bool once=false)
void	writeWindowUpdateFrame (uint32_t stream_id, uint8_t flags, uint32_t window_size)
bool	writeHeadersFrame (const HttpStream::Ptr &stream, bool verify_end_stream=true)
bool	writeDataFrame4Body (const HttpStream::Ptr &stream)
bool	writeDataFrame4SingleRange (const HttpStream::Ptr &stream)
bool	writeDataFrame4Ranges (const HttpStream::Ptr &stream)
void	writeSubheaderAndData (const HttpStream::Ptr &stream, const std::string &subheader, size_t remind)

Public Attributes
SharedSocket	socket
Public Attributes inherited from sese::internal::service::http::HttpConnectionEx
bool	keepalive = false
asio::system_timer	timer
sese::net::IPAddress::Ptr	remote_address
std::weak_ptr< HttpServiceImpl >	service
bool	is_read = false
bool	is_write = false
bool	expect_ack = false
uint32_t	accept_stream_count = 0
uint32_t	latest_stream_ident = 0
sese::net::http::Http2FrameInfo	frame {}
char	temp_buffer [MAX_FRAME_SIZE] {}
uint32_t	header_table_size = 4096
uint32_t	enable_push = 0
uint32_t	max_concurrent_stream = 0
uint32_t	endpoint_init_window_size = 65535
uint32_t	endpoint_window_size = 65535
uint32_t	window_size = 65535
uint32_t	endpoint_max_frame_size = 16384
uint32_t	max_frame_size = 16384
uint32_t	max_header_list_size = 0
sese::net::http::DynamicTable	req_dynamic_table
sese::net::http::DynamicTable	resp_dynamic_table
std::map< uint32_t, HttpStream::Ptr >	streams
std::set< uint32_t >	closed_streams
std::vector< sese::net::http::Http2Frame::Ptr >	pre_vector
	Send queues.
std::vector< sese::net::http::Http2Frame::Ptr >	vector
std::vector< asio::const_buffer >	asio_buffers

Additional Inherited Members
Static Public Attributes inherited from sese::internal::service::http::HttpConnectionEx
static constexpr uint32_t	MAX_FRAME_SIZE = 16384
static constexpr uint32_t	INIT_WINDOW_SIZE = 65535
static constexpr uint32_t	HEADER_TABLE_SIZE = 8192
static constexpr uint32_t	MAX_CONCURRENT_STREAMS = 16

Member Typedef Documentation

Ptr

using sese::internal::service::http::HttpConnectionExImpl::Ptr = std::shared_ptr<HttpConnectionExImpl>

SharedSocket

using sese::internal::service::http::HttpConnectionExImpl::SharedSocket = std::shared_ptr<Socket>

Socket

using sese::internal::service::http::HttpConnectionExImpl::Socket = asio::ip::tcp::socket

Constructor & Destructor Documentation

HttpConnectionExImpl()

sese::internal::service::http::HttpConnectionExImpl::HttpConnectionExImpl	(	const std::shared_ptr< HttpServiceImpl > &	service,
		asio::io_context &	context,
		const sese::net::IPAddress::Ptr &	addr,
		SharedSocket	socket )

Member Function Documentation

checkKeepalive()

void sese::internal::service::http::HttpConnectionExImpl::checkKeepalive ( )

overridevirtual

Implements sese::internal::service::http::HttpConnectionEx.

getPtr()

Ptr sese::internal::service::http::HttpConnectionExImpl::getPtr ( )

inline

readBlock()

void sese::internal::service::http::HttpConnectionExImpl::readBlock ( char * buffer, size_t length, const std::function< void(const asio::error_code &code)> & callback )

overridevirtual

Read block function. This function ensures that the specified size of the buffer is completely read, and calls back immediately if an error occurs

Parameters

buffer	Pointer to the buffer
length	Size of the buffer
callback	Completion callback function

Implements sese::internal::service::http::HttpConnectionEx.

References callback(), and read().

writeBlock()

void sese::internal::service::http::HttpConnectionExImpl::writeBlock ( const void * buffer, size_t size, const std::function< void(const asio::error_code &code)> & callback )

overridevirtual

Write block function. This function ensures that a single block of buffer is completely written, and calls back immediately if an error occurs

Parameters

buffer	Single block buffer
size	Size of the buffer
callback	Completion callback function

Implements sese::internal::service::http::HttpConnectionEx.

References callback().

writeBlocks()

void sese::internal::service::http::HttpConnectionExImpl::writeBlocks ( const std::vector< asio::const_buffer > & buffers, const std::function< void(const asio::error_code &code)> & callback )

overridevirtual

Write block function. This function ensures that the specified buffer is completely written, and calls back immediately if an error occurs

Parameters

buffers	Buffer
callback	Completion callback function

Implements sese::internal::service::http::HttpConnectionEx.

References callback().

Member Data Documentation

socket

SharedSocket sese::internal::service::http::HttpConnectionExImpl::socket

---

The documentation for this struct was generated from the following files:

• sese/internal/service/http/HttpConnectionEx.h
• sese/internal/service/http/HttpConnectionExImpl.cpp