You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airavata.apache.org by sc...@apache.org on 2015/08/31 19:34:56 UTC
[3/5] airavata git commit: adding addSSHForkJobSubmissionDetails API
method
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>