cxf-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From dk...@apache.org
Subject svn commit: r677996 - in /cxf/trunk/benchmark/performance: base/src/org/apache/cxf/pat/internal/TestCaseBase.java soap_http_doc_lit/src/org/apache/cxf/performance/complex_type/client/Client.java
Date Fri, 18 Jul 2008 18:46:41 GMT
Author: dkulp
Date: Fri Jul 18 11:46:40 2008
New Revision: 677996

URL: http://svn.apache.org/viewvc?rev=677996&view=rev
Log:
Minor updates to the perf thing to be what I was testing with the chunking stuff

Modified:
    cxf/trunk/benchmark/performance/base/src/org/apache/cxf/pat/internal/TestCaseBase.java
    cxf/trunk/benchmark/performance/soap_http_doc_lit/src/org/apache/cxf/performance/complex_type/client/Client.java

Modified: cxf/trunk/benchmark/performance/base/src/org/apache/cxf/pat/internal/TestCaseBase.java
URL: http://svn.apache.org/viewvc/cxf/trunk/benchmark/performance/base/src/org/apache/cxf/pat/internal/TestCaseBase.java?rev=677996&r1=677995&r2=677996&view=diff
==============================================================================
--- cxf/trunk/benchmark/performance/base/src/org/apache/cxf/pat/internal/TestCaseBase.java
(original)
+++ cxf/trunk/benchmark/performance/base/src/org/apache/cxf/pat/internal/TestCaseBase.java
Fri Jul 18 11:46:40 2008
@@ -183,19 +183,26 @@
                  return;
             }
 
-            System.out.println("TestCase " + name + " is warming up the jit. (20 sec/1200
iterations)");
-            final long endTime = System.currentTimeMillis() + 20000;
+            final int threadCount = 4;
+            final long timeLimit = 30;
+            final int countLimit = 1200;
+            
+            System.out.println("TestCase " + name + " is warming up the jit. (" + timeLimit
+ " sec/" + countLimit + " iterations, " + threadCount + " threads)");
+            final long startTime = System.currentTimeMillis();
+            final long endTime = startTime + (timeLimit * 1000l);
             final T t = getPort();
 
-            for (int x = 0; x < 12; x++) {
+            for (int x = 0; x < (threadCount - 1); x++) {
                 new Thread() {
                     public void run() {
                         try {
                             int count = 0;
-                            while (count < 1200 || System.currentTimeMillis() < endTime)
{
+                            while (count < countLimit || System.currentTimeMillis() <
endTime) {
                                 count++;
                                 doJob(t);
                             }
+                            //System.out.println(count);
+                            //System.out.println("" + (System.currentTimeMillis() - startTime));
                         } catch ( Exception ex ) {
                             ex.printStackTrace();
                         }
@@ -205,12 +212,15 @@
             }
 
             int count = 0;
-            while (count < 1200 || System.currentTimeMillis() < endTime) {
+            while (count < countLimit || System.currentTimeMillis() < endTime) {
                 count++;
                 doJob(t);
             }
-            while (initDone != 12) {
-		Thread.sleep(100);
+            //System.out.println(count);
+            //System.out.println("" + (System.currentTimeMillis() - startTime));
+            ++initDone;
+            while (initDone != threadCount) {
+                Thread.sleep(100);
             }
         } catch (Exception e) {
             e.printStackTrace();

Modified: cxf/trunk/benchmark/performance/soap_http_doc_lit/src/org/apache/cxf/performance/complex_type/client/Client.java
URL: http://svn.apache.org/viewvc/cxf/trunk/benchmark/performance/soap_http_doc_lit/src/org/apache/cxf/performance/complex_type/client/Client.java?rev=677996&r1=677995&r2=677996&view=diff
==============================================================================
--- cxf/trunk/benchmark/performance/soap_http_doc_lit/src/org/apache/cxf/performance/complex_type/client/Client.java
(original)
+++ cxf/trunk/benchmark/performance/soap_http_doc_lit/src/org/apache/cxf/performance/complex_type/client/Client.java
Fri Jul 18 11:46:40 2008
@@ -184,11 +184,9 @@
         }
 
         complexType.setVarEnum(ColourEnum.RED);
-        byte[] binary = new byte[256 * packetSize];
-        for (int idx = 0; idx < 1 * packetSize; idx++) {
-            for (int jdx = 0; jdx < 256; jdx++) {
-                binary[idx * 256 + jdx] = (byte)(jdx - 128);
-            }
+        byte[] binary = new byte[256];
+        for (int jdx = 0; jdx < 256; jdx++) {
+            binary[jdx] = (byte)(jdx - 128);
         }
         complexType.setVarHexBinary(binary);
         complexType.setVarBase64Binary(binary);
@@ -196,24 +194,25 @@
     }
 
     public void initTestData() {
-        //for (int i = 0; i < packetSize; i++) {
         NestedComplexType ct = createComplexType();
-        for (int i = 0; i < 1; i++) {
+        for (int i = 0; i < packetSize; i++) {
             complexTypeSeq.getItem().add(ct);
         }            
         // init String and Binary
         String temp = "abcdefghijklmnopqrstuvwxyz0123456789!@#$%^&*()_+?><[]/0123456789";
-        inputBase64 = new byte[1024 * packetSize];
-        for (int idx = 0; idx < 4 * packetSize; idx++) {
+        inputBase64 = new byte[1024];
+        for (int idx = 0; idx < 4; idx++) {
             for (int jdx = 0; jdx < 256; jdx++) {
                 inputBase64[idx * 256 + jdx] = (byte)(jdx - 128);
             }
         }
 
+        StringBuilder builder = new StringBuilder(packetSize * 1024);
+        builder.append(inputString);
         for (int i = 0; i < asciiCount / temp.length() * packetSize; i++) {
-            inputString = inputString + temp;
+            builder.append(temp);
         }
-
+        inputString = builder.toString();
     }
 
     public void doJob(DocPortType port) {



Mime
View raw message