You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by vk...@apache.org on 2014/12/23 00:40:09 UTC
[15/20] incubator-ignite git commit: IGNITE-61 - Portable format in
direct marshalling
IGNITE-61 - Portable format in direct marshalling
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/d0ecc3fd
Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/d0ecc3fd
Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/d0ecc3fd
Branch: refs/heads/ignite-61
Commit: d0ecc3fd21cd2ac07595c78140932f6044ad7d0d
Parents: 4abbc39
Author: Valentin Kulichenko <vk...@gridgain.com>
Authored: Fri Dec 19 19:16:51 2014 +0300
Committer: Valentin Kulichenko <vk...@gridgain.com>
Committed: Fri Dec 19 19:16:51 2014 +0300
----------------------------------------------------------------------
.../grid/util/direct/GridTcpCommunicationMessageState.java | 2 +-
.../grid/util/direct/GridTcpCommunicationPortableStream.java | 6 +-----
2 files changed, 2 insertions(+), 6 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/d0ecc3fd/modules/core/src/main/java/org/gridgain/grid/util/direct/GridTcpCommunicationMessageState.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/gridgain/grid/util/direct/GridTcpCommunicationMessageState.java b/modules/core/src/main/java/org/gridgain/grid/util/direct/GridTcpCommunicationMessageState.java
index c2d8b14..0a3f856 100644
--- a/modules/core/src/main/java/org/gridgain/grid/util/direct/GridTcpCommunicationMessageState.java
+++ b/modules/core/src/main/java/org/gridgain/grid/util/direct/GridTcpCommunicationMessageState.java
@@ -74,7 +74,7 @@ public class GridTcpCommunicationMessageState {
* @param buf Buffer.
*/
public final void setBuffer(ByteBuffer buf) {
- assert buf != null;
+ stream.setBuffer(buf);
}
/**
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/d0ecc3fd/modules/core/src/main/java/org/gridgain/grid/util/direct/GridTcpCommunicationPortableStream.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/gridgain/grid/util/direct/GridTcpCommunicationPortableStream.java b/modules/core/src/main/java/org/gridgain/grid/util/direct/GridTcpCommunicationPortableStream.java
index c87837f..3ec27df 100644
--- a/modules/core/src/main/java/org/gridgain/grid/util/direct/GridTcpCommunicationPortableStream.java
+++ b/modules/core/src/main/java/org/gridgain/grid/util/direct/GridTcpCommunicationPortableStream.java
@@ -249,11 +249,7 @@ public class GridTcpCommunicationPortableStream implements GridPortableOutputStr
* @return Whether last object was fully written.
*/
public boolean lastWritten() {
- boolean lastWritten0 = lastWritten;
-
- lastWritten = false;
-
- return lastWritten0;
+ return lastWritten;
}
/**