http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/d85b5133/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 86246d5..fecbe4f 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 @@ -139,4 +139,9 @@ public class IgfsSyncMessage extends IgfsCommunicationMessage { @Override public byte directType() { return 71; } + + /** {@inheritDoc} */ + @Override public byte fieldsCount() { + return 0; // TODO: implement. + } }
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/d85b5133/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 1d0d9d0..a221157 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 @@ -160,4 +160,9 @@ public class GridTaskResultRequest extends MessageAdapter { @Override public byte directType() { return 76; } + + /** {@inheritDoc} */ + @Override public byte fieldsCount() { + return 0; // TODO: implement. + } } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/d85b5133/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 b2d36a5..fe02543 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 @@ -206,4 +206,9 @@ public class GridTaskResultResponse extends MessageAdapter { @Override public byte directType() { return 77; } + + /** {@inheritDoc} */ + @Override public byte fieldsCount() { + return 0; // TODO: implement. + } } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/d85b5133/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 64301c6..6950f45 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 @@ -102,4 +102,9 @@ public class GridStreamerCancelRequest extends MessageAdapter { @Override public byte directType() { return 79; } + + /** {@inheritDoc} */ + @Override public byte fieldsCount() { + return 0; // TODO: implement. + } } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/d85b5133/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 0c4b386..3aa36e7 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 @@ -285,4 +285,9 @@ public class GridStreamerExecutionRequest extends MessageAdapter { @Override public byte directType() { return 80; } + + /** {@inheritDoc} */ + @Override public byte fieldsCount() { + return 0; // TODO: implement. + } } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/d85b5133/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 a5ba781..995a95f 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 @@ -136,4 +136,9 @@ public class GridStreamerResponse extends MessageAdapter { @Override public byte directType() { return 81; } + + /** {@inheritDoc} */ + @Override public byte fieldsCount() { + return 0; // TODO: implement. + } } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/d85b5133/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 eb4baec..cc0052c 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 @@ -470,6 +470,11 @@ public class GridByteArrayList extends MessageAdapter implements Externalizable } /** {@inheritDoc} */ + @Override public byte fieldsCount() { + return 0; // TODO: implement. + } + + /** {@inheritDoc} */ @Override public String toString() { return S.toString(GridByteArrayList.class, this); } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/d85b5133/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 f86e7df..6261e00 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 @@ -566,4 +566,9 @@ public class GridLongList extends MessageAdapter implements Externalizable { @Override public byte directType() { return 85; } + + /** {@inheritDoc} */ + @Override public byte fieldsCount() { + return 0; // TODO: implement. + } } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/d85b5133/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 7ef1905..2d5089b 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 @@ -104,6 +104,11 @@ public class JobStealingRequest extends MessageAdapter { } /** {@inheritDoc} */ + @Override public byte fieldsCount() { + return 0; // TODO: implement. + } + + /** {@inheritDoc} */ @Override public String toString() { return S.toString(JobStealingRequest.class, this); } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/d85b5133/modules/core/src/main/java/org/apache/ignite/spi/communication/tcp/TcpCommunicationSpi.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/spi/communication/tcp/TcpCommunicationSpi.java b/modules/core/src/main/java/org/apache/ignite/spi/communication/tcp/TcpCommunicationSpi.java index 230ef6c..255822e 100644 --- a/modules/core/src/main/java/org/apache/ignite/spi/communication/tcp/TcpCommunicationSpi.java +++ b/modules/core/src/main/java/org/apache/ignite/spi/communication/tcp/TcpCommunicationSpi.java @@ -3079,6 +3079,11 @@ public class TcpCommunicationSpi extends IgniteSpiAdapter } /** {@inheritDoc} */ + @Override public byte fieldsCount() { + throw new UnsupportedOperationException(); + } + + /** {@inheritDoc} */ @Override public String toString() { return S.toString(HandshakeMessage.class, this); } @@ -3143,6 +3148,10 @@ public class TcpCommunicationSpi extends IgniteSpiAdapter return RECOVERY_LAST_ID_MSG_TYPE; } + @Override public byte fieldsCount() { + return 0; // TODO: implement. + } + /** {@inheritDoc} */ @Override public boolean skipRecovery() { return true; @@ -3216,6 +3225,10 @@ public class TcpCommunicationSpi extends IgniteSpiAdapter return NODE_ID_MSG_TYPE; } + @Override public byte fieldsCount() { + return 0; // TODO: implement. + } + /** {@inheritDoc} */ @Override public String toString() { return S.toString(NodeIdMessage.class, this); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/d85b5133/modules/core/src/test/java/org/apache/ignite/internal/managers/communication/GridCommunicationSendMessageSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/managers/communication/GridCommunicationSendMessageSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/managers/communication/GridCommunicationSendMessageSelfTest.java index d37c67c..3f19bef 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/managers/communication/GridCommunicationSendMessageSelfTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/managers/communication/GridCommunicationSendMessageSelfTest.java @@ -159,5 +159,10 @@ public class GridCommunicationSendMessageSelfTest extends GridCommonAbstractTest @Override public byte directType() { return DIRECT_TYPE; } + + /** {@inheritDoc} */ + @Override public byte fieldsCount() { + return 0; + } } } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/d85b5133/modules/core/src/test/java/org/apache/ignite/internal/managers/communication/GridIoManagerSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/managers/communication/GridIoManagerSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/managers/communication/GridIoManagerSelfTest.java index b112617..f9add5a 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/managers/communication/GridIoManagerSelfTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/managers/communication/GridIoManagerSelfTest.java @@ -233,5 +233,10 @@ public class GridIoManagerSelfTest extends GridCommonAbstractTest { @Override public byte directType() { return 0; } + + /** {@inheritDoc} */ + @Override public byte fieldsCount() { + return 0; + } } } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/d85b5133/modules/core/src/test/java/org/apache/ignite/loadtests/communication/GridTestMessage.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/loadtests/communication/GridTestMessage.java b/modules/core/src/test/java/org/apache/ignite/loadtests/communication/GridTestMessage.java index e4d6ab4..dbc8394 100644 --- a/modules/core/src/test/java/org/apache/ignite/loadtests/communication/GridTestMessage.java +++ b/modules/core/src/test/java/org/apache/ignite/loadtests/communication/GridTestMessage.java @@ -121,4 +121,9 @@ class GridTestMessage extends MessageAdapter implements Externalizable { @Override public byte directType() { return 0; } + + /** {@inheritDoc} */ + @Override public byte fieldsCount() { + return 0; + } } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/d85b5133/modules/core/src/test/java/org/apache/ignite/spi/communication/GridTestMessage.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/spi/communication/GridTestMessage.java b/modules/core/src/test/java/org/apache/ignite/spi/communication/GridTestMessage.java index 20c009b..9104d20 100644 --- a/modules/core/src/test/java/org/apache/ignite/spi/communication/GridTestMessage.java +++ b/modules/core/src/test/java/org/apache/ignite/spi/communication/GridTestMessage.java @@ -98,7 +98,7 @@ public class GridTestMessage extends MessageAdapter { writer.setBuffer(buf); if (!writer.isHeaderWritten()) { - if (!writer.writeByte(null, directType())) + if (!writer.writeHeader(directType(), fieldsCount())) return false; writer.onHeaderWritten(); @@ -180,6 +180,11 @@ public class GridTestMessage extends MessageAdapter { } /** {@inheritDoc} */ + @Override public byte fieldsCount() { + return 4; + } + + /** {@inheritDoc} */ @Override public boolean equals(Object o) { if (this == o) return true;
