Use with RealTime to receive messages from python ServerPortfolio. More...

#include <TCPServer.h>

Collaboration diagram for TCPServer:

Public Member Functions
Constructors and destructor
	TCPServer (StockManager *sm, unsigned int iport)
	Constructor, io_service is a private data member (my_io_service). More...

	TCPServer (StockManager *sm, unsigned int iport, boost::asio::io_service &io_service)
	Constructor, io_service created in the calling function. More...

virtual	~TCPServer ()
	Destructor. More...

Functions for running / stopping the server
void	StartServer ()
	Start the server. More...

void	StopServer ()
	Stop the server. More...

bool	IsRunning ()
	Return the status of the server. More...

Private Member Functions
void	start_accept ()
	create a new tcp_connection to receive message More...

void	handle_accept (tcp_connection::pointer new_connection, const boost::system::error_code &error)
	handle the received message: parse and send string data to StockManager. More...

void	LoopThread ()
	Function run by the internal thread. More...

Private Attributes
StockManager *	f_sm
	Pointer to the StockManager singleton, will receive and treat the messages. More...

unsigned int	port
	Port where the server listens. More...

boost::asio::io_service	my_io_service
	io_service needed for asimc. More...

tcp::acceptor	acceptor_
	... More...

std::thread	t_
	Internal thread. More...

Status of the server
bool	is_running
	Indicate if the server is running. More...

bool	want_exit
	Indicate the thread must exit, set in destructor only. More...

Locks for threads communication
std::mutex	loop_mutex

std::condition_variable	loop_cv

Detailed Description

Use with RealTime to receive messages from python ServerPortfolio.

Alternative to re-reading INST files every time.
It can only receive messages, does not reply.

The server run in an independent thread, created in constructor.
It sends the data to StockManager (associated by aggregation)
Only one tcp_connection exists at a time, the thread will update StockManager.
Maybe need to extend if many messages.

Use boost::asio approach

Definition at line 122 of file TCPServer.h.

Constructor & Destructor Documentation

TCPServer::TCPServer	(	StockManager *	sm,
		unsigned int	iport
	)

Constructor, io_service is a private data member (my_io_service).

Creates a thread and a first tcp_connection, but the server is waiting after the constructor.
It seems supported to have it as data member. Not sure about the limitation.
Certainly fine if io_service is used only for one class. Would need a global instance if more objects use it ??

It is the version used now

Parameters

sm	pointer to the StockManager singleton
iport	port number where the server listens

Definition at line 75 of file TCPServer.cpp.

References f_sm, is_running, port, and want_exit.

TCPServer::TCPServer	(	StockManager *	sm,
		unsigned int	iport,
		boost::asio::io_service &	io_service
	)

Constructor, io_service created in the calling function.

Passing an instance of io_service seems to be in all examples
If it is used only for the server, we can use the other constructor which uses a data member

Parameters

sm	pointer to the StockManager singleton
iport	port number where the server listens
io_service	instance of boost::asio::io_service created in the main function (in most of the examples)