Class Server

• Defined in File thermal_server.h

Class Documentation

class Server

creates a TCP/IP server for the thermal daemon

Public Functions

inline Server()

class constructor

inline ~Server()

class deconstructor cleans up on exit

long telemetry(std::string args, std::string &retstring)

utility to stop/start/check status of telemetry

void exit_cleanly(void)

exit

long configure_thermald()

read and apply daemon config from configuration file

long configure_devices()

read and apply device config from configuration file

long configure_telemetry()

read and apply telemetry config from configuration file

long parse_lks_unit(std::string &input, int &lksnum, std::string &name, std::string &host, int &port)

long parse_lks_chan(std::string &input, int &lksnum, std::string &chan, bool &heater, std::string &label)

long parse_camp_chan(std::string &input)

void doit(Network::TcpSocket &sock)

the workhorse of each thread connetion

Public Members

int nbport

non-blocking port

int blkport

blocking port

int asyncport

asynchronous message port

std::string asyncgroup

asynchronous multicast group

int nonblocking_socket

int blocking_socket

std::atomic<int> cmd_num

Config config

Interface interface

the Interface class connects to the hardware

int telem_period

InterruptableSleepTimer telem_sleeptimer

allows interrupting telemetry

std::vector<std::string> db_info

info for constructing telemetry Database object

std::atomic<bool> telem_running

is the main telemetry thread running?

unsigned int telem_backoff_sec = 1

reconnect backoff (s); doubles to a cap on telemetry DB failure, reset on success

std::mutex conn_mutex

mutex to protect against simultaneous access to Accept()

Public Static Functions

static void new_log_day(std::string logpath)

creates a new logbook each day

static void block_main(Thermal::Server &tcs, Network::TcpSocket sock)

main function for blocking connection thread

static void thread_main(Thermal::Server &tcs, Network::TcpSocket sock)

main function for all non-blocked threads

static void async_main(Thermal::Server &tcs, Network::UdpSocket sock)

asynchronous message sending thread

static void telemetry_watchdog(Thermal::Server &server)

keeps the main telemetry thread running

static void dothread_telemetry(Thermal::Server &server)

main telemetry thread