ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sboi...@apache.org
Subject [49/50] [abbrv] ignite git commit: Merge remote-tracking branch 'remotes/origin/master' into ignite-db-x-10884
Date Fri, 22 Apr 2016 12:30:31 GMT
Merge remote-tracking branch 'remotes/origin/master' into ignite-db-x-10884

Conflicts:
	modules/core/src/main/java/org/apache/ignite/IgniteSystemProperties.java
	modules/core/src/main/java/org/apache/ignite/configuration/IgniteConfiguration.java
	modules/core/src/main/java/org/apache/ignite/internal/GridKernalContext.java
	modules/core/src/main/java/org/apache/ignite/internal/GridKernalContextImpl.java
	modules/core/src/main/java/org/apache/ignite/internal/IgniteKernal.java
	modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheEvictableEntryImpl.java
	modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheAdapter.java
	modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheContext.java
	modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheEntryEx.java
	modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheMapEntry.java
	modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheProcessor.java
	modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheSharedContext.java
	modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheSwapManager.java
	modules/core/src/main/java/org/apache/ignite/internal/processors/cache/binary/CacheObjectBinaryProcessorImpl.java
	modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtCacheAdapter.java
	modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtPartitionTopologyImpl.java
	modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtTransactionalCacheAdapter.java
	modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridPartitionedGetFuture.java
	modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridPartitionedSingleGetFuture.java
	modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridDhtAtomicCache.java
	modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/colocated/GridDhtColocatedCache.java
	modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearGetFuture.java
	modules/core/src/main/java/org/apache/ignite/internal/processors/cache/local/atomic/GridLocalAtomicCache.java
	modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/GridCacheQueryManager.java
	modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/IgniteTxAdapter.java
	modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/IgniteTxLocalAdapter.java
	modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheTestEntryEx.java
	modules/core/src/test/java/org/apache/ignite/testsuites/IgniteKernalSelfTestSuite.java
	pom.xml


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

Branch: refs/heads/ignite-db-x-10884
Commit: 1643a7cc90fd61292c672843854ab8d547156848
Parents: f61c260 e1eb931
Author: sboikov <sboikov@gridgain.com>
Authored: Fri Apr 22 15:28:51 2016 +0300
Committer: sboikov <sboikov@gridgain.com>
Committed: Fri Apr 22 15:28:51 2016 +0300

----------------------------------------------------------------------
 .gitignore                                      |    4 +
 DEVNOTES.txt                                    |    4 +-
 assembly/dependencies-fabric-lgpl.xml           |    1 +
 assembly/dependencies-fabric.xml                |    1 +
 bin/ignite.bat                                  |    7 +-
 bin/ignite.sh                                   |    6 +-
 .../store/CacheLoadOnlyStoreExample.java        |  171 +
 .../streaming/StreamVisitorExample.java         |   31 +-
 examples/src/main/resources/person.csv          |   20 +
 .../ignite/examples/CacheExamplesSelfTest.java  |    8 +
 modules/aws/pom.xml                             |   38 +-
 .../jmh/cache/JmhCacheAbstractBenchmark.java    |    3 +
 .../benchmarks/jmh/cache/JmhCacheBenchmark.java |  145 +
 .../jmh/cache/JmhCachePutBenchmark.java         |  124 -
 .../jmh/runner/JmhIdeBenchmarkRunner.java       |   20 +-
 .../ClientAbstractMultiNodeSelfTest.java        |    8 +-
 .../rest/RestBinaryProtocolSelfTest.java        |    4 +-
 .../rest/RestMemcacheProtocolSelfTest.java      |    4 +-
 .../java/org/apache/ignite/IgniteCache.java     |   20 +-
 .../java/org/apache/ignite/IgniteQueue.java     |   27 +-
 .../main/java/org/apache/ignite/IgniteSet.java  |   26 +-
 .../apache/ignite/IgniteSystemProperties.java   |   15 +-
 .../main/java/org/apache/ignite/Ignition.java   |   19 +-
 .../ignite/binary/BinaryBasicNameMapper.java    |    2 +-
 .../ignite/cache/CacheInterceptorEntry.java     |   39 +
 .../apache/ignite/cache/CacheMemoryMode.java    |    2 +
 .../ignite/cache/affinity/AffinityFunction.java |    2 +
 .../cache/query/CacheQueryEntryEvent.java       |   48 +
 .../ignite/cache/query/ContinuousQuery.java     |   35 +
 .../store/jdbc/CacheAbstractJdbcStore.java      |    4 +
 .../cache/store/jdbc/CacheJdbcPojoStore.java    |    2 +-
 .../configuration/ConnectorConfiguration.java   |    3 +
 .../configuration/FileSystemConfiguration.java  |   96 +-
 .../configuration/IgniteConfiguration.java      |   92 +
 .../ignite/configuration/OdbcConfiguration.java |  319 +
 .../configuration/TransactionConfiguration.java |   32 +
 .../igfs/IgfsIpcEndpointConfiguration.java      |   28 +
 .../java/org/apache/ignite/igfs/IgfsPath.java   |   32 +-
 .../internal/GridEventConsumeHandler.java       |    7 +-
 .../ignite/internal/GridJobCancelRequest.java   |    5 +
 .../ignite/internal/GridJobExecuteRequest.java  |    5 +
 .../ignite/internal/GridJobExecuteResponse.java |    5 +
 .../ignite/internal/GridJobSiblingsRequest.java |    5 +
 .../internal/GridJobSiblingsResponse.java       |    5 +
 .../ignite/internal/GridKernalContext.java      |    9 +
 .../ignite/internal/GridKernalContextImpl.java  |   13 +
 .../apache/ignite/internal/GridLoggerProxy.java |    3 +-
 .../internal/GridMessageListenHandler.java      |   23 +-
 .../ignite/internal/GridTaskCancelRequest.java  |    5 +
 .../ignite/internal/GridTaskSessionRequest.java |    5 +
 .../ignite/internal/IgniteComputeImpl.java      |    4 +-
 .../apache/ignite/internal/IgniteKernal.java    |   52 +-
 .../ignite/internal/IgniteNodeAttributes.java   |    3 +
 .../org/apache/ignite/internal/IgnitionEx.java  |   67 +-
 .../ignite/internal/MarshallerContextImpl.java  |   10 +-
 .../internal/binary/BinaryClassDescriptor.java  |   24 +-
 .../ignite/internal/binary/BinaryContext.java   |   73 +-
 .../internal/binary/BinaryEnumObjectImpl.java   |   55 +-
 .../internal/binary/BinaryFieldAccessor.java    |    1 +
 .../internal/binary/BinaryObjectImpl.java       |   57 +-
 .../binary/BinaryObjectOffheapImpl.java         |   45 +-
 .../internal/binary/BinaryReaderExImpl.java     |   70 +-
 .../ignite/internal/binary/BinarySchema.java    |   11 +-
 .../ignite/internal/binary/BinaryTypeImpl.java  |    8 +
 .../ignite/internal/binary/BinaryUtils.java     |  119 +-
 .../ignite/internal/binary/BinaryWriteMode.java |    3 +
 .../internal/binary/BinaryWriterExImpl.java     |   34 +
 .../internal/binary/GridBinaryMarshaller.java   |    7 +-
 .../binary/builder/BinaryBuilderReader.java     |   11 +-
 .../binary/builder/BinaryBuilderSerializer.java |   16 +-
 .../binary/builder/BinaryObjectBuilderImpl.java |  119 +-
 .../binary/builder/BinaryValueWithType.java     |    3 +-
 .../internal/direct/DirectMessageReader.java    |    2 +-
 .../internal/direct/DirectMessageWriter.java    |    4 +-
 .../direct/state/DirectMessageState.java        |    7 +-
 .../stream/v2/DirectByteBufferStreamImplV2.java |    2 +-
 .../ignite/internal/jdbc/JdbcStatement.java     |    9 +-
 .../ignite/internal/jdbc2/JdbcStatement.java    |    7 +-
 .../internal/managers/GridManagerAdapter.java   |    4 +-
 .../checkpoint/GridCheckpointManager.java       |    2 +-
 .../checkpoint/GridCheckpointRequest.java       |    5 +
 .../managers/communication/GridIoManager.java   |  256 +-
 .../managers/communication/GridIoMessage.java   |    5 +
 .../communication/GridIoMessageFactory.java     |    4 +-
 .../managers/communication/GridIoPolicy.java    |    3 +
 .../communication/GridIoUserMessage.java        |    5 +
 .../deployment/GridDeploymentCommunication.java |    5 +-
 .../deployment/GridDeploymentInfoBean.java      |    5 +
 .../deployment/GridDeploymentLocalStore.java    |    2 +-
 .../deployment/GridDeploymentRequest.java       |    5 +
 .../deployment/GridDeploymentResponse.java      |    5 +
 .../discovery/GridDiscoveryManager.java         |   92 +-
 .../eventstorage/GridEventStorageManager.java   |   10 +-
 .../eventstorage/GridEventStorageMessage.java   |    5 +
 .../affinity/AffinityTopologyVersion.java       |    5 +
 .../affinity/GridAffinityAssignment.java        |  100 +-
 .../affinity/GridAffinityAssignmentCache.java   |  314 +-
 .../affinity/GridAffinityProcessor.java         |    8 +-
 .../processors/affinity/GridAffinityUtils.java  |    6 +-
 .../cache/CacheAffinityChangeMessage.java       |  160 +
 .../cache/CacheAffinitySharedManager.java       | 1795 ++++++
 .../cache/CacheClusterMetricsMXBeanImpl.java    |  410 ++
 .../cache/CacheEntryInfoCollection.java         |    5 +
 .../cache/CacheEntryPredicateAdapter.java       |    8 +
 .../cache/CacheEntryPredicateContainsValue.java |    8 +-
 .../cache/CacheEntrySerializablePredicate.java  |    8 +-
 .../cache/CacheEvictableEntryImpl.java          |    6 +-
 .../processors/cache/CacheEvictionEntry.java    |    5 +
 .../cache/CacheInvokeDirectResult.java          |    8 +-
 .../processors/cache/CacheInvokeEntry.java      |   41 +-
 .../processors/cache/CacheLazyEntry.java        |   62 +-
 .../cache/CacheLocalMetricsMXBeanImpl.java      |  410 ++
 .../cache/CacheMetricsMXBeanImpl.java           |  410 --
 .../internal/processors/cache/CacheObject.java  |    3 +
 .../cache/CacheObjectByteArrayImpl.java         |    5 +
 .../processors/cache/CacheObjectImpl.java       |    5 +
 .../processors/cache/CacheOperationFilter.java  |   61 +
 .../cache/DynamicCacheChangeRequest.java        |   17 +
 .../cache/DynamicCacheDescriptor.java           |   49 +
 .../processors/cache/GridCacheAdapter.java      |  633 +-
 .../cache/GridCacheAffinityManager.java         |  160 +-
 .../processors/cache/GridCacheAtomicFuture.java |    5 -
 .../cache/GridCacheClearAllRunnable.java        |    3 +-
 .../processors/cache/GridCacheContext.java      |   22 +-
 .../cache/GridCacheDeploymentManager.java       |   13 +-
 .../processors/cache/GridCacheEntryEx.java      |   19 +-
 .../processors/cache/GridCacheEntryInfo.java    |    5 +
 .../cache/GridCacheEvictionManager.java         |   36 +-
 .../processors/cache/GridCacheIoManager.java    |   29 +-
 .../processors/cache/GridCacheLogger.java       |    3 +-
 .../processors/cache/GridCacheMapEntry.java     |  425 +-
 .../processors/cache/GridCacheMessage.java      |    9 +-
 .../cache/GridCacheMvccCandidate.java           |   16 +-
 .../processors/cache/GridCacheMvccManager.java  |  186 +-
 .../GridCachePartitionExchangeManager.java      |  194 +-
 .../processors/cache/GridCachePreloader.java    |   24 +-
 .../cache/GridCachePreloaderAdapter.java        |   17 +-
 .../processors/cache/GridCacheProcessor.java    |  289 +-
 .../processors/cache/GridCacheProxyImpl.java    |  110 +-
 .../processors/cache/GridCacheReturn.java       |    5 +
 .../cache/GridCacheSharedContext.java           |   18 +-
 .../processors/cache/GridCacheSwapManager.java  |   41 +-
 .../processors/cache/GridCacheTtlManager.java   |   75 +-
 .../cache/GridCacheUpdateAtomicResult.java      |    4 +-
 .../processors/cache/GridCacheUtils.java        |  209 +-
 .../processors/cache/IgniteCacheProxy.java      |   43 +-
 .../processors/cache/IgniteInternalCache.java   |  119 +-
 .../processors/cache/KeyCacheObjectImpl.java    |    5 +
 .../cache/affinity/GridCacheAffinityImpl.java   |    9 +-
 .../binary/CacheObjectBinaryProcessorImpl.java  |   18 +-
 .../CacheDataStructuresManager.java             |    8 +-
 .../distributed/GridCacheCommittedTxInfo.java   |    1 +
 .../GridDistributedCacheAdapter.java            |    2 +-
 .../GridDistributedLockResponse.java            |   11 +-
 .../GridDistributedTxFinishRequest.java         |    2 +
 .../GridDistributedTxPrepareRequest.java        |    2 +-
 .../GridDistributedTxPrepareResponse.java       |    3 +-
 .../GridDistributedTxRemoteAdapter.java         |   12 +-
 .../dht/CacheDistributedGetFutureAdapter.java   |    3 -
 .../dht/GridClientPartitionTopology.java        |   15 +-
 .../dht/GridDhtAffinityAssignmentResponse.java  |  199 +-
 .../dht/GridDhtAssignmentFetchFuture.java       |   80 +-
 .../distributed/dht/GridDhtCacheAdapter.java    |  128 +-
 .../distributed/dht/GridDhtCacheEntry.java      |    2 +-
 .../distributed/dht/GridDhtEmbeddedFuture.java  |   13 +-
 .../cache/distributed/dht/GridDhtGetFuture.java |  178 +-
 .../distributed/dht/GridDhtGetSingleFuture.java |  478 ++
 .../distributed/dht/GridDhtLocalPartition.java  |   76 +-
 .../distributed/dht/GridDhtLockFuture.java      |   24 +-
 .../distributed/dht/GridDhtPartitionState.java  |    2 +-
 .../dht/GridDhtPartitionTopology.java           |   15 +-
 .../dht/GridDhtPartitionTopologyImpl.java       |  367 +-
 .../dht/GridDhtTransactionalCacheAdapter.java   |    5 +-
 .../distributed/dht/GridDhtTxFinishFuture.java  |   29 +-
 .../dht/GridDhtTxFinishResponse.java            |    3 +-
 .../cache/distributed/dht/GridDhtTxLocal.java   |  210 +-
 .../distributed/dht/GridDhtTxLocalAdapter.java  |    4 +-
 .../distributed/dht/GridDhtTxPrepareFuture.java |   69 +-
 .../cache/distributed/dht/GridDhtTxRemote.java  |   20 +-
 .../dht/GridPartitionedGetFuture.java           |    8 +-
 .../dht/GridPartitionedSingleGetFuture.java     |    8 +-
 .../dht/atomic/GridDhtAtomicCache.java          |  503 +-
 .../dht/atomic/GridDhtAtomicUpdateFuture.java   |   94 +-
 .../dht/atomic/GridDhtAtomicUpdateRequest.java  |   40 +-
 .../dht/atomic/GridDhtAtomicUpdateResponse.java |    3 +-
 .../GridNearAtomicAbstractUpdateFuture.java     |  244 +
 .../GridNearAtomicSingleUpdateFuture.java       |  645 ++
 .../dht/atomic/GridNearAtomicUpdateFuture.java  | 1392 ++---
 .../dht/atomic/GridNearAtomicUpdateRequest.java |   19 +-
 .../atomic/GridNearAtomicUpdateResponse.java    |    3 +-
 .../dht/colocated/GridDhtColocatedCache.java    |   46 +-
 .../colocated/GridDhtColocatedLockFuture.java   |   17 +-
 .../dht/preloader/GridDhtForceKeysResponse.java |    3 +-
 .../GridDhtPartitionDemandMessage.java          |    3 +-
 .../dht/preloader/GridDhtPartitionDemander.java |   51 +-
 .../preloader/GridDhtPartitionExchangeId.java   |    5 +
 .../dht/preloader/GridDhtPartitionMap2.java     |    4 +-
 .../dht/preloader/GridDhtPartitionSupplier.java |   29 +-
 .../GridDhtPartitionsExchangeFuture.java        | 1538 +++--
 .../preloader/GridDhtPartitionsFullMessage.java |    5 +-
 .../GridDhtPartitionsSingleMessage.java         |    5 +-
 .../dht/preloader/GridDhtPreloader.java         |  119 +-
 .../distributed/near/CacheVersionedValue.java   |    5 +
 .../distributed/near/GridNearAtomicCache.java   |   41 +-
 .../distributed/near/GridNearCacheAdapter.java  |   32 +-
 .../distributed/near/GridNearCacheEntry.java    |  120 +-
 .../distributed/near/GridNearGetFuture.java     |   26 +-
 .../distributed/near/GridNearGetResponse.java   |    3 +-
 .../distributed/near/GridNearLockFuture.java    |   10 +-
 ...arOptimisticSerializableTxPrepareFuture.java |    9 +-
 .../near/GridNearOptimisticTxPrepareFuture.java |   54 +-
 ...ridNearOptimisticTxPrepareFutureAdapter.java |   16 +-
 .../GridNearPessimisticTxPrepareFuture.java     |    2 +-
 .../near/GridNearSingleGetResponse.java         |    3 +-
 .../near/GridNearTransactionalCache.java        |    7 +-
 .../near/GridNearTxFinishFuture.java            |  123 +-
 .../near/GridNearTxFinishRequest.java           |   46 +-
 .../near/GridNearTxFinishResponse.java          |    3 +-
 .../cache/distributed/near/GridNearTxLocal.java |  115 +-
 .../near/GridNearTxPrepareFutureAdapter.java    |    4 +-
 .../distributed/near/GridNearTxRemote.java      |   33 +-
 .../processors/cache/dr/GridCacheDrManager.java |    8 +-
 .../cache/dr/GridOsCacheDrManager.java          |    5 +-
 .../cache/local/GridLocalCacheEntry.java        |   27 -
 .../cache/local/GridLocalLockFuture.java        |   15 -
 .../local/atomic/GridLocalAtomicCache.java      |  121 +-
 .../cache/query/GridCacheLocalQueryFuture.java  |    7 +-
 .../cache/query/GridCacheQueryManager.java      |  569 +-
 .../cache/query/GridCacheQueryRequest.java      |   13 +-
 .../cache/query/GridCacheQueryResponse.java     |    3 +-
 .../cache/query/GridCacheSqlQuery.java          |   11 +-
 .../CacheContinuousQueryBatchAck.java           |    4 +
 .../continuous/CacheContinuousQueryEntry.java   |    5 +
 .../continuous/CacheContinuousQueryEvent.java   |   17 +-
 .../continuous/CacheContinuousQueryHandler.java |  384 +-
 .../CacheContinuousQueryHandlerV2.java          |  176 +
 .../CacheContinuousQueryListener.java           |    5 +-
 .../continuous/CacheContinuousQueryManager.java |  406 +-
 .../jdbc/GridCacheQueryJdbcValidationTask.java  |    3 +-
 .../store/GridCacheStoreManagerAdapter.java     |    3 +-
 .../cache/transactions/IgniteInternalTx.java    |   34 +-
 .../transactions/IgniteTransactionsImpl.java    |    9 +-
 .../cache/transactions/IgniteTxAdapter.java     |   99 +-
 .../cache/transactions/IgniteTxEntry.java       |   23 +-
 .../cache/transactions/IgniteTxHandler.java     |   33 +-
 .../IgniteTxImplicitSingleStateImpl.java        |   32 +-
 .../cache/transactions/IgniteTxKey.java         |    5 +
 .../transactions/IgniteTxLocalAdapter.java      |  170 +-
 .../cache/transactions/IgniteTxLocalEx.java     |   21 +-
 .../cache/transactions/IgniteTxManager.java     |   95 +-
 .../IgniteTxRemoteSingleStateImpl.java          |    6 +-
 .../IgniteTxRemoteStateAdapter.java             |    7 +-
 .../cache/transactions/IgniteTxState.java       |    5 +-
 .../cache/transactions/IgniteTxStateImpl.java   |   28 +-
 .../cache/transactions/TxEntryValueHolder.java  |    5 +
 .../version/GridCacheRawVersionedEntry.java     |    5 +-
 .../cache/version/GridCacheVersion.java         |   19 +-
 .../cache/version/GridCacheVersionEx.java       |    9 +
 .../cache/version/GridCacheVersionManager.java  |   21 +-
 .../IgniteCacheObjectProcessorImpl.java         |    5 +-
 .../clock/GridClockDeltaSnapshotMessage.java    |    5 +
 .../processors/clock/GridClockDeltaVersion.java |    5 +
 .../processors/clock/GridClockServer.java       |    3 +-
 .../closure/GridClosureProcessor.java           |  413 +-
 .../continuous/GridContinuousHandler.java       |    4 +-
 .../continuous/GridContinuousMessage.java       |    5 +
 .../continuous/GridContinuousProcessor.java     |  103 +-
 .../StartRoutineAckDiscoveryMessage.java        |   22 +-
 .../StartRoutineDiscoveryMessage.java           |   22 +-
 .../datastreamer/DataStreamProcessor.java       |   12 +-
 .../datastreamer/DataStreamerEntry.java         |    5 +
 .../datastreamer/DataStreamerImpl.java          |   58 +-
 .../datastreamer/DataStreamerRequest.java       |    5 +
 .../datastreamer/DataStreamerResponse.java      |    5 +
 .../datastructures/DataStructuresProcessor.java |   10 +-
 .../datastructures/GridCacheAtomicLongImpl.java |    3 +-
 .../GridCacheAtomicReferenceImpl.java           |   70 +-
 .../GridCacheAtomicSequenceImpl.java            |    3 +-
 .../GridCacheAtomicStampedImpl.java             |    3 +-
 .../GridCacheCountDownLatchImpl.java            |    3 +-
 .../datastructures/GridCacheQueueAdapter.java   |   25 +
 .../datastructures/GridCacheQueueProxy.java     |   17 +-
 .../datastructures/GridCacheSemaphoreEx.java    |    5 +
 .../datastructures/GridCacheSemaphoreImpl.java  |  164 +-
 .../datastructures/GridCacheSetImpl.java        |   38 +-
 .../datastructures/GridCacheSetProxy.java       |   17 +-
 .../processors/hadoop/HadoopNoopProcessor.java  |   24 +-
 .../processors/igfs/IgfsAckMessage.java         |    5 +
 .../internal/processors/igfs/IgfsBlockKey.java  |   35 +-
 .../processors/igfs/IgfsBlocksMessage.java      |    5 +
 .../IgfsColocatedMetadataAffinityKeyMapper.java |   47 +
 .../processors/igfs/IgfsDataManager.java        |  132 +-
 .../processors/igfs/IgfsDeleteMessage.java      |    5 +
 .../processors/igfs/IgfsDeleteWorker.java       |   71 +-
 .../processors/igfs/IgfsDirectoryInfo.java      |  284 +
 .../internal/processors/igfs/IgfsEntryInfo.java |  319 +
 .../ignite/internal/processors/igfs/IgfsEx.java |   12 -
 .../processors/igfs/IgfsFileAffinityRange.java  |   37 +-
 .../internal/processors/igfs/IgfsFileImpl.java  |   67 +-
 .../internal/processors/igfs/IgfsFileInfo.java  |  515 +-
 .../internal/processors/igfs/IgfsFileMap.java   |   50 +-
 .../processors/igfs/IgfsFileWorkerBatch.java    |   75 +-
 .../IgfsFileWorkerBatchCancelledException.java  |   51 +
 .../igfs/IgfsFragmentizerManager.java           |  107 +-
 .../igfs/IgfsFragmentizerRequest.java           |    5 +
 .../igfs/IgfsFragmentizerResponse.java          |    5 +
 .../internal/processors/igfs/IgfsImpl.java      |  162 +-
 .../processors/igfs/IgfsInputStreamAdapter.java |    5 +-
 .../processors/igfs/IgfsInputStreamImpl.java    |   34 +-
 .../igfs/IgfsInvalidRangeException.java         |    4 +-
 .../processors/igfs/IgfsIpcHandler.java         |  109 +-
 .../processors/igfs/IgfsListingEntry.java       |  161 +-
 .../processors/igfs/IgfsMetaManager.java        | 2598 ++++----
 .../processors/igfs/IgfsOutputStreamImpl.java   |  116 +-
 .../internal/processors/igfs/IgfsPathIds.java   |  315 +
 .../processors/igfs/IgfsPathsCreateResult.java  |   64 +
 .../internal/processors/igfs/IgfsProcessor.java |   60 +-
 .../IgfsSecondaryInputStreamDescriptor.java     |    6 +-
 .../IgfsSecondaryOutputStreamDescriptor.java    |   20 +-
 .../internal/processors/igfs/IgfsServer.java    |    2 +-
 .../processors/igfs/IgfsSyncMessage.java        |    5 +
 .../internal/processors/igfs/IgfsUtils.java     |  542 +-
 .../meta/IgfsMetaDirectoryCreateProcessor.java  |  172 +
 .../IgfsMetaDirectoryListingAddProcessor.java   |  136 +
 ...IgfsMetaDirectoryListingRemoveProcessor.java |  132 +
 ...gfsMetaDirectoryListingReplaceProcessor.java |  130 +
 .../igfs/meta/IgfsMetaFileCreateProcessor.java  |  172 +
 .../igfs/meta/IgfsMetaFileLockProcessor.java    |  107 +
 .../meta/IgfsMetaFileRangeDeleteProcessor.java  |  111 +
 .../meta/IgfsMetaFileRangeUpdateProcessor.java  |  120 +
 .../meta/IgfsMetaFileReserveSpaceProcessor.java |  120 +
 .../igfs/meta/IgfsMetaFileUnlockProcessor.java  |  103 +
 .../meta/IgfsMetaUpdatePropertiesProcessor.java |  121 +
 .../igfs/meta/IgfsMetaUpdateTimesProcessor.java |  113 +
 .../internal/processors/igfs/package-info.java  |    2 +-
 .../processors/job/GridJobProcessor.java        |   30 +-
 .../internal/processors/job/GridJobWorker.java  |    2 +-
 .../processors/odbc/OdbcBufferedParser.java     |   81 +
 .../processors/odbc/OdbcColumnMeta.java         |  110 +
 .../processors/odbc/OdbcHandshakeRequest.java   |   49 +
 .../processors/odbc/OdbcHandshakeResult.java    |   66 +
 .../processors/odbc/OdbcMessageParser.java      |  277 +
 .../processors/odbc/OdbcNioListener.java        |  171 +
 .../processors/odbc/OdbcNioServerBuffer.java    |  114 +
 .../internal/processors/odbc/OdbcProcessor.java |  116 +
 .../processors/odbc/OdbcQueryCloseRequest.java  |   49 +
 .../processors/odbc/OdbcQueryCloseResult.java   |   40 +
 .../odbc/OdbcQueryExecuteRequest.java           |   78 +
 .../processors/odbc/OdbcQueryExecuteResult.java |   54 +
 .../processors/odbc/OdbcQueryFetchRequest.java  |   61 +
 .../processors/odbc/OdbcQueryFetchResult.java   |   66 +
 .../odbc/OdbcQueryGetColumnsMetaRequest.java    |   74 +
 .../odbc/OdbcQueryGetColumnsMetaResult.java     |   42 +
 .../odbc/OdbcQueryGetTablesMetaRequest.java     |   85 +
 .../odbc/OdbcQueryGetTablesMetaResult.java      |   42 +
 .../internal/processors/odbc/OdbcRequest.java   |   58 +
 .../processors/odbc/OdbcRequestHandler.java     |  362 ++
 .../internal/processors/odbc/OdbcResponse.java  |   96 +
 .../internal/processors/odbc/OdbcTableMeta.java |   85 +
 .../internal/processors/odbc/OdbcUtils.java     |   56 +
 .../offheap/GridOffHeapProcessor.java           |    2 +-
 .../processors/platform/PlatformContext.java    |   16 +
 .../platform/PlatformContextImpl.java           |   86 +-
 .../platform/PlatformNoopProcessor.java         |   14 +-
 .../processors/platform/PlatformProcessor.java  |   20 +
 .../platform/PlatformProcessorImpl.java         |   58 +-
 .../platform/cache/PlatformCache.java           |   56 +-
 .../callback/PlatformCallbackGateway.java       |   30 +
 .../callback/PlatformCallbackUtils.java         |   16 +-
 .../platform/cluster/PlatformClusterGroup.java  |   12 +
 .../platform/compute/PlatformCompute.java       |   26 +-
 .../datastreamer/PlatformDataStreamer.java      |    7 +-
 .../datastructures/PlatformAtomicReference.java |  146 +
 .../datastructures/PlatformAtomicSequence.java  |  122 +
 .../PlatformDotNetConfigurationClosure.java     |    5 -
 .../platform/services/PlatformServices.java     |  249 +-
 .../utils/PlatformConfigurationUtils.java       |  102 +-
 .../platform/utils/PlatformFutureUtils.java     |    2 +-
 .../platform/utils/PlatformUtils.java           |  128 +
 .../processors/plugin/CachePluginManager.java   |   25 +
 .../processors/query/GridQueryProcessor.java    |   13 +-
 .../messages/GridQueryCancelRequest.java        |    5 +
 .../twostep/messages/GridQueryFailResponse.java |    5 +
 .../messages/GridQueryNextPageRequest.java      |    5 +
 .../messages/GridQueryNextPageResponse.java     |    5 +
 .../h2/twostep/messages/GridQueryRequest.java   |    5 +
 .../handlers/cache/GridCacheCommandHandler.java |    2 +-
 .../handlers/log/GridLogCommandHandler.java     |   32 +-
 .../handlers/task/GridTaskCommandHandler.java   |    8 +-
 .../handlers/task/GridTaskResultRequest.java    |    5 +
 .../handlers/task/GridTaskResultResponse.java   |    5 +
 .../rest/protocols/tcp/GridTcpRestProtocol.java |    7 +-
 .../service/GridServiceProcessor.java           |  173 +-
 .../processors/service/GridServiceProxy.java    |  239 +-
 .../processors/task/GridTaskProcessor.java      |    5 +-
 .../processors/task/GridTaskWorker.java         |    9 +-
 .../ignite/internal/util/GridByteArrayList.java |    5 +
 .../internal/util/GridExecutionStatistics.java  |  106 -
 .../ignite/internal/util/GridHandleTable.java   |    7 +-
 .../ignite/internal/util/GridLeanSet.java       |    1 +
 .../ignite/internal/util/GridLongList.java      |    5 +
 .../internal/util/GridMessageCollection.java    |    5 +
 .../ignite/internal/util/IgniteUtils.java       |   97 +-
 .../util/StripedCompositeReadWriteLock.java     |  174 +
 .../internal/util/UUIDCollectionMessage.java    |    5 +
 .../util/future/GridCompoundFuture.java         |    2 +-
 .../internal/util/future/GridFutureAdapter.java |    3 +-
 .../shmem/IpcSharedMemoryServerEndpoint.java    |    6 +-
 .../ignite/internal/util/lang/GridFunc.java     |   92 +-
 .../ignite/internal/util/lang/GridTuple.java    |    2 -
 .../ignite/internal/util/lang/GridTuple3.java   |    2 -
 .../ignite/internal/util/lang/GridTuple4.java   |    2 -
 .../ignite/internal/util/lang/GridTuple5.java   |    2 -
 .../ignite/internal/util/lang/GridTuple6.java   |    2 -
 .../ignite/internal/util/lang/GridTupleV.java   |    1 +
 .../internal/util/nio/GridDirectParser.java     |    4 +-
 .../util/nio/GridNioFinishedFuture.java         |    5 +
 .../ignite/internal/util/nio/GridNioFuture.java |    7 +-
 .../internal/util/nio/GridNioFutureImpl.java    |    5 +
 .../util/nio/GridNioRecoveryDescriptor.java     |   23 +-
 .../ignite/internal/util/nio/GridNioServer.java |  238 +-
 .../util/nio/GridSelectorNioSessionImpl.java    |    2 +-
 .../util/nio/SelectedSelectionKeySet.java       |  132 +
 .../util/offheap/unsafe/GridUnsafeMap.java      |    4 +-
 .../apache/ignite/internal/util/typedef/X.java  |    2 +-
 .../ignite/internal/visor/cache/VisorCache.java |   11 +-
 .../cache/VisorCacheAggregatedMetrics.java      |  113 +-
 .../internal/visor/cache/VisorCacheMetrics.java |   99 +-
 .../cache/VisorCacheMetricsCollectorTask.java   |   21 +-
 .../visor/cache/VisorCacheMetricsV2.java        |   66 +
 .../visor/cache/VisorCacheResetMetricsTask.java |    2 +-
 .../internal/visor/cache/VisorCacheV2.java      |    2 +-
 .../internal/visor/cache/VisorCacheV3.java      |  108 +
 .../visor/igfs/VisorIgfsProfilerTask.java       |   20 +-
 .../visor/node/VisorNodeDataCollectorJob.java   |   31 +-
 .../internal/visor/util/VisorTaskUtils.java     |    4 +-
 .../org/apache/ignite/lang/IgniteBiTuple.java   |    6 +-
 .../ignite/logger/java/JavaLoggerFormatter.java |    4 +-
 .../apache/ignite/marshaller/Marshaller.java    |    6 +-
 .../optimized/OptimizedClassDescriptor.java     |   37 +-
 .../optimized/OptimizedMarshallerUtils.java     |    3 +
 .../optimized/OptimizedObjectInputStream.java   |   15 +-
 .../optimized/OptimizedObjectOutputStream.java  |    4 +-
 .../OptimizedObjectStreamRegistry.java          |  145 +-
 .../ignite/plugin/CachePluginProvider.java      |   11 +
 .../extensions/communication/Message.java       |    5 +
 .../ignite/resources/JobContextResource.java    |    4 +-
 .../org/apache/ignite/spi/IgniteSpiAdapter.java |   15 +
 .../ignite/spi/IgniteSpiConsistencyChecked.java |    8 +
 .../jobstealing/JobStealingCollisionSpi.java    |   14 +-
 .../jobstealing/JobStealingRequest.java         |    5 +
 .../communication/tcp/TcpCommunicationSpi.java  |   57 +-
 .../tcp/TcpCommunicationSpiMBean.java           |    8 +-
 .../ignite/spi/discovery/tcp/ClientImpl.java    |   33 +-
 .../ignite/spi/discovery/tcp/ServerImpl.java    |  249 +-
 .../spi/discovery/tcp/TcpDiscoverySpi.java      |   29 +-
 .../tcp/internal/TcpDiscoveryNode.java          |   41 +-
 .../TcpDiscoveryMulticastIpFinder.java          |    1 +
 .../sharedfs/TcpDiscoverySharedFsIpFinder.java  |   35 +-
 .../TcpDiscoveryCustomEventMessage.java         |   12 +-
 .../apache/ignite/spi/indexing/IndexingSpi.java |    4 +-
 .../spi/swapspace/file/FileSwapSpaceSpi.java    |    2 +
 .../spi/swapspace/noop/NoopSwapSpaceSpi.java    |    2 +
 .../org/apache/ignite/thread/IgniteThread.java  |   34 +-
 .../ignite/thread/IgniteThreadFactory.java      |    7 +-
 .../resources/META-INF/classnames.properties    |  102 +-
 .../config/websession/example-cache-base.xml    |  148 +
 .../config/websession/example-cache-client.xml  |   33 +
 .../test/config/websession/example-cache.xml    |  128 +-
 .../test/config/websession/example-cache2.xml   |   31 +
 .../GridCacheAffinityBackupsSelfTest.java       |    2 +-
 .../affinity/AffinityClientNodeSelfTest.java    |    4 +-
 .../affinity/AffinityHistoryCleanupTest.java    |  414 ++
 .../fair/FairAffinityFunctionNodesSelfTest.java |    2 +
 .../local/LocalAffinityFunctionTest.java        |   80 +
 .../CacheJdbcPojoStoreAbstractSelfTest.java     |   28 +-
 ...eJdbcStoreAbstractMultithreadedSelfTest.java |   25 +-
 .../ignite/cache/store/jdbc/model/Person.java   |   25 +
 .../ignite/igfs/IgfsEventsAbstractSelfTest.java |   24 +-
 .../igfs/IgfsFragmentizerAbstractSelfTest.java  |    4 +-
 .../ComputeJobCancelWithServiceSelfTest.java    |  154 +
 .../internal/GridAffinityNoCacheSelfTest.java   |   13 +-
 .../ignite/internal/GridAffinitySelfTest.java   |    9 +-
 ...omputationBinarylizableClosuresSelfTest.java |  413 ++
 .../GridMultithreadedJobStealingSelfTest.java   |    3 +-
 .../internal/GridNodeMetricsLogSelfTest.java    |   98 +
 .../GridTaskCancelSingleNodeSelfTest.java       |   37 +-
 .../GridTaskFailoverAffinityRunTest.java        |    6 +-
 .../IgniteClientReconnectAbstractTest.java      |   15 +-
 .../IgniteClientReconnectAtomicsTest.java       |    8 +-
 .../IgniteClientReconnectCollectionsTest.java   |    4 +-
 .../IgniteClientReconnectComputeTest.java       |    6 +-
 ...eClientReconnectContinuousProcessorTest.java |   32 +-
 .../IgniteClientReconnectFailoverTest.java      |    2 +
 .../IgniteClientReconnectServicesTest.java      |    4 +-
 .../IgniteClientReconnectStreamerTest.java      |    2 +-
 .../internal/TestRecordingCommunicationSpi.java |   65 +-
 .../internal/binary/BinaryEnumsSelfTest.java    |   51 +-
 .../binary/BinaryMarshallerSelfTest.java        |   50 +
 .../BinaryObjectBuilderAdditionalSelfTest.java  |  231 +-
 ...naryObjectBuilderDefaultMappersSelfTest.java |   32 +-
 .../GridCommunicationSendMessageSelfTest.java   |    5 +
 .../communication/GridIoManagerSelfTest.java    |    5 +
 .../BinaryObjectOffHeapUnswapTemporaryTest.java |  362 ++
 .../cache/CacheAffinityCallSelfTest.java        |   45 +-
 .../cache/CacheConfigurationLeakTest.java       |   62 +
 .../cache/CacheEntryProcessorCopySelfTest.java  |  213 +
 .../cache/CacheEnumOperationsAbstractTest.java  |  339 +
 .../CacheEnumOperationsSingleNodeTest.java      |   28 +
 .../cache/CacheEnumOperationsTest.java          |   28 +
 ...erceptorPartitionCounterLocalSanityTest.java |  687 ++
 ...torPartitionCounterRandomOperationsTest.java | 1054 ++++
 .../CacheMetricsForClusterGroupSelfTest.java    |    2 +-
 .../processors/cache/CacheNamesSelfTest.java    |   16 +-
 .../CacheNamesWithSpecialCharactersTest.java    |   71 +
 ...cheNearUpdateTopologyChangeAbstractTest.java |    2 +
 .../cache/CacheReadThroughRestartSelfTest.java  |    2 +
 .../cache/CacheSwapUnswapGetTest.java           |    4 +-
 .../EntryVersionConsistencyReadThroughTest.java |  265 +
 .../cache/GridCacheAbstractFullApiSelfTest.java |   75 +-
 .../cache/GridCacheAbstractMetricsSelfTest.java |  124 +-
 .../GridCacheAbstractRemoveFailureTest.java     |   10 +-
 .../cache/GridCacheAbstractSelfTest.java        |   19 +
 .../cache/GridCacheDeploymentSelfTest.java      |   80 +-
 .../cache/GridCacheEntryVersionSelfTest.java    |    2 +-
 .../GridCacheOffHeapValuesEvictionSelfTest.java |  210 +
 .../GridCacheOnCopyFlagAbstractSelfTest.java    |  479 +-
 ...ridCacheStoreManagerDeserializationTest.java |  354 ++
 ...ridCacheSwapSpaceSpiConsistencySelfTest.java |  146 +
 ...acheTcpClientDiscoveryMultiThreadedTest.java |    2 +-
 .../processors/cache/GridCacheTestEntryEx.java  |   10 +-
 ...cheTransactionalAbstractMetricsSelfTest.java |    4 +-
 .../GridCacheVersionTopologyChangeTest.java     |  246 +
 ...calCacheStoreManagerDeserializationTest.java |  101 +
 .../cache/IgniteCacheAbstractTest.java          |    6 +
 .../IgniteCacheConfigVariationsFullApiTest.java | 5851 ++++++++++++++++++
 .../IgniteCacheEntryListenerAbstractTest.java   |  535 +-
 ...cheEntryListenerAtomicOffheapTieredTest.java |   32 +
 ...cheEntryListenerAtomicOffheapValuesTest.java |   32 +
 ...niteCacheEntryListenerExpiredEventsTest.java |  202 +
 ...teCacheEntryListenerTxOffheapTieredTest.java |   32 +
 ...teCacheEntryListenerTxOffheapValuesTest.java |   32 +
 .../cache/IgniteCacheEntryListenerTxTest.java   |    4 -
 .../IgniteCacheEntryProcessorNodeJoinTest.java  |  147 +-
 .../cache/IgniteCacheIncrementTxTest.java       |  299 +
 .../IgniteCacheInterceptorSelfTestSuite.java    |    2 +
 .../cache/IgniteCacheNearLockValueSelfTest.java |    2 +-
 .../IgniteCacheP2pUnmarshallingErrorTest.java   |    1 -
 ...CacheP2pUnmarshallingRebalanceErrorTest.java |   36 +-
 .../IgniteCacheP2pUnmarshallingTxErrorTest.java |    2 +
 .../IgniteCachePutStackOverflowSelfTest.java    |  133 +
 ...ReadThroughEvictionOffheapTiredSelfTest.java |   30 +
 .../IgniteCacheReadThroughEvictionSelfTest.java |  359 ++
 .../IgniteClientAffinityAssignmentSelfTest.java |    2 +-
 ...niteDynamicCacheStartStopConcurrentTest.java |    6 +-
 .../IgniteDynamicClientCacheStartSelfTest.java  |   97 +
 .../cache/IgniteTxConfigCacheSelfTest.java      |  249 +
 .../cache/IgniteTxReentryAbstractSelfTest.java  |    2 +-
 .../MarshallerCacheJobRunNodeRestartTest.java   |  307 +
 .../GridCacheBinaryObjectsAbstractSelfTest.java |  221 +-
 .../GridDataStreamerImplSelfTest.java           |   49 +-
 ...eAbstractDataStructuresFailoverSelfTest.java |   56 +-
 .../GridCacheQueueApiSelfAbstractTest.java      |  104 +-
 .../GridCacheSetAbstractSelfTest.java           |  103 +-
 .../CacheGetInsideLockChangingTopologyTest.java |    6 +
 ...eLateAffinityAssignmentFairAffinityTest.java |   32 +
 ...ffinityAssignmentNodeJoinValidationTest.java |  134 +
 .../CacheLateAffinityAssignmentTest.java        | 2688 ++++++++
 .../GridCacheAbstractJobExecutionTest.java      |    6 +-
 .../GridCacheTransformEventSelfTest.java        |    2 +-
 ...niteCacheClientNodeChangingTopologyTest.java |   28 +-
 ...teCacheClientNodePartitionsExchangeTest.java |   85 +-
 .../IgniteCacheClientReconnectTest.java         |    2 +
 .../distributed/IgniteCacheCreatePutTest.java   |  137 +-
 .../distributed/IgniteCacheGetRestartTest.java  |    4 +
 .../distributed/IgniteCacheManyClientsTest.java |    6 +
 .../IgniteCacheNearRestartRollbackSelfTest.java |  290 +
 .../distributed/IgniteCachePrimarySyncTest.java |   45 +-
 .../IgniteCacheReadFromBackupTest.java          |   12 +-
 .../IgniteCacheSingleGetMessageTest.java        |    8 +-
 .../IgniteTxCachePrimarySyncTest.java           | 1114 ++++
 ...teSynchronizationModesMultithreadedTest.java |  422 ++
 .../IgniteTxPreloadAbstractTest.java            |    2 +-
 .../dht/GridCacheColocatedDebugTest.java        |    2 +-
 .../GridCacheDhtPreloadMessageCountTest.java    |    6 +-
 ...ePartitionedNearDisabledMetricsSelfTest.java |    2 +-
 ...idCachePartitionedPreloadEventsSelfTest.java |   11 +
 ...ridCachePartitionedUnloadEventsSelfTest.java |    2 +
 .../dht/GridCacheTxNodeFailureSelfTest.java     |   10 +-
 .../IgniteCachePutRetryAbstractSelfTest.java    |    4 +-
 ...imaryWriteOrderMultiNodeFullApiSelfTest.java |   35 +
 ...AtomicPartitionedTckMetricsSelfTestImpl.java |   92 +-
 .../near/GridCacheNearJobExecutionSelfTest.java |    2 -
 .../near/GridCacheNearMetricsSelfTest.java      |  152 +-
 .../near/GridCacheNearMultiNodeSelfTest.java    |    4 +-
 .../near/GridCacheNearReadersSelfTest.java      |   21 +-
 .../near/GridCacheNearTxForceKeyTest.java       |    6 +-
 ...idCachePartitionedHitsAndMissesSelfTest.java |    2 +-
 ...LateAffDisabledMultiNodeFullApiSelfTest.java |   34 +
 ...achePartitionedMultiNodeCounterSelfTest.java |   43 +-
 ...achePartitionedMultiNodeFullApiSelfTest.java |    2 +
 ...idCacheRendezvousAffinityClientSelfTest.java |    2 +
 ...cingDelayedPartitionMapExchangeSelfTest.java |   14 +-
 .../GridCacheRebalancingSyncSelfTest.java       |  245 +-
 .../GridCacheReplicatedJobExecutionTest.java    |    2 -
 ...idCacheReplicatedPreloadOffHeapSelfTest.java |    3 +-
 .../GridCacheReplicatedPreloadSelfTest.java     |  397 +-
 .../GridCacheEvictableEntryEqualsSelfTest.java  |   85 +
 ...CacheAtomicLocalOffheapExpiryPolicyTest.java |   30 +
 ...gniteCacheAtomicOffheapExpiryPolicyTest.java |   30 +
 ...rimaryWriteOrderOffheapExpiryPolicyTest.java |   31 +
 ...teOrderWithStoreOffheapExpiryPolicyTest.java |   31 +
 ...AtomicReplicatedOffheapExpiryPolicyTest.java |   30 +
 ...eAtomicWithStoreOffheapExpiryPolicyTest.java |   30 +
 .../IgniteCacheExpiryPolicyAbstractTest.java    |  169 +-
 .../IgniteCacheExpiryPolicyTestSuite.java       |   13 +
 ...niteCacheTxLocalOffheapExpiryPolicyTest.java |   30 +
 .../IgniteCacheTxOffheapExpiryPolicyTest.java   |   30 +
 ...acheTxReplicatedOffheapExpiryPolicyTest.java |   30 +
 ...CacheTxWithStoreOffheapExpiryPolicyTest.java |   30 +
 ...CacheLocalOffHeapAndSwapMetricsSelfTest.java |  380 +-
 ...dCacheAtomicLocalTckMetricsSelfTestImpl.java |   92 +-
 .../continuous/CacheContinuousBatchAckTest.java |  355 ++
 ...heContinuousBatchForceServerModeAckTest.java |   80 +
 ...CacheContinuousQueryCounterAbstractTest.java |  612 ++
 ...inuousQueryCounterPartitionedAtomicTest.java |   41 +
 ...ContinuousQueryCounterPartitionedTxTest.java |   41 +
 ...tinuousQueryCounterReplicatedAtomicTest.java |   41 +
 ...eContinuousQueryCounterReplicatedTxTest.java |   41 +
 ...acheContinuousQueryExecuteInPrimaryTest.java |  306 +
 .../CacheContinuousQueryFactoryFilterTest.java  |  714 +++
 ...ContinuousQueryFailoverAbstractSelfTest.java |   61 +-
 ...tomicPrimaryWriteOrderOffheapTieredTest.java |   33 +
 ...tinuousQueryFailoverTxOffheapTieredTest.java |   32 +
 .../CacheContinuousQueryLostPartitionTest.java  |    2 +-
 .../CacheContinuousQueryOperationP2PTest.java   |  326 +
 ...acheContinuousQueryRandomOperationsTest.java | 1799 ++++++
 ...inuousQueryRandomOperationsTwoNodesTest.java |   28 +
 ...ridCacheContinuousQueryAbstractSelfTest.java |   19 +-
 ...eContinuousQueryAtomicOffheapTieredTest.java |   32 +
 ...eContinuousQueryAtomicOffheapValuesTest.java |   32 +
 .../GridCacheContinuousQueryConcurrentTest.java |  466 ++
 ...CacheContinuousQueryTxOffheapTieredTest.java |   32 +
 ...CacheContinuousQueryTxOffheapValuesTest.java |   32 +
 ...IgniteCacheContinuousQueryReconnectTest.java |  192 +
 ...BehindStorePartitionedMultiNodeSelfTest.java |   11 +-
 .../processors/igfs/IgfsAbstractSelfTest.java   |  180 +-
 ...lockMessageSystemPoolStarvationSelfTest.java |  299 +
 .../igfs/IgfsDataManagerSelfTest.java           |   67 +-
 .../igfs/IgfsDualAbstractSelfTest.java          |  104 +-
 .../processors/igfs/IgfsFileInfoSelfTest.java   |   26 +-
 .../igfs/IgfsMetaManagerSelfTest.java           |  105 +-
 .../igfs/IgfsPrimaryMultiNodeSelfTest.java      |   28 +
 .../IgfsPrimaryOptimziedMarshallerSelfTest.java |   28 +
 ...maryRelaxedConsistencyMultiNodeSelfTest.java |   28 +
 .../IgfsPrimaryRelaxedConsistencySelfTest.java  |   28 +
 .../processors/igfs/IgfsProcessorSelfTest.java  |   71 +-
 .../igfs/IgfsProcessorValidationSelfTest.java   |   43 +
 .../processors/igfs/IgfsSizeSelfTest.java       |   40 +-
 .../processors/igfs/IgfsStartCacheTest.java     |    9 +-
 .../processors/igfs/IgfsStreamsSelfTest.java    |   27 +-
 .../handlers/log/GridLogCommandHandlerTest.java |   97 +-
 ...GridServiceProxyClientReconnectSelfTest.java |  124 +
 .../GridServiceProxyNodeStopSelfTest.java       |  105 +
 .../GridServiceSerializationSelfTest.java       |  149 +
 .../processors/service/inner/MyService.java     |   11 +
 .../processors/service/inner/MyServiceImpl.java |   10 +
 .../internal/util/GridHandleTableSelfTest.java  |   50 +
 .../ignite/jvmtest/ConcurrentMapTest.java       |    3 +-
 .../apache/ignite/lang/GridTupleSelfTest.java   |   42 +-
 .../communication/GridTestMessage.java          |    5 +
 .../loadtests/hashmap/GridCacheTestContext.java |    2 +
 ...namicProxySerializationMultiJvmSelfTest.java |  191 +
 .../OptimizedMarshallerPooledSelfTest.java      |   44 +
 .../platform/PlatformAttributeNodeFilter.java   |   31 +
 .../platform/PlatformComputeEchoTask.java       |   11 +-
 .../platform/PlatformDeployServiceTask.java     |  360 ++
 .../ignite/platform/PlatformSqlQueryTask.java   |  117 +
 .../platform/PlatformStartIgniteTask.java       |   77 +
 .../ignite/platform/PlatformStopIgniteTask.java |   74 +
 .../GridSessionCheckpointAbstractSelfTest.java  |    6 +-
 .../spi/communication/GridTestMessage.java      |    5 +
 .../GridTcpCommunicationSpiConfigSelfTest.java  |   22 +
 .../tcp/TcpClientDiscoverySpiSelfTest.java      |   10 +-
 .../spi/discovery/tcp/TcpDiscoverySelfTest.java |  189 +-
 .../tcp/TcpDiscoverySpiConfigSelfTest.java      |   22 +
 .../TcpDiscoverySpiFailureTimeoutSelfTest.java  |   23 +-
 .../spi/discovery/tcp/TestTcpDiscoverySpi.java  |    5 +-
 .../TcpDiscoveryIpFinderAbstractSelfTest.java   |   15 +-
 .../GridSwapSpaceSpiConsistencySelfTest.java    |  131 +
 .../ignite/testframework/GridTestUtils.java     |    5 +-
 .../configvariations/CacheStartMode.java        |   29 +
 .../configvariations/ConfigFactory.java         |   39 +
 .../configvariations/ConfigParameter.java       |   34 +
 .../configvariations/ConfigVariations.java      |  346 ++
 .../ConfigVariationsFactory.java                |  197 +
 .../ConfigVariationsTestSuiteBuilder.java       |  382 ++
 .../IgniteConfigVariationsTestSuite.java        |   50 +
 .../configvariations/Parameters.java            |  377 ++
 .../configvariations/VariationsIterator.java    |  174 +
 .../configvariations/VariationsTestsConfig.java |  161 +
 .../testframework/junits/GridAbstractTest.java  |   52 +-
 .../junits/GridTestKernalContext.java           |   34 +-
 ...IgniteCacheConfigVariationsAbstractTest.java |  583 ++
 .../IgniteConfigVariationsAbstractTest.java     |  420 ++
 .../junits/common/GridCommonAbstractTest.java   |  171 +-
 .../multijvm/IgniteCacheProcessProxy.java       |    8 +
 .../junits/multijvm/IgniteNodeRunner.java       |   16 +-
 .../junits/multijvm/IgniteProcessProxy.java     |   19 +-
 .../ConfigVariationsTestSuiteBuilderTest.java   |  112 +
 .../testframework/test/ParametersTest.java      |   87 +
 .../test/VariationsIteratorTest.java            |  156 +
 .../ignite/testsuites/IgniteBasicTestSuite.java |   13 +
 .../testsuites/IgniteBinaryBasicTestSuite.java  |    6 +
 .../testsuites/IgniteBinaryCacheTestSuite.java  |    2 +
 ...IgniteBinaryObjectsComputeGridTestSuite.java |    7 +-
 .../IgniteBinaryObjectsTestSuite.java           |    8 +-
 ...heBasicConfigVariationsFullApiTestSuite.java |   41 +
 .../IgniteCacheDataStructuresSelfTestSuite.java |   10 +-
 .../IgniteCacheEvictionSelfTestSuite.java       |    4 +-
 .../IgniteCacheFullApiSelfTestSuite.java        |    6 +
 .../testsuites/IgniteCacheRestartTestSuite.java |    2 +
 .../ignite/testsuites/IgniteCacheTestSuite.java |   21 +
 .../testsuites/IgniteCacheTestSuite2.java       |   10 +
 .../testsuites/IgniteCacheTestSuite3.java       |    2 +
 .../testsuites/IgniteCacheTestSuite4.java       |   20 +-
 .../testsuites/IgniteCacheTestSuite5.java       |   15 +-
 .../ignite/testsuites/IgniteIgfsTestSuite.java  |   21 +-
 .../testsuites/IgniteKernalSelfTestSuite.java   |   11 +-
 .../IgniteMarshallerSelfTestSuite.java          |    8 +-
 .../IgniteSpiSwapSpaceSelfTestSuite.java        |    2 +
 .../p2p/CacheDeploymentAffinityKeyMapper.java   |   35 +
 .../CacheDeploymentAlwaysTruePredicate2.java    |   30 +
 ...oymentCacheEntryEventSerializableFilter.java |   32 +
 .../p2p/CacheDeploymentCacheEntryListener.java  |   31 +
 ...CacheDeploymentCachePluginConfiguration.java |   81 +
 .../p2p/CacheDeploymentEntryEventFilter.java    |   33 +
 .../CacheDeploymentEntryEventFilterFactory.java |   31 +
 .../CacheDeploymentExternalizableTestValue.java |   69 +
 ...heDeploymentStoreSessionListenerFactory.java |   83 +
 modules/flink/README.txt                        |   33 +
 modules/flink/licenses/apache-2.0.txt           |  202 +
 modules/flink/pom.xml                           |  167 +
 .../apache/ignite/sink/flink/IgniteSink.java    |  204 +
 .../apache/ignite/sink/flink/package-info.java  |   22 +
 .../sink/flink/FlinkIgniteSinkSelfTest.java     |  188 +
 .../flink/FlinkIgniteSinkSelfTestSuite.java     |   38 +
 .../flink/src/test/resources/example-ignite.xml |   70 +
 .../hadoop/fs/BasicHadoopFileSystemFactory.java |   22 +-
 .../fs/CachingHadoopFileSystemFactory.java      |    2 +-
 .../fs/IgniteHadoopIgfsSecondaryFileSystem.java |   45 +-
 .../fs/KerberosHadoopFileSystemFactory.java     |  217 +
 .../hadoop/fs/v1/IgniteHadoopFileSystem.java    |   19 +-
 .../hadoop/fs/v2/IgniteHadoopFileSystem.java    |   21 +-
 .../processors/hadoop/HadoopContext.java        |    3 +-
 .../hadoop/igfs/HadoopIgfsProperties.java       |   11 +-
 .../hadoop/igfs/HadoopIgfsWrapper.java          |   11 +-
 .../hadoop/jobtracker/HadoopJobTracker.java     |   13 +-
 .../child/HadoopChildProcessRunner.java         |    2 +-
 .../hadoop/cache/HadoopTxConfigCacheTest.java   |   42 +
 ...KerberosHadoopFileSystemFactorySelfTest.java |  121 +
 .../ignite/igfs/Hadoop1DualAbstractTest.java    |    5 +-
 ...oopFileSystemUniversalFileSystemAdapter.java |    8 +-
 .../HadoopIgfs20FileSystemAbstractSelfTest.java |    2 +
 .../igfs/HadoopIgfsDualAbstractSelfTest.java    |   11 +-
 .../apache/ignite/igfs/IgfsEventsTestSuite.java |   16 +-
 .../IgniteHadoopFileSystemAbstractSelfTest.java |    2 +
 ...IgniteHadoopFileSystemHandshakeSelfTest.java |  121 +-
 .../IgniteHadoopFileSystemLoggerSelfTest.java   |   21 +-
 .../hadoop/HadoopAbstractMapReduceTest.java     |  405 ++
 .../processors/hadoop/HadoopErrorSimulator.java |  326 +
 .../HadoopMapReduceErrorResilienceTest.java     |  154 +
 .../processors/hadoop/HadoopMapReduceTest.java  |  379 +-
 .../hadoop/HadoopNoHadoopMapReduceTest.java     |   47 +
 .../hadoop/HadoopSnappyFullMapReduceTest.java   |    8 +
 .../hadoop/examples/HadoopWordCount1Map.java    |   12 +
 .../hadoop/examples/HadoopWordCount1Reduce.java |    5 +
 .../hadoop/examples/HadoopWordCount2.java       |    2 +-
 .../examples/HadoopWordCount2Combiner.java      |   45 +
 .../hadoop/examples/HadoopWordCount2Mapper.java |   19 +-
 .../examples/HadoopWordCount2Reducer.java       |   43 +-
 .../testsuites/IgniteHadoopTestSuite.java       |   46 +-
 .../HibernateL2CacheTransactionalSelfTest.java  |    9 +
 ...nateL2CacheTransactionalUseSyncSelfTest.java |   31 +
 .../testsuites/IgniteHibernateTestSuite.java    |    4 +-
 .../processors/query/h2/IgniteH2Indexing.java   |   65 +-
 .../query/h2/opt/GridH2ValueCacheObject.java    |    9 +
 .../query/h2/sql/GridSqlAggregateFunction.java  |   12 +-
 .../query/h2/sql/GridSqlQueryParser.java        |   30 +-
 .../query/h2/sql/GridSqlQuerySplitter.java      |    6 +-
 .../processors/query/h2/sql/GridSqlSelect.java  |    2 +-
 .../query/h2/twostep/GridMapQueryExecutor.java  |    2 +-
 .../query/h2/twostep/GridMergeIndex.java        |   32 +-
 .../h2/twostep/GridMergeIndexUnsorted.java      |   19 +-
 .../query/h2/twostep/GridMergeTable.java        |   16 +-
 .../h2/twostep/GridReduceQueryExecutor.java     |    6 +-
 .../h2/twostep/msg/GridH2ValueMessage.java      |    5 +
 .../cache/AtomicBinaryOffheapBatchTest.java     |  384 ++
 .../cache/CacheQueryBuildValueTest.java         |  144 +
 .../cache/CacheQueryNewClientSelfTest.java      |  115 +
 .../CacheQueryOffheapEvictDataLostTest.java     |  138 +
 .../CacheRandomOperationsMultithreadedTest.java |  507 ++
 .../IgniteBinaryObjectQueryArgumentsTest.java   |  161 +
 .../cache/IgniteCacheAbstractQuerySelfTest.java |  197 +-
 .../cache/IgniteClientReconnectQueriesTest.java |   13 +-
 .../near/IgniteCacheQueryNodeFailTest.java      |  148 +
 .../IgniteCacheQueryNodeRestartSelfTest2.java   |    3 +
 .../h2/GridIndexingSpiAbstractSelfTest.java     |   43 +-
 .../IgniteBinaryCacheQueryTestSuite.java        |    1 -
 .../IgniteBinaryCacheQueryTestSuite2.java       |   39 +
 .../IgniteBinaryCacheQueryTestSuite3.java       |   39 +
 .../IgniteBinaryCacheQueryTestSuite4.java       |   39 +
 .../IgniteCacheQuerySelfTestSuite.java          |  117 +-
 .../IgniteCacheQuerySelfTestSuite2.java         |  109 +
 .../IgniteCacheQuerySelfTestSuite3.java         |   99 +
 .../IgniteCacheQuerySelfTestSuite4.java         |   49 +
 .../IgniteCacheWithIndexingTestSuite.java       |    2 +
 .../processors/cache/jta/CacheJtaManager.java   |   26 +-
 .../processors/cache/jta/CacheJtaResource.java  |  304 +
 .../cache/jta/GridCacheXAResource.java          |  251 -
 .../cache/AbstarctCacheJtaSelfTest.java         |  183 -
 .../cache/AbstractCacheJtaSelfTest.java         |  183 +
 .../GridPartitionedCacheJtaFactorySelfTest.java |    2 +-
 ...rtitionedCacheJtaFactoryUseSyncSelfTest.java |   32 +
 ...titionedCacheJtaLookupClassNameSelfTest.java |    2 +-
 ...eplicatedCacheJtaFactoryUseSyncSelfTest.java |   32 +
 .../ignite/testsuites/IgniteJtaTestSuite.java   |    5 +
 modules/kafka/README.txt                        |   85 +-
 .../kafka/connect/IgniteSourceConnector.java    |   81 +
 .../kafka/connect/IgniteSourceConstants.java    |   44 +
 .../stream/kafka/connect/IgniteSourceTask.java  |  335 +
 .../serialization/CacheEventConverter.java      |   66 +
 .../serialization/CacheEventDeserializer.java   |   54 +
 .../serialization/CacheEventSerializer.java     |   54 +
 .../kafka/IgniteKafkaStreamerSelfTestSuite.java |    4 +-
 .../kafka/KafkaIgniteStreamerSelfTest.java      |   11 +-
 .../ignite/stream/kafka/TestKafkaBroker.java    |   27 +-
 .../kafka/connect/IgniteSinkConnectorTest.java  |   13 +-
 .../connect/IgniteSourceConnectorMock.java      |   31 +
 .../connect/IgniteSourceConnectorTest.java      |  327 +
 .../kafka/connect/IgniteSourceTaskMock.java     |   31 +
 .../kafka/connect/TestCacheEventFilter.java     |   31 +
 .../kafka/src/test/resources/example-ignite.xml |    4 +-
 .../osgi-karaf/src/main/resources/features.xml  |   12 +-
 .../cpp/common/include/ignite/common/exports.h  |   21 +-
 .../cpp/common/include/ignite/common/java.h     |   53 +-
 .../os/linux/include/ignite/common/common.h     |   20 +-
 .../os/win/include/ignite/common/common.h       |    8 +-
 .../platforms/cpp/common/project/vs/module.def  |   15 +-
 modules/platforms/cpp/common/src/exports.cpp    |   58 +-
 modules/platforms/cpp/common/src/java.cpp       |  285 +-
 modules/platforms/cpp/core-test/Makefile.am     |    2 +
 .../cpp/core-test/project/vs/core-test.vcxproj  |    2 +
 .../project/vs/core-test.vcxproj.filters        |    6 +
 .../cpp/core-test/src/cache_query_test.cpp      |   45 +
 .../platforms/cpp/core-test/src/cache_test.cpp  |   12 +
 .../cpp/core-test/src/ignite_error_test.cpp     |   45 +
 .../cpp/core-test/src/interop_memory_test.cpp   |   95 +
 .../ignite/cache/query/query_fields_row.h       |    2 +-
 .../cpp/core/include/ignite/ignite_error.h      |   18 +-
 .../include/ignite/impl/ignite_environment.h    |   19 +-
 modules/platforms/cpp/core/src/ignite_error.cpp |   32 +-
 .../impl/binary/binary_type_updater_impl.cpp    |    2 +
 .../cpp/core/src/impl/cache/cache_impl.cpp      |    2 +-
 .../cpp/core/src/impl/ignite_environment.cpp    |   30 +-
 .../Apache.Ignite.Benchmarks.csproj             |   36 +-
 .../Apache.Ignite.Core.Tests.NuGet.csproj       |  134 +
 .../Apache.Ignite.Core.Tests.NuGet.sln          |   32 +
 ...ache.Ignite.Core.Tests.NuGet.sln.DotSettings |    4 +
 .../Apache.Ignite.Core.Tests.NuGet/CacheTest.cs |  134 +
 .../ComputeTest.cs                              |   84 +
 .../Config/ignite-config.xml                    |   50 +
 .../Apache.Ignite.Core.Tests.NuGet/NuGet.config |   35 +
 .../Properties/AssemblyInfo.cs                  |   35 +
 .../StartupTest.cs                              |   66 +
 .../TestRunner.cs                               |   70 +
 .../Apache.Ignite.Core.Tests.NuGet/TestUtil.cs  |   43 +
 .../install-package.ps1                         |   25 +
 .../packages.config                             |   24 +
 .../Apache.Ignite.Core.Tests.TestDll.csproj     |   32 +-
 .../Apache.Ignite.Core.Tests.csproj             |  135 +-
 .../Binary/BinaryBuilderSelfTest.cs             |   87 +-
 .../Binary/BinaryBuilderSelfTestFullFooter.cs   |   31 +
 .../Binary/BinaryCompactFooterInteropTest.cs    |  129 +
 .../Binary/BinarySelfTest.cs                    |  278 +-
 .../Binary/BinarySelfTestFullFooter.cs          |   35 +
 .../Binary/BinaryStructureTest.cs               |   38 +-
 .../Cache/CacheAffinityFieldTest.cs             |  199 +
 .../Cache/CacheConfigurationTest.cs             |   18 +-
 .../Cache/CacheTestAsyncWrapper.cs              |   12 +
 .../Cache/Query/CacheLinqTest.cs                | 1272 ++++
 .../Query/CacheQueriesCodeConfigurationTest.cs  |   20 +-
 .../Cache/Query/CacheQueriesTest.cs             |   13 +-
 .../Continuous/ContinuousQueryAbstractTest.cs   |   25 +-
 .../Cache/Store/CacheStoreTest.cs               |   36 +-
 .../Cache/Store/CacheStoreTestCodeConfig.cs     |  106 +
 .../Cache/Store/CacheTestStore.cs               |    2 +-
 .../Compute/ComputeApiTest.cs                   |   62 +-
 .../Compute/ComputeApiTestFullFooter.cs         |   65 +
 .../Compute/MixedClusterTest.cs                 |  183 +
 .../Config/Apache.Ignite.exe.config.test2       |   58 +
 .../Config/Apache.Ignite.exe.config.test3       |   34 +
 .../Config/Cache/Store/cache-store-session.xml  |    3 +-
 .../Config/Compute/compute-grid1.xml            |   24 +-
 .../Config/Compute/compute-grid2.xml            |   20 +-
 .../Config/Compute/compute-grid3.xml            |    7 +-
 .../Config/Compute/compute-standalone.xml       |    4 +-
 .../Config/Dynamic/dynamic-client.xml           |    3 +-
 .../Config/Dynamic/dynamic-data-no-cfg.xml      |    3 +-
 .../Config/Dynamic/dynamic-data.xml             |    3 +-
 .../Config/Lifecycle/lifecycle-beans.xml        |    3 +-
 .../Config/Lifecycle/lifecycle-no-beans.xml     |    3 +-
 .../Apache.Ignite.Core.Tests/Config/binary.xml  |   56 -
 .../Config/cache-binarizables.xml               |    3 +-
 .../Config/cache-local-node.xml                 |   66 +
 .../Config/cache-query-continuous.xml           |    3 +-
 .../Config/cache-query.xml                      |    5 +-
 .../Config/ignite-dotnet-cfg.xml                |   52 +
 .../Config/marshaller-default.xml               |    3 +-
 .../Config/marshaller-explicit.xml              |    3 +-
 .../Config/marshaller-invalid.xml               |    3 +-
 .../native-client-test-cache-affinity.xml       |    3 +-
 .../native-client-test-cache-parallel-store.xml |    3 +-
 .../Config/native-client-test-cache-store.xml   |    3 +-
 .../Config/native-client-test-cache.xml         |    3 +-
 .../Config/reconnect-test.xml                   |   43 +
 .../Config/start-test-grid1.xml                 |    3 +-
 .../Config/start-test-grid2.xml                 |    3 +-
 .../Config/start-test-grid3.xml                 |    3 +-
 .../DataStructures/AtomicReferenceTest.cs       |  239 +
 .../DataStructures/AtomicSequenceTest.cs        |  131 +
 .../Dataload/DataStreamerTestTopologyChange.cs  |  104 +
 .../Apache.Ignite.Core.Tests/DeploymentTest.cs  |  180 +
 .../Examples/ExamplesTest.cs                    |    3 +-
 .../Examples/ProjectFilesTest.cs                |    2 +-
 .../Apache.Ignite.Core.Tests/ExceptionsTest.cs  |    5 +
 .../Apache.Ignite.Core.Tests/ExecutableTest.cs  |   89 +-
 .../Apache.Ignite.Core.Tests/FutureTest.cs      |    1 +
 .../IgniteConfigurationSectionTest.cs           |   69 +
 .../IgniteConfigurationSerializerTest.cs        |  594 ++
 .../IgniteConfigurationTest.cs                  |   55 +-
 .../IgniteStartStopTest.cs                      |   58 +-
 .../Apache.Ignite.Core.Tests/JavaHomeTest.cs    |   69 +
 .../Process/IgniteProcess.cs                    |   31 +-
 .../ProcessExtensions.cs                        |   78 +
 .../ProjectFilesTest.cs                         |   88 +
 .../Apache.Ignite.Core.Tests/ReconnectTest.cs   |   97 +
 .../Services/ServiceProxyTest.cs                |    6 +-
 .../Services/ServicesTest.cs                    |  273 +-
 .../Services/ServicesTestFullFooter.cs          |   33 +
 .../Apache.Ignite.Core.Tests/TestRunner.cs      |    2 +-
 .../Apache.Ignite.Core.Tests/TestUtils.cs       |   34 +-
 .../dotnet/Apache.Ignite.Core.Tests/app.config  |   54 +
 .../Apache.Ignite.Core.csproj                   |   68 +-
 .../Apache.Ignite.Core.nuspec                   |   75 +
 .../Binary/BinaryConfiguration.cs               |   44 +-
 .../Binary/BinaryReflectiveSerializer.cs        |  241 +
 .../Binary/IBinarySerializer.cs                 |    6 +-
 .../Cache/Affinity/AffinityKey.cs               |  162 +
 .../Affinity/AffinityKeyMappedAttribute.cs      |   46 +
 .../Cache/CachePartialUpdateException.cs        |    1 -
 .../Cache/Configuration/CacheConfiguration.cs   |   36 +
 .../Cache/Configuration/QueryEntity.cs          |   17 +-
 .../Cache/Configuration/QueryField.cs           |    2 +-
 .../dotnet/Apache.Ignite.Core/Cache/ICache.cs   |   26 +
 .../Cache/Store/CacheStoreAdapter.cs            |    1 -
 .../Apache.Ignite.Core/Cluster/ICluster.cs      |   14 +
 .../Common/ClientDisconnectedException.cs       |   97 +
 .../Compute/ComputeTaskAdapter.cs               |    1 -
 .../Compute/ComputeTaskSplitAdapter.cs          |    1 -
 .../Configuration/AtomicConfiguration.cs        |   58 +
 .../DataStructures/IAtomicReference.cs          |   64 +
 .../DataStructures/IAtomicSequence.cs           |   69 +
 .../Multicast/TcpDiscoveryMulticastIpFinder.cs  |    6 +-
 .../Tcp/Static/TcpDiscoveryStaticIpFinder.cs    |    6 +-
 .../Apache.Ignite.Core/Events/EventBase.cs      |    1 -
 .../dotnet/Apache.Ignite.Core/IIgnite.cs        |   28 +
 .../Apache.Ignite.Core/IgniteConfiguration.cs   |  139 +-
 .../IgniteConfigurationSection.cs               |   80 +
 .../IgniteConfigurationSection.xsd              |  316 +
 .../dotnet/Apache.Ignite.Core/Ignition.cs       |   97 +-
 .../Apache.Ignite.Core/Impl/Binary/Binary.cs    |    8 +-
 .../Impl/Binary/BinaryHandleDictionary.cs       |   32 +-
 .../Impl/Binary/BinaryObject.cs                 |    9 +-
 .../Impl/Binary/BinaryObjectBuilder.cs          |    9 +-
 .../Impl/Binary/BinaryObjectHeader.cs           |  176 +-
 .../Impl/Binary/BinaryObjectSchema.cs           |   20 +
 .../Impl/Binary/BinaryObjectSchemaHolder.cs     |   18 +-
 .../Impl/Binary/BinaryObjectSchemaSerializer.cs |  262 +
 .../Impl/Binary/BinaryReader.cs                 |  109 +-
 .../Impl/Binary/BinaryReaderHandleDictionary.cs |    2 +-
 .../Impl/Binary/BinaryReflectiveActions.cs      |  611 +-
 .../Impl/Binary/BinaryReflectiveSerializer.cs   |  218 -
 .../Impl/Binary/BinarySystemHandlers.cs         |  147 +-
 .../Impl/Binary/BinaryUtils.cs                  |  180 +-
 .../Impl/Binary/BinaryWriter.cs                 |   72 +-
 .../Apache.Ignite.Core/Impl/Binary/JavaTypes.cs |   29 +-
 .../Impl/Binary/Marshaller.cs                   |   45 +-
 .../Impl/Binary/Metadata/BinaryType.cs          |   28 +-
 .../Impl/Binary/ReferenceEqualityComparer.cs    |   45 +
 .../Apache.Ignite.Core/Impl/Cache/CacheEntry.cs |    2 +-
 .../Apache.Ignite.Core/Impl/Cache/CacheImpl.cs  |   56 +-
 .../Apache.Ignite.Core/Impl/Cache/CacheOp.cs    |    3 +-
 .../Impl/Cache/ICacheInternal.cs                |   40 +
 .../Impl/Cache/Query/FieldsQueryCursor.cs       |   26 +-
 .../Impl/Cluster/ClusterGroupImpl.cs            |   15 +
 .../Impl/Cluster/ClusterNodeImpl.cs             |    2 +-
 .../Impl/Common/BooleanLowerCaseConverter.cs    |   60 +
 .../Apache.Ignite.Core/Impl/Common/Classpath.cs |   18 +-
 .../Impl/Common/DelegateConverter.cs            |  131 +-
 .../Apache.Ignite.Core/Impl/Common/Future.cs    |   14 +-
 .../Impl/Common/FutureType.cs                   |   18 +-
 .../Common/IgniteConfigurationXmlSerializer.cs  |  472 ++
 .../Impl/Common/IgniteHome.cs                   |    9 +-
 .../Apache.Ignite.Core/Impl/Common/Logger.cs    |   37 +
 .../Impl/Common/ObjectStringConverter.cs        |  104 +
 .../Apache.Ignite.Core/Impl/Common/Platform.cs  |   35 +
 .../Impl/Common/TypeCaster.cs                   |   12 +
 .../Impl/Common/TypeStringConverter.cs          |  115 +
 .../Closure/ComputeAbstractClosureTask.cs       |    1 -
 .../Impl/Compute/ComputeTaskHolder.cs           |    2 +-
 .../Impl/DataStructures/AtomicReference.cs      |   92 +
 .../Impl/DataStructures/AtomicSequence.cs       |   90 +
 .../Impl/Datastream/DataStreamerImpl.cs         |    9 +-
 .../Impl/Events/EventTypeConverter.cs           |  133 +
 .../Apache.Ignite.Core/Impl/ExceptionUtils.cs   |  110 +-
 .../Apache.Ignite.Core/Impl/Handle/Handle.cs    |    8 +-
 .../dotnet/Apache.Ignite.Core/Impl/Ignite.cs    |  101 +-
 .../Apache.Ignite.Core/Impl/IgniteManager.cs    |   19 +-
 .../Apache.Ignite.Core/Impl/IgniteProxy.cs      |   19 +
 .../Apache.Ignite.Core/Impl/IgniteUtils.cs      |   43 +-
 .../Impl/Memory/PlatformMemoryStream.cs         |  320 +-
 .../Apache.Ignite.Core/Impl/PlatformTarget.cs   |   47 +-
 .../Impl/Services/ServiceDescriptor.cs          |    7 +-
 .../Impl/Services/ServiceProxyInvoker.cs        |   29 +-
 .../Impl/Services/ServiceProxySerializer.cs     |   63 +-
 .../Impl/Services/Services.cs                   |   13 +-
 .../Impl/Unmanaged/IgniteJniNativeMethods.cs    |   37 +
 .../Impl/Unmanaged/UnmanagedCallbackHandlers.cs |    3 +
 .../Impl/Unmanaged/UnmanagedCallbacks.cs        |   32 +-
 .../Impl/Unmanaged/UnmanagedUtils.cs            |   85 +-
 .../dotnet/Apache.Ignite.Core/NuGet/Install.ps1 |   27 +
 .../NuGet/LINQPad/ComputeExample.linq           |  106 +
 .../NuGet/LINQPad/PutGetExample.linq            |   69 +
 .../NuGet/LINQPad/QueryExample.linq             |   96 +
 .../Apache.Ignite.Core/NuGet/PostBuild.ps1      |   20 +
 .../Apache.Ignite.Core/NuGet/Uninstall.ps1      |   21 +
 .../Transactions/ITransaction.cs                |    3 +-
 .../Transactions/TransactionConfiguration.cs    |   76 +
 .../dotnet/Apache.Ignite.Core/build-common.ps1  |   64 +
 .../powershell.exe.activation_config            |   29 +
 modules/platforms/dotnet/Apache.Ignite.FxCop    |    4 +-
 .../Apache.Ignite.Linq.csproj                   |   93 +
 .../Apache.Ignite.Linq.nuspec                   |   63 +
 .../Apache.Ignite.Linq/Apache.Ignite.Linq.snk   |  Bin 0 -> 596 bytes
 .../Apache.Ignite.Linq/CacheExtensions.cs       |   98 +
 .../dotnet/Apache.Ignite.Linq/CompiledQuery.cs  |  208 +
 .../Apache.Ignite.Linq/ICacheQueryable.cs       |   53 +
 .../Apache.Ignite.Linq/Impl/AliasDictionary.cs  |  102 +
 .../Impl/CacheFieldsQueryExecutor.cs            |  223 +
 .../Impl/CacheFieldsQueryProvider.cs            |  239 +
 .../Impl/CacheFieldsQueryable.cs                |   40 +
 .../Impl/CacheQueryExpressionVisitor.cs         |  506 ++
 .../Impl/CacheQueryModelVisitor.cs              |  509 ++
 .../Apache.Ignite.Linq/Impl/CacheQueryParser.cs |   56 +
 .../Apache.Ignite.Linq/Impl/CacheQueryable.cs   |   43 +
 .../Impl/CacheQueryableBase.cs                  |  122 +
 .../Apache.Ignite.Linq/Impl/ExpressionWalker.cs |  172 +
 .../Apache.Ignite.Linq/Impl/ICacheQueryProxy.cs |   40 +
 .../Impl/ICacheQueryableInternal.cs             |   54 +
 .../Apache.Ignite.Linq/Impl/MethodVisitor.cs    |  250 +
 .../dotnet/Apache.Ignite.Linq/Impl/QueryData.cs |   92 +
 .../dotnet/Apache.Ignite.Linq/Impl/SqlTypes.cs  |   63 +
 .../NuGet/LINQPad/QueryExample.linq             |  111 +
 .../Properties/AssemblyInfo.cs                  |   40 +
 .../dotnet/Apache.Ignite.Linq/packages.config   |   22 +
 modules/platforms/dotnet/Apache.Ignite.sln      |  163 +-
 .../dotnet/Apache.Ignite/Apache.Ignite.csproj   |   35 +-
 .../Config/AppSettingsConfigurator.cs           |   97 +-
 .../Apache.Ignite/Config/ArgsConfigurator.cs    |  145 +-
 .../dotnet/Apache.Ignite/Config/Configurator.cs |  168 +
 .../Apache.Ignite/Config/IConfigurator.cs       |   34 -
 .../dotnet/Apache.Ignite/IgniteRunner.cs        |   24 +-
 .../Apache.Ignite/Service/IgniteService.cs      |   21 +-
 modules/platforms/dotnet/DEVNOTES.txt           |    7 +-
 modules/platforms/dotnet/build.bat              |   94 -
 .../dotnet/examples/Apache.Ignite.Examples.sln  |   24 +-
 .../Apache.Ignite.Examples.csproj               |   49 +-
 .../Compute/ClosureExample.cs                   |   10 +-
 .../Compute/TaskExample.cs                      |   13 +-
 .../Datagrid/ContinuousQueryExample.cs          |   15 +-
 .../Datagrid/DataStreamerExample.cs             |   16 +-
 .../Datagrid/LinqExample.cs                     |  247 +
 .../Datagrid/PutGetExample.cs                   |   15 +-
 .../Datagrid/QueryExample.cs                    |   29 +-
 .../Datagrid/StoreExample.cs                    |   25 +-
 .../Datagrid/TransactionExample.cs              |   24 +-
 .../Events/EventsExample.cs                     |   14 +-
 .../Messaging/MessagingExample.cs               |   11 +-
 .../Misc/LifecycleExample.cs                    |    3 +-
 .../Services/ServicesExample.cs                 |   11 +-
 .../Apache.Ignite.ExamplesDll.csproj            |   43 +-
 .../Apache.Ignite.ExamplesDll/Binary/Account.cs |    1 -
 .../Apache.Ignite.ExamplesDll/Binary/Address.cs |    5 +-
 .../Binary/Employee.cs                          |    4 +
 .../Binary/EmployeeKey.cs                       |    6 +-
 .../Binary/Organization.cs                      |   11 +-
 .../Binary/OrganizationType.cs                  |    3 -
 .../Datagrid/EmployeeStoreFactory.cs            |   38 +
 .../examples/Config/example-cache-query.xml     |  118 -
 .../examples/Config/example-cache-store.xml     |   59 -
 .../dotnet/examples/Config/example-cache.xml    |   87 -
 .../dotnet/examples/Config/example-compute.xml  |   70 -
 .../dotnet/examples/Config/examples-config.xml  |   98 +
 .../http/jetty/GridJettyRestProtocol.java       |    4 +-
 .../ignite/schema/generator/CodeGenerator.java  |   84 +-
 .../ignite/schema/generator/GeneratorUtils.java |   70 +
 .../ignite/schema/generator/XmlGenerator.java   |   62 +-
 .../ignite/schema/ui/SchemaImportApp.java       |  205 +-
 .../schema/test/model/ignite-type-metadata.xml  |   44 +-
 .../org/apache/ignite/spark/IgniteContext.scala |   68 +-
 .../apache/ignite/spark/JavaIgniteContext.scala |   14 +-
 .../spark/JavaEmbeddedIgniteRDDSelfTest.java    |  343 +
 .../ignite/spark/JavaIgniteRDDSelfTest.java     |  302 -
 .../spark/JavaStandaloneIgniteRDDSelfTest.java  |  302 +
 .../ignite/testsuites/IgniteRDDTestSuite.java   |   40 +
 .../ignite/internal/GridFactorySelfTest.java    |   87 +-
 .../commands/cache/VisorCacheCommand.scala      |   42 +-
 .../commands/tasks/VisorTasksCommand.scala      |    4 +-
 .../scala/org/apache/ignite/visor/visor.scala   |    4 +
 modules/web/ignite-weblogic-test/pom.xml        |   76 +
 .../webapp/META-INF/config/default-config.xml   |   37 +
 .../src/main/webapp/WEB-INF/web.xml             |   52 +
 .../src/main/webapp/index.jsp                   |   36 +
 .../ignite/cache/websession/WebSession.java     |   91 +-
 .../cache/websession/WebSessionFilter.java      |  265 +-
 .../cache/websession/WebSessionListener.java    |   66 +-
 .../IgniteWebSessionSelfTestSuite.java          |   10 +
 .../internal/websession/WebSessionSelfTest.java |  418 +-
 modules/yardstick/.gitignore                    |    2 +
 .../config/benchmark-cache-load-win.properties  |   56 +
 .../config/benchmark-cache-load.properties      |   86 +
 .../config/ignite-base-load-config.xml          |  256 +
 .../config/ignite-cache-load-config.xml         |   70 +
 .../yardstick/IgniteBenchmarkArguments.java     |   25 +-
 .../org/apache/ignite/yardstick/IgniteNode.java |    2 +
 .../cache/IgniteCacheAbstractBenchmark.java     |   54 +
 .../yardstick/cache/IgniteInvokeBenchmark.java  |   65 +
 .../cache/IgniteInvokeTxBenchmark.java          |   30 +
 .../IgniteCacheRandomOperationBenchmark.java    |  941 +++
 .../yardstick/cache/load/model/ModelUtil.java   |  147 +
 .../cache/load/model/key/Identifier.java        |  107 +
 .../yardstick/cache/load/model/key/Mark.java    |  108 +
 .../yardstick/cache/load/model/value/Car.java   |  120 +
 .../yardstick/cache/load/model/value/Color.java |   50 +
 .../yardstick/cache/load/model/value/Truck.java |   63 +
 .../apache/ignite/yarn/ApplicationMaster.java   |   30 +-
 .../apache/ignite/yarn/IgniteYarnClient.java    |   25 +
 .../ignite/yarn/utils/IgniteYarnUtils.java      |   19 +
 modules/zookeeper/pom.xml                       |   50 +-
 .../tcp/ipfinder/zk/ZookeeperIpFinderTest.java  |   26 +-
 parent/pom.xml                                  |  103 +-
 pom.xml                                         |    3 +
 1163 files changed, 86167 insertions(+), 15524 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/ignite/blob/1643a7cc/modules/aws/pom.xml
----------------------------------------------------------------------

http://git-wip-us.apache.org/repos/asf/ignite/blob/1643a7cc/modules/core/src/main/java/org/apache/ignite/IgniteSystemProperties.java
----------------------------------------------------------------------
diff --cc modules/core/src/main/java/org/apache/ignite/IgniteSystemProperties.java
index c8dcc19,858cb71..93fc275
--- a/modules/core/src/main/java/org/apache/ignite/IgniteSystemProperties.java
+++ b/modules/core/src/main/java/org/apache/ignite/IgniteSystemProperties.java
@@@ -367,9 -367,9 +367,12 @@@ public final class IgniteSystemProperti
      /** JDBC driver cursor remove delay. */
      public static final String IGNITE_JDBC_DRIVER_CURSOR_REMOVE_DELAY = "IGNITE_JDBC_DRIVER_CURSOR_RMV_DELAY";
  
 +    /** Long-long offheap map load factor. */
 +    public static final String IGNITE_LONG_LONG_HASH_MAP_LOAD_FACTOR = "IGNITE_LONG_LONG_HASH_MAP_LOAD_FACTOR";
 +
+     /** Maximum number of nested listener calls before listener notification becomes asynchronous. */
+     public static final String IGNITE_MAX_NESTED_LISTENER_CALLS = "IGNITE_MAX_NESTED_LISTENER_CALLS";
+ 
      /**
       * Manages {@link OptimizedMarshaller} behavior of {@code serialVersionUID} computation for
       * {@link Serializable} classes.

http://git-wip-us.apache.org/repos/asf/ignite/blob/1643a7cc/modules/core/src/main/java/org/apache/ignite/configuration/IgniteConfiguration.java
----------------------------------------------------------------------
diff --cc modules/core/src/main/java/org/apache/ignite/configuration/IgniteConfiguration.java
index 2452894,e5bd05c..64cbc06
--- a/modules/core/src/main/java/org/apache/ignite/configuration/IgniteConfiguration.java
+++ b/modules/core/src/main/java/org/apache/ignite/configuration/IgniteConfiguration.java
@@@ -438,9 -446,9 +446,12 @@@ public class IgniteConfiguration 
      /** */
      private BinaryConfiguration binaryCfg;
  
+     /** */
+     private boolean lateAffAssignment = DFLT_LATE_AFF_ASSIGNMENT;
+ 
 +    /** Database configuration. */
 +    private DatabaseConfiguration dbCfg;
 +
      /**
       * Creates valid grid configuration with all default values.
       */

http://git-wip-us.apache.org/repos/asf/ignite/blob/1643a7cc/modules/core/src/main/java/org/apache/ignite/internal/GridKernalContext.java
----------------------------------------------------------------------

http://git-wip-us.apache.org/repos/asf/ignite/blob/1643a7cc/modules/core/src/main/java/org/apache/ignite/internal/GridKernalContextImpl.java
----------------------------------------------------------------------

http://git-wip-us.apache.org/repos/asf/ignite/blob/1643a7cc/modules/core/src/main/java/org/apache/ignite/internal/IgniteKernal.java
----------------------------------------------------------------------

http://git-wip-us.apache.org/repos/asf/ignite/blob/1643a7cc/modules/core/src/main/java/org/apache/ignite/internal/IgnitionEx.java
----------------------------------------------------------------------

http://git-wip-us.apache.org/repos/asf/ignite/blob/1643a7cc/modules/core/src/main/java/org/apache/ignite/internal/binary/BinaryContext.java
----------------------------------------------------------------------

http://git-wip-us.apache.org/repos/asf/ignite/blob/1643a7cc/modules/core/src/main/java/org/apache/ignite/internal/binary/BinaryEnumObjectImpl.java
----------------------------------------------------------------------
diff --cc modules/core/src/main/java/org/apache/ignite/internal/binary/BinaryEnumObjectImpl.java
index d6e8006,e58edd2..0f46967
--- a/modules/core/src/main/java/org/apache/ignite/internal/binary/BinaryEnumObjectImpl.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/binary/BinaryEnumObjectImpl.java
@@@ -206,18 -241,8 +241,18 @@@ public class BinaryEnumObjectImpl imple
      }
  
      /** {@inheritDoc} */
 +    @Override public boolean putValue(ByteBuffer buf, CacheObjectContext ctx) throws IgniteCheckedException {
 +        throw new UnsupportedOperationException("TODO implement.");
 +    }
 +
 +    /** {@inheritDoc} */
 +    @Override public int valueBytesLength(CacheObjectContext ctx) throws IgniteCheckedException {
 +        throw new UnsupportedOperationException("TODO implement.");
 +    }
 +
 +    /** {@inheritDoc} */
      @Override public byte cacheObjectType() {
-         return TYPE_BINARY;
+         return TYPE_BINARY_ENUM;
      }
  
      /** {@inheritDoc} */

http://git-wip-us.apache.org/repos/asf/ignite/blob/1643a7cc/modules/core/src/main/java/org/apache/ignite/internal/binary/BinaryObjectImpl.java
----------------------------------------------------------------------
diff --cc modules/core/src/main/java/org/apache/ignite/internal/binary/BinaryObjectImpl.java
index 1afbeb9,0997d6f..f5c5589
--- a/modules/core/src/main/java/org/apache/ignite/internal/binary/BinaryObjectImpl.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/binary/BinaryObjectImpl.java
@@@ -404,125 -401,9 +420,125 @@@ public final class BinaryObjectImpl ext
      }
  
      /** {@inheritDoc} */
 +    @SuppressWarnings("IfMayBeConditional")
 +    @Override public boolean writeFieldByOrder(int order, ByteBuffer buf) {
 +        // Calculate field position.
 +        int schemaOffset = BinaryPrimitives.readInt(arr, start + GridBinaryMarshaller.SCHEMA_OR_RAW_OFF_POS);
 +
 +        short flags = BinaryPrimitives.readShort(arr, start + GridBinaryMarshaller.FLAGS_POS);
 +
 +        int fieldIdLen = BinaryUtils.isCompactFooter(flags) ? 0 : BinaryUtils.FIELD_ID_LEN;
 +        int fieldOffsetLen = BinaryUtils.fieldOffsetLength(flags);
 +
 +        int fieldOffsetPos = start + schemaOffset + order * (fieldIdLen + fieldOffsetLen) + fieldIdLen;
 +
 +        int fieldPos;
 +
 +        if (fieldOffsetLen == BinaryUtils.OFFSET_1)
 +            fieldPos = start + ((int)BinaryPrimitives.readByte(arr, fieldOffsetPos) & 0xFF);
 +        else if (fieldOffsetLen == BinaryUtils.OFFSET_2)
 +            fieldPos = start + ((int)BinaryPrimitives.readShort(arr, fieldOffsetPos) & 0xFFFF);
 +        else
 +            fieldPos = start + BinaryPrimitives.readInt(arr, fieldOffsetPos);
 +
 +        // Read header and try performing fast lookup for well-known types (the most common types go first).
 +        byte hdr = BinaryPrimitives.readByte(arr, fieldPos);
 +
 +        int totalLen;
 +
 +        switch (hdr) {
 +            case GridBinaryMarshaller.NULL:
 +                totalLen = 1;
 +
 +                break;
 +
 +            case GridBinaryMarshaller.INT:
 +            case GridBinaryMarshaller.FLOAT:
 +                totalLen = 5;
 +
 +                break;
 +
 +            case GridBinaryMarshaller.LONG:
 +            case GridBinaryMarshaller.DOUBLE:
 +            case GridBinaryMarshaller.DATE:
 +                totalLen = 9;
 +
 +                break;
 +
 +            case GridBinaryMarshaller.BOOLEAN:
 +                totalLen = 2;
 +
 +                break;
 +
 +            case GridBinaryMarshaller.SHORT:
 +                totalLen = 3;
 +
 +                break;
 +
 +            case GridBinaryMarshaller.BYTE:
 +                totalLen = 2;
 +
 +                break;
 +
 +            case GridBinaryMarshaller.CHAR:
 +                totalLen = 3;
 +
 +                break;
 +
 +            case GridBinaryMarshaller.STRING: {
 +                int dataLen = BinaryPrimitives.readInt(arr, fieldPos + 1);
 +
 +                totalLen = dataLen + 5;
 +
 +                break;
 +            }
 +
 +            case GridBinaryMarshaller.TIMESTAMP:
 +                totalLen = 13;
 +
 +                break;
 +
 +            case GridBinaryMarshaller.UUID:
 +                totalLen = 17;
 +
 +                break;
 +
 +            case GridBinaryMarshaller.DECIMAL: {
 +                int dataLen = BinaryPrimitives.readInt(arr, fieldPos + 5);
 +
 +                totalLen = dataLen + 9;
 +
 +                break;
 +            }
 +
 +            case GridBinaryMarshaller.OBJ:
 +                totalLen = BinaryPrimitives.readInt(arr, fieldPos + GridBinaryMarshaller.TOTAL_LEN_POS);
 +
 +                break;
 +
 +            case GridBinaryMarshaller.OPTM_MARSH:
 +                totalLen = BinaryPrimitives.readInt(arr, fieldPos + 1);
 +
 +                break;
 +
 +            default:
 +                throw new UnsupportedOperationException("Failed to write field of the given type " +
 +                    "(field type is not supported): " + hdr);
 +
 +        }
 +
 +        if (buf.remaining() < totalLen)
 +            return false;
 +
 +        buf.put(arr, fieldPos, totalLen);
 +
 +        return true;
 +    }
 +
 +    /** {@inheritDoc} */
      @SuppressWarnings("unchecked")
      @Nullable @Override protected <F> F field(BinaryReaderHandles rCtx, String fieldName) {
-         return (F)reader(rCtx).unmarshalField(fieldName);
+         return (F)reader(rCtx, false).unmarshalField(fieldName);
      }
  
      /** {@inheritDoc} */

http://git-wip-us.apache.org/repos/asf/ignite/blob/1643a7cc/modules/core/src/main/java/org/apache/ignite/internal/binary/BinaryObjectOffheapImpl.java
----------------------------------------------------------------------
diff --cc modules/core/src/main/java/org/apache/ignite/internal/binary/BinaryObjectOffheapImpl.java
index aed936b,c687192..b942456
--- a/modules/core/src/main/java/org/apache/ignite/internal/binary/BinaryObjectOffheapImpl.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/binary/BinaryObjectOffheapImpl.java
@@@ -309,14 -309,9 +319,14 @@@ public class BinaryObjectOffheapImpl ex
      }
  
      /** {@inheritDoc} */
 +    @Override protected boolean writeFieldByOrder(int fieldOffset, ByteBuffer buf) {
 +        return false;
 +    }
 +
 +    /** {@inheritDoc} */
      @SuppressWarnings("unchecked")
      @Nullable @Override protected <F> F field(BinaryReaderHandles rCtx, String fieldName) {
-         return (F)reader(rCtx).unmarshalField(fieldName);
+         return (F)reader(rCtx, false).unmarshalField(fieldName);
      }
  
      /** {@inheritDoc} */

http://git-wip-us.apache.org/repos/asf/ignite/blob/1643a7cc/modules/core/src/main/java/org/apache/ignite/internal/direct/stream/v2/DirectByteBufferStreamImplV2.java
----------------------------------------------------------------------

http://git-wip-us.apache.org/repos/asf/ignite/blob/1643a7cc/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheEntryPredicateAdapter.java
----------------------------------------------------------------------
diff --cc modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheEntryPredicateAdapter.java
index 2768813,3d56ee3..57b6adf
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheEntryPredicateAdapter.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheEntryPredicateAdapter.java
@@@ -87,6 -90,16 +90,11 @@@ public abstract class CacheEntryPredica
       * @return Value.
       */
      @Nullable protected CacheObject peekVisibleValue(GridCacheEntryEx entry) {
 -        try {
 -            return locked ? entry.rawGetOrUnmarshal(true) : entry.peekVisibleValue();
 -        }
 -        catch (IgniteCheckedException e) {
 -            throw new IgniteException(e);
 -        }
 +        return locked ? entry.rawGet() : entry.peekVisibleValue();
      }
+ 
+     /** {@inheritDoc} */
+     @Override public void onAckReceived() {
+         // No-op.
+     }
  }

http://git-wip-us.apache.org/repos/asf/ignite/blob/1643a7cc/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheEvictableEntryImpl.java
----------------------------------------------------------------------

http://git-wip-us.apache.org/repos/asf/ignite/blob/1643a7cc/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheObject.java
----------------------------------------------------------------------

http://git-wip-us.apache.org/repos/asf/ignite/blob/1643a7cc/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheObjectByteArrayImpl.java
----------------------------------------------------------------------

http://git-wip-us.apache.org/repos/asf/ignite/blob/1643a7cc/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheAdapter.java
----------------------------------------------------------------------
diff --cc modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheAdapter.java
index 4eb1f9b,d807e26..9b13609
--- 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
@@@ -4486,10 -4518,10 +4394,10 @@@ public abstract class GridCacheAdapter<
          try {
              KeyCacheObject cacheKey = ctx.toCacheKeyObject(key);
  
 -            GridCacheEntryEx entry = ctx.isSwapOrOffheapEnabled() ? entryEx(cacheKey) : peekEx(cacheKey);
 +            GridCacheEntryEx entry = entryEx(cacheKey);
  
              if (entry != null)
-                 return entry.clear(obsoleteVer, readers, null);
+                 return entry.clear(obsoleteVer, readers);
          }
          catch (GridDhtInvalidPartitionException ignored) {
              // No-op.

http://git-wip-us.apache.org/repos/asf/ignite/blob/1643a7cc/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheClearAllRunnable.java
----------------------------------------------------------------------

http://git-wip-us.apache.org/repos/asf/ignite/blob/1643a7cc/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheContext.java
----------------------------------------------------------------------

http://git-wip-us.apache.org/repos/asf/ignite/blob/1643a7cc/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheDeploymentManager.java
----------------------------------------------------------------------


Mime
View raw message