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);
+ }
+
}
|