WIP.
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/75e04fae Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/75e04fae Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/75e04fae Branch: refs/heads/ignite-884 Commit: 75e04faebe7d9b452f3a7436f3cdfba9171a1ee2 Parents: 7b61a09 Author: vozerov-gridgain <voze...@gridgain.com> Authored: Tue Aug 25 15:35:23 2015 +0300 Committer: vozerov-gridgain <voze...@gridgain.com> Committed: Tue Aug 25 15:35:23 2015 +0300 ---------------------------------------------------------------------- .../internal/portable/PortableRawWriterEx.java | 16 ++++++++++++++++ .../internal/portable/PortableWriterExImpl.java | 18 ++++-------------- 2 files changed, 20 insertions(+), 14 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/75e04fae/modules/core/src/main/java/org/apache/ignite/internal/portable/PortableRawWriterEx.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/portable/PortableRawWriterEx.java b/modules/core/src/main/java/org/apache/ignite/internal/portable/PortableRawWriterEx.java index d3e65f0..b0d6c71 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/portable/PortableRawWriterEx.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/portable/PortableRawWriterEx.java @@ -41,4 +41,20 @@ public interface PortableRawWriterEx extends PortableRawWriter, AutoCloseable { * Cleans resources. */ @Override public void close(); + + /** + * Reserve a room for an integer. + * + * @return Position in the stream where value is to be written. + */ + public int reserveInt(); + + /** + * Write int value at the specific position. + * + * @param pos Position. + * @param val Value. + * @throws PortableException If failed. + */ + public void writeInt(int pos, int val) throws PortableException; } http://git-wip-us.apache.org/repos/asf/ignite/blob/75e04fae/modules/core/src/main/java/org/apache/ignite/internal/portable/PortableWriterExImpl.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/portable/PortableWriterExImpl.java b/modules/core/src/main/java/org/apache/ignite/internal/portable/PortableWriterExImpl.java index f801632..e100e13 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/portable/PortableWriterExImpl.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/portable/PortableWriterExImpl.java @@ -1663,23 +1663,13 @@ public class PortableWriterExImpl implements PortableWriter, PortableRawWriterEx // No-op. } - /** - * Reserve a room for an integer. - * - * @return Position in the stream where value is to be written. - */ - public int reserveInt() { + /** {@inheritDoc} */ + @Override public int reserveInt() { return reserve(LEN_INT); } - /** - * Write int value at the specific position. - * - * @param pos Position. - * @param val Value. - * @throws PortableException If failed. - */ - public void writeInt(int pos, int val) throws PortableException { + /** {@inheritDoc} */ + @Override public void writeInt(int pos, int val) throws PortableException { wCtx.out.writeInt(pos, val); }