[bookkeeper] 01/12: Merge tag 'upstream/4.3.0'
Emmanuel Bourg
ebourg-guest at moszumanska.debian.org
Mon Jan 16 10:01:11 UTC 2017
This is an automated email from the git hooks/post-receive script.
ebourg-guest pushed a commit to branch master
in repository bookkeeper.
commit c533116d350f09dde77c946efbd2641e6b5b29b7
Merge: 27b5a08 eadd2b5
Author: Emmanuel Bourg <ebourg at apache.org>
Date: Mon Jan 16 09:44:37 2017 +0100
Merge tag 'upstream/4.3.0'
Upstream version 4.3.0
CHANGES.txt | 340 +-
README | 13 +-
bin/test-patch-10-compile | 4 +-
bookkeeper-benchmark/pom.xml | 12 +-
.../apache/bookkeeper/benchmark/BenchBookie.java | 31 +-
.../benchmark/BenchReadThroughputLatency.java | 8 +-
.../benchmark/BenchThroughputLatency.java | 12 +-
.../apache/bookkeeper/benchmark/MySqlClient.java | 11 +-
.../apache/bookkeeper/benchmark/TestClient.java | 3 +-
.../apache/bookkeeper/benchmark/TestBenchmark.java | 26 +-
.../src/test/resources/log4j.properties | 1 -
bookkeeper-server/bin/bookkeeper | 2 +
bookkeeper-server/bin/bookkeeper-cluster.sh | 135 +
bookkeeper-server/conf/bk_server.conf | 53 +
bookkeeper-server/conf/bkenv.sh | 3 +
bookkeeper-server/pom.xml | 53 +-
.../bookkeeper/bookie/BookKeeperServerStats.java | 85 +
.../java/org/apache/bookkeeper/bookie/Bookie.java | 590 +--
...rCacheMXBean.java => BookieCriticalThread.java} | 61 +-
.../apache/bookkeeper/bookie/BookieException.java | 5 +-
.../org/apache/bookkeeper/bookie/BookieShell.java | 264 +-
.../org/apache/bookkeeper/bookie/BookieThread.java | 55 +
.../apache/bookkeeper/bookie/BufferedChannel.java | 176 +-
.../bookkeeper/bookie/BufferedChannelBase.java | 55 +
.../bookkeeper/bookie/BufferedReadChannel.java | 103 +
.../apache/bookkeeper/bookie/CacheCallback.java} | 15 +-
.../apache/bookkeeper/bookie/CheckpointSource.java | 83 +
.../java/org/apache/bookkeeper/bookie/Cookie.java | 330 +-
.../org/apache/bookkeeper/bookie/EntryKey.java | 83 +
.../apache/bookkeeper/bookie/EntryKeyValue.java | 129 +
.../org/apache/bookkeeper/bookie/EntryLogger.java | 499 +-
.../apache/bookkeeper/bookie/EntryMemTable.java | 440 ++
.../org/apache/bookkeeper/bookie/FileInfo.java | 127 +-
.../bookkeeper/bookie/FileSystemUpgrade.java | 17 +-
.../bookkeeper/bookie/GarbageCollectorThread.java | 62 +-
.../bookkeeper/bookie/HandleFactoryImpl.java | 34 +-
.../bookkeeper/bookie/IndexInMemPageMgr.java | 564 +++
.../bookkeeper/bookie/IndexPersistenceMgr.java | 588 +++
.../bookie/InterleavedLedgerStorage.java | 246 +-
.../java/org/apache/bookkeeper/bookie/Journal.java | 644 ++-
.../apache/bookkeeper/bookie/JournalChannel.java | 171 +-
.../bookkeeper/bookie/LEPStateChangeCallback.java} | 20 +-
.../apache/bookkeeper/bookie/LedgerCacheImpl.java | 845 +---
.../bookkeeper/bookie/LedgerCacheMXBean.java | 10 -
.../bookkeeper/bookie/LedgerDescriptorImpl.java | 2 +-
.../bookkeeper/bookie/LedgerDirsManager.java | 231 +-
.../apache/bookkeeper/bookie/LedgerEntryPage.java | 151 +-
.../apache/bookkeeper/bookie/LedgerStorage.java | 19 +-
.../java/org/apache/bookkeeper/bookie/LogMark.java | 83 +
.../bookkeeper/bookie/ReadOnlyEntryLogger.java | 2 +-
.../apache/bookkeeper/bookie/SkipListArena.java | 238 +
.../apache/bookkeeper/bookie/SkipListFlusher.java} | 24 +-
.../bookkeeper/bookie/SortedLedgerStorage.java | 186 +
.../org/apache/bookkeeper/bookie/SyncThread.java | 189 +
.../org/apache/bookkeeper/client/BKException.java | 12 +
.../org/apache/bookkeeper/client/BookKeeper.java | 321 +-
.../apache/bookkeeper/client/BookKeeperAdmin.java | 147 +-
.../bookkeeper/client/BookKeeperClientStats.java | 43 +
.../apache/bookkeeper/client/BookieWatcher.java | 133 +-
.../client/DefaultEnsemblePlacementPolicy.java | 93 +
.../bookkeeper/client/EnsemblePlacementPolicy.java | 89 +
.../apache/bookkeeper/client/LedgerChecker.java | 28 +-
.../apache/bookkeeper/client/LedgerCreateOp.java | 35 +-
.../apache/bookkeeper/client/LedgerDeleteOp.java | 11 +
.../org/apache/bookkeeper/client/LedgerEntry.java | 2 +-
.../apache/bookkeeper/client/LedgerFragment.java | 11 +-
.../client/LedgerFragmentReplicator.java | 39 +-
.../org/apache/bookkeeper/client/LedgerHandle.java | 277 +-
.../apache/bookkeeper/client/LedgerMetadata.java | 89 +-
.../org/apache/bookkeeper/client/LedgerOpenOp.java | 58 +-
.../apache/bookkeeper/client/LedgerRecoveryOp.java | 79 +-
.../apache/bookkeeper/client/MacDigestManager.java | 6 +-
.../org/apache/bookkeeper/client/PendingAddOp.java | 25 +-
.../apache/bookkeeper/client/PendingReadOp.java | 126 +-
.../client/RackawareEnsemblePlacementPolicy.java | 572 +++
.../bookkeeper/client/ReadLastConfirmedOp.java | 8 +-
.../bookkeeper/client/ReadOnlyLedgerHandle.java | 7 +-
.../client/RoundRobinDistributionSchedule.java | 34 +-
.../bookkeeper/client/TryReadLastConfirmedOp.java | 107 +
.../bookkeeper/conf/AbstractConfiguration.java | 9 +-
.../bookkeeper/conf/ClientConfiguration.java | 137 +-
.../org/apache/bookkeeper/conf/Configurable.java} | 30 +-
.../bookkeeper/conf/ServerConfiguration.java | 580 ++-
.../bookkeeper/meta/AbstractZkLedgerManager.java | 7 +-
.../bookkeeper/meta/CleanupLedgerManager.java | 226 +
.../bookkeeper/meta/HierarchicalLedgerManager.java | 1 -
.../bookkeeper/meta/LedgerManagerFactory.java | 10 +-
.../bookkeeper/meta/MSLedgerManagerFactory.java | 14 +-
.../meta/ZkLedgerUnderreplicationManager.java | 2 +-
.../metastore/InMemoryMetastoreTable.java | 8 +-
.../org/apache/bookkeeper/metastore/Value.java | 4 +-
.../bookkeeper/net/AbstractDNSToSwitchMapping.java | 142 +
.../apache/bookkeeper/net/BookieSocketAddress.java | 100 +
.../bookkeeper/net/CachedDNSToSwitchMapping.java | 153 +
.../bookkeeper/net/CommonConfigurationKeys.java} | 22 +-
.../main/java/org/apache/bookkeeper/net/DNS.java | 116 +-
.../apache/bookkeeper/net/DNSToSwitchMapping.java | 61 +
.../java/org/apache/bookkeeper/net/NetUtils.java | 61 +
.../org/apache/bookkeeper/net/NetworkTopology.java | 877 ++++
.../main/java/org/apache/bookkeeper/net/Node.java | 62 +
.../java/org/apache/bookkeeper/net/NodeBase.java | 186 +
.../apache/bookkeeper/net/ScriptBasedMapping.java | 264 ++
.../bookkeeper/processor/RequestProcessor.java} | 29 +-
.../org/apache/bookkeeper/proto/BookieClient.java | 293 +-
.../apache/bookkeeper/proto/BookieNettyServer.java | 199 +
.../bookkeeper/proto/BookieProtoEncoding.java | 330 ++
.../apache/bookkeeper/proto/BookieProtocol.java | 170 +
.../bookkeeper/proto/BookieRequestHandler.java | 89 +
.../bookkeeper/proto/BookieRequestProcessor.java | 193 +
.../org/apache/bookkeeper/proto/BookieServer.java | 374 +-
.../apache/bookkeeper/proto/BookieServerBean.java | 10 +-
.../proto/BookkeeperInternalCallbacks.java | 4 +-
.../bookkeeper/proto/BookkeeperProtocol.java | 4774 ++++++++++++++++++++
.../proto/DefaultPerChannelBookieClientPool.java | 93 +
.../apache/bookkeeper/proto/NIOServerFactory.java | 583 ---
.../bookkeeper/proto/PacketProcessorBase.java | 76 +
.../bookkeeper/proto/PacketProcessorBaseV3.java | 72 +
.../bookkeeper/proto/PerChannelBookieClient.java | 813 ++--
.../proto/PerChannelBookieClientFactory.java} | 22 +-
.../proto/PerChannelBookieClientPool.java | 59 +
.../bookkeeper/proto/ReadEntryProcessor.java | 133 +
.../bookkeeper/proto/ReadEntryProcessorV3.java | 164 +
.../apache/bookkeeper/proto/ResponseBuilder.java | 47 +
.../bookkeeper/proto/WriteEntryProcessor.java | 99 +
.../bookkeeper/proto/WriteEntryProcessorV3.java | 151 +
.../org/apache/bookkeeper/replication/Auditor.java | 77 +-
.../bookkeeper/replication/AuditorElector.java | 40 +-
.../bookkeeper/replication/AutoRecoveryMain.java | 30 +-
.../replication/BookieLedgerIndexer.java | 9 +-
.../bookkeeper/replication/ReplicationStats.java} | 28 +-
.../bookkeeper/replication/ReplicationWorker.java | 153 +-
.../bookkeeper/streaming/LedgerInputStream.java | 2 +-
.../bookkeeper/streaming/LedgerOutputStream.java | 2 +-
.../apache/bookkeeper/tools/BookKeeperTools.java | 20 +-
.../bookkeeper/util/DaemonThreadFactory.java | 44 +-
.../org/apache/bookkeeper/util/DiskChecker.java | 106 +-
.../org/apache/bookkeeper/util/EntryFormatter.java | 2 +-
.../java/org/apache/bookkeeper/util/HardLink.java | 16 +-
.../java/org/apache/bookkeeper/util/IOUtils.java | 20 +-
.../apache/bookkeeper/util/LocalBookKeeper.java | 6 +-
.../java/org/apache/bookkeeper/util/NativeIO.java | 119 +
.../bookkeeper/util/OrderedSafeExecutor.java | 86 +-
.../java/org/apache/bookkeeper/util/Shell.java | 677 +++
.../org/apache/bookkeeper/util/StringUtils.java | 29 -
.../org/apache/bookkeeper/util/ZeroBuffer.java | 73 +
.../BoundExponentialBackoffRetryPolicy.java} | 28 +-
.../zookeeper/ExponentialBackoffRetryPolicy.java} | 36 +-
.../apache/bookkeeper/zookeeper/RetryPolicy.java | 55 +
.../bookkeeper/zookeeper/ZooKeeperClient.java | 1046 +++++
.../bookkeeper/zookeeper/ZooKeeperWatcherBase.java | 47 +-
.../org/apache/bookkeeper/zookeeper/ZooWorker.java | 147 +
.../src/main/proto/BookkeeperProtocol.proto | 122 +
.../src/main/resources/NOTICE.bin.txt | 1 +
.../src/main/resources/findbugsExclude.xml | 17 +
.../apache/bookkeeper/bookie/BookieAccessor.java | 6 +-
.../bookie/BookieInitializationTest.java | 126 +-
.../bookkeeper/bookie/BookieJournalTest.java | 266 +-
.../bookkeeper/bookie/BookieShutdownTest.java | 130 +-
.../apache/bookkeeper/bookie/BookieThreadTest.java | 84 +
.../apache/bookkeeper/bookie/CompactionTest.java | 232 +-
.../org/apache/bookkeeper/bookie/CookieTest.java | 197 +-
.../apache/bookkeeper/bookie/CreateNewLogTest.java | 13 +-
.../org/apache/bookkeeper/bookie/EntryLogTest.java | 33 +-
.../bookkeeper/bookie/IndexCorruptionTest.java | 10 +-
.../apache/bookkeeper/bookie/LedgerCacheTest.java | 87 +-
.../bookkeeper/bookie/TestLedgerDirsManager.java | 17 +-
.../apache/bookkeeper/bookie/TestSyncThread.java | 353 ++
.../bookkeeper/bookie/UpdateCookieCmdTest.java | 216 +
.../org/apache/bookkeeper/bookie/UpgradeTest.java | 38 +-
.../bookkeeper/client/BookKeeperCloseTest.java | 552 +++
.../apache/bookkeeper/client/BookKeeperTest.java | 6 +-
.../bookkeeper/client/BookieRecoveryTest.java | 117 +-
.../bookkeeper/client/BookieWriteLedgerTest.java | 10 +-
.../org/apache/bookkeeper/client/ClientUtil.java | 18 +-
.../apache/bookkeeper/client/LedgerCloseTest.java | 44 +-
.../bookkeeper/client/LedgerRecoveryTest.java | 22 +-
.../apache/bookkeeper/client/ListLedgersTest.java | 3 +-
.../client/RoundRobinDistributionScheduleTest.java | 102 +-
.../apache/bookkeeper/client/SlowBookieTest.java | 36 +-
.../org/apache/bookkeeper/client/TestFencing.java | 72 +-
.../bookkeeper/client/TestLedgerChecker.java | 86 +-
.../client/TestLedgerFragmentReplication.java | 74 +-
.../TestRackawareEnsemblePlacementPolicy.java | 286 ++
.../apache/bookkeeper/client/TestReadTimeout.java | 32 +-
.../bookkeeper/client/TestSpeculativeRead.java | 34 +-
.../client/TestTryReadLastConfirmed.java | 188 +
.../bookkeeper/client/TestWatchEnsembleChange.java | 37 +-
.../TestBKConfiguration.java} | 26 +-
.../org/apache/bookkeeper/meta/GcLedgersTest.java | 2 +
.../apache/bookkeeper/meta/LedgerLayoutTest.java | 10 +-
.../bookkeeper/meta/LedgerManagerIteratorTest.java | 2 +
.../apache/bookkeeper/meta/TestLedgerManager.java | 55 +-
.../apache/bookkeeper/metastore/TestMetaStore.java | 10 +-
.../apache/bookkeeper/proto/TestDeathwatcher.java | 4 +-
.../proto/TestPerChannelBookieClient.java | 87 +-
.../apache/bookkeeper/proto/TestProtoVersions.java | 113 -
.../bookkeeper/replication/AuditorBookieTest.java | 17 +-
.../replication/AuditorLedgerCheckerTest.java | 32 +-
.../AuditorPeriodicBookieCheckTest.java | 16 +-
.../replication/AuditorPeriodicCheckTest.java | 73 +-
.../replication/AuditorRollingRestartTest.java | 8 +-
.../replication/AutoRecoveryMainTest.java | 3 +-
.../replication/BookieAutoRecoveryTest.java | 184 +-
.../replication/BookieLedgerIndexTest.java | 4 +-
.../TestAutoRecoveryAlongWithBookieServers.java | 18 +-
.../TestLedgerUnderreplicationManager.java | 25 +-
.../replication/TestReplicationWorker.java | 105 +-
.../apache/bookkeeper/test/AsyncLedgerOpsTest.java | 4 +-
.../bookkeeper/test/BookKeeperClusterTestCase.java | 62 +-
.../apache/bookkeeper/test/BookieClientTest.java | 42 +-
.../apache/bookkeeper/test/BookieFailureTest.java | 10 +-
.../bookkeeper/test/BookieJournalRollingTest.java | 56 +-
.../bookkeeper/test/BookieReadWriteTest.java | 242 +-
.../apache/bookkeeper/test/BookieZKExpireTest.java | 4 +-
.../java/org/apache/bookkeeper/test/CloseTest.java | 2 +-
.../bookkeeper/test/ConcurrentLedgerTest.java | 19 +-
.../apache/bookkeeper/test/ConditionalSetTest.java | 11 +-
.../apache/bookkeeper/test/ConfigurationTest.java | 6 +-
.../apache/bookkeeper/test/LedgerDeleteTest.java | 32 +-
.../org/apache/bookkeeper/test/LoopbackClient.java | 17 +-
.../bookkeeper/test/MultipleThreadReadTest.java | 308 ++
.../bookkeeper/test/NIOServerFactoryTest.java | 66 -
.../apache/bookkeeper/test/ReadOnlyBookieTest.java | 74 +
.../apache/bookkeeper/test/TestBackwardCompat.java | 253 +-
.../org/apache/bookkeeper/test/TestCallbacks.java | 18 -
.../org/apache/bookkeeper/test/ZooKeeperUtil.java | 28 +-
.../apache/bookkeeper/util/StaticDNSResolver.java | 80 +
.../apache/bookkeeper/util/TestDiskChecker.java | 31 +-
.../bookkeeper/zookeeper/TestZooKeeperClient.java | 367 ++
.../src/test/resources/log4j.properties | 1 -
.../codahale-metrics-provider/pom.xml | 62 +
.../bookkeeper/stats/CodahaleMetricsProvider.java | 147 +
.../bookkeeper/stats/CodahaleOpStatsLogger.java | 68 +
.../bookkeeper/stats/CodahaleStatsLogger.java | 99 +
.../pom.xml | 15 +-
.../twitter-ostrich-provider/pom.xml | 55 +
.../stats/twitter/ostrich/CounterImpl.java | 53 +
.../stats/twitter/ostrich/OpStatsLoggerImpl.java | 81 +
.../stats/twitter/ostrich/OstrichProvider.java | 78 +
.../twitter/ostrich/OstrichStatsLoggerImpl.java | 69 +
.../twitter-science-provider/pom.xml | 89 +
.../stats/twitter/science/CounterImpl.java | 69 +
.../stats/twitter/science/HTTPStatsExporter.java | 77 +
.../stats/twitter/science/OpStatsLoggerImpl.java | 72 +
.../twitter/science/TwitterStatsLoggerImpl.java | 72 +
.../twitter/science/TwitterStatsProvider.java | 63 +
bookkeeper-stats/pom.xml | 57 +
.../java/org/apache/bookkeeper/stats/Counter.java | 50 +
.../java/org/apache/bookkeeper/stats/Gauge.java | 37 +-
.../apache/bookkeeper/stats/NullStatsLogger.java | 96 +
.../apache/bookkeeper/stats/NullStatsProvider.java | 40 +
.../org/apache/bookkeeper/stats/OpStatsData.java | 76 +
.../org/apache/bookkeeper/stats/OpStatsLogger.java | 49 +
.../java/org/apache/bookkeeper/stats/Stats.java | 63 +
.../org/apache/bookkeeper/stats/StatsLogger.java | 55 +
.../org/apache/bookkeeper/stats/StatsProvider.java | 45 +
compat-deps/bookkeeper-server-compat-4.0.0/pom.xml | 2 +-
compat-deps/bookkeeper-server-compat-4.1.0/pom.xml | 2 +-
.../pom.xml | 22 +-
compat-deps/hedwig-server-compat-4.0.0/pom.xml | 2 +-
compat-deps/hedwig-server-compat-4.1.0/pom.xml | 2 +-
.../pom.xml | 22 +-
compat-deps/pom.xml | 6 +-
doc/bookieConfigParams.textile | 33 +-
hedwig-client-jms/pom.xml | 301 ++
.../src/main/grammar/javacc/readme.html | 26 +
.../src/main/grammar/javacc/selector_grammar.jjt | 689 +++
.../java/org/apache/hedwig/jms/ConnectionImpl.java | 476 ++
.../apache/hedwig/jms/ConnectionMetaDataImpl.java | 77 +
.../main/java/org/apache/hedwig/jms/DebugUtil.java | 69 +
.../java/org/apache/hedwig/jms/LRUCacheMap.java | 104 +
.../java/org/apache/hedwig/jms/LRUCacheSet.java | 115 +
.../apache/hedwig/jms/MessagingSessionFacade.java | 421 ++
.../main/java/org/apache/hedwig/jms/Mutable.java | 48 +-
.../java/org/apache/hedwig/jms/SessionImpl.java | 2009 ++++++++
.../java/org/apache/hedwig/jms/StateManager.java | 179 +
.../hedwig/jms/jndi/HedwigInitialContext.java | 106 +
.../jms/jndi/HedwigInitialContextFactory.java | 38 +-
.../org/apache/hedwig/jms/jndi/package-info.html | 65 +
.../hedwig/jms/message/BytesMessageImpl.java | 657 +++
.../apache/hedwig/jms/message/MapMessageImpl.java | 295 ++
.../org/apache/hedwig/jms/message/MessageImpl.java | 872 ++++
.../org/apache/hedwig/jms/message/MessageUtil.java | 444 ++
.../hedwig/jms/message/ObjectMessageImpl.java | 168 +
.../hedwig/jms/message/StreamMessageImpl.java | 752 +++
.../apache/hedwig/jms/message/TextMessageImpl.java | 135 +
.../hedwig/jms/message/header/JmsHeader.java | 1126 +++++
.../jms/message/header/MetadataProcessor.java | 163 +
.../apache/hedwig/jms/message/package-info.html | 29 +
.../java/org/apache/hedwig/jms/package-info.html | 92 +
.../jms/selector/BinaryArithmeticFunction.java | 184 +
.../hedwig/jms/selector/BinaryExprFunction.java | 51 +
.../apache/hedwig/jms/selector/ExprFunction.java | 34 +-
.../selector/InterpretSelectorParserVisitor.java | 180 +
.../jms/selector/LogicalComparisonFunction.java | 64 +
.../org/apache/hedwig/jms/selector/MyNode.java | 101 +
.../hedwig/jms/selector/PropertyExprFunction.java | 512 +++
.../hedwig/jms/selector/SelectorConstant.java | 187 +
.../hedwig/jms/selector/SelectorEvalState.java | 56 +
.../jms/selector/SelectorEvaluationException.java | 38 +-
.../selector/TreeDumperSelectorParserVisitor.java | 261 ++
.../jms/selector/UnaryArithmeticFunction.java | 73 +
.../hedwig/jms/selector/UnaryExprFunction.java | 65 +
.../jms/selector/ValueComparisonFunction.java | 329 ++
.../apache/hedwig/jms/selector/package-info.html | 35 +
.../jms/spi/HedwigConnectionFactoryImpl.java | 64 +
.../hedwig/jms/spi/HedwigConnectionImpl.java | 164 +
.../jms/spi/HedwigMessagingSessionFacade.java | 624 +++
.../apache/hedwig/jms/spi/MessageConsumerImpl.java | 74 +
.../apache/hedwig/jms/spi/MessageProducerImpl.java | 117 +
.../apache/hedwig/jms/spi/QueueSessionImpl.java | 84 +
.../apache/hedwig/jms/spi/TopicPublisherImpl.java | 226 +
.../apache/hedwig/jms/spi/TopicSessionImpl.java | 76 +
.../apache/hedwig/jms/spi/TopicSubscriberImpl.java | 323 ++
.../org/apache/hedwig/jms/spi/package-info.html | 30 +
.../src/main/protobuf/JmsHeader.proto | 54 +
.../src/main/resources/findbugsExclude.xml | 48 +
.../src/main/resources/log4j.properties | 35 +
.../org/apache/activemq/AutoFailTestSupport.java | 153 +
.../apache/activemq/CombinationTestSupport.java | 250 +
.../org/apache/activemq/ConnectionCleanupTest.java | 73 +
.../activemq/ConsumerReceiveWithTimeoutTest.java | 84 +
.../java/org/apache/activemq/ExpiryHogTest.java | 61 +
.../java/org/apache/activemq/JMSConsumerTest.java | 936 ++++
.../activemq/JMSDurableTopicRedeliverTest.java | 76 +
.../org/apache/activemq/JMSIndividualAckTest.java | 165 +
.../java/org/apache/activemq/JMSMessageTest.java | 504 +++
.../java/org/apache/activemq/JMSUsecaseTest.java | 109 +
.../apache/activemq/JmsAutoAckListenerTest.java | 77 +
.../java/org/apache/activemq/JmsAutoAckTest.java | 75 +
.../java/org/apache/activemq/JmsBenchmark.java | 204 +
.../apache/activemq/JmsClientAckListenerTest.java | 127 +
.../java/org/apache/activemq/JmsClientAckTest.java | 148 +
.../activemq/JmsConnectionStartStopTest.java | 169 +
.../JmsConsumerResetActiveListenerTest.java | 157 +
.../activemq/JmsCreateConsumerInOnMessageTest.java | 96 +
.../activemq/JmsDurableTopicSelectorTest.java | 26 +
.../activemq/JmsDurableTopicSendReceiveTest.java | 87 +
.../activemq/JmsDurableTopicTransactionTest.java | 38 +
.../activemq/JmsMultipleClientsTestSupport.java | 281 ++
.../org/apache/activemq/JmsRedeliveredTest.java | 380 ++
.../apache/activemq/JmsRollbackRedeliveryTest.java | 339 ++
.../apache/activemq/JmsSendReceiveTestSupport.java | 234 +
.../JmsSendReceiveWithMessageExpirationTest.java | 239 +
.../activemq/JmsSendWithAsyncCallbackTest.java | 107 +
.../java/org/apache/activemq/JmsTestSupport.java | 174 +
.../activemq/JmsTopicCompositeSendReceiveTest.java | 101 +
.../org/apache/activemq/JmsTopicRedeliverTest.java | 176 +
.../org/apache/activemq/JmsTopicSelectorTest.java | 212 +
.../JmsTopicSendReceiveSubscriberTest.java | 33 +
.../apache/activemq/JmsTopicSendReceiveTest.java | 95 +
.../JmsTopicSendReceiveWithTwoConnectionsTest.java | 116 +
...icSendReceiveWithTwoConnectionsWithJMXTest.java | 28 +
.../activemq/JmsTopicSendSameMessageTest.java | 46 +
.../apache/activemq/JmsTopicTransactionTest.java | 36 +
.../apache/activemq/JmsTransactionTestSupport.java | 692 +++
.../java/org/apache/activemq/LoadTestBurnIn.java | 164 +
.../activemq/MessageListenerRedeliveryTest.java | 193 +
.../org/apache/activemq/RedeliveryPolicyTest.java | 145 +
.../test/java/org/apache/activemq/TestSupport.java | 151 +
.../java/org/apache/activemq/TimeStampTest.java | 91 +
.../org/apache/activemq/demo/SimpleConsumer.java | 129 +
.../org/apache/activemq/demo/SimpleProducer.java | 138 +
.../java/org/apache/activemq/load/LoadClient.java | 222 +
.../org/apache/activemq/load/LoadController.java | 98 +
.../java/org/apache/activemq/load/LoadTest.java | 127 +
.../apache/activemq/perf/ConnectionChurnTest.java | 77 +
.../activemq/perf/InactiveDurableTopicTest.java | 171 +
.../apache/activemq/perf/NetworkedSyncTest.java | 212 +
.../activemq/perf/NumberOfDestinationsTest.java | 88 +
.../org/apache/activemq/perf/PerfConsumer.java | 139 +
.../org/apache/activemq/perf/PerfProducer.java | 125 +
.../java/org/apache/activemq/perf/PerfRate.java | 78 +
.../perf/SimpleDurableTopicNetworkTest.java | 50 +
.../activemq/perf/SimpleDurableTopicTest.java | 63 +
.../apache/activemq/perf/SimpleNetworkTest.java | 79 +
.../perf/SimpleNonPersistentTopicTest.java | 37 +
.../org/apache/activemq/perf/SimpleTopicTest.java | 181 +
.../org/apache/activemq/perf/SlowConsumer.java | 47 +
.../activemq/perf/SlowConsumerTopicTest.java | 56 +
.../perf/SlowDurableConsumerTopicTest.java | 38 +
.../apache/activemq/test/JmsResourceProvider.java | 237 +
.../activemq/test/JmsSendReceiveTestSupport.java | 273 ++
.../activemq/test/JmsTopicSendReceiveTest.java | 116 +
...ceiveWithTwoConnectionsAndByteSelectorTest.java | 35 +
.../JmsTopicSendReceiveWithTwoConnectionsTest.java | 129 +
.../java/org/apache/activemq/test/TestSupport.java | 261 ++
.../DelegatingTransactionalMessageListener.java | 71 +
.../activemq/usecases/ChangeSentMessageTest.java | 62 +
.../usecases/ChangeSessionDeliveryModeTest.java | 72 +
.../activemq/usecases/CompositeConsumeTest.java | 73 +
.../activemq/usecases/CompositePublishTest.java | 145 +
.../ConcurrentProducerDurableConsumerTest.java | 413 ++
.../usecases/DiscriminatingConsumerLoadTest.java | 322 ++
.../usecases/DispatchMultipleConsumersTest.java | 214 +
.../DurableConsumerCloseAndReconnectTest.java | 192 +
.../activemq/usecases/DurableSubProcessTest.java | 628 +++
.../usecases/DurableSubSelectorDelayTest.java | 256 ++
.../usecases/DurableSubscriptionHangTestCase.java | 119 +
.../org/apache/activemq/usecases/MyObject.java | 73 +
.../NonBlockingConsumerRedeliveryTest.java | 340 ++
.../usecases/ObjectMessageNotSerializableTest.java | 241 +
.../usecases/ProducerConsumerTestSupport.java | 54 +
.../PublishOnDurableTopicConsumedMessageTest.java | 27 +
.../PublishOnTopicConsumedMessageTest.java | 66 +
.../SubscribeClosePublishThenConsumeTest.java | 107 +
.../org/apache/activemq/usecases/TestSupport.java | 157 +
.../activemq/usecases/TopicRedeliverTest.java | 300 ++
.../usecases/TransactionRollbackOrderTest.java | 161 +
.../apache/activemq/usecases/TransactionTest.java | 120 +
.../org/apache/activemq/util/ConsumerThread.java | 86 +
.../apache/activemq/util/DefaultTestAppender.java | 82 +
.../java/org/apache/activemq/util/IdGenerator.java | 34 +-
.../org/apache/activemq/util/MessageIdList.java | 267 ++
.../org/apache/activemq/util/ProducerThread.java | 87 +
.../java/org/apache/activemq/util/SimplePojo.java | 77 +
.../test/java/org/apache/activemq/util/Wait.java | 40 +
.../test/java/org/apache/hedwig/JmsTestBase.java | 95 +
.../java/org/apache/hedwig/jms/BasicJMSTest.java | 337 ++
.../jms/selector/BasicSelectorGrammarTest.java | 376 ++
.../jms/selector/activemq/SelectorParserTest.java | 46 +
.../hedwig/jms/selector/activemq/SelectorTest.java | 399 ++
hedwig-client/pom.xml | 8 +-
.../client/benchmark/BenchmarkPublisher.java | 5 +-
.../client/benchmark/BenchmarkSubscriber.java | 10 +-
.../hedwig/client/netty/HedwigClientImpl.java | 7 +-
.../hedwig/client/netty/HedwigSubscriber.java | 1 +
.../org/apache/hedwig/client/netty/NetUtils.java | 2 +
.../hedwig/client/netty/impl/HChannelHandler.java | 4 +-
.../java/org/apache/hedwig/util/TestFileUtils.java | 4 +-
.../hedwig/util/TestHedwigSocketAddress.java | 6 +-
.../java/org/apache/hedwig/util/TestPathUtils.java | 6 +-
hedwig-protocol/pom.xml | 2 +-
hedwig-server/bin/hedwig | 5 +-
hedwig-server/pom.xml | 42 +-
.../java/org/apache/hedwig/admin/HedwigAdmin.java | 5 +-
.../apache/hedwig/admin/console/HedwigConsole.java | 11 +-
.../hedwig/admin/console/JLineHedwigCompletor.java | 15 +-
.../org/apache/hedwig/admin/console/ReadTopic.java | 3 +-
.../hedwig/server/benchmark/BookieBenchmark.java | 11 +-
.../server/benchmark/BookkeeperBenchmark.java | 3 +-
.../apache/hedwig/server/benchmark/FakeBookie.java | 4 +-
.../hedwig/server/common/ServerConfiguration.java | 150 +-
.../server/delivery/FIFODeliveryManager.java | 354 +-
.../apache/hedwig/server/meta/FactoryLayout.java | 5 +-
.../server/meta/MsMetadataManagerFactory.java | 11 +-
.../server/meta/ZkMetadataManagerFactory.java | 19 +-
.../apache/hedwig/server/netty/PubSubServer.java | 22 +-
.../hedwig/server/netty/UmbrellaHandler.java | 6 +-
.../persistence/BookkeeperPersistenceManager.java | 3 +-
.../persistence/LocalDBPersistenceManager.java | 4 +-
.../hedwig/server/persistence/ReadAheadCache.java | 3 +-
.../apache/hedwig/server/proxy/HedwigProxy.java | 11 +-
.../hedwig/server/proxy/ProxySubscribeHandler.java | 7 +-
.../subscriptions/AbstractSubscriptionManager.java | 10 +-
.../hedwig/server/topics/AbstractTopicManager.java | 174 +-
.../org/apache/hedwig/server/topics/HubLoad.java | 9 +-
.../hedwig/server/topics/HubServerManager.java | 16 +
.../hedwig/server/topics/MMTopicManager.java | 12 +-
.../server/topics/TopicBasedLoadShedder.java | 151 +
.../apache/hedwig/server/topics/TopicManager.java | 27 +
.../server/topics/TrivialOwnAllTopicManager.java | 3 +-
.../hedwig/server/topics/ZkHubServerManager.java | 182 +-
.../hedwig/server/topics/ZkTopicManager.java | 19 +-
.../java/org/apache/hedwig/zookeeper/ZkUtils.java | 2 +-
hedwig-server/src/main/resources/NOTICE.bin.txt | 2 +-
.../org/apache/hedwig/client/TestPubSubClient.java | 50 +-
.../apache/hedwig/client/TestSubAfterCloseSub.java | 21 +-
.../hedwig/client/netty/TestMultiplexing.java | 35 +-
.../apache/hedwig/server/HedwigHubTestBase.java | 52 +-
.../apache/hedwig/server/HedwigRegionTestBase.java | 11 +-
.../server/PubSubServerStandAloneTestBase.java | 11 +-
.../apache/hedwig/server/TestBackwardCompat.java | 184 +-
.../server/delivery/TestFIFODeliveryManager.java | 9 +-
.../server/delivery/TestThrottlingDelivery.java | 40 +-
.../hedwig/server/filter/TestMessageFilter.java | 32 +-
.../hedwig/server/handlers/TestBaseHandler.java | 6 +-
.../server/handlers/TestSubUnsubHandler.java | 12 +-
.../hedwig/server/integration/TestHedwigHub.java | 89 +-
.../server/integration/TestHedwigRegion.java | 46 +-
.../hedwig/server/netty/TestPubSubServer.java | 2 +
.../hedwig/server/netty/WriteRecordingChannel.java | 5 +
.../server/persistence/BookKeeperTestBase.java | 10 +-
.../persistence/MessageBoundedPersistenceTest.java | 16 +-
.../TestBookKeeperPersistenceManager.java | 12 +-
.../TestBookKeeperPersistenceManagerBlackBox.java | 13 +-
.../TestBookkeeperPersistenceManagerWhiteBox.java | 14 +-
.../hedwig/server/persistence/TestDeadlock.java | 14 +-
.../TestLocalDBPersistenceManagerBlackBox.java | 17 +-
.../TestPersistenceManagerBlackBox.java | 17 +-
.../persistence/TestReadAheadCacheBlackBox.java | 17 +-
.../persistence/TestReadAheadCacheWhiteBox.java | 5 -
.../subscriptions/TestUpdateSubscriptionState.java | 17 +-
.../hedwig/server/topics/StubTopicManager.java | 2 +-
.../topics/TestConcurrentTopicAcquisition.java | 10 +-
.../hedwig/server/topics/TestMMTopicManager.java | 38 +-
.../server/topics/TestTopicBasedLoadShedder.java | 194 +
.../hedwig/server/topics/TestZkTopicManager.java | 51 +-
hedwig-server/src/test/resources/log4j.properties | 1 -
pom.xml | 34 +-
500 files changed, 59723 insertions(+), 6512 deletions(-)
--
Alioth's /usr/local/bin/git-commit-notice on /srv/git.debian.org/git/pkg-java/bookkeeper.git
More information about the pkg-java-commits
mailing list