Repository: ignite Updated Branches: refs/heads/ignite-single-op-tx 19e1f4e16 -> 2de554525
'Single' operations optimizations for tx cache. Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/2de55452 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/2de55452 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/2de55452 Branch: refs/heads/ignite-single-op-tx Commit: 2de55452547970ac6fae1ca78c7021392918f843 Parents: 19e1f4e Author: sboikov <[email protected]> Authored: Mon Nov 16 16:24:36 2015 +0300 Committer: sboikov <[email protected]> Committed: Mon Nov 16 16:28:01 2015 +0300 ---------------------------------------------------------------------- .../processors/cache/distributed/near/GridNearTxLocal.java | 1 + .../cache/transactions/IgniteTxImplicitSingleStateImpl.java | 6 ++++++ .../cache/transactions/IgniteTxRemoteSingleStateImpl.java | 6 ++++++ .../processors/cache/transactions/IgniteTxRemoteStateImpl.java | 6 ++++++ .../processors/cache/transactions/IgniteTxStateImpl.java | 6 ++++++ 5 files changed, 25 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/2de55452/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearTxLocal.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearTxLocal.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearTxLocal.java index 8c351cc..5f98de8 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearTxLocal.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearTxLocal.java @@ -558,6 +558,7 @@ public class GridNearTxLocal extends GridDhtTxLocalAdapter { /** * @param map Mapping. + * @param entry Entry. */ void addSingleEntryMapping(GridDistributedTxMapping map, IgniteTxEntry entry) { ClusterNode n = map.node(); http://git-wip-us.apache.org/repos/asf/ignite/blob/2de55452/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/IgniteTxImplicitSingleStateImpl.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/IgniteTxImplicitSingleStateImpl.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/IgniteTxImplicitSingleStateImpl.java index c4012e9..5f48469 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/IgniteTxImplicitSingleStateImpl.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/IgniteTxImplicitSingleStateImpl.java @@ -29,6 +29,7 @@ import org.apache.ignite.internal.processors.cache.distributed.dht.GridDhtTopolo import org.apache.ignite.internal.processors.cache.store.CacheStoreManager; import org.apache.ignite.internal.util.future.GridFutureAdapter; import org.apache.ignite.internal.util.typedef.internal.CU; +import org.apache.ignite.internal.util.typedef.internal.S; import org.apache.ignite.internal.util.typedef.internal.U; import org.jetbrains.annotations.Nullable; @@ -250,4 +251,9 @@ public class IgniteTxImplicitSingleStateImpl extends IgniteTxLocalStateAdapter { @Override public IgniteTxEntry singleWrite() { return entry; } + + /** {@inheritDoc} */ + public String toString() { + return S.toString(IgniteTxImplicitSingleStateImpl.class, this); + } } http://git-wip-us.apache.org/repos/asf/ignite/blob/2de55452/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/IgniteTxRemoteSingleStateImpl.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/IgniteTxRemoteSingleStateImpl.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/IgniteTxRemoteSingleStateImpl.java index 07556a6..22f04a8 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/IgniteTxRemoteSingleStateImpl.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/IgniteTxRemoteSingleStateImpl.java @@ -21,6 +21,7 @@ import java.util.Collection; import java.util.Collections; import java.util.Map; import java.util.Set; +import org.apache.ignite.internal.util.typedef.internal.S; import org.jetbrains.annotations.Nullable; /** @@ -99,4 +100,9 @@ public class IgniteTxRemoteSingleStateImpl extends IgniteTxRemoteStateAdapter { @Nullable @Override public IgniteTxEntry singleWrite() { return entry; } + + /** {@inheritDoc} */ + public String toString() { + return S.toString(IgniteTxRemoteSingleStateImpl.class, this); + } } http://git-wip-us.apache.org/repos/asf/ignite/blob/2de55452/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/IgniteTxRemoteStateImpl.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/IgniteTxRemoteStateImpl.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/IgniteTxRemoteStateImpl.java index d7795ed..32bc646 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/IgniteTxRemoteStateImpl.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/IgniteTxRemoteStateImpl.java @@ -22,6 +22,7 @@ import java.util.Map; import java.util.Set; import org.apache.ignite.internal.util.tostring.GridToStringInclude; import org.apache.ignite.internal.util.typedef.F; +import org.apache.ignite.internal.util.typedef.internal.S; /** * @@ -115,4 +116,9 @@ public class IgniteTxRemoteStateImpl extends IgniteTxRemoteStateAdapter { @Override public IgniteTxEntry singleWrite() { return null; } + + /** {@inheritDoc} */ + public String toString() { + return S.toString(IgniteTxRemoteStateImpl.class, this); + } } http://git-wip-us.apache.org/repos/asf/ignite/blob/2de55452/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/IgniteTxStateImpl.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/IgniteTxStateImpl.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/IgniteTxStateImpl.java index d80cef9..c95fb19 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/IgniteTxStateImpl.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/IgniteTxStateImpl.java @@ -34,6 +34,7 @@ import org.apache.ignite.internal.util.tostring.GridToStringExclude; import org.apache.ignite.internal.util.tostring.GridToStringInclude; import org.apache.ignite.internal.util.typedef.F; import org.apache.ignite.internal.util.typedef.internal.CU; +import org.apache.ignite.internal.util.typedef.internal.S; import org.apache.ignite.internal.util.typedef.internal.U; import org.jetbrains.annotations.Nullable; @@ -366,4 +367,9 @@ public class IgniteTxStateImpl extends IgniteTxLocalStateAdapter { @Override public IgniteTxEntry singleWrite() { return writeView != null && writeView.size() == 1 ? F.firstValue(writeView) : null; } + + /** {@inheritDoc} */ + public String toString() { + return S.toString(IgniteTxStateImpl.class, this); + } }
