X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=atomix-storage%2Fsrc%2Fmain%2Fjava%2Fio%2Fatomix%2Fstorage%2Fjournal%2FDiskJournalSegmentWriter.java;h=54feee1adaacd07680c8b2b569bb71bb4f4ccbf5;hb=08d6b66f08fd997ab92e97e86d18059480eb693b;hp=266320127b214056942380d9d5f9a73437242557;hpb=0324432d000896c3f27c7be4e1863231bd50cadc;p=controller.git
diff --git a/atomix-storage/src/main/java/io/atomix/storage/journal/DiskJournalSegmentWriter.java b/atomix-storage/src/main/java/io/atomix/storage/journal/DiskJournalSegmentWriter.java
index 266320127b..54feee1ada 100644
--- a/atomix-storage/src/main/java/io/atomix/storage/journal/DiskJournalSegmentWriter.java
+++ b/atomix-storage/src/main/java/io/atomix/storage/journal/DiskJournalSegmentWriter.java
@@ -39,28 +39,28 @@ import java.nio.channels.FileChannel;
*
* @author Jordan Halterman
*/
-final class DiskJournalSegmentWriter extends JournalSegmentWriter {
+final class DiskJournalSegmentWriter extends JournalSegmentWriter {
private static final ByteBuffer ZERO_ENTRY_HEADER = ByteBuffer.wrap(new byte[HEADER_BYTES]);
- private final JournalSegmentReader reader;
+ private final JournalSegmentReader reader;
private final ByteBuffer buffer;
- DiskJournalSegmentWriter(final FileChannel channel, final JournalSegment segment, final int maxEntrySize,
- final JournalIndex index, final JournalSerdes namespace) {
- super(channel, segment, maxEntrySize, index, namespace);
+ DiskJournalSegmentWriter(final FileChannel channel, final JournalSegment segment, final int maxEntrySize,
+ final JournalIndex index) {
+ super(channel, segment, maxEntrySize, index);
buffer = DiskFileReader.allocateBuffer(maxSegmentSize, maxEntrySize);
- reader = new JournalSegmentReader<>(segment,
- new DiskFileReader(segment.file().file().toPath(), channel, buffer), maxEntrySize, namespace);
+ reader = new JournalSegmentReader(segment,
+ new DiskFileReader(segment.file().file().toPath(), channel, buffer), maxEntrySize);
reset(0);
}
- DiskJournalSegmentWriter(final JournalSegmentWriter previous) {
+ DiskJournalSegmentWriter(final JournalSegmentWriter previous) {
super(previous);
buffer = DiskFileReader.allocateBuffer(maxSegmentSize, maxEntrySize);
- reader = new JournalSegmentReader<>(segment,
- new DiskFileReader(segment.file().file().toPath(), channel, buffer), maxEntrySize, namespace);
+ reader = new JournalSegmentReader(segment,
+ new DiskFileReader(segment.file().file().toPath(), channel, buffer), maxEntrySize);
}
@Override
@@ -69,17 +69,17 @@ final class DiskJournalSegmentWriter extends JournalSegmentWriter {
}
@Override
- MappedJournalSegmentWriter toMapped() {
- return new MappedJournalSegmentWriter<>(this);
+ MappedJournalSegmentWriter toMapped() {
+ return new MappedJournalSegmentWriter(this);
}
@Override
- DiskJournalSegmentWriter toFileChannel() {
+ DiskJournalSegmentWriter toFileChannel() {
return this;
}
@Override
- JournalSegmentReader reader() {
+ JournalSegmentReader reader() {
return reader;
}