Author: shawkins
Date: 2011-02-25 15:40:17 -0500 (Fri, 25 Feb 2011)
New Revision: 2948
Modified:
trunk/engine/src/test/java/org/teiid/dqp/internal/process/TestDQPCore.java
Log:
ensuring that timing issues will not affect unit test
Modified: trunk/engine/src/test/java/org/teiid/dqp/internal/process/TestDQPCore.java
===================================================================
--- trunk/engine/src/test/java/org/teiid/dqp/internal/process/TestDQPCore.java 2011-02-25
05:57:52 UTC (rev 2947)
+++ trunk/engine/src/test/java/org/teiid/dqp/internal/process/TestDQPCore.java 2011-02-25
20:40:17 UTC (rev 2948)
@@ -210,7 +210,7 @@
Thread.sleep(100);
}
assertEquals(ThreadState.IDLE, item.getThreadState());
- assertEquals(46, item.resultsBuffer.getRowCount());
+ assertTrue(item.resultsBuffer.getManagedRowCount() < 44);
//pull the rest of the results
for (int j = 0; j < 48; j++) {
item =
core.getRequestWorkItem(DQPWorkContext.getWorkContext().getRequestID(reqMsg.getExecutionId()));