Horizon::Zone::PersistenceManager Class Reference

#include <PersistenceManager.hpp>

Inheritance diagram for Horizon::Zone::PersistenceManager:

Collaboration diagram for Horizon::Zone::PersistenceManager:

Public Member Functions
	PersistenceManager ()
void	initialize (int segment_number=1) override
void	finalize () override
void	start ()
void	update (uint64_t diff)
bool	is_initialized () override
bool	is_finalized () override
ResourceManager &	get_resource_manager ()
Public Member Functions inherited from KernelComponent
	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 ()

Protected Types
using	PrimaryResource = SharedPriorityResourceMedium< s_segment_storage< uint64_t, std::shared_ptr< Units::Player > > >
using	ResourceManager = SharedPriorityResourceManager< PrimaryResource >

Protected Attributes
ResourceManager	_resource_manager

Private Attributes
std::thread	_thread
std::atomic< bool >	_is_initialized {false}
std::atomic< bool >	_is_finalized {false}

Member Typedef Documentation

PrimaryResource

using Horizon::Zone::PersistenceManager::PrimaryResource = SharedPriorityResourceMedium<s_segment_storage<uint64_t, std::shared_ptr<Units::Player> >>

protected

ResourceManager

using Horizon::Zone::PersistenceManager::ResourceManager = SharedPriorityResourceManager<PrimaryResource>

protected

Constructor & Destructor Documentation

PersistenceManager()

PersistenceManager::PersistenceManager

(

)

: KernelComponent(sZone, Horizon::System::RUNTIME_PERSISTENCE),
_resource_manager(PrimaryResource(RESOURCE_PRIORITY_PRIMARY, std::make_shared<s_segment_storage<uint64_t, std::shared_ptr<Units::Player>>>()))
{
}

Member Function Documentation

finalize()

void PersistenceManager::finalize ( )

overridevirtual

Reimplemented from KernelComponent.

{
    if (_thread.joinable())
        _thread.join();
    
    _is_finalized.exchange(true);
}

References _is_finalized, and _thread.

get_resource_manager()

ResourceManager & Horizon::Zone::PersistenceManager::get_resource_manager ( )

inline

{ return _resource_manager; }

References _resource_manager.

initialize()

void PersistenceManager::initialize ( int  segment_number = 1 )

overridevirtual

Reimplemented from KernelComponent.

{
    set_segment_number(segment_number);
    _thread = std::thread(&PersistenceManager::start, this);
 
    _is_initialized.exchange(true);
}

References _is_initialized, _thread, KernelComponent::set_segment_number(), and start().

Here is the call graph for this function:

is_finalized()

bool Horizon::Zone::PersistenceManager::is_finalized ( )

inlineoverridevirtual

Reimplemented from KernelComponent.

{ return _is_finalized.load(); }

References _is_finalized.

is_initialized()

bool Horizon::Zone::PersistenceManager::is_initialized ( )

inlineoverridevirtual

Reimplemented from KernelComponent.

{ return _is_initialized.load(); }

References _is_initialized.

start()

void PersistenceManager::start

(

)

{
    while (!sZone->general_conf().is_test_run_minimal() && get_shutdown_stage() == SHUTDOWN_NOT_STARTED) {
        update(std::time(nullptr));
        std::this_thread::sleep_for(std::chrono::microseconds(MAX_CORE_UPDATE_INTERVAL));
    }
}

References get_shutdown_stage(), MAX_CORE_UPDATE_INTERVAL, SHUTDOWN_NOT_STARTED, sZone, and update().

Referenced by initialize(), and update().

Here is the call graph for this function:

Here is the caller graph for this function:

update()

void PersistenceManager::update

(

uint64_t

diff

)

{
    std::chrono::high_resolution_clock::time_point start = std::chrono::high_resolution_clock::now();
    get_system_routine_manager().process_queue();
#if WIN32
    DWORD cpu = GetCurrentProcessorNumber();
    if (get_thread_cpu_id() != (int) cpu) 
        set_thread_cpu_id(cpu);
#elif __linux__
    int cpu = sched_getcpu();
    if (get_thread_cpu_id() != cpu)
        set_thread_cpu_id(cpu);
#endif
    calculate_and_set_cpu_load();
    std::chrono::high_resolution_clock::time_point end = std::chrono::high_resolution_clock::now();
    std::chrono::nanoseconds time_span = std::chrono::duration_cast<std::chrono::nanoseconds>(end - start);
    set_total_execution_time(time_span.count());
}

References KernelComponent::calculate_and_set_cpu_load(), KernelComponent::get_system_routine_manager(), KernelComponent::get_thread_cpu_id(), Horizon::System::SystemRoutineManager::process_queue(), KernelComponent::set_thread_cpu_id(), KernelComponent::set_total_execution_time(), and start().

Referenced by start().

Here is the call graph for this function:

Here is the caller graph for this function:

Member Data Documentation

_is_finalized

std::atomic<bool> Horizon::Zone::PersistenceManager::_is_finalized {false}

private

Referenced by finalize(), and is_finalized().

_is_initialized

std::atomic<bool> Horizon::Zone::PersistenceManager::_is_initialized {false}

private

Referenced by initialize(), and is_initialized().

_resource_manager

ResourceManager Horizon::Zone::PersistenceManager::_resource_manager

protected

Referenced by get_resource_manager().

_thread

std::thread Horizon::Zone::PersistenceManager::_thread

private

Referenced by finalize(), and initialize().

---

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

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