Merge remote-tracking branch 'remotes/community/gridgain-7.5.25' into ignite-3038
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/bcd40112 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/bcd40112 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/bcd40112 Branch: refs/heads/ignite-3038 Commit: bcd401128413dadd49968c3a4953b3a62d980c97 Parents: c0e8c42 ec5706f Author: sboikov <sboi...@gridgain.com> Authored: Fri Jun 10 09:07:40 2016 +0300 Committer: sboikov <sboi...@gridgain.com> Committed: Fri Jun 10 09:07:40 2016 +0300 ---------------------------------------------------------------------- .../configuration/FileSystemConfiguration.java | 36 +- .../java/org/apache/ignite/igfs/IgfsPath.java | 26 +- .../org/apache/ignite/igfs/IgfsPathSummary.java | 32 +- .../ignite/internal/binary/BinaryUtils.java | 16 + .../GridClientConnectionManagerAdapter.java | 25 +- .../connection/GridClientNioTcpConnection.java | 3 + .../GridClientOptimizedMarshaller.java | 4 +- .../GridClientZipOptimizedMarshaller.java | 162 ++++++ .../impl/GridTcpRouterNioListenerAdapter.java | 11 +- .../internal/cluster/ClusterGroupAdapter.java | 6 + .../ignite/internal/cluster/ClusterGroupEx.java | 14 +- .../processors/cache/CacheObjectContext.java | 3 + .../internal/processors/igfs/IgfsAsyncImpl.java | 6 - .../processors/igfs/IgfsBlockLocationImpl.java | 87 ++- .../internal/processors/igfs/IgfsContext.java | 14 +- .../processors/igfs/IgfsDataManager.java | 89 ++- .../processors/igfs/IgfsDeleteWorker.java | 42 -- .../ignite/internal/processors/igfs/IgfsEx.java | 9 - .../internal/processors/igfs/IgfsFileImpl.java | 34 +- .../internal/processors/igfs/IgfsImpl.java | 377 +++++------- .../processors/igfs/IgfsInputStreamImpl.java | 6 +- ...zySecondaryFileSystemPositionedReadable.java | 77 +++ .../processors/igfs/IgfsMetaManager.java | 569 ++++++++++++------- .../processors/igfs/IgfsNodePredicate.java | 80 +++ .../igfs/IgfsOutputStreamAdapter.java | 265 --------- .../processors/igfs/IgfsOutputStreamImpl.java | 558 +++++++++++------- .../internal/processors/igfs/IgfsProcessor.java | 37 +- .../internal/processors/igfs/IgfsUtils.java | 57 +- .../igfs/client/IgfsClientAbstractCallable.java | 125 ++++ .../igfs/client/IgfsClientAffinityCallable.java | 95 ++++ .../igfs/client/IgfsClientDeleteCallable.java | 77 +++ .../igfs/client/IgfsClientExistsCallable.java | 58 ++ .../igfs/client/IgfsClientInfoCallable.java | 59 ++ .../client/IgfsClientListFilesCallable.java | 61 ++ .../client/IgfsClientListPathsCallable.java | 60 ++ .../igfs/client/IgfsClientMkdirsCallable.java | 82 +++ .../igfs/client/IgfsClientRenameCallable.java | 80 +++ .../igfs/client/IgfsClientSetTimesCallable.java | 87 +++ .../igfs/client/IgfsClientSizeCallable.java | 59 ++ .../igfs/client/IgfsClientSummaryCallable.java | 59 ++ .../igfs/client/IgfsClientUpdateCallable.java | 81 +++ .../meta/IgfsClientMetaIdsForPathCallable.java | 65 +++ .../meta/IgfsClientMetaInfoForPathCallable.java | 63 ++ .../igfs/meta/IgfsMetaFileUnlockProcessor.java | 69 ++- .../message/GridClientHandshakeRequest.java | 4 +- .../protocols/tcp/GridTcpRestNioListener.java | 19 +- .../rest/protocols/tcp/GridTcpRestProtocol.java | 12 +- .../ignite/internal/util/IgniteUtils.java | 40 ++ .../ignite/internal/util/nio/GridNioServer.java | 10 +- .../ignite/internal/visor/cache/VisorCache.java | 56 +- .../visor/cache/VisorCachePartition.java | 89 +++ .../visor/cache/VisorCachePartitions.java | 88 +++ .../visor/cache/VisorCachePartitionsTask.java | 152 +++++ .../internal/visor/cache/VisorCacheV3.java | 68 +-- .../ignite/igfs/IgfsFragmentizerSelfTest.java | 2 - .../GridCacheBinaryObjectsAbstractSelfTest.java | 78 ++- .../processors/igfs/IgfsAbstractSelfTest.java | 64 ++- .../igfs/IgfsClientCacheSelfTest.java | 139 ----- .../igfs/IgfsDataManagerSelfTest.java | 12 +- .../igfs/IgfsDualAsyncClientSelfTest.java | 28 + .../igfs/IgfsDualSyncClientSelfTest.java | 28 + .../processors/igfs/IgfsModesSelfTest.java | 1 + .../processors/igfs/IgfsOneClientNodeTest.java | 7 +- .../igfs/IgfsPrimaryClientSelfTest.java | 30 + .../igfs/IgfsPrimaryRelaxedClientSelfTest.java | 28 + .../igfs/IgfsProcessorValidationSelfTest.java | 38 +- .../processors/igfs/IgfsSizeSelfTest.java | 133 ----- .../processors/igfs/IgfsTaskSelfTest.java | 2 +- .../unsafe/GridOffheapSnapTreeSelfTest.java | 2 +- .../multijvm/IgniteClusterProcessProxy.java | 5 + .../ignite/testsuites/IgniteIgfsTestSuite.java | 11 +- .../ignite/hadoop/util/BasicUserNameMapper.java | 4 +- .../shuffle/collections/HadoopMultimapBase.java | 90 ++- .../util/BasicUserNameMapperSelfTest.java | 19 +- .../ignite/igfs/Hadoop1DualAbstractTest.java | 2 +- .../igfs/HadoopFIleSystemFactorySelfTest.java | 1 + .../HadoopDefaultMapReducePlannerSelfTest.java | 6 - .../query/h2/opt/GridH2AbstractKeyValueRow.java | 23 +- .../query/h2/opt/GridH2KeyValueRowOffheap.java | 17 +- .../cache/IgniteCacheOffheapIndexScanTest.java | 195 +++++++ .../IgniteCacheQuerySelfTestSuite.java | 2 + .../org/apache/ignite/spark/IgniteRDD.scala | 81 ++- .../org/apache/ignite/spark/JavaIgniteRDD.scala | 9 + .../spark/JavaStandaloneIgniteRDDSelfTest.java | 9 +- .../ignite/spark/EntityTestAllTypeFields.scala | 7 +- .../org/apache/ignite/spark/IgniteRDDSpec.scala | 77 ++- 86 files changed, 3907 insertions(+), 1606 deletions(-) ----------------------------------------------------------------------
