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/01/07 22:29:19 UTC
svn commit: r1650172 -
/uima/sandbox/uima-ducc/trunk/uima-ducc-cli/src/main/java/org/apache/uima/ducc/cli/DuccMonitor.java
Author: degenaro
Date: Wed Jan 7 21:29:19 2015
New Revision: 1650172
URL: http://svn.apache.org/r1650172
Log:
UIMA-4174 DUCC Monitor (CLI) should display host (and PID) for Managed Reservations
Modified:
uima/sandbox/uima-ducc/trunk/uima-ducc-cli/src/main/java/org/apache/uima/ducc/cli/DuccMonitor.java
Modified: uima/sandbox/uima-ducc/trunk/uima-ducc-cli/src/main/java/org/apache/uima/ducc/cli/DuccMonitor.java
URL: http://svn.apache.org/viewvc/uima/sandbox/uima-ducc/trunk/uima-ducc-cli/src/main/java/org/apache/uima/ducc/cli/DuccMonitor.java?rev=1650172&r1=1650171&r2=1650172&view=diff
==============================================================================
--- uima/sandbox/uima-ducc/trunk/uima-ducc-cli/src/main/java/org/apache/uima/ducc/cli/DuccMonitor.java (original)
+++ uima/sandbox/uima-ducc/trunk/uima-ducc-cli/src/main/java/org/apache/uima/ducc/cli/DuccMonitor.java Wed Jan 7 21:29:19 2015
@@ -233,6 +233,25 @@ public abstract class DuccMonitor {
}
}
+ private ArrayList<String> seenRemotePids = new ArrayList<String>();
+
+ private void displayRemotePids(MonitorInfo monitorInfo) {
+ if(monitorInfo != null) {
+ if(monitorInfo.remotePids != null) {
+ for(String remotePid : monitorInfo.remotePids) {
+ if(!seenRemotePids.contains(remotePid)) {
+ seenRemotePids.add(remotePid);
+ StringBuffer message = new StringBuffer();
+ message.append("id:" + id);
+ message.append(" ");
+ message.append("remote:" + remotePid);
+ info(message.toString());
+ }
+ }
+ }
+ }
+ }
+
private int runInternal(String[] args) throws Exception {
// DUCC_HOME
String ducc_home = Utils.findDuccHome();
@@ -296,6 +315,7 @@ public abstract class DuccMonitor {
message.append("location:");
message.append(ManagementFactory.getRuntimeMXBean().getName());
info(message.toString());
+ debug(urlString);
// Poll until finished
while (flag_observer.get()) {
DuccEventHttpDispatcher dispatcher = new DuccEventHttpDispatcher(urlString, urlTimeout);
@@ -307,6 +327,7 @@ public abstract class DuccMonitor {
// MonitorInfo monitorInfo = gson
// .fromJson(json, MonitorInfo.class);
if ( monitorInfo != null ) {
+ displayRemotePids(monitorInfo);
int stateCount = monitorInfo.stateSequence.size();
debug("states:" + stateCount);
if (stateCount <= 0) {