Searched refs:readThread (Results 1 – 3 of 3) sorted by relevance
27 static pthread_t readThread; variable251 int status = pthread_create(&readThread, NULL, readThreadRoutine, this); in StartReading()322 int status = pthread_join(readThread, &threadRetval); in RunTest()
862 Thread readThread = new Thread() { in sendOverPipe() local869 readThread.start(); in sendOverPipe()871 readThread.join(1000); in sendOverPipe()876 if (readThread.isAlive()) { in sendOverPipe()879 readThread.join(500); in sendOverPipe()
1662 Thread readThread = new Thread( in testActiveTransactionIsBlocking() local1671 readThread.start(); in testActiveTransactionIsBlocking()1672 readThread.join(500L); in testActiveTransactionIsBlocking()1674 readThread.isAlive()); in testActiveTransactionIsBlocking()1679 readThread.join(500L); in testActiveTransactionIsBlocking()1681 readThread.isAlive()); in testActiveTransactionIsBlocking()