Return-Path: X-Original-To: archive-asf-public-internal@cust-asf2.ponee.io Delivered-To: archive-asf-public-internal@cust-asf2.ponee.io Received: from cust-asf.ponee.io (cust-asf.ponee.io [163.172.22.183]) by cust-asf2.ponee.io (Postfix) with ESMTP id 151D3200BE9 for ; Mon, 26 Dec 2016 12:16:25 +0100 (CET) Received: by cust-asf.ponee.io (Postfix) id 13BC0160B3B; Mon, 26 Dec 2016 11:16:25 +0000 (UTC) Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by cust-asf.ponee.io (Postfix) with SMTP id 30779160B3E for ; Mon, 26 Dec 2016 12:16:24 +0100 (CET) Received: (qmail 24386 invoked by uid 500); 26 Dec 2016 11:16:18 -0000 Mailing-List: contact commits-help@ignite.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@ignite.apache.org Delivered-To: mailing list commits@ignite.apache.org Received: (qmail 23460 invoked by uid 99); 26 Dec 2016 11:16:17 -0000 Received: from git1-us-west.apache.org (HELO git1-us-west.apache.org) (140.211.11.23) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 26 Dec 2016 11:16:17 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id D409EF175F; Mon, 26 Dec 2016 11:16:17 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: vozerov@apache.org To: commits@ignite.apache.org Date: Mon, 26 Dec 2016 11:16:47 -0000 Message-Id: <54a70472ae6041a2bb63154d3e19cc05@git.apache.org> In-Reply-To: References: X-Mailer: ASF-Git Admin Mailer Subject: [31/50] [abbrv] ignite git commit: Merge remote-tracking branch 'origin/master' archived-at: Mon, 26 Dec 2016 11:16:25 -0000 Merge remote-tracking branch 'origin/master' Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/e2ac6667 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/e2ac6667 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/e2ac6667 Branch: refs/heads/ignite-2.0 Commit: e2ac66678fa28c6744c4806bda87ffc6800018ec Parents: 2591c16 848bb66 Author: Valentin Kulichenko Authored: Thu Dec 22 13:06:01 2016 -0800 Committer: Valentin Kulichenko Committed: Thu Dec 22 13:06:01 2016 -0800 ---------------------------------------------------------------------- .gitignore | 1 + bin/ignite.sh | 9 + examples/pom-standalone.xml | 6 + modules/cassandra/pom.xml | 24 +- .../store/cassandra/CassandraCacheStore.java | 6 + .../store/cassandra/datasource/DataSource.java | 9 + .../java/org/apache/ignite/IgniteServices.java | 16 + .../ignite/cache/store/CacheStoreAdapter.java | 6 + .../cache/store/jdbc/CacheJdbcPojoStore.java | 19 +- .../store/jdbc/JdbcTypesDefaultTransformer.java | 112 +-- .../org/apache/ignite/internal/GridTopic.java | 8 +- .../ignite/internal/IgniteServicesImpl.java | 9 +- .../internal/binary/BinaryClassDescriptor.java | 12 +- .../ignite/internal/binary/BinaryUtils.java | 10 +- .../binary/builder/BinaryObjectBuilderImpl.java | 11 +- .../affinity/GridAffinityProcessor.java | 2 +- .../cache/CacheStoreBalancingWrapper.java | 6 + .../processors/cache/GridCacheAdapter.java | 734 +++++++------------ .../cache/GridCacheLoaderWriterStore.java | 6 + .../GridCachePartitionExchangeManager.java | 60 +- .../processors/cache/GridCacheProcessor.java | 2 +- .../processors/cache/GridCacheUtils.java | 10 +- .../processors/cache/IgniteCacheProxy.java | 8 - .../CacheDataStructuresManager.java | 6 +- .../distributed/GridCacheTxRecoveryFuture.java | 4 +- .../GridDistributedTxFinishResponse.java | 6 - .../GridDistributedTxRemoteAdapter.java | 2 +- .../cache/distributed/dht/GridDhtGetFuture.java | 2 +- .../distributed/dht/GridDhtLockFuture.java | 4 +- .../distributed/dht/GridDhtTxFinishFuture.java | 74 +- .../cache/distributed/dht/GridDhtTxLocal.java | 125 ++-- .../distributed/dht/GridDhtTxLocalAdapter.java | 7 +- .../distributed/dht/GridDhtTxPrepareFuture.java | 4 +- .../dht/atomic/GridDhtAtomicCache.java | 472 +++++++----- .../dht/colocated/GridDhtColocatedCache.java | 13 - .../colocated/GridDhtColocatedLockFuture.java | 4 +- .../GridDhtPartitionsExchangeFuture.java | 6 +- .../distributed/near/GridNearAtomicCache.java | 65 +- .../distributed/near/GridNearLockFuture.java | 4 +- ...arOptimisticSerializableTxPrepareFuture.java | 4 +- .../near/GridNearOptimisticTxPrepareFuture.java | 15 +- .../GridNearPessimisticTxPrepareFuture.java | 4 +- .../near/GridNearTxFinishFuture.java | 46 +- .../cache/distributed/near/GridNearTxLocal.java | 48 +- .../local/atomic/GridLocalAtomicCache.java | 177 +---- .../cache/query/GridCacheQueryManager.java | 4 +- .../cache/store/CacheStoreManager.java | 4 +- .../store/GridCacheStoreManagerAdapter.java | 34 +- .../cache/store/GridCacheWriteBehindStore.java | 6 +- .../cache/transactions/IgniteTxHandler.java | 13 +- .../transactions/IgniteTxLocalAdapter.java | 30 +- .../cache/transactions/IgniteTxManager.java | 7 +- .../closure/GridClosureProcessor.java | 31 +- .../GridCacheAtomicSequenceImpl.java | 12 +- .../processors/hadoop/HadoopClassLoader.java | 1 + .../processors/hadoop/HadoopJobProperty.java | 10 +- .../processors/hadoop/HadoopTaskContext.java | 8 + .../io/PartiallyOffheapRawComparatorEx.java | 33 + .../internal/processors/job/GridJobWorker.java | 76 +- .../processors/odbc/OdbcRequestHandler.java | 14 +- .../platform/PlatformContextImpl.java | 2 +- .../dotnet/PlatformDotNetCacheStore.java | 11 + .../platform/services/PlatformServices.java | 2 +- .../platform/utils/PlatformUtils.java | 28 + .../service/GridServiceProcessor.java | 11 +- .../processors/service/GridServiceProxy.java | 18 +- .../processors/task/GridTaskWorker.java | 7 + .../util/future/GridCompoundFuture.java | 56 +- .../communication/tcp/TcpCommunicationSpi.java | 4 +- .../ignite/spi/discovery/tcp/ServerImpl.java | 2 +- .../spi/discovery/tcp/TcpDiscoverySpi.java | 14 +- .../jdbc/JdbcTypesDefaultTransformerTest.java | 283 +++++++ .../IgniteComputeTopologyExceptionTest.java | 5 +- .../binary/BinaryMarshallerSelfTest.java | 66 ++ .../GridCacheMissingCommitVersionSelfTest.java | 6 +- .../IgniteTxStoreExceptionAbstractSelfTest.java | 1 + ...heapCacheMetricsForClusterGroupSelfTest.java | 141 ++++ ...achePartitionedAtomicSequenceTxSelfTest.java | 169 +++++ .../CacheLockReleaseNodeLeaveTest.java | 135 ++++ ...nabledMultiNodeLongTxTimeoutFullApiTest.java | 2 +- ...achePartitionedMultiNodeFullApiSelfTest.java | 37 +- .../CacheOffHeapAndSwapMetricsSelfTest.java | 621 ---------------- ...LocalCacheOffHeapAndSwapMetricsSelfTest.java | 621 ++++++++++++++++ .../closure/GridClosureSerializationTest.java | 177 +++++ ...lockMessageSystemPoolStarvationSelfTest.java | 14 +- ...gniteServiceProxyTimeoutInitializedTest.java | 284 +++++++ .../ignite/testsuites/IgniteBasicTestSuite.java | 2 + .../IgniteCacheDataStructuresSelfTestSuite.java | 2 + .../IgniteCacheMetricsSelfTestSuite.java | 6 +- .../ignite/testsuites/IgniteCacheTestSuite.java | 2 + .../testsuites/IgniteKernalSelfTestSuite.java | 2 + .../hadoop/io/PartiallyRawComparator.java | 33 + .../org/apache/ignite/hadoop/io/RawMemory.java | 86 +++ .../hadoop/io/TextPartiallyRawComparator.java | 115 +++ .../apache/ignite/hadoop/io/package-info.java | 22 + ...DelegatingPartiallyOffheapRawComparator.java | 54 ++ .../hadoop/impl/v2/HadoopV2TaskContext.java | 21 + .../processors/hadoop/io/OffheapRawMemory.java | 131 ++++ .../hadoop/shuffle/HadoopShuffleJob.java | 2 +- .../shuffle/collections/HadoopMultimapBase.java | 5 +- .../shuffle/collections/HadoopSkipList.java | 14 +- .../hadoop/impl/HadoopTeraSortTest.java | 7 + .../collections/HadoopAbstractMapTest.java | 6 + .../processors/query/h2/IgniteH2Indexing.java | 75 +- .../cache/IgniteCacheLargeResultSelfTest.java | 15 +- ...niteCachePartitionedFieldsQuerySelfTest.java | 25 + .../IgniteCacheQuerySelfTestSuite.java | 130 +++- .../IgniteCacheQuerySelfTestSuite2.java | 111 +-- .../IgniteH2IndexingSpiTestSuite.java | 16 +- .../include/ignite/binary/binary_raw_reader.h | 21 + .../ignite/impl/binary/binary_reader_impl.h | 9 +- .../src/impl/binary/binary_reader_impl.cpp | 17 + .../platforms/cpp/common/include/Makefile.am | 5 +- .../common/include/ignite/common/concurrent.h | 90 ++- .../include/ignite/common/reference_impl.h | 286 ++++++++ .../cpp/common/include/ignite/reference.h | 564 ++++++++++++++ .../cpp/common/project/vs/common.vcxproj | 2 + .../common/project/vs/common.vcxproj.filters | 6 + modules/platforms/cpp/core-test/Makefile.am | 7 +- .../core-test/config/cache-query-continuous.xml | 87 +++ .../cpp/core-test/config/cache-test.xml | 1 + .../platforms/cpp/core-test/config/invalid.xml | 39 + .../cpp/core-test/project/vs/core-test.vcxproj | 13 +- .../project/vs/core-test.vcxproj.filters | 11 +- .../cpp/core-test/src/cache_query_test.cpp | 76 +- .../cpp/core-test/src/continuous_query_test.cpp | 611 +++++++++++++++ .../cpp/core-test/src/handle_registry_test.cpp | 18 +- .../cpp/core-test/src/interop_test.cpp | 17 +- .../cpp/core-test/src/reference_test.cpp | 412 +++++++++++ modules/platforms/cpp/core/Makefile.am | 1 + .../cpp/core/include/ignite/cache/cache.h | 104 ++- .../cpp/core/include/ignite/cache/cache_entry.h | 40 +- .../ignite/cache/event/cache_entry_event.h | 139 ++++ .../cache/event/cache_entry_event_listener.h | 71 ++ .../cache/query/continuous/continuous_query.h | 239 ++++++ .../query/continuous/continuous_query_handle.h | 133 ++++ .../core/include/ignite/impl/cache/cache_impl.h | 116 ++- .../continuous/continuous_query_handle_impl.h | 101 +++ .../query/continuous/continuous_query_impl.h | 351 +++++++++ .../core/include/ignite/impl/handle_registry.h | 62 +- .../include/ignite/impl/ignite_environment.h | 34 +- modules/platforms/cpp/core/namespaces.dox | 74 +- .../platforms/cpp/core/project/vs/core.vcxproj | 7 + .../cpp/core/project/vs/core.vcxproj.filters | 30 + modules/platforms/cpp/core/src/ignition.cpp | 15 +- .../cpp/core/src/impl/cache/cache_impl.cpp | 31 + .../continuous/continuous_query_handle_impl.cpp | 96 +++ .../cpp/core/src/impl/handle_registry.cpp | 102 ++- .../cpp/core/src/impl/ignite_environment.cpp | 98 ++- modules/platforms/cpp/examples/Makefile.am | 1 + modules/platforms/cpp/examples/configure.ac | 1 + .../continuous-query-example/Makefile.am | 58 ++ .../config/continuous-query-example.xml | 52 ++ .../project/vs/continuous-query-example.vcxproj | 110 +++ .../vs/continuous-query-example.vcxproj.filters | 35 + .../src/continuous_query_example.cpp | 142 ++++ .../examples/include/ignite/examples/person.h | 2 +- .../cpp/examples/project/vs/ignite-examples.sln | 6 + .../platforms/cpp/jni/include/ignite/jni/java.h | 2 +- modules/platforms/cpp/jni/src/java.cpp | 4 +- .../cpp/odbc-test/project/vs/odbc-test.vcxproj | 4 +- modules/platforms/cpp/project/vs/ignite.slnrel | 3 + .../platforms/cpp/project/vs/ignite_x86.slnrel | 3 + .../Cache/Query/CacheLinqTest.cs | 21 +- .../Apache.Ignite.Core.Tests/TestUtils.cs | 3 +- .../Impl/CacheQueryExpressionVisitor.cs | 12 +- .../Apache.Ignite.Linq/Impl/MethodVisitor.cs | 34 +- modules/platforms/dotnet/Apache.Ignite.sln | 2 + modules/platforms/dotnet/DEVNOTES.txt | 12 +- modules/platforms/dotnet/build.bat | 14 + modules/platforms/dotnet/build.ps1 | 211 ++++++ 171 files changed, 8519 insertions(+), 2409 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/e2ac6667/modules/core/src/test/java/org/apache/ignite/testsuites/IgniteBasicTestSuite.java ----------------------------------------------------------------------