Horizon::Char::CharNetworkThread Class Reference

#include <ClientSocketMgr.hpp>

Inheritance diagram for Horizon::Char::CharNetworkThread:

Collaboration diagram for Horizon::Char::CharNetworkThread:

Public Member Functions
	CharNetworkThread ()
bool	start (int segment_number=1)
	Initializes the network thread and runs. More...
void	run () override
	Run the I/O Service loop within this network thread. More...
void	update () override
	Updates the network thread and schedules a recursive call to itself. More...
virtual void	initialize (int segment_number=1) override
virtual void	finalize () override
virtual bool	is_initialized () override
virtual 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 ()
Public Member Functions inherited from Horizon::Networking::NetworkThread< CharSocket >
	NetworkThread ()
virtual	~NetworkThread ()
	Destructor of the network thread, performs a clean network finalisation routine before deleting. More...
virtual void	finalize ()
	Halts the IO Service and marks the network thread as stopped. More...
void	join ()
virtual bool	start (int segment_number=1)
	Initializes the network thread and runs. More...
virtual void	add_socket (std::shared_ptr< CharSocket > sock)
	Adds a new socket to a queue that is processed frequently within this network thread. More...
std::shared_ptr< tcp::socket >	get_new_socket ()
	Gets a socket for a new connection. More...
int32_t	connection_count () const
	Gets the total number of network connections or sockets handled by this network thread. More...
bool	is_finalizing ()
	Issues the status of network thread whether it is finalizing or not. More...

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

Protected Member Functions
void	on_socket_removed (std::shared_ptr< CharSocket > socket) override
void	on_socket_added (std::shared_ptr< CharSocket > socket) override
Protected Member Functions inherited from Horizon::Networking::NetworkThread< CharSocket >
virtual void	run ()
	Run the I/O Service loop within this network thread. More...
virtual void	on_socket_removed (std::shared_ptr< CharSocket > sock)=0
virtual void	on_socket_added (std::shared_ptr< CharSocket > sock)=0
virtual void	update ()
	Updates the network thread and schedules a recursive call to itself. More...
virtual void	add_new_sockets ()
	Processess the new socket queue. More...

Protected Attributes
std::atomic< bool >	_is_initialized {false}
std::atomic< bool >	_is_finalized {false}
ResourceManager	_resource_manager
Protected Attributes inherited from Horizon::Networking::NetworkThread< CharSocket >
SocketContainer	_active_sockets

Member Typedef Documentation

PrimaryResource

using Horizon::Char::CharNetworkThread::PrimaryResource = SharedPriorityResourceMedium<s_segment_storage<uint64_t, std::shared_ptr<CharSocket> >>

protected

ResourceManager

using Horizon::Char::CharNetworkThread::ResourceManager = SharedPriorityResourceManager<PrimaryResource>

protected

Constructor & Destructor Documentation

CharNetworkThread()

Horizon::Char::CharNetworkThread::CharNetworkThread ( )

inline

    : KernelComponent(sChar, Horizon::System::RUNTIME_NETWORKING),
    _resource_manager(PrimaryResource(RESOURCE_PRIORITY_PRIMARY, std::make_shared<s_segment_storage<uint64_t, std::shared_ptr<CharSocket>>>())) 
    {
    }

Member Function Documentation

finalize()

virtual void Horizon::Char::CharNetworkThread::finalize ( )

inlineoverridevirtual

Reimplemented from KernelComponent.

    {
        Networking::NetworkThread<CharSocket>::finalize();
        _is_finalized.exchange(true);
    }

References _is_finalized, and Horizon::Networking::NetworkThread< SocketType >::finalize().

Here is the call graph for this function:

get_resource_manager()

ResourceManager & Horizon::Char::CharNetworkThread::get_resource_manager ( )

inline

{ return _resource_manager; }

References _resource_manager.

Referenced by on_socket_added(), and on_socket_removed().

Here is the caller graph for this function:

initialize()

virtual void Horizon::Char::CharNetworkThread::initialize ( int  segment_number = 1 )

inlineoverridevirtual

Reimplemented from KernelComponent.

    {
        _is_initialized.exchange(true);
        set_segment_number(segment_number);
    }

References _is_initialized, and KernelComponent::set_segment_number().

Referenced by start().

Here is the call graph for this function:

Here is the caller graph for this function:

is_finalized()

virtual bool Horizon::Char::CharNetworkThread::is_finalized ( )

inlineoverridevirtual

Reimplemented from KernelComponent.

{ return _is_finalized.load(); }

References _is_finalized.

is_initialized()

virtual bool Horizon::Char::CharNetworkThread::is_initialized ( )

inlineoverridevirtual

Reimplemented from KernelComponent.

{ return _is_initialized.load(); }

References _is_initialized.

on_socket_added()

void Horizon::Char::CharNetworkThread::on_socket_added ( std::shared_ptr< CharSocket >  socket )

inlineoverrideprotected

    {
        get_resource_manager().add<RESOURCE_PRIORITY_PRIMARY>(socket->get_socket_id(), socket);
    }

References SharedPriorityResourceManager< SharedPriorityResourceMediums >::add(), get_resource_manager(), and RESOURCE_PRIORITY_PRIMARY.

Here is the call graph for this function:

on_socket_removed()

void Horizon::Char::CharNetworkThread::on_socket_removed ( std::shared_ptr< CharSocket >  socket )

inlineoverrideprotected

    {
        get_resource_manager().remove<RESOURCE_PRIORITY_PRIMARY>(socket->get_socket_id());
    }

References get_resource_manager(), SharedPriorityResourceManager< SharedPriorityResourceMediums >::remove(), and RESOURCE_PRIORITY_PRIMARY.

Here is the call graph for this function:

run()

void Horizon::Char::CharNetworkThread::run ( )

inlineoverridevirtual

Run the I/O Service loop within this network thread.

Before running, this method gives the I/O service some work by asynchronously running a deadline timer on

See also

update()

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

    {
        Networking::NetworkThread<CharSocket>::run();
    }

References Horizon::Networking::NetworkThread< SocketType >::run().

Here is the call graph for this function:

start()

bool Horizon::Char::CharNetworkThread::start ( int  segment_number = 1 )

inlinevirtual

Initializes the network thread and runs.

Returns

true on success, false if thread is a nullptr.

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

    {
        if (!Networking::NetworkThread<CharSocket>::start(segment_number))
            return false;
 
        initialize(segment_number);
        return true;
    }

References initialize().

Referenced by update().

Here is the call graph for this function:

Here is the caller graph for this function:

update()

void Horizon::Char::CharNetworkThread::update ( )

inlineoverridevirtual

Updates the network thread and schedules a recursive call to itself.

This method is responsible for the following tasks - 1) Issuing a routine to process the new sockets queue. 2) Closes sockets that cannot be updated.

See also

Socket<SocketType>::update()

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

    {
        std::chrono::high_resolution_clock::time_point start = std::chrono::high_resolution_clock::now();
        Networking::NetworkThread<CharSocket>::update();
 
        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(), start(), and Horizon::Networking::NetworkThread< SocketType >::update().

Here is the call graph for this function:

Member Data Documentation

_is_finalized

std::atomic<bool> Horizon::Char::CharNetworkThread::_is_finalized {false}

protected

Referenced by finalize(), and is_finalized().

_is_initialized

std::atomic<bool> Horizon::Char::CharNetworkThread::_is_initialized {false}

protected

Referenced by initialize(), and is_initialized().

_resource_manager

ResourceManager Horizon::Char::CharNetworkThread::_resource_manager

protected

Referenced by get_resource_manager().

---

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

• src/Server/Char/SocketMgr/ClientSocketMgr.hpp