#ignite-51: IgniteTxEntry implements Message: small fixs.
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/3dbf815c Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/3dbf815c Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/3dbf815c Branch: refs/heads/ignite-user-req Commit: 3dbf815ca7fab42d9b66e395d14acdb2ee3569f7 Parents: 832657e Author: ivasilinets <ivasilin...@gridgain.com> Authored: Wed Mar 4 12:48:06 2015 +0300 Committer: ivasilinets <ivasilin...@gridgain.com> Committed: Wed Mar 4 12:48:06 2015 +0300 ---------------------------------------------------------------------- .../cache/transactions/IgniteTxEntry.java | 24 ++++---------------- 1 file changed, 5 insertions(+), 19 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/3dbf815c/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/IgniteTxEntry.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/IgniteTxEntry.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/IgniteTxEntry.java index 43ea4e5..f85fc37 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/IgniteTxEntry.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/IgniteTxEntry.java @@ -825,24 +825,18 @@ public class IgniteTxEntry implements GridPeerDeployAware, Message { writer.incrementState(); case 8: - if (!writer.writeBoolean("transferExpiryPlc", transferExpiryPlc)) - return false; - - writer.incrementState(); - - case 9: if (!writer.writeByteArray("transformClosBytes", transformClosBytes)) return false; writer.incrementState(); - case 10: + case 9: if (!writer.writeLong("ttl", ttl)) return false; writer.incrementState(); - case 11: + case 10: if (!writer.writeMessage("val", val)) return false; @@ -926,14 +920,6 @@ public class IgniteTxEntry implements GridPeerDeployAware, Message { reader.incrementState(); case 8: - transferExpiryPlc = reader.readBoolean("transferExpiryPlc"); - - if (!reader.isLastRead()) - return false; - - reader.incrementState(); - - case 9: transformClosBytes = reader.readByteArray("transformClosBytes"); if (!reader.isLastRead()) @@ -941,7 +927,7 @@ public class IgniteTxEntry implements GridPeerDeployAware, Message { reader.incrementState(); - case 10: + case 9: ttl = reader.readLong("ttl"); if (!reader.isLastRead()) @@ -949,7 +935,7 @@ public class IgniteTxEntry implements GridPeerDeployAware, Message { reader.incrementState(); - case 11: + case 10: val = reader.readMessage("val"); if (!reader.isLastRead()) @@ -969,7 +955,7 @@ public class IgniteTxEntry implements GridPeerDeployAware, Message { /** {@inheritDoc} */ @Override public byte fieldsCount() { - return 12; + return 11; } /** {@inheritDoc} */
