Class for calculation jobs to be run on link graphs. More...

#include <linkgraphjob.h>

Inheritance diagram for LinkGraphJob:

Data Structures
struct	DemandAnnotation
	Demand between two nodes. More...
struct	EdgeAnnotation
	Annotation for a link graph edge. More...
struct	NodeAnnotation
	Annotation for a link graph node. More...

Public Member Functions
	LinkGraphJob (LinkGraphJobID index)
	Bare constructor, only for save/load.
	LinkGraphJob (LinkGraphJobID index, const LinkGraph &orig)
	Create a link graph job from a link graph.
	~LinkGraphJob ()
	Join the link graph job and destroy it.
void	Init ()
	Initialize the link graph job: Resize nodes and edges and populate them.
bool	IsJobCompleted () const
	Check if job has actually finished.
bool	IsJobAborted () const
	Check if job has been aborted.
void	AbortJob ()
	Abort job.
bool	IsScheduledToBeJoined () const
	Check if job is supposed to be finished.
TimerGameEconomy::Date	JoinDate () const
	Get the date when the job should be finished.
void	ShiftJoinDate (TimerGameEconomy::Date interval)
	Change the join date on date cheating.
const LinkGraphSettings &	Settings () const
	Get the link graph settings for this component.
NodeAnnotation &	operator[] (NodeID num)
	Get a node abstraction with the specified id.
NodeID	Size () const
	Get the size of the underlying link graph.
CargoType	Cargo () const
	Get the cargo of the underlying link graph.
TimerGameEconomy::Date	LastCompression () const
	Get the date when the underlying link graph was last compressed.
LinkGraphID	LinkGraphIndex () const
	Get the ID of the underlying link graph.
const LinkGraph &	Graph () const
	Get a reference to the underlying link graph.

Protected Member Functions
void	EraseFlows (StationID from)
	Erase all flows originating at a specific station.
void	JoinThread ()
	Join the calling thread with this job's thread if threading is enabled.
void	SpawnThread ()
	Spawn a thread if possible and run the link graph job in the thread.

Protected Attributes
const LinkGraph	link_graph
	Link graph to by analyzed. Is copied when job is started and mustn't be modified later.
const LinkGraphSettings	settings
	Copy of _settings_game.linkgraph at spawn time.
std::thread	thread {}
	Thread the job is running in or a default-constructed thread if it's running in the main thread.
TimerGameEconomy::Date	join_date = EconomyTime::INVALID_DATE
	Date when the job is to be joined.
NodeAnnotationVector	nodes {}
	Extra node data necessary for link graph calculation.
std::atomic< bool >	job_completed = false
	Is the job still running. This is accessed by multiple threads and reads may be stale.
std::atomic< bool >	job_aborted = false
	Has the job been aborted. This is accessed by multiple threads and reads may be stale.

Private Types
typedef std::vector< NodeAnnotation >	NodeAnnotationVector

Friends
class	LinkGraphSchedule
SaveLoadTable	GetLinkGraphJobDesc ()
	Get a SaveLoad array for a link graph job.

Detailed Description

Class for calculation jobs to be run on link graphs.

Definition at line 29 of file linkgraphjob.h.

Member Typedef Documentation

◆ NodeAnnotationVector

typedef std::vector<NodeAnnotation> LinkGraphJob::NodeAnnotationVector

private

Definition at line 159 of file linkgraphjob.h.

Constructor & Destructor Documentation

◆ LinkGraphJob() [1/2]

LinkGraphJob::LinkGraphJob ( LinkGraphJobID index )

inline

Bare constructor, only for save/load.

link_graph, join_date and actually settings have to be brutally const-casted in order to populate them.

Definition at line 182 of file linkgraphjob.h.

References _link_graph_job_pool, _settings_game, link_graph, and settings.

◆ LinkGraphJob() [2/2]

LinkGraphJob::LinkGraphJob	(	LinkGraphJobID	index,
		const LinkGraph &	orig )

Create a link graph job from a link graph.

The link graph will be copied so that the calculations don't interfere with the normal operations on the original. The job is immediately started.

Parameters

index	Index into the LinkGraphJob pool.
orig	Original LinkGraph to be copied.

Definition at line 36 of file linkgraphjob.cpp.

References _link_graph_job_pool, _settings_game, join_date, link_graph, and settings.

◆ ~LinkGraphJob()

LinkGraphJob::~LinkGraphJob ( )

Member Function Documentation

◆ AbortJob()

void LinkGraphJob::AbortJob ( )

inline

Abort job.

The job may exit early at the next available opportunity. After this method has been called the state of the job is undefined, and the only valid operation is to join the thread and discard the job data.

Definition at line 209 of file linkgraphjob.h.

◆ Cargo()

CargoType LinkGraphJob::Cargo ( ) const

inline

Get the cargo of the underlying link graph.

Returns: Cargo.

Definition at line 252 of file linkgraphjob.h.

References LinkGraph::Cargo().

Referenced by DemandCalculator::DemandCalculator(), and ~LinkGraphJob().

◆ EraseFlows()

void LinkGraphJob::EraseFlows ( StationID from )

protected

Erase all flows originating at a specific station.

Parameters

from	StationID to erase flows for.

Definition at line 50 of file linkgraphjob.cpp.

References Size().

Referenced by ~LinkGraphJob().

◆ Graph()

const LinkGraph & LinkGraphJob::Graph ( ) const

inline

Get a reference to the underlying link graph.

Only use this for save/load.

Returns: Link graph.

Definition at line 270 of file linkgraphjob.h.

Referenced by SlLinkgraphJobProxy::Load(), and SlLinkgraphJobProxy::Save().

◆ Init()

void LinkGraphJob::Init ( )

Initialize the link graph job: Resize nodes and edges and populate them.

This is done after the constructor so that we can do it in the calculation thread without delaying the main game.

Definition at line 184 of file linkgraphjob.cpp.

References link_graph, nodes, and Size().

Referenced by InitHandler::Run().

◆ IsJobAborted()

bool LinkGraphJob::IsJobAborted ( ) const

inline

Check if job has been aborted.

This is allowed to spuriously return false incorrectly, but is not allowed to incorrectly return true.

Returns: True if job has been aborted.

Definition at line 201 of file linkgraphjob.h.

Referenced by MCF1stPass::MCF1stPass(), LinkGraphSchedule::Run(), and ~LinkGraphJob().

◆ IsJobCompleted()

bool LinkGraphJob::IsJobCompleted ( ) const

inline

Check if job has actually finished.

This is allowed to spuriously return an incorrect value.

Returns: True if job has actually finished.

Definition at line 194 of file linkgraphjob.h.

Referenced by LinkGraphSchedule::IsJoinWithUnfinishedJobDue().

◆ IsScheduledToBeJoined()

bool LinkGraphJob::IsScheduledToBeJoined ( ) const

inline

Check if job is supposed to be finished.

Returns: True if job should be finished by now, false if not.

Definition at line 215 of file linkgraphjob.h.

References TimerGameEconomy::date.

Referenced by LinkGraphSchedule::IsJoinWithUnfinishedJobDue(), and LinkGraphSchedule::JoinNext().

◆ JoinDate()

TimerGameEconomy::Date LinkGraphJob::JoinDate ( ) const

inline

Get the date when the job should be finished.

Returns: Join date.

Definition at line 221 of file linkgraphjob.h.

References join_date.

Referenced by FlowMapper::Run().

◆ JoinThread()

void LinkGraphJob::JoinThread ( )

protected

Join the calling thread with this job's thread if threading is enabled.

Definition at line 78 of file linkgraphjob.cpp.

References thread.

Referenced by ~LinkGraphJob().

◆ LastCompression()

TimerGameEconomy::Date LinkGraphJob::LastCompression ( ) const

inline

Get the date when the underlying link graph was last compressed.

Returns: Compression date.

Definition at line 258 of file linkgraphjob.h.

References LinkGraph::LastCompression().

Referenced by FlowMapper::Run().

◆ LinkGraphIndex()

LinkGraphID LinkGraphJob::LinkGraphIndex ( ) const

inline

Get the ID of the underlying link graph.

Returns: Link graph ID.

Definition at line 264 of file linkgraphjob.h.

Referenced by LinkGraphSchedule::JoinNext().

◆ operator[]()

NodeAnnotation & LinkGraphJob::operator[] ( NodeID num )

inline

Get a node abstraction with the specified id.

Parameters

num	ID of the node.

Returns: the Requested node.

Definition at line 240 of file linkgraphjob.h.

◆ Settings()

const LinkGraphSettings & LinkGraphJob::Settings ( ) const

inline

Get the link graph settings for this component.

Returns: Settings.

Definition at line 233 of file linkgraphjob.h.

Referenced by DemandCalculator::DemandCalculator(), and FlowMapper::Run().

◆ ShiftJoinDate()

void LinkGraphJob::ShiftJoinDate ( TimerGameEconomy::Date interval )

inline

Change the join date on date cheating.

Parameters

interval Number of days to add.

Definition at line 227 of file linkgraphjob.h.

◆ Size()

NodeID LinkGraphJob::Size ( ) const

inline

Get the size of the underlying link graph.

Returns: Size.

Definition at line 246 of file linkgraphjob.h.

References LinkGraph::Size().

Referenced by DemandCalculator::CalcDemand(), EraseFlows(), Init(), FlowMapper::Run(), and ~LinkGraphJob().

◆ SpawnThread()

void LinkGraphJob::SpawnThread ( )

protected

Spawn a thread if possible and run the link graph job in the thread.

If that's not possible run the job right now in the current thread.

Definition at line 61 of file linkgraphjob.cpp.

References LinkGraphSchedule::Run(), StartNewThread(), and thread.

Referenced by LinkGraphSchedule::SpawnNext().

◆ GetLinkGraphJobDesc

SaveLoadTable GetLinkGraphJobDesc ( )

friend

Get a SaveLoad array for a link graph job.

The settings struct is derived from the global settings saveload array. The exact entries are calculated when the function is called the first time. It's necessary to keep a copy of the settings for each link graph job so that you can change the settings while in-game and still not mess with current link graph runs. Of course the settings have to be saved and loaded, too, to avoid desyncs.

Returns: Array of SaveLoad structs.

Definition at line 180 of file linkgraph_sl.cpp.

◆ LinkGraphSchedule

friend class LinkGraphSchedule

friend

Definition at line 162 of file linkgraphjob.h.

Field Documentation

◆ job_aborted

std::atomic<bool> LinkGraphJob::job_aborted = false

protected

Has the job been aborted. This is accessed by multiple threads and reads may be stale.

Definition at line 171 of file linkgraphjob.h.

◆ job_completed

std::atomic<bool> LinkGraphJob::job_completed = false

protected

Is the job still running. This is accessed by multiple threads and reads may be stale.

Definition at line 170 of file linkgraphjob.h.

Referenced by LinkGraphSchedule::Run().

◆ join_date

TimerGameEconomy::Date LinkGraphJob::join_date = EconomyTime::INVALID_DATE

protected

Date when the job is to be joined.

Definition at line 168 of file linkgraphjob.h.

Referenced by JoinDate(), and LinkGraphJob().

◆ link_graph

const LinkGraph LinkGraphJob::link_graph

protected

Link graph to by analyzed. Is copied when job is started and mustn't be modified later.

Definition at line 165 of file linkgraphjob.h.

Referenced by Init(), LinkGraphJob(), LinkGraphJob(), and ~LinkGraphJob().

◆ nodes

NodeAnnotationVector LinkGraphJob::nodes {}

protected

Extra node data necessary for link graph calculation.

Definition at line 169 of file linkgraphjob.h.

Referenced by Init(), and ~LinkGraphJob().

◆ settings

const LinkGraphSettings LinkGraphJob::settings

protected

Copy of _settings_game.linkgraph at spawn time.

Definition at line 166 of file linkgraphjob.h.

Referenced by LinkGraphJob(), and LinkGraphJob().

◆ thread

std::thread LinkGraphJob::thread {}

protected

Thread the job is running in or a default-constructed thread if it's running in the main thread.

Definition at line 167 of file linkgraphjob.h.

Referenced by JoinThread(), and SpawnThread().

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

src/linkgraph/linkgraphjob.h
src/linkgraph/linkgraphjob.cpp

Data Structures

Public Member Functions

Protected Member Functions

Protected Attributes

Private Types

Friends

Detailed Description

Member Typedef Documentation

◆ NodeAnnotationVector

Constructor & Destructor Documentation

◆ LinkGraphJob() [1/2]

◆ LinkGraphJob() [2/2]

◆ ~LinkGraphJob()

Member Function Documentation

◆ AbortJob()

◆ Cargo()

◆ EraseFlows()

◆ Graph()

◆ Init()

◆ IsJobAborted()

◆ IsJobCompleted()

◆ IsScheduledToBeJoined()

◆ JoinDate()

◆ JoinThread()

◆ LastCompression()

◆ LinkGraphIndex()

◆ operator[]()

◆ Settings()

◆ ShiftJoinDate()

◆ Size()

◆ SpawnThread()

Friends And Related Symbol Documentation

◆ GetLinkGraphJobDesc

◆ LinkGraphSchedule

Field Documentation

◆ job_aborted

◆ job_completed

◆ join_date

◆ link_graph

◆ nodes

◆ settings

◆ thread