DeviceSocketClient.h

#pragma once
 
#include "DeviceSocketBase.h"

namespace FLImaging
{
    namespace Devices
    {
        class CDeviceSocketServer;
        class CDeviceSocketClientSyncObject;
        class CInternalSocketClient;

        class FL_EXPORT CDeviceSocketClient : public CDeviceSocketBase
        {
        public:
            CDeviceSocketClient();

            CDeviceSocketClient(int64_t i64Socket);

            virtual ~CDeviceSocketClient();
 
 
            virtual const CResult Initialize() override;
            virtual const CResult Terminate() override;

            virtual const CResult Send(const CDeviceSocketPacket& packet);

            virtual const CResult Send(const CDeviceSocketPacket* pSocketPacket);
 
            virtual const CResult Recv(CDeviceSocketPacket& packet);

            virtual const CResult Recv(CDeviceSocketPacket* pSocketPacket);

            virtual bool IsThereRecvData() const;

            virtual const Base::CFLString<wchar_t>& GetUserID() const;

            virtual void SetUserID(const Base::CFLString<wchar_t>& strUserID);

            virtual int32_t GetPermission() const;

            virtual void SetPermission(int32_t i32Permission);
 

            virtual int32_t GetConnectionTimeoutSec() const;

            virtual const CResult SetConnectionTimeoutSec(uint32_t u32ConnectionTimeoutSec = 2);
 
            virtual int64_t GetClassType() const override;
 
        protected:
 
            virtual const CResult InternalRecvProxy(CDeviceSocketPacket* pSocketPacket);
            const CResult InternalRecv(char* pBuffer, int iToRecvByte);
            const CResult InternalRecvPacketData(CDeviceSocketPacket* pSocketPacket);
            const CResult InternalSendPacketData(CDeviceSocketPacket* pSocketPacket);
 
            HANDLE m_hReceivingThreadHandle;
 
            CDeviceSocketClientSyncObject* m_pSendingSyncObject;
            CDeviceSocketClientSyncObject* m_pReceivingSyncObject;
 
            CInternalSocketClient* m_pInternal;
 
            uint32_t m_u32ConnectionTimeoutSec;
 
            friend class CDeviceSocketServer;
            friend class CInternalSocketClient;
        };
    }
}