X-Git-Url: http://source.jalview.org/gitweb/?a=blobdiff_plain;f=src%2Fjalview%2Fws%2FAWSThread.java;h=5748414ab2e8438a114ba0d9e55dbeede4a56021;hb=2db272981f2778cc64df63bab6893c8347e120f8;hp=2ef525640850f891bd26f9ed8b2c0c729bb35cc8;hpb=f0a4a06301b7c7c4f103af39a10da7e0b3b4f084;p=jalview.git diff --git a/src/jalview/ws/AWSThread.java b/src/jalview/ws/AWSThread.java index 2ef5256..5748414a 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,115 +105,95 @@ 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; + Cache.log.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()) + JobStateSummary jstate = new JobStateSummary(); + for (final AWsJob job : jobs) { - StartJob(jobs[j]); - } - - if (jobs[j].submitted && !jobs[j].subjobComplete) - { - 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")); - } - jalview.bin.Cache.log.debug("Job " + j + " Result state " - + jobs[j].getState() + "(ServerError=" - + jobs[j].isServerError() + ")"); - } catch (Exception ex) + StartJob(job); + } + Cache.log.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 - Cache.log.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) + Cache.log.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 + Cache.log.debug(format("Job %s Result state:%s(ServerError=%b)", + job, job.getState(), job.isServerError())); + } catch (Exception exc) { - jobs[j].allowedServerExceptions--; - Cache.log.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 + Cache.log.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 { + Cache.log.warn(format("Dropping job %s %s", job, job.jobId)); + job.subjobComplete = true; + wsInfo.setStatus(job.jobnum, WebserviceInfo.STATE_STOPPED_SERVERERROR); } - } - else + } catch (OutOfMemoryError oomerror) { - Cache.log.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); + Cache.log.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); - Cache.log.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) - { - Cache.log - .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 - { - Cache.log - .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) @@ -233,40 +223,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) - { - super(group, target); - } - - public AWSThread(ThreadGroup group, String name) - { - super(group, name); - } - - public AWSThread(Runnable target, String name) + + public void interrupt() { - super(target, name); - } - - public AWSThread(ThreadGroup group, Runnable target, String name) - { - super(group, target, name); + timer.stop(); } /** @@ -319,12 +279,6 @@ public abstract class AWSThread extends Thread } } - public AWSThread(ThreadGroup group, Runnable target, String name, - long stackSize) - { - super(group, target, name, stackSize); - } - /** * * @return gap character to use for any alignment generation @@ -338,7 +292,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 @@ -383,7 +337,7 @@ public abstract class AWSThread extends Thread .getCodonFrames(); if (cf != null) { - codonframe = new ArrayList(); + codonframe = new ArrayList<>(); codonframe.addAll(cf); } }