Horizon::Char::CharSession Class Reference

#include <CharSession.hpp>

Inheritance diagram for Horizon::Char::CharSession:

Collaboration diagram for Horizon::Char::CharSession:

Public Member Functions
	CharSession (uint64_t uid)
	~CharSession ()
void	initialize ()
void	update (uint32_t diff)
void	perform_cleanup ()
std::unique_ptr< CharClientInterface > &	clif ()
std::unique_ptr< ClientPacketLengthTable > &	pkt_tbl ()
s_session_data &	get_session_data ()
void	set_session_data (s_session_data &data)
void	transmit_buffer (ByteBuffer _buffer, std::size_t size)
Public Member Functions inherited from Horizon::Networking::Session< CharSocket, CharSession >
	Session (uint64_t uid)
virtual	~Session ()
std::shared_ptr< CharSocket >	get_socket ()
	Get the socket. More...
void	set_socket (std::weak_ptr< CharSocket > socket)
	Set the socket. More...
virtual void	update (uint32_t diff)=0
virtual void	initialize ()=0
bool	is_initialized ()
	Called to verify if the session is initialized. More...
void	set_initialized (bool initialized)
	Set whether the session is initialized or not. More...
uint64_t	get_session_id ()
	Get the unique id of the session. More...
ThreadSafeQueue< ByteBuffer > &	get_recv_queue ()
	Receive queue of the buffer received by the socket. More...

Protected Attributes
std::unique_ptr< CharClientInterface >	_clif
std::unique_ptr< ClientPacketLengthTable >	_pkt_tbl
s_session_data	_session_data
std::mutex	_sd_mutex
bool	_first_packet_sent {false}

Constructor & Destructor Documentation

CharSession()

CharSession::CharSession

(

uint64_t

uid

)

: Horizon::Networking::Session<CharSocket, CharSession>(uid)
{
}

~CharSession()

CharSession::~CharSession

(

)

{
    //
}

Member Function Documentation

clif()

std::unique_ptr< CharClientInterface > & Horizon::Char::CharSession::clif ( )

inline

{ return _clif; }

References _clif.

get_session_data()

s_session_data & Horizon::Char::CharSession::get_session_data ( )

inline

{ std::lock_guard<std::mutex> lock(_sd_mutex); return _session_data; }

References _sd_mutex, and _session_data.

initialize()

void CharSession::initialize ( )

virtual

Called when the session is started. Virtual method that must be implmented by the derived class. Typically used to initialize the session.

Returns

void

Implements Horizon::Networking::Session< CharSocket, CharSession >.

{
    _pkt_tbl = std::make_unique<ClientPacketLengthTable>(shared_from_this());
    _clif = std::make_unique<CharClientInterface>(shared_from_this());
    set_initialized(true);
}

References _clif, _pkt_tbl, and Horizon::Networking::Session< CharSocket, CharSession >::set_initialized().

Here is the call graph for this function:

perform_cleanup()

void Horizon::Char::CharSession::perform_cleanup

(

)

pkt_tbl()

std::unique_ptr< ClientPacketLengthTable > & Horizon::Char::CharSession::pkt_tbl ( )

inline

{ return _pkt_tbl; }

References _pkt_tbl.

set_session_data()

void Horizon::Char::CharSession::set_session_data ( s_session_data &  data )

inline

{ std::lock_guard<std::mutex> lock(_sd_mutex); _session_data = data; }

References _sd_mutex, and _session_data.

transmit_buffer()

void CharSession::transmit_buffer	(	ByteBuffer	_buffer,
		std::size_t	size
	)

{
    if (get_socket() == nullptr || !get_socket()->is_open())
        return;
    
    if (!_buffer.is_empty()) {
        // The first packet in the character server has no packet_id
        // and is the account id so its length is not deduceable as it can't be looked up.
        if(_first_packet_sent == true) {
            uint16_t packet_id = 0x0;
            int16_t packet_len = 0;
            
            memcpy(&packet_id, _buffer.get_read_pointer(), sizeof(int16_t));
            
            TPacketTablePairType p = _pkt_tbl->get_tpacket_info(packet_id);
 
            if (p.first == -1) {
                memcpy(&packet_len, _buffer.get_read_pointer() + 2, sizeof(int16_t));
            } else {
                packet_len = p.first;
            }
 
            if (packet_id == 0x0000) {
                HLog(warning) << "Server tried to send a disabled packet... ignoring.";
                return;
            }
 
            if (packet_len != _buffer.active_length()) {
                HLog(warning) << "Packet 0x" << std::hex << packet_id << " has length len " << std::dec << packet_len << " but buffer has " << _buffer.active_length() << " bytes... ignoring.";
                return;
            }
        } else {
            _first_packet_sent = true;
        }
 
        get_socket()->queue_buffer(std::move(_buffer));
    }
}

References _first_packet_sent, _pkt_tbl, ByteBuffer::active_length(), ByteBuffer::get_read_pointer(), Horizon::Networking::Session< CharSocket, CharSession >::get_socket(), HLog, and ByteBuffer::is_empty().

Here is the call graph for this function:

update()

void CharSession::update ( uint32_t  diff )

virtual

Called when the session is started. Virtual method that must be implmented by the derived class. Typically used to update the session and process packets.

Returns

void

Implements Horizon::Networking::Session< CharSocket, CharSession >.

{
    std::shared_ptr<ByteBuffer> read_buf;
    while ((read_buf = get_recv_queue().try_pop())) {
        uint16_t packet_id = 0x0;
        memcpy(&packet_id, read_buf->get_read_pointer(), sizeof(uint16_t));
        HPacketTablePairType p = _pkt_tbl->get_hpacket_info(packet_id);
        
        HLog(debug) << "Handling packet 0x" << std::hex << packet_id << " - 0x" << p.first << std::endl;
        
        p.second->handle(std::move(*read_buf));
    }
}

References _pkt_tbl, Horizon::Networking::Session< CharSocket, CharSession >::get_recv_queue(), and HLog.

Here is the call graph for this function:

Member Data Documentation

_clif

std::unique_ptr<CharClientInterface> Horizon::Char::CharSession::_clif

protected

Referenced by clif(), and initialize().

_first_packet_sent

bool Horizon::Char::CharSession::_first_packet_sent {false}

protected

Referenced by transmit_buffer().

_pkt_tbl

std::unique_ptr<ClientPacketLengthTable> Horizon::Char::CharSession::_pkt_tbl

protected

Referenced by initialize(), pkt_tbl(), transmit_buffer(), and update().

_sd_mutex

std::mutex Horizon::Char::CharSession::_sd_mutex

protected

Referenced by get_session_data(), and set_session_data().

_session_data

s_session_data Horizon::Char::CharSession::_session_data

protected

Referenced by get_session_data(), and set_session_data().

---

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

• src/Server/Char/Session/CharSession.hpp
• src/Server/Char/Session/CharSession.cpp