PhysicalDevice/Machine/MachineryECOM/Deliver/Include/SCF.hpp

#pragma once


#include <string>
#include <functional>
#include <memory>


#pragma warning (disable:4251)


#ifndef SCF_EXPORTS
#ifdef _WIN64
#ifdef _DEBUG
#pragma comment(lib, "DIOS.Dev.SCFX64D.lib")
#else
#pragma comment(lib, "DIOS.Dev.SCFX64.lib")
#endif
#else
#ifdef _DEBUG
#pragma comment(lib, "DIOS.Dev.SCFXD.lib")
#else
#pragma comment(lib, "DIOS.Dev.SCFX.lib")
#endif
#endif
#endif



#ifdef SCF_EXPORTS
#define SCF_API __declspec (dllexport)
#else
#define SCF_API  __declspec (dllimport)
#endif


#include "SCF.Define.hpp"


namespace DIOS
{
namespace Dev
{
namespace Communication
{
	namespace Detail
	{
		class SCFDetail;	//	ÄÚ²¿ÊµÏÖÕæÕý¹¦ÄÜµÄ SCF
	}


//-----------------------------------------------------------------------------
//		SCF
//-----------------------------------------------------------------------------

	class  SCF_API  SCF
	{
	private:
		std::shared_ptr <Detail::SCFDetail>  m_SCFDetail;

	public:
		SCF ();
		~SCF ();

	public:
		SCF (const SCF & from) = default;
		//SCF (SCF && from) = default;
		//SCF & operator = (SCF && from) = default;
		SCF & operator = (const SCF & from) = default;

	public:
		operator bool () const
		{
			return bool(m_SCFDetail);
		}

	public:
		static SCF FromDLL (const char * DllName);

	public:
		int  Connect (std::string strProfile, tPacketPredate Pr, _SCF_Transfertype TransferType, DWORD msTimeOut);
		void Disconnect ();
		bool isConnected () const;

	public:
		class SCF_API IO
		{
			friend SCF;
			std::shared_ptr <Detail::SCFDetail>  m_SCFDetail;

		private:
			IO (std::shared_ptr <Detail::SCFDetail>  SCF, int msTimeOut);

		public:
			~IO ();

		public:
			IO & SendPacket (const char * Packet, DWORD length, DWORD msTimeOut, int&retLength);
			IO & ReceivePacket (char * Packet, DWORD length, DWORD msTimeOut, int& retLength);
		};

	public:
		IO Lock (int msTimeOut);

		std::function <void ()> OnPassiveDisconnected;

	public:
		class SCF_API tQueue
		{
			friend SCF;

		private:
			tQueue () = default;
			std::shared_ptr <Detail::SCFDetail>  m_SCFDetail;

		public:
			bool isEmpty () const;
			int  GetNbOfPackt () const;
//			void Clear ();

			int  Enqueue (const char * Packet, DWORD length);
			int  Dequeue (char * Packet, DWORD length, DWORD msTimeOut);

			std::function <void ()> OnNewPacket;
		} Queue;
	};


}
}
}