Merge remote-tracking branch 'origin/ignite-1.5' into ignite-1.5
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/f2092e7e Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/f2092e7e Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/f2092e7e Branch: refs/heads/ignite-1.5-cache-get-opts Commit: f2092e7eae9b0bbb8d259e946d188170ae961f9b Parents: 72e39c8 bfb839c Author: sboikov <[email protected]> Authored: Thu Nov 26 12:35:20 2015 +0300 Committer: sboikov <[email protected]> Committed: Thu Nov 26 12:35:20 2015 +0300 ---------------------------------------------------------------------- .../config/binary/example-ignite-binary.xml | 44 ---- examples/config/example-ignite.xml | 10 +- .../ignite/examples/binary/EmployeeKey.java | 3 + .../binary/ExampleBinaryNodeStartup.java | 36 --- ...ComputeClientBinaryTaskExecutionExample.java | 6 +- .../CacheClientBinaryPutGetExample.java | 6 +- .../datagrid/CacheClientBinaryQueryExample.java | 6 +- .../scalar/examples/ScalarCacheExample.scala | 19 +- .../ignite/codegen/MessageCodeGenerator.java | 1 + .../java/org/apache/ignite/IgniteBinary.java | 5 +- .../java/org/apache/ignite/IgniteCache.java | 3 +- .../apache/ignite/binary/BinaryIdMapper.java | 3 +- .../org/apache/ignite/binary/BinaryObject.java | 7 - .../org/apache/ignite/binary/BinaryType.java | 7 + .../apache/ignite/cache/CacheTypeMetadata.java | 2 + .../store/jdbc/CacheAbstractJdbcStore.java | 2 +- .../cache/store/jdbc/CacheJdbcPojoStore.java | 3 +- .../configuration/CacheConfiguration.java | 6 +- .../internal/GridEventConsumeHandler.java | 5 + .../internal/GridMessageListenHandler.java | 5 + .../apache/ignite/internal/IgniteKernal.java | 2 +- .../org/apache/ignite/internal/IgnitionEx.java | 6 +- .../ignite/internal/NodeStoppingException.java | 35 +++ .../internal/portable/BinaryFieldImpl.java | 6 +- .../internal/portable/BinaryMarshaller.java | 144 +++++++++++ .../internal/portable/BinaryObjectEx.java | 225 +---------------- .../internal/portable/BinaryObjectExImpl.java | 245 +++++++++++++++++++ .../internal/portable/BinaryObjectImpl.java | 2 +- .../portable/BinaryObjectOffheapImpl.java | 2 +- .../internal/portable/BinaryTypeImpl.java | 5 + .../portable/PortableClassDescriptor.java | 2 +- .../internal/portable/PortableContext.java | 35 ++- .../ignite/internal/portable/PortableUtils.java | 2 +- .../builder/BinaryObjectBuilderImpl.java | 9 +- .../builder/PortableBuilderSerializer.java | 4 +- .../processors/cache/CacheObjectContext.java | 2 +- .../cache/GridCacheDeploymentManager.java | 6 +- .../processors/cache/GridCacheEventManager.java | 38 ++- .../processors/cache/GridCacheIoManager.java | 6 + .../processors/cache/GridCacheMessage.java | 2 +- .../processors/cache/GridCacheMvccManager.java | 3 +- .../processors/cache/GridCacheProcessor.java | 11 +- .../processors/cache/IgniteCacheProxy.java | 14 +- .../cache/affinity/GridCacheAffinityImpl.java | 3 +- .../distributed/dht/GridDhtLockFuture.java | 19 +- .../distributed/dht/GridDhtTxFinishFuture.java | 1 + .../dht/GridPartitionedSingleGetFuture.java | 3 +- .../dht/atomic/GridDhtAtomicUpdateRequest.java | 2 +- .../dht/atomic/GridNearAtomicUpdateFuture.java | 3 +- .../CacheObjectBinaryProcessorImpl.java | 33 ++- .../continuous/CacheContinuousQueryEntry.java | 50 +++- .../continuous/CacheContinuousQueryEvent.java | 6 +- .../continuous/CacheContinuousQueryHandler.java | 32 ++- .../CacheContinuousQueryListener.java | 5 + .../continuous/CacheContinuousQueryManager.java | 57 +++-- .../cache/store/CacheOsStoreManager.java | 2 +- .../transactions/IgniteTxLocalAdapter.java | 29 ++- .../continuous/GridContinuousHandler.java | 5 + .../continuous/GridContinuousProcessor.java | 10 +- .../StartRoutineDiscoveryMessage.java | 13 +- .../cpp/PlatformCppConfigurationClosure.java | 2 +- .../PlatformDotNetConfigurationClosure.java | 2 +- .../processors/query/GridQueryProcessor.java | 28 ++- .../marshaller/portable/BinaryMarshaller.java | 146 ----------- ...heJdbcPojoStoreBinaryMarshallerSelfTest.java | 85 +++++++ ...JdbcPojoStorePortableMarshallerSelfTest.java | 85 ------- .../portable/BinaryFieldsAbstractSelfTest.java | 13 +- .../portable/BinaryFieldsHeapSelfTest.java | 4 +- .../portable/BinaryFieldsOffheapSelfTest.java | 3 +- .../BinaryFooterOffsetsAbstractSelfTest.java | 5 +- .../BinaryFooterOffsetsHeapSelfTest.java | 4 +- .../BinaryFooterOffsetsOffheapSelfTest.java | 3 +- .../portable/BinaryMarshallerSelfTest.java | 17 +- .../BinaryObjectBuilderAdditionalSelfTest.java | 1 - .../portable/BinaryObjectBuilderSelfTest.java | 102 +++++--- .../GridPortableAffinityKeySelfTest.java | 13 +- ...idPortableMarshallerCtxDisabledSelfTest.java | 1 - .../portable/GridPortableMetaDataSelfTest.java | 1 - .../portable/GridPortableWildcardsSelfTest.java | 1 - .../cache/GridCacheAbstractFullApiSelfTest.java | 97 ++++++++ ...IgniteCacheAbstractExecutionContextTest.java | 2 +- .../IgniteCachePutRetryAbstractSelfTest.java | 2 + ...naryObjectsAbstractDataStreamerSelfTest.java | 2 +- ...aryObjectsAbstractMultiThreadedSelfTest.java | 2 +- .../GridCacheBinaryObjectsAbstractSelfTest.java | 2 +- ...ntNodeBinaryObjectMetadataMultinodeTest.java | 2 +- ...CacheClientNodeBinaryObjectMetadataTest.java | 2 +- .../GridCachePortableStoreAbstractSelfTest.java | 2 +- ...ridPortableCacheEntryMemorySizeSelfTest.java | 2 +- ...leDuplicateIndexObjectsAbstractSelfTest.java | 2 +- .../DataStreamProcessorPortableSelfTest.java | 2 +- .../GridDataStreamerImplSelfTest.java | 2 +- ...ridCacheAffinityRoutingPortableSelfTest.java | 2 +- .../GridCacheMemoryModePortableSelfTest.java | 2 +- ...acheOffHeapTieredAtomicPortableSelfTest.java | 2 +- ...eapTieredEvictionAtomicPortableSelfTest.java | 2 +- ...heOffHeapTieredEvictionPortableSelfTest.java | 2 +- .../GridCacheOffHeapTieredPortableSelfTest.java | 2 +- ...sNearPartitionedByteArrayValuesSelfTest.java | 2 +- ...sPartitionedOnlyByteArrayValuesSelfTest.java | 2 +- .../PlatformComputeBinarizableArgTask.java | 6 +- .../ignite/testframework/junits/IgniteMock.java | 39 ++- .../IgniteBinaryObjectsCacheTestSuite2.java | 33 +++ .../ignite/testsuites/IgniteCacheTestSuite.java | 4 +- .../IgnitePortableCacheFullApiTestSuite.java | 2 +- .../IgnitePortableCacheTestSuite.java | 2 +- .../IgniteCacheAbstractFieldsQuerySelfTest.java | 23 ++ .../cache/IgniteCacheAbstractQuerySelfTest.java | 2 +- ...niteCacheP2pUnmarshallingQueryErrorTest.java | 2 - .../IgnitePortableCacheQueryTestSuite.java | 2 +- .../Config/Compute/compute-grid1.xml | 5 - .../Config/marshaller-explicit.xml | 2 +- .../test/resources/spring-ping-pong-partner.xml | 18 -- 113 files changed, 1244 insertions(+), 807 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/f2092e7e/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheMessage.java ----------------------------------------------------------------------
