Horizon::Zone::ZoneKernel Class Reference

#include <Zone.hpp>

Inheritance diagram for Horizon::Zone::ZoneKernel:

Collaboration diagram for Horizon::Zone::ZoneKernel:

Public Member Functions
	ZoneKernel (s_zone_server_configuration &config)
	~ZoneKernel ()
void	initialize ()
void	finalize ()
s_zone_server_configuration &	config ()
void	set_config (s_zone_server_configuration &config)
TaskScheduler &	getScheduler ()
void	verify_connected_sessions ()
Public Member Functions inherited from Server
	Server ()
	~Server ()
void	parse_exec_args (const char *argv[], int argc)
virtual void	initialize ()
virtual void	finalize ()
virtual void	post_initialize ()
virtual void	post_finalize ()
void	print_help ()
struct general_server_configuration &	general_conf ()
bool	parse_common_configs (sol::table &cfg)
std::shared_ptr< boost::mysql::tcp_ssl_connection >	get_database_connection ()
bool	test_database_connection ()
Public Member Functions inherited from Kernel
	Kernel (general_server_configuration &config)
	~Kernel ()
virtual void	initialize ()=0
virtual void	finalize ()=0
virtual void	post_initialize ()=0
virtual void	post_finalize ()=0
struct general_server_configuration &	general_conf ()
template<typename T >
std::shared_ptr< T >	get_component (std::string uuid)
template<typename T >
std::shared_ptr< T >	get_component_of_type (Horizon::System::runtime_module_type type, int segment_number=1)
template<typename T >
void	register_component (Horizon::System::runtime_module_type type, T &&component)
template<typename T >
void	register_component (Horizon::System::runtime_module_type type, std::shared_ptr< T > component)
void	deregister_component (Horizon::System::runtime_module_type type, int segment_number=1)
int	get_registered_component_count_of_type (Horizon::System::runtime_module_type type)
template<typename ComponentType , std::size_t Priority, typename Key , typename Value >
int	get_segment_number_for_resource (Horizon::System::runtime_module_type module_t, Key resource_key, Value resource_not_found_value)
int	get_component_count ()
KernelComponents &	get_components ()
void	system_routine_queue_push (std::shared_ptr< Horizon::System::RuntimeContext > context)
void	system_routine_queue_push (std::shared_ptr< Horizon::System::RuntimeContextChain > context)
void	system_routine_process_queue ()
void	system_routine_register (Horizon::System::runtime_module_type module_t, Horizon::System::runtime_synchronization_method sync_t, std::shared_ptr< Horizon::System::RuntimeContext > context)
Horizon::System::SystemRoutineManager &	get_system_routine_manager ()
boost::asio::io_context &	get_io_context ()
void	set_signal_interrupt_command_line_loop (bool signal)
bool	get_signal_interrupt_command_line_loop ()

Protected Attributes
TaskScheduler	_task_scheduler
s_zone_server_configuration	_config
Protected Attributes inherited from Server
struct general_server_configuration	general_config
Protected Attributes inherited from Kernel
boost::asio::io_context	_io_context_global
KernelComponents	_components
general_server_configuration	_config

Constructor & Destructor Documentation

ZoneKernel()

ZoneKernel::ZoneKernel

(

s_zone_server_configuration &

config

)

: Server(), _config(config)
{
 
}

~ZoneKernel()

ZoneKernel::~ZoneKernel

(

)

{
    if (!get_io_context().stopped())
        get_io_context().stop();
}

References Kernel::get_io_context().

Here is the call graph for this function:

Member Function Documentation

config()

s_zone_server_configuration & Horizon::Zone::ZoneKernel::config ( )

inline

{ return _config; }

References _config.

Referenced by set_config(), and verify_connected_sessions().

Here is the caller graph for this function:

finalize()

void ZoneKernel::finalize ( )

virtual

Reimplemented from Server.

Reimplemented in Horizon::Zone::ZoneServer.

{
    _task_scheduler.CancelAll();
    
    Server::finalize();
}

References _task_scheduler, TaskScheduler::CancelAll(), and Server::finalize().

Referenced by Horizon::Zone::ZoneServer::finalize().

Here is the call graph for this function:

Here is the caller graph for this function:

getScheduler()

TaskScheduler & Horizon::Zone::ZoneKernel::getScheduler ( )

inline

{ return _task_scheduler; }

References _task_scheduler.

initialize()

void ZoneKernel::initialize ( )

virtual

Reimplemented from Server.

Reimplemented in Horizon::Zone::ZoneServer.

{
    _task_scheduler.Schedule(Seconds(0), [this] (TaskContext context) {
        verify_connected_sessions();
        context.Repeat(Seconds(60));
    });
 
    Server::initialize();
}

References _task_scheduler, Server::initialize(), TaskContext::Repeat(), TaskScheduler::Schedule(), and verify_connected_sessions().

Referenced by Horizon::Zone::ZoneServer::initialize().

Here is the call graph for this function:

Here is the caller graph for this function:

set_config()

void Horizon::Zone::ZoneKernel::set_config ( s_zone_server_configuration &  config )

inline

{ _config = config; }

References _config, and config().

Here is the call graph for this function:

verify_connected_sessions()

void ZoneKernel::verify_connected_sessions

(

)

{   
    std::shared_ptr<boost::mysql::tcp_ssl_connection> conn = sZone->get_database_connection();
    
    try {
        int64_t time = std::time(nullptr) - config().session_max_timeout();
        boost::mysql::statement stmt = conn->prepare_statement("DELETE FROM `session_data` WHERE `current_server` = ? AND `last_update` < ?");
        auto b1 = stmt.bind("Z", time);
        boost::mysql::results results;
        conn->execute(b1, results);
 
        stmt = conn->prepare_statement("SELECT COUNT(`game_account_id`) FROM `session_data` WHERE `current_server` = ?");
        auto b2 = stmt.bind("Z");
        conn->execute(b2, results);
 
        if (results.rows().empty()) {
            HLog(info) << "There are no connected session(s).";
            return;
        }
        
        int32_t count = results.rows()[0][0].as_int64();
 
        HLog(info) << count << " connected session(s).";
    } catch (boost::mysql::error_with_diagnostics &err) {
        HLog(error) << "Error while verifying connected sessions: " << err.what();
        return;
    }
}

References config(), GridTypeListIterator::count(), HLog, Horizon::Zone::s_zone_server_configuration::session_max_timeout(), and sZone.

Referenced by initialize().

Here is the call graph for this function:

Here is the caller graph for this function:

Member Data Documentation

_config

s_zone_server_configuration Horizon::Zone::ZoneKernel::_config

protected

Referenced by config(), and set_config().

_task_scheduler

TaskScheduler Horizon::Zone::ZoneKernel::_task_scheduler

protected

Referenced by finalize(), getScheduler(), initialize(), and Horizon::Zone::ZoneServer::update().

---

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

• src/Server/Zone/Zone.hpp
• src/Server/Zone/Zone.cpp