hc-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From asan...@apache.org
Subject svn commit: r693049 - /httpcomponents/httpcore/trunk/contrib/src/main/java/org/apache/http/contrib/benchmark/BenchmarkWorker.java
Date Mon, 08 Sep 2008 10:50:32 GMT
Author: asankha
Date: Mon Sep  8 03:50:31 2008
New Revision: 693049

URL: http://svn.apache.org/viewvc?rev=693049&view=rev
Log:
close connections cleanly before ending a run
Support new options :
  -o : Use http 1.0 instead of default http 1.1
  -t <n> : Use the socket timeout as <n> milliseconds
  -H "h1: v1","h2: v2" : Support multiple http headers to work around a CLI limitation

Modified:
    httpcomponents/httpcore/trunk/contrib/src/main/java/org/apache/http/contrib/benchmark/BenchmarkWorker.java

Modified: httpcomponents/httpcore/trunk/contrib/src/main/java/org/apache/http/contrib/benchmark/BenchmarkWorker.java
URL: http://svn.apache.org/viewvc/httpcomponents/httpcore/trunk/contrib/src/main/java/org/apache/http/contrib/benchmark/BenchmarkWorker.java?rev=693049&r1=693048&r2=693049&view=diff
==============================================================================
--- httpcomponents/httpcore/trunk/contrib/src/main/java/org/apache/http/contrib/benchmark/BenchmarkWorker.java
(original)
+++ httpcomponents/httpcore/trunk/contrib/src/main/java/org/apache/http/contrib/benchmark/BenchmarkWorker.java
Mon Sep  8 03:50:31 2008
@@ -90,11 +90,11 @@
     private final Stats stats = new Stats();
 
     public BenchmarkWorker(
-            final HttpParams params, 
-            int verbosity, 
+            final HttpParams params,
+            int verbosity,
             final HttpRequest request,
-            final HttpHost targetHost, 
-            int count, 
+            final HttpHost targetHost,
+            int count,
             boolean keepalive) {
 
         super();
@@ -160,7 +160,7 @@
                     response = this.httpexecutor.execute(this.request, conn, this.context);
                     // Finalize response
                     this.httpexecutor.postProcess(response, this.httpProcessor, this.context);
-                    
+
                 } catch (HttpException e) {
                     stats.incWriteErrors();
                     if (this.verbosity >= 2) {
@@ -225,6 +225,16 @@
                 stats.setServerName(header.getValue());
             }
         }
+
+        try {
+            conn.close();
+        } catch (IOException ex) {
+            ex.printStackTrace();
+            stats.incFailureCount();
+            if (this.verbosity >= 2) {
+                System.err.println("I/O error: " + ex.getMessage());
+            }
+        }
     }
 
     private void verboseOutput(HttpResponse response) {



Mime
View raw message