agave-jobs/jobs-core/src/main/java/org/iplantc/service/jobs/managers/JobRequestQueueProcessor.java
/**
	 * Parses out all resource and queue info from the request and populates the internal variables with the info.
	 * @param jobRequestMap job request map sent from the user
	 * @throws JobProcessingException if a resource reqeut parameter is invalid, or either of the queue names is invalid
	 */
Parses out all resource and queue info from the request and populates the internal variables with the info.
@param jobRequestMap job request map sent from the user
@throws JobProcessingException if a resource reqeut parameter is invalid, or either of the queue names is invalid
Parses out all resource and queue info from the request and populates the internal variables with the info . @param jobRequestMap job request map sent from the user @throws JobProcessingException if a resource reqeut parameter is invalid or either of the queue names is invalid
protected void parseResourceRequestFromJobRequest(Map<String, Object> jobRequestMap) throws JobProcessingException, NoMatchingBatchQueueException {
		String userBatchQueueName = (String)jobRequestMap.get("batchQueue");
		if (StringUtils.isEmpty(userBatchQueueName)) {
			userBatchQueueName = (String)jobRequestMap.get("queue");
		}
		setUserBatchQueue(userBatchQueueName);
		setSoftwareBatchQueue(getSoftware().getDefaultQueue());
		String userNodeCount = (String)jobRequestMap.get("nodeCount");
		getResourceRequest().setMaxNodes(userNodeCount);
		String userMemoryPerNode = (String)jobRequestMap.get("memoryPerNode");
		if (StringUtils.isEmpty(userMemoryPerNode)) {
			userMemoryPerNode = (String)jobRequestMap.get("maxMemory");
		}
		try {
			getResourceRequest().setMaxMemoryPerNode(userMemoryPerNode);
		} catch (JobProcessingException e) {
			if (getUserBatchQueue() != null) {
				getResourceRequest().setMaxMemoryPerNode(getUserBatchQueue().getMaxMemoryPerNode());
			} else if (getSoftwareBatchQueue() != null) {
				getResourceRequest().setMaxMemoryPerNode(getSoftwareBatchQueue().getMaxMemoryPerNode());
			} else {
			}
		}
		String userRequestedTime = (String)jobRequestMap.get("maxRunTime");
		if (StringUtils.isEmpty(userRequestedTime)) {
			userRequestedTime = (String)jobRequestMap.get("requestedTime");
		}
		getResourceRequest().setMaxRequestedTime(userRequestedTime);
		String userProcessorsPerNode = (String)jobRequestMap.get("processorsPerNode");
		if (StringUtils.isEmpty(userProcessorsPerNode)) {
			userProcessorsPerNode = (String)jobRequestMap.get("processorCount");
		}
		getResourceRequest().setMaxProcessorsPerNode(userProcessorsPerNode);
	}
protected void parseResourceRequestFromJobRequest ( Map < String , Object > jobRequestMap ) throws JobProcessingException , NoMatchingBatchQueueException { String userBatchQueueName = ( String ) jobRequestMap . get ( "batchQueue" ) ; if ( StringUtils . isEmpty ( userBatchQueueName ) ) { userBatchQueueName = ( String ) jobRequestMap . get ( "queue" ) ; } setUserBatchQueue ( userBatchQueueName ) ; setSoftwareBatchQueue ( getSoftware ( ) . getDefaultQueue ( ) ) ; String userNodeCount = ( String ) jobRequestMap . get ( "nodeCount" ) ; getResourceRequest ( ) . setMaxNodes ( userNodeCount ) ; String userMemoryPerNode = ( String ) jobRequestMap . get ( "memoryPerNode" ) ; if ( StringUtils . isEmpty ( userMemoryPerNode ) ) { userMemoryPerNode = ( String ) jobRequestMap . get ( "maxMemory" ) ; } try { getResourceRequest ( ) . setMaxMemoryPerNode ( userMemoryPerNode ) ; } catch ( JobProcessingException e ) { if ( getUserBatchQueue ( ) != null ) { getResourceRequest ( ) . setMaxMemoryPerNode ( getUserBatchQueue ( ) . getMaxMemoryPerNode ( ) ) ; } else if ( getSoftwareBatchQueue ( ) != null ) { getResourceRequest ( ) . setMaxMemoryPerNode ( getSoftwareBatchQueue ( ) . getMaxMemoryPerNode ( ) ) ; } else { } } String userRequestedTime = ( String ) jobRequestMap . get ( "maxRunTime" ) ; if ( StringUtils . isEmpty ( userRequestedTime ) ) { userRequestedTime = ( String ) jobRequestMap . get ( "requestedTime" ) ; } getResourceRequest ( ) . setMaxRequestedTime ( userRequestedTime ) ; String userProcessorsPerNode = ( String ) jobRequestMap . get ( "processorsPerNode" ) ; if ( StringUtils . isEmpty ( userProcessorsPerNode ) ) { userProcessorsPerNode = ( String ) jobRequestMap . get ( "processorCount" ) ; } getResourceRequest ( ) . setMaxProcessorsPerNode ( userProcessorsPerNode ) ; }
Parses out all resource and queue info from the request and populates the internal variables with the info.
Parses out all resource and queue info from the request and populates the internal variables with the info .
// pull batch queue value from job requet // if that's not supplied, check the legacy queue parameter // if a queue is defined by the Software, resolve that as well // pull nodecount value from job request // pull memory per node value from job request // fall back on legacy field name if the current one is not present // use the max run time for the queue if no time was given by the user or system //				throw e; // pull max runtime value from job requet // fall back on legacy field name if the current one is not present // legacy compatibility // pull batch processors per node value from job request // fall back on legacy field name if the current one is not present