X-Git-Url: http://source.jalview.org/gitweb/?a=blobdiff_plain;f=src%2Fjalview%2Fws%2Frest%2FRestJobThread.java;fp=src%2Fjalview%2Fws%2Frest%2FRestJobThread.java;h=acb7904a002390587dc5c9e6c21c000f1b3508bb;hb=be762d8d9c71a7aa3121e845c45911c7192b7827;hp=0592426797c2ca9e60f3a064a5525849e22b01a0;hpb=d1bb7a31fc091606aedbc255a5766ac79e36fa91;p=jalview.git diff --git a/src/jalview/ws/rest/RestJobThread.java b/src/jalview/ws/rest/RestJobThread.java index 0592426..acb7904 100644 --- a/src/jalview/ws/rest/RestJobThread.java +++ b/src/jalview/ws/rest/RestJobThread.java @@ -90,8 +90,8 @@ public class RestJobThread extends AWSThread { jobs = new RestJob[1]; jobs[0] = new RestJob(0, this, - restClient._input.getVisibleAlignment(restClient.service - .getGapCharacter()), + restClient._input.getVisibleAlignment( + restClient.service.getGapCharacter()), restClient._input.getVisibleContigs()); // need a function to get a range on a view/alignment and return both // annotation, groups and selection subsetted to just that region. @@ -101,8 +101,8 @@ public class RestJobThread extends AWSThread { int[] viscontig = restClient._input.getVisibleContigs(); AlignmentI[] viscontigals = restClient._input - .getVisibleContigAlignments(restClient.service - .getGapCharacter()); + .getVisibleContigAlignments( + restClient.service.getGapCharacter()); if (viscontigals != null && viscontigals.length > 0) { jobs = new RestJob[viscontigals.length]; @@ -233,8 +233,8 @@ public class RestJobThread extends AWSThread { if (input.getValue().validFor(rj)) { - postentity.addPart(input.getKey(), input.getValue() - .formatForInput(rj)); + postentity.addPart(input.getKey(), + input.getValue().formatForInput(rj)); } else { @@ -289,10 +289,7 @@ public class RestJobThread extends AWSThread break; case 202: rj.statMessage = "
Job submitted successfully. Results available at this URL:\n" - + "" - + rj.getJobId() + + "" + rj.getJobId() + "
"; rj.running = true; break; @@ -305,11 +302,9 @@ public class RestJobThread extends AWSThread { if (loc.length > 1) { - Cache.log - .warn("Ignoring additional " - + (loc.length - 1) - + " location(s) provided in response header ( next one is '" - + loc[1].getValue() + "' )"); + Cache.log.warn("Ignoring additional " + (loc.length - 1) + + " location(s) provided in response header ( next one is '" + + loc[1].getValue() + "' )"); } rj.setJobId(loc[0].getValue()); rj.setSubmitted(true); @@ -323,8 +318,8 @@ public class RestJobThread extends AWSThread rj.setSubjobComplete(true); rj.error = true; rj.running = false; - completeStatus(rj, response, "" + getStage(stg) - + "failed. Reason below:\n"); + completeStatus(rj, response, + "" + getStage(stg) + "failed. Reason below:\n"); break; default: // Some other response. Probably need to pop up the content in a window. @@ -337,16 +332,10 @@ public class RestJobThread extends AWSThread rj.setSubmitted(true); try { - completeStatus( - rj, - response, - "" - + getStage(stg) - + " resulted in an unexpected server response.
Url concerned was " - + request.getURI() - + "
Filtered response content below:
"); + completeStatus(rj, response, "" + getStage(stg) + + " resulted in an unexpected server response.
Url concerned was " + request.getURI() + + "
Filtered response content below:
"); } catch (IOException e) { Cache.log.debug("IOException when consuming unhandled response", @@ -484,21 +473,19 @@ public class RestJobThread extends AWSThread } catch (Error ex) { - Cache.log.warn("Failed to finish parsing data for job " - + rj.getJobId()); + Cache.log.warn( + "Failed to finish parsing data for job " + rj.getJobId()); ex.printStackTrace(); } catch (Exception ex) { - Cache.log.warn("Failed to finish parsing data for job " - + rj.getJobId()); + Cache.log.warn( + "Failed to finish parsing data for job " + rj.getJobId()); ex.printStackTrace(); } finally { rj.error = true; rj.statMessage = "Error whilst parsing data for this job.
URL for job response is :" - + rj.resSet.getUrl() + + rj.resSet.getUrl() + "\">" + rj.resSet.getUrl() + "
"; } } @@ -736,9 +723,9 @@ public class RestJobThread extends AWSThread { destAl = restClient.av.getAlignment(); destHCs = restClient.av.getAlignment().getHiddenColumns(); - resultDest - .add(restClient.isShowResultsInNewView() ? AddDataTo.newView - : AddDataTo.currentView); + resultDest.add(restClient.isShowResultsInNewView() + ? AddDataTo.newView + : AddDataTo.currentView); destPanels.add(restClient.recoverAlignPanelForView()); } else @@ -767,8 +754,8 @@ public class RestJobThread extends AWSThread { // TODO: decide if multiple multiple alignments returned by // non-vseparable services are allowed. - Cache.log - .warn("dealing with multiple alignment products returned by non-vertically separable service."); + Cache.log.warn( + "dealing with multiple alignment products returned by non-vertically separable service."); } // recover reference to last alignment created for this rest frame // ready for extension @@ -810,8 +797,7 @@ public class RestJobThread extends AWSThread destColsel.add(destHCs); resultDest.add(AddDataTo.newAlignment); throw new Error( - MessageManager - .getString("error.implementation_error") + MessageManager.getString("error.implementation_error") + "TODO: "); } } @@ -882,8 +868,8 @@ public class RestJobThread extends AWSThread } else { - Cache.log - .warn("Couldn't resolve original sequence for new sequence."); + Cache.log.warn( + "Couldn't resolve original sequence for new sequence."); } } if (sg.hasSeqrep()) @@ -905,8 +891,8 @@ public class RestJobThread extends AWSThread { // adjust boundaries of recovered group w.r.t. new group being // merged on to original alignment. - int start = sg.getStartRes() + contigs[ncnt], end = sg - .getEndRes() + contigs[ncnt]; + int start = sg.getStartRes() + contigs[ncnt], + end = sg.getEndRes() + contigs[ncnt]; if (start < exsg.getStartRes()) { exsg.setStartRes(start); @@ -960,8 +946,8 @@ public class RestJobThread extends AWSThread grass = groupNames.get(alan[nrj][an].groupRef.getName()); if (grass == null) { - Cache.log - .error("Couldn't relocate group referemce for group " + Cache.log.error( + "Couldn't relocate group referemce for group " + alan[nrj][an].groupRef.getName()); } } @@ -987,7 +973,8 @@ public class RestJobThread extends AWSThread visan.sequenceRef = sqass; visAlAn.add(visan); } - if (contigs[ncnt] + alan[nrj][an].annotations.length > visan.annotations.length) + if (contigs[ncnt] + + alan[nrj][an].annotations.length > visan.annotations.length) { // increase width of annotation row Annotation[] newannv = new Annotation[contigs[ncnt] @@ -1010,8 +997,8 @@ public class RestJobThread extends AWSThread { // TODO: process each newick file, lifting over sequence refs to // current alignment, if necessary. - Cache.log - .error("Tree recovery from restjob not yet implemented."); + Cache.log.error( + "Tree recovery from restjob not yet implemented."); } } } @@ -1048,9 +1035,9 @@ public class RestJobThread extends AWSThread { AlignmentI destal; HiddenColumns destcs; - String alTitle = MessageManager.formatMessage( - "label.webservice_job_title_on", new String[] { - restClient.service.details.Action, + String alTitle = MessageManager + .formatMessage("label.webservice_job_title_on", new String[] + { restClient.service.details.Action, restClient.service.details.Name, restClient.viewTitle }); switch (action) { @@ -1059,8 +1046,8 @@ public class RestJobThread extends AWSThread destcs = destColsel.get(als); destaf = new AlignFrame(destal, destcs, AlignFrame.DEFAULT_WIDTH, AlignFrame.DEFAULT_HEIGHT); - PaintRefresher.Refresh(destaf, destaf.getViewport() - .getSequenceSetId()); + PaintRefresher.Refresh(destaf, + destaf.getViewport().getSequenceSetId()); // todo transfer any feature settings and colouring /* * destaf.getFeatureRenderer().transferSettings(this.featureSettings); @@ -1188,8 +1175,8 @@ public class RestJobThread extends AWSThread { if (start + width < end) { - blocks[c][s] = sequenceIs[s].getSubSequence(start, start - + width); + blocks[c][s] = sequenceIs[s].getSubSequence(start, + start + width); } else {