ClientConnection.h

Go to the documentation of this file.

#pragma once
#include <QIODevice>
#include <ami/service/BufferChopper.h>
#include <ami/service/InformationPacket.h>
#include <gii/gen/ResultDataTypes.h>
#include <gii/gen/VariableTypes.h>
 
namespace sf
{
 
class ClientConnection
  : public QObject
  , protected InformationTypes
{
  public:
    enum EState
    {
      sError = -1,
      sNone = 0,
      sHeaderRead,
      sPayloadRead,
      sPayloadProcess,
      sBufferWrite,
      sIdle,
      sWaitForRead,
      sDisconnect
    };
 
    explicit ClientConnection(QIODevice* ioDevice, QObject* parent = nullptr);
 
    bool process();
 
    void setState(EState state);
 
  private:
    bool sendPingPong(int counter);
 
    // Holds the IO device reference.
    QIODevice* _ioDevice;
    // Holds the variable client instances which are served.
    VariableTypes::PtrVector _listVariable;
    // Holds the result-data client instances which are served.
    ResultDataTypes::PtrVector _listResultData;
    // Holds the current state of the connection.
    EState _curState{sNone};
    // Holds the previous state of the connection.
    EState _prevState{sNone};
    //
    InformationPacket::Header _headerRead;
    DynamicBuffer _bufferRead;
    DynamicBuffer _bufferWrite;
    //
    BufferChopper bufChopper{16};
};
 
}// namespace sf