Mercurial > hg > blitz_condensed

changeset 15:cd96fcac1487

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
Add support for nano-second batch windows.
author Dan Creswell <dan.creswell@gmail.com>
date Sun, 05 Jul 2009 16:23:58 +0100
parents 872076165de4
children 46ac1a45718a
files src/org/dancres/blitz/config/Persistent.java
diffstat 1 files changed, 19 insertions(+), 4 deletions(-) [+]
line wrap: on
line diff
--- a/src/org/dancres/blitz/config/Persistent.java	Sun Jul 05 16:20:46 2009 +0100
+++ b/src/org/dancres/blitz/config/Persistent.java	Sun Jul 05 16:23:58 2009 +0100
@@ -9,7 +9,8 @@
 public class Persistent extends PersistentBase {
 
     private boolean useConcurrentBatcher;
-    private int theBatchWriteWindowSize;
+    private long theBatchWriteWindowSizeMs;
+    private int theBatchWriteWindowSizeNs;
 
     /**
        @param shouldReset specifies whether to reset the ObjectOutputStream
@@ -44,14 +45,28 @@
 
         super(shouldReset, shouldClean, aLogBufferSize, aMaxLogsBeforeSync);
         useConcurrentBatcher = useConcurrent;
-        theBatchWriteWindowSize = aBatchWriteWindowSize;
+        theBatchWriteWindowSizeMs = aBatchWriteWindowSize;
     }
 
     public boolean useConcurrentWriteBatcher() {
         return useConcurrentBatcher;
     }
 
-    public int getBatchWriteWindowSize() {
-        return theBatchWriteWindowSize;
+    public long getBatchWriteWindowSizeMs() {
+        return theBatchWriteWindowSizeMs;
+    }
+
+    public int getBatchWriteWindowSizeNs() {
+        return theBatchWriteWindowSizeNs;
+    }
+
+    public Persistent(boolean shouldReset, boolean shouldClean,
+                      long aBatchWindowSizeMs, int aBatchWindowSizeNs, boolean useConcurrent,
+                      int aMaxLogsBeforeSync, int aLogBufferSize) {
+
+        super(shouldReset, shouldClean, aLogBufferSize, aMaxLogsBeforeSync);
+        useConcurrentBatcher = useConcurrent;
+        theBatchWriteWindowSizeMs = aBatchWindowSizeMs;
+        theBatchWriteWindowSizeNs = aBatchWindowSizeNs;
     }
 }