import static org.junit.Assert.assertEquals;
import static org.junit.Assert.assertNotNull;
+import static org.junit.Assert.assertNull;
import static org.junit.Assert.assertTrue;
import org.junit.Test;
// Write should trigger an exception once the connector stops since the
// socket should be closed
assertNotNull(writeThread.getException());
+ assertNull(readThread.getException());
}
private boolean isCometSupported() {
}
assertTrue("The number of successful requests should have been 4-5, actual "+passcount,4==passcount || 5==passcount);
-
+ System.out.println("There were [" + connectfail + "] connection failures");
}
private static class ConnectThread extends Thread {
* 16 threads - ~45,600ms
*/
@Test
- public void testManagerBaseCreateSession() throws LifecycleException {
+ public void testManagerBaseCreateSession() {
doTestManagerBaseCreateSession(1, 1000000);
doTestManagerBaseCreateSession(2, 1000000);
doTestManagerBaseCreateSession(4, 1000000);
}
- private void doTestManagerBaseCreateSession(int threadCount, int iterCount)
- throws LifecycleException {
+ private void doTestManagerBaseCreateSession(int threadCount,
+ int iterCount) {
// Create a default session manager
StandardManager mgr = new StandardManager();