socket.h

Go to the documentation of this file.

#ifndef CPPSERVER_NANOMSG_SOCKET_H
#define CPPSERVER_NANOMSG_SOCKET_H

#include "message.h"

#include <string>
#include <tuple>

namespace CppServer {
namespace Nanomsg {


class Socket
{
public:

    explicit Socket(Domain domain, Protocol protocol);
    Socket(const Socket&) = delete;
    Socket(Socket&&) noexcept = default;
    ~Socket();

    Socket& operator=(const Socket&) = delete;
    Socket& operator=(Socket&&) noexcept = default;

    Domain domain() const noexcept { return _domain; }
    Protocol protocol() const noexcept { return _protocol; }
    int socket() const noexcept { return _socket; }
    int endpoint() const noexcept { return _endpoint; }
    const std::string& address() const noexcept { return _address; }

    uint64_t established_connections() const noexcept;
    uint64_t accepted_connections() const noexcept;
    uint64_t dropped_connections() const noexcept;
    uint64_t broken_connections() const noexcept;
    uint64_t connect_errors() const noexcept;
    uint64_t bind_errors() const noexcept;
    uint64_t accept_errors() const noexcept;
    uint64_t current_connections() const noexcept;
    uint64_t messages_sent() const noexcept;
    uint64_t messages_received() const noexcept;
    uint64_t bytes_sent() const noexcept;
    uint64_t bytes_received() const noexcept;

    bool IsOpened() const noexcept { return (_socket >= 0); }
    bool IsConnected() const noexcept { return (_endpoint >= 0); }


    bool Open();

    bool Close();

    bool Reopen();


    bool SetSocketOption(int level, int option, const void* value, size_t size);

    bool GetSocketOption(int level, int option, void* value, size_t* size);


    bool Bind(const std::string& address);

    bool Connect(const std::string& address);

    bool Link(const std::string& address);

    bool Disconnect();


    size_t Send(const void* buffer, size_t size);

    size_t Send(const std::string& text) { return Send(text.data(), text.size()); }

    size_t Send(const Message& message) { return Send(message.buffer(), message.size()); }


    size_t TrySend(const void* buffer, size_t size);

    size_t TrySend(const std::string& text) { return TrySend(text.data(), text.size()); }

    size_t TrySend(const Message& message) { return TrySend(message.buffer(), message.size()); }


    size_t Receive(Message& message);


    size_t TryReceive(Message& message);


    std::tuple<size_t, bool> ReceiveSurvey(Message& message);


    std::tuple<size_t, bool> TryReceiveSurvey(Message& message);

    static void Terminate();

private:
    Domain _domain;
    Protocol _protocol;
    int _socket;
    int _endpoint;
    std::string _address;
};

} // namespace Nanomsg
} // namespace CppServer

#endif // CPPSERVER_NANOMSG_SOCKET_H