AdaptiveTCPServer.h

#pragma once
#include <NDEVR/NDEVRCommunicationLogic.h>
#include <NDEVR/Buffer.h>
#include <NDEVR/QueueBuffer.h>
#include <NDEVR/Dictionary.h>
#include <NDEVR/UUID.h>
#include <QTcpServer>
#include <QTcpSocket>
#include <QElapsedTimer>
#include <QTimer>
#include <QMap>
namespace NDEVR
{
    class AdaptiveTCPServer : public QTcpServer, public NDEVRCommunicationLogic
    {
        Q_OBJECT
    public:
        explicit AdaptiveTCPServer(QObject* parent = nullptr);
        void start(quint16 port);
        virtual uint08 rx(void* socket, NDEVRDataPacket& packet) override;
        virtual uint08 tx(void* socket, NDEVRDataPacket& packet, uint08 size) override;
        uint08 bytesAvailable(void* socket) override;
        virtual void wait(const TimeSpan& span, LogPtr log = nullptr) override;
        void* connectTo(const NDEVRServerInfo& server);
        virtual void disconnectFrom(void* socket);
        virtual bool isOpen(void* socket = nullptr) const override;
    private slots:
        void onConnectionReadyRead();
        void onSendTick();
    protected:
        void incomingConnection(qintptr socketDescriptor) override;
    private:
        QTimer m_send_timer;    
    };
}