Amy's world

unsigned int ThreadCom(LPVOID dParameter)
{
    CSerialCom* pObj = (CSerialCom*)dParameter;

    OVERLAPPED comReader;
    BYTE szBuff[BUFFER_SIZE];
    DWORD dwIndex,dwRead = 0; // bytes actually read 
    DWORD dwCommEvent;

    
    ZeroMemory(&comReader, sizeof(comReader));
    ZeroMemory(&szBuff, sizeof(szBuff));

    //Creating overlapped event handle
    comReader.hEvent = CreateEvent(NULL, TRUE, FALSE, NULL);
    SetCommMask(pObj->m_hComm, EV_RXCHAR);

    while(pObj->m_bConnect)
    {
        if(pObj->m_bWait == FALSE)
        {
            dwCommEvent = 0;

            WaitCommEvent(pObj->m_hComm, &dwCommEvent, &comReader);
            if(((dwCommEvent & EV_RXCHAR) == EV_RXCHAR)
                /*WaitForSingleObject(comReader.hEvent, INFINITE) == WAIT_OBJECT_0*/)
            {
                ZeroMemory(szBuff, sizeof(szBuff));

                do
                {
                    dwRead = pObj->ReadComm(szBuff, sizeof(szBuff));
                    if(dwRead > 0)
                    {
                        for(dwIndex = 0; dwIndex < dwRead; dwIndex++)
                        {
                            pObj->m_byBuffer[pObj->m_uiBufferCnt++] = (BYTE)szBuff[dwIndex];
                        }

                        pObj->m_pOwner->PostMessage(pObj->m_uiEvt, dwRead, 0);
                    }
                } while(dwRead > 0);
            }
           Sleep(20);                                                            // 스레드 휴식 (1초 = 1000)
        }
        Sleep(0);                                                                // 우선순위가 높거나 같은 다른 스레드에게 cpu사용권 넘어감
                                                                                    // 기다리고있는 스레드 없으면 아무 일 x
                                                                                    // starvation 발생 하지 않도록 하기 위한 방법
   }

    CloseHandle(comReader.hEvent);
    CloseHandle(pObj->m_hComm);

    pObj->m_hThreadCom = NULL;

    return 0;
}