http://git-wip-us.apache.org/repos/asf/airavata-php-gateway/blob/488b772f/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/sdk/AuroraAdmin.java ---------------------------------------------------------------------- diff --git a/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/sdk/AuroraAdmin.java b/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/sdk/AuroraAdmin.java deleted file mode 100644 index f3a62e3..0000000 --- a/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/sdk/AuroraAdmin.java +++ /dev/null @@ -1,14400 +0,0 @@ -/** - * - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, - * software distributed under the License is distributed on an - * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY - * KIND, either express or implied. See the License for the - * specific language governing permissions and limitations - * under the License. - */ -/** - * Autogenerated by Thrift Compiler (0.9.3) - * - * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING - * @generated - */ -package org.apache.airavata.cloud.aurora.client.sdk; - -import org.apache.thrift.scheme.IScheme; -import org.apache.thrift.scheme.SchemeFactory; -import org.apache.thrift.scheme.StandardScheme; - -import org.apache.thrift.scheme.TupleScheme; -import org.apache.thrift.protocol.TTupleProtocol; -import org.apache.thrift.protocol.TProtocolException; -import org.apache.thrift.EncodingUtils; -import org.apache.thrift.TException; -import org.apache.thrift.async.AsyncMethodCallback; -import org.apache.thrift.server.AbstractNonblockingServer.*; -import java.util.List; -import java.util.ArrayList; -import java.util.Map; -import java.util.HashMap; -import java.util.EnumMap; -import java.util.Set; -import java.util.HashSet; -import java.util.EnumSet; -import java.util.Collections; -import java.util.BitSet; -import java.nio.ByteBuffer; -import java.util.Arrays; -import javax.annotation.Generated; -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-21") -public class AuroraAdmin { - - public interface Iface extends AuroraSchedulerManager.Iface { - - /** - * Assign quota to a user. This will overwrite any pre-existing quota for the user. - * - * @param ownerRole - * @param quota - */ - public Response setQuota(String ownerRole, ResourceAggregate quota) throws org.apache.thrift.TException; - - /** - * Forces a task into a specific state. This does not guarantee the task will enter the given - * state, as the task must still transition within the bounds of the state machine. However, - * it attempts to enter that state via the state machine. - * - * @param taskId - * @param status - */ - public Response forceTaskState(String taskId, ScheduleStatus status) throws org.apache.thrift.TException; - - /** - * Immediately writes a storage snapshot to disk. - */ - public Response performBackup() throws org.apache.thrift.TException; - - /** - * Lists backups that are available for recovery. - */ - public Response listBackups() throws org.apache.thrift.TException; - - /** - * Loads a backup to an in-memory storage. This must precede all other recovery operations. - * - * @param backupId - */ - public Response stageRecovery(String backupId) throws org.apache.thrift.TException; - - /** - * Queries for tasks in a staged recovery. - * - * @param query - */ - public Response queryRecovery(TaskQuery query) throws org.apache.thrift.TException; - - /** - * Deletes tasks from a staged recovery. - * - * @param query - */ - public Response deleteRecoveryTasks(TaskQuery query) throws org.apache.thrift.TException; - - /** - * Commits a staged recovery, completely replacing the previous storage state. - */ - public Response commitRecovery() throws org.apache.thrift.TException; - - /** - * Unloads (aborts) a staged recovery. - */ - public Response unloadRecovery() throws org.apache.thrift.TException; - - /** - * Put the given hosts into maintenance mode. - * - * @param hosts - */ - public Response startMaintenance(Hosts hosts) throws org.apache.thrift.TException; - - /** - * Ask scheduler to begin moving tasks scheduled on given hosts. - * - * @param hosts - */ - public Response drainHosts(Hosts hosts) throws org.apache.thrift.TException; - - /** - * Retrieve the current maintenance states for a group of hosts. - * - * @param hosts - */ - public Response maintenanceStatus(Hosts hosts) throws org.apache.thrift.TException; - - /** - * Set the given hosts back into serving mode. - * - * @param hosts - */ - public Response endMaintenance(Hosts hosts) throws org.apache.thrift.TException; - - /** - * Start a storage snapshot and block until it completes. - */ - public Response snapshot() throws org.apache.thrift.TException; - - /** - * Forcibly rewrites the stored definition of user configurations. This is intended to be used - * in a controlled setting, primarily to migrate pieces of configurations that are opaque to the - * scheduler (e.g. executorConfig). - * The scheduler may do some validation of the rewritten configurations, but it is important - * that the caller take care to provide valid input and alter only necessary fields. - * - * @param request - */ - public Response rewriteConfigs(RewriteConfigsRequest request) throws org.apache.thrift.TException; - - /** - * Tell scheduler to trigger an explicit task reconciliation with the given settings. - * - * @param settings - */ - public Response triggerExplicitTaskReconciliation(ExplicitReconciliationSettings settings) throws org.apache.thrift.TException; - - /** - * Tell scheduler to trigger an implicit task reconciliation. - */ - public Response triggerImplicitTaskReconciliation() throws org.apache.thrift.TException; - - } - - public interface AsyncIface extends AuroraSchedulerManager .AsyncIface { - - public void setQuota(String ownerRole, ResourceAggregate quota, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; - - public void forceTaskState(String taskId, ScheduleStatus status, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; - - public void performBackup(org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; - - public void listBackups(org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; - - public void stageRecovery(String backupId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; - - public void queryRecovery(TaskQuery query, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; - - public void deleteRecoveryTasks(TaskQuery query, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; - - public void commitRecovery(org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; - - public void unloadRecovery(org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; - - public void startMaintenance(Hosts hosts, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; - - public void drainHosts(Hosts hosts, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; - - public void maintenanceStatus(Hosts hosts, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; - - public void endMaintenance(Hosts hosts, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; - - public void snapshot(org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; - - public void rewriteConfigs(RewriteConfigsRequest request, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; - - public void triggerExplicitTaskReconciliation(ExplicitReconciliationSettings settings, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; - - public void triggerImplicitTaskReconciliation(org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; - - } - - public static class Client extends AuroraSchedulerManager.Client implements Iface { - public static class Factory implements org.apache.thrift.TServiceClientFactory<Client> { - public Factory() {} - public Client getClient(org.apache.thrift.protocol.TProtocol prot) { - return new Client(prot); - } - public Client getClient(org.apache.thrift.protocol.TProtocol iprot, org.apache.thrift.protocol.TProtocol oprot) { - return new Client(iprot, oprot); - } - } - - public Client(org.apache.thrift.protocol.TProtocol prot) - { - super(prot, prot); - } - - public Client(org.apache.thrift.protocol.TProtocol iprot, org.apache.thrift.protocol.TProtocol oprot) { - super(iprot, oprot); - } - - public Response setQuota(String ownerRole, ResourceAggregate quota) throws org.apache.thrift.TException - { - send_setQuota(ownerRole, quota); - return recv_setQuota(); - } - - public void send_setQuota(String ownerRole, ResourceAggregate quota) throws org.apache.thrift.TException - { - setQuota_args args = new setQuota_args(); - args.setOwnerRole(ownerRole); - args.setQuota(quota); - sendBase("setQuota", args); - } - - public Response recv_setQuota() throws org.apache.thrift.TException - { - setQuota_result result = new setQuota_result(); - receiveBase(result, "setQuota"); - if (result.isSetSuccess()) { - return result.success; - } - throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "setQuota failed: unknown result"); - } - - public Response forceTaskState(String taskId, ScheduleStatus status) throws org.apache.thrift.TException - { - send_forceTaskState(taskId, status); - return recv_forceTaskState(); - } - - public void send_forceTaskState(String taskId, ScheduleStatus status) throws org.apache.thrift.TException - { - forceTaskState_args args = new forceTaskState_args(); - args.setTaskId(taskId); - args.setStatus(status); - sendBase("forceTaskState", args); - } - - public Response recv_forceTaskState() throws org.apache.thrift.TException - { - forceTaskState_result result = new forceTaskState_result(); - receiveBase(result, "forceTaskState"); - if (result.isSetSuccess()) { - return result.success; - } - throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "forceTaskState failed: unknown result"); - } - - public Response performBackup() throws org.apache.thrift.TException - { - send_performBackup(); - return recv_performBackup(); - } - - public void send_performBackup() throws org.apache.thrift.TException - { - performBackup_args args = new performBackup_args(); - sendBase("performBackup", args); - } - - public Response recv_performBackup() throws org.apache.thrift.TException - { - performBackup_result result = new performBackup_result(); - receiveBase(result, "performBackup"); - if (result.isSetSuccess()) { - return result.success; - } - throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "performBackup failed: unknown result"); - } - - public Response listBackups() throws org.apache.thrift.TException - { - send_listBackups(); - return recv_listBackups(); - } - - public void send_listBackups() throws org.apache.thrift.TException - { - listBackups_args args = new listBackups_args(); - sendBase("listBackups", args); - } - - public Response recv_listBackups() throws org.apache.thrift.TException - { - listBackups_result result = new listBackups_result(); - receiveBase(result, "listBackups"); - if (result.isSetSuccess()) { - return result.success; - } - throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "listBackups failed: unknown result"); - } - - public Response stageRecovery(String backupId) throws org.apache.thrift.TException - { - send_stageRecovery(backupId); - return recv_stageRecovery(); - } - - public void send_stageRecovery(String backupId) throws org.apache.thrift.TException - { - stageRecovery_args args = new stageRecovery_args(); - args.setBackupId(backupId); - sendBase("stageRecovery", args); - } - - public Response recv_stageRecovery() throws org.apache.thrift.TException - { - stageRecovery_result result = new stageRecovery_result(); - receiveBase(result, "stageRecovery"); - if (result.isSetSuccess()) { - return result.success; - } - throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "stageRecovery failed: unknown result"); - } - - public Response queryRecovery(TaskQuery query) throws org.apache.thrift.TException - { - send_queryRecovery(query); - return recv_queryRecovery(); - } - - public void send_queryRecovery(TaskQuery query) throws org.apache.thrift.TException - { - queryRecovery_args args = new queryRecovery_args(); - args.setQuery(query); - sendBase("queryRecovery", args); - } - - public Response recv_queryRecovery() throws org.apache.thrift.TException - { - queryRecovery_result result = new queryRecovery_result(); - receiveBase(result, "queryRecovery"); - if (result.isSetSuccess()) { - return result.success; - } - throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "queryRecovery failed: unknown result"); - } - - public Response deleteRecoveryTasks(TaskQuery query) throws org.apache.thrift.TException - { - send_deleteRecoveryTasks(query); - return recv_deleteRecoveryTasks(); - } - - public void send_deleteRecoveryTasks(TaskQuery query) throws org.apache.thrift.TException - { - deleteRecoveryTasks_args args = new deleteRecoveryTasks_args(); - args.setQuery(query); - sendBase("deleteRecoveryTasks", args); - } - - public Response recv_deleteRecoveryTasks() throws org.apache.thrift.TException - { - deleteRecoveryTasks_result result = new deleteRecoveryTasks_result(); - receiveBase(result, "deleteRecoveryTasks"); - if (result.isSetSuccess()) { - return result.success; - } - throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "deleteRecoveryTasks failed: unknown result"); - } - - public Response commitRecovery() throws org.apache.thrift.TException - { - send_commitRecovery(); - return recv_commitRecovery(); - } - - public void send_commitRecovery() throws org.apache.thrift.TException - { - commitRecovery_args args = new commitRecovery_args(); - sendBase("commitRecovery", args); - } - - public Response recv_commitRecovery() throws org.apache.thrift.TException - { - commitRecovery_result result = new commitRecovery_result(); - receiveBase(result, "commitRecovery"); - if (result.isSetSuccess()) { - return result.success; - } - throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "commitRecovery failed: unknown result"); - } - - public Response unloadRecovery() throws org.apache.thrift.TException - { - send_unloadRecovery(); - return recv_unloadRecovery(); - } - - public void send_unloadRecovery() throws org.apache.thrift.TException - { - unloadRecovery_args args = new unloadRecovery_args(); - sendBase("unloadRecovery", args); - } - - public Response recv_unloadRecovery() throws org.apache.thrift.TException - { - unloadRecovery_result result = new unloadRecovery_result(); - receiveBase(result, "unloadRecovery"); - if (result.isSetSuccess()) { - return result.success; - } - throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "unloadRecovery failed: unknown result"); - } - - public Response startMaintenance(Hosts hosts) throws org.apache.thrift.TException - { - send_startMaintenance(hosts); - return recv_startMaintenance(); - } - - public void send_startMaintenance(Hosts hosts) throws org.apache.thrift.TException - { - startMaintenance_args args = new startMaintenance_args(); - args.setHosts(hosts); - sendBase("startMaintenance", args); - } - - public Response recv_startMaintenance() throws org.apache.thrift.TException - { - startMaintenance_result result = new startMaintenance_result(); - receiveBase(result, "startMaintenance"); - if (result.isSetSuccess()) { - return result.success; - } - throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "startMaintenance failed: unknown result"); - } - - public Response drainHosts(Hosts hosts) throws org.apache.thrift.TException - { - send_drainHosts(hosts); - return recv_drainHosts(); - } - - public void send_drainHosts(Hosts hosts) throws org.apache.thrift.TException - { - drainHosts_args args = new drainHosts_args(); - args.setHosts(hosts); - sendBase("drainHosts", args); - } - - public Response recv_drainHosts() throws org.apache.thrift.TException - { - drainHosts_result result = new drainHosts_result(); - receiveBase(result, "drainHosts"); - if (result.isSetSuccess()) { - return result.success; - } - throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "drainHosts failed: unknown result"); - } - - public Response maintenanceStatus(Hosts hosts) throws org.apache.thrift.TException - { - send_maintenanceStatus(hosts); - return recv_maintenanceStatus(); - } - - public void send_maintenanceStatus(Hosts hosts) throws org.apache.thrift.TException - { - maintenanceStatus_args args = new maintenanceStatus_args(); - args.setHosts(hosts); - sendBase("maintenanceStatus", args); - } - - public Response recv_maintenanceStatus() throws org.apache.thrift.TException - { - maintenanceStatus_result result = new maintenanceStatus_result(); - receiveBase(result, "maintenanceStatus"); - if (result.isSetSuccess()) { - return result.success; - } - throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "maintenanceStatus failed: unknown result"); - } - - public Response endMaintenance(Hosts hosts) throws org.apache.thrift.TException - { - send_endMaintenance(hosts); - return recv_endMaintenance(); - } - - public void send_endMaintenance(Hosts hosts) throws org.apache.thrift.TException - { - endMaintenance_args args = new endMaintenance_args(); - args.setHosts(hosts); - sendBase("endMaintenance", args); - } - - public Response recv_endMaintenance() throws org.apache.thrift.TException - { - endMaintenance_result result = new endMaintenance_result(); - receiveBase(result, "endMaintenance"); - if (result.isSetSuccess()) { - return result.success; - } - throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "endMaintenance failed: unknown result"); - } - - public Response snapshot() throws org.apache.thrift.TException - { - send_snapshot(); - return recv_snapshot(); - } - - public void send_snapshot() throws org.apache.thrift.TException - { - snapshot_args args = new snapshot_args(); - sendBase("snapshot", args); - } - - public Response recv_snapshot() throws org.apache.thrift.TException - { - snapshot_result result = new snapshot_result(); - receiveBase(result, "snapshot"); - if (result.isSetSuccess()) { - return result.success; - } - throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "snapshot failed: unknown result"); - } - - public Response rewriteConfigs(RewriteConfigsRequest request) throws org.apache.thrift.TException - { - send_rewriteConfigs(request); - return recv_rewriteConfigs(); - } - - public void send_rewriteConfigs(RewriteConfigsRequest request) throws org.apache.thrift.TException - { - rewriteConfigs_args args = new rewriteConfigs_args(); - args.setRequest(request); - sendBase("rewriteConfigs", args); - } - - public Response recv_rewriteConfigs() throws org.apache.thrift.TException - { - rewriteConfigs_result result = new rewriteConfigs_result(); - receiveBase(result, "rewriteConfigs"); - if (result.isSetSuccess()) { - return result.success; - } - throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "rewriteConfigs failed: unknown result"); - } - - public Response triggerExplicitTaskReconciliation(ExplicitReconciliationSettings settings) throws org.apache.thrift.TException - { - send_triggerExplicitTaskReconciliation(settings); - return recv_triggerExplicitTaskReconciliation(); - } - - public void send_triggerExplicitTaskReconciliation(ExplicitReconciliationSettings settings) throws org.apache.thrift.TException - { - triggerExplicitTaskReconciliation_args args = new triggerExplicitTaskReconciliation_args(); - args.setSettings(settings); - sendBase("triggerExplicitTaskReconciliation", args); - } - - public Response recv_triggerExplicitTaskReconciliation() throws org.apache.thrift.TException - { - triggerExplicitTaskReconciliation_result result = new triggerExplicitTaskReconciliation_result(); - receiveBase(result, "triggerExplicitTaskReconciliation"); - if (result.isSetSuccess()) { - return result.success; - } - throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "triggerExplicitTaskReconciliation failed: unknown result"); - } - - public Response triggerImplicitTaskReconciliation() throws org.apache.thrift.TException - { - send_triggerImplicitTaskReconciliation(); - return recv_triggerImplicitTaskReconciliation(); - } - - public void send_triggerImplicitTaskReconciliation() throws org.apache.thrift.TException - { - triggerImplicitTaskReconciliation_args args = new triggerImplicitTaskReconciliation_args(); - sendBase("triggerImplicitTaskReconciliation", args); - } - - public Response recv_triggerImplicitTaskReconciliation() throws org.apache.thrift.TException - { - triggerImplicitTaskReconciliation_result result = new triggerImplicitTaskReconciliation_result(); - receiveBase(result, "triggerImplicitTaskReconciliation"); - if (result.isSetSuccess()) { - return result.success; - } - throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "triggerImplicitTaskReconciliation failed: unknown result"); - } - - } - public static class AsyncClient extends AuroraSchedulerManager.AsyncClient implements AsyncIface { - public static class Factory implements org.apache.thrift.async.TAsyncClientFactory<AsyncClient> { - private org.apache.thrift.async.TAsyncClientManager clientManager; - private org.apache.thrift.protocol.TProtocolFactory protocolFactory; - public Factory(org.apache.thrift.async.TAsyncClientManager clientManager, org.apache.thrift.protocol.TProtocolFactory protocolFactory) { - this.clientManager = clientManager; - this.protocolFactory = protocolFactory; - } - public AsyncClient getAsyncClient(org.apache.thrift.transport.TNonblockingTransport transport) { - return new AsyncClient(protocolFactory, clientManager, transport); - } - } - - public AsyncClient(org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.async.TAsyncClientManager clientManager, org.apache.thrift.transport.TNonblockingTransport transport) { - super(protocolFactory, clientManager, transport); - } - - public void setQuota(String ownerRole, ResourceAggregate quota, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { - checkReady(); - setQuota_call method_call = new setQuota_call(ownerRole, quota, resultHandler, this, ___protocolFactory, ___transport); - this.___currentMethod = method_call; - ___manager.call(method_call); - } - - public static class setQuota_call extends org.apache.thrift.async.TAsyncMethodCall { - private String ownerRole; - private ResourceAggregate quota; - public setQuota_call(String ownerRole, ResourceAggregate quota, 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.ownerRole = ownerRole; - this.quota = quota; - } - - public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { - prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("setQuota", org.apache.thrift.protocol.TMessageType.CALL, 0)); - setQuota_args args = new setQuota_args(); - args.setOwnerRole(ownerRole); - args.setQuota(quota); - args.write(prot); - prot.writeMessageEnd(); - } - - public Response getResult() throws 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_setQuota(); - } - } - - public void forceTaskState(String taskId, ScheduleStatus status, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { - checkReady(); - forceTaskState_call method_call = new forceTaskState_call(taskId, status, resultHandler, this, ___protocolFactory, ___transport); - this.___currentMethod = method_call; - ___manager.call(method_call); - } - - public static class forceTaskState_call extends org.apache.thrift.async.TAsyncMethodCall { - private String taskId; - private ScheduleStatus status; - public forceTaskState_call(String taskId, ScheduleStatus status, 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.taskId = taskId; - this.status = status; - } - - public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { - prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("forceTaskState", org.apache.thrift.protocol.TMessageType.CALL, 0)); - forceTaskState_args args = new forceTaskState_args(); - args.setTaskId(taskId); - args.setStatus(status); - args.write(prot); - prot.writeMessageEnd(); - } - - public Response getResult() throws 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_forceTaskState(); - } - } - - public void performBackup(org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { - checkReady(); - performBackup_call method_call = new performBackup_call(resultHandler, this, ___protocolFactory, ___transport); - this.___currentMethod = method_call; - ___manager.call(method_call); - } - - public static class performBackup_call extends org.apache.thrift.async.TAsyncMethodCall { - public performBackup_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("performBackup", org.apache.thrift.protocol.TMessageType.CALL, 0)); - performBackup_args args = new performBackup_args(); - args.write(prot); - prot.writeMessageEnd(); - } - - public Response getResult() throws 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_performBackup(); - } - } - - public void listBackups(org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { - checkReady(); - listBackups_call method_call = new listBackups_call(resultHandler, this, ___protocolFactory, ___transport); - this.___currentMethod = method_call; - ___manager.call(method_call); - } - - public static class listBackups_call extends org.apache.thrift.async.TAsyncMethodCall { - public listBackups_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("listBackups", org.apache.thrift.protocol.TMessageType.CALL, 0)); - listBackups_args args = new listBackups_args(); - args.write(prot); - prot.writeMessageEnd(); - } - - public Response getResult() throws 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_listBackups(); - } - } - - public void stageRecovery(String backupId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { - checkReady(); - stageRecovery_call method_call = new stageRecovery_call(backupId, resultHandler, this, ___protocolFactory, ___transport); - this.___currentMethod = method_call; - ___manager.call(method_call); - } - - public static class stageRecovery_call extends org.apache.thrift.async.TAsyncMethodCall { - private String backupId; - public stageRecovery_call(String backupId, 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.backupId = backupId; - } - - public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { - prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("stageRecovery", org.apache.thrift.protocol.TMessageType.CALL, 0)); - stageRecovery_args args = new stageRecovery_args(); - args.setBackupId(backupId); - args.write(prot); - prot.writeMessageEnd(); - } - - public Response getResult() throws 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_stageRecovery(); - } - } - - public void queryRecovery(TaskQuery query, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { - checkReady(); - queryRecovery_call method_call = new queryRecovery_call(query, resultHandler, this, ___protocolFactory, ___transport); - this.___currentMethod = method_call; - ___manager.call(method_call); - } - - public static class queryRecovery_call extends org.apache.thrift.async.TAsyncMethodCall { - private TaskQuery query; - public queryRecovery_call(TaskQuery query, 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.query = query; - } - - public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { - prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("queryRecovery", org.apache.thrift.protocol.TMessageType.CALL, 0)); - queryRecovery_args args = new queryRecovery_args(); - args.setQuery(query); - args.write(prot); - prot.writeMessageEnd(); - } - - public Response getResult() throws 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_queryRecovery(); - } - } - - public void deleteRecoveryTasks(TaskQuery query, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { - checkReady(); - deleteRecoveryTasks_call method_call = new deleteRecoveryTasks_call(query, resultHandler, this, ___protocolFactory, ___transport); - this.___currentMethod = method_call; - ___manager.call(method_call); - } - - public static class deleteRecoveryTasks_call extends org.apache.thrift.async.TAsyncMethodCall { - private TaskQuery query; - public deleteRecoveryTasks_call(TaskQuery query, 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.query = query; - } - - public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { - prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("deleteRecoveryTasks", org.apache.thrift.protocol.TMessageType.CALL, 0)); - deleteRecoveryTasks_args args = new deleteRecoveryTasks_args(); - args.setQuery(query); - args.write(prot); - prot.writeMessageEnd(); - } - - public Response getResult() throws 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_deleteRecoveryTasks(); - } - } - - public void commitRecovery(org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { - checkReady(); - commitRecovery_call method_call = new commitRecovery_call(resultHandler, this, ___protocolFactory, ___transport); - this.___currentMethod = method_call; - ___manager.call(method_call); - } - - public static class commitRecovery_call extends org.apache.thrift.async.TAsyncMethodCall { - public commitRecovery_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("commitRecovery", org.apache.thrift.protocol.TMessageType.CALL, 0)); - commitRecovery_args args = new commitRecovery_args(); - args.write(prot); - prot.writeMessageEnd(); - } - - public Response getResult() throws 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_commitRecovery(); - } - } - - public void unloadRecovery(org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { - checkReady(); - unloadRecovery_call method_call = new unloadRecovery_call(resultHandler, this, ___protocolFactory, ___transport); - this.___currentMethod = method_call; - ___manager.call(method_call); - } - - public static class unloadRecovery_call extends org.apache.thrift.async.TAsyncMethodCall { - public unloadRecovery_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("unloadRecovery", org.apache.thrift.protocol.TMessageType.CALL, 0)); - unloadRecovery_args args = new unloadRecovery_args(); - args.write(prot); - prot.writeMessageEnd(); - } - - public Response getResult() throws 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_unloadRecovery(); - } - } - - public void startMaintenance(Hosts hosts, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { - checkReady(); - startMaintenance_call method_call = new startMaintenance_call(hosts, resultHandler, this, ___protocolFactory, ___transport); - this.___currentMethod = method_call; - ___manager.call(method_call); - } - - public static class startMaintenance_call extends org.apache.thrift.async.TAsyncMethodCall { - private Hosts hosts; - public startMaintenance_call(Hosts hosts, 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.hosts = hosts; - } - - public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { - prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("startMaintenance", org.apache.thrift.protocol.TMessageType.CALL, 0)); - startMaintenance_args args = new startMaintenance_args(); - args.setHosts(hosts); - args.write(prot); - prot.writeMessageEnd(); - } - - public Response getResult() throws 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_startMaintenance(); - } - } - - public void drainHosts(Hosts hosts, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { - checkReady(); - drainHosts_call method_call = new drainHosts_call(hosts, resultHandler, this, ___protocolFactory, ___transport); - this.___currentMethod = method_call; - ___manager.call(method_call); - } - - public static class drainHosts_call extends org.apache.thrift.async.TAsyncMethodCall { - private Hosts hosts; - public drainHosts_call(Hosts hosts, 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.hosts = hosts; - } - - public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { - prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("drainHosts", org.apache.thrift.protocol.TMessageType.CALL, 0)); - drainHosts_args args = new drainHosts_args(); - args.setHosts(hosts); - args.write(prot); - prot.writeMessageEnd(); - } - - public Response getResult() throws 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_drainHosts(); - } - } - - public void maintenanceStatus(Hosts hosts, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { - checkReady(); - maintenanceStatus_call method_call = new maintenanceStatus_call(hosts, resultHandler, this, ___protocolFactory, ___transport); - this.___currentMethod = method_call; - ___manager.call(method_call); - } - - public static class maintenanceStatus_call extends org.apache.thrift.async.TAsyncMethodCall { - private Hosts hosts; - public maintenanceStatus_call(Hosts hosts, 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.hosts = hosts; - } - - public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { - prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("maintenanceStatus", org.apache.thrift.protocol.TMessageType.CALL, 0)); - maintenanceStatus_args args = new maintenanceStatus_args(); - args.setHosts(hosts); - args.write(prot); - prot.writeMessageEnd(); - } - - public Response getResult() throws 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_maintenanceStatus(); - } - } - - public void endMaintenance(Hosts hosts, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { - checkReady(); - endMaintenance_call method_call = new endMaintenance_call(hosts, resultHandler, this, ___protocolFactory, ___transport); - this.___currentMethod = method_call; - ___manager.call(method_call); - } - - public static class endMaintenance_call extends org.apache.thrift.async.TAsyncMethodCall { - private Hosts hosts; - public endMaintenance_call(Hosts hosts, 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.hosts = hosts; - } - - public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { - prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("endMaintenance", org.apache.thrift.protocol.TMessageType.CALL, 0)); - endMaintenance_args args = new endMaintenance_args(); - args.setHosts(hosts); - args.write(prot); - prot.writeMessageEnd(); - } - - public Response getResult() throws 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_endMaintenance(); - } - } - - public void snapshot(org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { - checkReady(); - snapshot_call method_call = new snapshot_call(resultHandler, this, ___protocolFactory, ___transport); - this.___currentMethod = method_call; - ___manager.call(method_call); - } - - public static class snapshot_call extends org.apache.thrift.async.TAsyncMethodCall { - public snapshot_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("snapshot", org.apache.thrift.protocol.TMessageType.CALL, 0)); - snapshot_args args = new snapshot_args(); - args.write(prot); - prot.writeMessageEnd(); - } - - public Response getResult() throws 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_snapshot(); - } - } - - public void rewriteConfigs(RewriteConfigsRequest request, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { - checkReady(); - rewriteConfigs_call method_call = new rewriteConfigs_call(request, resultHandler, this, ___protocolFactory, ___transport); - this.___currentMethod = method_call; - ___manager.call(method_call); - } - - public static class rewriteConfigs_call extends org.apache.thrift.async.TAsyncMethodCall { - private RewriteConfigsRequest request; - public rewriteConfigs_call(RewriteConfigsRequest request, 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.request = request; - } - - public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { - prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("rewriteConfigs", org.apache.thrift.protocol.TMessageType.CALL, 0)); - rewriteConfigs_args args = new rewriteConfigs_args(); - args.setRequest(request); - args.write(prot); - prot.writeMessageEnd(); - } - - public Response getResult() throws 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_rewriteConfigs(); - } - } - - public void triggerExplicitTaskReconciliation(ExplicitReconciliationSettings settings, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { - checkReady(); - triggerExplicitTaskReconciliation_call method_call = new triggerExplicitTaskReconciliation_call(settings, resultHandler, this, ___protocolFactory, ___transport); - this.___currentMethod = method_call; - ___manager.call(method_call); - } - - public static class triggerExplicitTaskReconciliation_call extends org.apache.thrift.async.TAsyncMethodCall { - private ExplicitReconciliationSettings settings; - public triggerExplicitTaskReconciliation_call(ExplicitReconciliationSettings settings, 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.settings = settings; - } - - public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { - prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("triggerExplicitTaskReconciliation", org.apache.thrift.protocol.TMessageType.CALL, 0)); - triggerExplicitTaskReconciliation_args args = new triggerExplicitTaskReconciliation_args(); - args.setSettings(settings); - args.write(prot); - prot.writeMessageEnd(); - } - - public Response getResult() throws 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_triggerExplicitTaskReconciliation(); - } - } - - public void triggerImplicitTaskReconciliation(org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { - checkReady(); - triggerImplicitTaskReconciliation_call method_call = new triggerImplicitTaskReconciliation_call(resultHandler, this, ___protocolFactory, ___transport); - this.___currentMethod = method_call; - ___manager.call(method_call); - } - - public static class triggerImplicitTaskReconciliation_call extends org.apache.thrift.async.TAsyncMethodCall { - public triggerImplicitTaskReconciliation_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("triggerImplicitTaskReconciliation", org.apache.thrift.protocol.TMessageType.CALL, 0)); - triggerImplicitTaskReconciliation_args args = new triggerImplicitTaskReconciliation_args(); - args.write(prot); - prot.writeMessageEnd(); - } - - public Response getResult() throws 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_triggerImplicitTaskReconciliation(); - } - } - - } - - public static class Processor<I extends Iface> extends AuroraSchedulerManager.Processor<I> implements org.apache.thrift.TProcessor { - private static final Logger LOGGER = LoggerFactory.getLogger(Processor.class.getName()); - public Processor(I iface) { - super(iface, getProcessMap(new HashMap<String, org.apache.thrift.ProcessFunction<I, ? extends org.apache.thrift.TBase>>())); - } - - protected Processor(I iface, Map<String, org.apache.thrift.ProcessFunction<I, ? extends org.apache.thrift.TBase>> processMap) { - super(iface, getProcessMap(processMap)); - } - - private static <I extends Iface> Map<String, org.apache.thrift.ProcessFunction<I, ? extends org.apache.thrift.TBase>> getProcessMap(Map<String, org.apache.thrift.ProcessFunction<I, ? extends org.apache.thrift.TBase>> processMap) { - processMap.put("setQuota", new setQuota()); - processMap.put("forceTaskState", new forceTaskState()); - processMap.put("performBackup", new performBackup()); - processMap.put("listBackups", new listBackups()); - processMap.put("stageRecovery", new stageRecovery()); - processMap.put("queryRecovery", new queryRecovery()); - processMap.put("deleteRecoveryTasks", new deleteRecoveryTasks()); - processMap.put("commitRecovery", new commitRecovery()); - processMap.put("unloadRecovery", new unloadRecovery()); - processMap.put("startMaintenance", new startMaintenance()); - processMap.put("drainHosts", new drainHosts()); - processMap.put("maintenanceStatus", new maintenanceStatus()); - processMap.put("endMaintenance", new endMaintenance()); - processMap.put("snapshot", new snapshot()); - processMap.put("rewriteConfigs", new rewriteConfigs()); - processMap.put("triggerExplicitTaskReconciliation", new triggerExplicitTaskReconciliation()); - processMap.put("triggerImplicitTaskReconciliation", new triggerImplicitTaskReconciliation()); - return processMap; - } - - public static class setQuota<I extends Iface> extends org.apache.thrift.ProcessFunction<I, setQuota_args> { - public setQuota() { - super("setQuota"); - } - - public setQuota_args getEmptyArgsInstance() { - return new setQuota_args(); - } - - protected boolean isOneway() { - return false; - } - - public setQuota_result getResult(I iface, setQuota_args args) throws org.apache.thrift.TException { - setQuota_result result = new setQuota_result(); - result.success = iface.setQuota(args.ownerRole, args.quota); - return result; - } - } - - public static class forceTaskState<I extends Iface> extends org.apache.thrift.ProcessFunction<I, forceTaskState_args> { - public forceTaskState() { - super("forceTaskState"); - } - - public forceTaskState_args getEmptyArgsInstance() { - return new forceTaskState_args(); - } - - protected boolean isOneway() { - return false; - } - - public forceTaskState_result getResult(I iface, forceTaskState_args args) throws org.apache.thrift.TException { - forceTaskState_result result = new forceTaskState_result(); - result.success = iface.forceTaskState(args.taskId, args.status); - return result; - } - } - - public static class performBackup<I extends Iface> extends org.apache.thrift.ProcessFunction<I, performBackup_args> { - public performBackup() { - super("performBackup"); - } - - public performBackup_args getEmptyArgsInstance() { - return new performBackup_args(); - } - - protected boolean isOneway() { - return false; - } - - public performBackup_result getResult(I iface, performBackup_args args) throws org.apache.thrift.TException { - performBackup_result result = new performBackup_result(); - result.success = iface.performBackup(); - return result; - } - } - - public static class listBackups<I extends Iface> extends org.apache.thrift.ProcessFunction<I, listBackups_args> { - public listBackups() { - super("listBackups"); - } - - public listBackups_args getEmptyArgsInstance() { - return new listBackups_args(); - } - - protected boolean isOneway() { - return false; - } - - public listBackups_result getResult(I iface, listBackups_args args) throws org.apache.thrift.TException { - listBackups_result result = new listBackups_result(); - result.success = iface.listBackups(); - return result; - } - } - - public static class stageRecovery<I extends Iface> extends org.apache.thrift.ProcessFunction<I, stageRecovery_args> { - public stageRecovery() { - super("stageRecovery"); - } - - public stageRecovery_args getEmptyArgsInstance() { - return new stageRecovery_args(); - } - - protected boolean isOneway() { - return false; - } - - public stageRecovery_result getResult(I iface, stageRecovery_args args) throws org.apache.thrift.TException { - stageRecovery_result result = new stageRecovery_result(); - result.success = iface.stageRecovery(args.backupId); - return result; - } - } - - public static class queryRecovery<I extends Iface> extends org.apache.thrift.ProcessFunction<I, queryRecovery_args> { - public queryRecovery() { - super("queryRecovery"); - } - - public queryRecovery_args getEmptyArgsInstance() { - return new queryRecovery_args(); - } - - protected boolean isOneway() { - return false; - } - - public queryRecovery_result getResult(I iface, queryRecovery_args args) throws org.apache.thrift.TException { - queryRecovery_result result = new queryRecovery_result(); - result.success = iface.queryRecovery(args.query); - return result; - } - } - - public static class deleteRecoveryTasks<I extends Iface> extends org.apache.thrift.ProcessFunction<I, deleteRecoveryTasks_args> { - public deleteRecoveryTasks() { - super("deleteRecoveryTasks"); - } - - public deleteRecoveryTasks_args getEmptyArgsInstance() { - return new deleteRecoveryTasks_args(); - } - - protected boolean isOneway() { - return false; - } - - public deleteRecoveryTasks_result getResult(I iface, deleteRecoveryTasks_args args) throws org.apache.thrift.TException { - deleteRecoveryTasks_result result = new deleteRecoveryTasks_result(); - result.success = iface.deleteRecoveryTasks(args.query); - return result; - } - } - - public static class commitRecovery<I extends Iface> extends org.apache.thrift.ProcessFunction<I, commitRecovery_args> { - public commitRecovery() { - super("commitRecovery"); - } - - public commitRecovery_args getEmptyArgsInstance() { - return new commitRecovery_args(); - } - - protected boolean isOneway() { - return false; - } - - public commitRecovery_result getResult(I iface, commitRecovery_args args) throws org.apache.thrift.TException { - commitRecovery_result result = new commitRecovery_result(); - result.success = iface.commitRecovery(); - return result; - } - } - - public static class unloadRecovery<I extends Iface> extends org.apache.thrift.ProcessFunction<I, unloadRecovery_args> { - public unloadRecovery() { - super("unloadRecovery"); - } - - public unloadRecovery_args getEmptyArgsInstance() { - return new unloadRecovery_args(); - } - - protected boolean isOneway() { - return false; - } - - public unloadRecovery_result getResult(I iface, unloadRecovery_args args) throws org.apache.thrift.TException { - unloadRecovery_result result = new unloadRecovery_result(); - result.success = iface.unloadRecovery(); - return result; - } - } - - public static class startMaintenance<I extends Iface> extends org.apache.thrift.ProcessFunction<I, startMaintenance_args> { - public startMaintenance() { - super("startMaintenance"); - } - - public startMaintenance_args getEmptyArgsInstance() { - return new startMaintenance_args(); - } - - protected boolean isOneway() { - return false; - } - - public startMaintenance_result getResult(I iface, startMaintenance_args args) throws org.apache.thrift.TException { - startMaintenance_result result = new startMaintenance_result(); - result.success = iface.startMaintenance(args.hosts); - return result; - } - } - - public static class drainHosts<I extends Iface> extends org.apache.thrift.ProcessFunction<I, drainHosts_args> { - public drainHosts() { - super("drainHosts"); - } - - public drainHosts_args getEmptyArgsInstance() { - return new drainHosts_args(); - } - - protected boolean isOneway() { - return false; - } - - public drainHosts_result getResult(I iface, drainHosts_args args) throws org.apache.thrift.TException { - drainHosts_result result = new drainHosts_result(); - result.success = iface.drainHosts(args.hosts); - return result; - } - } - - public static class maintenanceStatus<I extends Iface> extends org.apache.thrift.ProcessFunction<I, maintenanceStatus_args> { - public maintenanceStatus() { - super("maintenanceStatus"); - } - - public maintenanceStatus_args getEmptyArgsInstance() { - return new maintenanceStatus_args(); - } - - protected boolean isOneway() { - return false; - } - - public maintenanceStatus_result getResult(I iface, maintenanceStatus_args args) throws org.apache.thrift.TException { - maintenanceStatus_result result = new maintenanceStatus_result(); - result.success = iface.maintenanceStatus(args.hosts); - return result; - } - } - - public static class endMaintenance<I extends Iface> extends org.apache.thrift.ProcessFunction<I, endMaintenance_args> { - public endMaintenance() { - super("endMaintenance"); - } - - public endMaintenance_args getEmptyArgsInstance() { - return new endMaintenance_args(); - } - - protected boolean isOneway() { - return false; - } - - public endMaintenance_result getResult(I iface, endMaintenance_args args) throws org.apache.thrift.TException { - endMaintenance_result result = new endMaintenance_result(); - result.success = iface.endMaintenance(args.hosts); - return result; - } - } - - public static class snapshot<I extends Iface> extends org.apache.thrift.ProcessFunction<I, snapshot_args> { - public snapshot() { - super("snapshot"); - } - - public snapshot_args getEmptyArgsInstance() { - return new snapshot_args(); - } - - protected boolean isOneway() { - return false; - } - - public snapshot_result getResult(I iface, snapshot_args args) throws org.apache.thrift.TException { - snapshot_result result = new snapshot_result(); - result.success = iface.snapshot(); - return result; - } - } - - public static class rewriteConfigs<I extends Iface> extends org.apache.thrift.ProcessFunction<I, rewriteConfigs_args> { - public rewriteConfigs() { - super("rewriteConfigs"); - } - - public rewriteConfigs_args getEmptyArgsInstance() { - return new rewriteConfigs_args(); - } - - protected boolean isOneway() { - return false; - } - - public rewriteConfigs_result getResult(I iface, rewriteConfigs_args args) throws org.apache.thrift.TException { - rewriteConfigs_result result = new rewriteConfigs_result(); - result.success = iface.rewriteConfigs(args.request); - return result; - } - } - - public static class triggerExplicitTaskReconciliation<I extends Iface> extends org.apache.thrift.ProcessFunction<I, triggerExplicitTaskReconciliation_args> { - public triggerExplicitTaskReconciliation() { - super("triggerExplicitTaskReconciliation"); - } - - public triggerExplicitTaskReconciliation_args getEmptyArgsInstance() { - return new triggerExplicitTaskReconciliation_args(); - } - - protected boolean isOneway() { - return false; - } - - public triggerExplicitTaskReconciliation_result getResult(I iface, triggerExplicitTaskReconciliation_args args) throws org.apache.thrift.TException { - triggerExplicitTaskReconciliation_result result = new triggerExplicitTaskReconciliation_result(); - result.success = iface.triggerExplicitTaskReconciliation(args.settings); - return result; - } - } - - public static class triggerImplicitTaskReconciliation<I extends Iface> extends org.apache.thrift.ProcessFunction<I, triggerImplicitTaskReconciliation_args> { - public triggerImplicitTaskReconciliation() { - super("triggerImplicitTaskReconciliation"); - } - - public triggerImplicitTaskReconciliation_args getEmptyArgsInstance() { - return new triggerImplicitTaskReconciliation_args(); - } - - protected boolean isOneway() { - return false; - } - - public triggerImplicitTaskReconciliation_result getResult(I iface, triggerImplicitTaskReconciliation_args args) throws org.apache.thrift.TException { - triggerImplicitTaskReconciliation_result result = new triggerImplicitTaskReconciliation_result(); - result.success = iface.triggerImplicitTaskReconciliation(); - return result; - } - } - - } - - public static class AsyncProcessor<I extends AsyncIface> extends AuroraSchedulerManager.AsyncProcessor<I> { - private static final Logger LOGGER = LoggerFactory.getLogger(AsyncProcessor.class.getName()); - public AsyncProcessor(I iface) { - super(iface, getProcessMap(new HashMap<String, org.apache.thrift.AsyncProcessFunction<I, ? extends org.apache.thrift.TBase, ?>>())); - } - - protected AsyncProcessor(I iface, Map<String, org.apache.thrift.AsyncProcessFunction<I, ? extends org.apache.thrift.TBase, ?>> processMap) { - super(iface, getProcessMap(processMap)); - } - - private static <I extends AsyncIface> Map<String, org.apache.thrift.AsyncProcessFunction<I, ? extends org.apache.thrift.TBase,?>> getProcessMap(Map<String, org.apache.thrift.AsyncProcessFunction<I, ? extends org.apache.thrift.TBase, ?>> processMap) { - processMap.put("setQuota", new setQuota()); - processMap.put("forceTaskState", new forceTaskState()); - processMap.put("performBackup", new performBackup()); - processMap.put("listBackups", new listBackups()); - processMap.put("stageRecovery", new stageRecovery()); - processMap.put("queryRecovery", new queryRecovery()); - processMap.put("deleteRecoveryTasks", new deleteRecoveryTasks()); - processMap.put("commitRecovery", new commitRecovery()); - processMap.put("unloadRecovery", new unloadRecovery()); - processMap.put("startMaintenance", new startMaintenance()); - processMap.put("drainHosts", new drainHosts()); - processMap.put("maintenanceStatus", new maintenanceStatus()); - processMap.put("endMaintenance", new endMaintenance()); - processMap.put("snapshot", new snapshot()); - processMap.put("rewriteConfigs", new rewriteConfigs()); - processMap.put("triggerExplicitTaskReconciliation", new triggerExplicitTaskReconciliation()); - processMap.put("triggerImplicitTaskReconciliation", new triggerImplicitTaskReconciliation()); - return processMap; - } - - public static class setQuota<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, setQuota_args, Response> { - public setQuota() { - super("setQuota"); - } - - public setQuota_args getEmptyArgsInstance() { - return new setQuota_args(); - } - - public AsyncMethodCallback<Response> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { - final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback<Response>() { - public void onComplete(Response o) { - setQuota_result result = new setQuota_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; - setQuota_result result = new setQuota_result(); - { - 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, setQuota_args args, org.apache.thrift.async.AsyncMethodCallback<Response> resultHandler) throws TException { - iface.setQuota(args.ownerRole, args.quota,resultHandler); - } - } - - public static class forceTaskState<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, forceTaskState_args, Response> { - public forceTaskState() { - super("forceTaskState"); - } - - public forceTaskState_args getEmptyArgsInstance() { - return new forceTaskState_args(); - } - - public AsyncMethodCallback<Response> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { - final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback<Response>() { - public void onComplete(Response o) { - forceTaskState_result result = new forceTaskState_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; - forceTaskState_result result = new forceTaskState_result(); - { - 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, forceTaskState_args args, org.apache.thrift.async.AsyncMethodCallback<Response> resultHandler) throws TException { - iface.forceTaskState(args.taskId, args.status,resultHandler); - } - } - - public static class performBackup<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, performBackup_args, Response> { - public performBackup() { - super("performBackup"); - } - - public performBackup_args getEmptyArgsInstance() { - return new performBackup_args(); - } - - public AsyncMethodCallback<Response> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { - final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback<Response>() { - public void onComplete(Response o) { - performBackup_result result = new performBackup_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; - performBackup_result result = new performBackup_result(); - { - 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, performBackup_args args, org.apache.thrift.async.AsyncMethodCallback<Response> resultHandler) throws TException { - iface.performBackup(resultHandler); - } - } - - public static class listBackups<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, listBackups_args, Response> { - public listBackups() { - super("listBackups"); - } - - public listBackups_args getEmptyArgsInstance() { - return new listBackups_args(); - } - - public AsyncMethodCallback<Response> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { - final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback<Response>() { - public void onComplete(Response o) { - listBackups_result result = new listBackups_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; - listBackups_result result = new listBackups_result(); - { - 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, listBackups_args args, org.apache.thrift.async.AsyncMethodCallback<Response> resultHandler) throws TException { - iface.listBackups(resultHandler); - } - } - - public static class stageRecovery<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, stageRecovery_args, Response> { - public stageRecovery() { - super("stageRecovery"); - } - - public stageRecovery_args getEmptyArgsInstance() { - return new stageRecovery_args(); - } - - public AsyncMethodCallback<Response> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { - final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback<Response>() { - public void onComplete(Response o) { - stageRecovery_result result = new stageRecovery_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; - stageRecovery_result result = new stageRecovery_result(); - { - 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, stageRecovery_args args, org.apache.thrift.async.AsyncMethodCallback<Response> resultHandler) throws TException { - iface.stageRecovery(args.backupId,resultHandler); - } - } - - public static class queryRecovery<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, queryRecovery_args, Response> { - public queryRecovery() { - super("queryRecovery"); - } - - public queryRecovery_args getEmptyArgsInstance() { - return new queryRecovery_args(); - } - - public AsyncMethodCallback<Response> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { - final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback<Response>() { - public void onComplete(Response o) { - queryRecovery_result result = new queryRecovery_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; - queryRecovery_result result = new queryRecovery_result(); - { - 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, queryRecovery_args args, org.apache.thrift.async.AsyncMethodCallback<Response> resultHandler) throws TException { - iface.queryRecovery(args.query,resultHandler); - } - } - - public static class deleteRecoveryTasks<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, deleteRecoveryTasks_args, Response> { - public deleteRecoveryTasks() { - super("deleteRecoveryTasks"); - } - - public deleteRecoveryTasks_args getEmptyArgsInstance() { - return new deleteRecoveryTasks_args(); - } - - public AsyncMethodCallback<Response> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { - final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback<Response>() { - public void onComplete(Response o) { - deleteRecoveryTasks_result result = new deleteRecoveryTasks_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; - deleteRecoveryTasks_result result = new deleteRecoveryTasks_result(); - { - 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, deleteRecoveryTasks_args args, org.apache.thrift.async.AsyncMethodCallback<Response> resultHandler) throws TException { - if
<TRUNCATED>
