uima-ducc-transport/src/main/java/org/apache/uima/ducc/transport/event/common/DuccProcessConcurrentMap.java [42:471]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
	public void addProcess(IDuccProcess process) {
		synchronized(this) {
			put(process.getDuccId(),process);
		}
	}
	
	
	public IDuccProcess getProcess(DuccId duccId) {
		synchronized(this) {
			return get(duccId);
		}
	}
	
	
	public void removeProcess(DuccId duccId) {
		synchronized(this) {
			remove(duccId);
		}
	}
	
	
	public IDuccProcess findProcess(String nodeIP, String processId) {
		IDuccProcess retVal = null;
		synchronized(this) {
			Iterator<IDuccProcess> iterator = values().iterator();
			while(iterator.hasNext()) {
				IDuccProcess duccProcess = iterator.next();
				NodeIdentity nodeIdentity = duccProcess.getNodeIdentity();
				if(nodeIdentity != null) {		
					String IP = nodeIdentity.getIp();
					if(IP != null) {
						String PID = duccProcess.getPID();
						if(PID != null ) {
							if(IP.equals(nodeIP)) {
								if(PID.equals(processId)) {
									retVal = duccProcess;
									break;
								}
				
							}
						}
					}
				}
			}
		}
		return retVal;
	}
	
	public IDuccProcess findProcess(DuccLogger duccLogger, String nodeIP, String processId) {
		String methodName = "findProcess";
		duccLogger.debug(methodName, null, "enter");
		IDuccProcess retVal = null;
		duccLogger.debug(methodName, null, "input nodeIP:"+nodeIP+" "+"processId:"+processId);
		synchronized(this) {
			Iterator<IDuccProcess> iterator = values().iterator();
			duccLogger.debug(methodName, null, "iterator:"+iterator);
			while(iterator.hasNext()) {
				IDuccProcess duccProcess = iterator.next();
				duccLogger.debug(methodName, null, "duccProcess:"+duccProcess);
				NodeIdentity nodeIdentity = duccProcess.getNodeIdentity();
				duccLogger.debug(methodName, null, "nodeIdentity:"+nodeIdentity);
				String IP = nodeIdentity.getIp();
				duccLogger.debug(methodName, null, "IP:"+IP);
				String PID = duccProcess.getPID();
				duccLogger.debug(methodName, null, "PID:"+PID);
				if(Util.compareNotNull(IP, nodeIP)) {
					if(Util.compareNotNull(PID,processId)) {
						retVal = duccProcess;
						duccLogger.debug(methodName, null, "retVal:"+retVal);
						break;
					}
					else {
						duccLogger.debug(methodName, null, ">"+PID+"<");
						duccLogger.debug(methodName, null, ">"+processId+"<");
					}
				}
				else {
					duccLogger.debug(methodName, null, ">"+IP+"<");
					duccLogger.debug(methodName, null, ">"+nodeIP+"<");
				}
			}
		}
		duccLogger.debug(methodName, null, "exit");
		return retVal;
	}
	
	/*
	
	public int getFailedProcessCount() {
		int retVal = 0;
		synchronized(this) {
			Iterator<IDuccProcess> iterator = this.values().iterator();
			while(iterator.hasNext()) {
				IDuccProcess process = iterator.next();
				if(process.isFailed()) {
					retVal++;
				}
			}
		}
		return retVal;
	}
	*/
	
	
	public int getFailedUnexpectedProcessCount() {
		int retVal = 0;
		synchronized(this) {
			Iterator<IDuccProcess> iterator = this.values().iterator();
			while(iterator.hasNext()) {
				IDuccProcess process = iterator.next();
				if(process.isFailed()) {
					switch(process.getProcessDeallocationType()) {
					case Forced:
						continue;
					}
					retVal++;
				}
			}
		}
		return retVal;
	}
	
	
	public int getReadyProcessCount() {
		int retVal = 0;
		synchronized(this) {
			Iterator<IDuccProcess> iterator = this.values().iterator();
			while(iterator.hasNext()) {
				IDuccProcess process = iterator.next();
				if(process.isReady()) {
					retVal++;
				}
			}
			
		}
		return retVal;
	}
	
	
	public int getUsableProcessCount() {
		int retVal = 0;
		synchronized(this) {
			Iterator<IDuccProcess> iterator = this.values().iterator();
			while(iterator.hasNext()) {
				IDuccProcess process = iterator.next();
				if(process.isDeallocated()) {
					continue;
				}
				if(process.isReady()) {
					retVal++;
				}
			}
		}
		return retVal;
	}

	public int getNoPidProcessCount() {
		int retVal = 0;
		synchronized(this) {
			Iterator<IDuccProcess> iterator = this.values().iterator();
			while(iterator.hasNext()) {
				IDuccProcess process = iterator.next();
				if(process.getPID() == null) {
					retVal++;
				}
			}
		}
		return retVal;
	}
	
	public int getAliveProcessCount() {
		int retVal = 0;
		synchronized(this) {
			Iterator<IDuccProcess> iterator = this.values().iterator();
			while(iterator.hasNext()) {
				IDuccProcess process = iterator.next();
				if(!process.isDefunct()) {
					retVal++;
				}
			}
			
		}
		return retVal;
	}

	
	public Map<DuccId, IDuccProcess> getMap() {
		return this;
	}
	
	
	public IDuccProcessMap deepCopy() {
		synchronized (this) {
			return (IDuccProcessMap) SerializationUtils.clone(this);
		}
	}

	// <UIMA-3489>
	private boolean isFailedInitialization(IDuccProcess process) {
		boolean retVal = false;
		try {
			// <UIMA-4791>
			ProcessState processState = process.getProcessState();
			switch(processState) {
			case FailedInitialization:
			case LaunchFailed:
				retVal = true;
				break;
			default:
				String reason = process.getReasonForStoppingProcess();
				if(ProcessState.FailedInitialization.name().equals(reason)) {
					retVal = true;
				}
				break;
			}
			// </UIMA-4791>
		}
		catch(Exception e) {
		}
		return retVal;
	}
	// </UIMA-3489>
	
	public ArrayList<DuccId> getFailedInitialization() {
		ArrayList<DuccId> list = new ArrayList<DuccId>();
		synchronized(this) {
			Iterator<IDuccProcess> iterator = this.values().iterator();
			while(iterator.hasNext()) {
				IDuccProcess process = iterator.next();
				if(process.isInitialized()) {
					// Nevermind
				}
				else {
					if(isFailedInitialization(process)) {
						list.add(process.getDuccId());
					}
					else if(DuccProcessHelper.isFailedProcess(process)) {
						list.add(process.getDuccId());
					}
				}
			}
		}
		return list;
	}

	public ArrayList<DuccId> getFailedNotInitialization() {
		ArrayList<DuccId> list = new ArrayList<DuccId>();
		synchronized(this) {
			Iterator<IDuccProcess> iterator = this.values().iterator();
			while(iterator.hasNext()) {
				IDuccProcess process = iterator.next();
				if(process.isInitialized()) {
					if(DuccProcessHelper.isFailedProcess(process)) {
						list.add(process.getDuccId());
					}
				}
				else {
					// Nevermind
				}
			}
		}
		return list;
	}

	public int getFailedInitializationCount() {
		ArrayList<DuccId> list = getFailedInitialization();
		return list.size();
	}

	
	public int getFailedNotInitializationCount() {
		ArrayList<DuccId> list = getFailedNotInitialization();
		return list.size();
	}
	
	public ArrayList<DuccId> getAbnormalDeallocations() {
		ArrayList<DuccId> list = new ArrayList<DuccId>();
		synchronized(this) {
			Iterator<IDuccProcess> iterator = this.values().iterator();
			while(iterator.hasNext()) {
				IDuccProcess process = iterator.next();
				if(!process.isDeallocationNormal()) {
					list.add(process.getDuccId());
				}
				else {
					// Nevermind
				}
			}
		}
		return list;
	}
	
	public int getAbnormalDeallocationCount() {
		ArrayList<DuccId> list = getAbnormalDeallocations();
		return list.size();
	}
	
	/*
	 * return actual count if all non-negative (all have cgroups)
	 * return -1 if all -1 (none have cgroups)
	 * return -2 if mixed (some do and some don't have cgroups) but retVal would have been == 0
	 * return -3 if mixed (some do and some don't have cgroups) but retVal would have been > 0
	 */
	public long getPgInCount() {
		long retVal = 0;
		boolean flagCgroup = false;
		boolean flagNoCgroup = false;
		synchronized(this) {
			Iterator<IDuccProcess> iterator = this.values().iterator();
			while(iterator.hasNext()) {
				IDuccProcess process = iterator.next();
				long value = process.getMajorFaults();
				if(value == SpecialValue.Unknown.getlong()) {
					// skip it
				}
				else {
					if(value < 0) {
						flagNoCgroup = true;
					}
					else {
						flagCgroup = true;
						retVal += value;
					}
				}
			}
		}
		if(flagCgroup && flagNoCgroup) {
			if(retVal > 0){
				retVal = -3;
			}
			else {
				retVal = -2;
			}
		}
		else if(flagNoCgroup) {
			retVal = -1;
		}
		return retVal;
	}
	
	/*
	 * return actual count if all non-negative (all have cgroups)
	 * return -1 if all -1 (none have cgroups)
	 * return -2 if mixed (some do and some don't have cgroups) but retVal would have been == 0
	 * return -3 if mixed (some do and some don't have cgroups) but retVal would have been > 0
	 */
	public double getSwapUsageGb() {
		double retVal = 0;
		boolean flagCgroup = false;
		boolean flagNoCgroup = false;
		synchronized(this) {
			Iterator<IDuccProcess> iterator = this.values().iterator();
			while(iterator.hasNext()) {
				IDuccProcess process = iterator.next();
				double value = process.getSwapUsage();
				if(value == SpecialValue.Unknown.getlong()) {
					// skip it
				}
				else {
					if(value < 0) {
						flagNoCgroup = true;
					}
					else {
						flagCgroup = true;
						retVal += value/Constants.GB;
					}
				}
			}
		}
		if(flagCgroup && flagNoCgroup) {
			if(retVal > 0){
				retVal = -3;
			}
			else {
				retVal = -2;
			}
		}
		else if(flagNoCgroup) {
			retVal = -1;
		}
		return retVal;
	}
	
	/*
	 * return actual count if all non-negative (all have cgroups)
	 * return -1 if all -1 (none have cgroups)
	 * return -2 if mixed (some do and some don't have cgroups) but retVal would have been == 0
	 * return -3 if mixed (some do and some don't have cgroups) but retVal would have been > 0
	 */
	public double getSwapUsageGbMax() {
		double retVal = 0;
		double swap = getSwapUsageGb();
		if(swap < 0) {
			retVal = swap;
		}
		else {
			boolean flagCgroup = false;
			boolean flagNoCgroup = false;
			synchronized(this) {
				Iterator<IDuccProcess> iterator = this.values().iterator();
				while(iterator.hasNext()) {
					IDuccProcess process = iterator.next();
					double value = process.getSwapUsageMax();
					if(value == SpecialValue.Unknown.getlong()) {
						// skip it
					}
					else {
						if(value < 0) {
							flagNoCgroup = true;
						}
						else {
							flagCgroup = true;
							retVal += value/Constants.GB;
						}
					}
				}
			}
			if(flagCgroup && flagNoCgroup) {
				if(retVal > 0){
					retVal = -3;
				}
				else {
					retVal = -2;
				}
			}
			else if(flagNoCgroup) {
				retVal = -1;
			}
		}
		return retVal;
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



uima-ducc-transport/src/main/java/org/apache/uima/ducc/transport/event/common/DuccProcessMap.java [48:477]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
	public void addProcess(IDuccProcess process) {
		synchronized(this) {
			put(process.getDuccId(),process);
		}
	}
	
	
	public IDuccProcess getProcess(DuccId duccId) {
		synchronized(this) {
			return get(duccId);
		}
	}
	
	
	public void removeProcess(DuccId duccId) {
		synchronized(this) {
			remove(duccId);
		}
	}
	
	
	public IDuccProcess findProcess(String nodeIP, String processId) {
		IDuccProcess retVal = null;
		synchronized(this) {
			Iterator<IDuccProcess> iterator = values().iterator();
			while(iterator.hasNext()) {
				IDuccProcess duccProcess = iterator.next();
				NodeIdentity nodeIdentity = duccProcess.getNodeIdentity();
				if(nodeIdentity != null) {		
					String IP = nodeIdentity.getIp();
					if(IP != null) {
						String PID = duccProcess.getPID();
						if(PID != null ) {
							if(IP.equals(nodeIP)) {
								if(PID.equals(processId)) {
									retVal = duccProcess;
									break;
								}
				
							}
						}
					}
				}
			}
		}
		return retVal;
	}
	
	public IDuccProcess findProcess(DuccLogger duccLogger, String nodeIP, String processId) {
		String methodName = "findProcess";
		duccLogger.debug(methodName, null, "enter");
		IDuccProcess retVal = null;
		duccLogger.debug(methodName, null, "input nodeIP:"+nodeIP+" "+"processId:"+processId);
		synchronized(this) {
			Iterator<IDuccProcess> iterator = values().iterator();
			duccLogger.debug(methodName, null, "iterator:"+iterator);
			while(iterator.hasNext()) {
				IDuccProcess duccProcess = iterator.next();
				duccLogger.debug(methodName, null, "duccProcess:"+duccProcess);
				NodeIdentity nodeIdentity = duccProcess.getNodeIdentity();
				duccLogger.debug(methodName, null, "nodeIdentity:"+nodeIdentity);
				String IP = nodeIdentity.getIp();
				duccLogger.debug(methodName, null, "IP:"+IP);
				String PID = duccProcess.getPID();
				duccLogger.debug(methodName, null, "PID:"+PID);
				if(Util.compareNotNull(IP, nodeIP)) {
					if(Util.compareNotNull(PID,processId)) {
						retVal = duccProcess;
						duccLogger.debug(methodName, null, "retVal:"+retVal);
						break;
					}
					else {
						duccLogger.debug(methodName, null, ">"+PID+"<");
						duccLogger.debug(methodName, null, ">"+processId+"<");
					}
				}
				else {
					duccLogger.debug(methodName, null, ">"+IP+"<");
					duccLogger.debug(methodName, null, ">"+nodeIP+"<");
				}
			}
		}
		duccLogger.debug(methodName, null, "exit");
		return retVal;
	}
	
	/*
	
	public int getFailedProcessCount() {
		int retVal = 0;
		synchronized(this) {
			Iterator<IDuccProcess> iterator = this.values().iterator();
			while(iterator.hasNext()) {
				IDuccProcess process = iterator.next();
				if(process.isFailed()) {
					retVal++;
				}
			}
		}
		return retVal;
	}
	*/
	
	
	public int getFailedUnexpectedProcessCount() {
		int retVal = 0;
		synchronized(this) {
			Iterator<IDuccProcess> iterator = this.values().iterator();
			while(iterator.hasNext()) {
				IDuccProcess process = iterator.next();
				if(process.isFailed()) {
					switch(process.getProcessDeallocationType()) {
					case Forced:
						continue;
					}
					retVal++;
				}
			}
		}
		return retVal;
	}
	
	
	public int getReadyProcessCount() {
		int retVal = 0;
		synchronized(this) {
			Iterator<IDuccProcess> iterator = this.values().iterator();
			while(iterator.hasNext()) {
				IDuccProcess process = iterator.next();
				if(process.isReady()) {
					retVal++;
				}
			}
			
		}
		return retVal;
	}
	
	
	public int getUsableProcessCount() {
		int retVal = 0;
		synchronized(this) {
			Iterator<IDuccProcess> iterator = this.values().iterator();
			while(iterator.hasNext()) {
				IDuccProcess process = iterator.next();
				if(process.isDeallocated()) {
					continue;
				}
				if(process.isReady()) {
					retVal++;
				}
			}
		}
		return retVal;
	}

	public int getNoPidProcessCount() {
		int retVal = 0;
		synchronized(this) {
			Iterator<IDuccProcess> iterator = this.values().iterator();
			while(iterator.hasNext()) {
				IDuccProcess process = iterator.next();
				if(process.getPID() == null) {
					retVal++;
				}
			}
		}
		return retVal;
	}
	
	public int getAliveProcessCount() {
		int retVal = 0;
		synchronized(this) {
			Iterator<IDuccProcess> iterator = this.values().iterator();
			while(iterator.hasNext()) {
				IDuccProcess process = iterator.next();
				if(!process.isDefunct()) {
					retVal++;
				}
			}
			
		}
		return retVal;
	}

	
	public Map<DuccId, IDuccProcess> getMap() {
		return this;
	}
	
	
	public IDuccProcessMap deepCopy() {
		synchronized (this) {
			return (IDuccProcessMap) SerializationUtils.clone(this);
		}
	}
	
	// <UIMA-3489>
	private boolean isFailedInitialization(IDuccProcess process) {
		boolean retVal = false;
		try {
			// <UIMA-4791>
			ProcessState processState = process.getProcessState();
			switch(processState) {
			case FailedInitialization:
			case LaunchFailed:
				retVal = true;
				break;
			default:
				String reason = process.getReasonForStoppingProcess();
				if(ProcessState.FailedInitialization.name().equals(reason)) {
					retVal = true;
				}
				break;
			}
			// </UIMA-4791>
		}
		catch(Exception e) {
		}
		return retVal;
	}
	// </UIMA-3489>
	
	public ArrayList<DuccId> getFailedInitialization() {
		ArrayList<DuccId> list = new ArrayList<DuccId>();
		synchronized(this) {
			Iterator<IDuccProcess> iterator = this.values().iterator();
			while(iterator.hasNext()) {
				IDuccProcess process = iterator.next();
				if(process.isInitialized()) {
					// Nevermind
				}
				else {
					if(isFailedInitialization(process)) {
						list.add(process.getDuccId());
					}
					else if(DuccProcessHelper.isFailedProcess(process)) {
						list.add(process.getDuccId());
					}
				}
			}
		}
		return list;
	}

	public ArrayList<DuccId> getFailedNotInitialization() {
		ArrayList<DuccId> list = new ArrayList<DuccId>();
		synchronized(this) {
			Iterator<IDuccProcess> iterator = this.values().iterator();
			while(iterator.hasNext()) {
				IDuccProcess process = iterator.next();
				if(process.isInitialized()) {
					if(DuccProcessHelper.isFailedProcess(process)) {
						list.add(process.getDuccId());
					}
				}
				else {
					// Nevermind
				}
			}
		}
		return list;
	}

	public int getFailedInitializationCount() {
		ArrayList<DuccId> list = getFailedInitialization();
		return list.size();
	}

	
	public int getFailedNotInitializationCount() {
		ArrayList<DuccId> list = getFailedNotInitialization();
		return list.size();
	}
	
	public ArrayList<DuccId> getAbnormalDeallocations() {
		ArrayList<DuccId> list = new ArrayList<DuccId>();
		synchronized(this) {
			Iterator<IDuccProcess> iterator = this.values().iterator();
			while(iterator.hasNext()) {
				IDuccProcess process = iterator.next();
				if(!process.isDeallocationNormal()) {
					list.add(process.getDuccId());
				}
				else {
					// Nevermind
				}
			}
		}
		return list;
	}
	
	public int getAbnormalDeallocationCount() {
		ArrayList<DuccId> list = getAbnormalDeallocations();
		return list.size();
	}
	
	/*
	 * return actual count if all non-negative (all have cgroups)
	 * return -1 if all -1 (none have cgroups)
	 * return -2 if mixed (some do and some don't have cgroups) but retVal would have been == 0
	 * return -3 if mixed (some do and some don't have cgroups) but retVal would have been > 0
	 */
	public long getPgInCount() {
		long retVal = 0;
		boolean flagCgroup = false;
		boolean flagNoCgroup = false;
		synchronized(this) {
			Iterator<IDuccProcess> iterator = this.values().iterator();
			while(iterator.hasNext()) {
				IDuccProcess process = iterator.next();
				long value = process.getMajorFaults();
				if(value == SpecialValue.Unknown.getlong()) {
					// skip it
				}
				else {
					if(value < 0) {
						flagNoCgroup = true;
					}
					else {
						flagCgroup = true;
						retVal += value;
					}
				}
			}
		}
		if(flagCgroup && flagNoCgroup) {
			if(retVal > 0){
				retVal = -3;
			}
			else {
				retVal = -2;
			}
		}
		else if(flagNoCgroup) {
			retVal = -1;
		}
		return retVal;
	}
	
	/*
	 * return actual count if all non-negative (all have cgroups)
	 * return -1 if all -1 (none have cgroups)
	 * return -2 if mixed (some do and some don't have cgroups) but retVal would have been == 0
	 * return -3 if mixed (some do and some don't have cgroups) but retVal would have been > 0
	 */
	public double getSwapUsageGb() {
		double retVal = 0;
		boolean flagCgroup = false;
		boolean flagNoCgroup = false;
		synchronized(this) {
			Iterator<IDuccProcess> iterator = this.values().iterator();
			while(iterator.hasNext()) {
				IDuccProcess process = iterator.next();
				double value = process.getSwapUsage();
				if(value == SpecialValue.Unknown.getlong()) {
					// skip it
				}
				else {
					if(value < 0) {
						flagNoCgroup = true;
					}
					else {
						flagCgroup = true;
						retVal += value/Constants.GB;
					}
				}
			}
		}
		if(flagCgroup && flagNoCgroup) {
			if(retVal > 0){
				retVal = -3;
			}
			else {
				retVal = -2;
			}
		}
		else if(flagNoCgroup) {
			retVal = -1;
		}
		return retVal;
	}
	
	/*
	 * return actual count if all non-negative (all have cgroups)
	 * return -1 if all -1 (none have cgroups)
	 * return -2 if mixed (some do and some don't have cgroups) but retVal would have been == 0
	 * return -3 if mixed (some do and some don't have cgroups) but retVal would have been > 0
	 */
	public double getSwapUsageGbMax() {
		double retVal = 0;
		double swap = getSwapUsageGb();
		if(swap < 0) {
			retVal = swap;
		}
		else {
			boolean flagCgroup = false;
			boolean flagNoCgroup = false;
			synchronized(this) {
				Iterator<IDuccProcess> iterator = this.values().iterator();
				while(iterator.hasNext()) {
					IDuccProcess process = iterator.next();
					double value = process.getSwapUsageMax();
					if(value == SpecialValue.Unknown.getlong()) {
						// skip it
					}
					else {
						if(value < 0) {
							flagNoCgroup = true;
						}
						else {
							flagCgroup = true;
							retVal += value/Constants.GB;
						}
					}
				}
			}
			if(flagCgroup && flagNoCgroup) {
				if(retVal > 0){
					retVal = -3;
				}
				else {
					retVal = -2;
				}
			}
			else if(flagNoCgroup) {
				retVal = -1;
			}
		}
		return retVal;
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -