You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@jena.apache.org by an...@apache.org on 2016/08/23 15:34:50 UTC
[2/6] jena git commit: JENA-1224: Flush based on trying to keep below
a max size.
JENA-1224: Flush based on trying to keep below a max size.
Project: http://git-wip-us.apache.org/repos/asf/jena/repo
Commit: http://git-wip-us.apache.org/repos/asf/jena/commit/166b6e9c
Tree: http://git-wip-us.apache.org/repos/asf/jena/tree/166b6e9c
Diff: http://git-wip-us.apache.org/repos/asf/jena/diff/166b6e9c
Branch: refs/heads/master
Commit: 166b6e9ccf1b4d4b0b93b49444a2534a083c09c4
Parents: 6e09208
Author: Andy Seaborne <an...@apache.org>
Authored: Sun Aug 21 20:48:37 2016 +0100
Committer: Andy Seaborne <an...@apache.org>
Committed: Sun Aug 21 20:48:37 2016 +0100
----------------------------------------------------------------------
.../jena/tdb/transaction/TransactionManager.java | 14 +++++++-------
1 file changed, 7 insertions(+), 7 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/jena/blob/166b6e9c/jena-tdb/src/main/java/org/apache/jena/tdb/transaction/TransactionManager.java
----------------------------------------------------------------------
diff --git a/jena-tdb/src/main/java/org/apache/jena/tdb/transaction/TransactionManager.java b/jena-tdb/src/main/java/org/apache/jena/tdb/transaction/TransactionManager.java
index 68b0344..43cb256 100644
--- a/jena-tdb/src/main/java/org/apache/jena/tdb/transaction/TransactionManager.java
+++ b/jena-tdb/src/main/java/org/apache/jena/tdb/transaction/TransactionManager.java
@@ -141,8 +141,9 @@ public class TransactionManager
// "one exclusive, or many other" lock which happens to be called a ReadWriteLock
private ReadWriteLock exclusivitylock = new ReentrantReadWriteLock() ;
- // Delayes enacting transactions.
+ // Delays enacting transactions.
private BlockingQueue<Transaction> queue = new LinkedBlockingDeque<>() ;
+ public long getQueueLength() { return queue.size() ; }
private DatasetGraphTDB baseDataset ;
private Journal journal ;
@@ -495,12 +496,11 @@ public class TransactionManager
releaseWriterLock();
}
}
- //TODO
-// // Imperfect in that writers may happen between releaseWriterLock and startExclusiveMode.
-// if ( excessiveQueue ) {
-// startExclusiveMode(true) ;
-// finishExclusiveMode();
-// }
+ // Imperfect in that writers may happen between releaseWriterLock and startExclusiveMode.
+ if ( excessiveQueue ) {
+ startExclusiveMode(true) ;
+ finishExclusiveMode();
+ }
}
synchronized