Method serialStream2ThreadLoop

test/MultiThreadUnitTests.cpp:94–131

}

void
MultiThreadUnitTests::serialStream2ThreadLoop()
{
    const size_t threadLoopStartTimeMilliseconds = getTimeInMilliSeconds() ;
    size_t timeElapsedMilliSeconds = 0;

    while (timeElapsedMilliSeconds < timeOutMilliseconds)
    {
        //
        // Write data to the serial port. It should be received by the other
        // thread.
        //
        serialStream2 << writeString2 << std::endl;
        serialStream2.DrainWriteBuffer() ;

        //
        // Wait for data to arrive from the other thread
        //
        if (serialStream2.IsDataAvailable())
        {
            alarm(5) ;   // Set a system alarm in case getline() blocks longer than 5 seconds.
            readString1.clear() ;
            getline(serialStream2, readString1) ;
            alarm(0) ;   // Deactivate the alarm.

            if(readString1 != writeString1)
            {
                const std::lock_guard<std::mutex> lock {mutex} ;
                failureRate++;
            } 
        } 

        const std::lock_guard<std::mutex> lock {mutex} ;
        loopCount++;

        timeElapsedMilliSeconds = getTimeInMilliSeconds() - threadLoopStartTimeMilliseconds;
    }
}

void
MultiThreadUnitTests::serialPort1ThreadLoop()