ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From agoncha...@apache.org
Subject [42/50] [abbrv] ignite git commit: Merge branch master into ignite-264
Date Thu, 03 Sep 2015 01:03:51 GMT
http://git-wip-us.apache.org/repos/asf/ignite/blob/22d15de3/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheContext.java
----------------------------------------------------------------------

http://git-wip-us.apache.org/repos/asf/ignite/blob/22d15de3/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheIoManager.java
----------------------------------------------------------------------

http://git-wip-us.apache.org/repos/asf/ignite/blob/22d15de3/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheMvcc.java
----------------------------------------------------------------------

http://git-wip-us.apache.org/repos/asf/ignite/blob/22d15de3/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridCacheTxRecoveryFuture.java
----------------------------------------------------------------------

http://git-wip-us.apache.org/repos/asf/ignite/blob/22d15de3/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridDistributedCacheEntry.java
----------------------------------------------------------------------

http://git-wip-us.apache.org/repos/asf/ignite/blob/22d15de3/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridDistributedTxFinishRequest.java
----------------------------------------------------------------------

http://git-wip-us.apache.org/repos/asf/ignite/blob/22d15de3/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridDistributedTxRemoteAdapter.java
----------------------------------------------------------------------

http://git-wip-us.apache.org/repos/asf/ignite/blob/22d15de3/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtTransactionalCacheAdapter.java
----------------------------------------------------------------------

http://git-wip-us.apache.org/repos/asf/ignite/blob/22d15de3/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtTxFinishFuture.java
----------------------------------------------------------------------

http://git-wip-us.apache.org/repos/asf/ignite/blob/22d15de3/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtTxFinishRequest.java
----------------------------------------------------------------------

http://git-wip-us.apache.org/repos/asf/ignite/blob/22d15de3/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtTxFinishResponse.java
----------------------------------------------------------------------
diff --cc modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtTxFinishResponse.java
index 1a269ec,d696c05..ec0f234
--- 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
@@@ -17,17 -17,14 +17,18 @@@
  
  package org.apache.ignite.internal.processors.cache.distributed.dht;
  
- import org.apache.ignite.*;
- import org.apache.ignite.internal.*;
- import org.apache.ignite.internal.processors.cache.*;
- import org.apache.ignite.internal.processors.cache.distributed.*;
- import org.apache.ignite.internal.processors.cache.version.*;
- import org.apache.ignite.internal.util.typedef.internal.*;
- import org.apache.ignite.lang.*;
- import org.apache.ignite.plugin.extensions.communication.*;
- 
- import java.io.*;
- import java.nio.*;
+ import java.io.Externalizable;
+ import java.nio.ByteBuffer;
++
++import org.apache.ignite.IgniteCheckedException;
++import org.apache.ignite.internal.GridDirectTransient;
++import org.apache.ignite.internal.processors.cache.GridCacheSharedContext;
+ import org.apache.ignite.internal.processors.cache.distributed.GridDistributedTxFinishResponse;
+ import org.apache.ignite.internal.processors.cache.version.GridCacheVersion;
+ import org.apache.ignite.internal.util.typedef.internal.S;
+ import org.apache.ignite.lang.IgniteUuid;
+ import org.apache.ignite.plugin.extensions.communication.MessageReader;
+ import org.apache.ignite.plugin.extensions.communication.MessageWriter;
  
  /**
   * DHT transaction finish response.
@@@ -211,6 -125,6 +212,6 @@@ public class GridDhtTxFinishResponse ex
  
      /** {@inheritDoc} */
      @Override public byte fieldsCount() {
 -        return 6;
 +        return 8;
      }
- }
+ }

http://git-wip-us.apache.org/repos/asf/ignite/blob/22d15de3/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtTxLocal.java
----------------------------------------------------------------------

http://git-wip-us.apache.org/repos/asf/ignite/blob/22d15de3/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtTxLocalAdapter.java
----------------------------------------------------------------------

http://git-wip-us.apache.org/repos/asf/ignite/blob/22d15de3/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtTxPrepareFuture.java
----------------------------------------------------------------------

http://git-wip-us.apache.org/repos/asf/ignite/blob/22d15de3/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtTxRemote.java
----------------------------------------------------------------------

http://git-wip-us.apache.org/repos/asf/ignite/blob/22d15de3/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridPartitionedGetFuture.java
----------------------------------------------------------------------

http://git-wip-us.apache.org/repos/asf/ignite/blob/22d15de3/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridNearAtomicUpdateFuture.java
----------------------------------------------------------------------

http://git-wip-us.apache.org/repos/asf/ignite/blob/22d15de3/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/colocated/GridDhtColocatedLockFuture.java
----------------------------------------------------------------------

http://git-wip-us.apache.org/repos/asf/ignite/blob/22d15de3/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearLockFuture.java
----------------------------------------------------------------------

http://git-wip-us.apache.org/repos/asf/ignite/blob/22d15de3/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearLockRequest.java
----------------------------------------------------------------------

http://git-wip-us.apache.org/repos/asf/ignite/blob/22d15de3/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearOptimisticTxPrepareFuture.java
----------------------------------------------------------------------

http://git-wip-us.apache.org/repos/asf/ignite/blob/22d15de3/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearPessimisticTxPrepareFuture.java
----------------------------------------------------------------------

http://git-wip-us.apache.org/repos/asf/ignite/blob/22d15de3/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearTxFinishFuture.java
----------------------------------------------------------------------
diff --cc modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearTxFinishFuture.java
index 7b164b8,f29bd28..d437909
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearTxFinishFuture.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearTxFinishFuture.java
@@@ -17,31 -17,39 +17,43 @@@
  
  package org.apache.ignite.internal.processors.cache.distributed.near;
  
- import org.apache.ignite.*;
- import org.apache.ignite.cluster.*;
- import org.apache.ignite.internal.*;
- import org.apache.ignite.internal.cluster.*;
- import org.apache.ignite.internal.processors.affinity.*;
- import org.apache.ignite.internal.processors.cache.*;
- import org.apache.ignite.internal.processors.cache.distributed.*;
- import org.apache.ignite.internal.processors.cache.distributed.dht.*;
- import org.apache.ignite.internal.processors.cache.transactions.*;
- import org.apache.ignite.internal.processors.cache.version.*;
- import org.apache.ignite.internal.transactions.*;
- import org.apache.ignite.internal.util.future.*;
- import org.apache.ignite.internal.util.tostring.*;
- import org.apache.ignite.internal.util.typedef.*;
- import org.apache.ignite.internal.util.typedef.internal.*;
- import org.apache.ignite.lang.*;
- import org.apache.ignite.transactions.*;
- import org.jetbrains.annotations.*;
- 
- import java.util.*;
- import java.util.concurrent.*;
- import java.util.concurrent.atomic.*;
- 
- import static org.apache.ignite.internal.processors.cache.GridCacheOperation.*;
- import static org.apache.ignite.transactions.TransactionState.*;
+ import java.util.Collection;
+ import java.util.UUID;
+ import java.util.concurrent.ConcurrentMap;
+ import java.util.concurrent.atomic.AtomicReference;
+ import org.apache.ignite.IgniteCheckedException;
+ import org.apache.ignite.IgniteLogger;
+ import org.apache.ignite.cluster.ClusterNode;
+ import org.apache.ignite.internal.IgniteInternalFuture;
+ import org.apache.ignite.internal.cluster.ClusterTopologyCheckedException;
+ import org.apache.ignite.internal.processors.affinity.AffinityTopologyVersion;
+ import org.apache.ignite.internal.processors.cache.GridCacheContext;
+ import org.apache.ignite.internal.processors.cache.GridCacheEntryEx;
+ import org.apache.ignite.internal.processors.cache.GridCacheFuture;
+ import org.apache.ignite.internal.processors.cache.GridCacheSharedContext;
+ import org.apache.ignite.internal.processors.cache.distributed.GridDistributedTxMapping;
++import org.apache.ignite.internal.processors.cache.distributed.dht.GridDhtTxFinishRequest;
++import org.apache.ignite.internal.processors.cache.distributed.dht.GridDhtTxFinishResponse;
+ import org.apache.ignite.internal.processors.cache.transactions.IgniteInternalTx;
+ import org.apache.ignite.internal.processors.cache.transactions.IgniteTxEntry;
+ import org.apache.ignite.internal.processors.cache.version.GridCacheVersion;
+ import org.apache.ignite.internal.transactions.IgniteTxHeuristicCheckedException;
+ import org.apache.ignite.internal.transactions.IgniteTxRollbackCheckedException;
+ import org.apache.ignite.internal.util.future.GridCompoundIdentityFuture;
+ import org.apache.ignite.internal.util.future.GridFutureAdapter;
+ import org.apache.ignite.internal.util.tostring.GridToStringInclude;
+ import org.apache.ignite.internal.util.typedef.C1;
+ 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.apache.ignite.lang.IgniteClosure;
+ import org.apache.ignite.lang.IgniteUuid;
++import org.apache.ignite.transactions.TransactionRollbackException;
+ import org.jetbrains.annotations.Nullable;
+ 
+ import static org.apache.ignite.internal.processors.cache.GridCacheOperation.NOOP;
 -import static org.apache.ignite.transactions.TransactionState.COMMITTING;
++import static org.apache.ignite.transactions.TransactionState.UNKNOWN;
  
  /**
   *

http://git-wip-us.apache.org/repos/asf/ignite/blob/22d15de3/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearTxFinishRequest.java
----------------------------------------------------------------------

http://git-wip-us.apache.org/repos/asf/ignite/blob/22d15de3/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearTxLocal.java
----------------------------------------------------------------------

http://git-wip-us.apache.org/repos/asf/ignite/blob/22d15de3/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearTxRemote.java
----------------------------------------------------------------------

http://git-wip-us.apache.org/repos/asf/ignite/blob/22d15de3/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/IgniteTxAdapter.java
----------------------------------------------------------------------

http://git-wip-us.apache.org/repos/asf/ignite/blob/22d15de3/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/IgniteTxHandler.java
----------------------------------------------------------------------
diff --cc modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/IgniteTxHandler.java
index 7523af6,d64b26e..5627201
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/IgniteTxHandler.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/IgniteTxHandler.java
@@@ -17,31 -17,69 +17,70 @@@
  
  package org.apache.ignite.internal.processors.cache.transactions;
  
- import org.apache.ignite.*;
- import org.apache.ignite.cluster.*;
- import org.apache.ignite.internal.*;
- import org.apache.ignite.internal.cluster.*;
- import org.apache.ignite.internal.processors.affinity.*;
- import org.apache.ignite.internal.processors.cache.*;
- import org.apache.ignite.internal.processors.cache.distributed.*;
- import org.apache.ignite.internal.processors.cache.distributed.dht.*;
- import org.apache.ignite.internal.processors.cache.distributed.near.*;
- import org.apache.ignite.internal.processors.cache.version.*;
- import org.apache.ignite.internal.transactions.*;
- import org.apache.ignite.internal.util.future.*;
- import org.apache.ignite.internal.util.lang.*;
- import org.apache.ignite.internal.util.typedef.*;
- import org.apache.ignite.internal.util.typedef.internal.*;
- import org.apache.ignite.lang.*;
- import org.jetbrains.annotations.*;
- 
- import java.util.*;
- 
- import static org.apache.ignite.internal.managers.communication.GridIoPolicy.*;
- import static org.apache.ignite.internal.processors.cache.GridCacheUtils.*;
- import static org.apache.ignite.internal.processors.cache.transactions.IgniteInternalTx.FinalizationStatus.*;
- import static org.apache.ignite.transactions.TransactionConcurrency.*;
- import static org.apache.ignite.transactions.TransactionState.*;
+ import java.util.Collection;
+ import java.util.UUID;
+ import org.apache.ignite.IgniteCheckedException;
+ import org.apache.ignite.IgniteLogger;
+ import org.apache.ignite.cluster.ClusterNode;
+ import org.apache.ignite.internal.IgniteInternalFuture;
+ import org.apache.ignite.internal.cluster.ClusterTopologyCheckedException;
+ import org.apache.ignite.internal.processors.affinity.AffinityTopologyVersion;
+ import org.apache.ignite.internal.processors.cache.GridCacheContext;
+ import org.apache.ignite.internal.processors.cache.GridCacheEntryEx;
+ import org.apache.ignite.internal.processors.cache.GridCacheEntryInfo;
+ import org.apache.ignite.internal.processors.cache.GridCacheMessage;
+ import org.apache.ignite.internal.processors.cache.GridCacheSharedContext;
+ import org.apache.ignite.internal.processors.cache.KeyCacheObject;
+ import org.apache.ignite.internal.processors.cache.distributed.GridCacheTxRecoveryFuture;
+ import org.apache.ignite.internal.processors.cache.distributed.GridCacheTxRecoveryRequest;
+ import org.apache.ignite.internal.processors.cache.distributed.GridCacheTxRecoveryResponse;
+ import org.apache.ignite.internal.processors.cache.distributed.GridDistributedTxRemoteAdapter;
+ import org.apache.ignite.internal.processors.cache.distributed.dht.GridDhtInvalidPartitionException;
+ import org.apache.ignite.internal.processors.cache.distributed.dht.GridDhtPartitionTopology;
+ import org.apache.ignite.internal.processors.cache.distributed.dht.GridDhtTxFinishFuture;
+ import org.apache.ignite.internal.processors.cache.distributed.dht.GridDhtTxFinishRequest;
+ import org.apache.ignite.internal.processors.cache.distributed.dht.GridDhtTxFinishResponse;
+ import org.apache.ignite.internal.processors.cache.distributed.dht.GridDhtTxLocal;
+ import org.apache.ignite.internal.processors.cache.distributed.dht.GridDhtTxPrepareFuture;
+ import org.apache.ignite.internal.processors.cache.distributed.dht.GridDhtTxPrepareRequest;
+ import org.apache.ignite.internal.processors.cache.distributed.dht.GridDhtTxPrepareResponse;
+ import org.apache.ignite.internal.processors.cache.distributed.dht.GridDhtTxRemote;
+ import org.apache.ignite.internal.processors.cache.distributed.near.GridNearCacheAdapter;
+ import org.apache.ignite.internal.processors.cache.distributed.near.GridNearTxFinishFuture;
+ import org.apache.ignite.internal.processors.cache.distributed.near.GridNearTxFinishRequest;
+ import org.apache.ignite.internal.processors.cache.distributed.near.GridNearTxFinishResponse;
+ import org.apache.ignite.internal.processors.cache.distributed.near.GridNearTxLocal;
+ import org.apache.ignite.internal.processors.cache.distributed.near.GridNearTxPrepareFutureAdapter;
+ import org.apache.ignite.internal.processors.cache.distributed.near.GridNearTxPrepareRequest;
+ import org.apache.ignite.internal.processors.cache.distributed.near.GridNearTxPrepareResponse;
+ import org.apache.ignite.internal.processors.cache.distributed.near.GridNearTxRemote;
+ import org.apache.ignite.internal.processors.cache.version.GridCacheVersion;
+ import org.apache.ignite.internal.transactions.IgniteTxHeuristicCheckedException;
+ import org.apache.ignite.internal.transactions.IgniteTxOptimisticCheckedException;
+ import org.apache.ignite.internal.transactions.IgniteTxRollbackCheckedException;
+ import org.apache.ignite.internal.util.future.GridCompoundFuture;
+ import org.apache.ignite.internal.util.future.GridEmbeddedFuture;
+ import org.apache.ignite.internal.util.future.GridFinishedFuture;
+ import org.apache.ignite.internal.util.lang.GridClosureException;
+ import org.apache.ignite.internal.util.typedef.C2;
+ import org.apache.ignite.internal.util.typedef.CI1;
+ import org.apache.ignite.internal.util.typedef.CI2;
+ import org.apache.ignite.internal.util.typedef.F;
++import org.apache.ignite.internal.util.typedef.X;
+ import org.apache.ignite.internal.util.typedef.internal.CU;
+ import org.apache.ignite.internal.util.typedef.internal.U;
++import org.apache.ignite.lang.IgniteFutureCancelledException;
+ import org.jetbrains.annotations.Nullable;
+ 
+ import static org.apache.ignite.internal.managers.communication.GridIoPolicy.SYSTEM_POOL;
+ import static org.apache.ignite.internal.managers.communication.GridIoPolicy.UTILITY_CACHE_POOL;
+ import static org.apache.ignite.internal.processors.cache.GridCacheUtils.isNearEnabled;
+ import static org.apache.ignite.internal.processors.cache.transactions.IgniteInternalTx.FinalizationStatus.USER_FINISH;
+ import static org.apache.ignite.transactions.TransactionConcurrency.OPTIMISTIC;
+ import static org.apache.ignite.transactions.TransactionConcurrency.PESSIMISTIC;
 -import static org.apache.ignite.transactions.TransactionIsolation.READ_COMMITTED;
+ import static org.apache.ignite.transactions.TransactionState.PREPARED;
+ import static org.apache.ignite.transactions.TransactionState.ROLLED_BACK;
+ import static org.apache.ignite.transactions.TransactionState.ROLLING_BACK;
  
  /**
   * Isolated logic to process cache messages.

http://git-wip-us.apache.org/repos/asf/ignite/blob/22d15de3/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/IgniteTxLocalAdapter.java
----------------------------------------------------------------------

http://git-wip-us.apache.org/repos/asf/ignite/blob/22d15de3/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/IgniteTxManager.java
----------------------------------------------------------------------

http://git-wip-us.apache.org/repos/asf/ignite/blob/22d15de3/modules/core/src/main/java/org/apache/ignite/internal/processors/datastructures/DataStructuresProcessor.java
----------------------------------------------------------------------

http://git-wip-us.apache.org/repos/asf/ignite/blob/22d15de3/modules/core/src/main/java/org/apache/ignite/internal/processors/datastructures/GridTransactionalCacheQueueImpl.java
----------------------------------------------------------------------
diff --cc modules/core/src/main/java/org/apache/ignite/internal/processors/datastructures/GridTransactionalCacheQueueImpl.java
index 7dfd41e,94cbfbd..c7750a6
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/datastructures/GridTransactionalCacheQueueImpl.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/datastructures/GridTransactionalCacheQueueImpl.java
@@@ -17,22 -17,24 +17,27 @@@
  
  package org.apache.ignite.internal.processors.datastructures;
  
- import org.apache.ignite.*;
- import org.apache.ignite.internal.cluster.*;
- import org.apache.ignite.internal.processors.cache.*;
- import org.apache.ignite.internal.processors.cache.transactions.*;
- import org.apache.ignite.internal.transactions.*;
- import org.apache.ignite.internal.util.typedef.internal.*;
- import org.apache.ignite.transactions.*;
- import org.jetbrains.annotations.*;
- 
- import java.util.*;
- 
- import static org.apache.ignite.transactions.TransactionConcurrency.*;
- import static org.apache.ignite.transactions.TransactionIsolation.*;
+ import java.util.Collection;
+ import java.util.HashMap;
+ import java.util.Map;
+ import org.apache.ignite.IgniteCheckedException;
+ import org.apache.ignite.IgniteException;
++import org.apache.ignite.IgniteQueue;
+ import org.apache.ignite.internal.cluster.ClusterGroupEmptyCheckedException;
+ import org.apache.ignite.internal.cluster.ClusterTopologyCheckedException;
+ import org.apache.ignite.internal.processors.cache.GridCacheContext;
+ import org.apache.ignite.internal.processors.cache.transactions.IgniteInternalTx;
++import org.apache.ignite.internal.transactions.IgniteTxRollbackCheckedException;
+ import org.apache.ignite.internal.util.typedef.internal.A;
+ import org.apache.ignite.internal.util.typedef.internal.U;
++import org.apache.ignite.transactions.TransactionRollbackException;
+ import org.jetbrains.annotations.Nullable;
+ 
+ import static org.apache.ignite.transactions.TransactionConcurrency.PESSIMISTIC;
+ import static org.apache.ignite.transactions.TransactionIsolation.REPEATABLE_READ;
  
  /**
 - * {@link org.apache.ignite.IgniteQueue} implementation using transactional cache.
 + * {@link IgniteQueue} implementation using transactional cache.
   */
  public class GridTransactionalCacheQueueImpl<T> extends GridCacheQueueAdapter<T>
{
      /**

http://git-wip-us.apache.org/repos/asf/ignite/blob/22d15de3/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsFileAffinityRange.java
----------------------------------------------------------------------

http://git-wip-us.apache.org/repos/asf/ignite/blob/22d15de3/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/CacheStoreUsageMultinodeAbstractTest.java
----------------------------------------------------------------------

http://git-wip-us.apache.org/repos/asf/ignite/blob/22d15de3/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheAbstractFullApiSelfTest.java
----------------------------------------------------------------------

http://git-wip-us.apache.org/repos/asf/ignite/blob/22d15de3/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheMvccSelfTest.java
----------------------------------------------------------------------

http://git-wip-us.apache.org/repos/asf/ignite/blob/22d15de3/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCachePutAllFailoverSelfTest.java
----------------------------------------------------------------------

http://git-wip-us.apache.org/repos/asf/ignite/blob/22d15de3/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/IgniteInternalCacheTypesTest.java
----------------------------------------------------------------------

http://git-wip-us.apache.org/repos/asf/ignite/blob/22d15de3/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/GridCachePartitionNotLoadedEventSelfTest.java
----------------------------------------------------------------------
diff --cc modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/GridCachePartitionNotLoadedEventSelfTest.java
index 3ef2641,9ef99f7..f0c0c20
--- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/GridCachePartitionNotLoadedEventSelfTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/GridCachePartitionNotLoadedEventSelfTest.java
@@@ -17,25 -17,29 +17,30 @@@
  
  package org.apache.ignite.internal.processors.cache.distributed;
  
- import org.apache.ignite.*;
- import org.apache.ignite.cache.*;
- import org.apache.ignite.cache.affinity.*;
- import org.apache.ignite.configuration.*;
- import org.apache.ignite.events.*;
- import org.apache.ignite.internal.*;
- import org.apache.ignite.internal.processors.cache.distributed.dht.preloader.*;
- import org.apache.ignite.internal.util.lang.*;
- import org.apache.ignite.lang.*;
- import org.apache.ignite.spi.discovery.tcp.*;
- import org.apache.ignite.spi.discovery.tcp.ipfinder.*;
- import org.apache.ignite.spi.discovery.tcp.ipfinder.vm.*;
- import org.apache.ignite.testframework.*;
- import org.apache.ignite.testframework.junits.common.*;
- import org.apache.ignite.util.*;
- import org.eclipse.jetty.util.*;
- 
- import java.util.*;
- import java.util.concurrent.*;
+ import java.util.Collection;
+ import java.util.UUID;
+ import java.util.concurrent.Callable;
+ import java.util.concurrent.TimeUnit;
+ import org.apache.ignite.IgniteCache;
+ import org.apache.ignite.cache.CacheMode;
+ import org.apache.ignite.cache.affinity.Affinity;
+ import org.apache.ignite.configuration.CacheConfiguration;
+ import org.apache.ignite.configuration.IgniteConfiguration;
+ import org.apache.ignite.events.CacheRebalancingEvent;
+ import org.apache.ignite.events.Event;
+ import org.apache.ignite.events.EventType;
+ import org.apache.ignite.internal.IgniteFutureTimeoutCheckedException;
+ import org.apache.ignite.internal.IgniteInternalFuture;
+ import org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtPartitionsFullMessage;
++import org.apache.ignite.internal.util.lang.GridAbsPredicate;
+ import org.apache.ignite.lang.IgnitePredicate;
+ import org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi;
+ import org.apache.ignite.spi.discovery.tcp.ipfinder.TcpDiscoveryIpFinder;
+ import org.apache.ignite.spi.discovery.tcp.ipfinder.vm.TcpDiscoveryVmIpFinder;
+ import org.apache.ignite.testframework.GridTestUtils;
+ import org.apache.ignite.testframework.junits.common.GridCommonAbstractTest;
+ import org.apache.ignite.util.TestTcpCommunicationSpi;
+ import org.eclipse.jetty.util.ConcurrentHashSet;
  
  /**
   *

http://git-wip-us.apache.org/repos/asf/ignite/blob/22d15de3/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/GridCacheTransformEventSelfTest.java
----------------------------------------------------------------------

http://git-wip-us.apache.org/repos/asf/ignite/blob/22d15de3/modules/core/src/test/java/org/apache/ignite/testsuites/IgniteCacheFailoverTestSuite.java
----------------------------------------------------------------------


Mime
View raw message