Mercurial > stress-tester

changeset 776:43eecfd20a76

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
encodeHeader -> encodeHeaders
author Devel 1
date Mon, 18 Dec 2017 16:27:55 +0100
parents c55915d92f35
children 4318bf3f6464
files stress-tester/src/main/java/com/passus/st/PcapReporter.java stress-tester/src/main/java/com/passus/st/client/http/HttpFlowBasedClientWorker.java stress-tester/src/main/java/com/passus/st/client/http/WriterHttpClientListener.java
diffstat 3 files changed, 4 insertions(+), 4 deletions(-) [+]
line wrap: on
line diff
--- a/stress-tester/src/main/java/com/passus/st/PcapReporter.java	Mon Dec 18 15:32:45 2017 +0100
+++ b/stress-tester/src/main/java/com/passus/st/PcapReporter.java	Mon Dec 18 16:27:55 2017 +0100
@@ -299,7 +299,7 @@
 
         private <T extends HttpMessage> void setSizeAndTimeTags(T msg, HttpMessageEncoder<T> encoder) {
             ByteBuff buffer = new HeapByteBuff();
-            encoder.encodeHeader(msg, buffer);
+            encoder.encodeHeaders(msg, buffer);
             long headerSize = buffer.readableBytes();
             encoder.encodeContent(msg, buffer);
             long contentSize = (long) (buffer.readableBytes() - headerSize);
--- a/stress-tester/src/main/java/com/passus/st/client/http/HttpFlowBasedClientWorker.java	Mon Dec 18 15:32:45 2017 +0100
+++ b/stress-tester/src/main/java/com/passus/st/client/http/HttpFlowBasedClientWorker.java	Mon Dec 18 16:27:55 2017 +0100
@@ -561,7 +561,7 @@
                     return false;
                 }
 
-                reqEncoder.encodeHeader(req, context.buffer);
+                reqEncoder.encodeHeaders(req, context.buffer);
                 long headerSize = context.buffer.readableBytes();
                 reqEncoder.encodeContent(req, context.buffer);
 
--- a/stress-tester/src/main/java/com/passus/st/client/http/WriterHttpClientListener.java	Mon Dec 18 15:32:45 2017 +0100
+++ b/stress-tester/src/main/java/com/passus/st/client/http/WriterHttpClientListener.java	Mon Dec 18 16:27:55 2017 +0100
@@ -64,9 +64,9 @@
         }
 
         if (message.isRequest()) {
-            requestEncoder.encodeHeader((HttpRequest) message, buffer);
+            requestEncoder.encodeHeaders((HttpRequest) message, buffer);
         } else {
-            responseEncoder.encodeHeader((HttpResponse) message, buffer);
+            responseEncoder.encodeHeaders((HttpResponse) message, buffer);
         }
 
         writer.write(buffer.toString());