blobbench.java

Java的面向对象数据库系统的源代码

// $Id: BLOBBench.java,v 1.2 2003/11/23 14:16:53 per_nyfelt Exp $

import java.util.*;
import java.util.zip.*;

import org.ozoneDB.*;
import org.ozoneDB.blob.*;


class BLOBBench extends Thread {
    
    final static int POOLSIZE = 10;
    final static int BUFFERSIZE = 32000;
    final static int PAGESIZE = 32;
    final static int MINSIZE = 1;
    final static int MAXSIZE = 1024;
    
    int pool;
    int bsize;
    int page;
    int min;
    int max;
    
    String[] names;
    int[] sizes;
    byte[] buffer;
    long[] check;
    RemoteDatabase db;
    
    Random objNr;
    Random objSize;
    
    boolean halted = false;
    
    long movement = 0;
    long avWritespeed = 0;
    int writecount = 0;
    long avReadspeed = 0;
    int readcount = 0;
    
    
    /** Constructor */
    public BLOBBench( RemoteDatabase _db, int _poolsize, int _buffersize, int _pagesize, int _rangeMin,
            int _rangeMax ) {
        
        pool = _poolsize;
        bsize = _buffersize;
        page = _pagesize;
        min = _rangeMin;
        max = _rangeMax;
        
        names = new String[pool];
        sizes = new int[pool];
        check = new long[pool];
        buffer = new byte[_buffersize];
        db = _db;
        
        objNr = new Random();
        objSize = new Random();
    }
    
    
    /**  RUN THE THREAD */
    public void run() {
        
        while (true) {
            
            int actObj = objNr.nextInt() % pool;
            actObj = actObj < 0 ? -actObj : actObj;
            
            try {
                if (names[actObj] == null) {
                    // at this place there isnt an object yet -> create one
                    if (halted) {
                        break;
                    } 
                    createBlob( actObj );
                } else {
                    // there is one -> try to find it
                    BLOBContainer blob = (BLOBContainer)db.objectForName( names[actObj] );
                    if (blob != null) {
                        // read and verify it
                        if (halted) {
                            break;
                        } 
                        verifyBlob( blob, actObj );
                        // delete it
                        db.deleteObject( blob );
                        names[actObj] = null;
                        sizes[actObj] = 0;
                        check[actObj] = 0;
                        System.out.println( " -> deleted." );
                        // create a new one
                        if (halted) {
                            break;
                        } 
                        createBlob( actObj );
                    } else {
                        System.out.println( "\nERROR!!! Object for name