Method serialPort2ThreadLoop

test/MultiThreadUnitTests.cpp:177–219

}

void
MultiThreadUnitTests::serialPort2ThreadLoop()
{
    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.
        //
        serialPort2.Write(writeString2 + '\n') ;
        serialPort2.DrainWriteBuffer() ;

        //
        // Wait for data to arrive from the other thread
        //
        if (serialPort2.IsDataAvailable())
        {
            try
            {
                readString1.clear() ;
                serialPort2.ReadLine(readString1, '\n', timeOutMilliseconds) ;
            }
            catch (const std::exception& err)
            {
                std::cerr << err.what() << std::endl ;
            }

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

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

        timeElapsedMilliSeconds = getTimeInMilliSeconds() - threadLoopStartTimeMilliseconds;
    }
}

void
MultiThreadUnitTests::testMultiThreadSerialStreamReadWrite()