Update of /cvsroot/cweb/bigdata/src/java/com/bigdata/rawstore
In directory sc8-pr-cvs4.sourceforge.net:/tmp/cvs-serv23960/src/java/com/bigdata/rawstore
Modified Files:
SimpleMemoryRawStore.java SimpleFileRawStore.java
IRawStore.java
Log Message:
Refactoring to introduce asynchronous handling of overflow events in support of a scale-up/scale-out design.
Index: SimpleFileRawStore.java
===================================================================
RCS file: /cvsroot/cweb/bigdata/src/java/com/bigdata/rawstore/SimpleFileRawStore.java,v
retrieving revision 1.5
retrieving revision 1.6
diff -C2 -d -r1.5 -r1.6
*** SimpleFileRawStore.java 22 Feb 2007 16:59:35 -0000 1.5
--- SimpleFileRawStore.java 6 Mar 2007 20:38:05 -0000 1.6
***************
*** 329,332 ****
--- 329,346 ----
}
+
+ public long size() {
+
+ try {
+
+ return raf.length();
+
+ } catch(IOException ex) {
+
+ throw new RuntimeException(ex);
+
+ }
+
+ }
}
Index: IRawStore.java
===================================================================
RCS file: /cvsroot/cweb/bigdata/src/java/com/bigdata/rawstore/IRawStore.java,v
retrieving revision 1.5
retrieving revision 1.6
diff -C2 -d -r1.5 -r1.6
*** IRawStore.java 22 Feb 2007 16:59:35 -0000 1.5
--- IRawStore.java 6 Mar 2007 20:38:05 -0000 1.6
***************
*** 258,260 ****
--- 258,266 ----
public void force(boolean metadata);
+ /**
+ * The #of application data bytes written on the store (does not count any
+ * headers or root blocks that may exist for the store).
+ */
+ public long size();
+
}
Index: SimpleMemoryRawStore.java
===================================================================
RCS file: /cvsroot/cweb/bigdata/src/java/com/bigdata/rawstore/SimpleMemoryRawStore.java,v
retrieving revision 1.4
retrieving revision 1.5
diff -C2 -d -r1.4 -r1.5
*** SimpleMemoryRawStore.java 22 Feb 2007 16:59:35 -0000 1.4
--- SimpleMemoryRawStore.java 6 Mar 2007 20:38:05 -0000 1.5
***************
*** 294,296 ****
--- 294,302 ----
}
+ public long size() {
+
+ return nextOffset;
+
+ }
+
}
|
