ServerConnection.h

Go to the documentation of this file.

#pragma once
#include <QIODevice>
#include <ami/service/InformationPacket.h>
#include <ami/service/VariableCollector.h>
#include <gii/gen/ResultDataTypes.h>
#include <gii/gen/VariableTypes.h>
#include <misc/gen/ThreadRelay.h>
 
namespace sf
{
 
class ServerConnection
  : public QObject
  , protected InformationTypes
{
  public:
    enum EState
    {
      sError = -1,
      sNone = 0,
      sHeaderRead,
      sPayloadRead,
      sPayloadProcess,
      sBufferWrite,
      sWaitForRead
    };
 
    explicit ServerConnection(QIODevice* ioDevice, QObject* parent = nullptr);
 
    ~ServerConnection() override;
 
    bool process();
 
    void setState(EState state);
 
    void relayThread();
 
  private:
    ThreadRelay _relay;
 
    VariableCollector* _varCollector;
 
    int fromMain(int v1);
 
    bool sendPingPong(int counter = -1);
 
    // Holds the IO device reference.
    QIODevice* _ioDevice;
    // Holds the current state of the connection.
    EState _curState;
    // Holds the previous state of the connection.
    EState _prevState;
    //
    InformationPacket::Header _headerRead;
    DynamicBuffer _bufferRead;
    DynamicBuffer _bufferWrite;
};
 
}// namespace sf