[Win32/C]Threaded serial code

[elleP]

Ik probeer op de nette manier een seriele poort uit te lezen onder windows. Dit lukt even (+- 30 sec) , daarna krijg ik een error 1814 (NOT ENOUGH QUOTA). Ook trekt mijn progje 100% cpu, terwijl WaitCommEvent dit niet zou moeten doen. Ook gooit dit m'n hele netwerk overhoop, putty geeft bv. ook een melding dat er niet genoeg bufferruimte beschikbaar is.

Ik heb al heel wat zitten klooien met dingen als WaitForSingleObject maar ik kom er niet uit.

code:

//this code opens the comport
BOOL openComport(HWND hwnd,char *name,int baud, HANDLE *port)
{
    closeComport(hwnd, port);
    // Open the serial port.
    *port = CreateFile (name, // Pointer to the name of the port
                        GENERIC_READ | GENERIC_WRITE,
                        // Access (read-write) mode
                        0,              // Share mode
                        NULL,           // Pointer to the security attribute
                        OPEN_EXISTING,  // How to open the serial port
                        FILE_FLAG_OVERLAPPED,              // Port attributes
                        NULL);          // Handle to port with attribute
    // to copy

    //if (port == INVALID_HANDLE_VALUE)
    //    MessageBox (hwnd, TEXT("Error creating port handle"), TEXT("Error"), MB_OK);

    DCB PortDCB;

    // Initialize the DCBlength member.
    PortDCB.DCBlength = sizeof (DCB);

    // Get the default port setting information.
    GetCommState (*port, &PortDCB);

    // Change the DCB structure settings.
    PortDCB.BaudRate = baud;              // Current baud
    PortDCB.fBinary = TRUE;               // Binary mode; no EOF check
    PortDCB.fParity = TRUE;               // Enable parity checking
    PortDCB.fOutxCtsFlow = FALSE;         // No CTS output flow control
    PortDCB.fOutxDsrFlow = FALSE;         // No DSR output flow control
    PortDCB.fDtrControl = DTR_CONTROL_ENABLE;
    // DTR flow control type
    PortDCB.fDsrSensitivity = FALSE;      // DSR sensitivity
    PortDCB.fTXContinueOnXoff = TRUE;     // XOFF continues Tx
    PortDCB.fOutX = FALSE;                // No XON/XOFF out flow control
    PortDCB.fInX = FALSE;                 // No XON/XOFF in flow control
    PortDCB.fErrorChar = FALSE;           // Disable error replacement
    PortDCB.fNull = FALSE;                // Disable null stripping
    PortDCB.fRtsControl = RTS_CONTROL_ENABLE;
    // RTS flow control
    PortDCB.fAbortOnError = FALSE;        // Do not abort reads/writes on
    PortDCB.EvtChar = '\r';               // event when \r is recieved

    // error
    PortDCB.ByteSize = 8;                 // Number of bits/byte, 4-8
    PortDCB.Parity = NOPARITY;            // 0-4=no,odd,even,mark,space
    PortDCB.StopBits = ONESTOPBIT;        // 0,1,2 = 1, 1.5, 2

    // Configure the port according to the specifications of the DCB
    // structure.
    if (!SetCommState (*port, &PortDCB))
    {
        // Could not configure the serial port.
        //dwError = GetLastError ();
        MessageBox (hwnd, TEXT("Unable to configure the serial port"),
                    TEXT("Error"), MB_OK);
        //close the port
        closeComport(hwnd,port);
        return false;
    }

    // Retrieve the timeout parameters for all read and write operations
    // on the port.
    COMMTIMEOUTS CommTimeouts;
    GetCommTimeouts (*port, &CommTimeouts);

    // Change the COMMTIMEOUTS structure settings.
    CommTimeouts.ReadIntervalTimeout = MAXDWORD;
    CommTimeouts.ReadTotalTimeoutMultiplier = 1;
    CommTimeouts.ReadTotalTimeoutConstant = 1;
    CommTimeouts.WriteTotalTimeoutMultiplier = 1;
    CommTimeouts.WriteTotalTimeoutConstant = 1;

    // Set the timeout parameters for all read and write operations
    // on the port.
    if (!SetCommTimeouts (*port, &CommTimeouts))
    {
        // Could not set the timeout parameters.
        MessageBox (hwnd, TEXT("Unable to set the timeout parameters, closing Comport"),
                    TEXT("Error"), MB_OK);
        //close the port
        closeComport(hwnd,port);
        return false;
    }

    if (!SetCommMask(*port,EV_RXCHAR) )
    {
        DWORD error = GetLastError();
        MessageBox (hwnd, TEXT("Unable to set the commask parameters, closing Comport"),
                    TEXT("Error"), MB_OK);
        //close the port
        //closeComport(mainhwnd,&port);
        return false;
    }

    //all is ok

    DWORD dwThreadId;
    DWORD frits;
    LPDWORD henk = &frits;
    //PMYDATA pData;
    //    pData = (PMYDATA) HeapAlloc(GetProcessHeap(),
              //  HEAP_ZERO_MEMORY, sizeof(MYDATA));

    HANDLE hThread = CreateThread(
            NULL,              // default security attributes
            0,                 // use default stack size
            ThreadProc,        // thread function
            henk,             // argument to thread function
            0,                 // use default creation flags
            &dwThreadId);   // returns the thread identifier


    return true;
}


DWORD WINAPI ThreadProc(LPVOID lpParam)
{
/********************************************************************/
/**THREAD CODE*******************************************************/

    //CSerialCommHelper* apThis = (CSerialCommHelper*) pvParam ;
    DWORD dwEventMask=0;

    OVERLAPPED ov;
    memset(&ov,0,sizeof(ov));
    ov.hEvent = CreateEvent( 0,true,0,0);
    //HANDLE arHandles[2];
    //arHandles[0] = apThis->m_hThreadTerm;

    DWORD dwWait;
    //SetEvent(apThis->m_hThreadStarted);
    while (  testerPort != NULL )
    {
        //Sleep(1);


        BOOL abRet = WaitCommEvent(testerPort,&dwEventMask, &ovNULL) ;
        //WaitForSingleObject(ov.hEvent,INFINITE);

        DWORD error = GetLastError();
        if ( !abRet && error != 997 )
        {
            char buf[33];
            char errormsg[1024];
            itoa (error,buf,10);
            strcpy(errormsg,"Transmission Error: ");
            strcat(errormsg,buf);


            MessageBox (mainHwnd, errormsg,
                        TEXT("Error"), MB_OK);
            closeComport(mainHwnd,&testerPort);
            break;
        }
        {
            OVERLAPPED rov;
            memset(&rov,0,sizeof(ov));
            rov.hEvent = CreateEvent( 0,true,0,0);
            ResetEvent( rov.hEvent  );

            DWORD dwBytesRecieved=0;
            DWORD dwBytesPeeked=0;
            //set time

            //repeat if no byte is read
            //read the file
            char text[1024];
            char byte[2];
            memset(text,0,1024);
            int len  =0;


            do
            {
            ReadFile (testerPort,                   // Port handle
                    &byte,                  // Pointer to data to read
                    1,                      // Number of bytes to read
                    &dwBytesRecieved,    // Pointer to number of bytesread
                    /*&rov */NULL                   // Must be NULL for Windows CE
                    );

            if ( !abRet && error != 997 )
            {
                char buf[33];
                char errormsg[1024];
                itoa (error,buf,10);
                strcpy(errormsg,"Transmission Error: ");
                strcat(errormsg,buf);


                MessageBox (mainHwnd, errormsg,
                            TEXT("Error 2"), MB_OK);
                closeComport(mainHwnd,&testerPort);
            }

            ResetEvent ( ov.hEvent );

            len++;
            strcat(text,byte);
            }
            while (dwBytesRecieved > 0 &&  !(len >2 && text[len-2] == '\n' && text[len-1 == '\r']));

            if (dwBytesRecieved != 0)
            {
                parseMessage(mainHwnd,text);
                //SendDlgItemMessage(mainHwnd, IDC_RECIEVE, LB_INSERTSTRING, 0, (LPARAM)text);
                PostMessage(mainHwnd,SERIAL_EVENT,dwEventMask,error);
            }
        }
        ResetEvent ( ov.hEvent );
    }
/********************************************************************/
    // Free the memory allocated by the caller for the thread
    // data structure.
    return 0;
}

[RobIII]

Ja, helaas. Zo werkt het hier niet. Het is niet de bedoeling dat je (kort) je probleem omschrijft en dan een lap code dumpt zodat wij mogen gaan staren waar de fout zit.

Geef op z'n minst enkel de relevante stukken code en geef aan waar je verwacht dat de fout zit. Geef ook aan wat je al hebt geprobeerd (heb je al gedebugged?) enz.

Kijk even, voor meer info, naar de volgende pagina's:
Programming Beleid Quickstart - Zo zien we graag topics in PRG
Debuggen: Hoe doe ik dat? - Mss handig voor je

Tevens geven wij geen support op code van derden; deze code is 1 op 1 'geleend' Als je daar support op wil moet je de makers maar even mailen.

[ Voor 18% gewijzigd door RobIII op 24-04-2007 10:16 ]