GoCtrlChannelV1.h

Go to the documentation of this file.

#ifndef GO_PXL_SDK_GOCTRLCHANNELV1_H
#define GO_PXL_SDK_GOCTRLCHANNELV1_H

#include "GoPxLSdk/Def.h"
#include "GoPxLSdk/Internal/GoCtrlChannel.h"

#include "GoApi/Object.h"

#include "kApi/Threads/kSemaphore.h"

class GoCtrlChannelV1Tests;

namespace GoPxLSdk
{
constexpr k16u MSGPACK_MESSAGE_TYPE = 0xB000;
constexpr k16u JSON_MESSAGE_TYPE = 0xB001;

class GoPxLSdkClass GoCtrlChannelV1 : public GoCtrlChannel
{
public:
    GoCtrlChannelV1();

    ~GoCtrlChannelV1();

    void Connect(const kIpAddress& address, k16u port,
                 k64u connectionTimeout = GO_PXL_SDK_DEFAULT_TCP_TIMEOUT_MILLISECONDS) override;

    void Disconnect() override;

    bool IsConnected() const override;

    void SendRequest(const GoRequest& request) override;

    void SetResponseHandler(GoCtrlChannelResponseHandler callback) override;

    void SetWriteErrorHandler(GoCtrlChannelWriteErrorHandler callback) override;

    void SetReadErrorHandler(GoCtrlChannelReadErrorHandler callback) override;

    const kIpAddress& Address() const;

    const k16u Port() const;

// Private constants
private:
    const k64u WRITE_THREAD_LOOP_SLEEP_USEC = 100000;   // 100 msec.
    const k64u READ_THREAD_LOOP_SLEEP_USEC = 100000;     // 100 msec.

private:
    void ProcessRequest(const ByteArray& msgpack) const;
    void ProcessResponse() const;

    void OnResponse(const ByteArray& bytes) const;
    void OnWriteError(k64u id, const std::exception& e) const;
    void OnReadError(ReadErrorType readErrorType, const std::exception& e) const;

    static kStatus kCall WriteThreadFunc(void* context);
    static kStatus kCall ReadThreadFunc(void* context);

private:
    kIpAddress address = { };
    k16u port = GO_PXL_SDK_DEFAULT_CONTROL_PORT;

    Go::Object<kTcpClient> client;
    bool isConnected = false;

    Go::Object<kThread> readThread;
    Go::Object<kThread> writeThread;

    std::mutex mutex;

    Go::Object<kSerializer> serializer;

    std::queue<GoRequest> sendQueue;
    Go::Object<kSemaphore> sendQueueSema;

    GoCtrlChannelResponseHandler responseHandler;

    GoCtrlChannelWriteErrorHandler writeErrorHandler;
    GoCtrlChannelReadErrorHandler readErrorHandler;

    friend class ::GoCtrlChannelV1Tests;
};

}

#endif