Commit 2d568e1
authored
2 files changed
+3
-3
lines changed| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
21 | 21 | | |
22 | 22 | | |
23 | 23 | | |
24 | | - | |
25 | | - | |
| 24 | + | |
| 25 | + | |
26 | 26 | | |
27 | 27 | | |
28 | 28 | | |
| |||
- build.gradle+4
- client/src/main/java/io/pravega/client/batch/impl/SegmentIteratorImpl.java+27-8
- client/src/main/java/io/pravega/client/netty/impl/ClientConnectionImpl.java+19-9
- client/src/main/java/io/pravega/client/netty/impl/FlowHandler.java+35-11
- client/src/main/java/io/pravega/client/segment/impl/SegmentOutputStreamImpl.java+22-16
- client/src/main/java/io/pravega/client/stream/impl/CheckpointState.java+37-7
- client/src/main/java/io/pravega/client/stream/impl/ControllerImpl.java+2-2
- client/src/main/java/io/pravega/client/stream/impl/EventStreamReaderImpl.java+25-16
- client/src/main/java/io/pravega/client/stream/impl/Orderer.java+1-1
- client/src/main/java/io/pravega/client/stream/impl/PositionImpl.java+22-6
- client/src/test/java/io/pravega/client/batch/impl/SegmentIteratorTest.java+25
- client/src/test/java/io/pravega/client/netty/impl/ClientConnectionTest.java+24-2
- client/src/test/java/io/pravega/client/netty/impl/ConnectionPoolingTest.java+3-2
- client/src/test/java/io/pravega/client/netty/impl/FlowHandlerTest.java+57-3
- client/src/test/java/io/pravega/client/stream/impl/EventStreamReaderTest.java+39
- client/src/test/java/io/pravega/client/stream/impl/SerializationTest.java+116-4
- client/src/test/resources/logback-test.xml+1-1
- client/src/test/resources/logback.xml+1-1
- common/src/main/java/io/pravega/common/ExponentialMovingAverage.java+8-8
- common/src/main/java/io/pravega/common/TimeoutTimer.java+10-1
- common/src/main/java/io/pravega/common/util/ReusableLatch.java+10-1
- common/src/test/java/io/pravega/common/TimeoutTimerTest.java+3-3
- common/src/test/java/io/pravega/common/util/ReusableLatchTests.java+2
- config/logback.xml+1-1
- controller/src/conf/logback.xml+1-1
- controller/src/main/java/io/pravega/controller/server/ControllerService.java+24-2
- controller/src/main/java/io/pravega/controller/server/eventProcessor/requesthandlers/CommitRequestHandler.java+1-1
- controller/src/main/java/io/pravega/controller/store/stream/PravegaTablesStoreHelper.java+27-10
- controller/src/test/java/io/pravega/controller/server/v1/ControllerServiceTest.java+50-2
- controller/src/test/java/io/pravega/controller/store/stream/PravegaTablesStoreHelperTest.java+55-2
- controller/src/test/java/io/pravega/controller/store/stream/StreamMetadataStoreTest.java+1-1
- controller/src/test/resources/logback.xml+1-1
- dist/conf/logback.xml+1-1
- docker/pravega/scripts/common.sh+9
- docker/pravega/scripts/init_tier2.sh+1
- gradle.properties+4-4
- gradle/java.gradle+9
- segmentstore/server/host/src/config/logback.xml+1-1
- segmentstore/server/host/src/test/java/io/pravega/segmentstore/server/host/handler/AppendProcessorTest.java+3-1
- segmentstore/server/src/main/java/io/pravega/segmentstore/server/CacheManager.java+58-53
- segmentstore/server/src/main/java/io/pravega/segmentstore/server/SegmentStoreMetrics.java+17-10
- segmentstore/server/src/main/java/io/pravega/segmentstore/server/logs/DurableLog.java+4-2
- segmentstore/server/src/main/java/io/pravega/segmentstore/server/logs/Throttler.java+11-2
- segmentstore/server/src/main/java/io/pravega/segmentstore/server/reading/StreamSegmentReadIndex.java+11-3
- segmentstore/server/src/main/java/io/pravega/segmentstore/server/writer/SegmentAggregator.java+16-18
- segmentstore/server/src/main/java/io/pravega/segmentstore/server/writer/StorageWriter.java+3-1
- segmentstore/server/src/test/java/io/pravega/segmentstore/server/CacheManagerTests.java+2-4
- segmentstore/server/src/test/java/io/pravega/segmentstore/server/SegmentStoreMetricsTests.java+24-1
- segmentstore/server/src/test/java/io/pravega/segmentstore/server/logs/ThrottlerTests.java+155-6
- segmentstore/server/src/test/java/io/pravega/segmentstore/server/reading/ContainerReadIndexTests.java+110-4
- segmentstore/server/src/test/java/io/pravega/segmentstore/server/writer/SegmentAggregatorTests.java+40-6
- segmentstore/server/src/test/java/io/pravega/segmentstore/server/writer/StorageWriterTests.java+39
- segmentstore/server/src/test/java/io/pravega/segmentstore/server/writer/TestWriterDataSource.java+6-1
- segmentstore/storage/impl/src/main/java/io/pravega/segmentstore/storage/impl/bookkeeper/BookKeeperLog.java+82-23
- segmentstore/storage/impl/src/main/java/io/pravega/segmentstore/storage/impl/bookkeeper/DebugLogWrapper.java+127-6
- segmentstore/storage/impl/src/main/java/io/pravega/segmentstore/storage/impl/bookkeeper/LedgerMetadata.java+2
- segmentstore/storage/impl/src/main/java/io/pravega/segmentstore/storage/impl/bookkeeper/Ledgers.java+67-2
- segmentstore/storage/impl/src/main/java/io/pravega/segmentstore/storage/impl/bookkeeper/LogMetadata.java+9-4
- segmentstore/storage/impl/src/main/java/io/pravega/segmentstore/storage/impl/bookkeeper/LogReader.java+13-1
- segmentstore/storage/impl/src/main/java/io/pravega/segmentstore/storage/impl/bookkeeper/ReadOnlyLogMetadata.java+31
- segmentstore/storage/impl/src/test/java/io/pravega/segmentstore/storage/impl/bookkeeper/BookKeeperLogTests.java+405-2
- segmentstore/storage/impl/src/test/java/io/pravega/segmentstore/storage/impl/bookkeeper/LogMetadataTests.java+47
- segmentstore/storage/impl/src/test/resources/logback.xml+1-1
- segmentstore/storage/src/main/java/io/pravega/segmentstore/storage/DataLogCorruptedException.java+21
- segmentstore/storage/src/main/java/io/pravega/segmentstore/storage/cache/CacheStorage.java+4-3
- segmentstore/storage/src/main/java/io/pravega/segmentstore/storage/cache/DirectMemoryCache.java+18-6
- segmentstore/storage/src/main/java/io/pravega/segmentstore/storage/cache/NoOpCache.java+1-1
- segmentstore/storage/src/test/java/io/pravega/segmentstore/storage/cache/DirectMemoryCacheTests.java+5-4
- segmentstore/storage/src/test/java/io/pravega/segmentstore/storage/noop/NoOpStorageUserDataWriteOnlyTests.java+2
- segmentstore/storage/src/test/resources/logback.xml+1-1
- shared/metrics/src/main/java/io/pravega/shared/MetricsTags.java+11
- shared/metrics/src/test/java/io/pravega/shared/MetricsTagsTest.java+10-8
- shared/protocol/src/main/java/io/pravega/shared/protocol/netty/CommandEncoder.java+3-3
- shared/protocol/src/main/java/io/pravega/shared/protocol/netty/FlushingMessageToByteEncoder.java+3-1
- shared/protocol/src/test/java/io/pravega/shared/protocol/netty/AppendEncodeDecodeTest.java+15-14
- shared/protocol/src/test/java/io/pravega/shared/protocol/netty/CommandEncoderTest.java+1-1
- test/integration/src/main/resources/logback-test.xml+1-1
- test/integration/src/test/java/io/pravega/test/integration/AppendTest.java+64-2
- test/integration/src/test/resources/logback.xml+1-1
- test/system/src/test/resources/logback-test.xml+1-1
- test/testcommon/src/main/java/io/pravega/test/common/LeakDetectorTestSuite.java+298
0 commit comments