You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@uima.apache.org by de...@apache.org on 2015/02/23 15:55:49 UTC
svn commit: r1661692 - in
/uima/sandbox/uima-ducc/trunk/uima-ducc-container/src/main/java/org/apache/uima/ducc/container:
common/Standardize.java jd/mh/MessageHandler.java
jd/mh/iface/IProcessInfo.java jd/mh/impl/ProcessInfo.java
Author: degenaro
Date: Mon Feb 23 14:55:49 2015
New Revision: 1661692
URL: http://svn.apache.org/r1661692
Log:
UIMA-4069 DUCC Job Driver (JD) system classpath
Add process deallocate reason to JD logging (e.g. Purged)
Modified:
uima/sandbox/uima-ducc/trunk/uima-ducc-container/src/main/java/org/apache/uima/ducc/container/common/Standardize.java
uima/sandbox/uima-ducc/trunk/uima-ducc-container/src/main/java/org/apache/uima/ducc/container/jd/mh/MessageHandler.java
uima/sandbox/uima-ducc/trunk/uima-ducc-container/src/main/java/org/apache/uima/ducc/container/jd/mh/iface/IProcessInfo.java
uima/sandbox/uima-ducc/trunk/uima-ducc-container/src/main/java/org/apache/uima/ducc/container/jd/mh/impl/ProcessInfo.java
Modified: uima/sandbox/uima-ducc/trunk/uima-ducc-container/src/main/java/org/apache/uima/ducc/container/common/Standardize.java
URL: http://svn.apache.org/viewvc/uima/sandbox/uima-ducc/trunk/uima-ducc-container/src/main/java/org/apache/uima/ducc/container/common/Standardize.java?rev=1661692&r1=1661691&r2=1661692&view=diff
==============================================================================
--- uima/sandbox/uima-ducc/trunk/uima-ducc-container/src/main/java/org/apache/uima/ducc/container/common/Standardize.java (original)
+++ uima/sandbox/uima-ducc/trunk/uima-ducc-container/src/main/java/org/apache/uima/ducc/container/common/Standardize.java Mon Feb 23 14:55:49 2015
@@ -21,6 +21,7 @@ package org.apache.uima.ducc.container.c
public class Standardize {
public enum Label {
+ deallocate,
text,
limit,
classname,
Modified: uima/sandbox/uima-ducc/trunk/uima-ducc-container/src/main/java/org/apache/uima/ducc/container/jd/mh/MessageHandler.java
URL: http://svn.apache.org/viewvc/uima/sandbox/uima-ducc/trunk/uima-ducc-container/src/main/java/org/apache/uima/ducc/container/jd/mh/MessageHandler.java?rev=1661692&r1=1661691&r2=1661692&view=diff
==============================================================================
--- uima/sandbox/uima-ducc/trunk/uima-ducc-container/src/main/java/org/apache/uima/ducc/container/jd/mh/MessageHandler.java (original)
+++ uima/sandbox/uima-ducc/trunk/uima-ducc-container/src/main/java/org/apache/uima/ducc/container/jd/mh/MessageHandler.java Mon Feb 23 14:55:49 2015
@@ -219,6 +219,10 @@ public class MessageHandler implements I
MessageBuffer mb1 = new MessageBuffer();
mb1.append(Standardize.Label.remote.get()+rwt.toString());
mb1.append(Standardize.Label.status.get()+"transition to down");
+ String reasonDeallocated = processInfo.getReasonDeallocated();
+ if(reasonDeallocated != null) {
+ mb1.append(Standardize.Label.deallocate.get()+reasonDeallocated);
+ }
logger.warn(location, ILogger.null_id, mb1.toString());
IWorkItem wi = entry.getValue();
IFsm fsm = wi.getFsm();
Modified: uima/sandbox/uima-ducc/trunk/uima-ducc-container/src/main/java/org/apache/uima/ducc/container/jd/mh/iface/IProcessInfo.java
URL: http://svn.apache.org/viewvc/uima/sandbox/uima-ducc/trunk/uima-ducc-container/src/main/java/org/apache/uima/ducc/container/jd/mh/iface/IProcessInfo.java?rev=1661692&r1=1661691&r2=1661692&view=diff
==============================================================================
--- uima/sandbox/uima-ducc/trunk/uima-ducc-container/src/main/java/org/apache/uima/ducc/container/jd/mh/iface/IProcessInfo.java (original)
+++ uima/sandbox/uima-ducc/trunk/uima-ducc-container/src/main/java/org/apache/uima/ducc/container/jd/mh/iface/IProcessInfo.java Mon Feb 23 14:55:49 2015
@@ -47,4 +47,10 @@ public interface IProcessInfo extends IR
public void setMin(long value);
public long getMin();
+
+ public void setReasonStopped(String value);
+ public String getReasonStopped();
+
+ public void setReasonDeallocated(String value);
+ public String getReasonDeallocated();
}
Modified: uima/sandbox/uima-ducc/trunk/uima-ducc-container/src/main/java/org/apache/uima/ducc/container/jd/mh/impl/ProcessInfo.java
URL: http://svn.apache.org/viewvc/uima/sandbox/uima-ducc/trunk/uima-ducc-container/src/main/java/org/apache/uima/ducc/container/jd/mh/impl/ProcessInfo.java?rev=1661692&r1=1661691&r2=1661692&view=diff
==============================================================================
--- uima/sandbox/uima-ducc/trunk/uima-ducc-container/src/main/java/org/apache/uima/ducc/container/jd/mh/impl/ProcessInfo.java (original)
+++ uima/sandbox/uima-ducc/trunk/uima-ducc-container/src/main/java/org/apache/uima/ducc/container/jd/mh/impl/ProcessInfo.java Mon Feb 23 14:55:49 2015
@@ -40,12 +40,23 @@ public class ProcessInfo implements IPro
private long max = 0;
private long min = 0;
+ private String reasonStopped = null;
+ private String reasonDeallocated = null;
+
public ProcessInfo(String nodeName, String nodeAddress, String pidName, int pid) {
setNodeName(nodeName);
setPidName(pidName);
setPid(pid);
}
+ public ProcessInfo(String nodeName, String nodeAddress, String pidName, int pid, String reasonStopped, String reasonDeallocated) {
+ setNodeName(nodeName);
+ setPidName(pidName);
+ setPid(pid);
+ setReasonStopped(reasonStopped);
+ setReasonDeallocated(reasonDeallocated);
+ }
+
public ProcessInfo(String nodeName, String nodeAddress, String pidName, int pid, IProcessStatistics pStats) {
setNodeName(nodeName);
setNodeAddress(nodeAddress);
@@ -180,4 +191,24 @@ public class ProcessInfo implements IPro
return min;
}
+ @Override
+ public void setReasonStopped(String value) {
+ reasonStopped = value;
+ }
+
+ @Override
+ public String getReasonStopped() {
+ return reasonStopped;
+ }
+
+ @Override
+ public void setReasonDeallocated(String value) {
+ reasonDeallocated = value;
+ }
+
+ @Override
+ public String getReasonDeallocated() {
+ return reasonDeallocated;
+ }
+
}