#pragma once



#include "akNetworkLinker.h"
#include <WinSock2.h>

#include "akThread.h"
#include "akPacketStorage.h"

class AKNETWORK_DLLSPEC CakPIPEClient : public CakThreadInterface
{
public:
	typedef void (*SystemMsgFunc) (char* pMsg, int nMsglen, void*);

public:
	 CakPIPEClient(void);
	 ~CakPIPEClient(void);

	void setServerName(char* pServerName);

	// ½Ã½ºÅÛ ¸Þ¼¼Áö ¼ö½Å ÄÝ¹é ¼³Á¤
	void SetSystemMessageCallback(SystemMsgFunc userFunc, void* data = NULL);
	// ¸Þ¼¼Áö Àü¼Û
	bool Send(char* pSend, int nLen);
	bool SendForce(char* pSend, int nLen, int nWaitTimeMS=0);
	bool SendLarge(char* pSend, long nLen, int nWaitTimeMS=0);


protected:
	void setSystemMsg(const char* pMsg, ...);

	SystemMsgFunc m_systemmsgFunc;
	void* m_systemmsgData;

	virtual void threadRun();

protected:
	CPacketStorage m_PacketSorageSend;
	CakThread	m_akThread;
	int m_nWaitTime;//0
	HANDLE m_hNamedPipe;
	DWORD m_nNumberOfBytesWritten;
	char m_strPipename[64];// = L"\\\\.\\pipe\\MyNamedPipe";// ÆÄÀÌÇÁ ¿ÀºêÁ§Æ® À̸§
	//CRITICAL_SECTION					m_csSendSafe;

// 	class queueData
// 	{
// 	public:
// 		queueData()
// 		{
// 			m_nLen = 0;
// 			m_pData = NULL;
// 		};
// 		queueData(const queueData& rhs)
// 		{
// 			m_nLen = 0;
// 			m_pData = NULL;
//
// 			if(rhs.m_nLen > 0)
// 			{
// 				m_pData = new char[rhs.m_nLen+1];
// 				memcpy(m_pData, rhs.m_pData, sizeof(char)*(rhs.m_nLen));
// 				m_pData[rhs.m_nLen] = 0;
// 				m_nLen = rhs.m_nLen;
// 			}
// 		}
// 		~queueData()
// 		{
// 			clear();
// 		};
// 		queueData& operator=(const queueData& rhs)
// 		{
// 			clear();
// 			if(rhs.m_nLen > 0)
// 			{
// 				m_pData = new char[rhs.m_nLen+1];
// 				memcpy(m_pData, rhs.m_pData, sizeof(char)*(rhs.m_nLen));
// 				m_pData[rhs.m_nLen] = 0;
// 				m_nLen = rhs.m_nLen;
// 			}
// 			return *this;
// 		};
// 		void clear()
// 		{
// 			if(m_nLen > 0)
// 			{
// 				delete [] m_pData;
// 				m_pData = NULL;
// 				m_nLen = 0;
// 			}
// 		}
// 		void setData(char* pData, long nLen)
// 		{
// 			clear();
// 			if(nLen <= 0 || pData == NULL)
// 			{
// 				return;
// 			}
//
// 			m_pData = new char[nLen+1];
// 			memcpy(m_pData, pData, sizeof(char)*nLen);
// 			m_pData[nLen] = 0;
// 			m_nLen = nLen;
// 		}
//
// 		//char Data[4096];
// 		char* m_pData;
// 		long m_nLen;
// 	};
// 	std::queue<queueData> m_queSendData;
};