Mercurial > hg > blitz_condensed

comparison src/org/dancres/blitz/txn/PersistentPersonality.java @ 32:a77f0a9ed93c 2.1.1

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
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
31:243c74d599bf 32: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