add the size of magic string

apache · May 30, 2024 · ba2b184 · ba2b184
1 parent dbc130e
commit ba2b184
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 1 deletion.
diff --git a/...datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/wal/io/LogWriter.java b/...datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/wal/io/LogWriter.java
@@ -61,6 +61,7 @@ protected LogWriter(File logFile) throws IOException {
     this.logChannel = this.logStream.getChannel();
     if (!logFile.exists() || logFile.length() == 0) {
       this.logChannel.write(ByteBuffer.wrap(WALWriter.MAGIC_STRING.getBytes()));
+      size += logChannel.position();
     }
     if (compressionAlg != CompressionType.UNCOMPRESSED) {
       compressedByteBuffer =

diff --git a/...ode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/wal/io/WALInputStream.java b/...ode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/wal/io/WALInputStream.java
@@ -260,9 +260,10 @@ public void skipToGivenPosition(long pos) throws IOException {
       }
       dataBuffer = ByteBuffer.allocate(currSegmentSize);
       channel.read(dataBuffer);
+      dataBuffer.flip();
       dataBuffer.position((int) posRemain);
     } else {
-      dataBuffer.clear();
+      dataBuffer = null;
       channel.position(pos);
     }
   }

diff --git a/...datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/wal/io/WALWriter.java b/...datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/wal/io/WALWriter.java
@@ -75,6 +75,7 @@ private void endFile() throws IOException {
     buffer.putInt(metaDataSize);
     // add magic string
     buffer.put(MAGIC_STRING.getBytes());
+    size += buffer.position();
     writeMetadata(buffer);
   }