You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by vo...@apache.org on 2016/03/09 07:48:42 UTC

[09/18] ignite git commit: Merge remote-tracking branch 'upstream/master'

Merge remote-tracking branch 'upstream/master'


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

Branch: refs/heads/ignite-2753
Commit: 92d856183d8e72df87d628a88baeeb7c3d56624e
Parents: 3523de2 bcaa0a8
Author: dkarachentsev <dk...@gridgain.com>
Authored: Fri Feb 19 15:40:06 2016 +0300
Committer: dkarachentsev <dk...@gridgain.com>
Committed: Fri Feb 19 15:40:06 2016 +0300

----------------------------------------------------------------------
 .../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/GridTaskCancelRequest.java  |   5 +
 .../ignite/internal/GridTaskSessionRequest.java |   5 +
 .../ignite/internal/MarshallerContextImpl.java  |   3 +-
 .../ignite/internal/binary/BinaryContext.java   |   1 +
 .../internal/binary/BinaryEnumObjectImpl.java   |   5 +
 .../internal/binary/BinaryObjectImpl.java       |   5 +
 .../binary/BinaryObjectOffheapImpl.java         |   5 +
 .../ignite/internal/binary/BinaryUtils.java     |   5 +-
 .../checkpoint/GridCheckpointRequest.java       |   5 +
 .../managers/communication/GridIoMessage.java   |   5 +
 .../communication/GridIoUserMessage.java        |   5 +
 .../deployment/GridDeploymentInfoBean.java      |   5 +
 .../deployment/GridDeploymentRequest.java       |   5 +
 .../deployment/GridDeploymentResponse.java      |   5 +
 .../eventstorage/GridEventStorageMessage.java   |   5 +
 .../affinity/AffinityTopologyVersion.java       |   5 +
 .../cache/CacheEntryInfoCollection.java         |   5 +
 .../cache/CacheEntryPredicateAdapter.java       |   5 +
 .../cache/CacheEntryPredicateContainsValue.java |   8 +-
 .../cache/CacheEntrySerializablePredicate.java  |   5 +
 .../processors/cache/CacheEvictionEntry.java    |   5 +
 .../cache/CacheInvokeDirectResult.java          |   5 +
 .../cache/CacheObjectByteArrayImpl.java         |   5 +
 .../processors/cache/CacheObjectImpl.java       |   5 +
 .../cache/GridCacheDeploymentManager.java       |   8 +-
 .../processors/cache/GridCacheEntryEx.java      |   2 +-
 .../processors/cache/GridCacheEntryInfo.java    |   5 +
 .../cache/GridCacheEvictionManager.java         |   6 +-
 .../processors/cache/GridCacheMapEntry.java     | 105 ++---
 .../processors/cache/GridCacheMessage.java      |   5 +
 .../processors/cache/GridCacheProcessor.java    |   4 +-
 .../processors/cache/GridCacheReturn.java       |   5 +
 .../processors/cache/GridCacheTtlManager.java   |  75 +++-
 .../processors/cache/KeyCacheObjectImpl.java    |   5 +
 .../binary/CacheObjectBinaryProcessorImpl.java  |  13 +-
 .../CacheDataStructuresManager.java             |   4 +-
 .../distributed/dht/GridDhtCacheAdapter.java    |  29 +-
 .../distributed/dht/GridDhtCacheEntry.java      |   2 +-
 .../dht/atomic/GridDhtAtomicCache.java          |   5 +-
 .../dht/atomic/GridDhtAtomicUpdateRequest.java  |  14 +-
 .../dht/atomic/GridNearAtomicUpdateRequest.java |  16 +
 .../dht/preloader/GridDhtPartitionDemander.java |   3 +-
 .../preloader/GridDhtPartitionExchangeId.java   |   5 +
 .../distributed/near/CacheVersionedValue.java   |   5 +
 .../distributed/near/GridNearCacheEntry.java    |   4 +-
 .../cache/query/GridCacheQueryManager.java      | 424 +++++++++++++------
 .../cache/query/GridCacheSqlQuery.java          |   5 +
 .../continuous/CacheContinuousQueryEntry.java   |   5 +
 .../continuous/CacheContinuousQueryHandler.java |  21 +-
 .../continuous/CacheContinuousQueryManager.java |  18 +-
 .../cache/transactions/IgniteTxEntry.java       |   5 +
 .../cache/transactions/IgniteTxKey.java         |   5 +
 .../transactions/IgniteTxLocalAdapter.java      |   4 +-
 .../cache/transactions/TxEntryValueHolder.java  |   5 +
 .../cache/version/GridCacheVersion.java         |   5 +
 .../clock/GridClockDeltaSnapshotMessage.java    |   5 +
 .../processors/clock/GridClockDeltaVersion.java |   5 +
 .../continuous/GridContinuousMessage.java       |   5 +
 .../datastreamer/DataStreamerEntry.java         |   5 +
 .../datastreamer/DataStreamerImpl.java          |   6 +-
 .../datastreamer/DataStreamerRequest.java       |   5 +
 .../datastreamer/DataStreamerResponse.java      |   5 +
 .../datastructures/DataStructuresProcessor.java |   1 +
 .../processors/igfs/IgfsAckMessage.java         |   5 +
 .../internal/processors/igfs/IgfsBlockKey.java  |   5 +
 .../processors/igfs/IgfsBlocksMessage.java      |   5 +
 .../processors/igfs/IgfsDeleteMessage.java      |   5 +
 .../processors/igfs/IgfsFileAffinityRange.java  |   5 +
 .../igfs/IgfsFragmentizerRequest.java           |   5 +
 .../igfs/IgfsFragmentizerResponse.java          |   5 +
 .../processors/igfs/IgfsSyncMessage.java        |   5 +
 .../platform/PlatformProcessorImpl.java         |  17 +-
 .../callback/PlatformCallbackGateway.java       |  30 ++
 .../callback/PlatformCallbackUtils.java         |  15 +
 .../messages/GridQueryCancelRequest.java        |   5 +
 .../twostep/messages/GridQueryFailResponse.java |   5 +
 .../messages/GridQueryNextPageRequest.java      |   5 +
 .../messages/GridQueryNextPageResponse.java     |   5 +
 .../h2/twostep/messages/GridQueryRequest.java   |   5 +
 .../handlers/task/GridTaskResultRequest.java    |   5 +
 .../handlers/task/GridTaskResultResponse.java   |   5 +
 .../service/GridServiceProcessor.java           | 101 ++++-
 .../processors/service/GridServiceProxy.java    |  22 +-
 .../ignite/internal/util/GridByteArrayList.java |   5 +
 .../ignite/internal/util/GridLongList.java      |   5 +
 .../internal/util/GridMessageCollection.java    |   5 +
 .../internal/util/UUIDCollectionMessage.java    |   5 +
 .../util/nio/GridNioFinishedFuture.java         |   5 +
 .../ignite/internal/util/nio/GridNioFuture.java |   7 +-
 .../internal/util/nio/GridNioFutureImpl.java    |   5 +
 .../util/nio/GridNioRecoveryDescriptor.java     |   2 +
 .../ignite/internal/util/nio/GridNioServer.java |   7 +
 .../extensions/communication/Message.java       |   5 +
 .../jobstealing/JobStealingRequest.java         |   5 +
 .../communication/tcp/TcpCommunicationSpi.java  |  15 +
 .../internal/GridAffinityNoCacheSelfTest.java   |   5 +
 .../GridCommunicationSendMessageSelfTest.java   |   5 +
 .../communication/GridIoManagerSelfTest.java    |   5 +
 .../cache/CacheEnumOperationsAbstractTest.java  | 307 ++++++++++++++
 .../CacheEnumOperationsSingleNodeTest.java      |  28 ++
 .../cache/CacheEnumOperationsTest.java          |  28 ++
 .../cache/GridCacheDeploymentSelfTest.java      |  78 +++-
 .../GridDataStreamerImplSelfTest.java           |  49 ++-
 ...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 ++
 ...CacheContinuousQueryCounterAbstractTest.java |  11 +-
 .../GridServiceSerializationSelfTest.java       | 149 +++++++
 .../communication/GridTestMessage.java          |   5 +
 .../spi/communication/GridTestMessage.java      |   5 +
 .../testsuites/IgniteBinaryCacheTestSuite.java  |   2 +
 .../testsuites/IgniteCacheTestSuite2.java       |   4 +
 .../testsuites/IgniteKernalSelfTestSuite.java   |   2 +
 .../hadoop/jobtracker/HadoopJobTracker.java     |   5 +-
 .../processors/query/h2/IgniteH2Indexing.java   |  95 +++--
 .../query/h2/sql/GridSqlAggregateFunction.java  |  12 +-
 .../query/h2/sql/GridSqlQueryParser.java        |  30 +-
 .../h2/twostep/msg/GridH2ValueMessage.java      |   5 +
 .../cache/IgniteClientReconnectQueriesTest.java |   9 +-
 .../h2/GridIndexingSpiAbstractSelfTest.java     |  43 +-
 .../cpp/common/include/ignite/common/exports.h  |   6 +-
 .../cpp/common/include/ignite/common/java.h     |  21 +-
 modules/platforms/cpp/common/src/exports.cpp    |   6 +-
 modules/platforms/cpp/common/src/java.cpp       |  28 +-
 .../cpp/core-test/src/cache_query_test.cpp      |  45 ++
 .../ignite/cache/query/query_fields_row.h       |   2 +-
 .../Apache.Ignite.Core.Tests.csproj             |   2 +
 .../Process/IgniteProcess.cs                    |  16 +
 .../ProcessExtensions.cs                        |  78 ++++
 .../Apache.Ignite.Core.Tests/ReconnectTest.cs   |  96 +++++
 .../Apache.Ignite.Core.csproj                   |   1 +
 .../Apache.Ignite.Core/Cluster/ICluster.cs      |  14 +
 .../Common/ClientDisconnectedException.cs       |  97 +++++
 .../Impl/Binary/BinaryUtils.cs                  |   2 +-
 .../Apache.Ignite.Core/Impl/Cache/CacheImpl.cs  |   2 +-
 .../Impl/Compute/ComputeTaskHolder.cs           |   2 +-
 .../Apache.Ignite.Core/Impl/ExceptionUtils.cs   | 110 +++--
 .../dotnet/Apache.Ignite.Core/Impl/Ignite.cs    |  32 +-
 .../Apache.Ignite.Core/Impl/IgniteProxy.cs      |   7 +
 .../Impl/Unmanaged/UnmanagedCallbackHandlers.cs |   3 +
 .../Impl/Unmanaged/UnmanagedCallbacks.cs        |  32 +-
 pom.xml                                         |   2 +-
 156 files changed, 2833 insertions(+), 464 deletions(-)
----------------------------------------------------------------------