geode-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From kl...@apache.org
Subject [16/50] [abbrv] incubator-geode git commit: Merge remote-tracking branch 'origin/wan_cq_donation' into develop
Date Mon, 01 Feb 2016 20:55:33 GMT
Merge remote-tracking branch 'origin/wan_cq_donation' 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/46ae4ef5
Tree: http://git-wip-us.apache.org/repos/asf/incubator-geode/tree/46ae4ef5
Diff: http://git-wip-us.apache.org/repos/asf/incubator-geode/diff/46ae4ef5

Branch: refs/heads/feature/GEODE-773-2
Commit: 46ae4ef56d3548de033d3e20ff1e786520528b28
Parents: c01506b 441c29c
Author: Dan Smith <upthewaterspout@apache.org>
Authored: Thu Jan 28 09:56:14 2016 -0800
Committer: Dan Smith <upthewaterspout@apache.org>
Committed: Thu Jan 28 09:56:14 2016 -0800

----------------------------------------------------------------------
 gemfire-assembly/build.gradle                   |   10 +
 gemfire-cq/build.gradle                         |   22 +
 .../cache/client/internal/CloseCQOp.java        |   72 +
 .../cache/client/internal/CreateCQOp.java       |  163 +
 .../cache/client/internal/CreateCQWithIROp.java |   92 +
 .../cache/client/internal/GetDurableCQsOp.java  |  135 +
 .../client/internal/ServerCQProxyImpl.java      |  111 +
 .../gemfire/cache/client/internal/StopCQOp.java |   72 +
 .../cache/query/internal/cq/ClientCQImpl.java   |  615 +++
 .../internal/cq/CqAttributesMutatorImpl.java    |   68 +
 .../cache/query/internal/cq/CqConflatable.java  |  223 +
 .../cache/query/internal/cq/CqEventImpl.java    |  162 +
 .../cache/query/internal/cq/CqListenerImpl.java |   56 +
 .../cache/query/internal/cq/CqQueryImpl.java    |  383 ++
 .../query/internal/cq/CqServiceFactoryImpl.java |   69 +
 .../cache/query/internal/cq/CqServiceImpl.java  | 2087 +++++++
 .../internal/cq/CqServiceStatisticsImpl.java    |  100 +
 .../query/internal/cq/CqServiceVsdStats.java    |  411 ++
 .../query/internal/cq/CqStatisticsImpl.java     |   75 +
 .../cache/query/internal/cq/ServerCQImpl.java   |  655 +++
 .../tier/sockets/command/BaseCQCommand.java     |   59 +
 .../cache/tier/sockets/command/CloseCQ.java     |  131 +
 .../cache/tier/sockets/command/ExecuteCQ.java   |  168 +
 .../cache/tier/sockets/command/ExecuteCQ61.java |  220 +
 .../cache/tier/sockets/command/GetCQStats.java  |  100 +
 .../tier/sockets/command/GetDurableCQs.java     |  143 +
 .../cache/tier/sockets/command/MonitorCQ.java   |  100 +
 .../cache/tier/sockets/command/StopCQ.java      |  135 +
 ...cache.query.internal.cq.spi.CqServiceFactory |   15 +
 .../gemfire/cache/query/cq/CQJUnitTest.java     |  150 +
 .../cache/query/cq/dunit/CqDataDUnitTest.java   | 1162 ++++
 .../dunit/CqDataOptimizedExecuteDUnitTest.java  |   54 +
 .../cq/dunit/CqDataUsingPoolDUnitTest.java      | 1567 ++++++
 ...qDataUsingPoolOptimizedExecuteDUnitTest.java |   53 +
 .../cache/query/cq/dunit/CqPerfDUnitTest.java   | 1044 ++++
 .../cq/dunit/CqPerfUsingPoolDUnitTest.java      | 1004 ++++
 .../cache/query/cq/dunit/CqQueryDUnitTest.java  | 4004 ++++++++++++++
 .../dunit/CqQueryOptimizedExecuteDUnitTest.java |  311 ++
 .../cq/dunit/CqQueryUsingPoolDUnitTest.java     | 3322 +++++++++++
 ...QueryUsingPoolOptimizedExecuteDUnitTest.java |   50 +
 .../cq/dunit/CqResultSetUsingPoolDUnitTest.java | 1139 ++++
 ...ltSetUsingPoolOptimizedExecuteDUnitTest.java |  231 +
 .../cache/query/cq/dunit/CqStateDUnitTest.java  |  134 +
 .../cache/query/cq/dunit/CqStatsDUnitTest.java  |  441 ++
 .../dunit/CqStatsOptimizedExecuteDUnitTest.java |   51 +
 .../cq/dunit/CqStatsUsingPoolDUnitTest.java     |  452 ++
 ...StatsUsingPoolOptimizedExecuteDUnitTest.java |   51 +
 .../query/cq/dunit/CqTimeTestListener.java      |  266 +
 .../PartitionedRegionCqQueryDUnitTest.java      | 1788 ++++++
 ...dRegionCqQueryOptimizedExecuteDUnitTest.java |  246 +
 .../query/cq/dunit/PrCqUsingPoolDUnitTest.java  | 2029 +++++++
 .../PrCqUsingPoolOptimizedExecuteDUnitTest.java |   50 +
 .../cache/query/dunit/PdxQueryCQDUnitTest.java  |  702 +++
 .../cache/query/dunit/PdxQueryCQTestBase.java   |  494 ++
 .../dunit/QueryIndexUpdateRIDUnitTest.java      |  819 +++
 .../query/dunit/QueryMonitorDUnitTest.java      | 1296 +++++
 .../cache/snapshot/ClientSnapshotDUnitTest.java |  284 +
 .../AnalyzeCQSerializablesJUnitTest.java        |   79 +
 .../cache/PRDeltaPropagationDUnitTest.java      | 1212 ++++
 .../internal/cache/PutAllCSDUnitTest.java       | 4419 +++++++++++++++
 .../cache/RemoteCQTransactionDUnitTest.java     | 1121 ++++
 .../internal/cache/ha/CQListGIIDUnitTest.java   |  820 +++
 .../cache/ha/HADispatcherDUnitTest.java         |  695 +++
 .../sockets/ClientToServerDeltaDUnitTest.java   | 1037 ++++
 .../DeltaPropagationWithCQDUnitTest.java        |  341 ++
 ...ToRegionRelationCQRegistrationDUnitTest.java |  786 +++
 .../sockets/DurableClientCrashDUnitTest.java    |   99 +
 .../sockets/DurableClientNetDownDUnitTest.java  |   80 +
 .../sockets/DurableClientSimpleDUnitTest.java   | 3404 ++++++++++++
 .../tier/sockets/DurableClientTestCase.java     | 2089 +++++++
 .../CacheServerManagementDUnitTest.java         |  571 ++
 .../cli/commands/ClientCommandsDUnitTest.java   | 1443 +++++
 .../DurableClientCommandsDUnitTest.java         |  433 ++
 .../internal/pulse/TestCQDUnitTest.java         |  147 +
 .../internal/pulse/TestClientsDUnitTest.java    |  108 +
 .../internal/pulse/TestServerDUnitTest.java     |   99 +
 .../ClientAuthorizationTwoDUnitTest.java        |  245 +
 .../security/ClientAuthzObjectModDUnitTest.java |  416 ++
 .../ClientCQPostAuthorizationDUnitTest.java     |  522 ++
 .../ClientPostAuthorizationDUnitTest.java       |  398 ++
 .../gemfire/security/MultiuserAPIDUnitTest.java |  391 ++
 .../MultiuserDurableCQAuthzDUnitTest.java       |  489 ++
 .../gemfire/codeAnalysis/excludedClasses.txt    |    2 +
 .../gemstone/gemfire/codeAnalysis/openBugs.txt  |   21 +
 .../sanctionedDataSerializables.txt             |    4 +
 .../codeAnalysis/sanctionedSerializables.txt    |    1 +
 .../tier/sockets/durablecq-client-cache.xml     |   37 +
 .../tier/sockets/durablecq-server-cache.xml     |   32 +
 gemfire-wan/build.gradle                        |   22 +
 .../client/internal/GatewaySenderBatchOp.java   |  313 ++
 .../cache/client/internal/SenderProxy.java      |   43 +
 .../internal/locator/wan/LocatorDiscovery.java  |  227 +
 .../internal/locator/wan/LocatorHelper.java     |  143 +
 .../locator/wan/LocatorJoinMessage.java         |  105 +
 .../wan/LocatorMembershipListenerImpl.java      |  230 +
 .../locator/wan/RemoteLocatorJoinRequest.java   |   87 +
 .../locator/wan/RemoteLocatorJoinResponse.java  |   89 +
 .../locator/wan/RemoteLocatorPingRequest.java   |   56 +
 .../locator/wan/RemoteLocatorPingResponse.java  |   55 +
 .../locator/wan/RemoteLocatorRequest.java       |   66 +
 .../locator/wan/RemoteLocatorResponse.java      |   74 +
 .../internal/locator/wan/WANFactoryImpl.java    |   74 +
 .../locator/wan/WanLocatorDiscovererImpl.java   |  138 +
 .../cache/wan/AbstractRemoteGatewaySender.java  |  169 +
 .../cache/wan/GatewayReceiverFactoryImpl.java   |  147 +
 .../internal/cache/wan/GatewayReceiverImpl.java |  253 +
 .../wan/GatewaySenderEventRemoteDispatcher.java |  767 +++
 .../cache/wan/GatewaySenderFactoryImpl.java     |  389 ++
 .../wan/parallel/ParallelGatewaySenderImpl.java |  267 +
 ...rentParallelGatewaySenderEventProcessor.java |   67 +
 ...moteParallelGatewaySenderEventProcessor.java |  122 +
 ...urrentSerialGatewaySenderEventProcessor.java |   45 +
 ...RemoteSerialGatewaySenderEventProcessor.java |   50 +
 .../wan/serial/SerialGatewaySenderImpl.java     |  260 +
 ...ternal.locator.wan.LocatorMembershipListener |   15 +
 ...ne.gemfire.internal.cache.wan.spi.WANFactory |   15 +
 .../cache/CacheXml70GatewayDUnitTest.java       |  243 +
 .../cache/CacheXml80GatewayDUnitTest.java       |   77 +
 .../AnalyzeWANSerializablesJUnitTest.java       |   91 +
 .../internal/cache/UpdateVersionDUnitTest.java  |  960 ++++
 .../gemfire/internal/cache/wan/WANTestBase.java | 5178 ++++++++++++++++++
 ...oncurrentParallelGatewaySenderDUnitTest.java |  860 +++
 ...ntParallelGatewaySenderOffHeapDUnitTest.java |   32 +
 ...allelGatewaySenderOperation_1_DUnitTest.java |  848 +++
 ...allelGatewaySenderOperation_2_DUnitTest.java |  579 ++
 ...tSerialGatewaySenderOperationsDUnitTest.java |  111 +
 ...GatewaySenderOperationsOffHeapDUnitTest.java |   32 +
 .../ConcurrentWANPropogation_1_DUnitTest.java   |  608 ++
 .../ConcurrentWANPropogation_2_DUnitTest.java   |  485 ++
 .../cache/wan/disttx/DistTXWANDUnitTest.java    |  209 +
 .../CommonParallelGatewaySenderDUnitTest.java   |  481 ++
 ...onParallelGatewaySenderOffHeapDUnitTest.java |   32 +
 ...wWANConcurrencyCheckForDestroyDUnitTest.java |  526 ++
 .../cache/wan/misc/PDXNewWanDUnitTest.java      |  787 +++
 ...dRegion_ParallelWANPersistenceDUnitTest.java |  752 +++
 ...dRegion_ParallelWANPropogationDUnitTest.java | 1132 ++++
 .../SenderWithTransportFilterDUnitTest.java     |  274 +
 ...downAllPersistentGatewaySenderDUnitTest.java |  205 +
 .../wan/misc/WANConfigurationJUnitTest.java     |  617 +++
 .../wan/misc/WANLocatorServerDUnitTest.java     |  193 +
 .../cache/wan/misc/WANSSLDUnitTest.java         |  151 +
 .../wan/misc/WanAutoDiscoveryDUnitTest.java     |  557 ++
 .../cache/wan/misc/WanValidationsDUnitTest.java | 1678 ++++++
 ...GatewaySenderOperationsOffHeapDUnitTest.java |   34 +
 ...ewaySenderQueueOverflowOffHeapDUnitTest.java |   34 +
 .../ParallelWANConflationOffHeapDUnitTest.java  |   34 +
 ...nceEnabledGatewaySenderOffHeapDUnitTest.java |   34 +
 ...ropogationConcurrentOpsOffHeapDUnitTest.java |   34 +
 .../ParallelWANPropogationOffHeapDUnitTest.java |   34 +
 ...erialGatewaySenderQueueOffHeapDUnitTest.java |   34 +
 ...nceEnabledGatewaySenderOffHeapDUnitTest.java |   34 +
 .../SerialWANPropogationOffHeapDUnitTest.java   |   34 +
 ...ation_PartitionedRegionOffHeapDUnitTest.java |   34 +
 ...arallelGatewaySenderOperationsDUnitTest.java | 1984 +++++++
 ...llelGatewaySenderQueueOverflowDUnitTest.java |  531 ++
 .../ParallelWANConflationDUnitTest.java         |  496 ++
 ...ersistenceEnabledGatewaySenderDUnitTest.java | 1823 ++++++
 ...llelWANPropagationClientServerDUnitTest.java |  114 +
 ...lelWANPropagationConcurrentOpsDUnitTest.java |  290 +
 .../ParallelWANPropagationDUnitTest.java        | 1448 +++++
 ...ParallelWANPropagationLoopBackDUnitTest.java |  425 ++
 .../wan/parallel/ParallelWANStatsDUnitTest.java |  632 +++
 ...tewaySenderDistributedDeadlockDUnitTest.java |  407 ++
 ...rialGatewaySenderEventListenerDUnitTest.java |  390 ++
 .../SerialGatewaySenderOperationsDUnitTest.java |  602 ++
 .../SerialGatewaySenderQueueDUnitTest.java      |  337 ++
 ...ersistenceEnabledGatewaySenderDUnitTest.java |  602 ++
 .../SerialWANPropagationLoopBackDUnitTest.java  |  538 ++
 .../serial/SerialWANPropogationDUnitTest.java   | 1602 ++++++
 ...NPropogation_PartitionedRegionDUnitTest.java |  439 ++
 .../SerialWANPropogationsFeatureDUnitTest.java  |  373 ++
 .../wan/serial/SerialWANStatsDUnitTest.java     |  596 ++
 .../wan/wancommand/WANCommandTestBase.java      |  513 ++
 ...anCommandCreateGatewayReceiverDUnitTest.java |  699 +++
 .../WanCommandCreateGatewaySenderDUnitTest.java |  763 +++
 ...WanCommandGatewayReceiverStartDUnitTest.java |  327 ++
 .../WanCommandGatewayReceiverStopDUnitTest.java |  332 ++
 .../WanCommandGatewaySenderStartDUnitTest.java  |  416 ++
 .../WanCommandGatewaySenderStopDUnitTest.java   |  367 ++
 .../wan/wancommand/WanCommandListDUnitTest.java |  403 ++
 .../WanCommandPauseResumeDUnitTest.java         |  716 +++
 .../wancommand/WanCommandStatusDUnitTest.java   |  582 ++
 .../management/WANManagementDUnitTest.java      |  525 ++
 .../ClusterConfigurationDUnitTest.java          | 1055 ++++
 .../pulse/TestRemoteClusterDUnitTest.java       |  274 +
 .../gemfire/codeAnalysis/excludedClasses.txt    |    2 +
 .../gemstone/gemfire/codeAnalysis/openBugs.txt  |   21 +
 .../sanctionedDataSerializables.txt             |   28 +
 .../codeAnalysis/sanctionedSerializables.txt    |    0
 settings.gradle                                 |    2 +
 190 files changed, 94367 insertions(+)
----------------------------------------------------------------------



Mime
View raw message