X-Git-Url: http://source.jalview.org/gitweb/?a=blobdiff_plain;f=src%2Fjalview%2Fws%2FAWSThread.java;h=ead413ee1074dbee94b86a4ead936147b7c2967f;hb=a1984b1c8c273ed33c7ce9283039f4027dcae2de;hp=e55761428171003eb8a3746527bd834602b44975;hpb=be32c14cd8e48fe0a207cd7030cb9cd46f894678;p=jalview.git diff --git a/src/jalview/ws/AWSThread.java b/src/jalview/ws/AWSThread.java index e557614..ead413e 100644 --- a/src/jalview/ws/AWSThread.java +++ b/src/jalview/ws/AWSThread.java @@ -31,8 +31,8 @@ import jalview.gui.WebserviceInfo; import jalview.util.MessageManager; import jalview.viewmodel.seqfeatures.FeatureRendererSettings; -import java.util.LinkedHashSet; -import java.util.Set; +import java.util.ArrayList; +import java.util.List; public abstract class AWSThread extends Thread { @@ -60,7 +60,7 @@ public abstract class AWSThread extends Thread /** * dataset sequence relationships to be propagated onto new results */ - protected Set codonframe = null; + protected List codonframe = null; /** * are there jobs still running in this thread. @@ -98,6 +98,7 @@ public abstract class AWSThread extends Thread /** * generic web service job/subjob poll loop */ + @Override public void run() { JobStateSummary jstate = null; @@ -126,7 +127,7 @@ public abstract class AWSThread extends Thread throw (new Exception( "Timed out when communicating with server\nTry again later.\n")); } - jalview.bin.Cache.log.debug("Job " + j + " Result state " + Cache.debug("Job " + j + " Result state " + jobs[j].getState() + "(ServerError=" + jobs[j].isServerError() + ")"); } catch (Exception ex) @@ -136,7 +137,7 @@ public abstract class AWSThread extends Thread .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 + Cache.warn(WebServiceName + " job(" + jobs[j].jobnum + ") Server exception."); // todo: could limit trace to cause if this is a SOAPFaultException. ex.printStackTrace(); @@ -144,7 +145,7 @@ public abstract class AWSThread extends Thread if (jobs[j].allowedServerExceptions > 0) { jobs[j].allowedServerExceptions--; - Cache.log.debug("Sleeping after a server exception."); + Cache.debug("Sleeping after a server exception."); try { Thread.sleep(5000); @@ -154,7 +155,7 @@ public abstract class AWSThread extends Thread } else { - Cache.log.warn("Dropping job " + j + " " + jobs[j].jobId); + Cache.warn("Dropping job " + j + " " + jobs[j].jobId); jobs[j].subjobComplete = true; wsInfo.setStatus(jobs[j].jobnum, WebserviceInfo.STATE_STOPPED_SERVERERROR); @@ -166,10 +167,10 @@ public abstract class AWSThread extends Thread 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 + Cache.error("Out of memory when retrieving Job " + j + " id:" + WsUrl + "/" + jobs[j].jobId, er); - new jalview.gui.OOMWarning("retrieving result for " - + WebServiceName, er); + new jalview.gui.OOMWarning( + "retrieving result for " + WebServiceName, er); System.gc(); } } @@ -184,8 +185,8 @@ public abstract class AWSThread extends Thread Thread.sleep(5000); } catch (InterruptedException e) { - Cache.log - .debug("Interrupted sleep waiting for next job poll.", e); + Cache.debug("Interrupted sleep waiting for next job poll.", + e); } // System.out.println("I'm alive "+alTitle); } @@ -196,10 +197,11 @@ public abstract class AWSThread extends Thread } else { - Cache.log - .debug("WebServiceJob poll loop finished with no jobs created."); + Cache.debug( + "WebServiceJob poll loop finished with no jobs created."); wsInfo.setStatus(WebserviceInfo.STATE_STOPPED_ERROR); - wsInfo.appendProgressText(MessageManager.getString("info.no_jobs_ran")); + wsInfo.appendProgressText( + MessageManager.getString("info.no_jobs_ran")); wsInfo.setFinishedNoResults(); } } @@ -377,11 +379,11 @@ public abstract class AWSThread extends Thread WsUrl = wsurl2; if (alframe != null) { - Set cf = alframe.getViewport().getAlignment() + List cf = alframe.getViewport().getAlignment() .getCodonFrames(); if (cf != null) { - codonframe = new LinkedHashSet(); + codonframe = new ArrayList(); codonframe.addAll(cf); } }