http://git-wip-us.apache.org/repos/asf/airavata/blob/284ce423/airavata-api/airavata-api-stubs/src/main/java/org/apache/airavata/api/Airavata.java ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-api-stubs/src/main/java/org/apache/airavata/api/Airavata.java b/airavata-api/airavata-api-stubs/src/main/java/org/apache/airavata/api/Airavata.java index 81e3891..9b85c0b 100644 --- a/airavata-api/airavata-api-stubs/src/main/java/org/apache/airavata/api/Airavata.java +++ b/airavata-api/airavata-api-stubs/src/main/java/org/apache/airavata/api/Airavata.java @@ -51,7 +51,7 @@ import org.slf4j.Logger; import org.slf4j.LoggerFactory; @SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"}) -@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-8-27") +@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-8-31") public class Airavata { public interface Iface { @@ -1151,6 +1151,30 @@ public class Airavata { public String addSSHJobSubmissionDetails(org.apache.airavata.model.security.AuthzToken authzToken, String computeResourceId, int priorityOrder, org.apache.airavata.model.appcatalog.computeresource.SSHJobSubmission sshJobSubmission) throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.airavata.model.error.AuthorizationException, org.apache.thrift.TException; /** + * Add a SSH_FORK Job Submission details to a compute resource + * App catalog will return a jobSubmissionInterfaceId which will be added to the jobSubmissionInterfaces. + * + * @param computeResourceId + * The identifier of the compute resource to which JobSubmission protocol to be added + * + * @param priorityOrder + * Specify the priority of this job manager. If this is the only jobmanager, the priority can be zero. + * + * @param sshJobSubmission + * The SSHJobSubmission object to be added to the resource. + * + * @return status + * Returns the unique job submission id. + * + * + * @param authzToken + * @param computeResourceId + * @param priorityOrder + * @param sshJobSubmission + */ + public String addSSHForkJobSubmissionDetails(org.apache.airavata.model.security.AuthzToken authzToken, String computeResourceId, int priorityOrder, org.apache.airavata.model.appcatalog.computeresource.SSHJobSubmission sshJobSubmission) throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.airavata.model.error.AuthorizationException, org.apache.thrift.TException; + + /** * This method returns SSHJobSubmission object * @param jobSubmissionInterfaceId * The identifier of the JobSubmission Interface to be retrieved. @@ -1887,6 +1911,8 @@ public class Airavata { public void addSSHJobSubmissionDetails(org.apache.airavata.model.security.AuthzToken authzToken, String computeResourceId, int priorityOrder, org.apache.airavata.model.appcatalog.computeresource.SSHJobSubmission sshJobSubmission, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + public void addSSHForkJobSubmissionDetails(org.apache.airavata.model.security.AuthzToken authzToken, String computeResourceId, int priorityOrder, org.apache.airavata.model.appcatalog.computeresource.SSHJobSubmission sshJobSubmission, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + public void getSSHJobSubmission(org.apache.airavata.model.security.AuthzToken authzToken, String jobSubmissionId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; public void addUNICOREJobSubmissionDetails(org.apache.airavata.model.security.AuthzToken authzToken, String computeResourceId, int priorityOrder, org.apache.airavata.model.appcatalog.computeresource.UnicoreJobSubmission unicoreJobSubmission, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; @@ -4550,6 +4576,44 @@ public class Airavata { throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "addSSHJobSubmissionDetails failed: unknown result"); } + public String addSSHForkJobSubmissionDetails(org.apache.airavata.model.security.AuthzToken authzToken, String computeResourceId, int priorityOrder, org.apache.airavata.model.appcatalog.computeresource.SSHJobSubmission sshJobSubmission) throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.airavata.model.error.AuthorizationException, org.apache.thrift.TException + { + send_addSSHForkJobSubmissionDetails(authzToken, computeResourceId, priorityOrder, sshJobSubmission); + return recv_addSSHForkJobSubmissionDetails(); + } + + public void send_addSSHForkJobSubmissionDetails(org.apache.airavata.model.security.AuthzToken authzToken, String computeResourceId, int priorityOrder, org.apache.airavata.model.appcatalog.computeresource.SSHJobSubmission sshJobSubmission) throws org.apache.thrift.TException + { + addSSHForkJobSubmissionDetails_args args = new addSSHForkJobSubmissionDetails_args(); + args.setAuthzToken(authzToken); + args.setComputeResourceId(computeResourceId); + args.setPriorityOrder(priorityOrder); + args.setSshJobSubmission(sshJobSubmission); + sendBase("addSSHForkJobSubmissionDetails", args); + } + + public String recv_addSSHForkJobSubmissionDetails() throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.airavata.model.error.AuthorizationException, org.apache.thrift.TException + { + addSSHForkJobSubmissionDetails_result result = new addSSHForkJobSubmissionDetails_result(); + receiveBase(result, "addSSHForkJobSubmissionDetails"); + if (result.isSetSuccess()) { + return result.success; + } + if (result.ire != null) { + throw result.ire; + } + if (result.ace != null) { + throw result.ace; + } + if (result.ase != null) { + throw result.ase; + } + if (result.ae != null) { + throw result.ae; + } + throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "addSSHForkJobSubmissionDetails failed: unknown result"); + } + public org.apache.airavata.model.appcatalog.computeresource.SSHJobSubmission getSSHJobSubmission(org.apache.airavata.model.security.AuthzToken authzToken, String jobSubmissionId) throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.airavata.model.error.AuthorizationException, org.apache.thrift.TException { send_getSSHJobSubmission(authzToken, jobSubmissionId); @@ -8930,6 +8994,47 @@ public class Airavata { } } + public void addSSHForkJobSubmissionDetails(org.apache.airavata.model.security.AuthzToken authzToken, String computeResourceId, int priorityOrder, org.apache.airavata.model.appcatalog.computeresource.SSHJobSubmission sshJobSubmission, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { + checkReady(); + addSSHForkJobSubmissionDetails_call method_call = new addSSHForkJobSubmissionDetails_call(authzToken, computeResourceId, priorityOrder, sshJobSubmission, resultHandler, this, ___protocolFactory, ___transport); + this.___currentMethod = method_call; + ___manager.call(method_call); + } + + public static class addSSHForkJobSubmissionDetails_call extends org.apache.thrift.async.TAsyncMethodCall { + private org.apache.airavata.model.security.AuthzToken authzToken; + private String computeResourceId; + private int priorityOrder; + private org.apache.airavata.model.appcatalog.computeresource.SSHJobSubmission sshJobSubmission; + public addSSHForkJobSubmissionDetails_call(org.apache.airavata.model.security.AuthzToken authzToken, String computeResourceId, int priorityOrder, org.apache.airavata.model.appcatalog.computeresource.SSHJobSubmission sshJobSubmission, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException { + super(client, protocolFactory, transport, resultHandler, false); + this.authzToken = authzToken; + this.computeResourceId = computeResourceId; + this.priorityOrder = priorityOrder; + this.sshJobSubmission = sshJobSubmission; + } + + public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { + prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("addSSHForkJobSubmissionDetails", org.apache.thrift.protocol.TMessageType.CALL, 0)); + addSSHForkJobSubmissionDetails_args args = new addSSHForkJobSubmissionDetails_args(); + args.setAuthzToken(authzToken); + args.setComputeResourceId(computeResourceId); + args.setPriorityOrder(priorityOrder); + args.setSshJobSubmission(sshJobSubmission); + args.write(prot); + prot.writeMessageEnd(); + } + + public String getResult() throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.airavata.model.error.AuthorizationException, org.apache.thrift.TException { + if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) { + throw new IllegalStateException("Method call not finished!"); + } + org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array()); + org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport); + return (new Client(prot)).recv_addSSHForkJobSubmissionDetails(); + } + } + public void getSSHJobSubmission(org.apache.airavata.model.security.AuthzToken authzToken, String jobSubmissionId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { checkReady(); getSSHJobSubmission_call method_call = new getSSHJobSubmission_call(authzToken, jobSubmissionId, resultHandler, this, ___protocolFactory, ___transport); @@ -10791,6 +10896,7 @@ public class Airavata { processMap.put("updateLocalSubmissionDetails", new updateLocalSubmissionDetails()); processMap.put("getLocalJobSubmission", new getLocalJobSubmission()); processMap.put("addSSHJobSubmissionDetails", new addSSHJobSubmissionDetails()); + processMap.put("addSSHForkJobSubmissionDetails", new addSSHForkJobSubmissionDetails()); processMap.put("getSSHJobSubmission", new getSSHJobSubmission()); processMap.put("addUNICOREJobSubmissionDetails", new addUNICOREJobSubmissionDetails()); processMap.put("getUnicoreJobSubmission", new getUnicoreJobSubmission()); @@ -12937,6 +13043,36 @@ public class Airavata { } } + public static class addSSHForkJobSubmissionDetails<I extends Iface> extends org.apache.thrift.ProcessFunction<I, addSSHForkJobSubmissionDetails_args> { + public addSSHForkJobSubmissionDetails() { + super("addSSHForkJobSubmissionDetails"); + } + + public addSSHForkJobSubmissionDetails_args getEmptyArgsInstance() { + return new addSSHForkJobSubmissionDetails_args(); + } + + protected boolean isOneway() { + return false; + } + + public addSSHForkJobSubmissionDetails_result getResult(I iface, addSSHForkJobSubmissionDetails_args args) throws org.apache.thrift.TException { + addSSHForkJobSubmissionDetails_result result = new addSSHForkJobSubmissionDetails_result(); + try { + result.success = iface.addSSHForkJobSubmissionDetails(args.authzToken, args.computeResourceId, args.priorityOrder, args.sshJobSubmission); + } catch (org.apache.airavata.model.error.InvalidRequestException ire) { + result.ire = ire; + } catch (org.apache.airavata.model.error.AiravataClientException ace) { + result.ace = ace; + } catch (org.apache.airavata.model.error.AiravataSystemException ase) { + result.ase = ase; + } catch (org.apache.airavata.model.error.AuthorizationException ae) { + result.ae = ae; + } + return result; + } + } + public static class getSSHJobSubmission<I extends Iface> extends org.apache.thrift.ProcessFunction<I, getSSHJobSubmission_args> { public getSSHJobSubmission() { super("getSSHJobSubmission"); @@ -14481,6 +14617,7 @@ public class Airavata { processMap.put("updateLocalSubmissionDetails", new updateLocalSubmissionDetails()); processMap.put("getLocalJobSubmission", new getLocalJobSubmission()); processMap.put("addSSHJobSubmissionDetails", new addSSHJobSubmissionDetails()); + processMap.put("addSSHForkJobSubmissionDetails", new addSSHForkJobSubmissionDetails()); processMap.put("getSSHJobSubmission", new getSSHJobSubmission()); processMap.put("addUNICOREJobSubmissionDetails", new addUNICOREJobSubmissionDetails()); processMap.put("getUnicoreJobSubmission", new getUnicoreJobSubmission()); @@ -19536,92 +19673,20 @@ public class Airavata { } } - public static class getSSHJobSubmission<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getSSHJobSubmission_args, org.apache.airavata.model.appcatalog.computeresource.SSHJobSubmission> { - public getSSHJobSubmission() { - super("getSSHJobSubmission"); + public static class addSSHForkJobSubmissionDetails<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, addSSHForkJobSubmissionDetails_args, String> { + public addSSHForkJobSubmissionDetails() { + super("addSSHForkJobSubmissionDetails"); } - public getSSHJobSubmission_args getEmptyArgsInstance() { - return new getSSHJobSubmission_args(); - } - - public AsyncMethodCallback<org.apache.airavata.model.appcatalog.computeresource.SSHJobSubmission> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { - final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback<org.apache.airavata.model.appcatalog.computeresource.SSHJobSubmission>() { - public void onComplete(org.apache.airavata.model.appcatalog.computeresource.SSHJobSubmission o) { - getSSHJobSubmission_result result = new getSSHJobSubmission_result(); - result.success = o; - try { - fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); - return; - } catch (Exception e) { - LOGGER.error("Exception writing to internal frame buffer", e); - } - fb.close(); - } - public void onError(Exception e) { - byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; - org.apache.thrift.TBase msg; - getSSHJobSubmission_result result = new getSSHJobSubmission_result(); - if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { - result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; - result.setIreIsSet(true); - msg = result; - } - else if (e instanceof org.apache.airavata.model.error.AiravataClientException) { - result.ace = (org.apache.airavata.model.error.AiravataClientException) e; - result.setAceIsSet(true); - msg = result; - } - else if (e instanceof org.apache.airavata.model.error.AiravataSystemException) { - result.ase = (org.apache.airavata.model.error.AiravataSystemException) e; - result.setAseIsSet(true); - msg = result; - } - else if (e instanceof org.apache.airavata.model.error.AuthorizationException) { - result.ae = (org.apache.airavata.model.error.AuthorizationException) e; - result.setAeIsSet(true); - msg = result; - } - else - { - msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION; - msg = (org.apache.thrift.TBase)new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, e.getMessage()); - } - try { - fcall.sendResponse(fb,msg,msgType,seqid); - return; - } catch (Exception ex) { - LOGGER.error("Exception writing to internal frame buffer", ex); - } - fb.close(); - } - }; - } - - protected boolean isOneway() { - return false; - } - - public void start(I iface, getSSHJobSubmission_args args, org.apache.thrift.async.AsyncMethodCallback<org.apache.airavata.model.appcatalog.computeresource.SSHJobSubmission> resultHandler) throws TException { - iface.getSSHJobSubmission(args.authzToken, args.jobSubmissionId,resultHandler); - } - } - - public static class addUNICOREJobSubmissionDetails<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, addUNICOREJobSubmissionDetails_args, String> { - public addUNICOREJobSubmissionDetails() { - super("addUNICOREJobSubmissionDetails"); - } - - public addUNICOREJobSubmissionDetails_args getEmptyArgsInstance() { - return new addUNICOREJobSubmissionDetails_args(); + public addSSHForkJobSubmissionDetails_args getEmptyArgsInstance() { + return new addSSHForkJobSubmissionDetails_args(); } public AsyncMethodCallback<String> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { final org.apache.thrift.AsyncProcessFunction fcall = this; return new AsyncMethodCallback<String>() { public void onComplete(String o) { - addUNICOREJobSubmissionDetails_result result = new addUNICOREJobSubmissionDetails_result(); + addSSHForkJobSubmissionDetails_result result = new addSSHForkJobSubmissionDetails_result(); result.success = o; try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); @@ -19634,7 +19699,7 @@ public class Airavata { public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - addUNICOREJobSubmissionDetails_result result = new addUNICOREJobSubmissionDetails_result(); + addSSHForkJobSubmissionDetails_result result = new addSSHForkJobSubmissionDetails_result(); if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; result.setIreIsSet(true); @@ -19675,25 +19740,25 @@ public class Airavata { return false; } - public void start(I iface, addUNICOREJobSubmissionDetails_args args, org.apache.thrift.async.AsyncMethodCallback<String> resultHandler) throws TException { - iface.addUNICOREJobSubmissionDetails(args.authzToken, args.computeResourceId, args.priorityOrder, args.unicoreJobSubmission,resultHandler); + public void start(I iface, addSSHForkJobSubmissionDetails_args args, org.apache.thrift.async.AsyncMethodCallback<String> resultHandler) throws TException { + iface.addSSHForkJobSubmissionDetails(args.authzToken, args.computeResourceId, args.priorityOrder, args.sshJobSubmission,resultHandler); } } - public static class getUnicoreJobSubmission<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getUnicoreJobSubmission_args, org.apache.airavata.model.appcatalog.computeresource.UnicoreJobSubmission> { - public getUnicoreJobSubmission() { - super("getUnicoreJobSubmission"); + public static class getSSHJobSubmission<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getSSHJobSubmission_args, org.apache.airavata.model.appcatalog.computeresource.SSHJobSubmission> { + public getSSHJobSubmission() { + super("getSSHJobSubmission"); } - public getUnicoreJobSubmission_args getEmptyArgsInstance() { - return new getUnicoreJobSubmission_args(); + public getSSHJobSubmission_args getEmptyArgsInstance() { + return new getSSHJobSubmission_args(); } - public AsyncMethodCallback<org.apache.airavata.model.appcatalog.computeresource.UnicoreJobSubmission> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + public AsyncMethodCallback<org.apache.airavata.model.appcatalog.computeresource.SSHJobSubmission> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback<org.apache.airavata.model.appcatalog.computeresource.UnicoreJobSubmission>() { - public void onComplete(org.apache.airavata.model.appcatalog.computeresource.UnicoreJobSubmission o) { - getUnicoreJobSubmission_result result = new getUnicoreJobSubmission_result(); + return new AsyncMethodCallback<org.apache.airavata.model.appcatalog.computeresource.SSHJobSubmission>() { + public void onComplete(org.apache.airavata.model.appcatalog.computeresource.SSHJobSubmission o) { + getSSHJobSubmission_result result = new getSSHJobSubmission_result(); result.success = o; try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); @@ -19706,7 +19771,7 @@ public class Airavata { public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - getUnicoreJobSubmission_result result = new getUnicoreJobSubmission_result(); + getSSHJobSubmission_result result = new getSSHJobSubmission_result(); if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; result.setIreIsSet(true); @@ -19747,25 +19812,25 @@ public class Airavata { return false; } - public void start(I iface, getUnicoreJobSubmission_args args, org.apache.thrift.async.AsyncMethodCallback<org.apache.airavata.model.appcatalog.computeresource.UnicoreJobSubmission> resultHandler) throws TException { - iface.getUnicoreJobSubmission(args.authzToken, args.jobSubmissionId,resultHandler); + public void start(I iface, getSSHJobSubmission_args args, org.apache.thrift.async.AsyncMethodCallback<org.apache.airavata.model.appcatalog.computeresource.SSHJobSubmission> resultHandler) throws TException { + iface.getSSHJobSubmission(args.authzToken, args.jobSubmissionId,resultHandler); } } - public static class addCloudJobSubmissionDetails<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, addCloudJobSubmissionDetails_args, String> { - public addCloudJobSubmissionDetails() { - super("addCloudJobSubmissionDetails"); + public static class addUNICOREJobSubmissionDetails<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, addUNICOREJobSubmissionDetails_args, String> { + public addUNICOREJobSubmissionDetails() { + super("addUNICOREJobSubmissionDetails"); } - public addCloudJobSubmissionDetails_args getEmptyArgsInstance() { - return new addCloudJobSubmissionDetails_args(); + public addUNICOREJobSubmissionDetails_args getEmptyArgsInstance() { + return new addUNICOREJobSubmissionDetails_args(); } public AsyncMethodCallback<String> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { final org.apache.thrift.AsyncProcessFunction fcall = this; return new AsyncMethodCallback<String>() { public void onComplete(String o) { - addCloudJobSubmissionDetails_result result = new addCloudJobSubmissionDetails_result(); + addUNICOREJobSubmissionDetails_result result = new addUNICOREJobSubmissionDetails_result(); result.success = o; try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); @@ -19778,7 +19843,7 @@ public class Airavata { public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - addCloudJobSubmissionDetails_result result = new addCloudJobSubmissionDetails_result(); + addUNICOREJobSubmissionDetails_result result = new addUNICOREJobSubmissionDetails_result(); if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; result.setIreIsSet(true); @@ -19819,25 +19884,25 @@ public class Airavata { return false; } - public void start(I iface, addCloudJobSubmissionDetails_args args, org.apache.thrift.async.AsyncMethodCallback<String> resultHandler) throws TException { - iface.addCloudJobSubmissionDetails(args.authzToken, args.computeResourceId, args.priorityOrder, args.cloudSubmission,resultHandler); + public void start(I iface, addUNICOREJobSubmissionDetails_args args, org.apache.thrift.async.AsyncMethodCallback<String> resultHandler) throws TException { + iface.addUNICOREJobSubmissionDetails(args.authzToken, args.computeResourceId, args.priorityOrder, args.unicoreJobSubmission,resultHandler); } } - public static class getCloudJobSubmission<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getCloudJobSubmission_args, org.apache.airavata.model.appcatalog.computeresource.CloudJobSubmission> { - public getCloudJobSubmission() { - super("getCloudJobSubmission"); + public static class getUnicoreJobSubmission<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getUnicoreJobSubmission_args, org.apache.airavata.model.appcatalog.computeresource.UnicoreJobSubmission> { + public getUnicoreJobSubmission() { + super("getUnicoreJobSubmission"); } - public getCloudJobSubmission_args getEmptyArgsInstance() { - return new getCloudJobSubmission_args(); + public getUnicoreJobSubmission_args getEmptyArgsInstance() { + return new getUnicoreJobSubmission_args(); } - public AsyncMethodCallback<org.apache.airavata.model.appcatalog.computeresource.CloudJobSubmission> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + public AsyncMethodCallback<org.apache.airavata.model.appcatalog.computeresource.UnicoreJobSubmission> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback<org.apache.airavata.model.appcatalog.computeresource.CloudJobSubmission>() { - public void onComplete(org.apache.airavata.model.appcatalog.computeresource.CloudJobSubmission o) { - getCloudJobSubmission_result result = new getCloudJobSubmission_result(); + return new AsyncMethodCallback<org.apache.airavata.model.appcatalog.computeresource.UnicoreJobSubmission>() { + public void onComplete(org.apache.airavata.model.appcatalog.computeresource.UnicoreJobSubmission o) { + getUnicoreJobSubmission_result result = new getUnicoreJobSubmission_result(); result.success = o; try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); @@ -19850,7 +19915,7 @@ public class Airavata { public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - getCloudJobSubmission_result result = new getCloudJobSubmission_result(); + getUnicoreJobSubmission_result result = new getUnicoreJobSubmission_result(); if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; result.setIreIsSet(true); @@ -19891,27 +19956,26 @@ public class Airavata { return false; } - public void start(I iface, getCloudJobSubmission_args args, org.apache.thrift.async.AsyncMethodCallback<org.apache.airavata.model.appcatalog.computeresource.CloudJobSubmission> resultHandler) throws TException { - iface.getCloudJobSubmission(args.authzToken, args.jobSubmissionId,resultHandler); + public void start(I iface, getUnicoreJobSubmission_args args, org.apache.thrift.async.AsyncMethodCallback<org.apache.airavata.model.appcatalog.computeresource.UnicoreJobSubmission> resultHandler) throws TException { + iface.getUnicoreJobSubmission(args.authzToken, args.jobSubmissionId,resultHandler); } } - public static class updateSSHJobSubmissionDetails<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, updateSSHJobSubmissionDetails_args, Boolean> { - public updateSSHJobSubmissionDetails() { - super("updateSSHJobSubmissionDetails"); + public static class addCloudJobSubmissionDetails<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, addCloudJobSubmissionDetails_args, String> { + public addCloudJobSubmissionDetails() { + super("addCloudJobSubmissionDetails"); } - public updateSSHJobSubmissionDetails_args getEmptyArgsInstance() { - return new updateSSHJobSubmissionDetails_args(); + public addCloudJobSubmissionDetails_args getEmptyArgsInstance() { + return new addCloudJobSubmissionDetails_args(); } - public AsyncMethodCallback<Boolean> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + public AsyncMethodCallback<String> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback<Boolean>() { - public void onComplete(Boolean o) { - updateSSHJobSubmissionDetails_result result = new updateSSHJobSubmissionDetails_result(); + return new AsyncMethodCallback<String>() { + public void onComplete(String o) { + addCloudJobSubmissionDetails_result result = new addCloudJobSubmissionDetails_result(); result.success = o; - result.setSuccessIsSet(true); try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); return; @@ -19923,7 +19987,7 @@ public class Airavata { public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - updateSSHJobSubmissionDetails_result result = new updateSSHJobSubmissionDetails_result(); + addCloudJobSubmissionDetails_result result = new addCloudJobSubmissionDetails_result(); if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; result.setIreIsSet(true); @@ -19964,27 +20028,26 @@ public class Airavata { return false; } - public void start(I iface, updateSSHJobSubmissionDetails_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException { - iface.updateSSHJobSubmissionDetails(args.authzToken, args.jobSubmissionInterfaceId, args.sshJobSubmission,resultHandler); + public void start(I iface, addCloudJobSubmissionDetails_args args, org.apache.thrift.async.AsyncMethodCallback<String> resultHandler) throws TException { + iface.addCloudJobSubmissionDetails(args.authzToken, args.computeResourceId, args.priorityOrder, args.cloudSubmission,resultHandler); } } - public static class updateCloudJobSubmissionDetails<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, updateCloudJobSubmissionDetails_args, Boolean> { - public updateCloudJobSubmissionDetails() { - super("updateCloudJobSubmissionDetails"); + public static class getCloudJobSubmission<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getCloudJobSubmission_args, org.apache.airavata.model.appcatalog.computeresource.CloudJobSubmission> { + public getCloudJobSubmission() { + super("getCloudJobSubmission"); } - public updateCloudJobSubmissionDetails_args getEmptyArgsInstance() { - return new updateCloudJobSubmissionDetails_args(); + public getCloudJobSubmission_args getEmptyArgsInstance() { + return new getCloudJobSubmission_args(); } - public AsyncMethodCallback<Boolean> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + public AsyncMethodCallback<org.apache.airavata.model.appcatalog.computeresource.CloudJobSubmission> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback<Boolean>() { - public void onComplete(Boolean o) { - updateCloudJobSubmissionDetails_result result = new updateCloudJobSubmissionDetails_result(); + return new AsyncMethodCallback<org.apache.airavata.model.appcatalog.computeresource.CloudJobSubmission>() { + public void onComplete(org.apache.airavata.model.appcatalog.computeresource.CloudJobSubmission o) { + getCloudJobSubmission_result result = new getCloudJobSubmission_result(); result.success = o; - result.setSuccessIsSet(true); try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); return; @@ -19996,7 +20059,7 @@ public class Airavata { public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - updateCloudJobSubmissionDetails_result result = new updateCloudJobSubmissionDetails_result(); + getCloudJobSubmission_result result = new getCloudJobSubmission_result(); if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; result.setIreIsSet(true); @@ -20037,25 +20100,25 @@ public class Airavata { return false; } - public void start(I iface, updateCloudJobSubmissionDetails_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException { - iface.updateCloudJobSubmissionDetails(args.authzToken, args.jobSubmissionInterfaceId, args.sshJobSubmission,resultHandler); + public void start(I iface, getCloudJobSubmission_args args, org.apache.thrift.async.AsyncMethodCallback<org.apache.airavata.model.appcatalog.computeresource.CloudJobSubmission> resultHandler) throws TException { + iface.getCloudJobSubmission(args.authzToken, args.jobSubmissionId,resultHandler); } } - public static class updateUnicoreJobSubmissionDetails<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, updateUnicoreJobSubmissionDetails_args, Boolean> { - public updateUnicoreJobSubmissionDetails() { - super("updateUnicoreJobSubmissionDetails"); + public static class updateSSHJobSubmissionDetails<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, updateSSHJobSubmissionDetails_args, Boolean> { + public updateSSHJobSubmissionDetails() { + super("updateSSHJobSubmissionDetails"); } - public updateUnicoreJobSubmissionDetails_args getEmptyArgsInstance() { - return new updateUnicoreJobSubmissionDetails_args(); + public updateSSHJobSubmissionDetails_args getEmptyArgsInstance() { + return new updateSSHJobSubmissionDetails_args(); } public AsyncMethodCallback<Boolean> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { final org.apache.thrift.AsyncProcessFunction fcall = this; return new AsyncMethodCallback<Boolean>() { public void onComplete(Boolean o) { - updateUnicoreJobSubmissionDetails_result result = new updateUnicoreJobSubmissionDetails_result(); + updateSSHJobSubmissionDetails_result result = new updateSSHJobSubmissionDetails_result(); result.success = o; result.setSuccessIsSet(true); try { @@ -20069,7 +20132,7 @@ public class Airavata { public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - updateUnicoreJobSubmissionDetails_result result = new updateUnicoreJobSubmissionDetails_result(); + updateSSHJobSubmissionDetails_result result = new updateSSHJobSubmissionDetails_result(); if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; result.setIreIsSet(true); @@ -20110,26 +20173,27 @@ public class Airavata { return false; } - public void start(I iface, updateUnicoreJobSubmissionDetails_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException { - iface.updateUnicoreJobSubmissionDetails(args.authzToken, args.jobSubmissionInterfaceId, args.unicoreJobSubmission,resultHandler); + public void start(I iface, updateSSHJobSubmissionDetails_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException { + iface.updateSSHJobSubmissionDetails(args.authzToken, args.jobSubmissionInterfaceId, args.sshJobSubmission,resultHandler); } } - public static class addLocalDataMovementDetails<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, addLocalDataMovementDetails_args, String> { - public addLocalDataMovementDetails() { - super("addLocalDataMovementDetails"); + public static class updateCloudJobSubmissionDetails<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, updateCloudJobSubmissionDetails_args, Boolean> { + public updateCloudJobSubmissionDetails() { + super("updateCloudJobSubmissionDetails"); } - public addLocalDataMovementDetails_args getEmptyArgsInstance() { - return new addLocalDataMovementDetails_args(); + public updateCloudJobSubmissionDetails_args getEmptyArgsInstance() { + return new updateCloudJobSubmissionDetails_args(); } - public AsyncMethodCallback<String> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + public AsyncMethodCallback<Boolean> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback<String>() { - public void onComplete(String o) { - addLocalDataMovementDetails_result result = new addLocalDataMovementDetails_result(); + return new AsyncMethodCallback<Boolean>() { + public void onComplete(Boolean o) { + updateCloudJobSubmissionDetails_result result = new updateCloudJobSubmissionDetails_result(); result.success = o; + result.setSuccessIsSet(true); try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); return; @@ -20141,7 +20205,7 @@ public class Airavata { public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - addLocalDataMovementDetails_result result = new addLocalDataMovementDetails_result(); + updateCloudJobSubmissionDetails_result result = new updateCloudJobSubmissionDetails_result(); if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; result.setIreIsSet(true); @@ -20182,25 +20246,25 @@ public class Airavata { return false; } - public void start(I iface, addLocalDataMovementDetails_args args, org.apache.thrift.async.AsyncMethodCallback<String> resultHandler) throws TException { - iface.addLocalDataMovementDetails(args.authzToken, args.computeResourceId, args.priorityOrder, args.localDataMovement,resultHandler); + public void start(I iface, updateCloudJobSubmissionDetails_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException { + iface.updateCloudJobSubmissionDetails(args.authzToken, args.jobSubmissionInterfaceId, args.sshJobSubmission,resultHandler); } } - public static class updateLocalDataMovementDetails<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, updateLocalDataMovementDetails_args, Boolean> { - public updateLocalDataMovementDetails() { - super("updateLocalDataMovementDetails"); + public static class updateUnicoreJobSubmissionDetails<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, updateUnicoreJobSubmissionDetails_args, Boolean> { + public updateUnicoreJobSubmissionDetails() { + super("updateUnicoreJobSubmissionDetails"); } - public updateLocalDataMovementDetails_args getEmptyArgsInstance() { - return new updateLocalDataMovementDetails_args(); + public updateUnicoreJobSubmissionDetails_args getEmptyArgsInstance() { + return new updateUnicoreJobSubmissionDetails_args(); } public AsyncMethodCallback<Boolean> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { final org.apache.thrift.AsyncProcessFunction fcall = this; return new AsyncMethodCallback<Boolean>() { public void onComplete(Boolean o) { - updateLocalDataMovementDetails_result result = new updateLocalDataMovementDetails_result(); + updateUnicoreJobSubmissionDetails_result result = new updateUnicoreJobSubmissionDetails_result(); result.success = o; result.setSuccessIsSet(true); try { @@ -20214,7 +20278,7 @@ public class Airavata { public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - updateLocalDataMovementDetails_result result = new updateLocalDataMovementDetails_result(); + updateUnicoreJobSubmissionDetails_result result = new updateUnicoreJobSubmissionDetails_result(); if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; result.setIreIsSet(true); @@ -20255,25 +20319,25 @@ public class Airavata { return false; } - public void start(I iface, updateLocalDataMovementDetails_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException { - iface.updateLocalDataMovementDetails(args.authzToken, args.dataMovementInterfaceId, args.localDataMovement,resultHandler); + public void start(I iface, updateUnicoreJobSubmissionDetails_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException { + iface.updateUnicoreJobSubmissionDetails(args.authzToken, args.jobSubmissionInterfaceId, args.unicoreJobSubmission,resultHandler); } } - public static class getLocalDataMovement<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getLocalDataMovement_args, org.apache.airavata.model.appcatalog.computeresource.LOCALDataMovement> { - public getLocalDataMovement() { - super("getLocalDataMovement"); + public static class addLocalDataMovementDetails<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, addLocalDataMovementDetails_args, String> { + public addLocalDataMovementDetails() { + super("addLocalDataMovementDetails"); } - public getLocalDataMovement_args getEmptyArgsInstance() { - return new getLocalDataMovement_args(); + public addLocalDataMovementDetails_args getEmptyArgsInstance() { + return new addLocalDataMovementDetails_args(); } - public AsyncMethodCallback<org.apache.airavata.model.appcatalog.computeresource.LOCALDataMovement> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + public AsyncMethodCallback<String> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback<org.apache.airavata.model.appcatalog.computeresource.LOCALDataMovement>() { - public void onComplete(org.apache.airavata.model.appcatalog.computeresource.LOCALDataMovement o) { - getLocalDataMovement_result result = new getLocalDataMovement_result(); + return new AsyncMethodCallback<String>() { + public void onComplete(String o) { + addLocalDataMovementDetails_result result = new addLocalDataMovementDetails_result(); result.success = o; try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); @@ -20286,7 +20350,7 @@ public class Airavata { public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - getLocalDataMovement_result result = new getLocalDataMovement_result(); + addLocalDataMovementDetails_result result = new addLocalDataMovementDetails_result(); if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; result.setIreIsSet(true); @@ -20327,26 +20391,27 @@ public class Airavata { return false; } - public void start(I iface, getLocalDataMovement_args args, org.apache.thrift.async.AsyncMethodCallback<org.apache.airavata.model.appcatalog.computeresource.LOCALDataMovement> resultHandler) throws TException { - iface.getLocalDataMovement(args.authzToken, args.dataMovementId,resultHandler); + public void start(I iface, addLocalDataMovementDetails_args args, org.apache.thrift.async.AsyncMethodCallback<String> resultHandler) throws TException { + iface.addLocalDataMovementDetails(args.authzToken, args.computeResourceId, args.priorityOrder, args.localDataMovement,resultHandler); } } - public static class addSCPDataMovementDetails<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, addSCPDataMovementDetails_args, String> { - public addSCPDataMovementDetails() { - super("addSCPDataMovementDetails"); + public static class updateLocalDataMovementDetails<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, updateLocalDataMovementDetails_args, Boolean> { + public updateLocalDataMovementDetails() { + super("updateLocalDataMovementDetails"); } - public addSCPDataMovementDetails_args getEmptyArgsInstance() { - return new addSCPDataMovementDetails_args(); + public updateLocalDataMovementDetails_args getEmptyArgsInstance() { + return new updateLocalDataMovementDetails_args(); } - public AsyncMethodCallback<String> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + public AsyncMethodCallback<Boolean> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback<String>() { - public void onComplete(String o) { - addSCPDataMovementDetails_result result = new addSCPDataMovementDetails_result(); + return new AsyncMethodCallback<Boolean>() { + public void onComplete(Boolean o) { + updateLocalDataMovementDetails_result result = new updateLocalDataMovementDetails_result(); result.success = o; + result.setSuccessIsSet(true); try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); return; @@ -20358,7 +20423,7 @@ public class Airavata { public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - addSCPDataMovementDetails_result result = new addSCPDataMovementDetails_result(); + updateLocalDataMovementDetails_result result = new updateLocalDataMovementDetails_result(); if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; result.setIreIsSet(true); @@ -20399,27 +20464,26 @@ public class Airavata { return false; } - public void start(I iface, addSCPDataMovementDetails_args args, org.apache.thrift.async.AsyncMethodCallback<String> resultHandler) throws TException { - iface.addSCPDataMovementDetails(args.authzToken, args.computeResourceId, args.priorityOrder, args.scpDataMovement,resultHandler); + public void start(I iface, updateLocalDataMovementDetails_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException { + iface.updateLocalDataMovementDetails(args.authzToken, args.dataMovementInterfaceId, args.localDataMovement,resultHandler); } } - public static class updateSCPDataMovementDetails<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, updateSCPDataMovementDetails_args, Boolean> { - public updateSCPDataMovementDetails() { - super("updateSCPDataMovementDetails"); + public static class getLocalDataMovement<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getLocalDataMovement_args, org.apache.airavata.model.appcatalog.computeresource.LOCALDataMovement> { + public getLocalDataMovement() { + super("getLocalDataMovement"); } - public updateSCPDataMovementDetails_args getEmptyArgsInstance() { - return new updateSCPDataMovementDetails_args(); + public getLocalDataMovement_args getEmptyArgsInstance() { + return new getLocalDataMovement_args(); } - public AsyncMethodCallback<Boolean> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + public AsyncMethodCallback<org.apache.airavata.model.appcatalog.computeresource.LOCALDataMovement> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback<Boolean>() { - public void onComplete(Boolean o) { - updateSCPDataMovementDetails_result result = new updateSCPDataMovementDetails_result(); + return new AsyncMethodCallback<org.apache.airavata.model.appcatalog.computeresource.LOCALDataMovement>() { + public void onComplete(org.apache.airavata.model.appcatalog.computeresource.LOCALDataMovement o) { + getLocalDataMovement_result result = new getLocalDataMovement_result(); result.success = o; - result.setSuccessIsSet(true); try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); return; @@ -20431,7 +20495,7 @@ public class Airavata { public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - updateSCPDataMovementDetails_result result = new updateSCPDataMovementDetails_result(); + getLocalDataMovement_result result = new getLocalDataMovement_result(); if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; result.setIreIsSet(true); @@ -20472,25 +20536,25 @@ public class Airavata { return false; } - public void start(I iface, updateSCPDataMovementDetails_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException { - iface.updateSCPDataMovementDetails(args.authzToken, args.dataMovementInterfaceId, args.scpDataMovement,resultHandler); + public void start(I iface, getLocalDataMovement_args args, org.apache.thrift.async.AsyncMethodCallback<org.apache.airavata.model.appcatalog.computeresource.LOCALDataMovement> resultHandler) throws TException { + iface.getLocalDataMovement(args.authzToken, args.dataMovementId,resultHandler); } } - public static class getSCPDataMovement<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getSCPDataMovement_args, org.apache.airavata.model.appcatalog.computeresource.SCPDataMovement> { - public getSCPDataMovement() { - super("getSCPDataMovement"); + public static class addSCPDataMovementDetails<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, addSCPDataMovementDetails_args, String> { + public addSCPDataMovementDetails() { + super("addSCPDataMovementDetails"); } - public getSCPDataMovement_args getEmptyArgsInstance() { - return new getSCPDataMovement_args(); + public addSCPDataMovementDetails_args getEmptyArgsInstance() { + return new addSCPDataMovementDetails_args(); } - public AsyncMethodCallback<org.apache.airavata.model.appcatalog.computeresource.SCPDataMovement> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + public AsyncMethodCallback<String> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback<org.apache.airavata.model.appcatalog.computeresource.SCPDataMovement>() { - public void onComplete(org.apache.airavata.model.appcatalog.computeresource.SCPDataMovement o) { - getSCPDataMovement_result result = new getSCPDataMovement_result(); + return new AsyncMethodCallback<String>() { + public void onComplete(String o) { + addSCPDataMovementDetails_result result = new addSCPDataMovementDetails_result(); result.success = o; try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); @@ -20503,7 +20567,7 @@ public class Airavata { public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - getSCPDataMovement_result result = new getSCPDataMovement_result(); + addSCPDataMovementDetails_result result = new addSCPDataMovementDetails_result(); if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; result.setIreIsSet(true); @@ -20544,26 +20608,27 @@ public class Airavata { return false; } - public void start(I iface, getSCPDataMovement_args args, org.apache.thrift.async.AsyncMethodCallback<org.apache.airavata.model.appcatalog.computeresource.SCPDataMovement> resultHandler) throws TException { - iface.getSCPDataMovement(args.authzToken, args.dataMovementId,resultHandler); + public void start(I iface, addSCPDataMovementDetails_args args, org.apache.thrift.async.AsyncMethodCallback<String> resultHandler) throws TException { + iface.addSCPDataMovementDetails(args.authzToken, args.computeResourceId, args.priorityOrder, args.scpDataMovement,resultHandler); } } - public static class addUnicoreDataMovementDetails<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, addUnicoreDataMovementDetails_args, String> { - public addUnicoreDataMovementDetails() { - super("addUnicoreDataMovementDetails"); + public static class updateSCPDataMovementDetails<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, updateSCPDataMovementDetails_args, Boolean> { + public updateSCPDataMovementDetails() { + super("updateSCPDataMovementDetails"); } - public addUnicoreDataMovementDetails_args getEmptyArgsInstance() { - return new addUnicoreDataMovementDetails_args(); + public updateSCPDataMovementDetails_args getEmptyArgsInstance() { + return new updateSCPDataMovementDetails_args(); } - public AsyncMethodCallback<String> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + public AsyncMethodCallback<Boolean> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback<String>() { - public void onComplete(String o) { - addUnicoreDataMovementDetails_result result = new addUnicoreDataMovementDetails_result(); + return new AsyncMethodCallback<Boolean>() { + public void onComplete(Boolean o) { + updateSCPDataMovementDetails_result result = new updateSCPDataMovementDetails_result(); result.success = o; + result.setSuccessIsSet(true); try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); return; @@ -20575,7 +20640,7 @@ public class Airavata { public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - addUnicoreDataMovementDetails_result result = new addUnicoreDataMovementDetails_result(); + updateSCPDataMovementDetails_result result = new updateSCPDataMovementDetails_result(); if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; result.setIreIsSet(true); @@ -20616,27 +20681,26 @@ public class Airavata { return false; } - public void start(I iface, addUnicoreDataMovementDetails_args args, org.apache.thrift.async.AsyncMethodCallback<String> resultHandler) throws TException { - iface.addUnicoreDataMovementDetails(args.authzToken, args.computeResourceId, args.priorityOrder, args.unicoreDataMovement,resultHandler); + public void start(I iface, updateSCPDataMovementDetails_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException { + iface.updateSCPDataMovementDetails(args.authzToken, args.dataMovementInterfaceId, args.scpDataMovement,resultHandler); } } - public static class updateUnicoreDataMovementDetails<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, updateUnicoreDataMovementDetails_args, Boolean> { - public updateUnicoreDataMovementDetails() { - super("updateUnicoreDataMovementDetails"); + public static class getSCPDataMovement<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getSCPDataMovement_args, org.apache.airavata.model.appcatalog.computeresource.SCPDataMovement> { + public getSCPDataMovement() { + super("getSCPDataMovement"); } - public updateUnicoreDataMovementDetails_args getEmptyArgsInstance() { - return new updateUnicoreDataMovementDetails_args(); + public getSCPDataMovement_args getEmptyArgsInstance() { + return new getSCPDataMovement_args(); } - public AsyncMethodCallback<Boolean> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + public AsyncMethodCallback<org.apache.airavata.model.appcatalog.computeresource.SCPDataMovement> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback<Boolean>() { - public void onComplete(Boolean o) { - updateUnicoreDataMovementDetails_result result = new updateUnicoreDataMovementDetails_result(); + return new AsyncMethodCallback<org.apache.airavata.model.appcatalog.computeresource.SCPDataMovement>() { + public void onComplete(org.apache.airavata.model.appcatalog.computeresource.SCPDataMovement o) { + getSCPDataMovement_result result = new getSCPDataMovement_result(); result.success = o; - result.setSuccessIsSet(true); try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); return; @@ -20648,7 +20712,7 @@ public class Airavata { public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - updateUnicoreDataMovementDetails_result result = new updateUnicoreDataMovementDetails_result(); + getSCPDataMovement_result result = new getSCPDataMovement_result(); if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; result.setIreIsSet(true); @@ -20689,25 +20753,25 @@ public class Airavata { return false; } - public void start(I iface, updateUnicoreDataMovementDetails_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException { - iface.updateUnicoreDataMovementDetails(args.authzToken, args.dataMovementInterfaceId, args.unicoreDataMovement,resultHandler); + public void start(I iface, getSCPDataMovement_args args, org.apache.thrift.async.AsyncMethodCallback<org.apache.airavata.model.appcatalog.computeresource.SCPDataMovement> resultHandler) throws TException { + iface.getSCPDataMovement(args.authzToken, args.dataMovementId,resultHandler); } } - public static class getUnicoreDataMovement<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getUnicoreDataMovement_args, org.apache.airavata.model.appcatalog.computeresource.UnicoreDataMovement> { - public getUnicoreDataMovement() { - super("getUnicoreDataMovement"); + public static class addUnicoreDataMovementDetails<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, addUnicoreDataMovementDetails_args, String> { + public addUnicoreDataMovementDetails() { + super("addUnicoreDataMovementDetails"); } - public getUnicoreDataMovement_args getEmptyArgsInstance() { - return new getUnicoreDataMovement_args(); + public addUnicoreDataMovementDetails_args getEmptyArgsInstance() { + return new addUnicoreDataMovementDetails_args(); } - public AsyncMethodCallback<org.apache.airavata.model.appcatalog.computeresource.UnicoreDataMovement> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + public AsyncMethodCallback<String> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback<org.apache.airavata.model.appcatalog.computeresource.UnicoreDataMovement>() { - public void onComplete(org.apache.airavata.model.appcatalog.computeresource.UnicoreDataMovement o) { - getUnicoreDataMovement_result result = new getUnicoreDataMovement_result(); + return new AsyncMethodCallback<String>() { + public void onComplete(String o) { + addUnicoreDataMovementDetails_result result = new addUnicoreDataMovementDetails_result(); result.success = o; try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); @@ -20720,7 +20784,7 @@ public class Airavata { public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - getUnicoreDataMovement_result result = new getUnicoreDataMovement_result(); + addUnicoreDataMovementDetails_result result = new addUnicoreDataMovementDetails_result(); if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; result.setIreIsSet(true); @@ -20761,26 +20825,27 @@ public class Airavata { return false; } - public void start(I iface, getUnicoreDataMovement_args args, org.apache.thrift.async.AsyncMethodCallback<org.apache.airavata.model.appcatalog.computeresource.UnicoreDataMovement> resultHandler) throws TException { - iface.getUnicoreDataMovement(args.authzToken, args.dataMovementId,resultHandler); + public void start(I iface, addUnicoreDataMovementDetails_args args, org.apache.thrift.async.AsyncMethodCallback<String> resultHandler) throws TException { + iface.addUnicoreDataMovementDetails(args.authzToken, args.computeResourceId, args.priorityOrder, args.unicoreDataMovement,resultHandler); } } - public static class addGridFTPDataMovementDetails<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, addGridFTPDataMovementDetails_args, String> { - public addGridFTPDataMovementDetails() { - super("addGridFTPDataMovementDetails"); + public static class updateUnicoreDataMovementDetails<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, updateUnicoreDataMovementDetails_args, Boolean> { + public updateUnicoreDataMovementDetails() { + super("updateUnicoreDataMovementDetails"); } - public addGridFTPDataMovementDetails_args getEmptyArgsInstance() { - return new addGridFTPDataMovementDetails_args(); + public updateUnicoreDataMovementDetails_args getEmptyArgsInstance() { + return new updateUnicoreDataMovementDetails_args(); } - public AsyncMethodCallback<String> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + public AsyncMethodCallback<Boolean> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback<String>() { - public void onComplete(String o) { - addGridFTPDataMovementDetails_result result = new addGridFTPDataMovementDetails_result(); + return new AsyncMethodCallback<Boolean>() { + public void onComplete(Boolean o) { + updateUnicoreDataMovementDetails_result result = new updateUnicoreDataMovementDetails_result(); result.success = o; + result.setSuccessIsSet(true); try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); return; @@ -20792,7 +20857,7 @@ public class Airavata { public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - addGridFTPDataMovementDetails_result result = new addGridFTPDataMovementDetails_result(); + updateUnicoreDataMovementDetails_result result = new updateUnicoreDataMovementDetails_result(); if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; result.setIreIsSet(true); @@ -20833,27 +20898,26 @@ public class Airavata { return false; } - public void start(I iface, addGridFTPDataMovementDetails_args args, org.apache.thrift.async.AsyncMethodCallback<String> resultHandler) throws TException { - iface.addGridFTPDataMovementDetails(args.authzToken, args.computeResourceId, args.priorityOrder, args.gridFTPDataMovement,resultHandler); + public void start(I iface, updateUnicoreDataMovementDetails_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException { + iface.updateUnicoreDataMovementDetails(args.authzToken, args.dataMovementInterfaceId, args.unicoreDataMovement,resultHandler); } } - public static class updateGridFTPDataMovementDetails<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, updateGridFTPDataMovementDetails_args, Boolean> { - public updateGridFTPDataMovementDetails() { - super("updateGridFTPDataMovementDetails"); + public static class getUnicoreDataMovement<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getUnicoreDataMovement_args, org.apache.airavata.model.appcatalog.computeresource.UnicoreDataMovement> { + public getUnicoreDataMovement() { + super("getUnicoreDataMovement"); } - public updateGridFTPDataMovementDetails_args getEmptyArgsInstance() { - return new updateGridFTPDataMovementDetails_args(); + public getUnicoreDataMovement_args getEmptyArgsInstance() { + return new getUnicoreDataMovement_args(); } - public AsyncMethodCallback<Boolean> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + public AsyncMethodCallback<org.apache.airavata.model.appcatalog.computeresource.UnicoreDataMovement> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback<Boolean>() { - public void onComplete(Boolean o) { - updateGridFTPDataMovementDetails_result result = new updateGridFTPDataMovementDetails_result(); + return new AsyncMethodCallback<org.apache.airavata.model.appcatalog.computeresource.UnicoreDataMovement>() { + public void onComplete(org.apache.airavata.model.appcatalog.computeresource.UnicoreDataMovement o) { + getUnicoreDataMovement_result result = new getUnicoreDataMovement_result(); result.success = o; - result.setSuccessIsSet(true); try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); return; @@ -20865,7 +20929,7 @@ public class Airavata { public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - updateGridFTPDataMovementDetails_result result = new updateGridFTPDataMovementDetails_result(); + getUnicoreDataMovement_result result = new getUnicoreDataMovement_result(); if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; result.setIreIsSet(true); @@ -20906,25 +20970,25 @@ public class Airavata { return false; } - public void start(I iface, updateGridFTPDataMovementDetails_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException { - iface.updateGridFTPDataMovementDetails(args.authzToken, args.dataMovementInterfaceId, args.gridFTPDataMovement,resultHandler); + public void start(I iface, getUnicoreDataMovement_args args, org.apache.thrift.async.AsyncMethodCallback<org.apache.airavata.model.appcatalog.computeresource.UnicoreDataMovement> resultHandler) throws TException { + iface.getUnicoreDataMovement(args.authzToken, args.dataMovementId,resultHandler); } } - public static class getGridFTPDataMovement<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getGridFTPDataMovement_args, org.apache.airavata.model.appcatalog.computeresource.GridFTPDataMovement> { - public getGridFTPDataMovement() { - super("getGridFTPDataMovement"); + public static class addGridFTPDataMovementDetails<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, addGridFTPDataMovementDetails_args, String> { + public addGridFTPDataMovementDetails() { + super("addGridFTPDataMovementDetails"); } - public getGridFTPDataMovement_args getEmptyArgsInstance() { - return new getGridFTPDataMovement_args(); + public addGridFTPDataMovementDetails_args getEmptyArgsInstance() { + return new addGridFTPDataMovementDetails_args(); } - public AsyncMethodCallback<org.apache.airavata.model.appcatalog.computeresource.GridFTPDataMovement> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + public AsyncMethodCallback<String> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback<org.apache.airavata.model.appcatalog.computeresource.GridFTPDataMovement>() { - public void onComplete(org.apache.airavata.model.appcatalog.computeresource.GridFTPDataMovement o) { - getGridFTPDataMovement_result result = new getGridFTPDataMovement_result(); + return new AsyncMethodCallback<String>() { + public void onComplete(String o) { + addGridFTPDataMovementDetails_result result = new addGridFTPDataMovementDetails_result(); result.success = o; try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); @@ -20937,7 +21001,7 @@ public class Airavata { public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - getGridFTPDataMovement_result result = new getGridFTPDataMovement_result(); + addGridFTPDataMovementDetails_result result = new addGridFTPDataMovementDetails_result(); if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; result.setIreIsSet(true); @@ -20978,25 +21042,25 @@ public class Airavata { return false; } - public void start(I iface, getGridFTPDataMovement_args args, org.apache.thrift.async.AsyncMethodCallback<org.apache.airavata.model.appcatalog.computeresource.GridFTPDataMovement> resultHandler) throws TException { - iface.getGridFTPDataMovement(args.authzToken, args.dataMovementId,resultHandler); + public void start(I iface, addGridFTPDataMovementDetails_args args, org.apache.thrift.async.AsyncMethodCallback<String> resultHandler) throws TException { + iface.addGridFTPDataMovementDetails(args.authzToken, args.computeResourceId, args.priorityOrder, args.gridFTPDataMovement,resultHandler); } } - public static class changeJobSubmissionPriority<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, changeJobSubmissionPriority_args, Boolean> { - public changeJobSubmissionPriority() { - super("changeJobSubmissionPriority"); + public static class updateGridFTPDataMovementDetails<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, updateGridFTPDataMovementDetails_args, Boolean> { + public updateGridFTPDataMovementDetails() { + super("updateGridFTPDataMovementDetails"); } - public changeJobSubmissionPriority_args getEmptyArgsInstance() { - return new changeJobSubmissionPriority_args(); + public updateGridFTPDataMovementDetails_args getEmptyArgsInstance() { + return new updateGridFTPDataMovementDetails_args(); } public AsyncMethodCallback<Boolean> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { final org.apache.thrift.AsyncProcessFunction fcall = this; return new AsyncMethodCallback<Boolean>() { public void onComplete(Boolean o) { - changeJobSubmissionPriority_result result = new changeJobSubmissionPriority_result(); + updateGridFTPDataMovementDetails_result result = new updateGridFTPDataMovementDetails_result(); result.success = o; result.setSuccessIsSet(true); try { @@ -21010,7 +21074,7 @@ public class Airavata { public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - changeJobSubmissionPriority_result result = new changeJobSubmissionPriority_result(); + updateGridFTPDataMovementDetails_result result = new updateGridFTPDataMovementDetails_result(); if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; result.setIreIsSet(true); @@ -21051,27 +21115,26 @@ public class Airavata { return false; } - public void start(I iface, changeJobSubmissionPriority_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException { - iface.changeJobSubmissionPriority(args.authzToken, args.jobSubmissionInterfaceId, args.newPriorityOrder,resultHandler); + public void start(I iface, updateGridFTPDataMovementDetails_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException { + iface.updateGridFTPDataMovementDetails(args.authzToken, args.dataMovementInterfaceId, args.gridFTPDataMovement,resultHandler); } } - public static class changeDataMovementPriority<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, changeDataMovementPriority_args, Boolean> { - public changeDataMovementPriority() { - super("changeDataMovementPriority"); + public static class getGridFTPDataMovement<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getGridFTPDataMovement_args, org.apache.airavata.model.appcatalog.computeresource.GridFTPDataMovement> { + public getGridFTPDataMovement() { + super("getGridFTPDataMovement"); } - public changeDataMovementPriority_args getEmptyArgsInstance() { - return new changeDataMovementPriority_args(); + public getGridFTPDataMovement_args getEmptyArgsInstance() { + return new getGridFTPDataMovement_args(); } - public AsyncMethodCallback<Boolean> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + public AsyncMethodCallback<org.apache.airavata.model.appcatalog.computeresource.GridFTPDataMovement> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback<Boolean>() { - public void onComplete(Boolean o) { - changeDataMovementPriority_result result = new changeDataMovementPriority_result(); + return new AsyncMethodCallback<org.apache.airavata.model.appcatalog.computeresource.GridFTPDataMovement>() { + public void onComplete(org.apache.airavata.model.appcatalog.computeresource.GridFTPDataMovement o) { + getGridFTPDataMovement_result result = new getGridFTPDataMovement_result(); result.success = o; - result.setSuccessIsSet(true); try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); return; @@ -21083,7 +21146,7 @@ public class Airavata { public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - changeDataMovementPriority_result result = new changeDataMovementPriority_result(); + getGridFTPDataMovement_result result = new getGridFTPDataMovement_result(); if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; result.setIreIsSet(true); @@ -21124,25 +21187,25 @@ public class Airavata { return false; } - public void start(I iface, changeDataMovementPriority_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException { - iface.changeDataMovementPriority(args.authzToken, args.dataMovementInterfaceId, args.newPriorityOrder,resultHandler); + public void start(I iface, getGridFTPDataMovement_args args, org.apache.thrift.async.AsyncMethodCallback<org.apache.airavata.model.appcatalog.computeresource.GridFTPDataMovement> resultHandler) throws TException { + iface.getGridFTPDataMovement(args.authzToken, args.dataMovementId,resultHandler); } } - public static class changeJobSubmissionPriorities<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, changeJobSubmissionPriorities_args, Boolean> { - public changeJobSubmissionPriorities() { - super("changeJobSubmissionPriorities"); + public static class changeJobSubmissionPriority<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, changeJobSubmissionPriority_args, Boolean> { + public changeJobSubmissionPriority() { + super("changeJobSubmissionPriority"); } - public changeJobSubmissionPriorities_args getEmptyArgsInstance() { - return new changeJobSubmissionPriorities_args(); + public changeJobSubmissionPriority_args getEmptyArgsInstance() { + return new changeJobSubmissionPriority_args(); } public AsyncMethodCallback<Boolean> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { final org.apache.thrift.AsyncProcessFunction fcall = this; return new AsyncMethodCallback<Boolean>() { public void onComplete(Boolean o) { - changeJobSubmissionPriorities_result result = new changeJobSubmissionPriorities_result(); + changeJobSubmissionPriority_result result = new changeJobSubmissionPriority_result(); result.success = o; result.setSuccessIsSet(true); try { @@ -21156,7 +21219,7 @@ public class Airavata { public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - changeJobSubmissionPriorities_result result = new changeJobSubmissionPriorities_result(); + changeJobSubmissionPriority_result result = new changeJobSubmissionPriority_result(); if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; result.setIreIsSet(true); @@ -21197,25 +21260,25 @@ public class Airavata { return false; } - public void start(I iface, changeJobSubmissionPriorities_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException { - iface.changeJobSubmissionPriorities(args.authzToken, args.jobSubmissionPriorityMap,resultHandler); + public void start(I iface, changeJobSubmissionPriority_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException { + iface.changeJobSubmissionPriority(args.authzToken, args.jobSubmissionInterfaceId, args.newPriorityOrder,resultHandler); } } - public static class changeDataMovementPriorities<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, changeDataMovementPriorities_args, Boolean> { - public changeDataMovementPriorities() { - super("changeDataMovementPriorities"); + public static class changeDataMovementPriority<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, changeDataMovementPriority_args, Boolean> { + public changeDataMovementPriority() { + super("changeDataMovementPriority"); } - public changeDataMovementPriorities_args getEmptyArgsInstance() { - return new changeDataMovementPriorities_args(); + public changeDataMovementPriority_args getEmptyArgsInstance() { + return new changeDataMovementPriority_args(); } public AsyncMethodCallback<Boolean> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { final org.apache.thrift.AsyncProcessFunction fcall = this; return new AsyncMethodCallback<Boolean>() { public void onComplete(Boolean o) { - changeDataMovementPriorities_result result = new changeDataMovementPriorities_result(); + changeDataMovementPriority_result result = new changeDataMovementPriority_result(); result.success = o; result.setSuccessIsSet(true); try { @@ -21229,7 +21292,7 @@ public class Airavata { public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - changeDataMovementPriorities_result result = new changeDataMovementPriorities_result(); + changeDataMovementPriority_result result = new changeDataMovementPriority_result(); if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; result.setIreIsSet(true); @@ -21270,25 +21333,25 @@ public class Airavata { return false; } - public void start(I iface, changeDataMovementPriorities_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException { - iface.changeDataMovementPriorities(args.authzToken, args.dataMovementPriorityMap,resultHandler); + public void start(I iface, changeDataMovementPriority_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException { + iface.changeDataMovementPriority(args.authzToken, args.dataMovementInterfaceId, args.newPriorityOrder,resultHandler); } } - public static class deleteJobSubmissionInterface<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, deleteJobSubmissionInterface_args, Boolean> { - public deleteJobSubmissionInterface() { - super("deleteJobSubmissionInterface"); + public static class changeJobSubmissionPriorities<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, changeJobSubmissionPriorities_args, Boolean> { + public changeJobSubmissionPriorities() { + super("changeJobSubmissionPriorities"); } - public deleteJobSubmissionInterface_args getEmptyArgsInstance() { - return new deleteJobSubmissionInterface_args(); + public changeJobSubmissionPriorities_args getEmptyArgsInstance() { + return new changeJobSubmissionPriorities_args();
<TRUNCATED>
