#include "stdafx.h"
#include "HsmsAction.h"


CHsmsAction::CHsmsAction()
{
	m_nAction = ACTION_IDLE;
	m_bNeedWaitReply = FALSE;
	m_nTimeout = 45;
	m_nResponseTime = 0;
	m_pContext = NULL;
	m_hEvent = ::CreateEvent(NULL, TRUE, FALSE, NULL);
}

CHsmsAction::CHsmsAction(int nAction, BOOL bNeedReply, unsigned int nTimeout)
{
	m_nAction = nAction;
	m_bNeedWaitReply = bNeedReply;
	m_nTimeout = nTimeout;
	m_nResponseTime = 0;
	m_pContext = NULL;
	m_hEvent = ::CreateEvent(NULL, TRUE, FALSE, NULL);
}

CHsmsAction::~CHsmsAction()
{
	if (m_hEvent != NULL) {
		CloseHandle(m_hEvent);
		m_hEvent = NULL;
	}

	if (m_pSendMessage != NULL) {
		HSMS_Destroy1Message(m_pSendMessage);
		m_pSendMessage = NULL;
	}
}

void CHsmsAction::reset()
{
	m_nAction = ACTION_IDLE;
	m_bNeedWaitReply = FALSE;
	m_nTimeout = 45;
	m_nResponseTime = 0;
	::ResetEvent(m_hEvent);
}

void CHsmsAction::resetResponseTime()
{
	m_nResponseTime = 0;
}

void CHsmsAction::setAction(int nAction, BOOL bNeedReply/* = TRUE*/, unsigned int nTimeout/* = 45*/)
{
	m_nAction = nAction;
	m_bNeedWaitReply = bNeedReply;
	m_nTimeout = nTimeout;
}

int CHsmsAction::getAction()
{
	return m_nAction;
}

void CHsmsAction::setContext(CContext* pContext)
{
	m_pContext = pContext;
}

CContext* CHsmsAction::getContext()
{
	return m_pContext;
}

void CHsmsAction::setSendMessage(IMessage* pMessage)
{
	m_pSendMessage = pMessage;
}

IMessage* CHsmsAction::getSendMessage()
{
	return m_pSendMessage;
}

unsigned int CHsmsAction::getTimeout()
{
	return m_nTimeout;
}

BOOL CHsmsAction::isNeedWaitReply()
{
	return m_bNeedWaitReply;
}

HANDLE CHsmsAction::getEvent()
{
	return m_hEvent;
}

int CHsmsAction::responseTimeIncrement()
{
	return InterlockedIncrement(&m_nResponseTime);
}

BOOL CHsmsAction::incrementAndCheckTimeout()
{
	unsigned int nResponseTime = InterlockedIncrement(&m_nResponseTime);
	return nResponseTime >= m_nTimeout;
}