Merge remote-tracking branch 'remotes/origin/master' into ignite-1093-2
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/388b0e55 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/388b0e55 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/388b0e55 Branch: refs/heads/ignite-1093-2 Commit: 388b0e55d63ca503c334d6ecd4d8940b08d1ddaf Parents: 6df36b2 2b16b57 Author: Anton Vinogradov <[email protected]> Authored: Fri Sep 4 19:25:55 2015 +0300 Committer: Anton Vinogradov <[email protected]> Committed: Fri Sep 4 19:25:55 2015 +0300 ---------------------------------------------------------------------- examples/config/example-default.xml | 76 + examples/config/example-ignite.xml | 56 +- .../config/portable/example-ignite-portable.xml | 44 + examples/pom.xml | 2 +- .../ignite/examples/portable/Address.java | 72 + .../ignite/examples/portable/Employee.java | 93 + .../ignite/examples/portable/EmployeeKey.java | 90 + .../portable/ExamplePortableNodeStartup.java | 36 + .../ignite/examples/portable/Organization.java | 93 + .../examples/portable/OrganizationType.java | 32 + ...mputeClientPortableTaskExecutionExample.java | 154 + .../portable/computegrid/ComputeClientTask.java | 116 + .../portable/computegrid/package-info.java | 21 + .../CacheClientPortablePutGetExample.java | 230 ++ .../CacheClientPortableQueryExample.java | 328 ++ .../portable/datagrid/package-info.java | 21 + .../ignite/examples/portable/package-info.java | 21 + .../java8/datagrid/CacheAffinityExample.java | 15 + .../java8/messaging/MessagingExample.java | 11 +- .../CacheClientPortableExampleTest.java | 46 + .../ComputeClientPortableExampleTest.java | 37 + .../testsuites/IgniteExamplesSelfTestSuite.java | 6 + .../java8/examples/BasicExamplesSelfTest.java | 10 +- .../java8/examples/CacheExamplesSelfTest.java | 8 +- .../examples/CheckpointExamplesSelfTest.java | 8 +- .../examples/ClusterGroupExampleSelfTest.java | 4 +- .../examples/ContinuationExamplesSelfTest.java | 8 +- .../ContinuousMapperExamplesSelfTest.java | 8 +- .../examples/DeploymentExamplesSelfTest.java | 6 +- .../java8/examples/EventsExamplesSelfTest.java | 5 +- .../HibernateL2CacheExampleSelfTest.java | 8 +- .../java8/examples/IgfsExamplesSelfTest.java | 6 +- .../examples/LifecycleExamplesSelfTest.java | 8 +- .../examples/MemcacheRestExamplesSelfTest.java | 4 +- .../examples/MessagingExamplesSelfTest.java | 6 +- .../examples/MonteCarloExamplesSelfTest.java | 8 +- .../examples/SpringBeanExamplesSelfTest.java | 8 +- .../java8/examples/TaskExamplesSelfTest.java | 4 +- .../IgniteExamplesJ8SelfTestSuite.java | 12 +- modules/aop/pom.xml | 3 +- modules/apache-license-gen/pom.xml | 6 +- modules/aws/pom.xml | 3 +- modules/clients/pom.xml | 3 +- modules/cloud/pom.xml | 3 +- modules/codegen/pom.xml | 3 +- modules/core/pom.xml | 3 +- .../configuration/CacheConfiguration.java | 70 +- .../configuration/PlatformConfiguration.java | 2 +- .../ignite/configuration/TopologyValidator.java | 4 +- .../apache/ignite/internal/IgniteKernal.java | 111 +- .../discovery/GridDiscoveryManager.java | 52 +- .../portable/GridPortableMarshaller.java | 44 +- .../portable/PortableAbstractLazyValue.java | 57 - .../internal/portable/PortableBuilderEnum.java | 114 - .../internal/portable/PortableBuilderImpl.java | 531 --- .../portable/PortableBuilderReader.java | 776 ---- .../PortableBuilderSerializationAware.java | 29 - .../portable/PortableBuilderSerializer.java | 211 -- .../portable/PortableClassDescriptor.java | 134 +- .../internal/portable/PortableContext.java | 126 +- .../portable/PortableEnumArrayLazyValue.java | 112 - .../portable/PortableLazyArrayList.java | 159 - .../portable/PortableLazyLinkedList.java | 215 -- .../internal/portable/PortableLazyMap.java | 218 -- .../internal/portable/PortableLazyMapEntry.java | 66 - .../internal/portable/PortableLazySet.java | 89 - .../internal/portable/PortableLazyValue.java | 28 - .../portable/PortableObjectArrayLazyValue.java | 89 - .../portable/PortablePlainLazyValue.java | 47 - .../portable/PortablePlainPortableObject.java | 50 - .../internal/portable/PortableReaderExImpl.java | 154 +- .../ignite/internal/portable/PortableUtils.java | 11 + .../portable/PortableValueWithType.java | 74 - .../internal/portable/PortableWriterExImpl.java | 251 +- .../builder/PortableAbstractLazyValue.java | 57 + .../portable/builder/PortableBuilderEnum.java | 116 + .../portable/builder/PortableBuilderImpl.java | 537 +++ .../portable/builder/PortableBuilderReader.java | 800 +++++ .../PortableBuilderSerializationAware.java | 31 + .../builder/PortableBuilderSerializer.java | 214 ++ .../builder/PortableEnumArrayLazyValue.java | 114 + .../portable/builder/PortableLazyArrayList.java | 166 + .../builder/PortableLazyLinkedList.java | 217 ++ .../portable/builder/PortableLazyMap.java | 220 ++ .../portable/builder/PortableLazyMapEntry.java | 68 + .../portable/builder/PortableLazySet.java | 92 + .../portable/builder/PortableLazyValue.java | 28 + .../builder/PortableModifiableLazyValue.java | 52 + .../builder/PortableObjectArrayLazyValue.java | 91 + .../builder/PortablePlainLazyValue.java | 49 + .../builder/PortablePlainPortableObject.java | 53 + .../portable/builder/PortableValueWithType.java | 75 + .../internal/portable/builder/package-info.java | 22 + .../affinity/GridAffinityProcessor.java | 4 + .../cache/DynamicCacheChangeRequest.java | 19 +- .../cache/DynamicCacheDescriptor.java | 16 +- .../GridCacheLoaderWriterStoreFactory.java | 20 +- .../GridCachePartitionExchangeManager.java | 4 +- .../processors/cache/GridCacheProcessor.java | 199 +- .../distributed/dht/GridDhtTxPrepareFuture.java | 15 +- .../dht/GridPartitionedGetFuture.java | 19 +- .../distributed/near/GridNearGetFuture.java | 22 +- .../CacheObjectPortableProcessorImpl.java | 2 +- .../cache/store/CacheOsStoreManager.java | 32 +- .../cache/store/CacheStoreManager.java | 10 + .../store/GridCacheStoreManagerAdapter.java | 5 - .../processors/platform/PlatformContext.java | 4 +- .../processors/platform/PlatformException.java | 71 + .../platform/PlatformExtendedException.java | 57 + .../platform/PlatformNativeException.java | 77 + .../platform/PlatformNoCallbackException.java | 50 + .../platform/PlatformNoopProcessor.java | 11 +- .../processors/platform/PlatformProcessor.java | 10 + .../cache/store/PlatformCacheStore.java | 25 + .../callback/PlatformCallbackGateway.java | 10 +- .../internal/util/GridStripedSpinBusyLock.java | 127 + .../ignite/internal/util/lang/GridFunc.java | 1 + .../dotnet/PlatformDotNetConfiguration.java | 119 + .../PlatformDotNetPortableConfiguration.java | 228 ++ ...PlatformDotNetPortableTypeConfiguration.java | 248 ++ .../resources/META-INF/classnames.properties | 2 +- .../core/src/main/resources/ignite.properties | 2 +- .../store/StoreResourceInjectionSelfTest.java | 104 + .../GridPortableBuilderAdditionalSelfTest.java | 232 +- .../portable/GridPortableBuilderSelfTest.java | 1 + .../GridPortableMarshallerSelfTest.java | 138 +- .../GridPortableMetaDataDisabledSelfTest.java | 17 + .../portable/GridPortableMetaDataSelfTest.java | 17 + .../portable/GridPortableWildcardsSelfTest.java | 60 +- .../mutabletest/GridPortableTestClasses.java | 38 +- .../cache/CacheAffinityCallSelfTest.java | 85 +- .../IgniteCacheP2pUnmarshallingErrorTest.java | 5 + .../cache/IgniteDynamicCacheStartSelfTest.java | 4 +- ...gniteTopologyValidatorAbstractCacheTest.java | 46 +- .../CachePutAllFailoverAbstractTest.java | 334 ++ .../CachePutAllFailoverAtomicTest.java | 30 + .../distributed/CachePutAllFailoverTxTest.java | 30 + ...ridCachePartitionNotLoadedEventSelfTest.java | 6 +- ...gniteCachePutRetryTransactionalSelfTest.java | 42 - ...ClientNodePortableMetadataMultinodeTest.java | 11 + .../igfs/IgfsProcessorValidationSelfTest.java | 26 +- .../junits/common/GridCommonAbstractTest.java | 41 + .../IgniteCacheFailoverTestSuite2.java | 2 + .../ignite/testsuites/IgniteCacheTestSuite.java | 4 +- .../testsuites/IgniteCacheTestSuite3.java | 3 +- modules/extdata/p2p/pom.xml | 2 +- .../extdata/uri/modules/uri-dependency/pom.xml | 2 +- modules/extdata/uri/pom.xml | 2 +- modules/gce/pom.xml | 3 +- modules/geospatial/pom.xml | 3 +- modules/hadoop/pom.xml | 3 +- modules/hibernate/pom.xml | 3 +- modules/indexing/pom.xml | 3 +- .../query/h2/opt/GridH2IndexBase.java | 42 + .../query/IgniteSqlSplitterSelfTest.java | 35 +- modules/jcl/pom.xml | 3 +- modules/jms11/pom.xml | 6 +- modules/jta/pom.xml | 3 +- modules/kafka/pom.xml | 3 +- modules/log4j/pom.xml | 3 +- modules/log4j2/pom.xml | 3 +- .../ignite/logger/log4j2/Log4J2Logger.java | 20 +- modules/mesos/pom.xml | 3 +- modules/platform/licenses/apache-2.0.txt | 202 ++ modules/platform/pom.xml | 17 +- .../platform/src/main/cpp/common/configure.ac | 2 +- .../src/main/cpp/common/ignite-common.pc.in | 2 +- .../cpp/common/include/ignite/common/exports.h | 8 +- .../cpp/common/include/ignite/common/java.h | 16 +- .../src/main/cpp/common/src/exports.cpp | 16 +- .../platform/src/main/cpp/common/src/java.cpp | 45 +- .../platform/src/main/cpp/core-test/Makefile.am | 49 + .../main/cpp/core-test/config/cache-query.xml | 91 + .../main/cpp/core-test/config/cache-test.xml | 129 + .../src/main/cpp/core-test/configure.ac | 62 + .../src/main/cpp/core-test/include/Makefile.am | 22 + .../include/ignite/portable_test_defs.h | 320 ++ .../include/ignite/portable_test_utils.h | 516 +++ .../cpp/core-test/include/teamcity_messages.h | 55 + .../src/main/cpp/core-test/project/README.TXT | 1 + .../main/cpp/core-test/project/vs/README.TXT | 1 + .../cpp/core-test/project/vs/core-test.vcxproj | 174 + .../project/vs/core-test.vcxproj.filters | 68 + .../main/cpp/core-test/src/cache_query_test.cpp | 651 ++++ .../src/main/cpp/core-test/src/cache_test.cpp | 481 +++ .../main/cpp/core-test/src/concurrent_test.cpp | 186 + .../cpp/core-test/src/handle_registry_test.cpp | 176 + .../main/cpp/core-test/src/ignition_test.cpp | 97 + .../src/portable_reader_writer_raw_test.cpp | 1532 ++++++++ .../src/portable_reader_writer_test.cpp | 1951 ++++++++++ .../cpp/core-test/src/portable_session_test.cpp | 257 ++ .../cpp/core-test/src/portable_test_defs.cpp | 65 + .../main/cpp/core-test/src/teamcity_boost.cpp | 159 + .../cpp/core-test/src/teamcity_messages.cpp | 150 + modules/platform/src/main/cpp/core/Makefile.am | 66 + modules/platform/src/main/cpp/core/configure.ac | 62 + modules/platform/src/main/cpp/core/ignite.pc.in | 9 + .../src/main/cpp/core/include/Makefile.am | 61 + .../main/cpp/core/include/ignite/cache/cache.h | 1153 ++++++ .../cpp/core/include/ignite/cache/cache_entry.h | 118 + .../core/include/ignite/cache/cache_peek_mode.h | 71 + .../cpp/core/include/ignite/cache/query/query.h | 27 + .../include/ignite/cache/query/query_argument.h | 125 + .../include/ignite/cache/query/query_cursor.h | 191 + .../include/ignite/cache/query/query_scan.h | 151 + .../core/include/ignite/cache/query/query_sql.h | 253 ++ .../include/ignite/cache/query/query_text.h | 159 + .../src/main/cpp/core/include/ignite/guid.h | 112 + .../src/main/cpp/core/include/ignite/ignite.h | 154 + .../core/include/ignite/ignite_configuration.h | 92 + .../main/cpp/core/include/ignite/ignite_error.h | 260 ++ .../src/main/cpp/core/include/ignite/ignition.h | 195 + .../core/include/ignite/impl/cache/cache_impl.h | 418 +++ .../ignite/impl/cache/query/query_impl.h | 115 + .../core/include/ignite/impl/handle_registry.h | 202 ++ .../include/ignite/impl/ignite_environment.h | 130 + .../cpp/core/include/ignite/impl/ignite_impl.h | 146 + .../core/include/ignite/impl/interop/interop.h | 25 + .../ignite/impl/interop/interop_input_stream.h | 234 ++ .../ignite/impl/interop/interop_memory.h | 280 ++ .../ignite/impl/interop/interop_output_stream.h | 234 ++ .../cpp/core/include/ignite/impl/operations.h | 452 +++ .../ignite/impl/portable/portable_common.h | 146 + .../ignite/impl/portable/portable_id_resolver.h | 106 + .../impl/portable/portable_metadata_handler.h | 102 + .../impl/portable/portable_metadata_manager.h | 120 + .../impl/portable/portable_metadata_snapshot.h | 122 + .../impl/portable/portable_metadata_updater.h | 53 + .../portable/portable_metadata_updater_impl.h | 65 + .../ignite/impl/portable/portable_reader_impl.h | 1130 ++++++ .../ignite/impl/portable/portable_utils.h | 344 ++ .../ignite/impl/portable/portable_writer_impl.h | 859 +++++ .../cpp/core/include/ignite/portable/portable.h | 29 + .../include/ignite/portable/portable_consts.h | 106 + .../ignite/portable/portable_containers.h | 525 +++ .../ignite/portable/portable_raw_reader.h | 324 ++ .../ignite/portable/portable_raw_writer.h | 300 ++ .../include/ignite/portable/portable_reader.h | 355 ++ .../include/ignite/portable/portable_type.h | 293 ++ .../include/ignite/portable/portable_writer.h | 335 ++ .../main/cpp/core/os/linux/include/Makefile.am | 20 + .../core/os/linux/include/ignite/impl/utils.h | 155 + .../main/cpp/core/os/linux/src/impl/utils.cpp | 439 +++ .../cpp/core/os/win/include/ignite/impl/utils.h | 155 + .../src/main/cpp/core/os/win/src/impl/utils.cpp | 453 +++ .../src/main/cpp/core/project/README.TXT | 1 + .../src/main/cpp/core/project/vs/README.TXT | 1 + .../src/main/cpp/core/project/vs/core.vcxproj | 272 ++ .../cpp/core/project/vs/core.vcxproj.filters | 246 ++ .../main/cpp/core/project/vs/core.vcxprojrel | 272 ++ modules/platform/src/main/cpp/core/src/guid.cpp | 65 + .../platform/src/main/cpp/core/src/ignite.cpp | 43 + .../src/main/cpp/core/src/ignite_error.cpp | 222 ++ .../platform/src/main/cpp/core/src/ignition.cpp | 468 +++ .../main/cpp/core/src/impl/cache/cache_impl.cpp | 388 ++ .../core/src/impl/cache/query/query_impl.cpp | 193 + .../main/cpp/core/src/impl/handle_registry.cpp | 234 ++ .../cpp/core/src/impl/ignite_environment.cpp | 166 + .../src/main/cpp/core/src/impl/ignite_impl.cpp | 42 + .../src/impl/interop/interop_input_stream.cpp | 215 ++ .../core/src/impl/interop/interop_memory.cpp | 182 + .../src/impl/interop/interop_output_stream.cpp | 215 ++ .../impl/portable/portable_metadata_handler.cpp | 78 + .../impl/portable/portable_metadata_manager.cpp | 201 ++ .../portable/portable_metadata_snapshot.cpp | 70 + .../impl/portable/portable_metadata_updater.cpp | 32 + .../portable/portable_metadata_updater_impl.cpp | 94 + .../src/impl/portable/portable_reader_impl.cpp | 683 ++++ .../core/src/impl/portable/portable_utils.cpp | 214 ++ .../src/impl/portable/portable_writer_impl.cpp | 600 ++++ .../core/src/portable/portable_containers.cpp | 76 + .../core/src/portable/portable_raw_reader.cpp | 135 + .../core/src/portable/portable_raw_writer.cpp | 147 + .../cpp/core/src/portable/portable_reader.cpp | 142 + .../cpp/core/src/portable/portable_type.cpp | 51 + .../cpp/core/src/portable/portable_writer.cpp | 154 + .../Apache.Ignite.Core.csproj | 283 +- .../Cache/CacheAtomicUpdateTimeoutException.cs | 67 + .../Cache/CacheEntryProcessorException.cs | 79 + .../Apache.Ignite.Core/Cache/CacheException.cs | 68 + .../Cache/CachePartialUpdateException.cs | 119 + .../Apache.Ignite.Core/Cache/CachePeekMode.cs | 68 + .../Cache/Event/CacheEntryEventType.cs | 41 + .../Cache/Event/ICacheEntryEvent.cs | 40 + .../Cache/Event/ICacheEntryEventFilter.cs | 31 + .../Cache/Event/ICacheEntryEventListener.cs | 33 + .../Cache/Expiry/ExpiryPolicy.cs | 89 + .../Cache/Expiry/IExpiryPolicy.cs | 59 + .../dotnet/Apache.Ignite.Core/Cache/ICache.cs | 542 +++ .../Apache.Ignite.Core/Cache/ICacheAffinity.cs | 161 + .../Apache.Ignite.Core/Cache/ICacheEntry.cs | 37 + .../Cache/ICacheEntryFilter.cs | 34 + .../Cache/ICacheEntryProcessor.cs | 45 + .../Cache/ICacheEntryProcessorResult.cs | 40 + .../Apache.Ignite.Core/Cache/ICacheLock.cs | 58 + .../Apache.Ignite.Core/Cache/ICacheMetrics.cs | 486 +++ .../Cache/IMutableCacheEntry.cs | 47 + .../Cache/Query/Continuous/ContinuousQuery.cs | 170 + .../Query/Continuous/IContinuousQueryHandle.cs | 51 + .../Cache/Query/IQueryCursor.cs | 40 + .../Apache.Ignite.Core/Cache/Query/QueryBase.cs | 82 + .../Apache.Ignite.Core/Cache/Query/ScanQuery.cs | 77 + .../Cache/Query/SqlFieldsQuery.cs | 81 + .../Apache.Ignite.Core/Cache/Query/SqlQuery.cs | 119 + .../Apache.Ignite.Core/Cache/Query/TextQuery.cs | 104 + .../Store/CacheParallelLoadStoreAdapter.cs | 205 ++ .../Cache/Store/CacheStoreAdapter.cs | 146 + .../Cache/Store/CacheStoreException.cs | 66 + .../Cache/Store/ICacheStore.cs | 184 + .../Cache/Store/ICacheStoreSession.cs | 42 + .../Cluster/ClusterGroupEmptyException.cs | 70 + .../Cluster/ClusterTopologyException.cs | 69 + .../Apache.Ignite.Core/Cluster/ICluster.cs | 80 + .../Apache.Ignite.Core/Cluster/IClusterGroup.cs | 229 ++ .../Cluster/IClusterMetrics.cs | 515 +++ .../Apache.Ignite.Core/Cluster/IClusterNode.cs | 138 + .../Cluster/IClusterNodeFilter.cs | 32 + .../Apache.Ignite.Core/Common/IAsyncSupport.cs | 2 +- .../Common/IgniteException.cs | 2 +- .../Apache.Ignite.Core/Common/IgniteGuid.cs | 138 + .../ComputeExecutionRejectedException.cs | 69 + .../Compute/ComputeJobAdapter.cs | 122 + .../Compute/ComputeJobFailoverException.cs | 72 + .../Compute/ComputeJobResultPolicy.cs | 45 + .../Compute/ComputeTaskAdapter.cs | 93 + .../Compute/ComputeTaskCancelledException.cs | 69 + .../ComputeTaskNoResultCacheAttribute.cs | 35 + .../Compute/ComputeTaskSplitAdapter.cs | 95 + .../Compute/ComputeTaskTimeoutException.cs | 67 + .../Compute/ComputeUserUndeclaredException.cs | 70 + .../Apache.Ignite.Core/Compute/ICompute.cs | 274 ++ .../Apache.Ignite.Core/Compute/IComputeFunc.cs | 55 + .../Apache.Ignite.Core/Compute/IComputeJob.cs | 58 + .../Compute/IComputeJobResult.cs | 73 + .../Compute/IComputeReducer.cs | 39 + .../Apache.Ignite.Core/Compute/IComputeTask.cs | 132 + .../Datastream/IDataStreamer.cs | 206 ++ .../Datastream/IStreamReceiver.cs | 38 + .../Datastream/StreamTransformer.cs | 73 + .../Datastream/StreamVisitor.cs | 55 + .../Apache.Ignite.Core/Events/CacheEvent.cs | 176 + .../Events/CacheQueryExecutedEvent.cs | 97 + .../Events/CacheQueryReadEvent.cs | 134 + .../Events/CacheRebalancingEvent.cs | 98 + .../Events/CheckpointEvent.cs | 50 + .../Apache.Ignite.Core/Events/DiscoveryEvent.cs | 80 + .../Apache.Ignite.Core/Events/EventBase.cs | 160 + .../Apache.Ignite.Core/Events/EventReader.cs | 72 + .../Apache.Ignite.Core/Events/EventType.cs | 514 +++ .../dotnet/Apache.Ignite.Core/Events/IEvent.cs | 74 + .../Apache.Ignite.Core/Events/IEventFilter.cs | 36 + .../dotnet/Apache.Ignite.Core/Events/IEvents.cs | 182 + .../Apache.Ignite.Core/Events/JobEvent.cs | 100 + .../Apache.Ignite.Core/Events/SwapSpaceEvent.cs | 50 + .../Apache.Ignite.Core/Events/TaskEvent.cs | 91 + .../main/dotnet/Apache.Ignite.Core/IIgnite.cs | 168 + .../Apache.Ignite.Core/IgniteConfiguration.cs | 140 + .../main/dotnet/Apache.Ignite.Core/Ignition.cs | 626 +++- .../Impl/Cache/CacheAffinityImpl.cs | 275 ++ .../Apache.Ignite.Core/Impl/Cache/CacheEntry.cs | 126 + .../Impl/Cache/CacheEntryFilterHolder.cs | 147 + .../Impl/Cache/CacheEntryProcessorHolder.cs | 145 + .../Impl/Cache/CacheEntryProcessorResult.cs | 65 + .../Cache/CacheEntryProcessorResultHolder.cs | 127 + .../Impl/Cache/CacheEnumerable.cs | 82 + .../Impl/Cache/CacheEnumerator.cs | 117 + .../Impl/Cache/CacheEnumeratorProxy.cs | 156 + .../Apache.Ignite.Core/Impl/Cache/CacheImpl.cs | 932 +++++ .../Apache.Ignite.Core/Impl/Cache/CacheLock.cs | 171 + .../Impl/Cache/CacheMetricsImpl.cs | 248 ++ .../Apache.Ignite.Core/Impl/Cache/CacheOp.cs | 63 + .../Impl/Cache/CacheProxyImpl.cs | 499 +++ .../Impl/Cache/Event/CacheEntryCreateEvent.cs | 74 + .../Impl/Cache/Event/CacheEntryRemoveEvent.cs | 74 + .../Impl/Cache/Event/CacheEntryUpdateEvent.cs | 79 + .../Impl/Cache/MutableCacheEntry.cs | 163 + .../Impl/Cache/Query/AbstractQueryCursor.cs | 264 ++ .../Query/Continuous/ContinuousQueryFilter.cs | 125 + .../Continuous/ContinuousQueryFilterHolder.cs | 118 + .../Continuous/ContinuousQueryHandleImpl.cs | 216 ++ .../Query/Continuous/ContinuousQueryUtils.cs | 115 + .../Impl/Cache/Query/FieldsQueryCursor.cs | 54 + .../Impl/Cache/Query/QueryCursor.cs | 50 + .../Impl/Cache/Store/CacheStore.cs | 263 ++ .../Impl/Cache/Store/CacheStoreSession.cs | 53 + .../Impl/Cache/Store/CacheStoreSessionProxy.cs | 63 + .../Impl/Cluster/ClusterGroupImpl.cs | 577 +++ .../Impl/Cluster/ClusterMetricsImpl.cs | 292 ++ .../Impl/Cluster/ClusterNodeImpl.cs | 221 ++ .../Impl/Cluster/IClusterGroupEx.cs | 35 + .../Impl/Common/DelegateTypeDescriptor.cs | 327 ++ .../Apache.Ignite.Core/Impl/Common/Future.cs | 3 +- .../Impl/Common/FutureConverter.cs | 62 + .../Impl/Common/GridArgumentCheck.cs | 76 - .../Impl/Common/IgniteArgumentCheck.cs | 76 + .../Impl/Common/PortableResultWrapper.cs | 68 + .../Closure/ComputeAbstractClosureTask.cs | 101 + .../Impl/Compute/Closure/ComputeActionJob.cs | 83 + .../Impl/Compute/Closure/ComputeFuncJob.cs | 89 + .../Compute/Closure/ComputeMultiClosureTask.cs | 56 + .../Impl/Compute/Closure/ComputeOutFuncJob.cs | 76 + .../Closure/ComputeReducingClosureTask.cs | 61 + .../Compute/Closure/ComputeSingleClosureTask.cs | 48 + .../Compute/Closure/IComputeResourceInjector.cs | 31 + .../Apache.Ignite.Core/Impl/Compute/Compute.cs | 213 ++ .../Impl/Compute/ComputeAsync.cs | 261 ++ .../Impl/Compute/ComputeFunc.cs | 119 + .../Impl/Compute/ComputeImpl.cs | 645 ++++ .../Impl/Compute/ComputeJob.cs | 163 + .../Impl/Compute/ComputeJobHolder.cs | 240 ++ .../Compute/ComputeJobResultGenericWrapper.cs | 70 + .../Impl/Compute/ComputeJobResultImpl.cs | 96 + .../Impl/Compute/ComputeOutFunc.cs | 123 + .../Impl/Compute/ComputeTaskHolder.cs | 484 +++ .../Impl/Datastream/DataStreamerBatch.cs | 269 ++ .../Impl/Datastream/DataStreamerEntry.cs | 64 + .../Impl/Datastream/DataStreamerImpl.cs | 832 +++++ .../Impl/Datastream/DataStreamerRemoveEntry.cs | 48 + .../Impl/Datastream/StreamReceiverHolder.cs | 144 + .../Apache.Ignite.Core/Impl/Events/Events.cs | 498 +++ .../Impl/Events/EventsAsync.cs | 158 + .../Impl/Events/RemoteListenEventFilter.cs | 85 + .../Apache.Ignite.Core/Impl/ExceptionUtils.cs | 204 ++ .../Impl/Handle/HandleRegistry.cs | 4 +- .../Apache.Ignite.Core/Impl/IInteropCallback.cs | 34 + .../dotnet/Apache.Ignite.Core/Impl/Ignite.cs | 547 +++ .../Impl/IgniteConfigurationEx.cs | 57 + .../Apache.Ignite.Core/Impl/IgniteManager.cs | 492 +++ .../Apache.Ignite.Core/Impl/IgniteProxy.cs | 351 ++ .../Apache.Ignite.Core/Impl/IgniteUtils.cs | 438 +++ .../Impl/Interop/InteropDotNetConfiguration.cs | 62 + .../InteropDotNetPortableConfiguration.cs | 127 + .../InteropDotNetPortableTypeConfiguration.cs | 151 + .../Impl/InteropExceptionHolder.cs | 85 + .../Impl/LifecycleBeanHolder.cs | 66 + .../Impl/Memory/InteropExternalMemory.cs | 46 + .../Impl/Memory/InteropMemoryUtils.cs | 38 + .../Impl/Memory/PlatformMemoryManager.cs | 5 +- .../Impl/Memory/PlatformMemoryStream.cs | 3 +- .../Impl/Memory/PlatformMemoryUtils.cs | 2 +- .../Impl/Memory/PlatformPooledMemory.cs | 2 +- .../Impl/Messaging/MessageFilterHolder.cs | 179 + .../Impl/Messaging/Messaging.cs | 262 ++ .../Impl/Messaging/MessagingAsync.cs | 68 + .../Apache.Ignite.Core/Impl/NativeMethods.cs | 47 + .../Apache.Ignite.Core/Impl/PlatformTarget.cs | 715 ++++ .../Portable/IPortableSystemTypeSerializer.cs | 34 + .../Impl/Portable/IPortableTypeDescriptor.cs | 124 + .../Impl/Portable/IPortableWriteAware.cs | 34 + .../Impl/Portable/Io/PortableAbstractStream.cs | 1299 +++++++ .../Impl/Portable/Io/PortableHeapStream.cs | 447 +++ .../Impl/Portable/Io/PortableStreamAdapter.cs | 114 + .../Metadata/IPortableMetadataHandler.cs | 41 + .../Metadata/PortableHashsetMetadataHandler.cs | 69 + .../Portable/Metadata/PortableMetadataHolder.cs | 149 + .../Portable/Metadata/PortableMetadataImpl.cs | 200 ++ .../Impl/Portable/PortableBuilderField.cs | 73 + .../Impl/Portable/PortableBuilderImpl.cs | 923 +++++ .../Impl/Portable/PortableCollectionInfo.cs | 251 ++ .../Impl/Portable/PortableFullTypeDescriptor.cs | 203 ++ .../Impl/Portable/PortableHandleDictionary.cs | 187 + .../Portable/PortableMarshalAwareSerializer.cs | 45 + .../Impl/Portable/PortableMarshaller.cs | 603 ++++ .../Impl/Portable/PortableMode.cs | 40 + .../Impl/Portable/PortableObjectHandle.cs | 59 + .../PortableOrSerializableObjectHolder.cs | 66 + .../Portable/PortableReaderHandleDictionary.cs | 42 + .../Impl/Portable/PortableReaderImpl.cs | 1013 ++++++ .../Impl/Portable/PortableReflectiveRoutines.cs | 483 +++ .../Portable/PortableReflectiveSerializer.cs | 218 ++ .../Portable/PortableSurrogateTypeDescriptor.cs | 133 + .../Impl/Portable/PortableSystemHandlers.cs | 1336 +++++++ .../Portable/PortableSystemTypeSerializer.cs | 62 + .../Impl/Portable/PortableUserObject.cs | 385 ++ .../Impl/Portable/PortableUtils.cs | 2039 +++++++++++ .../Impl/Portable/PortableWriterImpl.cs | 1305 +++++++ .../Impl/Portable/PortablesImpl.cs | 205 ++ .../Impl/Portable/SerializableObjectHolder.cs | 66 + .../Impl/Portable/TypeResolver.cs | 227 ++ .../Impl/Resource/IResourceInjector.cs | 27 + .../Impl/Resource/ResourceFieldInjector.cs | 47 + .../Impl/Resource/ResourceMethodInjector.cs | 48 + .../Impl/Resource/ResourceProcessor.cs | 105 + .../Impl/Resource/ResourcePropertyInjector.cs | 47 + .../Impl/Resource/ResourceTypeDescriptor.cs | 291 ++ .../Impl/Services/ServiceContext.cs | 60 + .../Impl/Services/ServiceDescriptor.cs | 106 + .../Impl/Services/ServiceProxy.cs | 71 + .../Impl/Services/ServiceProxyInvoker.cs | 136 + .../Impl/Services/ServiceProxySerializer.cs | 140 + .../Impl/Services/Services.cs | 316 ++ .../Impl/Services/ServicesAsync.cs | 89 + .../Impl/Transactions/AsyncTransaction.cs | 78 + .../Impl/Transactions/Transaction.cs | 155 + .../Impl/Transactions/TransactionImpl.cs | 489 +++ .../Impl/Transactions/TransactionMetricsImpl.cs | 62 + .../Impl/Transactions/TransactionsImpl.cs | 201 ++ .../Impl/Unmanaged/IUnmanagedTarget.cs | 42 + .../Impl/Unmanaged/UnmanagedCallbackHandlers.cs | 99 + .../Impl/Unmanaged/UnmanagedCallbacks.cs | 1152 ++++++ .../Impl/Unmanaged/UnmanagedContext.cs | 53 + .../Unmanaged/UnmanagedNonReleaseableTarget.cs | 68 + .../Impl/Unmanaged/UnmanagedTarget.cs | 77 + .../Impl/Unmanaged/UnmanagedUtils.cs | 1252 +++++++ .../Lifecycle/ILifecycleBean.cs | 64 + .../Lifecycle/LifecycleEventType.cs | 49 + .../Messaging/IMessageFilter.cs | 35 + .../Apache.Ignite.Core/Messaging/IMessaging.cs | 105 + .../Portable/IPortableBuilder.cs | 78 + .../Portable/IPortableIdMapper.cs | 40 + .../Portable/IPortableMarshalAware.cs | 39 + .../Portable/IPortableMetadata.cs | 61 + .../Portable/IPortableNameMapper.cs | 39 + .../Portable/IPortableObject.cs | 44 + .../Portable/IPortableRawReader.cs | 264 ++ .../Portable/IPortableRawWriter.cs | 221 ++ .../Portable/IPortableReader.cs | 340 ++ .../Portable/IPortableSerializer.cs | 39 + .../Portable/IPortableWriter.cs | 259 ++ .../Apache.Ignite.Core/Portable/IPortables.cs | 120 + .../Portable/PortableConfiguration.cs | 122 + .../Portable/PortableException.cs | 64 + .../Portable/PortableTypeConfiguration.cs | 162 + .../Portable/PortableTypeNames.cs | 115 + .../Properties/AssemblyInfo.cs | 4 +- .../Resource/InstanceResourceAttribute.cs | 35 + .../Resource/StoreSessionResourceAttribute.cs | 32 + .../Apache.Ignite.Core/Services/IService.cs | 51 + .../Services/IServiceContext.cs | 69 + .../Services/IServiceDescriptor.cs | 96 + .../Apache.Ignite.Core/Services/IServices.cs | 181 + .../Services/ServiceConfiguration.cs | 62 + .../Services/ServiceInvocationException.cs | 101 + .../Transactions/ITransaction.cs | 230 ++ .../Transactions/ITransactionMetrics.cs | 47 + .../Transactions/ITransactions.cs | 73 + .../Transactions/TransactionConcurrency.cs | 36 + .../TransactionHeuristicException.cs | 72 + .../Transactions/TransactionIsolation.cs | 41 + .../TransactionOptimisticException.cs | 69 + .../TransactionRollbackException.cs | 68 + .../Transactions/TransactionState.cs | 70 + .../Transactions/TransactionTimeoutException.cs | 69 + .../platform/src/main/dotnet/Apache.Ignite.sln | 27 +- ...processors.platform.PlatformBootstrapFactory | 2 + .../PlatformAbstractConfigurationClosure.java | 61 + .../platform/PlatformAbstractTarget.java | 34 +- .../platform/PlatformConfigurationEx.java | 48 + .../platform/PlatformContextImpl.java | 621 ++++ .../processors/platform/PlatformException.java | 71 - .../platform/PlatformExtendedException.java | 39 - .../platform/PlatformNoCallbackException.java | 50 - .../platform/PlatformProcessorImpl.java | 360 ++ .../platform/cache/PlatformCache.java | 46 +- .../PlatformCachePartialUpdateException.java | 24 +- .../cache/store/PlatformCacheStore.java | 25 - .../platform/compute/PlatformAbstractTask.java | 1 + .../compute/PlatformNativeException.java | 77 - .../platform/cpp/PlatformCppBootstrap.java | 31 + .../cpp/PlatformCppBootstrapFactory.java | 39 + .../cpp/PlatformCppConfigurationClosure.java | 99 + .../cpp/PlatformCppConfigurationEx.java | 82 + .../datastreamer/PlatformDataStreamer.java | 2 +- .../dotnet/PlatformDotNetBootstrap.java | 31 + .../dotnet/PlatformDotNetBootstrapFactory.java | 39 + .../dotnet/PlatformDotNetCacheStore.java | 497 +++ .../PlatformDotNetConfigurationClosure.java | 255 ++ .../dotnet/PlatformDotNetConfigurationEx.java | 91 + .../lifecycle/PlatformLifecycleBean.java | 4 +- .../messaging/PlatformMessageFilterImpl.java | 2 +- .../transactions/PlatformTransactions.java | 2 +- .../platform/utils/PlatformFutureUtils.java | 82 +- .../platform/utils/PlatformUtils.java | 16 +- .../platform/cpp/PlatformCppConfiguration.java | 47 + .../ignite/platform/cpp/package-info.java | 22 + .../dotnet/PlatformDotNetCacheStoreFactory.java | 139 + .../dotnet/PlatformDotNetLifecycleBean.java | 109 + .../ignite/platform/dotnet/package-info.java | 22 + .../apache/ignite/platform/package-info.java | 22 + .../Apache.Ignite.Core.Tests.TestDll.csproj | 52 + .../Properties/AssemblyInfo.cs | 49 + .../TestClass.cs | 35 + .../Apache.Ignite.Core.Tests.csproj | 165 +- .../Cache/CacheAbstractTest.cs | 3321 ++++++++++++++++++ .../Cache/CacheAffinityTest.cs | 139 + .../Cache/CacheDynamicStartTest.cs | 281 ++ .../Cache/CacheEntryTest.cs | 69 + .../Cache/CacheForkedTest.cs | 82 + .../Cache/CacheLocalAtomicTest.cs | 57 + .../Cache/CacheLocalTest.cs | 56 + .../CachePartitionedAtomicNearEnabledTest.cs | 50 + .../Cache/CachePartitionedAtomicTest.cs | 50 + .../Cache/CachePartitionedNearEnabledTest.cs | 50 + .../Cache/CachePartitionedTest.cs | 50 + .../Cache/CacheReplicatedAtomicTest.cs | 60 + .../Cache/CacheReplicatedTest.cs | 60 + .../Cache/CacheTestAsyncWrapper.cs | 436 +++ .../Cache/Query/CacheQueriesTest.cs | 928 +++++ .../Continuous/ContinuousQueryAbstractTest.cs | 1181 +++++++ .../ContinuousQueryAtomicBackupTest.cs | 33 + .../ContinuousQueryAtomicNoBackupTest.cs | 34 + .../ContinuousQueryNoBackupAbstractTest.cs | 72 + .../ContinuousQueryTransactionalBackupTest.cs | 34 + .../ContinuousQueryTransactionalNoBackupTest.cs | 33 + .../Cache/Store/CacheParallelLoadStoreTest.cs | 110 + .../Cache/Store/CacheStoreSessionTest.cs | 285 ++ .../Cache/Store/CacheStoreTest.cs | 510 +++ .../Cache/Store/CacheTestParallelLoadStore.cs | 91 + .../Cache/Store/CacheTestStore.cs | 155 + .../Compute/AbstractTaskTest.cs | 217 ++ .../Compute/ClosureTaskTest.cs | 390 ++ .../Compute/ComputeApiTest.cs | 1281 +++++++ .../Compute/ComputeMultithreadedTest.cs | 269 ++ .../Compute/FailoverTaskSelfTest.cs | 246 ++ .../Forked/ForkedPortableClosureTaskTest.cs | 33 + .../Compute/Forked/ForkedResourceTaskTest.cs | 33 + .../Forked/ForkedSerializableClosureTaskTest.cs | 33 + .../Compute/Forked/ForkedTaskAdapterTest.cs | 33 + .../Compute/IgniteExceptionTaskSelfTest.cs | 753 ++++ .../Compute/PortableClosureTaskTest.cs | 217 ++ .../Compute/PortableTaskTest.cs | 253 ++ .../Compute/ResourceTaskTest.cs | 568 +++ .../Compute/SerializableClosureTaskTest.cs | 217 ++ .../Compute/TaskAdapterTest.cs | 274 ++ .../Compute/TaskResultTest.cs | 437 +++ .../Config/Cache/Store/cache-store-session.xml | 80 + .../Config/Compute/compute-grid1.xml | 90 + .../Config/Compute/compute-grid2.xml | 63 + .../Config/Compute/compute-grid3.xml | 52 + .../Config/Compute/compute-standalone.xml | 87 + .../Config/Dynamic/dynamic-client.xml | 51 + .../Config/Dynamic/dynamic-data-no-cfg.xml | 47 + .../Config/Dynamic/dynamic-data.xml | 65 + .../Config/Ignite.exe.config.test | 41 + .../Config/Lifecycle/lifecycle-beans.xml | 66 + .../Config/Lifecycle/lifecycle-no-beans.xml | 44 + .../Config/cache-portables.xml | 78 + .../Config/cache-query-continuous.xml | 171 + .../Config/cache-query.xml | 100 + .../Config/marshaller-default.xml | 43 + .../Config/marshaller-invalid.xml | 46 + .../Config/marshaller-portable.xml | 43 + .../native-client-test-cache-affinity.xml | 70 + .../native-client-test-cache-parallel-store.xml | 69 + .../native-client-test-cache-portables.xml | 226 ++ .../Config/native-client-test-cache-store.xml | 125 + .../Config/native-client-test-cache.xml | 224 ++ .../Config/portable.xml | 56 + .../Config/start-test-grid1.xml | 54 + .../Config/start-test-grid2.xml | 45 + .../Config/start-test-grid3.xml | 43 + .../Dataload/DataStreamerTest.cs | 592 ++++ .../Apache.Ignite.Core.Tests/EventsTest.cs | 961 +++++ .../Apache.Ignite.Core.Tests/ExceptionsTest.cs | 352 ++ .../Apache.Ignite.Core.Tests/ExecutableTest.cs | 444 +++ .../Apache.Ignite.Core.Tests/FutureTest.cs | 278 ++ .../IgniteManagerTest.cs | 51 + .../IgniteStartStopTest.cs | 380 ++ .../Apache.Ignite.Core.Tests/IgnitionTest.cs | 30 - .../Apache.Ignite.Core.Tests/LifecycleTest.cs | 288 ++ .../Apache.Ignite.Core.Tests/LoadDllTest.cs | 243 ++ .../Apache.Ignite.Core.Tests/MarshallerTest.cs | 71 + .../Apache.Ignite.Core.Tests/MessagingTest.cs | 646 ++++ .../Portable/PortableApiSelfTest.cs | 1787 ++++++++++ .../Portable/PortableSelfTest.cs | 2078 +++++++++++ .../PortableConfigurationTest.cs | 173 + .../Process/IIgniteProcessOutputReader.cs | 35 + .../Process/IgniteProcess.cs | 292 ++ .../Process/IgniteProcessConsoleOutputReader.cs | 40 + .../Properties/AssemblyInfo.cs | 4 +- .../Query/ImplicitPortablePerson.cs | 46 + .../Query/NoDefPortablePerson.cs | 35 + .../Query/PortablePerson.cs | 69 + .../SerializationTest.cs | 240 ++ .../Services/ServiceProxyTest.cs | 741 ++++ .../Services/ServicesAsyncWrapper.cs | 174 + .../Services/ServicesTest.cs | 823 +++++ .../Services/ServicesTestAsync.cs | 33 + .../Apache.Ignite.Core.Tests/TestRunner.cs | 15 +- .../Apache.Ignite.Core.Tests/TestUtils.cs | 292 ++ .../TypeResolverTest.cs | 107 + .../platform/PlatformComputeBroadcastTask.java | 73 + .../platform/PlatformComputeDecimalTask.java | 106 + .../platform/PlatformComputeEchoTask.java | 188 + .../ignite/platform/PlatformComputeEnum.java | 28 + .../platform/PlatformComputeJavaPortable.java | 39 + .../platform/PlatformComputePortable.java | 42 + .../PlatformComputePortableArgTask.java | 119 + .../platform/PlatformEventsWriteEventTask.java | 146 + .../ignite/platform/PlatformMaxMemoryTask.java | 57 + .../ignite/platform/PlatformMinMemoryTask.java | 57 + .../lifecycle/PlatformJavaLifecycleBean.java | 47 + .../lifecycle/PlatformJavaLifecycleTask.java | 65 + modules/rest-http/pom.xml | 3 +- modules/scalar-2.10/pom.xml | 3 +- modules/scalar/pom.xml | 3 +- modules/schedule/pom.xml | 3 +- modules/schema-import/pom.xml | 3 +- modules/slf4j/pom.xml | 3 +- modules/spark-2.10/pom.xml | 3 +- modules/spark/pom.xml | 3 +- modules/spring/pom.xml | 3 +- modules/ssh/pom.xml | 3 +- modules/tools/pom.xml | 3 +- modules/urideploy/pom.xml | 3 +- modules/visor-console-2.10/pom.xml | 3 +- modules/visor-console/pom.xml | 3 +- modules/visor-plugins/pom.xml | 3 +- modules/web/pom.xml | 3 +- modules/yardstick/pom.xml | 3 +- modules/yarn/pom.xml | 3 +- modules/zookeeper/pom.xml | 3 +- parent/pom.xml | 26 +- pom.xml | 119 +- 714 files changed, 110768 insertions(+), 4185 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/388b0e55/modules/core/src/main/java/org/apache/ignite/configuration/CacheConfiguration.java ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/388b0e55/modules/core/src/main/java/org/apache/ignite/internal/IgniteKernal.java ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/388b0e55/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCachePartitionExchangeManager.java ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/388b0e55/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheProcessor.java ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/388b0e55/modules/core/src/test/java/org/apache/ignite/testsuites/IgniteCacheTestSuite3.java ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/388b0e55/modules/yardstick/pom.xml ---------------------------------------------------------------------- diff --cc modules/yardstick/pom.xml index 553158c,2f0c5fe..eba8a61 --- a/modules/yardstick/pom.xml +++ b/modules/yardstick/pom.xml @@@ -31,10 -31,11 +31,11 @@@ </parent> <artifactId>ignite-yardstick</artifactId> - <version>1.4.1-SNAPSHOT</version> + <version>1.5.0-SNAPSHOT</version> + <url>http://ignite.apache.org</url> <properties> - <yardstick.version>0.7.0</yardstick.version> + <yardstick.version>0.7.1</yardstick.version> </properties>
