jena-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From a...@apache.org
Subject svn commit: r1137956 - in /incubator/jena/Experimental/TxTDB/trunk/src/main/java/com/hp/hpl/jena/tdb: base/block/ base/page/ base/recordbuffer/ index/bplustree/ index/ext/ transaction/
Date Tue, 21 Jun 2011 11:10:45 GMT
Author: andy
Date: Tue Jun 21 11:10:45 2011
New Revision: 1137956

URL: http://svn.apache.org/viewvc?rev=1137956&view=rev
Log: (empty)

Modified:
    incubator/jena/Experimental/TxTDB/trunk/src/main/java/com/hp/hpl/jena/tdb/base/block/Block.java
    incubator/jena/Experimental/TxTDB/trunk/src/main/java/com/hp/hpl/jena/tdb/base/page/PageBase.java
    incubator/jena/Experimental/TxTDB/trunk/src/main/java/com/hp/hpl/jena/tdb/base/recordbuffer/RecordBufferPage.java
    incubator/jena/Experimental/TxTDB/trunk/src/main/java/com/hp/hpl/jena/tdb/base/recordbuffer/RecordBufferPageBase.java
    incubator/jena/Experimental/TxTDB/trunk/src/main/java/com/hp/hpl/jena/tdb/base/recordbuffer/RecordBufferPageMgr.java
    incubator/jena/Experimental/TxTDB/trunk/src/main/java/com/hp/hpl/jena/tdb/index/bplustree/BPTreeRecords.java
    incubator/jena/Experimental/TxTDB/trunk/src/main/java/com/hp/hpl/jena/tdb/index/ext/HashBucket.java
    incubator/jena/Experimental/TxTDB/trunk/src/main/java/com/hp/hpl/jena/tdb/index/ext/HashBucketMgr.java
    incubator/jena/Experimental/TxTDB/trunk/src/main/java/com/hp/hpl/jena/tdb/transaction/BlockMgrJournal.java

Modified: incubator/jena/Experimental/TxTDB/trunk/src/main/java/com/hp/hpl/jena/tdb/base/block/Block.java
URL: http://svn.apache.org/viewvc/incubator/jena/Experimental/TxTDB/trunk/src/main/java/com/hp/hpl/jena/tdb/base/block/Block.java?rev=1137956&r1=1137955&r2=1137956&view=diff
==============================================================================
--- incubator/jena/Experimental/TxTDB/trunk/src/main/java/com/hp/hpl/jena/tdb/base/block/Block.java
(original)
+++ incubator/jena/Experimental/TxTDB/trunk/src/main/java/com/hp/hpl/jena/tdb/base/block/Block.java
Tue Jun 21 11:10:45 2011
@@ -120,11 +120,19 @@ public final class Block
     {
         ByteBuffer dstBlk = ByteBuffer.allocate(srcBlk.capacity()) ;
         
+        int x = srcBlk.position() ;
+        int y = srcBlk.limit() ;
+        srcBlk.clear() ;
+        
         if ( srcBlk.hasArray() && dstBlk.hasArray() )
             System.arraycopy(srcBlk.array(), 0, dstBlk.array(), 0, srcBlk.capacity()) ;
         else
             dstBlk.put(srcBlk) ;
-        dstBlk.clear() ;
+        
+        srcBlk.position(x);
+        dstBlk.position(x);
+        srcBlk.limit(y);
+        dstBlk.limit(y);
         return dstBlk ; 
     }  
 

Modified: incubator/jena/Experimental/TxTDB/trunk/src/main/java/com/hp/hpl/jena/tdb/base/page/PageBase.java
URL: http://svn.apache.org/viewvc/incubator/jena/Experimental/TxTDB/trunk/src/main/java/com/hp/hpl/jena/tdb/base/page/PageBase.java?rev=1137956&r1=1137955&r2=1137956&view=diff
==============================================================================
--- incubator/jena/Experimental/TxTDB/trunk/src/main/java/com/hp/hpl/jena/tdb/base/page/PageBase.java
(original)
+++ incubator/jena/Experimental/TxTDB/trunk/src/main/java/com/hp/hpl/jena/tdb/base/page/PageBase.java
Tue Jun 21 11:10:45 2011
@@ -7,6 +7,8 @@
 
 package com.hp.hpl.jena.tdb.base.page;
 
+import org.openjena.atlas.logging.Log ;
+
 import com.hp.hpl.jena.tdb.TDBException ;
 import com.hp.hpl.jena.tdb.base.block.Block ;
 
@@ -14,7 +16,7 @@ import com.hp.hpl.jena.tdb.base.block.Bl
 public abstract class PageBase implements Page
 {
     private final int id ;
-    private final Block block ;
+    private Block block ;
 
     protected PageBase(Block block)
     {
@@ -28,7 +30,15 @@ public abstract class PageBase implement
     }
     
     @Override
-    public abstract void reset(Block block) ;
+    final public void reset(Block block2)
+    { 
+        if ( block2.getId() != id )
+            Log.fatal(this, "Block id changed: "+id+" => "+block2.getId()) ;
+        _reset(block2) ; 
+        this.block = block2 ;
+    } 
+
+    protected abstract void _reset(Block block) ;
 
     @Override
     final public Block getBackingBlock()    { return block ; }

Modified: incubator/jena/Experimental/TxTDB/trunk/src/main/java/com/hp/hpl/jena/tdb/base/recordbuffer/RecordBufferPage.java
URL: http://svn.apache.org/viewvc/incubator/jena/Experimental/TxTDB/trunk/src/main/java/com/hp/hpl/jena/tdb/base/recordbuffer/RecordBufferPage.java?rev=1137956&r1=1137955&r2=1137956&view=diff
==============================================================================
--- incubator/jena/Experimental/TxTDB/trunk/src/main/java/com/hp/hpl/jena/tdb/base/recordbuffer/RecordBufferPage.java
(original)
+++ incubator/jena/Experimental/TxTDB/trunk/src/main/java/com/hp/hpl/jena/tdb/base/recordbuffer/RecordBufferPage.java
Tue Jun 21 11:10:45 2011
@@ -6,8 +6,6 @@
 
 package com.hp.hpl.jena.tdb.base.recordbuffer;
 
-import org.openjena.atlas.lib.NotImplemented ;
-
 import com.hp.hpl.jena.tdb.base.block.Block ;
 import com.hp.hpl.jena.tdb.base.page.Page ;
 import com.hp.hpl.jena.tdb.base.record.RecordFactory ;
@@ -44,8 +42,11 @@ public final class RecordBufferPage exte
     }
     
     @Override
-    public void reset(Block block)
-    { throw new NotImplemented("reset") ; }
+    protected void _reset(Block block)
+    { 
+        super.reset(block, this.getCount()) ;
+        this.link = block.getByteBuffer().getInt(LINK) ;
+    }
 
     public static int calcRecordSize(RecordFactory factory, int blkSize)
     { return RecordBufferPageBase.calcRecordSize(factory, blkSize, FIELD_LENGTH) ; }
@@ -53,14 +54,26 @@ public final class RecordBufferPage exte
     public static int calcBlockSize(RecordFactory factory, int maxRec)
     { return RecordBufferPageBase.calcBlockSize(factory, maxRec, FIELD_LENGTH) ; }
     
+    /** The construction methods */
+    public static RecordBufferPage createBlank(Block block,RecordFactory factory)
+    {
+        int count = 0 ;
+        int linkId = NO_ID ;
+        return new RecordBufferPage(block, factory, count, linkId) ;
+    }
+
+    public static RecordBufferPage format(Block block, RecordFactory factory)
+    {
+        int count = block.getByteBuffer().getInt(COUNT) ;
+        int linkId = block.getByteBuffer().getInt(LINK) ;
+        return new RecordBufferPage(block, factory, count, linkId) ;
+    } 
+        
     
-    /*public*/ RecordBufferPage(Block block, int linkId,
-                                RecordFactory factory, 
-                                int count)
+    private RecordBufferPage(Block block, RecordFactory factory, int count, int linkId) 

     {
         super(block, FIELD_LENGTH, factory, count) ;
         this.link = linkId ;
-        
     }
     
     @Override

Modified: incubator/jena/Experimental/TxTDB/trunk/src/main/java/com/hp/hpl/jena/tdb/base/recordbuffer/RecordBufferPageBase.java
URL: http://svn.apache.org/viewvc/incubator/jena/Experimental/TxTDB/trunk/src/main/java/com/hp/hpl/jena/tdb/base/recordbuffer/RecordBufferPageBase.java?rev=1137956&r1=1137955&r2=1137956&view=diff
==============================================================================
--- incubator/jena/Experimental/TxTDB/trunk/src/main/java/com/hp/hpl/jena/tdb/base/recordbuffer/RecordBufferPageBase.java
(original)
+++ incubator/jena/Experimental/TxTDB/trunk/src/main/java/com/hp/hpl/jena/tdb/base/recordbuffer/RecordBufferPageBase.java
Tue Jun 21 11:10:45 2011
@@ -34,6 +34,7 @@ public abstract class RecordBufferPageBa
 
     // Interface: "Page" - id, byteBuffer, count
     protected RecordBuffer recBuff ;
+    private final RecordFactory factory ;
     
     //private int offset ;                // Bytes of overhead.
     
@@ -55,12 +56,18 @@ public abstract class RecordBufferPageBa
     }
 
     protected RecordBufferPageBase(Block block, int offset, 
-                                   RecordFactory factory,
-                                   int count)
+                                   RecordFactory factory, int count)
     {   // This code knows the alignment of the records in the ByteBuffer.
         super(block) ;
         this.headerLength = FIELD_LENGTH+offset ;        // NB +4 for the count field
+        this.factory = factory ;
+        reset(block, count) ;
+    }
+    
+    protected void reset(Block block, int count)
+    {
         ByteBuffer bb = block.getByteBuffer() ;
+        bb.clear() ;
         bb.position(headerLength) ;
         bb = bb.slice();
         this.recBuff = new RecordBuffer(bb, factory, count) ;

Modified: incubator/jena/Experimental/TxTDB/trunk/src/main/java/com/hp/hpl/jena/tdb/base/recordbuffer/RecordBufferPageMgr.java
URL: http://svn.apache.org/viewvc/incubator/jena/Experimental/TxTDB/trunk/src/main/java/com/hp/hpl/jena/tdb/base/recordbuffer/RecordBufferPageMgr.java?rev=1137956&r1=1137955&r2=1137956&view=diff
==============================================================================
--- incubator/jena/Experimental/TxTDB/trunk/src/main/java/com/hp/hpl/jena/tdb/base/recordbuffer/RecordBufferPageMgr.java
(original)
+++ incubator/jena/Experimental/TxTDB/trunk/src/main/java/com/hp/hpl/jena/tdb/base/recordbuffer/RecordBufferPageMgr.java
Tue Jun 21 11:10:45 2011
@@ -59,18 +59,19 @@ public class RecordBufferPageMgr extends
             if ( blkType != BlockType.RECORD_BLOCK )
                 throw new RecordException("Not RECORD_BLOCK: "+blkType) ;
             // Initially empty
-            RecordBufferPage rb = new RecordBufferPage(block, NO_ID, factory, 0) ;
+            RecordBufferPage rb = RecordBufferPage.createBlank(block, factory) ;
             return rb ;
         }
 
         @Override
         public RecordBufferPage fromBlock(Block block)
         {
-            synchronized (block)
+            synchronized (block)    // [[TxTDB:TODO] needed? Right place?
             {
-                int count = block.getByteBuffer().getInt(COUNT) ;
-                int linkId = block.getByteBuffer().getInt(LINK) ;
-                RecordBufferPage rb = new RecordBufferPage(block, linkId, factory, count)
;
+                RecordBufferPage rb = RecordBufferPage.format(block, factory) ;
+//                int count = block.getByteBuffer().getInt(COUNT) ;
+//                int linkId = block.getByteBuffer().getInt(LINK) ;
+//                RecordBufferPage rb = new RecordBufferPage(block, linkId, factory, count)
;
                 return rb ;
             }
         }
@@ -79,7 +80,6 @@ public class RecordBufferPageMgr extends
         public Block toBlock(RecordBufferPage rbp)
         {
             int count = rbp.getRecordBuffer().size() ;
-            rbp.setCount(count) ;
             ByteBuffer bb = rbp.getBackingBlock().getByteBuffer() ;
             bb.putInt(COUNT, rbp.getCount()) ;
             bb.putInt(LINK, rbp.getLink()) ;

Modified: incubator/jena/Experimental/TxTDB/trunk/src/main/java/com/hp/hpl/jena/tdb/index/bplustree/BPTreeRecords.java
URL: http://svn.apache.org/viewvc/incubator/jena/Experimental/TxTDB/trunk/src/main/java/com/hp/hpl/jena/tdb/index/bplustree/BPTreeRecords.java?rev=1137956&r1=1137955&r2=1137956&view=diff
==============================================================================
--- incubator/jena/Experimental/TxTDB/trunk/src/main/java/com/hp/hpl/jena/tdb/index/bplustree/BPTreeRecords.java
(original)
+++ incubator/jena/Experimental/TxTDB/trunk/src/main/java/com/hp/hpl/jena/tdb/index/bplustree/BPTreeRecords.java
Tue Jun 21 11:10:45 2011
@@ -11,7 +11,6 @@ import static com.hp.hpl.jena.tdb.index.
 import static java.lang.String.format ;
 import static org.openjena.atlas.lib.Alg.decodeIndex ;
 import org.openjena.atlas.io.IndentedWriter ;
-import org.openjena.atlas.lib.NotImplemented ;
 import org.slf4j.Logger ;
 import org.slf4j.LoggerFactory ;
 
@@ -26,8 +25,8 @@ import com.hp.hpl.jena.tdb.base.recordbu
 public final class BPTreeRecords extends BPTreePage
 {
     private static Logger log = LoggerFactory.getLogger(BPTreeRecords.class) ;
-    private final RecordBufferPage    rBuffPage ;
-    private final RecordBuffer        rBuff ;        // Used heavily.
+    private final RecordBufferPage  rBuffPage ;
+    private RecordBuffer            rBuff ;         // Used heavily.
     
     BPTreeRecords(BPlusTree bpTree, RecordBufferPage rbp)
     {
@@ -50,7 +49,10 @@ public final class BPTreeRecords extends
     
     @Override
     public void reset(Block block)
-    { throw new NotImplemented("reset") ; }
+    { 
+        rBuffPage.reset(block) ;
+        rBuff = rBuffPage.getRecordBuffer() ;
+    }
 
     int getLink()
     { return rBuffPage.getLink() ; }

Modified: incubator/jena/Experimental/TxTDB/trunk/src/main/java/com/hp/hpl/jena/tdb/index/ext/HashBucket.java
URL: http://svn.apache.org/viewvc/incubator/jena/Experimental/TxTDB/trunk/src/main/java/com/hp/hpl/jena/tdb/index/ext/HashBucket.java?rev=1137956&r1=1137955&r2=1137956&view=diff
==============================================================================
--- incubator/jena/Experimental/TxTDB/trunk/src/main/java/com/hp/hpl/jena/tdb/index/ext/HashBucket.java
(original)
+++ incubator/jena/Experimental/TxTDB/trunk/src/main/java/com/hp/hpl/jena/tdb/index/ext/HashBucket.java
Tue Jun 21 11:10:45 2011
@@ -7,6 +7,9 @@
 package com.hp.hpl.jena.tdb.index.ext;
 
 import static org.openjena.atlas.lib.Alg.decodeIndex ;
+
+import java.nio.ByteBuffer ;
+
 import org.openjena.atlas.lib.NotImplemented ;
 
 import com.hp.hpl.jena.tdb.base.StorageException ;
@@ -30,16 +33,36 @@ public final class HashBucket extends Re
     private int trie ;
     // How many bits are used for storing in this bucket.
     private int bucketBitLen ;
-    private HashBucketMgr pageMgr ;
+
+    public static HashBucket format(Block block, RecordFactory factory)
+    {
+        ByteBuffer byteBuffer = block.getByteBuffer() ;
+        int count = byteBuffer.getInt(COUNT) ;
+        int hash = byteBuffer.getInt(TRIE) ;
+        int hashLen = byteBuffer.getInt(BITLEN) ;
+        HashBucket bucket = new HashBucket(NO_ID, hash, hashLen, block, factory, count) ;
+        return bucket ;
+    }
+    
+    public static HashBucket createBlank(Block block, RecordFactory factory)
+    {
+        ByteBuffer byteBuffer = block.getByteBuffer() ;
+        int count = 0 ; 
+        int hash = -1 ;
+        int hashLen = -1 ;
+        HashBucket bucket = new HashBucket(NO_ID, hash, hashLen, block, factory, count) ;
+        return bucket ;
+    }
+
+
     
     /** Create a bucket */
     public HashBucket(int id, int hashValue, int bucketBitLen,
                       Block block,
-                      RecordFactory factory, HashBucketMgr hashBucketPageMgr, 
+                      RecordFactory factory, 
                       int count)
     {
         super(block, FIELD_LENGTH, factory, count) ;
-        this.pageMgr = hashBucketPageMgr ;
         this.bucketBitLen = bucketBitLen ;
         this.trie = hashValue ;
     }
@@ -98,7 +121,7 @@ public final class HashBucket extends Re
     }
     
     @Override
-    public void reset(Block block)
+    public void _reset(Block block)
     { throw new NotImplemented("reset") ; }
 
     public final boolean isFull()
@@ -126,16 +149,16 @@ public final class HashBucket extends Re
     public final int getTrieBitLen()        { return bucketBitLen ; }
     
     public void setTrieLength(int trieBitLen) { bucketBitLen = trieBitLen ; }
-
-    public void setPageMgr(HashBucketMgr pageMgr)
-    {
-        this.pageMgr = pageMgr;
-    }
-
-    public HashBucketMgr getPageMgr()
-    {
-        return pageMgr;
-    }
+//
+//    public void setPageMgr(HashBucketMgr pageMgr)
+//    {
+//        this.pageMgr = pageMgr;
+//    }
+//
+//    public HashBucketMgr getPageMgr()
+//    {
+//        return pageMgr;
+//    }
 
     final void incTrieBitLen()              { bucketBitLen++ ; }
 

Modified: incubator/jena/Experimental/TxTDB/trunk/src/main/java/com/hp/hpl/jena/tdb/index/ext/HashBucketMgr.java
URL: http://svn.apache.org/viewvc/incubator/jena/Experimental/TxTDB/trunk/src/main/java/com/hp/hpl/jena/tdb/index/ext/HashBucketMgr.java?rev=1137956&r1=1137955&r2=1137956&view=diff
==============================================================================
--- incubator/jena/Experimental/TxTDB/trunk/src/main/java/com/hp/hpl/jena/tdb/index/ext/HashBucketMgr.java
(original)
+++ incubator/jena/Experimental/TxTDB/trunk/src/main/java/com/hp/hpl/jena/tdb/index/ext/HashBucketMgr.java
Tue Jun 21 11:10:45 2011
@@ -7,19 +7,18 @@
 package com.hp.hpl.jena.tdb.index.ext;
 
 import static com.hp.hpl.jena.tdb.base.recordbuffer.RecordBufferPageBase.COUNT ;
-import static com.hp.hpl.jena.tdb.base.recordbuffer.RecordBufferPageBase.NO_ID;
-import static com.hp.hpl.jena.tdb.index.ext.HashBucket.BITLEN;
-import static com.hp.hpl.jena.tdb.index.ext.HashBucket.TRIE;
+import static com.hp.hpl.jena.tdb.index.ext.HashBucket.BITLEN ;
+import static com.hp.hpl.jena.tdb.index.ext.HashBucket.TRIE ;
 
-import java.nio.ByteBuffer;
+import java.nio.ByteBuffer ;
 
 import com.hp.hpl.jena.tdb.base.block.Block ;
 import com.hp.hpl.jena.tdb.base.block.BlockConverter ;
-import com.hp.hpl.jena.tdb.base.block.BlockMgr;
-import com.hp.hpl.jena.tdb.base.block.BlockType;
+import com.hp.hpl.jena.tdb.base.block.BlockMgr ;
+import com.hp.hpl.jena.tdb.base.block.BlockType ;
 import com.hp.hpl.jena.tdb.base.page.PageBlockMgr ;
-import com.hp.hpl.jena.tdb.base.record.RecordException;
-import com.hp.hpl.jena.tdb.base.record.RecordFactory;
+import com.hp.hpl.jena.tdb.base.record.RecordException ;
+import com.hp.hpl.jena.tdb.base.record.RecordFactory ;
 
 
 public class HashBucketMgr extends PageBlockMgr<HashBucket>
@@ -27,7 +26,7 @@ public class HashBucketMgr extends PageB
     public HashBucketMgr(RecordFactory factory, BlockMgr blockMgr)
     {
         super(null, blockMgr) ;
-        Block2HashBucketMgr conv = new Block2HashBucketMgr(factory, null) ;
+        Block2HashBucketMgr conv = new Block2HashBucketMgr(factory) ;
         super.setConverter(conv) ;
     }
 
@@ -60,7 +59,6 @@ public class HashBucketMgr extends PageB
     {
         // [TxTDB:PATCH-UP]
         HashBucket bucket = super.getWrite(id) ;
-        bucket.setPageMgr(this) ;
         // Link and Count are in the block and got done by the converter.
         return bucket ;
     }
@@ -68,12 +66,10 @@ public class HashBucketMgr extends PageB
     private static class Block2HashBucketMgr implements BlockConverter<HashBucket>
     {
         private RecordFactory factory ;
-        private HashBucketMgr pageMgr ;
 
-        Block2HashBucketMgr(RecordFactory factory, HashBucketMgr pageMgr)
+        Block2HashBucketMgr(RecordFactory factory)
         {
             this.factory = factory ;
-            this.pageMgr = pageMgr ;
         }
         
         @Override
@@ -83,7 +79,7 @@ public class HashBucketMgr extends PageB
             if ( blkType != BlockType.RECORD_BLOCK )
                 throw new RecordException("Not RECORD_BLOCK: "+blkType) ;
             // Initially empty
-            HashBucket bucket = new HashBucket(NO_ID, -1, -1, block, factory, pageMgr, 0)
;
+            HashBucket bucket = HashBucket.createBlank(block, factory) ; // NO_ID, -1, -1,
block, factory, 0) ;
             return bucket ;
         }
 
@@ -92,15 +88,16 @@ public class HashBucketMgr extends PageB
         {
             synchronized (block)
             {
-                // Be safe - one reader only.
-                // But it is likely that the caller needs to also
-                // perform internal updates so syncrhoized on
-                // the bytebuffer here is not enough.
-                ByteBuffer byteBuffer = block.getByteBuffer() ;
-                int count = byteBuffer.getInt(COUNT) ;
-                int hash = byteBuffer.getInt(TRIE) ;
-                int hashLen = byteBuffer.getInt(BITLEN) ;
-                HashBucket bucket = new HashBucket(NO_ID, hash, hashLen, block, factory,
pageMgr, count) ;
+                HashBucket bucket = HashBucket.format(block, factory) ;
+//                // Be safe - one reader only.
+//                // But it is likely that the caller needs to also
+//                // perform internal updates so syncrhoized on
+//                // the bytebuffer here is not enough.
+//                ByteBuffer byteBuffer = block.getByteBuffer() ;
+//                int count = byteBuffer.getInt(COUNT) ;
+//                int hash = byteBuffer.getInt(TRIE) ;
+//                int hashLen = byteBuffer.getInt(BITLEN) ;
+//                HashBucket bucket = new HashBucket(NO_ID, hash, hashLen, block, factory,
pageMgr, count) ;
                 return bucket ;
             }
         }
@@ -110,7 +107,6 @@ public class HashBucketMgr extends PageB
         {
             // No need to additionally sync - this is a triggered by write operations so
only one writer.
             int count = bucket.getRecordBuffer().size() ;
-            bucket.setCount(count) ;
             ByteBuffer bb = bucket.getBackingBlock().getByteBuffer() ;
             bb.putInt(COUNT, bucket.getCount()) ;
             bb.putInt(TRIE,  bucket.getTrieValue()) ;

Modified: incubator/jena/Experimental/TxTDB/trunk/src/main/java/com/hp/hpl/jena/tdb/transaction/BlockMgrJournal.java
URL: http://svn.apache.org/viewvc/incubator/jena/Experimental/TxTDB/trunk/src/main/java/com/hp/hpl/jena/tdb/transaction/BlockMgrJournal.java?rev=1137956&r1=1137955&r2=1137956&view=diff
==============================================================================
--- incubator/jena/Experimental/TxTDB/trunk/src/main/java/com/hp/hpl/jena/tdb/transaction/BlockMgrJournal.java
(original)
+++ incubator/jena/Experimental/TxTDB/trunk/src/main/java/com/hp/hpl/jena/tdb/transaction/BlockMgrJournal.java
Tue Jun 21 11:10:45 2011
@@ -160,9 +160,7 @@ public class BlockMgrJournal implements 
 
     private Block _promote(Block block)
     {
-        ByteBufferLib.print(block.getByteBuffer()) ;
         block = block.replicate() ;
-        ByteBufferLib.print(block.getByteBuffer()) ;
         writeBlocks.put(block.getId(), block) ;
         return block ;
     }



Mime
View raw message