From: Bryan T. <tho...@us...> - 2007-03-06 20:38:16
|
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; + + } + } |