This is an automated email from the git hooks/post-receive script. ebourg-guest pushed a commit to branch master in repository openhft-chronicle-queue.
commit c07a175289d7effe5a8151489d3d54fd6017aee8 Merge: 88ecd87 4945182 Author: Emmanuel Bourg <[email protected]> Date: Sat Jul 30 01:29:41 2016 +0200 Merge tag 'upstream/3.6.0' Upstream version 3.6.0 .gitignore | 10 + .idea/copyright/Apache_2_0.xml | 10 - LICENSE | 165 +++ README.md | 576 ++++++++- chronicle-demo/pom.xml | 101 +- .../src/main/java/demo/ChronicleController.java | 253 ++++ .../src/main/java/demo/ChronicleDashboard.java | 352 ++++++ .../src/main/java/demo/ChronicleUpdatable.java | 41 + .../src/main/java/demo/ControlledThread.java | 73 ++ chronicle-demo/src/main/java/demo/Price.java | 114 ++ .../java/vanilla/java/echo/QueueClientMain.java | 130 ++ .../java/vanilla/java/echo/QueueServerMain.java | 68 ++ .../java/vanilla/java/intserver/ClientMain.java | 66 + .../java/vanilla/java/intserver/ServerMain.java | 83 ++ .../java/vanilla/java/intserver/api/C2SReader.java | 47 + .../api/C2SWriter.java} | 26 +- .../api/IClient.java} | 15 +- .../java/vanilla/java/intserver/api/IServer.java | 12 +- .../java/vanilla/java/intserver/api/S2CReader.java | 52 + .../api/S2CWriter.java} | 33 +- .../java/vanilla/java/processingengine/GWMain.java | 36 +- .../java/processingengine/MicroJitterSampler.java | 46 +- .../java/vanilla/java/processingengine/PEMain.java | 19 +- .../java/processingengine/api/Gw2PeEvents.java | 6 +- .../java/processingengine/api/Gw2PeReader.java | 9 +- .../java/processingengine/api/Gw2PeWriter.java | 8 +- .../java/processingengine/api/MessageType.java | 6 +- .../java/processingengine/api/MetaData.java | 18 +- .../java/processingengine/api/Pe2GwEvents.java | 6 +- .../java/processingengine/api/Pe2GwReader.java | 7 +- .../java/processingengine/api/Pe2GwWriter.java | 8 +- .../java/processingengine/api/ReportStatus.java | 6 +- .../vanilla/java/processingengine/api/Side.java | 6 +- .../java/processingengine/api/SmallCommand.java | 14 +- .../java/processingengine/api/SmallReport.java | 16 +- .../java/processingengine/testing/Histogram.java | 10 +- .../java/vanilla/java/proxy/FromChronicle.java | 65 + .../src/main/java/vanilla/java/proxy/MetaData.java | 102 ++ .../src/main/java/vanilla/java/proxy/PrintAll.java | 51 + .../main/java/vanilla/java/proxy/ToChronicle.java | 61 + .../main/java/vanilla/java/single/QueueMain.java | 53 + .../java/tutorial/OffHeapDirectInstance.java | 48 + .../java/tutorial/OffHeapDirectReference.java | 57 + .../java/vanilla/java/tutorial/OffHeapHelper.java | 105 ++ chronicle-demo/src/main/resources/diagram.jpg | Bin 0 -> 76807 bytes chronicle-queue/.gitignore | 118 ++ chronicle-queue/README.md | 25 + chronicle-queue/pom.xml | 227 ++++ .../openhft/chronicle/queue/ChronicleQueue.java | 112 ++ .../chronicle/queue/ChronicleQueueBuilder.java | 30 + .../java/net/openhft/chronicle/queue/Excerpt.java | 79 ++ .../openhft/chronicle/queue/ExcerptAppender.java | 63 + .../net/openhft/chronicle/queue/ExcerptCommon.java | 26 + .../openhft/chronicle/queue/ExcerptComparator.java | 30 + .../net/openhft/chronicle/queue/ExcerptTailer.java | 92 ++ .../net/openhft/chronicle/queue/RollCycle.java | 79 ++ .../net/openhft/chronicle/queue/RollCycles.java | 52 + .../net/openhft/chronicle/queue/RollDateCache.java | 85 ++ .../queue/impl/AbstractChronicleQueue.java | 106 ++ .../openhft/chronicle/queue/impl/BytesWriter.java | 27 + .../queue/impl/DelegatedChronicleQueue.java | 88 ++ .../net/openhft/chronicle/queue/impl/Excerpts.java | 421 +++++++ .../chronicle/queue/impl/WireConstants.java | 23 + .../openhft/chronicle/queue/impl/WireStore.java | 79 ++ .../chronicle/queue/impl/WireStorePool.java | 54 + .../chronicle/queue/impl/WireStoreSupplier.java | 22 + .../queue/impl/async/AsyncChronicleQueue.java | 109 ++ .../impl/async/AsyncChronicleQueueBuilder.java | 59 + .../queue/impl/ringbuffer/BytesRingBuffer.java | 559 +++++++++ .../impl/ringbuffer/ZippedDocumentAppender.java | 178 +++ .../chronicle/queue/impl/single/Compression.java | 14 +- .../chronicle/queue/impl/single/Header.java | 142 +++ .../queue/impl/single/SingleChronicleQueue.java | 226 ++++ .../impl/single/SingleChronicleQueueBuilder.java | 135 +++ .../impl/single/SingleChronicleQueueStore.java | 965 +++++++++++++++ .../queue/ChronicleQueueLatencyDistribution.java | 181 +++ ...ChronicleQueueLatencyDistributionWithBytes.java | 185 +++ .../chronicle/queue/ChronicleQueueMicrobench.java | 117 ++ .../chronicle/queue/ChronicleQueueTestBase.java | 154 +++ .../queue/impl/ringbuffer/BytesRingBufferTest.java | 238 ++++ .../ringbuffer/ReadMarshableRingBufferTest.java | 98 ++ .../impl/ringbuffer/ZipBytesRingBufferTest.java | 91 ++ .../queue/impl/single/AsyncChronicleQueueTest.java | 53 + .../queue/impl/single/IndexOffsetTest.java | 42 + .../chronicle/queue/impl/single/IndexTest.java | 55 + .../impl/single/SingleChronicleQueueTest.java | 393 ++++++ .../chronicle/queue/impl/single/jira/Queue28.java | 74 ++ .../chronicle/queue/impl/single/jira/Queue30.java | 95 ++ chronicle-sandbox/pom.xml | 97 +- .../ClientWiredChronicleQueueStateless.java | 113 ++ .../ClientWiredExcerptAppenderStateless.java | 62 + .../ClientWiredExcerptTailerStateless.java | 82 ++ .../engine/client/internal/CoreFields.java | 75 ++ .../client/internal/QueueAppenderResponse.java | 49 + .../client/internal/QueueTailerResponse.java | 40 + .../engine/client/internal/QueueWireHandler.java | 231 ++++ .../net/openhft/chronicle/queue/Compression.java | 14 +- .../java/net/openhft/chronicle/queue/Excerpts.java | 107 ++ .../net/openhft/chronicle/queue/QueueDumpMain.java | 54 + .../chronicle/queue/impl/AbstractChronicle.java | 21 +- .../chronicle/queue/impl/DirectChronicleQueue.java | 51 + .../net/openhft/chronicle/queue/impl/Header.java | 134 ++ .../net/openhft/chronicle/queue/impl/Indexer.java | 142 +++ .../chronicle/queue/impl/SingleAppender.java | 83 ++ .../chronicle/queue/impl/SingleChronicleQueue.java | 396 ++++++ .../openhft/chronicle/queue/impl/SingleTailer.java | 212 ++++ .../net/openhft/chronicle/queue/impl/WireUtil.java | 29 + .../queue/impl/ringbuffer/BytesRingBuffer.java | 445 +++++++ .../impl/ringbuffer/ZippedDocumentAppender.java | 166 +++ .../queue/stateless/StatelessAppender.java | 72 ++ .../queue/stateless/StatelessChronicleQueue.java | 101 ++ .../queue/stateless/StatelessExcerpt.java | 104 ++ .../chronicle/queue/stateless/StatelessTailer.java | 97 ++ .../stateless/bytes/StatelessRawBytesAppender.java | 46 + .../stateless/bytes/StatelessRawBytesTailer.java | 59 + .../chronicle/sandbox/DailyRollingChronicle.java | 383 ------ .../chronicle/sandbox/DailyRollingConfig.java | 148 --- .../net/openhft/chronicle/sandbox/Journal.java | 40 - .../openhft/chronicle/sandbox/JournalConfig.java | 59 - .../net/openhft/chronicle/sandbox/JournalFile.java | 48 - .../openhft/chronicle/sandbox/JournalRecord.java | 76 -- .../sandbox/PrefetchingMappedFileCache.java | 216 ---- .../chronicle/sandbox/RollingChronicle.java | 225 ---- .../chronicle/sandbox/SingleMappedFileCache.java | 94 -- .../chronicle/sandbox/VanillaChronicle.java | 533 -------- .../chronicle/sandbox/VanillaChronicleConfig.java | 94 -- .../chronicle/sandbox/VanillaChronicleReader.java | 177 --- .../chronicle/sandbox/VanillaDataCache.java | 151 --- .../net/openhft/chronicle/sandbox/VanillaFile.java | 117 -- .../chronicle/sandbox/VanillaIndexCache.java | 159 --- .../openhft/chronicle/sandbox/VanillaJournal.java | 35 - .../chronicle/sandbox/replay/GenerateData.java | 62 + .../sandbox/replay/OffHeapGenerateData.java | 62 + .../sandbox/replay/OffHeapReplayData.java | 69 ++ .../chronicle/sandbox/replay/OffHeapTestData.java | 53 + .../chronicle/sandbox/replay/ReplayData.java | 69 ++ .../openhft/chronicle/sandbox/replay/TestData.java | 52 + .../sandbox/tcp/VanillaChronicleSink.java | 264 ---- .../sandbox/tcp/VanillaChronicleSource.java | 302 ----- .../sandbox/tcp/VanillaChronicleTCPCommon.java | 21 - .../chronicle/queue/BytesRingBufferTest.java | 327 +++++ .../chronicle/queue/ChronicleQueueTest.java | 106 ++ .../queue/DirectChronicleQueueStringTest.java | 152 +++ .../openhft/chronicle/queue/MappedMemoryTest.java | 152 +++ .../chronicle/queue/MappingReferenceCountTest.java | 82 ++ .../chronicle/queue/impl/IndexOffsetTest.java | 48 + .../queue/impl/SingleChronicleQueueTest.java | 338 ++++++ .../queue/impl/ZipBytesRingBufferTest.java | 94 ++ .../openhft/chronicle/queue/simple/WriterMain.java | 86 ++ .../sandbox/DailyRollingChronicleTest.java | 133 -- .../chronicle/sandbox/RollingChronicleTest.java | 67 - .../sandbox/VanillaChronicleSourceTest.java | 69 -- .../chronicle/sandbox/VanillaChronicleTest.java | 229 ---- .../chronicle/sandbox/VanillaDataCacheTest.java | 94 -- .../chronicle/sandbox/VanillaIndexCacheTest.java | 64 - .../chronicle/sandbox/{ => attic}/VdsoTest.java | 19 +- chronicle-test/pom.xml | 177 +++ .../openhft/chronicle/osgi/OSGiPlaceholder.java | 14 +- .../net/openhft/chronicle/osgi/OSGiBundleTest.java | 58 +- .../net/openhft/chronicle/osgi/OSGiTestBase.java | 52 + chronicle/pom.xml | 287 ++--- .../openhft/chronicle/AbstractNativeExcerpt.java | 307 ----- .../main/java/net/openhft/chronicle/Chronicle.java | 47 +- .../net/openhft/chronicle/ChronicleConfig.java | 161 --- .../openhft/chronicle/ChronicleQueueBuilder.java | 1274 ++++++++++++++++++++ .../net/openhft/chronicle/ChronicleQueueSink.java | 397 ++++++ .../openhft/chronicle/ChronicleQueueSource.java | 84 ++ .../main/java/net/openhft/chronicle/Excerpt.java | 11 +- .../net/openhft/chronicle/ExcerptAppender.java | 29 +- .../java/net/openhft/chronicle/ExcerptCommon.java | 30 +- .../net/openhft/chronicle/ExcerptComparator.java | 6 +- .../net/openhft/chronicle/ExcerptMarshallable.java | 6 +- .../java/net/openhft/chronicle/ExcerptTailer.java | 10 +- .../net/openhft/chronicle/IndexedChronicle.java | 1215 ++++++++++++++++--- .../openhft/chronicle/IndexedChronicleCache.java | 49 - .../{MappedFileCache.java => MappingFunction.java} | 26 +- .../net/openhft/chronicle/MappingProvider.java | 21 +- .../java/net/openhft/chronicle/NativeExcerpt.java | 162 --- .../openhft/chronicle/NativeExcerptAppender.java | 201 --- .../net/openhft/chronicle/NativeExcerptTailer.java | 148 --- .../openhft/chronicle/RemoteChronicleQueue.java | 455 +++++++ ...tils.java => RemoteChronicleQueueAppender.java} | 28 +- .../chronicle/RemoteChronicleQueueTailer.java | 39 + .../net/openhft/chronicle/VanillaChronicle.java | 821 +++++++++++++ .../openhft/chronicle/VanillaChronicleUtils.java | 84 ++ .../net/openhft/chronicle/VanillaDataCache.java | 203 ++++ .../net/openhft/chronicle/VanillaDateCache.java | 39 +- .../net/openhft/chronicle/VanillaIndexCache.java | 290 +++++ .../net/openhft/chronicle/tcp/AddressProvider.java | 16 +- .../openhft/chronicle/tcp/AddressProviders.java | 44 + .../net/openhft/chronicle/tcp/AppenderAdapter.java | 38 + .../openhft/chronicle/tcp/AppenderAdapters.java | 97 ++ .../java/net/openhft/chronicle/tcp/Attached.java | 47 + .../net/openhft/chronicle/tcp/ChronicleTcp.java | 118 ++ .../chronicle/tcp/InProcessChronicleSink.java | 261 ---- .../chronicle/tcp/InProcessChronicleSource.java | 301 ----- .../java/net/openhft/chronicle/tcp/SinkTcp.java | 84 ++ .../net/openhft/chronicle/tcp/SinkTcpAcceptor.java | 100 ++ .../openhft/chronicle/tcp/SinkTcpInitiator.java | 55 + .../java/net/openhft/chronicle/tcp/SourceTcp.java | 731 +++++++++++ .../openhft/chronicle/tcp/SourceTcpAcceptor.java | 133 ++ .../openhft/chronicle/tcp/SourceTcpInitiator.java | 99 ++ .../net/openhft/chronicle/tcp/TcpConnection.java | 292 +++++ .../chronicle/tcp/TcpConnectionHandler.java | 40 + .../chronicle/tcp/TcpConnectionListener.java | 29 + .../java/net/openhft/chronicle/tcp/TcpUtil.java | 63 - .../chronicle/tcp/VanillaSelectionKeySet.java | 154 +++ .../net/openhft/chronicle/tcp/VanillaSelector.java | 114 ++ .../openhft/chronicle/tools/CheckedExcerpt.java | 185 +++ .../chronicle/tools/ChronicleIndexReader.java | 8 +- .../chronicle/tools/ChronicleMasterReader.java | 10 +- .../openhft/chronicle/tools/ChronicleReader.java | 18 +- .../openhft/chronicle/tools/ChronicleTools.java | 113 +- .../openhft/chronicle/tools/ChronicleWarmup.java | 62 + .../chronicle/tools/DailingRollingIndexReader.java | 47 - .../chronicle/tools/DailingRollingReader.java | 78 -- .../openhft/chronicle/tools/MasterIndexFile.java | 79 -- .../tools/ResizableDirectByteBufferBytes.java | 80 ++ .../openhft/chronicle/tools/WrappedChronicle.java | 86 ++ .../openhft/chronicle/tools/WrappedExcerpt.java | 1053 +--------------- .../chronicle/tools/WrappedExcerptAppender.java | 94 ++ .../chronicle/tools/WrappedExcerptAppenders.java | 133 ++ .../chronicle/tools/WrappedExcerptTailer.java | 98 ++ .../openhft/chronicle/tools/WrappedExcerpts.java | 130 ++ .../chronicle/AssertionErrorNextIndexTest.java | 49 +- .../chronicle/ChainedInProcessChronicleTest.java | 67 - .../net/openhft/chronicle/ChronicleIndexTest.java | 55 + .../java/net/openhft/chronicle/ChronicleTest.java | 107 ++ .../chronicle/ChronicleTestRunListener.java | 40 + .../java/net/openhft/chronicle}/DateCacheTest.java | 14 +- .../test/java/net/openhft/chronicle/GitHub174.java | 98 ++ .../openhft/chronicle/InProcessChronicleTest.java | 421 ------- .../openhft/chronicle/IndexedChronicle1Test.java | 340 +++--- .../openhft/chronicle/IndexedChronicle2Test.java | 252 ++++ .../openhft/chronicle/IndexedChronicle3Test.java | 214 ++++ .../chronicle/IndexedChronicleLargeFileTest.java | 115 ++ ....java => IndexedChronicleNumberAppendTest.java} | 78 +- .../chronicle/IndexedChronicleResourcesTest.java | 62 + .../openhft/chronicle/IndexedChronicleTest.java | 540 +++++---- .../chronicle/IndexedChronicleTestBase.java | 76 ++ .../chronicle/IndexedChronicleTimeoutTest.java | 103 ++ .../chronicle/IndexedChronicleToEndTest.java | 63 + .../test/java/net/openhft/chronicle/Jira57.java | 130 ++ .../openhft/chronicle/TestTaskExecutionUtil.java | 91 ++ .../openhft/chronicle/VanillaBlockSizeTest.java | 186 +++ .../openhft/chronicle/VanillaChronicle3Test.java | 431 +++++++ .../chronicle/VanillaChronicleCycleTest.java | 217 ++++ .../VanillaChronicleQueueBuilderTest.java | 60 + .../chronicle/VanillaChronicleResourcesTest.java | 356 ++++++ .../openhft/chronicle/VanillaChronicleTest.java | 1104 +++++++++++++++++ .../chronicle/VanillaChronicleTestBase.java | 129 ++ .../chronicle/VanillaChronicleTimeoutTest.java | 119 ++ .../openhft/chronicle/VanillaDataCacheTest.java | 186 +++ .../openhft/chronicle/VanillaIndexCacheTest.java | 241 ++++ .../net/openhft/chronicle/VanillaLatencyTest.java | 134 ++ .../openhft/chronicle/WriteSerializableTest.java | 105 ++ .../chronicle/comparison/ChronicleTestMain.java | 77 ++ .../chronicle/comparison/KafkaTestMain.java | 79 ++ .../openhft/chronicle/examples/CachePerfMain.java | 141 ++- .../chronicle/examples/ExampleCache2Main.java | 15 +- .../chronicle/examples/ExampleCacheMain.java | 15 +- .../examples/ExampleKeyedExcerptMain.java | 16 +- .../chronicle/examples/ExampleRewriteMain.java | 20 +- .../examples/ExampleSimpleWriteReadMain.java | 14 +- .../chronicle/examples/PagingLatencyTest.java | 81 ++ .../net/openhft/chronicle/examples/TestIndex.java | 85 ++ .../chronicle/examples/TestManyUpdates2Main.java | 10 +- .../chronicle/examples/TestManyUpdatesMain.java | 10 +- .../examples/WriteReadDatedMessages2Main.java | 98 ++ .../chronicle/examples/WritingTextMain.java | 68 ++ .../chronicle/lataeg/ChronicleQueueReader.java | 104 ++ .../chronicle/lataeg/ChronicleQueueWriter.java | 85 ++ .../chronicle/lataeg/IChronicleQueueData.java | 87 ++ .../tcp/ChainedInProcessChronicleTest.java | 139 +++ .../chronicle/tcp/ChronicleTcpTestBase.java | 293 +++++ .../chronicle/tcp/StatefulChronicleTestBase.java | 166 +++ .../tcp/StatefulIndexedChronicleTest.java | 666 ++++++++++ .../tcp/StatefulLocalIndexedChronicleTest.java | 101 ++ .../tcp/StatefulLocalVanillaChronicleTest.java | 100 ++ .../tcp/StatefulVanillaChronicleTest.java | 604 ++++++++++ .../tcp/StatelessChronicleTailerTest.java | 47 + .../chronicle/tcp/StatelessChronicleTestBase.java | 340 ++++++ .../tcp/StatelessIndexedChronicleAppenderTest.java | 94 ++ .../tcp/StatelessIndexedChronicleTailerTest.java | 565 +++++++++ .../tcp/StatelessVanillaChronicleAppenderTest.java | 398 ++++++ .../tcp/StatelessVanillaChronicleTailerTest.java | 562 +++++++++ .../net/openhft/chronicle/tcp/WithMappedTest.java | 736 +++++++++++ chronicle/src/test/resources/ftse-prices.csv | 130 ++ docs/FAQ.md | 54 +- docs/HowItWorks.md | 26 +- {chronicle-sandbox => docs}/VanillaChronicle.md | 2 - pom.xml | 45 +- 292 files changed, 33231 insertions(+), 8488 deletions(-) -- Alioth's /usr/local/bin/git-commit-notice on /srv/git.debian.org/git/pkg-java/openhft-chronicle-queue.git _______________________________________________ pkg-java-commits mailing list [email protected] http://lists.alioth.debian.org/cgi-bin/mailman/listinfo/pkg-java-commits
