af.basl

openPBS的开放源代码

		str = "1st job in fast whose JobDateTimeCreatedGet < 4|9|1997@12h0m0s: " + "NOJOB";
	}
	print(str);

	i = 1;
	job = QueJobFind(que, JobCpuTimeUsedGet, OP_GT, i);
	if( job NEQ NOJOB ) {
		str = "1st job in fast whose JobCpuTimeUsedGet > 10: " + JobIdGet(job);
	} else {
		str = "1st job in fast whose JobCpuTimeUsedGet > 10: " + "NOJOB";
	}
	print(str);

	job = QueJobFind(que, JobVirtualMemAvailGet, OP_LE, 30mb);
	if( job NEQ NOJOB ) {
		str = "1st job in fast whose JobVirtualMemAvailGet <= 30mb: " + JobIdGet(job);
	} else {
		str = "1st job in fast whose JobVirtualMemAvailGet <= 30mb: " + "NOJOB";
	}
	print(str);

	job = QueJobFind(que, JobCpuTimeReqGet, OP_MAX);
	if( job NEQ NOJOB ) {
		str = "1st job in fast whose JobCpuTimeReqGet is MAX: " + JobIdGet(job);
	} else {
		str = "1st job in fast whose JobCpuTimeReqGet is MAX: " + "NOJOB";
	}
	print(str);

	job = QueJobFind(que, JobCpuTimeReqGet, OP_MIN);
	if( job NEQ NOJOB ) {
		str = "1st job in fast whose JobCpuTimeReqGet is MIN: " + JobIdGet(job);
	} else {
		str = "1st job in fast whose JobCpuTimeReqGet is MIN: " + "NOJOB";
	}
	print(str);

	i = 300;
	newq = QueFilter(que, JobWallTimeReqGet, OP_EQ, i);
	if( newq NEQ NOQUE ) {
		str = "jobs in fast whose wallTimeReq == 300s: ";
		alljs = QueJobsGet(newq);
		foreach( j in alljs ) {
			str = str + JobIdGet(j) + " ";
		}
	} else {
		str = "jobs in fast whose wallTimeReq == 300s: " + "NOQUE";
	}
	print(str);

	str = "bayucan";
	newq = QueFilter(que, JobEmailAddrGet, OP_NEQ, str);
	if( newq NEQ NOQUE ) {
		str = "jobs in fast whose JobEmailAddrGet != bayucan: ";
		alljs = QueJobsGet(newq);
		foreach( j in alljs ) {
			str = str + JobIdGet(j) + " ";
		}
	} else {
		str = "jobs in fast whose JobEmailAddrGet != bayucan: " + "NOQUE"; 
	}
	print(str);


	d = (4|9|1997);
	newq = QueFilter(que, JobDateTimeCreatedGet, OP_GE, d);
	if( newq NEQ NOQUE ) {
		str = "jobs in fast whose JobDateTimeCreatedGet >= 4|9|1997: ";
		alljs = QueJobsGet(newq);
		foreach( j in alljs ) {
			str = str + JobIdGet(j) + " ";
		}
	} else {
		str = "jobs in fast whose JobDateTimeCreatedGet >= 4|9|1997: " + "NOQUE";
	}
	print(str);


	d = (12:00:00);
	newq = QueFilter(que, JobDateTimeCreatedGet, OP_GT, d);
	if( newq NEQ NOQUE ) {
		str = "jobs in fast whose JobDateTimeCreatedGet > 12h0m0s: ";
		alljs = QueJobsGet(newq);
		foreach( j in alljs ) {
			str = str + JobIdGet(j) + " ";
		}
	} else {
		str = "jobs in fast whose JobDateTimeCreatedGet > 12h0m0s: " + "NOQUE";
	}
	print(str);

	d = (4|9|1997@12:0:0);
	newq = QueFilter(que, JobDateTimeCreatedGet, OP_LT, d);
	if( newq NEQ NOQUE ) {
		str = "jobs in fast whose JobDateTimeCreatedGet < 4|9|1997@12h0m0s: ";
		alljs = QueJobsGet(newq);
		foreach( j in alljs ) {
			str = str + JobIdGet(j) + " ";
		}
	} else {
		str = "jobs in fast whose JobDateTimeCreatedGet < 4|9|1997@14h58m44s: " + "NOQUE";
	}
	print(str);

	i = 10;
	newq = QueFilter(que, JobCpuTimeUsedGet, OP_GT, i);
	if( newq NEQ NOQUE ) {
		str = "jobs in fast whose JobCpuTimeUsedGet > 10: ";
		alljs = QueJobsGet(newq);
		foreach( j in alljs ) {
			str = str + JobIdGet(j) + " ";
		}
	} else {
		str = "jobs in fast whose JobCpuTimeUsedGet > 10: " + "NOQUE";
	}
	print(str);

	newq = QueFilter(que, JobVirtualMemAvailGet, OP_LE, 30mb);
	if( newq NEQ NOQUE ) {
		str = "jobs in fast whose JobVirtualMemAvailGet <= 30mb: ";
		alljs = QueJobsGet(newq);
		foreach( j in alljs ) {
			str = str + JobIdGet(j) + " ";
		}
	} else {
		str = "jobs in fast whose JobVirtualMemAvailGet <= 30mb: " + "NOQUE";
	}
	print(str);


	s   = AllServersHeadGet();
	sq  = 	ServerQueuesGet(s) ;
	que = findQueByName(sq, "fast");

	alljs = QueJobsGet(que);

	i = 1;
	foreach( j in alljs ) {
	   str = "JobAction[" + JobIdGet(j); 
	   switch(i) {
	     case 1:
	      {
		res = JobAction(j, SYNCRUN, NULLSTR);
		hstr = str;
                str = hstr + "," + "SYNCRUN" + "," + "NULLSTR" + "]: "; 
		if( res EQ SUCCESS ) {
		        str = str + "SUCCESS"; 
		} else {
			if( res EQ FAIL ) { 
		        	str = str + "FAIL"; 
			}
		}
		print(str);

		res = JobAction(j, SIGNAL, "SIGHUP");
                str = hstr + "," + "SIGNAL" + "," + "SIGHUP" + "]: "; 
		if( res EQ SUCCESS ) { 
		        str = str + "SUCCESS"; 
		} else {
			if( res EQ FAIL ) { 
		        	str = str + "FAIL"; 
			}
		}
		print(str);
		res = JobAction(j, RERUN, NULLSTR);
                str = hstr + "," + "RERUN" + "," + "NULLSTR" + "]: "; 
		if( res EQ SUCCESS ) { 
		        str = str + "SUCCESS"; 
		} else {
			if( res EQ FAIL ) { 
		        	str = str + "FAIL"; 
			}
		}
		print(str);

		res = JobAction(j, ASYNCRUN, mom_name1);
                str = hstr + "," + "ASYNCRUN" + "," + mom_name1 + "]: "; 
		if( res EQ SUCCESS ) { 
		        str = str + "SUCCESS"; 
		} else {
			if( res EQ FAIL ) { 
		        	str = str + "FAIL"; 
			}
		}
		print(str);
		JobAction(j, SIGNAL, "SIGKILL");
		JobAction(j, DELETE, NULLSTR);

	      }

	     case 2:
	      {
		res = JobAction(j, DELETE, NULLSTR);
                str = str + "," + "DELETE" + "," + "NULLSTR" + "]: "; 
		if( res EQ SUCCESS ) { 
		        str = str + "SUCCESS"; 
		} else {
			if( res EQ FAIL ) { 
		        	str = str + "FAIL";
			}
		}
		print(str);
	      } 

	     case 3:
	      {

		res = JobAction(j, DELETE, "deldelay=5");
                str = str + "," + "DELETE" + "," + "deldelay=5" + "]: "; 
		if( res EQ SUCCESS ) { 
		        str = str + "SUCCESS"; 
		} else {
			if( res EQ FAIL ) { 
		        	str = str + "FAIL"; 
			}
		}
		print(str);
	      }	


	
	     case 4:
	      {
		res = JobAction(j, HOLD, "u");
                str = str + "," + "HOLD" + "," + "u" + "]: "; 
		if( res EQ SUCCESS ) { 
		        str = str + "SUCCESS"; 
		} else {
			if( res EQ FAIL ) { 
		        	str = str + "FAIL"; 
			}
		}
		print(str);
	      }
	     case 5:
	      { 
		res = JobAction(j, HOLD, "u");
                str = str + "," + "HOLD" + "," + "u" + "]: "; 
		if( res EQ SUCCESS ) { 
		        str = str + "SUCCESS"; 
		} else {
			if( res EQ FAIL ) { 
		        	str = str + "FAIL"; 
			}
		}
		res = JobAction(j, RELEASE, "u");
                str = str + "," + "RELEASE" + "," + "u" + "]: "; 
		if( res EQ SUCCESS ) { 
		        str = str + "SUCCESS"; 
		} else {
			if( res EQ FAIL ) { 
		        	str = str + "FAIL"; 
			}
		}
		print(str);
	      } 	


	     case 6:
	      {
		res = JobAction(j, HOLD, "o");
                str = str + "," + "HOLD" + "," + "o" + "]: "; 
		if( res EQ SUCCESS ) { 
		        str = str + "SUCCESS"; 
		} else {
			if( res EQ FAIL ) { 
		        	str = str + "FAIL"; 
			}
		}
		print(str);
	      }

	     case 7:
	      {
		res = JobAction(j, HOLD, "o");
                str = str + "," + "HOLD" + "," + "o" + "]: "; 
		if( res EQ SUCCESS ) { 
		        str = str + "SUCCESS"; 
		} else {
			if( res EQ FAIL ) { 
		        	str = str + "FAIL"; 
			}
		}
		res = JobAction(j, RELEASE, "o");
                str = str + "," + "RELEASE" + "," + "o" + "]: "; 
		if( res EQ SUCCESS ) { 
		        str = str + "SUCCESS"; 
		} else {
			if( res EQ FAIL ) { 
		        	str = str + "FAIL"; 
			}
		}
		print(str);
	      } 	

	     case 8:
	      {
		res = JobAction(j, HOLD, "s");
                str = str + "," + "HOLD" + "," + "s" + "]: "; 
		if( res EQ SUCCESS ) { 
		        str = str + "SUCCESS"; 
		} else {
			if( res EQ FAIL ) { 
		        	str = str + "FAIL"; 
			}
		}
		print(str);
	      }

	    case 9:
	      {
		res = JobAction(j, HOLD, "s");
                str = str + "," + "HOLD" + "," + "s" + "]: "; 
		if( res EQ SUCCESS ) { 
		        str = str + "SUCCESS"; 
		} else {
			if( res EQ FAIL ) { 
		        	str = str + "FAIL"; 
			}
		}
		res = JobAction(j, RELEASE, "s");
                str = str + "," + "RELEASE" + "," + "s" + "]: "; 
		if( res EQ SUCCESS ) { 
		        str = str + "SUCCESS"; 
		} else {
			if( res EQ FAIL ) { 
		        	str = str + "FAIL"; 
			}
		}
		print(str);

	      } 	

	     case 10:
	      {
		res = JobAction(j, HOLD, NULLSTR);
                str = str + "," + "HOLD" + "," + "NULLSTR" + "]: "; 
		if( res EQ SUCCESS ) { 
		        str = str + "SUCCESS"; 
		} else {
			if( res EQ FAIL ) { 
		        	str = str + "FAIL"; 
			}
		}
		print(str);

	      }	

	    case 11:
	      {  
		res = JobAction(j, HOLD, NULLSTR);
                str = str + "," + "HOLD" + "," + "NULLSTR" + "]: "; 
		if( res EQ SUCCESS ) { 
		        str = str + "SUCCESS"; 
		} else {
			if( res EQ FAIL ) { 
		        	str = str + "SUCCESS"; 
			}
		}

		res = JobAction(j, RELEASE, NULLSTR);
                str = str + "," + "RELEASE" + "," + "NULLSTR" + "]: "; 
		if( res EQ SUCCESS ) { 
		        str = str + "SUCCESS"; 
		} else {
			if( res EQ FAIL ) { 
		        	str = str + "FAIL"; 
			}
		}
		print(str);
	      }

	     case 12:
	      {
		res = JobAction(j, HOLD, "p");
                str = str + "," + "HOLD" + "," + "p" + "]: "; 
		if( res EQ SUCCESS ) { 
		        str = str + "SUCCESS"; 
		} else {
			if( res EQ FAIL ) { 
		        	str = str + "FAIL"; 
			}
		}
		res = JobAction(j, RELEASE, "p");
                str = str + "," + "RELEASE" + "," + "p" + "]: "; 
		if( res EQ SUCCESS ) { 
		        str = str + "SUCCESS"; 
		} else {
			if( res EQ FAIL ) { 
		        	str = str + "FAIL"; 
			}
		}
		print(str);
	      }

	     case 13:
	      {

		res = JobAction(j, MODIFYATTR, "comment=what a message");
                str = str + "," + "MODIFYATTR" + "," + "comment=what a message" + "]: "; 
		if( res EQ SUCCESS ) { 
		        str = str + "SUCCESS"; 
		} else {
			if( res EQ FAIL ) { 
		        	str = str + "FAIL"; 
			}
		}
		print(str);
	      }
	     case 14:
	      {

		res = JobAction(j, MODIFYATTR, "what a message");
                str = str + "," + "MODIFYATTR" + "," + "what a message" + "]: "; 
		if( res EQ SUCCESS ) { 
		        str = str + "SUCCESS"; 
		} else {
			if( res EQ FAIL ) { 
		        	str = str + "FAIL"; 
			}
		}
		print(str);
	      }
	     case 15:
	      {

		res = JobAction(j, MODIFYRES, "cput=3600");
                str = str + "," + "MODIFYRES" + "," + "cput=3600" + "]: "; 
		if( res EQ SUCCESS ) { 
		        str = str + "SUCCESS"; 
		} else {
			if( res EQ FAIL ) { 
		        	str = str + "FAIL"; 
			}
		}
		print(str);
	      }
	     case 16:
	      {

		res = JobAction(j, MODIFYATTR, "comment=");
                str = str + "," + "MODIFYATTR" + "," + "comment=" + "]: "; 
		if( res EQ SUCCESS ) { 
		        str = str + "SUCCESS"; 
		} else {
			if( res EQ FAIL ) { 
		        	str = str + "FAIL"; 
			}
		}
		print(str);
	      }
	     case 17:
	      {

		res = JobAction(j, MODIFYRES, "=what");
                str = str + "," + "MODIFYRES" + "," + "=what" + "]: "; 
		if( res EQ SUCCESS ) { 
		        str = str + "SUCCESS"; 
		} else {
			if( res EQ FAIL ) { 
		        	str = str + "FAIL"; 
			}
		}
		print(str);
	      }
	     case 18:
	      {

		res = JobAction(j, MODIFYRES, "=");
                str = str + "," + "MODIFYRES" + "," + "=" + "]: "; 
		if( res EQ SUCCESS ) { 
		        str = str + "SUCCESS"; 
		} else {
			if( res EQ FAIL ) {
		        	str = str + "FAIL"; 
			}
		}
		print(str);
	      }
	   }
	   i++;
	}
}