Merge branch 'sprint-1' of https://git-wip-us.apache.org/repos/asf/incubator-ignite into ignite-143
Conflicts: modules/core/src/main/java/org/apache/ignite/internal/IgnitionEx.java Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/d8f64839 Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/d8f64839 Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/d8f64839 Branch: refs/heads/ignite-143 Commit: d8f648393e445f4b140a132eace052e42d010cd1 Parents: edf03b4 d1778c1 Author: Valentin Kulichenko <vkuliche...@gridgain.com> Authored: Fri Feb 13 09:24:18 2015 -0800 Committer: Valentin Kulichenko <vkuliche...@gridgain.com> Committed: Fri Feb 13 09:24:18 2015 -0800 ---------------------------------------------------------------------- config/fabric/default-config.xml | 6 +- config/hadoop/default-config.xml | 30 +- config/ignite-log4j.xml | 2 +- docs/core-site.ignite.xml | 26 +- docs/hadoop_readme.md | 8 +- examples/config/filesystem/core-site.xml | 14 +- examples/config/filesystem/example-igfs.xml | 162 + examples/config/filesystem/example-ignitefs.xml | 162 - examples/config/filesystem/readme.txt | 2 +- examples/pom-standalone.xml | 28 +- .../HibernateL2CacheExampleNodeStartup.java | 2 +- .../ignite/examples/igfs/IgfsExample.java | 278 ++ .../examples/igfs/IgfsMapReduceExample.java | 249 ++ .../ignite/examples/igfs/IgfsNodeStartup.java | 41 + .../apache/ignite/examples/igfs/package.html | 24 + .../examples/ignitefs/IgniteFsExample.java | 278 -- .../ignitefs/IgniteFsMapReduceExample.java | 249 -- .../examples/ignitefs/IgniteFsNodeStartup.java | 41 - .../ignite/examples/ignitefs/package.html | 24 - .../MemcacheRestExampleNodeStartup.java | 2 +- .../ignite/examples/IgfsExamplesSelfTest.java | 51 + .../examples/IgniteFsExamplesSelfTest.java | 51 - .../testsuites/IgniteExamplesSelfTestSuite.java | 2 +- .../src/test/resources/spring-server-node.xml | 23 - .../test/resources/spring-server-ssl-node.xml | 24 - modules/core/pom.xml | 10 + .../src/main/java/org/apache/ignite/Ignite.java | 24 +- .../main/java/org/apache/ignite/IgniteFs.java | 106 +- .../apache/ignite/cache/CacheProjection.java | 4 +- .../ignite/cache/cloner/CacheBasicCloner.java | 34 - .../apache/ignite/cache/cloner/CacheCloner.java | 57 - .../ignite/cache/cloner/CacheDeepCloner.java | 87 - .../org/apache/ignite/cache/cloner/package.html | 24 - .../eviction/igfs/CacheIgfsEvictionFilter.java | 35 + .../CacheIgfsPerBlockLruEvictionPolicy.java | 358 +++ ...acheIgfsPerBlockLruEvictionPolicyMXBean.java | 93 + .../ignite/cache/eviction/igfs/package.html | 24 + .../ignitefs/CacheIgniteFsEvictionFilter.java | 35 - .../CacheIgniteFsPerBlockLruEvictionPolicy.java | 358 --- ...IgniteFsPerBlockLruEvictionPolicyMXBean.java | 93 - .../ignite/cache/eviction/ignitefs/package.html | 24 - .../store/jdbc/CacheAbstractJdbcStore.java | 100 +- .../cache/store/jdbc/CacheJdbcPojoStore.java | 8 +- .../configuration/CacheConfiguration.java | 34 - .../ignite/configuration/IgfsConfiguration.java | 807 +++++ .../configuration/IgniteConfiguration.java | 128 +- .../configuration/IgniteFsConfiguration.java | 807 ----- .../ignite/events/AuthenticationEvent.java | 172 - .../ignite/events/AuthorizationEvent.java | 146 - .../org/apache/ignite/events/EventType.java | 248 +- .../org/apache/ignite/events/IgfsEvent.java | 197 ++ .../org/apache/ignite/events/IgniteFsEvent.java | 197 -- .../ignite/events/SecureSessionEvent.java | 154 - .../main/java/org/apache/ignite/igfs/Igfs.java | 216 ++ .../apache/ignite/igfs/IgfsBlockLocation.java | 63 + .../IgfsConcurrentModificationException.java | 36 + .../ignite/igfs/IgfsCorruptedFileException.java | 50 + .../org/apache/ignite/igfs/IgfsException.java | 57 + .../java/org/apache/ignite/igfs/IgfsFile.java | 120 + .../ignite/igfs/IgfsFileNotFoundException.java | 44 + .../igfs/IgfsGroupDataBlocksKeyMapper.java | 101 + .../org/apache/ignite/igfs/IgfsInputStream.java | 80 + .../igfs/IgfsInvalidHdfsVersionException.java | 42 + .../ignite/igfs/IgfsInvalidPathException.java | 57 + .../org/apache/ignite/igfs/IgfsMetrics.java | 159 + .../java/org/apache/ignite/igfs/IgfsMode.java | 80 + .../ignite/igfs/IgfsOutOfSpaceException.java | 58 + .../apache/ignite/igfs/IgfsOutputStream.java | 35 + .../igfs/IgfsParentNotDirectoryException.java | 50 + .../java/org/apache/ignite/igfs/IgfsPath.java | 262 ++ .../igfs/IgfsPathAlreadyExistsException.java | 50 + .../org/apache/ignite/igfs/IgfsPathSummary.java | 138 + .../java/org/apache/ignite/igfs/IgfsReader.java | 38 + .../ignite/igfs/mapreduce/IgfsFileRange.java | 80 + .../mapreduce/IgfsInputStreamJobAdapter.java | 52 + .../apache/ignite/igfs/mapreduce/IgfsJob.java | 69 + .../ignite/igfs/mapreduce/IgfsJobAdapter.java | 28 + .../igfs/mapreduce/IgfsRangeInputStream.java | 197 ++ .../igfs/mapreduce/IgfsRecordResolver.java | 56 + .../apache/ignite/igfs/mapreduce/IgfsTask.java | 172 + .../ignite/igfs/mapreduce/IgfsTaskArgs.java | 82 + .../igfs/mapreduce/IgfsTaskNoReduceAdapter.java | 42 + .../apache/ignite/igfs/mapreduce/package.html | 24 + .../IgfsByteDelimiterRecordResolver.java | 347 ++ .../records/IgfsFixedLengthRecordResolver.java | 86 + .../records/IgfsNewLineRecordResolver.java | 66 + .../IgfsStringDelimiterRecordResolver.java | 84 + .../ignite/igfs/mapreduce/records/package.html | 24 + .../java/org/apache/ignite/igfs/package.html | 24 + .../ignite/ignitefs/IgniteFsBlockLocation.java | 63 - ...IgniteFsConcurrentModificationException.java | 36 - .../IgniteFsCorruptedFileException.java | 50 - .../ignite/ignitefs/IgniteFsException.java | 57 - .../apache/ignite/ignitefs/IgniteFsFile.java | 120 - .../ignitefs/IgniteFsFileNotFoundException.java | 44 - .../ignite/ignitefs/IgniteFsFileSystem.java | 216 -- .../IgniteFsGroupDataBlocksKeyMapper.java | 101 - .../ignite/ignitefs/IgniteFsInputStream.java | 80 - .../IgniteFsInvalidHdfsVersionException.java | 42 - .../ignitefs/IgniteFsInvalidPathException.java | 57 - .../apache/ignite/ignitefs/IgniteFsMetrics.java | 159 - .../apache/ignite/ignitefs/IgniteFsMode.java | 80 - .../ignitefs/IgniteFsOutOfSpaceException.java | 58 - .../ignite/ignitefs/IgniteFsOutputStream.java | 35 - .../IgniteFsParentNotDirectoryException.java | 50 - .../apache/ignite/ignitefs/IgniteFsPath.java | 262 -- .../IgniteFsPathAlreadyExistsException.java | 50 - .../ignite/ignitefs/IgniteFsPathSummary.java | 138 - .../apache/ignite/ignitefs/IgniteFsReader.java | 38 - .../ignitefs/mapreduce/IgniteFsFileRange.java | 80 - .../IgniteFsInputStreamJobAdapter.java | 52 - .../ignite/ignitefs/mapreduce/IgniteFsJob.java | 69 - .../ignitefs/mapreduce/IgniteFsJobAdapter.java | 28 - .../mapreduce/IgniteFsRangeInputStream.java | 197 -- .../mapreduce/IgniteFsRecordResolver.java | 56 - .../ignite/ignitefs/mapreduce/IgniteFsTask.java | 172 - .../ignitefs/mapreduce/IgniteFsTaskArgs.java | 82 - .../mapreduce/IgniteFsTaskNoReduceAdapter.java | 42 - .../ignite/ignitefs/mapreduce/package.html | 24 - .../IgniteFsByteDelimiterRecordResolver.java | 347 -- .../IgniteFsFixedLengthRecordResolver.java | 86 - .../records/IgniteFsNewLineRecordResolver.java | 66 - .../IgniteFsStringDelimiterRecordResolver.java | 84 - .../ignitefs/mapreduce/records/package.html | 24 - .../org/apache/ignite/ignitefs/package.html | 24 - .../ignite/internal/ClusterMetricsSnapshot.java | 79 +- .../ignite/internal/GridKernalContext.java | 32 +- .../ignite/internal/GridKernalContextImpl.java | 58 +- .../org/apache/ignite/internal/GridTopic.java | 2 +- .../ignite/internal/IgniteComponentType.java | 16 +- .../org/apache/ignite/internal/IgniteEx.java | 8 +- .../apache/ignite/internal/IgniteKernal.java | 76 +- .../ignite/internal/IgniteNodeAttributes.java | 2 +- .../org/apache/ignite/internal/IgnitionEx.java | 55 +- .../fs/common/GridGgfsControlResponse.java | 633 ---- .../fs/common/GridGgfsDataInputStream.java | 40 - .../fs/common/GridGgfsDataOutputStream.java | 43 - .../fs/common/GridGgfsHandshakeRequest.java | 93 - .../internal/fs/common/GridGgfsIpcCommand.java | 98 - .../internal/fs/common/GridGgfsLogger.java | 767 ----- .../internal/fs/common/GridGgfsMarshaller.java | 374 --- .../internal/fs/common/GridGgfsMessage.java | 41 - .../fs/common/GridGgfsPathControlRequest.java | 238 -- .../fs/common/GridGgfsStatusRequest.java | 35 - .../fs/common/GridGgfsStreamControlRequest.java | 101 - .../ignite/internal/fs/common/package.html | 24 - .../igfs/common/IgfsControlResponse.java | 633 ++++ .../igfs/common/IgfsDataInputStream.java | 40 + .../igfs/common/IgfsDataOutputStream.java | 43 + .../igfs/common/IgfsHandshakeRequest.java | 93 + .../internal/igfs/common/IgfsIpcCommand.java | 98 + .../ignite/internal/igfs/common/IgfsLogger.java | 767 +++++ .../internal/igfs/common/IgfsMarshaller.java | 374 +++ .../internal/igfs/common/IgfsMessage.java | 41 + .../igfs/common/IgfsPathControlRequest.java | 238 ++ .../internal/igfs/common/IgfsStatusRequest.java | 35 + .../igfs/common/IgfsStreamControlRequest.java | 101 + .../ignite/internal/igfs/common/package.html | 24 + .../managers/GridNoopManagerAdapter.java | 93 - .../communication/GridIoMessageFactory.java | 18 +- .../managers/deployment/GridDeployment.java | 3 - .../deployment/GridDeploymentManager.java | 3 - .../GridDeploymentPerLoaderStore.java | 3 - .../GridDeploymentPerVersionStore.java | 3 - .../discovery/GridDiscoveryManager.java | 2 +- .../securesession/GridSecureSession.java | 54 - .../securesession/GridSecureSessionManager.java | 54 - .../os/GridOsSecureSessionManager.java | 56 - .../managers/securesession/os/package.html | 24 - .../managers/securesession/package.html | 24 - .../security/GridAllowAllPermissionSet.java | 55 - .../managers/security/GridSecurityContext.java | 248 -- .../managers/security/GridSecurityManager.java | 93 - .../security/GridSecuritySubjectAdapter.java | 131 - .../security/os/GridOsSecurityManager.java | 97 - .../internal/managers/security/os/package.html | 24 - .../internal/managers/security/package.html | 24 - .../affinity/GridAffinityAssignmentCache.java | 30 +- .../processors/cache/GridCacheAdapter.java | 118 +- .../cache/GridCacheAffinityManager.java | 5 + .../processors/cache/GridCacheAttributes.java | 13 - .../processors/cache/GridCacheContext.java | 11 +- .../processors/cache/GridCacheEntryEx.java | 7 +- .../processors/cache/GridCacheMapEntry.java | 44 +- .../processors/cache/GridCacheProcessor.java | 26 +- .../processors/cache/GridCacheProjectionEx.java | 18 +- .../cache/GridCacheProjectionImpl.java | 20 +- .../processors/cache/GridCacheProxyImpl.java | 20 +- .../processors/cache/GridCacheUtils.java | 16 +- .../cache/IgniteCacheExpiryPolicy.java | 6 + .../processors/cache/IgniteCacheProxy.java | 2 +- .../distributed/GridDistributedCacheEntry.java | 3 - .../distributed/dht/GridDhtCacheAdapter.java | 27 +- .../distributed/dht/GridDhtCacheEntry.java | 3 - .../dht/atomic/GridDhtAtomicCache.java | 96 +- .../dht/atomic/GridDhtAtomicCacheEntry.java | 3 - .../dht/colocated/GridDhtColocatedCache.java | 4 +- .../colocated/GridDhtColocatedCacheEntry.java | 3 - .../preloader/GridDhtPartitionDemandPool.java | 6 +- .../dht/preloader/GridDhtPartitionMap.java | 32 +- .../distributed/near/GridNearCacheAdapter.java | 18 +- .../distributed/near/GridNearCacheEntry.java | 3 - .../cache/distributed/near/GridNearTxLocal.java | 19 +- .../cache/local/GridLocalCacheEntry.java | 3 - .../local/atomic/GridLocalAtomicCache.java | 7 +- .../cache/query/GridCacheQueryManager.java | 112 +- .../cache/transactions/IgniteTxAdapter.java | 3 - .../processors/closure/GridClosurePolicy.java | 4 +- .../closure/GridClosureProcessor.java | 14 +- .../processors/fs/GridGgfsAckMessage.java | 208 -- .../processors/fs/GridGgfsAsyncImpl.java | 316 -- .../processors/fs/GridGgfsAttributes.java | 186 -- .../processors/fs/GridGgfsBlockKey.java | 275 -- .../fs/GridGgfsBlockLocationImpl.java | 258 -- .../processors/fs/GridGgfsBlocksMessage.java | 188 -- .../processors/fs/GridGgfsClientSession.java | 75 - .../fs/GridGgfsCommunicationMessage.java | 75 - .../internal/processors/fs/GridGgfsContext.java | 205 -- .../processors/fs/GridGgfsDataManager.java | 1906 ----------- .../processors/fs/GridGgfsDeleteMessage.java | 202 -- .../processors/fs/GridGgfsDeleteWorker.java | 345 -- .../fs/GridGgfsDirectoryNotEmptyException.java | 44 - .../internal/processors/fs/GridGgfsEx.java | 143 - .../fs/GridGgfsFileAffinityRange.java | 394 --- .../processors/fs/GridGgfsFileInfo.java | 569 ---- .../internal/processors/fs/GridGgfsFileMap.java | 361 --- .../processors/fs/GridGgfsFileWorker.java | 182 -- .../processors/fs/GridGgfsFileWorkerBatch.java | 236 -- .../processors/fs/GridGgfsFileWorkerTask.java | 32 - .../fs/GridGgfsFragmentizerManager.java | 831 ----- .../fs/GridGgfsFragmentizerRequest.java | 168 - .../fs/GridGgfsFragmentizerResponse.java | 129 - .../fs/GridGgfsHandshakeResponse.java | 122 - .../internal/processors/fs/GridGgfsImpl.java | 2224 ------------- .../fs/GridGgfsInputStreamAdapter.java | 49 - .../fs/GridGgfsInputStreamDescriptor.java | 78 - .../processors/fs/GridGgfsInputStreamImpl.java | 533 --- .../fs/GridGgfsInvalidRangeException.java | 43 - .../processors/fs/GridGgfsIpcHandler.java | 562 ---- .../internal/processors/fs/GridGgfsJobImpl.java | 117 - .../processors/fs/GridGgfsListingEntry.java | 197 -- .../processors/fs/GridGgfsLocalMetrics.java | 212 -- .../internal/processors/fs/GridGgfsManager.java | 155 - .../processors/fs/GridGgfsMetaManager.java | 3027 ------------------ .../processors/fs/GridGgfsModeResolver.java | 177 - .../internal/processors/fs/GridGgfsPaths.java | 124 - .../processors/fs/GridGgfsSamplingKey.java | 83 - .../GridGgfsSecondaryInputStreamDescriptor.java | 59 - ...GridGgfsSecondaryOutputStreamDescriptor.java | 74 - .../internal/processors/fs/GridGgfsServer.java | 427 --- .../processors/fs/GridGgfsServerHandler.java | 57 - .../processors/fs/GridGgfsServerManager.java | 211 -- .../internal/processors/fs/GridGgfsStatus.java | 76 - .../processors/fs/GridGgfsSyncMessage.java | 161 - .../internal/processors/fs/GridGgfsThread.java | 82 - .../processors/fs/IgniteFsFileImpl.java | 245 -- .../internal/processors/fs/IgniteFsHelper.java | 49 - .../processors/fs/IgniteFsHelperImpl.java | 54 - .../processors/fs/IgniteFsMetricsAdapter.java | 239 -- .../processors/fs/IgniteFsNoopHelper.java | 41 - .../processors/fs/IgniteFsNoopProcessor.java | 71 - .../fs/IgniteFsOutputStreamAdapter.java | 263 -- .../processors/fs/IgniteFsOutputStreamImpl.java | 505 --- .../processors/fs/IgniteFsProcessor.java | 420 --- .../processors/fs/IgniteFsProcessorAdapter.java | 80 - .../processors/fs/IgniteFsTaskArgsImpl.java | 135 - .../ignite/internal/processors/fs/package.html | 24 - .../processors/igfs/IgfsAckMessage.java | 208 ++ .../internal/processors/igfs/IgfsAsyncImpl.java | 316 ++ .../processors/igfs/IgfsAttributes.java | 186 ++ .../internal/processors/igfs/IgfsBlockKey.java | 274 ++ .../processors/igfs/IgfsBlockLocationImpl.java | 258 ++ .../processors/igfs/IgfsBlocksMessage.java | 188 ++ .../processors/igfs/IgfsClientSession.java | 75 + .../igfs/IgfsCommunicationMessage.java | 75 + .../internal/processors/igfs/IgfsContext.java | 205 ++ .../processors/igfs/IgfsDataManager.java | 1907 +++++++++++ .../processors/igfs/IgfsDeleteMessage.java | 202 ++ .../processors/igfs/IgfsDeleteWorker.java | 345 ++ .../igfs/IgfsDirectoryNotEmptyException.java | 44 + .../ignite/internal/processors/igfs/IgfsEx.java | 143 + .../processors/igfs/IgfsFileAffinityRange.java | 394 +++ .../internal/processors/igfs/IgfsFileImpl.java | 245 ++ .../internal/processors/igfs/IgfsFileInfo.java | 569 ++++ .../internal/processors/igfs/IgfsFileMap.java | 361 +++ .../processors/igfs/IgfsFileWorker.java | 182 ++ .../processors/igfs/IgfsFileWorkerBatch.java | 236 ++ .../processors/igfs/IgfsFileWorkerTask.java | 32 + .../igfs/IgfsFragmentizerManager.java | 831 +++++ .../igfs/IgfsFragmentizerRequest.java | 168 + .../igfs/IgfsFragmentizerResponse.java | 129 + .../processors/igfs/IgfsHandshakeResponse.java | 122 + .../internal/processors/igfs/IgfsHelper.java | 49 + .../processors/igfs/IgfsHelperImpl.java | 54 + .../internal/processors/igfs/IgfsImpl.java | 2224 +++++++++++++ .../processors/igfs/IgfsInputStreamAdapter.java | 49 + .../igfs/IgfsInputStreamDescriptor.java | 78 + .../processors/igfs/IgfsInputStreamImpl.java | 533 +++ .../igfs/IgfsInvalidRangeException.java | 43 + .../processors/igfs/IgfsIpcHandler.java | 562 ++++ .../internal/processors/igfs/IgfsJobImpl.java | 117 + .../processors/igfs/IgfsListingEntry.java | 197 ++ .../processors/igfs/IgfsLocalMetrics.java | 212 ++ .../internal/processors/igfs/IgfsManager.java | 155 + .../processors/igfs/IgfsMetaManager.java | 3027 ++++++++++++++++++ .../processors/igfs/IgfsMetricsAdapter.java | 239 ++ .../processors/igfs/IgfsModeResolver.java | 177 + .../processors/igfs/IgfsNoopHelper.java | 41 + .../processors/igfs/IgfsNoopProcessor.java | 71 + .../igfs/IgfsOutputStreamAdapter.java | 263 ++ .../processors/igfs/IgfsOutputStreamImpl.java | 505 +++ .../internal/processors/igfs/IgfsPaths.java | 124 + .../internal/processors/igfs/IgfsProcessor.java | 420 +++ .../processors/igfs/IgfsProcessorAdapter.java | 80 + .../processors/igfs/IgfsSamplingKey.java | 83 + .../IgfsSecondaryInputStreamDescriptor.java | 59 + .../IgfsSecondaryOutputStreamDescriptor.java | 74 + .../internal/processors/igfs/IgfsServer.java | 427 +++ .../processors/igfs/IgfsServerHandler.java | 57 + .../processors/igfs/IgfsServerManager.java | 211 ++ .../internal/processors/igfs/IgfsStatus.java | 76 + .../processors/igfs/IgfsSyncMessage.java | 161 + .../processors/igfs/IgfsTaskArgsImpl.java | 135 + .../internal/processors/igfs/IgfsThread.java | 82 + .../internal/processors/igfs/package.html | 24 + .../internal/processors/job/GridJobWorker.java | 4 +- .../portable/GridPortableProcessor.java | 9 + .../portable/os/GridOsPortableProcessor.java | 5 + .../processors/rest/GridRestProcessor.java | 7 +- .../handlers/cache/GridCacheCommandHandler.java | 11 +- .../securesession/GridSecureSession.java | 60 + .../GridSecureSessionProcessor.java | 59 + .../os/GridOsSecureSessionProcessor.java | 61 + .../security/GridSecurityContext.java | 248 ++ .../security/GridSecurityProcessor.java | 97 + .../security/os/GridOsSecurityProcessor.java | 218 ++ .../processors/task/GridTaskWorker.java | 4 +- .../ignite/internal/util/IgniteUtils.java | 14 +- .../ignite/internal/util/ipc/IpcEndpoint.java | 2 +- .../internal/util/ipc/IpcEndpointFactory.java | 2 +- .../shmem/IpcSharedMemoryServerEndpoint.java | 7 +- .../util/lang/GridMetadataAwareAdapter.java | 3 - .../ignite/internal/visor/cache/VisorCache.java | 51 - .../visor/cache/VisorCacheConfiguration.java | 170 +- .../visor/cache/VisorCacheTypeMetadata.java | 16 + .../event/VisorGridAuthenticationEvent.java | 2 +- .../event/VisorGridAuthorizationEvent.java | 2 +- .../ignite/internal/visor/ggfs/VisorGgfs.java | 113 - .../internal/visor/ggfs/VisorGgfsEndpoint.java | 106 - .../visor/ggfs/VisorGgfsFormatTask.java | 70 - .../internal/visor/ggfs/VisorGgfsMetrics.java | 350 -- .../internal/visor/ggfs/VisorGgfsProfiler.java | 88 - .../visor/ggfs/VisorGgfsProfilerClearTask.java | 114 - .../visor/ggfs/VisorGgfsProfilerEntry.java | 238 -- .../visor/ggfs/VisorGgfsProfilerTask.java | 507 --- .../VisorGgfsProfilerUniformityCounters.java | 197 -- .../visor/ggfs/VisorGgfsResetMetricsTask.java | 73 - .../visor/ggfs/VisorGgfsSamplingStateTask.java | 77 - .../ignite/internal/visor/igfs/VisorIgfs.java | 113 + .../internal/visor/igfs/VisorIgfsEndpoint.java | 106 + .../visor/igfs/VisorIgfsFormatTask.java | 70 + .../internal/visor/igfs/VisorIgfsMetrics.java | 350 ++ .../internal/visor/igfs/VisorIgfsProfiler.java | 88 + .../visor/igfs/VisorIgfsProfilerClearTask.java | 114 + .../visor/igfs/VisorIgfsProfilerEntry.java | 238 ++ .../visor/igfs/VisorIgfsProfilerTask.java | 507 +++ .../VisorIgfsProfilerUniformityCounters.java | 197 ++ .../visor/igfs/VisorIgfsResetMetricsTask.java | 73 + .../visor/igfs/VisorIgfsSamplingStateTask.java | 77 + .../visor/node/VisorBasicConfiguration.java | 1 - .../visor/node/VisorGgfsConfiguration.java | 574 ---- .../visor/node/VisorGridConfiguration.java | 20 +- .../visor/node/VisorIgfsConfiguration.java | 574 ++++ .../visor/node/VisorNodeDataCollectorJob.java | 30 +- .../node/VisorNodeDataCollectorJobResult.java | 30 +- .../visor/node/VisorNodeDataCollectorTask.java | 12 +- .../node/VisorNodeDataCollectorTaskResult.java | 38 +- .../node/VisorNodeEventsCollectorTask.java | 21 +- .../visor/node/VisorSpisConfiguration.java | 2 - .../internal/visor/util/VisorTaskUtils.java | 47 +- .../ignite/lang/IgniteProductVersion.java | 12 +- .../apache/ignite/logger/java/JavaLogger.java | 3 - .../optimized/optimized-classnames.properties | 8 +- .../org/apache/ignite/mxbean/IgniteMXBean.java | 16 - .../plugin/security/AuthenticationContext.java | 110 + .../security/GridSecurityCredentials.java | 5 - .../GridSecurityCredentialsProvider.java | 5 - .../org/apache/ignite/spi/IgniteSpiAdapter.java | 19 +- .../AuthenticationAclProvider.java | 41 - .../authentication/AuthenticationContext.java | 56 - .../AuthenticationContextAdapter.java | 112 - .../spi/authentication/AuthenticationSpi.java | 90 - .../noop/NoopAuthenticationSpi.java | 127 - .../noop/NoopAuthenticationSpiMBean.java | 29 - .../ignite/spi/authentication/noop/package.html | 24 - .../ignite/spi/authentication/package.html | 24 - .../communication/tcp/TcpCommunicationSpi.java | 3 +- .../DiscoverySpiNodeAuthenticator.java | 2 +- .../spi/discovery/tcp/TcpDiscoverySpi.java | 2 +- .../discovery/tcp/TcpDiscoverySpiAdapter.java | 2 +- .../spi/securesession/SecureSessionSpi.java | 92 - .../noop/NoopSecureSessionSpi.java | 123 - .../noop/NoopSecureSessionSpiMBean.java | 29 - .../ignite/spi/securesession/noop/package.html | 24 - .../ignite/spi/securesession/package.html | 24 - modules/core/src/test/config/ggfs-loopback.xml | 167 - modules/core/src/test/config/ggfs-shmem.xml | 167 - .../hadoop/core-site-loopback-secondary.xml | 16 +- .../test/config/hadoop/core-site-loopback.xml | 12 +- .../test/config/hadoop/core-site-secondary.xml | 12 +- .../core/src/test/config/hadoop/core-site.xml | 10 +- modules/core/src/test/config/igfs-loopback.xml | 167 + modules/core/src/test/config/igfs-shmem.xml | 167 + .../store/jdbc/CacheJdbcPojoStoreTest.java | 8 +- .../ignite/igfs/IgfsEventsAbstractSelfTest.java | 848 +++++ .../igfs/IgfsFragmentizerAbstractSelfTest.java | 168 + .../ignite/igfs/IgfsFragmentizerSelfTest.java | 268 ++ .../igfs/IgfsFragmentizerTopologySelfTest.java | 49 + .../apache/ignite/igfs/IgfsPathSelfTest.java | 162 + .../ignite/igfs/IgfsTestInputGenerator.java | 51 + .../GridGgfsEventsAbstractSelfTest.java | 848 ----- .../GridGgfsFragmentizerAbstractSelfTest.java | 168 - .../ignitefs/GridGgfsFragmentizerSelfTest.java | 268 -- .../GridGgfsFragmentizerTopologySelfTest.java | 49 - .../ignite/ignitefs/GridGgfsPathSelfTest.java | 162 - .../ignitefs/GridGgfsTestInputGenerator.java | 51 - .../internal/ClusterNodeMetricsSelfTest.java | 15 + .../communication/GridIoManagerSelfTest.java | 4 +- ...idCacheConfigurationConsistencySelfTest.java | 12 - .../processors/cache/GridCacheLeakTest.java | 2 +- .../cache/GridCacheLifecycleAwareSelfTest.java | 23 - .../processors/cache/GridCacheTestEntryEx.java | 8 +- .../cache/GridCacheVersionMultinodeTest.java | 208 ++ .../IgniteCacheExpiryPolicyAbstractTest.java | 20 + ...heGgfsPerBlockLruEvictionPolicySelfTest.java | 485 --- .../processors/fs/GridGgfsAbstractSelfTest.java | 2453 -------------- .../fs/GridGgfsAttributesSelfTest.java | 75 - .../processors/fs/GridGgfsCacheSelfTest.java | 133 - .../fs/GridGgfsCommonAbstractTest.java | 67 - .../fs/GridGgfsDataManagerSelfTest.java | 600 ---- .../fs/GridGgfsDualAbstractSelfTest.java | 1601 --------- .../fs/GridGgfsDualAsyncSelfTest.java | 32 - .../processors/fs/GridGgfsDualSyncSelfTest.java | 32 - .../processors/fs/GridGgfsFileInfoSelfTest.java | 88 - .../processors/fs/GridGgfsFileMapSelfTest.java | 337 -- ...GgfsGroupDataBlockKeyMapperHashSelfTest.java | 136 - .../fs/GridGgfsMetaManagerSelfTest.java | 475 --- .../processors/fs/GridGgfsMetricsSelfTest.java | 536 ---- .../fs/GridGgfsModeResolverSelfTest.java | 77 - .../processors/fs/GridGgfsModesSelfTest.java | 604 ---- .../GridGgfsPrimaryOffheapTieredSelfTest.java | 33 - .../GridGgfsPrimaryOffheapValuesSelfTest.java | 33 - .../processors/fs/GridGgfsPrimarySelfTest.java | 32 - .../fs/GridGgfsProcessorSelfTest.java | 978 ------ .../fs/GridGgfsProcessorValidationSelfTest.java | 535 ---- ...IpcEndpointRegistrationAbstractSelfTest.java | 185 -- ...dpointRegistrationOnLinuxAndMacSelfTest.java | 50 - ...pcEndpointRegistrationOnWindowsSelfTest.java | 53 - .../processors/fs/GridGgfsSizeSelfTest.java | 875 ----- .../processors/fs/GridGgfsStreamsSelfTest.java | 472 --- .../processors/fs/GridGgfsTaskSelfTest.java | 311 -- .../processors/fs/GridGgfsTestInputStream.java | 66 - .../ignite/internal/processors/fs/package.html | 24 - .../GridGgfsAbstractRecordResolverSelfTest.java | 186 -- ...GgfsByteDelimiterRecordResolverSelfTest.java | 335 -- ...idGgfsFixedLengthRecordResolverSelfTest.java | 147 - ...sNewLineDelimiterRecordResolverSelfTest.java | 129 - ...fsStringDelimiterRecordResolverSelfTest.java | 137 - ...heIgfsPerBlockLruEvictionPolicySelfTest.java | 485 +++ .../processors/igfs/IgfsAbstractSelfTest.java | 2453 ++++++++++++++ .../processors/igfs/IgfsAttributesSelfTest.java | 75 + .../processors/igfs/IgfsCacheSelfTest.java | 133 + .../processors/igfs/IgfsCommonAbstractTest.java | 67 + .../igfs/IgfsDataManagerSelfTest.java | 600 ++++ .../igfs/IgfsDualAbstractSelfTest.java | 1601 +++++++++ .../processors/igfs/IgfsDualAsyncSelfTest.java | 32 + .../processors/igfs/IgfsDualSyncSelfTest.java | 32 + .../processors/igfs/IgfsFileInfoSelfTest.java | 88 + .../processors/igfs/IgfsFileMapSelfTest.java | 337 ++ ...IgfsGroupDataBlockKeyMapperHashSelfTest.java | 136 + .../igfs/IgfsMetaManagerSelfTest.java | 475 +++ .../processors/igfs/IgfsMetricsSelfTest.java | 536 ++++ .../igfs/IgfsModeResolverSelfTest.java | 77 + .../processors/igfs/IgfsModesSelfTest.java | 604 ++++ .../igfs/IgfsPrimaryOffheapTieredSelfTest.java | 33 + .../igfs/IgfsPrimaryOffheapValuesSelfTest.java | 33 + .../processors/igfs/IgfsPrimarySelfTest.java | 32 + .../processors/igfs/IgfsProcessorSelfTest.java | 978 ++++++ .../igfs/IgfsProcessorValidationSelfTest.java | 535 ++++ ...IpcEndpointRegistrationAbstractSelfTest.java | 185 ++ ...dpointRegistrationOnLinuxAndMacSelfTest.java | 50 + ...pcEndpointRegistrationOnWindowsSelfTest.java | 53 + .../processors/igfs/IgfsSizeSelfTest.java | 875 +++++ .../processors/igfs/IgfsStreamsSelfTest.java | 472 +++ .../processors/igfs/IgfsTaskSelfTest.java | 311 ++ .../processors/igfs/IgfsTestInputStream.java | 66 + .../internal/processors/igfs/package.html | 24 + .../IgfsAbstractRecordResolverSelfTest.java | 186 ++ ...IgfsByteDelimiterRecordResolverSelfTest.java | 335 ++ .../IgfsFixedLengthRecordResolverSelfTest.java | 147 + ...sNewLineDelimiterRecordResolverSelfTest.java | 129 + ...fsStringDelimiterRecordResolverSelfTest.java | 137 + .../product/GridProductVersionSelfTest.java | 20 + .../internal/util/GridTestClockTimer.java | 2 - .../IpcServerEndpointDeserializerSelfTest.java | 4 +- .../ipc/shmem/GgfsSharedMemoryTestClient.java | 76 - .../ipc/shmem/GgfsSharedMemoryTestServer.java | 71 - .../ipc/shmem/IgfsSharedMemoryTestClient.java | 76 + .../ipc/shmem/IgfsSharedMemoryTestServer.java | 71 + .../IpcSharedMemoryCrashDetectionSelfTest.java | 24 +- .../ipc/shmem/IpcSharedMemoryNodeStartup.java | 12 +- .../discovery/AbstractDiscoverySelfTest.java | 7 +- .../tcp/TcpDiscoverySpiStartStopSelfTest.java | 7 +- .../ignite/testframework/junits/IgniteMock.java | 2 - .../junits/logger/GridTestLog4jLogger.java | 3 - .../junits/spi/GridSpiAbstractTest.java | 93 +- .../ignite/testsuites/IgniteCacheTestSuite.java | 1 + .../ignite/testsuites/IgniteFsTestSuite.java | 79 - .../ignite/testsuites/IgniteIgfsTestSuite.java | 79 + .../core/src/test/webapp/META-INF/gg-config.xml | 349 -- .../webapp/META-INF/ignite-webapp-config.xml | 349 ++ modules/core/src/test/webapp/WEB-INF/web.xml | 6 +- modules/hadoop/readme.txt | 2 +- .../igfs/hadoop/IgfsHadoopParameters.java | 94 + .../org/apache/ignite/igfs/hadoop/package.html | 24 + .../igfs/hadoop/v1/IgfsHadoopFileSystem.java | 1253 ++++++++ .../apache/ignite/igfs/hadoop/v1/package.html | 24 + .../igfs/hadoop/v2/IgfsHadoopFileSystem.java | 1007 ++++++ .../apache/ignite/igfs/hadoop/v2/package.html | 24 + .../java/org/apache/ignite/igfs/package.html | 24 + .../hadoop/GridGgfsHadoopParameters.java | 94 - .../apache/ignite/ignitefs/hadoop/package.html | 24 - .../hadoop/v1/GridGgfsHadoopFileSystem.java | 1253 -------- .../ignite/ignitefs/hadoop/v1/package.html | 24 - .../hadoop/v2/GridGgfsHadoopFileSystem.java | 1007 ------ .../ignite/ignitefs/hadoop/v2/package.html | 24 - .../org/apache/ignite/ignitefs/package.html | 24 - .../internal/fs/hadoop/GridGgfsHadoop.java | 198 -- .../GridGgfsHadoopCommunicationException.java | 57 - .../fs/hadoop/GridGgfsHadoopEndpoint.java | 210 -- .../internal/fs/hadoop/GridGgfsHadoopEx.java | 88 - .../fs/hadoop/GridGgfsHadoopFSProperties.java | 88 - .../hadoop/GridGgfsHadoopFileSystemWrapper.java | 413 --- .../fs/hadoop/GridGgfsHadoopFuture.java | 94 - .../fs/hadoop/GridGgfsHadoopInProc.java | 409 --- .../fs/hadoop/GridGgfsHadoopInputStream.java | 626 ---- .../internal/fs/hadoop/GridGgfsHadoopIo.java | 76 - .../internal/fs/hadoop/GridGgfsHadoopIpcIo.java | 599 ---- .../fs/hadoop/GridGgfsHadoopIpcIoListener.java | 36 - .../fs/hadoop/GridGgfsHadoopJclLogger.java | 115 - .../fs/hadoop/GridGgfsHadoopOutProc.java | 466 --- .../fs/hadoop/GridGgfsHadoopOutputStream.java | 201 -- .../hadoop/GridGgfsHadoopProxyInputStream.java | 335 -- .../hadoop/GridGgfsHadoopProxyOutputStream.java | 165 - .../fs/hadoop/GridGgfsHadoopReader.java | 104 - .../fs/hadoop/GridGgfsHadoopStreamDelegate.java | 96 - .../GridGgfsHadoopStreamEventListener.java | 39 - .../internal/fs/hadoop/GridGgfsHadoopUtils.java | 131 - .../fs/hadoop/GridGgfsHadoopWrapper.java | 511 --- .../ignite/internal/fs/hadoop/package.html | 24 - .../org/apache/ignite/internal/fs/package.html | 24 - .../ignite/internal/igfs/hadoop/IgfsHadoop.java | 198 ++ .../IgfsHadoopCommunicationException.java | 57 + .../igfs/hadoop/IgfsHadoopEndpoint.java | 210 ++ .../internal/igfs/hadoop/IgfsHadoopEx.java | 88 + .../igfs/hadoop/IgfsHadoopFSProperties.java | 88 + .../hadoop/IgfsHadoopFileSystemWrapper.java | 413 +++ .../internal/igfs/hadoop/IgfsHadoopFuture.java | 94 + .../internal/igfs/hadoop/IgfsHadoopInProc.java | 409 +++ .../igfs/hadoop/IgfsHadoopInputStream.java | 626 ++++ .../internal/igfs/hadoop/IgfsHadoopIo.java | 76 + .../internal/igfs/hadoop/IgfsHadoopIpcIo.java | 599 ++++ .../igfs/hadoop/IgfsHadoopIpcIoListener.java | 36 + .../igfs/hadoop/IgfsHadoopJclLogger.java | 112 + .../internal/igfs/hadoop/IgfsHadoopOutProc.java | 466 +++ .../igfs/hadoop/IgfsHadoopOutputStream.java | 201 ++ .../igfs/hadoop/IgfsHadoopProxyInputStream.java | 335 ++ .../hadoop/IgfsHadoopProxyOutputStream.java | 165 + .../internal/igfs/hadoop/IgfsHadoopReader.java | 104 + .../igfs/hadoop/IgfsHadoopStreamDelegate.java | 96 + .../hadoop/IgfsHadoopStreamEventListener.java | 39 + .../internal/igfs/hadoop/IgfsHadoopUtils.java | 131 + .../internal/igfs/hadoop/IgfsHadoopWrapper.java | 511 +++ .../ignite/internal/igfs/hadoop/package.html | 24 + .../apache/ignite/internal/igfs/package.html | 24 + .../hadoop/GridHadoopClassLoader.java | 10 +- .../fs/GridHadoopDistributedFileSystem.java | 2 +- .../hadoop/fs/GridHadoopFileSystemsUtils.java | 6 +- .../GridHadoopDefaultMapReducePlanner.java | 28 +- .../GridHadoopExternalCommunication.java | 3 +- .../hadoop/v2/GridHadoopV2TaskContext.java | 4 +- .../GridHadoopClientProtocolSelfTest.java | 40 +- .../apache/ignite/igfs/IgfsEventsTestSuite.java | 267 ++ .../IgfsHadoop20FileSystemAbstractSelfTest.java | 1967 ++++++++++++ ...doop20FileSystemLoopbackPrimarySelfTest.java | 74 + ...sHadoop20FileSystemShmemPrimarySelfTest.java | 74 + .../igfs/IgfsHadoopDualAbstractSelfTest.java | 304 ++ .../igfs/IgfsHadoopDualAsyncSelfTest.java | 32 + .../ignite/igfs/IgfsHadoopDualSyncSelfTest.java | 32 + .../IgfsHadoopFileSystemAbstractSelfTest.java | 2365 ++++++++++++++ .../IgfsHadoopFileSystemClientSelfTest.java | 199 ++ .../IgfsHadoopFileSystemHandshakeSelfTest.java | 311 ++ .../IgfsHadoopFileSystemIpcCacheSelfTest.java | 207 ++ .../IgfsHadoopFileSystemLoggerSelfTest.java | 287 ++ ...IgfsHadoopFileSystemLoggerStateSelfTest.java | 325 ++ ...adoopFileSystemLoopbackAbstractSelfTest.java | 46 + ...SystemLoopbackEmbeddedDualAsyncSelfTest.java | 33 + ...eSystemLoopbackEmbeddedDualSyncSelfTest.java | 33 + ...leSystemLoopbackEmbeddedPrimarySelfTest.java | 33 + ...SystemLoopbackEmbeddedSecondarySelfTest.java | 34 + ...SystemLoopbackExternalDualAsyncSelfTest.java | 33 + ...eSystemLoopbackExternalDualSyncSelfTest.java | 33 + ...leSystemLoopbackExternalPrimarySelfTest.java | 33 + ...SystemLoopbackExternalSecondarySelfTest.java | 34 + ...fsHadoopFileSystemSecondaryModeSelfTest.java | 319 ++ ...fsHadoopFileSystemShmemAbstractSelfTest.java | 88 + ...ileSystemShmemEmbeddedDualAsyncSelfTest.java | 33 + ...FileSystemShmemEmbeddedDualSyncSelfTest.java | 33 + ...pFileSystemShmemEmbeddedPrimarySelfTest.java | 33 + ...ileSystemShmemEmbeddedSecondarySelfTest.java | 33 + ...ileSystemShmemExternalDualAsyncSelfTest.java | 33 + ...FileSystemShmemExternalDualSyncSelfTest.java | 33 + ...pFileSystemShmemExternalPrimarySelfTest.java | 33 + ...ileSystemShmemExternalSecondarySelfTest.java | 33 + .../java/org/apache/ignite/igfs/IgfsLoad.java | 549 ++++ .../igfs/IgfsNearOnlyMultiNodeSelfTest.java | 212 ++ .../ignite/ignitefs/GridFileSystemLoad.java | 549 ---- ...dGgfsHadoop20FileSystemAbstractSelfTest.java | 1967 ------------ ...doop20FileSystemLoopbackPrimarySelfTest.java | 74 - ...sHadoop20FileSystemShmemPrimarySelfTest.java | 74 - .../GridGgfsHadoopDualAbstractSelfTest.java | 304 -- .../GridGgfsHadoopDualAsyncSelfTest.java | 32 - .../GridGgfsHadoopDualSyncSelfTest.java | 32 - ...ridGgfsHadoopFileSystemAbstractSelfTest.java | 2365 -------------- .../GridGgfsHadoopFileSystemClientSelfTest.java | 199 -- ...idGgfsHadoopFileSystemHandshakeSelfTest.java | 310 -- ...ridGgfsHadoopFileSystemIpcCacheSelfTest.java | 207 -- .../GridGgfsHadoopFileSystemLoggerSelfTest.java | 287 -- ...GgfsHadoopFileSystemLoggerStateSelfTest.java | 325 -- ...adoopFileSystemLoopbackAbstractSelfTest.java | 46 - ...SystemLoopbackEmbeddedDualAsyncSelfTest.java | 33 - ...eSystemLoopbackEmbeddedDualSyncSelfTest.java | 33 - ...leSystemLoopbackEmbeddedPrimarySelfTest.java | 33 - ...SystemLoopbackEmbeddedSecondarySelfTest.java | 34 - ...SystemLoopbackExternalDualAsyncSelfTest.java | 33 - ...eSystemLoopbackExternalDualSyncSelfTest.java | 33 - ...leSystemLoopbackExternalPrimarySelfTest.java | 33 - ...SystemLoopbackExternalSecondarySelfTest.java | 34 - ...fsHadoopFileSystemSecondaryModeSelfTest.java | 319 -- ...fsHadoopFileSystemShmemAbstractSelfTest.java | 88 - ...ileSystemShmemEmbeddedDualAsyncSelfTest.java | 33 - ...FileSystemShmemEmbeddedDualSyncSelfTest.java | 33 - ...pFileSystemShmemEmbeddedPrimarySelfTest.java | 33 - ...ileSystemShmemEmbeddedSecondarySelfTest.java | 33 - ...ileSystemShmemExternalDualAsyncSelfTest.java | 33 - ...FileSystemShmemExternalDualSyncSelfTest.java | 33 - ...pFileSystemShmemExternalPrimarySelfTest.java | 33 - ...ileSystemShmemExternalSecondarySelfTest.java | 33 - .../GridGgfsNearOnlyMultiNodeSelfTest.java | 212 -- .../ignitefs/IgniteFsEventsTestSuite.java | 267 -- .../hadoop/GridHadoopAbstractSelfTest.java | 77 +- .../hadoop/GridHadoopAbstractWordCountTest.java | 16 +- .../hadoop/GridHadoopCommandLineTest.java | 28 +- ...idHadoopDefaultMapReducePlannerSelfTest.java | 146 +- .../hadoop/GridHadoopFileSystemsTest.java | 8 +- .../hadoop/GridHadoopGroupingTest.java | 2 +- .../hadoop/GridHadoopJobTrackerSelfTest.java | 6 +- .../GridHadoopMapReduceEmbeddedSelfTest.java | 14 +- .../hadoop/GridHadoopMapReduceTest.java | 20 +- .../hadoop/GridHadoopSortingTest.java | 14 +- .../processors/hadoop/GridHadoopStartup.java | 7 +- .../hadoop/GridHadoopTaskExecutionSelfTest.java | 38 +- .../hadoop/GridHadoopTasksAllVersionsTest.java | 34 +- ...GridHadoopExternalTaskExecutionSelfTest.java | 16 +- .../loadtests/ggfs/GridGgfsNodeStartup.java | 49 - .../ggfs/GridGgfsPerformanceBenchmark.java | 274 -- .../ignite/loadtests/igfs/IgfsNodeStartup.java | 49 + .../igfs/IgfsPerformanceBenchmark.java | 274 ++ .../IgniteFsLinuxAndMacOSTestSuite.java | 63 - .../testsuites/IgniteHadoopTestSuite.java | 36 +- .../IgniteIgfsLinuxAndMacOSTestSuite.java | 63 + .../ignite/logger/jcl/IgniteJclLogger.java | 3 - .../IgniteLog4jDailyRollingFileAppender.java | 77 - ...IgniteLog4jExternallyRolledFileAppender.java | 63 - .../logger/log4j/IgniteLog4jFileAppender.java | 107 - .../logger/log4j/IgniteLog4jFileAware.java | 32 - .../logger/log4j/IgniteLog4jNodeIdFilePath.java | 64 - .../log4j/IgniteLog4jRollingFileAppender.java | 90 - .../log4j/Log4JDailyRollingFileAppender.java | 77 + .../Log4JExternallyRolledFileAppender.java | 63 + .../ignite/logger/log4j/Log4JFileAppender.java | 107 + .../apache/ignite/logger/log4j/Log4JLogger.java | 12 +- .../ignite/logger/log4j/Log4jFileAware.java | 32 + .../logger/log4j/Log4jNodeIdFilePath.java | 64 + .../logger/log4j/Log4jRollingFileAppender.java | 90 + .../log4j/GridLog4jCorrectFileNameTest.java | 12 +- .../processors/schedule/ScheduleFutureImpl.java | 3 - .../ignite/logger/slf4j/GridSlf4jLogger.java | 3 - .../commands/cache/VisorCacheCommand.scala | 11 +- .../commands/events/VisorEventsCommand.scala | 6 - .../scala/org/apache/ignite/visor/visor.scala | 4 +- .../ignite/cache/websession/GridWebSession.java | 286 -- .../cache/websession/GridWebSessionFilter.java | 466 --- .../websession/GridWebSessionListener.java | 196 -- .../cache/websession/IgniteWebSession.java | 286 ++ .../websession/IgniteWebSessionFilter.java | 466 +++ .../websession/IgniteWebSessionListener.java | 196 ++ .../internal/websession/WebSessionSelfTest.java | 8 +- .../websession/WebSessionServerStart.java | 2 +- .../internal/websession/WebSessionTest.java | 2 +- pom.xml | 70 +- 711 files changed, 63709 insertions(+), 65410 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/d8f64839/examples/config/filesystem/example-igfs.xml ---------------------------------------------------------------------- diff --cc examples/config/filesystem/example-igfs.xml index 0000000,30cf51e..8350e2a mode 000000,100644..100644 --- a/examples/config/filesystem/example-igfs.xml +++ b/examples/config/filesystem/example-igfs.xml @@@ -1,0 -1,165 +1,162 @@@ + <?xml version="1.0" encoding="UTF-8"?> + + <!-- + Licensed to the Apache Software Foundation (ASF) under one or more + contributor license agreements. See the NOTICE file distributed with + this work for additional information regarding copyright ownership. + The ASF licenses this file to You under the Apache License, Version 2.0 + (the "License"); you may not use this file except in compliance with + the License. You may obtain a copy of the License at + + http://www.apache.org/licenses/LICENSE-2.0 + + Unless required by applicable law or agreed to in writing, software + distributed under the License is distributed on an "AS IS" BASIS, + WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + See the License for the specific language governing permissions and + limitations under the License. + --> + + <!-- + Ignite Spring configuration file to startup ignite cache. + + When starting a standalone node, you need to execute the following command: + {IGNITE_HOME}/bin/ignite.{bat|sh} examples/config/filesystem/example-igfs.xml + + When starting Ignite from Java IDE, pass path to this file into Ignition: + Ignition.start("examples/config/filesystem/example-igfs.xml"); + --> + <beans xmlns="http://www.springframework.org/schema/beans" - xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:util="http://www.springframework.org/schema/util" - xsi:schemaLocation=" - http://www.springframework.org/schema/beans - http://www.springframework.org/schema/beans/spring-beans.xsd - http://www.springframework.org/schema/util - http://www.springframework.org/schema/util/spring-util.xsd"> ++ xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" ++ xsi:schemaLocation="http://www.springframework.org/schema/beans ++ http://www.springframework.org/schema/beans/spring-beans.xsd"> + + <!-- + Optional description. + --> + <description> + Spring file for ignite configuration with client available endpoints. + </description> + + <!-- + Initialize property configurer so we can reference environment variables. + --> + <bean id="propertyConfigurer" class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer"> + <property name="systemPropertiesModeName" value="SYSTEM_PROPERTIES_MODE_FALLBACK"/> + <property name="searchSystemEnvironment" value="true"/> + </bean> + + <!-- + Configuration below demonstrates how to setup a IgniteFs node with file data. + --> + <bean id="ignite.cfg" class="org.apache.ignite.configuration.IgniteConfiguration"> + <!-- Set to true to enable cluster-aware class loading for examples, default is false. --> + <property name="peerClassLoadingEnabled" value="true"/> + + <property name="marshaller"> + <bean class="org.apache.ignite.marshaller.optimized.OptimizedMarshaller"> + <!-- Set to false to allow non-serializable objects in examples, default is true. --> + <property name="requireSerializable" value="false"/> + </bean> + </property> + + <property name="igfsConfiguration"> + <list> + <bean class="org.apache.ignite.configuration.IgfsConfiguration"> + <property name="name" value="igfs"/> + <property name="metaCacheName" value="igfs-meta"/> + <property name="dataCacheName" value="igfs-data"/> + + <!-- Must correlate with cache affinity mapper. --> + <property name="blockSize" value="#{128 * 1024}"/> + <property name="perNodeBatchSize" value="512"/> + <property name="perNodeParallelBatchCount" value="16"/> + + <!-- Set number of prefetch blocks. --> + <property name="prefetchBlocks" value="32"/> + + <!-- + This will disable IPC endpoint binding thus preventing Hadoop clients from connecting to IgniteFs. + With this option set to false the only possible way to interact with IgniteFs is through + Ignite API. + --> + <property name="ipcEndpointEnabled" value="false"/> + + <!-- + Example of configured IPC loopback endpoint. + --> + <!-- + <property name="ipcEndpointConfiguration"> + <map> + <entry key="type" value="tcp"/> + </map> + </property> + --> + + <!-- + Example of configured shared memory endpoint. + --> + <!-- + <property name="ipcEndpointConfiguration"> + <map> + <entry key="type" value="shmem"/> + <entry key="port" value="10500"/> + </map> + </property> + --> + </bean> + </list> + </property> + + <property name="cacheConfiguration"> + <list> + <bean class="org.apache.ignite.configuration.CacheConfiguration"> + <property name="name" value="igfs-data"/> + <property name="cacheMode" value="PARTITIONED"/> + <property name="atomicityMode" value="TRANSACTIONAL"/> + <property name="queryIndexEnabled" value="false"/> + <property name="writeSynchronizationMode" value="FULL_SYNC"/> + <property name="distributionMode" value="PARTITIONED_ONLY"/> + <property name="backups" value="0"/> + <property name="affinityMapper"> + <bean class="org.apache.ignite.igfs.IgfsGroupDataBlocksKeyMapper"> + <!-- Haw many blocks in row will be stored on the same node. --> + <constructor-arg value="512"/> + </bean> + </property> + </bean> + + <bean class="org.apache.ignite.configuration.CacheConfiguration"> + <property name="name" value="igfs-meta"/> + <property name="cacheMode" value="REPLICATED"/> + <property name="atomicityMode" value="TRANSACTIONAL"/> + <property name="queryIndexEnabled" value="false"/> + <property name="writeSynchronizationMode" value="FULL_SYNC"/> + </bean> + </list> + </property> + + <!-- Explicitly configure TCP discovery SPI to provide list of initial nodes. --> + <property name="discoverySpi"> + <bean class="org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi"> + <property name="ipFinder"> + <!-- + Ignition provides several options for automatic discovery that can be used + instead os static IP based discovery. For information on all options refer + to our documentation: http://doc.gridgain.org/latest/Automatic+Node+Discovery + --> + <!-- Uncomment static IP finder to enable static-based discovery of initial nodes. --> + <!--<bean class="org.apache.ignite.spi.discovery.tcp.ipfinder.vm.TcpDiscoveryVmIpFinder">--> + <bean class="org.apache.ignite.spi.discovery.tcp.ipfinder.multicast.TcpDiscoveryMulticastIpFinder"> + <property name="addresses"> + <list> + <!-- In distributed environment, replace with actual host IP address. --> + <value>127.0.0.1:47500..47509</value> + </list> + </property> + </bean> + </property> + </bean> + </property> + </bean> + </beans> http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/d8f64839/examples/src/main/java/org/apache/ignite/examples/misc/client/memcache/MemcacheRestExampleNodeStartup.java ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/d8f64839/modules/core/src/main/java/org/apache/ignite/cache/CacheProjection.java ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/d8f64839/modules/core/src/main/java/org/apache/ignite/configuration/CacheConfiguration.java ---------------------------------------------------------------------- diff --cc modules/core/src/main/java/org/apache/ignite/configuration/CacheConfiguration.java index 723ac5f,6105f26..d6c27a1 --- a/modules/core/src/main/java/org/apache/ignite/configuration/CacheConfiguration.java +++ b/modules/core/src/main/java/org/apache/ignite/configuration/CacheConfiguration.java @@@ -20,8 -20,8 +20,7 @@@ package org.apache.ignite.configuration import org.apache.ignite.*; import org.apache.ignite.cache.*; import org.apache.ignite.cache.affinity.*; - import org.apache.ignite.cache.cloner.*; import org.apache.ignite.cache.eviction.*; -import org.apache.ignite.cache.query.*; import org.apache.ignite.cache.store.*; import org.apache.ignite.internal.util.typedef.internal.*; import org.apache.ignite.spi.indexing.*; http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/d8f64839/modules/core/src/main/java/org/apache/ignite/configuration/IgniteConfiguration.java ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/d8f64839/modules/core/src/main/java/org/apache/ignite/internal/IgnitionEx.java ---------------------------------------------------------------------- diff --cc modules/core/src/main/java/org/apache/ignite/internal/IgnitionEx.java index 9c79ca8,c5b4c46..33b6f6e --- a/modules/core/src/main/java/org/apache/ignite/internal/IgnitionEx.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/IgnitionEx.java @@@ -34,15 -34,6 +34,10 @@@ import org.apache.ignite.marshaller.opt import org.apache.ignite.mxbean.*; import org.apache.ignite.plugin.segmentation.*; import org.apache.ignite.spi.*; - import org.apache.ignite.spi.authentication.*; - import org.apache.ignite.spi.authentication.noop.*; +import org.apache.ignite.spi.indexing.*; +import org.apache.ignite.spi.indexing.noop.*; +import org.apache.ignite.streamer.*; +import org.apache.ignite.thread.*; - import org.apache.ignite.internal.processors.resource.*; - import org.apache.ignite.internal.processors.spring.*; - import org.apache.ignite.plugin.segmentation.*; import org.apache.ignite.spi.checkpoint.*; import org.apache.ignite.spi.checkpoint.noop.*; import org.apache.ignite.spi.collision.*; @@@ -58,16 -49,14 +53,11 @@@ import org.apache.ignite.spi.eventstora import org.apache.ignite.spi.eventstorage.memory.*; import org.apache.ignite.spi.failover.*; import org.apache.ignite.spi.failover.always.*; --import org.apache.ignite.spi.indexing.*; import org.apache.ignite.spi.loadbalancing.*; import org.apache.ignite.spi.loadbalancing.roundrobin.*; - import org.apache.ignite.spi.securesession.*; - import org.apache.ignite.spi.securesession.noop.*; import org.apache.ignite.spi.swapspace.*; import org.apache.ignite.spi.swapspace.file.*; import org.apache.ignite.spi.swapspace.noop.*; --import org.apache.ignite.streamer.*; --import org.apache.ignite.thread.*; import org.jdk8.backport.*; import org.jetbrains.annotations.*; http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/d8f64839/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheAttributes.java ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/d8f64839/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheContext.java ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/d8f64839/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheMapEntry.java ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/d8f64839/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheProcessor.java ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/d8f64839/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheProjectionEx.java ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/d8f64839/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheProjectionImpl.java ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/d8f64839/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/IgniteCacheProxy.java ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/d8f64839/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/GridCacheQueryManager.java ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/d8f64839/modules/core/src/main/java/org/apache/ignite/internal/visor/cache/VisorCacheConfiguration.java ---------------------------------------------------------------------- diff --cc modules/core/src/main/java/org/apache/ignite/internal/visor/cache/VisorCacheConfiguration.java index 2809560,afd34ff..1f900ce --- a/modules/core/src/main/java/org/apache/ignite/internal/visor/cache/VisorCacheConfiguration.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/visor/cache/VisorCacheConfiguration.java @@@ -156,10 -165,8 +162,7 @@@ public class VisorCacheConfiguration im cfg.offsetHeapMaxMemory(ccfg.getOffHeapMaxMemory()); cfg.maxQueryIteratorCount(ccfg.getMaximumQueryIteratorCount()); cfg.maxConcurrentAsyncOperations(ccfg.getMaxConcurrentAsyncOperations()); - // cfg.pessimisticTxLoggerSize(ccfg.getPessimisticTxLogSize()); - // cfg.pessimisticTxLoggerLinger(ccfg.getPessimisticTxLogLinger()); cfg.memoryMode(ccfg.getMemoryMode()); - cfg.indexingSpiName(ccfg.getIndexingSpiName()); cfg.interceptor(compactClass(ccfg.getInterceptor())); cfg.affinityConfiguration(VisorCacheAffinityConfiguration.from(ccfg)); cfg.preloadConfiguration(VisorCachePreloadConfiguration.from(ccfg)); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/d8f64839/modules/core/src/main/java/org/apache/ignite/marshaller/optimized/optimized-classnames.properties ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/d8f64839/modules/core/src/test/webapp/META-INF/ignite-webapp-config.xml ---------------------------------------------------------------------- diff --cc modules/core/src/test/webapp/META-INF/ignite-webapp-config.xml index 0000000,a254173..9739822 mode 000000,100644..100644 --- a/modules/core/src/test/webapp/META-INF/ignite-webapp-config.xml +++ b/modules/core/src/test/webapp/META-INF/ignite-webapp-config.xml @@@ -1,0 -1,349 +1,349 @@@ + <?xml version="1.0" encoding="UTF-8"?> + + <!-- + Licensed to the Apache Software Foundation (ASF) under one or more + contributor license agreements. See the NOTICE file distributed with + this work for additional information regarding copyright ownership. + The ASF licenses this file to You under the Apache License, Version 2.0 + (the "License"); you may not use this file except in compliance with + the License. You may obtain a copy of the License at + + http://www.apache.org/licenses/LICENSE-2.0 + + Unless required by applicable law or agreed to in writing, software + distributed under the License is distributed on an "AS IS" BASIS, + WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + See the License for the specific language governing permissions and + limitations under the License. + --> + + <!-- + Ignite Spring configuration file to startup grid cache. + + When starting a standalone Ignite node, you need to execute the following command: + {IGNITE_HOME}/bin/ignite.{bat|sh} examples/config/spring-cache.xml + + When starting Ignite from Java IDE, pass path to this file into Ignition: + Ignition.start("examples/config/spring-cache.xml"); + --> + <beans xmlns="http://www.springframework.org/schema/beans" + xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" + xmlns:util="http://www.springframework.org/schema/util" + xsi:schemaLocation=" + http://www.springframework.org/schema/beans + http://www.springframework.org/schema/beans/spring-beans.xsd + http://www.springframework.org/schema/util + http://www.springframework.org/schema/util/spring-util.xsd"> + <!-- + Configuration below demonstrates how to setup caches within grid nodes. + --> + <bean id="grid.cfg" class="org.apache.ignite.configuration.IgniteConfiguration"> + <property name="deploymentMode" value="SHARED"/> + + <!-- + For better performance set this property to false in case + peer deployment is not used. + Default value is false. + --> + <property name="peerClassLoadingEnabled" value="true"/> + + <!-- + Configure optimized marshaller. + --> + <property name="marshaller"> + <bean class="org.apache.ignite.marshaller.optimized.OptimizedMarshaller"> + <!-- + For better performance set this property to true in case + all marshalled classes implement java.io.Serializable. + Default value is true. + + Note, that it is recommended to implement java.io.Externalizable + instead of java.io.Serializable for smaller network footprint + and even better performance. + --> + <property name="requireSerializable" value="false"/> + </bean> + </property> + + <!-- Set to local host address just for examples. --> + <property name="localHost" value="127.0.0.1"/> + + <!-- Configure REST TCP server address. --> + <property name="connectorConfiguration"> + <bean class="org.apache.ignite.configuration.ConnectorConfiguration"> + <property name="host" value="127.0.0.1"/> + </bean> + </property> + + <!-- + Enable cache events. + --> + <property name="includeEventTypes"> + <util:constant static-field="org.apache.ignite.events.EventType.EVTS_CACHE"/> + </property> + + <property name="cacheConfiguration"> + <!-- + Specify list of cache configurations here. Any property from + CacheConfiguration interface can be configured here. + Note that absolutely all configuration properties are optional. + --> + <list> + <!-- + Partitioned cache example configuration (Atomic mode). + --> + <bean class="org.apache.ignite.configuration.CacheConfiguration"> + <property name="name" value="partitioned"/> + + <property name="cacheMode" value="PARTITIONED"/> + + <!-- Only atomic updates will be supported. --> + <property name="atomicityMode" value="ATOMIC"/> + + <!-- Enable primary sync write mode. --> + <property name="writeSynchronizationMode" value="PRIMARY_SYNC"/> + + <!-- Disable near cache in atomic mode. --> + <property name="distributionMode" value="PARTITIONED_ONLY"/> + + <!-- Initial cache size. --> + <property name="startSize" value="1500000"/> + + <!-- + For better performance set this property to false in case + cache queries are not used. + Default value is false. + --> + <property name="queryIndexEnabled" value="true"/> + + <!-- Allow to index primitive values. --> + <property name="queryConfiguration"> - <bean class="org.apache.ignite.cache.query.CacheQueryConfiguration"> ++ <bean class="org.apache.ignite.cache.query.QueryConfiguration"> + <!-- Index primitives. --> + <property name="indexPrimitiveKey" value="true"/> + </bean> + </property> + + <!-- + This shows how to configure number of backups. The below configuration + sets the number of backups to 1 (which is default). + --> + <property name="backups" value="1"/> + + <!-- Set synchronous preloading (default is asynchronous). --> + <property name="preloadMode" value="SYNC"/> + </bean> + + <!-- + Partitioned cache example configuration (Transactional mode). + --> + <bean class="org.apache.ignite.configuration.CacheConfiguration"> + <property name="name" value="partitioned_tx"/> + + <property name="cacheMode" value="PARTITIONED"/> + + <!-- Transactional updates supported. --> + <property name="atomicityMode" value="TRANSACTIONAL"/> + + <!-- Enable near cache to cache recently accessed data. --> + <property name="distributionMode" value="NEAR_PARTITIONED"/> + + <!-- Initial cache size. --> + <property name="startSize" value="1500000"/> + + <!-- + Setting this value will cause local node to wait for remote commits. + However, it's important to set it this way in the examples as we assert on + conditions that usually assume full completion of transactions on all nodes. + --> + <property name="writeSynchronizationMode" value="FULL_SYNC"/> + + <!-- + For better performance set this property to false in case + cache queries are not used. + Default value is false. + --> + <property name="queryIndexEnabled" value="true"/> + + <!-- Allow to index primitive values. --> + <property name="queryConfiguration"> - <bean class="org.apache.ignite.cache.query.CacheQueryConfiguration"> ++ <bean class="org.apache.ignite.cache.query.QueryConfiguration"> + <!-- Index primitives. --> + <property name="indexPrimitiveKey" value="true"/> + </bean> + </property> + + <!-- + This shows how to configure number of backups. The below configuration + sets the number of backups to 1 (which is default). + --> + <property name="backups" value="1"/> + + <!-- Set synchronous preloading (default is asynchronous). --> + <property name="preloadMode" value="SYNC"/> + </bean> + + <!-- + Replicated cache example configuration. + --> + <bean class="org.apache.ignite.configuration.CacheConfiguration"> + <property name="name" value="replicated"/> + + <!-- + Setting this value will cause local node to wait for remote commits. + However, it's important to set it this way in the examples as we assert on + conditions that usually assume full completion of transactions on all nodes. + --> + <property name="writeSynchronizationMode" value="FULL_SYNC"/> + + <!-- REPLICATED cache mode. --> + <property name="cacheMode" value="REPLICATED"/> + + <!-- Set synchronous preloading (default is asynchronous). --> + <property name="preloadMode" value="SYNC"/> + + <!-- Initial cache size. --> + <property name="startSize" value="150000"/> + + <!-- + For better performance set this property to false in case + cache queries are not used. + Default value is false. + --> + <property name="queryIndexEnabled" value="true"/> + + <!-- Allow to index primitive values. --> + <property name="queryConfiguration"> - <bean class="org.apache.ignite.cache.query.CacheQueryConfiguration"> ++ <bean class="org.apache.ignite.cache.query.QueryConfiguration"> + <!-- Index primitives. --> + <property name="indexPrimitiveKey" value="true"/> + </bean> + </property> + </bean> + + <!-- + Local cache example configuration. + --> + <bean class="org.apache.ignite.configuration.CacheConfiguration"> + <!-- Cache name is 'local'. --> + <property name="name" value="local"/> + + <!-- LOCAL cache mode. --> + <property name="cacheMode" value="LOCAL"/> + + <!-- Initial cache size. --> + <property name="startSize" value="150000"/> + + <!-- + For better performance set this property to false in case + cache queries are not used. + Default value is false. + --> + <property name="queryIndexEnabled" value="true"/> + + <!-- Allow to index primitive values. --> + <property name="queryConfiguration"> - <bean class="org.apache.ignite.cache.query.CacheQueryConfiguration"> ++ <bean class="org.apache.ignite.cache.query.QueryConfiguration"> + <!-- Index primitives. --> + <property name="indexPrimitiveKey" value="true"/> + </bean> + </property> + </bean> + </list> + </property> + + <!-- + Uncomment this to provide TCP discovery SPI (Amazon EC2). + --> + <!-- + <property name="discoverySpi"> + <bean class="org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi"> + <property name="ipFinder"> + <bean class="org.apache.ignite.spi.discovery.tcp.ipfinder.s3.TcpDiscoveryS3IpFinder"> + <property name="awsCredentials"> + <bean class="com.amazonaws.auth.BasicAWSCredentials"> + <constructor-arg value="YOUR_ACCESS_KEY_ID" /> + <constructor-arg value="YOUR_SECRET_ACCESS_KEY" /> + </bean> + </property> + <property name="bucketName" value="YOUR_BUCKET_NAME_IP_FINDER"/> + </bean> + </property> + <property name="heartbeatFrequency" value="2000"/> + </bean> + </property> + --> + + <!-- + Uncomment this to provide TCP discovery SPI (Local network). + + If path to shared file system is not explicitly provided, + then only local nodes will be able to discover each other. + --> + <!-- + <property name="discoverySpi"> + <bean class="org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi"> + <property name="ipFinder"> + <bean class="org.apache.ignite.spi.discovery.tcp.ipfinder.sharedfs.TcpDiscoverySharedFsIpFinder"> + <property name="path" value="work/disco/tcp"/> + </bean> + </property> + </bean> + </property> + --> + + <!-- + TCP discovery SPI configuration with predefined addresses. + Use the addresses list to provide IP addresses of initial nodes in the grid + (at least one address must be provided). + + Note: + ===== + If running in distributed environment, you should change IP addresses to the actual IP addresses + of the servers on your network. Not all addresses need to be specified, only the addresses + of one or more servers which will always be started first. + --> + <property name="discoverySpi"> + <bean class="org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi"> + <property name="ipFinder"> + <bean class="org.apache.ignite.spi.discovery.tcp.ipfinder.vm.TcpDiscoveryVmIpFinder"> + <property name="addresses"> + <list> + <!-- + List all IP/port configurations that potentially + can be started first in examples. We are assuming + grid of size 10 or less. + --> + <value>127.0.0.1:47500</value> + <value>127.0.0.1:47501</value> + <value>127.0.0.1:47502</value> + <value>127.0.0.1:47503</value> + <value>127.0.0.1:47504</value> + <value>127.0.0.1:47505</value> + <value>127.0.0.1:47506</value> + <value>127.0.0.1:47507</value> + <value>127.0.0.1:47508</value> + <value>127.0.0.1:47509</value> + </list> + </property> + </bean> + <!-- + Uncomment this to provide IP finder using multicast for nodes discovery. + In addition to addresses received via multicast this finder can work with pre-configured + list of addresses. + --> + <!-- + <bean class="org.apache.ignite.spi.discovery.tcp.ipfinder.multicast.TcpDiscoveryMulticastIpFinder"> + <property name="addresses"> + <list> + <value>host1:port1</value> + <value>host2:port2</value> + </list> + </property> + </bean> + --> + </property> + </bean> + </property> + </bean> + </beans> http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/d8f64839/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/cache/VisorCacheCommand.scala ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/d8f64839/pom.xml ----------------------------------------------------------------------