You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@uima.apache.org by cw...@apache.org on 2011/09/26 19:38:03 UTC
svn commit: r1175969 -
/uima/uima-as/trunk/uimaj-as-core/src/main/java/org/apache/uima/aae/controller/LocalCache.java
Author: cwiklik
Date: Mon Sep 26 17:38:02 2011
New Revision: 1175969
URL: http://svn.apache.org/viewvc?rev=1175969&view=rev
Log:
UIMA-2239 added special purpose monitor(lock) in incrementOutstandingFlowCounter and decrementOutstandingFlowCounter
Modified:
uima/uima-as/trunk/uimaj-as-core/src/main/java/org/apache/uima/aae/controller/LocalCache.java
Modified: uima/uima-as/trunk/uimaj-as-core/src/main/java/org/apache/uima/aae/controller/LocalCache.java
URL: http://svn.apache.org/viewvc/uima/uima-as/trunk/uimaj-as-core/src/main/java/org/apache/uima/aae/controller/LocalCache.java?rev=1175969&r1=1175968&r2=1175969&view=diff
==============================================================================
--- uima/uima-as/trunk/uimaj-as-core/src/main/java/org/apache/uima/aae/controller/LocalCache.java (original)
+++ uima/uima-as/trunk/uimaj-as-core/src/main/java/org/apache/uima/aae/controller/LocalCache.java Mon Sep 26 17:38:02 2011
@@ -236,7 +236,7 @@ public class LocalCache extends Concurre
private List<AnalysisEnginePerformanceMetrics> performanceList =
new ArrayList<AnalysisEnginePerformanceMetrics>();
-
+ private Object monitor = new Object();
public String getHostIpProcessingCAS() {
return hostIpProcessingCAS;
@@ -422,7 +422,7 @@ public class LocalCache extends Concurre
*
*/
public void incrementOutstandingFlowCounter() {
- synchronized( flowSemaphore ) {
+ synchronized( monitor ) {
if ( childCasOutstandingFlowCounter.incrementAndGet() == 1 ) {
try {
acquireFlowSemaphore();
@@ -438,7 +438,7 @@ public class LocalCache extends Concurre
* with its Flow.
*/
public void decrementOutstandingFlowCounter() {
- synchronized( flowSemaphore ) {
+ synchronized( monitor ) {
if( flowSemaphore.availablePermits() == 0 ) {
if ( childCasOutstandingFlowCounter.get() > 0 ) {
childCasOutstandingFlowCounter.decrementAndGet();