[bookkeeper] 02/02: Merge tag 'upstream/4.2.4'
Emmanuel Bourg
ebourg-guest at moszumanska.debian.org
Fri Jul 24 16:03:54 UTC 2015
This is an automated email from the git hooks/post-receive script.
ebourg-guest pushed a commit to branch master
in repository bookkeeper.
commit a8ae1f64bbf2623d1654b25b71c779e8e4c6418c
Merge: db92361 b37988c
Author: Emmanuel Bourg <ebourg at apache.org>
Date: Fri Jul 24 17:58:15 2015 +0200
Merge tag 'upstream/4.2.4'
Upstream version 4.2.4
CHANGES.txt | 1020 +++++++++++++++
LICENSE | 202 +++
NOTICE | 6 +
README | 85 ++
bin/find-new-patch-available-jiras | 129 ++
bin/raw-check-patch | 47 +
bin/test-patch | 416 ++++++
bin/test-patch-00-clean | 100 ++
bin/test-patch-05-patch-raw-analysis | 165 +++
bin/test-patch-08-rat | 132 ++
bin/test-patch-09-javadoc | 118 ++
bin/test-patch-10-compile | 144 +++
bin/test-patch-11-findbugs | 156 +++
bin/test-patch-20-tests | 125 ++
bin/test-patch-30-dist | 106 ++
bookkeeper-benchmark/bin/benchmark | 131 ++
bookkeeper-benchmark/conf/log4j.properties | 73 ++
bookkeeper-benchmark/pom.xml | 160 +++
.../apache/bookkeeper/benchmark/BenchBookie.java | 215 ++++
.../benchmark/BenchReadThroughputLatency.java | 272 ++++
.../benchmark/BenchThroughputLatency.java | 459 +++++++
.../apache/bookkeeper/benchmark/MySqlClient.java | 137 ++
.../apache/bookkeeper/benchmark/TestClient.java | 357 ++++++
.../apache/bookkeeper/benchmark/TestBenchmark.java | 163 +++
.../src/test/resources/log4j.properties | 73 ++
bookkeeper-server/bin/bookkeeper | 201 +++
bookkeeper-server/bin/bookkeeper-daemon.sh | 174 +++
bookkeeper-server/conf/bk_server.conf | 224 ++++
bookkeeper-server/conf/bkenv.sh | 47 +
bookkeeper-server/conf/log4j.properties | 77 ++
bookkeeper-server/conf/log4j.shell.properties | 41 +
bookkeeper-server/pom.xml | 316 +++++
.../java/org/apache/bookkeeper/bookie/Bookie.java | 1243 ++++++++++++++++++
.../org/apache/bookkeeper/bookie/BookieBean.java | 51 +
.../apache/bookkeeper/bookie/BookieException.java | 154 +++
.../org/apache/bookkeeper/bookie/BookieMXBean.java | 31 +
.../org/apache/bookkeeper/bookie/BookieShell.java | 1332 ++++++++++++++++++++
.../apache/bookkeeper/bookie/BufferedChannel.java | 180 +++
.../java/org/apache/bookkeeper/bookie/Cookie.java | 260 ++++
.../org/apache/bookkeeper/bookie/EntryLogger.java | 584 +++++++++
.../org/apache/bookkeeper/bookie/ExitCode.java | 40 +
.../org/apache/bookkeeper/bookie/FileInfo.java | 376 ++++++
.../bookkeeper/bookie/FileSystemUpgrade.java | 388 ++++++
.../apache/bookkeeper/bookie/GarbageCollector.java | 51 +
.../bookkeeper/bookie/GarbageCollectorThread.java | 609 +++++++++
.../apache/bookkeeper/bookie/HandleFactory.java | 32 +
.../bookkeeper/bookie/HandleFactoryImpl.java | 66 +
.../bookie/InterleavedLedgerStorage.java | 180 +++
.../java/org/apache/bookkeeper/bookie/Journal.java | 587 +++++++++
.../apache/bookkeeper/bookie/JournalChannel.java | 164 +++
.../org/apache/bookkeeper/bookie/LedgerCache.java | 50 +
.../apache/bookkeeper/bookie/LedgerCacheBean.java | 27 +
.../apache/bookkeeper/bookie/LedgerCacheImpl.java | 938 ++++++++++++++
.../bookkeeper/bookie/LedgerCacheMXBean.java | 60 +
.../apache/bookkeeper/bookie/LedgerDescriptor.java | 62 +
.../bookkeeper/bookie/LedgerDescriptorImpl.java | 87 ++
.../bookie/LedgerDescriptorReadOnlyImpl.java | 52 +
.../bookkeeper/bookie/LedgerDirsManager.java | 270 ++++
.../apache/bookkeeper/bookie/LedgerEntryPage.java | 163 +++
.../apache/bookkeeper/bookie/LedgerStorage.java | 109 ++
.../bookkeeper/bookie/MarkerFileChannel.java | 147 +++
.../bookkeeper/bookie/ReadOnlyEntryLogger.java | 58 +
.../apache/bookkeeper/bookie/ReadOnlyFileInfo.java | 44 +
.../bookie/ScanAndCompareGarbageCollector.java | 108 ++
.../apache/bookkeeper/client/AsyncCallback.java | 151 +++
.../org/apache/bookkeeper/client/BKException.java | 352 ++++++
.../org/apache/bookkeeper/client/BookKeeper.java | 715 +++++++++++
.../apache/bookkeeper/client/BookKeeperAdmin.java | 883 +++++++++++++
.../apache/bookkeeper/client/BookieWatcher.java | 356 ++++++
.../apache/bookkeeper/client/BookiesListener.java | 27 +
.../bookkeeper/client/CRC32DigestManager.java | 55 +
.../apache/bookkeeper/client/DigestManager.java | 191 +++
.../bookkeeper/client/DistributionSchedule.java | 90 ++
.../apache/bookkeeper/client/LedgerChecker.java | 271 ++++
.../apache/bookkeeper/client/LedgerCreateOp.java | 137 ++
.../apache/bookkeeper/client/LedgerDeleteOp.java | 79 ++
.../org/apache/bookkeeper/client/LedgerEntry.java | 82 ++
.../apache/bookkeeper/client/LedgerFragment.java | 147 +++
.../client/LedgerFragmentReplicator.java | 422 +++++++
.../org/apache/bookkeeper/client/LedgerHandle.java | 1123 +++++++++++++++++
.../apache/bookkeeper/client/LedgerMetadata.java | 529 ++++++++
.../org/apache/bookkeeper/client/LedgerOpenOp.java | 189 +++
.../apache/bookkeeper/client/LedgerRecoveryOp.java | 167 +++
.../apache/bookkeeper/client/MacDigestManager.java | 84 ++
.../org/apache/bookkeeper/client/PendingAddOp.java | 197 +++
.../apache/bookkeeper/client/PendingReadOp.java | 374 ++++++
.../bookkeeper/client/ReadLastConfirmedOp.java | 126 ++
.../bookkeeper/client/ReadOnlyLedgerHandle.java | 167 +++
.../client/RoundRobinDistributionSchedule.java | 107 ++
.../org/apache/bookkeeper/client/SyncCounter.java | 85 ++
.../bookkeeper/conf/AbstractConfiguration.java | 236 ++++
.../bookkeeper/conf/ClientConfiguration.java | 394 ++++++
.../bookkeeper/conf/ServerConfiguration.java | 837 ++++++++++++
.../org/apache/bookkeeper/jmx/BKMBeanInfo.java | 27 +
.../org/apache/bookkeeper/jmx/BKMBeanRegistry.java | 89 ++
.../bookkeeper/meta/AbstractZkLedgerManager.java | 483 +++++++
.../apache/bookkeeper/meta/FlatLedgerManager.java | 166 +++
.../bookkeeper/meta/FlatLedgerManagerFactory.java | 92 ++
.../bookkeeper/meta/HierarchicalLedgerManager.java | 477 +++++++
.../meta/HierarchicalLedgerManagerFactory.java | 93 ++
.../org/apache/bookkeeper/meta/LedgerLayout.java | 244 ++++
.../org/apache/bookkeeper/meta/LedgerManager.java | 204 +++
.../bookkeeper/meta/LedgerManagerFactory.java | 250 ++++
.../meta/LedgerUnderreplicationManager.java | 119 ++
.../bookkeeper/meta/MSLedgerManagerFactory.java | 729 +++++++++++
.../meta/ZkLedgerUnderreplicationManager.java | 630 +++++++++
.../java/org/apache/bookkeeper/meta/ZkVersion.java | 69 +
.../bookkeeper/metastore/InMemoryMetaStore.java | 77 ++
.../metastore/InMemoryMetastoreCursor.java | 97 ++
.../metastore/InMemoryMetastoreTable.java | 374 ++++++
.../apache/bookkeeper/metastore/MSException.java | 214 ++++
.../bookkeeper/metastore/MSWatchedEvent.java | 38 +
.../org/apache/bookkeeper/metastore/MetaStore.java | 79 ++
.../bookkeeper/metastore/MetastoreCallback.java | 25 +
.../bookkeeper/metastore/MetastoreCursor.java | 84 ++
.../bookkeeper/metastore/MetastoreException.java | 34 +
.../bookkeeper/metastore/MetastoreFactory.java | 33 +
.../metastore/MetastoreScannableTable.java | 104 ++
.../bookkeeper/metastore/MetastoreTable.java | 193 +++
.../bookkeeper/metastore/MetastoreTableItem.java | 70 +
.../bookkeeper/metastore/MetastoreUtils.java | 140 ++
.../bookkeeper/metastore/MetastoreWatcher.java | 22 +
.../org/apache/bookkeeper/metastore/Value.java | 154 +++
.../main/java/org/apache/bookkeeper/net/DNS.java | 356 ++++++
.../java/org/apache/bookkeeper/proto/BKStats.java | 248 ++++
.../org/apache/bookkeeper/proto/BookieClient.java | 283 +++++
.../apache/bookkeeper/proto/BookieProtocol.java | 176 +++
.../org/apache/bookkeeper/proto/BookieServer.java | 637 ++++++++++
.../apache/bookkeeper/proto/BookieServerBean.java | 86 ++
.../bookkeeper/proto/BookieServerMXBean.java | 53 +
.../proto/BookkeeperInternalCallbacks.java | 148 +++
.../apache/bookkeeper/proto/NIOServerFactory.java | 583 +++++++++
.../bookkeeper/proto/PerChannelBookieClient.java | 823 ++++++++++++
.../org/apache/bookkeeper/proto/ServerStats.java | 101 ++
.../org/apache/bookkeeper/replication/Auditor.java | 565 +++++++++
.../bookkeeper/replication/AuditorElector.java | 360 ++++++
.../bookkeeper/replication/AutoRecoveryMain.java | 280 ++++
.../replication/BookieLedgerIndexer.java | 136 ++
.../replication/ReplicationEnableCb.java | 56 +
.../replication/ReplicationException.java | 78 ++
.../bookkeeper/replication/ReplicationWorker.java | 406 ++++++
.../bookkeeper/streaming/LedgerInputStream.java | 174 +++
.../bookkeeper/streaming/LedgerOutputStream.java | 148 +++
.../apache/bookkeeper/tools/BookKeeperTools.java | 92 ++
.../bookkeeper/util/BookKeeperConstants.java | 45 +
.../org/apache/bookkeeper/util/DiskChecker.java | 168 +++
.../org/apache/bookkeeper/util/EntryFormatter.java | 77 ++
.../java/org/apache/bookkeeper/util/HardLink.java | 665 ++++++++++
.../java/org/apache/bookkeeper/util/IOUtils.java | 88 ++
.../apache/bookkeeper/util/LocalBookKeeper.java | 261 ++++
.../main/java/org/apache/bookkeeper/util/Main.java | 54 +
.../java/org/apache/bookkeeper/util/MathUtils.java | 76 ++
.../bookkeeper/util/OrderedSafeExecutor.java | 140 ++
.../apache/bookkeeper/util/ReflectionUtils.java | 152 +++
.../org/apache/bookkeeper/util/SafeRunnable.java | 39 +
.../org/apache/bookkeeper/util/SnapshotMap.java | 131 ++
.../bookkeeper/util/StringEntryFormatter.java | 47 +
.../org/apache/bookkeeper/util/StringUtils.java | 129 ++
.../main/java/org/apache/bookkeeper/util/Tool.java | 43 +
.../java/org/apache/bookkeeper/util/ZkUtils.java | 257 ++++
.../org/apache/bookkeeper/versioning/Version.java | 62 +
.../apache/bookkeeper/versioning/Versioned.java | 45 +
.../bookkeeper/zookeeper/ZooKeeperWatcherBase.java | 94 ++
bookkeeper-server/src/main/proto/DataFormats.proto | 84 ++
.../src/main/resources/LICENSE.bin.txt | 302 +++++
.../src/main/resources/NOTICE.bin.txt | 35 +
.../src/main/resources/findbugsExclude.xml | 23 +
.../apache/bookkeeper/bookie/BookieAccessor.java | 35 +
.../bookie/BookieInitializationTest.java | 355 ++++++
.../bookkeeper/bookie/BookieJournalTest.java | 594 +++++++++
.../bookkeeper/bookie/BookieShutdownTest.java | 122 ++
.../apache/bookkeeper/bookie/CompactionTest.java | 448 +++++++
.../org/apache/bookkeeper/bookie/CookieTest.java | 367 ++++++
.../apache/bookkeeper/bookie/CreateNewLogTest.java | 103 ++
.../org/apache/bookkeeper/bookie/EntryLogTest.java | 230 ++++
.../bookkeeper/bookie/IndexCorruptionTest.java | 153 +++
.../apache/bookkeeper/bookie/LedgerCacheTest.java | 510 ++++++++
.../bookkeeper/bookie/TestLedgerDirsManager.java | 81 ++
.../org/apache/bookkeeper/bookie/UpgradeTest.java | 270 ++++
.../apache/bookkeeper/client/BookKeeperTest.java | 241 ++++
.../bookkeeper/client/BookKeeperTestClient.java | 71 ++
.../bookkeeper/client/BookieRecoveryTest.java | 991 +++++++++++++++
.../bookkeeper/client/BookieWriteLedgerTest.java | 230 ++++
.../org/apache/bookkeeper/client/ClientUtil.java | 36 +
.../apache/bookkeeper/client/LedgerCloseTest.java | 265 ++++
.../bookkeeper/client/LedgerHandleAdapter.java | 32 +
.../bookkeeper/client/LedgerRecoveryTest.java | 420 ++++++
.../apache/bookkeeper/client/ListLedgersTest.java | 112 ++
.../client/RoundRobinDistributionScheduleTest.java | 133 ++
.../apache/bookkeeper/client/SlowBookieTest.java | 209 +++
.../org/apache/bookkeeper/client/TestFencing.java | 397 ++++++
.../bookkeeper/client/TestLedgerChecker.java | 462 +++++++
.../client/TestLedgerFragmentReplication.java | 340 +++++
.../apache/bookkeeper/client/TestReadTimeout.java | 101 ++
.../bookkeeper/client/TestSpeculativeRead.java | 343 +++++
.../bookkeeper/client/TestWatchEnsembleChange.java | 147 +++
.../org/apache/bookkeeper/meta/GcLedgersTest.java | 272 ++++
.../apache/bookkeeper/meta/LedgerLayoutTest.java | 148 +++
.../bookkeeper/meta/LedgerManagerIteratorTest.java | 43 +
.../bookkeeper/meta/LedgerManagerTestCase.java | 89 ++
.../apache/bookkeeper/meta/TestLedgerManager.java | 325 +++++
.../org/apache/bookkeeper/meta/TestZkVersion.java | 65 +
...etastoreScannableTableAsyncToSyncConverter.java | 59 +
.../MetastoreTableAsyncToSyncConverter.java | 131 ++
.../apache/bookkeeper/metastore/TestMetaStore.java | 648 ++++++++++
.../org/apache/bookkeeper/proto/TestBKStats.java | 43 +
.../apache/bookkeeper/proto/TestDeathwatcher.java | 60 +
.../proto/TestPerChannelBookieClient.java | 285 +++++
.../apache/bookkeeper/proto/TestProtoVersions.java | 113 ++
.../bookkeeper/replication/AuditorBookieTest.java | 288 +++++
.../replication/AuditorLedgerCheckerTest.java | 387 ++++++
.../AuditorPeriodicBookieCheckTest.java | 128 ++
.../replication/AuditorPeriodicCheckTest.java | 321 +++++
.../replication/AuditorRollingRestartTest.java | 73 ++
.../replication/AutoRecoveryMainTest.java | 108 ++
.../replication/BookieAutoRecoveryTest.java | 463 +++++++
.../replication/BookieLedgerIndexTest.java | 230 ++++
.../replication/ReplicationTestUtil.java | 59 +
.../TestAutoRecoveryAlongWithBookieServers.java | 99 ++
.../TestLedgerUnderreplicationManager.java | 764 +++++++++++
.../replication/TestReplicationWorker.java | 599 +++++++++
.../apache/bookkeeper/test/AsyncLedgerOpsTest.java | 258 ++++
.../org/apache/bookkeeper/test/BaseTestCase.java | 49 +
.../bookkeeper/test/BookKeeperClusterTestCase.java | 548 ++++++++
.../apache/bookkeeper/test/BookieClientTest.java | 244 ++++
.../apache/bookkeeper/test/BookieFailureTest.java | 400 ++++++
.../bookkeeper/test/BookieJournalRollingTest.java | 261 ++++
.../bookkeeper/test/BookieReadWriteTest.java | 1038 +++++++++++++++
.../apache/bookkeeper/test/BookieZKExpireTest.java | 109 ++
.../java/org/apache/bookkeeper/test/CloseTest.java | 100 ++
.../bookkeeper/test/ConcurrentLedgerTest.java | 187 +++
.../apache/bookkeeper/test/ConditionalSetTest.java | 118 ++
.../apache/bookkeeper/test/ConfigurationTest.java | 67 +
.../bookkeeper/test/LedgerCreateDeleteTest.java | 99 ++
.../apache/bookkeeper/test/LedgerDeleteTest.java | 153 +++
.../org/apache/bookkeeper/test/LoopbackClient.java | 120 ++
.../MultiLedgerManagerMultiDigestTestCase.java | 64 +
.../test/MultiLedgerManagerTestCase.java | 56 +
.../bookkeeper/test/NIOServerFactoryTest.java | 66 +
.../org/apache/bookkeeper/test/PortManager.java | 55 +
.../apache/bookkeeper/test/ReadOnlyBookieTest.java | 223 ++++
.../apache/bookkeeper/test/TestBackwardCompat.java | 618 +++++++++
.../org/apache/bookkeeper/test/TestCallbacks.java | 75 ++
.../org/apache/bookkeeper/test/ZooKeeperUtil.java | 157 +++
.../apache/bookkeeper/util/TestDiskChecker.java | 96 ++
.../java/org/apache/bookkeeper/util/TestUtils.java | 52 +
.../src/test/resources/log4j.properties | 73 ++
compat-deps/bookkeeper-server-compat-4.0.0/pom.xml | 84 ++
compat-deps/bookkeeper-server-compat-4.1.0/pom.xml | 93 ++
compat-deps/hedwig-server-compat-4.0.0/pom.xml | 97 ++
compat-deps/hedwig-server-compat-4.1.0/pom.xml | 97 ++
compat-deps/pom.xml | 43 +
doc/bookieConfigParams.textile | 71 ++
doc/bookieRecovery.textile | 79 ++
doc/bookkeeperConfig.textile | 167 +++
doc/bookkeeperConfigParams.textile | 39 +
doc/bookkeeperInternals.textile | 84 ++
doc/bookkeeperJMX.textile | 32 +
doc/bookkeeperMetadata.textile | 40 +
doc/bookkeeperOverview.textile | 185 +++
doc/bookkeeperProgrammer.textile | 99 ++
doc/bookkeeperStarted.textile | 102 ++
doc/bookkeeperStream.textile | 124 ++
doc/doc.textile | 21 +
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 | 52 +
doc/metastore.textile | 47 +
formatter.xml | 286 +++++
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 | 138 ++
.../client/benchmark/BenchmarkSubscriber.java | 142 +++
.../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 | 125 ++
.../hedwig/client/netty/HedwigPublisher.java | 151 +++
.../hedwig/client/netty/HedwigSubscriber.java | 421 +++++++
.../org/apache/hedwig/client/netty/NetUtils.java | 219 ++++
.../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 | 284 +++++
.../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/client/AppTest.java | 51 +
.../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 | 204 +++
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 | 258 ++++
.../java/org/apache/hedwig/admin/HedwigAdmin.java | 549 ++++++++
.../hedwig/admin/console/HedwigCommands.java | 437 +++++++
.../apache/hedwig/admin/console/HedwigConsole.java | 1033 +++++++++++++++
.../hedwig/admin/console/JLineHedwigCompletor.java | 101 ++
.../org/apache/hedwig/admin/console/ReadTopic.java | 331 +++++
.../org/apache/hedwig/data/MessageFormatter.java | 123 ++
.../hedwig/server/benchmark/AbstractBenchmark.java | 106 ++
.../hedwig/server/benchmark/BookieBenchmark.java | 106 ++
.../server/benchmark/BookkeeperBenchmark.java | 93 ++
.../apache/hedwig/server/benchmark/FakeBookie.java | 101 ++
.../hedwig/server/common/ByteStringInterner.java | 38 +
.../hedwig/server/common/ServerConfiguration.java | 584 +++++++++
.../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 | 907 +++++++++++++
.../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 | 166 +++
.../hedwig/server/meta/MetadataManagerFactory.java | 213 ++++
.../server/meta/MsMetadataManagerFactory.java | 866 +++++++++++++
.../server/meta/SubscriptionDataManager.java | 159 +++
.../hedwig/server/meta/TopicOwnershipManager.java | 100 ++
.../server/meta/TopicPersistenceManager.java | 96 ++
.../server/meta/ZkMetadataManagerFactory.java | 841 ++++++++++++
.../apache/hedwig/server/netty/PubSubServer.java | 525 ++++++++
.../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 | 1262 +++++++++++++++++++
.../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 | 489 +++++++
.../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 | 862 +++++++++++++
.../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 | 177 +++
.../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 | 83 ++
.../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 | 798 ++++++++++++
.../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 | 204 +++
.../org/apache/hedwig/server/topics/HubInfo.java | 162 +++
.../org/apache/hedwig/server/topics/HubLoad.java | 130 ++
.../hedwig/server/topics/HubServerManager.java | 108 ++
.../hedwig/server/topics/MMTopicManager.java | 353 ++++++
.../apache/hedwig/server/topics/TopicManager.java | 80 ++
.../topics/TopicOwnershipChangeListener.java | 28 +
.../server/topics/TrivialOwnAllTopicManager.java | 57 +
.../hedwig/server/topics/ZkHubServerManager.java | 306 +++++
.../hedwig/server/topics/ZkTopicManager.java | 340 +++++
.../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 0 -> 3925 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 | 688 ++++++++++
.../apache/hedwig/client/TestSubAfterCloseSub.java | 196 +++
.../hedwig/client/netty/TestMultiplexing.java | 430 +++++++
.../apache/hedwig/server/HedwigHubTestBase.java | 172 +++
.../apache/hedwig/server/HedwigRegionTestBase.java | 287 +++++
.../hedwig/server/LoggingExceptionHandler.java | 35 +
.../server/PubSubServerStandAloneTestBase.java | 103 ++
.../apache/hedwig/server/TestBackwardCompat.java | 1200 ++++++++++++++++++
.../hedwig/server/TestPubSubServerStartup.java | 139 ++
.../server/delivery/StubDeliveryManager.java | 90 ++
.../server/delivery/TestFIFODeliveryManager.java | 297 +++++
.../server/delivery/TestThrottlingDelivery.java | 369 ++++++
.../hedwig/server/filter/TestMessageFilter.java | 399 ++++++
.../hedwig/server/handlers/TestBaseHandler.java | 116 ++
.../server/handlers/TestSubUnsubHandler.java | 178 +++
.../hedwig/server/integration/TestHedwigHub.java | 740 +++++++++++
.../server/integration/TestHedwigHubProxy.java | 36 +
.../server/integration/TestHedwigHubRegular.java | 36 +
.../server/integration/TestHedwigHubSSL.java | 36 +
.../server/integration/TestHedwigRegion.java | 300 +++++
.../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 | 263 ++++
.../hedwig/server/netty/TestServerStats.java | 41 +
.../hedwig/server/netty/WriteRecordingChannel.java | 170 +++
.../server/persistence/BookKeeperTestBase.java | 259 ++++
.../persistence/MessageBoundedPersistenceTest.java | 280 ++++
.../server/persistence/StubPersistenceManager.java | 137 ++
.../server/persistence/StubScanCallback.java | 48 +
.../TestBookKeeperPersistenceManager.java | 802 ++++++++++++
.../TestBookKeeperPersistenceManagerBlackBox.java | 86 ++
.../TestBookkeeperPersistenceManagerWhiteBox.java | 359 ++++++
.../hedwig/server/persistence/TestDeadlock.java | 270 ++++
.../TestLocalDBPersistenceManagerBlackBox.java | 53 +
.../TestPersistenceManagerBlackBox.java | 308 +++++
.../persistence/TestReadAheadCacheBlackBox.java | 54 +
.../persistence/TestReadAheadCacheWhiteBox.java | 308 +++++
.../subscriptions/StubSubscriptionManager.java | 55 +
.../subscriptions/TestMMSubscriptionManager.java | 214 ++++
.../subscriptions/TestUpdateSubscriptionState.java | 247 ++++
.../hedwig/server/topics/StubTopicManager.java | 64 +
.../topics/TestConcurrentTopicAcquisition.java | 206 +++
.../apache/hedwig/server/topics/TestHubInfo.java | 62 +
.../apache/hedwig/server/topics/TestHubLoad.java | 60 +
.../hedwig/server/topics/TestMMTopicManager.java | 321 +++++
.../hedwig/server/topics/TestZkTopicManager.java | 329 +++++
.../org/apache/hedwig/zookeeper/TestZkUtils.java | 47 +
.../apache/hedwig/zookeeper/ZooKeeperTestBase.java | 94 ++
hedwig-server/src/test/resources/log4j.properties | 73 ++
pom.xml | 186 +++
src/assemble/bin.xml | 79 ++
src/assemble/src.xml | 63 +
585 files changed, 114024 insertions(+)
--
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