You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@lucene.apache.org by si...@apache.org on 2017/12/11 13:46:23 UTC
[2/3] lucene-solr:branch_7_2: LUCENE-8090: Prevent stale threadstate
reads in DocumentsWriterFlushControl
LUCENE-8090: Prevent stale threadstate reads in DocumentsWriterFlushControl
Project: http://git-wip-us.apache.org/repos/asf/lucene-solr/repo
Commit: http://git-wip-us.apache.org/repos/asf/lucene-solr/commit/50593919
Tree: http://git-wip-us.apache.org/repos/asf/lucene-solr/tree/50593919
Diff: http://git-wip-us.apache.org/repos/asf/lucene-solr/diff/50593919
Branch: refs/heads/branch_7_2
Commit: 5059391923f18daf27a038d1b8b3c72d2375c919
Parents: 576b0b5
Author: Simon Willnauer <si...@apache.org>
Authored: Mon Dec 11 14:45:26 2017 +0100
Committer: Simon Willnauer <si...@apache.org>
Committed: Mon Dec 11 14:45:52 2017 +0100
----------------------------------------------------------------------
.../java/org/apache/lucene/index/DocumentsWriterFlushControl.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/lucene-solr/blob/50593919/lucene/core/src/java/org/apache/lucene/index/DocumentsWriterFlushControl.java
----------------------------------------------------------------------
diff --git a/lucene/core/src/java/org/apache/lucene/index/DocumentsWriterFlushControl.java b/lucene/core/src/java/org/apache/lucene/index/DocumentsWriterFlushControl.java
index 761db0e..bf55991 100644
--- a/lucene/core/src/java/org/apache/lucene/index/DocumentsWriterFlushControl.java
+++ b/lucene/core/src/java/org/apache/lucene/index/DocumentsWriterFlushControl.java
@@ -716,7 +716,7 @@ final class DocumentsWriterFlushControl implements Accountable {
return infoStream;
}
- ThreadState findLargestNonPendingWriter() {
+ synchronized ThreadState findLargestNonPendingWriter() {
ThreadState maxRamUsingThreadState = null;
long maxRamSoFar = 0;
Iterator<ThreadState> activePerThreadsIterator = allActiveThreadStates();