TCPListenServer.h

#ifndef _TCPListenServer_h_
#define _TCPListenServer_h_
 
#include "otsdaq/NetworkUtilities/TCPReceiverSocket.h"
#include "otsdaq/NetworkUtilities/TCPServerBase.h"
 
#include "TRACE/trace.h"
 
#include <chrono>
 
namespace ots
{
class TCPListenServer : public TCPServerBase
{
  public:
    TCPListenServer(unsigned int serverPort, unsigned int maxNumberOfClients = -1);
    virtual ~TCPListenServer(void);
 
    template<class T>
    T receive();
    std::string receivePacket();
 
  protected:
    void acceptConnections() override;
 
    TCPReceiverSocket* waitForReadableClient(std::chrono::milliseconds timeout);
 
    static constexpr std::chrono::milliseconds kPollTimeout{5};
 
    int lastReceived = -1;
};
 
template<class T>
inline T TCPListenServer::receive()
{
    TCPReceiverSocket* client = waitForReadableClient(kPollTimeout);
    if(client == nullptr)
        return T();
    const int socketId = client->getSocketId();
    try
    {
        return client->receive<T>();
    }
    catch(...)
    {
        removeClient(socketId);
        throw;
    }
}
}  // namespace ots
#endif