versionedcodecstreamwwrapper to not write/read header/footer

opensearch-project · Mar 28, 2023 · 55ef13d · 55ef13d
1 parent dc9ab0d
commit 55ef13d
Showing 1 changed file with 5 additions and 5 deletions.
diff --git a/server/src/main/java/org/opensearch/common/io/VersionedCodecStreamWrapper.java b/server/src/main/java/org/opensearch/common/io/VersionedCodecStreamWrapper.java
@@ -48,9 +48,9 @@ public VersionedCodecStreamWrapper(IndexIOStreamHandler<T> indexIOStreamHandler,
      */
     public T readStream(IndexInput indexInput) throws IOException {
         ChecksumIndexInput checksumIndexInput = new BufferedChecksumIndexInput(indexInput);
-        int readStreamVersion = checkHeader(checksumIndexInput);
-        T content = getHandlerForVersion(readStreamVersion).readContent(checksumIndexInput);
-        checkFooter(checksumIndexInput);
+//        int readStreamVersion = checkHeader(checksumIndexInput);
+        T content = getHandlerForVersion(1).readContent(indexInput);
+//        checkFooter(checksumIndexInput);
         return content;
     }
 
@@ -60,9 +60,9 @@ public T readStream(IndexInput indexInput) throws IOException {
      * @param content stream content.
      */
     public void writeStream(IndexOutput indexOutput, T content) throws IOException {
-        this.writeHeader(indexOutput);
+//        this.writeHeader(indexOutput);
         getHandlerForVersion(this.currentVersion).writeContent(indexOutput, content);
-        this.writeFooter(indexOutput);
+//        this.writeFooter(indexOutput);
     }
 
     /**