Merge pull request #5 from ashishb/patch-1

Add buffering to file read/write process

Author: solkin

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");