geode-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jinmeil...@apache.org
Subject [3/4] incubator-geode git commit: Merge branch 'develop' of https://git-wip-us.apache.org/repos/asf/incubator-geode into develop
Date Tue, 26 Apr 2016 15:24:57 GMT
Merge branch 'develop' of https://git-wip-us.apache.org/repos/asf/incubator-geode into develop


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

Branch: refs/heads/feature/GEODE-17-2
Commit: 9fbcb93b6937499c097c030ec356c81bb4659fa0
Parents: b2b4852 872f955
Author: Dave Barnes <dbarnes@pivotal.io>
Authored: Mon Apr 25 11:54:57 2016 -0700
Committer: Dave Barnes <dbarnes@pivotal.io>
Committed: Mon Apr 25 11:54:57 2016 -0700

----------------------------------------------------------------------
 LICENSE                                         |   60 +
 .../apache/geode/gradle/PasswordDialog.groovy   |   41 +
 extensions/geode-modules-assembly/build.gradle  |    1 +
 .../SessionReplicationIntegrationJUnitTest.java |   10 +-
 geode-assembly/build.gradle                     |    4 +-
 geode-assembly/src/main/dist/LICENSE            |    8 +-
 geode-assembly/src/main/dist/NOTICE             |   36 +-
 .../LauncherLifecycleCommandsDUnitTest.java     |   87 +-
 .../SharedConfigurationEndToEndDUnitTest.java   |   18 +-
 .../client/internal/CloseConnectionOp.java      |   26 +-
 .../cache/client/internal/ConnectionImpl.java   |    8 +-
 .../client/internal/ServerRegionProxy.java      |    3 +-
 .../gemfire/cache/execute/Function.java         |    2 +-
 .../distributed/internal/InternalLocator.java   |   24 +-
 .../internal/WanLocatorDiscoverer.java          |    4 +
 .../membership/InternalDistributedMember.java   |   68 +-
 .../internal/membership/NetMember.java          |    4 +-
 .../internal/membership/gms/GMSMember.java      |   36 +-
 .../internal/membership/gms/ServiceConfig.java  |   18 +
 .../membership/gms/locator/GMSLocator.java      |    2 +-
 .../membership/gms/membership/GMSJoinLeave.java |  152 +-
 .../gms/messenger/JGroupsMessenger.java         |    7 +-
 .../internal/tcpserver/TcpServer.java           |    4 +-
 .../gemfire/internal/AvailablePort.java         |    6 +-
 .../gemfire/internal/SocketCreator.java         |   25 +-
 .../gemfire/internal/SocketIOWithTimeout.java   |  491 ----
 .../gemfire/internal/SocketInputStream.java     |  181 --
 .../gemfire/internal/SocketInputWrapper.java    |   93 -
 .../gemfire/internal/SocketOutputStream.java    |  174 --
 .../gemstone/gemfire/internal/SocketUtils.java  |  220 --
 .../internal/admin/ClientStatsManager.java      |    3 +-
 .../cache/AbstractBucketRegionQueue.java        |    3 +-
 .../internal/cache/AbstractLRURegionMap.java    |    4 +
 .../internal/cache/AbstractRegionEntry.java     |    2 +-
 .../internal/cache/AbstractRegionMap.java       |   15 +-
 .../gemfire/internal/cache/BucketRegion.java    |   14 +-
 .../internal/cache/BucketRegionQueue.java       |    7 +-
 .../internal/cache/DestroyOperation.java        |    6 +-
 .../internal/cache/DistPeerTXStateStub.java     |    2 +
 .../gemfire/internal/cache/DistTXState.java     |    9 +-
 .../cache/DistTXStateOnCoordinator.java         |    2 +
 .../DistTXStateProxyImplOnCoordinator.java      |    2 +
 .../cache/DistributedCacheOperation.java        |    4 +-
 .../cache/DistributedPutAllOperation.java       |   23 +-
 .../internal/cache/DistributedRegion.java       |    9 +-
 .../cache/DistributedRemoveAllOperation.java    |   22 +-
 .../gemfire/internal/cache/EntryEventImpl.java  |   41 +-
 .../gemfire/internal/cache/EntryExpiryTask.java |    9 +-
 .../gemfire/internal/cache/EventIDHolder.java   |   35 +
 .../gemfire/internal/cache/FilterProfile.java   |   13 +-
 .../internal/cache/GemFireCacheImpl.java        |   14 +-
 .../gemfire/internal/cache/HARegion.java        |    5 +-
 .../internal/cache/InitialImageOperation.java   |    2 +-
 .../internal/cache/InvalidateOperation.java     |    5 +-
 .../gemfire/internal/cache/LocalRegion.java     |  141 +-
 .../internal/cache/PartitionedRegion.java       |   13 +-
 .../gemfire/internal/cache/ProxyRegionMap.java  |    7 +-
 .../gemfire/internal/cache/QueuedOperation.java |    3 +-
 .../internal/cache/RemoteDestroyMessage.java    |    3 +-
 .../internal/cache/RemoteInvalidateMessage.java |    4 +-
 .../internal/cache/RemotePutAllMessage.java     |    5 +-
 .../internal/cache/RemotePutMessage.java        |    4 +-
 .../internal/cache/RemoteRemoveAllMessage.java  |    5 +-
 .../cache/SearchLoadAndWriteProcessor.java      |    6 +-
 .../gemfire/internal/cache/TXCommitMessage.java |    4 +-
 .../gemfire/internal/cache/TXEntryState.java    |    6 +-
 .../gemfire/internal/cache/TXRegionState.java   |    1 +
 .../gemfire/internal/cache/TXRmtEvent.java      |    9 +-
 .../gemfire/internal/cache/TXState.java         |    9 +-
 .../cache/TimestampedEntryEventImpl.java        |    2 +
 .../cache/UpdateEntryVersionOperation.java      |    4 +-
 .../gemfire/internal/cache/UpdateOperation.java |    8 +-
 .../internal/cache/VersionTagHolder.java        |   34 +
 .../cache/partitioned/DestroyMessage.java       |   11 +-
 .../partitioned/FetchBulkEntriesMessage.java    |    4 +-
 .../internal/cache/partitioned/GetMessage.java  |    5 +-
 .../cache/partitioned/InvalidateMessage.java    |    3 +-
 .../PRUpdateEntryVersionMessage.java            |    1 +
 .../cache/partitioned/PutAllPRMessage.java      |   12 +-
 .../internal/cache/partitioned/PutMessage.java  |   11 +-
 .../cache/partitioned/RemoveAllPRMessage.java   |   13 +-
 .../cache/tier/sockets/AcceptorImpl.java        |    3 +-
 .../cache/tier/sockets/BaseCommand.java         |   12 +-
 .../cache/tier/sockets/CacheClientNotifier.java |  105 +-
 .../cache/tier/sockets/CacheClientUpdater.java  |    8 +-
 .../internal/cache/tier/sockets/HandShake.java  |   13 +-
 .../internal/cache/tier/sockets/Message.java    |    3 +-
 .../cache/tier/sockets/ServerConnection.java    |    5 +-
 .../tier/sockets/ServerHandShakeProcessor.java  |   26 +-
 .../tier/sockets/command/CloseConnection.java   |   17 +-
 .../cache/tier/sockets/command/Destroy.java     |    3 +-
 .../cache/tier/sockets/command/Destroy65.java   |    3 +-
 .../sockets/command/GatewayReceiverCommand.java |   11 +-
 .../cache/tier/sockets/command/Get70.java       |   15 +-
 .../cache/tier/sockets/command/Invalidate.java  |    3 +-
 .../cache/tier/sockets/command/Put.java         |    5 +-
 .../cache/tier/sockets/command/Put61.java       |    5 +-
 .../cache/tier/sockets/command/Put65.java       |    3 +-
 .../internal/cache/tx/DistTxEntryEvent.java     |   13 +-
 .../cache/tx/PartitionedTXRegionStub.java       |   17 +-
 .../cache/wan/AbstractGatewaySender.java        |    5 +-
 .../AbstractGatewaySenderEventProcessor.java    |    2 +
 .../cache/wan/serial/BatchDestroyOperation.java |    5 +-
 ...urrentSerialGatewaySenderEventProcessor.java |    3 +-
 .../wan/serial/SerialGatewaySenderQueue.java    |    2 +-
 .../serial/SerialSecondaryGatewayListener.java  |   19 +-
 .../internal/i18n/ParentLocalizedStrings.java   |    2 +-
 .../gemfire/internal/lang/ThrowableUtils.java   |  101 +
 .../gemfire/internal/shared/NativeCalls.java    |    2 +-
 .../gemfire/internal/tcp/Connection.java        |    5 +-
 .../gemfire/management/internal/RestAgent.java  |   51 +-
 .../internal/cli/commands/ShellCommands.java    |    2 +-
 .../cli/functions/ShutDownFunction.java         |   52 +-
 .../com/gemstone/gemfire/TXExpiryJUnitTest.java |    6 +-
 .../gemfire/cache/ConnectionPoolDUnitTest.java  |   24 +-
 .../pooling/ConnectionManagerJUnitTest.java     |    8 +-
 .../management/MemoryThresholdsDUnitTest.java   |    4 +
 .../MemoryThresholdsOffHeapDUnitTest.java       |    9 +-
 .../management/ResourceManagerDUnitTest.java    |   16 +-
 .../gemfire/cache/query/QueryTestUtils.java     |  238 +-
 .../cache/query/QueryTestUtilsJUnitTest.java    |    1 +
 .../query/dunit/CompactRangeIndexDUnitTest.java |    1 +
 .../cache/query/dunit/HashIndexDUnitTest.java   |    1 +
 .../dunit/QueryDataInconsistencyDUnitTest.java  |   12 +-
 .../QueryUsingFunctionContextDUnitTest.java     |   11 +-
 .../query/dunit/QueryUsingPoolDUnitTest.java    | 2714 ++++++++----------
 .../cache/query/dunit/RemoteQueryDUnitTest.java |    3 +
 .../query/dunit/SelectStarQueryDUnitTest.java   |  216 +-
 .../QueryREUpdateInProgressJUnitTest.java       |    3 +-
 .../index/CompactRangeIndexJUnitTest.java       |    1 +
 ...pdateWithInplaceObjectModFalseDUnitTest.java |    9 +-
 ...itializeIndexEntryDestroyQueryDUnitTest.java |   14 +-
 .../partitioned/PRQueryCacheCloseDUnitTest.java |   29 +-
 .../gemfire/cache30/Bug44418JUnitTest.java      |   10 +-
 .../gemfire/cache30/CacheLogRollDUnitTest.java  |   13 +-
 .../cache30/ClientMembershipDUnitTest.java      |    4 +
 ...iskDistributedNoAckAsyncRegionDUnitTest.java |    4 -
 .../DiskDistributedNoAckRegionTestCase.java     |    7 +-
 ...tributedAckPersistentRegionCCEDUnitTest.java |   80 +-
 .../DistributedAckRegionCCEDUnitTest.java       |   76 +-
 .../cache30/DistributedAckRegionDUnitTest.java  |    2 -
 .../DistributedNoAckRegionCCEDUnitTest.java     |   76 +-
 .../DistributedNoAckRegionDUnitTest.java        |    3 +-
 .../gemfire/cache30/MultiVMRegionTestCase.java  |   62 +-
 .../cache30/PartitionedRegionDUnitTest.java     |    6 +-
 .../cache30/RegionReliabilityTestCase.java      |    4 +
 .../gemfire/cache30/RegionTestCase.java         |   11 +-
 .../gemfire/cache30/TXDistributedDUnitTest.java |    5 +-
 .../gemfire/distributed/LocatorDUnitTest.java   |  570 ++--
 .../LocatorLauncherRemoteJUnitTest.java         |   13 +-
 .../ServerLauncherRemoteJUnitTest.java          |   11 +-
 .../internal/LocatorLoadSnapshotJUnitTest.java  |    2 +
 .../GemFireDeadlockDetectorDUnitTest.java       |   12 +-
 .../gms/membership/GMSJoinLeaveJUnitTest.java   |    7 +-
 .../gms/membership/GMSJoinLeaveTestHelper.java  |    7 +-
 .../gemfire/disttx/DistTXExpiryJUnitTest.java   |    1 -
 .../gemfire/internal/JSSESocketJUnitTest.java   |   11 +-
 ...hreadPoolExecutorWithKeepAliveJUnitTest.java |    9 +-
 .../cache/FixedPRSinglehopDUnitTest.java        |    4 +
 .../internal/cache/GIIDeltaDUnitTest.java       |    9 +-
 .../cache/NetSearchMessagingDUnitTest.java      |   12 +-
 .../gemfire/internal/cache/OplogJUnitTest.java  |   13 +-
 .../PartitionedRegionCreationDUnitTest.java     |   17 +-
 ...rtitionedRegionDelayedRecoveryDUnitTest.java |   13 +-
 .../PartitionedRegionSingleHopDUnitTest.java    |    5 +
 .../internal/cache/SingleHopStatsDUnitTest.java |    9 +-
 .../internal/cache/UpdateVersionJUnitTest.java  |    4 +-
 ...ributedRegionFunctionExecutionDUnitTest.java |   11 +-
 ...onFunctionExecutionNoSingleHopDUnitTest.java |    7 +-
 .../PRFunctionExecutionTimeOutDUnitTest.java    |   17 +-
 .../internal/cache/ha/Bug48571DUnitTest.java    |    6 +-
 .../cache/ha/EventIdOptimizationDUnitTest.java  |    5 +-
 .../cache/ha/HARegionQueueDUnitTest.java        |   14 +-
 ...tentColocatedPartitionedRegionDUnitTest.java |   16 +-
 .../PersistentPartitionedRegionDUnitTest.java   |   15 +-
 ...tentPartitionedRegionOldConfigDUnitTest.java |    6 +-
 .../cache/partitioned/ShutdownAllDUnitTest.java |   10 +-
 .../fixed/FixedPartitioningDUnitTest.java       |   12 +-
 .../PersistentRecoveryOrderDUnitTest.java       |    6 +-
 .../DestroyEntryPropagationDUnitTest.java       |   19 +-
 .../sockets/HAStartupAndFailoverDUnitTest.java  |   21 +-
 .../sockets/ReliableMessagingDUnitTest.java     |   12 +-
 .../sockets/UpdatePropagationDUnitTest.java     |   17 +-
 .../asyncqueue/AsyncEventListenerDUnitTest.java |    3 +
 .../AsyncEventListenerOffHeapDUnitTest.java     |    4 +-
 .../internal/lang/ThrowableUtilsTest.java       |  242 ++
 .../management/DLockManagementDUnitTest.java    |   22 +-
 ...ersalMembershipListenerAdapterDUnitTest.java |    5 +-
 .../AbstractCommandsSupportJUnitTest.java       |   16 +-
 .../cli/commands/CliCommandTestBase.java        |  108 +-
 .../cli/commands/ConfigCommandsDUnitTest.java   |   85 +-
 ...eateAlterDestroyRegionCommandsDUnitTest.java |  117 +-
 .../cli/commands/DeployCommandsDUnitTest.java   |   33 +-
 .../commands/DiskStoreCommandsDUnitTest.java    |   85 +-
 .../commands/DiskStoreCommandsJUnitTest.java    |   19 +-
 .../cli/commands/FunctionCommandsDUnitTest.java |   97 +-
 .../commands/GemfireDataCommandsDUnitTest.java  |  269 +-
 ...WithCacheLoaderDuringCacheMissDUnitTest.java |   20 +-
 .../HTTPServiceSSLSupportJUnitTest.java         |   12 +-
 .../cli/commands/IndexCommandsDUnitTest.java    |   33 +-
 .../cli/commands/IndexCommandsJUnitTest.java    |   18 +-
 ...stAndDescribeDiskStoreCommandsDUnitTest.java |   23 +-
 .../ListAndDescribeRegionDUnitTest.java         |   52 +-
 .../cli/commands/ListIndexCommandDUnitTest.java |   29 +-
 .../cli/commands/MemberCommandsDUnitTest.java   |   60 +-
 .../MiscellaneousCommandsDUnitTest.java         |   85 +-
 ...laneousCommandsExportLogsPart1DUnitTest.java |   37 +-
 ...laneousCommandsExportLogsPart2DUnitTest.java |   38 +-
 ...laneousCommandsExportLogsPart3DUnitTest.java |   41 +-
 ...laneousCommandsExportLogsPart4DUnitTest.java |   36 +-
 .../cli/commands/QueueCommandsDUnitTest.java    |   41 +-
 .../SharedConfigurationCommandsDUnitTest.java   |   55 +-
 .../cli/commands/ShellCommandsDUnitTest.java    |   94 +-
 .../cli/commands/ShowDeadlockDUnitTest.java     |   56 +-
 .../cli/commands/ShowMetricsDUnitTest.java      |   71 +-
 .../cli/commands/ShowStackTraceDUnitTest.java   |   43 +-
 .../cli/commands/UserCommandsDUnitTest.java     |   24 +-
 .../SharedConfigurationUsingDirDUnitTest.java   |    2 +
 .../GemcachedDevelopmentJUnitTest.java          |    2 +
 .../pdx/DistributedSystemIdDUnitTest.java       |   13 +-
 .../gemfire/redis/RedisDistDUnitTest.java       |    4 +
 .../security/ClientAuthenticationDUnitTest.java |    8 +-
 .../ClientAuthenticationPart2DUnitTest.java     |    6 +-
 .../security/ClientAuthenticationTestCase.java  |    3 +
 .../security/ClientAuthorizationDUnitTest.java  |   16 +-
 .../security/ClientAuthorizationTestCase.java   |   26 +-
 .../security/ClientMultiUserAuthzDUnitTest.java |   10 +-
 .../DeltaClientAuthorizationDUnitTest.java      |   10 +-
 .../DeltaClientPostAuthorizationDUnitTest.java  |   14 +-
 .../security/GemFireSecurityExceptionTest.java  |    6 +-
 .../security/NotAuthorizedExceptionTest.java    |    6 +-
 .../security/P2PAuthenticationDUnitTest.java    |   15 +-
 .../gemfire/security/SecurityTestUtils.java     |   13 +-
 .../generator/AuthzCredentialGenerator.java     |   15 +-
 .../security/generator/CredentialGenerator.java |    3 +-
 .../generator/DummyCredentialGenerator.java     |    6 +-
 .../generator/LdapUserCredentialGenerator.java  |   15 +-
 .../generator/PKCSCredentialGenerator.java      |    8 +-
 .../generator/SSLCredentialGenerator.java       |    9 +-
 .../UserPasswordWithExtraPropsAuthInit.java     |    6 +-
 .../generator/XmlAuthzCredentialGenerator.java  |   10 +-
 .../security/templates/DummyAuthorization.java  |    8 +-
 .../templates/LdapUserAuthenticator.java        |    3 +-
 .../security/templates/PKCSAuthInit.java        |    3 +-
 .../security/templates/PKCSAuthenticator.java   |    3 +-
 .../security/templates/PKCSPrincipalTest.java   |    9 +-
 .../templates/UserPasswordAuthInit.java         |    4 +-
 .../templates/UsernamePrincipalTest.java        |    9 +-
 .../security/templates/XmlAuthorization.java    |   19 +-
 .../security/templates/XmlErrorHandler.java     |    5 +-
 .../gemfire/test/dunit/AsyncInvocation.java     |  511 +++-
 .../gemfire/test/dunit/DistributedTestCase.java |    8 +-
 .../test/dunit/DistributedTestUtils.java        |    2 +-
 .../gemfire/test/dunit/ThreadUtils.java         |   13 +-
 .../com/gemstone/gemfire/test/dunit/VM.java     |  521 ++--
 .../com/gemstone/gemfire/test/dunit/Wait.java   |    2 +-
 .../cache/internal/JUnit4CacheTestCase.java     |    4 +-
 .../internal/JUnit3DistributedTestCase.java     |    9 +-
 .../internal/JUnit4DistributedTestCase.java     |   19 +-
 .../internal/tests/JUnit3BasicDUnitTest.java    |  189 --
 .../JUnit3GetDefaultDiskStoreNameDUnitTest.java |   66 -
 .../tests/JUnit3GetTestMethodNameDUnitTest.java |   53 -
 .../dunit/internal/tests/JUnit3VMDUnitTest.java |  192 --
 .../internal/tests/JUnit4BasicDUnitTest.java    |  202 --
 .../JUnit4GetDefaultDiskStoreNameDUnitTest.java |   65 -
 .../tests/JUnit4GetTestMethodNameDUnitTest.java |   52 -
 .../dunit/internal/tests/JUnit4VMDUnitTest.java |  200 --
 .../DistributedRestoreSystemProperties.java     |    3 +-
 .../gemfire/test/dunit/rules/RemoteInvoker.java |    3 +-
 .../gemfire/test/dunit/standalone/ChildVM.java  |    5 +-
 .../test/dunit/standalone/DUnitLauncher.java    |   10 +-
 .../test/dunit/standalone/ProcessManager.java   |    7 +-
 .../test/dunit/standalone/RemoteDUnitVM.java    |    5 +-
 .../test/dunit/standalone/RemoteDUnitVMIF.java  |    4 +-
 .../test/dunit/tests/BasicDUnitTest.java        |  221 +-
 .../tests/GetDefaultDiskStoreNameDUnitTest.java |    1 -
 .../dunit/tests/GetTestMethodNameDUnitTest.java |    1 -
 .../test/dunit/tests/JUnit4BasicDUnitTest.java  |  234 ++
 .../JUnit4GetDefaultDiskStoreNameDUnitTest.java |   66 +
 .../tests/JUnit4GetTestMethodNameDUnitTest.java |   53 +
 ...ingGetPropertiesDisconnectsAllDUnitTest.java |   60 +
 .../test/dunit/tests/JUnit4VMDUnitTest.java     |  201 ++
 ...ingGetPropertiesDisconnectsAllDUnitTest.java |    3 +
 .../cache/query/cq/dunit/CqPerfDUnitTest.java   |    5 +-
 .../cq/dunit/CqPerfUsingPoolDUnitTest.java      |    9 +-
 .../cache/query/cq/dunit/CqQueryDUnitTest.java  |    2 +-
 .../cq/dunit/CqQueryUsingPoolDUnitTest.java     |   22 +-
 .../query/cq/dunit/PrCqUsingPoolDUnitTest.java  |   18 +-
 .../query/dunit/QueryMonitorDUnitTest.java      |    8 +-
 .../cache/RemoteCQTransactionDUnitTest.java     |   17 +-
 .../sockets/DurableClientSimpleDUnitTest.java   |  203 +-
 .../tier/sockets/DurableClientTestCase.java     |    1 -
 .../cli/commands/ClientCommandsDUnitTest.java   | 1813 +++++-------
 .../DurableClientCommandsDUnitTest.java         |   53 +-
 .../ClientAuthorizationTwoDUnitTest.java        |    8 +-
 .../security/ClientAuthzObjectModDUnitTest.java |   48 +-
 .../ClientCQPostAuthorizationDUnitTest.java     |   16 +-
 .../ClientPostAuthorizationDUnitTest.java       |   28 +-
 .../gemfire/security/MultiUserAPIDUnitTest.java |    8 +-
 .../MultiUserDurableCQAuthzDUnitTest.java       |   16 +-
 .../test/junit/categories/FlakyTest.java        |   24 +
 .../test/junit/categories/SecurityTest.java     |   23 +
 .../gemfire/test/junit/rules/RetryRule.java     |    2 +-
 .../test/junit/categories/CategoryOne.java      |   20 +
 .../test/junit/categories/CategoryTest.java     |  169 ++
 .../test/junit/categories/CategoryTwo.java      |   20 +
 .../cache/lucene/LuceneServiceProvider.java     |    9 +-
 .../LuceneIndexForPartitionedRegion.java        |  123 +-
 .../internal/directory/RegionDirectory.java     |   20 +-
 .../lucene/internal/filesystem/FileSystem.java  |    5 +
 .../repository/IndexRepositoryImpl.java         |    2 +-
 .../repository/serializer/SerializerUtil.java   |   16 +-
 .../LuceneIndexForPartitionedRegionTest.java    |  348 +++
 .../LuceneIndexRecoveryHAJUnitTest.java         |   25 +-
 .../internal/LuceneServiceImplJUnitTest.java    |  240 +-
 .../IndexRepositoryImplPerformanceTest.java     |    4 +-
 geode-pulse/src/main/webapp/META-INF/NOTICE     |   18 +-
 geode-site/website/content/releases/index.html  |   52 +
 geode-spark-connector/doc/10_demos.md           |   12 +-
 geode-spark-connector/doc/1_building.md         |   18 +-
 geode-spark-connector/doc/2_quick.md            |   26 +-
 geode-spark-connector/doc/3_connecting.md       |   38 +-
 geode-spark-connector/doc/4_loading.md          |   30 +-
 geode-spark-connector/doc/5_rdd_join.md         |   26 +-
 geode-spark-connector/doc/6_save_rdd.md         |   20 +-
 geode-spark-connector/doc/7_save_dstream.md     |   10 +-
 geode-spark-connector/doc/8_oql.md              |    8 +-
 geode-spark-connector/doc/9_java_api.md         |   36 +-
 .../connector/internal/RegionMetadata.java      |   93 -
 .../gemfirefunctions/QueryFunction.java         |   99 -
 .../RetrieveRegionFunction.java                 |  208 --
 .../RetrieveRegionMetadataFunction.java         |  118 -
 .../StructStreamingResultSender.java            |  219 --
 .../gemfire/spark/connector/Employee.java       |   54 -
 .../spark/connector/JavaApiIntegrationTest.java |  424 ---
 .../gemfire/spark/connector/Portfolio.java      |  109 -
 .../gemfire/spark/connector/Position.java       |   73 -
 .../src/it/resources/test-regions.xml           |   49 -
 .../src/it/resources/test-retrieve-regions.xml  |   57 -
 .../spark/connector/BasicIntegrationTest.scala  |  598 ----
 .../RDDJoinRegionIntegrationTest.scala          |  300 --
 .../RetrieveRegionIntegrationTest.scala         |  253 --
 .../gemfire/spark/connector/package.scala       |   29 -
 .../connector/testkit/GemFireCluster.scala      |   47 -
 .../spark/connector/testkit/GemFireRunner.scala |  148 -
 .../spark/connector/testkit/IOUtils.scala       |   94 -
 .../spark/streaming/ManualClockHelper.scala     |   28 -
 .../spark/streaming/TestInputDStream.scala      |   44 -
 .../javaapi/GemFireJavaDStreamFunctions.java    |   86 -
 .../GemFireJavaPairDStreamFunctions.java        |   77 -
 .../javaapi/GemFireJavaPairRDDFunctions.java    |  238 --
 .../javaapi/GemFireJavaRDDFunctions.java        |  178 --
 .../javaapi/GemFireJavaSQLContextFunctions.java |   49 -
 .../GemFireJavaSparkContextFunctions.java       |   87 -
 .../connector/javaapi/GemFireJavaUtil.java      |  122 -
 .../spark/connector/GemFireConnection.scala     |   67 -
 .../spark/connector/GemFireConnectionConf.scala |   73 -
 .../connector/GemFireConnectionManager.scala    |   31 -
 .../connector/GemFireFunctionDeployer.scala     |   81 -
 .../connector/GemFireKryoRegistrator.scala      |   29 -
 .../connector/GemFirePairRDDFunctions.scala     |  140 -
 .../spark/connector/GemFireRDDFunctions.scala   |  120 -
 .../connector/GemFireSQLContextFunctions.scala  |   42 -
 .../GemFireSparkContextFunctions.scala          |   39 -
 .../internal/DefaultGemFireConnection.scala     |  164 --
 .../DefaultGemFireConnectionManager.scala       |   77 -
 .../connector/internal/LocatorHelper.scala      |  135 -
 .../StructStreamingResultCollector.scala        |  152 -
 .../connector/internal/oql/QueryParser.scala    |   58 -
 .../spark/connector/internal/oql/QueryRDD.scala |   83 -
 .../internal/oql/QueryResultCollector.scala     |   69 -
 .../connector/internal/oql/RDDConverter.scala   |   40 -
 .../connector/internal/oql/RowBuilder.scala     |   38 -
 .../connector/internal/oql/SchemaBuilder.scala  |   73 -
 .../internal/oql/UndefinedSerializer.scala      |   46 -
 .../connector/internal/rdd/GemFireJoinRDD.scala |   67 -
 .../internal/rdd/GemFireOuterJoinRDD.scala      |   69 -
 .../internal/rdd/GemFireRDDPartition.scala      |   36 -
 .../internal/rdd/GemFireRDDPartitioner.scala    |   59 -
 .../rdd/GemFireRDDPartitionerImpl.scala         |   89 -
 .../internal/rdd/GemFireRDDWriter.scala         |   82 -
 .../internal/rdd/GemFireRegionRDD.scala         |  138 -
 .../javaapi/GemFireJavaRegionRDD.scala          |   26 -
 .../spark/connector/javaapi/JavaAPIHelper.scala |   53 -
 .../gemfire/spark/connector/package.scala       |   69 -
 .../streaming/GemFireDStreamFunctions.scala     |   89 -
 .../spark/connector/streaming/package.scala     |   32 -
 .../gemfire/spark/connector/JavaAPITest.java    |  163 --
 .../connector/GemFireFunctionDeployerTest.scala |   58 -
 .../DefaultGemFireConnectionManagerTest.scala   |   82 -
 ...tStreamingResultSenderAndCollectorTest.scala |  254 --
 .../internal/oql/QueryParserTest.scala          |   83 -
 .../connector/ConnectorImplicitsTest.scala      |   50 -
 .../connector/GemFireConnectionConfTest.scala   |  100 -
 .../connector/GemFireDStreamFunctionsTest.scala |   79 -
 .../connector/GemFireRDDFunctionsTest.scala     |  139 -
 .../spark/connector/LocatorHelperTest.scala     |  168 --
 .../rdd/GemFireRDDPartitionerTest.scala         |  190 --
 .../connector/rdd/GemFireRegionRDDTest.scala    |  117 -
 .../basic-demos/src/main/java/demo/Emp.java     |   95 -
 .../src/main/java/demo/OQLJavaDemo.java         |   59 -
 .../src/main/java/demo/PairRDDSaveJavaDemo.java |   86 -
 .../src/main/java/demo/RDDSaveJavaDemo.java     |   85 -
 .../src/main/java/demo/RegionToRDDJavaDemo.java |   57 -
 .../src/main/scala/demo/NetworkWordCount.scala  |   75 -
 .../connector/internal/RegionMetadata.java      |   93 +
 .../internal/geodefunctions/QueryFunction.java  |   99 +
 .../geodefunctions/RetrieveRegionFunction.java  |  208 ++
 .../RetrieveRegionMetadataFunction.java         |  118 +
 .../StructStreamingResultSender.java            |  219 ++
 .../pivotal/geode/spark/connector/Employee.java |   54 +
 .../spark/connector/JavaApiIntegrationTest.java |  424 +++
 .../geode/spark/connector/Portfolio.java        |  109 +
 .../pivotal/geode/spark/connector/Position.java |   73 +
 .../src/it/resources/test-regions.xml           |   49 +
 .../src/it/resources/test-retrieve-regions.xml  |   57 +
 .../spark/connector/BasicIntegrationTest.scala  |  598 ++++
 .../RDDJoinRegionIntegrationTest.scala          |  300 ++
 .../RetrieveRegionIntegrationTest.scala         |  253 ++
 .../pivotal/geode/spark/connector/package.scala |   29 +
 .../spark/connector/testkit/GeodeCluster.scala  |   47 +
 .../spark/connector/testkit/GeodeRunner.scala   |  148 +
 .../geode/spark/connector/testkit/IOUtils.scala |   94 +
 .../spark/streaming/ManualClockHelper.scala     |   28 +
 .../spark/streaming/TestInputDStream.scala      |   44 +
 .../javaapi/GeodeJavaDStreamFunctions.java      |   86 +
 .../javaapi/GeodeJavaPairDStreamFunctions.java  |   77 +
 .../javaapi/GeodeJavaPairRDDFunctions.java      |  238 ++
 .../javaapi/GeodeJavaRDDFunctions.java          |  178 ++
 .../javaapi/GeodeJavaSQLContextFunctions.java   |   49 +
 .../javaapi/GeodeJavaSparkContextFunctions.java |   87 +
 .../spark/connector/javaapi/GeodeJavaUtil.java  |  122 +
 .../geode/spark/connector/GeodeConnection.scala |   67 +
 .../spark/connector/GeodeConnectionConf.scala   |   73 +
 .../connector/GeodeConnectionManager.scala      |   31 +
 .../spark/connector/GeodeFunctionDeployer.scala |   81 +
 .../spark/connector/GeodeKryoRegistrator.scala  |   29 +
 .../spark/connector/GeodePairRDDFunctions.scala |  140 +
 .../spark/connector/GeodeRDDFunctions.scala     |  120 +
 .../connector/GeodeSQLContextFunctions.scala    |   42 +
 .../connector/GeodeSparkContextFunctions.scala  |   39 +
 .../internal/DefaultGeodeConnection.scala       |  164 ++
 .../DefaultGeodeConnectionManager.scala         |   77 +
 .../connector/internal/LocatorHelper.scala      |  135 +
 .../StructStreamingResultCollector.scala        |  152 +
 .../connector/internal/oql/QueryParser.scala    |   58 +
 .../spark/connector/internal/oql/QueryRDD.scala |   83 +
 .../internal/oql/QueryResultCollector.scala     |   69 +
 .../connector/internal/oql/RDDConverter.scala   |   40 +
 .../connector/internal/oql/RowBuilder.scala     |   38 +
 .../connector/internal/oql/SchemaBuilder.scala  |   73 +
 .../internal/oql/UndefinedSerializer.scala      |   46 +
 .../connector/internal/rdd/GeodeJoinRDD.scala   |   67 +
 .../internal/rdd/GeodeOuterJoinRDD.scala        |   69 +
 .../internal/rdd/GeodeRDDPartition.scala        |   36 +
 .../internal/rdd/GeodeRDDPartitioner.scala      |   59 +
 .../internal/rdd/GeodeRDDPartitionerImpl.scala  |   89 +
 .../connector/internal/rdd/GeodeRDDWriter.scala |   82 +
 .../connector/internal/rdd/GeodeRegionRDD.scala |  138 +
 .../connector/javaapi/GeodeJavaRegionRDD.scala  |   26 +
 .../spark/connector/javaapi/JavaAPIHelper.scala |   53 +
 .../pivotal/geode/spark/connector/package.scala |   69 +
 .../streaming/GeodeDStreamFunctions.scala       |   89 +
 .../spark/connector/streaming/package.scala     |   32 +
 .../geode/spark/connector/JavaAPITest.java      |  163 ++
 .../connector/GeodeFunctionDeployerTest.scala   |   58 +
 .../DefaultGeodeConnectionManagerTest.scala     |   82 +
 ...tStreamingResultSenderAndCollectorTest.scala |  254 ++
 .../internal/oql/QueryParserTest.scala          |   83 +
 .../connector/ConnectorImplicitsTest.scala      |   50 +
 .../connector/GeodeConnectionConfTest.scala     |  100 +
 .../connector/GeodeDStreamFunctionsTest.scala   |   79 +
 .../spark/connector/GeodeRDDFunctionsTest.scala |  139 +
 .../spark/connector/LocatorHelperTest.scala     |  168 ++
 .../connector/rdd/GeodeRDDPartitionerTest.scala |  190 ++
 .../connector/rdd/GeodeRegionRDDTest.scala      |  117 +
 .../basic-demos/src/main/java/demo/Emp.java     |   95 +
 .../src/main/java/demo/OQLJavaDemo.java         |   59 +
 .../src/main/java/demo/PairRDDSaveJavaDemo.java |   86 +
 .../src/main/java/demo/RDDSaveJavaDemo.java     |   85 +
 .../src/main/java/demo/RegionToRDDJavaDemo.java |   57 +
 .../src/main/scala/demo/NetworkWordCount.scala  |   75 +
 .../project/Dependencies.scala                  |    8 +-
 .../project/GemFireSparkBuild.scala             |   76 -
 .../project/GeodeSparkBuild.scala               |   76 +
 geode-spark-connector/project/Settings.scala    |    4 +-
 .../client/internal/GatewaySenderBatchOp.java   |    9 +-
 .../internal/locator/wan/LocatorDiscovery.java  |   16 +-
 .../locator/wan/WanLocatorDiscovererImpl.java   |   19 +-
 .../cache/CacheXml70GatewayDUnitTest.java       |   22 +-
 .../cache/CacheXml80GatewayDUnitTest.java       |    4 +-
 .../internal/cache/UpdateVersionDUnitTest.java  |    4 +-
 .../cache/wan/CacheClientNotifierDUnitTest.java |    6 +-
 .../gemfire/internal/cache/wan/WANTestBase.java | 1866 ++----------
 ...oncurrentParallelGatewaySenderDUnitTest.java |   38 +-
 ...allelGatewaySenderOperation_1_DUnitTest.java |   27 +-
 ...allelGatewaySenderOperation_2_DUnitTest.java |  168 +-
 .../ConcurrentWANPropogation_1_DUnitTest.java   |   16 +-
 .../ConcurrentWANPropogation_2_DUnitTest.java   |   39 +-
 .../cache/wan/disttx/DistTXWANDUnitTest.java    |   10 +-
 .../CommonParallelGatewaySenderDUnitTest.java   |    8 +-
 ...wWANConcurrencyCheckForDestroyDUnitTest.java |   18 +-
 .../cache/wan/misc/PDXNewWanDUnitTest.java      |   31 +-
 ...dRegion_ParallelWANPersistenceDUnitTest.java |   19 +-
 ...dRegion_ParallelWANPropogationDUnitTest.java |   51 +-
 ...downAllPersistentGatewaySenderDUnitTest.java |    4 +-
 .../wan/misc/WANConfigurationJUnitTest.java     |   11 +-
 .../cache/wan/misc/WANSSLDUnitTest.java         |    6 +-
 .../wan/misc/WanAutoDiscoveryDUnitTest.java     |   42 +-
 .../cache/wan/misc/WanValidationsDUnitTest.java |   27 +-
 .../ParallelWANPropogationOffHeapDUnitTest.java |    3 +-
 .../SerialWANPropogationOffHeapDUnitTest.java   |    3 +-
 ...ation_PartitionedRegionOffHeapDUnitTest.java |    3 +-
 ...arallelGatewaySenderOperationsDUnitTest.java |   16 +-
 ...llelGatewaySenderQueueOverflowDUnitTest.java |   24 +-
 .../ParallelWANConflationDUnitTest.java         |   20 +-
 ...ersistenceEnabledGatewaySenderDUnitTest.java |   35 +-
 ...lelWANPropagationConcurrentOpsDUnitTest.java |    6 +-
 .../ParallelWANPropagationDUnitTest.java        |   51 +-
 ...ParallelWANPropagationLoopBackDUnitTest.java |   21 +-
 .../wan/parallel/ParallelWANStatsDUnitTest.java |   23 +-
 ...tewaySenderDistributedDeadlockDUnitTest.java |   12 +-
 ...rialGatewaySenderEventListenerDUnitTest.java |   16 +-
 .../SerialGatewaySenderOperationsDUnitTest.java |   25 +-
 .../SerialGatewaySenderQueueDUnitTest.java      |    6 +-
 ...ersistenceEnabledGatewaySenderDUnitTest.java |   14 +-
 .../SerialWANPropagationLoopBackDUnitTest.java  |   28 +-
 .../serial/SerialWANPropogationDUnitTest.java   |  119 +-
 ...NPropogation_PartitionedRegionDUnitTest.java |   24 +-
 .../SerialWANPropogationsFeatureDUnitTest.java  |   19 +-
 .../wan/serial/SerialWANStatsDUnitTest.java     |   49 +-
 .../wan/wancommand/WANCommandTestBase.java      |   35 +-
 ...anCommandCreateGatewayReceiverDUnitTest.java |   45 +-
 .../WanCommandCreateGatewaySenderDUnitTest.java |   45 +-
 ...WanCommandGatewayReceiverStartDUnitTest.java |   39 +-
 .../WanCommandGatewayReceiverStopDUnitTest.java |   37 +-
 .../WanCommandGatewaySenderStartDUnitTest.java  |   44 +-
 .../WanCommandGatewaySenderStopDUnitTest.java   |   39 +-
 .../wan/wancommand/WanCommandListDUnitTest.java |   52 +-
 .../WanCommandPauseResumeDUnitTest.java         |  138 +-
 .../wancommand/WanCommandStatusDUnitTest.java   |   79 +-
 .../management/WANManagementDUnitTest.java      |    6 +-
 .../ClusterConfigurationDUnitTest.java          |   64 +-
 .../pulse/TestRemoteClusterDUnitTest.java       |    2 +-
 .../web/swagger/config/RestApiPathProvider.java |   27 +-
 geode-web-api/src/main/webapp/META-INF/NOTICE   |   12 +-
 gradle/dependency-versions.properties           |    2 +-
 gradle/publish.gradle                           |   35 +
 gradle/utilities.gradle                         |    5 +
 549 files changed, 17514 insertions(+), 19093 deletions(-)
----------------------------------------------------------------------



Mime
View raw message