You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@uima.apache.org by ch...@apache.org on 2013/08/07 18:11:23 UTC
svn commit: r1511371 -
/uima/sandbox/uima-ducc/trunk/uima-ducc-rm/src/main/java/org/apache/uima/ducc/rm/scheduler/NodePool.java
Author: challngr
Date: Wed Aug 7 16:11:22 2013
New Revision: 1511371
URL: http://svn.apache.org/r1511371
Log:
UIMA-2968 Update memory stats for a node if it leaves, and then rejoins the cluster.
Modified:
uima/sandbox/uima-ducc/trunk/uima-ducc-rm/src/main/java/org/apache/uima/ducc/rm/scheduler/NodePool.java
Modified: uima/sandbox/uima-ducc/trunk/uima-ducc-rm/src/main/java/org/apache/uima/ducc/rm/scheduler/NodePool.java
URL: http://svn.apache.org/viewvc/uima/sandbox/uima-ducc/trunk/uima-ducc-rm/src/main/java/org/apache/uima/ducc/rm/scheduler/NodePool.java?rev=1511371&r1=1511370&r2=1511371&view=diff
==============================================================================
--- uima/sandbox/uima-ducc/trunk/uima-ducc-rm/src/main/java/org/apache/uima/ducc/rm/scheduler/NodePool.java (original)
+++ uima/sandbox/uima-ducc/trunk/uima-ducc-rm/src/main/java/org/apache/uima/ducc/rm/scheduler/NodePool.java Wed Aug 7 16:11:22 2013
@@ -696,6 +696,11 @@ class NodePool
if ( unresponsiveMachines.containsKey(node) ) { // reactive the node
Machine m = unresponsiveMachines.remove(node);
+
+ if ( m.getShareOrder() != order ) { // can change. e.g. if it was taken offline for
+ m.setShareOrder(order); // hardware changes.
+ }
+
allMachines.put(node, m);
machinesByName.put(m.getId(), m);
machinesByIp.put(m.getIp(), m);