This is an automated email from the ASF dual-hosted git repository.
zhouxj pushed a change to branch feature/GEODE-3967
in repository https://gitbox.apache.org/repos/asf/geode.git.
omit d6332e0 GEODE-3967: There're following 6 problems fixed here: 1) When
ConcurrentCacheModificationException happened, GatewaySenderEventImpl should
save the status and notify gatewaysender if it hold primary queue, because
other member might have put the event into the secondary queue. 2) In
AbstractUpdateOperation's doPutOrCreate's 3 tries of basicUpdate, the 3rd try
should allow both create and update. 3) Let event with CME not to dispatch. The
old logic does not allow CME eve [...]
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)
add 8670ade GEODE-4618: Mark test as flaky while root cause is
investigated (#1398)
add 82f41a4 GEODE-4616: Missed capturing the callstacks into the
artifacts. (#1399)
add aa46923 GEODE-3974: improve permission for Internal functions (#1395)
add 8e9d4ce GEODE-4596: remove an unused TestFunction class. (#1386)
add 952db5f GEODE-1758: Refactor, test and clean up TypeUtils (#1367)
add c248b1e Use openjdk:8 for base docker image.
add f69130e GEODE-4609: Create region gfsh command option
--skip-if-exists defaults to false
add e1781fb GEODE-4354: On create region command change option
--skip-if-exists to --if-not-exists
add 31b7f15 GEODE-4353: Deprecating security-client-dhalgo
add ad5a311 [GEODE-4630] Add timestamps directories to subdivide test
artifacts. (#1412)
add 45312b9 GEODE-4621: Schedule scans only if list is above max eviction
attempt… (#1408)
add cd92f9a GEODE-4631: need a public class to mock (#1413)
add 05e2c8c GEODE-4573 set JTAPaused flag even if JTA is not yet
bootstrapped when pauseTransaction is executed. (#1403)
add fe31227 GEODE-4607: Remove protobuf Request and Response objects,
renumber message types (#1389)
add ff215d4 GEODE-4435 Move queueSize stat increment to after writing to
disk. (#1397)
add a39394e GEODE-4320: Reconcile disparity between Banner and
AbstractConfig
add 24601a6 GEODE-4629: Ignore tests that assume non-approximate LRU
(#1417)
add f848621 GEODE-4588: remove call of getAnyInstance (#1394)
add b1ba8fd GEODE-4583: remove getAnyInstance calls (#1407)
add 17654b9 GEODE-2569: Avoid unhelpful log message via a null check.
(#1404)
add bbea69a GEODE-3540: unable to gfsh destroy gateway-sender (#1414)
add b7c4bd8 merge from feature/GEODE-3643
add f6a982e GEODE-4639: Removing Java PathFinder concurrency test runner
add 783005a GEODE-4566: remove getInstance calls from PartitionMessage
(#1411)
add 735b44e GEODE-4575: remove getAnyInstance call in CacheCreation
(#1406)
add fc3e144 GEODE-4586: remove getAnyInstance calls from
RegionVersionVector (#1402)
add 75d0f9d GEODE-4629: Fix tests dependant on LRU eviction order (#1423)
add 2685566 GEODE-4372: clean up RemoteOperationMessage classes (#1338)
add 3114c21 GEODE-4636: Update Style XML to allow human-readable spacing
in comments (#1415)
add 03b7c14 GEODE-4642: Remove PowerMock any() method calls from non-mock
invocations.
add 5749ec9 Adding 1.4.0 as an old version to test against
add cb82c21 GEODE-4615 Deadlock shutting down client cache
add 024110c GEODE-4613: always redirect jdk loggers to file no matter
what mode Gfsh is in. (#1424)
add 66dbc8e GEODE-3813: Deprecating RegisterInterest ALL_KEYS and List
behavior (#1376)
add 4a9e651 GEODE-2667: Add API to destroy GatewayReceiver (#1410)
add e7867c5 User Guide: Fixed format issues in <cache> element reference
add 08755b7 GEODE-3967: There're following 6 problems fixed here: 1) When
ConcurrentCacheModificationException happened, GatewaySenderEventImpl should
save the status and notify gatewaysender if it hold primary queue, because
other member might have put the event into the secondary queue. 2) In
AbstractUpdateOperation's doPutOrCreate's 3 tries of basicUpdate, the 3rd try
should allow both create and update. 3) Let event with CME not to dispatch. The
old logic does not allow CME eve [...]
add 7d47d2a GEODE-3967: change version to 150
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (d6332e0)
\
N -- N -- N refs/heads/feature/GEODE-3967 (7d47d2a)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
build.gradle | 1 -
ci/docker/Dockerfile | 8 +-
ci/pipelines/docker-images.yml | 9 +-
ci/scripts/test-archive.sh | 9 +-
etc/eclipse-java-google-style.xml | 598 +++---
.../geode/modules/util/BootstrappingFunction.java | 12 +-
.../cli/commands/GfshStartLocatorLogTest.java | 3 +-
.../LogsAreFullyRedactedAcceptanceTest.java | 126 ++
.../internal/web/RestFunctionExecuteDUnitTest.java | 124 ++
.../internal/web/RestSecurityIntegrationTest.java | 150 +-
geode-assembly/src/test/resources/security.json | 45 +
.../source/subnavs/geode-subnav.erb | 3 -
geode-concurrency-test/build.gradle | 8 -
.../src/main/java/java/net/InetAddress.java | 155 --
.../test/concurrency/ConcurrentTestRunner.java | 11 +-
.../annotation/ConcurrentTestConfig.java | 4 +-
.../geode/test/concurrency/jpf/JpfRunner.java | 98 -
.../test/concurrency/jpf/JpfRunnerConfig.java | 34 -
.../test/concurrency/jpf/ParallelExecutorImpl.java | 87 -
.../test/concurrency/jpf/logging/EmptyLogger.java | 1975 --------------------
...il_concurrent_locks_ReentrantReadWriteLock.java | 42 -
...g_apache_geode_internal_logging_LogService.java | 42 -
...che_geode_internal_logging_log4j_LogMarker.java | 27 -
.../JPF_org_apache_logging_log4j_LogManager.java | 29 -
.../jdbc/internal/cli/AlterConnectionFunction.java | 9 -
.../jdbc/internal/cli/AlterMappingFunction.java | 9 -
.../internal/cli/CreateConnectionFunction.java | 10 -
.../jdbc/internal/cli/CreateMappingFunction.java | 10 -
.../internal/cli/DescribeConnectionFunction.java | 10 -
.../jdbc/internal/cli/DescribeMappingFunction.java | 10 -
.../internal/cli/DestroyConnectionFunction.java | 10 -
.../jdbc/internal/cli/DestroyMappingFunction.java | 10 -
.../jdbc/internal/cli/JdbcCliFunction.java | 15 +-
.../jdbc/internal/cli/ListConnectionFunction.java | 9 -
.../jdbc/internal/cli/ListMappingFunction.java | 9 -
.../cli/JDBCConnectorFunctionsSecurityTest.java | 22 +-
geode-core/build.gradle | 13 +-
.../internal/DistributedSystemHealthEvaluator.java | 14 +-
.../apache/geode/cache/CacheExistsException.java | 4 +
.../main/java/org/apache/geode/cache/Region.java | 342 +++-
.../geode/cache/client/internal/GetEntryOp.java | 2 +-
.../cache/client/internal/ServerRegionProxy.java | 3 +-
.../client/internal/SingleHopClientExecutor.java | 10 -
.../internal/locator/LocatorStatusResponse.java | 3 +-
.../internal/pooling/ConnectionManagerImpl.java | 144 +-
.../client/internal/pooling/PooledConnection.java | 4 +
.../cache/query/internal/index/IndexManager.java | 11 +-
.../cache/query/internal/types/TypeUtils.java | 662 ++++---
.../apache/geode/cache/wan/GatewayReceiver.java | 5 +
.../geode/distributed/ConfigurationProperties.java | 2 +
.../internal/ClusterDistributionManager.java | 61 +-
.../distributed/internal/DistributionAdvisor.java | 18 +-
.../distributed/internal/DistributionConfig.java | 3 +-
.../internal/DistributionConfigImpl.java | 6 -
.../distributed/internal/DistributionManager.java | 5 +
.../distributed/internal/FlowControlParams.java | 4 -
.../internal/LonerDistributionManager.java | 27 +-
.../distributed/internal/MembershipListener.java | 15 +-
.../geode/distributed/internal/ProductUseLog.java | 13 +-
.../internal/ReliableReplyProcessor21.java | 3 +-
.../geode/distributed/internal/ReplyException.java | 10 +-
.../distributed/internal/ReplyProcessor21.java | 19 +-
.../geode/distributed/internal/ResourceEvent.java | 1 +
.../distributed/internal/StartupOperation.java | 2 +-
.../internal/deadlock/GemFireDeadlockDetector.java | 5 +-
.../distributed/internal/direct/DirectChannel.java | 31 +-
.../distributed/internal/locks/DLockGrantor.java | 15 +-
.../internal/locks/DLockQueryProcessor.java | 2 +-
.../locks/DLockRecoverGrantorProcessor.java | 2 +-
.../internal/locks/DLockReleaseProcessor.java | 2 +-
.../distributed/internal/locks/DLockService.java | 39 +-
.../internal/locks/DeposeGrantorProcessor.java | 2 +-
.../internal/locks/ElderInitProcessor.java | 2 +-
.../internal/locks/GrantorRequestProcessor.java | 2 +-
.../locks/NonGrantorDestroyedProcessor.java | 2 +-
.../membership/gms/messenger/GMSEncrypt.java | 15 +-
.../internal/streaming/StreamingOperation.java | 2 +-
.../org/apache/geode/internal/AbstractConfig.java | 380 ++--
.../org/apache/geode/internal/DSFIDFactory.java | 32 +-
.../geode/internal/DataSerializableFixedID.java | 22 +-
.../org/apache/geode/internal/ManagerInfo.java | 20 +-
.../admin/remote/RemoteGfManagerAgent.java | 14 +-
.../internal/admin/remote/ShutdownAllRequest.java | 2 +-
.../internal/cache/AbstractBucketRegionQueue.java | 2 +-
.../geode/internal/cache/AbstractRegion.java | 5 +-
.../geode/internal/cache/AbstractRegionMap.java | 12 +-
.../apache/geode/internal/cache/BucketRegion.java | 10 +-
.../geode/internal/cache/BucketRegionQueue.java | 2 +-
.../internal/cache/CreateRegionProcessor.java | 2 +-
.../cache/DestroyPartitionedRegionMessage.java | 1 +
.../apache/geode/internal/cache/DiskRegion.java | 2 +-
.../apache/geode/internal/cache/DiskStoreImpl.java | 206 +-
.../internal/cache/DistTXPrecommitMessage.java | 3 +-
.../internal/cache/DistTXRollbackMessage.java | 15 +-
.../cache/DistTXStateProxyImplOnCoordinator.java | 4 -
.../cache/DistTXStateProxyImplOnDatanode.java | 2 -
.../internal/cache/DistributedCacheOperation.java | 3 +-
.../internal/cache/DistributedPutAllOperation.java | 1 +
.../geode/internal/cache/DistributedRegion.java | 65 +-
.../cache/DistributedRemoveAllOperation.java | 2 +
.../geode/internal/cache/EntryEventImpl.java | 2 +
.../apache/geode/internal/cache/EntrySnapshot.java | 9 +-
.../internal/cache/FindDurableQueueProcessor.java | 2 +-
.../geode/internal/cache/GemFireCacheImpl.java | 47 +
.../internal/cache/InitialImageFlowControl.java | 14 +-
.../internal/cache/InitialImageOperation.java | 8 +-
.../apache/geode/internal/cache/InternalCache.java | 4 +
.../geode/internal/cache/InternalRegion.java | 7 +-
.../cache/InvalidatePartitionedRegionMessage.java | 1 +
.../apache/geode/internal/cache/LocalRegion.java | 19 +-
.../org/apache/geode/internal/cache/Oplog.java | 4 -
.../internal/cache/PRContainsValueFunction.java | 5 +-
.../internal/cache/PRHARedundancyProvider.java | 28 +-
.../geode/internal/cache/PRQueryProcessor.java | 19 +-
.../geode/internal/cache/PartitionedRegion.java | 16 +-
.../internal/cache/PartitionedRegionHelper.java | 14 +-
.../cache/PartitionedRegionQueryEvaluator.java | 6 +-
.../geode/internal/cache/PeerTXStateStub.java | 3 +
.../geode/internal/cache/RegionMapOwner.java | 1 +
.../internal/cache/RemoteOperationException.java | 91 +-
.../cache/RemoveCacheServerProfileMessage.java | 162 ++
.../cache/SearchLoadAndWriteProcessor.java | 13 +-
.../geode/internal/cache/StateFlushOperation.java | 7 +-
.../geode/internal/cache/TXCommitMessage.java | 26 +-
.../geode/internal/cache/TXFarSideCMTracker.java | 14 +-
.../apache/geode/internal/cache/TXLockRequest.java | 13 +-
.../apache/geode/internal/cache/TXManagerImpl.java | 33 +-
.../internal/cache/TXRemoteCommitMessage.java | 19 +-
.../org/apache/geode/internal/cache/TXState.java | 25 +-
.../apache/geode/internal/cache/TXStateStub.java | 23 +-
.../internal/cache/UpdateAttributesProcessor.java | 2 +-
.../internal/cache/VMCachedDeserializable.java | 2 +-
.../geode/internal/cache/backup/BackupService.java | 15 +-
.../cache/eviction/LRUListWithAsyncSorting.java | 14 +-
.../execute/FunctionStreamingResultCollector.java | 6 +-
.../internal/cache/execute/InternalFunction.java | 35 +-
.../PartitionedRegionFunctionResultWaiter.java | 6 +-
.../util/FindRestEnabledServersFunction.java | 5 +-
.../geode/internal/cache/locks/TXLockService.java | 5 +-
.../internal/cache/locks/TXLockServiceImpl.java | 6 +-
.../cache/locks/TXOriginatorRecoveryProcessor.java | 2 +-
.../partitioned/BecomePrimaryBucketMessage.java | 1 +
.../cache/partitioned/BucketBackupMessage.java | 1 +
.../cache/partitioned/BucketSizeMessage.java | 3 +-
.../cache/partitioned/ContainsKeyValueMessage.java | 4 +-
.../cache/partitioned/CreateBucketMessage.java | 3 +-
.../partitioned/DeposePrimaryBucketMessage.java | 1 +
.../internal/cache/partitioned/DestroyMessage.java | 1 +
.../DestroyRegionOnDataStoreMessage.java | 1 +
.../cache/partitioned/DumpAllPRConfigMessage.java | 1 +
.../internal/cache/partitioned/DumpB2NRegion.java | 1 +
.../cache/partitioned/DumpBucketsMessage.java | 1 +
.../partitioned/EndBucketCreationMessage.java | 1 +
.../cache/partitioned/FetchBulkEntriesMessage.java | 3 +-
.../cache/partitioned/FetchEntriesMessage.java | 3 +-
.../cache/partitioned/FetchEntryMessage.java | 1 +
.../cache/partitioned/FetchKeysMessage.java | 4 +-
.../partitioned/FetchPartitionDetailsMessage.java | 1 +
.../internal/cache/partitioned/GetMessage.java | 29 +-
.../cache/partitioned/IndexCreationMsg.java | 1 +
.../cache/partitioned/InterestEventMessage.java | 1 +
.../cache/partitioned/InvalidateMessage.java | 2 +
.../partitioned/ManageBackupBucketMessage.java | 3 +-
.../cache/partitioned/ManageBucketMessage.java | 3 +-
.../cache/partitioned/MoveBucketMessage.java | 3 +-
.../PRFunctionStreamingResultCollector.java | 4 +-
.../cache/partitioned/PRSanityCheckMessage.java | 2 +
.../cache/partitioned/PRTombstoneMessage.java | 1 +
.../partitioned/PRUpdateEntryVersionMessage.java | 1 +
.../cache/partitioned/PartitionMessage.java | 30 +-
.../partitioned/PartitionedRegionRebalanceOp.java | 14 +-
.../cache/partitioned/PrimaryRequestMessage.java | 3 +-
.../cache/partitioned/PutAllPRMessage.java | 6 +-
.../internal/cache/partitioned/PutMessage.java | 3 +-
.../cache/partitioned/RemoveAllPRMessage.java | 6 +-
.../cache/partitioned/RemoveBucketMessage.java | 3 +-
.../cache/partitioned/RemoveIndexesMessage.java | 2 +
.../internal/cache/partitioned/SizeMessage.java | 1 +
.../partitioned/StreamingPartitionOperation.java | 7 +-
.../cache/persistence/PersistenceAdvisorImpl.java | 14 +-
.../cache/persistence/PersistentMemberManager.java | 14 +-
.../internal/cache/snapshot/ClientExporter.java | 4 +-
.../cache/snapshot/RegionSnapshotServiceImpl.java | 4 +-
.../internal/cache/snapshot/WindowedExporter.java | 5 +-
.../tier/sockets/ClientBlacklistProcessor.java | 2 +-
.../internal/cache/tier/sockets/EncryptorImpl.java | 10 +-
.../cache/tier/sockets/ObjectPartList.java | 2 +-
.../tier/sockets/ServerHandshakeProcessor.java | 101 +-
.../tier/sockets/command/TXFailoverCommand.java | 2 +-
.../cache/tx/AbstractPeerTXRegionStub.java | 25 +-
.../internal/cache/tx/BucketTXRegionStub.java | 21 +-
.../internal/cache/tx/ClientTXRegionStub.java | 2 +-
.../geode/internal/cache/tx/ClientTXStateStub.java | 2 +-
.../internal/cache/tx/DistributedTXRegionStub.java | 78 +-
.../internal/cache/tx/PartitionedTXRegionStub.java | 19 +-
.../RemoteClearMessage.java} | 86 +-
.../{ => tx}/RemoteContainsKeyValueMessage.java | 44 +-
.../cache/{ => tx}/RemoteDestroyMessage.java | 113 +-
.../cache/{ => tx}/RemoteFetchEntryMessage.java | 81 +-
.../RemoteFetchKeysMessage.java | 153 +-
.../cache/{ => tx}/RemoteFetchVersionMessage.java | 38 +-
.../internal/cache/{ => tx}/RemoteGetMessage.java | 73 +-
.../cache/{ => tx}/RemoteInvalidateMessage.java | 107 +-
.../cache/{ => tx}/RemoteOperationMessage.java | 240 +--
.../RemoteOperationMessageWithDirectReply.java | 28 +-
.../cache/{ => tx}/RemotePutAllMessage.java | 105 +-
.../internal/cache/{ => tx}/RemotePutMessage.java | 153 +-
.../cache/{ => tx}/RemoteRemoveAllMessage.java | 95 +-
.../{partitioned => tx}/RemoteSizeMessage.java | 122 +-
.../geode/internal/cache/tx/TXRegionStub.java | 2 +-
.../cache/versions/RegionVersionVector.java | 23 +-
.../cache/versions/VMRegionVersionVector.java | 13 +-
.../internal/cache/wan/AbstractGatewaySender.java | 4 +-
.../internal/cache/wan/GatewaySenderEventImpl.java | 10 +-
...aySenderQueueEntrySynchronizationOperation.java | 2 +-
...currentParallelGatewaySenderEventProcessor.java | 3 -
.../parallel/ParallelQueueBatchRemovalMessage.java | 7 +-
...oncurrentSerialGatewaySenderEventProcessor.java | 3 -
.../serial/SerialGatewaySenderEventProcessor.java | 29 +-
.../cache/wan/serial/SerialGatewaySenderQueue.java | 2 +-
.../internal/cache/xmlcache/CacheCreation.java | 17 +-
.../cache/xmlcache/GatewayReceiverCreation.java | 4 +
.../geode/internal/shared/NativeCallsJNAImpl.java | 46 +-
.../org/apache/geode/internal/tcp/Connection.java | 2 -
.../apache/geode/internal/tcp/ConnectionTable.java | 8 +-
.../geode/internal/tcp/DirectReplySender.java | 4 -
.../geode/internal/util/ArgumentRedactor.java | 27 +-
.../ConcurrentMapWithReusableEntries.java | 9 +
.../concurrent/CustomEntryConcurrentHashMap.java | 23 +-
.../geode/management/JMXNotificationType.java | 16 +
.../management/internal/JmxManagerLocator.java | 5 +-
.../geode/management/internal/MBeanJMXAdapter.java | 1 -
.../management/internal/ManagementConstants.java | 2 +
.../management/internal/ManagementFunction.java | 5 +-
.../internal/ManagementMembershipListener.java | 14 +-
.../internal/SystemManagementService.java | 8 +-
.../internal/beans/GatewayReceiverMBeanBridge.java | 4 +
.../management/internal/beans/MBeanAggregator.java | 14 +-
.../internal/beans/ManagementAdapter.java | 47 +
.../internal/beans/ManagementListener.java | 8 +
.../internal/beans/QueryDataFunction.java | 3 +-
.../internal/cli/AbstractCliAroundInterceptor.java | 35 +-
.../internal/cli/commands/ConnectCommand.java | 4 -
.../internal/cli/commands/ShutdownCommand.java | 2 +-
.../cli/functions/AlterRuntimeConfigFunction.java | 14 +-
.../cli/functions/ChangeLogLevelFunction.java | 14 +-
.../cli/functions/CloseDurableClientFunction.java | 15 +-
.../cli/functions/CloseDurableCqFunction.java | 15 +-
.../cli/functions/ContinuousQueryFunction.java | 13 +-
.../functions/CreateAsyncEventQueueFunction.java | 14 +-
.../functions/CreateDefinedIndexesFunction.java | 14 +-
.../cli/functions/CreateDiskStoreFunction.java | 15 +-
.../cli/functions/CreateIndexFunction.java | 15 +-
.../cli/functions/DataCommandFunction.java | 13 +-
.../internal/cli/functions/DeployFunction.java | 14 +-
.../cli/functions/DescribeDiskStoreFunction.java | 14 +-
.../functions/DestroyAsyncEventQueueFunction.java | 15 +-
.../cli/functions/DestroyDiskStoreFunction.java | 16 +-
.../cli/functions/DestroyIndexFunction.java | 14 +-
.../cli/functions/ExportConfigFunction.java | 14 +-
.../internal/cli/functions/ExportDataFunction.java | 14 +-
.../internal/cli/functions/ExportLogsFunction.java | 14 +-
.../functions/FetchRegionAttributesFunction.java | 14 +-
.../FetchSharedConfigurationStatusFunction.java | 16 +-
.../cli/functions/GarbageCollectionFunction.java | 15 +-
.../functions/GatewayReceiverCreateFunction.java | 14 +-
.../cli/functions/GatewaySenderCreateFunction.java | 15 +-
.../functions/GatewaySenderDestroyFunction.java | 15 +-
.../GetMemberConfigInformationFunction.java | 14 +-
.../functions/GetMemberInformationFunction.java | 14 +-
.../functions/GetRegionDescriptionFunction.java | 15 +-
.../internal/cli/functions/GetRegionsFunction.java | 14 +-
.../cli/functions/GetStackTracesFunction.java | 15 +-
.../GetSubscriptionQueueSizeFunction.java | 15 +-
.../internal/cli/functions/ImportDataFunction.java | 14 +-
.../functions/ListAsyncEventQueuesFunction.java | 14 +-
.../cli/functions/ListDeployedFunction.java | 14 +-
.../cli/functions/ListDiskStoresFunction.java | 14 +-
.../cli/functions/ListDurableCqNamesFunction.java | 14 +-
.../cli/functions/ListFunctionFunction.java | 13 +-
.../internal/cli/functions/ListIndexFunction.java | 14 +-
.../internal/cli/functions/NetstatFunction.java | 14 +-
.../internal/cli/functions/RebalanceFunction.java | 14 +-
.../cli/functions/RegionAlterFunction.java | 14 +-
.../cli/functions/RegionCreateFunction.java | 14 +-
.../cli/functions/RegionDestroyFunction.java | 15 +-
.../functions/ShowMissingDiskStoresFunction.java | 14 +-
.../internal/cli/functions/ShutDownFunction.java | 14 +-
.../cli/functions/SizeExportLogsFunction.java | 14 +-
.../internal/cli/functions/UndeployFunction.java | 14 +-
.../internal/cli/functions/UnregisterFunction.java | 15 +-
.../cli/functions/UserFunctionExecution.java | 4 +-
.../management/internal/cli/json/GfJsonArray.java | 2 -
.../geode/management/internal/cli/shell/Gfsh.java | 14 +-
.../internal/cli/shell/JmxOperationInvoker.java | 8 -
.../functions/DownloadJarFunction.java | 14 +-
.../functions/GetClusterConfigurationFunction.java | 17 +-
.../functions/GetRegionNamesFunction.java | 14 +-
.../functions/RecreateCacheFunction.java | 15 +-
.../internal/web/shell/HttpOperationInvoker.java | 2 +-
.../java/org/apache/geode/pdx/JSONFormatter.java | 136 +-
.../sanctioned-geode-core-serializables.txt | 1 -
.../geode/cache/ConnectionPoolDUnitTest.java | 16 +-
.../pooling/ConnectionManagerJUnitTest.java | 73 +
.../cache/execute/CoreFunctionSecurityTest.java | 100 +-
.../query/internal/index/IndexHintJUnitTest.java | 53 +
.../query/internal/types/ObjectTypeAssert.java | 67 +
.../cache/query/internal/types/TypeUtilTest.java | 44 -
.../query/internal/types/TypeUtilsJUnitTest.java | 1163 ++++++++++++
.../apache/geode/cache30/DiskRegionDUnitTest.java | 1632 ----------------
.../geode/cache30/DiskRegionDistributedTest.java | 415 ++++
.../geode/cache30/DiskRegionIntegrationTest.java | 580 ++++++
.../apache/geode/distributed/LocatorDUnitTest.java | 15 +-
.../InternalDistributedSystemJUnitTest.java | 35 +-
.../geode/internal/AbstractConfigJUnitTest.java | 91 -
.../internal/cache/AbstractRegionJUnitTest.java | 1 +
.../cache/DiskStoreImplIntegrationTest.java | 49 +
.../cache/FilterProfileConcurrencyTest.java | 3 +
.../geode/internal/cache/FlusherThreadTest.java | 77 +
.../geode/internal/cache/GemFireCacheImplTest.java | 23 +
.../geode/internal/cache/OplogFlushTest.java | 10 +-
.../geode/internal/cache/OplogJUnitTest.java | 4 +-
.../internal/cache/RemoteOperationMessageTest.java | 109 --
.../internal/cache/RemoteTransactionDUnitTest.java | 23 +-
.../cache/SearchLoadAndWriteProcessorTest.java | 2 +-
.../internal/cache/SimpleDiskRegionJUnitTest.java | 2 +-
.../eviction/LRUListWithAsyncSortingTest.java | 40 +-
.../eviction/TestLRUListWithAsyncSorting.java | 2 +-
...> PRTransactionWithSizeOperationDUnitTest.java} | 56 +-
.../geode/internal/cache/execute/TestFunction.java | 163 --
.../cache/locks/TXLockServiceDUnitTest.java | 28 +-
.../cache/partitioned/PartitionMessageTest.java | 2 -
.../sockets/RegisterInterestIntegrationTest.java | 331 ++++
.../cache/tx/AbstractPeerTXRegionStubTest.java | 13 +-
.../{ => tx}/RemoteFetchEntryMessageTest.java | 4 +-
.../cache/tx/RemoteOperationMessageTest.java | 300 +++
.../cache/tx/RemoteOperationResponseTest.java | 162 ++
.../cache/{ => tx}/RemotePutAllMessageTest.java | 3 +-
.../{ => tx}/RemotePutReplyMessageJUnitTest.java | 5 +-
.../cache/{ => tx}/RemoteRemoveAllMessageTest.java | 3 +-
.../cache/versions/RegionVersionVectorTest.java | 6 +-
.../cache/wan/AsyncEventQueueTestBase.java | 18 +-
.../internal/util/ArgumentRedactorJUnitTest.java | 134 +-
.../cli/AbstractCliAroundInterceptorJUnitTest.java | 59 -
...DeployCommandFunctionRegistrationDUnitTest.java | 11 +-
.../internal/cli/shell/GfshJunitTest.java | 55 +-
...aAuthorizationUsingLegacySecurityDUnitTest.java | 9 +
...onUsingLegacySecurityWithFailoverDUnitTest.java | 8 +
.../java/org/apache/geode/test/fake/Fakes.java | 4 +
.../geode/test/junit/rules/GfshCommandRule.java | 3 +-
.../geode/test/junit/rules/ServerStarterRule.java | 10 +
.../apache/geode/codeAnalysis/excludedClasses.txt | 8 +
.../codeAnalysis/sanctionedDataSerializables.txt | 67 +-
.../internal/deployment/ImplementsFunction.java | 17 +
.../security/authentication_overview.html.md.erb | 4 -
.../encrypting_with_diffie_hellman.html.md.erb | 66 -
geode-docs/reference/topics/cache_xml.html.md.erb | 326 ++--
.../topics/gemfire_properties.html.md.erb | 5 +-
.../gfsh/command-pages/create.html.md.erb | 9 +-
.../geode/experimental/driver/ProtobufDriver.java | 17 +-
.../geode/experimental/driver/ProtobufRegion.java | 38 +-
.../cli/functions/LuceneCreateIndexFunction.java | 17 +-
.../cli/functions/LuceneDescribeIndexFunction.java | 16 +-
.../cli/functions/LuceneDestroyIndexFunction.java | 18 +-
.../cli/functions/LuceneListIndexFunction.java | 15 +-
.../cli/functions/LuceneSearchIndexFunction.java | 20 +-
.../internal/directory/DumpDirectoryFiles.java | 18 +-
.../internal/distributed/LuceneQueryFunction.java | 14 +-
.../distributed/WaitUntilFlushedFunction.java | 15 +-
.../internal/results/LuceneGetPageFunction.java | 15 +-
.../lucene/LuceneClientSecurityDUnitTest.java | 5 +-
.../lucene/test/LuceneFunctionSecurityTest.java | 56 +-
geode-old-versions/build.gradle | 4 +-
.../src/main/proto/v1/clientProtocol.proto | 54 +-
.../src/main/proto/v1/function_API.proto | 13 +-
.../protobuf/v1/ProtobufOperationContext.java | 20 +-
.../protocol/protobuf/v1/ProtobufOpsProcessor.java | 10 +-
.../protobuf/v1/ProtobufStreamProcessor.java | 8 +-
...teFunctionOnMemberRequestOperationHandler.java} | 84 +-
...uteFunctionOnRegionRequestOperationHandler.java | 12 +-
.../AuthenticationRequestOperationHandler.java | 2 -
.../registry/ProtobufOperationContextRegistry.java | 76 +-
.../v1/utilities/ProtobufRequestUtilities.java | 18 +-
.../protobuf/v1/utilities/ProtobufUtilities.java | 33 +-
.../protobuf/v1/AuthenticationIntegrationTest.java | 82 +-
.../protobuf/v1/AuthorizationIntegrationTest.java | 58 +-
...=> ExecuteFunctionOnMemberIntegrationTest.java} | 113 +-
...=> ExecuteFunctionOnRegionIntegrationTest.java} | 51 +-
.../internal/protocol/protobuf/v1/MessageUtil.java | 19 +-
.../v1/acceptance/CacheConnectionJUnitTest.java | 15 +-
.../v1/acceptance/CacheMaxConnectionJUnitTest.java | 10 +-
.../v1/acceptance/CacheOperationsJUnitTest.java | 67 +-
.../LocatorConnectionAuthenticationDUnitTest.java | 33 +-
.../v1/acceptance/LocatorConnectionDUnitTest.java | 32 +-
...onOnMemberRequestOperationHandlerJUnitTest.java | 189 ++
.../GetRegionRequestOperationHandlerJUnitTest.java | 4 -
.../RemoveRequestOperationHandlerJUnitTest.java | 2 +-
.../client/internal/GatewaySenderBatchOp.java | 2 -
.../internal/cache/wan/GatewayReceiverImpl.java | 11 +
.../RemoteParallelGatewaySenderEventProcessor.java | 3 +-
.../RemoteSerialGatewaySenderEventProcessor.java | 10 +-
.../cache/wan/GatewayReceiverImplJUnitTest.java | 56 +
.../cache/wan/GatewayReceiverMBeanDUnitTest.java | 118 ++
.../cache/wan/serial/GatewayReceiverDUnitTest.java | 144 ++
.../DestroyGatewaySenderCommandDUnitTest.java | 106 ++
.../web/controllers/AbstractBaseController.java | 2 +-
.../web/controllers/BaseControllerAdvice.java | 15 +
.../web/controllers/FunctionAccessController.java | 37 +-
.../internal/web/security/RestSecurityService.java | 13 +
409 files changed, 8622 insertions(+), 9690 deletions(-)
create mode 100644
geode-assembly/src/test/java/org/apache/geode/management/internal/cli/commands/LogsAreFullyRedactedAcceptanceTest.java
create mode 100644
geode-assembly/src/test/java/org/apache/geode/rest/internal/web/RestFunctionExecuteDUnitTest.java
create mode 100644 geode-assembly/src/test/resources/security.json
delete mode 100644
geode-concurrency-test/src/main/java/java/net/InetAddress.java
delete mode 100644
geode-concurrency-test/src/main/java/org/apache/geode/test/concurrency/jpf/JpfRunner.java
delete mode 100644
geode-concurrency-test/src/main/java/org/apache/geode/test/concurrency/jpf/JpfRunnerConfig.java
delete mode 100644
geode-concurrency-test/src/main/java/org/apache/geode/test/concurrency/jpf/ParallelExecutorImpl.java
delete mode 100644
geode-concurrency-test/src/main/java/org/apache/geode/test/concurrency/jpf/logging/EmptyLogger.java
delete mode 100644
geode-concurrency-test/src/main/java/org/apache/geode/test/concurrency/jpf/peers/JPF_java_util_concurrent_locks_ReentrantReadWriteLock.java
delete mode 100644
geode-concurrency-test/src/main/java/org/apache/geode/test/concurrency/jpf/peers/JPF_org_apache_geode_internal_logging_LogService.java
delete mode 100644
geode-concurrency-test/src/main/java/org/apache/geode/test/concurrency/jpf/peers/JPF_org_apache_geode_internal_logging_log4j_LogMarker.java
delete mode 100644
geode-concurrency-test/src/main/java/org/apache/geode/test/concurrency/jpf/peers/JPF_org_apache_logging_log4j_LogManager.java
create mode 100644
geode-core/src/main/java/org/apache/geode/internal/cache/RemoveCacheServerProfileMessage.java
copy
geode-connectors/src/main/java/org/apache/geode/connectors/jdbc/internal/cli/DescribeMappingFunction.java
=>
geode-core/src/main/java/org/apache/geode/internal/cache/execute/InternalFunction.java
(52%)
rename
geode-concurrency-test/src/main/java/org/apache/geode/test/concurrency/jpf/peers/JPF_org_apache_geode_distributed_internal_InternalDistributedSystem.java
=>
geode-core/src/main/java/org/apache/geode/internal/cache/tx/BucketTXRegionStub.java
(65%)
rename
geode-core/src/main/java/org/apache/geode/internal/cache/{RemoteRegionOperation.java
=> tx/RemoteClearMessage.java} (62%)
rename geode-core/src/main/java/org/apache/geode/internal/cache/{ =>
tx}/RemoteContainsKeyValueMessage.java (88%)
rename geode-core/src/main/java/org/apache/geode/internal/cache/{ =>
tx}/RemoteDestroyMessage.java (87%)
rename geode-core/src/main/java/org/apache/geode/internal/cache/{ =>
tx}/RemoteFetchEntryMessage.java (77%)
rename geode-core/src/main/java/org/apache/geode/internal/cache/{partitioned
=> tx}/RemoteFetchKeysMessage.java (75%)
rename geode-core/src/main/java/org/apache/geode/internal/cache/{ =>
tx}/RemoteFetchVersionMessage.java (91%)
rename geode-core/src/main/java/org/apache/geode/internal/cache/{ =>
tx}/RemoteGetMessage.java (85%)
rename geode-core/src/main/java/org/apache/geode/internal/cache/{ =>
tx}/RemoteInvalidateMessage.java (80%)
rename geode-core/src/main/java/org/apache/geode/internal/cache/{ =>
tx}/RemoteOperationMessage.java (67%)
rename geode-core/src/main/java/org/apache/geode/internal/cache/{ =>
tx}/RemoteOperationMessageWithDirectReply.java (70%)
rename geode-core/src/main/java/org/apache/geode/internal/cache/{ =>
tx}/RemotePutAllMessage.java (83%)
rename geode-core/src/main/java/org/apache/geode/internal/cache/{ =>
tx}/RemotePutMessage.java (88%)
rename geode-core/src/main/java/org/apache/geode/internal/cache/{ =>
tx}/RemoteRemoveAllMessage.java (85%)
rename geode-core/src/main/java/org/apache/geode/internal/cache/{partitioned
=> tx}/RemoteSizeMessage.java (63%)
create mode 100644
geode-core/src/test/java/org/apache/geode/cache/query/internal/types/ObjectTypeAssert.java
delete mode 100644
geode-core/src/test/java/org/apache/geode/cache/query/internal/types/TypeUtilTest.java
create mode 100644
geode-core/src/test/java/org/apache/geode/cache/query/internal/types/TypeUtilsJUnitTest.java
delete mode 100644
geode-core/src/test/java/org/apache/geode/cache30/DiskRegionDUnitTest.java
create mode 100644
geode-core/src/test/java/org/apache/geode/cache30/DiskRegionDistributedTest.java
create mode 100644
geode-core/src/test/java/org/apache/geode/cache30/DiskRegionIntegrationTest.java
delete mode 100644
geode-core/src/test/java/org/apache/geode/internal/AbstractConfigJUnitTest.java
rename geode-core/src/{jpfTest =>
test}/java/org/apache/geode/internal/cache/FilterProfileConcurrencyTest.java
(95%)
create mode 100644
geode-core/src/test/java/org/apache/geode/internal/cache/FlusherThreadTest.java
delete mode 100644
geode-core/src/test/java/org/apache/geode/internal/cache/RemoteOperationMessageTest.java
rename
geode-core/src/test/java/org/apache/geode/internal/cache/execute/{PRTransaction2DUnitTest.java
=> PRTransactionWithSizeOperationDUnitTest.java} (72%)
delete mode 100755
geode-core/src/test/java/org/apache/geode/internal/cache/execute/TestFunction.java
create mode 100644
geode-core/src/test/java/org/apache/geode/internal/cache/tier/sockets/RegisterInterestIntegrationTest.java
rename geode-core/src/test/java/org/apache/geode/internal/cache/{ =>
tx}/RemoteFetchEntryMessageTest.java (92%)
create mode 100644
geode-core/src/test/java/org/apache/geode/internal/cache/tx/RemoteOperationMessageTest.java
create mode 100644
geode-core/src/test/java/org/apache/geode/internal/cache/tx/RemoteOperationResponseTest.java
rename geode-core/src/test/java/org/apache/geode/internal/cache/{ =>
tx}/RemotePutAllMessageTest.java (93%)
rename geode-core/src/test/java/org/apache/geode/internal/cache/{ =>
tx}/RemotePutReplyMessageJUnitTest.java (91%)
rename geode-core/src/test/java/org/apache/geode/internal/cache/{ =>
tx}/RemoteRemoveAllMessageTest.java (93%)
delete mode 100644
geode-core/src/test/java/org/apache/geode/management/internal/cli/AbstractCliAroundInterceptorJUnitTest.java
delete mode 100644
geode-docs/managing/security/encrypting_with_diffie_hellman.html.md.erb
copy
geode-protobuf/src/main/java/org/apache/geode/internal/protocol/protobuf/v1/operations/{ExecuteFunctionOnRegionRequestOperationHandler.java
=> ExecuteFunctionOnMemberRequestOperationHandler.java} (66%)
copy
geode-protobuf/src/test/java/org/apache/geode/internal/protocol/protobuf/v1/{FunctionExecutionIntegrationTest.java
=> ExecuteFunctionOnMemberIntegrationTest.java} (71%)
rename
geode-protobuf/src/test/java/org/apache/geode/internal/protocol/protobuf/v1/{FunctionExecutionIntegrationTest.java
=> ExecuteFunctionOnRegionIntegrationTest.java} (87%)
create mode 100644
geode-protobuf/src/test/java/org/apache/geode/internal/protocol/protobuf/v1/operations/ExecuteFunctionOnMemberRequestOperationHandlerJUnitTest.java
create mode 100644
geode-wan/src/test/java/org/apache/geode/internal/cache/wan/GatewayReceiverMBeanDUnitTest.java
create mode 100644
geode-wan/src/test/java/org/apache/geode/internal/cache/wan/serial/GatewayReceiverDUnitTest.java
create mode 100644
geode-wan/src/test/java/org/apache/geode/internal/cache/wan/wancommand/DestroyGatewaySenderCommandDUnitTest.java
--
To stop receiving notification emails like this one, please contact
zho...@apache.org.
