ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From vkuliche...@apache.org
Subject [15/20] incubator-ignite git commit: IGNITE-61 - Portable format in direct marshalling
Date Mon, 22 Dec 2014 23:40:09 GMT
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 <vkulichenko@gridgain.com>
Authored: Fri Dec 19 19:16:51 2014 +0300
Committer: Valentin Kulichenko <vkulichenko@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;
     }
 
     /**


Mime
View raw message