Hao Hao has submitted this change and it was merged. ( 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 Reviewed-on: http://gerrit.cloudera.org:8080/15210 Reviewed-by: Adar Dembo <[email protected]> Reviewed-by: Attila Bukor <[email protected]> Tested-by: Hao Hao <[email protected]> --- 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, 289 insertions(+), 127 deletions(-) Approvals: Adar Dembo: Looks good to me, approved Attila Bukor: Looks good to me, approved Hao Hao: Verified -- 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: merged Gerrit-Change-Id: I0793ad35af5342bb9af4f2f0eaed4090f78ef3c6 Gerrit-Change-Number: 15210 Gerrit-PatchSet: 5 Gerrit-Owner: Hao Hao <[email protected]> Gerrit-Reviewer: Adar Dembo <[email protected]> Gerrit-Reviewer: Andrew Wong <[email protected]> Gerrit-Reviewer: Attila Bukor <[email protected]> Gerrit-Reviewer: Hao Hao <[email protected]> Gerrit-Reviewer: Kudu Jenkins (120)
