Author: pferraro Date: 2008-09-22 23:56:50 -0400 (Mon, 22 Sep 2008) New Revision: 1882 Added: trunk/mod_cluster/src/demo/java/org/jboss/modcluster/demo/servlet/BusyConnectorsLoadServlet.java Removed: trunk/mod_cluster/src/demo/java/org/jboss/modcluster/demo/servlet/BusyConnectorsServlet.java Log: Renamed Copied: trunk/mod_cluster/src/demo/java/org/jboss/modcluster/demo/servlet/BusyConnectorsLoadServlet.java (from rev 1876, trunk/mod_cluster/src/demo/java/org/jboss/modcluster/demo/servlet/BusyConnectorsServlet.java) =================================================================== --- trunk/mod_cluster/src/demo/java/org/jboss/modcluster/demo/servlet/BusyConnectorsLoadServlet.java (rev 0) +++ trunk/mod_cluster/src/demo/java/org/jboss/modcluster/demo/servlet/BusyConnectorsLoadServlet.java 2008-09-23 03:56:50 UTC (rev 1882) @@ -0,0 +1,111 @@ +/* + * JBoss, Home of Professional Open Source. + * Copyright 2008, Red Hat Middleware LLC, and individual contributors + * as indicated by the @author tags. See the copyright.txt file in the + * distribution for a full listing of individual contributors. + * + * This is free software; you can redistribute it and/or modify it + * under the terms of the GNU Lesser General Public License as + * published by the Free Software Foundation; either version 2.1 of + * the License, or (at your option) any later version. + * + * This software is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU + * Lesser General Public License for more details. + * + * You should have received a copy of the GNU Lesser General Public + * License along with this software; if not, write to the Free + * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA + * 02110-1301 USA, or see the FSF site: http://www.fsf.org. + */ +package org.jboss.modcluster.demo.servlet; + +import java.io.IOException; +import java.util.Collections; + +import javax.servlet.http.HttpServletRequest; +import javax.servlet.http.HttpServletResponse; + +import org.apache.commons.httpclient.HttpClient; +import org.apache.commons.httpclient.HttpException; +import org.apache.commons.httpclient.HttpMethod; +import org.apache.commons.httpclient.MultiThreadedHttpConnectionManager; +import org.apache.commons.httpclient.methods.HeadMethod; + +/** + * @author Paul Ferraro + * + */ +public class BusyConnectorsLoadServlet extends LoadServlet +{ + /** The serialVersionUID */ + private static final long serialVersionUID = -946741803216943778L; + + private static final String END = "end"; + + /** + * @{inheritDoc} + * @see javax.servlet.http.HttpServlet#service(javax.servlet.http.HttpServletRequest, javax.servlet.http.HttpServletResponse) + */ + @Override + protected void service(HttpServletRequest request, HttpServletResponse response) throws IOException + { + String parameter = request.getParameter(END); + + if (parameter == null) + { + int duration = Integer.parseInt(this.getParameter(request, DURATION, "15")) * 1000; + + long end = System.currentTimeMillis() + duration; + + HttpClient client = new HttpClient(new MultiThreadedHttpConnectionManager()); + HttpMethod method = new HeadMethod(this.createLocalURL(request, Collections.singletonMap(END, String.valueOf(end)))); + Runnable task = new ExecuteMethodTask(client, method); + + int count = Integer.parseInt(this.getParameter(request, COUNT, "50")); + + for (int i = 0; i < count; ++i) + { + new Thread(task).start(); + } + } + else + { + long end = Long.parseLong(parameter); + + if (end < System.currentTimeMillis()) + { + response.sendRedirect(response.encodeRedirectURL(this.createLocalURL(request, Collections.singletonMap(END, String.valueOf(end))))); + } + } + } + + private class ExecuteMethodTask implements Runnable + { + private final HttpClient client; + private final HttpMethod method; + + ExecuteMethodTask(HttpClient client, HttpMethod method) + { + this.client = client; + this.method = method; + } + + public void run() + { + try + { + this.client.executeMethod(this.method); + } + catch (HttpException e) + { + BusyConnectorsLoadServlet.this.log(e.getMessage(), e); + } + catch (IOException e) + { + BusyConnectorsLoadServlet.this.log(e.getMessage(), e); + } + } + } +} Property changes on: trunk/mod_cluster/src/demo/java/org/jboss/modcluster/demo/servlet/BusyConnectorsLoadServlet.java ___________________________________________________________________ Name: svn:mergeinfo + Deleted: trunk/mod_cluster/src/demo/java/org/jboss/modcluster/demo/servlet/BusyConnectorsServlet.java =================================================================== --- trunk/mod_cluster/src/demo/java/org/jboss/modcluster/demo/servlet/BusyConnectorsServlet.java 2008-09-22 16:12:40 UTC (rev 1881) +++ trunk/mod_cluster/src/demo/java/org/jboss/modcluster/demo/servlet/BusyConnectorsServlet.java 2008-09-23 03:56:50 UTC (rev 1882) @@ -1,111 +0,0 @@ -/* - * JBoss, Home of Professional Open Source. - * Copyright 2008, Red Hat Middleware LLC, and individual contributors - * as indicated by the @author tags. See the copyright.txt file in the - * distribution for a full listing of individual contributors. - * - * This is free software; you can redistribute it and/or modify it - * under the terms of the GNU Lesser General Public License as - * published by the Free Software Foundation; either version 2.1 of - * the License, or (at your option) any later version. - * - * This software is distributed in the hope that it will be useful, - * but WITHOUT ANY WARRANTY; without even the implied warranty of - * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU - * Lesser General Public License for more details. - * - * You should have received a copy of the GNU Lesser General Public - * License along with this software; if not, write to the Free - * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA - * 02110-1301 USA, or see the FSF site: http://www.fsf.org. - */ -package org.jboss.modcluster.demo.servlet; - -import java.io.IOException; -import java.util.Collections; - -import javax.servlet.http.HttpServletRequest; -import javax.servlet.http.HttpServletResponse; - -import org.apache.commons.httpclient.HttpClient; -import org.apache.commons.httpclient.HttpException; -import org.apache.commons.httpclient.HttpMethod; -import org.apache.commons.httpclient.MultiThreadedHttpConnectionManager; -import org.apache.commons.httpclient.methods.HeadMethod; - -/** - * @author Paul Ferraro - * - */ -public class BusyConnectorsServlet extends LoadServlet -{ - /** The serialVersionUID */ - private static final long serialVersionUID = -946741803216943778L; - - private static final String END = "end"; - - /** - * @{inheritDoc} - * @see javax.servlet.http.HttpServlet#service(javax.servlet.http.HttpServletRequest, javax.servlet.http.HttpServletResponse) - */ - @Override - protected void service(HttpServletRequest request, HttpServletResponse response) throws IOException - { - String parameter = request.getParameter(END); - - if (parameter == null) - { - int duration = Integer.parseInt(this.getParameter(request, DURATION, "15")) * 1000; - - long end = System.currentTimeMillis() + duration; - - HttpClient client = new HttpClient(new MultiThreadedHttpConnectionManager()); - HttpMethod method = new HeadMethod(this.createLocalURL(request, Collections.singletonMap(END, String.valueOf(end)))); - Runnable task = new ExecuteMethodTask(client, method); - - int count = Integer.parseInt(this.getParameter(request, COUNT, "50")); - - for (int i = 0; i < count; ++i) - { - new Thread(task).start(); - } - } - else - { - long end = Long.parseLong(parameter); - - if (end < System.currentTimeMillis()) - { - response.sendRedirect(response.encodeRedirectURL(this.createLocalURL(request, Collections.singletonMap(END, String.valueOf(end))))); - } - } - } - - private class ExecuteMethodTask implements Runnable - { - private final HttpClient client; - private final HttpMethod method; - - ExecuteMethodTask(HttpClient client, HttpMethod method) - { - this.client = client; - this.method = method; - } - - public void run() - { - try - { - this.client.executeMethod(this.method); - } - catch (HttpException e) - { - BusyConnectorsServlet.this.log(e.getMessage(), e); - } - catch (IOException e) - { - BusyConnectorsServlet.this.log(e.getMessage(), e); - } - } - } -}