Eclipse
/
jetty.project
mirror of https://github.com/jetty/jetty.project.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Avoided division by zero on single CPU boxes. 

git-svn-id: svn+ssh://dev.eclipse.org/svnroot/rt/org.eclipse.jetty/jetty/trunk@2934 7e9141cc-0065-0410-87d8-b60c137991c4
This commit is contained in:
Simone Bordet 2011-03-30 13:23:41 +00:00
parent 51f21301d6
commit e9e7a72b08
1 changed files with 6 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
jetty-server/src/test/java/org/eclipse/jetty/server/StressTest.java
View File

@ -13,16 +13,12 @@
package org.eclipse.jetty.server; package org.eclipse.jetty.server;
import static org.junit.Assert.assertEquals;
import static org.junit.Assert.assertTrue;
import java.io.IOException; import java.io.IOException;
import java.net.Socket; import java.net.Socket;
import java.util.Queue; import java.util.Queue;
import java.util.Random; import java.util.Random;
import java.util.concurrent.ConcurrentLinkedQueue; import java.util.concurrent.ConcurrentLinkedQueue;
import java.util.concurrent.atomic.AtomicInteger; import java.util.concurrent.atomic.AtomicInteger;
import javax.servlet.ServletException; import javax.servlet.ServletException;
import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse; import javax.servlet.http.HttpServletResponse;
@ -39,6 +35,9 @@ import org.junit.Before;
import org.junit.BeforeClass; import org.junit.BeforeClass;
import org.junit.Test; import org.junit.Test;
import static org.junit.Assert.assertEquals;
import static org.junit.Assert.assertTrue;
public class StressTest public class StressTest
{ {
private static QueuedThreadPool _threads; private static QueuedThreadPool _threads;
@ -86,7 +85,7 @@ public class StressTest
_server.setThreadPool(_threads); _server.setThreadPool(_threads);
_connector = new SelectChannelConnector(); _connector = new SelectChannelConnector();
_connector.setAcceptors(Runtime.getRuntime().availableProcessors()/2); _connector.setAcceptors(Math.max(1, Runtime.getRuntime().availableProcessors() / 2));
_connector.setAcceptQueueSize(5000); _connector.setAcceptQueueSize(5000);
_connector.setMaxIdleTime(30000); _connector.setMaxIdleTime(30000);
_server.addConnector(_connector); _server.addConnector(_connector);
@ -244,7 +243,7 @@ public class StressTest
final int other[] = new int[_latencies.length]; final int other[] = new int[_latencies.length];
long total=0; long total=0;
for (int i=0;i<_latencies.length;i++) for (int i=0;i<_latencies.length;i++)
{ {
Queue<Long> latencies=_latencies[i]; Queue<Long> latencies=_latencies[i];
@ -264,7 +263,7 @@ public class StressTest
} }
} }
other[i]++; other[i]++;
} }
} }