~akiban-technologies/akiban-persistit/build

Viewing changes to src/main/java/com/persistit/VolumeStorageL2.java

Committer: build-akiban
Date: 2013-03-13 17:51:59 UTC
mfrom: (421.2.14 fix-1126868-lock-table-pruning)
Revision ID: build@akiban.com-20130313175159-p4v32riupkg42bak

merge pbeaman: Fixes bug1126868.

https://code.launchpad.net/~pbeaman/akiban-persistit/fix-1126868-lock-table-pruning/+merge/152063

files added:
src/main/java/com/persistit/VolumeStorageL2.java

files modified:
src/main/java/com/persistit/Buffer.java

src/main/java/com/persistit/BufferPool.java

src/main/java/com/persistit/CleanupManager.java

src/main/java/com/persistit/Exchange.java

src/main/java/com/persistit/IntegrityCheck.java

src/main/java/com/persistit/Management.java

src/main/java/com/persistit/ManagementImpl.java

src/main/java/com/persistit/Persistit.java

src/main/java/com/persistit/Transaction.java

src/main/java/com/persistit/TransactionIndex.java

src/main/java/com/persistit/Tree.java

src/main/java/com/persistit/Volume.java

src/main/java/com/persistit/VolumeStorageT2.java

src/main/java/com/persistit/VolumeStructure.java

src/main/java/com/persistit/ui/AdminUISummaryPanel.java

src/main/java/com/persistit/ui/AdminUITreePanel.java

src/main/java/com/persistit/ui/VTComboBoxModel.java

src/main/resources/com/persistit/ui/AdminUI.properties

src/test/java/com/persistit/Bug1041293Test.java

src/test/java/com/persistit/CleanupManagerTest.java

src/test/java/com/persistit/ExchangeLockTest.java

src/test/java/com/persistit/MVCCPruneBufferTest.java

src/test/java/com/persistit/TestShim.java

Show diffs side-by-side

added added

removed removed

src/main/java/com/persistit/VolumeStorageL2.java

/**

* This program and the accompanying materials are made available

* under the terms of the Eclipse Public License v1.0 which

* accompanies this distribution, and is available at

* http://www.eclipse.org/legal/epl-v10.html

* This program may also be available under different license terms.

* For more information, see www.akiban.com or contact licensing@akiban.com.

* Contributors:

* Akiban Technologies, Inc.

package com.persistit;

import java.io.File;

import com.persistit.exception.InUseException;

import com.persistit.exception.PersistitException;

/**

* Manage all details of file I/O for a special <code>Volume</code> that backs

* the {@link Exchange#lock()} method. The lock volume differs from a temporary

* volume in the following ways:

* <ul>

* <li>It has a defined name and is visible in the

* {@link Persistit#getVolumes()} array.</li>

* <li>It is threadsafe.</li>

* </ul>

* Like a temporary volume, it is intended that pages of the lock volume should

* seldom, if ever, need to be written to disk. And also like a temporary

* volume, the contents of the lock volume are not recovered during startup.

* @author peter

class VolumeStorageL2 extends VolumeStorageT2 {

final static String LOCK_VOLUME_FILE_PREFIX = "persistit_lockvol_";

private Buffer _headBuffer;

VolumeStorageL2(final Persistit persistit, final Volume volume, final File tempDirectory) {

super(persistit, volume, tempDirectory);

}

/**

* Indicate whether this is a temporary volume. The Lock volume is not

* temporary, although it inherits most of the characteristics of a

* temporary volume.

* @return <code>true</code> if this volume is temporary

@Override

boolean isTemp() {

return false;

}

@Override

void truncate() throws PersistitException {

if (!claim(true, 0)) {

throw new InUseException("Unable to acquire claim on " + this);

}

try {

_headBuffer = _volume.getStructure().getPool().get(_volume, 0, true, false);

_headBuffer.init(Buffer.PAGE_TYPE_HEAD);

_headBuffer.setFixed();

truncateInternal();

releaseHeadBuffer();

} finally {

release();

}

@Override

void claimHeadBuffer() throws PersistitException {

if (!_headBuffer.claim(true)) {

throw new InUseException("Unable to acquire claim on " + _headBuffer);

}

@Override

void releaseHeadBuffer() {

_headBuffer.release();

}

Older »