geode-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From lgalli...@apache.org
Subject [geode] branch feature/GEODE-4435 updated (5302d88 -> 43b395f)
Date Wed, 07 Feb 2018 17:28:27 GMT
This is an automated email from the ASF dual-hosted git repository.

lgallinat pushed a change to branch feature/GEODE-4435
in repository https://gitbox.apache.org/repos/asf/geode.git.


    from 5302d88  GEODE-4368: Rename server connection classes. (#1343)
     add 52ff5ef  GEODE-4328: Make backup into a task run by a single thread (#1351)
     add 5149f3e  GEODE-4438: Removing unused .ser files
     add 215177f  GEODE-4308: Allow two caches in the same JVM if a feature flag is on
     add 8dab486  GEODE-4417: Remove support for DES. (#1355)
     add a0fc41b  GEODE-4380: Trigger build of geode-examples off geode success. (#1342)
     add 0d4940d  GEODE-4219: Test will properly shutdown listeners (#1325)
     add c6ce067  GEODE-4375: Fix problem that an exception occurs when transaction from CacheServer via Pool (#1363)
     add 21e2e0a  GEODE-4364: extract RegionMapDestroy and add RegionMapDestroyTest (#1347)
     add de9d814  GEODE-4429: Remove unnecessary modifiers from interfaces in geode-core:cache
     add a6ac186  GEODE-4431: Remove unnecessary modifiers from interfaces in geode-core:internal
     add adfd511  [GEODE-4371] Add lurker process that captures callstacks. (#1337)
     add 9cf05c1  GEODE-4433: Remove unnecessary modifiers from interfaces outside geode-core
     add 751735d  GEODE-4432: Remove unnecessary modifiers from interfaces in geode-core
     add 9438685  GEODE-4430: Remove unnecessary modifiers from interfaces in geode-core:internal.cache
     add 2615332  GEODE-4373: gfsh 'describe region' not showing accessor region description (#1365)
     add 4a75148  GEODE-4390: Replace flaky test with new tests (#1371)
     add a5068ff  GEODE-3834: Use TemporaryFolder rule in backup tests that did not yet use it (#1373)
     add 503d622  GEODE-4013: Ensure that non-daemon thread is used during shutdown of … (#1368)
     add 329e0c5  GEODE-3653: Remove testHook from AbstractGatewaySenderEventProcessor (#1217)
     add 0f6e09c  GEODE-3800: Replace BackupManager with BackupService (#1372)
     add 94049aa  GEODE-4405: Move backup target and base line dirs to prepare backup message (#1377)
     add b22db64  Update NOTICE with 2018 copyright
     add 6011e09  GEODE-3127: add function execution to new client protocol. (#1357)
     add 80ad2d7  GEODE-4270: remove race condition where CacheClientProxy could be asked to (#1378)
     add c1b21c0  GEODE-4439 Refactor HandShake.java
     add 198b9e0  GEODE-4076: throw AuthenticationRequiredException when failed to find… (#1369)
     add 232d16c  Update Dockerfile to: - use geode binary rather than building one on the fly - update to version 1.4.0 Updated Readme
     add 40a2ca0  GEODE-3966: Avoid singletons by passing distributed system and cache. (#1366)
     add 1c89fe1  GEODE-4397: refactor RegionMapDestroy destroy operation (#1370)
     add 158992b  GEODE-4509: change uses of LocalRegion to InternalRegion (#1379)
     add c36a113  GEODE-4487: Remove singleton calls from offheap package (#1382)
     add e9b4bd5  GEODE-4442: Move abort of backups to separate message (#1381)
     add b578408  GEODE-3876: refactor expiry options for create region and alter regio… (#1356)
     add 674e729  GEODE-4375: Fix problem that an exception occurs when transaction from CacheServer via Pool (#1363)
     add 4caba98  oops - spotlessApply
     add 906ed2a  GEODE-3948 Improve CQ performance under flaky network conditions
     add 6c331d1  GEODE-4499: Test adding a compressor to an existing persistent region. (#1384)
     add 69443da  GEODE-4598: Make LRUListWithAsyncSorting the default eviction list (#1387)
     add ff1b8c7  GEODE-4389: Ensure that region template creation does not require callback classes on the locator (#1390)
     add e3b0666  Fix capture_call_stacks.sh (#1393)
     add 2ebd5b0  GEODE-4392: Remove catch blocks that immediately rethrow the caught exception. (#1385)
     add f0d40e3  GEODE-4604: rest api function execution needs to check the required p… (#1388)
     add 5bec6b8  GEODE-4590: pass executor in to clear (#1392)
     new 43b395f  GEODE-4435 Move queueSize stat increment to after writing to disk.

The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.


Summary of changes:
 NOTICE                                             |    4 +-
 ci/docker/Dockerfile                               |    4 +-
 ci/pipelines/develop.yml                           |   14 +-
 ci/scripts/capture-call-stacks.sh                  |   61 +
 ci/scripts/test-run.sh                             |    3 +
 docker/Dockerfile                                  |   18 +-
 docker/README.md                                   |    4 +-
 .../session/internal/common/SessionCache.java      |   12 +-
 .../session/internal/filter/SessionManager.java    |   16 +-
 .../filter/attributes/SessionAttributes.java       |   24 +-
 .../internal/jmx/SessionStatisticsMXBean.java      |    6 +-
 .../geode/modules/gatewaydelta/GatewayDelta.java   |    6 +-
 .../modules/gatewaydelta/GatewayDeltaEvent.java    |    2 +-
 .../modules/session/catalina/SessionCache.java     |   36 +-
 .../modules/session/catalina/SessionManager.java   |   26 +-
 .../internal/DeltaSessionAttributeEvent.java       |    3 +-
 geode-assembly/src/main/dist/NOTICE                |    2 +-
 .../internal/web/RestFunctionExecuteDUnitTest.java |  124 ++
 .../internal/web/RestSecurityIntegrationTest.java  |  150 +-
 .../java/org/apache/geode/DataSerializable.java    |   13 +-
 .../src/main/java/org/apache/geode/LogWriter.java  |   74 +-
 .../java/org/apache/geode/StatisticDescriptor.java |   14 +-
 .../src/main/java/org/apache/geode/Statistics.java |   98 +-
 .../java/org/apache/geode/StatisticsFactory.java   |   18 +-
 .../main/java/org/apache/geode/StatisticsType.java |   10 +-
 .../org/apache/geode/StatisticsTypeFactory.java    |   32 +-
 .../apache/geode/admin/AdminDistributedSystem.java |   94 +-
 .../main/java/org/apache/geode/admin/Alert.java    |   12 +-
 .../java/org/apache/geode/admin/AlertListener.java |    2 +-
 .../org/apache/geode/admin/CacheHealthConfig.java  |   24 +-
 .../java/org/apache/geode/admin/CacheServer.java   |    4 +-
 .../org/apache/geode/admin/CacheServerConfig.java  |    8 +-
 .../main/java/org/apache/geode/admin/CacheVm.java  |    2 +-
 .../java/org/apache/geode/admin/CacheVmConfig.java |    8 +-
 .../apache/geode/admin/ConfigurationParameter.java |   24 +-
 .../geode/admin/DistributedSystemConfig.java       |  154 +-
 .../geode/admin/DistributedSystemHealthConfig.java |    6 +-
 .../apache/geode/admin/DistributionLocator.java    |    4 +-
 .../geode/admin/DistributionLocatorConfig.java     |   12 +-
 .../java/org/apache/geode/admin/GemFireHealth.java |   30 +-
 .../apache/geode/admin/GemFireHealthConfig.java    |    8 +-
 .../java/org/apache/geode/admin/ManagedEntity.java |   12 +-
 .../apache/geode/admin/ManagedEntityConfig.java    |   20 +-
 .../org/apache/geode/admin/MemberHealthConfig.java |   24 +-
 .../java/org/apache/geode/admin/Statistic.java     |   10 +-
 .../org/apache/geode/admin/StatisticResource.java  |   14 +-
 .../java/org/apache/geode/admin/SystemMember.java  |   36 +-
 .../geode/admin/SystemMemberBridgeServer.java      |   60 +-
 .../org/apache/geode/admin/SystemMemberCache.java  |   39 +-
 .../apache/geode/admin/SystemMemberCacheEvent.java |    2 +-
 .../geode/admin/SystemMemberCacheListener.java     |   12 +-
 .../geode/admin/SystemMemberCacheServer.java       |   60 +-
 .../org/apache/geode/admin/SystemMemberRegion.java |  104 +-
 .../geode/admin/SystemMemberRegionEvent.java       |    2 +-
 .../apache/geode/admin/SystemMembershipEvent.java  |    4 +-
 .../geode/admin/SystemMembershipListener.java      |    6 +-
 .../internal/ConfigurationParameterListener.java   |    2 +-
 .../admin/internal/InternalManagedEntity.java      |   26 +-
 .../admin/internal/ManagedEntityController.java    |   12 +-
 .../java/org/apache/geode/admin/jmx/Agent.java     |   26 +-
 .../org/apache/geode/admin/jmx/AgentConfig.java    |  216 ++-
 .../geode/admin/jmx/internal/ManagedResource.java  |   14 +-
 .../jmx/internal/RMIRegistryServiceMBean.java      |   14 +-
 .../admin/jmx/internal/StatAlertsAggregator.java   |   20 +-
 .../geode/admin/jmx/internal/SystemMemberJmx.java  |   59 +-
 .../org/apache/geode/cache/AttributesMutator.java  |   38 +-
 .../java/org/apache/geode/cache/CacheCallback.java |    2 +-
 .../java/org/apache/geode/cache/CacheEvent.java    |   13 +-
 .../java/org/apache/geode/cache/CacheFactory.java  |    4 +-
 .../java/org/apache/geode/cache/CacheListener.java |   18 +-
 .../java/org/apache/geode/cache/CacheLoader.java   |    2 +-
 .../org/apache/geode/cache/CacheStatistics.java    |   12 +-
 .../geode/cache/CacheTransactionManager.java       |   42 +-
 .../java/org/apache/geode/cache/CacheWriter.java   |   10 +-
 .../java/org/apache/geode/cache/ClientSession.java |   18 +-
 .../java/org/apache/geode/cache/CustomExpiry.java  |    2 +-
 .../java/org/apache/geode/cache/Declarable.java    |    2 +-
 .../java/org/apache/geode/cache/DiskStore.java     |   38 +-
 .../org/apache/geode/cache/DiskStoreFactory.java   |   50 +-
 .../apache/geode/cache/DiskWriteAttributes.java    |   12 +-
 .../apache/geode/cache/DynamicRegionFactory.java   |    7 +-
 .../apache/geode/cache/DynamicRegionListener.java  |    8 +-
 .../java/org/apache/geode/cache/EntryEvent.java    |   16 +-
 .../org/apache/geode/cache/EntryOperation.java     |   12 +-
 .../geode/cache/EvictionAttributesMutator.java     |    2 +-
 .../org/apache/geode/cache/ExpirationAction.java   |    3 +-
 .../apache/geode/cache/FixedPartitionResolver.java |    3 +-
 .../java/org/apache/geode/cache/GemFireCache.java  |   46 +-
 .../geode/cache/InterestRegistrationEvent.java     |   16 +-
 .../geode/cache/InterestRegistrationListener.java  |    4 +-
 .../java/org/apache/geode/cache/LoaderHelper.java  |    8 +-
 .../apache/geode/cache/PartitionAttributes.java    |   27 +-
 .../org/apache/geode/cache/PartitionResolver.java  |    4 +-
 .../main/java/org/apache/geode/cache/Region.java   |  209 ++-
 .../org/apache/geode/cache/RegionAttributes.java   |   92 +-
 .../java/org/apache/geode/cache/RegionEvent.java   |    2 +-
 .../java/org/apache/geode/cache/RegionFactory.java |    4 +-
 .../geode/cache/RegionMembershipListener.java      |    8 +-
 .../org/apache/geode/cache/RegionRoleListener.java |    4 +-
 .../java/org/apache/geode/cache/RegionService.java |   16 +-
 .../java/org/apache/geode/cache/RequiredRoles.java |    4 +-
 .../java/org/apache/geode/cache/RoleEvent.java     |    2 +-
 .../apache/geode/cache/SerializedCacheValue.java   |    4 +-
 .../org/apache/geode/cache/TransactionEvent.java   |    8 +-
 .../apache/geode/cache/TransactionListener.java    |    6 +-
 .../org/apache/geode/cache/TransactionWriter.java  |    2 +-
 .../apache/geode/cache/asyncqueue/AsyncEvent.java  |    4 +-
 .../geode/cache/asyncqueue/AsyncEventListener.java |    2 +-
 .../geode/cache/asyncqueue/AsyncEventQueue.java    |   34 +-
 .../cache/asyncqueue/AsyncEventQueueFactory.java   |   34 +-
 .../org/apache/geode/cache/client/ClientCache.java |   25 +-
 .../geode/cache/client/ClientRegionFactory.java    |   47 +-
 .../java/org/apache/geode/cache/client/Pool.java   |   70 +-
 .../org/apache/geode/cache/client/PoolFactory.java |  110 +-
 .../geode/cache/client/internal/AbstractOp.java    |    9 +-
 .../cache/client/internal/AuthenticateUserOp.java  |   17 +-
 .../client/internal/ClientMetadataService.java     |   21 +-
 .../client/internal/ClientRegionFactoryImpl.java   |    4 +-
 .../client/internal/ClientSideHandshakeImpl.java   |  458 +++++
 .../geode/cache/client/internal/ClientUpdater.java |    6 +-
 .../geode/cache/client/internal/Connection.java    |   38 +-
 .../client/internal/ConnectionFactoryImpl.java     |   53 +-
 .../cache/client/internal/ConnectionImpl.java      |   24 +-
 .../cache/client/internal/EndpointManager.java     |   10 +-
 .../cache/client/internal/ExecutablePool.java      |   29 +-
 .../geode/cache/client/internal/PoolImpl.java      |   99 +-
 .../cache/client/internal/ProxyCacheCloseOp.java   |    2 +-
 .../apache/geode/cache/client/internal/PutOp.java  |    2 +-
 .../geode/cache/client/internal/QueueManager.java  |   18 +-
 .../geode/cache/client/internal/QueueState.java    |   14 +-
 .../cache/client/internal/ServerBlackList.java     |   12 +-
 .../client/internal/ServerRegionDataAccess.java    |   38 +-
 .../client/internal/SingleHopClientExecutor.java   |   10 -
 .../locator/wan/LocatorMembershipListener.java     |   16 +-
 .../client/internal/pooling/ConnectionManager.java |    8 +-
 .../internal/pooling/ConnectionManagerImpl.java    |    1 -
 .../geode/cache/control/RebalanceFactory.java      |    4 +-
 .../geode/cache/control/RebalanceOperation.java    |   10 +-
 .../geode/cache/control/RebalanceResults.java      |   20 +-
 .../geode/cache/control/ResourceManager.java       |   24 +-
 .../org/apache/geode/cache/execute/Execution.java  |   12 +-
 .../geode/cache/execute/FunctionContext.java       |   12 +-
 .../geode/cache/execute/RegionFunctionContext.java |    4 +-
 .../geode/cache/execute/ResultCollector.java       |   10 +-
 .../apache/geode/cache/execute/ResultSender.java   |    6 +-
 .../execute/internal/FunctionServiceManager.java   |    5 +-
 .../geode/cache/partition/PartitionListener.java   |   10 +-
 .../geode/cache/partition/PartitionMemberInfo.java |   10 +-
 .../cache/partition/PartitionRebalanceInfo.java    |   30 +-
 .../geode/cache/partition/PartitionRegionInfo.java |   18 +-
 .../geode/cache/persistence/PersistentID.java      |    6 +-
 .../org/apache/geode/cache/query/Aggregator.java   |    6 +-
 .../org/apache/geode/cache/query/CqAttributes.java |    4 +-
 .../geode/cache/query/CqAttributesMutator.java     |    6 +-
 .../java/org/apache/geode/cache/query/CqEvent.java |   14 +-
 .../org/apache/geode/cache/query/CqListener.java   |    4 +-
 .../java/org/apache/geode/cache/query/CqQuery.java |   30 +-
 .../geode/cache/query/CqServiceStatistics.java     |   12 +-
 .../java/org/apache/geode/cache/query/CqState.java |   10 +-
 .../org/apache/geode/cache/query/CqStatistics.java |    8 +-
 .../apache/geode/cache/query/CqStatusListener.java |    4 +-
 .../java/org/apache/geode/cache/query/Index.java   |   24 +-
 .../apache/geode/cache/query/IndexStatistics.java  |   18 +-
 .../java/org/apache/geode/cache/query/Query.java   |   21 +-
 .../org/apache/geode/cache/query/QueryService.java |   94 +-
 .../apache/geode/cache/query/QueryStatistics.java  |    4 +-
 .../apache/geode/cache/query/SelectResults.java    |   19 +-
 .../java/org/apache/geode/cache/query/Struct.java  |    6 +-
 .../apache/geode/cache/query/internal/Filter.java  |   37 +-
 .../cache/query/internal/HashingStrategy.java      |    4 +-
 .../geode/cache/query/internal/Negatable.java      |    2 +-
 .../geode/cache/query/internal/QueryExecutor.java  |    4 +-
 .../geode/cache/query/internal/StructFields.java   |   10 +-
 .../geode/cache/query/internal/cq/ClientCQ.java    |    7 +-
 .../geode/cache/query/internal/cq/CqService.java   |   77 +-
 .../cache/query/internal/cq/InternalCqQuery.java   |   29 +-
 .../geode/cache/query/internal/cq/ServerCQ.java    |   24 +-
 .../cache/query/internal/index/IndexManager.java   |    2 +-
 .../cache/query/internal/index/IndexProtocol.java  |   19 +-
 .../cache/query/internal/index/IndexStore.java     |   42 +-
 .../internal/index/IndexedExpressionEvaluator.java |   17 +-
 .../geode/cache/query/types/CollectionType.java    |    6 +-
 .../apache/geode/cache/query/types/MapType.java    |    4 +-
 .../apache/geode/cache/query/types/ObjectType.java |   10 +-
 .../apache/geode/cache/query/types/StructType.java |    2 +-
 .../org/apache/geode/cache/server/CacheServer.java |  104 +-
 .../cache/server/ClientSubscriptionConfig.java     |   22 +-
 .../cache/snapshot/RegionSnapshotService.java      |    2 +-
 .../geode/cache/util/GatewayConflictHelper.java    |    4 +-
 .../geode/cache/util/GatewayConflictResolver.java  |    2 +-
 .../org/apache/geode/cache/util/GatewayEvent.java  |   18 +-
 .../org/apache/geode/cache/util/ObjectSizer.java   |    8 +-
 .../geode/cache/util/TimestampedEntryEvent.java    |    8 +-
 .../apache/geode/cache/wan/GatewayEventFilter.java |    6 +-
 .../cache/wan/GatewayEventSubstitutionFilter.java  |    2 +-
 .../apache/geode/cache/wan/GatewayQueueEvent.java  |   12 +-
 .../apache/geode/cache/wan/GatewayReceiver.java    |   46 +-
 .../geode/cache/wan/GatewayReceiverFactory.java    |   20 +-
 .../org/apache/geode/cache/wan/GatewaySender.java  |  113 +-
 .../geode/cache/wan/GatewaySenderFactory.java      |   43 +-
 .../geode/cache/wan/GatewayTransportFilter.java    |    4 +-
 .../org/apache/geode/compression/Compressor.java   |    4 +-
 .../geode/distributed/ClientSocketFactory.java     |    2 +-
 .../geode/distributed/DistributedMember.java       |   14 +-
 .../geode/distributed/DistributedSystem.java       |    6 +
 .../java/org/apache/geode/distributed/Role.java    |    6 +-
 .../apache/geode/distributed/ServerLauncher.java   |   32 +-
 .../geode/distributed/internal/CacheTime.java      |    2 +-
 .../internal/ClusterDistributionManager.java       |    3 -
 .../apache/geode/distributed/internal/DMStats.java |  352 ++--
 .../apache/geode/distributed/internal/DSClock.java |    8 +-
 .../distributed/internal/DistributionAdvisee.java  |   20 +-
 .../distributed/internal/DistributionAdvisor.java  |    8 +-
 .../distributed/internal/DistributionConfig.java   |    8 +-
 .../geode/distributed/internal/HealthMonitor.java  |    8 +-
 .../internal/InternalDistributedSystem.java        |   21 +-
 .../apache/geode/distributed/internal/MQueue.java  |    2 +-
 .../distributed/internal/MembershipListener.java   |   10 +-
 .../distributed/internal/MessageWithReply.java     |    6 +-
 .../geode/distributed/internal/PoolStatHelper.java |    4 +-
 .../distributed/internal/QueueStatHelper.java      |    6 +-
 .../geode/distributed/internal/ReplySender.java    |    2 +-
 .../geode/distributed/internal/Sizeable.java       |    2 +-
 .../internal/ThrottledMemQueueStatHelper.java      |    8 +-
 .../internal/ThrottledQueueStatHelper.java         |    4 +-
 .../distributed/internal/WanLocatorDiscoverer.java |    2 +-
 .../internal/deadlock/DependencyMonitor.java       |    4 +-
 .../distributed/internal/direct/DirectChannel.java |   29 +-
 .../internal/direct/DirectChannelListener.java     |    4 +-
 .../distributed/internal/locks/DLockBatch.java     |   12 +-
 .../distributed/internal/locks/DLockBatchId.java   |    3 +-
 .../locks/DLockLessorDepartureHandler.java         |    4 +-
 .../locks/DLockRecoverGrantorProcessor.java        |    4 +-
 .../distributed/internal/locks/DLockService.java   |   39 +-
 .../internal/locks/DistributedLockStats.java       |  207 +--
 .../internal/locks/DistributedMemberLock.java      |    2 +-
 .../membership/DistributedMembershipListener.java  |   20 +-
 .../internal/membership/MemberServices.java        |   10 +-
 .../internal/membership/MembershipManager.java     |   82 +-
 .../internal/membership/MembershipTestHook.java    |    4 +-
 .../distributed/internal/membership/NetMember.java |   63 +-
 .../internal/membership/QuorumChecker.java         |   12 +-
 .../internal/membership/gms/NetLocator.java        |    2 +-
 .../membership/gms/auth/GMSAuthenticator.java      |    4 +-
 .../membership/gms/interfaces/HealthMonitor.java   |   15 +-
 .../membership/gms/interfaces/JoinLeave.java       |    2 +-
 .../membership/gms/interfaces/MessageHandler.java  |    2 +-
 .../membership/gms/messages/HasMemberID.java       |    2 +-
 .../membership/gms/messenger/GMSEncrypt.java       |   22 +-
 .../distributed/internal/tcpserver/TcpServer.java  |    5 +-
 .../java/org/apache/geode/i18n/LogWriterI18n.java  |  114 +-
 .../apache/geode/internal/ByteBufferWriter.java    |    2 +-
 .../apache/geode/internal/ConnectionWatcher.java   |    4 +-
 .../java/org/apache/geode/internal/DSCODE.java     |  150 +-
 .../org/apache/geode/internal/DSFIDFactory.java    |    2 +
 .../geode/internal/DataSerializableFixedID.java    | 1075 ++++++------
 .../org/apache/geode/internal/ManagerInfo.java     |   20 +-
 .../java/org/apache/geode/internal/NanoTimer.java  |    2 +-
 .../geode/internal/ObjToByteArraySerializer.java   |    5 +-
 .../apache/geode/internal/OneTaskOnlyExecutor.java |    2 +-
 .../geode/internal/SerializationVersions.java      |    2 +-
 .../java/org/apache/geode/internal/Version.java    |    8 +-
 .../apache/geode/internal/VersionedDataStream.java |    2 +-
 .../geode/internal/admin/AdminBridgeServer.java    |    2 +-
 .../org/apache/geode/internal/admin/Alert.java     |   34 +-
 .../apache/geode/internal/admin/AlertListener.java |    2 +-
 .../apache/geode/internal/admin/ApplicationVM.java |    2 +-
 .../org/apache/geode/internal/admin/CacheInfo.java |   24 +-
 .../apache/geode/internal/admin/CacheSnapshot.java |   14 +-
 .../org/apache/geode/internal/admin/DLockInfo.java |   16 +-
 .../apache/geode/internal/admin/EntrySnapshot.java |    2 +-
 .../geode/internal/admin/EntryValueNode.java       |   10 +-
 .../org/apache/geode/internal/admin/GemFireVM.java |   98 +-
 .../geode/internal/admin/GfManagerAgent.java       |   24 +-
 .../org/apache/geode/internal/admin/GfObject.java  |    8 +-
 .../geode/internal/admin/HealthListener.java       |    2 +-
 .../geode/internal/admin/JoinLeaveListener.java    |    6 +-
 .../geode/internal/admin/RegionSnapshot.java       |    2 +-
 .../geode/internal/admin/SnapshotClient.java       |    2 +-
 .../java/org/apache/geode/internal/admin/Stat.java |    6 +-
 .../geode/internal/admin/StatAlertDefinition.java  |   30 +-
 .../apache/geode/internal/admin/StatListener.java  |    4 +-
 .../apache/geode/internal/admin/StatResource.java  |   16 +-
 .../geode/internal/admin/remote/Cancellable.java   |    2 +-
 .../internal/admin/statalerts/StatisticInfo.java   |   18 +-
 .../internal/cache/AbstractBucketRegionQueue.java  |    2 +-
 .../geode/internal/cache/AbstractDiskRegion.java   |   96 +-
 .../geode/internal/cache/AbstractRegion.java       |   30 +-
 .../geode/internal/cache/AbstractRegionMap.java    |  767 ++-------
 .../cache/AddCacheServerProfileMessage.java        |    6 +-
 .../apache/geode/internal/cache/BucketRegion.java  |    6 +-
 .../internal/cache/CacheDistributionAdvisee.java   |   10 +-
 .../internal/cache/CacheDistributionAdvisor.java   |    2 +-
 .../apache/geode/internal/cache/CacheObserver.java |   36 +-
 .../apache/geode/internal/cache/CacheService.java  |    6 +-
 .../geode/internal/cache/CacheStatisticsImpl.java  |    4 +-
 .../geode/internal/cache/CachedDeserializable.java |   22 +-
 .../geode/internal/cache/ClientServerObserver.java |   24 +-
 .../geode/internal/cache/CompactableOplog.java     |    9 +-
 .../apache/geode/internal/cache/Conflatable.java   |   12 +-
 .../apache/geode/internal/cache/DiskRegion.java    |    2 +-
 .../geode/internal/cache/DiskStoreFactoryImpl.java |    4 +-
 .../apache/geode/internal/cache/DiskStoreImpl.java |  230 +--
 .../apache/geode/internal/cache/DiskStoreTask.java |    2 +-
 .../internal/cache/DistTXCoordinatorInterface.java |   23 +-
 .../cache/DistTXStateProxyImplOnCoordinator.java   |    4 -
 .../cache/DistTXStateProxyImplOnDatanode.java      |    2 -
 .../internal/cache/DistributedCacheOperation.java  |    2 +-
 .../geode/internal/cache/DistributedRegion.java    |   10 +-
 .../apache/geode/internal/cache/EntriesMap.java    |   10 +-
 .../geode/internal/cache/EntryEventImpl.java       |    6 +-
 .../geode/internal/cache/EvictableRegion.java      |    3 +-
 .../apache/geode/internal/cache/ExpiryTask.java    |   10 +-
 .../geode/internal/cache/ExportDiskRegion.java     |    4 +-
 .../apache/geode/internal/cache/FilterProfile.java |    6 +-
 .../internal/cache/FindVersionTagOperation.java    |    4 +-
 .../geode/internal/cache/GemFireCacheImpl.java     |  218 ++-
 .../org/apache/geode/internal/cache/HARegion.java  |    4 +-
 .../apache/geode/internal/cache/ImageState.java    |   64 +-
 .../internal/cache/InitialImageOperation.java      |    6 +-
 .../geode/internal/cache/InterestFilter.java       |   10 +-
 .../apache/geode/internal/cache/InternalCache.java |   34 +-
 .../geode/internal/cache/InternalCacheEvent.java   |   20 +-
 .../geode/internal/cache/InternalDataView.java     |   10 +-
 ...{DiskStoreTask.java => InternalEntryEvent.java} |    9 +-
 .../geode/internal/cache/InternalRegion.java       |   80 +-
 .../geode/internal/cache/LoaderHelperFactory.java  |    4 +-
 .../apache/geode/internal/cache/LocalRegion.java   |   75 +-
 .../cache/OfflineCompactionDiskRegion.java         |   16 +-
 .../org/apache/geode/internal/cache/Oplog.java     |   34 +-
 .../org/apache/geode/internal/cache/OplogSet.java  |    8 +-
 .../internal/cache/PRHARedundancyProvider.java     |   38 +-
 .../geode/internal/cache/PRQueryProcessor.java     |   19 +-
 .../geode/internal/cache/PartitionedRegion.java    |    4 +-
 .../internal/cache/PartitionedRegionDataStore.java |    8 +-
 .../cache/PartitionedRegionQueryEvaluator.java     |   49 +-
 .../internal/cache/PlaceHolderDiskRegion.java      |   27 +-
 .../geode/internal/cache/PoolFactoryImpl.java      |   41 +-
 .../geode/internal/cache/ProxyRegionMap.java       |   18 +-
 .../geode/internal/cache/RegionEntryFactory.java   |    8 +-
 .../cache/RegionEntrySynchronizationListener.java  |    2 +-
 .../org/apache/geode/internal/cache/RegionMap.java |    9 +-
 .../{DiskStoreTask.java => RegionMapOwner.java}    |    9 +-
 .../apache/geode/internal/cache/RegionQueue.java   |   32 +-
 .../cache/RemoteContainsKeyValueMessage.java       |    6 -
 .../internal/cache/RemoteFetchEntryMessage.java    |    7 +-
 .../geode/internal/cache/RemoteGetMessage.java     |    4 -
 .../internal/cache/RemoteOperationMessage.java     |    2 +-
 .../geode/internal/cache/SerializationHelper.java  |    4 +-
 .../geode/internal/cache/StateFlushOperation.java  |    4 +-
 .../geode/internal/cache/TXCommitMessage.java      |   18 +-
 .../geode/internal/cache/TXEntryStateFactory.java  |    6 +-
 .../internal/cache/TXRemoteCommitMessage.java      |    4 -
 .../org/apache/geode/internal/cache/TXState.java   |   25 +-
 .../geode/internal/cache/TXStateInterface.java     |   79 +-
 .../apache/geode/internal/cache/TXStateProxy.java  |   40 +-
 .../apache/geode/internal/cache/TXStateStub.java   |   21 +-
 .../geode/internal/cache/TransactionMessage.java   |   14 +-
 .../geode/internal/cache/TxEntryFactory.java       |    4 +-
 .../geode/internal/cache/VMLRURegionMap.java       |   32 +-
 .../apache/geode/internal/cache/VMRegionMap.java   |    2 +-
 .../geode/internal/cache/ValidatingDiskRegion.java |    5 -
 .../geode/internal/cache/backup/AbortBackup.java}  |   19 +-
 ...eBackupFactory.java => AbortBackupFactory.java} |   10 +-
 ...kupOperation.java => AbortBackupOperation.java} |   35 +-
 ...BackupResponse.java => AbortBackupRequest.java} |   51 +-
 .../cache/backup/BackupDataStoreHelper.java        |   14 +-
 .../geode/internal/cache/backup/BackupLock.java    |  114 --
 .../internal/cache/backup/BackupResponse.java      |    3 +-
 .../geode/internal/cache/backup/BackupService.java |  161 ++
 .../backup/{BackupManager.java => BackupTask.java} |  125 +-
 .../cache/backup/FileSystemBackupDestination.java  |    2 +-
 .../geode/internal/cache/backup/FinishBackup.java  |   13 +-
 .../internal/cache/backup/FinishBackupFactory.java |   12 +-
 .../cache/backup/FinishBackupOperation.java        |   17 +-
 .../internal/cache/backup/FinishBackupRequest.java |   34 +-
 .../geode/internal/cache/backup/PrepareBackup.java |   12 +-
 .../cache/backup/PrepareBackupFactory.java         |   11 +-
 .../cache/backup/PrepareBackupOperation.java       |   15 +-
 .../cache/backup/PrepareBackupRequest.java         |   28 +-
 .../cache/backup/TemporaryBackupFiles.java         |    3 +-
 .../client/protocol/ClientProtocolService.java     |    5 +-
 .../cache/control/InternalResourceManager.java     |   16 +-
 .../internal/cache/control/MemoryMonitor.java      |   12 +-
 .../cache/control/OffHeapMemoryMonitor.java        |   16 +-
 .../internal/cache/control/ResourceEvent.java      |    6 +-
 .../internal/cache/control/ResourceListener.java   |    2 +-
 .../internal/cache/control/ResourceMonitor.java    |    6 +-
 .../cache/entries/AbstractRegionEntry.java         |    2 +-
 .../geode/internal/cache/entries/DiskEntry.java    |   51 +-
 .../internal/cache/entries/HashRegionEntry.java    |    9 +-
 .../internal/cache/entries/OffHeapRegionEntry.java |    4 +-
 .../cache/eviction/EvictionListBuilder.java        |   10 +-
 .../cache/eviction/LRUListWithAsyncSorting.java    |    1 -
 .../internal/cache/execute/AbstractExecution.java  |    6 +-
 .../internal/cache/execute/InternalExecution.java  |   10 +-
 .../execute/InternalRegionFunctionContext.java     |    7 +-
 .../cache/execute/InternalResultSender.java        |    8 +-
 .../cache/execute/MultiRegionFunctionContext.java  |    4 +-
 .../geode/internal/cache/extension/Extensible.java |    2 +-
 .../internal/cache/ha/HAContainerWrapper.java      |   18 +-
 .../geode/internal/cache/ha/HARegionQueue.java     |   24 +-
 .../geode/internal/cache/locks/TXLockId.java       |   10 +-
 .../internal/cache/locks/TXRegionLockRequest.java  |    8 +-
 .../cache/map/CacheModificationLock.java}          |   29 +-
 .../geode/internal/cache/map/FocusedRegionMap.java |   45 +
 .../geode/internal/cache/map/RegionMapDestroy.java |  741 ++++++++
 .../geode/internal/cache/partitioned/Bucket.java   |   16 +-
 .../cache/partitioned/ContainsKeyValueMessage.java |    3 -
 .../internal/cache/partitioned/GetMessage.java     |   28 +-
 .../internal/cache/partitioned/InternalPRInfo.java |    5 +-
 .../partitioned/InternalPartitionDetails.java      |    4 +-
 .../cache/partitioned/OfflineMemberDetails.java    |    4 +-
 .../cache/partitioned/PREntriesIterator.java       |    4 +-
 .../partitioned/PartitionedRegionObserver.java     |    6 +-
 .../cache/partitioned/PutAllPRMessage.java         |    6 +-
 .../internal/cache/partitioned/RegionAdvisor.java  |   29 +-
 .../cache/partitioned/RemoveAllPRMessage.java      |    6 +-
 .../partitioned/rebalance/BucketOperator.java      |    8 +-
 .../rebalance/PartitionedRegionLoadModel.java      |    7 +-
 .../partitioned/rebalance/RebalanceDirector.java   |    8 +-
 .../cache/persistence/DiskInitFileInterpreter.java |   10 +-
 .../cache/persistence/DiskRecoveryStore.java       |   44 +-
 .../internal/cache/persistence/DiskRegionView.java |  123 +-
 .../cache/persistence/PersistenceAdvisor.java      |   32 +-
 .../cache/persistence/PersistenceAdvisorImpl.java  |   18 +-
 .../persistence/PersistenceObserverHolder.java     |   16 +-
 .../cache/persistence/PersistentMemberManager.java |   12 +-
 .../cache/persistence/PersistentMemberView.java    |   42 +-
 .../cache/persistence/PersistentStateListener.java |    8 +-
 .../UninterruptibleRandomAccessFile.java           |    4 +-
 .../internal/cache/persistence/query/IndexMap.java |    2 +-
 .../cache/persistence/query/ResultBag.java         |    2 +-
 .../cache/persistence/query/ResultList.java        |    2 +-
 .../cache/persistence/query/ResultMap.java         |    2 +-
 .../cache/persistence/query/ResultSet.java         |    2 +-
 .../apache/geode/internal/cache/properties.html    |    4 +-
 .../internal/cache/tier/ClientSideHandshake.java   |   40 +
 .../geode/internal/cache/tier/ConnectionProxy.java |    2 +-
 .../{DiskStoreTask.java => tier/Encryptor.java}    |   10 +-
 ...ientHandShake.java => ServerSideHandshake.java} |   23 +-
 .../internal/cache/tier/sockets/AcceptorImpl.java  |   15 +-
 .../internal/cache/tier/sockets/BaseCommand.java   |    2 +-
 .../cache/tier/sockets/CacheClientNotifier.java    |  109 +-
 .../cache/tier/sockets/CacheClientProxy.java       |   11 +-
 .../cache/tier/sockets/CacheClientUpdater.java     |   40 +-
 .../internal/cache/tier/sockets/ClientMessage.java |    2 +-
 .../cache/tier/sockets/ClientUpdateMessage.java    |   44 +-
 .../tier/sockets/ClientUpdateMessageImpl.java      |   20 +-
 .../cache/tier/sockets/CommBufferPool.java         |    4 +-
 .../cache/tier/sockets/CommandInitializer.java     |    5 +
 .../internal/cache/tier/sockets/EncryptorImpl.java |  749 ++++++++
 .../internal/cache/tier/sockets/HandShake.java     | 1801 --------------------
 .../internal/cache/tier/sockets/Handshake.java     |  527 ++++++
 .../geode/internal/cache/tier/sockets/Message.java |  130 +-
 .../cache/tier/sockets/MessageIdExtractor.java     |    6 +-
 .../internal/cache/tier/sockets/MessageStats.java  |    8 +-
 .../tier/sockets/OldClientSupportService.java      |    8 +-
 .../tier/sockets/OriginalServerConnection.java     |    6 +-
 .../tier/sockets/ProtobufServerConnection.java     |    2 +-
 .../cache/tier/sockets/ServerConnection.java       |   74 +-
 ...rocessor.java => ServerHandshakeProcessor.java} |  186 +-
 .../cache/tier/sockets/ServerQueueStatus.java      |   58 +-
 .../tier/sockets/ServerSideHandshakeImpl.java      |  212 +++
 .../tier/sockets/command/ExecuteFunction.java      |   11 +-
 .../tier/sockets/command/ExecuteFunction65.java    |   11 +-
 .../tier/sockets/command/ExecuteFunction66.java    |   10 +-
 .../sockets/command/ExecuteRegionFunction.java     |   11 +-
 .../sockets/command/ExecuteRegionFunction61.java   |   11 +-
 .../sockets/command/ExecuteRegionFunction65.java   |   11 +-
 .../sockets/command/ExecuteRegionFunction66.java   |   11 +-
 .../command/ExecuteRegionFunctionSingleHop.java    |   11 +-
 .../geode/internal/cache/tx/ClientTXStateStub.java |    3 +-
 .../internal/cache/versions/VersionHolder.java     |    4 +-
 .../internal/cache/vmotion/VMotionObserver.java    |    6 +-
 .../internal/cache/wan/AbstractGatewaySender.java  |    3 +-
 .../wan/AbstractGatewaySenderEventProcessor.java   |   15 +-
 .../cache/wan/DistributedSystemListener.java       |    4 +-
 .../cache/wan/GatewaySenderEventDispatcher.java    |   10 +-
 ...waySenderQueueEntrySynchronizationListener.java |    4 +-
 ...aySenderQueueEntrySynchronizationOperation.java |    7 +-
 .../cache/wan/InternalGatewaySenderFactory.java    |   13 +-
 ...currentParallelGatewaySenderEventProcessor.java |    8 +-
 .../ParallelGatewaySenderEventProcessor.java       |    3 +-
 .../parallel/ParallelQueueBatchRemovalMessage.java |    6 -
 ...oncurrentSerialGatewaySenderEventProcessor.java |    3 -
 .../serial/SerialGatewaySenderEventProcessor.java  |   30 +-
 .../internal/cache/xmlcache/CacheCreation.java     |   38 +-
 .../cache/xmlcache/ClientCacheCreation.java        |    3 +-
 .../geode/internal/cache/xmlcache/Declarable2.java |    2 +-
 .../internal/cache/xmlcache/PropertyResolver.java  |   16 +-
 .../org/apache/geode/internal/concurrent/AL.java   |   24 +-
 .../geode/internal/concurrent/MapCallback.java     |   31 +-
 .../geode/internal/concurrent/MapResult.java       |    4 +-
 .../internal/datasource/ConnectionPoolCache.java   |    8 +-
 .../internal/datasource/ConnectionProvider.java    |    8 +-
 .../internal/datasource/DataSourceResources.java   |   14 +-
 .../geode/internal/i18n/LocalizedStrings.java      |    6 +-
 .../org/apache/geode/internal/i18n/StringId.java   |   10 +-
 .../org/apache/geode/internal/lang/Filter.java     |    2 +-
 .../org/apache/geode/internal/lang/Initable.java   |    2 +-
 .../geode/internal/lang/MutableIdentifiable.java   |    2 +-
 .../org/apache/geode/internal/lang/Orderable.java  |    2 +-
 .../org/apache/geode/internal/lang/Ordered.java    |    4 +-
 .../geode/internal/lang/SystemPropertyHelper.java  |   41 +-
 .../geode/internal/logging/InternalLogWriter.java  |   40 +-
 .../geode/internal/logging/MergeLogFiles.java      |   12 +-
 .../internal/logging/log4j/GemFireLogger.java      |  171 +-
 .../geode/internal/logging/log4j/LogMarker.java    |  123 +-
 .../geode/internal/memcached/CommandProcessor.java |    2 +-
 .../apache/geode/internal/offheap/DataType.java    |   31 +-
 .../geode/internal/offheap/FreeListManager.java    |   10 +-
 .../geode/internal/offheap/LifecycleListener.java  |   13 +-
 .../geode/internal/offheap/MemoryAllocator.java    |   23 +-
 .../internal/offheap/MemoryAllocatorImpl.java      |   10 +-
 .../apache/geode/internal/offheap/MemoryBlock.java |   24 +-
 .../geode/internal/offheap/MemoryInspector.java    |   14 +-
 .../internal/offheap/MemoryUsageListener.java      |    2 +-
 .../geode/internal/offheap/OffHeapMemoryStats.java |   48 +-
 .../offheap/OutOfOffHeapMemoryListener.java        |    4 +-
 .../apache/geode/internal/offheap/Releasable.java  |    2 +-
 .../org/apache/geode/internal/offheap/Slab.java    |    6 +-
 .../apache/geode/internal/offheap/SlabFactory.java |    2 +-
 .../geode/internal/offheap/StoredObject.java       |   46 +-
 .../security/IntegratedSecurityService.java        |    2 +-
 .../geode/internal/sequencelog/SequenceLogger.java |    8 +-
 .../geode/internal/sequencelog/io/Filter.java      |    5 +-
 .../sequencelog/model/GraphReaderCallback.java     |    6 +-
 .../apache/geode/internal/shared/NativeCalls.java  |    4 +-
 .../geode/internal/shared/NativeCallsJNAImpl.java  |    5 +-
 .../geode/internal/size/ObjectGraphSizer.java      |    2 +-
 .../geode/internal/statistics/HostStatSampler.java |    2 +-
 .../internal/statistics/LocalStatListener.java     |    2 +-
 .../geode/internal/statistics/SampleHandler.java   |    8 +-
 .../internal/statistics/StatArchiveFormat.java     |   74 +-
 .../statistics/StatArchiveHandlerConfig.java       |   14 +-
 .../geode/internal/statistics/StatisticId.java     |    4 +-
 .../internal/statistics/StatisticsListener.java    |    2 +-
 .../internal/statistics/StatisticsManager.java     |   20 +-
 .../statistics/StatisticsNotification.java         |   16 +-
 .../internal/statistics/StatisticsSampler.java     |    8 +-
 .../geode/internal/statistics/VMStatsContract.java |    4 +-
 .../statistics/platform/OsStatisticsFactory.java   |    5 +-
 .../apache/geode/internal/tcp/BaseMsgStreamer.java |   12 +-
 .../geode/internal/tcp/ByteBufferInputStream.java  |    3 +-
 .../org/apache/geode/internal/tcp/Connection.java  |   14 +-
 .../geode/internal/tcp/DirectReplySender.java      |    4 -
 .../apache/geode/internal/tcp/ServerDelegate.java  |    8 +-
 .../geode/internal/util/ObjectIntProcedure.java    |    2 +-
 .../apache/geode/internal/util/Transformer.java    |    2 +-
 .../apache/geode/internal/util/Versionable.java    |    8 +-
 .../ConcurrentMapWithReusableEntries.java          |   50 +
 .../concurrent/CustomEntryConcurrentHashMap.java   |   59 +-
 .../java/org/apache/geode/lang/Identifiable.java   |    2 +-
 .../geode/management/AsyncEventQueueMXBean.java    |   28 +-
 .../management/DistributedLockServiceMXBean.java   |   12 +-
 .../geode/management/DistributedRegionMXBean.java  |   98 +-
 .../geode/management/JMXNotificationType.java      |   55 +-
 .../geode/management/JMXNotificationUserData.java  |    6 +-
 .../org/apache/geode/management/LocatorMXBean.java |   16 +-
 .../org/apache/geode/management/ManagerMXBean.java |   14 +-
 .../org/apache/geode/management/RegionMXBean.java  |  104 +-
 .../apache/geode/management/cli/CliMetaData.java   |    6 +-
 .../geode/management/cli/CommandStatement.java     |    8 +-
 .../org/apache/geode/management/cli/Result.java    |   18 +-
 .../management/internal/ManagementConstants.java   |  134 +-
 .../internal/NotificationBroadCasterProxy.java     |    2 +-
 .../geode/management/internal/ProxyInterface.java  |    4 +-
 .../geode/management/internal/ProxyListener.java   |    6 +-
 .../internal/beans/AggregateHandler.java           |   10 +-
 .../internal/beans/CacheServiceMBeanBase.java      |    4 +-
 .../internal/beans/MemberMBeanBridge.java          |   21 +-
 .../internal/cli/commands/AlterRegionCommand.java  |    9 +-
 .../internal/cli/commands/CreateRegionCommand.java |  110 +-
 .../cli/commands/DescribeRegionCommand.java        |  211 ++-
 .../internal/cli/commands/GfshCommand.java         |    2 +-
 .../internal/cli/converters/EnumConverter.java     |   15 +-
 ...nverter.java => ExpirationActionConverter.java} |   36 +-
 .../cli/domain/RegionDescriptionPerMember.java     |   19 -
 .../functions/FetchRegionAttributesFunction.java   |   61 +-
 .../cli/functions/RegionAlterFunction.java         |   45 +-
 .../cli/functions/RegionAttributesWrapper.java     |  108 ++
 .../cli/functions/RegionCreateFunction.java        |   16 +-
 .../internal/cli/functions/RegionFunctionArgs.java |  137 +-
 .../management/internal/cli/json/GfJsonArray.java  |    2 -
 .../internal/cli/shell/OperationInvoker.java       |   23 +-
 .../functions/GetRegionNamesFunction.java          |    4 +-
 .../internal/security/AccessControlMXBean.java     |    2 +-
 .../membership/ClientMembershipEvent.java          |    6 +-
 .../membership/ClientMembershipListener.java       |    6 +-
 .../management/membership/MembershipEvent.java     |    4 +-
 .../management/membership/MembershipListener.java  |    6 +-
 .../java/org/apache/geode/pdx/JSONFormatter.java   |  136 +-
 .../java/org/apache/geode/pdx/PdxInstance.java     |   22 +-
 .../org/apache/geode/pdx/PdxInstanceFactory.java   |   57 +-
 .../main/java/org/apache/geode/pdx/PdxReader.java  |   52 +-
 .../java/org/apache/geode/pdx/PdxSerializable.java |    4 +-
 .../java/org/apache/geode/pdx/PdxSerializer.java   |    4 +-
 .../main/java/org/apache/geode/pdx/PdxWriter.java  |   61 +-
 .../org/apache/geode/pdx/WritablePdxInstance.java  |    2 +-
 .../apache/geode/pdx/internal/ComparableEnum.java  |    6 +-
 .../geode/pdx/internal/ConvertableToBytes.java     |    2 +-
 .../geode/pdx/internal/InternalPdxReader.java      |   96 +-
 .../geode/pdx/internal/TypeRegistration.java       |   36 +-
 .../java/org/apache/geode/ra/GFConnection.java     |    2 +-
 .../org/apache/geode/ra/GFConnectionFactory.java   |    2 +-
 .../org/apache/geode/redis/internal/Executor.java  |    2 +-
 .../apache/geode/redis/internal/Extendable.java    |    2 +-
 .../org/apache/geode/security/AuthInitialize.java  |    5 +-
 .../org/apache/geode/internal/privatekey.ser       |  Bin 756 -> 0 bytes
 .../org/apache/geode/internal/publickey.ser        |  Bin 1029 -> 0 bytes
 .../sanctioned-geode-core-serializables.txt        |    4 +-
 .../geode/cache/ConnectionPoolDUnitTest.java       |   16 +-
 .../AutoConnectionSourceImplJUnitTest.java         |    5 +
 .../client/internal/QueueManagerJUnitTest.java     |   50 +-
 .../cache30/DistributedAckRegionCCEDUnitTest.java  |    2 +-
 .../geode/distributed/ServerLauncherDUnitTest.java |  112 ++
 .../ServerLauncherDUnitTestHelper.java}            |   34 +-
 .../gms/messenger/GMSEncryptJUnitTest.java         |  457 +----
 .../internal/cache/ARMLockTestHookAdapter.java     |   18 +-
 .../internal/cache/AbstractRegionJUnitTest.java    |  668 +-------
 .../internal/cache/AbstractRegionMapTest.java      |  214 +--
 .../internal/cache/ClearRvvLockingDUnitTest.java   |    8 +-
 .../internal/cache/ClearTXLockingDUnitTest.java    |    2 +-
 .../cache/ClientServerTransactionDUnitTest.java    |    4 +-
 ...stroyEntryWithConcurrentOperationJUnitTest.java |  229 ---
 .../cache/DiskStoreImplIntegrationTest.java        |   54 +-
 .../geode/internal/cache/FlusherThreadTest.java    |   76 +
 .../geode/internal/cache/OplogFlushTest.java       |   10 +-
 .../geode/internal/cache/OplogJUnitTest.java       |    4 +-
 .../internal/cache/SimpleDiskRegionJUnitTest.java  |    2 +-
 ...ommitMessageBackwardCompatibilityDUnitTest.java |  640 +++++++
 ...actoryTest.java => AbortBackupFactoryTest.java} |   23 +-
 .../cache/backup/AbortBackupOperationTest.java     |  183 ++
 ...actoryTest.java => AbortBackupRequestTest.java} |   61 +-
 .../cache/backup/BackupIntegrationTest.java        |   50 +-
 .../internal/cache/backup/BackupLockTest.java      |  105 --
 .../backup/BackupPrepareAndFinishMsgDUnitTest.java |   50 +-
 .../internal/cache/backup/BackupServiceTest.java   |   90 +
 .../cache/backup/FinishBackupFactoryTest.java      |    8 +-
 .../cache/backup/FinishBackupOperationTest.java    |   14 +-
 .../cache/backup/FinishBackupRequestTest.java      |   21 +-
 .../backup/IncrementalBackupDistributedTest.java   |    2 +-
 ...titionedBackupPrepareAndFinishMsgDUnitTest.java |    4 +-
 .../cache/backup/PrepareBackupFactoryTest.java     |    7 +-
 .../cache/backup/PrepareBackupOperationTest.java   |   15 +-
 .../cache/backup/PrepareBackupRequestTest.java     |   15 +-
 ...eplicateBackupPrepareAndFinishMsgDUnitTest.java |    4 +-
 .../cache/eviction/EvictionListBuilderTest.java    |   80 +
 .../ClientFunctionTimeoutRegressionTest.java       |    4 +-
 .../internal/cache/ha/HARegionQueueDUnitTest.java  |   88 +-
 .../DestroyEntryDuringCloseIntegrationTest.java    |   97 ++
 .../internal/cache/map/RegionMapDestroyTest.java   |  658 +++++++
 .../cache/partitioned/PersistPRKRFDUnitTest.java   |  258 ---
 .../partitioned/PersistPRKRFIntegrationTest.java   |  176 ++
 ...dCompatibilityHigherVersionClientDUnitTest.java |    5 +-
 .../tier/sockets/ClientServerMiscDUnitTest.java    |   55 +
 .../{HandShakeTest.java => HandshakeTest.java}     |   10 +-
 .../cache/tier/sockets/MessageIdExtractorTest.java |    9 +-
 .../cache/tier/sockets/MessageJUnitTest.java       |   58 +
 .../cache/tier/sockets/ServerConnectionTest.java   |   24 +-
 .../sockets/command/ExecuteFunction65Test.java     |    5 +-
 .../sockets/command/ExecuteFunction66Test.java     |    4 +-
 .../tier/sockets/command/ExecuteFunctionTest.java  |    7 +-
 .../cache/wan/AsyncEventQueueTestBase.java         |   18 +-
 ...UnitTest.java => SystemPropertyHelperTest.java} |   43 +-
 .../geode/internal/offheap/DataTypeJUnitTest.java  |  106 +-
 .../offheap/OutOfOffHeapMemoryDUnitTest.java       |    6 +-
 .../security/IntegratedSecurityServiceTest.java    |    4 +-
 .../beans/DistributedSystemBridgeJUnitTest.java    |   27 +-
 .../internal/cli/GfshParserConverterTest.java      |   23 +
 .../cli/commands/AlterCompressorDUnitTest.java     |  249 +++
 .../cli/commands/AlterRegionCommandDUnitTest.java  |  107 +-
 .../cli/commands/CreateRegionCommandDUnitTest.java |  155 ++
 .../cli/commands/CreateRegionCommandTest.java      |   40 +-
 ...DeployCommandFunctionRegistrationDUnitTest.java |   11 +-
 .../cli/commands/DescribeRegionDUnitTest.java      |  107 +-
 .../internal/cli/commands/TestCompressor1.java}    |   39 +-
 .../cli/functions/ExpirationAttrsTest.java         |   67 +-
 .../geode/pdx/internal/MultipleCacheJUnitTest.java |  123 ++
 .../ClientRegisterInterestAuthDUnitTest.java       |   39 +-
 .../apache/geode/security/SecurityTestUtil.java    |    8 +
 .../generator/LdapUserCredentialGenerator.java     |   20 +-
 .../geode/test/junit/rules/ServerStarterRule.java  |   10 +
 .../apache/geode/codeAnalysis/excludedClasses.txt  |    1 -
 .../codeAnalysis/sanctionedDataSerializables.txt   |    8 +-
 .../internal/deployment/ImplementsFunction.java    |   17 +
 .../tier/sockets/ClientServerMiscBCDUnitTest.java  |   10 +
 .../geode/experimental/driver/JSONWrapper.java     |    6 +-
 geode-json/src/main/java/org/json/JSONString.java  |    2 +-
 .../java/org/apache/geode/test/junit/Repeat.java   |    2 +-
 .../java/org/apache/geode/test/junit/Retry.java    |    2 +-
 .../serializable/FieldsOfTemporaryFolder.java      |    6 +-
 .../junit/rules/serializable/FieldsOfTestName.java |    2 +-
 .../junit/rules/serializable/FieldsOfTimeout.java  |    6 +-
 .../geode/test/junit/runners/SuiteRunner.java      |    2 +-
 .../org/apache/geode/cache/lucene/LuceneIndex.java |   10 +-
 .../geode/cache/lucene/LuceneIndexFactory.java     |    2 +-
 .../org/apache/geode/cache/lucene/LuceneQuery.java |   12 +-
 .../geode/cache/lucene/LuceneQueryFactory.java     |    8 +-
 .../geode/cache/lucene/LuceneQueryProvider.java    |    2 +-
 .../geode/cache/lucene/LuceneResultStruct.java     |    6 +-
 .../apache/geode/cache/lucene/LuceneService.java   |   18 +-
 .../cache/lucene/PageableLuceneQueryResults.java   |    8 +-
 .../geode/cache/lucene/internal/IndexListener.java |    8 +-
 .../cache/lucene/internal/InternalLuceneIndex.java |    6 +-
 .../internal/repository/IndexRepository.java       |    4 +-
 .../internal/repository/IndexResultCollector.java  |    4 +-
 .../lucene/management/LuceneServiceMXBean.java     |    6 +-
 .../src/main/proto/v1/clientProtocol.proto         |    5 +
 .../src/main/proto/v1/function_API.proto           |   28 +-
 .../v1/LocatorMessageExecutionContext.java         |    4 +-
 .../protobuf/v1/MessageExecutionContext.java       |    4 +-
 .../protobuf/v1/ProtobufProtocolService.java       |    4 +-
 .../protobuf/v1/ProtobufSerializationService.java  |    6 +-
 .../protobuf/v1/ServerMessageExecutionContext.java |   12 +-
 ...uteFunctionOnRegionRequestOperationHandler.java |  135 ++
 .../registry/ProtobufOperationContextRegistry.java |   13 +-
 .../internal/protocol/TestExecutionContext.java    |    4 +-
 .../v1/FunctionExecutionIntegrationTest.java       |  360 ++++
 ...onOnRegionRequestOperationHandlerJUnitTest.java |  161 ++
 .../GetAllRequestOperationHandlerJUnitTest.java    |    2 -
 ...egionNamesRequestOperationHandlerJUnitTest.java |    6 +-
 .../GetRegionRequestOperationHandlerJUnitTest.java |    6 +-
 .../GetRequestOperationHandlerJUnitTest.java       |    2 -
 .../GetServerOperationHandlerJUnitTest.java        |    2 -
 .../v1/operations/OperationHandlerJUnitTest.java   |    5 +-
 .../PutAllRequestOperationHandlerJUnitTest.java    |    1 -
 .../PutRequestOperationHandlerJUnitTest.java       |    2 -
 .../RemoveRequestOperationHandlerJUnitTest.java    |    2 -
 geode-pulse/src/main/webapp/META-INF/NOTICE        |    2 +-
 .../client/internal/GatewaySenderBatchOp.java      |    5 +-
 .../geode/internal/cache/wan/WANTestBase.java      |    5 +-
 .../ConcurrentParallelGatewaySenderDUnitTest.java  |   76 +-
 .../cache/wan/wancommand/WANCommandUtils.java      |    3 +-
 .../web/controllers/AbstractBaseController.java    |    2 +-
 .../web/controllers/BaseControllerAdvice.java      |   15 +
 .../web/controllers/FunctionAccessController.java  |   37 +-
 .../CustomMappingJackson2HttpMessageConverter.java |    4 +-
 .../internal/web/security/RestSecurityService.java |   13 +
 geode-web-api/src/main/webapp/META-INF/NOTICE      |    2 +-
 geode-web/src/main/webapp/META-INF/NOTICE          |    2 +-
 742 files changed, 15142 insertions(+), 11871 deletions(-)
 create mode 100755 ci/scripts/capture-call-stacks.sh
 create mode 100644 geode-assembly/src/test/java/org/apache/geode/rest/internal/web/RestFunctionExecuteDUnitTest.java
 create mode 100644 geode-core/src/main/java/org/apache/geode/cache/client/internal/ClientSideHandshakeImpl.java
 copy geode-core/src/main/java/org/apache/geode/internal/cache/{DiskStoreTask.java => InternalEntryEvent.java} (80%)
 copy geode-core/src/main/java/org/apache/geode/internal/cache/{DiskStoreTask.java => RegionMapOwner.java} (89%)
 copy geode-core/src/{test/java/org/apache/geode/internal/cache/backup/ReplicateBackupPrepareAndFinishMsgDUnitTest.java => main/java/org/apache/geode/internal/cache/backup/AbortBackup.java} (72%)
 copy geode-core/src/main/java/org/apache/geode/internal/cache/backup/{PrepareBackupFactory.java => AbortBackupFactory.java} (83%)
 copy geode-core/src/main/java/org/apache/geode/internal/cache/backup/{PrepareBackupOperation.java => AbortBackupOperation.java} (66%)
 copy geode-core/src/main/java/org/apache/geode/internal/cache/backup/{BackupResponse.java => AbortBackupRequest.java} (50%)
 delete mode 100644 geode-core/src/main/java/org/apache/geode/internal/cache/backup/BackupLock.java
 create mode 100644 geode-core/src/main/java/org/apache/geode/internal/cache/backup/BackupService.java
 rename geode-core/src/main/java/org/apache/geode/internal/cache/backup/{BackupManager.java => BackupTask.java} (84%)
 copy extensions/geode-modules/src/main/java/org/apache/geode/modules/gatewaydelta/GatewayDeltaEvent.java => geode-core/src/main/java/org/apache/geode/internal/cache/entries/HashRegionEntry.java (74%)
 copy geode-core/src/main/java/org/apache/geode/{distributed/internal/QueueStatHelper.java => internal/cache/map/CacheModificationLock.java} (60%)
 create mode 100644 geode-core/src/main/java/org/apache/geode/internal/cache/map/FocusedRegionMap.java
 create mode 100644 geode-core/src/main/java/org/apache/geode/internal/cache/map/RegionMapDestroy.java
 create mode 100644 geode-core/src/main/java/org/apache/geode/internal/cache/tier/ClientSideHandshake.java
 copy geode-core/src/main/java/org/apache/geode/internal/cache/{DiskStoreTask.java => tier/Encryptor.java} (74%)
 rename geode-core/src/main/java/org/apache/geode/internal/cache/tier/{ClientHandShake.java => ServerSideHandshake.java} (64%)
 create mode 100644 geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/EncryptorImpl.java
 delete mode 100644 geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/HandShake.java
 create mode 100644 geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/Handshake.java
 rename geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/{ServerHandShakeProcessor.java => ServerHandshakeProcessor.java} (72%)
 create mode 100644 geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/ServerSideHandshakeImpl.java
 create mode 100644 geode-core/src/main/java/org/apache/geode/internal/util/concurrent/ConcurrentMapWithReusableEntries.java
 copy geode-core/src/main/java/org/apache/geode/management/internal/cli/converters/{EnumConverter.java => ExpirationActionConverter.java} (50%)
 create mode 100644 geode-core/src/main/java/org/apache/geode/management/internal/cli/functions/RegionAttributesWrapper.java
 delete mode 100644 geode-core/src/main/resources/org/apache/geode/internal/privatekey.ser
 delete mode 100644 geode-core/src/main/resources/org/apache/geode/internal/publickey.ser
 create mode 100644 geode-core/src/test/java/org/apache/geode/distributed/ServerLauncherDUnitTest.java
 copy geode-core/src/{main/java/org/apache/geode/internal/admin/HealthListener.java => test/java/org/apache/geode/distributed/ServerLauncherDUnitTestHelper.java} (58%)
 delete mode 100644 geode-core/src/test/java/org/apache/geode/internal/cache/DestroyEntryWithConcurrentOperationJUnitTest.java
 create mode 100644 geode-core/src/test/java/org/apache/geode/internal/cache/FlusherThreadTest.java
 create mode 100644 geode-core/src/test/java/org/apache/geode/internal/cache/TxCommitMessageBackwardCompatibilityDUnitTest.java
 copy geode-core/src/test/java/org/apache/geode/internal/cache/backup/{PrepareBackupFactoryTest.java => AbortBackupFactoryTest.java} (77%)
 create mode 100644 geode-core/src/test/java/org/apache/geode/internal/cache/backup/AbortBackupOperationTest.java
 copy geode-core/src/test/java/org/apache/geode/internal/cache/backup/{PrepareBackupFactoryTest.java => AbortBackupRequestTest.java} (53%)
 delete mode 100644 geode-core/src/test/java/org/apache/geode/internal/cache/backup/BackupLockTest.java
 create mode 100644 geode-core/src/test/java/org/apache/geode/internal/cache/backup/BackupServiceTest.java
 create mode 100644 geode-core/src/test/java/org/apache/geode/internal/cache/eviction/EvictionListBuilderTest.java
 create mode 100644 geode-core/src/test/java/org/apache/geode/internal/cache/map/DestroyEntryDuringCloseIntegrationTest.java
 create mode 100644 geode-core/src/test/java/org/apache/geode/internal/cache/map/RegionMapDestroyTest.java
 delete mode 100644 geode-core/src/test/java/org/apache/geode/internal/cache/partitioned/PersistPRKRFDUnitTest.java
 create mode 100644 geode-core/src/test/java/org/apache/geode/internal/cache/partitioned/PersistPRKRFIntegrationTest.java
 rename geode-core/src/test/java/org/apache/geode/internal/cache/tier/sockets/{HandShakeTest.java => HandshakeTest.java} (86%)
 rename geode-core/src/test/java/org/apache/geode/internal/lang/{SystemPropertyHelperJUnitTest.java => SystemPropertyHelperTest.java} (65%)
 create mode 100644 geode-core/src/test/java/org/apache/geode/management/internal/cli/commands/AlterCompressorDUnitTest.java
 copy geode-core/src/{main/java/org/apache/geode/distributed/internal/ThrottledQueueStatHelper.java => test/java/org/apache/geode/management/internal/cli/commands/TestCompressor1.java} (52%)
 create mode 100644 geode-core/src/test/java/org/apache/geode/pdx/internal/MultipleCacheJUnitTest.java
 copy geode-lucene/src/main/java/org/apache/geode/cache/lucene/internal/InternalLuceneIndex.java => geode-protobuf-messages/src/main/proto/v1/function_API.proto (62%)
 create mode 100644 geode-protobuf/src/main/java/org/apache/geode/internal/protocol/protobuf/v1/operations/ExecuteFunctionOnRegionRequestOperationHandler.java
 create mode 100644 geode-protobuf/src/test/java/org/apache/geode/internal/protocol/protobuf/v1/FunctionExecutionIntegrationTest.java
 create mode 100644 geode-protobuf/src/test/java/org/apache/geode/internal/protocol/protobuf/v1/operations/ExecuteFunctionOnRegionRequestOperationHandlerJUnitTest.java

-- 
To stop receiving notification emails like this one, please contact
lgallinat@apache.org.

Mime
View raw message