Mercurial > hg > blitz_stable
changeset 16:cd96fcac1487
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; } }