[bookkeeper] branch master updated (27b5a08 -> 3c6f141)
Emmanuel Bourg
ebourg-guest at moszumanska.debian.org
Mon Jan 16 10:01:10 UTC 2017
This is an automated email from the git hooks/post-receive script.
ebourg-guest pushed a change to branch master
in repository bookkeeper.
from 27b5a08 Build with the DH sequencer instead of CDBS
adds eadd2b5 New upstream version 4.3.0
new c533116 Merge tag 'upstream/4.3.0'
new 280633a Refreshed the patch
new d8f8648 New dependency on libjna-java
new 4a92483 Build the new bookkeeper-stats module
new c07530f Updated the ignore rules
new f8e1fef Patched around a pom parsing bug in maven-repo-helper
adds 6e46ad0 New upstream version 4.3.2
new ab2edef Merge tag 'upstream/4.3.2'
adds 2261c12 New upstream version 4.4.0
new 58abc1b Merge tag 'upstream/4.4.0'
new fc2f76b Removed references to hedwig
new 14c714e Refreshed the patches
new 7cbc491 Fixed the compatibility with protoc >= 2.6
new 3c6f141 Upload to unstable
The 12 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "adds" were already present in the repository and have only
been added to this reference.
Summary of changes:
CHANGES.txt | 452 +-
NOTICE | 2 +-
README | 30 +-
bin/test-patch-10-compile | 4 +-
bin/update-master-docs | 44 +
bookkeeper-benchmark/pom.xml | 12 +-
.../apache/bookkeeper/benchmark/BenchBookie.java | 34 +-
.../benchmark/BenchReadThroughputLatency.java | 74 +-
.../benchmark/BenchThroughputLatency.java | 12 +-
.../apache/bookkeeper/benchmark/MySqlClient.java | 11 +-
.../apache/bookkeeper/benchmark/TestClient.java | 3 +-
.../apache/bookkeeper/benchmark/TestBenchmark.java | 64 +-
.../src/test/resources/log4j.properties | 1 -
bookkeeper-server/bin/bookkeeper | 2 +
bookkeeper-server/bin/bookkeeper-cluster.sh | 135 +
bookkeeper-server/conf/bk_server.conf | 70 +
bookkeeper-server/conf/bkenv.sh | 3 +
bookkeeper-server/conf/log4j.properties | 4 -
bookkeeper-server/pom.xml | 64 +-
.../auth/AuthProviderFactoryFactory.java | 111 +
.../apache/bookkeeper/auth/BookieAuthProvider.java | 83 +
.../apache/bookkeeper/auth/ClientAuthProvider.java | 89 +
.../bookkeeper/bookie/BookKeeperServerStats.java | 93 +
.../java/org/apache/bookkeeper/bookie/Bookie.java | 803 +--
.../bookkeeper/bookie/BookieCriticalThread.java | 33 +-
.../apache/bookkeeper/bookie/BookieException.java | 5 +-
.../org/apache/bookkeeper/bookie/BookieShell.java | 722 ++-
.../org/apache/bookkeeper/bookie/BookieThread.java | 33 +-
.../apache/bookkeeper/bookie/BufferedChannel.java | 176 +-
.../bookkeeper/bookie/BufferedChannelBase.java | 55 +
.../bookkeeper/bookie/BufferedReadChannel.java | 103 +
.../apache/bookkeeper/bookie/CacheCallback.java} | 15 +-
.../apache/bookkeeper/bookie/CheckpointSource.java | 83 +
.../bookie/CompactableLedgerStorage.java | 61 +
.../java/org/apache/bookkeeper/bookie/Cookie.java | 378 +-
.../org/apache/bookkeeper/bookie/EntryKey.java | 83 +
.../apache/bookkeeper/bookie/EntryKeyValue.java | 129 +
.../{HandleFactory.java => EntryLocation.java} | 16 +-
.../apache/bookkeeper/bookie/EntryLogMetadata.java | 101 +
.../org/apache/bookkeeper/bookie/EntryLogger.java | 771 ++-
.../apache/bookkeeper/bookie/EntryMemTable.java | 440 ++
.../org/apache/bookkeeper/bookie/FileInfo.java | 122 +-
.../bookkeeper/bookie/FileSystemUpgrade.java | 62 +-
.../bookkeeper/bookie/GarbageCollectorThread.java | 357 +-
.../bookkeeper/bookie/HandleFactoryImpl.java | 34 +-
.../bookkeeper/bookie/IndexInMemPageMgr.java | 567 ++
.../bookkeeper/bookie/IndexPersistenceMgr.java | 581 +++
.../bookie/InterleavedLedgerStorage.java | 321 +-
.../java/org/apache/bookkeeper/bookie/Journal.java | 645 ++-
.../apache/bookkeeper/bookie/JournalChannel.java | 171 +-
.../bookkeeper/bookie/LEPStateChangeCallback.java} | 20 +-
.../apache/bookkeeper/bookie/LedgerCacheImpl.java | 845 +--
.../bookkeeper/bookie/LedgerCacheMXBean.java | 10 -
.../bookkeeper/bookie/LedgerDescriptorImpl.java | 2 +-
.../bookkeeper/bookie/LedgerDirsManager.java | 221 +-
.../apache/bookkeeper/bookie/LedgerEntryPage.java | 151 +-
.../apache/bookkeeper/bookie/LedgerStorage.java | 45 +-
.../bookkeeper/bookie/LedgerStorageFactory.java} | 22 +-
.../bookie/LocalBookieEnsemblePlacementPolicy.java | 88 +
.../java/org/apache/bookkeeper/bookie/LogMark.java | 83 +
.../apache/bookkeeper/bookie/ReadOnlyBookie.java | 66 +
.../bookkeeper/bookie/ReadOnlyEntryLogger.java | 4 +-
.../bookie/ScanAndCompareGarbageCollector.java | 175 +-
.../apache/bookkeeper/bookie/SkipListArena.java | 238 +
...{ReadOnlyFileInfo.java => SkipListFlusher.java} | 29 +-
.../bookkeeper/bookie/SortedLedgerStorage.java | 200 +
.../org/apache/bookkeeper/bookie/SyncThread.java | 189 +
.../org/apache/bookkeeper/client/BKException.java | 53 +
.../org/apache/bookkeeper/client/BookKeeper.java | 494 +-
.../apache/bookkeeper/client/BookKeeperAdmin.java | 280 +-
.../bookkeeper/client/BookKeeperClientStats.java | 43 +
.../apache/bookkeeper/client/BookieWatcher.java | 214 +-
.../client/DefaultEnsemblePlacementPolicy.java | 93 +
.../bookkeeper/client/EnsemblePlacementPolicy.java | 89 +
.../apache/bookkeeper/client/LedgerChecker.java | 28 +-
.../apache/bookkeeper/client/LedgerCreateOp.java | 92 +-
.../apache/bookkeeper/client/LedgerDeleteOp.java | 18 +
.../org/apache/bookkeeper/client/LedgerEntry.java | 2 +-
.../apache/bookkeeper/client/LedgerFragment.java | 11 +-
.../client/LedgerFragmentReplicator.java | 63 +-
.../org/apache/bookkeeper/client/LedgerHandle.java | 410 +-
.../apache/bookkeeper/client/LedgerHandleAdv.java | 214 +
.../apache/bookkeeper/client/LedgerMetadata.java | 115 +-
.../org/apache/bookkeeper/client/LedgerOpenOp.java | 64 +-
.../apache/bookkeeper/client/LedgerRecoveryOp.java | 79 +-
.../apache/bookkeeper/client/MacDigestManager.java | 6 +-
.../org/apache/bookkeeper/client/PendingAddOp.java | 90 +-
.../apache/bookkeeper/client/PendingReadOp.java | 134 +-
.../client/RackawareEnsemblePlacementPolicy.java | 572 ++
.../bookkeeper/client/ReadLastConfirmedOp.java | 8 +-
.../bookkeeper/client/ReadOnlyLedgerHandle.java | 12 +-
.../bookkeeper/client/TryReadLastConfirmedOp.java | 107 +
.../apache/bookkeeper/client/UpdateLedgerOp.java | 250 +
.../bookkeeper/conf/AbstractConfiguration.java | 11 +-
.../bookkeeper/conf/ClientConfiguration.java | 458 +-
.../org/apache/bookkeeper/conf/Configurable.java} | 30 +-
.../bookkeeper/conf/ServerConfiguration.java | 893 +++-
.../bookkeeper/meta/AbstractZkLedgerManager.java | 60 +-
.../bookkeeper/meta/CleanupLedgerManager.java | 227 +
.../apache/bookkeeper/meta/FlatLedgerManager.java | 42 +-
.../bookkeeper/meta/FlatLedgerManagerFactory.java | 21 +-
.../bookkeeper/meta/HierarchicalLedgerManager.java | 96 +-
.../meta/HierarchicalLedgerManagerFactory.java | 23 +-
.../apache/bookkeeper/meta/LedgerIdGenerator.java | 40 +-
.../org/apache/bookkeeper/meta/LedgerManager.java | 43 +-
.../bookkeeper/meta/LedgerManagerFactory.java | 18 +-
.../bookkeeper/meta/MSLedgerManagerFactory.java | 147 +-
.../bookkeeper/meta/ZkLedgerIdGenerator.java | 122 +
.../meta/ZkLedgerUnderreplicationManager.java | 121 +-
.../metastore/InMemoryMetastoreTable.java | 8 +-
.../org/apache/bookkeeper/metastore/Value.java | 4 +-
.../bookkeeper/net/AbstractDNSToSwitchMapping.java | 142 +
.../apache/bookkeeper/net/BookieSocketAddress.java | 108 +
.../bookkeeper/net/CachedDNSToSwitchMapping.java | 153 +
.../CommonConfigurationKeys.java} | 31 +-
.../main/java/org/apache/bookkeeper/net/DNS.java | 116 +-
.../apache/bookkeeper/net/DNSToSwitchMapping.java | 61 +
.../java/org/apache/bookkeeper/net/NetUtils.java | 61 +
.../org/apache/bookkeeper/net/NetworkTopology.java | 877 ++++
.../main/java/org/apache/bookkeeper/net/Node.java | 62 +
.../java/org/apache/bookkeeper/net/NodeBase.java | 186 +
.../apache/bookkeeper/net/ScriptBasedMapping.java | 264 +
.../bookkeeper/processor/RequestProcessor.java} | 29 +-
.../org/apache/bookkeeper/proto/AuthHandler.java | 363 ++
.../org/apache/bookkeeper/proto/BookieClient.java | 319 +-
.../apache/bookkeeper/proto/BookieNettyServer.java | 243 +
.../bookkeeper/proto/BookieProtoEncoding.java | 417 ++
.../apache/bookkeeper/proto/BookieProtocol.java | 206 +
.../bookkeeper/proto/BookieRequestHandler.java | 89 +
.../bookkeeper/proto/BookieRequestProcessor.java | 194 +
.../org/apache/bookkeeper/proto/BookieServer.java | 384 +-
.../apache/bookkeeper/proto/BookieServerBean.java | 10 +-
.../proto/BookkeeperInternalCallbacks.java | 4 +-
.../bookkeeper/proto/BookkeeperProtocol.java | 5501 ++++++++++++++++++++
.../proto/DefaultPerChannelBookieClientPool.java | 101 +
.../bookkeeper/proto/LocalBookiesRegistry.java} | 37 +-
.../apache/bookkeeper/proto/NIOServerFactory.java | 583 ---
.../bookkeeper/proto/PacketProcessorBase.java | 78 +
.../bookkeeper/proto/PacketProcessorBaseV3.java | 78 +
.../bookkeeper/proto/PerChannelBookieClient.java | 911 ++--
.../proto/PerChannelBookieClientFactory.java} | 22 +-
.../proto/PerChannelBookieClientPool.java | 64 +
.../bookkeeper/proto/ReadEntryProcessor.java | 140 +
.../bookkeeper/proto/ReadEntryProcessorV3.java | 166 +
.../apache/bookkeeper/proto/ResponseBuilder.java | 47 +
.../bookkeeper/proto/WriteEntryProcessor.java | 109 +
.../bookkeeper/proto/WriteEntryProcessorV3.java | 154 +
.../org/apache/bookkeeper/replication/Auditor.java | 101 +-
.../bookkeeper/replication/AuditorElector.java | 40 +-
.../bookkeeper/replication/AutoRecoveryMain.java | 64 +-
.../replication/BookieLedgerIndexer.java | 9 +-
.../ReplicationStats.java} | 19 +-
.../bookkeeper/replication/ReplicationWorker.java | 197 +-
.../bookkeeper/streaming/LedgerInputStream.java | 2 +-
.../bookkeeper/streaming/LedgerOutputStream.java | 2 +-
.../apache/bookkeeper/tools/BookKeeperTools.java | 20 +-
.../bookkeeper/util/BookKeeperConstants.java | 8 +
...{SafeRunnable.java => DaemonThreadFactory.java} | 34 +-
.../apache/bookkeeper/util/DirectMemoryUtils.java | 57 +
.../org/apache/bookkeeper/util/DiskChecker.java | 114 +-
.../org/apache/bookkeeper/util/EntryFormatter.java | 2 +-
.../java/org/apache/bookkeeper/util/HardLink.java | 16 +-
.../java/org/apache/bookkeeper/util/IOUtils.java | 62 +-
.../apache/bookkeeper/util/LocalBookKeeper.java | 125 +-
.../java/org/apache/bookkeeper/util/MathUtils.java | 24 +
.../java/org/apache/bookkeeper/util/NativeIO.java | 119 +
.../bookkeeper/util/OrderedSafeExecutor.java | 257 +-
.../java/org/apache/bookkeeper/util/Shell.java | 677 +++
.../org/apache/bookkeeper/util/StringUtils.java | 29 -
.../org/apache/bookkeeper/util/ZeroBuffer.java | 73 +
.../java/org/apache/bookkeeper/util/ZkUtils.java | 27 +-
.../BoundExponentialBackoffRetryPolicy.java} | 34 +-
.../ExponentialBackoffRetryPolicy.java} | 34 +-
.../apache/bookkeeper/zookeeper/RetryPolicy.java | 55 +
.../bookkeeper/zookeeper/ZooKeeperClient.java | 1279 +++++
.../bookkeeper/zookeeper/ZooKeeperWatcherBase.java | 109 +-
.../org/apache/bookkeeper/zookeeper/ZooWorker.java | 163 +
.../src/main/proto/BookkeeperProtocol.proto | 134 +
bookkeeper-server/src/main/proto/DataFormats.proto | 2 +
.../src/main/resources/NOTICE.bin.txt | 3 +-
.../src/main/resources/findbugsExclude.xml | 17 +
.../java/org/apache/bookkeeper/auth/TestAuth.java | 654 +++
.../apache/bookkeeper/bookie/BookieAccessor.java | 6 +-
.../bookie/BookieInitializationTest.java | 228 +-
.../bookkeeper/bookie/BookieJournalTest.java | 350 +-
.../bookkeeper/bookie/BookieShutdownTest.java | 130 +-
.../apache/bookkeeper/bookie/BookieThreadTest.java | 84 +
.../apache/bookkeeper/bookie/CompactionTest.java | 377 +-
.../org/apache/bookkeeper/bookie/CookieTest.java | 268 +-
.../apache/bookkeeper/bookie/CreateNewLogTest.java | 13 +-
.../org/apache/bookkeeper/bookie/EntryLogTest.java | 175 +-
.../bookkeeper/bookie/IndexCorruptionTest.java | 10 +-
.../bookkeeper/bookie/IndexPersistenceMgrTest.java | 125 +
.../apache/bookkeeper/bookie/LedgerCacheTest.java | 123 +-
.../bookie/TestGcOverreplicatedLedger.java | 240 +
.../bookkeeper/bookie/TestLedgerDirsManager.java | 148 +-
.../apache/bookkeeper/bookie/TestSyncThread.java | 371 ++
.../bookkeeper/bookie/UpdateCookieCmdTest.java | 216 +
.../org/apache/bookkeeper/bookie/UpgradeTest.java | 117 +-
.../client/BookKeeperClientZKSessionExpiry.java | 79 +
.../bookkeeper/client/BookKeeperCloseTest.java | 610 +++
.../apache/bookkeeper/client/BookKeeperTest.java | 79 +-
.../bookkeeper/client/BookieRecoveryTest.java | 117 +-
.../bookkeeper/client/BookieWriteLedgerTest.java | 375 +-
.../org/apache/bookkeeper/client/ClientUtil.java | 18 +-
.../apache/bookkeeper/client/LedgerCloseTest.java | 10 +-
.../bookkeeper/client/LedgerRecoveryTest.java | 22 +-
.../apache/bookkeeper/client/ListLedgersTest.java | 28 +-
.../bookkeeper/client/LocalBookKeeperTest.java | 67 +
.../client/RoundRobinDistributionScheduleTest.java | 3 +-
.../apache/bookkeeper/client/SlowBookieTest.java | 36 +-
.../client/TestAddEntryQuorumTimeout.java | 144 +
.../bookkeeper/client/TestBookieHealthCheck.java | 149 +
.../bookkeeper/client/TestBookieWatcher.java | 140 +
.../org/apache/bookkeeper/client/TestFencing.java | 72 +-
.../bookkeeper/client/TestLedgerChecker.java | 121 +-
.../client/TestLedgerFragmentReplication.java | 74 +-
.../TestRackawareEnsemblePlacementPolicy.java | 286 +
.../apache/bookkeeper/client/TestReadTimeout.java | 32 +-
.../bookkeeper/client/TestSpeculativeRead.java | 34 +-
.../client/TestTryReadLastConfirmed.java | 188 +
.../bookkeeper/client/TestWatchEnsembleChange.java | 108 +-
.../bookkeeper/client/UpdateLedgerCmdTest.java | 133 +
.../bookkeeper/client/UpdateLedgerOpTest.java | 305 ++
.../TestBKConfiguration.java} | 27 +-
.../org/apache/bookkeeper/meta/GcLedgersTest.java | 68 +-
.../apache/bookkeeper/meta/LedgerLayoutTest.java | 10 +-
.../bookkeeper/meta/LedgerManagerIteratorTest.java | 2 +
.../bookkeeper/meta/LedgerManagerTestCase.java | 131 +-
.../apache/bookkeeper/meta/TestLedgerManager.java | 72 +-
.../bookkeeper/meta/TestZkLedgerIdGenerator.java | 122 +
.../apache/bookkeeper/metastore/TestMetaStore.java | 10 +-
.../bookkeeper/proto/TestBackwardCompatCMS42.java | 239 +
.../apache/bookkeeper/proto/TestDataFormats.java | 126 +
.../apache/bookkeeper/proto/TestDeathwatcher.java | 4 +-
.../proto/TestPerChannelBookieClient.java | 107 +-
.../apache/bookkeeper/proto/TestProtoVersions.java | 113 -
.../bookkeeper/replication/AuditorBookieTest.java | 29 +-
.../replication/AuditorLedgerCheckerTest.java | 76 +-
.../AuditorPeriodicBookieCheckTest.java | 28 +-
.../replication/AuditorPeriodicCheckTest.java | 93 +-
.../replication/AuditorRollingRestartTest.java | 6 +-
.../replication/AutoRecoveryMainTest.java | 3 +-
.../replication/BookieAutoRecoveryTest.java | 184 +-
.../replication/BookieLedgerIndexTest.java | 4 +-
.../TestAutoRecoveryAlongWithBookieServers.java | 18 +-
.../TestLedgerUnderreplicationManager.java | 42 +-
.../replication/TestReplicationWorker.java | 145 +-
.../apache/bookkeeper/test/AsyncLedgerOpsTest.java | 4 +-
.../bookkeeper/test/BookKeeperClusterTestCase.java | 147 +-
.../apache/bookkeeper/test/BookieClientTest.java | 51 +-
.../apache/bookkeeper/test/BookieFailureTest.java | 10 +-
.../bookkeeper/test/BookieJournalRollingTest.java | 56 +-
.../bookkeeper/test/BookieReadWriteTest.java | 242 +-
.../apache/bookkeeper/test/BookieZKExpireTest.java | 24 +-
.../java/org/apache/bookkeeper/test/CloseTest.java | 2 +-
.../bookkeeper/test/ConcurrentLedgerTest.java | 34 +-
.../apache/bookkeeper/test/ConditionalSetTest.java | 11 +-
.../apache/bookkeeper/test/ConfigurationTest.java | 6 +-
.../bookkeeper/test/ForceReadOnlyBookieTest.java | 96 +
.../apache/bookkeeper/test/LedgerDeleteTest.java | 34 +-
.../org/apache/bookkeeper/test/LoopbackClient.java | 20 +-
.../bookkeeper/test/MultipleThreadReadTest.java | 308 ++
.../bookkeeper/test/NIOServerFactoryTest.java | 66 -
.../apache/bookkeeper/test/ReadOnlyBookieTest.java | 103 +-
.../apache/bookkeeper/test/TestBackwardCompat.java | 288 +-
.../org/apache/bookkeeper/test/ZooKeeperUtil.java | 48 +-
.../apache/bookkeeper/util/StaticDNSResolver.java | 80 +
.../apache/bookkeeper/util/TestDiskChecker.java | 63 +-
.../bookkeeper/zookeeper/TestZooKeeperClient.java | 372 ++
.../src/test/proto/TestDataFormats.proto | 34 +
.../src/test/resources/log4j.properties | 1 -
.../codahale-metrics-provider/pom.xml | 68 +
.../bookkeeper/stats/CodahaleMetricsProvider.java | 147 +
.../bookkeeper/stats/CodahaleOpStatsLogger.java | 77 +
.../bookkeeper/stats/CodahaleStatsLogger.java | 99 +
.../bookkeeper/stats/CodahaleOpStatsTest.java | 31 +
.../pom.xml | 15 +-
.../twitter-ostrich-provider/pom.xml | 55 +
.../stats/twitter/ostrich/CounterImpl.java | 53 +
.../stats/twitter/ostrich/OpStatsLoggerImpl.java | 95 +
.../stats/twitter/ostrich/OstrichProvider.java | 77 +
.../twitter/ostrich/OstrichStatsLoggerImpl.java | 69 +
.../twitter-science-provider/pom.xml | 89 +
.../stats/twitter/science/CounterImpl.java | 69 +
.../stats/twitter/science/HTTPStatsExporter.java | 77 +
.../stats/twitter/science/OpStatsLoggerImpl.java | 80 +
.../twitter/science/TwitterStatsLoggerImpl.java | 72 +
.../twitter/science/TwitterStatsProvider.java | 63 +
bookkeeper-stats/pom.xml | 57 +
.../java/org/apache/bookkeeper/stats/Counter.java | 50 +
.../java/org/apache/bookkeeper/stats/Gauge.java | 13 +-
.../apache/bookkeeper/stats/NullStatsLogger.java | 108 +
.../apache/bookkeeper/stats/NullStatsProvider.java | 40 +
.../org/apache/bookkeeper/stats/OpStatsData.java | 76 +
.../org/apache/bookkeeper/stats/OpStatsLogger.java | 64 +
.../java/org/apache/bookkeeper/stats/Stats.java | 63 +
.../org/apache/bookkeeper/stats/StatsLogger.java | 55 +
.../org/apache/bookkeeper/stats/StatsProvider.java | 45 +
compat-deps/bookkeeper-server-compat-4.0.0/pom.xml | 4 +-
compat-deps/bookkeeper-server-compat-4.1.0/pom.xml | 4 +-
.../pom.xml | 26 +-
compat-deps/hedwig-server-compat-4.0.0/pom.xml | 97 -
compat-deps/pom.xml | 7 +-
debian/changelog | 12 +-
debian/clean | 1 -
debian/control | 1 +
debian/copyright | 14 -
debian/libbookkeeper-java.poms | 5 +-
debian/maven.ignoreRules | 3 +-
.../01-add-commons-collections-dependency.patch | 2 +-
debian/patches/02-ignore-xlint-settings.patch | 14 +
debian/patches/03-protoc-compatibility.patch | 12 +
debian/patches/series | 2 +
dev/bk-merge-pr.py | 506 ++
doc/bookieConfigParams.textile | 33 +-
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/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/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 ---
.../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 -
.../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 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 | 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 -
patch-review.py | 228 +
pom.xml | 47 +-
640 files changed, 39876 insertions(+), 62619 deletions(-)
create mode 100644 bin/update-master-docs
create mode 100644 bookkeeper-server/bin/bookkeeper-cluster.sh
create mode 100644 bookkeeper-server/src/main/java/org/apache/bookkeeper/auth/AuthProviderFactoryFactory.java
create mode 100644 bookkeeper-server/src/main/java/org/apache/bookkeeper/auth/BookieAuthProvider.java
create mode 100644 bookkeeper-server/src/main/java/org/apache/bookkeeper/auth/ClientAuthProvider.java
create mode 100644 bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/BookKeeperServerStats.java
rename hedwig-server/src/main/java/org/apache/hedwig/server/jmx/HedwigMBeanRegistry.java => bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/BookieCriticalThread.java (56%)
rename hedwig-server/src/main/java/org/apache/hedwig/server/common/TerminateJVMExceptionHandler.java => bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/BookieThread.java (53%)
create mode 100644 bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/BufferedChannelBase.java
create mode 100644 bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/BufferedReadChannel.java
copy bookkeeper-server/src/{test/java/org/apache/bookkeeper/bookie/BookieAccessor.java => main/java/org/apache/bookkeeper/bookie/CacheCallback.java} (78%)
create mode 100644 bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/CheckpointSource.java
create mode 100644 bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/CompactableLedgerStorage.java
create mode 100644 bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/EntryKey.java
create mode 100644 bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/EntryKeyValue.java
copy bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/{HandleFactory.java => EntryLocation.java} (74%)
create mode 100644 bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/EntryLogMetadata.java
create mode 100644 bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/EntryMemTable.java
create mode 100644 bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/IndexInMemPageMgr.java
create mode 100644 bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/IndexPersistenceMgr.java
copy bookkeeper-server/src/{test/java/org/apache/bookkeeper/bookie/BookieAccessor.java => main/java/org/apache/bookkeeper/bookie/LEPStateChangeCallback.java} (74%)
copy bookkeeper-server/src/{test/java/org/apache/bookkeeper/bookie/BookieAccessor.java => main/java/org/apache/bookkeeper/bookie/LedgerStorageFactory.java} (69%)
create mode 100644 bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/LocalBookieEnsemblePlacementPolicy.java
create mode 100644 bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/LogMark.java
create mode 100644 bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/ReadOnlyBookie.java
create mode 100644 bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/SkipListArena.java
copy bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/{ReadOnlyFileInfo.java => SkipListFlusher.java} (69%)
create mode 100644 bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/SortedLedgerStorage.java
create mode 100644 bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/SyncThread.java
create mode 100644 bookkeeper-server/src/main/java/org/apache/bookkeeper/client/BookKeeperClientStats.java
create mode 100644 bookkeeper-server/src/main/java/org/apache/bookkeeper/client/DefaultEnsemblePlacementPolicy.java
create mode 100644 bookkeeper-server/src/main/java/org/apache/bookkeeper/client/EnsemblePlacementPolicy.java
create mode 100644 bookkeeper-server/src/main/java/org/apache/bookkeeper/client/LedgerHandleAdv.java
create mode 100644 bookkeeper-server/src/main/java/org/apache/bookkeeper/client/RackawareEnsemblePlacementPolicy.java
create mode 100644 bookkeeper-server/src/main/java/org/apache/bookkeeper/client/TryReadLastConfirmedOp.java
create mode 100644 bookkeeper-server/src/main/java/org/apache/bookkeeper/client/UpdateLedgerOp.java
copy bookkeeper-server/src/{test/java/org/apache/bookkeeper/bookie/BookieAccessor.java => main/java/org/apache/bookkeeper/conf/Configurable.java} (59%)
create mode 100644 bookkeeper-server/src/main/java/org/apache/bookkeeper/meta/CleanupLedgerManager.java
rename hedwig-client/src/test/java/org/apache/hedwig/client/AppTest.java => bookkeeper-server/src/main/java/org/apache/bookkeeper/meta/LedgerIdGenerator.java (55%)
create mode 100644 bookkeeper-server/src/main/java/org/apache/bookkeeper/meta/ZkLedgerIdGenerator.java
create mode 100644 bookkeeper-server/src/main/java/org/apache/bookkeeper/net/AbstractDNSToSwitchMapping.java
create mode 100644 bookkeeper-server/src/main/java/org/apache/bookkeeper/net/BookieSocketAddress.java
create mode 100644 bookkeeper-server/src/main/java/org/apache/bookkeeper/net/CachedDNSToSwitchMapping.java
copy bookkeeper-server/src/main/java/org/apache/bookkeeper/{bookie/ReadOnlyFileInfo.java => net/CommonConfigurationKeys.java} (60%)
create mode 100644 bookkeeper-server/src/main/java/org/apache/bookkeeper/net/DNSToSwitchMapping.java
create mode 100644 bookkeeper-server/src/main/java/org/apache/bookkeeper/net/NetUtils.java
create mode 100644 bookkeeper-server/src/main/java/org/apache/bookkeeper/net/NetworkTopology.java
create mode 100644 bookkeeper-server/src/main/java/org/apache/bookkeeper/net/Node.java
create mode 100644 bookkeeper-server/src/main/java/org/apache/bookkeeper/net/NodeBase.java
create mode 100644 bookkeeper-server/src/main/java/org/apache/bookkeeper/net/ScriptBasedMapping.java
copy bookkeeper-server/src/{test/java/org/apache/bookkeeper/bookie/BookieAccessor.java => main/java/org/apache/bookkeeper/processor/RequestProcessor.java} (66%)
create mode 100644 bookkeeper-server/src/main/java/org/apache/bookkeeper/proto/AuthHandler.java
create mode 100644 bookkeeper-server/src/main/java/org/apache/bookkeeper/proto/BookieNettyServer.java
create mode 100644 bookkeeper-server/src/main/java/org/apache/bookkeeper/proto/BookieProtoEncoding.java
create mode 100644 bookkeeper-server/src/main/java/org/apache/bookkeeper/proto/BookieRequestHandler.java
create mode 100644 bookkeeper-server/src/main/java/org/apache/bookkeeper/proto/BookieRequestProcessor.java
create mode 100644 bookkeeper-server/src/main/java/org/apache/bookkeeper/proto/BookkeeperProtocol.java
create mode 100644 bookkeeper-server/src/main/java/org/apache/bookkeeper/proto/DefaultPerChannelBookieClientPool.java
copy bookkeeper-server/src/{test/java/org/apache/bookkeeper/proto/TestBKStats.java => main/java/org/apache/bookkeeper/proto/LocalBookiesRegistry.java} (54%)
delete mode 100644 bookkeeper-server/src/main/java/org/apache/bookkeeper/proto/NIOServerFactory.java
create mode 100644 bookkeeper-server/src/main/java/org/apache/bookkeeper/proto/PacketProcessorBase.java
create mode 100644 bookkeeper-server/src/main/java/org/apache/bookkeeper/proto/PacketProcessorBaseV3.java
copy bookkeeper-server/src/{test/java/org/apache/bookkeeper/bookie/BookieAccessor.java => main/java/org/apache/bookkeeper/proto/PerChannelBookieClientFactory.java} (63%)
create mode 100644 bookkeeper-server/src/main/java/org/apache/bookkeeper/proto/PerChannelBookieClientPool.java
create mode 100644 bookkeeper-server/src/main/java/org/apache/bookkeeper/proto/ReadEntryProcessor.java
create mode 100644 bookkeeper-server/src/main/java/org/apache/bookkeeper/proto/ReadEntryProcessorV3.java
create mode 100644 bookkeeper-server/src/main/java/org/apache/bookkeeper/proto/ResponseBuilder.java
create mode 100644 bookkeeper-server/src/main/java/org/apache/bookkeeper/proto/WriteEntryProcessor.java
create mode 100644 bookkeeper-server/src/main/java/org/apache/bookkeeper/proto/WriteEntryProcessorV3.java
copy bookkeeper-server/src/main/java/org/apache/bookkeeper/{bookie/HandleFactory.java => replication/ReplicationStats.java} (62%)
copy bookkeeper-server/src/main/java/org/apache/bookkeeper/util/{SafeRunnable.java => DaemonThreadFactory.java} (55%)
create mode 100644 bookkeeper-server/src/main/java/org/apache/bookkeeper/util/DirectMemoryUtils.java
create mode 100644 bookkeeper-server/src/main/java/org/apache/bookkeeper/util/NativeIO.java
create mode 100644 bookkeeper-server/src/main/java/org/apache/bookkeeper/util/Shell.java
create mode 100644 bookkeeper-server/src/main/java/org/apache/bookkeeper/util/ZeroBuffer.java
copy bookkeeper-server/src/main/java/org/apache/bookkeeper/{util/StringEntryFormatter.java => zookeeper/BoundExponentialBackoffRetryPolicy.java} (55%)
copy bookkeeper-server/src/main/java/org/apache/bookkeeper/{util/StringEntryFormatter.java => zookeeper/ExponentialBackoffRetryPolicy.java} (52%)
create mode 100644 bookkeeper-server/src/main/java/org/apache/bookkeeper/zookeeper/RetryPolicy.java
create mode 100644 bookkeeper-server/src/main/java/org/apache/bookkeeper/zookeeper/ZooKeeperClient.java
create mode 100644 bookkeeper-server/src/main/java/org/apache/bookkeeper/zookeeper/ZooWorker.java
create mode 100644 bookkeeper-server/src/main/proto/BookkeeperProtocol.proto
create mode 100644 bookkeeper-server/src/test/java/org/apache/bookkeeper/auth/TestAuth.java
create mode 100644 bookkeeper-server/src/test/java/org/apache/bookkeeper/bookie/BookieThreadTest.java
create mode 100644 bookkeeper-server/src/test/java/org/apache/bookkeeper/bookie/IndexPersistenceMgrTest.java
create mode 100644 bookkeeper-server/src/test/java/org/apache/bookkeeper/bookie/TestGcOverreplicatedLedger.java
create mode 100644 bookkeeper-server/src/test/java/org/apache/bookkeeper/bookie/TestSyncThread.java
create mode 100644 bookkeeper-server/src/test/java/org/apache/bookkeeper/bookie/UpdateCookieCmdTest.java
create mode 100644 bookkeeper-server/src/test/java/org/apache/bookkeeper/client/BookKeeperClientZKSessionExpiry.java
create mode 100644 bookkeeper-server/src/test/java/org/apache/bookkeeper/client/BookKeeperCloseTest.java
create mode 100644 bookkeeper-server/src/test/java/org/apache/bookkeeper/client/LocalBookKeeperTest.java
create mode 100644 bookkeeper-server/src/test/java/org/apache/bookkeeper/client/TestAddEntryQuorumTimeout.java
create mode 100644 bookkeeper-server/src/test/java/org/apache/bookkeeper/client/TestBookieHealthCheck.java
create mode 100644 bookkeeper-server/src/test/java/org/apache/bookkeeper/client/TestBookieWatcher.java
create mode 100644 bookkeeper-server/src/test/java/org/apache/bookkeeper/client/TestRackawareEnsemblePlacementPolicy.java
create mode 100644 bookkeeper-server/src/test/java/org/apache/bookkeeper/client/TestTryReadLastConfirmed.java
create mode 100644 bookkeeper-server/src/test/java/org/apache/bookkeeper/client/UpdateLedgerCmdTest.java
create mode 100644 bookkeeper-server/src/test/java/org/apache/bookkeeper/client/UpdateLedgerOpTest.java
copy bookkeeper-server/src/test/java/org/apache/bookkeeper/{bookie/BookieAccessor.java => conf/TestBKConfiguration.java} (63%)
create mode 100644 bookkeeper-server/src/test/java/org/apache/bookkeeper/meta/TestZkLedgerIdGenerator.java
create mode 100644 bookkeeper-server/src/test/java/org/apache/bookkeeper/proto/TestBackwardCompatCMS42.java
create mode 100644 bookkeeper-server/src/test/java/org/apache/bookkeeper/proto/TestDataFormats.java
delete mode 100644 bookkeeper-server/src/test/java/org/apache/bookkeeper/proto/TestProtoVersions.java
create mode 100644 bookkeeper-server/src/test/java/org/apache/bookkeeper/test/ForceReadOnlyBookieTest.java
create mode 100644 bookkeeper-server/src/test/java/org/apache/bookkeeper/test/MultipleThreadReadTest.java
delete mode 100644 bookkeeper-server/src/test/java/org/apache/bookkeeper/test/NIOServerFactoryTest.java
create mode 100644 bookkeeper-server/src/test/java/org/apache/bookkeeper/util/StaticDNSResolver.java
create mode 100644 bookkeeper-server/src/test/java/org/apache/bookkeeper/zookeeper/TestZooKeeperClient.java
create mode 100644 bookkeeper-server/src/test/proto/TestDataFormats.proto
create mode 100644 bookkeeper-stats-providers/codahale-metrics-provider/pom.xml
create mode 100644 bookkeeper-stats-providers/codahale-metrics-provider/src/main/java/org/apache/bookkeeper/stats/CodahaleMetricsProvider.java
create mode 100644 bookkeeper-stats-providers/codahale-metrics-provider/src/main/java/org/apache/bookkeeper/stats/CodahaleOpStatsLogger.java
create mode 100644 bookkeeper-stats-providers/codahale-metrics-provider/src/main/java/org/apache/bookkeeper/stats/CodahaleStatsLogger.java
create mode 100644 bookkeeper-stats-providers/codahale-metrics-provider/src/test/java/org/apache/bookkeeper/stats/CodahaleOpStatsTest.java
copy {compat-deps => bookkeeper-stats-providers}/pom.xml (81%)
create mode 100644 bookkeeper-stats-providers/twitter-ostrich-provider/pom.xml
create mode 100644 bookkeeper-stats-providers/twitter-ostrich-provider/src/main/java/org/apache/bookkeeper/stats/twitter/ostrich/CounterImpl.java
create mode 100644 bookkeeper-stats-providers/twitter-ostrich-provider/src/main/java/org/apache/bookkeeper/stats/twitter/ostrich/OpStatsLoggerImpl.java
create mode 100644 bookkeeper-stats-providers/twitter-ostrich-provider/src/main/java/org/apache/bookkeeper/stats/twitter/ostrich/OstrichProvider.java
create mode 100644 bookkeeper-stats-providers/twitter-ostrich-provider/src/main/java/org/apache/bookkeeper/stats/twitter/ostrich/OstrichStatsLoggerImpl.java
create mode 100644 bookkeeper-stats-providers/twitter-science-provider/pom.xml
create mode 100644 bookkeeper-stats-providers/twitter-science-provider/src/main/java/org/apache/bookkeeper/stats/twitter/science/CounterImpl.java
create mode 100644 bookkeeper-stats-providers/twitter-science-provider/src/main/java/org/apache/bookkeeper/stats/twitter/science/HTTPStatsExporter.java
create mode 100644 bookkeeper-stats-providers/twitter-science-provider/src/main/java/org/apache/bookkeeper/stats/twitter/science/OpStatsLoggerImpl.java
create mode 100644 bookkeeper-stats-providers/twitter-science-provider/src/main/java/org/apache/bookkeeper/stats/twitter/science/TwitterStatsLoggerImpl.java
create mode 100644 bookkeeper-stats-providers/twitter-science-provider/src/main/java/org/apache/bookkeeper/stats/twitter/science/TwitterStatsProvider.java
create mode 100644 bookkeeper-stats/pom.xml
create mode 100644 bookkeeper-stats/src/main/java/org/apache/bookkeeper/stats/Counter.java
copy bookkeeper-server/src/main/java/org/apache/bookkeeper/client/BookiesListener.java => bookkeeper-stats/src/main/java/org/apache/bookkeeper/stats/Gauge.java (72%)
create mode 100644 bookkeeper-stats/src/main/java/org/apache/bookkeeper/stats/NullStatsLogger.java
create mode 100644 bookkeeper-stats/src/main/java/org/apache/bookkeeper/stats/NullStatsProvider.java
create mode 100644 bookkeeper-stats/src/main/java/org/apache/bookkeeper/stats/OpStatsData.java
create mode 100644 bookkeeper-stats/src/main/java/org/apache/bookkeeper/stats/OpStatsLogger.java
create mode 100644 bookkeeper-stats/src/main/java/org/apache/bookkeeper/stats/Stats.java
create mode 100644 bookkeeper-stats/src/main/java/org/apache/bookkeeper/stats/StatsLogger.java
create mode 100644 bookkeeper-stats/src/main/java/org/apache/bookkeeper/stats/StatsProvider.java
rename compat-deps/{hedwig-server-compat-4.1.0 => bookkeeper-server-compat-4.2.0}/pom.xml (80%)
delete mode 100644 compat-deps/hedwig-server-compat-4.0.0/pom.xml
create mode 100644 debian/patches/02-ignore-xlint-settings.patch
create mode 100644 debian/patches/03-protoc-compatibility.patch
create mode 100755 dev/bk-merge-pr.py
create mode 100644 doc/bookkeeperLedgers2Logs.textile
create mode 100644 doc/bookkeeperProtocol.textile
create mode 100644 doc/bookkeeperTutorial.textile
delete mode 100644 doc/hedwigBuild.textile
delete mode 100644 doc/hedwigConsole.textile
delete mode 100644 doc/hedwigDesign.textile
delete mode 100644 doc/hedwigJMX.textile
delete mode 100644 doc/hedwigMessageFilter.textile
delete mode 100644 doc/hedwigMetadata.textile
delete mode 100644 doc/hedwigParams.textile
delete mode 100644 doc/hedwigUser.textile
delete mode 100644 hedwig-client/conf/hw_client.conf
delete mode 100644 hedwig-client/pom.xml
delete mode 100644 hedwig-client/src/main/cpp/Makefile.am
delete mode 100644 hedwig-client/src/main/cpp/README
delete mode 100644 hedwig-client/src/main/cpp/aminclude.am
delete mode 100644 hedwig-client/src/main/cpp/c-doc.Doxyfile
delete mode 100644 hedwig-client/src/main/cpp/configure.ac
delete mode 100644 hedwig-client/src/main/cpp/hedwig-0.1.pc.in
delete mode 100644 hedwig-client/src/main/cpp/inc/hedwig/callback.h
delete mode 100644 hedwig-client/src/main/cpp/inc/hedwig/client.h
delete mode 100644 hedwig-client/src/main/cpp/inc/hedwig/exceptions.h
delete mode 100644 hedwig-client/src/main/cpp/inc/hedwig/publish.h
delete mode 100644 hedwig-client/src/main/cpp/inc/hedwig/subscribe.h
delete mode 100644 hedwig-client/src/main/cpp/lib/Makefile.am
delete mode 100644 hedwig-client/src/main/cpp/lib/channel.cpp
delete mode 100644 hedwig-client/src/main/cpp/lib/channel.h
delete mode 100644 hedwig-client/src/main/cpp/lib/client.cpp
delete mode 100644 hedwig-client/src/main/cpp/lib/clientimpl.cpp
delete mode 100644 hedwig-client/src/main/cpp/lib/clientimpl.h
delete mode 100644 hedwig-client/src/main/cpp/lib/data.cpp
delete mode 100644 hedwig-client/src/main/cpp/lib/data.h
delete mode 100644 hedwig-client/src/main/cpp/lib/eventdispatcher.cpp
delete mode 100644 hedwig-client/src/main/cpp/lib/eventdispatcher.h
delete mode 100644 hedwig-client/src/main/cpp/lib/exceptions.cpp
delete mode 100644 hedwig-client/src/main/cpp/lib/filterablemessagehandler.cpp
delete mode 100644 hedwig-client/src/main/cpp/lib/filterablemessagehandler.h
delete mode 100644 hedwig-client/src/main/cpp/lib/multiplexsubscriberimpl.cpp
delete mode 100644 hedwig-client/src/main/cpp/lib/multiplexsubscriberimpl.h
delete mode 100644 hedwig-client/src/main/cpp/lib/publisherimpl.cpp
delete mode 100644 hedwig-client/src/main/cpp/lib/publisherimpl.h
delete mode 100644 hedwig-client/src/main/cpp/lib/simplesubscriberimpl.cpp
delete mode 100644 hedwig-client/src/main/cpp/lib/simplesubscriberimpl.h
delete mode 100644 hedwig-client/src/main/cpp/lib/subscriberimpl.cpp
delete mode 100644 hedwig-client/src/main/cpp/lib/subscriberimpl.h
delete mode 100644 hedwig-client/src/main/cpp/lib/util.cpp
delete mode 100644 hedwig-client/src/main/cpp/lib/util.h
delete mode 100644 hedwig-client/src/main/cpp/m4/ax_boost_asio.m4
delete mode 100644 hedwig-client/src/main/cpp/m4/ax_boost_base.m4
delete mode 100644 hedwig-client/src/main/cpp/m4/ax_boost_thread.m4
delete mode 100644 hedwig-client/src/main/cpp/m4/ax_doxygen.m4
delete mode 100644 hedwig-client/src/main/cpp/m4/gtest.m4
delete mode 100644 hedwig-client/src/main/cpp/scripts/log4cxx.conf
delete mode 100644 hedwig-client/src/main/cpp/scripts/network-delays.sh
delete mode 100644 hedwig-client/src/main/cpp/scripts/server-control.sh
delete mode 100644 hedwig-client/src/main/cpp/scripts/tester.sh
delete mode 100644 hedwig-client/src/main/cpp/test/Makefile.am
delete mode 100644 hedwig-client/src/main/cpp/test/main.cpp
delete mode 100644 hedwig-client/src/main/cpp/test/messageboundtest.cpp
delete mode 100644 hedwig-client/src/main/cpp/test/messagefiltertest.cpp
delete mode 100644 hedwig-client/src/main/cpp/test/multiplextest.cpp
delete mode 100644 hedwig-client/src/main/cpp/test/publishtest.cpp
delete mode 100644 hedwig-client/src/main/cpp/test/pubsubtest.cpp
delete mode 100644 hedwig-client/src/main/cpp/test/subscribetest.cpp
delete mode 100644 hedwig-client/src/main/cpp/test/test.sh
delete mode 100644 hedwig-client/src/main/cpp/test/throttledeliverytest.cpp
delete mode 100644 hedwig-client/src/main/cpp/test/util.h
delete mode 100644 hedwig-client/src/main/cpp/test/utiltest.cpp
delete mode 100644 hedwig-client/src/main/java/org/apache/hedwig/client/HedwigClient.java
delete mode 100644 hedwig-client/src/main/java/org/apache/hedwig/client/api/Client.java
delete mode 100644 hedwig-client/src/main/java/org/apache/hedwig/client/api/MessageHandler.java
delete mode 100644 hedwig-client/src/main/java/org/apache/hedwig/client/api/Publisher.java
delete mode 100644 hedwig-client/src/main/java/org/apache/hedwig/client/api/Subscriber.java
delete mode 100644 hedwig-client/src/main/java/org/apache/hedwig/client/benchmark/BenchmarkPublisher.java
delete mode 100644 hedwig-client/src/main/java/org/apache/hedwig/client/benchmark/BenchmarkSubscriber.java
delete mode 100644 hedwig-client/src/main/java/org/apache/hedwig/client/benchmark/BenchmarkUtils.java
delete mode 100644 hedwig-client/src/main/java/org/apache/hedwig/client/benchmark/BenchmarkWorker.java
delete mode 100644 hedwig-client/src/main/java/org/apache/hedwig/client/benchmark/HedwigBenchmark.java
delete mode 100644 hedwig-client/src/main/java/org/apache/hedwig/client/conf/ClientConfiguration.java
delete mode 100644 hedwig-client/src/main/java/org/apache/hedwig/client/data/MessageConsumeData.java
delete mode 100644 hedwig-client/src/main/java/org/apache/hedwig/client/data/PubSubData.java
delete mode 100644 hedwig-client/src/main/java/org/apache/hedwig/client/data/TopicSubscriber.java
delete mode 100644 hedwig-client/src/main/java/org/apache/hedwig/client/exceptions/AlreadyStartDeliveryException.java
delete mode 100644 hedwig-client/src/main/java/org/apache/hedwig/client/exceptions/InvalidSubscriberIdException.java
delete mode 100644 hedwig-client/src/main/java/org/apache/hedwig/client/exceptions/NoResponseHandlerException.java
delete mode 100644 hedwig-client/src/main/java/org/apache/hedwig/client/exceptions/ResubscribeException.java
delete mode 100644 hedwig-client/src/main/java/org/apache/hedwig/client/exceptions/ServerRedirectLoopException.java
delete mode 100644 hedwig-client/src/main/java/org/apache/hedwig/client/exceptions/TooManyServerRedirectsException.java
delete mode 100644 hedwig-client/src/main/java/org/apache/hedwig/client/handlers/AbstractResponseHandler.java
delete mode 100644 hedwig-client/src/main/java/org/apache/hedwig/client/handlers/CloseSubscriptionResponseHandler.java
delete mode 100644 hedwig-client/src/main/java/org/apache/hedwig/client/handlers/MessageConsumeCallback.java
delete mode 100644 hedwig-client/src/main/java/org/apache/hedwig/client/handlers/PubSubCallback.java
delete mode 100644 hedwig-client/src/main/java/org/apache/hedwig/client/handlers/PublishResponseHandler.java
delete mode 100644 hedwig-client/src/main/java/org/apache/hedwig/client/handlers/SubscribeResponseHandler.java
delete mode 100644 hedwig-client/src/main/java/org/apache/hedwig/client/handlers/UnsubscribeResponseHandler.java
delete mode 100644 hedwig-client/src/main/java/org/apache/hedwig/client/netty/CleanupChannelMap.java
delete mode 100644 hedwig-client/src/main/java/org/apache/hedwig/client/netty/FilterableMessageHandler.java
delete mode 100644 hedwig-client/src/main/java/org/apache/hedwig/client/netty/HChannel.java
delete mode 100644 hedwig-client/src/main/java/org/apache/hedwig/client/netty/HChannelManager.java
delete mode 100644 hedwig-client/src/main/java/org/apache/hedwig/client/netty/HedwigClientImpl.java
delete mode 100644 hedwig-client/src/main/java/org/apache/hedwig/client/netty/HedwigPublisher.java
delete mode 100644 hedwig-client/src/main/java/org/apache/hedwig/client/netty/HedwigSubscriber.java
delete mode 100644 hedwig-client/src/main/java/org/apache/hedwig/client/netty/NetUtils.java
delete mode 100644 hedwig-client/src/main/java/org/apache/hedwig/client/netty/SubscriptionEventEmitter.java
delete mode 100644 hedwig-client/src/main/java/org/apache/hedwig/client/netty/VoidCallbackAdapter.java
delete mode 100644 hedwig-client/src/main/java/org/apache/hedwig/client/netty/impl/AbstractHChannelManager.java
delete mode 100644 hedwig-client/src/main/java/org/apache/hedwig/client/netty/impl/AbstractSubscribeResponseHandler.java
delete mode 100644 hedwig-client/src/main/java/org/apache/hedwig/client/netty/impl/ActiveSubscriber.java
delete mode 100644 hedwig-client/src/main/java/org/apache/hedwig/client/netty/impl/ClientChannelPipelineFactory.java
delete mode 100644 hedwig-client/src/main/java/org/apache/hedwig/client/netty/impl/DefaultServerChannel.java
delete mode 100644 hedwig-client/src/main/java/org/apache/hedwig/client/netty/impl/HChannelHandler.java
delete mode 100644 hedwig-client/src/main/java/org/apache/hedwig/client/netty/impl/HChannelImpl.java
delete mode 100644 hedwig-client/src/main/java/org/apache/hedwig/client/netty/impl/NonSubscriptionChannelPipelineFactory.java
delete mode 100644 hedwig-client/src/main/java/org/apache/hedwig/client/netty/impl/ResubscribeCallback.java
delete mode 100644 hedwig-client/src/main/java/org/apache/hedwig/client/netty/impl/WriteCallback.java
delete mode 100644 hedwig-client/src/main/java/org/apache/hedwig/client/netty/impl/multiplex/MultiplexHChannelManager.java
delete mode 100644 hedwig-client/src/main/java/org/apache/hedwig/client/netty/impl/multiplex/MultiplexSubscribeResponseHandler.java
delete mode 100644 hedwig-client/src/main/java/org/apache/hedwig/client/netty/impl/multiplex/MultiplexSubscriptionChannelPipelineFactory.java
delete mode 100644 hedwig-client/src/main/java/org/apache/hedwig/client/netty/impl/simple/SimpleHChannelManager.java
delete mode 100644 hedwig-client/src/main/java/org/apache/hedwig/client/netty/impl/simple/SimpleSubscribeResponseHandler.java
delete mode 100644 hedwig-client/src/main/java/org/apache/hedwig/client/netty/impl/simple/SimpleSubscriptionChannelPipelineFactory.java
delete mode 100644 hedwig-client/src/main/java/org/apache/hedwig/client/netty/package-info.java
delete mode 100644 hedwig-client/src/main/java/org/apache/hedwig/client/ssl/SslClientContextFactory.java
delete mode 100644 hedwig-client/src/main/java/org/apache/hedwig/client/ssl/SslContextFactory.java
delete mode 100644 hedwig-client/src/main/java/org/apache/hedwig/conf/AbstractConfiguration.java
delete mode 100644 hedwig-client/src/main/java/org/apache/hedwig/filter/ClientMessageFilter.java
delete mode 100644 hedwig-client/src/main/java/org/apache/hedwig/filter/MessageFilterBase.java
delete mode 100644 hedwig-client/src/main/java/org/apache/hedwig/filter/PipelineFilter.java
delete mode 100644 hedwig-client/src/main/java/org/apache/hedwig/filter/ServerMessageFilter.java
delete mode 100644 hedwig-client/src/main/java/org/apache/hedwig/util/Callback.java
delete mode 100644 hedwig-client/src/main/java/org/apache/hedwig/util/CallbackUtils.java
delete mode 100644 hedwig-client/src/main/java/org/apache/hedwig/util/ConcurrencyUtils.java
delete mode 100644 hedwig-client/src/main/java/org/apache/hedwig/util/Either.java
delete mode 100644 hedwig-client/src/main/java/org/apache/hedwig/util/FileUtils.java
delete mode 100644 hedwig-client/src/main/java/org/apache/hedwig/util/HedwigSocketAddress.java
delete mode 100644 hedwig-client/src/main/java/org/apache/hedwig/util/Option.java
delete mode 100644 hedwig-client/src/main/java/org/apache/hedwig/util/Pair.java
delete mode 100644 hedwig-client/src/main/java/org/apache/hedwig/util/PathUtils.java
delete mode 100644 hedwig-client/src/main/java/org/apache/hedwig/util/SubscriptionListener.java
delete mode 100644 hedwig-client/src/main/java/org/apache/hedwig/util/VarArgs.java
delete mode 100644 hedwig-client/src/test/java/org/apache/hedwig/util/TestFileUtils.java
delete mode 100644 hedwig-client/src/test/java/org/apache/hedwig/util/TestHedwigSocketAddress.java
delete mode 100644 hedwig-client/src/test/java/org/apache/hedwig/util/TestPathUtils.java
delete mode 100644 hedwig-protocol/pom.xml
delete mode 100644 hedwig-protocol/src/main/java/org/apache/hedwig/exceptions/PubSubException.java
delete mode 100644 hedwig-protocol/src/main/java/org/apache/hedwig/protoextensions/MapUtils.java
delete mode 100644 hedwig-protocol/src/main/java/org/apache/hedwig/protoextensions/MessageIdUtils.java
delete mode 100644 hedwig-protocol/src/main/java/org/apache/hedwig/protoextensions/PubSubResponseUtils.java
delete mode 100644 hedwig-protocol/src/main/java/org/apache/hedwig/protoextensions/SubscriptionStateUtils.java
delete mode 100644 hedwig-protocol/src/main/protobuf/PubSubProtocol.proto
delete mode 100644 hedwig-protocol/src/main/resources/findbugsExclude.xml
delete mode 100755 hedwig-server/bin/hedwig
delete mode 100755 hedwig-server/bin/hedwig-daemon.sh
delete mode 100644 hedwig-server/conf/hw_region_client.conf
delete mode 100644 hedwig-server/conf/hw_server.conf
delete mode 100644 hedwig-server/conf/hwenv.sh
delete mode 100644 hedwig-server/conf/log4j.properties
delete mode 100644 hedwig-server/pom.xml
delete mode 100644 hedwig-server/src/main/java/org/apache/hedwig/admin/HedwigAdmin.java
delete mode 100644 hedwig-server/src/main/java/org/apache/hedwig/admin/console/HedwigCommands.java
delete mode 100644 hedwig-server/src/main/java/org/apache/hedwig/admin/console/HedwigConsole.java
delete mode 100644 hedwig-server/src/main/java/org/apache/hedwig/admin/console/JLineHedwigCompletor.java
delete mode 100644 hedwig-server/src/main/java/org/apache/hedwig/admin/console/ReadTopic.java
delete mode 100644 hedwig-server/src/main/java/org/apache/hedwig/data/MessageFormatter.java
delete mode 100644 hedwig-server/src/main/java/org/apache/hedwig/server/benchmark/AbstractBenchmark.java
delete mode 100644 hedwig-server/src/main/java/org/apache/hedwig/server/benchmark/BookieBenchmark.java
delete mode 100644 hedwig-server/src/main/java/org/apache/hedwig/server/benchmark/BookkeeperBenchmark.java
delete mode 100644 hedwig-server/src/main/java/org/apache/hedwig/server/benchmark/FakeBookie.java
delete mode 100644 hedwig-server/src/main/java/org/apache/hedwig/server/common/ByteStringInterner.java
delete mode 100644 hedwig-server/src/main/java/org/apache/hedwig/server/common/ServerConfiguration.java
delete mode 100644 hedwig-server/src/main/java/org/apache/hedwig/server/common/TopicOpQueuer.java
delete mode 100644 hedwig-server/src/main/java/org/apache/hedwig/server/common/UnexpectedError.java
delete mode 100644 hedwig-server/src/main/java/org/apache/hedwig/server/delivery/ChannelEndPoint.java
delete mode 100644 hedwig-server/src/main/java/org/apache/hedwig/server/delivery/DeliveryCallback.java
delete mode 100644 hedwig-server/src/main/java/org/apache/hedwig/server/delivery/DeliveryEndPoint.java
delete mode 100644 hedwig-server/src/main/java/org/apache/hedwig/server/delivery/DeliveryManager.java
delete mode 100644 hedwig-server/src/main/java/org/apache/hedwig/server/delivery/FIFODeliveryManager.java
delete mode 100644 hedwig-server/src/main/java/org/apache/hedwig/server/handlers/BaseHandler.java
delete mode 100644 hedwig-server/src/main/java/org/apache/hedwig/server/handlers/ChannelDisconnectListener.java
delete mode 100644 hedwig-server/src/main/java/org/apache/hedwig/server/handlers/CloseSubscriptionHandler.java
delete mode 100644 hedwig-server/src/main/java/org/apache/hedwig/server/handlers/ConsumeHandler.java
delete mode 100644 hedwig-server/src/main/java/org/apache/hedwig/server/handlers/Handler.java
delete mode 100644 hedwig-server/src/main/java/org/apache/hedwig/server/handlers/NettyHandlerBean.java
delete mode 100644 hedwig-server/src/main/java/org/apache/hedwig/server/handlers/NettyHandlerMXBean.java
delete mode 100644 hedwig-server/src/main/java/org/apache/hedwig/server/handlers/PublishHandler.java
delete mode 100644 hedwig-server/src/main/java/org/apache/hedwig/server/handlers/SubscribeHandler.java
delete mode 100644 hedwig-server/src/main/java/org/apache/hedwig/server/handlers/SubscriptionChannelManager.java
delete mode 100644 hedwig-server/src/main/java/org/apache/hedwig/server/handlers/UnsubscribeHandler.java
delete mode 100644 hedwig-server/src/main/java/org/apache/hedwig/server/jmx/HedwigJMXService.java
delete mode 100644 hedwig-server/src/main/java/org/apache/hedwig/server/jmx/HedwigMBeanInfo.java
delete mode 100644 hedwig-server/src/main/java/org/apache/hedwig/server/meta/FactoryLayout.java
delete mode 100644 hedwig-server/src/main/java/org/apache/hedwig/server/meta/MetadataManagerFactory.java
delete mode 100644 hedwig-server/src/main/java/org/apache/hedwig/server/meta/MsMetadataManagerFactory.java
delete mode 100644 hedwig-server/src/main/java/org/apache/hedwig/server/meta/SubscriptionDataManager.java
delete mode 100644 hedwig-server/src/main/java/org/apache/hedwig/server/meta/TopicOwnershipManager.java
delete mode 100644 hedwig-server/src/main/java/org/apache/hedwig/server/meta/TopicPersistenceManager.java
delete mode 100644 hedwig-server/src/main/java/org/apache/hedwig/server/meta/ZkMetadataManagerFactory.java
delete mode 100644 hedwig-server/src/main/java/org/apache/hedwig/server/netty/PubSubServer.java
delete mode 100644 hedwig-server/src/main/java/org/apache/hedwig/server/netty/PubSubServerBean.java
delete mode 100644 hedwig-server/src/main/java/org/apache/hedwig/server/netty/PubSubServerMXBean.java
delete mode 100644 hedwig-server/src/main/java/org/apache/hedwig/server/netty/PubSubServerPipelineFactory.java
delete mode 100644 hedwig-server/src/main/java/org/apache/hedwig/server/netty/ServerStats.java
delete mode 100644 hedwig-server/src/main/java/org/apache/hedwig/server/netty/UmbrellaHandler.java
delete mode 100644 hedwig-server/src/main/java/org/apache/hedwig/server/persistence/BookkeeperPersistenceManager.java
delete mode 100644 hedwig-server/src/main/java/org/apache/hedwig/server/persistence/CacheKey.java
delete mode 100644 hedwig-server/src/main/java/org/apache/hedwig/server/persistence/CacheValue.java
delete mode 100644 hedwig-server/src/main/java/org/apache/hedwig/server/persistence/CancelScanRequest.java
delete mode 100644 hedwig-server/src/main/java/org/apache/hedwig/server/persistence/Factory.java
delete mode 100644 hedwig-server/src/main/java/org/apache/hedwig/server/persistence/LocalDBPersistenceManager.java
delete mode 100644 hedwig-server/src/main/java/org/apache/hedwig/server/persistence/MapMethods.java
delete mode 100644 hedwig-server/src/main/java/org/apache/hedwig/server/persistence/PersistRequest.java
delete mode 100644 hedwig-server/src/main/java/org/apache/hedwig/server/persistence/PersistenceManager.java
delete mode 100644 hedwig-server/src/main/java/org/apache/hedwig/server/persistence/PersistenceManagerWithRangeScan.java
delete mode 100644 hedwig-server/src/main/java/org/apache/hedwig/server/persistence/RangeScanRequest.java
delete mode 100644 hedwig-server/src/main/java/org/apache/hedwig/server/persistence/ReadAheadCache.java
delete mode 100644 hedwig-server/src/main/java/org/apache/hedwig/server/persistence/ReadAheadCacheBean.java
delete mode 100644 hedwig-server/src/main/java/org/apache/hedwig/server/persistence/ReadAheadCacheMXBean.java
delete mode 100644 hedwig-server/src/main/java/org/apache/hedwig/server/persistence/ScanCallback.java
delete mode 100644 hedwig-server/src/main/java/org/apache/hedwig/server/persistence/ScanCallbackWithContext.java
delete mode 100644 hedwig-server/src/main/java/org/apache/hedwig/server/persistence/ScanRequest.java
delete mode 100644 hedwig-server/src/main/java/org/apache/hedwig/server/proxy/ChannelTracker.java
delete mode 100644 hedwig-server/src/main/java/org/apache/hedwig/server/proxy/HedwigProxy.java
delete mode 100644 hedwig-server/src/main/java/org/apache/hedwig/server/proxy/ProxyCloseSubscriptionHandler.java
delete mode 100644 hedwig-server/src/main/java/org/apache/hedwig/server/proxy/ProxyConfiguration.java
delete mode 100644 hedwig-server/src/main/java/org/apache/hedwig/server/proxy/ProxyConsumeHandler.java
delete mode 100644 hedwig-server/src/main/java/org/apache/hedwig/server/proxy/ProxyPublishHander.java
delete mode 100644 hedwig-server/src/main/java/org/apache/hedwig/server/proxy/ProxyStartDeliveryHandler.java
delete mode 100644 hedwig-server/src/main/java/org/apache/hedwig/server/proxy/ProxyStopDeliveryHandler.java
delete mode 100644 hedwig-server/src/main/java/org/apache/hedwig/server/proxy/ProxySubscribeHandler.java
delete mode 100644 hedwig-server/src/main/java/org/apache/hedwig/server/proxy/ProxyUnsubscribeHandler.java
delete mode 100644 hedwig-server/src/main/java/org/apache/hedwig/server/regions/HedwigHubClient.java
delete mode 100644 hedwig-server/src/main/java/org/apache/hedwig/server/regions/HedwigHubClientFactory.java
delete mode 100644 hedwig-server/src/main/java/org/apache/hedwig/server/regions/HedwigHubSubscriber.java
delete mode 100644 hedwig-server/src/main/java/org/apache/hedwig/server/regions/RegionManager.java
delete mode 100644 hedwig-server/src/main/java/org/apache/hedwig/server/ssl/SslServerContextFactory.java
delete mode 100644 hedwig-server/src/main/java/org/apache/hedwig/server/subscriptions/AbstractSubscriptionManager.java
delete mode 100644 hedwig-server/src/main/java/org/apache/hedwig/server/subscriptions/AllToAllTopologyFilter.java
delete mode 100644 hedwig-server/src/main/java/org/apache/hedwig/server/subscriptions/InMemorySubscriptionManager.java
delete mode 100644 hedwig-server/src/main/java/org/apache/hedwig/server/subscriptions/InMemorySubscriptionState.java
delete mode 100644 hedwig-server/src/main/java/org/apache/hedwig/server/subscriptions/MMSubscriptionManager.java
delete mode 100644 hedwig-server/src/main/java/org/apache/hedwig/server/subscriptions/SubscriptionEventListener.java
delete mode 100644 hedwig-server/src/main/java/org/apache/hedwig/server/subscriptions/SubscriptionManager.java
delete mode 100644 hedwig-server/src/main/java/org/apache/hedwig/server/topics/AbstractTopicManager.java
delete mode 100644 hedwig-server/src/main/java/org/apache/hedwig/server/topics/HubInfo.java
delete mode 100644 hedwig-server/src/main/java/org/apache/hedwig/server/topics/HubLoad.java
delete mode 100644 hedwig-server/src/main/java/org/apache/hedwig/server/topics/HubServerManager.java
delete mode 100644 hedwig-server/src/main/java/org/apache/hedwig/server/topics/MMTopicManager.java
delete mode 100644 hedwig-server/src/main/java/org/apache/hedwig/server/topics/TopicManager.java
delete mode 100644 hedwig-server/src/main/java/org/apache/hedwig/server/topics/TopicOwnershipChangeListener.java
delete mode 100644 hedwig-server/src/main/java/org/apache/hedwig/server/topics/TrivialOwnAllTopicManager.java
delete mode 100644 hedwig-server/src/main/java/org/apache/hedwig/server/topics/ZkHubServerManager.java
delete mode 100644 hedwig-server/src/main/java/org/apache/hedwig/server/topics/ZkTopicManager.java
delete mode 100644 hedwig-server/src/main/java/org/apache/hedwig/zookeeper/SafeAsynBKCallback.java
delete mode 100644 hedwig-server/src/main/java/org/apache/hedwig/zookeeper/SafeAsyncCallback.java
delete mode 100644 hedwig-server/src/main/java/org/apache/hedwig/zookeeper/SafeAsyncZKCallback.java
delete mode 100644 hedwig-server/src/main/java/org/apache/hedwig/zookeeper/ZkUtils.java
delete mode 100644 hedwig-server/src/main/resources/LICENSE.bin.txt
delete mode 100644 hedwig-server/src/main/resources/NOTICE.bin.txt
delete mode 100644 hedwig-server/src/main/resources/findbugsExclude.xml
delete mode 100644 hedwig-server/src/main/resources/p12.pass
delete mode 100644 hedwig-server/src/main/resources/server.p12
delete mode 100644 hedwig-server/src/test/java/org/apache/hedwig/HelperMethods.java
delete mode 100644 hedwig-server/src/test/java/org/apache/hedwig/StubCallback.java
delete mode 100644 hedwig-server/src/test/java/org/apache/hedwig/StubScanCallback.java
delete mode 100644 hedwig-server/src/test/java/org/apache/hedwig/client/TestPubSubClient.java
delete mode 100644 hedwig-server/src/test/java/org/apache/hedwig/client/TestSubAfterCloseSub.java
delete mode 100644 hedwig-server/src/test/java/org/apache/hedwig/client/netty/TestMultiplexing.java
delete mode 100644 hedwig-server/src/test/java/org/apache/hedwig/server/HedwigHubTestBase.java
delete mode 100644 hedwig-server/src/test/java/org/apache/hedwig/server/HedwigRegionTestBase.java
delete mode 100644 hedwig-server/src/test/java/org/apache/hedwig/server/LoggingExceptionHandler.java
delete mode 100644 hedwig-server/src/test/java/org/apache/hedwig/server/PubSubServerStandAloneTestBase.java
delete mode 100644 hedwig-server/src/test/java/org/apache/hedwig/server/TestBackwardCompat.java
delete mode 100644 hedwig-server/src/test/java/org/apache/hedwig/server/TestPubSubServerStartup.java
delete mode 100644 hedwig-server/src/test/java/org/apache/hedwig/server/delivery/StubDeliveryManager.java
delete mode 100644 hedwig-server/src/test/java/org/apache/hedwig/server/delivery/TestFIFODeliveryManager.java
delete mode 100644 hedwig-server/src/test/java/org/apache/hedwig/server/delivery/TestThrottlingDelivery.java
delete mode 100644 hedwig-server/src/test/java/org/apache/hedwig/server/filter/TestMessageFilter.java
delete mode 100644 hedwig-server/src/test/java/org/apache/hedwig/server/handlers/TestBaseHandler.java
delete mode 100644 hedwig-server/src/test/java/org/apache/hedwig/server/handlers/TestSubUnsubHandler.java
delete mode 100644 hedwig-server/src/test/java/org/apache/hedwig/server/integration/TestHedwigHub.java
delete mode 100644 hedwig-server/src/test/java/org/apache/hedwig/server/integration/TestHedwigHubProxy.java
delete mode 100644 hedwig-server/src/test/java/org/apache/hedwig/server/integration/TestHedwigHubRegular.java
delete mode 100644 hedwig-server/src/test/java/org/apache/hedwig/server/integration/TestHedwigHubSSL.java
delete mode 100644 hedwig-server/src/test/java/org/apache/hedwig/server/integration/TestHedwigRegion.java
delete mode 100644 hedwig-server/src/test/java/org/apache/hedwig/server/meta/MetadataManagerFactoryTestCase.java
delete mode 100644 hedwig-server/src/test/java/org/apache/hedwig/server/meta/TestFactoryLayout.java
delete mode 100644 hedwig-server/src/test/java/org/apache/hedwig/server/meta/TestMetadataManager.java
delete mode 100644 hedwig-server/src/test/java/org/apache/hedwig/server/meta/TestMetadataManagerFactory.java
delete mode 100644 hedwig-server/src/test/java/org/apache/hedwig/server/netty/TestPubSubServer.java
delete mode 100644 hedwig-server/src/test/java/org/apache/hedwig/server/netty/TestServerStats.java
delete mode 100644 hedwig-server/src/test/java/org/apache/hedwig/server/netty/WriteRecordingChannel.java
delete mode 100644 hedwig-server/src/test/java/org/apache/hedwig/server/persistence/BookKeeperTestBase.java
delete mode 100644 hedwig-server/src/test/java/org/apache/hedwig/server/persistence/MessageBoundedPersistenceTest.java
delete mode 100644 hedwig-server/src/test/java/org/apache/hedwig/server/persistence/StubPersistenceManager.java
delete mode 100644 hedwig-server/src/test/java/org/apache/hedwig/server/persistence/StubScanCallback.java
delete mode 100644 hedwig-server/src/test/java/org/apache/hedwig/server/persistence/TestBookKeeperPersistenceManager.java
delete mode 100644 hedwig-server/src/test/java/org/apache/hedwig/server/persistence/TestBookKeeperPersistenceManagerBlackBox.java
delete mode 100644 hedwig-server/src/test/java/org/apache/hedwig/server/persistence/TestBookkeeperPersistenceManagerWhiteBox.java
delete mode 100644 hedwig-server/src/test/java/org/apache/hedwig/server/persistence/TestDeadlock.java
delete mode 100644 hedwig-server/src/test/java/org/apache/hedwig/server/persistence/TestLocalDBPersistenceManagerBlackBox.java
delete mode 100644 hedwig-server/src/test/java/org/apache/hedwig/server/persistence/TestPersistenceManagerBlackBox.java
delete mode 100644 hedwig-server/src/test/java/org/apache/hedwig/server/persistence/TestReadAheadCacheBlackBox.java
delete mode 100644 hedwig-server/src/test/java/org/apache/hedwig/server/persistence/TestReadAheadCacheWhiteBox.java
delete mode 100644 hedwig-server/src/test/java/org/apache/hedwig/server/subscriptions/StubSubscriptionManager.java
delete mode 100644 hedwig-server/src/test/java/org/apache/hedwig/server/subscriptions/TestMMSubscriptionManager.java
delete mode 100644 hedwig-server/src/test/java/org/apache/hedwig/server/subscriptions/TestUpdateSubscriptionState.java
delete mode 100644 hedwig-server/src/test/java/org/apache/hedwig/server/topics/StubTopicManager.java
delete mode 100644 hedwig-server/src/test/java/org/apache/hedwig/server/topics/TestConcurrentTopicAcquisition.java
delete mode 100644 hedwig-server/src/test/java/org/apache/hedwig/server/topics/TestHubInfo.java
delete mode 100644 hedwig-server/src/test/java/org/apache/hedwig/server/topics/TestHubLoad.java
delete mode 100644 hedwig-server/src/test/java/org/apache/hedwig/server/topics/TestMMTopicManager.java
delete mode 100644 hedwig-server/src/test/java/org/apache/hedwig/server/topics/TestZkTopicManager.java
delete mode 100644 hedwig-server/src/test/java/org/apache/hedwig/zookeeper/TestZkUtils.java
delete mode 100644 hedwig-server/src/test/java/org/apache/hedwig/zookeeper/ZooKeeperTestBase.java
delete mode 100644 hedwig-server/src/test/resources/log4j.properties
create mode 100755 patch-review.py
--
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