Home
last modified time | relevance | path

Searched refs:STAXJob (Results 1 – 25 of 62) sorted by relevance

123

/dports/devel/staf/src/staf/services/stax/service/
H A DSTAXTestcase.java156 job.log(STAXJob.JOB_LOG, status, msg); in updateStatus()
160 public void start(STAXJob job) in start()
195 public void stop(STAXJob job, STAXTimestamp startTimestamp) in stop()
207 job.log(STAXJob.JOB_LOG, "warning", in stop()
222 job.log(STAXJob.JOB_LOG, "stop", "Testcase: " + fName + in stop()
285 job.log(STAXJob.JOB_LOG, "warning", in addElapsedTimes()
301 job.log(STAXJob.JOB_LOG, "warning", in addElapsedTimes()
329 job.log(STAXJob.JOB_LOG, "warning", in addElapsedTimes()
344 job.log(STAXJob.JOB_LOG, "warning", in addElapsedTimes()
360 job.log(STAXJob.JOB_LOG, "warning", in addElapsedTimes()
[all …]
H A DSTAXSubmitResult.java28 public STAXSubmitResult(STAFResult result, STAXJob job) in STAXSubmitResult()
38 (fJob.getState() == STAXJob.PENDING_STATE) && in STAXSubmitResult()
60 public STAXJob getJob() { return fJob; } in getJob()
61 public void setJob(STAXJob job) { fJob = job; } in setJob()
64 private STAXJob fJob = null;
H A DSTAXBlockAction.java98 fOwningThread.getJob().log(STAXJob.JOB_LOG, "info", msg); in holdBlock()
128 fOwningThread.getJob().log(STAXJob.JOB_LOG, "info", msg); in releaseBlock()
167 fOwningThread.getJob().log(STAXJob.JOB_LOG, "info", msg); in terminateBlock()
255 new Integer(STAXJob.ABNORMAL_STATUS)); in execute()
330 new Integer(STAXJob.ABNORMAL_STATUS)); in execute()
332 thread.getJob().log(STAXJob.JOB_LOG, "error", in execute()
366 new Integer(STAXJob.NORMAL_STATUS)); in execute()
383 thread.getJob().log(STAXJob.JOB_LOG, "error", in exitBlock()
399 thread.getJob().log(STAXJob.JOB_LOG, "error", in exitBlock()
447 new Integer(STAXJob.TERMINATED_STATUS)); in handleCondition()
[all …]
H A DSTAXJob.java112 public STAXJob(STAX staxService) { in STAXJob() method in STAXJob
354 return STAXJob.NORMAL_STATUS_STRING; in getCompletionStatusAsString()
1387 STAXJob job = null; in addImportedFunctions()
1789 int logfile = STAXJob.JOB_LOG; in addDefaultSignalHandlers()
1918 if (logfile == STAXJob.JVM_LOG) in log()
1936 if (logfile == STAXJob.SERVICE_LOG) in log()
1941 else if (logfile == STAXJob.JOB_LOG) in log()
2519 log(STAXJob.JOB_LOG, "stop", msg); in cleanupPendingJob()
2711 log(STAXJob.JVM_LOG, "Error", in writeStringToFile()
2827 STAFQueueMonitor(STAXJob job) in STAFQueueMonitor()
[all …]
H A DSTAXBlockActionFactory.java109 public void initJob(STAXJob job) in initJob()
115 job.log(STAXJob.JOB_LOG, "error", msg); in initJob()
119 public void terminateJob(STAXJob job) in terminateJob()
122 public STAFResult handleListRequest(String type, STAXJob job, in handleListRequest()
219 public STAFResult handleQueryJobRequest(STAXJob job, in handleQueryJobRequest()
274 public STAXAction parseAction(STAX staxService, STAXJob job, in parseAction()
408 STAXJob job = null; in handleRequest()
438 if ((job.getState() == STAXJob.PENDING_STATE) && in handleRequest()
549 job.log(STAXJob.JOB_LOG, "info", msg); in handleRequest()
559 job.log(STAXJob.JOB_LOG, "info", msg); in handleRequest()
[all …]
H A DSTAXParser.java61 public STAXJob parse(String xmlSource, String xmlFile, String xmlMachine, in parse()
62 STAXJob job) throws STAXException in parse()
138 job = new STAXJob(fSTAX); in parse()
239 public STAXJob parse(String xmlSource, String xmlFile, String xmlMachine) in parse()
252 public STAXJob parse(InputSource xmlSource) throws STAXException in parse()
254 STAXJob job = null; in parse()
262 job = new STAXJob(fSTAX); in parse()
331 private void handleDefaultFunction(STAXJob job, in handleDefaultFunction()
H A DSTAXBreakpointActionFactory.java328 STAXJob job = null; in handleAddRequest()
330 job = (STAXJob)staxService.getJobMap().get(jobID); in handleAddRequest()
500 STAXJob job = null; in handleRemoveRequest()
502 job = (STAXJob)staxService.getJobMap().get(jobID); in handleRemoveRequest()
571 STAXJob job = null; in handleResumeRequest()
573 job = (STAXJob)staxService.getJobMap().get(jobID); in handleResumeRequest()
663 STAXJob job = null; in handleStepRequest()
795 public STAFResult handleQueryJobRequest(STAXJob job, in handleQueryJobRequest()
978 public void initJob(STAXJob job) in initJob()
984 job.log(STAXJob.JOB_LOG, "error", msg); in initJob()
[all …]
H A DSTAXSTAFCommandActionFactory.java87 public STAXAction parseAction(STAX staxService, STAXJob job, in parseAction()
187 public void initJob(STAXJob job) in initJob()
197 job.log(STAXJob.JOB_LOG, "error", msg); in initJob()
201 public void terminateJob(STAXJob job) in terminateJob()
207 public STAFResult handleListRequest(String type, STAXJob job, in handleListRequest()
265 public STAFResult handleQueryRequest(String type, String key, STAXJob job, in handleQueryRequest()
315 public STAFResult handleQueryJobRequest(STAXJob job, in handleQueryJobRequest()
H A DSTAXTestcaseActionFactory.java199 public void initJob(STAXJob job) in initJob()
205 job.log(STAXJob.JOB_LOG, "error", msg); in initJob()
213 job.log(STAXJob.JOB_LOG, "error", msg); in initJob()
217 public void terminateJob(STAXJob job) in terminateJob()
250 job.log(STAXJob.JOB_LOG, "warning", in terminateJob()
352 job.log(STAXJob.JOB_LOG, "status", msg); in terminateJob()
497 public STAFResult handleQueryJobRequest(STAXJob job, in handleQueryJobRequest()
651 STAXJob job = null; in handleUpdateRequest()
653 job = (STAXJob)staxService.getJobMap().get(jobID); in handleUpdateRequest()
879 STAXJob job = null; in handleStartRequest()
[all …]
H A DSTAXLogActionFactory.java103 public STAXAction parseAction(STAX staxService, STAXJob job, in parseAction()
107 action.setLogfile(STAXJob.USER_JOB_LOG); in parseAction()
224 STAXJob job = null; in handleLogRequest()
226 job = (STAXJob)staxService.getJobMap().get(jobID); in handleLogRequest()
258 res = job.log(STAXJob.USER_JOB_LOG, level, message); in handleLogRequest()
H A DSTAXJobCompleteNotifiee.java27 public void jobComplete(STAXJob job) in jobComplete()
58 if (fNotifyOnEnd == STAXJob.NOTIFY_ONEND_BY_HANDLE) in jobComplete()
74 if (fNotifyOnEnd == STAXJob.NOTIFY_ONEND_BY_HANDLE) in getNotifyByString()
H A DSTAXJobManagementHandler.java34 public void initJob(STAXJob job); in initJob()
43 public void terminateJob(STAXJob job); in terminateJob()
H A DSTAXTestcaseAction.java155 thread.getJob().log(STAXJob.JOB_LOG, "error", in execute()
189 STAXJob.JOB_LOG, "warning", in execute()
273 STAXJob.JOB_LOG, "warning", in exitTestcase()
286 fThread.getJob().log(STAXJob.JOB_LOG, "error", in exitTestcase()
302 fThread.getJob().log(STAXJob.JOB_LOG, "error", in exitTestcase()
H A DSTAXPythonOutput.java58 private STAXJob fJob = null;
75 public STAXPythonOutput(STAXJob job) in STAXPythonOutput()
88 public STAXPythonOutput(STAXJob job, String logLevel) in STAXPythonOutput()
187 STAXJob.USER_JOB_LOG, fLogLevel, fData.toString()); in writeToJobUserLog()
H A DSTAXQueryRequestHandler.java13 public STAFResult handleQueryRequest(String type, String key, STAXJob job, in handleQueryRequest()
16 public STAFResult handleQueryJobRequest(STAXJob job, in handleQueryJobRequest()
H A DSTAXPythonInterpreter.java83 STAXJob job) in STAXPythonInterpreter()
140 private STAXJob fJob = null;
H A DSTAXProcessActionFactory.java166 public STAXAction parseAction(STAX staxService, STAXJob job, in parseAction()
660 public void handleQueueMessage(STAXSTAFMessage message, STAXJob job) in handleQueueMessage()
734 job.log(STAXJob.JOB_LOG, "warning", msg); in handleQueueMessage()
756 public void initJob(STAXJob job) in initJob()
764 job.log(STAXJob.JOB_LOG, "error", msg); in initJob()
774 job.log(STAXJob.JOB_LOG, "error", msg); in initJob()
780 public void terminateJob(STAXJob job) in terminateJob()
786 public STAFResult handleListRequest(String type, STAXJob job, in handleListRequest()
998 public STAFResult handleQueryJobRequest(STAXJob job, in handleQueryJobRequest()
1083 STAXJob job = null; in handleStopRequest()
[all …]
H A DSTAXMessageActionFactory.java101 public STAXAction parseAction(STAX staxService, STAXJob job, in parseAction()
221 STAXJob job = null; in handleSendRequest()
223 job = (STAXJob)staxService.getJobMap().get(jobID); in handleSendRequest()
H A DSTAXThread.java560 public STAXThread(STAXJob job) in STAXThread()
798 public STAXJob getJob() { return fJob; } in getJob()
1207 getJob().log(STAXJob.JOB_LOG, "error", "Duplicate signal " + name + in raiseSignal()
1239 getJob().log(STAXJob.JOB_LOG, "error", "No signal " + in raiseSignal()
1691 fJob.setCompletionStatus(STAXJob.ABNORMAL_STATUS); in execute()
1693 fJob.log(STAXJob.JOB_LOG, "error", "Error evaluating" + in execute()
1713 fJob.setCompletionStatus(STAXJob.ABNORMAL_STATUS); in execute()
1746 fJob.log(STAXJob.JOB_LOG, "error", in execute()
1930 private STAXJob fJob = null;
H A DSTAXIfActionFactory.java47 public STAXAction parseAction(STAX staxService, STAXJob job, in parseAction()
144 private STAXElseIf handleElseifChild(STAX staxService, STAXJob job, in handleElseifChild()
204 private STAXAction handleElseChild(STAX staxService, STAXJob job, in handleElseChild()
H A DSTAXTryActionFactory.java56 public STAXAction parseAction(STAX staxService, STAXJob job, in parseAction()
141 private STAXCatchAction handleCatch(STAX staxService, STAXJob job, in handleCatch()
228 private STAXFinallyAction handleFinally(STAX staxService, STAXJob job, in handleFinally()
H A DSTAXJobActionFactory.java69 public STAXAction parseAction(STAX staxService, STAXJob job, in parseAction()
493 public void initJob(STAXJob job) in initJob()
502 job.log(STAXJob.JOB_LOG, "error", msg); in initJob()
506 public void terminateJob(STAXJob job) in terminateJob()
524 public STAFResult handleListRequest(String type, STAXJob job, in handleListRequest()
/dports/devel/staf/src/staf/services/stax/beta/service/
H A DSTAXJob.java110 public STAXJob(STAX staxService) { in STAXJob() method in STAXJob
351 return STAXJob.NORMAL_STATUS_STRING; in getCompletionStatusAsString()
1345 STAXJob job = null; in addImportedFunctions()
1752 int logfile = STAXJob.JOB_LOG; in addDefaultSignalHandlers()
1876 if (logfile == STAXJob.JVM_LOG) in log()
1897 if (logfile == STAXJob.SERVICE_LOG) in log()
1902 else if (logfile == STAXJob.JOB_LOG) in log()
2478 log(STAXJob.JOB_LOG, "stop", msg); in cleanupPendingJob()
2668 log(STAXJob.JVM_LOG, "Error", in writeStringToFile()
2748 STAFQueueMonitor(STAXJob job) in STAFQueueMonitor()
[all …]
H A DSTAXThread.java518 public STAXThread(STAXJob job) in STAXThread()
744 public STAXJob getJob() { return fJob; } in getJob()
1141 getJob().log(STAXJob.JOB_LOG, "error", "Duplicate signal " + name + in raiseSignal()
1173 getJob().log(STAXJob.JOB_LOG, "error", "No signal " + in raiseSignal()
1620 fJob.setCompletionStatus(STAXJob.ABNORMAL_STATUS); in execute()
1622 fJob.log(STAXJob.JOB_LOG, "error", "Error evaluating" + in execute()
1645 fJob.setCompletionStatus(STAXJob.ABNORMAL_STATUS); in execute()
1678 fJob.log(STAXJob.JOB_LOG, "error", in execute()
1861 private STAXJob fJob = null;
/dports/devel/staf/src/staf/services/stax/ext/delay/
H A DExtDelayActionFactory.java113 public STAXAction parseAction(STAX staxService, STAXJob job, in parseAction()
152 public void initJob(STAXJob job) in initJob()
165 STAXJob.JOB_LOG)); in initJob()
183 public void terminateJob(STAXJob job) in terminateJob()

123