qzserialserver.cpp

wince中 我自己的流驱动实现 注册表和bib文件 修改在QZSerialServerARMV4IRel目录下

// QZSerialServer.cpp : Defines the initialization routines for the DLL.
//

#include "stdafx.h"
#include "QZSerialServer.h"


#ifdef _DEBUG
#define new DEBUG_NEW
#undef THIS_FILE
static char THIS_FILE[] = __FILE__;
#endif

extern HANDLE        m_hWriteSerialEvent;
extern bool          writethreadmutex;

HANDLE               m_hMMObj = 0;                 // Memory-mapped object
pCommandVar          m_pBuff = 0;              // Pointer to mm object
HANDLE               m_hmWriteOkay = 0;            // Write mutex

HANDLE               m_hComeDataEvent = 0;             //  要求写串口时的事件
HANDLE               m_hComeDataReadEndEvent = 0;         //  完成写串口时的事件

UINT                 ReadComeDataThread(LPVOID);
//
//	Note!
//
//		If this DLL is dynamically linked against the MFC
//		DLLs, any functions exported from this DLL which
//		call into MFC must have the AFX_MANAGE_STATE macro
//		added at the very beginning of the function.
//
//		For example:
//
//		extern "C" BOOL PASCAL EXPORT ExportedFunction()
//		{
//			AFX_MANAGE_STATE(AfxGetStaticModuleState());
//			// normal function body here
//		}
//
//		It is very important that this macro appear in each
//		function, prior to any calls into MFC.  This means that
//		it must appear as the first statement within the 
//		function, even before any object variable declarations
//		as their constructors may generate calls into the MFC
//		DLL.
//
//		Please see MFC Technical Notes 33 and 58 for additional
//		details.
//

/////////////////////////////////////////////////////////////////////////////
// CQZSerialServerApp

BEGIN_MESSAGE_MAP(CQZSerialServerApp, CWinApp)
	//{{AFX_MSG_MAP(CQZSerialServerApp)
		// NOTE - the ClassWizard will add and remove mapping macros here.
		//    DO NOT EDIT what you see in these blocks of generated code!
	//}}AFX_MSG_MAP
END_MESSAGE_MAP()

/////////////////////////////////////////////////////////////////////////////
// CQZSerialServerApp construction

CQZSerialServerApp::CQZSerialServerApp()
{
	// TODO: add construction code here,
	// Place all significant initialization in InitInstance
}

/////////////////////////////////////////////////////////////////////////////
// The one and only CQZSerialServerApp object

CQZSerialServerApp theApp;

/////////////////////////////////////////////////////////////////////////////
// CQZSerialServerApp initialization

BOOL CQZSerialServerApp::InitInstance()
{
	if (!AfxSocketInit())
	{
		AfxMessageBox(IDP_SOCKETS_INIT_FAILED);
		return FALSE;
	}

	return TRUE;
}

/////////////////////////////////////////////////////////////////////////////
//service interface
CMobileModule  mobile;
extern CList<VariableList,VariableList&>ComData_List ;

HWND           hWnd;
int            m_cmd=0,m_int1=0,m_int2=0,m_int3=0,m_int4=0,m_int5=0;
char           m_str1[1024],m_str2[1024],m_str3[1024] ;

void GetVariable(CommandVar *CV)
{
	m_cmd  = CV->ATCommand;
	m_int1 = CV->CV.var_int1;
	m_int2 = CV->CV.var_int2;
	m_int3 = CV->CV.var_int3;
	m_int4 = CV->CV.var_int4;
	m_int5 = CV->CV.var_int5;

	strcpy(m_str1,CV->CV.var_str1);
	strcpy(m_str2,CV->CV.var_str2);
	strcpy(m_str3,CV->CV.var_str3);
}

extern "C" DWORD PASCAL EXPORT QZS_Init (DWORD dwData)
{
	AFX_MANAGE_STATE(AfxGetStaticModuleState());

	// Create a file-mapping object.
    m_hMMObj = CreateFileMapping ((HANDLE)-1, NULL, PAGE_READWRITE, 0, 
                                  4*1024, TEXT ("DataComeBuffer"));
    if (m_hMMObj == 0)
	{
		return 0;
	}
	// Map into memory the file-mapping object.
    m_pBuff = (pCommandVar)MapViewOfFile (m_hMMObj, FILE_MAP_WRITE,0, 0, 0);
    if (!m_pBuff) 
        CloseHandle (m_hMMObj);

    // Initialize structure if first application started.
    memset (m_pBuff, 0, sizeof (CommandVar));
	// Create event 
	m_hComeDataEvent = CreateEvent (NULL, FALSE, FALSE, TEXT ("COMEDATAEVENT"));
    m_hComeDataReadEndEvent = CreateEvent (NULL, FALSE, FALSE, TEXT ("COMEDATAREADENDEVENT"));

    if (!m_hComeDataEvent || !m_hComeDataReadEndEvent)  
	{
        return 0;
	}

	mobile.OpenComm(L"COM1:",38400);

	printf("server begin\n");
	AfxBeginThread(ReadComeDataThread,0);
	
	return 1;
}



extern "C" BOOL  PASCAL EXPORT QZS_Deinit(DWORD dwData) 
{
	AFX_MANAGE_STATE(AfxGetStaticModuleState());
	return TRUE;
}

extern "C" DWORD  PASCAL EXPORT QZS_Open (DWORD dwData, DWORD dwAccess, DWORD dwShareMode) 
{
	AFX_MANAGE_STATE(AfxGetStaticModuleState());
	return 1;
}


extern "C" BOOL  PASCAL EXPORT QZS_Close (DWORD dwData)  
{
	AFX_MANAGE_STATE(AfxGetStaticModuleState());
	return TRUE;
}

extern "C" DWORD PASCAL EXPORT QZS_Write (DWORD dwData, LPCVOID pInBuf, DWORD dwInLen) 
{
	AFX_MANAGE_STATE(AfxGetStaticModuleState());
	return 1;
}


extern "C" DWORD PASCAL EXPORT QZS_Read (DWORD dwData, LPVOID pBuf, DWORD dwLen) 
{
	AFX_MANAGE_STATE(AfxGetStaticModuleState());
	return 1;
}



extern "C" BOOL PASCAL EXPORT
QZS_IOControl(DWORD dwData, DWORD dwCode, PBYTE pBufIn,
			  DWORD dwLenIn, PBYTE pBufOut, DWORD dwLenOut,
			  PDWORD pdwActualOut) {
	AFX_MANAGE_STATE(AfxGetStaticModuleState());
	CString str_send;
	TCHAR   *tcIn=(TCHAR *)pBufIn;

	switch (dwCode) {
		// 
		// IOCTLs to handle well-defined services.exe codes
		//
	
		// Control code sent to start a service (not the same as IOCTL_SERVICE_STARTED).
		case IOCTL_SERVICE_START:
	
		break;

		case IOCTL_SERVICE_REFRESH:
		case IOCTL_SERVICE_STOP: 
		break;

		case IOCTL_SERVICE_STATUS:	
		break;

		case IOCTL_SERVICE_CONTROL:	
		break;

		case IOCTL_SERVICE_STARTED:		
		break;

		case IOCTL_SERVICE_REGISTER_SOCKADDR: {
			return TRUE;
		}
		break;

		case IOCTL_SERVICE_DEREGISTER_SOCKADDR:
			// When our sockets are being disconnected this message is sent to us.
			return TRUE;
		break;

		case IOCTL_SERVICE_CONNECTION:

		
		break;
	}

	SetLastError(ERROR_INVALID_PARAMETER);
	return FALSE;
}


extern "C" DWORD  PASCAL EXPORT QZS_Seek (DWORD dwData, long pos, DWORD type) 
{
	AFX_MANAGE_STATE(AfxGetStaticModuleState());
	// We don't support seek -- return an error
	return (DWORD)-1;
}

extern "C" void PASCAL EXPORT QZS_PowerUp(void) 
{
	AFX_MANAGE_STATE(AfxGetStaticModuleState());
	return;
}

extern "C" void PASCAL EXPORT QZS_PowerDown(void) 
{
	AFX_MANAGE_STATE(AfxGetStaticModuleState());
	return;
}
//end service interface
/////////////////////////////////////////////////////////////////////
UINT ReadComeDataThread( LPVOID pParam )
{
	VariableList m_vList;
	int nGoCode, rc;

    hWnd = (HWND)pParam;
    while (1) 
	{
		printf("wait come date\n");
        nGoCode = WaitForSingleObject(m_hComeDataEvent, INFINITE);
        if (nGoCode == WAIT_OBJECT_0)
		{
			GetVariable((CommandVar*)m_pBuff);
			
			memset(&m_vList,0,sizeof(m_vList));

			m_vList.m_CommandId = m_cmd ;

		    m_vList.var.var_int1 = m_int1 ;
		    m_vList.var.var_int2 = m_int2 ;
		    m_vList.var.var_int3 = m_int3 ;
		    m_vList.var.var_int4 = m_int4 ;
		    m_vList.var.var_int5 = m_int5 ;
		    strcpy(m_vList.var.var_str1,m_str1) ;
		    strcpy(m_vList.var.var_str2,m_str2) ;
		    strcpy(m_vList.var.var_str3,m_str3) ;

			ComData_List.AddHead(m_vList) ;

			SetEvent(m_hWriteSerialEvent) ;

			SetEvent (m_hComeDataReadEndEvent);
        } 
		else 
		{
            rc = GetLastError();
        }
    }
	UnmapViewOfFile(m_pBuff);
	return 1;
}