http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/ae9df458/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsDeleteMessage.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsDeleteMessage.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsDeleteMessage.java index 8057e21..7e5a690 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsDeleteMessage.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsDeleteMessage.java @@ -142,6 +142,9 @@ public class IgfsDeleteMessage extends IgfsCommunicationMessage { @Override public boolean readFrom(ByteBuffer buf) { reader.setBuffer(buf); + if (!reader.beforeMessageRead()) + return false; + if (!super.readFrom(buf)) return false;
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/ae9df458/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsFileAffinityRange.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsFileAffinityRange.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsFileAffinityRange.java index 626a24e..e83705f 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsFileAffinityRange.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsFileAffinityRange.java @@ -313,6 +313,9 @@ public class IgfsFileAffinityRange extends MessageAdapter implements Externaliza @Override public boolean readFrom(ByteBuffer buf) { reader.setBuffer(buf); + if (!reader.beforeMessageRead()) + return false; + switch (readState) { case 0: affKey = reader.readIgniteUuid("affKey"); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/ae9df458/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsFragmentizerRequest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsFragmentizerRequest.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsFragmentizerRequest.java index ce819d2..4f09056 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsFragmentizerRequest.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsFragmentizerRequest.java @@ -114,6 +114,9 @@ public class IgfsFragmentizerRequest extends IgfsCommunicationMessage { @Override public boolean readFrom(ByteBuffer buf) { reader.setBuffer(buf); + if (!reader.beforeMessageRead()) + return false; + if (!super.readFrom(buf)) return false; http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/ae9df458/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsFragmentizerResponse.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsFragmentizerResponse.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsFragmentizerResponse.java index fdcf6a1..a08b1b5 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsFragmentizerResponse.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsFragmentizerResponse.java @@ -84,6 +84,9 @@ public class IgfsFragmentizerResponse extends IgfsCommunicationMessage { @Override public boolean readFrom(ByteBuffer buf) { reader.setBuffer(buf); + if (!reader.beforeMessageRead()) + return false; + if (!super.readFrom(buf)) return false; http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/ae9df458/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsSyncMessage.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsSyncMessage.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsSyncMessage.java index 18f5870..86246d5 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsSyncMessage.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsSyncMessage.java @@ -107,6 +107,9 @@ public class IgfsSyncMessage extends IgfsCommunicationMessage { @Override public boolean readFrom(ByteBuffer buf) { reader.setBuffer(buf); + if (!reader.beforeMessageRead()) + return false; + if (!super.readFrom(buf)) return false; http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/ae9df458/modules/core/src/main/java/org/apache/ignite/internal/processors/rest/handlers/task/GridTaskResultRequest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/rest/handlers/task/GridTaskResultRequest.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/rest/handlers/task/GridTaskResultRequest.java index d61543f..1d0d9d0 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/rest/handlers/task/GridTaskResultRequest.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/rest/handlers/task/GridTaskResultRequest.java @@ -131,6 +131,9 @@ public class GridTaskResultRequest extends MessageAdapter { @Override public boolean readFrom(ByteBuffer buf) { reader.setBuffer(buf); + if (!reader.beforeMessageRead()) + return false; + switch (readState) { case 0: taskId = reader.readIgniteUuid("taskId"); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/ae9df458/modules/core/src/main/java/org/apache/ignite/internal/processors/rest/handlers/task/GridTaskResultResponse.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/rest/handlers/task/GridTaskResultResponse.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/rest/handlers/task/GridTaskResultResponse.java index 5bd6e11..b2d36a5 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/rest/handlers/task/GridTaskResultResponse.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/rest/handlers/task/GridTaskResultResponse.java @@ -161,6 +161,9 @@ public class GridTaskResultResponse extends MessageAdapter { @Override public boolean readFrom(ByteBuffer buf) { reader.setBuffer(buf); + if (!reader.beforeMessageRead()) + return false; + switch (readState) { case 0: err = reader.readString("err"); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/ae9df458/modules/core/src/main/java/org/apache/ignite/internal/processors/streamer/GridStreamerCancelRequest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/streamer/GridStreamerCancelRequest.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/streamer/GridStreamerCancelRequest.java index be0ce55..64301c6 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/streamer/GridStreamerCancelRequest.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/streamer/GridStreamerCancelRequest.java @@ -81,6 +81,9 @@ public class GridStreamerCancelRequest extends MessageAdapter { @Override public boolean readFrom(ByteBuffer buf) { reader.setBuffer(buf); + if (!reader.beforeMessageRead()) + return false; + switch (readState) { case 0: cancelledFutId = reader.readIgniteUuid("cancelledFutId"); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/ae9df458/modules/core/src/main/java/org/apache/ignite/internal/processors/streamer/GridStreamerExecutionRequest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/streamer/GridStreamerExecutionRequest.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/streamer/GridStreamerExecutionRequest.java index d49b4c0..0c4b386 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/streamer/GridStreamerExecutionRequest.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/streamer/GridStreamerExecutionRequest.java @@ -212,6 +212,9 @@ public class GridStreamerExecutionRequest extends MessageAdapter { @Override public boolean readFrom(ByteBuffer buf) { reader.setBuffer(buf); + if (!reader.beforeMessageRead()) + return false; + switch (readState) { case 0: batchBytes = reader.readByteArray("batchBytes"); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/ae9df458/modules/core/src/main/java/org/apache/ignite/internal/processors/streamer/GridStreamerResponse.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/streamer/GridStreamerResponse.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/streamer/GridStreamerResponse.java index 1e2b2c7..a5ba781 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/streamer/GridStreamerResponse.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/streamer/GridStreamerResponse.java @@ -107,6 +107,9 @@ public class GridStreamerResponse extends MessageAdapter { @Override public boolean readFrom(ByteBuffer buf) { reader.setBuffer(buf); + if (!reader.beforeMessageRead()) + return false; + switch (readState) { case 0: errBytes = reader.readByteArray("errBytes"); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/ae9df458/modules/core/src/main/java/org/apache/ignite/internal/util/GridByteArrayList.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/GridByteArrayList.java b/modules/core/src/main/java/org/apache/ignite/internal/util/GridByteArrayList.java index f96e0fb..eb4baec 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/GridByteArrayList.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/GridByteArrayList.java @@ -439,6 +439,9 @@ public class GridByteArrayList extends MessageAdapter implements Externalizable @Override public boolean readFrom(ByteBuffer buf) { reader.setBuffer(buf); + if (!reader.beforeMessageRead()) + return false; + switch (readState) { case 0: data = reader.readByteArray("data"); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/ae9df458/modules/core/src/main/java/org/apache/ignite/internal/util/GridLongList.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/GridLongList.java b/modules/core/src/main/java/org/apache/ignite/internal/util/GridLongList.java index a29dbcb..f86e7df 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/GridLongList.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/GridLongList.java @@ -537,6 +537,9 @@ public class GridLongList extends MessageAdapter implements Externalizable { @Override public boolean readFrom(ByteBuffer buf) { reader.setBuffer(buf); + if (!reader.beforeMessageRead()) + return false; + switch (readState) { case 0: arr = reader.readLongArray("arr"); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/ae9df458/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 66d50f8..7ef1905 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 @@ -81,6 +81,9 @@ public class JobStealingRequest extends MessageAdapter { @Override public boolean readFrom(ByteBuffer buf) { reader.setBuffer(buf); + if (!reader.beforeMessageRead()) + return false; + switch (readState) { case 0: delta = reader.readInt("delta");
