src/jalview/ws/AWSThread.java

   1 /*
   2  * Jalview - A Sequence Alignment Editor and Viewer (Version 2.8)
   3  * Copyright (C) 2012 J Procter, AM Waterhouse, LM Lui, J Engelhardt, G Barton, M Clamp, S Searle
   4  *
   5  * This file is part of Jalview.
   6  *
   7  * Jalview is free software: you can redistribute it and/or
   8  * modify it under the terms of the GNU General Public License
   9  * as published by the Free Software Foundation, either version 3 of the License, or (at your option) any later version.
  10  *
  11  * Jalview is distributed in the hope that it will be useful, but
  12  * WITHOUT ANY WARRANTY; without even the implied warranty
  13  * of MERCHANTABILITY or FITNESS FOR A PARTICULAR
  14  * PURPOSE.  See the GNU General Public License for more details.
  15  *
  16  * You should have received a copy of the GNU General Public License along with Jalview.  If not, see <http://www.gnu.org/licenses/>.
  17  */
  18 package jalview.ws;
  19
  20 import jalview.bin.Cache;
  21 import jalview.datamodel.AlignedCodonFrame;
  22 import jalview.datamodel.Alignment;
  23 import jalview.datamodel.AlignmentI;
  24 import jalview.datamodel.AlignmentView;
  25 import jalview.datamodel.SequenceI;
  26 import jalview.gui.AlignFrame;
  27 import jalview.gui.WebserviceInfo;
  28 import jalview.gui.FeatureRenderer.FeatureRendererSettings;
  29
  30 public abstract class AWSThread extends Thread
  31 {
  32
  33   /**
  34    * view that this job was associated with
  35    */
  36   protected AlignmentI currentView = null;
  37
  38   /**
  39    * feature settings from view that job was associated with
  40    */
  41   protected FeatureRendererSettings featureSettings = null;
  42
  43   /**
  44    * metadata about this web service
  45    */
  46   protected WebserviceInfo wsInfo = null;
  47
  48   /**
  49    * original input data for this job
  50    */
  51   protected AlignmentView input = null;
  52
  53   /**
  54    * dataset sequence relationships to be propagated onto new results
  55    */
  56   protected AlignedCodonFrame[] codonframe = null;
  57
  58   /**
  59    * are there jobs still running in this thread.
  60    */
  61   protected boolean jobComplete = false;
  62
  63   /**
  64    * one or more jobs being managed by this thread.
  65    */
  66   protected AWsJob jobs[] = null;
  67
  68   /**
  69    * full name of service
  70    */
  71   protected String WebServiceName = null;
  72
  73   protected char defGapChar = '-';
  74
  75   /**
  76    * header prepended to all output from job
  77    */
  78   protected String OutputHeader;
  79
  80   /**
  81    * only used when reporting a web service out of memory error - the job ID
  82    * will be concatenated to the URL
  83    */
  84   protected String WsUrl = null;
  85
  86   /**
  87    * generic web service job/subjob poll loop
  88    */
  89   public void run()
  90   {
  91     JobStateSummary jstate = null;
  92     if (jobs == null)
  93     {
  94       jobComplete = true;
  95     }
  96     while (!jobComplete)
  97     {
  98       jstate = new JobStateSummary();
  99       for (int j = 0; j < jobs.length; j++)
 100       {
 101
 102         if (!jobs[j].submitted && jobs[j].hasValidInput())
 103         {
 104           StartJob(jobs[j]);
 105         }
 106
 107         if (jobs[j].submitted && !jobs[j].subjobComplete)
 108         {
 109           try
 110           {
 111             pollJob(jobs[j]);
 112             if (!jobs[j].hasResponse())
 113             {
 114               throw (new Exception(
 115                       "Timed out when communicating with server\nTry again later.\n"));
 116             }
 117             jalview.bin.Cache.log.debug("Job " + j + " Result state "
 118                     + jobs[j].getState() + "(ServerError="
 119                     + jobs[j].isServerError() + ")");
 120           } catch (Exception ex)
 121           {
 122             // Deal with Transaction exceptions
 123             wsInfo.appendProgressText(jobs[j].jobnum, "\n" + WebServiceName
 124                     + " Server exception!\n" + ex.getMessage());
 125             // always output the exception's stack trace to the log
 126             Cache.log.warn(WebServiceName + " job(" + jobs[j].jobnum
 127                     + ") Server exception.");
 128             // todo: could limit trace to cause if this is a SOAPFaultException.
 129             ex.printStackTrace();
 130
 131             if (jobs[j].allowedServerExceptions > 0)
 132             {
 133               jobs[j].allowedServerExceptions--;
 134               Cache.log.debug("Sleeping after a server exception.");
 135               try
 136               {
 137                 Thread.sleep(5000);
 138               } catch (InterruptedException ex1)
 139               {
 140               }
 141             }
 142             else
 143             {
 144               Cache.log.warn("Dropping job " + j + " " + jobs[j].jobId);
 145               jobs[j].subjobComplete = true;
 146               wsInfo.setStatus(jobs[j].jobnum,
 147                       WebserviceInfo.STATE_STOPPED_SERVERERROR);
 148             }
 149           } catch (OutOfMemoryError er)
 150           {
 151             jobComplete = true;
 152             jobs[j].subjobComplete = true;
 153             jobs[j].clearResponse(); // may contain out of date result data
 154             wsInfo.setStatus(jobs[j].jobnum,
 155                     WebserviceInfo.STATE_STOPPED_ERROR);
 156             Cache.log.error("Out of memory when retrieving Job " + j
 157                     + " id:" + WsUrl + "/" + jobs[j].jobId, er);
 158             new jalview.gui.OOMWarning("retrieving result for "
 159                     + WebServiceName, er);
 160             System.gc();
 161           }
 162         }
 163         jstate.updateJobPanelState(wsInfo, OutputHeader, jobs[j]);
 164       }
 165       // Decide on overall state based on collected jobs[] states
 166       updateGlobalStatus(jstate);
 167       if (!jobComplete)
 168       {
 169         try
 170         {
 171           Thread.sleep(5000);
 172         } catch (InterruptedException e)
 173         {
 174           Cache.log
 175                   .debug("Interrupted sleep waiting for next job poll.", e);
 176         }
 177         // System.out.println("I'm alive "+alTitle);
 178       }
 179     }
 180     if (jobComplete && jobs != null)
 181     {
 182       parseResult(); // tidy up and make results available to user
 183     }
 184     else
 185     {
 186       Cache.log
 187               .debug("WebServiceJob poll loop finished with no jobs created.");
 188       wsInfo.setStatus(wsInfo.STATE_STOPPED_ERROR);
 189       wsInfo.appendProgressText("No jobs ran.");
 190       wsInfo.setFinishedNoResults();
 191     }
 192   }
 193
 194   protected void updateGlobalStatus(JobStateSummary jstate)
 195   {
 196     if (jstate.running > 0)
 197     {
 198       wsInfo.setStatus(WebserviceInfo.STATE_RUNNING);
 199     }
 200     else if (jstate.queuing > 0)
 201     {
 202       wsInfo.setStatus(WebserviceInfo.STATE_QUEUING);
 203     }
 204     else
 205     {
 206       jobComplete = true;
 207       if (jstate.finished > 0)
 208       {
 209         wsInfo.setStatus(WebserviceInfo.STATE_STOPPED_OK);
 210       }
 211       else if (jstate.error > 0)
 212       {
 213         wsInfo.setStatus(WebserviceInfo.STATE_STOPPED_ERROR);
 214       }
 215       else if (jstate.serror > 0)
 216       {
 217         wsInfo.setStatus(WebserviceInfo.STATE_STOPPED_SERVERERROR);
 218       }
 219     }
 220   }
 221
 222   public AWSThread()
 223   {
 224     super();
 225   }
 226
 227   public AWSThread(Runnable target)
 228   {
 229     super(target);
 230   }
 231
 232   public AWSThread(String name)
 233   {
 234     super(name);
 235   }
 236
 237   public AWSThread(ThreadGroup group, Runnable target)
 238   {
 239     super(group, target);
 240   }
 241
 242   public AWSThread(ThreadGroup group, String name)
 243   {
 244     super(group, name);
 245   }
 246
 247   public AWSThread(Runnable target, String name)
 248   {
 249     super(target, name);
 250   }
 251
 252   public AWSThread(ThreadGroup group, Runnable target, String name)
 253   {
 254     super(group, target, name);
 255   }
 256
 257   /**
 258    * query web service for status of job. on return, job.result must not be null
 259    * - if it is then it will be assumed that the job status query timed out and
 260    * a server exception will be logged.
 261    *
 262    * @param job
 263    * @throws Exception
 264    *           will be logged as a server exception for this job
 265    */
 266   public abstract void pollJob(AWsJob job) throws Exception;
 267
 268   /**
 269    * submit job to web service
 270    *
 271    * @param job
 272    */
 273   public abstract void StartJob(AWsJob job);
 274
 275   /**
 276    * process the set of AWsJob objects into a set of results, and tidy up.
 277    */
 278   public abstract void parseResult();
 279
 280   /**
 281    * helper function to conserve dataset references to sequence objects returned
 282    * from web services 1. Propagates AlCodonFrame data from
 283    * <code>codonframe</code> to <code>al</code> TODO: refactor to datamodel
 284    *
 285    * @param al
 286    */
 287   public void propagateDatasetMappings(Alignment al)
 288   {
 289     if (codonframe != null)
 290     {
 291       SequenceI[] alignment = al.getSequencesArray();
 292       for (int sq = 0; sq < alignment.length; sq++)
 293       {
 294         for (int i = 0; i < codonframe.length; i++)
 295         {
 296           if (codonframe[i] != null
 297                   && codonframe[i].involvesSequence(alignment[sq]))
 298           {
 299             al.addCodonFrame(codonframe[i]);
 300             codonframe[i] = null;
 301             break;
 302           }
 303         }
 304       }
 305     }
 306   }
 307
 308   public AWSThread(ThreadGroup group, Runnable target, String name,
 309           long stackSize)
 310   {
 311     super(group, target, name, stackSize);
 312   }
 313
 314   /**
 315    *
 316    * @return gap character to use for any alignment generation
 317    */
 318   public char getGapChar()
 319   {
 320     return defGapChar;
 321   }
 322
 323   /**
 324    *
 325    * @param alignFrame
 326    *          reference for copying mappings across
 327    * @param wsInfo
 328    *          gui attachment point
 329    * @param input
 330    *          input data for the calculation
 331    * @param webServiceName
 332    *          name of service
 333    * @param wsUrl
 334    *          url of the service being invoked
 335    */
 336   public AWSThread(AlignFrame alignFrame, WebserviceInfo wsinfo,
 337           AlignmentView input, String webServiceName, String wsUrl)
 338   {
 339     this(alignFrame, wsinfo, input, wsUrl);
 340     WebServiceName = webServiceName;
 341   }
 342
 343   /**
 344    * Extracts additional info from alignment view's context.
 345    *
 346    * @param alframe
 347    *          - reference for copying mappings and display styles across
 348    * @param wsinfo2
 349    *          - gui attachment point - may be null
 350    * @param alview
 351    *          - input data for the calculation
 352    * @param wsurl2
 353    *          - url of the service being invoked
 354    */
 355   public AWSThread(AlignFrame alframe, WebserviceInfo wsinfo2,
 356           AlignmentView alview, String wsurl2)
 357   {
 358     super();
 359     // this.alignFrame = alframe;
 360     currentView = alframe.getCurrentView().getAlignment();
 361     featureSettings = alframe.getFeatureRenderer().getSettings();
 362     defGapChar = alframe.getViewport().getGapCharacter();
 363     this.wsInfo = wsinfo2;
 364     this.input = alview;
 365     WsUrl = wsurl2;
 366     if (alframe != null)
 367     {
 368       AlignedCodonFrame[] cf = alframe.getViewport().getAlignment()
 369               .getCodonFrames();
 370       if (cf != null)
 371       {
 372         codonframe = new AlignedCodonFrame[cf.length];
 373         System.arraycopy(cf, 0, codonframe, 0, cf.length);
 374       }
 375     }
 376   }
 377 }