This class represents the main thread of the application, so the name is ControlThread. This is the GNSS Receiver Control Plane: it connects the flowgraph, starts running it, and while it does not stop, reads the control messages generated by the blocks, processes them, and applies the corresponding actions. More...

#include <control_thread.h>

Public Member Functions
	ControlThread ()
	Default constructor. More...

	ControlThread (std::shared_ptr< ConfigurationInterface > configuration)
	Constructor that initializes the class with parameters. More...

	~ControlThread ()
	Destructor. More...

int	run ()
	Runs the control thread. More...

void	set_control_queue (std::shared_ptr< Concurrent_Queue< pmt::pmt_t >> control_queue)
	Sets the control_queue. More...

unsigned int	processed_control_messages () const

unsigned int	applied_actions () const

std::shared_ptr< GNSSFlowgraph >	flowgraph ()
	Instantiates a flowgraph. More...

Static Public Attributes
static ControlThread *	me

Detailed Description

This class represents the main thread of the application, so the name is ControlThread. This is the GNSS Receiver Control Plane: it connects the flowgraph, starts running it, and while it does not stop, reads the control messages generated by the blocks, processes them, and applies the corresponding actions.

Definition at line 64 of file control_thread.h.

Constructor & Destructor Documentation

◆ ControlThread() [1/2]

ControlThread::ControlThread ( )

Default constructor.

◆ ControlThread() [2/2]

ControlThread::ControlThread ( std::shared_ptr< ConfigurationInterface > configuration )

explicit

Constructor that initializes the class with parameters.

Parameters

[in] configuration Pointer to a ConfigurationInterface

◆ ~ControlThread()

ControlThread::~ControlThread ( )

Destructor.

Member Function Documentation

◆ flowgraph()

std::shared_ptr<GNSSFlowgraph> ControlThread::flowgraph ( )

inline

Instantiates a flowgraph.

Returns: Returns a smart pointer to a flowgraph object

Definition at line 121 of file control_thread.h.

◆ run()

int ControlThread::run ( )

Runs the control thread.

This is the main loop that reads and process the control messages:

Connect the GNSS receiver flowgraph;
Start the GNSS receiver flowgraph;

while (flowgraph_->running() && !stop_){

Read control messages and process them; }

◆ set_control_queue()

void ControlThread::set_control_queue ( std::shared_ptr< Concurrent_Queue< pmt::pmt_t >> control_queue )

Sets the control_queue.