TcpServer.h

Go to the documentation of this file.

 
#ifndef TcpServer_H
#define TcpServer_H
 
#include "CscCommon.h"
#include "TcpClient.h"
#include "AsioContext.h"
#include <mutex>
#include <thread>
#include <functional>
 
using std::mutex, std::thread, std::function;
 
namespace conscience_core::communication {
 
    class TcpServerRuntimeError : public runtime_error {
    public:
        TcpServerRuntimeError(const string &message) : runtime_error(message.c_str()) {}
    };
 
    class TcpServer {
    public:
        TcpServer(unsigned int port, function<void(TcpClient *communicationClient)> onConnection);
        ~TcpServer();
 
 
    private:
        void waitClients();
 
        unique_ptr<CscLogger> logger = nullptr;
        AsioContext *asioContext = nullptr;
 
        class Acceptor;
        Acceptor *acceptor = nullptr;
        function<void(TcpClient *communicationClient)> onConnection;
 
 
    };
 
}
#endif