README

Slightly more resilient stress test

finagle-example/README

@@ -0,0 +1,12 @@
+# How to run the examples:
+
+From the command line:
+
+% sbt "project finagle-example" run
+
+If the example requires a command line parameter, do this:
+
+% sbt "project finagle-example" "run p1 p2"
+
+If you are running a server and a client, start the server in one terminal, then start the client in another.
+

finagle-example/src/main/scala/com/twitter/finagle/example/stress/Stress.scala

@@ -37,12 +37,16 @@ object Stress {
       .build()
 
 
+    val completedRequests = new AtomicInteger(0)
+
     val requests = Future.parallel(concurrency) {
       Future.times(totalRequests / concurrency) {
         client(request) onSuccess { response =>
           responses(response.getStatus).incrementAndGet()
-        } onFailure { f =>
+        } handle { case e =>
           errors.incrementAndGet()
+        } ensure {
+          completedRequests.incrementAndGet()
         }
       }
     }
@@ -58,8 +62,9 @@ object Stress {
         println("%20s\t%d".format(status, stat.get))
       }
       println("================")
-      println("%d requests completed in %dms (%2f requests per second)".format(
-        totalRequests, duration.inMilliseconds, totalRequests.toFloat / duration.inSeconds))
+      println("%d requests completed in %dms (%f requests per second)".format(
+        completedRequests.get, duration.inMilliseconds, totalRequests.toFloat / duration.inMillis.toFloat * 1000))
+      println("%d errors".format(errors.get))
     }
   }