sese::iocp::v1::IOCPService Class Reference

Completion port sub-service based on sese-event. More...

#include <IOCPServer_V1.h>

Inheritance diagram for sese::iocp::v1::IOCPService:

Public Member Functions
	IOCPService (IOCPServer *master, bool active_release_mode)
	~IOCPService () override
void	postRead (Context *ctx)
void	postWrite (Context *ctx)
void	postClose (Context *ctx)
Public Member Functions inherited from sese::service::v2::TimerableService
void	dispatch (uint32_t timeout) override
v2::TimeoutEvent *	setTimeoutEvent (int64_t seconds, void *data)
void	cancelTimeoutEvent (v2::TimeoutEvent *event)

Static Public Member Functions
static void	onAcceptCompleted (Context *ctx)
static void	onPreRead (Context *ctx)
static void	onReadCompleted (Context *ctx)
static void	onWriteCompleted (Context *ctx)
static void	onTimeout (Context *ctx)
static void	onConnected (Context *ctx)
static void	onAlpnGet (Context *ctx, const uint8_t *in, uint32_t in_length)
static int	alpnCallbackFunction (void *ssl, const uint8_t **out, uint8_t *out_length, const uint8_t *in, uint32_t in_length, IOCPService *service)

Private Member Functions
void	onAccept (int fd) override
void	onRead (event::BaseEvent *event) override
void	onWrite (event::BaseEvent *event) override
void	onClose (event::BaseEvent *event) override
void	onTimeout (service::v2::TimeoutEvent *event) override
event::BaseEvent *	createEventEx (int fd, unsigned int events, void *data)
void	freeEventEx (sese::event::BaseEvent *event)
void	releaseContext (Context *ctx)

Static Private Member Functions
static int64_t	read (int fd, void *buffer, size_t len, void *ssl)
static int64_t	write (int fd, const void *buffer, size_t len, void *ssl)

Private Attributes
IOCPServer *	master {}
std::set< event::BaseEvent * >	eventSet

Detailed Description

Completion port sub-service based on sese-event.

Constructor & Destructor Documentation

IOCPService()

IOCPService::IOCPService ( IOCPServer * master, bool active_release_mode )

explicit

Initialize sub-service

Parameters

master	Master server
active_release_mode	Active release mode

References alpnCallbackFunction(), sese::iocp::v1::IOCPServer::getServCtx(), and master.

~IOCPService()

IOCPService::~IOCPService ( )

override

References sese::service::v2::TimerableService::cancelTimeoutEvent(), sese::net::Socket::close(), CTX, and eventSet.

Member Function Documentation

alpnCallbackFunction()

int IOCPService::alpnCallbackFunction ( void * ssl, const uint8_t ** out, uint8_t * out_length, const uint8_t * in, uint32_t in_length, IOCPService * service )

static

ALPN negotiation callback function

Parameters

ssl	SSL context
out	Expected content from peer
out_length	Length of expected content from peer
in	Response content
in_length	Length of response content
service	Associated sub-service

Returns

ALPN status code

References in(), master, and sese::iocp::v1::IOCPServer::onAlpnSelect().

Referenced by IOCPService().

createEventEx()

sese::event::BaseEvent * IOCPService::createEventEx ( int fd, unsigned int events, void * data )

private

References eventSet.

Referenced by postRead(), and postWrite().

freeEventEx()

void IOCPService::freeEventEx ( sese::event::BaseEvent * event )

private

References eventSet.

Referenced by releaseContext().

onAccept()

void IOCPService::onAccept ( int fd )

overrideprivate

References sese::net::Socket::close(), CTX, sese::iocp::v1::IOCPServer::getServCtx(), master, onAcceptCompleted(), onAlpnGet(), sese::iocp::v1::Context::self, and sese::net::Socket::setNonblocking().

onAcceptCompleted()

void IOCPService::onAcceptCompleted ( Context * ctx )

static

Sub-server connection access completion callback function

Parameters

ctx	Operation context

References sese::iocp::v1::IOCPServer::onAcceptCompleted(), and sese::iocp::v1::Context::self.

Referenced by onAccept().

onAlpnGet()

void IOCPService::onAlpnGet ( Context * ctx, const uint8_t * in, uint32_t in_length )

static

ALPN negotiation completion callback function

Parameters

ctx	Operation context
in	Negotiation content
in_length	Negotiation content length

References in(), sese::iocp::v1::IOCPServer::onAlpnGet(), and sese::iocp::v1::Context::self.

Referenced by onAccept(), and onWrite().

onClose()

void IOCPService::onClose ( event::BaseEvent * event )

overrideprivate

References CTX, and releaseContext().

onConnected()

void IOCPService::onConnected ( Context * ctx )

static

Connection event callback function

Parameters

ctx	Operation context

References sese::iocp::v1::IOCPServer::onConnected(), and sese::iocp::v1::Context::self.

Referenced by onWrite().

onPreRead()

void IOCPService::onPreRead ( Context * ctx )

static

Sub-service read event trigger callback function

Parameters

ctx	Operation context

References sese::iocp::v1::IOCPServer::onPreRead(), and sese::iocp::v1::Context::self.

Referenced by onRead().

onRead()

void IOCPService::onRead ( event::BaseEvent * event )

overrideprivate

References CTX, MTU_VALUE, onPreRead(), onReadCompleted(), read(), and releaseContext().

onReadCompleted()

void IOCPService::onReadCompleted ( Context * ctx )

static

Sub-service read event completion trigger callback function

Parameters

ctx	Operation context

References sese::iocp::v1::IOCPServer::onReadCompleted(), and sese::iocp::v1::Context::self.

Referenced by onRead().

onTimeout() [1/2]

void IOCPService::onTimeout ( Context * ctx )

static

Sub-service timeout callback function

Parameters

ctx	Operation context

References sese::iocp::v1::IOCPServer::onTimeout(), sese::iocp::v1::Context::self, and sese::iocp::v1::Context::timeoutEvent.

Referenced by onTimeout().

onTimeout() [2/2]

void IOCPService::onTimeout ( service::v2::TimeoutEvent * event )

overrideprivatevirtual

Timeout callback function

Parameters

event

Event

Reimplemented from sese::service::v2::TimerableService.

References CTX, and onTimeout().

onWrite()

void IOCPService::onWrite ( event::BaseEvent * event )

overrideprivate

References CTX, sese::event::BaseEvent::data, EINTR, EWOULDBLOCK, sese::net::getNetworkError(), MTU_VALUE, onAlpnGet(), onConnected(), onWriteCompleted(), postWrite(), releaseContext(), and write().

onWriteCompleted()

void IOCPService::onWriteCompleted ( Context * ctx )

static

Sub-service write event completion trigger callback function

Parameters

ctx	Operation context

References sese::iocp::v1::IOCPServer::onWriteCompleted(), and sese::iocp::v1::Context::self.

Referenced by onWrite().

postClose()

void IOCPService::postClose

(

Context *

ctx

)

Submit close event to the master server

Parameters

ctx	Operation context

References sese::iocp::v1::Context::fd, and releaseContext().

Referenced by sese::iocp::v1::IOCPServer::postClose().

postRead()

void IOCPService::postRead

(

Context *

ctx

)

Submit read event to the master server

Parameters

ctx	Operation context

References createEventEx(), sese::event::BaseEvent::data, sese::iocp::v1::Context::event, EVENT_READ, sese::event::BaseEvent::events, and sese::iocp::v1::Context::fd.

Referenced by sese::iocp::v1::IOCPServer::postRead().

postWrite()

void IOCPService::postWrite

(

Context *

ctx

)

Submit write event to the master server

Parameters

ctx	Operation context

References createEventEx(), sese::event::BaseEvent::data, sese::iocp::v1::Context::event, EVENT_WRITE, sese::event::BaseEvent::events, and sese::iocp::v1::Context::fd.

Referenced by onWrite(), and sese::iocp::v1::IOCPServer::postWrite().

read()

int64_t IOCPService::read ( int fd, void * buffer, size_t len, void * ssl )

staticprivate

References sese::net::Socket::read().

Referenced by onRead().

releaseContext()

void IOCPService::releaseContext ( Context * ctx )

private

References sese::service::v2::TimerableService::cancelTimeoutEvent(), sese::iocp::v1::Context::client, sese::net::Socket::close(), sese::iocp::v1::Context::event, sese::iocp::v1::Context::fd, freeEventEx(), sese::iocp::v1::IOCPServer::getDeleteContextCallback(), sese::iocp::v1::Context::self, sese::iocp::v1::Context::ssl, and sese::iocp::v1::Context::timeoutEvent.

Referenced by onClose(), onRead(), onWrite(), and postClose().

write()

int64_t IOCPService::write ( int fd, const void * buffer, size_t len, void * ssl )

staticprivate

References sese::net::Socket::write().

Referenced by onWrite().

Member Data Documentation

eventSet

std::set<event::BaseEvent *> sese::iocp::v1::IOCPService::eventSet

private

Referenced by createEventEx(), freeEventEx(), and ~IOCPService().

master

IOCPServer* sese::iocp::v1::IOCPService::master {}

private

Referenced by alpnCallbackFunction(), IOCPService(), and onAccept().

---

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

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