geode-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From vfor...@apache.org
Subject [50/50] [abbrv] incubator-geode git commit: Merge branch 'develop' into feature/GEODE-78
Date Wed, 25 Nov 2015 19:08:03 GMT
Merge branch 'develop' into feature/GEODE-78


Project: http://git-wip-us.apache.org/repos/asf/incubator-geode/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-geode/commit/f29845a0
Tree: http://git-wip-us.apache.org/repos/asf/incubator-geode/tree/f29845a0
Diff: http://git-wip-us.apache.org/repos/asf/incubator-geode/diff/f29845a0

Branch: refs/heads/feature/GEODE-78
Commit: f29845a0cd308dec2f51f8642477f90ebb461c23
Parents: ee567c3 17fdf57
Author: Vince Ford <vford13@apache.org>
Authored: Mon Oct 12 16:12:10 2015 -0700
Committer: Vince Ford <vford13@apache.org>
Committed: Mon Oct 12 16:12:10 2015 -0700

----------------------------------------------------------------------
 README.md                                       |    2 +-
 build.gradle                                    |   20 +-
 docker/Dockerfile                               |   56 +
 docker/README.md                                |   67 +
 etc/eclipseFormatterProfile.xml                 |   11 +-
 gemfire-assembly/build.gradle                   |    3 +-
 .../src/test/java/AgentUtilJUnitTest.java       |  109 -
 .../management/internal/AgentUtilJUnitTest.java |  106 +
 gemfire-core/build.gradle                       |   30 +-
 .../com/gemstone/gemfire/DataSerializer.java    |   11 +-
 .../gemfire/admin/GemFireMemberStatus.java      |   13 +-
 .../gemfire/admin/SystemMemberBridgeServer.java |    5 +-
 .../gemfire/admin/SystemMemberCache.java        |   27 -
 .../DistributedSystemHealthMonitor.java         |    2 +-
 .../admin/internal/SystemMemberCacheImpl.java   |   17 +-
 .../jmx/internal/SystemMemberCacheJmxImpl.java  |   13 -
 .../gemfire/cache/AttributesFactory.java        |   31 -
 .../java/com/gemstone/gemfire/cache/Cache.java  |   27 -
 .../gemfire/cache/DiskStoreFactory.java         |   15 +-
 .../gemfire/cache/DynamicRegionFactory.java     |  121 +-
 .../gemstone/gemfire/cache/EvictionAction.java  |    3 +-
 .../gemfire/cache/EvictionAlgorithm.java        |    3 +-
 .../gemstone/gemfire/cache/RegionService.java   |    2 +-
 .../cache/client/ClientCacheFactory.java        |   18 +-
 .../gemfire/cache/client/PoolFactory.java       |   28 +-
 .../cache/client/internal/AbstractOp.java       |    2 +-
 .../cache/client/internal/BridgePoolImpl.java   |  479 -----
 .../internal/BridgeServerLoadMessage.java       |   99 -
 .../client/internal/CacheServerLoadMessage.java |   99 +
 .../client/internal/ConnectionFactoryImpl.java  |    7 +-
 .../cache/client/internal/ConnectionImpl.java   |    6 +-
 .../cache/client/internal/DestroyOp.java        |    5 -
 .../client/internal/EndpointManagerImpl.java    |    8 +-
 .../internal/ExplicitConnectionSourceImpl.java  |   85 +-
 .../gemfire/cache/client/internal/GetOp.java    |    5 -
 .../gemfire/cache/client/internal/PoolImpl.java |   14 +-
 .../gemfire/cache/client/internal/PutOp.java    |    5 -
 .../cache/client/internal/QueueManagerImpl.java |   14 +-
 .../cache/client/internal/QueueStateImpl.java   |    6 +-
 .../internal/RegisterDataSerializersOp.java     |    8 +-
 .../internal/RegisterInstantiatorsOp.java       |    8 +-
 .../client/internal/ServerRegionProxy.java      |   44 +-
 .../internal/FunctionServiceManager.java        |    3 +-
 .../cache/hdfs/HDFSEventQueueAttributes.java    |   72 -
 .../hdfs/HDFSEventQueueAttributesFactory.java   |  160 --
 .../gemstone/gemfire/cache/hdfs/HDFSStore.java  |  381 +++-
 .../gemfire/cache/hdfs/HDFSStoreFactory.java    |  271 +--
 .../gemfire/cache/hdfs/HDFSStoreMutator.java    |  315 ++-
 .../internal/HDFSEventQueueAttributesImpl.java  |  179 --
 .../hdfs/internal/HDFSIntegrationUtil.java      |  121 +-
 .../hdfs/internal/HDFSStoreConfigHolder.java    |  658 +++---
 .../cache/hdfs/internal/HDFSStoreCreation.java  |  189 +-
 .../hdfs/internal/HDFSStoreFactoryImpl.java     |    2 +
 .../cache/hdfs/internal/HDFSStoreImpl.java      |   87 +-
 .../hdfs/internal/HDFSStoreMutatorImpl.java     |  279 +--
 .../SizeTieredHdfsCompactionConfigHolder.java   |   74 -
 .../internal/hoplog/HDFSCompactionManager.java  |   27 +-
 .../hoplog/HDFSUnsortedHoplogOrganizer.java     |   10 +-
 .../hoplog/HdfsSortedOplogOrganizer.java        |   22 +-
 .../cache/operations/GetOperationContext.java   |    7 +-
 .../operations/KeyValueOperationContext.java    |   70 +-
 .../internal/GetOperationContextImpl.java       |   16 +-
 .../cache/query/internal/CompiledSelect.java    |   39 +-
 .../cache/query/internal/DefaultQuery.java      |    9 +-
 .../cache/query/internal/RuntimeIterator.java   |    3 -
 .../query/internal/index/AbstractIndex.java     |    4 +-
 .../query/internal/index/AbstractMapIndex.java  |    6 +-
 .../internal/index/CompactMapRangeIndex.java    |    7 +-
 .../index/FunctionalIndexCreationHelper.java    |    1 -
 .../cache/query/internal/index/HashIndex.java   |   11 +
 .../query/internal/index/PartitionedIndex.java  |   16 +-
 .../gemfire/cache/server/ServerLoadProbe.java   |   10 +-
 .../gemfire/cache/server/ServerMetrics.java     |   10 +-
 .../cache/server/internal/LoadMonitor.java      |   12 +-
 .../gemfire/cache/util/BridgeClient.java        |  156 --
 .../gemfire/cache/util/BridgeLoader.java        |  607 ------
 .../gemfire/cache/util/BridgeMembership.java    |   55 -
 .../cache/util/BridgeMembershipEvent.java       |   23 -
 .../cache/util/BridgeMembershipListener.java    |   41 -
 .../util/BridgeMembershipListenerAdapter.java   |   43 -
 .../gemfire/cache/util/BridgeServer.java        |  442 ----
 .../gemfire/cache/util/BridgeWriter.java        |  795 -------
 .../cache/util/BridgeWriterException.java       |   48 -
 .../util/EndpointDoesNotExistException.java     |   34 -
 .../gemfire/cache/util/EndpointException.java   |   61 -
 .../cache/util/EndpointExistsException.java     |   28 -
 .../cache/util/EndpointInUseException.java      |   27 -
 .../util/IncompatibleVersionException.java      |   47 -
 .../util/ServerRefusedConnectionException.java  |   36 -
 .../UniversalMembershipListenerAdapter.java     |  352 ---
 .../cache/util/UnknownVersionException.java     |   39 -
 .../gemfire/cache/util/VersionException.java    |   45 -
 .../gemstone/gemfire/cache/util/package.html    |    3 -
 .../gemfire/distributed/DistributedSystem.java  |   44 +-
 .../gemfire/distributed/ServerLauncher.java     |    4 +-
 .../internal/AbstractDistributionConfig.java    |   21 +-
 .../internal/DistributionConfig.java            |   12 +
 .../internal/DistributionConfigImpl.java        |   15 +-
 .../FunctionExecutionPooledExecutor.java        |    7 +-
 .../internal/InternalDistributedSystem.java     |   12 +-
 .../internal/PooledExecutorWithDMStats.java     |    7 +-
 .../distributed/internal/ServerLocator.java     |   10 +-
 .../jgroup/JGroupMembershipManager.java         |    8 +-
 .../gemstone/gemfire/internal/DSFIDFactory.java |   12 +-
 .../internal/DataSerializableFixedID.java       |    6 +-
 .../internal/InternalDataSerializer.java        |   33 +-
 .../gemstone/gemfire/internal/NanoTimer.java    |   37 +-
 .../gemfire/internal/SharedLibrary.java         |   20 +-
 .../gemstone/gemfire/internal/SocketCloser.java |  241 +++
 .../gemfire/internal/SocketCreator.java         |   98 -
 .../internal/admin/ClientStatsManager.java      |    7 -
 .../gemfire/internal/admin/GemFireVM.java       |    2 +-
 .../admin/remote/BridgeServerResponse.java      |   18 +-
 .../admin/remote/DurableClientInfoResponse.java |    4 +-
 .../admin/remote/RemoteBridgeServer.java        |   10 +-
 .../internal/admin/remote/RemoteCacheInfo.java  |    6 +-
 .../internal/admin/remote/RemoteGemFireVM.java  |    2 +-
 .../internal/cache/AbstractBridgeServer.java    |  425 ----
 .../internal/cache/AbstractCacheServer.java     |  398 ++++
 .../gemfire/internal/cache/AbstractRegion.java  |   54 +-
 .../internal/cache/AbstractRegionEntry.java     |    2 +-
 .../gemfire/internal/cache/BridgeObserver.java  |   89 -
 .../internal/cache/BridgeObserverAdapter.java   |  107 -
 .../internal/cache/BridgeObserverHolder.java    |   53 -
 .../internal/cache/BridgeRegionEventImpl.java   |  108 -
 .../internal/cache/BridgeServerAdvisor.java     |  165 --
 .../internal/cache/BridgeServerImpl.java        |  816 -------
 .../gemfire/internal/cache/BucketAdvisor.java   |    2 +-
 .../gemfire/internal/cache/BucketRegion.java    |   10 +
 .../gemfire/internal/cache/CacheConfig.java     |   12 +-
 .../internal/cache/CacheServerAdvisor.java      |  164 ++
 .../gemfire/internal/cache/CacheServerImpl.java |  812 +++++++
 .../internal/cache/ClientRegionEventImpl.java   |  108 +
 .../internal/cache/ClientServerObserver.java    |   90 +
 .../cache/ClientServerObserverAdapter.java      |  107 +
 .../cache/ClientServerObserverHolder.java       |   53 +
 .../internal/cache/DestroyRegionOperation.java  |    6 +-
 .../gemfire/internal/cache/DiskEntry.java       |   29 +-
 .../gemfire/internal/cache/DiskRegion.java      |    9 +
 .../gemfire/internal/cache/DiskRegionStats.java |   22 +
 .../cache/DistTXAdjunctCommitMessage.java       |   35 +
 .../internal/cache/DistTXCommitMessage.java     |   12 +-
 .../gemfire/internal/cache/DistTXState.java     |   77 +-
 .../DistTXStateProxyImplOnCoordinator.java      |   28 +-
 .../cache/DistributedCacheOperation.java        |   10 +-
 .../cache/DistributedClearOperation.java        |    6 +-
 .../internal/cache/DistributedRegion.java       |    6 -
 .../gemfire/internal/cache/EntryEventImpl.java  |   10 +-
 .../gemfire/internal/cache/ExpiryTask.java      |   46 +-
 .../cache/FindDurableQueueProcessor.java        |    4 +-
 .../internal/cache/GemFireCacheImpl.java        |  101 +-
 .../gemfire/internal/cache/GridAdvisor.java     |    6 +-
 .../gemfire/internal/cache/LocalRegion.java     |   80 +-
 .../cache/MinimumSystemRequirements.java        |    4 +-
 .../internal/cache/PartitionedRegion.java       |   19 +-
 .../internal/cache/PartitionedRegionStats.java  |   12 +-
 .../gemfire/internal/cache/PoolFactoryImpl.java |  174 +-
 .../gemfire/internal/cache/PoolManagerImpl.java |   19 -
 .../gemfire/internal/cache/RegionEventImpl.java |    2 +-
 .../internal/cache/RegionIdleExpiryTask.java    |    5 +-
 .../internal/cache/RegionTTLExpiryTask.java     |    2 +-
 .../internal/cache/RemoteOperationMessage.java  |    2 +
 .../internal/cache/RemotePutMessage.java        |   56 +-
 .../gemfire/internal/cache/TXCommitMessage.java |  109 +-
 .../gemfire/internal/cache/TXEntryState.java    |   19 +-
 .../gemfire/internal/cache/TXManagerImpl.java   |   11 +-
 .../gemfire/internal/cache/TXRegionState.java   |   50 +-
 .../cache/control/HeapMemoryMonitor.java        |   14 +-
 .../cache/control/InternalResourceManager.java  |   15 +-
 .../internal/cache/control/MemoryEvent.java     |    9 +-
 .../cache/control/OffHeapMemoryMonitor.java     |   88 +-
 .../control/PartitionRebalanceDetailsImpl.java  |    8 +-
 .../cache/control/RebalanceOperationImpl.java   |  157 +-
 .../cache/control/RebalanceResultsImpl.java     |   16 +-
 .../cache/control/ResourceManagerStats.java     |   13 +
 .../internal/cache/doc-files/properties.html    |    4 +-
 .../cache/execute/InternalFunctionService.java  |    4 +-
 .../internal/cache/ha/HARegionQueue.java        |    6 +-
 .../internal/cache/partitioned/GetMessage.java  |    6 +
 .../cache/partitioned/PartitionMessage.java     |    4 +-
 .../PartitionedRegionObserverHolder.java        |    2 +-
 .../PartitionedRegionRebalanceOp.java           |  100 +-
 .../cache/partitioned/PutAllPRMessage.java      |   37 +
 .../internal/cache/partitioned/PutMessage.java  |   21 +-
 .../partitioned/rebalance/BucketOperator.java   |   46 +-
 .../rebalance/ParallelBucketOperator.java       |  151 ++
 .../rebalance/PartitionedRegionLoadModel.java   |   45 +-
 .../rebalance/SatisfyRedundancy.java            |    7 +-
 .../rebalance/SatisfyRedundancyFPR.java         |    1 +
 .../rebalance/SimulatedBucketOperator.java      |   11 +-
 .../internal/cache/tier/ConnectionProxy.java    |  160 +-
 .../cache/tier/InternalBridgeMembership.java    |  715 ------
 .../cache/tier/InternalClientMembership.java    |  617 ++++++
 .../cache/tier/sockets/AcceptorImpl.java        |   20 +-
 .../cache/tier/sockets/CacheClientNotifier.java |   26 +-
 .../cache/tier/sockets/CacheClientProxy.java    |   38 +-
 .../cache/tier/sockets/CacheClientUpdater.java  |   12 +-
 .../tier/sockets/ClientBlacklistProcessor.java  |    4 +-
 .../RemoveClientFromBlacklistMessage.java       |    4 +-
 .../cache/tier/sockets/ServerConnection.java    |    8 +-
 .../doc-files/communication-architecture.fig    |    4 +-
 .../internal/cache/tx/DistTxEntryEvent.java     |   70 +-
 .../AbstractGatewaySenderEventProcessor.java    |    1 +
 .../cache/wan/GatewaySenderAdvisor.java         |    1 -
 .../parallel/ParallelGatewaySenderQueue.java    |   41 +-
 .../wan/serial/SerialGatewaySenderQueue.java    |    2 +
 .../cache/xmlcache/BridgeServerCreation.java    |  249 ---
 .../internal/cache/xmlcache/CacheCreation.java  |   49 +-
 .../cache/xmlcache/CacheServerCreation.java     |  238 ++
 .../cache/xmlcache/CacheXmlGenerator.java       |   41 +-
 .../internal/cache/xmlcache/CacheXmlParser.java |  152 +-
 .../cache/xmlcache/ClientCacheCreation.java     |    5 -
 .../xmlcache/RegionAttributesCreation.java      |    9 -
 .../gemfire/internal/i18n/LocalizedStrings.java |   22 +-
 .../internal/i18n/ParentLocalizedStrings.java   |   81 +-
 .../gemfire/internal/lang/StringUtils.java      |  364 +++-
 .../gemfire/internal/lang/SystemUtils.java      |   35 +-
 .../gemfire/internal/logging/LogService.java    |   56 +-
 .../internal/logging/log4j/Configurator.java    |   73 +-
 .../internal/logging/log4j/FastLogger.java      |   50 +-
 .../offheap/OffHeapCachedDeserializable.java    |   27 +-
 .../offheap/SimpleMemoryAllocatorImpl.java      |   46 +-
 .../gemfire/internal/offheap/StoredObject.java  |   26 +-
 .../internal/redis/ByteArrayWrapper.java        |   11 +-
 .../internal/redis/ByteToCommandDecoder.java    |   57 +-
 .../gemstone/gemfire/internal/redis/Coder.java  |  228 +-
 .../gemfire/internal/redis/Command.java         |   25 +-
 .../gemfire/internal/redis/DoubleWrapper.java   |   14 +-
 .../internal/redis/ExecutionHandlerContext.java |  202 +-
 .../gemfire/internal/redis/Executor.java        |    2 +-
 .../gemfire/internal/redis/Extendable.java      |    6 +-
 .../internal/redis/RedisCommandType.java        |   21 +
 .../gemfire/internal/redis/RedisConstants.java  |    6 +-
 .../gemfire/internal/redis/RedisDataType.java   |    9 -
 .../gemfire/internal/redis/RegionCache.java     |  410 ----
 .../internal/redis/RegionCreationException.java |    9 +-
 .../gemfire/internal/redis/RegionProvider.java  |  538 +++++
 .../redis/executor/AbstractExecutor.java        |   12 +-
 .../redis/executor/AbstractScanExecutor.java    |    2 +-
 .../internal/redis/executor/AuthExecutor.java   |   38 +
 .../internal/redis/executor/DBSizeExecutor.java |    2 +-
 .../internal/redis/executor/DelExecutor.java    |    2 +-
 .../internal/redis/executor/EchoExecutor.java   |    2 +-
 .../internal/redis/executor/ExistsExecutor.java |    2 +-
 .../redis/executor/ExpirationExecutor.java      |    6 +-
 .../redis/executor/ExpireAtExecutor.java        |    4 +-
 .../internal/redis/executor/ExpireExecutor.java |    4 +-
 .../redis/executor/FlushAllExecutor.java        |   15 +-
 .../internal/redis/executor/KeysExecutor.java   |    7 +-
 .../internal/redis/executor/ListQuery.java      |   12 +-
 .../redis/executor/PersistExecutor.java         |    2 +-
 .../internal/redis/executor/PingExecutor.java   |    2 +-
 .../internal/redis/executor/QuitExecutor.java   |    2 +-
 .../internal/redis/executor/ScanExecutor.java   |    4 +-
 .../internal/redis/executor/SortedSetQuery.java |   36 +-
 .../internal/redis/executor/TTLExecutor.java    |    4 +-
 .../internal/redis/executor/TypeExecutor.java   |    2 +-
 .../internal/redis/executor/UnkownExecutor.java |    2 +-
 .../redis/executor/hash/HDelExecutor.java       |    2 +-
 .../redis/executor/hash/HGetAllExecutor.java    |    7 +-
 .../redis/executor/hash/HKeysExecutor.java      |    7 +-
 .../redis/executor/hash/HScanExecutor.java      |    5 +-
 .../redis/executor/hash/HValsExecutor.java      |    9 +-
 .../redis/executor/hash/HashExecutor.java       |    4 +-
 .../redis/executor/hll/HllExecutor.java         |    2 +-
 .../redis/executor/hll/PFAddExecutor.java       |    2 +-
 .../redis/executor/hll/PFCountExecutor.java     |    2 +-
 .../redis/executor/hll/PFMergeExecutor.java     |    4 +-
 .../redis/executor/list/LIndexExecutor.java     |    4 +-
 .../redis/executor/list/LLenExecutor.java       |    2 +-
 .../redis/executor/list/LRangeExecutor.java     |   10 +-
 .../redis/executor/list/LRemExecutor.java       |    4 +-
 .../redis/executor/list/LSetExecutor.java       |    4 +-
 .../redis/executor/list/LTrimExecutor.java      |   26 +-
 .../redis/executor/list/ListExecutor.java       |   26 +-
 .../redis/executor/list/PopExecutor.java        |   23 +-
 .../redis/executor/list/PushExecutor.java       |    2 +-
 .../redis/executor/list/PushXExecutor.java      |    2 +-
 .../org/apache/hadoop/fs/GlobPattern.java       |  164 --
 .../redis/executor/set/SAddExecutor.java        |    2 +-
 .../redis/executor/set/SCardExecutor.java       |    2 +-
 .../redis/executor/set/SIsMemberExecutor.java   |    2 +-
 .../redis/executor/set/SMembersExecutor.java    |    7 +-
 .../redis/executor/set/SMoveExecutor.java       |    2 +-
 .../redis/executor/set/SPopExecutor.java        |    4 +-
 .../redis/executor/set/SRandMemberExecutor.java |    4 +-
 .../redis/executor/set/SRemExecutor.java        |    2 +-
 .../redis/executor/set/SScanExecutor.java       |    4 +-
 .../redis/executor/set/SetOpExecutor.java       |    9 +-
 .../executor/sortedset/SortedSetExecutor.java   |    4 +-
 .../executor/sortedset/ZRangeByLexExecutor.java |    2 -
 .../sortedset/ZRangeByScoreExecutor.java        |    3 +-
 .../redis/executor/sortedset/ZRemExecutor.java  |    2 +-
 .../sortedset/ZRemRangeByLexExecutor.java       |    3 +-
 .../sortedset/ZRemRangeByRankExecutor.java      |    4 +-
 .../sortedset/ZRemRangeByScoreExecutor.java     |    4 +-
 .../redis/executor/sortedset/ZScanExecutor.java |    5 +-
 .../redis/executor/string/AppendExecutor.java   |    2 +-
 .../redis/executor/string/BitCountExecutor.java |    2 +-
 .../redis/executor/string/BitOpExecutor.java    |    2 +-
 .../redis/executor/string/BitPosExecutor.java   |    2 +-
 .../redis/executor/string/DecrByExecutor.java   |    2 +-
 .../redis/executor/string/DecrExecutor.java     |    4 +-
 .../redis/executor/string/GetBitExecutor.java   |    2 +-
 .../redis/executor/string/GetExecutor.java      |    2 +-
 .../redis/executor/string/GetRangeExecutor.java |    2 +-
 .../redis/executor/string/GetSetExecutor.java   |    2 +-
 .../redis/executor/string/IncrByExecutor.java   |    2 +-
 .../executor/string/IncrByFloatExecutor.java    |    2 +-
 .../redis/executor/string/IncrExecutor.java     |    2 +-
 .../redis/executor/string/MGetExecutor.java     |    2 +-
 .../redis/executor/string/MSetExecutor.java     |    2 +-
 .../redis/executor/string/MSetNXExecutor.java   |    2 +-
 .../redis/executor/string/SetBitExecutor.java   |    2 +-
 .../redis/executor/string/SetEXExecutor.java    |    4 +-
 .../redis/executor/string/SetExecutor.java      |    4 +-
 .../redis/executor/string/SetNXExecutor.java    |    2 +-
 .../redis/executor/string/SetRangeExecutor.java |    4 +-
 .../redis/executor/string/StringExecutor.java   |    4 +-
 .../redis/executor/string/StrlenExecutor.java   |    2 +-
 .../redis/org/apache/hadoop/fs/GlobPattern.java |  164 ++
 .../size/ReflectionSingleObjectSizer.java       |    4 +-
 .../gemfire/internal/tcp/Connection.java        |  130 +-
 .../gemfire/internal/tcp/ConnectionTable.java   |   95 +-
 .../gemfire/internal/tcp/MsgOutputStream.java   |    4 +-
 .../gfsh/aggregator/AggregateFunction.java      |   67 -
 .../tools/gfsh/aggregator/AggregateResults.java |  126 --
 .../aggregator/AggregatorPartitionFunction.java |   54 -
 .../tools/gfsh/app/CommandExecutable.java       |    8 -
 .../gemfire/internal/tools/gfsh/app/Gfsh.java   | 2027 ------------------
 .../internal/tools/gfsh/app/GfshVersion.java    |  455 ----
 .../internal/tools/gfsh/app/Nextable.java       |    8 -
 .../tools/gfsh/app/ServerExecutable.java        |   11 -
 .../app/aggregator/AggregateFunctionTask.java   |   62 -
 .../tools/gfsh/app/aggregator/Aggregator.java   |  549 -----
 .../app/aggregator/AggregatorException.java     |   50 -
 .../gfsh/app/aggregator/AggregatorPeer.java     |  254 ---
 .../functions/util/LocalRegionInfoFunction.java |  235 --
 .../functions/util/RegionCreateFunction.java    |   81 -
 .../functions/util/RegionDestroyFunction.java   |   86 -
 .../tools/gfsh/app/cache/CacheBase.java         |  178 --
 .../gfsh/app/cache/InstantiatorClassLoader.java |  101 -
 .../tools/gfsh/app/cache/data/GenericMap.java   |  196 --
 .../gfsh/app/cache/data/GenericMessage.java     |  807 -------
 .../app/cache/data/InvalidTypeException.java    |   28 -
 .../tools/gfsh/app/cache/data/ListMap.java      |  197 --
 .../gfsh/app/cache/data/ListMapMessage.java     |  615 ------
 .../tools/gfsh/app/cache/data/ListMessage.java  |  594 -----
 .../tools/gfsh/app/cache/data/Listable.java     |   45 -
 .../tools/gfsh/app/cache/data/MapMessage.java   |  629 ------
 .../tools/gfsh/app/cache/data/Mappable.java     |   50 -
 .../tools/gfsh/app/cache/index/EntryMap.java    |   80 -
 .../tools/gfsh/app/cache/index/IndexInfo.java   |   52 -
 .../tools/gfsh/app/cache/index/Indexer.java     |   13 -
 .../gfsh/app/cache/index/IndexerManager.java    |   32 -
 .../gfsh/app/cache/index/LookupService.java     |  352 ---
 .../app/cache/index/LookupServiceException.java |   64 -
 .../gfsh/app/cache/index/task/ForceGCTask.java  |   32 -
 .../app/cache/index/task/IndexInfoTask.java     |  131 --
 .../app/cache/index/task/QuerySizeTask.java     |  134 --
 .../gfsh/app/cache/index/task/QueryTask.java    |  323 ---
 .../tools/gfsh/app/command/CommandClient.java   |  417 ----
 .../gfsh/app/command/CommandException.java      |   31 -
 .../app/command/CommandResultsListener.java     |   15 -
 .../tools/gfsh/app/command/task/EchoTask.java   |   63 -
 .../task/PartitionedRegionAttributeTask.java    |  205 --
 .../gfsh/app/command/task/QueryResults.java     |  123 --
 .../tools/gfsh/app/command/task/QueryTask.java  |  522 -----
 .../task/RefreshAggregatorRegionTask.java       |   53 -
 .../gfsh/app/command/task/RegionClearTask.java  |   85 -
 .../gfsh/app/command/task/RegionCreateTask.java |  162 --
 .../app/command/task/RegionDestroyTask.java     |   97 -
 .../gfsh/app/command/task/RegionPathTask.java   |  156 --
 .../gfsh/app/command/task/RegionSizeTask.java   |   70 -
 .../gfsh/app/command/task/data/MemberInfo.java  |   79 -
 .../task/data/PartitionAttributeInfo.java       |  124 --
 .../command/task/data/RegionAttributeInfo.java  |  286 ---
 .../internal/tools/gfsh/app/commands/bcp.java   |  527 -----
 .../internal/tools/gfsh/app/commands/cd.java    |   79 -
 .../tools/gfsh/app/commands/classloader.java    |  323 ---
 .../internal/tools/gfsh/app/commands/clear.java |  197 --
 .../tools/gfsh/app/commands/connect.java        |  124 --
 .../internal/tools/gfsh/app/commands/db.java    |  312 ---
 .../internal/tools/gfsh/app/commands/debug.java |   48 -
 .../tools/gfsh/app/commands/deploy.java         |  271 ---
 .../internal/tools/gfsh/app/commands/echo.java  |   59 -
 .../internal/tools/gfsh/app/commands/fetch.java |   48 -
 .../internal/tools/gfsh/app/commands/gc.java    |   93 -
 .../internal/tools/gfsh/app/commands/get.java   |  143 --
 .../internal/tools/gfsh/app/commands/help.java  |   40 -
 .../internal/tools/gfsh/app/commands/index.java |  395 ----
 .../internal/tools/gfsh/app/commands/key.java   |   67 -
 .../internal/tools/gfsh/app/commands/local.java |  101 -
 .../internal/tools/gfsh/app/commands/ls.java    |  584 -----
 .../internal/tools/gfsh/app/commands/mkdir.java |  253 ---
 .../internal/tools/gfsh/app/commands/next.java  |   63 -
 .../tools/gfsh/app/commands/optional/look.java  |  166 --
 .../tools/gfsh/app/commands/optional/perf.java  |  150 --
 .../internal/tools/gfsh/app/commands/pr.java    |  209 --
 .../tools/gfsh/app/commands/property.java       |   85 -
 .../internal/tools/gfsh/app/commands/put.java   |  490 -----
 .../internal/tools/gfsh/app/commands/pwd.java   |   37 -
 .../tools/gfsh/app/commands/rebalance.java      |  186 --
 .../tools/gfsh/app/commands/refresh.java        |   67 -
 .../internal/tools/gfsh/app/commands/rm.java    |  175 --
 .../internal/tools/gfsh/app/commands/rmdir.java |  249 ---
 .../tools/gfsh/app/commands/select.java         |  139 --
 .../internal/tools/gfsh/app/commands/show.java  |  240 ---
 .../internal/tools/gfsh/app/commands/size.java  |  281 ---
 .../internal/tools/gfsh/app/commands/value.java |   48 -
 .../internal/tools/gfsh/app/commands/which.java |  189 --
 .../internal/tools/gfsh/app/commands/zone.java  |   49 -
 .../tools/gfsh/app/function/GfshData.java       |   86 -
 .../tools/gfsh/app/function/GfshFunction.java   |  149 --
 .../tools/gfsh/app/function/command/clear.java  |   95 -
 .../tools/gfsh/app/function/command/deploy.java |  111 -
 .../tools/gfsh/app/function/command/gc.java     |   49 -
 .../tools/gfsh/app/function/command/index.java  |  199 --
 .../tools/gfsh/app/function/command/ls.java     |   80 -
 .../tools/gfsh/app/function/command/pr.java     |  118 -
 .../gfsh/app/function/command/rebalance.java    |  129 --
 .../tools/gfsh/app/function/command/rm.java     |   43 -
 .../tools/gfsh/app/function/command/which.java  |  159 --
 .../tools/gfsh/app/misc/util/ClassFinder.java   |  209 --
 .../gfsh/app/misc/util/DataSerializerEx.java    |   98 -
 .../app/misc/util/QueueDispatcherListener.java  |   11 -
 .../app/misc/util/QueueDispatcherThread.java    |   87 -
 .../gfsh/app/misc/util/ReflectionUtil.java      |  303 ---
 .../tools/gfsh/app/misc/util/StringUtil.java    |  142 --
 .../app/misc/util/SystemClassPathManager.java   |  171 --
 .../gfsh/app/pogo/InvalidKeyException.java      |   34 -
 .../internal/tools/gfsh/app/pogo/KeyType.java   |   96 -
 .../tools/gfsh/app/pogo/KeyTypeManager.java     |  199 --
 .../internal/tools/gfsh/app/pogo/MapLite.java   | 1136 ----------
 .../tools/gfsh/app/pogo/MapLiteSerializer.java  |  338 ---
 .../internal/tools/gfsh/app/util/DBUtil.java    | 1094 ----------
 .../tools/gfsh/app/util/DBUtilException.java    |   48 -
 .../tools/gfsh/app/util/GfshResultsBag.java     |  600 ------
 .../tools/gfsh/app/util/ObjectUtil.java         |  164 --
 .../tools/gfsh/app/util/OutputUtil.java         |  255 ---
 .../internal/tools/gfsh/app/util/PrintUtil.java | 1683 ---------------
 .../tools/gfsh/app/util/SimplePrintUtil.java    | 1366 ------------
 .../tools/gfsh/command/AbstractCommandTask.java |  136 --
 .../tools/gfsh/command/CommandResults.java      |  119 -
 .../tools/gfsh/command/CommandTask.java         |   23 -
 .../internal/tools/gfsh/util/RegionUtil.java    |  829 -------
 .../internal/beans/CacheServerBridge.java       |   20 +-
 .../beans/GatewayReceiverMBeanBridge.java       |    4 +-
 .../internal/beans/ManagementAdapter.java       |   42 +-
 .../internal/beans/MemberMBeanBridge.java       |   11 +-
 .../management/internal/beans/ServerBridge.java |    6 +-
 .../cli/commands/HDFSStoreCommands.java         |   81 +-
 .../cli/commands/LauncherLifecycleCommands.java |    5 +
 .../internal/cli/commands/QueueCommands.java    |    4 +-
 .../cli/functions/AlterHDFSStoreFunction.java   |   24 +-
 .../cli/functions/ContunuousQueryFunction.java  |    4 +-
 .../CreateAsyncEventQueueFunction.java          |    8 +-
 .../cli/functions/CreateHDFSStoreFunction.java  |   20 +-
 .../functions/GetMemberInformationFunction.java |    4 +-
 .../internal/cli/i18n/CliStrings.java           |    8 +-
 .../controllers/QueueCommandsController.java    |    6 +-
 .../web/controllers/WanCommandsController.java  |    2 +-
 .../management/membership/ClientMembership.java |    8 +-
 .../pdx/ReflectionBasedAutoSerializer.java      |    9 +
 .../pdx/internal/AutoSerializableManager.java   |    8 -
 .../gemfire/pdx/internal/TypeRegistry.java      |   19 +-
 .../gemfire/redis/GemFireRedisServer.java       |  155 +-
 .../util/concurrent/SynchronousQueueNoSpin.java | 1144 ----------
 .../gemfire/cache/cache-9.0.xsd                 |   26 -
 .../batterytest/greplogs/ExpectedStrings.java   |    4 +-
 .../com/gemstone/gemfire/TXExpiryJUnitTest.java |  505 +++--
 .../cache/AttributesFactoryJUnitTest.java       |   18 -
 .../gemfire/cache/Bug52289JUnitTest.java        |   81 +
 .../gemstone/gemfire/cache/ClientHelper.java    |    1 -
 .../cache/ClientServerTimeSyncDUnitTest.java    |    9 +-
 .../cache/ConnectionPoolAndLoaderDUnitTest.java |    4 +-
 .../gemfire/cache/RegionFactoryJUnitTest.java   |   19 +-
 .../internal/AutoConnectionSourceDUnitTest.java |   23 +-
 .../AutoConnectionSourceWithUDPDUnitTest.java   |    4 +-
 .../internal/ConnectionPoolImplJUnitTest.java   |   11 +-
 .../internal/LocatorLoadBalancingDUnitTest.java |   10 +-
 .../cache/client/internal/LocatorTestBase.java  |   12 +-
 .../ColocatedRegionWithHDFSDUnitTest.java       |   20 +-
 .../hdfs/internal/HDFSConfigJUnitTest.java      |  146 +-
 .../internal/HdfsStoreMutatorJUnitTest.java     |  147 +-
 .../hdfs/internal/RegionRecoveryDUnitTest.java  |  415 ++++
 .../internal/RegionWithHDFSBasicDUnitTest.java  | 1594 ++++++++++++++
 .../RegionWithHDFSOffHeapBasicDUnitTest.java    |  114 +
 ...RegionWithHDFSPersistenceBasicDUnitTest.java |   77 +
 .../hdfs/internal/RegionWithHDFSTestBase.java   |   44 +-
 .../internal/hoplog/BaseHoplogTestCase.java     |    7 +-
 .../hoplog/HDFSCacheLoaderJUnitTest.java        |    4 +-
 .../hoplog/HDFSCompactionManagerJUnitTest.java  |    8 +-
 .../HDFSUnsortedHoplogOrganizerJUnitTest.java   |    2 +-
 .../HdfsSortedOplogOrganizerJUnitTest.java      |   10 +-
 .../hoplog/TieredCompactionJUnitTest.java       |   25 +-
 .../hoplog/mapreduce/HoplogUtilJUnitTest.java   |    7 +-
 .../management/MemoryThresholdsDUnitTest.java   |    4 +-
 .../MemoryThresholdsOffHeapDUnitTest.java       |   94 +-
 .../PutOperationContextJUnitTest.java           |  248 +++
 .../GetOperationContextImplJUnitTest.java       |  275 +++
 .../gemfire/cache/query/QueryJUnitTest.java     |   91 +
 .../query/dunit/CloseCacheAuthorization.java    |    2 -
 .../query/dunit/PdxStringQueryDUnitTest.java    |   16 +-
 .../query/dunit/QueryUsingPoolDUnitTest.java    |   12 +-
 .../cache/query/dunit/RemoteQueryDUnitTest.java |   90 +-
 ...esourceManagerWithQueryMonitorDUnitTest.java |    4 +-
 .../cache/query/functional/GroupByTestImpl.java |    2 +-
 .../query/functional/StructSetOrResultsSet.java |  260 +--
 ...rrentIndexInitOnOverflowRegionDUnitTest.java |    4 +-
 .../index/CopyOnReadIndexDUnitTest.java         |   68 +-
 .../index/CopyOnReadIndexJUnitTest.java         |    5 +-
 .../internal/index/HashIndexJUnitTest.java      |   20 +-
 .../query/internal/index/IndexUseJUnitTest.java |   52 +
 .../MapRangeIndexMaintenanceJUnitTest.java      |   50 +
 .../internal/index/RangeIndexAPIJUnitTest.java  |   32 +-
 .../query/partitioned/PRQueryDUnitTest.java     |    8 +-
 .../query/partitioned/PRQueryJUnitTest.java     |   30 +
 .../cache30/BridgeMembershipDUnitTest.java      | 1597 --------------
 .../BridgeMembershipSelectorDUnitTest.java      |   16 -
 .../gemfire/cache30/BridgeTestCase.java         |  376 ----
 .../gemfire/cache30/BridgeWriterDUnitTest.java  |  418 ----
 .../cache30/BridgeWriterSelectorDUnitTest.java  |   16 -
 .../gemfire/cache30/Bug38741DUnitTest.java      |   10 +-
 .../gemfire/cache30/CacheLoaderTestCase.java    |    2 +-
 .../gemstone/gemfire/cache30/CacheTestCase.java |   27 +-
 .../gemfire/cache30/CacheXml30DUnitTest.java    |  127 --
 .../gemfire/cache30/CacheXml40DUnitTest.java    |    8 +-
 .../gemfire/cache30/CacheXml41DUnitTest.java    |   28 +-
 .../gemfire/cache30/CacheXml45DUnitTest.java    |    4 +-
 .../gemfire/cache30/CacheXml51DUnitTest.java    |    8 +-
 .../gemfire/cache30/CacheXml57DUnitTest.java    |    1 -
 .../cache30/ClientMembershipDUnitTest.java      | 1642 ++++++++++++++
 .../ClientMembershipSelectorDUnitTest.java      |   16 +
 .../ClientRegisterInterestDUnitTest.java        |  418 ++++
 ...ClientRegisterInterestSelectorDUnitTest.java |   16 +
 .../gemfire/cache30/ClientServerTestCase.java   |  376 ++++
 .../DistributedNoAckRegionDUnitTest.java        |   14 +
 .../gemfire/cache30/MultiVMRegionTestCase.java  |  376 ++--
 .../PartitionedRegionCompressionDUnitTest.java  |    4 -
 .../gemfire/cache30/RegionTestCase.java         |  944 ++++----
 .../gemfire/cache30/TestCacheCallback.java      |   13 +-
 .../AbstractServerLauncherJUnitTestCase.java    |    4 +-
 .../LocatorLauncherRemoteFileJUnitTest.java     |    8 +-
 .../LocatorLauncherRemoteJUnitTest.java         |   57 +-
 .../ServerLauncherLocalJUnitTest.java           |   51 +-
 .../ServerLauncherRemoteFileJUnitTest.java      |    2 -
 .../ServerLauncherRemoteJUnitTest.java          |   10 +-
 .../ServerLauncherWithSpringJUnitTest.java      |    5 +
 .../internal/ProductUseLogDUnitTest.java        |    2 +-
 .../gemfire/disttx/CacheMapDistTXDUnitTest.java |    9 +-
 .../gemfire/disttx/DistTXDebugDUnitTest.java    |    8 +-
 .../disttx/DistTXDistributedTestSuite.java      |    5 +-
 .../gemfire/disttx/DistTXOrderDUnitTest.java    |   13 +-
 .../disttx/DistTXPersistentDebugDUnitTest.java  |    4 -
 .../disttx/DistTXRestrictionsDUnitTest.java     |    1 -
 .../disttx/DistTXWithDeltaDUnitTest.java        |   22 +
 .../disttx/DistributedTransactionDUnitTest.java |  814 ++++++-
 .../gemfire/disttx/PRDistTXDUnitTest.java       |   49 +
 .../disttx/PRDistTXWithVersionsDUnitTest.java   |   50 +
 .../gemstone/gemfire/internal/FDDUnitTest.java  |   12 +-
 .../gemfire/internal/NanoTimer2JUnitTest.java   |   79 -
 .../gemfire/internal/NanoTimerJUnitTest.java    |  121 +-
 .../gemfire/internal/SocketCloserJUnitTest.java |  180 ++
 .../internal/SocketCloserWithWaitJUnitTest.java |   22 +
 .../internal/cache/Bug34011JUnitTest.java       |  199 --
 .../internal/cache/Bug39079DUnitTest.java       |    6 +-
 .../internal/cache/Bug41957DUnitTest.java       |    6 +-
 .../cache/ChunkValueWrapperJUnitTest.java       |    2 +-
 ...ssagesRegionCreationAndDestroyJUnitTest.java |   10 +-
 .../cache/ClientServerGetAllDUnitTest.java      |   41 +-
 .../cache/ClientServerTransactionDUnitTest.java |  195 +-
 .../cache/ConcurrentMapOpsDUnitTest.java        |   75 +-
 .../ConcurrentRegionOperationsJUnitTest.java    |    7 +-
 .../cache/DeltaPropagationDUnitTest.java        |    8 +-
 .../cache/DeltaPropagationStatsDUnitTest.java   |    2 +-
 .../internal/cache/DiskRegionJUnitTest.java     |   39 +-
 .../internal/cache/EventTrackerDUnitTest.java   |    8 +-
 .../internal/cache/GridAdvisorDUnitTest.java    |  106 +-
 .../internal/cache/HABug36773DUnitTest.java     |    8 +-
 .../HAOverflowMemObjectSizerDUnitTest.java      |   12 +-
 .../cache/HDFSRegionOperationsJUnitTest.java    |    5 +-
 .../cache/OldValueImporterTestBase.java         |  165 ++
 .../PartitionedRegionSingleHopDUnitTest.java    |    4 -
 .../cache/PartitionedRegionStatsJUnitTest.java  |  320 ++-
 .../cache/PartitionedRegionTestHelper.java      |    3 +-
 .../cache/RemotePutReplyMessageJUnitTest.java   |   37 +
 .../cache/RemoteTransactionDUnitTest.java       |  181 +-
 .../control/RebalanceOperationDUnitTest.java    |  468 +++-
 .../cache/execute/Bug51193DUnitTest.java        |    4 +-
 .../execute/SingleHopGetAllPutAllDUnitTest.java |   18 +-
 .../internal/cache/functions/TestFunction.java  |   10 +-
 .../cache/ha/Bug36853EventsExpiryDUnitTest.java |    9 +-
 .../internal/cache/ha/Bug48571DUnitTest.java    |    2 +-
 .../cache/ha/EventIdOptimizationDUnitTest.java  |   12 +-
 .../internal/cache/ha/FailoverDUnitTest.java    |   22 +-
 .../internal/cache/ha/HABugInPutDUnitTest.java  |    8 +-
 .../internal/cache/ha/HAClearDUnitTest.java     |   10 +-
 .../cache/ha/HAConflationDUnitTest.java         |    8 +-
 .../internal/cache/ha/HADuplicateDUnitTest.java |   10 +-
 .../cache/ha/HAEventIdPropagationDUnitTest.java |   10 +-
 .../internal/cache/ha/HAGIIDUnitTest.java       |   14 +-
 .../cache/ha/HARQueueNewImplDUnitTest.java      |   66 +-
 .../cache/ha/HASlowReceiverDUnitTest.java       |   10 +-
 .../ha/OperationsPropagationDUnitTest.java      |    8 +-
 .../internal/cache/ha/PutAllDUnitTest.java      |   12 +-
 .../cache/ha/StatsBugDUnitDisabledTest.java     |   14 +-
 .../cache/partitioned/Bug43684DUnitTest.java    |    4 +-
 .../PartitionedRegionLoadModelJUnitTest.java    |   97 +-
 ...tentColocatedPartitionedRegionDUnitTest.java |    2 +-
 .../PutPutReplyMessageJUnitTest.java            |   38 +
 .../fixed/FixedPartitioningTestBase.java        |    6 +-
 .../tier/sockets/AcceptorImplJUnitTest.java     |   62 +-
 ...rdCompatibilityCommandDUnitDisabledTest.java |  235 --
 ...CompatibilityHandshakeDUnitDisabledTest.java |  218 --
 ...mpatibilityHigherVersionClientDUnitTest.java |    4 +-
 ...rdCompatibilityMessageDUnitDisabledTest.java |  299 ---
 .../BridgeServerMaxConnectionsJUnitTest.java    |  221 --
 ...geServerSelectorMaxConnectionsJUnitTest.java |   19 -
 .../tier/sockets/BridgeWriterMiscDUnitTest.java | 1384 ------------
 .../BridgeWriterMiscSelectorDUnitTest.java      |   27 -
 .../cache/tier/sockets/Bug36269DUnitTest.java   |    4 +-
 .../cache/tier/sockets/Bug36457DUnitTest.java   |   18 +-
 .../cache/tier/sockets/Bug36805DUnitTest.java   |    6 +-
 .../cache/tier/sockets/Bug36995DUnitTest.java   |   11 +-
 .../cache/tier/sockets/Bug37210DUnitTest.java   |   10 +-
 .../CacheServerMaxConnectionsJUnitTest.java     |  220 ++
 ...heServerSelectorMaxConnectionsJUnitTest.java |   19 +
 .../cache/tier/sockets/CacheServerTestUtil.java |   51 +-
 .../CacheServerTransactionsDUnitTest.java       |    4 +-
 .../tier/sockets/ClearPropagationDUnitTest.java |    4 +-
 .../tier/sockets/ClientConflationDUnitTest.java |   20 +-
 .../sockets/ClientHealthMonitorJUnitTest.java   |    6 +-
 .../sockets/ClientInterestNotifyDUnitTest.java  |   14 +-
 .../tier/sockets/ClientServerMiscDUnitTest.java | 1381 ++++++++++++
 .../ClientServerMiscSelectorDUnitTest.java      |   27 +
 .../cache/tier/sockets/ConflationDUnitTest.java |   24 +-
 .../tier/sockets/ConnectionProxyJUnitTest.java  |  257 +--
 .../DataSerializerPropogationDUnitTest.java     |   36 +-
 .../DestroyEntryPropagationDUnitTest.java       |   12 +-
 .../DurableClientReconnectDUnitTest.java        |   10 +-
 .../sockets/DurableClientStatsDUnitTest.java    |   10 +-
 .../sockets/DurableRegistrationDUnitTest.java   |    8 +-
 .../sockets/DurableResponseMatrixDUnitTest.java |   10 +-
 .../sockets/EventIDVerificationDUnitTest.java   |   10 +-
 .../ForceInvalidateEvictionDUnitTest.java       |   10 +-
 .../cache/tier/sockets/HAInterestBaseTest.java  | 1447 ++++++-------
 .../sockets/HAInterestDistributedTestCase.java  |   15 +
 .../tier/sockets/HAInterestPart1DUnitTest.java  |  210 +-
 .../tier/sockets/HAInterestPart2DUnitTest.java  |  514 +++--
 .../sockets/HAStartupAndFailoverDUnitTest.java  |   81 +-
 .../tier/sockets/InterestListDUnitTest.java     |    4 +-
 .../sockets/InterestListEndpointDUnitTest.java  |   18 +-
 .../sockets/InterestListFailoverDUnitTest.java  |    6 +-
 .../sockets/InterestListRecoveryDUnitTest.java  |   10 +-
 .../sockets/InterestResultPolicyDUnitTest.java  |    4 +-
 .../tier/sockets/RedundancyLevelJUnitTest.java  |   14 +-
 .../sockets/RedundancyLevelPart1DUnitTest.java  |    4 +-
 .../sockets/RedundancyLevelPart3DUnitTest.java  |    6 +-
 .../tier/sockets/RedundancyLevelTestBase.java   |   51 +-
 .../tier/sockets/RegionCloseDUnitTest.java      |   14 +-
 ...erInterestBeforeRegionCreationDUnitTest.java |    6 +-
 .../sockets/RegisterInterestKeysDUnitTest.java  |    4 +-
 .../sockets/ReliableMessagingDUnitTest.java     |   24 +-
 .../internal/cache/tier/sockets/TestPut.java    |   53 -
 .../sockets/UpdatePropagationDUnitTest.java     |   10 +-
 ...UpdatesFromNonInterestEndPointDUnitTest.java |    4 +-
 .../compression/SnappyCompressorJUnitTest.java  |    2 +-
 .../internal/lang/StringUtilsJUnitTest.java     |   33 +
 .../DistributedSystemLogFileJUnitTest.java      |   20 +-
 .../logging/LogServiceIntegrationJUnitTest.java |  209 ++
 .../LogServiceIntegrationTestSupport.java       |   24 +
 .../internal/logging/LogServiceJUnitTest.java   |  190 +-
 .../LogServiceUserDirIntegrationJUnitTest.java  |   70 +
 .../logging/LoggingIntegrationTestSuite.java    |   15 +
 .../internal/logging/LoggingUnitTestSuite.java  |   13 +
 .../log4j/FastLoggerIntegrationJUnitTest.java   |  557 +++++
 .../logging/log4j/FastLoggerJUnitTest.java      |  274 +--
 .../FastLoggerWithDefaultConfigJUnitTest.java   |   74 +
 .../log4j/Log4jIntegrationTestSuite.java        |   12 +
 .../logging/log4j/Log4jUnitTestSuite.java       |   16 +
 .../offheap/OffHeapValidationJUnitTest.java     |   45 +-
 .../OffHeapWriteObjectAsByteArrayJUnitTest.java |  101 +
 .../internal/size/ObjectSizerJUnitTest.java     |   14 +-
 ...ersalMembershipListenerAdapterDUnitTest.java |   32 +-
 .../commands/HDFSStoreCommandsJUnitTest.java    |  124 +-
 .../AlterHDFSStoreFunctionJUnitTest.java        |  146 +-
 .../CreateHDFSStoreFunctionJUnitTest.java       |  156 +-
 .../DescribeHDFSStoreFunctionJUnitTest.java     |   98 +-
 .../WanCommandsControllerJUnitTest.java         |  124 ++
 .../gemfire/pdx/AutoSerializableJUnitTest.java  |    2 +-
 .../gemfire/pdx/ByteSourceJUnitTest.java        |    4 +-
 .../pdx/PdxFormatterPutGetJUnitTest.java        |    4 +-
 .../gemstone/gemfire/redis/AuthJUnitTest.java   |  144 ++
 .../gemfire/redis/ConcurrentStartTest.java      |   58 +
 .../gemstone/gemfire/redis/HashesJUnitTest.java |  175 ++
 .../gemstone/gemfire/redis/ListsJUnitTest.java  |  238 ++
 .../gemfire/redis/RedisDistDUnitTest.java       |  234 ++
 .../gemstone/gemfire/redis/SetsJUnitTest.java   |  242 +++
 .../gemfire/redis/SortedSetsJUnitTest.java      |  414 ++++
 .../gemfire/redis/StringsJunitTest.java         |  296 +++
 .../gemfire/test/golden/ExecutableProcess.java  |    8 +
 .../gemfire/test/golden/FailOutputTestCase.java |   22 +-
 .../golden/FailWithErrorInOutputJUnitTest.java  |   18 +-
 .../FailWithExtraLineInOutputJUnitTest.java     |   41 +-
 ...WithLineMissingFromEndOfOutputJUnitTest.java |   39 +-
 ...hLineMissingFromMiddleOfOutputJUnitTest.java |   39 +-
 .../FailWithLoggerErrorInOutputJUnitTest.java   |   18 +-
 .../FailWithLoggerFatalInOutputJUnitTest.java   |   18 +-
 .../FailWithLoggerWarnInOutputJUnitTest.java    |   18 +-
 .../golden/FailWithProblemInOutputTestCase.java |   30 +-
 .../golden/FailWithSevereInOutputJUnitTest.java |   18 +-
 ...hTimeoutOfWaitForOutputToMatchJUnitTest.java |   42 +-
 .../FailWithWarningInOutputJUnitTest.java       |   18 +-
 .../gemfire/test/golden/GoldenComparator.java   |   64 +-
 .../test/golden/GoldenStringComparator.java     |    5 +-
 .../gemfire/test/golden/GoldenTestCase.java     |  108 +-
 .../golden/GoldenTestFrameworkTestSuite.java    |   27 +
 .../gemfire/test/golden/PassJUnitTest.java      |   50 +-
 .../golden/PassWithExpectedErrorJUnitTest.java  |   18 +-
 .../golden/PassWithExpectedProblemTestCase.java |   58 +-
 .../golden/PassWithExpectedSevereJUnitTest.java |   18 +-
 .../PassWithExpectedWarningJUnitTest.java       |   18 +-
 .../test/golden/RegexGoldenComparator.java      |   10 +-
 .../test/golden/StringGoldenComparator.java     |    4 +-
 .../process/ProcessTestFrameworkTestSuite.java  |   12 +
 .../gemfire/test/process/ProcessWrapper.java    |  251 ++-
 .../test/process/ProcessWrapperJUnitTest.java   |   19 +-
 .../test/java/dunit/DistributedTestCase.java    |   88 +-
 .../java/dunit/standalone/DUnitLauncher.java    |    8 +-
 .../gemfire/codeAnalysis/excludedClasses.txt    |    2 +-
 .../sanctionedDataSerializables.txt             |   30 +-
 .../codeAnalysis/sanctionedSerializables.txt    |   16 +-
 .../tier/sockets/RedundancyLevelJUnitTest.xml   |   21 +-
 .../gemfire/test/golden/log4j2-test.xml         |   18 +
 .../gemstone/org/jgroups/protocols/FRAG2.java   |    2 +-
 .../gemstone/org/jgroups/protocols/SMACK.java   |    3 +-
 .../gemstone/org/jgroups/protocols/UDP_NIO.java |    4 +-
 .../org/jgroups/protocols/VIEW_ENFORCER.java    |    2 +-
 gemfire-rebalancer/build.gradle                 |   12 +
 .../gemfire/cache/util/AutoBalancer.java        |  512 +++++
 .../cache/util/AutoBalancerJUnitTest.java       |  772 +++++++
 gemfire-spark-connector/.gitignore              |    1 +
 gemfire-spark-connector/README.md               |   32 +
 gemfire-spark-connector/doc/10_demos.md         |   84 +
 gemfire-spark-connector/doc/1_building.md       |   34 +
 gemfire-spark-connector/doc/2_quick.md          |  178 ++
 gemfire-spark-connector/doc/3_connecting.md     |   55 +
 gemfire-spark-connector/doc/4_loading.md        |  108 +
 gemfire-spark-connector/doc/5_rdd_join.md       |  237 ++
 gemfire-spark-connector/doc/6_save_rdd.md       |   81 +
 gemfire-spark-connector/doc/7_save_dstream.md   |   68 +
 gemfire-spark-connector/doc/8_oql.md            |   58 +
 gemfire-spark-connector/doc/9_java_api.md       |  129 ++
 .../connector/internal/RegionMetadata.java      |   77 +
 .../gemfirefunctions/QueryFunction.java         |   83 +
 .../RetrieveRegionFunction.java                 |  192 ++
 .../RetrieveRegionMetadataFunction.java         |  102 +
 .../StructStreamingResultSender.java            |  203 ++
 .../gemfire/spark/connector/Employee.java       |   38 +
 .../spark/connector/JavaApiIntegrationTest.java |  408 ++++
 .../gemfire/spark/connector/Portfolio.java      |   93 +
 .../gemfire/spark/connector/Position.java       |   57 +
 .../src/it/resources/test-regions.xml           |   32 +
 .../src/it/resources/test-retrieve-regions.xml  |   40 +
 .../spark/connector/BasicIntegrationTest.scala  |  582 +++++
 .../RDDJoinRegionIntegrationTest.scala          |  284 +++
 .../RetrieveRegionIntegrationTest.scala         |  237 ++
 .../gemfire/spark/connector/package.scala       |   13 +
 .../connector/testkit/GemFireCluster.scala      |   31 +
 .../spark/connector/testkit/GemFireRunner.scala |  132 ++
 .../spark/connector/testkit/IOUtils.scala       |   78 +
 .../spark/streaming/ManualClockHelper.scala     |   12 +
 .../spark/streaming/TestInputDStream.scala      |   28 +
 .../javaapi/GemFireJavaDStreamFunctions.java    |   70 +
 .../GemFireJavaPairDStreamFunctions.java        |   61 +
 .../javaapi/GemFireJavaPairRDDFunctions.java    |  222 ++
 .../javaapi/GemFireJavaRDDFunctions.java        |  162 ++
 .../javaapi/GemFireJavaSQLContextFunctions.java |   33 +
 .../GemFireJavaSparkContextFunctions.java       |   71 +
 .../connector/javaapi/GemFireJavaUtil.java      |  106 +
 .../spark/connector/GemFireConnection.scala     |   51 +
 .../spark/connector/GemFireConnectionConf.scala |   57 +
 .../connector/GemFireConnectionManager.scala    |   15 +
 .../connector/GemFireFunctionDeployer.scala     |   65 +
 .../connector/GemFireKryoRegistrator.scala      |   13 +
 .../connector/GemFirePairRDDFunctions.scala     |  124 ++
 .../spark/connector/GemFireRDDFunctions.scala   |  104 +
 .../connector/GemFireSQLContextFunctions.scala  |   26 +
 .../GemFireSparkContextFunctions.scala          |   23 +
 .../internal/DefaultGemFireConnection.scala     |  148 ++
 .../DefaultGemFireConnectionManager.scala       |   61 +
 .../connector/internal/LocatorHelper.scala      |  119 +
 .../StructStreamingResultCollector.scala        |  136 ++
 .../connector/internal/oql/QueryParser.scala    |   42 +
 .../spark/connector/internal/oql/QueryRDD.scala |   67 +
 .../internal/oql/QueryResultCollector.scala     |   53 +
 .../connector/internal/oql/RDDConverter.scala   |   24 +
 .../connector/internal/oql/RowBuilder.scala     |   22 +
 .../connector/internal/oql/SchemaBuilder.scala  |   57 +
 .../internal/oql/UndefinedSerializer.scala      |   30 +
 .../connector/internal/rdd/GemFireJoinRDD.scala |   51 +
 .../internal/rdd/GemFireOuterJoinRDD.scala      |   53 +
 .../internal/rdd/GemFireRDDPartition.scala      |   20 +
 .../internal/rdd/GemFireRDDPartitioner.scala    |   43 +
 .../rdd/GemFireRDDPartitionerImpl.scala         |   73 +
 .../internal/rdd/GemFireRDDWriter.scala         |   66 +
 .../internal/rdd/GemFireRegionRDD.scala         |  122 ++
 .../javaapi/GemFireJavaRegionRDD.scala          |   10 +
 .../spark/connector/javaapi/JavaAPIHelper.scala |   37 +
 .../gemfire/spark/connector/package.scala       |   53 +
 .../streaming/GemFireDStreamFunctions.scala     |   73 +
 .../spark/connector/streaming/package.scala     |   16 +
 .../gemfire/spark/connector/JavaAPITest.java    |  147 ++
 .../connector/GemFireFunctionDeployerTest.scala |   42 +
 .../DefaultGemFireConnectionManagerTest.scala   |   66 +
 ...tStreamingResultSenderAndCollectorTest.scala |  238 ++
 .../internal/oql/QueryParserTest.scala          |   67 +
 .../connector/ConnectorImplicitsTest.scala      |   34 +
 .../connector/GemFireConnectionConfTest.scala   |   84 +
 .../connector/GemFireDStreamFunctionsTest.scala |   63 +
 .../connector/GemFireRDDFunctionsTest.scala     |  123 ++
 .../spark/connector/LocatorHelperTest.scala     |  152 ++
 .../rdd/GemFireRDDPartitionerTest.scala         |  174 ++
 .../connector/rdd/GemFireRegionRDDTest.scala    |  101 +
 .../basic-demos/src/main/java/demo/Emp.java     |   79 +
 .../src/main/java/demo/OQLJavaDemo.java         |   43 +
 .../src/main/java/demo/PairRDDSaveJavaDemo.java |   70 +
 .../src/main/java/demo/RDDSaveJavaDemo.java     |   69 +
 .../src/main/java/demo/RegionToRDDJavaDemo.java |   41 +
 .../src/main/scala/demo/NetworkWordCount.scala  |   59 +
 .../project/Dependencies.scala                  |   29 +
 .../project/GemFireSparkBuild.scala             |   60 +
 gemfire-spark-connector/project/Settings.scala  |   41 +
 .../project/build.properties                    |    1 +
 gemfire-spark-connector/project/plugins.sbt     |    8 +
 gemfire-spark-connector/scalastyle-config.xml   |  117 +
 settings.gradle                                 |    1 +
 838 files changed, 35115 insertions(+), 50912 deletions(-)
----------------------------------------------------------------------



Mime
View raw message