camel-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From cmuel...@apache.org
Subject svn commit: r1429327 - in /camel/trunk/tests/camel-performance/src/test/java/org/apache/camel/test/perf: ./ esb/
Date Sat, 05 Jan 2013 16:40:54 GMT
Author: cmueller
Date: Sat Jan  5 16:40:53 2013
New Revision: 1429327

URL: http://svn.apache.org/viewvc?rev=1429327&view=rev
Log:
CAMEL-5918: Add performance tests - work in progress

Modified:
    camel/trunk/tests/camel-performance/src/test/java/org/apache/camel/test/perf/SplitterPerformanceTest.java
    camel/trunk/tests/camel-performance/src/test/java/org/apache/camel/test/perf/esb/AbstractBaseEsbPerformanceIntegrationTest.java
    camel/trunk/tests/camel-performance/src/test/java/org/apache/camel/test/perf/esb/CbrEsbPerformanceIntegrationTest.java
    camel/trunk/tests/camel-performance/src/test/java/org/apache/camel/test/perf/esb/EchoService.java
    camel/trunk/tests/camel-performance/src/test/java/org/apache/camel/test/perf/esb/HttpHbrEsbPerformanceIntegrationTest.java
    camel/trunk/tests/camel-performance/src/test/java/org/apache/camel/test/perf/esb/ProxyEsbPerformanceIntegrationTest.java
    camel/trunk/tests/camel-performance/src/test/java/org/apache/camel/test/perf/esb/SecureProxyEsbPerformanceIntegrationTest.java
    camel/trunk/tests/camel-performance/src/test/java/org/apache/camel/test/perf/esb/SoapHbrEsbPerformanceIntegrationTest.java
    camel/trunk/tests/camel-performance/src/test/java/org/apache/camel/test/perf/esb/XsltEsbPerformanceIntegrationTest.java

Modified: camel/trunk/tests/camel-performance/src/test/java/org/apache/camel/test/perf/SplitterPerformanceTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/tests/camel-performance/src/test/java/org/apache/camel/test/perf/SplitterPerformanceTest.java?rev=1429327&r1=1429326&r2=1429327&view=diff
==============================================================================
--- camel/trunk/tests/camel-performance/src/test/java/org/apache/camel/test/perf/SplitterPerformanceTest.java
(original)
+++ camel/trunk/tests/camel-performance/src/test/java/org/apache/camel/test/perf/SplitterPerformanceTest.java
Sat Jan  5 16:40:53 2013
@@ -42,7 +42,7 @@ public class SplitterPerformanceTest ext
             + "</soapenv:Body>"
             + "</soapenv:Envelope>";
 
-    protected static String PAYLOAD = null;
+    protected static final String PAYLOAD;
 
     static {
         StringBuilder builder = new StringBuilder(HEADER);

Modified: camel/trunk/tests/camel-performance/src/test/java/org/apache/camel/test/perf/esb/AbstractBaseEsbPerformanceIntegrationTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/tests/camel-performance/src/test/java/org/apache/camel/test/perf/esb/AbstractBaseEsbPerformanceIntegrationTest.java?rev=1429327&r1=1429326&r2=1429327&view=diff
==============================================================================
--- camel/trunk/tests/camel-performance/src/test/java/org/apache/camel/test/perf/esb/AbstractBaseEsbPerformanceIntegrationTest.java
(original)
+++ camel/trunk/tests/camel-performance/src/test/java/org/apache/camel/test/perf/esb/AbstractBaseEsbPerformanceIntegrationTest.java
Sat Jan  5 16:40:53 2013
@@ -54,7 +54,7 @@ public abstract class AbstractBaseEsbPer
         ServletContextHandler context = new ServletContextHandler(ServletContextHandler.SESSIONS);
         context.setContextPath("/service");
         server.setHandler(context);
-        context.addServlet(new ServletHolder(new EchoService()),"/EchoService");
+        context.addServlet(new ServletHolder(new EchoService()), "/EchoService");
         server.start();
 
         payload = readPayload();
@@ -80,7 +80,8 @@ public abstract class AbstractBaseEsbPer
         Map<String, Object> headers = new HashMap<String, Object>();
         headers.put("Content-Type", "text/xml;charset=UTF-8");
         headers.put("SOAPAction", "urn:buyStocks.2");
-        
+        headers.put("routing", "xadmin;server1;community#1.0##");
+
         for (int i = 0; i < messagesToSend; i++) {
             template.requestBodyAndHeaders(payload, headers);
         }

Modified: camel/trunk/tests/camel-performance/src/test/java/org/apache/camel/test/perf/esb/CbrEsbPerformanceIntegrationTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/tests/camel-performance/src/test/java/org/apache/camel/test/perf/esb/CbrEsbPerformanceIntegrationTest.java?rev=1429327&r1=1429326&r2=1429327&view=diff
==============================================================================
--- camel/trunk/tests/camel-performance/src/test/java/org/apache/camel/test/perf/esb/CbrEsbPerformanceIntegrationTest.java
(original)
+++ camel/trunk/tests/camel-performance/src/test/java/org/apache/camel/test/perf/esb/CbrEsbPerformanceIntegrationTest.java
Sat Jan  5 16:40:53 2013
@@ -23,6 +23,9 @@ public class CbrEsbPerformanceIntegratio
 
     @Test
     public void testCbr() throws Exception {
+        // warm up with 1.000 messages so that the JIT compiler kicks in
+        send("http://127.0.0.1:8192/service/CBRProxy", 1000);
+
         StopWatch watch = new StopWatch();
         send("http://127.0.0.1:8192/service/CBRProxy", count);
 

Modified: camel/trunk/tests/camel-performance/src/test/java/org/apache/camel/test/perf/esb/EchoService.java
URL: http://svn.apache.org/viewvc/camel/trunk/tests/camel-performance/src/test/java/org/apache/camel/test/perf/esb/EchoService.java?rev=1429327&r1=1429326&r2=1429327&view=diff
==============================================================================
--- camel/trunk/tests/camel-performance/src/test/java/org/apache/camel/test/perf/esb/EchoService.java
(original)
+++ camel/trunk/tests/camel-performance/src/test/java/org/apache/camel/test/perf/esb/EchoService.java
Sat Jan  5 16:40:53 2013
@@ -16,9 +16,6 @@
  */
 package org.apache.camel.test.perf.esb;
 
-import javax.servlet.http.HttpServlet;
-import javax.servlet.http.HttpServletRequest;
-import javax.servlet.http.HttpServletResponse;
 import java.io.OutputStream;
 import java.nio.ByteBuffer;
 import java.nio.channels.Channels;
@@ -26,10 +23,13 @@ import java.nio.channels.ReadableByteCha
 import java.nio.channels.WritableByteChannel;
 import java.util.ArrayList;
 import java.util.List;
+import javax.servlet.http.HttpServlet;
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
 
 public class EchoService extends HttpServlet {
 
-    public static volatile long delayMillis = 0;
+    public static volatile long delayMillis;
 
     private static final long serialVersionUID = 1L;
     private static final int DEFAULT_BUFFER_SIZE = 4;
@@ -48,20 +48,21 @@ public class EchoService extends HttpSer
                     soapAction = soapAction.replaceAll("\"", "");
                 }
                 int dotPos = soapAction.indexOf(".");
-                int secondDotPos = (dotPos == -1 ? -1 : soapAction.indexOf(".", dotPos+1));
+                int secondDotPos = dotPos == -1 ? -1 : soapAction.indexOf(".", dotPos + 1);
 
                 if (secondDotPos > 0) {
-                    bufKBytes = Integer.parseInt(soapAction.substring(dotPos+1, secondDotPos));
-                    delaySecs = Integer.parseInt(soapAction.substring(secondDotPos+1));
+                    bufKBytes = Integer.parseInt(soapAction.substring(dotPos + 1, secondDotPos));
+                    delaySecs = Integer.parseInt(soapAction.substring(secondDotPos + 1));
                 } else if (dotPos > 0) {
-                    bufKBytes = Integer.parseInt(soapAction.substring(dotPos+1));
+                    bufKBytes = Integer.parseInt(soapAction.substring(dotPos + 1));
                 }
             }
 
             bb = ByteBuffer.allocate(bufKBytes * 1024);
             ReadableByteChannel rbc = Channels.newChannel(request.getInputStream());
 
-            int len, tot = 0;
+            int len = 0;
+            int tot = 0;
             while ((len = rbc.read(bb)) > 0) {
                 tot += len;
                 if (tot >= bb.capacity()) {

Modified: camel/trunk/tests/camel-performance/src/test/java/org/apache/camel/test/perf/esb/HttpHbrEsbPerformanceIntegrationTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/tests/camel-performance/src/test/java/org/apache/camel/test/perf/esb/HttpHbrEsbPerformanceIntegrationTest.java?rev=1429327&r1=1429326&r2=1429327&view=diff
==============================================================================
--- camel/trunk/tests/camel-performance/src/test/java/org/apache/camel/test/perf/esb/HttpHbrEsbPerformanceIntegrationTest.java
(original)
+++ camel/trunk/tests/camel-performance/src/test/java/org/apache/camel/test/perf/esb/HttpHbrEsbPerformanceIntegrationTest.java
Sat Jan  5 16:40:53 2013
@@ -23,6 +23,9 @@ public class HttpHbrEsbPerformanceIntegr
 
     @Test
     public void testHttpHbr() throws Exception {
+        // warm up with 1.000 messages so that the JIT compiler kicks in
+        send("http://127.0.0.1:8192/service/CBRTransportHeaderProxy", 1000);
+
         StopWatch watch = new StopWatch();
         send("http://127.0.0.1:8192/service/CBRTransportHeaderProxy", count);
 

Modified: camel/trunk/tests/camel-performance/src/test/java/org/apache/camel/test/perf/esb/ProxyEsbPerformanceIntegrationTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/tests/camel-performance/src/test/java/org/apache/camel/test/perf/esb/ProxyEsbPerformanceIntegrationTest.java?rev=1429327&r1=1429326&r2=1429327&view=diff
==============================================================================
--- camel/trunk/tests/camel-performance/src/test/java/org/apache/camel/test/perf/esb/ProxyEsbPerformanceIntegrationTest.java
(original)
+++ camel/trunk/tests/camel-performance/src/test/java/org/apache/camel/test/perf/esb/ProxyEsbPerformanceIntegrationTest.java
Sat Jan  5 16:40:53 2013
@@ -23,6 +23,9 @@ public class ProxyEsbPerformanceIntegrat
 
     @Test
     public void testProxy() throws Exception {
+        // warm up with 1.000 messages so that the JIT compiler kicks in
+        send("http://127.0.0.1:8192/service/DirectProxy", 1000);
+
         StopWatch watch = new StopWatch();
         send("http://127.0.0.1:8192/service/DirectProxy", count);
 

Modified: camel/trunk/tests/camel-performance/src/test/java/org/apache/camel/test/perf/esb/SecureProxyEsbPerformanceIntegrationTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/tests/camel-performance/src/test/java/org/apache/camel/test/perf/esb/SecureProxyEsbPerformanceIntegrationTest.java?rev=1429327&r1=1429326&r2=1429327&view=diff
==============================================================================
--- camel/trunk/tests/camel-performance/src/test/java/org/apache/camel/test/perf/esb/SecureProxyEsbPerformanceIntegrationTest.java
(original)
+++ camel/trunk/tests/camel-performance/src/test/java/org/apache/camel/test/perf/esb/SecureProxyEsbPerformanceIntegrationTest.java
Sat Jan  5 16:40:53 2013
@@ -26,6 +26,9 @@ public class SecureProxyEsbPerformanceIn
 
     @Test
     public void testSecureProxy() throws Exception {
+        // warm up with 1.000 messages so that the JIT compiler kicks in
+        send("http://127.0.0.1:8192/service/SecureProxy", 1000);
+
         StopWatch watch = new StopWatch();
         send("http://127.0.0.1:8192/service/SecureProxy", count);
 

Modified: camel/trunk/tests/camel-performance/src/test/java/org/apache/camel/test/perf/esb/SoapHbrEsbPerformanceIntegrationTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/tests/camel-performance/src/test/java/org/apache/camel/test/perf/esb/SoapHbrEsbPerformanceIntegrationTest.java?rev=1429327&r1=1429326&r2=1429327&view=diff
==============================================================================
--- camel/trunk/tests/camel-performance/src/test/java/org/apache/camel/test/perf/esb/SoapHbrEsbPerformanceIntegrationTest.java
(original)
+++ camel/trunk/tests/camel-performance/src/test/java/org/apache/camel/test/perf/esb/SoapHbrEsbPerformanceIntegrationTest.java
Sat Jan  5 16:40:53 2013
@@ -23,6 +23,9 @@ public class SoapHbrEsbPerformanceIntegr
 
     @Test
     public void testSoapHbr() throws Exception {
+        // warm up with 1.000 messages so that the JIT compiler kicks in
+        send("http://127.0.0.1:8192/service/CBRSOAPHeaderProxy", 1000);
+
         StopWatch watch = new StopWatch();
         send("http://127.0.0.1:8192/service/CBRSOAPHeaderProxy", count);
 

Modified: camel/trunk/tests/camel-performance/src/test/java/org/apache/camel/test/perf/esb/XsltEsbPerformanceIntegrationTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/tests/camel-performance/src/test/java/org/apache/camel/test/perf/esb/XsltEsbPerformanceIntegrationTest.java?rev=1429327&r1=1429326&r2=1429327&view=diff
==============================================================================
--- camel/trunk/tests/camel-performance/src/test/java/org/apache/camel/test/perf/esb/XsltEsbPerformanceIntegrationTest.java
(original)
+++ camel/trunk/tests/camel-performance/src/test/java/org/apache/camel/test/perf/esb/XsltEsbPerformanceIntegrationTest.java
Sat Jan  5 16:40:53 2013
@@ -23,6 +23,9 @@ public class XsltEsbPerformanceIntegrati
 
     @Test
     public void testXSLTProxy() throws Exception {
+        // warm up with 1.000 messages so that the JIT compiler kicks in
+        send("http://127.0.0.1:8192/service/XSLTProxy", 1000);
+
         StopWatch watch = new StopWatch();
         send("http://127.0.0.1:8192/service/XSLTProxy", count);
 



Mime
View raw message