Connection.hpp

Go to the documentation of this file.

#pragma once
 
#include <vector>
#include <mutex>
#include <iostream>
#include <memory>
#include "ConnectionSocket.hpp"
#include "Socket.hpp"
#include "logger.hpp"
#include "Tracy.hpp"
 
class Connection
{
public:
    constexpr static size_t READ_BUFFER_SIZE_MAX = 1024 * 1024 * 4; //  4 MB
    Connection(std::shared_ptr<Socket> socket);
    ~Connection();
 
    Connection(const Connection& other) = delete;
    Connection& operator=(const Connection& other) = delete;
 
    Connection(Connection&& other);
    Connection& operator=(Connection&& other);
 
    void                    queueAndSendMessage(const std::vector<uint8_t> & msg);
 
    void                    queueMessage(const std::vector<uint8_t> & msg);
 
    const uint8_t *         getReadBufferPtr() const;
 
    size_t                  getReadBufferSize() const;
 
    void                    reduceReadBuffer(size_t size);
 
    void                    clearReadBuffer();
 
    const std::vector<uint8_t> &    getWriteBufferRef() const;
 
    LockableBase (std::mutex) & ReadLock() const;
 
    LockableBase (std::mutex) & WriteLock() const;
 
    bool                    dataToSend() const;
 
    ssize_t                 recv();
 
    ssize_t                 sendQueue();
 
 
    const Socket &      getSocket() const;
    const uint64_t &    getConnectionId() const;
    void                setConnectionId(const uint64_t & connection_id);
private:
 
    std::shared_ptr<Socket> m_socket;
    uint64_t                m_connection_id;
    size_t                  m_read_offset = 0;
    std::vector<uint8_t>    m_read_buffer;
    std::vector<uint8_t>    m_write_buffer;
 
    mutable TracyLockableN (std::mutex, m_mutex, "Connection Mutex");
    mutable TracyLockableN (std::mutex, m_write_mutex, "Write Mutex");
    mutable TracyLockableN (std::mutex, m_read_mutex, "Read Mutex");
};