Channel.h

// Author: Kang Lin <kl222@126.com>
 
#ifndef CDATACHANNEL_H
#define CDATACHANNEL_H
 
#pragma once
 
#include <QIODevice>
#include <QTcpSocket>
#include <QMessageBox>
#include <QMutex>
#include "plugin_export.h"
#include "Stats.h"
 
#define DEFAULT_TIMEOUT 500000

class PLUGIN_EXPORT CChannel : public QIODevice
{
    Q_OBJECT
 
public:
    explicit CChannel(QTcpSocket* pSocket, QObject *parent = nullptr);
    virtual ~CChannel();

    virtual bool open(OpenMode mode) override;
    virtual void close() override;

    virtual QString GetDetails();

    static int InitTranslation();
    static int RemoveTranslation();
 
Q_SIGNALS:
    void sigConnected();
    void sigDisconnected();
    void sigError(int nErr, const QString& szErr);

    void sigSecurityLevel(CSecurityLevel::Levels level);
    void sigSend(quint64 counts);
    void sigReceive(quint64 counts);
 
private Q_SLOTS:
    void slotError(QAbstractSocket::SocketError e);
 
private:
    QTcpSocket* m_pSocket;
 
protected:
    explicit CChannel(QObject *parent = nullptr);
 
    // QIODevice interface
protected:
    virtual qint64 readData(char *data, qint64 maxlen) override;
    virtual qint64 writeData(const char *data, qint64 len) override;
    virtual bool isSequential() const override;
};
 
#endif // CDATACHANNEL_H