code_app/sdk/webservice/MsgPumpCallback.cpp

#include "MsgPumpCallback.h"
#include "base/HGDef.h"
#include "base/HGInc.h"
#include "ManagerV1.h"
#include "ManagerV2.h"
#include "HttpServer.h"
#include "SockIoServer.h"
#include "WSServer.h"

namespace ver_1
{
	void HGAPI HGMsgPumpCallback(HGMsgPump msgPump, const HGMsg* msg, HGPointer param)
	{
		(void)msgPump;
		(void)param;
		assert(NULL != msg);

		switch (msg->id)
		{
		case MSGID_CONNECT:
		{
			ConnectParam* param = (ConnectParam*)msg->data;
			param->svr->Connect(param);
			delete param;
		}
		break;
		case MSGID_DISCONNECT:
		{
			DisConnectParam* param = (DisConnectParam*)msg->data;
			param->svr->DisConnect(param);
			delete param;
		}
		break;
		case MSGID_OPEN_DEVICE:
		{
			OpenDevParam* param = (OpenDevParam*)msg->data;
			param->mgr->OpenDev(param);
			delete param;
		}
		break;
		case MSGID_CLOSE_DEVICE:
		{
			CloseDevParam* param = (CloseDevParam*)msg->data;
			param->mgr->CloseDev(param);
			delete param;
		}
		break;
		case MSGID_SCAN_FINISH:
		{
			ScanFinishParam* param = (ScanFinishParam*)msg->data;
			param->mgr->ScanFinish(param);
			delete param;
		}
		break;
		case MSGID_HTTP_COMMAND:
		{
			HttpCmdParam* param = (HttpCmdParam*)msg->data;
			param->svr->Command(param);
			delete param;
		}
		break;
		case MSGID_SOCKIO_COMMAND:
		{
			SockIoCmdParam* param = (SockIoCmdParam*)msg->data;
			param->svr->Command(param);
			delete param;
		}
		break;
		case MSGID_SOCKIO_EVENT:
		{
			SockIoEvtParam* param = (SockIoEvtParam*)msg->data;
			param->svr->Event(param);
			delete param;
		}
		break;
		}
	}
}


namespace ver_2
{
	void HGAPI HGMsgPumpCallback(HGMsgPump msgPump, const HGMsg* msg, HGPointer param)
	{
		(void)msgPump;
		(void)param;
		assert(NULL != msg);

		switch (msg->id)
		{
		case MSGID_CONNECT:
		{
			ConnectParam* param = (ConnectParam*)msg->data;
			param->svr->Connect(param);
			delete param;
		}
		break;
		case MSGID_DISCONNECT:
		{
			DisConnectParam* param = (DisConnectParam*)msg->data;
			param->svr->DisConnect(param);
			delete param;
		}
		break;
        case MSGID_DEINIT_DEVICE:
        {
            DeinitDevParam* param = (DeinitDevParam*)msg->data;
            param->mgr->DeinitDev(param);
            delete param;
        }
        break;
		case MSGID_CLOSE_DEVICE:
		{
			CloseDevParam* param = (CloseDevParam*)msg->data;
			param->mgr->CloseDev(param);
			delete param;
		}
		break;
		case MSGID_SCAN_FINISH:
		{
			ScanFinishParam* param = (ScanFinishParam*)msg->data;
			param->mgr->ScanFinish(param);
			delete param;
		}
		break;
		case MSGID_ADD_SAVEDFILE:
		{
			AddSavedFileParam* param = (AddSavedFileParam*)msg->data;
			param->mgr->AddSavedFile(param);
			delete param;
		}
		break;
		case MSGID_REMOVE_SAVEDFILE:
		{
			RemoveSavedFileParam* param = (RemoveSavedFileParam*)msg->data;
			param->mgr->RemoveSavedFile(param);
			delete param;
		}
		break;
		case MSGID_WS_COMMAND:
		{
			WSCmdParam* param = (WSCmdParam*)msg->data;
			param->svr->Command(param);
			delete[] param->data;
			param->size = 0;
			delete param;
		}
		break;
		case MSGID_WS_EVENT:
		{
			WSEvtParam* param = (WSEvtParam*)msg->data;
			param->svr->Event(param);
			delete[] param->data;
			param->size = 0;
			delete param;
		}
		break;
		}
	}
}