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 2015/01/06 17:14:07 UTC
svn commit: r1649856 - in
/uima/sandbox/uima-ducc/trunk/uima-ducc-transport/src/main/java/org/apache/uima/ducc/transport/configuration/jp:
HttpWorkerThread.java JobProcessComponent.java
Author: cwiklik
Date: Tue Jan 6 16:14:06 2015
New Revision: 1649856
URL: http://svn.apache.org/r1649856
Log:
UIMA-4060 fixed race condition causing one of process threads to exit before calling GET
Modified:
uima/sandbox/uima-ducc/trunk/uima-ducc-transport/src/main/java/org/apache/uima/ducc/transport/configuration/jp/HttpWorkerThread.java
uima/sandbox/uima-ducc/trunk/uima-ducc-transport/src/main/java/org/apache/uima/ducc/transport/configuration/jp/JobProcessComponent.java
Modified: uima/sandbox/uima-ducc/trunk/uima-ducc-transport/src/main/java/org/apache/uima/ducc/transport/configuration/jp/HttpWorkerThread.java
URL: http://svn.apache.org/viewvc/uima/sandbox/uima-ducc/trunk/uima-ducc-transport/src/main/java/org/apache/uima/ducc/transport/configuration/jp/HttpWorkerThread.java?rev=1649856&r1=1649855&r2=1649856&view=diff
==============================================================================
--- uima/sandbox/uima-ducc/trunk/uima-ducc-transport/src/main/java/org/apache/uima/ducc/transport/configuration/jp/HttpWorkerThread.java (original)
+++ uima/sandbox/uima-ducc/trunk/uima-ducc-transport/src/main/java/org/apache/uima/ducc/transport/configuration/jp/HttpWorkerThread.java Tue Jan 6 16:14:06 2015
@@ -283,6 +283,9 @@ public class HttpWorkerThread implements
// **************************************************************************
threadReadyCount.await();
+ synchronized(JobProcessComponent.class) {
+ duccComponent.setRunning();
+ }
} catch( Throwable t) {
logger.error("HttpWorkerThread.run()", null, t);
Modified: uima/sandbox/uima-ducc/trunk/uima-ducc-transport/src/main/java/org/apache/uima/ducc/transport/configuration/jp/JobProcessComponent.java
URL: http://svn.apache.org/viewvc/uima/sandbox/uima-ducc/trunk/uima-ducc-transport/src/main/java/org/apache/uima/ducc/transport/configuration/jp/JobProcessComponent.java?rev=1649856&r1=1649855&r2=1649856&view=diff
==============================================================================
--- uima/sandbox/uima-ducc/trunk/uima-ducc-transport/src/main/java/org/apache/uima/ducc/transport/configuration/jp/JobProcessComponent.java (original)
+++ uima/sandbox/uima-ducc/trunk/uima-ducc-transport/src/main/java/org/apache/uima/ducc/transport/configuration/jp/JobProcessComponent.java Tue Jan 6 16:14:06 2015
@@ -269,6 +269,9 @@ public class JobProcessComponent extends
}
}
+ public void setRunning() {
+ currentState = ProcessState.Running;
+ }
public boolean isRunning() {
return currentState.equals(ProcessState.Running);
}