geode-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From zho...@apache.org
Subject [geode] branch feature/GEODE-3967 updated (d6332e0 -> 7d47d2a)
Date Sun, 11 Feb 2018 03:14:07 GMT
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
zhouxj@apache.org.

Mime
View raw message