Author: pferraro
Date: 2009-05-18 11:13:48 -0400 (Mon, 18 May 2009)
New Revision: 2428
Modified:
trunk/mod_cluster/src/demo/java/org/jboss/modcluster/demo/servlet/ActiveSessionsLoadServlet.java
trunk/mod_cluster/src/demo/java/org/jboss/modcluster/demo/servlet/BusyConnectorsLoadServlet.java
trunk/mod_cluster/src/demo/java/org/jboss/modcluster/demo/servlet/ConnectionPoolLoadServlet.java
trunk/mod_cluster/src/demo/java/org/jboss/modcluster/demo/servlet/HeapMemoryLoadServlet.java
trunk/mod_cluster/src/demo/java/org/jboss/modcluster/demo/servlet/ReceiveTrafficLoadServlet.java
trunk/mod_cluster/src/demo/java/org/jboss/modcluster/demo/servlet/RequestCountLoadServlet.java
trunk/mod_cluster/src/demo/java/org/jboss/modcluster/demo/servlet/SendTrafficLoadServlet.java
trunk/mod_cluster/src/demo/java/org/jboss/modcluster/demo/servlet/SystemLoadServlet.java
Log:
Add detailed logging
Modified:
trunk/mod_cluster/src/demo/java/org/jboss/modcluster/demo/servlet/ActiveSessionsLoadServlet.java
===================================================================
---
trunk/mod_cluster/src/demo/java/org/jboss/modcluster/demo/servlet/ActiveSessionsLoadServlet.java 2009-05-17
20:45:35 UTC (rev 2427)
+++
trunk/mod_cluster/src/demo/java/org/jboss/modcluster/demo/servlet/ActiveSessionsLoadServlet.java 2009-05-18
15:13:48 UTC (rev 2428)
@@ -25,6 +25,7 @@
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
+import javax.servlet.http.HttpSession;
import org.apache.commons.httpclient.HttpClient;
import org.apache.commons.httpclient.HttpMethod;
@@ -46,7 +47,8 @@
@Override
protected void doHead(HttpServletRequest request, HttpServletResponse response)
{
- request.getSession(true);
+ HttpSession session = request.getSession(true);
+ this.log("Handling session load request from: " +
request.getRequestURL().toString() + ", using session id: " + session.getId());
}
/**
@@ -58,6 +60,10 @@
{
int count = Integer.parseInt(this.getParameter(request, COUNT, "20"));
+ String url = this.createLocalURL(request, null);
+
+ this.log("Sending " + count + " requests to: " + url);
+
for (int i = 0; i < count; ++i)
{
HttpClient client = new HttpClient();
Modified:
trunk/mod_cluster/src/demo/java/org/jboss/modcluster/demo/servlet/BusyConnectorsLoadServlet.java
===================================================================
---
trunk/mod_cluster/src/demo/java/org/jboss/modcluster/demo/servlet/BusyConnectorsLoadServlet.java 2009-05-17
20:45:35 UTC (rev 2427)
+++
trunk/mod_cluster/src/demo/java/org/jboss/modcluster/demo/servlet/BusyConnectorsLoadServlet.java 2009-05-18
15:13:48 UTC (rev 2428)
@@ -63,6 +63,8 @@
int count = Integer.parseInt(this.getParameter(request, COUNT,
"50"));
+ this.log("Sending " + count + " concurrent requests to: " +
url);
+
for (int i = 0; i < count; ++i)
{
new Thread(task).start();
@@ -73,6 +75,8 @@
else
{
long end = Long.parseLong(parameter);
+
+ this.log("Handling busy connector request from: " +
request.getRequestURL().toString());
if (end < System.currentTimeMillis())
{
Modified:
trunk/mod_cluster/src/demo/java/org/jboss/modcluster/demo/servlet/ConnectionPoolLoadServlet.java
===================================================================
---
trunk/mod_cluster/src/demo/java/org/jboss/modcluster/demo/servlet/ConnectionPoolLoadServlet.java 2009-05-17
20:45:35 UTC (rev 2427)
+++
trunk/mod_cluster/src/demo/java/org/jboss/modcluster/demo/servlet/ConnectionPoolLoadServlet.java 2009-05-18
15:13:48 UTC (rev 2428)
@@ -64,6 +64,8 @@
String user = this.getParameter(request, USER, null);
String password = this.getParameter(request, PASSWORD, null);
+ this.log("Acquiring " + count + " database connections to: "
+ name);
+
List<Connection> connections = new ArrayList<Connection>(count);
try
@@ -81,6 +83,8 @@
}
finally
{
+ this.log("Closing " + count + " database connections to:
" + name);
+
for (Connection connection: connections)
{
try
Modified:
trunk/mod_cluster/src/demo/java/org/jboss/modcluster/demo/servlet/HeapMemoryLoadServlet.java
===================================================================
---
trunk/mod_cluster/src/demo/java/org/jboss/modcluster/demo/servlet/HeapMemoryLoadServlet.java 2009-05-17
20:45:35 UTC (rev 2427)
+++
trunk/mod_cluster/src/demo/java/org/jboss/modcluster/demo/servlet/HeapMemoryLoadServlet.java 2009-05-18
15:13:48 UTC (rev 2428)
@@ -39,6 +39,8 @@
/** The serialVersionUID */
private static final long serialVersionUID = -8183119455180366670L;
+ private static final int MB = 1024 * 1024;
+
/**
* @{inheritDoc}
* @see javax.servlet.http.HttpServlet#service(javax.servlet.http.HttpServletRequest,
javax.servlet.http.HttpServletResponse)
@@ -59,6 +61,10 @@
// Reserve half the available free memory
long reserve = free / 2;
+ this.log((total / MB) + "MB total memory");
+ this.log((free / MB) + "MB free memory");
+ this.log("Reserving " + (reserve / MB) + "MB of memory");
+
List<Object> list = new ArrayList<Object>(2);
if (free > Integer.MAX_VALUE)
@@ -78,6 +84,8 @@
Thread.currentThread().interrupt();
}
+ this.log("Freeing " + (reserve / MB) + "MB of memory");
+
list.clear();
System.gc();
Modified:
trunk/mod_cluster/src/demo/java/org/jboss/modcluster/demo/servlet/ReceiveTrafficLoadServlet.java
===================================================================
---
trunk/mod_cluster/src/demo/java/org/jboss/modcluster/demo/servlet/ReceiveTrafficLoadServlet.java 2009-05-17
20:45:35 UTC (rev 2427)
+++
trunk/mod_cluster/src/demo/java/org/jboss/modcluster/demo/servlet/ReceiveTrafficLoadServlet.java 2009-05-18
15:13:48 UTC (rev 2428)
@@ -50,16 +50,20 @@
{
int duration = Integer.parseInt(this.getParameter(request, DURATION,
DEFAULT_DURATION));
- int size = Integer.parseInt(this.getParameter(request, SIZE, "100")) *
1000;
+ int size = Integer.parseInt(this.getParameter(request, SIZE, "100")) *
1024;
HttpClient client = new HttpClient();
RequestEntity entity = new ByteArrayRequestEntity(new byte[size]);
+ String url = this.createLocalURL(request, null);
+
for (int i = 0; i < duration; ++i)
{
long start = System.currentTimeMillis();
- PutMethod method = new PutMethod(this.createLocalURL(request, null));
+ this.log("Sending " + (size / 1024) + "KB packet to: " +
url);
+
+ PutMethod method = new PutMethod(url);
method.setRequestEntity(entity);
client.executeMethod(method);
Modified:
trunk/mod_cluster/src/demo/java/org/jboss/modcluster/demo/servlet/RequestCountLoadServlet.java
===================================================================
---
trunk/mod_cluster/src/demo/java/org/jboss/modcluster/demo/servlet/RequestCountLoadServlet.java 2009-05-17
20:45:35 UTC (rev 2427)
+++
trunk/mod_cluster/src/demo/java/org/jboss/modcluster/demo/servlet/RequestCountLoadServlet.java 2009-05-18
15:13:48 UTC (rev 2428)
@@ -47,7 +47,11 @@
if (count > 1)
{
- response.sendRedirect(this.createLocalURL(request,
Collections.singletonMap(COUNT, String.valueOf(count - 1))));
+ String url = this.createLocalURL(request, Collections.singletonMap(COUNT,
String.valueOf(count - 1)));
+
+ this.log("Sending request count redirect to: " + url);
+
+ response.sendRedirect(url);
}
else
{
Modified:
trunk/mod_cluster/src/demo/java/org/jboss/modcluster/demo/servlet/SendTrafficLoadServlet.java
===================================================================
---
trunk/mod_cluster/src/demo/java/org/jboss/modcluster/demo/servlet/SendTrafficLoadServlet.java 2009-05-17
20:45:35 UTC (rev 2427)
+++
trunk/mod_cluster/src/demo/java/org/jboss/modcluster/demo/servlet/SendTrafficLoadServlet.java 2009-05-18
15:13:48 UTC (rev 2428)
@@ -49,8 +49,10 @@
@Override
protected void doPost(HttpServletRequest request, HttpServletResponse response) throws
ServletException, IOException
{
- int size = Integer.parseInt(request.getParameter(SIZE)) * 1000;
+ int size = Integer.parseInt(request.getParameter(SIZE)) * 1024;
+ this.log("Writing " + (size / 1024) + "KB blob to response for:
" + request.getRequestURL().toString());
+
response.getOutputStream().write(new byte[size]);
response.flushBuffer();
}
@@ -65,12 +67,15 @@
int duration = Integer.parseInt(this.getParameter(request, DURATION,
DEFAULT_DURATION));
String size = this.getParameter(request, SIZE, "100");
+ String url = this.createLocalURL(request, Collections.singletonMap(SIZE, size));
HttpClient client = new HttpClient();
- HttpMethod method = new PostMethod(this.createLocalURL(request,
Collections.singletonMap(SIZE, size)));
+ HttpMethod method = new PostMethod(url);
for (int i = 0; i < duration; ++i)
{
+ this.log("Sending send traffic load request to: " + url);
+
long start = System.currentTimeMillis();
client.executeMethod(method);
Modified:
trunk/mod_cluster/src/demo/java/org/jboss/modcluster/demo/servlet/SystemLoadServlet.java
===================================================================
---
trunk/mod_cluster/src/demo/java/org/jboss/modcluster/demo/servlet/SystemLoadServlet.java 2009-05-17
20:45:35 UTC (rev 2427)
+++
trunk/mod_cluster/src/demo/java/org/jboss/modcluster/demo/servlet/SystemLoadServlet.java 2009-05-18
15:13:48 UTC (rev 2428)
@@ -46,6 +46,8 @@
int duration = Integer.parseInt(this.getParameter(request, DURATION,
"15")) * 1000;
+ this.log("Begin handling system load request");
+
// Naughty loop
while (System.currentTimeMillis() - start < duration)
{
@@ -62,6 +64,8 @@
}
}
+ this.log("End handling system load request");
+
this.writeLocalName(request, response);
}
}
\ No newline at end of file