DL-99: Enable thriftmux for distributedlog smoketest reader

Project: http://git-wip-us.apache.org/repos/asf/incubator-distributedlog/repo
Commit: 
http://git-wip-us.apache.org/repos/asf/incubator-distributedlog/commit/3ea8853e
Tree: 
http://git-wip-us.apache.org/repos/asf/incubator-distributedlog/tree/3ea8853e
Diff: 
http://git-wip-us.apache.org/repos/asf/incubator-distributedlog/diff/3ea8853e

Branch: refs/heads/master
Commit: 3ea8853e9e707e81c52fed891c671fa2cf28c515
Parents: f9a0783
Author: Dave Rusek <dru...@apache.org>
Authored: Mon Jul 18 12:23:49 2016 -0700
Committer: Sijie Guo <sij...@twitter.com>
Committed: Tue Dec 27 16:49:26 2016 -0800

----------------------------------------------------------------------
 .../java/com/twitter/distributedlog/benchmark/ReaderWorker.java     | 1 +
 1 file changed, 1 insertion(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-distributedlog/blob/3ea8853e/distributedlog-benchmark/src/main/java/com/twitter/distributedlog/benchmark/ReaderWorker.java
----------------------------------------------------------------------
diff --git 
a/distributedlog-benchmark/src/main/java/com/twitter/distributedlog/benchmark/ReaderWorker.java
 
b/distributedlog-benchmark/src/main/java/com/twitter/distributedlog/benchmark/ReaderWorker.java
index 91f36cd..3e82e30 100644
--- 
a/distributedlog-benchmark/src/main/java/com/twitter/distributedlog/benchmark/ReaderWorker.java
+++ 
b/distributedlog-benchmark/src/main/java/com/twitter/distributedlog/benchmark/ReaderWorker.java
@@ -270,6 +270,7 @@ public class ReaderWorker implements Worker {
                     .redirectBackoffMaxMs(500)
                     .requestTimeoutMs(2000)
                     .statsReceiver(statsReceiver)
+                    .thriftmux(true)
                     .name("reader");
 
             if (serverSetPaths.isEmpty()) {

Reply via email to