ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sboi...@apache.org
Subject [4/5] incubator-ignite git commit: #ignite-758: Remove methods txSynchronize, txUnsynchronize, txSynchronizations from GridCache.
Date Wed, 15 Apr 2015 17:00:49 GMT
#ignite-758: Remove methods txSynchronize, txUnsynchronize, txSynchronizations from GridCache.


Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/399ddd23
Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/399ddd23
Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/399ddd23

Branch: refs/heads/ignite-758
Commit: 399ddd23d3cc007c79d1a88c81c27c9b4e2aec20
Parents: 0316790
Author: ivasilinets <ivasilinets@gridgain.com>
Authored: Wed Apr 15 18:22:57 2015 +0300
Committer: ivasilinets <ivasilinets@gridgain.com>
Committed: Wed Apr 15 18:22:57 2015 +0300

----------------------------------------------------------------------
 .../internal/processors/cache/GridCache.java    | 26 --------------
 .../processors/cache/GridCacheAdapter.java      | 15 --------
 .../processors/cache/GridCacheProxyImpl.java    | 36 --------------------
 .../TransactionSynchronization.java             |  3 +-
 4 files changed, 1 insertion(+), 79 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/399ddd23/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCache.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCache.java
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCache.java
index d2cfffb..f17410d 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCache.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCache.java
@@ -66,32 +66,6 @@ public interface GridCache<K, V> extends CacheProjection<K, V>
{
     public CacheConfiguration configuration();
 
     /**
-     * Registers transactions synchronizations for all transactions started by this cache.
-     * Use it whenever you need to get notifications on transaction lifecycle and possibly
change
-     * its course. It is also particularly useful when integrating cache transactions
-     * with some other in-house transactions.
-     *
-     * @param syncs Transaction synchronizations to register.
-     */
-    public void txSynchronize(@Nullable TransactionSynchronization syncs);
-
-    /**
-     * Removes transaction synchronizations.
-     *
-     * @param syncs Transactions synchronizations to remove.
-     * @see #txSynchronize(TransactionSynchronization)
-     */
-    public void txUnsynchronize(@Nullable TransactionSynchronization syncs);
-
-    /**
-     * Gets registered transaction synchronizations.
-     *
-     * @return Registered transaction synchronizations.
-     * @see #txSynchronize(TransactionSynchronization)
-     */
-    public Collection<TransactionSynchronization> txSynchronizations();
-
-    /**
      * Gets affinity service to provide information about data partitioning
      * and distribution.
      *

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/399ddd23/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheAdapter.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheAdapter.java
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheAdapter.java
index 63c42d3..da5fa3c 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheAdapter.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheAdapter.java
@@ -3310,21 +3310,6 @@ public abstract class GridCacheAdapter<K, V> implements GridCache<K,
V>,
     }
 
     /** {@inheritDoc} */
-    @Override public void txSynchronize(TransactionSynchronization syncs) {
-        ctx.tm().addSynchronizations(syncs);
-    }
-
-    /** {@inheritDoc} */
-    @Override public void txUnsynchronize(TransactionSynchronization syncs) {
-        ctx.tm().removeSynchronizations(syncs);
-    }
-
-    /** {@inheritDoc} */
-    @Override public Collection<TransactionSynchronization> txSynchronizations() {
-        return ctx.tm().synchronizations();
-    }
-
-    /** {@inheritDoc} */
     @Override public void localLoadCache(final IgniteBiPredicate<K, V> p, Object[]
args)
         throws IgniteCheckedException {
         final boolean replicate = ctx.isDrEnabled();

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/399ddd23/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheProxyImpl.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheProxyImpl.java
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheProxyImpl.java
index 895f82d..6739bcb 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheProxyImpl.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheProxyImpl.java
@@ -158,42 +158,6 @@ public class GridCacheProxyImpl<K, V> implements GridCacheProxy<K,
V>, Externali
     }
 
     /** {@inheritDoc} */
-    @Override public void txSynchronize(@Nullable TransactionSynchronization syncs) {
-        GridCacheProjectionImpl<K, V> prev = gate.enter(prj);
-
-        try {
-            cache.txSynchronize(syncs);
-        }
-        finally {
-            gate.leave(prev);
-        }
-    }
-
-    /** {@inheritDoc} */
-    @Override public void txUnsynchronize(@Nullable TransactionSynchronization syncs) {
-        GridCacheProjectionImpl<K, V> prev = gate.enter(prj);
-
-        try {
-            cache.txUnsynchronize(syncs);
-        }
-        finally {
-            gate.leave(prev);
-        }
-    }
-
-    /** {@inheritDoc} */
-    @Override public Collection<TransactionSynchronization> txSynchronizations() {
-        GridCacheProjectionImpl<K, V> prev = gate.enter(prj);
-
-        try {
-            return cache.txSynchronizations();
-        }
-        finally {
-            gate.leave(prev);
-        }
-    }
-
-    /** {@inheritDoc} */
     @Override public CacheMetrics metrics() {
         GridCacheProjectionImpl<K, V> prev = gate.enter(prj);
 

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/399ddd23/modules/core/src/main/java/org/apache/ignite/transactions/TransactionSynchronization.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/transactions/TransactionSynchronization.java
b/modules/core/src/main/java/org/apache/ignite/transactions/TransactionSynchronization.java
index 01d24d5..9766bdc 100644
--- a/modules/core/src/main/java/org/apache/ignite/transactions/TransactionSynchronization.java
+++ b/modules/core/src/main/java/org/apache/ignite/transactions/TransactionSynchronization.java
@@ -21,8 +21,7 @@ import org.jetbrains.annotations.*;
 
 /**
  * Synchronization callback for transaction. You can subscribe to receive transaction
- * state change callbacks by registering transaction synchronization via
- * {@link org.apache.ignite.internal.processors.cache.GridCache#txSynchronize(TransactionSynchronization)}
method.
+ * state change callbacks by registering transaction synchronization.
  */
 public interface TransactionSynchronization {
     /**


Mime
View raw message