[bookkeeper] 08/12: Merge tag 'upstream/4.4.0'
Emmanuel Bourg
ebourg-guest at moszumanska.debian.org
Mon Jan 16 10:01:12 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 58abc1bcb9a14d42cecd0265c09f45968632ee32
Merge: ab2edef 2261c12
Author: Emmanuel Bourg <ebourg at apache.org>
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
More information about the pkg-java-commits
mailing list