eroomnetavictrl.cpp

network library that can be use all network application!

#include "EroomNetAviCtrl.h"


CEroomNetAviCtrl::CEroomNetAviCtrl() : CWiseNet(WN_QUEUE_NOUSE)
{
	m_AviCtrlRecvFunc = NULL;

	m_Code[0] = 'A';
	m_Code[1] = 'C';
	m_Code[2] = '0';

}


CEroomNetAviCtrl::~CEroomNetAviCtrl()
{
	m_AviCtrlRecvFunc = NULL;
}


int CEroomNetAviCtrl::Send(char *ap_Ip, int a_Port, int a_Command)
{
	EATL_PACKET		w_Packet;

	memset(&w_Packet, 0x00, EATL_PACKE_SIZE);

	w_Packet.m_Code[0] = m_Code[0];
	w_Packet.m_Code[1] = m_Code[1];
	w_Packet.m_Check = EATL_PACKET_ONLY;
	w_Packet.m_Sequence = 0;
	w_Packet.m_Cmd = a_Command;

	return(Send(ap_Ip, a_Port, &w_Packet));
}

int CEroomNetAviCtrl::Send(char *ap_Ip, int a_Port, EATL_PACKET *ap_Packet)
{
	return(CWiseNet::Send(ap_Ip, a_Port, (char *)ap_Packet, EATL_PACKE_SIZE));
}

int	CEroomNetAviCtrl::Recv(char *ap_Ip, int &ar_Port, char *ap_Buff, int &ar_Len)
{
	int				w_Rtn;
	EATL_PACKET		*wp_RPacket;

	w_Rtn = CWiseNet::Recv(ap_Ip, ar_Port, ap_Buff, ar_Len, m_WaitFlag);
	if(w_Rtn <= 0) {
		return(w_Rtn);
	}
	if(ar_Len < EATL_PACKE_SIZE) {
		return(0);
	}
	wp_RPacket = (EATL_PACKET *)ap_Buff;

	if(wp_RPacket->m_Code[0] != m_Code[0] || wp_RPacket->m_Code[1] != m_Code[1]) {
		return(0);
	}
	if(!(wp_RPacket->m_Check & EATL_PACKET_ONLY)){
		return(0);
	}

	if(m_AviCtrlRecvFunc) {
		m_AviCtrlRecvFunc(ap_Ip, ar_Port, wp_RPacket->m_Cmd);
	}

	return(0);
}


extern "C" {
	DWORD WINAPI EroomNetAviCtrlRecvProc(LPVOID Param);
	int	         EroomAviCtrlRecvFunc(char *ap_Ip, int a_Port, char *ap_Buff, int w_Len);
};

int	EroomAviCtrlRecvFunc(char *ap_Ip, int a_Port, char *ap_Buff, int w_Len)
{
	return(1);
}

int CEroomNetAviCtrl::SetRecvFunc(int (*ap_RecvFunc)(char *ap_Ip, int ar_Port, int a_Command))
{
	DWORD		IDThread;
	HANDLE		hThread;

	if(!m_RecvFunc && ap_RecvFunc) {
		m_RecvFlag = 1;
		m_RecvFunc = EroomAviCtrlRecvFunc;
		m_AviCtrlRecvFunc = ap_RecvFunc;

		m_HEvent = CreateEvent(NULL, TRUE, FALSE, NULL);
		hThread = ::CreateThread(NULL, 0, EroomNetAviCtrlRecvProc, this, 0, &IDThread);
		if(!hThread) {
			SetEvent(m_HEvent);
			CloseHandle(m_HEvent);
			m_HEvent = NULL;
			m_RecvFlag = 0;
			m_RecvFunc = NULL;
			return(-1);
		}
	} else if(m_RecvFunc && !ap_RecvFunc) {
		m_RecvFlag = 0;

		if(m_HEvent) {
			MSG		w_Msg;
			if(::PeekMessage(&w_Msg, NULL, 0, 0, PM_REMOVE)) {
				if (w_Msg.message != WM_QUIT) {
					::TranslateMessage(&w_Msg);
					::DispatchMessage(&w_Msg);
				}
			}

			WaitForSingleObject(m_HEvent, WN_KILLWAITTIME);
			CloseHandle(m_HEvent);
			m_HEvent = NULL;
		}
	}

	return(1);
}


extern "C" DWORD WINAPI EroomNetAviCtrlRecvProc(LPVOID Param)
{
	int			w_Flag = 0;
	int			w_Port;
	char		w_Ip[256];
	char		w_Buff[WN_MAX_RECVLEN+WN_MAX_RECVLEN];
	int			w_Len;
	int			w_Rtn;
	CEroomNetAviCtrl	*wp_EroomNetAviCtrl = (CEroomNetAviCtrl *)Param;

	while(wp_EroomNetAviCtrl->m_RecvFlag) {
		w_Rtn = wp_EroomNetAviCtrl->Recv(w_Ip, w_Port, w_Buff, w_Len);
		if(w_Rtn < 0) {
//			printf("Getting Error\n");
//			printf("Open : 1, Send : 2, Close : 3, Wait Flag(Sending):4 QUIT: Q,q!!!!\n");
		} else if(w_Rtn > 0) {
			wp_EroomNetAviCtrl->m_RecvFunc(w_Ip, w_Port, w_Buff, w_Len);
//			printf("Dada : (%s), Ip : (%s)\n", w_Ip, w_Buff);
//			printf("Open : 1, Send : 2, Close : 3, Wait Flag(Sending):4 QUIT: Q,q!!!!\n");
//		} else {
//			printf("Data Nothing\n");
//			printf("Open : 1, Send : 2, Close : 3, Wait Flag(Sending):4 QUIT: Q,q!!!!\n");
		}
		Sleep(1);
	}
	SetEvent(wp_EroomNetAviCtrl->m_HEvent);
	wp_EroomNetAviCtrl->m_RecvFlag = 0;
	wp_EroomNetAviCtrl->m_RecvFunc = NULL;
	wp_EroomNetAviCtrl->m_AviCtrlRecvFunc = NULL;
	return(1);
}