From e0366a345f3b68f1c5f10838a734264553b989cb Mon Sep 17 00:00:00 2001
From: Ashish Bhatia <ashishb@ashishb.net>
Date: Mon, 13 Feb 2023 22:37:24 -0800
Subject: [PATCH] Add buffering to file read/write process

---
 cache/src/main/java/com/tomclaw/cache/Journal.java | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)

diff --git a/cache/src/main/java/com/tomclaw/cache/Journal.java b/cache/src/main/java/com/tomclaw/cache/Journal.java
index 6c38839..8234fd1 100644
--- a/cache/src/main/java/com/tomclaw/cache/Journal.java
+++ b/cache/src/main/java/com/tomclaw/cache/Journal.java
@@ -1,5 +1,7 @@
 package com.tomclaw.cache;
 
+import java.io.BufferedInputStream;
+import java.io.BufferedOutputStream;
 import java.io.DataInputStream;
 import java.io.DataOutputStream;
 import java.io.File;
@@ -105,7 +107,7 @@ private void setTotalSize(long totalSize) {
 
     public void writeJournal() {
         try (FileOutputStream fileStream = new FileOutputStream(file)) {
-            try (DataOutputStream stream = new DataOutputStream(fileStream)) {
+            try (DataOutputStream stream = new DataOutputStream(new BufferedOutputStream(fileStream))) {
                 stream.writeShort(JOURNAL_FORMAT_VERSION);
                 stream.writeInt(map.size());
                 for (Record record : map.values()) {
@@ -126,7 +128,7 @@ public static Journal readJournal(FileManager fileManager, Logger logger) {
         logger.log("[.] Start journal reading", file.getName());
         Journal journal = new Journal(file, fileManager, logger);
         try (FileInputStream fileStream = new FileInputStream(file)) {
-            try (DataInputStream stream = new DataInputStream(fileStream)) {
+            try (DataInputStream stream = new DataInputStream(new BufferedInputStream(fileStream))) {
                 int version = stream.readShort();
                 if (version != JOURNAL_FORMAT_VERSION) {
                     throw new IllegalArgumentException("Invalid journal format version");