← Back to branch summary

~nwilliams/akiban-persistit/fix_912514_fetchAndRemove_2

~nwilliams/akiban-persistit/fix_912514_fetchAndRemove_2

« back to all changes in this revision

Viewing changes to core/src/main/java/com/persistit/TransactionStatus.java

Committer: build-akiban
Date: 2012-05-15 21:24:26 UTC
mfrom: (292.3.38 fix_959456)
Revision ID: build-akiban-20120515212426-6lp526nql1wu790g

merge pbeaman: This branch fixes several problems related to https://bugs.launchpad.net/akiban-persistit/+bug/959456 Journal copier falls behind in 4-hour Persistit TPCC test.

https://code.launchpad.net/~pbeaman/akiban-persistit/fix_959456/+merge/105529

files added:
core/src/main/java/com/persistit/mxbeans/CheckpointManagerMXBean.java

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

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

core/src/main/java/com/persistit/CheckpointManager.java

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

core/src/main/java/com/persistit/Configuration.java

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

core/src/main/java/com/persistit/JournalManager.java

core/src/main/java/com/persistit/MVV.java

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

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

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

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

core/src/main/java/com/persistit/TransactionStatus.java

core/src/main/java/com/persistit/mxbeans/JournalManagerMXBean.java

core/src/main/java/com/persistit/mxbeans/ManagementMXBean.java

core/src/test/java/com/persistit/BufferPoolTest.java

core/src/test/java/com/persistit/Bug927701Test.java

core/src/test/java/com/persistit/Bug942669Test.java

core/src/test/java/com/persistit/IntegrityCheckTest.java

core/src/test/java/com/persistit/JournalManagerTest.java

Show diffs side-by-side

added added

removed removed

core/src/main/java/com/persistit/TransactionStatus.java

311

311

int decrementMvvCount() {

312

312

assert _tc == ABORTED : "can only decrement MVVs for an aborted transaction";

313

313

int count = _mvvCount.decrementAndGet();

314

assert count >= 0;

314

assert count >= 0: "mvvCount is negative";

315

315

if (count == 0) {

316

316

_ta = _bucket.getTimestampAllocator().getCurrentTimestamp();

317

317

}

Older »