Implementation of heartbeat routers that deal with server heartbeating sending and receiving. More...

#include "comms/serverheartbeat.hpp"
#include <stdexcept>
#include <glog/logging.h>

Include dependency graph for serverheartbeat.cpp:

Functions
void	stateline::comms::insertClient (const Message &m, HBClients &clients, HBMap &lastHeartbeats)
	Add a new client to be monitored for heartbeating. More...

void	stateline::comms::deleteClient (const Message &m, HBClients &clients, HBMap &lastHeartbeats)
	Remove a client from being monitored for heartbeating. More...

void	stateline::comms::failedSendServer (const Message &m)
	Stop the heartbeat thread. This is called when the thread can't send to the local socket.

void	stateline::comms::receiveHeartbeat (const Message &m, HBMap &lastHeartbeats)
	Update book-keeping on client heartbeats. Called when a heartbeat message arrives from a client. More...

void	stateline::comms::monitorTimeouts (HBClients &clients, HBMap &lastHeartbeats, SocketRouter &router, uint msTimeout)
	Update book-keeping on client heartbeats. Called every time the socket is polled. More...

void	stateline::comms::sendHeartbeats (HBClients &clients, hrc::time_point &lastHbTime, SocketRouter &router, uint msFrequency)
	Send heartbeats to all the clients if necessary. More...

Detailed Description

Implementation of heartbeat routers that deal with server heartbeating sending and receiving.

Namespaces