IGNITE-264 - Rebuilt mesasge.
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/6356e5e7 Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/6356e5e7 Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/6356e5e7 Branch: refs/heads/ignite-264 Commit: 6356e5e71ce247b417a3d09064122eefb950a42b Parents: e9fd4f7 Author: Alexey Goncharuk <agoncha...@gridgain.com> Authored: Tue Feb 24 17:36:53 2015 -0800 Committer: Alexey Goncharuk <agoncha...@gridgain.com> Committed: Tue Feb 24 17:36:53 2015 -0800 ---------------------------------------------------------------------- .../dht/GridDhtTxFinishResponse.java | 20 +++++++++++++++++--- 1 file changed, 17 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/6356e5e7/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtTxFinishResponse.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtTxFinishResponse.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtTxFinishResponse.java index 1627334..9f3c38e 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtTxFinishResponse.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtTxFinishResponse.java @@ -142,12 +142,18 @@ public class GridDhtTxFinishResponse<K, V> extends GridDistributedTxFinishRespon switch (writer.state()) { case 5: - if (!writer.writeByteArray("errBytes", errBytes)) + if (!writer.writeBoolean("checkCommitted", checkCommitted)) return false; writer.incrementState(); case 6: + if (!writer.writeByteArray("errBytes", errBytes)) + return false; + + writer.incrementState(); + + case 7: if (!writer.writeIgniteUuid("miniId", miniId)) return false; @@ -170,7 +176,7 @@ public class GridDhtTxFinishResponse<K, V> extends GridDistributedTxFinishRespon switch (reader.state()) { case 5: - errBytes = reader.readByteArray("errBytes"); + checkCommitted = reader.readBoolean("checkCommitted"); if (!reader.isLastRead()) return false; @@ -178,6 +184,14 @@ public class GridDhtTxFinishResponse<K, V> extends GridDistributedTxFinishRespon reader.incrementState(); case 6: + errBytes = reader.readByteArray("errBytes"); + + if (!reader.isLastRead()) + return false; + + reader.incrementState(); + + case 7: miniId = reader.readIgniteUuid("miniId"); if (!reader.isLastRead()) @@ -197,6 +211,6 @@ public class GridDhtTxFinishResponse<K, V> extends GridDistributedTxFinishRespon /** {@inheritDoc} */ @Override public byte fieldsCount() { - return 7; + return 8; } }
