#include <Socket.h>

Inheritance diagram for Trinity::Net::Socket< Stream >:

Public Member Functions
template<typename... Args>
	Socket (IoContextTcpSocket &&socket, Args &&... args)

template<typename... Args>
	Socket (boost::asio::io_context &context, Args &&... args)

	Socket (Socket const &other)=delete

	Socket (Socket &&other)=delete

Socket &	operator= (Socket const &other)=delete

Socket &	operator= (Socket &&other)=delete

virtual	~Socket ()

virtual void	Start ()

virtual bool	Update ()

boost::asio::ip::address const &	GetRemoteIpAddress () const

uint16	GetRemotePort () const

template<SocketReadCallback Callback>
void	AsyncRead (Callback &&callback)

void	QueuePacket (MessageBuffer &&buffer)

bool	IsOpen () const

void	CloseSocket ()

void	DelayedCloseSocket ()
	Marks the socket for closing after write buffer becomes empty.

MessageBuffer &	GetReadBuffer ()

Stream &	underlying_stream ()

Protected Member Functions
virtual void	OnClose ()

virtual SocketReadCallbackResult	ReadHandler ()

bool	AsyncProcessQueue ()

void	SetNoDelay (bool enable)

Private Member Functions
bool	ReadHandlerInternal (boost::system::error_code const &error, size_t transferredBytes)

void	WriteHandlerWrapper (boost::system::error_code const &)

bool	HandleQueue ()

Private Attributes
Stream	_socket

boost::asio::ip::address	_remoteAddress

uint16	_remotePort = 0

MessageBuffer	_readBuffer = MessageBuffer(READ_BLOCK_SIZE)

std::queue< MessageBuffer >	_writeQueue

std::atomic< uint8 >	_openState

bool	_isWritingAsync = false

Static Private Attributes
static constexpr uint8	OpenState_Open = 0x0

static constexpr uint8	OpenState_Closing = 0x1
	Transition to Closed state after sending all queued data.

static constexpr uint8	OpenState_Closed = 0x2

Detailed Description

template<class Stream = IoContextTcpSocket>
class Trinity::Net::Socket< Stream >

Base async socket implementation

Template Parameters

Stream stream type used for operations on socket Stream must implement the following methods:

void close(boost::system::error_code& error);

void shutdown(boost::asio::socket_base::shutdown_type what, boost::system::error_code& shutdownError);

template<typename MutableBufferSequence, typename ReadHandlerType> void async_read_some(MutableBufferSequence const& buffers, ReadHandlerType&& handler);

template<typename ConstBufferSequence, typename WriteHandlerType> void async_write_some(ConstBufferSequence const& buffers, WriteHandlerType&& handler);

template<typename ConstBufferSequence> std::size_t write_some(ConstBufferSequence const& buffers, boost::system::error_code& error);

template<typename WaitHandlerType> void async_wait(boost::asio::socket_base::wait_type type, WaitHandlerType&& handler);

template<typename SettableSocketOption> void set_option(SettableSocketOption const& option, boost::system::error_code& error);

tcp::socket::endpoint_type remote_endpoint() const;

Definition at line 109 of file Socket.h.

Constructor & Destructor Documentation

◆ Socket() [1/4]

template<class Stream = IoContextTcpSocket>

template<typename... Args>

Trinity::Net::Socket< Stream >::Socket	(	IoContextTcpSocket< Stream > &&	socket,
		Args &&...	args
	)

inlineexplicit

Definition at line 113 of file Socket.h.

◆ Socket() [2/4]

template<class Stream = IoContextTcpSocket>

template<typename... Args>

Trinity::Net::Socket< Stream >::Socket	(	boost::asio::io_context &	context,
		Args &&...	args
	)

inlineexplicit

Definition at line 119 of file Socket.h.

◆ Socket() [3/4]

template<class Stream = IoContextTcpSocket>

Trinity::Net::Socket< Stream >::Socket ( Socket< Stream > const & other )

delete

◆ Socket() [4/4]

template<class Stream = IoContextTcpSocket>

Trinity::Net::Socket< Stream >::Socket ( Socket< Stream > && other )

delete

◆ ~Socket()

template<class Stream = IoContextTcpSocket>

virtual Trinity::Net::Socket< Stream >::~Socket ( )

inlinevirtual

Definition at line 128 of file Socket.h.

References Trinity::Net::Socket< Stream >::_openState, Trinity::Net::Socket< Stream >::_socket, and Trinity::Net::Socket< Stream >::OpenState_Closed.

Member Function Documentation

◆ AsyncProcessQueue()

template<class Stream = IoContextTcpSocket>

bool Trinity::Net::Socket< Stream >::AsyncProcessQueue ( )

inlineprotected

Definition at line 227 of file Socket.h.

References Trinity::Net::Socket< Stream >::_isWritingAsync, Trinity::Net::Socket< Stream >::_socket, Trinity::Net::Socket< Stream >::_writeQueue, MessageBuffer::GetActiveSize(), and MessageBuffer::GetReadPointer().

Referenced by Trinity::Net::Socket< Stream >::HandleQueue(), and Trinity::Net::Socket< Stream >::QueuePacket().

◆ AsyncRead()

template<class Stream = IoContextTcpSocket>

template<SocketReadCallback Callback>

void Trinity::Net::Socket< Stream >::AsyncRead ( Callback && callback )

inline

Definition at line 164 of file Socket.h.

References Trinity::Net::Socket< Stream >::_readBuffer, Trinity::Net::Socket< Stream >::_socket, MessageBuffer::EnsureFreeSpace(), MessageBuffer::GetRemainingSpace(), MessageBuffer::GetWritePointer(), Trinity::Net::Socket< Stream >::IsOpen(), and MessageBuffer::Normalize().

Referenced by WorldSocket::HandleAuthSessionCallback().

◆ CloseSocket()

template<class Stream = IoContextTcpSocket>

void Trinity::Net::Socket< Stream >::CloseSocket ( )

inline

Definition at line 191 of file Socket.h.

References Trinity::Net::Socket< Stream >::_openState, Trinity::Net::Socket< Stream >::_socket, Trinity::Net::Socket< Stream >::GetRemoteIpAddress(), Trinity::Net::Socket< Stream >::OnClose(), Trinity::Net::Socket< Stream >::OpenState_Closed, and TC_LOG_DEBUG.

Referenced by Trinity::Net::Socket< Stream >::DelayedCloseSocket(), Trinity::Net::Socket< Stream >::HandleQueue(), AuthSession::ReadHandler(), WorldSocket::ReadHandler(), and Trinity::Net::Socket< Stream >::ReadHandlerInternal().

◆ DelayedCloseSocket()

template<class Stream = IoContextTcpSocket>

void Trinity::Net::Socket< Stream >::DelayedCloseSocket ( )

inline

Marks the socket for closing after write buffer becomes empty.

Definition at line 206 of file Socket.h.

References Trinity::Net::Socket< Stream >::_openState, Trinity::Net::Socket< Stream >::_writeQueue, Trinity::Net::Socket< Stream >::CloseSocket(), and Trinity::Net::Socket< Stream >::OpenState_Closing.

Referenced by WorldSocket::HandleAuthSessionCallback().

◆ GetReadBuffer()

template<class Stream = IoContextTcpSocket>

MessageBuffer & Trinity::Net::Socket< Stream >::GetReadBuffer ( )

inline

Definition at line 215 of file Socket.h.

References Trinity::Net::Socket< Stream >::_readBuffer.

Referenced by AuthSession::HandleLogonChallenge(), AuthSession::HandleLogonProof(), AuthSession::HandleReconnectChallenge(), AuthSession::HandleReconnectProof(), AuthSession::ReadHandler(), and WorldSocket::ReadHandler().

◆ GetRemoteIpAddress()

template<class Stream = IoContextTcpSocket>

boost::asio::ip::address const & Trinity::Net::Socket< Stream >::GetRemoteIpAddress ( ) const

inline

Definition at line 153 of file Socket.h.

References Trinity::Net::Socket< Stream >::_remoteAddress.

Referenced by Trinity::Net::Socket< Stream >::CloseSocket(), WorldSocket::HandleAuthSessionCallback(), AuthSession::HandleLogonProof(), WorldSocket::HandlePing(), AuthSession::HandleReconnectProof(), AuthSession::LogonChallengeCallback(), WorldSocket::LogOpcodeText(), WorldSocket::ReadDataHandler(), WorldSocket::ReadHeaderHandler(), AuthSession::RealmListCallback(), WorldSocket::SendPacket(), WorldSocket::SendPacketAndLogOpcode(), and Trinity::Net::Socket< Stream >::SetNoDelay().

◆ GetRemotePort()

template<class Stream = IoContextTcpSocket>

uint16 Trinity::Net::Socket< Stream >::GetRemotePort ( ) const

inline

Definition at line 158 of file Socket.h.

References Trinity::Net::Socket< Stream >::_remotePort.

Referenced by AuthSession::HandleLogonProof(), AuthSession::HandleReconnectProof(), AuthSession::LogonChallengeCallback(), WorldSocket::ReadDataHandler(), and WorldSocket::SendPacket().

◆ HandleQueue()

template<class Stream = IoContextTcpSocket>

bool Trinity::Net::Socket< Stream >::HandleQueue ( )

inlineprivate

Definition at line 302 of file Socket.h.

References Trinity::Net::Socket< Stream >::_openState, Trinity::Net::Socket< Stream >::_socket, Trinity::Net::Socket< Stream >::_writeQueue, Trinity::Net::Socket< Stream >::AsyncProcessQueue(), Trinity::Net::Socket< Stream >::CloseSocket(), MessageBuffer::GetActiveSize(), MessageBuffer::GetReadPointer(), Trinity::Net::Socket< Stream >::OpenState_Closing, and MessageBuffer::ReadCompleted().

Referenced by Trinity::Net::Socket< Stream >::Update(), and Trinity::Net::Socket< Stream >::WriteHandlerWrapper().

◆ IsOpen()

template<class Stream = IoContextTcpSocket>

bool Trinity::Net::Socket< Stream >::IsOpen ( ) const

inline

Definition at line 189 of file Socket.h.

References Trinity::Net::Socket< Stream >::_openState, and Trinity::Net::Socket< Stream >::OpenState_Open.

Referenced by Trinity::Net::Socket< Stream >::AsyncRead(), Trinity::Net::Socket< Stream >::ReadHandlerInternal(), AuthSession::SendPacket(), and WorldSocket::SendPacket().

◆ OnClose()

template<class Stream = IoContextTcpSocket>

virtual void Trinity::Net::Socket< Stream >::OnClose ( )

inlineprotectedvirtual

Reimplemented in WorldSocket.

Definition at line 223 of file Socket.h.

Referenced by Trinity::Net::Socket< Stream >::CloseSocket().

◆ operator=() [1/2]

template<class Stream = IoContextTcpSocket>

Socket & Trinity::Net::Socket< Stream >::operator= ( Socket< Stream > && other )

delete

◆ operator=() [2/2]

template<class Stream = IoContextTcpSocket>

Socket & Trinity::Net::Socket< Stream >::operator= ( Socket< Stream > const & other )

delete

◆ QueuePacket()

template<class Stream = IoContextTcpSocket>

void Trinity::Net::Socket< Stream >::QueuePacket ( MessageBuffer && buffer )

inline

Definition at line 180 of file Socket.h.

References Trinity::Net::Socket< Stream >::_writeQueue, and Trinity::Net::Socket< Stream >::AsyncProcessQueue().

Referenced by AuthSession::SendPacket(), and WorldSocket::Update().

◆ ReadHandler()

template<class Stream = IoContextTcpSocket>

virtual SocketReadCallbackResult Trinity::Net::Socket< Stream >::ReadHandler ( )

inlineprotectedvirtual

Reimplemented in AuthSession, and WorldSocket.

Definition at line 225 of file Socket.h.

References Trinity::Net::KeepReading.

Referenced by Trinity::Net::InvokeReadHandlerCallback< SocketType >::operator()().

◆ ReadHandlerInternal()

template<class Stream = IoContextTcpSocket>

bool Trinity::Net::Socket< Stream >::ReadHandlerInternal	(	boost::system::error_code const &	error,
		size_t	transferredBytes
	)

inlineprivate

Definition at line 262 of file Socket.h.

References Trinity::Net::Socket< Stream >::_readBuffer, Trinity::Net::Socket< Stream >::CloseSocket(), Trinity::Net::Socket< Stream >::IsOpen(), and MessageBuffer::WriteCompleted().

◆ SetNoDelay()

template<class Stream = IoContextTcpSocket>

void Trinity::Net::Socket< Stream >::SetNoDelay ( bool enable )

inlineprotected

Definition at line 252 of file Socket.h.

References Trinity::Net::Socket< Stream >::_socket, Trinity::Net::Socket< Stream >::GetRemoteIpAddress(), and TC_LOG_DEBUG.

◆ Start()

template<class Stream = IoContextTcpSocket>

virtual void Trinity::Net::Socket< Stream >::Start ( )

inlinevirtual

Reimplemented in AuthSession, and WorldSocket.

Definition at line 135 of file Socket.h.

◆ underlying_stream()

template<class Stream = IoContextTcpSocket>

Stream & Trinity::Net::Socket< Stream >::underlying_stream ( )

inline

Definition at line 217 of file Socket.h.

References Trinity::Net::Socket< Stream >::_socket.

◆ Update()

template<class Stream = IoContextTcpSocket>

virtual bool Trinity::Net::Socket< Stream >::Update ( )

inlinevirtual

Reimplemented in AuthSession, and WorldSocket.

Definition at line 137 of file Socket.h.

References Trinity::Net::Socket< Stream >::_isWritingAsync, Trinity::Net::Socket< Stream >::_openState, Trinity::Net::Socket< Stream >::_writeQueue, Trinity::Net::Socket< Stream >::HandleQueue(), Trinity::Net::Socket< Stream >::OpenState_Closed, and Trinity::Net::Socket< Stream >::OpenState_Open.

◆ WriteHandlerWrapper()

template<class Stream = IoContextTcpSocket>

void Trinity::Net::Socket< Stream >::WriteHandlerWrapper ( boost::system::error_code const & )

inlineprivate

Definition at line 296 of file Socket.h.

References Trinity::Net::Socket< Stream >::_isWritingAsync, and Trinity::Net::Socket< Stream >::HandleQueue().

Member Data Documentation

◆ _isWritingAsync

template<class Stream = IoContextTcpSocket>

bool Trinity::Net::Socket< Stream >::_isWritingAsync = false

private

Definition at line 360 of file Socket.h.

Referenced by Trinity::Net::Socket< Stream >::AsyncProcessQueue(), Trinity::Net::Socket< Stream >::Update(), and Trinity::Net::Socket< Stream >::WriteHandlerWrapper().

◆ _openState

template<class Stream = IoContextTcpSocket>

std::atomic<uint8> Trinity::Net::Socket< Stream >::_openState

private

Definition at line 358 of file Socket.h.

Referenced by Trinity::Net::Socket< Stream >::CloseSocket(), Trinity::Net::Socket< Stream >::DelayedCloseSocket(), Trinity::Net::Socket< Stream >::HandleQueue(), Trinity::Net::Socket< Stream >::IsOpen(), Trinity::Net::Socket< Stream >::Update(), and Trinity::Net::Socket< Stream >::~Socket().

◆ _readBuffer

template<class Stream = IoContextTcpSocket>

MessageBuffer Trinity::Net::Socket< Stream >::_readBuffer = MessageBuffer(READ_BLOCK_SIZE)

private

Definition at line 350 of file Socket.h.

Referenced by Trinity::Net::Socket< Stream >::AsyncRead(), Trinity::Net::Socket< Stream >::GetReadBuffer(), and Trinity::Net::Socket< Stream >::ReadHandlerInternal().

◆ _remoteAddress

template<class Stream = IoContextTcpSocket>

boost::asio::ip::address Trinity::Net::Socket< Stream >::_remoteAddress

private

Definition at line 347 of file Socket.h.

Referenced by Trinity::Net::Socket< Stream >::GetRemoteIpAddress().

◆ _remotePort

template<class Stream = IoContextTcpSocket>

uint16 Trinity::Net::Socket< Stream >::_remotePort = 0

private

Definition at line 348 of file Socket.h.

Referenced by Trinity::Net::Socket< Stream >::GetRemotePort().

◆ _socket

template<class Stream = IoContextTcpSocket>

Stream Trinity::Net::Socket< Stream >::_socket

private

Definition at line 345 of file Socket.h.

Referenced by Trinity::Net::Socket< Stream >::AsyncProcessQueue(), Trinity::Net::Socket< Stream >::AsyncRead(), Trinity::Net::Socket< Stream >::CloseSocket(), Trinity::Net::Socket< Stream >::HandleQueue(), Trinity::Net::Socket< Stream >::SetNoDelay(), Trinity::Net::Socket< Stream >::underlying_stream(), and Trinity::Net::Socket< Stream >::~Socket().

◆ _writeQueue

template<class Stream = IoContextTcpSocket>

std::queue<MessageBuffer> Trinity::Net::Socket< Stream >::_writeQueue

private

Definition at line 351 of file Socket.h.

Referenced by Trinity::Net::Socket< Stream >::AsyncProcessQueue(), Trinity::Net::Socket< Stream >::DelayedCloseSocket(), Trinity::Net::Socket< Stream >::HandleQueue(), Trinity::Net::Socket< Stream >::QueuePacket(), and Trinity::Net::Socket< Stream >::Update().

◆ OpenState_Closed

template<class Stream = IoContextTcpSocket>

constexpr uint8 Trinity::Net::Socket< Stream >::OpenState_Closed = 0x2

staticconstexprprivate

Definition at line 356 of file Socket.h.

Referenced by Trinity::Net::Socket< Stream >::CloseSocket(), Trinity::Net::Socket< Stream >::Update(), and Trinity::Net::Socket< Stream >::~Socket().

◆ OpenState_Closing

template<class Stream = IoContextTcpSocket>

constexpr uint8 Trinity::Net::Socket< Stream >::OpenState_Closing = 0x1

staticconstexprprivate

Transition to Closed state after sending all queued data.

Definition at line 355 of file Socket.h.

Referenced by Trinity::Net::Socket< Stream >::DelayedCloseSocket(), and Trinity::Net::Socket< Stream >::HandleQueue().

◆ OpenState_Open

template<class Stream = IoContextTcpSocket>

constexpr uint8 Trinity::Net::Socket< Stream >::OpenState_Open = 0x0

staticconstexprprivate

Definition at line 354 of file Socket.h.

Referenced by Trinity::Net::Socket< Stream >::IsOpen(), and Trinity::Net::Socket< Stream >::Update().

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

server/shared/Networking/Socket.h

Public Member Functions

Protected Member Functions

Private Member Functions

Private Attributes

Static Private Attributes

Detailed Description

Constructor & Destructor Documentation

◆ Socket() [1/4]

◆ Socket() [2/4]

◆ Socket() [3/4]

◆ Socket() [4/4]

◆ ~Socket()

Member Function Documentation

◆ AsyncProcessQueue()

◆ AsyncRead()

◆ CloseSocket()

◆ DelayedCloseSocket()

◆ GetReadBuffer()

◆ GetRemoteIpAddress()

◆ GetRemotePort()

◆ HandleQueue()

◆ IsOpen()

◆ OnClose()

◆ operator=() [1/2]

◆ operator=() [2/2]

◆ QueuePacket()

◆ ReadHandler()

◆ ReadHandlerInternal()

◆ SetNoDelay()

◆ Start()

◆ underlying_stream()

◆ Update()

◆ WriteHandlerWrapper()

Member Data Documentation

◆ _isWritingAsync

◆ _openState

◆ _readBuffer

◆ _remoteAddress

◆ _remotePort

◆ _socket

◆ _writeQueue

◆ OpenState_Closed

◆ OpenState_Closing

◆ OpenState_Open