This is an automated email from the git hooks/post-receive script. ebourg-guest pushed a commit to branch master in repository bookkeeper.
commit 58abc1bcb9a14d42cecd0265c09f45968632ee32 Merge: ab2edef 2261c12 Author: Emmanuel Bourg <[email protected]> Date: Mon Jan 16 10:18:39 2017 +0100 Merge tag 'upstream/4.4.0' Upstream version 4.4.0 CHANGES.txt | 179 +- README | 25 +- bin/update-master-docs | 44 + bookkeeper-benchmark/pom.xml | 2 +- .../apache/bookkeeper/benchmark/BenchBookie.java | 5 +- .../benchmark/BenchReadThroughputLatency.java | 68 +- .../apache/bookkeeper/benchmark/TestBenchmark.java | 54 +- bookkeeper-server/conf/bk_server.conf | 17 + bookkeeper-server/conf/log4j.properties | 4 - bookkeeper-server/pom.xml | 13 +- .../auth/AuthProviderFactoryFactory.java | 111 ++ .../apache/bookkeeper/auth/BookieAuthProvider.java | 83 + .../apache/bookkeeper/auth/ClientAuthProvider.java | 89 + .../bookkeeper/bookie/BookKeeperServerStats.java | 8 + .../java/org/apache/bookkeeper/bookie/Bookie.java | 265 ++- .../org/apache/bookkeeper/bookie/BookieShell.java | 287 ++- .../bookie/CompactableLedgerStorage.java | 61 + .../apache/bookkeeper/bookie/EntryLocation.java} | 21 +- .../apache/bookkeeper/bookie/EntryLogMetadata.java | 101 + .../org/apache/bookkeeper/bookie/EntryLogger.java | 258 ++- .../apache/bookkeeper/bookie/EntryMemTable.java | 18 +- .../org/apache/bookkeeper/bookie/FileInfo.java | 1 + .../bookkeeper/bookie/FileSystemUpgrade.java | 47 +- .../bookkeeper/bookie/GarbageCollectorThread.java | 328 ++-- .../bookkeeper/bookie/IndexInMemPageMgr.java | 11 +- .../bookkeeper/bookie/IndexPersistenceMgr.java | 9 +- .../bookie/InterleavedLedgerStorage.java | 123 +- .../java/org/apache/bookkeeper/bookie/Journal.java | 50 +- .../bookkeeper/bookie/LedgerDirsManager.java | 64 +- .../apache/bookkeeper/bookie/LedgerStorage.java | 26 +- .../bookkeeper/bookie/LedgerStorageFactory.java} | 20 +- .../bookie/LocalBookieEnsemblePlacementPolicy.java | 88 + .../apache/bookkeeper/bookie/ReadOnlyBookie.java | 66 + .../bookkeeper/bookie/ReadOnlyEntryLogger.java | 2 +- .../bookie/ScanAndCompareGarbageCollector.java | 175 +- .../bookkeeper/bookie/SortedLedgerStorage.java | 21 +- .../org/apache/bookkeeper/client/BKException.java | 32 + .../org/apache/bookkeeper/client/BookKeeper.java | 270 ++- .../apache/bookkeeper/client/BookKeeperAdmin.java | 176 +- .../apache/bookkeeper/client/BookieWatcher.java | 103 +- .../apache/bookkeeper/client/LedgerCreateOp.java | 20 +- .../apache/bookkeeper/client/LedgerDeleteOp.java | 11 +- .../client/LedgerFragmentReplicator.java | 24 +- .../org/apache/bookkeeper/client/LedgerHandle.java | 186 +- .../apache/bookkeeper/client/LedgerHandleAdv.java | 214 +++ .../apache/bookkeeper/client/LedgerMetadata.java | 26 +- .../org/apache/bookkeeper/client/LedgerOpenOp.java | 10 +- .../org/apache/bookkeeper/client/PendingAddOp.java | 81 +- .../apache/bookkeeper/client/PendingReadOp.java | 20 +- .../bookkeeper/client/ReadOnlyLedgerHandle.java | 5 + .../bookkeeper/conf/ClientConfiguration.java | 212 ++- .../bookkeeper/conf/ServerConfiguration.java | 312 ++- .../bookkeeper/meta/AbstractZkLedgerManager.java | 24 +- .../apache/bookkeeper/meta/FlatLedgerManager.java | 5 + .../bookkeeper/meta/FlatLedgerManagerFactory.java | 16 +- .../meta/HierarchicalLedgerManagerFactory.java | 16 +- .../bookkeeper/meta/MSLedgerManagerFactory.java | 3 +- .../bookkeeper/meta/ZkLedgerIdGenerator.java | 4 +- .../meta/ZkLedgerUnderreplicationManager.java | 119 +- .../apache/bookkeeper/net/BookieSocketAddress.java | 10 +- .../org/apache/bookkeeper/proto/AuthHandler.java | 363 ++++ .../org/apache/bookkeeper/proto/BookieClient.java | 92 +- .../apache/bookkeeper/proto/BookieNettyServer.java | 54 +- .../bookkeeper/proto/BookieProtoEncoding.java | 125 +- .../apache/bookkeeper/proto/BookieProtocol.java | 36 + .../bookkeeper/proto/BookieRequestProcessor.java | 1 + .../org/apache/bookkeeper/proto/BookieServer.java | 12 +- .../bookkeeper/proto/BookkeeperProtocol.java | 787 +++++++- .../proto/DefaultPerChannelBookieClientPool.java | 12 +- ...lientFactory.java => LocalBookiesRegistry.java} | 29 +- .../bookkeeper/proto/PacketProcessorBase.java | 6 +- .../bookkeeper/proto/PacketProcessorBaseV3.java | 10 +- .../bookkeeper/proto/PerChannelBookieClient.java | 213 ++- .../proto/PerChannelBookieClientFactory.java | 2 +- .../proto/PerChannelBookieClientPool.java | 5 + .../bookkeeper/proto/ReadEntryProcessor.java | 11 +- .../bookkeeper/proto/ReadEntryProcessorV3.java | 6 +- .../bookkeeper/proto/WriteEntryProcessor.java | 16 +- .../bookkeeper/proto/WriteEntryProcessorV3.java | 7 +- .../org/apache/bookkeeper/replication/Auditor.java | 24 +- .../bookkeeper/replication/AutoRecoveryMain.java | 34 +- .../bookkeeper/replication/ReplicationWorker.java | 48 +- .../bookkeeper/util/BookKeeperConstants.java | 1 + .../apache/bookkeeper/util/DirectMemoryUtils.java | 57 + .../org/apache/bookkeeper/util/DiskChecker.java | 8 + .../apache/bookkeeper/util/LocalBookKeeper.java | 62 +- .../java/org/apache/bookkeeper/util/MathUtils.java | 24 + .../bookkeeper/util/OrderedSafeExecutor.java | 221 ++- .../java/org/apache/bookkeeper/util/ZkUtils.java | 27 +- .../zookeeper/ExponentialBackoffRetryPolicy.java | 2 +- .../bookkeeper/zookeeper/ZooKeeperClient.java | 493 +++-- .../bookkeeper/zookeeper/ZooKeeperWatcherBase.java | 72 +- .../org/apache/bookkeeper/zookeeper/ZooWorker.java | 50 +- .../src/main/proto/BookkeeperProtocol.proto | 14 +- bookkeeper-server/src/main/proto/DataFormats.proto | 2 + .../java/org/apache/bookkeeper/auth/TestAuth.java | 654 +++++++ .../bookie/BookieInitializationTest.java | 42 +- .../apache/bookkeeper/bookie/CompactionTest.java | 161 +- .../org/apache/bookkeeper/bookie/CookieTest.java | 2 +- .../apache/bookkeeper/bookie/CreateNewLogTest.java | 2 +- .../org/apache/bookkeeper/bookie/EntryLogTest.java | 100 +- .../apache/bookkeeper/bookie/LedgerCacheTest.java | 2 +- .../bookie/TestGcOverreplicatedLedger.java | 240 +++ .../bookkeeper/bookie/TestLedgerDirsManager.java | 115 +- .../apache/bookkeeper/bookie/TestSyncThread.java | 18 + .../bookkeeper/bookie/UpdateCookieCmdTest.java | 2 +- .../client/BookKeeperClientZKSessionExpiry.java | 79 + .../apache/bookkeeper/client/BookKeeperTest.java | 73 +- .../bookkeeper/client/BookieWriteLedgerTest.java | 365 +++- .../apache/bookkeeper/client/LedgerCloseTest.java | 3 +- .../apache/bookkeeper/client/ListLedgersTest.java | 25 + .../bookkeeper/client/LocalBookKeeperTest.java | 67 + .../client/TestAddEntryQuorumTimeout.java | 144 ++ .../bookkeeper/client/TestBookieHealthCheck.java | 149 ++ .../bookkeeper/client/TestBookieWatcher.java | 140 ++ .../bookkeeper/client/UpdateLedgerCmdTest.java | 2 +- .../bookkeeper/conf/TestBKConfiguration.java | 1 + .../org/apache/bookkeeper/meta/GcLedgersTest.java | 30 +- .../bookkeeper/meta/LedgerManagerTestCase.java | 118 +- .../apache/bookkeeper/meta/TestLedgerManager.java | 17 +- .../bookkeeper/proto/TestBackwardCompatCMS42.java | 239 +++ .../apache/bookkeeper/proto/TestDataFormats.java | 126 ++ .../proto/TestPerChannelBookieClient.java | 46 +- .../bookkeeper/replication/AuditorBookieTest.java | 12 +- .../replication/AuditorLedgerCheckerTest.java | 44 +- .../AuditorPeriodicBookieCheckTest.java | 12 +- .../replication/AuditorPeriodicCheckTest.java | 10 +- .../TestLedgerUnderreplicationManager.java | 17 +- .../replication/TestReplicationWorker.java | 66 +- .../bookkeeper/test/BookKeeperClusterTestCase.java | 70 +- .../apache/bookkeeper/test/BookieClientTest.java | 5 +- .../apache/bookkeeper/test/BookieZKExpireTest.java | 15 +- .../bookkeeper/test/ForceReadOnlyBookieTest.java | 96 + .../apache/bookkeeper/test/LedgerDeleteTest.java | 4 +- .../org/apache/bookkeeper/test/LoopbackClient.java | 5 +- .../apache/bookkeeper/test/ReadOnlyBookieTest.java | 32 +- .../apache/bookkeeper/test/TestBackwardCompat.java | 1 + .../org/apache/bookkeeper/test/ZooKeeperUtil.java | 15 +- .../bookkeeper/zookeeper/TestZooKeeperClient.java | 11 +- .../src/test/proto/TestDataFormats.proto | 23 +- .../codahale-metrics-provider/pom.xml | 8 +- .../bookkeeper/stats/CodahaleOpStatsLogger.java | 21 +- .../bookkeeper/stats/CodahaleOpStatsTest.java | 31 + bookkeeper-stats-providers/pom.xml | 4 +- .../twitter-ostrich-provider/pom.xml | 2 +- .../stats/twitter/ostrich/OpStatsLoggerImpl.java | 22 +- .../stats/twitter/ostrich/OstrichProvider.java | 6 +- .../twitter-science-provider/pom.xml | 2 +- .../stats/twitter/science/OpStatsLoggerImpl.java | 16 +- bookkeeper-stats/pom.xml | 2 +- .../apache/bookkeeper/stats/NullStatsLogger.java | 16 +- .../org/apache/bookkeeper/stats/OpStatsLogger.java | 27 +- compat-deps/bookkeeper-server-compat-4.0.0/pom.xml | 4 +- compat-deps/bookkeeper-server-compat-4.1.0/pom.xml | 4 +- compat-deps/bookkeeper-server-compat-4.2.0/pom.xml | 2 +- compat-deps/hedwig-server-compat-4.0.0/pom.xml | 97 - compat-deps/hedwig-server-compat-4.1.0/pom.xml | 97 - compat-deps/hedwig-server-compat-4.2.0/pom.xml | 97 - compat-deps/pom.xml | 7 +- dev/bk-merge-pr.py | 506 +++++ doc/bookkeeperConfig.textile | 2 +- doc/bookkeeperConfigParams.textile | 2 +- doc/bookkeeperLedgers2Logs.textile | 56 + doc/bookkeeperOverview.textile | 4 +- doc/bookkeeperProtocol.textile | 115 ++ doc/bookkeeperStarted.textile | 6 +- doc/bookkeeperTutorial.textile | 552 ++++++ doc/hedwigBuild.textile | 38 - doc/hedwigConsole.textile | 187 -- doc/hedwigDesign.textile | 72 - doc/hedwigJMX.textile | 32 - doc/hedwigMessageFilter.textile | 76 - doc/hedwigMetadata.textile | 123 -- doc/hedwigParams.textile | 92 - doc/hedwigUser.textile | 63 - doc/index.textile | 50 +- doc/metastore.textile | 6 +- formatter.xml | 2 +- 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 | 61 - .../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 | 33 - .../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 | 25 - .../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 | 39 - .../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 - .../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 | 29 - .../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/conf/hw_client.conf | 22 - hedwig-client/pom.xml | 142 -- hedwig-client/src/main/cpp/Makefile.am | 44 - hedwig-client/src/main/cpp/README | 38 - hedwig-client/src/main/cpp/aminclude.am | 186 -- hedwig-client/src/main/cpp/c-doc.Doxyfile | 1267 ------------ hedwig-client/src/main/cpp/configure.ac | 49 - hedwig-client/src/main/cpp/hedwig-0.1.pc.in | 30 - hedwig-client/src/main/cpp/inc/hedwig/callback.h | 84 - hedwig-client/src/main/cpp/inc/hedwig/client.h | 98 - hedwig-client/src/main/cpp/inc/hedwig/exceptions.h | 57 - hedwig-client/src/main/cpp/inc/hedwig/publish.h | 72 - hedwig-client/src/main/cpp/inc/hedwig/subscribe.h | 71 - hedwig-client/src/main/cpp/lib/Makefile.am | 32 - hedwig-client/src/main/cpp/lib/channel.cpp | 801 -------- hedwig-client/src/main/cpp/lib/channel.h | 438 ----- hedwig-client/src/main/cpp/lib/client.cpp | 66 - hedwig-client/src/main/cpp/lib/clientimpl.cpp | 738 ------- hedwig-client/src/main/cpp/lib/clientimpl.h | 493 ----- hedwig-client/src/main/cpp/lib/data.cpp | 277 --- hedwig-client/src/main/cpp/lib/data.h | 131 -- hedwig-client/src/main/cpp/lib/eventdispatcher.cpp | 131 -- hedwig-client/src/main/cpp/lib/eventdispatcher.h | 87 - hedwig-client/src/main/cpp/lib/exceptions.cpp | 31 - .../src/main/cpp/lib/filterablemessagehandler.cpp | 45 - .../src/main/cpp/lib/filterablemessagehandler.h | 49 - .../src/main/cpp/lib/multiplexsubscriberimpl.cpp | 566 ------ .../src/main/cpp/lib/multiplexsubscriberimpl.h | 193 -- hedwig-client/src/main/cpp/lib/publisherimpl.cpp | 134 -- hedwig-client/src/main/cpp/lib/publisherimpl.h | 66 - .../src/main/cpp/lib/simplesubscriberimpl.cpp | 495 ----- .../src/main/cpp/lib/simplesubscriberimpl.h | 196 -- hedwig-client/src/main/cpp/lib/subscriberimpl.cpp | 687 ------- hedwig-client/src/main/cpp/lib/subscriberimpl.h | 338 ---- hedwig-client/src/main/cpp/lib/util.cpp | 183 -- hedwig-client/src/main/cpp/lib/util.h | 128 -- hedwig-client/src/main/cpp/m4/ax_boost_asio.m4 | 111 -- hedwig-client/src/main/cpp/m4/ax_boost_base.m4 | 252 --- hedwig-client/src/main/cpp/m4/ax_boost_thread.m4 | 149 -- hedwig-client/src/main/cpp/m4/ax_doxygen.m4 | 533 ------ hedwig-client/src/main/cpp/m4/gtest.m4 | 74 - hedwig-client/src/main/cpp/scripts/log4cxx.conf | 44 - .../src/main/cpp/scripts/network-delays.sh | 68 - .../src/main/cpp/scripts/server-control.sh | 170 -- hedwig-client/src/main/cpp/scripts/tester.sh | 175 -- hedwig-client/src/main/cpp/test/Makefile.am | 47 - hedwig-client/src/main/cpp/test/main.cpp | 88 - .../src/main/cpp/test/messageboundtest.cpp | 216 --- .../src/main/cpp/test/messagefiltertest.cpp | 248 --- hedwig-client/src/main/cpp/test/multiplextest.cpp | 418 ---- hedwig-client/src/main/cpp/test/publishtest.cpp | 318 ---- hedwig-client/src/main/cpp/test/pubsubtest.cpp | 735 ------- hedwig-client/src/main/cpp/test/subscribetest.cpp | 253 --- hedwig-client/src/main/cpp/test/test.sh | 21 - .../src/main/cpp/test/throttledeliverytest.cpp | 159 -- hedwig-client/src/main/cpp/test/util.h | 201 -- hedwig-client/src/main/cpp/test/utiltest.cpp | 74 - .../org/apache/hedwig/client/HedwigClient.java | 72 - .../java/org/apache/hedwig/client/api/Client.java | 42 - .../apache/hedwig/client/api/MessageHandler.java | 48 - .../org/apache/hedwig/client/api/Publisher.java | 89 - .../org/apache/hedwig/client/api/Subscriber.java | 380 ---- .../client/benchmark/BenchmarkPublisher.java | 141 -- .../client/benchmark/BenchmarkSubscriber.java | 148 -- .../hedwig/client/benchmark/BenchmarkUtils.java | 191 -- .../hedwig/client/benchmark/BenchmarkWorker.java | 46 - .../hedwig/client/benchmark/HedwigBenchmark.java | 165 -- .../hedwig/client/conf/ClientConfiguration.java | 171 -- .../hedwig/client/data/MessageConsumeData.java | 56 - .../org/apache/hedwig/client/data/PubSubData.java | 179 -- .../apache/hedwig/client/data/TopicSubscriber.java | 74 - .../exceptions/AlreadyStartDeliveryException.java | 36 - .../exceptions/InvalidSubscriberIdException.java | 37 - .../exceptions/NoResponseHandlerException.java | 34 - .../client/exceptions/ResubscribeException.java | 34 - .../exceptions/ServerRedirectLoopException.java | 38 - .../TooManyServerRedirectsException.java | 39 - .../client/handlers/AbstractResponseHandler.java | 156 -- .../handlers/CloseSubscriptionResponseHandler.java | 84 - .../client/handlers/MessageConsumeCallback.java | 117 -- .../hedwig/client/handlers/PubSubCallback.java | 94 - .../client/handlers/PublishResponseHandler.java | 71 - .../client/handlers/SubscribeResponseHandler.java | 183 -- .../handlers/UnsubscribeResponseHandler.java | 85 - .../hedwig/client/netty/CleanupChannelMap.java | 183 -- .../client/netty/FilterableMessageHandler.java | 70 - .../org/apache/hedwig/client/netty/HChannel.java | 54 - .../hedwig/client/netty/HChannelManager.java | 160 -- .../hedwig/client/netty/HedwigClientImpl.java | 128 -- .../hedwig/client/netty/HedwigPublisher.java | 151 -- .../hedwig/client/netty/HedwigSubscriber.java | 422 ---- .../org/apache/hedwig/client/netty/NetUtils.java | 221 --- .../client/netty/SubscriptionEventEmitter.java | 50 - .../hedwig/client/netty/VoidCallbackAdapter.java | 42 - .../client/netty/impl/AbstractHChannelManager.java | 624 ------ .../impl/AbstractSubscribeResponseHandler.java | 377 ---- .../hedwig/client/netty/impl/ActiveSubscriber.java | 382 ---- .../netty/impl/ClientChannelPipelineFactory.java | 72 - .../client/netty/impl/DefaultServerChannel.java | 92 - .../hedwig/client/netty/impl/HChannelHandler.java | 282 --- .../hedwig/client/netty/impl/HChannelImpl.java | 371 ---- .../NonSubscriptionChannelPipelineFactory.java | 47 - .../client/netty/impl/ResubscribeCallback.java | 108 -- .../hedwig/client/netty/impl/WriteCallback.java | 111 -- .../impl/multiplex/MultiplexHChannelManager.java | 319 ---- .../MultiplexSubscribeResponseHandler.java | 129 -- ...ultiplexSubscriptionChannelPipelineFactory.java | 49 - .../netty/impl/simple/SimpleHChannelManager.java | 358 ---- .../simple/SimpleSubscribeResponseHandler.java | 277 --- .../SimpleSubscriptionChannelPipelineFactory.java | 49 - .../apache/hedwig/client/netty/package-info.java | 89 - .../hedwig/client/ssl/SslClientContextFactory.java | 41 - .../hedwig/client/ssl/SslContextFactory.java | 66 - .../apache/hedwig/conf/AbstractConfiguration.java | 63 - .../apache/hedwig/filter/ClientMessageFilter.java | 24 - .../apache/hedwig/filter/MessageFilterBase.java | 50 - .../org/apache/hedwig/filter/PipelineFilter.java | 72 - .../apache/hedwig/filter/ServerMessageFilter.java | 47 - .../main/java/org/apache/hedwig/util/Callback.java | 47 - .../java/org/apache/hedwig/util/CallbackUtils.java | 183 -- .../org/apache/hedwig/util/ConcurrencyUtils.java | 49 - .../main/java/org/apache/hedwig/util/Either.java | 50 - .../java/org/apache/hedwig/util/FileUtils.java | 98 - .../apache/hedwig/util/HedwigSocketAddress.java | 143 -- .../main/java/org/apache/hedwig/util/Option.java | 43 - .../src/main/java/org/apache/hedwig/util/Pair.java | 42 - .../java/org/apache/hedwig/util/PathUtils.java | 56 - .../apache/hedwig/util/SubscriptionListener.java | 44 - .../main/java/org/apache/hedwig/util/VarArgs.java | 26 - .../java/org/apache/hedwig/util/TestFileUtils.java | 41 - .../hedwig/util/TestHedwigSocketAddress.java | 104 - .../java/org/apache/hedwig/util/TestPathUtils.java | 54 - hedwig-protocol/pom.xml | 116 -- .../apache/hedwig/exceptions/PubSubException.java | 254 --- .../apache/hedwig/protoextensions/MapUtils.java | 74 - .../hedwig/protoextensions/MessageIdUtils.java | 153 -- .../protoextensions/PubSubResponseUtils.java | 68 - .../protoextensions/SubscriptionStateUtils.java | 100 - .../src/main/protobuf/PubSubProtocol.proto | 313 --- .../src/main/resources/findbugsExclude.xml | 23 - hedwig-server/bin/hedwig | 205 -- hedwig-server/bin/hedwig-daemon.sh | 163 -- hedwig-server/conf/hw_region_client.conf | 42 - hedwig-server/conf/hw_server.conf | 168 -- hedwig-server/conf/hwenv.sh | 56 - hedwig-server/conf/log4j.properties | 78 - hedwig-server/pom.xml | 294 --- .../java/org/apache/hedwig/admin/HedwigAdmin.java | 550 ------ .../hedwig/admin/console/HedwigCommands.java | 437 ----- .../apache/hedwig/admin/console/HedwigConsole.java | 1038 ---------- .../hedwig/admin/console/JLineHedwigCompletor.java | 104 - .../org/apache/hedwig/admin/console/ReadTopic.java | 332 ---- .../org/apache/hedwig/data/MessageFormatter.java | 123 -- .../hedwig/server/benchmark/AbstractBenchmark.java | 106 -- .../hedwig/server/benchmark/BookieBenchmark.java | 105 - .../server/benchmark/BookkeeperBenchmark.java | 94 - .../apache/hedwig/server/benchmark/FakeBookie.java | 101 - .../hedwig/server/common/ByteStringInterner.java | 38 - .../hedwig/server/common/ServerConfiguration.java | 666 ------- .../common/TerminateJVMExceptionHandler.java | 32 - .../apache/hedwig/server/common/TopicOpQueuer.java | 111 -- .../hedwig/server/common/UnexpectedError.java | 35 - .../hedwig/server/delivery/ChannelEndPoint.java | 90 - .../hedwig/server/delivery/DeliveryCallback.java | 27 - .../hedwig/server/delivery/DeliveryEndPoint.java | 28 - .../hedwig/server/delivery/DeliveryManager.java | 92 - .../server/delivery/FIFODeliveryManager.java | 979 ---------- .../apache/hedwig/server/handlers/BaseHandler.java | 67 - .../server/handlers/ChannelDisconnectListener.java | 29 - .../server/handlers/CloseSubscriptionHandler.java | 105 - .../hedwig/server/handlers/ConsumeHandler.java | 72 - .../org/apache/hedwig/server/handlers/Handler.java | 37 - .../hedwig/server/handlers/NettyHandlerBean.java | 47 - .../hedwig/server/handlers/NettyHandlerMXBean.java | 31 - .../hedwig/server/handlers/PublishHandler.java | 90 - .../hedwig/server/handlers/SubscribeHandler.java | 223 --- .../handlers/SubscriptionChannelManager.java | 214 --- .../hedwig/server/handlers/UnsubscribeHandler.java | 107 -- .../apache/hedwig/server/jmx/HedwigJMXService.java | 37 - .../apache/hedwig/server/jmx/HedwigMBeanInfo.java | 27 - .../hedwig/server/jmx/HedwigMBeanRegistry.java | 48 - .../apache/hedwig/server/meta/FactoryLayout.java | 167 -- .../hedwig/server/meta/MetadataManagerFactory.java | 213 --- .../server/meta/MsMetadataManagerFactory.java | 867 --------- .../server/meta/SubscriptionDataManager.java | 159 -- .../hedwig/server/meta/TopicOwnershipManager.java | 100 - .../server/meta/TopicPersistenceManager.java | 96 - .../server/meta/ZkMetadataManagerFactory.java | 842 -------- .../apache/hedwig/server/netty/PubSubServer.java | 535 ------ .../hedwig/server/netty/PubSubServerBean.java | 83 - .../hedwig/server/netty/PubSubServerMXBean.java | 63 - .../server/netty/PubSubServerPipelineFactory.java | 76 - .../apache/hedwig/server/netty/ServerStats.java | 202 -- .../hedwig/server/netty/UmbrellaHandler.java | 155 -- .../persistence/BookkeeperPersistenceManager.java | 1263 ------------ .../apache/hedwig/server/persistence/CacheKey.java | 74 - .../hedwig/server/persistence/CacheValue.java | 101 - .../server/persistence/CancelScanRequest.java | 27 - .../apache/hedwig/server/persistence/Factory.java | 22 - .../persistence/LocalDBPersistenceManager.java | 491 ----- .../hedwig/server/persistence/MapMethods.java | 62 - .../hedwig/server/persistence/PersistRequest.java | 59 - .../server/persistence/PersistenceManager.java | 99 - .../PersistenceManagerWithRangeScan.java | 27 - .../server/persistence/RangeScanRequest.java | 77 - .../hedwig/server/persistence/ReadAheadCache.java | 863 --------- .../server/persistence/ReadAheadCacheBean.java | 64 - .../server/persistence/ReadAheadCacheMXBean.java | 45 - .../hedwig/server/persistence/ScanCallback.java | 63 - .../persistence/ScanCallbackWithContext.java | 54 - .../hedwig/server/persistence/ScanRequest.java | 64 - .../apache/hedwig/server/proxy/ChannelTracker.java | 132 -- .../apache/hedwig/server/proxy/HedwigProxy.java | 182 -- .../proxy/ProxyCloseSubscriptionHandler.java | 70 - .../hedwig/server/proxy/ProxyConfiguration.java | 36 - .../hedwig/server/proxy/ProxyConsumeHandler.java | 58 - .../hedwig/server/proxy/ProxyPublishHander.java | 62 - .../server/proxy/ProxyStartDeliveryHandler.java | 132 -- .../server/proxy/ProxyStopDeliveryHandler.java | 74 - .../hedwig/server/proxy/ProxySubscribeHandler.java | 86 - .../server/proxy/ProxyUnsubscribeHandler.java | 74 - .../hedwig/server/regions/HedwigHubClient.java | 48 - .../server/regions/HedwigHubClientFactory.java | 74 - .../hedwig/server/regions/HedwigHubSubscriber.java | 86 - .../hedwig/server/regions/RegionManager.java | 355 ---- .../hedwig/server/ssl/SslServerContextFactory.java | 53 - .../subscriptions/AbstractSubscriptionManager.java | 804 -------- .../subscriptions/AllToAllTopologyFilter.java | 75 - .../subscriptions/InMemorySubscriptionManager.java | 125 -- .../subscriptions/InMemorySubscriptionState.java | 200 -- .../subscriptions/MMSubscriptionManager.java | 134 -- .../subscriptions/SubscriptionEventListener.java | 57 - .../server/subscriptions/SubscriptionManager.java | 123 -- .../hedwig/server/topics/AbstractTopicManager.java | 314 --- .../org/apache/hedwig/server/topics/HubInfo.java | 162 -- .../org/apache/hedwig/server/topics/HubLoad.java | 137 -- .../hedwig/server/topics/HubServerManager.java | 124 -- .../hedwig/server/topics/MMTopicManager.java | 359 ---- .../server/topics/TopicBasedLoadShedder.java | 151 -- .../apache/hedwig/server/topics/TopicManager.java | 107 -- .../topics/TopicOwnershipChangeListener.java | 28 - .../server/topics/TrivialOwnAllTopicManager.java | 58 - .../hedwig/server/topics/ZkHubServerManager.java | 470 ----- .../hedwig/server/topics/ZkTopicManager.java | 347 ---- .../hedwig/zookeeper/SafeAsynBKCallback.java | 104 - .../apache/hedwig/zookeeper/SafeAsyncCallback.java | 35 - .../hedwig/zookeeper/SafeAsyncZKCallback.java | 98 - .../java/org/apache/hedwig/zookeeper/ZkUtils.java | 117 -- hedwig-server/src/main/resources/LICENSE.bin.txt | 302 --- hedwig-server/src/main/resources/NOTICE.bin.txt | 40 - .../src/main/resources/findbugsExclude.xml | 25 - hedwig-server/src/main/resources/p12.pass | 1 - hedwig-server/src/main/resources/server.p12 | Bin 3925 -> 0 bytes .../test/java/org/apache/hedwig/HelperMethods.java | 58 - .../test/java/org/apache/hedwig/StubCallback.java | 51 - .../java/org/apache/hedwig/StubScanCallback.java | 57 - .../org/apache/hedwig/client/TestPubSubClient.java | 708 ------- .../apache/hedwig/client/TestSubAfterCloseSub.java | 209 -- .../hedwig/client/netty/TestMultiplexing.java | 439 ----- .../apache/hedwig/server/HedwigHubTestBase.java | 192 -- .../apache/hedwig/server/HedwigRegionTestBase.java | 282 --- .../hedwig/server/LoggingExceptionHandler.java | 35 - .../server/PubSubServerStandAloneTestBase.java | 98 - .../apache/hedwig/server/TestBackwardCompat.java | 1320 ------------- .../hedwig/server/TestPubSubServerStartup.java | 139 -- .../server/delivery/StubDeliveryManager.java | 90 - .../server/delivery/TestFIFODeliveryManager.java | 298 --- .../server/delivery/TestThrottlingDelivery.java | 375 ---- .../hedwig/server/filter/TestMessageFilter.java | 415 ---- .../hedwig/server/handlers/TestBaseHandler.java | 116 -- .../server/handlers/TestSubUnsubHandler.java | 178 -- .../hedwig/server/integration/TestHedwigHub.java | 777 -------- .../server/integration/TestHedwigHubProxy.java | 36 - .../server/integration/TestHedwigHubRegular.java | 36 - .../server/integration/TestHedwigHubSSL.java | 36 - .../server/integration/TestHedwigRegion.java | 304 --- .../meta/MetadataManagerFactoryTestCase.java | 79 - .../hedwig/server/meta/TestFactoryLayout.java | 84 - .../hedwig/server/meta/TestMetadataManager.java | 365 ---- .../server/meta/TestMetadataManagerFactory.java | 306 --- .../hedwig/server/netty/TestPubSubServer.java | 265 --- .../hedwig/server/netty/TestServerStats.java | 41 - .../hedwig/server/netty/WriteRecordingChannel.java | 175 -- .../server/persistence/BookKeeperTestBase.java | 267 --- .../persistence/MessageBoundedPersistenceTest.java | 288 --- .../server/persistence/StubPersistenceManager.java | 137 -- .../server/persistence/StubScanCallback.java | 48 - .../TestBookKeeperPersistenceManager.java | 798 -------- .../TestBookKeeperPersistenceManagerBlackBox.java | 83 - .../TestBookkeeperPersistenceManagerWhiteBox.java | 355 ---- .../hedwig/server/persistence/TestDeadlock.java | 276 --- .../TestLocalDBPersistenceManagerBlackBox.java | 56 - .../TestPersistenceManagerBlackBox.java | 305 --- .../persistence/TestReadAheadCacheBlackBox.java | 57 - .../persistence/TestReadAheadCacheWhiteBox.java | 303 --- .../subscriptions/StubSubscriptionManager.java | 55 - .../subscriptions/TestMMSubscriptionManager.java | 214 --- .../subscriptions/TestUpdateSubscriptionState.java | 252 --- .../hedwig/server/topics/StubTopicManager.java | 64 - .../topics/TestConcurrentTopicAcquisition.java | 210 -- .../apache/hedwig/server/topics/TestHubInfo.java | 62 - .../apache/hedwig/server/topics/TestHubLoad.java | 60 - .../hedwig/server/topics/TestMMTopicManager.java | 357 ---- .../server/topics/TestTopicBasedLoadShedder.java | 194 -- .../hedwig/server/topics/TestZkTopicManager.java | 376 ---- .../org/apache/hedwig/zookeeper/TestZkUtils.java | 47 - .../apache/hedwig/zookeeper/ZooKeeperTestBase.java | 94 - hedwig-server/src/test/resources/log4j.properties | 72 - patch-review.py | 228 +++ pom.xml | 17 +- 645 files changed, 11029 insertions(+), 89284 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
