GoGdpClient.h

Go to the documentation of this file.

#ifndef GO_PXL_SDK_GOGDPCLIENT_H
#define GO_PXL_SDK_GOGDPCLIENT_H

#include <kApi/Io/kNetwork.h>
#include <kApi/Io/kTcpClient.h>

#include <kApi/Threads/kThread.h>
#include <kApi/Threads/kLock.h>
#include <kApi/Threads/kTimer.h>

#include <GoApi/GoApi.h>
#include <GoApi/Threads/MsgQueue.h>
#include <GoApi/Threads/Locker.h>

#include <GoPxLSdk/Def.h>
#include <GoPxLSdk/GoDataSet.h>
#include <GoPxLSdk/GoGdpMsg/GoGdpMsgDef.h>

class GoGdpClientTests;

namespace GoPxLSdk
{
    class GoPxLSdkClass GoGdpClient
    {
    public:
        GoGdpClient();
        ~GoGdpClient();

        const int CONNECT_TIMEOUT = 5000000;
        const int CANCEL_QUERY_INTERVAL = 100000;

        void Connect(kIpAddress ipAddr, k16u port = GO_PXL_SDK_DEFAULT_GDP_SERVER_PORT);

        void Close();

        bool IsConnected();

        void ReceiveDataSync(k64u receiveTimeoutInMilliseconds);

        void ReceiveDataAsync(std::function<void(const GoDataSet& receivedDataSet)>& func);

        const GoDataSet& DataSet() const;

        void ClearData();

    private:
        void GetGdpMsgType(MessageType& type);

        void InitTcpClient();

        void InitThreadAndTimer();

        static kStatus kCall OnDataReceive(void* context);

        static kStatus kCall DataThreadEntry(void* context);

    private:
        void TryClose();

        std::function<void(const GoDataSet& pDataSet)> func;

        GoDataSet dataSet;

        bool isConnected = false;
        bool async = false;
        bool isCompleteSet;

        Go::Object<kTcpClient> socket;
        Go::Object<kSerializer> serializer;
        Go::Object<kTimer> timer;
        Go::Object<kThread> receiveThread;
        Go::MsgQueue<GoDataSet> dataQueue;
        Go::Object<kThread> dataThread;

        kIpAddress ipAddress;
        k16u port;

        friend class ::GoGdpClientTests;
    };
}


#endif