Merge remote-tracking branch 'origin/develop' into feature/GEODE-11
Project: http://git-wip-us.apache.org/repos/asf/incubator-geode/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-geode/commit/3e07ec2f Tree: http://git-wip-us.apache.org/repos/asf/incubator-geode/tree/3e07ec2f Diff: http://git-wip-us.apache.org/repos/asf/incubator-geode/diff/3e07ec2f Branch: refs/heads/develop Commit: 3e07ec2f1114bfdb1a42b1eafd6347c913731a3a Parents: 71cd7c6 17fdf57 Author: Dan Smith <[email protected]> Authored: Thu Oct 8 17:32:27 2015 -0700 Committer: Dan Smith <[email protected]> Committed: Thu Oct 8 17:32:27 2015 -0700 ---------------------------------------------------------------------- README.md | 2 +- build.gradle | 13 +- .../src/test/java/AgentUtilJUnitTest.java | 109 - .../management/internal/AgentUtilJUnitTest.java | 106 + .../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 +- .../gemfire/cache/client/PoolFactory.java | 10 +- .../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/query/internal/CompiledSelect.java | 34 +- .../cache/query/internal/DefaultQuery.java | 9 +- .../cache/query/internal/RuntimeIterator.java | 3 - .../index/FunctionalIndexCreationHelper.java | 1 - .../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 | 38 +- .../gemfire/distributed/ServerLauncher.java | 4 +- .../FunctionExecutionPooledExecutor.java | 7 +- .../internal/InternalDistributedSystem.java | 12 +- .../internal/PooledExecutorWithDMStats.java | 7 +- .../distributed/internal/ServerLocator.java | 10 +- .../jgroup/JGroupMembershipManager.java | 6 +- .../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 | 52 - .../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/CacheConfig.java | 8 +- .../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 +- .../cache/DistributedCacheOperation.java | 10 +- .../cache/DistributedClearOperation.java | 6 +- .../internal/cache/DistributedRegion.java | 6 - .../gemfire/internal/cache/ExpiryTask.java | 38 +- .../cache/FindDurableQueueProcessor.java | 4 +- .../internal/cache/GemFireCacheImpl.java | 92 +- .../gemfire/internal/cache/GridAdvisor.java | 6 +- .../gemfire/internal/cache/LocalRegion.java | 48 +- .../cache/MinimumSystemRequirements.java | 4 +- .../internal/cache/PartitionedRegion.java | 8 +- .../gemfire/internal/cache/PoolFactoryImpl.java | 171 +- .../gemfire/internal/cache/PoolManagerImpl.java | 19 - .../gemfire/internal/cache/RegionEventImpl.java | 2 +- .../internal/cache/RemotePutMessage.java | 56 +- .../gemfire/internal/cache/TXCommitMessage.java | 45 +- .../gemfire/internal/cache/TXEntryState.java | 19 +- .../cache/control/HeapMemoryMonitor.java | 1 + .../internal/cache/control/MemoryEvent.java | 9 +- .../cache/control/OffHeapMemoryMonitor.java | 88 +- .../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 | 2 +- .../PartitionedRegionObserverHolder.java | 2 +- .../internal/cache/partitioned/PutMessage.java | 21 +- .../rebalance/ParallelBucketOperator.java | 6 + .../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 +- .../wan/serial/SerialGatewaySenderQueue.java | 2 + .../cache/xmlcache/BridgeServerCreation.java | 249 --- .../internal/cache/xmlcache/CacheCreation.java | 47 +- .../cache/xmlcache/CacheServerCreation.java | 238 ++ .../cache/xmlcache/CacheXmlGenerator.java | 41 +- .../internal/cache/xmlcache/CacheXmlParser.java | 18 +- .../cache/xmlcache/ClientCacheCreation.java | 5 - .../xmlcache/RegionAttributesCreation.java | 9 - .../gemfire/internal/i18n/LocalizedStrings.java | 20 +- .../internal/i18n/ParentLocalizedStrings.java | 81 +- .../gemfire/internal/lang/SystemUtils.java | 35 +- .../gemfire/internal/logging/LogService.java | 11 +- .../internal/logging/log4j/Configurator.java | 8 + .../offheap/OffHeapCachedDeserializable.java | 20 + .../offheap/SimpleMemoryAllocatorImpl.java | 44 +- .../gemfire/internal/offheap/StoredObject.java | 26 +- .../gemstone/gemfire/internal/redis/Coder.java | 194 +- .../internal/redis/ExecutionHandlerContext.java | 3 +- .../gemfire/internal/redis/RegionProvider.java | 53 +- .../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 +- .../management/internal/beans/ServerBridge.java | 6 +- .../cli/functions/ContunuousQueryFunction.java | 4 +- .../cli/functions/CreateHDFSStoreFunction.java | 4 +- .../functions/GetMemberInformationFunction.java | 4 +- .../internal/cli/i18n/CliStrings.java | 2 +- .../web/controllers/WanCommandsController.java | 2 +- .../management/membership/ClientMembership.java | 8 +- .../gemfire/pdx/internal/TypeRegistry.java | 15 +- .../gemfire/redis/GemFireRedisServer.java | 11 +- .../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 +- .../internal/AutoConnectionSourceDUnitTest.java | 23 +- .../AutoConnectionSourceWithUDPDUnitTest.java | 4 +- .../internal/ConnectionPoolImplJUnitTest.java | 11 +- .../internal/LocatorLoadBalancingDUnitTest.java | 10 +- .../cache/client/internal/LocatorTestBase.java | 12 +- .../internal/RegionWithHDFSBasicDUnitTest.java | 4 +- .../hdfs/internal/RegionWithHDFSTestBase.java | 4 +- .../management/MemoryThresholdsDUnitTest.java | 4 +- .../MemoryThresholdsOffHeapDUnitTest.java | 4 +- .../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 +- .../query/internal/index/IndexUseJUnitTest.java | 52 + .../cache30/BridgeMembershipDUnitTest.java | 1660 -------------- .../BridgeMembershipSelectorDUnitTest.java | 16 - .../gemfire/cache30/BridgeTestCase.java | 376 ---- .../gemfire/cache30/BridgeWriterDUnitTest.java | 418 ---- .../cache30/BridgeWriterSelectorDUnitTest.java | 16 - .../gemfire/cache30/Bug38741DUnitTest.java | 10 +- .../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 ++++ .../gemfire/cache30/MultiVMRegionTestCase.java | 12 +- .../gemfire/cache30/RegionTestCase.java | 14 +- .../AbstractServerLauncherJUnitTestCase.java | 4 +- .../LocatorLauncherRemoteFileJUnitTest.java | 8 +- .../LocatorLauncherRemoteJUnitTest.java | 57 +- .../ServerLauncherLocalJUnitTest.java | 51 +- .../ServerLauncherRemoteFileJUnitTest.java | 2 - .../ServerLauncherRemoteJUnitTest.java | 8 +- .../ServerLauncherWithSpringJUnitTest.java | 2 + .../internal/ProductUseLogDUnitTest.java | 2 +- .../disttx/DistributedTransactionDUnitTest.java | 4 +- .../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/Bug39079DUnitTest.java | 6 +- .../internal/cache/Bug41957DUnitTest.java | 6 +- ...ssagesRegionCreationAndDestroyJUnitTest.java | 10 +- .../cache/ClientServerGetAllDUnitTest.java | 41 +- .../cache/ClientServerTransactionDUnitTest.java | 157 +- .../cache/ConcurrentMapOpsDUnitTest.java | 75 +- .../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/OldValueImporterTestBase.java | 165 ++ .../cache/RemotePutReplyMessageJUnitTest.java | 37 + .../cache/RemoteTransactionDUnitTest.java | 68 + .../control/RebalanceOperationDUnitTest.java | 6 +- .../cache/execute/Bug51193DUnitTest.java | 4 +- .../internal/cache/functions/TestFunction.java | 10 +- .../cache/ha/Bug36853EventsExpiryDUnitTest.java | 8 +- .../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 +- ...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 | 64 +- .../tier/sockets/HAInterestPart2DUnitTest.java | 12 +- .../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 +- .../logging/LogServiceIntegrationJUnitTest.java | 209 ++ .../LogServiceIntegrationTestSupport.java | 24 + .../internal/logging/LogServiceJUnitTest.java | 190 +- .../LogServiceUserDirIntegrationJUnitTest.java | 70 + .../logging/LoggingIntegrationTestSuite.java | 3 +- .../internal/logging/LoggingUnitTestSuite.java | 1 + .../offheap/OffHeapValidationJUnitTest.java | 45 +- .../OffHeapWriteObjectAsByteArrayJUnitTest.java | 101 + .../internal/size/ObjectSizerJUnitTest.java | 14 +- ...ersalMembershipListenerAdapterDUnitTest.java | 32 +- .../WanCommandsControllerJUnitTest.java | 124 ++ .../gemfire/pdx/ByteSourceJUnitTest.java | 4 +- .../pdx/PdxFormatterPutGetJUnitTest.java | 4 +- .../gemfire/redis/RedisDistDUnitTest.java | 15 +- ...hTimeoutOfWaitForOutputToMatchJUnitTest.java | 3 +- .../test/java/dunit/DistributedTestCase.java | 62 +- .../java/dunit/standalone/DUnitLauncher.java | 8 +- .../gemfire/codeAnalysis/excludedClasses.txt | 2 +- .../sanctionedDataSerializables.txt | 14 +- .../codeAnalysis/sanctionedSerializables.txt | 9 - .../tier/sockets/RedundancyLevelJUnitTest.xml | 21 +- .../cache/util/AutoBalancerJUnitTest.java | 55 +- 472 files changed, 11445 insertions(+), 44140 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/3e07ec2f/gemfire-core/src/main/java/com/gemstone/gemfire/internal/DataSerializableFixedID.java ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/3e07ec2f/gemfire-core/src/main/java/com/gemstone/gemfire/internal/cache/GemFireCacheImpl.java ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/3e07ec2f/gemfire-core/src/main/java/com/gemstone/gemfire/internal/cache/xmlcache/CacheCreation.java ---------------------------------------------------------------------- diff --cc gemfire-core/src/main/java/com/gemstone/gemfire/internal/cache/xmlcache/CacheCreation.java index 2e2ec2b,0347d67..31de4e9 --- a/gemfire-core/src/main/java/com/gemstone/gemfire/internal/cache/xmlcache/CacheCreation.java +++ b/gemfire-core/src/main/java/com/gemstone/gemfire/internal/cache/xmlcache/CacheCreation.java @@@ -52,9 -52,9 +52,8 @@@ import com.gemstone.gemfire.cache.async import com.gemstone.gemfire.cache.client.Pool; import com.gemstone.gemfire.cache.client.PoolFactory; import com.gemstone.gemfire.cache.client.PoolManager; - import com.gemstone.gemfire.cache.client.internal.BridgePoolImpl; import com.gemstone.gemfire.cache.client.internal.PoolImpl; import com.gemstone.gemfire.cache.execute.FunctionService; -import com.gemstone.gemfire.cache.lucene.LuceneService; import com.gemstone.gemfire.cache.query.CqAttributes; import com.gemstone.gemfire.cache.query.CqException; import com.gemstone.gemfire.cache.query.CqExistsException;
