* 为事务日志模块增加实时刷新支持

bytejta-core/src/main/java/org/bytesoft/bytejta/logging/store/VirtualLoggingSystemImpl.java

@@ -53,6 +53,8 @@ public abstract class VirtualLoggingSystemImpl implements VirtualLoggingSystem,
 	private VirtualLoggingFile master;
 	private VirtualLoggingFile slaver;
 
+	private boolean optimized = true;
+
 	public void construct() throws IOException {
 		if (this.directory == null) {
 			this.directory = this.getDefaultDirectory();
@@ -73,6 +75,8 @@ public void construct() throws IOException {
 		slaverMgr.initialize(false);
 
 		this.initialize(masterMgr, slaverMgr);
+
+		this.flushAllIfNecessary();
 	}
 
 	private void initialize(VirtualLoggingFile prev, VirtualLoggingFile next) {
@@ -96,6 +100,7 @@ private void initialize(VirtualLoggingFile prev, VirtualLoggingFile next) {
 			this.master.clearMarkedFlag();
 			this.slaver.clearMarkedFlag();
 		}
+
 	}
 
 	private void fixSwitchError(VirtualLoggingFile prev, VirtualLoggingFile next) {
@@ -192,6 +197,8 @@ public void create(Xid xid, byte[] textByteArray) {
 		try {
 			this.lock.lock();
 			this.master.write(byteArray);
+
+			this.flushMasterIfNecessary();
 		} finally {
 			this.lock.unlock();
 		}
@@ -210,6 +217,8 @@ public void delete(Xid xid) {
 		try {
 			this.lock.lock();
 			this.master.write(byteArray);
+
+			this.flushMasterIfNecessary();
 		} finally {
 			this.lock.unlock();
 		}
@@ -229,6 +238,8 @@ public void modify(Xid xid, byte[] textByteArray) {
 		try {
 			this.lock.lock();
 			this.master.write(byteArray);
+
+			this.flushMasterIfNecessary();
 		} finally {
 			this.lock.unlock();
 		}
@@ -239,6 +250,8 @@ public void syncMasterAndSlaver() {
 		Map<Xid, Boolean> recordMap = this.syncStepOne();
 		this.master.prepareForReading();
 		this.syncStepTwo(recordMap);
+
+		this.flushSlaverIfNecessary();
 	}
 
 	public Map<Xid, Boolean> syncStepOne() {
@@ -329,6 +342,8 @@ public void swapMasterAndSlaver() {
 			this.master.switchToSlaver();
 			this.slaver.switchToMaster();
 
+			this.flushAllIfNecessary();
+
 			VirtualLoggingFile theNextMaster = this.slaver;
 			this.slaver = this.master;
 			this.master = theNextMaster;
@@ -338,6 +353,23 @@ public void swapMasterAndSlaver() {
 		}
 	}
 
+	private void flushAllIfNecessary() {
+		this.flushMasterIfNecessary();
+		this.flushSlaverIfNecessary();
+	}
+
+	private void flushMasterIfNecessary() {
+		if (this.optimized == false) {
+			this.master.flushImmediately();
+		}
+	}
+
+	private void flushSlaverIfNecessary() {
+		if (this.optimized == false) {
+			this.slaver.flushImmediately();
+		}
+	}
+
 	public void flushImmediately() {
 		this.master.flushImmediately();
 	}
@@ -367,6 +399,14 @@ public VirtualLoggingFile createTransactionLogging(File file) throws IOException
 		return logging;
 	}
 
+	public boolean isOptimized() {
+		return optimized;
+	}
+
+	public void setOptimized(boolean optimized) {
+		this.optimized = optimized;
+	}
+
 	public File getDirectory() {
 		return directory;
 	}