Return-Path: X-Original-To: apmail-ignite-commits-archive@minotaur.apache.org Delivered-To: apmail-ignite-commits-archive@minotaur.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id C6D07C5DF for ; Sun, 21 Dec 2014 23:05:39 +0000 (UTC) Received: (qmail 85757 invoked by uid 500); 21 Dec 2014 23:05:39 -0000 Delivered-To: apmail-ignite-commits-archive@ignite.apache.org Received: (qmail 85717 invoked by uid 500); 21 Dec 2014 23:05:39 -0000 Mailing-List: contact commits-help@ignite.incubator.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@ignite.incubator.apache.org Delivered-To: mailing list commits@ignite.incubator.apache.org Received: (qmail 85704 invoked by uid 99); 21 Dec 2014 23:05:39 -0000 Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136) by apache.org (qpsmtpd/0.29) with ESMTP; Sun, 21 Dec 2014 23:05:39 +0000 X-ASF-Spam-Status: No, hits=-2000.0 required=5.0 tests=ALL_TRUSTED,T_RP_MATCHES_RCVD X-Spam-Check-By: apache.org Received: from [140.211.11.3] (HELO mail.apache.org) (140.211.11.3) by apache.org (qpsmtpd/0.29) with SMTP; Sun, 21 Dec 2014 23:05:31 +0000 Received: (qmail 82510 invoked by uid 99); 21 Dec 2014 23:03:56 -0000 Received: from tyr.zones.apache.org (HELO tyr.zones.apache.org) (140.211.11.114) by apache.org (qpsmtpd/0.29) with ESMTP; Sun, 21 Dec 2014 23:03:56 +0000 Received: by tyr.zones.apache.org (Postfix, from userid 65534) id C237B9CC536; Sun, 21 Dec 2014 23:03:55 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: agoncharuk@apache.org To: commits@ignite.incubator.apache.org Date: Sun, 21 Dec 2014 23:04:13 -0000 Message-Id: <28d06b2b4c8e4c0da58c53e1850c77bf@git.apache.org> In-Reply-To: References: X-Mailer: ASF-Git Admin Mailer Subject: [20/46] incubator-ignite git commit: GG-9141 - Renaming X-Virus-Checked: Checked by ClamAV on apache.org http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/3008d2ad/modules/core/src/main/java/org/gridgain/grid/kernal/processors/cache/GridCacheTxLocalAdapter.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/gridgain/grid/kernal/processors/cache/GridCacheTxLocalAdapter.java b/modules/core/src/main/java/org/gridgain/grid/kernal/processors/cache/GridCacheTxLocalAdapter.java index 85702a7..28c56ee 100644 --- a/modules/core/src/main/java/org/gridgain/grid/kernal/processors/cache/GridCacheTxLocalAdapter.java +++ b/modules/core/src/main/java/org/gridgain/grid/kernal/processors/cache/GridCacheTxLocalAdapter.java @@ -2971,8 +2971,8 @@ public abstract class GridCacheTxLocalAdapter extends GridCacheTxAdapter, T>() { - @Override public T apply(IgniteFuture f) { + return rollbackAsync().chain(new C1, T>() { + @Override public T apply(IgniteFuture f) { throw new GridClosureException(e); } }); @@ -2988,8 +2988,8 @@ public abstract class GridCacheTxLocalAdapter extends GridCacheTxAdapter V1 meta(String name) { - return tx.meta(name); - } - - /** {@inheritDoc} */ - @SuppressWarnings({"RedundantTypeArguments"}) - @Override public V1 removeMeta(String name) { - return tx.removeMeta(name); - } - - /** {@inheritDoc} */ - @Override public boolean removeMeta(String name, V1 val) { - return tx.removeMeta(name, val); - } - - /** {@inheritDoc} */ - @Override public Map allMeta() { - return tx.allMeta(); - } - - /** {@inheritDoc} */ - @Override public boolean hasMeta(String name) { - return tx.hasMeta(name); - } - - /** {@inheritDoc} */ - @Override public boolean hasMeta(String name, V1 val) { - return tx.hasMeta(name, val); - } - - /** {@inheritDoc} */ - @Override public boolean replaceMeta(String name, V1 curVal, V1 newVal) { - return tx.replaceMeta(name, curVal, newVal); - } - - /** {@inheritDoc} */ - @Override public void writeExternal(ObjectOutput out) throws IOException { - out.writeObject(tx); - } - - /** {@inheritDoc} */ - @Override public void readExternal(ObjectInput in) throws IOException, ClassNotFoundException { - tx = (GridCacheTxAdapter)in.readObject(); - } - - /** {@inheritDoc} */ - @Override public String toString() { - return S.toString(GridCacheTxProxyImpl.class, this); - } -} http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/3008d2ad/modules/core/src/main/java/org/gridgain/grid/kernal/processors/cache/GridCacheUtils.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/gridgain/grid/kernal/processors/cache/GridCacheUtils.java b/modules/core/src/main/java/org/gridgain/grid/kernal/processors/cache/GridCacheUtils.java index e081126..dbd7c0f 100644 --- a/modules/core/src/main/java/org/gridgain/grid/kernal/processors/cache/GridCacheUtils.java +++ b/modules/core/src/main/java/org/gridgain/grid/kernal/processors/cache/GridCacheUtils.java @@ -155,8 +155,8 @@ public class GridCacheUtils { }; /** Converts transaction to XID. */ - private static final IgniteClosure tx2xid = new C1() { - @Override public IgniteUuid apply(GridCacheTx tx) { + private static final IgniteClosure tx2xid = new C1() { + @Override public IgniteUuid apply(IgniteTx tx) { return tx.xid(); } @@ -796,7 +796,7 @@ public class GridCacheUtils { /** * @return Closure which converts transaction to xid. */ - public static IgniteClosure tx2xid() { + public static IgniteClosure tx2xid() { return tx2xid; } @@ -1198,7 +1198,7 @@ public class GridCacheUtils { * @param isolation Isolation. * @return New transaction. */ - public static GridCacheTx txStartInternal(GridCacheContext ctx, GridCacheProjection prj, + public static IgniteTx txStartInternal(GridCacheContext ctx, GridCacheProjection prj, GridCacheTxConcurrency concurrency, GridCacheTxIsolation isolation) { assert ctx != null; assert prj != null; @@ -1212,7 +1212,7 @@ public class GridCacheUtils { * @param tx Transaction. * @return String view of all safe-to-print transaction properties. */ - public static String txString(@Nullable GridCacheTx tx) { + public static String txString(@Nullable IgniteTx tx) { if (tx == null) return "null"; @@ -1615,7 +1615,7 @@ public class GridCacheUtils { public static void inTx(GridCacheProjection cache, GridCacheTxConcurrency concurrency, GridCacheTxIsolation isolation, IgniteInClosureX> clo) throws IgniteCheckedException { - try (GridCacheTx tx = cache.txStart(concurrency, isolation)) { + try (IgniteTx tx = cache.txStart(concurrency, isolation)) { clo.applyx(cache); tx.commit(); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/3008d2ad/modules/core/src/main/java/org/gridgain/grid/kernal/processors/cache/GridCacheWriteBehindStore.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/gridgain/grid/kernal/processors/cache/GridCacheWriteBehindStore.java b/modules/core/src/main/java/org/gridgain/grid/kernal/processors/cache/GridCacheWriteBehindStore.java index 043f702..981bdca 100644 --- a/modules/core/src/main/java/org/gridgain/grid/kernal/processors/cache/GridCacheWriteBehindStore.java +++ b/modules/core/src/main/java/org/gridgain/grid/kernal/processors/cache/GridCacheWriteBehindStore.java @@ -378,7 +378,7 @@ public class GridCacheWriteBehindStore implements GridCacheStore, Li /** {@inheritDoc} */ @SuppressWarnings({"NullableProblems"}) - @Override public void loadAll(@Nullable GridCacheTx tx, + @Override public void loadAll(@Nullable IgniteTx tx, @Nullable Collection keys, IgniteBiInClosure c) throws IgniteCheckedException { if (log.isDebugEnabled()) log.debug("Store load all [keys=" + keys + ", tx=" + tx + ']'); @@ -421,7 +421,7 @@ public class GridCacheWriteBehindStore implements GridCacheStore, Li } /** {@inheritDoc} */ - @Override public V load(@Nullable GridCacheTx tx, K key) throws IgniteCheckedException { + @Override public V load(@Nullable IgniteTx tx, K key) throws IgniteCheckedException { if (log.isDebugEnabled()) log.debug("Store load [key=" + key + ", tx=" + tx + ']'); @@ -451,14 +451,14 @@ public class GridCacheWriteBehindStore implements GridCacheStore, Li } /** {@inheritDoc} */ - @Override public void putAll(@Nullable GridCacheTx tx, @Nullable Map map) + @Override public void putAll(@Nullable IgniteTx tx, @Nullable Map map) throws IgniteCheckedException { for (Map.Entry e : map.entrySet()) put(tx, e.getKey(), e.getValue()); } /** {@inheritDoc} */ - @Override public void put(@Nullable GridCacheTx tx, K key, V val) throws IgniteCheckedException { + @Override public void put(@Nullable IgniteTx tx, K key, V val) throws IgniteCheckedException { if (log.isDebugEnabled()) log.debug("Store put [key=" + key + ", val=" + val + ", tx=" + tx + ']'); @@ -466,14 +466,14 @@ public class GridCacheWriteBehindStore implements GridCacheStore, Li } /** {@inheritDoc} */ - @Override public void removeAll(@Nullable GridCacheTx tx, @Nullable Collection keys) + @Override public void removeAll(@Nullable IgniteTx tx, @Nullable Collection keys) throws IgniteCheckedException { for (K key : keys) remove(tx, key); } /** {@inheritDoc} */ - @Override public void remove(@Nullable GridCacheTx tx, K key) throws IgniteCheckedException { + @Override public void remove(@Nullable IgniteTx tx, K key) throws IgniteCheckedException { if (log.isDebugEnabled()) log.debug("Store remove [key=" + key + ", tx=" + tx + ']'); @@ -481,7 +481,7 @@ public class GridCacheWriteBehindStore implements GridCacheStore, Li } /** {@inheritDoc} */ - @Override public void txEnd(GridCacheTx tx, boolean commit) throws IgniteCheckedException { + @Override public void txEnd(IgniteTx tx, boolean commit) throws IgniteCheckedException { // No-op. } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/3008d2ad/modules/core/src/main/java/org/gridgain/grid/kernal/processors/cache/IgniteTxProxy.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/gridgain/grid/kernal/processors/cache/IgniteTxProxy.java b/modules/core/src/main/java/org/gridgain/grid/kernal/processors/cache/IgniteTxProxy.java new file mode 100644 index 0000000..19c8116 --- /dev/null +++ b/modules/core/src/main/java/org/gridgain/grid/kernal/processors/cache/IgniteTxProxy.java @@ -0,0 +1,19 @@ +/* @java.file.header */ + +/* _________ _____ __________________ _____ + * __ ____/___________(_)______ /__ ____/______ ____(_)_______ + * _ / __ __ ___/__ / _ __ / _ / __ _ __ `/__ / __ __ \ + * / /_/ / _ / _ / / /_/ / / /_/ / / /_/ / _ / _ / / / + * \____/ /_/ /_/ \_,__/ \____/ \__,_/ /_/ /_/ /_/ + */ + +package org.gridgain.grid.kernal.processors.cache; + +import org.apache.ignite.transactions.*; + +/** + * Marker interface for transaction proxy. + */ +public interface IgniteTxProxy extends IgniteTx { + // No-op. +} http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/3008d2ad/modules/core/src/main/java/org/gridgain/grid/kernal/processors/cache/IgniteTxProxyImpl.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/gridgain/grid/kernal/processors/cache/IgniteTxProxyImpl.java b/modules/core/src/main/java/org/gridgain/grid/kernal/processors/cache/IgniteTxProxyImpl.java new file mode 100644 index 0000000..844bd44 --- /dev/null +++ b/modules/core/src/main/java/org/gridgain/grid/kernal/processors/cache/IgniteTxProxyImpl.java @@ -0,0 +1,303 @@ +/* @java.file.header */ + +/* _________ _____ __________________ _____ + * __ ____/___________(_)______ /__ ____/______ ____(_)_______ + * _ / __ __ ___/__ / _ __ / _ / __ _ __ `/__ / __ __ \ + * / /_/ / _ / _ / / /_/ / / /_/ / / /_/ / _ / _ / / / + * \____/ /_/ /_/ \_,__/ \____/ \__,_/ /_/ /_/ /_/ + */ + +package org.gridgain.grid.kernal.processors.cache; + +import org.apache.ignite.*; +import org.apache.ignite.lang.*; +import org.apache.ignite.transactions.*; +import org.gridgain.grid.*; +import org.gridgain.grid.util.tostring.*; +import org.gridgain.grid.util.typedef.internal.*; +import org.jetbrains.annotations.*; + +import java.io.*; +import java.util.*; +import java.util.concurrent.*; + +/** + * Cache transaction proxy. + */ +public class IgniteTxProxyImpl implements IgniteTxProxy, Externalizable { + /** */ + private static final long serialVersionUID = 0L; + + /** Wrapped transaction. */ + @GridToStringInclude + private GridCacheTxEx tx; + + /** Gateway. */ + @GridToStringExclude + private GridCacheSharedContext cctx; + + /** + * Empty constructor required for {@link Externalizable}. + */ + public IgniteTxProxyImpl() { + // No-op. + } + + /** + * @param tx Transaction. + */ + public IgniteTxProxyImpl(GridCacheTxEx tx, GridCacheSharedContext cctx) { + assert tx != null; + assert cctx != null; + + this.tx = tx; + this.cctx = cctx; + } + + /** + * Enters a call. + */ + private void enter() { + if (cctx.deploymentEnabled()) + cctx.deploy().onEnter(); + + try { + cctx.kernalContext().gateway().readLock(); + } + catch (IllegalStateException e) { + throw e; + } + catch (RuntimeException | Error e) { + cctx.kernalContext().gateway().readUnlock(); + + throw e; + } + } + + /** + * Leaves a call. + */ + private void leave() { + try { + CU.unwindEvicts(cctx); + } + finally { + cctx.kernalContext().gateway().readUnlock(); + } + } + + /** {@inheritDoc} */ + @Override public IgniteUuid xid() { + return tx.xid(); + } + + /** {@inheritDoc} */ + @Override public UUID nodeId() { + return tx.nodeId(); + } + + /** {@inheritDoc} */ + @Override public long threadId() { + return tx.threadId(); + } + + /** {@inheritDoc} */ + @Override public long startTime() { + return tx.startTime(); + } + + /** {@inheritDoc} */ + @Override public GridCacheTxIsolation isolation() { + return tx.isolation(); + } + + /** {@inheritDoc} */ + @Override public GridCacheTxConcurrency concurrency() { + return tx.concurrency(); + } + + /** {@inheritDoc} */ + @Override public boolean isInvalidate() { + return tx.isInvalidate(); + } + + /** {@inheritDoc} */ + @Override public boolean implicit() { + return tx.implicit(); + } + + /** {@inheritDoc} */ + @Override public long timeout() { + return tx.timeout(); + } + + /** {@inheritDoc} */ + @Override public GridCacheTxState state() { + return tx.state(); + } + + /** {@inheritDoc} */ + @Override public long timeout(long timeout) { + return tx.timeout(timeout); + } + + /** {@inheritDoc} */ + @Override public boolean setRollbackOnly() { + enter(); + + try { + return tx.setRollbackOnly(); + } + finally { + leave(); + } + } + + /** {@inheritDoc} */ + @Override public boolean isRollbackOnly() { + enter(); + + try { + return tx.isRollbackOnly(); + } + finally { + leave(); + } + } + + /** {@inheritDoc} */ + @Override public void commit() throws IgniteCheckedException { + enter(); + + try { + cctx.commitTxAsync(tx).get(); + } + finally { + leave(); + } + } + + /** {@inheritDoc} */ + @Override public void close() throws IgniteCheckedException { + enter(); + + try { + cctx.endTx(tx); + } + finally { + leave(); + } + } + + /** {@inheritDoc} */ + @Override public IgniteFuture commitAsync() { + enter(); + + try { + + return cctx.commitTxAsync(tx); + } + finally { + leave(); + } + } + + /** {@inheritDoc} */ + @Override public void rollback() throws IgniteCheckedException { + enter(); + + try { + cctx.rollbackTx(tx); + } + finally { + leave(); + } + } + + /** {@inheritDoc} */ + @Override public void copyMeta(GridMetadataAware from) { + tx.copyMeta(from); + } + + /** {@inheritDoc} */ + @Override public void copyMeta(Map data) { + tx.copyMeta(data); + } + + /** {@inheritDoc} */ + @Override public V1 addMeta(String name, V1 val) { + return tx.addMeta(name, val); + } + + /** {@inheritDoc} */ + @Override public V1 putMetaIfAbsent(String name, V1 val) { + return tx.putMetaIfAbsent(name, val); + } + + /** {@inheritDoc} */ + @Override public V1 putMetaIfAbsent(String name, Callable c) { + return tx.putMetaIfAbsent(name, c); + } + + /** {@inheritDoc} */ + @Nullable @Override public V1 addMetaIfAbsent(String name, V1 val) { + return tx.addMeta(name, val); + } + + /** {@inheritDoc} */ + @Override public V1 addMetaIfAbsent(String name, @Nullable Callable c) { + return tx.addMetaIfAbsent(name, c); + } + + /** {@inheritDoc} */ + @SuppressWarnings({"RedundantTypeArguments"}) + @Override public V1 meta(String name) { + return tx.meta(name); + } + + /** {@inheritDoc} */ + @SuppressWarnings({"RedundantTypeArguments"}) + @Override public V1 removeMeta(String name) { + return tx.removeMeta(name); + } + + /** {@inheritDoc} */ + @Override public boolean removeMeta(String name, V1 val) { + return tx.removeMeta(name, val); + } + + /** {@inheritDoc} */ + @Override public Map allMeta() { + return tx.allMeta(); + } + + /** {@inheritDoc} */ + @Override public boolean hasMeta(String name) { + return tx.hasMeta(name); + } + + /** {@inheritDoc} */ + @Override public boolean hasMeta(String name, V1 val) { + return tx.hasMeta(name, val); + } + + /** {@inheritDoc} */ + @Override public boolean replaceMeta(String name, V1 curVal, V1 newVal) { + return tx.replaceMeta(name, curVal, newVal); + } + + /** {@inheritDoc} */ + @Override public void writeExternal(ObjectOutput out) throws IOException { + out.writeObject(tx); + } + + /** {@inheritDoc} */ + @Override public void readExternal(ObjectInput in) throws IOException, ClassNotFoundException { + tx = (GridCacheTxAdapter)in.readObject(); + } + + /** {@inheritDoc} */ + @Override public String toString() { + return S.toString(IgniteTxProxyImpl.class, this); + } +} http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/3008d2ad/modules/core/src/main/java/org/gridgain/grid/kernal/processors/cache/datastructures/GridCacheAtomicLongImpl.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/gridgain/grid/kernal/processors/cache/datastructures/GridCacheAtomicLongImpl.java b/modules/core/src/main/java/org/gridgain/grid/kernal/processors/cache/datastructures/GridCacheAtomicLongImpl.java index d42ba00..10a2ad6 100644 --- a/modules/core/src/main/java/org/gridgain/grid/kernal/processors/cache/datastructures/GridCacheAtomicLongImpl.java +++ b/modules/core/src/main/java/org/gridgain/grid/kernal/processors/cache/datastructures/GridCacheAtomicLongImpl.java @@ -73,7 +73,7 @@ public final class GridCacheAtomicLongImpl implements GridCacheAtomicLongEx, Ext /** Callable for {@link #incrementAndGet()}. */ private final Callable incAndGetCall = new Callable() { @Override public Long call() throws Exception { - GridCacheTx tx = CU.txStartInternal(ctx, atomicView, PESSIMISTIC, REPEATABLE_READ); + IgniteTx tx = CU.txStartInternal(ctx, atomicView, PESSIMISTIC, REPEATABLE_READ); try { GridCacheAtomicLongValue val = atomicView.get(key); @@ -104,7 +104,7 @@ public final class GridCacheAtomicLongImpl implements GridCacheAtomicLongEx, Ext /** Callable for {@link #getAndIncrement()}. */ private final Callable getAndIncCall = new Callable() { @Override public Long call() throws Exception { - GridCacheTx tx = CU.txStartInternal(ctx, atomicView, PESSIMISTIC, REPEATABLE_READ); + IgniteTx tx = CU.txStartInternal(ctx, atomicView, PESSIMISTIC, REPEATABLE_READ); try { GridCacheAtomicLongValue val = atomicView.get(key); @@ -135,7 +135,7 @@ public final class GridCacheAtomicLongImpl implements GridCacheAtomicLongEx, Ext /** Callable for {@link #decrementAndGet()}. */ private final Callable decAndGetCall = new Callable() { @Override public Long call() throws Exception { - GridCacheTx tx = CU.txStartInternal(ctx, atomicView, PESSIMISTIC, REPEATABLE_READ); + IgniteTx tx = CU.txStartInternal(ctx, atomicView, PESSIMISTIC, REPEATABLE_READ); try { GridCacheAtomicLongValue val = atomicView.get(key); @@ -166,7 +166,7 @@ public final class GridCacheAtomicLongImpl implements GridCacheAtomicLongEx, Ext /** Callable for {@link #getAndDecrement()}. */ private final Callable getAndDecCall = new Callable() { @Override public Long call() throws Exception { - GridCacheTx tx = CU.txStartInternal(ctx, atomicView, PESSIMISTIC, REPEATABLE_READ); + IgniteTx tx = CU.txStartInternal(ctx, atomicView, PESSIMISTIC, REPEATABLE_READ); try { GridCacheAtomicLongValue val = atomicView.get(key); @@ -331,7 +331,7 @@ public final class GridCacheAtomicLongImpl implements GridCacheAtomicLongEx, Ext private Callable internalAddAndGet(final long l) { return new Callable() { @Override public Long call() throws Exception { - GridCacheTx tx = CU.txStartInternal(ctx, atomicView, PESSIMISTIC, REPEATABLE_READ); + IgniteTx tx = CU.txStartInternal(ctx, atomicView, PESSIMISTIC, REPEATABLE_READ); try { GridCacheAtomicLongValue val = atomicView.get(key); @@ -369,7 +369,7 @@ public final class GridCacheAtomicLongImpl implements GridCacheAtomicLongEx, Ext private Callable internalGetAndAdd(final long l) { return new Callable() { @Override public Long call() throws Exception { - GridCacheTx tx = CU.txStartInternal(ctx, atomicView, PESSIMISTIC, REPEATABLE_READ); + IgniteTx tx = CU.txStartInternal(ctx, atomicView, PESSIMISTIC, REPEATABLE_READ); try { GridCacheAtomicLongValue val = atomicView.get(key); @@ -407,7 +407,7 @@ public final class GridCacheAtomicLongImpl implements GridCacheAtomicLongEx, Ext private Callable internalGetAndSet(final long l) { return new Callable() { @Override public Long call() throws Exception { - GridCacheTx tx = CU.txStartInternal(ctx, atomicView, PESSIMISTIC, REPEATABLE_READ); + IgniteTx tx = CU.txStartInternal(ctx, atomicView, PESSIMISTIC, REPEATABLE_READ); try { GridCacheAtomicLongValue val = atomicView.get(key); @@ -447,7 +447,7 @@ public final class GridCacheAtomicLongImpl implements GridCacheAtomicLongEx, Ext private Callable internalCompareAndSet(final long expVal, final long newVal) { return new Callable() { @Override public Boolean call() throws Exception { - GridCacheTx tx = CU.txStartInternal(ctx, atomicView, PESSIMISTIC, REPEATABLE_READ); + IgniteTx tx = CU.txStartInternal(ctx, atomicView, PESSIMISTIC, REPEATABLE_READ); try { GridCacheAtomicLongValue val = atomicView.get(key); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/3008d2ad/modules/core/src/main/java/org/gridgain/grid/kernal/processors/cache/datastructures/GridCacheAtomicReferenceImpl.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/gridgain/grid/kernal/processors/cache/datastructures/GridCacheAtomicReferenceImpl.java b/modules/core/src/main/java/org/gridgain/grid/kernal/processors/cache/datastructures/GridCacheAtomicReferenceImpl.java index 908e28c..7d10060 100644 --- a/modules/core/src/main/java/org/gridgain/grid/kernal/processors/cache/datastructures/GridCacheAtomicReferenceImpl.java +++ b/modules/core/src/main/java/org/gridgain/grid/kernal/processors/cache/datastructures/GridCacheAtomicReferenceImpl.java @@ -186,7 +186,7 @@ public final class GridCacheAtomicReferenceImpl implements GridCacheAtomicRef return new Callable() { @Override public Boolean call() throws Exception { - GridCacheTx tx = CU.txStartInternal(ctx, atomicView, PESSIMISTIC, REPEATABLE_READ); + IgniteTx tx = CU.txStartInternal(ctx, atomicView, PESSIMISTIC, REPEATABLE_READ); try { GridCacheAtomicReferenceValue ref = atomicView.get(key); @@ -225,7 +225,7 @@ public final class GridCacheAtomicReferenceImpl implements GridCacheAtomicRef final IgniteClosure newValClos) { return new Callable() { @Override public Boolean call() throws Exception { - GridCacheTx tx = CU.txStartInternal(ctx, atomicView, PESSIMISTIC, REPEATABLE_READ); + IgniteTx tx = CU.txStartInternal(ctx, atomicView, PESSIMISTIC, REPEATABLE_READ); try { GridCacheAtomicReferenceValue ref = atomicView.get(key); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/3008d2ad/modules/core/src/main/java/org/gridgain/grid/kernal/processors/cache/datastructures/GridCacheAtomicSequenceImpl.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/gridgain/grid/kernal/processors/cache/datastructures/GridCacheAtomicSequenceImpl.java b/modules/core/src/main/java/org/gridgain/grid/kernal/processors/cache/datastructures/GridCacheAtomicSequenceImpl.java index 80f7e09..ba25633 100644 --- a/modules/core/src/main/java/org/gridgain/grid/kernal/processors/cache/datastructures/GridCacheAtomicSequenceImpl.java +++ b/modules/core/src/main/java/org/gridgain/grid/kernal/processors/cache/datastructures/GridCacheAtomicSequenceImpl.java @@ -391,7 +391,7 @@ public final class GridCacheAtomicSequenceImpl implements GridCacheAtomicSequenc private Callable internalUpdate(final long l, final boolean updated) { return new Callable() { @Override public Long call() throws Exception { - GridCacheTx tx = CU.txStartInternal(ctx, seqView, PESSIMISTIC, REPEATABLE_READ); + IgniteTx tx = CU.txStartInternal(ctx, seqView, PESSIMISTIC, REPEATABLE_READ); try { GridCacheAtomicSequenceValue seq = seqView.get(key); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/3008d2ad/modules/core/src/main/java/org/gridgain/grid/kernal/processors/cache/datastructures/GridCacheAtomicStampedImpl.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/gridgain/grid/kernal/processors/cache/datastructures/GridCacheAtomicStampedImpl.java b/modules/core/src/main/java/org/gridgain/grid/kernal/processors/cache/datastructures/GridCacheAtomicStampedImpl.java index e4a0b55..51aaf45 100644 --- a/modules/core/src/main/java/org/gridgain/grid/kernal/processors/cache/datastructures/GridCacheAtomicStampedImpl.java +++ b/modules/core/src/main/java/org/gridgain/grid/kernal/processors/cache/datastructures/GridCacheAtomicStampedImpl.java @@ -212,7 +212,7 @@ public final class GridCacheAtomicStampedImpl implements GridCacheAtomicSt return new Callable() { @Override public Boolean call() throws Exception { - GridCacheTx tx = CU.txStartInternal(ctx, atomicView, PESSIMISTIC, REPEATABLE_READ); + IgniteTx tx = CU.txStartInternal(ctx, atomicView, PESSIMISTIC, REPEATABLE_READ); try { GridCacheAtomicStampedValue stmp = atomicView.get(key); @@ -254,7 +254,7 @@ public final class GridCacheAtomicStampedImpl implements GridCacheAtomicSt final IgniteClosure newStampClos) { return new Callable() { @Override public Boolean call() throws Exception { - GridCacheTx tx = CU.txStartInternal(ctx, atomicView, PESSIMISTIC, REPEATABLE_READ); + IgniteTx tx = CU.txStartInternal(ctx, atomicView, PESSIMISTIC, REPEATABLE_READ); try { GridCacheAtomicStampedValue stmp = atomicView.get(key); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/3008d2ad/modules/core/src/main/java/org/gridgain/grid/kernal/processors/cache/datastructures/GridCacheCountDownLatchImpl.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/gridgain/grid/kernal/processors/cache/datastructures/GridCacheCountDownLatchImpl.java b/modules/core/src/main/java/org/gridgain/grid/kernal/processors/cache/datastructures/GridCacheCountDownLatchImpl.java index 559bdbe..579b11c 100644 --- a/modules/core/src/main/java/org/gridgain/grid/kernal/processors/cache/datastructures/GridCacheCountDownLatchImpl.java +++ b/modules/core/src/main/java/org/gridgain/grid/kernal/processors/cache/datastructures/GridCacheCountDownLatchImpl.java @@ -211,7 +211,7 @@ public final class GridCacheCountDownLatchImpl implements GridCacheCountDownLatc internalLatch = CU.outTx( new Callable() { @Override public CountDownLatch call() throws Exception { - GridCacheTx tx = CU.txStartInternal(ctx, latchView, PESSIMISTIC, REPEATABLE_READ); + IgniteTx tx = CU.txStartInternal(ctx, latchView, PESSIMISTIC, REPEATABLE_READ); try { GridCacheCountDownLatchValue val = latchView.get(key); @@ -310,7 +310,7 @@ public final class GridCacheCountDownLatchImpl implements GridCacheCountDownLatc /** {@inheritDoc} */ @Override public Integer call() throws Exception { - GridCacheTx tx = CU.txStartInternal(ctx, latchView, PESSIMISTIC, REPEATABLE_READ); + IgniteTx tx = CU.txStartInternal(ctx, latchView, PESSIMISTIC, REPEATABLE_READ); try { GridCacheCountDownLatchValue latchVal = latchView.get(key); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/3008d2ad/modules/core/src/main/java/org/gridgain/grid/kernal/processors/cache/datastructures/GridCacheDataStructuresManager.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/gridgain/grid/kernal/processors/cache/datastructures/GridCacheDataStructuresManager.java b/modules/core/src/main/java/org/gridgain/grid/kernal/processors/cache/datastructures/GridCacheDataStructuresManager.java index 3066811..8878f37 100644 --- a/modules/core/src/main/java/org/gridgain/grid/kernal/processors/cache/datastructures/GridCacheDataStructuresManager.java +++ b/modules/core/src/main/java/org/gridgain/grid/kernal/processors/cache/datastructures/GridCacheDataStructuresManager.java @@ -190,7 +190,7 @@ public final class GridCacheDataStructuresManager extends GridCacheManager return CU.outTx(new Callable() { @Override public GridCacheAtomicSequence call() throws Exception { - try (GridCacheTx tx = CU.txStartInternal(cctx, dsView, PESSIMISTIC, REPEATABLE_READ)) { + try (IgniteTx tx = CU.txStartInternal(cctx, dsView, PESSIMISTIC, REPEATABLE_READ)) { GridCacheAtomicSequenceValue seqVal = cast(dsView.get(key), GridCacheAtomicSequenceValue.class); @@ -308,7 +308,7 @@ public final class GridCacheDataStructuresManager extends GridCacheManager return CU.outTx(new Callable() { @Override public GridCacheAtomicLong call() throws Exception { - try (GridCacheTx tx = CU.txStartInternal(cctx, dsView, PESSIMISTIC, REPEATABLE_READ)) { + try (IgniteTx tx = CU.txStartInternal(cctx, dsView, PESSIMISTIC, REPEATABLE_READ)) { GridCacheAtomicLongValue val = cast(dsView.get(key), GridCacheAtomicLongValue.class); @@ -404,7 +404,7 @@ public final class GridCacheDataStructuresManager extends GridCacheManager return CU.outTx(new Callable>() { @Override public GridCacheAtomicReference call() throws Exception { - try (GridCacheTx tx = CU.txStartInternal(cctx, dsView, PESSIMISTIC, REPEATABLE_READ)) { + try (IgniteTx tx = CU.txStartInternal(cctx, dsView, PESSIMISTIC, REPEATABLE_READ)) { GridCacheAtomicReferenceValue val = cast(dsView.get(key), GridCacheAtomicReferenceValue.class); @@ -503,7 +503,7 @@ public final class GridCacheDataStructuresManager extends GridCacheManager return CU.outTx(new Callable>() { @Override public GridCacheAtomicStamped call() throws Exception { - try (GridCacheTx tx = CU.txStartInternal(cctx, dsView, PESSIMISTIC, REPEATABLE_READ)) { + try (IgniteTx tx = CU.txStartInternal(cctx, dsView, PESSIMISTIC, REPEATABLE_READ)) { GridCacheAtomicStampedValue val = cast(dsView.get(key), GridCacheAtomicStampedValue.class); @@ -774,7 +774,7 @@ public final class GridCacheDataStructuresManager extends GridCacheManager return CU.outTx(new Callable() { @Override public GridCacheCountDownLatch call() throws Exception { - try (GridCacheTx tx = CU.txStartInternal(cctx, dsView, PESSIMISTIC, REPEATABLE_READ)) { + try (IgniteTx tx = CU.txStartInternal(cctx, dsView, PESSIMISTIC, REPEATABLE_READ)) { GridCacheCountDownLatchValue val = cast(dsView.get(key), GridCacheCountDownLatchValue.class); @@ -838,7 +838,7 @@ public final class GridCacheDataStructuresManager extends GridCacheManager @Override public Boolean call() throws Exception { GridCacheInternal key = new GridCacheInternalKeyImpl(name); - try (GridCacheTx tx = CU.txStartInternal(cctx, dsView, PESSIMISTIC, REPEATABLE_READ)) { + try (IgniteTx tx = CU.txStartInternal(cctx, dsView, PESSIMISTIC, REPEATABLE_READ)) { // Check correctness type of removable object. GridCacheCountDownLatchValue val = cast(dsView.get(key), GridCacheCountDownLatchValue.class); @@ -885,7 +885,7 @@ public final class GridCacheDataStructuresManager extends GridCacheManager return CU.outTx( new Callable() { @Override public Boolean call() throws Exception { - try (GridCacheTx tx = CU.txStartInternal(cctx, dsView, PESSIMISTIC, REPEATABLE_READ)) { + try (IgniteTx tx = CU.txStartInternal(cctx, dsView, PESSIMISTIC, REPEATABLE_READ)) { // Check correctness type of removable object. R val = cast(dsView.get(key), cls); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/3008d2ad/modules/core/src/main/java/org/gridgain/grid/kernal/processors/cache/datastructures/GridTransactionalCacheQueueImpl.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/gridgain/grid/kernal/processors/cache/datastructures/GridTransactionalCacheQueueImpl.java b/modules/core/src/main/java/org/gridgain/grid/kernal/processors/cache/datastructures/GridTransactionalCacheQueueImpl.java index ef64d31..98720b2 100644 --- a/modules/core/src/main/java/org/gridgain/grid/kernal/processors/cache/datastructures/GridTransactionalCacheQueueImpl.java +++ b/modules/core/src/main/java/org/gridgain/grid/kernal/processors/cache/datastructures/GridTransactionalCacheQueueImpl.java @@ -47,7 +47,7 @@ public class GridTransactionalCacheQueueImpl extends GridCacheQueueAdapter while (true) { try { - try (GridCacheTx tx = cache.txStart(PESSIMISTIC, REPEATABLE_READ)) { + try (IgniteTx tx = cache.txStart(PESSIMISTIC, REPEATABLE_READ)) { Long idx = (Long)cache.transformAndCompute(queueKey, new AddClosure(id, 1)); if (idx != null) { @@ -97,7 +97,7 @@ public class GridTransactionalCacheQueueImpl extends GridCacheQueueAdapter T retVal; while (true) { - try (GridCacheTx tx = cache.txStart(PESSIMISTIC, REPEATABLE_READ)) { + try (IgniteTx tx = cache.txStart(PESSIMISTIC, REPEATABLE_READ)) { Long idx = (Long)cache.transformAndCompute(queueKey, new PollClosure(id)); if (idx != null) { @@ -146,7 +146,7 @@ public class GridTransactionalCacheQueueImpl extends GridCacheQueueAdapter int cnt = 0; while (true) { - try (GridCacheTx tx = cache.txStart(PESSIMISTIC, REPEATABLE_READ)) { + try (IgniteTx tx = cache.txStart(PESSIMISTIC, REPEATABLE_READ)) { Long idx = (Long)cache.transformAndCompute(queueKey, new AddClosure(id, items.size())); if (idx != null) { @@ -199,7 +199,7 @@ public class GridTransactionalCacheQueueImpl extends GridCacheQueueAdapter int cnt = 0; while (true) { - try (GridCacheTx tx = cache.txStart(PESSIMISTIC, REPEATABLE_READ)) { + try (IgniteTx tx = cache.txStart(PESSIMISTIC, REPEATABLE_READ)) { Long idx = (Long)cache.transformAndCompute(queueKey, new RemoveClosure(id, rmvIdx)); if (idx != null) { http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/3008d2ad/modules/core/src/main/java/org/gridgain/grid/kernal/processors/cache/distributed/GridDistributedTxRemoteAdapter.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/gridgain/grid/kernal/processors/cache/distributed/GridDistributedTxRemoteAdapter.java b/modules/core/src/main/java/org/gridgain/grid/kernal/processors/cache/distributed/GridDistributedTxRemoteAdapter.java index 248b4a0..bc8688c 100644 --- a/modules/core/src/main/java/org/gridgain/grid/kernal/processors/cache/distributed/GridDistributedTxRemoteAdapter.java +++ b/modules/core/src/main/java/org/gridgain/grid/kernal/processors/cache/distributed/GridDistributedTxRemoteAdapter.java @@ -728,11 +728,11 @@ public class GridDistributedTxRemoteAdapter extends GridCacheTxAdapter commitAsync() { + @Override public IgniteFuture commitAsync() { try { commit(); - return new GridFinishedFutureEx(this); + return new GridFinishedFutureEx(this); } catch (IgniteCheckedException e) { return new GridFinishedFutureEx<>(e); @@ -759,10 +759,10 @@ public class GridDistributedTxRemoteAdapter extends GridCacheTxAdapter rollbackAsync() { + @Override public IgniteFuture rollbackAsync() { rollback(); - return new GridFinishedFutureEx(this); + return new GridFinishedFutureEx(this); } /** {@inheritDoc} */ http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/3008d2ad/modules/core/src/main/java/org/gridgain/grid/kernal/processors/cache/distributed/dht/GridDhtTransactionalCacheAdapter.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/gridgain/grid/kernal/processors/cache/distributed/dht/GridDhtTransactionalCacheAdapter.java b/modules/core/src/main/java/org/gridgain/grid/kernal/processors/cache/distributed/dht/GridDhtTransactionalCacheAdapter.java index fee6d0a..1c9d367 100644 --- a/modules/core/src/main/java/org/gridgain/grid/kernal/processors/cache/distributed/dht/GridDhtTransactionalCacheAdapter.java +++ b/modules/core/src/main/java/org/gridgain/grid/kernal/processors/cache/distributed/dht/GridDhtTransactionalCacheAdapter.java @@ -828,8 +828,8 @@ public abstract class GridDhtTransactionalCacheAdapter extends GridDhtCach assert t.implicit(); return t.commitAsync().chain( - new C1, GridNearLockResponse>() { - @Override public GridNearLockResponse apply(IgniteFuture f) { + new C1, GridNearLockResponse>() { + @Override public GridNearLockResponse apply(IgniteFuture f) { try { // Check for error. f.get(); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/3008d2ad/modules/core/src/main/java/org/gridgain/grid/kernal/processors/cache/distributed/dht/GridDhtTxFinishFuture.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/gridgain/grid/kernal/processors/cache/distributed/dht/GridDhtTxFinishFuture.java b/modules/core/src/main/java/org/gridgain/grid/kernal/processors/cache/distributed/dht/GridDhtTxFinishFuture.java index 2f1c971..33c116c 100644 --- a/modules/core/src/main/java/org/gridgain/grid/kernal/processors/cache/distributed/dht/GridDhtTxFinishFuture.java +++ b/modules/core/src/main/java/org/gridgain/grid/kernal/processors/cache/distributed/dht/GridDhtTxFinishFuture.java @@ -31,8 +31,8 @@ import static org.gridgain.grid.kernal.managers.communication.GridIoPolicy.*; /** * */ -public final class GridDhtTxFinishFuture extends GridCompoundIdentityFuture - implements GridCacheFuture { +public final class GridDhtTxFinishFuture extends GridCompoundIdentityFuture + implements GridCacheFuture { /** */ private static final long serialVersionUID = 0L; @@ -81,7 +81,7 @@ public final class GridDhtTxFinishFuture extends GridCompoundIdentityFutur * @param commit Commit flag. */ public GridDhtTxFinishFuture(GridCacheSharedContext cctx, GridDhtTxLocalAdapter tx, boolean commit) { - super(cctx.kernalContext(), F.identityReducer(tx)); + super(cctx.kernalContext(), F.identityReducer(tx)); assert cctx != null; @@ -189,7 +189,7 @@ public final class GridDhtTxFinishFuture extends GridCompoundIdentityFutur */ public void onResult(UUID nodeId, GridDhtTxFinishResponse res) { if (!isDone()) { - for (IgniteFuture fut : futures()) { + for (IgniteFuture fut : futures()) { if (isMini(fut)) { MiniFuture f = (MiniFuture)fut; @@ -204,7 +204,7 @@ public final class GridDhtTxFinishFuture extends GridCompoundIdentityFutur } /** {@inheritDoc} */ - @Override public boolean onDone(GridCacheTx tx, Throwable err) { + @Override public boolean onDone(IgniteTx tx, Throwable err) { if (initialized() || err != null) { if (this.tx.onePhaseCommit() && (this.tx.state() == COMMITTING)) this.tx.tmCommit(); @@ -413,7 +413,7 @@ public final class GridDhtTxFinishFuture extends GridCompoundIdentityFutur * Mini-future for get operations. Mini-futures are only waiting on a single * node as opposed to multiple nodes. */ - private class MiniFuture extends GridFutureAdapter { + private class MiniFuture extends GridFutureAdapter { /** */ private static final long serialVersionUID = 0L; http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/3008d2ad/modules/core/src/main/java/org/gridgain/grid/kernal/processors/cache/distributed/dht/GridDhtTxLocal.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/gridgain/grid/kernal/processors/cache/distributed/dht/GridDhtTxLocal.java b/modules/core/src/main/java/org/gridgain/grid/kernal/processors/cache/distributed/dht/GridDhtTxLocal.java index 1a0d840..b3f5d38 100644 --- a/modules/core/src/main/java/org/gridgain/grid/kernal/processors/cache/distributed/dht/GridDhtTxLocal.java +++ b/modules/core/src/main/java/org/gridgain/grid/kernal/processors/cache/distributed/dht/GridDhtTxLocal.java @@ -439,7 +439,7 @@ public class GridDhtTxLocal extends GridDhtTxLocalAdapter implements /** {@inheritDoc} */ @SuppressWarnings({"ThrowableInstanceNeverThrown"}) - @Override public IgniteFuture commitAsync() { + @Override public IgniteFuture commitAsync() { if (log.isDebugEnabled()) log.debug("Committing dht local tx: " + this); @@ -534,7 +534,7 @@ public class GridDhtTxLocal extends GridDhtTxLocalAdapter implements } /** {@inheritDoc} */ - @Override public IgniteFuture rollbackAsync() { + @Override public IgniteFuture rollbackAsync() { GridDhtTxPrepareFuture prepFut = this.prepFut.get(); final GridDhtTxFinishFuture fut = new GridDhtTxFinishFuture<>(cctx, this, /*rollback*/false); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/3008d2ad/modules/core/src/main/java/org/gridgain/grid/kernal/processors/cache/distributed/near/GridNearTxFinishFuture.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/gridgain/grid/kernal/processors/cache/distributed/near/GridNearTxFinishFuture.java b/modules/core/src/main/java/org/gridgain/grid/kernal/processors/cache/distributed/near/GridNearTxFinishFuture.java index 1a3aba0..5b4b637 100644 --- a/modules/core/src/main/java/org/gridgain/grid/kernal/processors/cache/distributed/near/GridNearTxFinishFuture.java +++ b/modules/core/src/main/java/org/gridgain/grid/kernal/processors/cache/distributed/near/GridNearTxFinishFuture.java @@ -33,8 +33,8 @@ import static org.gridgain.grid.kernal.processors.cache.GridCacheOperation.*; /** * */ -public final class GridNearTxFinishFuture extends GridCompoundIdentityFuture - implements GridCacheFuture { +public final class GridNearTxFinishFuture extends GridCompoundIdentityFuture + implements GridCacheFuture { /** */ private static final long serialVersionUID = 0L; @@ -79,7 +79,7 @@ public final class GridNearTxFinishFuture extends GridCompoundIdentityFutu * @param commit Commit flag. */ public GridNearTxFinishFuture(GridCacheSharedContext cctx, GridNearTxLocal tx, boolean commit) { - super(cctx.kernalContext(), F.identityReducer(tx)); + super(cctx.kernalContext(), F.identityReducer(tx)); assert cctx != null; @@ -188,7 +188,7 @@ public final class GridNearTxFinishFuture extends GridCompoundIdentityFutu */ public void onResult(UUID nodeId, GridNearTxFinishResponse res) { if (!isDone()) - for (IgniteFuture fut : futures()) { + for (IgniteFuture fut : futures()) { if (isMini(fut)) { MiniFuture f = (MiniFuture)fut; @@ -202,7 +202,7 @@ public final class GridNearTxFinishFuture extends GridCompoundIdentityFutu } /** {@inheritDoc} */ - @Override public boolean onDone(GridCacheTx tx, Throwable err) { + @Override public boolean onDone(IgniteTx tx, Throwable err) { if ((initialized() || err != null)) { if (this.tx.onePhaseCommit() && (this.tx.state() == COMMITTING)) this.tx.tmCommit(); @@ -271,7 +271,7 @@ public final class GridNearTxFinishFuture extends GridCompoundIdentityFutu // Finish local mapping only as we need send commit message to backups. for (GridDistributedTxMapping m : mappings.values()) { if (m.node().isLocal()) { - IgniteFuture fut = cctx.tm().txHandler().finishColocatedLocal(commit, tx); + IgniteFuture fut = cctx.tm().txHandler().finishColocatedLocal(commit, tx); // Add new future. if (fut != null) @@ -358,7 +358,7 @@ public final class GridNearTxFinishFuture extends GridCompoundIdentityFutu if (n.isLocal()) { req.miniId(IgniteUuid.randomUuid()); - IgniteFuture fut = cctx.tm().txHandler().finish(n.id(), tx, req); + IgniteFuture fut = cctx.tm().txHandler().finish(n.id(), tx, req); // Add new future. if (fut != null) @@ -403,7 +403,7 @@ public final class GridNearTxFinishFuture extends GridCompoundIdentityFutu * Mini-future for get operations. Mini-futures are only waiting on a single * node as opposed to multiple nodes. */ - private class MiniFuture extends GridFutureAdapter { + private class MiniFuture extends GridFutureAdapter { /** */ private static final long serialVersionUID = 0L; http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/3008d2ad/modules/core/src/main/java/org/gridgain/grid/kernal/processors/cache/distributed/near/GridNearTxLocal.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/gridgain/grid/kernal/processors/cache/distributed/near/GridNearTxLocal.java b/modules/core/src/main/java/org/gridgain/grid/kernal/processors/cache/distributed/near/GridNearTxLocal.java index b178649..24c7feb 100644 --- a/modules/core/src/main/java/org/gridgain/grid/kernal/processors/cache/distributed/near/GridNearTxLocal.java +++ b/modules/core/src/main/java/org/gridgain/grid/kernal/processors/cache/distributed/near/GridNearTxLocal.java @@ -734,7 +734,7 @@ public class GridNearTxLocal extends GridDhtTxLocalAdapter { /** {@inheritDoc} */ @SuppressWarnings({"ThrowableInstanceNeverThrown"}) - @Override public IgniteFuture commitAsync() { + @Override public IgniteFuture commitAsync() { if (log.isDebugEnabled()) log.debug("Committing near local tx: " + this); @@ -780,7 +780,7 @@ public class GridNearTxLocal extends GridDhtTxLocalAdapter { } /** {@inheritDoc} */ - @Override public IgniteFuture rollbackAsync() { + @Override public IgniteFuture rollbackAsync() { if (log.isDebugEnabled()) log.debug("Rolling back near tx: " + this); @@ -928,7 +928,7 @@ public class GridNearTxLocal extends GridDhtTxLocalAdapter { * * @return Commit future. */ - public IgniteFuture commitAsyncLocal() { + public IgniteFuture commitAsyncLocal() { if (log.isDebugEnabled()) log.debug("Committing colocated tx locally: " + this); @@ -941,9 +941,9 @@ public class GridNearTxLocal extends GridDhtTxLocalAdapter { // Do not create finish future if there are no remote nodes. if (F.isEmpty(dhtMap) && F.isEmpty(nearMap)) { if (prep != null) - return (IgniteFuture)(IgniteFuture)prep; + return (IgniteFuture)(IgniteFuture)prep; - return new GridFinishedFuture(cctx.kernalContext(), this); + return new GridFinishedFuture(cctx.kernalContext(), this); } final GridDhtTxFinishFuture fut = new GridDhtTxFinishFuture<>(cctx, this, /*commit*/true); @@ -1001,7 +1001,7 @@ public class GridNearTxLocal extends GridDhtTxLocalAdapter { * * @return Commit future. */ - public IgniteFuture rollbackAsyncLocal() { + public IgniteFuture rollbackAsyncLocal() { if (log.isDebugEnabled()) log.debug("Rolling back colocated tx locally: " + this); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/3008d2ad/modules/core/src/main/java/org/gridgain/grid/kernal/processors/cache/local/GridLocalTx.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/gridgain/grid/kernal/processors/cache/local/GridLocalTx.java b/modules/core/src/main/java/org/gridgain/grid/kernal/processors/cache/local/GridLocalTx.java index 6356034..c049af8 100644 --- a/modules/core/src/main/java/org/gridgain/grid/kernal/processors/cache/local/GridLocalTx.java +++ b/modules/core/src/main/java/org/gridgain/grid/kernal/processors/cache/local/GridLocalTx.java @@ -142,7 +142,7 @@ class GridLocalTx extends GridCacheTxLocalAdapter { /** {@inheritDoc} */ @SuppressWarnings( {"unchecked", "RedundantCast"}) - @Override public IgniteFuture commitAsync() { + @Override public IgniteFuture commitAsync() { try { prepare(); } @@ -172,7 +172,7 @@ class GridLocalTx extends GridCacheTxLocalAdapter { rollbackAsync().get(); } - @Override public IgniteFuture rollbackAsync() { + @Override public IgniteFuture rollbackAsync() { try { state(ROLLING_BACK); @@ -180,7 +180,7 @@ class GridLocalTx extends GridCacheTxLocalAdapter { state(ROLLED_BACK); - return new GridFinishedFuture(cctx.kernalContext(), this); + return new GridFinishedFuture(cctx.kernalContext(), this); } catch (IgniteCheckedException e) { return new GridFinishedFuture<>(cctx.kernalContext(), e); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/3008d2ad/modules/core/src/main/java/org/gridgain/grid/kernal/processors/cache/transactions/IgniteTransactionsImpl.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/gridgain/grid/kernal/processors/cache/transactions/IgniteTransactionsImpl.java b/modules/core/src/main/java/org/gridgain/grid/kernal/processors/cache/transactions/IgniteTransactionsImpl.java index 7ce1e11..084f196 100644 --- a/modules/core/src/main/java/org/gridgain/grid/kernal/processors/cache/transactions/IgniteTransactionsImpl.java +++ b/modules/core/src/main/java/org/gridgain/grid/kernal/processors/cache/transactions/IgniteTransactionsImpl.java @@ -39,7 +39,7 @@ public class IgniteTransactionsImpl implements IgniteTransactionsEx { } /** {@inheritDoc} */ - @Override public GridCacheTx txStart() throws IllegalStateException { + @Override public IgniteTx txStart() throws IllegalStateException { TransactionsConfiguration cfg = cctx.gridConfig().getTransactionsConfiguration(); return txStart0( @@ -52,7 +52,7 @@ public class IgniteTransactionsImpl implements IgniteTransactionsEx { } /** {@inheritDoc} */ - @Override public GridCacheTx txStart(GridCacheTxConcurrency concurrency, GridCacheTxIsolation isolation) { + @Override public IgniteTx txStart(GridCacheTxConcurrency concurrency, GridCacheTxIsolation isolation) { A.notNull(concurrency, "concurrency"); A.notNull(isolation, "isolation"); @@ -68,7 +68,7 @@ public class IgniteTransactionsImpl implements IgniteTransactionsEx { } /** {@inheritDoc} */ - @Override public GridCacheTx txStart(GridCacheTxConcurrency concurrency, GridCacheTxIsolation isolation, + @Override public IgniteTx txStart(GridCacheTxConcurrency concurrency, GridCacheTxIsolation isolation, long timeout, int txSize) { A.notNull(concurrency, "concurrency"); A.notNull(isolation, "isolation"); @@ -84,7 +84,7 @@ public class IgniteTransactionsImpl implements IgniteTransactionsEx { ); } - @Override public GridCacheTx txStartSystem(GridCacheTxConcurrency concurrency, GridCacheTxIsolation isolation, + @Override public IgniteTx txStartSystem(GridCacheTxConcurrency concurrency, GridCacheTxIsolation isolation, long timeout, int txSize) { A.notNull(concurrency, "concurrency"); A.notNull(isolation, "isolation"); @@ -108,7 +108,7 @@ public class IgniteTransactionsImpl implements IgniteTransactionsEx { * @param sys System flag. * @return Transaction. */ - private GridCacheTx txStart0(GridCacheTxConcurrency concurrency, GridCacheTxIsolation isolation, + private IgniteTx txStart0(GridCacheTxConcurrency concurrency, GridCacheTxIsolation isolation, long timeout, int txSize, boolean sys) { TransactionsConfiguration cfg = cctx.gridConfig().getTransactionsConfiguration(); @@ -139,12 +139,12 @@ public class IgniteTransactionsImpl implements IgniteTransactionsEx { assert tx != null; // Wrap into proxy. - return new GridCacheTxProxyImpl<>(tx, cctx); + return new IgniteTxProxyImpl<>(tx, cctx); } /** {@inheritDoc} */ - @Override public GridCacheTx txStartAffinity(String cacheName, Object affinityKey, GridCacheTxConcurrency concurrency, + @Override public IgniteTx txStartAffinity(String cacheName, Object affinityKey, GridCacheTxConcurrency concurrency, GridCacheTxIsolation isolation, long timeout, int txSize) throws IllegalStateException, IgniteCheckedException { GridCacheAdapter cache = cctx.kernalContext().cache().internalCache(cacheName); @@ -156,7 +156,7 @@ public class IgniteTransactionsImpl implements IgniteTransactionsEx { } /** {@inheritDoc} */ - @Override public GridCacheTx txStartPartition(String cacheName, int partId, GridCacheTxConcurrency concurrency, + @Override public IgniteTx txStartPartition(String cacheName, int partId, GridCacheTxConcurrency concurrency, GridCacheTxIsolation isolation, long timeout, int txSize) throws IllegalStateException, IgniteCheckedException { GridCacheAdapter cache = cctx.kernalContext().cache().internalCache(cacheName); @@ -185,10 +185,10 @@ public class IgniteTransactionsImpl implements IgniteTransactionsEx { * @throws IgniteCheckedException In case of error. */ @SuppressWarnings("unchecked") - private GridCacheTx txStartGroupLock(GridCacheContext ctx, Object grpLockKey, GridCacheTxConcurrency concurrency, + private IgniteTx txStartGroupLock(GridCacheContext ctx, Object grpLockKey, GridCacheTxConcurrency concurrency, GridCacheTxIsolation isolation, boolean partLock, long timeout, int txSize, boolean sys) throws IllegalStateException, IgniteCheckedException { - GridCacheTx tx = cctx.tm().userTx(); + IgniteTx tx = cctx.tm().userTx(); if (tx != null) throw new IllegalStateException("Failed to start new transaction " + @@ -225,11 +225,11 @@ public class IgniteTransactionsImpl implements IgniteTransactionsEx { } // Wrap into proxy. - return new GridCacheTxProxyImpl<>(tx0, cctx); + return new IgniteTxProxyImpl<>(tx0, cctx); } /** {@inheritDoc} */ - @Nullable @Override public GridCacheTx tx() { + @Nullable @Override public IgniteTx tx() { return cctx.tm().userTx(); } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/3008d2ad/modules/core/src/main/java/org/gridgain/grid/kernal/processors/dataload/GridDataLoadCacheUpdaters.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/gridgain/grid/kernal/processors/dataload/GridDataLoadCacheUpdaters.java b/modules/core/src/main/java/org/gridgain/grid/kernal/processors/dataload/GridDataLoadCacheUpdaters.java index 421f24e..e07a7e5 100644 --- a/modules/core/src/main/java/org/gridgain/grid/kernal/processors/dataload/GridDataLoadCacheUpdaters.java +++ b/modules/core/src/main/java/org/gridgain/grid/kernal/processors/dataload/GridDataLoadCacheUpdaters.java @@ -264,7 +264,7 @@ public class GridDataLoadCacheUpdaters { Integer part = e.getKey(); int cnt = e.getValue(); - GridCacheTx tx = cache.txStartPartition(part, PESSIMISTIC, REPEATABLE_READ, 0, cnt); + IgniteTx tx = cache.txStartPartition(part, PESSIMISTIC, REPEATABLE_READ, 0, cnt); try { updateAll(cache, rmvPartMap == null ? null : rmvPartMap.get(part), http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/3008d2ad/modules/core/src/main/java/org/gridgain/grid/kernal/processors/ggfs/GridGgfsDataManager.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/gridgain/grid/kernal/processors/ggfs/GridGgfsDataManager.java b/modules/core/src/main/java/org/gridgain/grid/kernal/processors/ggfs/GridGgfsDataManager.java index ddbeae2..946e39e 100644 --- a/modules/core/src/main/java/org/gridgain/grid/kernal/processors/ggfs/GridGgfsDataManager.java +++ b/modules/core/src/main/java/org/gridgain/grid/kernal/processors/ggfs/GridGgfsDataManager.java @@ -677,7 +677,7 @@ public class GridGgfsDataManager extends GridGgfsManager { // Need to check if block is partially written. // If so, must update it in pessimistic transaction. if (block.length != fileInfo.blockSize()) { - try (GridCacheTx tx = dataCachePrj.txStart(PESSIMISTIC, REPEATABLE_READ)) { + try (IgniteTx tx = dataCachePrj.txStart(PESSIMISTIC, REPEATABLE_READ)) { Map vals = dataCachePrj.getAll(F.asList(colocatedKey, key)); byte[] val = vals.get(colocatedKey); @@ -1117,7 +1117,7 @@ public class GridGgfsDataManager extends GridGgfsManager { GridGgfsBlockKey key = new GridGgfsBlockKey(colocatedKey.getFileId(), null, colocatedKey.evictExclude(), colocatedKey.getBlockId()); - GridCacheTx tx = dataCachePrj.txStart(PESSIMISTIC, REPEATABLE_READ); + IgniteTx tx = dataCachePrj.txStart(PESSIMISTIC, REPEATABLE_READ); try { // Lock keys. http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/3008d2ad/modules/core/src/main/java/org/gridgain/grid/kernal/processors/ggfs/GridGgfsMetaManager.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/gridgain/grid/kernal/processors/ggfs/GridGgfsMetaManager.java b/modules/core/src/main/java/org/gridgain/grid/kernal/processors/ggfs/GridGgfsMetaManager.java index 0e2f286..da7832c 100644 --- a/modules/core/src/main/java/org/gridgain/grid/kernal/processors/ggfs/GridGgfsMetaManager.java +++ b/modules/core/src/main/java/org/gridgain/grid/kernal/processors/ggfs/GridGgfsMetaManager.java @@ -399,7 +399,7 @@ public class GridGgfsMetaManager extends GridGgfsManager { assert validTxState(false); assert fileId != null; - GridCacheTx tx = metaCache.txStart(PESSIMISTIC, REPEATABLE_READ); + IgniteTx tx = metaCache.txStart(PESSIMISTIC, REPEATABLE_READ); try { // Lock file ID for this transaction. @@ -482,7 +482,7 @@ public class GridGgfsMetaManager extends GridGgfsManager { IgniteUuid fileId = info.id(); - GridCacheTx tx = metaCache.txStart(PESSIMISTIC, REPEATABLE_READ); + IgniteTx tx = metaCache.txStart(PESSIMISTIC, REPEATABLE_READ); try { // Lock file ID for this transaction. @@ -683,7 +683,7 @@ public class GridGgfsMetaManager extends GridGgfsManager { IgniteUuid res = null; - GridCacheTx tx = metaCache.txStart(PESSIMISTIC, REPEATABLE_READ); + IgniteTx tx = metaCache.txStart(PESSIMISTIC, REPEATABLE_READ); try { res = putIfAbsentNonTx(parentId, fileName, newFileInfo); @@ -772,7 +772,7 @@ public class GridGgfsMetaManager extends GridGgfsManager { try { assert validTxState(false); - GridCacheTx tx = metaCache.txStart(PESSIMISTIC, REPEATABLE_READ); + IgniteTx tx = metaCache.txStart(PESSIMISTIC, REPEATABLE_READ); try { moveNonTx(fileId, srcFileName, srcParentId, destFileName, destParentId); @@ -892,7 +892,7 @@ public class GridGgfsMetaManager extends GridGgfsManager { try { assert validTxState(false); - GridCacheTx tx = metaCache.txStart(PESSIMISTIC, REPEATABLE_READ); + IgniteTx tx = metaCache.txStart(PESSIMISTIC, REPEATABLE_READ); try { if (parentId != null) @@ -1006,7 +1006,7 @@ public class GridGgfsMetaManager extends GridGgfsManager { try { assert validTxState(false); - GridCacheTx tx = metaCache.txStart(PESSIMISTIC, REPEATABLE_READ); + IgniteTx tx = metaCache.txStart(PESSIMISTIC, REPEATABLE_READ); try { if (parentId == null) @@ -1127,7 +1127,7 @@ public class GridGgfsMetaManager extends GridGgfsManager { assert listing != null; assert validTxState(false); - GridCacheTx tx = metaCache.txStart(PESSIMISTIC, REPEATABLE_READ); + IgniteTx tx = metaCache.txStart(PESSIMISTIC, REPEATABLE_READ); try { Collection res = new HashSet<>(); @@ -1212,7 +1212,7 @@ public class GridGgfsMetaManager extends GridGgfsManager { try { assert validTxState(false); - GridCacheTx tx = metaCache.txStart(PESSIMISTIC, REPEATABLE_READ); + IgniteTx tx = metaCache.txStart(PESSIMISTIC, REPEATABLE_READ); try { boolean res = false; @@ -1385,7 +1385,7 @@ public class GridGgfsMetaManager extends GridGgfsManager { try { assert validTxState(false); - GridCacheTx tx = metaCache.txStart(PESSIMISTIC, REPEATABLE_READ); + IgniteTx tx = metaCache.txStart(PESSIMISTIC, REPEATABLE_READ); try { GridGgfsFileInfo info = updatePropertiesNonTx(parentId, fileId, fileName, props); @@ -1455,7 +1455,7 @@ public class GridGgfsMetaManager extends GridGgfsManager { if (log.isDebugEnabled()) log.debug("Update file info [fileId=" + fileId + ", c=" + c + ']'); - GridCacheTx tx = metaCache.isLockedByThread(fileId) ? null : metaCache.txStart(PESSIMISTIC, + IgniteTx tx = metaCache.isLockedByThread(fileId) ? null : metaCache.txStart(PESSIMISTIC, REPEATABLE_READ); try { @@ -1518,7 +1518,7 @@ public class GridGgfsMetaManager extends GridGgfsManager { try { validTxState(false); - GridCacheTx tx = metaCache.txStart(PESSIMISTIC, REPEATABLE_READ); + IgniteTx tx = metaCache.txStart(PESSIMISTIC, REPEATABLE_READ); try { Object prev = val != null ? metaCache.put(sampling, val) : metaCache.remove(sampling); @@ -2352,7 +2352,7 @@ public class GridGgfsMetaManager extends GridGgfsManager { pathIds.add(fileIds(path)); // Start pessimistic. - GridCacheTx tx = metaCache.txStart(PESSIMISTIC, REPEATABLE_READ); + IgniteTx tx = metaCache.txStart(PESSIMISTIC, REPEATABLE_READ); try { // Lock the very first existing parents and possibly the leaf as well. @@ -2574,7 +2574,7 @@ public class GridGgfsMetaManager extends GridGgfsManager { assert validTxState(false); // Start pessimistic transaction. - GridCacheTx tx = metaCache.txStart(PESSIMISTIC, REPEATABLE_READ); + IgniteTx tx = metaCache.txStart(PESSIMISTIC, REPEATABLE_READ); try { Map infoMap = lockIds(fileId, parentId); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/3008d2ad/modules/core/src/main/java/org/gridgain/grid/kernal/processors/rest/handlers/cache/GridCacheCommandHandler.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/gridgain/grid/kernal/processors/rest/handlers/cache/GridCacheCommandHandler.java b/modules/core/src/main/java/org/gridgain/grid/kernal/processors/rest/handlers/cache/GridCacheCommandHandler.java index b897b93..c05097c 100644 --- a/modules/core/src/main/java/org/gridgain/grid/kernal/processors/rest/handlers/cache/GridCacheCommandHandler.java +++ b/modules/core/src/main/java/org/gridgain/grid/kernal/processors/rest/handlers/cache/GridCacheCommandHandler.java @@ -456,7 +456,7 @@ public class GridCacheCommandHandler extends GridRestCommandHandlerAdapter { return ctx.closure().callLocalSafe(new Callable() { @Override public Object call() throws Exception { - try (GridCacheTx tx = cache.txStart(PESSIMISTIC, REPEATABLE_READ)) { + try (IgniteTx tx = cache.txStart(PESSIMISTIC, REPEATABLE_READ)) { Object curVal = cache.get(key); if (curVal == null) http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/3008d2ad/modules/core/src/main/java/org/gridgain/grid/kernal/processors/service/GridServiceProcessor.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/gridgain/grid/kernal/processors/service/GridServiceProcessor.java b/modules/core/src/main/java/org/gridgain/grid/kernal/processors/service/GridServiceProcessor.java index 39215f8..a78d063 100644 --- a/modules/core/src/main/java/org/gridgain/grid/kernal/processors/service/GridServiceProcessor.java +++ b/modules/core/src/main/java/org/gridgain/grid/kernal/processors/service/GridServiceProcessor.java @@ -620,7 +620,7 @@ public class GridServiceProcessor extends GridProcessorAdapter { Object affKey = cfg.getAffinityKey(); while (true) { - try (GridCacheTx tx = cache.txStart(PESSIMISTIC, REPEATABLE_READ)) { + try (IgniteTx tx = cache.txStart(PESSIMISTIC, REPEATABLE_READ)) { GridServiceAssignmentsKey key = new GridServiceAssignmentsKey(cfg.getName()); GridServiceAssignments oldAssigns = (GridServiceAssignments)cache.get(key); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/3008d2ad/modules/core/src/test/java/org/gridgain/grid/cache/store/GridCacheBalancingStoreSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/gridgain/grid/cache/store/GridCacheBalancingStoreSelfTest.java b/modules/core/src/test/java/org/gridgain/grid/cache/store/GridCacheBalancingStoreSelfTest.java index a0eeae1..8239278 100644 --- a/modules/core/src/test/java/org/gridgain/grid/cache/store/GridCacheBalancingStoreSelfTest.java +++ b/modules/core/src/test/java/org/gridgain/grid/cache/store/GridCacheBalancingStoreSelfTest.java @@ -120,7 +120,7 @@ public class GridCacheBalancingStoreSelfTest extends GridCommonAbstractTest { } /** {@inheritDoc} */ - @Nullable @Override public Integer load(@Nullable GridCacheTx tx, Integer key) throws IgniteCheckedException { + @Nullable @Override public Integer load(@Nullable IgniteTx tx, Integer key) throws IgniteCheckedException { boolean res = locks[key].tryLock(); if (res) { @@ -144,7 +144,7 @@ public class GridCacheBalancingStoreSelfTest extends GridCommonAbstractTest { } /** {@inheritDoc} */ - @Override public void loadAll(@Nullable GridCacheTx tx, Collection keys, + @Override public void loadAll(@Nullable IgniteTx tx, Collection keys, IgniteBiInClosure c) throws IgniteCheckedException { for (Integer key : keys) { boolean res = locks[key].tryLock(); @@ -163,29 +163,29 @@ public class GridCacheBalancingStoreSelfTest extends GridCommonAbstractTest { } /** {@inheritDoc} */ - @Override public void put(@Nullable GridCacheTx tx, Integer key, Integer val) throws IgniteCheckedException { + @Override public void put(@Nullable IgniteTx tx, Integer key, Integer val) throws IgniteCheckedException { // No-op. } /** {@inheritDoc} */ - @Override public void putAll(@Nullable GridCacheTx tx, Map map) + @Override public void putAll(@Nullable IgniteTx tx, Map map) throws IgniteCheckedException { // No-op. } /** {@inheritDoc} */ - @Override public void remove(@Nullable GridCacheTx tx, Integer key) throws IgniteCheckedException { + @Override public void remove(@Nullable IgniteTx tx, Integer key) throws IgniteCheckedException { // No-op. } /** {@inheritDoc} */ - @Override public void removeAll(@Nullable GridCacheTx tx, Collection keys) + @Override public void removeAll(@Nullable IgniteTx tx, Collection keys) throws IgniteCheckedException { // No-op. } /** {@inheritDoc} */ - @Override public void txEnd(GridCacheTx tx, boolean commit) throws IgniteCheckedException { + @Override public void txEnd(IgniteTx tx, boolean commit) throws IgniteCheckedException { // No-op. } }