[openhft-chronicle-queue] 06/16: Merge tag 'upstream/3.6.0'
Emmanuel Bourg
ebourg-guest at moszumanska.debian.org
Wed Aug 3 10:21:56 UTC 2016
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 <ebourg at apache.org>
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
More information about the pkg-java-commits
mailing list