X-Git-Url: http://source.jalview.org/gitweb/?a=blobdiff_plain;f=src%2Fjalview%2Fws%2FAWSThread.java;h=021382ce607cca961186812f53a2e0eee2e4b992;hb=d043ce47fc710d3eb2629ba926a8a7417bd67d8c;hp=6746d1a6a8cc12cf2b40b043e69f2c23ce68e7c0;hpb=04c8f7bff663aa469127e9eed4164e02933782f1;p=jalview.git diff --git a/src/jalview/ws/AWSThread.java b/src/jalview/ws/AWSThread.java index 6746d1a..021382c 100644 --- a/src/jalview/ws/AWSThread.java +++ b/src/jalview/ws/AWSThread.java @@ -34,8 +34,16 @@ import jalview.viewmodel.seqfeatures.FeatureRendererSettings; import java.util.ArrayList; import java.util.List; -public abstract class AWSThread extends Thread +import static java.lang.String.format; + +import java.awt.event.ActionEvent; +import java.awt.event.ActionListener; +import javax.swing.Timer; + +public abstract class AWSThread { + + private javax.swing.Timer timer; /** * view that this job was associated with @@ -64,13 +72,15 @@ public abstract class AWSThread extends Thread /** * are there jobs still running in this thread. + * + * fixme: initialize with an empty array? */ protected boolean jobComplete = false; /** * one or more jobs being managed by this thread. */ - protected AWsJob jobs[] = null; + protected AWsJob[] jobs = null; /** * full name of service @@ -95,113 +105,96 @@ public abstract class AWSThread extends Thread */ private AlignFrame alignFrame; - /** - * generic web service job/subjob poll loop - */ - @Override - public void run() + public void start() { - JobStateSummary jstate = null; if (jobs == null) { jobComplete = true; + Console.debug( + "WebServiceJob poll loop finished with no jobs created."); + wsInfo.setStatus(WebserviceInfo.STATE_STOPPED_ERROR); + wsInfo.appendProgressText( + MessageManager.getString("info.no_jobs_ran")); + wsInfo.setFinishedNoResults(); + return; } - while (!jobComplete) + timer = new Timer(5000, new ActionListener() { - jstate = new JobStateSummary(); - for (int j = 0; j < jobs.length; j++) + + @Override + public void actionPerformed(ActionEvent e) { - if (!jobs[j].submitted && jobs[j].hasValidInput()) - { - StartJob(jobs[j]); - } - - if (jobs[j].submitted && !jobs[j].subjobComplete) + JobStateSummary jstate = new JobStateSummary(); + for (final AWsJob job : jobs) { - try + if (!job.submitted && job.hasValidInput()) { - pollJob(jobs[j]); - if (!jobs[j].hasResponse()) - { - throw (new Exception( - "Timed out when communicating with server\nTry again later.\n")); - } - Console.debug("Job " + j + " Result state " + jobs[j].getState() - + "(ServerError=" + jobs[j].isServerError() + ")"); - } catch (Exception ex) + StartJob(job); + } + Console.debug(format( + "Job %s is %ssubmitted", job, job.submitted ? "" : "not ")); + if (job.submitted && !job.subjobComplete) { - // Deal with Transaction exceptions - wsInfo.appendProgressText(jobs[j].jobnum, MessageManager - .formatMessage("info.server_exception", new Object[] - { WebServiceName, ex.getMessage() })); - // always output the exception's stack trace to the log - Console.warn(WebServiceName + " job(" + jobs[j].jobnum - + ") Server exception."); - // todo: could limit trace to cause if this is a SOAPFaultException. - ex.printStackTrace(); - - if (jobs[j].allowedServerExceptions > 0) + Console.debug(format( + "Polling Job %s Result state was:%s(ServerError=%b)", + job, job.getState(), job.isServerError())); + try + { + pollJob(job); + if (!job.hasResponse()) + throw new Exception("Timed out when communicating with server. Try again later."); + else + Console.debug(format("Job %s Result state:%s(ServerError=%b)", + job, job.getState(), job.isServerError())); + } catch (Exception exc) { - jobs[j].allowedServerExceptions--; - Console.debug("Sleeping after a server exception."); - try + // Deal with Transaction exceptions + wsInfo.appendProgressText(job.jobnum, MessageManager + .formatMessage("info.server_exception", WebServiceName, + exc.getMessage())); + // always output the exception's stack trace to the log + Console.warn(format("%s job(%s) Server exception.", + WebServiceName, job.jobnum)); + exc.printStackTrace(); + + if (job.allowedServerExceptions > 0) { - Thread.sleep(5000); - } catch (InterruptedException ex1) + job.allowedServerExceptions--; + } + else { + Console.warn(format("Dropping job %s %s", job, job.jobId)); + job.subjobComplete = true; + wsInfo.setStatus(job.jobnum, WebserviceInfo.STATE_STOPPED_SERVERERROR); } - } - else + } catch (OutOfMemoryError oomerror) { - Console.warn("Dropping job " + j + " " + jobs[j].jobId); - jobs[j].subjobComplete = true; - wsInfo.setStatus(jobs[j].jobnum, - WebserviceInfo.STATE_STOPPED_SERVERERROR); + jobComplete = true; + job.subjobComplete = true; + job.clearResponse(); + wsInfo.setStatus(job.jobnum, WebserviceInfo.STATE_STOPPED_ERROR); + Console.error(format("Out of memory when retrieving Job %s id:%s/%s", + job, WsUrl, job.jobId), oomerror); + new jalview.gui.OOMWarning("retrieving result for " + WebServiceName, oomerror); + System.gc(); } - } catch (OutOfMemoryError er) - { - jobComplete = true; - jobs[j].subjobComplete = true; - jobs[j].clearResponse(); // may contain out of date result data - wsInfo.setStatus(jobs[j].jobnum, - WebserviceInfo.STATE_STOPPED_ERROR); - Console.error("Out of memory when retrieving Job " + j + " id:" - + WsUrl + "/" + jobs[j].jobId, er); - new jalview.gui.OOMWarning( - "retrieving result for " + WebServiceName, er); - System.gc(); } + jstate.updateJobPanelState(wsInfo, OutputHeader, job); } - jstate.updateJobPanelState(wsInfo, OutputHeader, jobs[j]); - } - // Decide on overall state based on collected jobs[] states - updateGlobalStatus(jstate); - if (!jobComplete) - { - try + // Decide on overall state based on collected jobs[] states + updateGlobalStatus(jstate); + if (jobComplete) { - Thread.sleep(5000); - } catch (InterruptedException e) - { - Console.debug("Interrupted sleep waiting for next job poll.", e); + timer.stop(); + // jobs should never be null at this point + parseResult(); // tidy up and make results available to user + } - // System.out.println("I'm alive "+alTitle); } - } - if (jobComplete && jobs != null) - { - parseResult(); // tidy up and make results available to user - } - else - { - Console.debug( - "WebServiceJob poll loop finished with no jobs created."); - wsInfo.setStatus(WebserviceInfo.STATE_STOPPED_ERROR); - wsInfo.appendProgressText( - MessageManager.getString("info.no_jobs_ran")); - wsInfo.setFinishedNoResults(); - } + }); + timer.setInitialDelay(0); + timer.start(); } protected void updateGlobalStatus(JobStateSummary jstate) @@ -232,39 +225,10 @@ public abstract class AWSThread extends Thread } } - public AWSThread() - { - super(); - } - - public AWSThread(Runnable target) - { - super(target); - } - - public AWSThread(String name) - { - super(name); - } - - public AWSThread(ThreadGroup group, Runnable target) + + public void interrupt() { - super(group, target); - } - - public AWSThread(ThreadGroup group, String name) - { - super(group, name); - } - - public AWSThread(Runnable target, String name) - { - super(target, name); - } - - public AWSThread(ThreadGroup group, Runnable target, String name) - { - super(group, target, name); + timer.stop(); } /** @@ -317,11 +281,6 @@ public abstract class AWSThread extends Thread } } - public AWSThread(ThreadGroup group, Runnable target, String name, - long stackSize) - { - super(group, target, name, stackSize); - } /** * @@ -336,7 +295,7 @@ public abstract class AWSThread extends Thread * * @param alignFrame * reference for copying mappings across - * @param wsInfo + * @param wsinfo * gui attachment point * @param input * input data for the calculation @@ -381,7 +340,7 @@ public abstract class AWSThread extends Thread .getCodonFrames(); if (cf != null) { - codonframe = new ArrayList(); + codonframe = new ArrayList<>(); codonframe.addAll(cf); } }