You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by sb...@apache.org on 2016/02/15 08:52:03 UTC
[19/50] [abbrv] ignite git commit: ignite-split2 - compatibility
ignite-split2 - compatibility
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/281fe7cf
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/281fe7cf
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/281fe7cf
Branch: refs/heads/ignite-1232
Commit: 281fe7cf4725b31ac88b6315d487a8f2f0fb18d2
Parents: 1113c6f
Author: S.Vladykin <sv...@gridgain.com>
Authored: Tue Dec 8 04:26:03 2015 +0300
Committer: S.Vladykin <sv...@gridgain.com>
Committed: Tue Dec 8 04:26:03 2015 +0300
----------------------------------------------------------------------
.../query/h2/twostep/msg/GridH2ValueMessage.java | 16 +---------------
1 file changed, 1 insertion(+), 15 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/281fe7cf/modules/indexing/src/main/java/org/apache/ignite/internal/processors/query/h2/twostep/msg/GridH2ValueMessage.java
----------------------------------------------------------------------
diff --git a/modules/indexing/src/main/java/org/apache/ignite/internal/processors/query/h2/twostep/msg/GridH2ValueMessage.java b/modules/indexing/src/main/java/org/apache/ignite/internal/processors/query/h2/twostep/msg/GridH2ValueMessage.java
index 3a9f43a..ee8856b 100644
--- a/modules/indexing/src/main/java/org/apache/ignite/internal/processors/query/h2/twostep/msg/GridH2ValueMessage.java
+++ b/modules/indexing/src/main/java/org/apache/ignite/internal/processors/query/h2/twostep/msg/GridH2ValueMessage.java
@@ -40,25 +40,11 @@ public abstract class GridH2ValueMessage implements Message {
/** {@inheritDoc} */
@Override public boolean writeTo(ByteBuffer buf, MessageWriter writer) {
- writer.setBuffer(buf);
-
- if (!writer.isHeaderWritten()) {
- if (!writer.writeHeader(directType(), fieldsCount()))
- return false;
-
- writer.onHeaderWritten();
- }
-
return true;
}
/** {@inheritDoc} */
@Override public boolean readFrom(ByteBuffer buf, MessageReader reader) {
- reader.setBuffer(buf);
-
- if (!reader.beforeMessageRead())
- return false;
-
- return reader.afterMessageRead(GridH2ValueMessage.class);
+ return true;
}
}