Horizon::Char::CharSocket Class Reference

#include <CharSocket.hpp>

Inheritance diagram for Horizon::Char::CharSocket:

Collaboration diagram for Horizon::Char::CharSocket:

Public Member Functions
	CharSocket (uint64_t uid, std::shared_ptr< tcp::socket > socket)
	~CharSocket ()
void	start () override
	Initial method invoked once from the network thread that handles the CharSocket. More...
bool	update () override
	Asynchronous update method periodically called from network threads. More...
std::shared_ptr< CharSession >	get_session ()
	@thread created by network thread and called from main thread / client-sockt-mgr for update(). More...
void	set_session (std::shared_ptr< CharSession > session)
void	update_session (uint32_t diff)
Public Member Functions inherited from Horizon::Networking::Socket< CharSocket >
	Socket (uint64_t socket_id)
	Socket (uint64_t socket_id, std::shared_ptr< tcp::socket > socket)
virtual	~Socket ()
virtual void	start ()=0
	Initial method invoked once from the network thread that handles the AuthSocket. More...
virtual bool	update ()
	Socket update loop called from its NetworkThread every n nanoseconds. More...
uint64_t	get_socket_id ()
std::string &	remote_ip_address ()
uint16_t	remote_port () const
void	async_read ()
	Asynchronous read operation @thread NetworkThread. More...
void	async_read_with_callback (ByteBuffer &buf, void(Socket< CharSocket >::*)(boost::system::error_code, std::size_t))
	Asynchronous read operation with callback handler @thread NetworkThread. More...
virtual void	queue_buffer (ByteBuffer &&buffer)
bool	is_open ()
void	close_socket ()
	Socket close operation that performs cleanups before shutting down the connection. More...
void	delayed_close_socket ()
ByteBuffer &	get_read_buffer ()

Protected Member Functions
void	read_handler () override
	Incoming buffer read handler. More...
void	on_close () override
	Socket cleanup method on connection closure. More...
void	on_error () override
Protected Member Functions inherited from Horizon::Networking::Socket< CharSocket >
virtual void	on_close ()=0
virtual void	read_handler ()=0
virtual void	on_error ()=0
bool	async_process_queue ()
	Socket write operation. More...
void	set_no_delay (bool enable)
	Disable the Nagle Algorithm on our socket. More...
std::size_t	write_buffer_and_send (ByteBuffer &to_send, boost::system::error_code &error)
	Write a message to the buffer. More...

Private Types
typedef Socket< CharSocket >	BaseSocket

Private Attributes
std::shared_ptr< CharSession >	_session

Member Typedef Documentation

BaseSocket

typedef Socket<CharSocket> Horizon::Char::CharSocket::BaseSocket

private

Constructor & Destructor Documentation

CharSocket()

CharSocket::CharSocket ( uint64_t  uid, std::shared_ptr< tcp::socket >  socket  )

explicit

: Socket(uid, socket)
{
    //
}

~CharSocket()

CharSocket::~CharSocket

(

)

{
    //
}

Member Function Documentation

get_session()

std::shared_ptr< CharSession > CharSocket::get_session

(

)

@thread created by network thread and called from main thread / client-sockt-mgr for update().

{ return std::atomic_load(&_session); }

References _session.

Referenced by read_handler(), and update_session().

Here is the caller graph for this function:

on_close()

void CharSocket::on_close ( )

overrideprotectedvirtual

Socket cleanup method on connection closure.

Implements Horizon::Networking::Socket< CharSocket >.

{
    HLog(info) << "Closed connection from " << remote_ip_address() << ".";
 
    /* Perform socket manager cleanup. */
    sClientSocketMgr->set_socket_for_removal(shared_from_this());
}

References HLog, Horizon::Networking::Socket< CharSocket >::remote_ip_address(), and sClientSocketMgr.

Here is the call graph for this function:

on_error()

void CharSocket::on_error ( )

overrideprotectedvirtual

Implements Horizon::Networking::Socket< CharSocket >.

{
 
}

read_handler()

void CharSocket::read_handler ( )

overrideprotectedvirtual

Incoming buffer read handler.

Implements Horizon::Networking::Socket< CharSocket >.

{
    while (get_read_buffer().active_length()) {
        uint16_t packet_id = 0x0;
        memcpy(&packet_id, get_read_buffer().get_read_pointer(), sizeof(uint16_t));
        
        HPacketTablePairType p = get_session()->pkt_tbl()->get_hpacket_info(packet_id);
        
        int16_t packet_length = p.first;
        
        HLog(debug) << "Received packet 0x" << packet_id << " of length " << packet_length << " from client.";
        HLog(debug) << "Data:" << get_read_buffer().to_string();
        
        if (packet_length == -1) {
            memcpy(&packet_length, get_read_buffer().get_read_pointer() + 2, sizeof(int16_t));
            if (get_read_buffer().active_length() < packet_length) {
                HLog(debug) << "Received packet 0x" << packet_id << " has expected length " << packet_length << " but buffer only supplied " << get_read_buffer().active_length() << " from client.";
                break;
            }
        } else if (packet_length == 0) {
            HLog(warning) << "Received non-existent packet id 0x" << std::hex << packet_id << ", disconnecting session..." << std::endl;
            get_read_buffer().read_completed(get_read_buffer().active_length());
            close_socket();
            break;
        }
        
        ByteBuffer b;
        b.append(get_read_buffer().get_read_pointer(), packet_length);
        get_session()->get_recv_queue().push(std::move(b));
        get_read_buffer().read_completed(packet_length);
    }
}

References ByteBuffer::active_length(), ByteBuffer::append(), Horizon::Networking::Socket< CharSocket >::close_socket(), Horizon::Networking::Socket< CharSocket >::get_read_buffer(), get_session(), HLog, ByteBuffer::read_completed(), and ByteBuffer::to_string().

Here is the call graph for this function:

set_session()

void CharSocket::set_session

(

std::shared_ptr< CharSession >

session

)

{ std::atomic_store(&_session, session); }

References _session.

Referenced by start().

Here is the caller graph for this function:

start()

void CharSocket::start ( )

overridevirtual

Initial method invoked once from the network thread that handles the CharSocket.

Implements Horizon::Networking::Socket< CharSocket >.

{
    auto session = std::make_shared<CharSession>(get_socket_id());
    session->set_socket(shared_from_this());
    set_session(session);
 
    session->initialize();
 
    HLog(info) << "Established connection from " << remote_ip_address() << ".";
 
    // Start async_read loop.
    async_read();
}

References Horizon::Networking::Socket< CharSocket >::async_read(), Horizon::Networking::Socket< CharSocket >::get_socket_id(), HLog, Horizon::Networking::Socket< CharSocket >::remote_ip_address(), and set_session().

Here is the call graph for this function:

update()

bool CharSocket::update ( )

overridevirtual

Asynchronous update method periodically called from network threads.

Returns

true on successful update, false on failure.

Reimplemented from Horizon::Networking::Socket< CharSocket >.

{
    if (get_shutdown_stage() > SHUTDOWN_NOT_STARTED)
        sClientSocketMgr->set_socket_for_removal(shared_from_this());
 
    return BaseSocket::update();
}

References get_shutdown_stage(), sClientSocketMgr, and SHUTDOWN_NOT_STARTED.

Here is the call graph for this function:

update_session()

void CharSocket::update_session

(

uint32_t

diff

)

{
    get_session()->update(diff);
}

References get_session().

Here is the call graph for this function:

Member Data Documentation

_session

std::shared_ptr<CharSession> Horizon::Char::CharSocket::_session

private

Referenced by get_session(), and set_session().

---

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

• src/Server/Char/Socket/CharSocket.hpp
• src/Server/Char/Socket/CharSocket.cpp