From: Bryan T. <tho...@us...> - 2007-02-21 20:17:34
|
Update of /cvsroot/cweb/bigdata/src/java/com/bigdata/scaleup In directory sc8-pr-cvs4.sourceforge.net:/tmp/cvs-serv5461/src/java/com/bigdata/scaleup Modified Files: PartitionedJournal.java Log Message: Further work supporting transactional isolation. Index: PartitionedJournal.java =================================================================== RCS file: /cvsroot/cweb/bigdata/src/java/com/bigdata/scaleup/PartitionedJournal.java,v retrieving revision 1.8 retrieving revision 1.9 diff -C2 -d -r1.8 -r1.9 *** PartitionedJournal.java 17 Feb 2007 21:34:21 -0000 1.8 --- PartitionedJournal.java 21 Feb 2007 20:17:22 -0000 1.9 *************** *** 1153,1162 **** } public boolean isStable() { return slave.isStable(); } ! public ByteBuffer read(long addr, ByteBuffer dst) { ! return slave.read(addr, dst); } --- 1153,1174 ---- } + /** + * A partitioned journal always reports and does not allow the use + * of non-stable backing stored for the {@link SlaveJournal}. + */ public boolean isStable() { return slave.isStable(); } ! /** ! * true iff the {@link SlaveJournal} is fully buffered (this does not ! * consider the index segments). ! */ ! public boolean isFullyBuffered() { ! return slave.isFullyBuffered(); ! } ! ! public ByteBuffer read(long addr) { ! return slave.read(addr); } *************** *** 1201,1203 **** --- 1213,1239 ---- } + public void abort(long ts) { + slave.abort(ts); + } + + public long commit(long ts) { + return slave.commit(ts); + } + + public IIndex getIndex(String name, long ts) { + return slave.getIndex(name, ts); + } + + public long newReadCommittedTx() { + return slave.newReadCommittedTx(); + } + + public long newTx() { + return slave.newTx(); + } + + public long newTx(boolean readOnly) { + return slave.newTx(readOnly); + } + } |