import javax.microedition.rms.RecordStoreNotOpenException; //导入依赖的package包/类
/**
 * Return total size used by this StorageUtility, including all underlying RMSes
 *
 * @return total size (bytes)
 */
public int getTotalSize () {
    int size = 0;

    synchronized (getAccessLock()) {

        checkNotCorrupt();

        RMSStorageInfo info = getInfoRecord();

        try {
            size += index.getIndexStoreSize();
            for (int i = 0; i < info.numDataStores; i++) {
                size += getDataStore(i).rms.getSize();
            }
        } catch (RecordStoreNotOpenException e) {
            throw new RuntimeException("can't happen");
        }
    }

    return size;
}
 

import javax.microedition.rms.RecordStoreNotOpenException; //导入依赖的package包/类
public void closeRecordStore() 
		throws RecordStoreNotOpenException, RecordStoreException
{
	if (!open) {
	    throw new RecordStoreNotOpenException();
	}
	
	if (recordListeners != null) {
		recordListeners.removeAllElements();
	}	
	recordStoreManager.fireRecordStoreListener(ExtendedRecordListener.RECORDSTORE_CLOSE, this.getName());

	records.clear();
	
	open = false;		
}
 

import javax.microedition.rms.RecordStoreNotOpenException; //导入依赖的package包/类
public void deleteRecord(int recordId) 
		throws RecordStoreNotOpenException, InvalidRecordIDException, RecordStoreException
{
	if (!open) {
	    throw new RecordStoreNotOpenException();
	}
	
	synchronized (this) {
		// throws InvalidRecordIDException when no record found
		getRecord(recordId);
	    records.remove(new Integer(recordId));
	    version++;
	    lastModified = System.currentTimeMillis();
	    size--;
	}
	
       recordStoreManager.deleteRecord(this, recordId);
	
	fireRecordListener(ExtendedRecordListener.RECORD_DELETE, recordId);
}
 

import javax.microedition.rms.RecordStoreNotOpenException; //导入依赖的package包/类
public int getRecordSize(int recordId) 
		throws RecordStoreNotOpenException, InvalidRecordIDException, RecordStoreException
{
	if (!open) {
	    throw new RecordStoreNotOpenException();
	}
	
	synchronized (this) {
	    byte[] data = (byte[]) records.get(new Integer(recordId));
	    if (data == null) {
	    	recordStoreManager.loadRecord(this, recordId);
	    	data = (byte[]) records.get(new Integer(recordId));
	    	if (data == null) {
	    		throw new InvalidRecordIDException();
	    	}
	    }
	
	    return data.length;
	}
}
 

import javax.microedition.rms.RecordStoreNotOpenException; //导入依赖的package包/类
public byte[] getRecord(int recordId) 
		throws RecordStoreNotOpenException, InvalidRecordIDException, RecordStoreException
{
	if (!open) {
	    throw new RecordStoreNotOpenException();
	}

	byte[] data;
	
	synchronized (this) {
	    data = new byte[getRecordSize(recordId)];
	    getRecord(recordId, data, 0);
	}
	
	return data.length < 1 ? null : data;
}
 

import javax.microedition.rms.RecordStoreNotOpenException; //导入依赖的package包/类
public byte[] nextRecord() 
		throws InvalidRecordIDException, RecordStoreNotOpenException, RecordStoreException
{
    if (!recordStoreImpl.isOpen()) {
        throw new RecordStoreNotOpenException();
    }

    if (currentRecord >= numRecords()) {
        throw new InvalidRecordIDException();
    }

    byte[] result = ((EnumerationRecord) enumerationRecords.elementAt(currentRecord)).value;
    currentRecord++;

    return result;
}
 

import javax.microedition.rms.RecordStoreNotOpenException; //导入依赖的package包/类
/**
 * Check that the record store is open, and reopen it if not. (It may have
 * been closed by other threads or StorageUtilitys)
 */
public void ensureOpen() {
    try {
        rms.getName(); // presumably the simplest operation that will
                        // trigger a 'not open' exception
    } catch (RecordStoreNotOpenException e) {
        try {
            rms = RecordStore.openRecordStore(name, false);
        } catch (RecordStoreException e1) {
            throw new RuntimeException("error");
        }
    }
}
 

import javax.microedition.rms.RecordStoreNotOpenException; //导入依赖的package包/类
private int getRMSSize (RecordStore rms) {
    int n = -1;
    try {
        n = rms.getSize();
    } catch (RecordStoreNotOpenException e) {
        fail("getRMSSize", e);
    }
    return n;
}
 

import javax.microedition.rms.RecordStoreNotOpenException; //导入依赖的package包/类
private int getRMSAvailSpace (RecordStore rms) {
    int n = -1;
    try {
        n = rms.getSizeAvailable();
    } catch (RecordStoreNotOpenException e) {
        fail("getRMSAvailSpace", e);
    }
    return n;
}
 

import javax.microedition.rms.RecordStoreNotOpenException; //导入依赖的package包/类
public boolean hasAnyRecord() {
    try {
        return recordStore.getNumRecords() != 0;
    } catch (RecordStoreNotOpenException ex) {
        //#debug debug
        ex.printStackTrace();
        throw new ComcraftException("Exception while checking if record store has any records! Record strore isn't opened.", ex);
    }
}
 

import javax.microedition.rms.RecordStoreNotOpenException; //导入依赖的package包/类
public void saveChanges(RecordStoreImpl recordStoreImpl) throws RecordStoreNotOpenException {
	ByteArrayOutputStream baos = new ByteArrayOutputStream();
	DataOutputStream dos = new DataOutputStream(baos);
	try {
		recordStoreImpl.write(dos);
		CookieContent cookieContent = new CookieContent(Base64Coder.encode(baos.toByteArray()));

		CookieContent previousCookie = (CookieContent) cookies.get(recordStoreImpl.getName());
		if (previousCookie != null) {
			removeCookie(recordStoreImpl.getName(), previousCookie);
		}

		cookies.put(recordStoreImpl.getName(), cookieContent);

		String[] parts = cookieContent.getParts();
		if (parts.length == 1) {
			document.setMember("cookie", "x" + recordStoreImpl.getName() + "=a" + parts[0] + expires);
		} else {
			for (int i = 0; i < parts.length; i++) {
				document.setMember("cookie", i + recordStoreImpl.getName() + "=a" + parts[i] + expires);
			}
		}

		System.out.println("saveChanges: " + recordStoreImpl.getName() + " (" + cookieContent.getParts().length
				+ ")");
	} catch (IOException ex) {
		Logger.error(ex);
	}
}
 

import javax.microedition.rms.RecordStoreNotOpenException; //导入依赖的package包/类
public String getName()
		throws RecordStoreNotOpenException
{
	if (!open) {
	    throw new RecordStoreNotOpenException();
	}

	return recordStoreName;
}
 

import javax.microedition.rms.RecordStoreNotOpenException; //导入依赖的package包/类
public int getVersion() 
		throws RecordStoreNotOpenException
{
	if (!open) {
	    throw new RecordStoreNotOpenException();
	}
	
	synchronized (this) {
	    return version;
	}
}
 

import javax.microedition.rms.RecordStoreNotOpenException; //导入依赖的package包/类
public int getNumRecords() 
		throws RecordStoreNotOpenException
{
	if (!open) {
	    throw new RecordStoreNotOpenException();
	}
	
	return size;
}
 

import javax.microedition.rms.RecordStoreNotOpenException; //导入依赖的package包/类
public int getSize()
		throws RecordStoreNotOpenException
{
	if (!open) {
	    throw new RecordStoreNotOpenException();
	}
	
	// TODO include size overhead such as the data structures used to hold the state of the record store
	
	// Preload all records
	enumerateRecords(null, null, false);
	
	int result = 0;
	Enumeration keys = records.keys();
	while (keys.hasMoreElements()) {
		int key = ((Integer) keys.nextElement()).intValue();
		try {
		    byte[] data = getRecord(key);
		    if (data != null) {
		        result += data.length;
		    }
		} catch (RecordStoreException e) {
			e.printStackTrace();
		}
	}
	return result;
}
 

import javax.microedition.rms.RecordStoreNotOpenException; //导入依赖的package包/类
public int getSizeAvailable()
		throws RecordStoreNotOpenException
{
	if (!open) {
	    throw new RecordStoreNotOpenException();
	}
	
	return recordStoreManager.getSizeAvailable(this); 
}
 

import javax.microedition.rms.RecordStoreNotOpenException; //导入依赖的package包/类
public long getLastModified() 
		throws RecordStoreNotOpenException
{
	if (!open) {
	    throw new RecordStoreNotOpenException();
	}
	
	synchronized (this) {
	    return lastModified;
	}
}
 

import javax.microedition.rms.RecordStoreNotOpenException; //导入依赖的package包/类
public int getNextRecordID() 
		throws RecordStoreNotOpenException, RecordStoreException
{
	if (!open) {
	    throw new RecordStoreNotOpenException();
	}
	
	// lastRecordId needs to hold correct number, all records have to be preloaded
	enumerateRecords(null, null, false);

	synchronized (this) {
	    return lastRecordId + 1;
	}
}
 

import javax.microedition.rms.RecordStoreNotOpenException; //导入依赖的package包/类
public int addRecord(byte[] data, int offset, int numBytes)
   		throws RecordStoreNotOpenException, RecordStoreException, RecordStoreFullException
{
	if (!open) {
	    throw new RecordStoreNotOpenException();
	}
	if (data == null && numBytes > 0) {
	    throw new NullPointerException();
	}
	if (numBytes > recordStoreManager.getSizeAvailable(this)) {
		throw new RecordStoreFullException();
	}		
	
	// lastRecordId needs to hold correct number, all records have to be preloaded
	enumerateRecords(null, null, false);
	
	byte[] recordData = new byte[numBytes];
	if (data != null) {
	    System.arraycopy(data, offset, recordData, 0, numBytes);
	}
	
	int nextRecordID = getNextRecordID();
	synchronized (this) {
	    records.put(new Integer(nextRecordID), recordData);
	    version++;
	    lastModified = System.currentTimeMillis();
	    lastRecordId++;
	    size++;
	}
	
       recordStoreManager.saveRecord(this, nextRecordID);
	
	fireRecordListener(ExtendedRecordListener.RECORD_ADD, nextRecordID);
	
	return nextRecordID;
}
 

import javax.microedition.rms.RecordStoreNotOpenException; //导入依赖的package包/类
public void setRecord(int recordId, byte[] newData, int offset, int numBytes)
   		throws RecordStoreNotOpenException, InvalidRecordIDException, RecordStoreException, RecordStoreFullException
{
	if (!open) {
	    throw new RecordStoreNotOpenException();
	}
	
	// FIXME fixit
	if (numBytes > recordStoreManager.getSizeAvailable(this)) {
		throw new RecordStoreFullException();
	}		

	byte[] recordData = new byte[numBytes];
	System.arraycopy(newData, offset, recordData, 0, numBytes);
	
	synchronized (this) {
		// throws InvalidRecordIDException when no record found
		getRecord(recordId);
	    records.put(new Integer(recordId), recordData);
	    version++;
	    lastModified = System.currentTimeMillis();
	}
	
       recordStoreManager.saveRecord(this, recordId);
	
	fireRecordListener(ExtendedRecordListener.RECORD_CHANGE, recordId);
}