Updated Branches: refs/heads/trunk 88a86ea70 -> e6c4c4170
GIRAPH-830: directMemory used in netty message (pavanka via aching) Project: http://git-wip-us.apache.org/repos/asf/giraph/repo Commit: http://git-wip-us.apache.org/repos/asf/giraph/commit/e6c4c417 Tree: http://git-wip-us.apache.org/repos/asf/giraph/tree/e6c4c417 Diff: http://git-wip-us.apache.org/repos/asf/giraph/diff/e6c4c417 Branch: refs/heads/trunk Commit: e6c4c4170aa675819dc17761470806eaec08bb33 Parents: 88a86ea Author: Avery Ching <[email protected]> Authored: Mon Jan 27 21:48:47 2014 -0800 Committer: Avery Ching <[email protected]> Committed: Mon Jan 27 21:59:02 2014 -0800 ---------------------------------------------------------------------- CHANGELOG | 2 ++ .../org/apache/giraph/comm/netty/handler/RequestServerHandler.java | 2 +- 2 files changed, 3 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/giraph/blob/e6c4c417/CHANGELOG ---------------------------------------------------------------------- diff --git a/CHANGELOG b/CHANGELOG index dc25b49..45551fd 100644 --- a/CHANGELOG +++ b/CHANGELOG @@ -1,6 +1,8 @@ Giraph Change Log Release 1.1.0 - unreleased + GIRAPH-830: directMemory used in netty message (pavanka via aching) + GIRAPH-829: Compilation error due to wrong rexster jar file (armax00 via claudio) GIRAPH-803: Rexster I/O new complete API (armax00 via claudio) http://git-wip-us.apache.org/repos/asf/giraph/blob/e6c4c417/giraph-core/src/main/java/org/apache/giraph/comm/netty/handler/RequestServerHandler.java ---------------------------------------------------------------------- diff --git a/giraph-core/src/main/java/org/apache/giraph/comm/netty/handler/RequestServerHandler.java b/giraph-core/src/main/java/org/apache/giraph/comm/netty/handler/RequestServerHandler.java index 781e37c..bfcfb8d 100644 --- a/giraph-core/src/main/java/org/apache/giraph/comm/netty/handler/RequestServerHandler.java +++ b/giraph-core/src/main/java/org/apache/giraph/comm/netty/handler/RequestServerHandler.java @@ -121,7 +121,7 @@ public abstract class RequestServerHandler<R> extends } // Send the response with the request id - ChannelBuffer buffer = ChannelBuffers.directBuffer(RESPONSE_BYTES); + ChannelBuffer buffer = ChannelBuffers.buffer(RESPONSE_BYTES); buffer.writeInt(myTaskInfo.getTaskId()); buffer.writeLong(writableRequest.getRequestId()); buffer.writeByte(alreadyDone);
