changeset 1481:3cff066f3bbc

output buffering
author Franklin Schmidt <fschmidt@gmail.com>
date Fri, 24 Apr 2020 15:57:30 -0600
parents 1f41e5921090
children 4c409291090f
files src/goodjava/lucene/logging/LogFile.java
diffstat 1 files changed, 15 insertions(+), 15 deletions(-) [+]
line wrap: on
line diff
diff -r 1f41e5921090 -r 3cff066f3bbc src/goodjava/lucene/logging/LogFile.java
--- a/src/goodjava/lucene/logging/LogFile.java	Fri Apr 24 14:32:20 2020 -0600
+++ b/src/goodjava/lucene/logging/LogFile.java	Fri Apr 24 15:57:30 2020 -0600
@@ -2,11 +2,12 @@
 
 import java.io.File;
 import java.io.InputStream;
-import java.io.DataOutput;
+import java.io.OutputStream;
+import java.io.BufferedOutputStream;
 import java.io.DataOutputStream;
 import java.io.RandomAccessFile;
-import java.io.ByteArrayOutputStream;
 import java.io.FileInputStream;
+import java.io.FileOutputStream;
 import java.io.IOException;
 import java.util.List;
 import java.util.Map;
@@ -32,14 +33,15 @@
 	private static final Logger logger = LoggerFactory.getLogger(LogFile.class);
 	public final File file;
 	private final RandomAccessFile raf;
-	private ByteArrayOutputStream baos = new ByteArrayOutputStream();
-	private DataOutput out;
+	private final DataOutputStream out;
 	private long end;
 
 	public LogFile(File file,String mode) throws IOException {
 		this.file = file;
 		this.raf = new RandomAccessFile(file,mode);
-		this.out = new DataOutputStream(baos);
+		OutputStream out = new FileOutputStream(raf.getFD());
+		out = new BufferedOutputStream(out);
+		this.out = new DataOutputStream(out);
 		init();
 	}
 
@@ -61,6 +63,10 @@
 		this.end = lf.end;
 	}
 
+	public void close() throws IOException {
+		raf.close();
+	}
+
 	public LogFile snapshot() throws IOException {
 		return new LogFile(this);
 	}
@@ -87,22 +93,16 @@
 	}
 
 	public void commit() throws IOException {
-		raf.seek(end);
-		raf.write(baos.toByteArray());
-		//logger.info("size "+baos.size());
-		if( baos.size() < 10000 ) {
-			baos.reset();
-		} else {
-			baos = new ByteArrayOutputStream();
-			out = new DataOutputStream(baos);
-		}
+		out.flush();
 		end = raf.getFilePointer();
 		raf.seek(0L);
 		raf.writeLong(end);
+		raf.seek(end);
 	}
 
 	public void rollback() throws IOException {
-		baos.reset();
+		out.flush();
+		raf.seek(end);
 	}
 
 	static final int TYPE_NULL = 0;