# HG changeset patch # User Dan Creswell # Date 1246807438 -3600 # Node ID cd96fcac14871ff7a3da31691c0f8ceba53ed863 # Parent 872076165de44f3759c738328626ba467d985598 Add support for nano-second batch windows. diff -r 872076165de4 -r cd96fcac1487 src/org/dancres/blitz/config/Persistent.java --- 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; } }