communicator-tcp.hpp

#ifndef MAMMUT_COMMUNICATOR_TCP_HPP_
#define MAMMUT_COMMUNICATOR_TCP_HPP_

#ifdef MAMMUT_REMOTE

#include "./communicator.hpp"

#include "cstddef"

namespace mammut{

class ServerTcp;

class CommunicatorTcp: public Communicator{
private:
    int _socket;
    mutable utils::LockPthreadMutex _lock;
public:
    CommunicatorTcp(std::string serverAddress, uint16_t serverPort);

    CommunicatorTcp(const ServerTcp& serverTcp);

    ~CommunicatorTcp();
    void send(const char* message, size_t messageLength) const;
    bool receive(char* message, size_t messageLength) const;
    utils::Lock& getLock() const;
};

// A TCP based server.
class ServerTcp{
private:
    int _listenSocket;
public:
    ServerTcp(uint16_t listeningPort);
    ~ServerTcp();

    int accept() const;
};

}

#endif

#endif /* MAMMUT_COMMUNICATOR_TCP_HPP_ */