Hao Hao has uploaded this change for review. ( http://gerrit.cloudera.org:8080/15210
Change subject: [java] KUDU-2971: add an outbound queue ...................................................................... [java] KUDU-2971: add an outbound queue This commit updates the writer tasks to put the responses to an outbound queue, and uses a separate thread to poll the queue and write the messages to stdout. So that in case stdout fills up, the message parser tasks can continue processing the requests without blocking. Change-Id: I0793ad35af5342bb9af4f2f0eaed4090f78ef3c6 --- M java/kudu-subprocess-echo/src/test/java/org/apache/kudu/subprocess/echo/TestEchoSubprocess.java A java/kudu-subprocess/src/main/java/org/apache/kudu/subprocess/MessageParser.java M java/kudu-subprocess/src/main/java/org/apache/kudu/subprocess/MessageReader.java M java/kudu-subprocess/src/main/java/org/apache/kudu/subprocess/MessageWriter.java A java/kudu-subprocess/src/main/java/org/apache/kudu/subprocess/QueueUtil.java M java/kudu-subprocess/src/main/java/org/apache/kudu/subprocess/SubprocessConfiguration.java M java/kudu-subprocess/src/main/java/org/apache/kudu/subprocess/SubprocessExecutor.java M java/kudu-subprocess/src/test/java/org/apache/kudu/subprocess/TestMessageIO.java 8 files changed, 223 insertions(+), 119 deletions(-) git pull ssh://gerrit.cloudera.org:29418/kudu refs/changes/10/15210/1 -- To view, visit http://gerrit.cloudera.org:8080/15210 To unsubscribe, visit http://gerrit.cloudera.org:8080/settings Gerrit-Project: kudu Gerrit-Branch: master Gerrit-MessageType: newchange Gerrit-Change-Id: I0793ad35af5342bb9af4f2f0eaed4090f78ef3c6 Gerrit-Change-Number: 15210 Gerrit-PatchSet: 1 Gerrit-Owner: Hao Hao <[email protected]>
