Examples of com.caucho.db.block.Block

com.caucho.db.block.Block
Represents a versioned row


    if (! _store.isIndexBlock(blockId)) {
      return -1;
    }
    
    Block block = _store.readBlock(blockId);


    block.read();
    byte []buffer = block.getBuffer();
      
    long next = getPointer(buffer, NEXT_OFFSET);


    block.free();
    
    return next / BlockStore.BLOCK_SIZE;
  }

View Full Code Here

    db.init();


    BlockStore store = new BlockStore(db, "test", null);
    store.create();


    Block block = store.allocateIndexBlock();
    long blockId = block.getBlockId();
    block.free();


    return new BTree(store, blockId, keySize, new KeyCompare());
  }

View Full Code Here

  public static BTree createStringTest(Path path, int keySize)
    throws IOException, java.sql.SQLException
  {
    BlockStore store = BlockStore.create(path);


    Block block = store.allocateIndexBlock();
    long blockId = block.getBlockId();
    block.free();


    return new BTree(store, blockId, keySize, new StringKeyCompare());
  }

View Full Code Here

    return Long.toHexString(blockId);
  }


  public void close()
  {
    Block rootBlock = _rootBlock;
    _rootBlock = null;
    
    if (rootBlock != null)
      rootBlock.free();
  }

View Full Code Here

      KeyCompare keyCompare = column.getIndexKeyCompare();


      if (keyCompare == null)
        continue;


      Block rootBlock = allocateIndexBlock();
      long rootBlockId = rootBlock.getBlockId();
      rootBlock.free();


      BTree btree = new BTree(this, rootBlockId, column.getLength(),
                              keyCompare);


      column.setIndex(btree);

View Full Code Here

      if (index == null)
        continue;


      long rootAddr = index.getIndexRoot();


      Block block = readBlock(addressToBlockId(rootAddr));


      try {
        byte []blockBuffer = block.getBuffer();


        synchronized (blockBuffer) {
          for (int j = 0; j < blockBuffer.length; j++) {
            blockBuffer[j] = 0;
          }


          block.setDirty(0, BLOCK_SIZE);
        }
      } finally {
        block.free();
      }
    }


    long blockAddr = 0;

View Full Code Here

    throws IOException, SQLException
  {
    if (log.isLoggable(Level.ALL))
      log.log(Level.ALL, "db table " + getName() + " insert row xa:" + xa);


    Block block = null;


    try {
      while (true) {
        long blockId = allocateInsertRowBlock();


        block = xa.loadBlock(this, blockId);


        int rowOffset = allocateRow(block, xa);


        if (rowOffset >= 0) {
          insertRow(queryContext, xa, columns, values,
                    block, rowOffset);


          block.saveAllocation();
          
          freeRowBlockId(blockId);


          return blockIdToAddress(blockId, rowOffset);
        }


        Block freeBlock = block;
        block = null;
        freeBlock.free();
      }
    } catch (InterruptedException e) {
      throw new IllegalStateException(e);
    } finally {
      if (block != null)

View Full Code Here

    long rowTailOffset = _rowTailOffset.get();


    blockId = firstRowBlock(rowTailOffset);


    if (blockId <= 0) {
      Block block = allocateRow();


      blockId = block.getBlockId();
      // System.out.println("ALLOC: " + blockId + " " + _rowTailOffset.get() + " " + _rowTailTop);


      block.free();
    }


    _rowTailOffset.compareAndSet(rowTailOffset, blockId + BLOCK_SIZE);
    
    return blockId;

View Full Code Here

    throws IOException
  {
    if (isClosed())
      return false;
    
    Block block = readBlock(blockId);


    try {
      int rowOffset = 0;


      byte []buffer = block.getBuffer();
      boolean isFree = false;


      for (; rowOffset < _rowEnd; rowOffset += _rowLength) {
        if (buffer[rowOffset] == 0) {
          isFree = true;
          _clockRowFree++;
        }
        else
          _clockRowUsed++;
      }


      return isFree;
    } finally {
      block.free();
    }
  }

View Full Code Here

                     int keyOffset,
                     int keyLength,
                     long blockId)
    throws IOException, SQLException, InterruptedException
  {
    Block block;


    if (blockId == _rootBlockId) {
      block = _rootBlock;
      block.allocate();
    }
    else
      block = _store.loadBlock(blockId);


    try {
      Lock blockLock = block.getReadLock();
      
      blockLock.tryLock(_timeout, TimeUnit.MILLISECONDS);


      try {
        validateIndex(block);
        
        block.read();
        
        byte []buffer = block.getBuffer();


        boolean isLeaf = isLeaf(buffer, block);
      
        long value = lookupTuple(blockId, buffer,
                                 keyBuffer, keyOffset, keyLength,
                                 isLeaf);


        if (isLeaf || value == FAIL)
          return value;
        else
          return lookup(keyBuffer, keyOffset, keyLength, value);
      } finally {
        blockLock.unlock();
      }
    } finally {
      block.free();
    }
  }

View Full Code Here

0 1 2 3 4 5 6 7

TOP

Related Classes of com.caucho.db.block.Block

com.caucho.db.blob.Inode

com.caucho.db.blob.InodeBlobInputStream

com.caucho.db.index.BTree

com.caucho.db.lock.Lock

com.caucho.db.sql.QueryContext

com.caucho.db.table.Table

com.caucho.db.table.TableIterator

com.caucho.db.xa.DbTransaction

com.caucho.db.xa.Transaction

com.caucho.server.cache.TempFileInode$TempFileOutputStream

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.