http://git-wip-us.apache.org/repos/asf/airavata/blob/914799c1/modules/registry/registry-server/registry-api-stubs/src/main/java/org/apache/airavata/registry/api/RegistryService.java ---------------------------------------------------------------------- diff --git a/modules/registry/registry-server/registry-api-stubs/src/main/java/org/apache/airavata/registry/api/RegistryService.java b/modules/registry/registry-server/registry-api-stubs/src/main/java/org/apache/airavata/registry/api/RegistryService.java index d649aeb..9c4ad05 100644 --- a/modules/registry/registry-server/registry-api-stubs/src/main/java/org/apache/airavata/registry/api/RegistryService.java +++ b/modules/registry/registry-server/registry-api-stubs/src/main/java/org/apache/airavata/registry/api/RegistryService.java @@ -50,7 +50,7 @@ import org.slf4j.Logger; import org.slf4j.LoggerFactory; @SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"}) -@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)", date = "2016-10-05") +@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)", date = "2016-11-08") public class RegistryService { public interface Iface { @@ -2081,7 +2081,7 @@ public class RegistryService { * @param gatewayID * The identifier to link gateway for the requested User Resource resource. * - * @return userResourceProfile + * @return userResourceProfile or null if not found * User Resource Profile Object. * * @@ -2369,6 +2369,14 @@ public class RegistryService { */ public boolean deleteUserStoragePreference(String userId, String gatewayID, String userStorageId) throws org.apache.airavata.registry.api.exception.RegistryServiceException, org.apache.thrift.TException; + /** + * * Get queue statuses of all compute resources + * * + */ + public List<org.apache.airavata.model.status.QueueStatusModel> getLatestQueueStatuses() throws org.apache.airavata.registry.api.exception.RegistryServiceException, org.apache.thrift.TException; + + public void registerQueueStatuses(List<org.apache.airavata.model.status.QueueStatusModel> queueStatuses) throws org.apache.airavata.registry.api.exception.RegistryServiceException, org.apache.thrift.TException; + public List<String> getAllWorkflows(String gatewayId) throws org.apache.airavata.registry.api.exception.RegistryServiceException, org.apache.thrift.TException; /** @@ -2674,6 +2682,10 @@ public class RegistryService { public void deleteUserStoragePreference(String userId, String gatewayID, String userStorageId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + public void getLatestQueueStatuses(org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + + public void registerQueueStatuses(List<org.apache.airavata.model.status.QueueStatusModel> queueStatuses, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + public void getAllWorkflows(String gatewayId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; public void getWorkflow(String workflowTemplateId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; @@ -6248,6 +6260,54 @@ public class RegistryService { throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "deleteUserStoragePreference failed: unknown result"); } + public List<org.apache.airavata.model.status.QueueStatusModel> getLatestQueueStatuses() throws org.apache.airavata.registry.api.exception.RegistryServiceException, org.apache.thrift.TException + { + send_getLatestQueueStatuses(); + return recv_getLatestQueueStatuses(); + } + + public void send_getLatestQueueStatuses() throws org.apache.thrift.TException + { + getLatestQueueStatuses_args args = new getLatestQueueStatuses_args(); + sendBase("getLatestQueueStatuses", args); + } + + public List<org.apache.airavata.model.status.QueueStatusModel> recv_getLatestQueueStatuses() throws org.apache.airavata.registry.api.exception.RegistryServiceException, org.apache.thrift.TException + { + getLatestQueueStatuses_result result = new getLatestQueueStatuses_result(); + receiveBase(result, "getLatestQueueStatuses"); + if (result.isSetSuccess()) { + return result.success; + } + if (result.rse != null) { + throw result.rse; + } + throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getLatestQueueStatuses failed: unknown result"); + } + + public void registerQueueStatuses(List<org.apache.airavata.model.status.QueueStatusModel> queueStatuses) throws org.apache.airavata.registry.api.exception.RegistryServiceException, org.apache.thrift.TException + { + send_registerQueueStatuses(queueStatuses); + recv_registerQueueStatuses(); + } + + public void send_registerQueueStatuses(List<org.apache.airavata.model.status.QueueStatusModel> queueStatuses) throws org.apache.thrift.TException + { + registerQueueStatuses_args args = new registerQueueStatuses_args(); + args.setQueueStatuses(queueStatuses); + sendBase("registerQueueStatuses", args); + } + + public void recv_registerQueueStatuses() throws org.apache.airavata.registry.api.exception.RegistryServiceException, org.apache.thrift.TException + { + registerQueueStatuses_result result = new registerQueueStatuses_result(); + receiveBase(result, "registerQueueStatuses"); + if (result.rse != null) { + throw result.rse; + } + return; + } + public List<String> getAllWorkflows(String gatewayId) throws org.apache.airavata.registry.api.exception.RegistryServiceException, org.apache.thrift.TException { send_getAllWorkflows(gatewayId); @@ -11122,6 +11182,67 @@ public class RegistryService { } } + public void getLatestQueueStatuses(org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { + checkReady(); + getLatestQueueStatuses_call method_call = new getLatestQueueStatuses_call(resultHandler, this, ___protocolFactory, ___transport); + this.___currentMethod = method_call; + ___manager.call(method_call); + } + + public static class getLatestQueueStatuses_call extends org.apache.thrift.async.TAsyncMethodCall { + public getLatestQueueStatuses_call(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); + } + + public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { + prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("getLatestQueueStatuses", org.apache.thrift.protocol.TMessageType.CALL, 0)); + getLatestQueueStatuses_args args = new getLatestQueueStatuses_args(); + args.write(prot); + prot.writeMessageEnd(); + } + + public List<org.apache.airavata.model.status.QueueStatusModel> getResult() throws org.apache.airavata.registry.api.exception.RegistryServiceException, 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_getLatestQueueStatuses(); + } + } + + public void registerQueueStatuses(List<org.apache.airavata.model.status.QueueStatusModel> queueStatuses, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { + checkReady(); + registerQueueStatuses_call method_call = new registerQueueStatuses_call(queueStatuses, resultHandler, this, ___protocolFactory, ___transport); + this.___currentMethod = method_call; + ___manager.call(method_call); + } + + public static class registerQueueStatuses_call extends org.apache.thrift.async.TAsyncMethodCall { + private List<org.apache.airavata.model.status.QueueStatusModel> queueStatuses; + public registerQueueStatuses_call(List<org.apache.airavata.model.status.QueueStatusModel> queueStatuses, 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.queueStatuses = queueStatuses; + } + + public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { + prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("registerQueueStatuses", org.apache.thrift.protocol.TMessageType.CALL, 0)); + registerQueueStatuses_args args = new registerQueueStatuses_args(); + args.setQueueStatuses(queueStatuses); + args.write(prot); + prot.writeMessageEnd(); + } + + public void getResult() throws org.apache.airavata.registry.api.exception.RegistryServiceException, 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); + (new Client(prot)).recv_registerQueueStatuses(); + } + } + public void getAllWorkflows(String gatewayId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { checkReady(); getAllWorkflows_call method_call = new getAllWorkflows_call(gatewayId, resultHandler, this, ___protocolFactory, ___transport); @@ -11657,6 +11778,8 @@ public class RegistryService { processMap.put("updateUserStoragePreference", new updateUserStoragePreference()); processMap.put("deleteUserComputeResourcePreference", new deleteUserComputeResourcePreference()); processMap.put("deleteUserStoragePreference", new deleteUserStoragePreference()); + processMap.put("getLatestQueueStatuses", new getLatestQueueStatuses()); + processMap.put("registerQueueStatuses", new registerQueueStatuses()); processMap.put("getAllWorkflows", new getAllWorkflows()); processMap.put("getWorkflow", new getWorkflow()); processMap.put("deleteWorkflow", new deleteWorkflow()); @@ -14891,6 +15014,54 @@ public class RegistryService { } } + public static class getLatestQueueStatuses<I extends Iface> extends org.apache.thrift.ProcessFunction<I, getLatestQueueStatuses_args> { + public getLatestQueueStatuses() { + super("getLatestQueueStatuses"); + } + + public getLatestQueueStatuses_args getEmptyArgsInstance() { + return new getLatestQueueStatuses_args(); + } + + protected boolean isOneway() { + return false; + } + + public getLatestQueueStatuses_result getResult(I iface, getLatestQueueStatuses_args args) throws org.apache.thrift.TException { + getLatestQueueStatuses_result result = new getLatestQueueStatuses_result(); + try { + result.success = iface.getLatestQueueStatuses(); + } catch (org.apache.airavata.registry.api.exception.RegistryServiceException rse) { + result.rse = rse; + } + return result; + } + } + + public static class registerQueueStatuses<I extends Iface> extends org.apache.thrift.ProcessFunction<I, registerQueueStatuses_args> { + public registerQueueStatuses() { + super("registerQueueStatuses"); + } + + public registerQueueStatuses_args getEmptyArgsInstance() { + return new registerQueueStatuses_args(); + } + + protected boolean isOneway() { + return false; + } + + public registerQueueStatuses_result getResult(I iface, registerQueueStatuses_args args) throws org.apache.thrift.TException { + registerQueueStatuses_result result = new registerQueueStatuses_result(); + try { + iface.registerQueueStatuses(args.queueStatuses); + } catch (org.apache.airavata.registry.api.exception.RegistryServiceException rse) { + result.rse = rse; + } + return result; + } + } + public static class getAllWorkflows<I extends Iface> extends org.apache.thrift.ProcessFunction<I, getAllWorkflows_args> { public getAllWorkflows() { super("getAllWorkflows"); @@ -15325,6 +15496,8 @@ public class RegistryService { processMap.put("updateUserStoragePreference", new updateUserStoragePreference()); processMap.put("deleteUserComputeResourcePreference", new deleteUserComputeResourcePreference()); processMap.put("deleteUserStoragePreference", new deleteUserStoragePreference()); + processMap.put("getLatestQueueStatuses", new getLatestQueueStatuses()); + processMap.put("registerQueueStatuses", new registerQueueStatuses()); processMap.put("getAllWorkflows", new getAllWorkflows()); processMap.put("getWorkflow", new getWorkflow()); processMap.put("deleteWorkflow", new deleteWorkflow()); @@ -22911,20 +23084,20 @@ public class RegistryService { } } - public static class getAllWorkflows<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getAllWorkflows_args, List<String>> { - public getAllWorkflows() { - super("getAllWorkflows"); + public static class getLatestQueueStatuses<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getLatestQueueStatuses_args, List<org.apache.airavata.model.status.QueueStatusModel>> { + public getLatestQueueStatuses() { + super("getLatestQueueStatuses"); } - public getAllWorkflows_args getEmptyArgsInstance() { - return new getAllWorkflows_args(); + public getLatestQueueStatuses_args getEmptyArgsInstance() { + return new getLatestQueueStatuses_args(); } - public AsyncMethodCallback<List<String>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + public AsyncMethodCallback<List<org.apache.airavata.model.status.QueueStatusModel>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback<List<String>>() { - public void onComplete(List<String> o) { - getAllWorkflows_result result = new getAllWorkflows_result(); + return new AsyncMethodCallback<List<org.apache.airavata.model.status.QueueStatusModel>>() { + public void onComplete(List<org.apache.airavata.model.status.QueueStatusModel> o) { + getLatestQueueStatuses_result result = new getLatestQueueStatuses_result(); result.success = o; try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); @@ -22937,7 +23110,7 @@ public class RegistryService { public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - getAllWorkflows_result result = new getAllWorkflows_result(); + getLatestQueueStatuses_result result = new getLatestQueueStatuses_result(); if (e instanceof org.apache.airavata.registry.api.exception.RegistryServiceException) { result.rse = (org.apache.airavata.registry.api.exception.RegistryServiceException) e; result.setRseIsSet(true); @@ -22963,26 +23136,25 @@ public class RegistryService { return false; } - public void start(I iface, getAllWorkflows_args args, org.apache.thrift.async.AsyncMethodCallback<List<String>> resultHandler) throws TException { - iface.getAllWorkflows(args.gatewayId,resultHandler); + public void start(I iface, getLatestQueueStatuses_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.status.QueueStatusModel>> resultHandler) throws TException { + iface.getLatestQueueStatuses(resultHandler); } } - public static class getWorkflow<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getWorkflow_args, org.apache.airavata.model.WorkflowModel> { - public getWorkflow() { - super("getWorkflow"); + public static class registerQueueStatuses<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, registerQueueStatuses_args, Void> { + public registerQueueStatuses() { + super("registerQueueStatuses"); } - public getWorkflow_args getEmptyArgsInstance() { - return new getWorkflow_args(); + public registerQueueStatuses_args getEmptyArgsInstance() { + return new registerQueueStatuses_args(); } - public AsyncMethodCallback<org.apache.airavata.model.WorkflowModel> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + public AsyncMethodCallback<Void> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback<org.apache.airavata.model.WorkflowModel>() { - public void onComplete(org.apache.airavata.model.WorkflowModel o) { - getWorkflow_result result = new getWorkflow_result(); - result.success = o; + return new AsyncMethodCallback<Void>() { + public void onComplete(Void o) { + registerQueueStatuses_result result = new registerQueueStatuses_result(); try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); return; @@ -22994,7 +23166,7 @@ public class RegistryService { public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - getWorkflow_result result = new getWorkflow_result(); + registerQueueStatuses_result result = new registerQueueStatuses_result(); if (e instanceof org.apache.airavata.registry.api.exception.RegistryServiceException) { result.rse = (org.apache.airavata.registry.api.exception.RegistryServiceException) e; result.setRseIsSet(true); @@ -23020,25 +23192,26 @@ public class RegistryService { return false; } - public void start(I iface, getWorkflow_args args, org.apache.thrift.async.AsyncMethodCallback<org.apache.airavata.model.WorkflowModel> resultHandler) throws TException { - iface.getWorkflow(args.workflowTemplateId,resultHandler); + public void start(I iface, registerQueueStatuses_args args, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws TException { + iface.registerQueueStatuses(args.queueStatuses,resultHandler); } } - public static class deleteWorkflow<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, deleteWorkflow_args, Void> { - public deleteWorkflow() { - super("deleteWorkflow"); + public static class getAllWorkflows<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getAllWorkflows_args, List<String>> { + public getAllWorkflows() { + super("getAllWorkflows"); } - public deleteWorkflow_args getEmptyArgsInstance() { - return new deleteWorkflow_args(); + public getAllWorkflows_args getEmptyArgsInstance() { + return new getAllWorkflows_args(); } - public AsyncMethodCallback<Void> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + public AsyncMethodCallback<List<String>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback<Void>() { - public void onComplete(Void o) { - deleteWorkflow_result result = new deleteWorkflow_result(); + return new AsyncMethodCallback<List<String>>() { + public void onComplete(List<String> o) { + getAllWorkflows_result result = new getAllWorkflows_result(); + result.success = o; try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); return; @@ -23050,7 +23223,7 @@ public class RegistryService { public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - deleteWorkflow_result result = new deleteWorkflow_result(); + getAllWorkflows_result result = new getAllWorkflows_result(); if (e instanceof org.apache.airavata.registry.api.exception.RegistryServiceException) { result.rse = (org.apache.airavata.registry.api.exception.RegistryServiceException) e; result.setRseIsSet(true); @@ -23076,25 +23249,25 @@ public class RegistryService { return false; } - public void start(I iface, deleteWorkflow_args args, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws TException { - iface.deleteWorkflow(args.workflowTemplateId,resultHandler); + public void start(I iface, getAllWorkflows_args args, org.apache.thrift.async.AsyncMethodCallback<List<String>> resultHandler) throws TException { + iface.getAllWorkflows(args.gatewayId,resultHandler); } } - public static class registerWorkflow<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, registerWorkflow_args, String> { - public registerWorkflow() { - super("registerWorkflow"); + public static class getWorkflow<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getWorkflow_args, org.apache.airavata.model.WorkflowModel> { + public getWorkflow() { + super("getWorkflow"); } - public registerWorkflow_args getEmptyArgsInstance() { - return new registerWorkflow_args(); + public getWorkflow_args getEmptyArgsInstance() { + return new getWorkflow_args(); } - public AsyncMethodCallback<String> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + public AsyncMethodCallback<org.apache.airavata.model.WorkflowModel> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback<String>() { - public void onComplete(String o) { - registerWorkflow_result result = new registerWorkflow_result(); + return new AsyncMethodCallback<org.apache.airavata.model.WorkflowModel>() { + public void onComplete(org.apache.airavata.model.WorkflowModel o) { + getWorkflow_result result = new getWorkflow_result(); result.success = o; try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); @@ -23107,7 +23280,7 @@ public class RegistryService { public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - registerWorkflow_result result = new registerWorkflow_result(); + getWorkflow_result result = new getWorkflow_result(); if (e instanceof org.apache.airavata.registry.api.exception.RegistryServiceException) { result.rse = (org.apache.airavata.registry.api.exception.RegistryServiceException) e; result.setRseIsSet(true); @@ -23133,25 +23306,25 @@ public class RegistryService { return false; } - public void start(I iface, registerWorkflow_args args, org.apache.thrift.async.AsyncMethodCallback<String> resultHandler) throws TException { - iface.registerWorkflow(args.gatewayId, args.workflow,resultHandler); + public void start(I iface, getWorkflow_args args, org.apache.thrift.async.AsyncMethodCallback<org.apache.airavata.model.WorkflowModel> resultHandler) throws TException { + iface.getWorkflow(args.workflowTemplateId,resultHandler); } } - public static class updateWorkflow<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, updateWorkflow_args, Void> { - public updateWorkflow() { - super("updateWorkflow"); + public static class deleteWorkflow<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, deleteWorkflow_args, Void> { + public deleteWorkflow() { + super("deleteWorkflow"); } - public updateWorkflow_args getEmptyArgsInstance() { - return new updateWorkflow_args(); + public deleteWorkflow_args getEmptyArgsInstance() { + return new deleteWorkflow_args(); } public AsyncMethodCallback<Void> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { final org.apache.thrift.AsyncProcessFunction fcall = this; return new AsyncMethodCallback<Void>() { public void onComplete(Void o) { - updateWorkflow_result result = new updateWorkflow_result(); + deleteWorkflow_result result = new deleteWorkflow_result(); try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); return; @@ -23163,7 +23336,7 @@ public class RegistryService { public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - updateWorkflow_result result = new updateWorkflow_result(); + deleteWorkflow_result result = new deleteWorkflow_result(); if (e instanceof org.apache.airavata.registry.api.exception.RegistryServiceException) { result.rse = (org.apache.airavata.registry.api.exception.RegistryServiceException) e; result.setRseIsSet(true); @@ -23189,25 +23362,25 @@ public class RegistryService { return false; } - public void start(I iface, updateWorkflow_args args, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws TException { - iface.updateWorkflow(args.workflowTemplateId, args.workflow,resultHandler); + public void start(I iface, deleteWorkflow_args args, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws TException { + iface.deleteWorkflow(args.workflowTemplateId,resultHandler); } } - public static class getWorkflowTemplateId<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getWorkflowTemplateId_args, String> { - public getWorkflowTemplateId() { - super("getWorkflowTemplateId"); + public static class registerWorkflow<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, registerWorkflow_args, String> { + public registerWorkflow() { + super("registerWorkflow"); } - public getWorkflowTemplateId_args getEmptyArgsInstance() { - return new getWorkflowTemplateId_args(); + public registerWorkflow_args getEmptyArgsInstance() { + return new registerWorkflow_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) { - getWorkflowTemplateId_result result = new getWorkflowTemplateId_result(); + registerWorkflow_result result = new registerWorkflow_result(); result.success = o; try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); @@ -23220,7 +23393,7 @@ public class RegistryService { public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - getWorkflowTemplateId_result result = new getWorkflowTemplateId_result(); + registerWorkflow_result result = new registerWorkflow_result(); if (e instanceof org.apache.airavata.registry.api.exception.RegistryServiceException) { result.rse = (org.apache.airavata.registry.api.exception.RegistryServiceException) e; result.setRseIsSet(true); @@ -23246,27 +23419,25 @@ public class RegistryService { return false; } - public void start(I iface, getWorkflowTemplateId_args args, org.apache.thrift.async.AsyncMethodCallback<String> resultHandler) throws TException { - iface.getWorkflowTemplateId(args.workflowName,resultHandler); + public void start(I iface, registerWorkflow_args args, org.apache.thrift.async.AsyncMethodCallback<String> resultHandler) throws TException { + iface.registerWorkflow(args.gatewayId, args.workflow,resultHandler); } } - public static class isWorkflowExistWithName<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, isWorkflowExistWithName_args, Boolean> { - public isWorkflowExistWithName() { - super("isWorkflowExistWithName"); + public static class updateWorkflow<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, updateWorkflow_args, Void> { + public updateWorkflow() { + super("updateWorkflow"); } - public isWorkflowExistWithName_args getEmptyArgsInstance() { - return new isWorkflowExistWithName_args(); + public updateWorkflow_args getEmptyArgsInstance() { + return new updateWorkflow_args(); } - public AsyncMethodCallback<Boolean> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + public AsyncMethodCallback<Void> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback<Boolean>() { - public void onComplete(Boolean o) { - isWorkflowExistWithName_result result = new isWorkflowExistWithName_result(); - result.success = o; - result.setSuccessIsSet(true); + return new AsyncMethodCallback<Void>() { + public void onComplete(Void o) { + updateWorkflow_result result = new updateWorkflow_result(); try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); return; @@ -23278,7 +23449,7 @@ public class RegistryService { public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - isWorkflowExistWithName_result result = new isWorkflowExistWithName_result(); + updateWorkflow_result result = new updateWorkflow_result(); if (e instanceof org.apache.airavata.registry.api.exception.RegistryServiceException) { result.rse = (org.apache.airavata.registry.api.exception.RegistryServiceException) e; result.setRseIsSet(true); @@ -23304,25 +23475,25 @@ public class RegistryService { return false; } - public void start(I iface, isWorkflowExistWithName_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException { - iface.isWorkflowExistWithName(args.workflowName,resultHandler); + public void start(I iface, updateWorkflow_args args, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws TException { + iface.updateWorkflow(args.workflowTemplateId, args.workflow,resultHandler); } } - public static class registerDataProduct<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, registerDataProduct_args, String> { - public registerDataProduct() { - super("registerDataProduct"); + public static class getWorkflowTemplateId<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getWorkflowTemplateId_args, String> { + public getWorkflowTemplateId() { + super("getWorkflowTemplateId"); } - public registerDataProduct_args getEmptyArgsInstance() { - return new registerDataProduct_args(); + public getWorkflowTemplateId_args getEmptyArgsInstance() { + return new getWorkflowTemplateId_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) { - registerDataProduct_result result = new registerDataProduct_result(); + getWorkflowTemplateId_result result = new getWorkflowTemplateId_result(); result.success = o; try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); @@ -23335,7 +23506,122 @@ public class RegistryService { public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - registerDataProduct_result result = new registerDataProduct_result(); + getWorkflowTemplateId_result result = new getWorkflowTemplateId_result(); + if (e instanceof org.apache.airavata.registry.api.exception.RegistryServiceException) { + result.rse = (org.apache.airavata.registry.api.exception.RegistryServiceException) e; + result.setRseIsSet(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, getWorkflowTemplateId_args args, org.apache.thrift.async.AsyncMethodCallback<String> resultHandler) throws TException { + iface.getWorkflowTemplateId(args.workflowName,resultHandler); + } + } + + public static class isWorkflowExistWithName<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, isWorkflowExistWithName_args, Boolean> { + public isWorkflowExistWithName() { + super("isWorkflowExistWithName"); + } + + public isWorkflowExistWithName_args getEmptyArgsInstance() { + return new isWorkflowExistWithName_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) { + isWorkflowExistWithName_result result = new isWorkflowExistWithName_result(); + result.success = o; + result.setSuccessIsSet(true); + 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; + isWorkflowExistWithName_result result = new isWorkflowExistWithName_result(); + if (e instanceof org.apache.airavata.registry.api.exception.RegistryServiceException) { + result.rse = (org.apache.airavata.registry.api.exception.RegistryServiceException) e; + result.setRseIsSet(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, isWorkflowExistWithName_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException { + iface.isWorkflowExistWithName(args.workflowName,resultHandler); + } + } + + public static class registerDataProduct<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, registerDataProduct_args, String> { + public registerDataProduct() { + super("registerDataProduct"); + } + + public registerDataProduct_args getEmptyArgsInstance() { + return new registerDataProduct_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) { + registerDataProduct_result result = new registerDataProduct_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; + registerDataProduct_result result = new registerDataProduct_result(); if (e instanceof org.apache.airavata.registry.api.exception.RegistryServiceException) { result.rse = (org.apache.airavata.registry.api.exception.RegistryServiceException) e; result.setRseIsSet(true); @@ -144828,22 +145114,20 @@ public class RegistryService { } - public static class getAllWorkflows_args implements org.apache.thrift.TBase<getAllWorkflows_args, getAllWorkflows_args._Fields>, java.io.Serializable, Cloneable, Comparable<getAllWorkflows_args> { - private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("getAllWorkflows_args"); + public static class getLatestQueueStatuses_args implements org.apache.thrift.TBase<getLatestQueueStatuses_args, getLatestQueueStatuses_args._Fields>, java.io.Serializable, Cloneable, Comparable<getLatestQueueStatuses_args> { + private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("getLatestQueueStatuses_args"); - private static final org.apache.thrift.protocol.TField GATEWAY_ID_FIELD_DESC = new org.apache.thrift.protocol.TField("gatewayId", org.apache.thrift.protocol.TType.STRING, (short)1); private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); static { - schemes.put(StandardScheme.class, new getAllWorkflows_argsStandardSchemeFactory()); - schemes.put(TupleScheme.class, new getAllWorkflows_argsTupleSchemeFactory()); + schemes.put(StandardScheme.class, new getLatestQueueStatuses_argsStandardSchemeFactory()); + schemes.put(TupleScheme.class, new getLatestQueueStatuses_argsTupleSchemeFactory()); } - public String gatewayId; // required /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */ public enum _Fields implements org.apache.thrift.TFieldIdEnum { - GATEWAY_ID((short)1, "gatewayId"); +; private static final Map<String, _Fields> byName = new HashMap<String, _Fields>(); @@ -144858,8 +145142,6 @@ public class RegistryService { */ public static _Fields findByThriftId(int fieldId) { switch(fieldId) { - case 1: // GATEWAY_ID - return GATEWAY_ID; default: return null; } @@ -144898,87 +145180,37 @@ public class RegistryService { return _fieldName; } } - - // isset id assignments public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap; static { Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class); - tmpMap.put(_Fields.GATEWAY_ID, new org.apache.thrift.meta_data.FieldMetaData("gatewayId", org.apache.thrift.TFieldRequirementType.REQUIRED, - new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); metaDataMap = Collections.unmodifiableMap(tmpMap); - org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(getAllWorkflows_args.class, metaDataMap); + org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(getLatestQueueStatuses_args.class, metaDataMap); } - public getAllWorkflows_args() { - } - - public getAllWorkflows_args( - String gatewayId) - { - this(); - this.gatewayId = gatewayId; + public getLatestQueueStatuses_args() { } /** * Performs a deep copy on <i>other</i>. */ - public getAllWorkflows_args(getAllWorkflows_args other) { - if (other.isSetGatewayId()) { - this.gatewayId = other.gatewayId; - } + public getLatestQueueStatuses_args(getLatestQueueStatuses_args other) { } - public getAllWorkflows_args deepCopy() { - return new getAllWorkflows_args(this); + public getLatestQueueStatuses_args deepCopy() { + return new getLatestQueueStatuses_args(this); } @Override public void clear() { - this.gatewayId = null; - } - - public String getGatewayId() { - return this.gatewayId; - } - - public getAllWorkflows_args setGatewayId(String gatewayId) { - this.gatewayId = gatewayId; - return this; - } - - public void unsetGatewayId() { - this.gatewayId = null; - } - - /** Returns true if field gatewayId is set (has been assigned a value) and false otherwise */ - public boolean isSetGatewayId() { - return this.gatewayId != null; - } - - public void setGatewayIdIsSet(boolean value) { - if (!value) { - this.gatewayId = null; - } } public void setFieldValue(_Fields field, Object value) { switch (field) { - case GATEWAY_ID: - if (value == null) { - unsetGatewayId(); - } else { - setGatewayId((String)value); - } - break; - } } public Object getFieldValue(_Fields field) { switch (field) { - case GATEWAY_ID: - return getGatewayId(); - } throw new IllegalStateException(); } @@ -144990,8 +145222,6 @@ public class RegistryService { } switch (field) { - case GATEWAY_ID: - return isSetGatewayId(); } throw new IllegalStateException(); } @@ -145000,24 +145230,15 @@ public class RegistryService { public boolean equals(Object that) { if (that == null) return false; - if (that instanceof getAllWorkflows_args) - return this.equals((getAllWorkflows_args)that); + if (that instanceof getLatestQueueStatuses_args) + return this.equals((getLatestQueueStatuses_args)that); return false; } - public boolean equals(getAllWorkflows_args that) { + public boolean equals(getLatestQueueStatuses_args that) { if (that == null) return false; - boolean this_present_gatewayId = true && this.isSetGatewayId(); - boolean that_present_gatewayId = true && that.isSetGatewayId(); - if (this_present_gatewayId || that_present_gatewayId) { - if (!(this_present_gatewayId && that_present_gatewayId)) - return false; - if (!this.gatewayId.equals(that.gatewayId)) - return false; - } - return true; } @@ -145025,32 +145246,17 @@ public class RegistryService { public int hashCode() { List<Object> list = new ArrayList<Object>(); - boolean present_gatewayId = true && (isSetGatewayId()); - list.add(present_gatewayId); - if (present_gatewayId) - list.add(gatewayId); - return list.hashCode(); } @Override - public int compareTo(getAllWorkflows_args other) { + public int compareTo(getLatestQueueStatuses_args other) { if (!getClass().equals(other.getClass())) { return getClass().getName().compareTo(other.getClass().getName()); } int lastComparison = 0; - lastComparison = Boolean.valueOf(isSetGatewayId()).compareTo(other.isSetGatewayId()); - if (lastComparison != 0) { - return lastComparison; - } - if (isSetGatewayId()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.gatewayId, other.gatewayId); - if (lastComparison != 0) { - return lastComparison; - } - } return 0; } @@ -145068,25 +145274,15 @@ public class RegistryService { @Override public String toString() { - StringBuilder sb = new StringBuilder("getAllWorkflows_args("); + StringBuilder sb = new StringBuilder("getLatestQueueStatuses_args("); boolean first = true; - sb.append("gatewayId:"); - if (this.gatewayId == null) { - sb.append("null"); - } else { - sb.append(this.gatewayId); - } - first = false; sb.append(")"); return sb.toString(); } public void validate() throws org.apache.thrift.TException { // check for required fields - if (gatewayId == null) { - throw new org.apache.thrift.protocol.TProtocolException("Required field 'gatewayId' was not present! Struct: " + toString()); - } // check for sub-struct validity } @@ -145106,15 +145302,15 @@ public class RegistryService { } } - private static class getAllWorkflows_argsStandardSchemeFactory implements SchemeFactory { - public getAllWorkflows_argsStandardScheme getScheme() { - return new getAllWorkflows_argsStandardScheme(); + private static class getLatestQueueStatuses_argsStandardSchemeFactory implements SchemeFactory { + public getLatestQueueStatuses_argsStandardScheme getScheme() { + return new getLatestQueueStatuses_argsStandardScheme(); } } - private static class getAllWorkflows_argsStandardScheme extends StandardScheme<getAllWorkflows_args> { + private static class getLatestQueueStatuses_argsStandardScheme extends StandardScheme<getLatestQueueStatuses_args> { - public void read(org.apache.thrift.protocol.TProtocol iprot, getAllWorkflows_args struct) throws org.apache.thrift.TException { + public void read(org.apache.thrift.protocol.TProtocol iprot, getLatestQueueStatuses_args struct) throws org.apache.thrift.TException { org.apache.thrift.protocol.TField schemeField; iprot.readStructBegin(); while (true) @@ -145124,14 +145320,6 @@ public class RegistryService { break; } switch (schemeField.id) { - case 1: // GATEWAY_ID - if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { - struct.gatewayId = iprot.readString(); - struct.setGatewayIdIsSet(true); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; default: org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); } @@ -145143,58 +145331,50 @@ public class RegistryService { struct.validate(); } - public void write(org.apache.thrift.protocol.TProtocol oprot, getAllWorkflows_args struct) throws org.apache.thrift.TException { + public void write(org.apache.thrift.protocol.TProtocol oprot, getLatestQueueStatuses_args struct) throws org.apache.thrift.TException { struct.validate(); oprot.writeStructBegin(STRUCT_DESC); - if (struct.gatewayId != null) { - oprot.writeFieldBegin(GATEWAY_ID_FIELD_DESC); - oprot.writeString(struct.gatewayId); - oprot.writeFieldEnd(); - } oprot.writeFieldStop(); oprot.writeStructEnd(); } } - private static class getAllWorkflows_argsTupleSchemeFactory implements SchemeFactory { - public getAllWorkflows_argsTupleScheme getScheme() { - return new getAllWorkflows_argsTupleScheme(); + private static class getLatestQueueStatuses_argsTupleSchemeFactory implements SchemeFactory { + public getLatestQueueStatuses_argsTupleScheme getScheme() { + return new getLatestQueueStatuses_argsTupleScheme(); } } - private static class getAllWorkflows_argsTupleScheme extends TupleScheme<getAllWorkflows_args> { + private static class getLatestQueueStatuses_argsTupleScheme extends TupleScheme<getLatestQueueStatuses_args> { @Override - public void write(org.apache.thrift.protocol.TProtocol prot, getAllWorkflows_args struct) throws org.apache.thrift.TException { + public void write(org.apache.thrift.protocol.TProtocol prot, getLatestQueueStatuses_args struct) throws org.apache.thrift.TException { TTupleProtocol oprot = (TTupleProtocol) prot; - oprot.writeString(struct.gatewayId); } @Override - public void read(org.apache.thrift.protocol.TProtocol prot, getAllWorkflows_args struct) throws org.apache.thrift.TException { + public void read(org.apache.thrift.protocol.TProtocol prot, getLatestQueueStatuses_args struct) throws org.apache.thrift.TException { TTupleProtocol iprot = (TTupleProtocol) prot; - struct.gatewayId = iprot.readString(); - struct.setGatewayIdIsSet(true); } } } - public static class getAllWorkflows_result implements org.apache.thrift.TBase<getAllWorkflows_result, getAllWorkflows_result._Fields>, java.io.Serializable, Cloneable, Comparable<getAllWorkflows_result> { - private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("getAllWorkflows_result"); + public static class getLatestQueueStatuses_result implements org.apache.thrift.TBase<getLatestQueueStatuses_result, getLatestQueueStatuses_result._Fields>, java.io.Serializable, Cloneable, Comparable<getLatestQueueStatuses_result> { + private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("getLatestQueueStatuses_result"); private static final org.apache.thrift.protocol.TField SUCCESS_FIELD_DESC = new org.apache.thrift.protocol.TField("success", org.apache.thrift.protocol.TType.LIST, (short)0); private static final org.apache.thrift.protocol.TField RSE_FIELD_DESC = new org.apache.thrift.protocol.TField("rse", org.apache.thrift.protocol.TType.STRUCT, (short)1); private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); static { - schemes.put(StandardScheme.class, new getAllWorkflows_resultStandardSchemeFactory()); - schemes.put(TupleScheme.class, new getAllWorkflows_resultTupleSchemeFactory()); + schemes.put(StandardScheme.class, new getLatestQueueStatuses_resultStandardSchemeFactory()); + schemes.put(TupleScheme.class, new getLatestQueueStatuses_resultTupleSchemeFactory()); } - public List<String> success; // required + public List<org.apache.airavata.model.status.QueueStatusModel> success; // required public org.apache.airavata.registry.api.exception.RegistryServiceException rse; // required /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */ @@ -145264,18 +145444,18 @@ public class RegistryService { Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class); tmpMap.put(_Fields.SUCCESS, new org.apache.thrift.meta_data.FieldMetaData("success", org.apache.thrift.TFieldRequirementType.DEFAULT, new org.apache.thrift.meta_data.ListMetaData(org.apache.thrift.protocol.TType.LIST, - new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)))); + new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, org.apache.airavata.model.status.QueueStatusModel.class)))); tmpMap.put(_Fields.RSE, new org.apache.thrift.meta_data.FieldMetaData("rse", org.apache.thrift.TFieldRequirementType.DEFAULT, new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRUCT))); metaDataMap = Collections.unmodifiableMap(tmpMap); - org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(getAllWorkflows_result.class, metaDataMap); + org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(getLatestQueueStatuses_result.class, metaDataMap); } - public getAllWorkflows_result() { + public getLatestQueueStatuses_result() { } - public getAllWorkflows_result( - List<String> success, + public getLatestQueueStatuses_result( + List<org.apache.airavata.model.status.QueueStatusModel> success, org.apache.airavata.registry.api.exception.RegistryServiceException rse) { this(); @@ -145286,9 +145466,12 @@ public class RegistryService { /** * Performs a deep copy on <i>other</i>. */ - public getAllWorkflows_result(getAllWorkflows_result other) { + public getLatestQueueStatuses_result(getLatestQueueStatuses_result other) { if (other.isSetSuccess()) { - List<String> __this__success = new ArrayList<String>(other.success); + List<org.apache.airavata.model.status.QueueStatusModel> __this__success = new ArrayList<org.apache.airavata.model.status.QueueStatusModel>(other.success.size()); + for (org.apache.airavata.model.status.QueueStatusModel other_element : other.success) { + __this__success.add(new org.apache.airavata.model.status.QueueStatusModel(other_element)); + } this.success = __this__success; } if (other.isSetRse()) { @@ -145296,8 +145479,8 @@ public class RegistryService { } } - public getAllWorkflows_result deepCopy() { - return new getAllWorkflows_result(this); + public getLatestQueueStatuses_result deepCopy() { + return new getLatestQueueStatuses_result(this); } @Override @@ -145310,22 +145493,22 @@ public class RegistryService { return (this.success == null) ? 0 : this.success.size(); } - public java.util.Iterator<String> getSuccessIterator() { + public java.util.Iterator<org.apache.airavata.model.status.QueueStatusModel> getSuccessIterator() { return (this.success == null) ? null : this.success.iterator(); } - public void addToSuccess(String elem) { + public void addToSuccess(org.apache.airavata.model.status.QueueStatusModel elem) { if (this.success == null) { - this.success = new ArrayList<String>(); + this.success = new ArrayList<org.apache.airavata.model.status.QueueStatusModel>(); } this.success.add(elem); } - public List<String> getSuccess() { + public List<org.apache.airavata.model.status.QueueStatusModel> getSuccess() { return this.success; } - public getAllWorkflows_result setSuccess(List<String> success) { + public getLatestQueueStatuses_result setSuccess(List<org.apache.airavata.model.status.QueueStatusModel> success) { this.success = success; return this; } @@ -145349,7 +145532,7 @@ public class RegistryService { return this.rse; } - public getAllWorkflows_result setRse(org.apache.airavata.registry.api.exception.RegistryServiceException rse) { + public getLatestQueueStatuses_result setRse(org.apache.airavata.registry.api.exception.RegistryServiceException rse) { this.rse = rse; return this; } @@ -145375,7 +145558,7 @@ public class RegistryService { if (value == null) { unsetSuccess(); } else { - setSuccess((List<String>)value); + setSuccess((List<org.apache.airavata.model.status.QueueStatusModel>)value); } break; @@ -145421,12 +145604,12 @@ public class RegistryService { public boolean equals(Object that) { if (that == null) return false; - if (that instanceof getAllWorkflows_result) - return this.equals((getAllWorkflows_result)that); + if (that instanceof getLatestQueueStatuses_result) + return this.equals((getLatestQueueStatuses_result)that); return false; } - public boolean equals(getAllWorkflows_result that) { + public boolean equals(getLatestQueueStatuses_result that) { if (that == null) return false; @@ -145469,7 +145652,7 @@ public class RegistryService { } @Override - public int compareTo(getAllWorkflows_result other) { + public int compareTo(getLatestQueueStatuses_result other) { if (!getClass().equals(other.getClass())) { return getClass().getName().compareTo(other.getClass().getName()); } @@ -145513,7 +145696,7 @@ public class RegistryService { @Override public String toString() { - StringBuilder sb = new StringBuilder("getAllWorkflows_result("); + StringBuilder sb = new StringBuilder("getLatestQueueStatuses_result("); boolean first = true; sb.append("success:"); @@ -145556,15 +145739,15 @@ public class RegistryService { } } - private static class getAllWorkflows_resultStandardSchemeFactory implements SchemeFactory { - public getAllWorkflows_resultStandardScheme getScheme() { - return new getAllWorkflows_resultStandardScheme(); + private static class getLatestQueueStatuses_resultStandardSchemeFactory implements SchemeFactory { + public getLatestQueueStatuses_resultStandardScheme getScheme() { + return new getLatestQueueStatuses_resultStandardScheme(); } } - private static class getAllWorkflows_resultStandardScheme extends StandardScheme<getAllWorkflows_result> { + private static class getLatestQueueStatuses_resultStandardScheme extends StandardScheme<getLatestQueueStatuses_result> { - public void read(org.apache.thrift.protocol.TProtocol iprot, getAllWorkflows_result struct) throws org.apache.thrift.TException { + public void read(org.apache.thrift.protocol.TProtocol iprot, getLatestQueueStatuses_result struct) throws org.apache.thrift.TException { org.apache.thrift.protocol.TField schemeField; iprot.readStructBegin(); while (true) @@ -145578,11 +145761,12 @@ public class RegistryService { if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { { org.apache.thrift.protocol.TList _list290 = iprot.readListBegin(); - struct.success = new ArrayList<String>(_list290.size); - String _elem291; + struct.success = new ArrayList<org.apache.airavata.model.status.QueueStatusModel>(_list290.size); + org.apache.airavata.model.status.QueueStatusModel _elem291; for (int _i292 = 0; _i292 < _list290.size; ++_i292) { - _elem291 = iprot.readString(); + _elem291 = new org.apache.airavata.model.status.QueueStatusModel(); + _elem291.read(iprot); struct.success.add(_elem291); } iprot.readListEnd(); @@ -145612,17 +145796,17 @@ public class RegistryService { struct.validate(); } - public void write(org.apache.thrift.protocol.TProtocol oprot, getAllWorkflows_result struct) throws org.apache.thrift.TException { + public void write(org.apache.thrift.protocol.TProtocol oprot, getLatestQueueStatuses_result struct) throws org.apache.thrift.TException { struct.validate(); oprot.writeStructBegin(STRUCT_DESC); if (struct.success != null) { oprot.writeFieldBegin(SUCCESS_FIELD_DESC); { - oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.success.size())); - for (String _iter293 : struct.success) + oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.success.size())); + for (org.apache.airavata.model.status.QueueStatusModel _iter293 : struct.success) { - oprot.writeString(_iter293); + _iter293.write(oprot); } oprot.writeListEnd(); } @@ -145639,16 +145823,16 @@ public class RegistryService { } - private static class getAllWorkflows_resultTupleSchemeFactory implements SchemeFactory { - public getAllWorkflows_resultTupleScheme getScheme() { - return new getAllWorkflows_resultTupleScheme(); + private static class getLatestQueueStatuses_resultTupleSchemeFactory implements SchemeFactory { + public getLatestQueueStatuses_resultTupleScheme getScheme() { + return new getLatestQueueStatuses_resultTupleScheme(); } } - private static class getAllWorkflows_resultTupleScheme extends TupleScheme<getAllWorkflows_result> { + private static class getLatestQueueStatuses_resultTupleScheme extends TupleScheme<getLatestQueueStatuses_result> { @Override - public void write(org.apache.thrift.protocol.TProtocol prot, getAllWorkflows_result struct) throws org.apache.thrift.TException { + public void write(org.apache.thrift.protocol.TProtocol prot, getLatestQueueStatuses_result struct) throws org.apache.thrift.TException { TTupleProtocol oprot = (TTupleProtocol) prot; BitSet optionals = new BitSet(); if (struct.isSetSuccess()) { @@ -145661,9 +145845,9 @@ public class RegistryService { if (struct.isSetSuccess()) { { oprot.writeI32(struct.success.size()); - for (String _iter294 : struct.success) + for (org.apache.airavata.model.status.QueueStatusModel _iter294 : struct.success) { - oprot.writeString(_iter294); + _iter294.write(oprot); } } } @@ -145673,17 +145857,18 @@ public class RegistryService { } @Override - public void read(org.apache.thrift.protocol.TProtocol prot, getAllWorkflows_result struct) throws org.apache.thrift.TException { + public void read(org.apache.thrift.protocol.TProtocol prot, getLatestQueueStatuses_result struct) throws org.apache.thrift.TException { TTupleProtocol iprot = (TTupleProtocol) prot; BitSet incoming = iprot.readBitSet(2); if (incoming.get(0)) { { - org.apache.thrift.protocol.TList _list295 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32()); - struct.success = new ArrayList<String>(_list295.size); - String _elem296; + org.apache.thrift.protocol.TList _list295 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); + struct.success = new ArrayList<org.apache.airavata.model.status.QueueStatusModel>(_list295.size); + org.apache.airavata.model.status.QueueStatusModel _elem296; for (int _i297 = 0; _i297 < _list295.size; ++_i297) { - _elem296 = iprot.readString(); + _elem296 = new org.apache.airavata.model.status.QueueStatusModel(); + _elem296.read(iprot); struct.success.add(_elem296); } } @@ -145699,22 +145884,22 @@ public class RegistryService { } - public static class getWorkflow_args implements org.apache.thrift.TBase<getWorkflow_args, getWorkflow_args._Fields>, java.io.Serializable, Cloneable, Comparable<getWorkflow_args> { - private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("getWorkflow_args"); + public static class registerQueueStatuses_args implements org.apache.thrift.TBase<registerQueueStatuses_args, registerQueueStatuses_args._Fields>, java.io.Serializable, Cloneable, Comparable<registerQueueStatuses_args> { + private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("registerQueueStatuses_args"); - private static final org.apache.thrift.protocol.TField WORKFLOW_TEMPLATE_ID_FIELD_DESC = new org.apache.thrift.protocol.TField("workflowTemplateId", org.apache.thrift.protocol.TType.STRING, (short)1); + private static final org.apache.thrift.protocol.TField QUEUE_STATUSES_FIELD_DESC = new org.apache.thrift.protocol.TField("queueStatuses", org.apache.thrift.protocol.TType.LIST, (short)1); private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); static { - schemes.put(StandardScheme.class, new getWorkflow_argsStandardSchemeFactory()); - schemes.put(TupleScheme.class, new getWorkflow_argsTupleSchemeFactory()); + schemes.put(StandardScheme.class, new registerQueueStatuses_argsStandardSchemeFactory()); + schemes.put(TupleScheme.class, new registerQueueStatuses_argsTupleSchemeFactory()); } - public String workflowTemplateId; // required + public List<org.apache.airavata.model.status.QueueStatusModel> queueStatuses; // required /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */ public enum _Fields implements org.apache.thrift.TFieldIdEnum { - WORKFLOW_TEMPLATE_ID((short)1, "workflowTemplateId"); + QUEUE_STATUSES((short)1, "queueStatuses"); private static final Map<String, _Fields> byName = new HashMap<String, _Fields>(); @@ -145729,8 +145914,8 @@ public class RegistryService { */ public static _Fields findByThriftId(int fieldId) { switch(fieldId) { - case 1: // WORKFLOW_TEMPLATE_ID - return WORKFLOW_TEMPLATE_ID; + case 1: // QUEUE_STATUSES + return QUEUE_STATUSES; default: return null; } @@ -145774,71 +145959,91 @@ public class RegistryService { public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap; static { Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class); - tmpMap.put(_Fields.WORKFLOW_TEMPLATE_ID, new org.apache.thrift.meta_data.FieldMetaData("workflowTemplateId", org.apache.thrift.TFieldRequirementType.REQUIRED, - new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); + tmpMap.put(_Fields.QUEUE_STATUSES, new org.apache.thrift.meta_data.FieldMetaData("queueStatuses", org.apache.thrift.TFieldRequirementType.REQUIRED, + new org.apache.thrift.meta_data.ListMetaData(org.apache.thrift.protocol.TType.LIST, + new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, org.apache.airavata.model.status.QueueStatusModel.class)))); metaDataMap = Collections.unmodifiableMap(tmpMap); - org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(getWorkflow_args.class, metaDataMap); + org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(registerQueueStatuses_args.class, metaDataMap); } - public getWorkflow_args() { + public registerQueueStatuses_args() { } - public getWorkflow_args( - String workflowTemplateId) + public registerQueueStatuses_args( + List<org.apache.airavata.model.status.QueueStatusModel> queueStatuses) { this(); - this.workflowTemplateId = workflowTemplateId; + this.queueStatuses = queueStatuses; } /** * Performs a deep copy on <i>other</i>. */ - public getWorkflow_args(getWorkflow_args other) { - if (other.isSetWorkflowTemplateId()) { - this.workflowTemplateId = other.workflowTemplateId; + public registerQueueStatuses_args(registerQueueStatuses_args other) { + if (other.isSetQueueStatuses()) { + List<org.apache.airavata.model.status.QueueStatusModel> __this__queueStatuses = new ArrayList<org.apache.airavata.model.status.QueueStatusModel>(other.queueStatuses.size()); + for (org.apache.airavata.model.status.QueueStatusModel other_element : other.queueStatuses) { + __this__queueStatuses.add(new org.apache.airavata.model.status.QueueStatusModel(other_element)); + } + this.queueStatuses = __this__queueStatuses; } } - public getWorkflow_args deepCopy() { - return new getWorkflow_args(this); + public registerQueueStatuses_args deepCopy() { + return new registerQueueStatuses_args(this); } @Override public void clear() { - this.workflowTemplateId = null; + this.queueStatuses = null; } - public String getWorkflowTemplateId() { - return this.workflowTemplateId; + public int getQueueStatusesSize() { + return (this.queueStatuses == null) ? 0 : this.queueStatuses.size(); } - public getWorkflow_args setWorkflowTemplateId(String workflowTemplateId) { - this.workflowTemplateId = workflowTemplateId; + public java.util.Iterator<org.apache.airavata.model.status.QueueStatusModel> getQueueStatusesIterator() { + return (this.queueStatuses == null) ? null : this.queueStatuses.iterator(); + } + + public void addToQueueStatuses(org.apache.airavata.model.status.QueueStatusModel elem) { + if (this.queueStatuses == null) { + this.queueStatuses = new ArrayList<org.apache.airavata.model.status.QueueStatusModel>(); + } + this.queueStatuses.add(elem); + } + + public List<org.apache.airavata.model.status.QueueStatusModel> getQueueStatuses() { + return this.queueStatuses; + } + + public registerQueueStatuses_args setQueueStatuses(List<org.apache.airavata.model.status.QueueStatusModel> queueStatuses) { + this.queueStatuses = queueStatuses; return this; } - public void unsetWorkflowTemplateId() { - this.workflowTemplateId = null; + public void unsetQueueStatuses() { + this.queueStatuses = null; } - /** Returns true if field workflowTemplateId is set (has been assigned a value) and false otherwise */ - public boolean isSetWorkflowTemplateId() { - return this.workflowTemplateId != null; + /** Returns true if field queueStatuses is set (has been assigned a value) and false otherwise */ + public boolean isSetQueueStatuses() { + return this.queueStatuses != null; } - public void setWorkflowTemplateIdIsSet(boolean value) { + public void setQueueStatusesIsSet(boolean value) { if (!value) { - this.workflowTemplateId = null; + this.queueStatuses = null; } } public void setFieldValue(_Fields field, Object value) { switch (field) { - case WORKFLOW_TEMPLATE_ID: + case QUEUE_STATUSES: if (value == null) { - unsetWorkflowTemplateId(); + unsetQueueStatuses(); } else { - setWorkflowTemplateId((String)value); + setQueueStatuses((List<org.apache.airavata.model.status.QueueStatusModel>)value); } break; @@ -145847,8 +146052,8 @@ public class RegistryService { public Object getFieldValue(_Fields field) { switch (field) { - case WORKFLOW_TEMPLATE_ID: - return getWorkflowTemplateId(); + case QUEUE_STATUSES: + return getQueueStatuses(); } throw new IllegalStateException(); @@ -145861,8 +146066,8 @@ public class RegistryService { } switch (field) { - case WORKFLOW_TEMPLATE_ID: - return isSetWorkflowTemplateId(); + case QUEUE_STATUSES: + return isSetQueueStatuses(); } throw new IllegalStateException(); } @@ -145871,21 +146076,21 @@ public class RegistryService { public boolean equals(Object that) { if (that == null) return false; - if (that instanceof getWorkflow_args) - return this.equals((getWorkflow_args)that); + if (that instanceof registerQueueStatuses_args) + return this.equals((registerQueueStatuses_args)that); return false; } - public boolean equals(getWorkflow_args that) { + public boolean equals(registerQueueStatuses_args that) { if (that == null) return false; - boolean this_present_workflowTemplateId = true && this.isSetWorkflowTemplateId(); - boolean that_present_workflowTemplateId = true && that.isSetWorkflowTemplateId(); - if (this_present_workflowTemplateId || that_present_workflowTemplateId) { - if (!(this_present_workflowTemplateId && that_present_workflowTemplateId)) + boolean this_present_queueStatuses = true && this.isSetQueueStatuses(); + boolean that_present_queueStatuses = true && that.isSetQueueStatuses(); + if (this_present_queueStatuses || that_present_queueStatuses) { + if (!(this_present_queueStatuses && that_present_queueStatuses)) return false; - if (!this.workflowTemplateId.equals(that.workflowTemplateId)) + if (!this.queueStatuses.equals(that.queueStatuses)) return false; } @@ -145896,28 +146101,28 @@ public class RegistryService { public int hashCode() { List<Object> list = new ArrayList<Object>(); - boolean present_workflowTemplateId = true && (isSetWorkflowTemplateId()); - list.add(present_workflowTemplateId); - if (present_workflowTemplateId) - list.add(workflowTemplateId); + boolean present_queueStatuses = true && (isSetQueueStatuses()); + list.add(present_queueStatuses); + if (present_queueStatuses) + list.add(queueStatuses); return list.hashCode(); } @Override - public int compareTo(getWorkflow_args other) { + public int compareTo(registerQueueStatuses_args other) { if (!getClass().equals(other.getClass())) { return getClass().getName().compareTo(other.getClass().getName()); } int lastComparison = 0; - lastComparison = Boolean.valueOf(isSetWorkflowTemplateId()).compareTo(other.isSetWorkflowTemplateId()); + lastComparison = Boolean.valueOf(isSetQueueStatuses()).compareTo(other.isSetQueueStatuses()); if (lastComparison != 0) { return lastComparison; } - if (isSetWorkflowTemplateId()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.workflowTemplateId, other.workflowTemplateId); + if (isSetQueueStatuses()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.queueStatuses, other.queueStatuses); if (lastComparison != 0) { return lastComparison; } @@ -145939,14 +146144,14 @@ public class RegistryService { @Override public String toString() { - StringBuilder sb = new StringBuilder("getWorkflow_args("); + StringBuilder sb = new StringBuilder("registerQueueStatuses_args("); boolean first = true; - sb.append("workflowTemplateId:"); - if (this.workflowTemplateId == null) { + sb.append("queueStatuses:"); + if (this.queueStatuses == null) { sb.append("null"); } else { - sb.append(this.workflowTemplateId); + sb.append(this.queueStatuses); } first = false; sb.append(")"); @@ -145955,8 +146160,8 @@ public class RegistryService { public void validate() throws org.apache.thrift.TException { // check for required fields - if (workflowTemplateId == null) { - throw new org.apache.thrift.protocol.TProtocolException("Required field 'workflowTemplateId' was not present! Struct: " + toString()); + if (queueStatuses == null) { + throw new org.apache.thrift.protocol.TProtocolException("Required field 'queueStatuses' was not present! Struct: " + toString()); } // check for sub-struct validity } @@ -145977,15 +146182,15 @@ public class RegistryService { } } - private static class getWorkflow_argsStandardSchemeFactory implements SchemeFactory { - public getWorkflow_argsStandardScheme getScheme() { - return new getWorkflow_argsStandardScheme(); + private static class registerQueueStatuses_argsStandardSchemeFactory implements SchemeFactory { + public registerQueueStatuses_argsStandardScheme getScheme() { + return new registerQueueStatuses_argsStandardScheme(); } } - private static class getWorkflow_argsStandardScheme extends StandardScheme<getWorkflow_args> { + private static class registerQueueStatuses_argsStandardScheme extends StandardScheme<registerQueueStatuses_args> { - public void read(org.apache.thrift.protocol.TProtocol iprot, getWorkflow_args struct) throws org.apache.thrift.TException { + public void read(org.apache.thrift.protocol.TProtocol iprot, registerQueueStatuses_args struct) throws org.apache.thrift.TException { org.apache.thrift.protocol.TField schemeField; iprot.readStructBegin(); while (true) @@ -145995,10 +146200,21 @@ public class RegistryService { break; } switch (schemeField.id) { - case 1: // WORKFLOW_TEMPLATE_ID - if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { - struct.workflowTemplateId = iprot.readString(); - struct.setWorkflowTemplateIdIsSet(true); + case 1: // QUEUE_STATUSES + if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { + { + org.apache.thrift.protocol.TList _list298 = iprot.readListBegin(); + struct.queueStatuses = new ArrayList<org.apache.airavata.model.status.QueueStatusModel>(_list298.size); + org.apache.airavata.model.status.QueueStatusModel _elem299; + for (int _i300 = 0; _i300 < _list298.size; ++_i300) + { + _elem299 = new org.apache.airavata.model.status.QueueStatusModel(); + _elem299.read(iprot); + struct.queueStatuses.add(_elem299); + } + iprot.readListEnd(); + } + struct.setQueueStatusesIsSet(true); } else { org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); } @@ -146014,13 +146230,20 @@ public class RegistryService { struct.validate(); } - public void write(org.apache.thrift.protocol.TProtocol oprot, getWorkflow_args struct) throws org.apache.thrift.TException { + public void write(org.apache.thrift.protocol.TProtocol oprot, registerQueueStatuses_args struct) throws org.apache.thrift.TException { struct.validate(); oprot.writeStructBegin(STRUCT_DESC); - if (struct.workflowTemplateId != null) { - oprot.writeFieldBegin(WORKFLOW_TEMPLATE_ID_FIELD_DESC); - oprot.writeString(struct.workflowTemplateId); + if (struct.queueStatuses != null) { + oprot.writeFieldBegin(QUEUE_STATUSES_FIELD_DESC); + { + oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.queueStatuses.size())); + for (org.apache.airavata.model.status.QueueStatusModel _iter301 : struct.queueStatuses) + { + _iter301.write(oprot); + } + oprot.writeListEnd(); + } oprot.writeFieldEnd(); } oprot.writeFieldStop(); @@ -146029,48 +146252,61 @@ public class RegistryService { } - private static class getWorkflow_argsTupleSchemeFactory implements SchemeFactory { - public getWorkflow_argsTupleScheme getScheme() { - return new getWorkflow_argsTupleScheme(); + private static class registerQueueStatuses_argsTupleSchemeFactory implements SchemeFactory { + public registerQueueStatuses_argsTupleScheme getScheme() { + return new registerQueueStatuses_argsTupleScheme(); } } - private static class getWorkflow_argsTupleScheme extends TupleScheme<getWorkflow_args> { + private static class registerQueueStatuses_argsTupleScheme extends TupleScheme<registerQueueStatuses_args> { @Override - public void write(org.apache.thrift.protocol.TProtocol prot, getWorkflow_args struct) throws org.apache.thrift.TException { + public void write(org.apache.thrift.protocol.TProtocol prot, registerQueueStatuses_args struct) throws org.apache.thrift.TException { TTupleProtocol oprot = (TTupleProtocol) prot; - oprot.writeString(struct.workflowTemplateId); + { + oprot.writeI32(struct.queueStatuses.size()); + for (org.apache.airavata.model.status.QueueStatusModel _iter302 : struct.queueStatuses) + { + _iter302.write(oprot); + } + } } @Override - public void read(org.apache.thrift.protocol.TProtocol prot, getWorkflow_args struct) throws org.apache.thrift.TException { + public void read(org.apache.thrift.protocol.TProtocol prot, registerQueueStatuses_args struct) throws org.apache.thrift.TException { TTupleProtocol iprot = (TTupleProtocol) prot; - struct.workflowTemplateId = iprot.readString(); - struct.setWorkflowTemplateIdIsSet(true); + { + org.apache.thrift.protocol.TList _list303 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); + struct.queueStatuses = new ArrayList<org.apache.airavata.model.status.QueueStatusModel>(_list303.size); + org.apache.airavata.model.status.QueueStatusModel _elem304; + for (int _i305 = 0; _i305 < _list303.size; ++_i305) + { + _elem304 = new org.apache.airavata.model.status.QueueStatusModel(); + _elem304.read(iprot); + struct.queueStatuses.add(_elem304); + } + } + struct.setQueueStatusesIsSet(true); } } } - public static class getWorkflow_result implements org.apache.thrift.TBase<getWorkflow_result, getWorkflow_result._Fields>, java.io.Serializable, Cloneable, Comparable<getWorkflow_result> { - private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("getWorkflow_result"); + public static class registerQueueStatuses_result implements org.apache.thrift.TBase<registerQueueStatuses_result, registerQueueStatuses_result._Fields>, java.io.Serializable, Cloneable, Comparable<registerQueueStatuses_result> { + private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("registerQueueStatuses_result"); - private static final org.apache.thrift.protocol.TField SUCCESS_FIELD_DESC = new org.apache.thrift.protocol.TField("success", org.apache.thrift.protocol.TType.STRUCT, (short)0); private static final org.apache.thrift.protocol.TField RSE_FIELD_DESC = new org.apache.thrift.protocol.TField("rse", org.apache.thrift.protocol.TType.STRUCT, (short)1); private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); static { - schemes.put(StandardScheme.class, new getWorkflow_resultStandardSchemeFactory()); - schemes.put(TupleScheme.class, new getWorkflow_resultTupleSchemeFactory()); + schemes.put(StandardScheme.class, new registerQueueStatuses_resultStandardSchemeFactory()); + schemes.put(TupleScheme.class, new registerQueueStatuses_resultTupleSchemeFactory()); } - public org.apache.airavata.model.WorkflowModel success; // required public org.apache.airavata.registry.api.exception.RegistryServiceException rse; // required /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */ public enum _Fields implements org.apache.thrift.TFieldIdEnum { - SUCCESS((short)0, "success"), RSE((short)1, "rse"); private static final Map<String, _Fields> byName = new HashMap<String, _Fields>(); @@ -146086,8 +146322,6 @@ public class RegistryService { */ public static _Fields findByThriftId(int fieldId) { switch(fieldId) { - case 0: // SUCCESS - return SUCCESS; case 1: // RSE return RSE; default: @@ -146133,77 +146367,45 @@ public class RegistryService { public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap; static { Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class); - tmpMap.put(_Fields.SUCCESS, new org.apache.thrift.meta_data.FieldMetaData("success", org.apache.thrift.TFieldRequirementType.DEFAULT, - new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, org.apache.airavata.model.WorkflowModel.class))); tmpMap.put(_Fields.RSE, new org.apache.thrift.meta_data.FieldMetaData("rse", org.apache.thrift.TFieldRequirementType.DEFAULT, new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRUCT))); metaDataMap = Collections.unmodifiableMap(tmpMap); - org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(getWorkflow_result.class, metaDataMap); + org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(registerQueueStatuses_result.class, metaDataMap); } - public getWorkflow_result() { + public registerQueueStatuses_result() { } - public getWorkflow_result( - org.apache.airavata.model.WorkflowModel success, + public registerQueueStatuses_result( org.apache.airavata.registry.api.exception.RegistryServiceException rse) { this(); - this.success = success; this.rse = rse; } /** * Performs a deep copy on <i>other</i>. */ - public getWorkflow_result(getWorkflow_result other) { - if (other.isSetSuccess()) { - this.success = new org.apache.airavata.model.WorkflowModel(other.success); - } + public registerQueueStatuses_result(registerQueueStatuses_result other) { if (other.isSetRse()) { this.rse = new org.apache.airavata.registry.api.exception.RegistryServiceException(other.rse); }
<TRUNCATED>
