http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/1edbb8d9/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearTxPrepareRequest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearTxPrepareRequest.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearTxPrepareRequest.java index 6016553..ede1da3 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearTxPrepareRequest.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearTxPrepareRequest.java @@ -250,7 +250,7 @@ public class GridNearTxPrepareRequest<K, V> extends GridDistributedTxPrepareRequ return false; if (!writer.isHeaderWritten()) { - if (!writer.writeHeader(directType(), (byte)33)) + if (!writer.writeHeader(directType(), fieldsCount())) return false; writer.onHeaderWritten(); @@ -425,7 +425,7 @@ public class GridNearTxPrepareRequest<K, V> extends GridDistributedTxPrepareRequ /** {@inheritDoc} */ @Override public byte fieldsCount() { - return 0; // TODO: implement. + return 33; } /** {@inheritDoc} */
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/1edbb8d9/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearTxPrepareResponse.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearTxPrepareResponse.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearTxPrepareResponse.java index 6b93c70..07ad949 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearTxPrepareResponse.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearTxPrepareResponse.java @@ -290,7 +290,7 @@ public class GridNearTxPrepareResponse<K, V> extends GridDistributedTxPrepareRes return false; if (!writer.isHeaderWritten()) { - if (!writer.writeHeader(directType(), (byte)18)) + if (!writer.writeHeader(directType(), fieldsCount())) return false; writer.onHeaderWritten(); @@ -437,7 +437,7 @@ public class GridNearTxPrepareResponse<K, V> extends GridDistributedTxPrepareRes /** {@inheritDoc} */ @Override public byte fieldsCount() { - return 0; // TODO: implement. + return 18; } /** {@inheritDoc} */ http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/1edbb8d9/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearUnlockRequest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearUnlockRequest.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearUnlockRequest.java index 91c944d..59f6c22 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearUnlockRequest.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearUnlockRequest.java @@ -54,7 +54,7 @@ public class GridNearUnlockRequest<K, V> extends GridDistributedUnlockRequest<K, return false; if (!writer.isHeaderWritten()) { - if (!writer.writeHeader(directType(), (byte)9)) + if (!writer.writeHeader(directType(), fieldsCount())) return false; writer.onHeaderWritten(); @@ -83,7 +83,7 @@ public class GridNearUnlockRequest<K, V> extends GridDistributedUnlockRequest<K, /** {@inheritDoc} */ @Override public byte fieldsCount() { - return 0; // TODO: implement. + return 9; } /** {@inheritDoc} */ http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/1edbb8d9/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/GridCacheQueryRequest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/GridCacheQueryRequest.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/GridCacheQueryRequest.java index c330d58..0d8c00a 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/GridCacheQueryRequest.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/GridCacheQueryRequest.java @@ -448,7 +448,7 @@ public class GridCacheQueryRequest<K, V> extends GridCacheMessage<K, V> implemen return false; if (!writer.isHeaderWritten()) { - if (!writer.writeHeader(directType(), (byte)22)) + if (!writer.writeHeader(directType(), fieldsCount())) return false; writer.onHeaderWritten(); @@ -753,7 +753,7 @@ public class GridCacheQueryRequest<K, V> extends GridCacheMessage<K, V> implemen /** {@inheritDoc} */ @Override public byte fieldsCount() { - return 0; // TODO: implement. + return 22; } /** {@inheritDoc} */ http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/1edbb8d9/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/GridCacheQueryResponse.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/GridCacheQueryResponse.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/GridCacheQueryResponse.java index 1667090..7b79d4b 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/GridCacheQueryResponse.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/GridCacheQueryResponse.java @@ -209,7 +209,7 @@ public class GridCacheQueryResponse<K, V> extends GridCacheMessage<K, V> impleme return false; if (!writer.isHeaderWritten()) { - if (!writer.writeHeader(directType(), (byte)9)) + if (!writer.writeHeader(directType(), fieldsCount())) return false; writer.onHeaderWritten(); @@ -328,7 +328,7 @@ public class GridCacheQueryResponse<K, V> extends GridCacheMessage<K, V> impleme /** {@inheritDoc} */ @Override public byte fieldsCount() { - return 0; // TODO: implement. + return 9; } /** {@inheritDoc} */ http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/1edbb8d9/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/version/GridCacheVersion.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/version/GridCacheVersion.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/version/GridCacheVersion.java index ac7213a..d7bffac 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/version/GridCacheVersion.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/version/GridCacheVersion.java @@ -257,7 +257,7 @@ public class GridCacheVersion extends MessageAdapter implements Comparable<GridC writer.setBuffer(buf); if (!writer.isHeaderWritten()) { - if (!writer.writeHeader(directType(), (byte)4)) + if (!writer.writeHeader(directType(), fieldsCount())) return false; writer.onHeaderWritten(); @@ -345,7 +345,7 @@ public class GridCacheVersion extends MessageAdapter implements Comparable<GridC /** {@inheritDoc} */ @Override public byte fieldsCount() { - return 0; // TODO: implement. + return 4; } /** {@inheritDoc} */ http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/1edbb8d9/modules/core/src/main/java/org/apache/ignite/internal/processors/clock/GridClockDeltaSnapshotMessage.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/clock/GridClockDeltaSnapshotMessage.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/clock/GridClockDeltaSnapshotMessage.java index 08175c3..5fdc693 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/clock/GridClockDeltaSnapshotMessage.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/clock/GridClockDeltaSnapshotMessage.java @@ -76,7 +76,7 @@ public class GridClockDeltaSnapshotMessage extends MessageAdapter { writer.setBuffer(buf); if (!writer.isHeaderWritten()) { - if (!writer.writeHeader(directType(), (byte)2)) + if (!writer.writeHeader(directType(), fieldsCount())) return false; writer.onHeaderWritten(); @@ -136,7 +136,7 @@ public class GridClockDeltaSnapshotMessage extends MessageAdapter { /** {@inheritDoc} */ @Override public byte fieldsCount() { - return 0; // TODO: implement. + return 2; } /** {@inheritDoc} */ http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/1edbb8d9/modules/core/src/main/java/org/apache/ignite/internal/processors/clock/GridClockDeltaVersion.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/clock/GridClockDeltaVersion.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/clock/GridClockDeltaVersion.java index 86fab7e..faae44c 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/clock/GridClockDeltaVersion.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/clock/GridClockDeltaVersion.java @@ -117,7 +117,7 @@ public class GridClockDeltaVersion extends MessageAdapter implements Comparable< writer.setBuffer(buf); if (!writer.isHeaderWritten()) { - if (!writer.writeHeader(directType(), (byte)2)) + if (!writer.writeHeader(directType(), fieldsCount())) return false; writer.onHeaderWritten(); @@ -177,7 +177,7 @@ public class GridClockDeltaVersion extends MessageAdapter implements Comparable< /** {@inheritDoc} */ @Override public byte fieldsCount() { - return 0; // TODO: implement. + return 2; } /** {@inheritDoc} */ http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/1edbb8d9/modules/core/src/main/java/org/apache/ignite/internal/processors/continuous/GridContinuousMessage.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/continuous/GridContinuousMessage.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/continuous/GridContinuousMessage.java index 0b999b1..0159af7 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/continuous/GridContinuousMessage.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/continuous/GridContinuousMessage.java @@ -135,7 +135,7 @@ public class GridContinuousMessage extends MessageAdapter { writer.setBuffer(buf); if (!writer.isHeaderWritten()) { - if (!writer.writeHeader(directType(), (byte)4)) + if (!writer.writeHeader(directType(), fieldsCount())) return false; writer.onHeaderWritten(); @@ -227,7 +227,7 @@ public class GridContinuousMessage extends MessageAdapter { /** {@inheritDoc} */ @Override public byte fieldsCount() { - return 0; // TODO: implement. + return 4; } /** {@inheritDoc} */ http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/1edbb8d9/modules/core/src/main/java/org/apache/ignite/internal/processors/dataload/GridDataLoadRequest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/dataload/GridDataLoadRequest.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/dataload/GridDataLoadRequest.java index 453ab43..5c1578c 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/dataload/GridDataLoadRequest.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/dataload/GridDataLoadRequest.java @@ -227,7 +227,7 @@ public class GridDataLoadRequest extends MessageAdapter { writer.setBuffer(buf); if (!writer.isHeaderWritten()) { - if (!writer.writeHeader(directType(), (byte)13)) + if (!writer.writeHeader(directType(), fieldsCount())) return false; writer.onHeaderWritten(); @@ -445,6 +445,6 @@ public class GridDataLoadRequest extends MessageAdapter { /** {@inheritDoc} */ @Override public byte fieldsCount() { - return 0; // TODO: implement. + return 13; } } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/1edbb8d9/modules/core/src/main/java/org/apache/ignite/internal/processors/dataload/GridDataLoadResponse.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/dataload/GridDataLoadResponse.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/dataload/GridDataLoadResponse.java index 19a599c..84f11d5 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/dataload/GridDataLoadResponse.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/dataload/GridDataLoadResponse.java @@ -87,7 +87,7 @@ public class GridDataLoadResponse extends MessageAdapter { writer.setBuffer(buf); if (!writer.isHeaderWritten()) { - if (!writer.writeHeader(directType(), (byte)3)) + if (!writer.writeHeader(directType(), fieldsCount())) return false; writer.onHeaderWritten(); @@ -161,6 +161,6 @@ public class GridDataLoadResponse extends MessageAdapter { /** {@inheritDoc} */ @Override public byte fieldsCount() { - return 0; // TODO: implement. + return 3; } } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/1edbb8d9/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsAckMessage.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsAckMessage.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsAckMessage.java index 6f8000f..5e6917e 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsAckMessage.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsAckMessage.java @@ -110,7 +110,7 @@ public class IgfsAckMessage extends IgfsCommunicationMessage { return false; if (!writer.isHeaderWritten()) { - if (!writer.writeHeader(directType(), (byte)3)) + if (!writer.writeHeader(directType(), fieldsCount())) return false; writer.onHeaderWritten(); @@ -187,6 +187,6 @@ public class IgfsAckMessage extends IgfsCommunicationMessage { /** {@inheritDoc} */ @Override public byte fieldsCount() { - return 0; // TODO: implement. + return 3; } } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/1edbb8d9/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsBlockKey.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsBlockKey.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsBlockKey.java index 514eab3..b9be6a3 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsBlockKey.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsBlockKey.java @@ -162,7 +162,7 @@ public final class IgfsBlockKey extends MessageAdapter implements Externalizable writer.setBuffer(buf); if (!writer.isHeaderWritten()) { - if (!writer.writeHeader(directType(), (byte)4)) + if (!writer.writeHeader(directType(), fieldsCount())) return false; writer.onHeaderWritten(); @@ -250,7 +250,7 @@ public final class IgfsBlockKey extends MessageAdapter implements Externalizable /** {@inheritDoc} */ @Override public byte fieldsCount() { - return 0; // TODO: implement. + return 4; } /** {@inheritDoc} */ http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/1edbb8d9/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsBlocksMessage.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsBlocksMessage.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsBlocksMessage.java index 7f054e8..006ca39 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsBlocksMessage.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsBlocksMessage.java @@ -91,7 +91,7 @@ public class IgfsBlocksMessage extends IgfsCommunicationMessage { return false; if (!writer.isHeaderWritten()) { - if (!writer.writeHeader(directType(), (byte)3)) + if (!writer.writeHeader(directType(), fieldsCount())) return false; writer.onHeaderWritten(); @@ -168,6 +168,6 @@ public class IgfsBlocksMessage extends IgfsCommunicationMessage { /** {@inheritDoc} */ @Override public byte fieldsCount() { - return 0; // TODO: implement. + return 3; } } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/1edbb8d9/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsCommunicationMessage.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsCommunicationMessage.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsCommunicationMessage.java index 5f2a801..ecfd876 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsCommunicationMessage.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsCommunicationMessage.java @@ -53,7 +53,7 @@ public abstract class IgfsCommunicationMessage extends MessageAdapter { writer.setBuffer(buf); if (!writer.isHeaderWritten()) { - if (!writer.writeHeader(directType(), (byte)0)) + if (!writer.writeHeader(directType(), fieldsCount())) return false; writer.onHeaderWritten(); @@ -74,6 +74,6 @@ public abstract class IgfsCommunicationMessage extends MessageAdapter { /** {@inheritDoc} */ @Override public byte fieldsCount() { - return 0; // TODO: implement. + return 0; } } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/1edbb8d9/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 3f0828c..e02f1a3 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 @@ -114,7 +114,7 @@ public class IgfsDeleteMessage extends IgfsCommunicationMessage { return false; if (!writer.isHeaderWritten()) { - if (!writer.writeHeader(directType(), (byte)2)) + if (!writer.writeHeader(directType(), fieldsCount())) return false; writer.onHeaderWritten(); @@ -177,7 +177,7 @@ public class IgfsDeleteMessage extends IgfsCommunicationMessage { /** {@inheritDoc} */ @Override public byte fieldsCount() { - return 0; // TODO: implement. + return 2; } /** {@inheritDoc} */ http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/1edbb8d9/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 2d4bd91..e736520 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 @@ -267,7 +267,7 @@ public class IgfsFileAffinityRange extends MessageAdapter implements Externaliza writer.setBuffer(buf); if (!writer.isHeaderWritten()) { - if (!writer.writeHeader(directType(), (byte)5)) + if (!writer.writeHeader(directType(), fieldsCount())) return false; writer.onHeaderWritten(); @@ -369,7 +369,7 @@ public class IgfsFileAffinityRange extends MessageAdapter implements Externaliza /** {@inheritDoc} */ @Override public byte fieldsCount() { - return 0; // TODO: implement. + return 5; } /** {@inheritDoc} */ http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/1edbb8d9/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 a23cca2..f915c83 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 @@ -86,7 +86,7 @@ public class IgfsFragmentizerRequest extends IgfsCommunicationMessage { return false; if (!writer.isHeaderWritten()) { - if (!writer.writeHeader(directType(), (byte)2)) + if (!writer.writeHeader(directType(), fieldsCount())) return false; writer.onHeaderWritten(); @@ -149,6 +149,6 @@ public class IgfsFragmentizerRequest extends IgfsCommunicationMessage { /** {@inheritDoc} */ @Override public byte fieldsCount() { - return 0; // TODO: implement. + return 2; } } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/1edbb8d9/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 a2a0151..d0cc4d1 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 @@ -62,7 +62,7 @@ public class IgfsFragmentizerResponse extends IgfsCommunicationMessage { return false; if (!writer.isHeaderWritten()) { - if (!writer.writeHeader(directType(), (byte)1)) + if (!writer.writeHeader(directType(), fieldsCount())) return false; writer.onHeaderWritten(); @@ -111,6 +111,6 @@ public class IgfsFragmentizerResponse extends IgfsCommunicationMessage { /** {@inheritDoc} */ @Override public byte fieldsCount() { - return 0; // TODO: implement. + return 1; } } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/1edbb8d9/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 fecbe4f..2f8b941 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 @@ -79,7 +79,7 @@ public class IgfsSyncMessage extends IgfsCommunicationMessage { return false; if (!writer.isHeaderWritten()) { - if (!writer.writeHeader(directType(), (byte)2)) + if (!writer.writeHeader(directType(), fieldsCount())) return false; writer.onHeaderWritten(); @@ -142,6 +142,6 @@ public class IgfsSyncMessage extends IgfsCommunicationMessage { /** {@inheritDoc} */ @Override public byte fieldsCount() { - return 0; // TODO: implement. + return 2; } } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/1edbb8d9/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 a221157..7fd99e3 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 @@ -103,7 +103,7 @@ public class GridTaskResultRequest extends MessageAdapter { writer.setBuffer(buf); if (!writer.isHeaderWritten()) { - if (!writer.writeHeader(directType(), (byte)2)) + if (!writer.writeHeader(directType(), fieldsCount())) return false; writer.onHeaderWritten(); @@ -163,6 +163,6 @@ public class GridTaskResultRequest extends MessageAdapter { /** {@inheritDoc} */ @Override public byte fieldsCount() { - return 0; // TODO: implement. + return 2; } } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/1edbb8d9/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 fe02543..9636dc8 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 @@ -121,7 +121,7 @@ public class GridTaskResultResponse extends MessageAdapter { writer.setBuffer(buf); if (!writer.isHeaderWritten()) { - if (!writer.writeHeader(directType(), (byte)4)) + if (!writer.writeHeader(directType(), fieldsCount())) return false; writer.onHeaderWritten(); @@ -209,6 +209,6 @@ public class GridTaskResultResponse extends MessageAdapter { /** {@inheritDoc} */ @Override public byte fieldsCount() { - return 0; // TODO: implement. + return 4; } } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/1edbb8d9/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 6950f45..264b73c 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 @@ -59,7 +59,7 @@ public class GridStreamerCancelRequest extends MessageAdapter { writer.setBuffer(buf); if (!writer.isHeaderWritten()) { - if (!writer.writeHeader(directType(), (byte)1)) + if (!writer.writeHeader(directType(), fieldsCount())) return false; writer.onHeaderWritten(); @@ -105,6 +105,6 @@ public class GridStreamerCancelRequest extends MessageAdapter { /** {@inheritDoc} */ @Override public byte fieldsCount() { - return 0; // TODO: implement. + return 1; } } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/1edbb8d9/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 3aa36e7..c4d01c8 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 @@ -154,7 +154,7 @@ public class GridStreamerExecutionRequest extends MessageAdapter { writer.setBuffer(buf); if (!writer.isHeaderWritten()) { - if (!writer.writeHeader(directType(), (byte)7)) + if (!writer.writeHeader(directType(), fieldsCount())) return false; writer.onHeaderWritten(); @@ -288,6 +288,6 @@ public class GridStreamerExecutionRequest extends MessageAdapter { /** {@inheritDoc} */ @Override public byte fieldsCount() { - return 0; // TODO: implement. + return 7; } } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/1edbb8d9/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 995a95f..2260921 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 @@ -79,7 +79,7 @@ public class GridStreamerResponse extends MessageAdapter { writer.setBuffer(buf); if (!writer.isHeaderWritten()) { - if (!writer.writeHeader(directType(), (byte)2)) + if (!writer.writeHeader(directType(), fieldsCount())) return false; writer.onHeaderWritten(); @@ -139,6 +139,6 @@ public class GridStreamerResponse extends MessageAdapter { /** {@inheritDoc} */ @Override public byte fieldsCount() { - return 0; // TODO: implement. + return 2; } } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/1edbb8d9/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 cc0052c..85bd7c8 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 @@ -411,7 +411,7 @@ public class GridByteArrayList extends MessageAdapter implements Externalizable writer.setBuffer(buf); if (!writer.isHeaderWritten()) { - if (!writer.writeHeader(directType(), (byte)2)) + if (!writer.writeHeader(directType(), fieldsCount())) return false; writer.onHeaderWritten(); @@ -471,7 +471,7 @@ public class GridByteArrayList extends MessageAdapter implements Externalizable /** {@inheritDoc} */ @Override public byte fieldsCount() { - return 0; // TODO: implement. + return 2; } /** {@inheritDoc} */ http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/1edbb8d9/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 6261e00..439063e 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 @@ -509,7 +509,7 @@ public class GridLongList extends MessageAdapter implements Externalizable { writer.setBuffer(buf); if (!writer.isHeaderWritten()) { - if (!writer.writeHeader(directType(), (byte)2)) + if (!writer.writeHeader(directType(), fieldsCount())) return false; writer.onHeaderWritten(); @@ -569,6 +569,6 @@ public class GridLongList extends MessageAdapter implements Externalizable { /** {@inheritDoc} */ @Override public byte fieldsCount() { - return 0; // TODO: implement. + return 2; } } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/1edbb8d9/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 2d5089b..d17fd23 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 @@ -59,7 +59,7 @@ public class JobStealingRequest extends MessageAdapter { writer.setBuffer(buf); if (!writer.isHeaderWritten()) { - if (!writer.writeHeader(directType(), (byte)1)) + if (!writer.writeHeader(directType(), fieldsCount())) return false; writer.onHeaderWritten(); @@ -105,7 +105,7 @@ public class JobStealingRequest extends MessageAdapter { /** {@inheritDoc} */ @Override public byte fieldsCount() { - return 0; // TODO: implement. + return 1; } /** {@inheritDoc} */
