// Message.h: interface for the CMessage class.
//
//////////////////////////////////////////////////////////////////////

#if !defined(AFX_MESSAGE_H__73BF6A77_14BE_47EA_A691_7DD1B10E986B__INCLUDED_)
#define AFX_MESSAGE_H__73BF6A77_14BE_47EA_A691_7DD1B10E986B__INCLUDED_

#if _MSC_VER > 1000
#pragma once
#endif // _MSC_VER > 1000

#include "PDUdecoding.h"
#include "JustinIO.h"

#define MAX_SM_SEND		128		// 發送隊列長度
#define MAX_SM_RECV		128		// 接收隊列長度

class CMessage  
{
public:
	CMessage();
	virtual ~CMessage();

    int m_nSendIn;		// 發送隊列的輸入指針
	int m_nSendOut;		// 發送隊列的輸出指針

	int m_nRecvIn;		// 接收隊列的輸入指針
	int m_nRecvOut;		// 接收隊列的輸出指針

	SM_PARAM m_SmSend[MAX_SM_SEND];		// 發送短消息隊列
	SM_PARAM m_SmRecv[MAX_SM_SEND];		// 接收短消息隊列

	CRITICAL_SECTION m_csSend;		// 與發送相關的臨界段
	CRITICAL_SECTION m_csRecv;		// 與接收相關的臨界段

	HANDLE m_hKillThreadEvent;		// 通知子線程關閉的事件
	HANDLE m_hThreadKilledEvent;	// 子線程宣告關閉的事件

	void PutSendMessage(SM_PARAM* pSmParam);	// 將短消息放入發送隊列
	BOOL GetSendMessage(SM_PARAM* pSmParam);	// 從發送隊列中取一條短消息
	void PutRecvMessage(SM_PARAM* pSmParam, int nCount);	// 將短消息放入接收隊列
	BOOL GetRecvMessage(SM_PARAM* pSmParam);	// 從接收隊列中取一條短消息

	static UINT SmThread(LPVOID lpParam);	// 短消息收發處理子線程
};

#endif // !defined(AFX_MESSAGE_H__73BF6A77_14BE_47EA_A691_7DD1B10E986B__INCLUDED_)