package org.hsqldb.persist;
import org.hsqldb.lib.DoubleIntIndex;
public class DataSpaceManagerSimple implements DataSpaceManager {
DataFileCache cache;
TableSpaceManager defaultSpaceManager;
int fileBlockSize = DataSpaceManager.fixedBlockSizeUnit;
long totalFragmentSize;
int spaceIdSequence = tableIdFirst;
DoubleIntIndex lookup;
DataSpaceManagerSimple(DataFileCache cache, boolean isReadOnly) {
this.cache = cache;
if (cache instanceof DataFileCacheSession) {
defaultSpaceManager = new TableSpaceManagerSimple(cache);
} else if (cache instanceof TextCache) {
defaultSpaceManager = new TableSpaceManagerSimple(cache);
} else {
int capacity = cache.database.logger.propMaxFreeBlocks;
defaultSpaceManager = new TableSpaceManagerBlocks(this,
DataSpaceManager.tableIdDefault, fileBlockSize, capacity,
cache.getDataFileScale(), 0);
if (!isReadOnly) {
initialiseSpaces();
cache.spaceManagerPosition = 0;
}
}
totalFragmentSize = cache.lostSpaceSize;
}
public TableSpaceManager getDefaultTableSpace() {
return defaultSpaceManager;
}
public TableSpaceManager getTableSpace(int spaceId) {
if (spaceId >= spaceIdSequence) {
spaceIdSequence = spaceId + 1;
}
return defaultSpaceManager;
}
public int getNewTableSpaceID() {
return spaceIdSequence++;
}
public long getFileBlocks(int spaceId, int blockCount) {
long filePosition = cache.enlargeFileSpace((long) blockCount
* fileBlockSize);
return filePosition;
}
public void freeTableSpace(int spaceId) {}
public void freeTableSpace(int spaceId, DoubleIntIndex spaceList,
long offset, long limit, boolean full) {
totalFragmentSize += spaceList.getTotalValues()
* cache.getDataFileScale();
if (full) {
if (cache.fileFreePosition == limit) {
cache.writeLock.lock();
try {
cache.fileFreePosition = offset;
} finally {
cache.writeLock.unlock();
}
} else {
totalFragmentSize += limit - offset;
}
if (spaceList.size() != 0) {
lookup = new DoubleIntIndex(spaceList.size(), true);
spaceList.copyTo(lookup);
spaceList.clear();
}
} else {
spaceList.compactLookupAsIntervals();
spaceList.setValuesSearchTarget();
spaceList.sort();
int extra = spaceList.size() - spaceList.capacity() / 2;
if (extra > 0) {
spaceList.removeRange(0, extra);
totalFragmentSize -= spaceList.getTotalValues()
* cache.getDataFileScale();
}
}
}
public long getLostBlocksSize() {
return totalFragmentSize + defaultSpaceManager.getLostBlocksSize();
}
public int getFileBlockSize() {
return 1024 * 1024 * cache.getDataFileScale() / 16;
}
public boolean isModified() {
return true;
}
public void initialiseSpaces() {
long currentSize = cache.getFileFreePos();
long totalBlocks = (currentSize + fileBlockSize) / fileBlockSize;
long lastFreePosition = cache.enlargeFileSpace(totalBlocks
* fileBlockSize - currentSize);
defaultSpaceManager.initialiseFileBlock(lookup, lastFreePosition,
cache.getFileFreePos());
if (lookup != null) {
totalFragmentSize -= lookup.getTotalValues()
* cache.getDataFileScale();
lookup = null;
}
}
public void reset() {
defaultSpaceManager.reset();
}
public boolean isMultiSpace() {
return false;
}
public int getFileBlockItemCount() {
return 1024 * 64;
}
public DirectoryBlockCachedObject[] getDirectoryList() {
return new DirectoryBlockCachedObject[0];
}
}