tomcat-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From fha...@apache.org
Subject svn commit: r1051335 - /tomcat/trunk/test/org/apache/catalina/connector/TestMaxConnections.java
Date Tue, 21 Dec 2010 00:24:25 GMT
Author: fhanik
Date: Tue Dec 21 00:24:24 2010
New Revision: 1051335

URL: http://svn.apache.org/viewvc?rev=1051335&view=rev
Log:
Test can piggy back on the 'ant test' auto switch between connectors


Modified:
    tomcat/trunk/test/org/apache/catalina/connector/TestMaxConnections.java

Modified: tomcat/trunk/test/org/apache/catalina/connector/TestMaxConnections.java
URL: http://svn.apache.org/viewvc/tomcat/trunk/test/org/apache/catalina/connector/TestMaxConnections.java?rev=1051335&r1=1051334&r2=1051335&view=diff
==============================================================================
--- tomcat/trunk/test/org/apache/catalina/connector/TestMaxConnections.java (original)
+++ tomcat/trunk/test/org/apache/catalina/connector/TestMaxConnections.java Tue Dec 21 00:24:24
2010
@@ -27,46 +27,25 @@ import org.apache.catalina.Context;
 import org.apache.catalina.startup.SimpleHttpClient;
 import org.apache.catalina.startup.Tomcat;
 import org.apache.catalina.startup.TomcatBaseTest;
-import org.apache.coyote.http11.Http11NioProtocol;
-import org.apache.coyote.http11.Http11Protocol;
+import org.apache.juli.logging.LogFactory;
+import org.apache.juli.logging.Log;
 
 public class TestMaxConnections extends TomcatBaseTest{
-
+    private static Log log = LogFactory.getLog(TestMaxConnections.class);
     static int soTimeout = 3000;
     static int connectTimeout = 1000;
     
-    @Override
-    public void setUp() throws Exception {
-        //do nothing
-    }
     
-    public void testBio() throws Exception {
-        init(Http11Protocol.class.getName());
+    public void testConnector() throws Exception {
+        init();
         ConnectThread[] t = new ConnectThread[10];
         int passcount = 0;
         int connectfail = 0;
         for (int i=0; i<t.length; i++) {
             t[i] = new ConnectThread();
-            t[i].setName("ConnectThread["+i+"+]");
-            t[i].start();
-        }
-        for (int i=0; i<t.length; i++) {
-            t[i].join();
-            if (t[i].passed) passcount++;
-            if (t[i].connectfailed) connectfail++;
+            t[i].setName("ConnectThread["+i+"]");
         }
-        assertEquals("The number of successful requests should have been 5.",5, passcount);
-        assertEquals("The number of failed connects should have been 5.",5, connectfail);
-    }
-    
-    public void testNio() throws Exception {
-        init(Http11NioProtocol.class.getName());
-        ConnectThread[] t = new ConnectThread[10];
-        int passcount = 0;
-        int connectfail = 0;
         for (int i=0; i<t.length; i++) {
-            t[i] = new ConnectThread();
-            t[i].setName("ConnectThread["+i+"+]");
             t[i].start();
         }
         for (int i=0; i<t.length; i++) {
@@ -88,28 +67,26 @@ public class TestMaxConnections extends 
                 client.doHttp10Request();
             }catch (Exception x) {
                 passed = false;
-                System.err.println(Thread.currentThread().getName()+" Error:"+x.getMessage());
+                log.error(Thread.currentThread().getName()+" Error:"+x.getMessage());
                 connectfailed = "connect timed out".equals(x.getMessage()) || "Connection
refused: connect".equals(x.getMessage());
             }
         }
     }
 
     
-    private synchronized void init(String protocol) throws Exception {
-        System.setProperty("tomcat.test.protocol", protocol);
-        super.setUp();
+    private synchronized void init() throws Exception {
         Tomcat tomcat = getTomcatInstance();
         Context root = tomcat.addContext("", SimpleHttpClient.TEMP_DIR);
         Tomcat.addServlet(root, "Simple", new SimpleServlet());
         root.addServletMapping("/test", "Simple");
         tomcat.getConnector().setProperty("maxKeepAliveRequests", "1");
+        tomcat.getConnector().setProperty("maxThreads", "10");
         tomcat.getConnector().setProperty("soTimeout", "20000");
         tomcat.getConnector().setProperty("keepAliveTimeout", "50000");
         tomcat.getConnector().setProperty("port", "8080");
         tomcat.getConnector().setProperty("maxConnections", "4");
         tomcat.getConnector().setProperty("acceptCount", "1");
         tomcat.start();
-        Thread.sleep(5000);
     }
 
     private class TestClient extends SimpleHttpClient {
@@ -128,7 +105,7 @@ public class TestMaxConnections extends 
             boolean passed = false;
             processRequest(false); // blocks until response has been read
             long stop = System.currentTimeMillis();
-            System.out.println(Thread.currentThread().getName()+" Request complete:"+(stop-start)+"
ms.");
+            log.info(Thread.currentThread().getName()+" Request complete:"+(stop-start)+"
ms.");
             passed = (this.readLine()==null);
             // Close the connection
             disconnect();



---------------------------------------------------------------------
To unsubscribe, e-mail: dev-unsubscribe@tomcat.apache.org
For additional commands, e-mail: dev-help@tomcat.apache.org


Mime
View raw message