Class Server

Class Documentation

class Server

creates a TCP/IP server for the flexure daemon

Public Functions

inline Server()

class constructor

inline ~Server()

class deconstructor cleans up on exit

inline void remove_socket(int id)
void exit_cleanly(void)

exit

long configure_flexured()

read and apply the configuration file

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
std::atomic<int> threads_active

number of blocking threads that exist

Common::CorrIdCache corr_cache

dedup cache for tagged inter-daemon commands

NumberPool id_pool

creates a number pool used for socket ids

Config config
Interface interface

the Interface class connects to the hardware

std::mutex conn_mutex

mutex to protect against simultaneous access to Accept()

std::mutex sock_block_mutex

mutex to protect against simultaneous access to Accept()

std::mutex socklist_mutex

mutex to protect against simultaneous access to socklist

std::map<int, std::shared_ptr<Network::TcpSocket>> socklist

container to hold TcpSocket object pointers

Public Static Functions

static void new_log_day(std::string logpath)

creates a new logbook each day

static void block_main(Flexure::Server &tcs, std::shared_ptr<Network::TcpSocket> sock)

main function for blocking connection thread

static void thread_main(Flexure::Server &tcs, std::shared_ptr<Network::TcpSocket> sock)

main function for all non-blocked threads

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

asynchronous message sending thread