AbstractBaseSocket.h

#ifndef TENDUKE_OSA_ABSTRACTBASESOCKET_H
#define TENDUKE_OSA_ABSTRACTBASESOCKET_H
 
#include "osa/Socket.h"
 
#include <cstdint>
#include <memory>
#include <string>
 
#if defined(__APPLE__) || defined(__linux__) || defined(__unix__) || defined(_POSIX_VERSION) || defined(__ANDROID__)
 
#include <arpa/inet.h>
#include <sys/socket.h>
 
#elif defined(WIN32) || defined(_WIN32) || defined(__WIN32__) || defined(__NT__) || defined (_WIN64)
 
#include <WinSock2.h>
 
#endif // OS-detection
 
 
namespace tenduke { namespace osa {
 
 

class SocketDescriptor
{
public:
    explicit SocketDescriptor(int descriptor);
    virtual ~SocketDescriptor();

    int get() const {return descriptor;}
private:
    int descriptor;
};

class AbstractBaseSocket : public tenduke::osa::Socket
{
public:
    AbstractBaseSocket(uint32_t address, uint16_t port);

    std::unique_ptr<tenduke::osa::Socket> accept(uint32_t timeoutMs) override;
    using tenduke::osa::Socket::accept;

    void listen() override;

    int read(void * buffer, std::size_t bufferSize) override;

    int write(const void * buffer, std::size_t len) override;
 
protected:
    AbstractBaseSocket(int descriptor, const struct ::sockaddr_in *address);

    virtual std::unique_ptr<tenduke::osa::Socket> createSocket(int descriptor, const struct ::sockaddr_in *address) = 0;

    virtual int getLastError() const = 0;

    virtual std::string mkErrorMessage(const std::string &body) const;

    virtual std::string mkErrorMessage(const char *body) const;

    virtual std::string mkErrorMessage(const std::string &body, int errorCode) const = 0;

    virtual bool wouldBlock(int errorCode) const = 0;

    SocketDescriptor descriptor;
 
private:
    struct ::sockaddr_in address;
};
 
}}
 
#endif //TENDUKE_OSA_ABSTRACTBASESOCKET_H