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 <[email protected]> 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 _______________________________________________ pkg-java-commits mailing list [email protected] http://lists.alioth.debian.org/cgi-bin/mailman/listinfo/pkg-java-commits
