sese::iocp::v1::Context Class Reference

Completion port operation context based on sese-event. More...

#include <IOCPServer_V1.h>

Inheritance diagram for sese::iocp::v1::Context:

Public Member Functions
int64_t	read (void *buffer, size_t length) override
int64_t	write (const void *buffer, size_t length) override
int64_t	peek (void *buffer, size_t length) override
int64_t	trunc (size_t length) override
int32_t	getFd () const
void *	getData () const
void	setData (void *p_data)
Public Member Functions inherited from sese::io::InputStream
virtual	~InputStream () noexcept=default
Public Member Functions inherited from sese::io::OutputStream
virtual	~OutputStream () noexcept=default
int64_t	write (const std::string_view &buffer)
int64_t	write (const text::StringView &buffer)
template<typename T >
int64_t	write (std::vector< T > &buffer)
template<typename T , size_t N>
int64_t	write (std::array< T, N > &buffer)
Public Member Functions inherited from sese::io::PeekableStream
virtual	~PeekableStream ()=default

Private Attributes
IOCPServer *	self {}
IOCPService *	client {}
socket_t	fd {0}
void *	ssl {}
bool	isConn {false}
event::BaseEvent *	event {}
service::v2::TimeoutEvent *	timeoutEvent {}
io::ByteBuilder	send {8192, 8192}
io::ByteBuilder	recv {8192, 8192}
void *	data {}

Friends
class	IOCPServer
class	IOCPService

Additional Inherited Members
Public Types inherited from sese::io::InputStream
typedef std::shared_ptr< InputStream >	Ptr
Public Types inherited from sese::io::OutputStream
typedef std::shared_ptr< OutputStream >	Ptr
Public Types inherited from sese::io::PeekableStream
typedef std::shared_ptr< PeekableStream >	Ptr

Detailed Description

Completion port operation context based on sese-event.

Member Function Documentation

getData()

void * sese::iocp::v1::Context::getData ( ) const

inlinenodiscard

Get additional data of the current context

Returns

Additional data

References data.

getFd()

int32_t sese::iocp::v1::Context::getFd ( ) const

inlinenodiscard

Get the file descriptor of the current context connection

Returns

File descriptor

References fd.

peek()

int64_t Context::peek ( void * buffer, size_t length )

overridevirtual

Read content from the current connection without advancing

Parameters

buffer	Buffer
length	Size of buffer

Returns

Actual read size

Implements sese::io::PeekableStream.

References sese::io::AbstractByteBuffer::peek(), and recv.

read()

int64_t Context::read ( void * buffer, size_t length )

overridevirtual

Read content from the current connection

Parameters

buffer	Buffer
length	Size of buffer

Returns

Actual read size

Implements sese::io::InputStream.

References sese::io::AbstractByteBuffer::read(), and recv.

setData()

void sese::iocp::v1::Context::setData ( void * p_data )

inline

Set additional data for the current context

Parameters

p_data

Additional data

References data.

trunc()

int64_t Context::trunc ( size_t length )

overridevirtual

Advance in the current connection without reading content

Parameters

length

Advance size

Returns

Actual advance size

Implements sese::io::PeekableStream.

References recv, and sese::io::AbstractByteBuffer::trunc().

write()

int64_t Context::write ( const void * buffer, size_t length )

overridevirtual

Write content to the current connection

Parameters

buffer	Buffer
length	Size of buffer

Returns

Actual written size

Implements sese::io::OutputStream.

References send, and sese::io::AbstractByteBuffer::write().

Friends And Related Symbol Documentation

IOCPServer

friend class IOCPServer

friend

IOCPService

friend class IOCPService

friend

Member Data Documentation

client

IOCPService* sese::iocp::v1::Context::client {}

private

Referenced by sese::iocp::v1::IOCPServer::cancelTimeout(), sese::iocp::v1::IOCPServer::postClose(), sese::iocp::v1::IOCPServer::postRead(), sese::iocp::v1::IOCPServer::postWrite(), sese::iocp::v1::IOCPServer::preConnectCallback(), sese::iocp::v1::IOCPService::releaseContext(), and sese::iocp::v1::IOCPServer::setTimeout().

data

void* sese::iocp::v1::Context::data {}

private

Referenced by getData(), and setData().

event

event::BaseEvent* sese::iocp::v1::Context::event {}

private

Referenced by sese::iocp::v1::IOCPService::postRead(), sese::iocp::v1::IOCPService::postWrite(), and sese::iocp::v1::IOCPService::releaseContext().

fd

socket_t sese::iocp::v1::Context::fd {0}

private

Referenced by getFd(), sese::iocp::v1::IOCPService::postClose(), sese::iocp::v1::IOCPServer::postConnect(), sese::iocp::v1::IOCPService::postRead(), sese::iocp::v1::IOCPService::postWrite(), and sese::iocp::v1::IOCPService::releaseContext().

isConn

bool sese::iocp::v1::Context::isConn {false}

private

recv

io::ByteBuilder sese::iocp::v1::Context::recv {8192, 8192}

private

Referenced by peek(), read(), and trunc().

self

IOCPServer* sese::iocp::v1::Context::self {}

private

Referenced by sese::iocp::v1::IOCPService::onAccept(), sese::iocp::v1::IOCPService::onAcceptCompleted(), sese::iocp::v1::IOCPService::onAlpnGet(), sese::iocp::v1::IOCPService::onConnected(), sese::iocp::v1::IOCPService::onPreRead(), sese::iocp::v1::IOCPService::onReadCompleted(), sese::iocp::v1::IOCPService::onTimeout(), sese::iocp::v1::IOCPService::onWriteCompleted(), and sese::iocp::v1::IOCPService::releaseContext().

send

io::ByteBuilder sese::iocp::v1::Context::send {8192, 8192}

private

Referenced by write().

ssl

void* sese::iocp::v1::Context::ssl {}

private

Referenced by sese::iocp::v1::IOCPService::releaseContext().

timeoutEvent

service::v2::TimeoutEvent* sese::iocp::v1::Context::timeoutEvent {}

private

Referenced by sese::iocp::v1::IOCPServer::cancelTimeout(), sese::iocp::v1::IOCPService::onTimeout(), sese::iocp::v1::IOCPService::releaseContext(), and sese::iocp::v1::IOCPServer::setTimeout().

---

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

• sese/service/iocp/IOCPServer_V1.h
• sese/service/iocp/IOCPServer_V1.cpp