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:05 UTC
[11/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/1767ba5e
Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/1767ba5e
Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/1767ba5e
Branch: refs/heads/ignite-61
Commit: 1767ba5e69648c3e5d471a73b66b0bf172f28a6f
Parents: 5ed5176
Author: Valentin Kulichenko <vk...@gridgain.com>
Authored: Fri Dec 19 14:56:59 2014 +0300
Committer: Valentin Kulichenko <vk...@gridgain.com>
Committed: Fri Dec 19 14:56:59 2014 +0300
----------------------------------------------------------------------
.../jobstealing/JobStealingRequest.java | 2 +-
.../GridTcpCommunicationMessageState.java | 30 ++++++++++++++++----
2 files changed, 26 insertions(+), 6 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/1767ba5e/modules/core/src/main/java/org/apache/ignite/spi/collision/jobstealing/JobStealingRequest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/spi/collision/jobstealing/JobStealingRequest.java b/modules/core/src/main/java/org/apache/ignite/spi/collision/jobstealing/JobStealingRequest.java
index 1b3a91e..73450e0 100644
--- a/modules/core/src/main/java/org/apache/ignite/spi/collision/jobstealing/JobStealingRequest.java
+++ b/modules/core/src/main/java/org/apache/ignite/spi/collision/jobstealing/JobStealingRequest.java
@@ -69,7 +69,7 @@ public class JobStealingRequest extends GridTcpCommunicationMessageAdapter {
commState.setBuffer(buf);
if (!commState.typeWritten) {
- if (!commState.writeType(directType()))
+ if (!commState.writeByte(directType()))
return false;
commState.typeWritten = true;
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/1767ba5e/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 5a3e74d..1357627 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
@@ -78,19 +78,39 @@ public class GridTcpCommunicationMessageState {
}
/**
- * @param type Message type.
- * @return Whether message type was written.
+ * @param val Byte value.
+ * @return Whether value was written.
+ */
+ public final boolean writeByte(byte val) {
+ if (stream.remaining() < 1)
+ return false;
+
+ stream.writeByte(val);
+
+ return true;
+ }
+
+ /**
+ * @param val Int value.
+ * @return Whether value was written.
*/
- public final boolean writeType(byte type) {
- if (stream.remaining() == 0)
+ public final boolean writeInt(int val) {
+ if (stream.remaining() < 4)
return false;
- stream.writeByte(type);
+ stream.writeInt(val);
return true;
}
/**
+ * @return Int value.
+ */
+ public final int readInt() {
+ return stream.readInt();
+ }
+
+ /**
* @param name Field name.
* @param b Byte value.
* @return Whether value was written.