[cweb-CVS] bigdata/src/java/com/bigdata/journal AbstractBufferStrategy.java, 1.11, 1.12 TemporaryRawStore.java, 1.2, 1.3 Journal.java, 1.57, 1.58

[Bryan T. <tho...@us...>]

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) {