Update of /cvsroot/cweb/bigdata/src/java/com/bigdata/journal
In directory sc8-pr-cvs4.sourceforge.net:/tmp/cvs-serv23960/src/java/com/bigdata/journal
Modified Files:
AbstractBufferStrategy.java TemporaryRawStore.java
Journal.java
Log Message:
Refactoring to introduce asynchronous handling of overflow events in support of a scale-up/scale-out design.
Index: TemporaryRawStore.java
===================================================================
RCS file: /cvsroot/cweb/bigdata/src/java/com/bigdata/journal/TemporaryRawStore.java,v
retrieving revision 1.2
retrieving revision 1.3
diff -C2 -d -r1.2 -r1.3
*** TemporaryRawStore.java 22 Feb 2007 16:59:34 -0000 1.2
--- TemporaryRawStore.java 6 Mar 2007 20:38:06 -0000 1.3
***************
*** 195,198 ****
--- 195,204 ----
}
+ public long size() {
+
+ return buf.size();
+
+ }
+
public boolean isOpen() {
Index: AbstractBufferStrategy.java
===================================================================
RCS file: /cvsroot/cweb/bigdata/src/java/com/bigdata/journal/AbstractBufferStrategy.java,v
retrieving revision 1.11
retrieving revision 1.12
diff -C2 -d -r1.11 -r1.12
*** AbstractBufferStrategy.java 21 Feb 2007 20:17:21 -0000 1.11
--- AbstractBufferStrategy.java 6 Mar 2007 20:38:06 -0000 1.12
***************
*** 104,107 ****
--- 104,113 ----
}
+
+ public final long size() {
+
+ return (long)nextOffset;
+
+ }
/**
Index: Journal.java
===================================================================
RCS file: /cvsroot/cweb/bigdata/src/java/com/bigdata/journal/Journal.java,v
retrieving revision 1.57
retrieving revision 1.58
diff -C2 -d -r1.57 -r1.58
*** Journal.java 28 Feb 2007 13:59:10 -0000 1.57
--- Journal.java 6 Mar 2007 20:38:06 -0000 1.58
***************
*** 1107,1110 ****
--- 1107,1116 ----
}
+ public long size() {
+
+ return _bufferStrategy.size();
+
+ }
+
public long write(ByteBuffer data) {
|
