message.h

Go to the documentation of this file.

#ifndef CPPSERVER_NANOMSG_MESSAGE_H
#define CPPSERVER_NANOMSG_MESSAGE_H

#include "nanomsg.h"

#include "errors/exceptions.h"

#include <iostream>
#include <string>

namespace CppServer {
namespace Nanomsg {


class Message
{
    friend class Socket;

public:
    Message();

    explicit Message(size_t size, int type = 0);

    explicit Message(const void* data, size_t size, int type = 0);
    Message(const Message& message);
    Message(Message&&) noexcept = default;
    ~Message();

    Message& operator=(const Message& message);
    Message& operator=(Message&&) noexcept = default;

    explicit operator bool() const { return (_buffer == nullptr); }

    uint8_t* buffer() noexcept { return _buffer; }
    const uint8_t* buffer() const noexcept { return _buffer; }
    size_t size() const noexcept { return _size; }
    int type() const noexcept { return _type; }

    void Clear();


    void Reallocate(size_t size);

    std::string string() const { return std::string((const char*)_buffer, _size); }

    friend std::ostream& operator<<(std::ostream& os, const Message& instance)
    { os << instance.string(); return os; }

    void swap(Message& message) noexcept;
    friend void swap(Message& message1, Message& message2) noexcept;

private:
    uint8_t* _buffer;
    size_t _size;
    int _type;
};

} // namespace Nanomsg
} // namespace CppServer

#include "message.inl"

#endif // CPPSERVER_NANOMSG_MESSAGE_H