KernelComponent Class Reference

#include <Server.hpp>

Inheritance diagram for KernelComponent:

Collaboration diagram for KernelComponent:

Public Member Functions
	KernelComponent (Kernel *kernel, Horizon::System::runtime_module_type module_type)
virtual void	initialize (int segment_number=1)
virtual void	finalize ()
virtual bool	is_initialized ()
virtual bool	is_finalized ()
void	set_segment_number (int64_t segment_number)
int64_t	get_segment_number ()
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)
const std::string	get_uuid_string ()
const std::string	get_type_string ()
Horizon::System::SystemRoutineManager &	get_system_routine_manager ()
Kernel *	get_kernel ()
void	set_thread_cpu_id (int cpu_id)
int	get_thread_cpu_id ()
void	set_thread_update_rate (double rate)
double	get_thread_update_rate ()
void	set_total_execution_time (int time)
int	get_total_execution_time ()
void	calculate_and_set_cpu_load ()

Private Attributes
std::atomic< int64_t >	_segment_number {0}
Horizon::System::runtime_module_type	_module_type {Horizon::System::RUNTIME_MAIN}
Horizon::System::SystemRoutineManager	_hsr_manager
boost::uuids::uuid	_uuid
std::atomic< int >	_thread_cpu_id {0}
Kernel *	_kernel {nullptr}
int	_update_count {0}
std::chrono::steady_clock::time_point	_last_thread_update_rate_time
std::chrono::steady_clock::time_point	_last_total_execution_time_update
std::atomic< double >	_thread_update_rate {0.0}
int	_total_execution_time_aggregate {0}
std::atomic< int >	_total_execution_time_average {0}

Constructor & Destructor Documentation

KernelComponent()

KernelComponent::KernelComponent ( Kernel *  kernel, Horizon::System::runtime_module_type  module_type  )

inline

    : _kernel(kernel), _module_type(module_type), _hsr_manager(module_type), _uuid(boost::uuids::random_generator()()) 
    { }

Member Function Documentation

calculate_and_set_cpu_load()

void KernelComponent::calculate_and_set_cpu_load ( )

inline

    {
        _update_count++;
 
        // Update thread update rate every second to determine the number of updates per second
        auto current_time = std::chrono::steady_clock::now();
        auto diff_time = std::chrono::duration_cast<std::chrono::nanoseconds>(current_time - _last_thread_update_rate_time).count();
        if (diff_time >= 1e9) {
            double update_rate = _update_count / (diff_time / 1e9);
            set_thread_update_rate(update_rate);
            _update_count = 0;
            _last_thread_update_rate_time = current_time;
        }
    }

References _last_thread_update_rate_time, _update_count, and set_thread_update_rate().

Referenced by CommandLineProcess::cli_thread_start(), DatabaseProcess::initialize(), Horizon::Auth::AuthNetworkThread::update(), Horizon::Char::CharNetworkThread::update(), Horizon::Zone::ZoneNetworkThread::update(), Horizon::Zone::ZoneRuntime::update(), Horizon::Zone::GameLogicProcess::update(), Horizon::Zone::PersistenceManager::update(), and Horizon::Zone::ScriptManager::update().

Here is the call graph for this function:

Here is the caller graph for this function:

finalize()

virtual void KernelComponent::finalize ( )

inlinevirtual

Reimplemented in Horizon::Auth::AuthNetworkThread, Horizon::Char::CharNetworkThread, CommandLineProcess, DatabaseProcess, Horizon::Zone::GameLogicProcess, Horizon::Zone::PersistenceManager, Horizon::Zone::ScriptManager, Horizon::Zone::ZoneNetworkThread, and Horizon::Zone::ZoneRuntime.

{ }

get_kernel()

Kernel * KernelComponent::get_kernel ( )

inline

{ return _kernel; }

References _kernel.

Referenced by CommandLineProcess::clicmd_kernel_info().

Here is the caller graph for this function:

get_segment_number()

int64_t KernelComponent::get_segment_number ( )

inline

{ return _segment_number.load(); }

References _segment_number.

Referenced by DatabaseProcess::reinitialize(), and Horizon::Zone::GameLogicProcess::start_internal().

Here is the caller graph for this function:

get_system_routine_manager()

Horizon::System::SystemRoutineManager & KernelComponent::get_system_routine_manager ( )

inline

{ return _hsr_manager; }

References _hsr_manager.

Referenced by Horizon::Zone::ZoneClientInterface::disconnect(), Horizon::Zone::ZoneClientInterface::login(), Horizon::Zone::ZoneClientInterface::restart(), Horizon::Auth::AuthNetworkThread::update(), Horizon::Char::CharNetworkThread::update(), Horizon::Zone::ZoneNetworkThread::update(), Horizon::Zone::ZoneRuntime::update(), Horizon::Zone::GameLogicProcess::update(), Horizon::Zone::PersistenceManager::update(), Horizon::Zone::ScriptManager::update(), and Horizon::Zone::ZoneClientInterface::walk_to_coordinates().

Here is the caller graph for this function:

get_thread_cpu_id()

int KernelComponent::get_thread_cpu_id ( )

inline

{ return _thread_cpu_id.load(); }

References _thread_cpu_id.

Referenced by CommandLineProcess::cli_thread_start(), DatabaseProcess::initialize(), Horizon::Auth::AuthNetworkThread::update(), Horizon::Char::CharNetworkThread::update(), Horizon::Zone::ZoneNetworkThread::update(), Horizon::Zone::GameLogicProcess::update(), Horizon::Zone::PersistenceManager::update(), and Horizon::Zone::ScriptManager::update().

Here is the caller graph for this function:

get_thread_update_rate()

double KernelComponent::get_thread_update_rate ( )

inline

{ return _thread_update_rate.load(); }

References _thread_update_rate.

Referenced by set_total_execution_time().

Here is the caller graph for this function:

get_total_execution_time()

int KernelComponent::get_total_execution_time ( )

inline

{ return _total_execution_time_average.load(); }

References _total_execution_time_average.

get_type_string()

const std::string KernelComponent::get_type_string ( )

inline

    { 
        switch (_module_type)
        {
            case Horizon::System::RUNTIME_MAIN: return "Main";
            case Horizon::System::RUNTIME_GAMELOGIC: return "Game-logic";
            case Horizon::System::RUNTIME_PERSISTENCE: return "Persistence";
            case Horizon::System::RUNTIME_DATABASE: return "Database";
            case Horizon::System::RUNTIME_COMMANDLINE: return "Command-Line";
            case Horizon::System::RUNTIME_SCRIPTVM: return "Script-VM";
            case Horizon::System::RUNTIME_NETWORKING: return "Networking";
            case Horizon::System::RUNTIME_RUNTIME: return "Runtime";
            case Horizon::System::RUNTIME_CLIENT_NETWORKING: return "Client-Networking"; 
            case Horizon::System::RUNTIME_HTTP_SERVICE: return "Http Service";
            case Horizon::System::RUNTIME_WEB_SOCKET: return "Web Socket Service";
            default: return "Unknown";
        }
    }

References _module_type, Horizon::System::RUNTIME_CLIENT_NETWORKING, Horizon::System::RUNTIME_COMMANDLINE, Horizon::System::RUNTIME_DATABASE, Horizon::System::RUNTIME_GAMELOGIC, Horizon::System::RUNTIME_HTTP_SERVICE, Horizon::System::RUNTIME_MAIN, Horizon::System::RUNTIME_NETWORKING, Horizon::System::RUNTIME_PERSISTENCE, Horizon::System::RUNTIME_RUNTIME, Horizon::System::RUNTIME_SCRIPTVM, and Horizon::System::RUNTIME_WEB_SOCKET.

get_uuid_string()

const std::string KernelComponent::get_uuid_string ( )

inline

{ return boost::uuids::to_string(_uuid); }

References _uuid.

initialize()

virtual void KernelComponent::initialize ( int  segment_number = 1 )

inlinevirtual

Reimplemented in Horizon::Auth::AuthNetworkThread, Horizon::Char::CharNetworkThread, CommandLineProcess, DatabaseProcess, Horizon::Zone::GameLogicProcess, Horizon::Zone::PersistenceManager, Horizon::Zone::ScriptManager, Horizon::Zone::ZoneNetworkThread, and Horizon::Zone::ZoneRuntime.

    {
        set_segment_number(segment_number);
    }

References set_segment_number().

Here is the call graph for this function:

is_finalized()

virtual bool KernelComponent::is_finalized ( )

inlinevirtual

Reimplemented in Horizon::Auth::AuthNetworkThread, Horizon::Char::CharNetworkThread, CommandLineProcess, DatabaseProcess, Horizon::Zone::GameLogicProcess, Horizon::Zone::PersistenceManager, Horizon::Zone::ScriptManager, Horizon::Zone::ZoneNetworkThread, and Horizon::Zone::ZoneRuntime.

{ return false; }

is_initialized()

virtual bool KernelComponent::is_initialized ( )

inlinevirtual

Reimplemented in Horizon::Auth::AuthNetworkThread, Horizon::Char::CharNetworkThread, CommandLineProcess, DatabaseProcess, Horizon::Zone::GameLogicProcess, Horizon::Zone::PersistenceManager, Horizon::Zone::ScriptManager, Horizon::Zone::ZoneNetworkThread, and Horizon::Zone::ZoneRuntime.

{ return false; }

set_segment_number()

void KernelComponent::set_segment_number ( int64_t  segment_number )

inline

{ _segment_number = segment_number; }

References _segment_number.

Referenced by DatabaseProcess::initialize(), initialize(), Horizon::Auth::AuthNetworkThread::initialize(), Horizon::Char::CharNetworkThread::initialize(), CommandLineProcess::initialize(), Horizon::Zone::GameLogicProcess::initialize(), Horizon::Zone::PersistenceManager::initialize(), Horizon::Zone::ScriptManager::initialize(), Horizon::Zone::ZoneNetworkThread::initialize(), and Horizon::Zone::ZoneRuntime::initialize().

Here is the caller graph for this function:

set_thread_cpu_id()

void KernelComponent::set_thread_cpu_id ( int  cpu_id )

inline

{ _thread_cpu_id.exchange(cpu_id); }

References _thread_cpu_id.

Referenced by CommandLineProcess::cli_thread_start(), DatabaseProcess::initialize(), Horizon::Auth::AuthNetworkThread::update(), Horizon::Char::CharNetworkThread::update(), Horizon::Zone::ZoneNetworkThread::update(), Horizon::Zone::GameLogicProcess::update(), Horizon::Zone::PersistenceManager::update(), and Horizon::Zone::ScriptManager::update().

Here is the caller graph for this function:

set_thread_update_rate()

void KernelComponent::set_thread_update_rate ( double  rate )

inline

{ _thread_update_rate.exchange(rate); }

References _thread_update_rate.

Referenced by calculate_and_set_cpu_load().

Here is the caller graph for this function:

set_total_execution_time()

void KernelComponent::set_total_execution_time ( int  time )

inline

    {
        _total_execution_time_aggregate += time;
 
        if (std::chrono::duration_cast<std::chrono::seconds>(std::chrono::steady_clock::now() - _last_total_execution_time_update).count() >= 1) {
            _last_total_execution_time_update = std::chrono::steady_clock::now();
            _total_execution_time_average.exchange(_total_execution_time_aggregate / get_thread_update_rate());
            _total_execution_time_aggregate = 0;
        }
    }

References _last_total_execution_time_update, _total_execution_time_aggregate, _total_execution_time_average, GridTypeListIterator::count(), and get_thread_update_rate().

Referenced by Horizon::Auth::AuthNetworkThread::update(), Horizon::Char::CharNetworkThread::update(), Horizon::Zone::ZoneNetworkThread::update(), Horizon::Zone::ZoneRuntime::update(), Horizon::Zone::GameLogicProcess::update(), Horizon::Zone::PersistenceManager::update(), and Horizon::Zone::ScriptManager::update().

Here is the call graph for this function:

Here is the caller graph for this function:

system_routine_process_queue()

void KernelComponent::system_routine_process_queue

(

)

{ _hsr_manager.process_queue(); }

References _hsr_manager, and Horizon::System::SystemRoutineManager::process_queue().

Here is the call graph for this function:

system_routine_queue_push() [1/2]

void KernelComponent::system_routine_queue_push

(

std::shared_ptr< Horizon::System::RuntimeContext >

context

)

{ _hsr_manager.push(context); }

References _hsr_manager, and Horizon::System::SystemRoutineManager::push().

Here is the call graph for this function:

system_routine_queue_push() [2/2]

void KernelComponent::system_routine_queue_push

(

std::shared_ptr< Horizon::System::RuntimeContextChain >

context

)

{ _hsr_manager.push(context); }

References _hsr_manager, and Horizon::System::SystemRoutineManager::push().

Here is the call graph for this function:

system_routine_register()

void KernelComponent::system_routine_register	(	Horizon::System::runtime_module_type	module_t,
		Horizon::System::runtime_synchronization_method	sync_t,
		std::shared_ptr< Horizon::System::RuntimeContext >	context
	)

{
    _hsr_manager.register_(module_t, sync_t, context);
}

References _hsr_manager, and Horizon::System::SystemRoutineManager::register_().

Here is the call graph for this function:

Member Data Documentation

_hsr_manager

Horizon::System::SystemRoutineManager KernelComponent::_hsr_manager

private

Referenced by get_system_routine_manager(), system_routine_process_queue(), system_routine_queue_push(), and system_routine_register().

_kernel

Kernel* KernelComponent::_kernel {nullptr}

private

Referenced by get_kernel().

_last_thread_update_rate_time

std::chrono::steady_clock::time_point KernelComponent::_last_thread_update_rate_time

private

Referenced by calculate_and_set_cpu_load().

_last_total_execution_time_update

std::chrono::steady_clock::time_point KernelComponent::_last_total_execution_time_update

private

Referenced by set_total_execution_time().

_module_type

Horizon::System::runtime_module_type KernelComponent::_module_type {Horizon::System::RUNTIME_MAIN}

private

Referenced by get_type_string().

_segment_number

std::atomic<int64_t> KernelComponent::_segment_number {0}

private

Referenced by get_segment_number(), and set_segment_number().

_thread_cpu_id

std::atomic<int> KernelComponent::_thread_cpu_id {0}

private

Referenced by get_thread_cpu_id(), and set_thread_cpu_id().

_thread_update_rate

std::atomic<double> KernelComponent::_thread_update_rate {0.0}

private

Referenced by get_thread_update_rate(), and set_thread_update_rate().

_total_execution_time_aggregate

int KernelComponent::_total_execution_time_aggregate {0}

private

Referenced by set_total_execution_time().

_total_execution_time_average

std::atomic<int> KernelComponent::_total_execution_time_average {0}

private

Referenced by get_total_execution_time(), and set_total_execution_time().

_update_count

int KernelComponent::_update_count {0}

private

Referenced by calculate_and_set_cpu_load().

_uuid

boost::uuids::uuid KernelComponent::_uuid

private

Referenced by get_uuid_string().

---

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

• src/Server/Common/Server.hpp
• src/Server/Common/Server.cpp