Mercurial > hg > blitz_stable
comparison src/org/dancres/blitz/txn/PersistentPersonality.java @ 33:a77f0a9ed93c 2.1.1
Add support for optimistic log batching.
author | Dan Creswell <dan.creswell@gmail.com> |
---|---|
date | Sat, 12 Jun 2010 10:42:31 +0100 |
parents | 4580bb12db30 |
children |
comparison
equal
deleted
inserted
replaced
32:243c74d599bf | 33:a77f0a9ed93c |
---|---|
32 TxnManager.theLogger.log(Level.INFO, "Reset log stream: " + | 32 TxnManager.theLogger.log(Level.INFO, "Reset log stream: " + |
33 theModel.shouldResetLogStream()); | 33 theModel.shouldResetLogStream()); |
34 TxnManager.theLogger.log(Level.INFO, "Write barrier window: " + | 34 TxnManager.theLogger.log(Level.INFO, "Write barrier window: " + |
35 theModel.getBatchWriteWindowSizeMs() + ", " + theModel.getBatchWriteWindowSizeNs()); | 35 theModel.getBatchWriteWindowSizeMs() + ", " + theModel.getBatchWriteWindowSizeNs()); |
36 | 36 |
37 if (theModel.useConcurrentWriteBatcher()) | 37 if (!theModel.dontUseExperimentalBatcher()) |
38 TxnManager.theLogger.log(Level.INFO, | 38 TxnManager.theLogger.log(Level.INFO, |
39 "*** Concurrent batching enabled ***"); | 39 "*** Experimental batcher enabled ***"); |
40 | 40 |
41 if (theModel.shouldCleanLogs()) { | 41 if (theModel.shouldCleanLogs()) { |
42 TxnManager.theLogger.log(Level.WARNING, | 42 TxnManager.theLogger.log(Level.WARNING, |
43 "*** Automatically cleaning logs *** [EXPERIMENTAL]"); | 43 "*** Automatically cleaning logs *** [EXPERIMENTAL]"); |
44 } | 44 } |
68 if ((theModel.getBatchWriteWindowSizeMs() != 0) || | 68 if ((theModel.getBatchWriteWindowSizeMs() != 0) || |
69 (theModel.getBatchWriteWindowSizeNs() != 0)) { | 69 (theModel.getBatchWriteWindowSizeNs() != 0)) { |
70 long myWindowSizeMs = theModel.getBatchWriteWindowSizeMs(); | 70 long myWindowSizeMs = theModel.getBatchWriteWindowSizeMs(); |
71 int myWindowSizeNs = theModel.getBatchWriteWindowSizeNs(); | 71 int myWindowSizeNs = theModel.getBatchWriteWindowSizeNs(); |
72 | 72 |
73 if (theModel.useConcurrentWriteBatcher()) { | 73 if (theModel.dontUseExperimentalBatcher()) { |
74 return new ConcurrentWriteBatcher(myPrevayler, myWindowSizeMs, myWindowSizeNs); | 74 return new ConcurrentWriteBatcher(myPrevayler, myWindowSizeMs, myWindowSizeNs); |
75 } else { | 75 } else { |
76 return new WriteBatcher(myPrevayler, myWindowSizeMs, myWindowSizeNs); | 76 return new OptimisticBatcher(myPrevayler); |
77 } | 77 } |
78 } else | 78 } else |
79 return new NullBatcher(myPrevayler); | 79 return new NullBatcher(myPrevayler); |
80 } | 80 } |
81 | 81 |