X-Git-Url: http://source.jalview.org/gitweb/?a=blobdiff_plain;f=src%2Fjalview%2Fws%2FAWSThread.java;h=b64a526efbeff2e57e341d04ef6b9cdb0bbcf646;hb=cb8e52fbbc5f725e3f7f48c672cdddb0690bd978;hp=4f3b5750730b21eea5ff3584ab66bdc05b89a146;hpb=c19d2a91ca05e052e3408bf5852d88eb5d0608f1;p=jalview.git diff --git a/src/jalview/ws/AWSThread.java b/src/jalview/ws/AWSThread.java index 4f3b575..b64a526 100644 --- a/src/jalview/ws/AWSThread.java +++ b/src/jalview/ws/AWSThread.java @@ -1,6 +1,6 @@ /* - * Jalview - A Sequence Alignment Editor and Viewer (Version 2.9.0b2) - * Copyright (C) 2015 The Jalview Authors + * Jalview - A Sequence Alignment Editor and Viewer ($$Version-Rel$$) + * Copyright (C) $$Year-Rel$$ The Jalview Authors * * This file is part of Jalview. * @@ -20,7 +20,7 @@ */ package jalview.ws; -import jalview.bin.Cache; +import jalview.bin.Console; import jalview.datamodel.AlignedCodonFrame; import jalview.datamodel.Alignment; import jalview.datamodel.AlignmentI; @@ -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,17 +127,17 @@ 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 " + Console.debug("Job " + j + " Result state " + jobs[j].getState() + "(ServerError=" + jobs[j].isServerError() + ")"); } catch (Exception ex) { // Deal with Transaction exceptions wsInfo.appendProgressText(jobs[j].jobnum, MessageManager - .formatMessage("info.server_exception", new Object[] { - WebServiceName, ex.getMessage() })); + .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 + Console.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."); + Console.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); + Console.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 + Console.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); + Console.debug("Interrupted sleep waiting for next job poll.", + e); } // System.out.println("I'm alive "+alTitle); } @@ -196,11 +197,11 @@ public abstract class AWSThread extends Thread } else { - Cache.log - .debug("WebServiceJob poll loop finished with no jobs created."); + 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.appendProgressText( + MessageManager.getString("info.no_jobs_ran")); wsInfo.setFinishedNoResults(); } } @@ -378,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); } }