Return-Path: X-Original-To: archive-asf-public-internal@cust-asf2.ponee.io Delivered-To: archive-asf-public-internal@cust-asf2.ponee.io Received: from cust-asf.ponee.io (cust-asf.ponee.io [163.172.22.183]) by cust-asf2.ponee.io (Postfix) with ESMTP id 70887200B8F for ; Fri, 16 Sep 2016 00:33:00 +0200 (CEST) Received: by cust-asf.ponee.io (Postfix) id 6F05E160AC6; Thu, 15 Sep 2016 22:33:00 +0000 (UTC) Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by cust-asf.ponee.io (Postfix) with SMTP id C1382160AD7 for ; Fri, 16 Sep 2016 00:32:57 +0200 (CEST) Received: (qmail 99808 invoked by uid 500); 15 Sep 2016 22:32:56 -0000 Mailing-List: contact commits-help@accumulo.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@accumulo.apache.org Delivered-To: mailing list commits@accumulo.apache.org Received: (qmail 99787 invoked by uid 99); 15 Sep 2016 22:32:56 -0000 Received: from git1-us-west.apache.org (HELO git1-us-west.apache.org) (140.211.11.23) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 15 Sep 2016 22:32:56 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id B5676E08B5; Thu, 15 Sep 2016 22:32:56 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: elserj@apache.org To: commits@accumulo.apache.org Date: Thu, 15 Sep 2016 22:32:57 -0000 Message-Id: In-Reply-To: References: X-Mailer: ASF-Git Admin Mailer Subject: [2/3] accumulo git commit: ACCUMULO-4456 Add a Thrift exception to handle when a service is not the active instance archived-at: Thu, 15 Sep 2016 22:33:00 -0000 http://git-wip-us.apache.org/repos/asf/accumulo/blob/780045ce/core/src/main/java/org/apache/accumulo/core/master/thrift/MasterClientService.java ---------------------------------------------------------------------- diff --git a/core/src/main/java/org/apache/accumulo/core/master/thrift/MasterClientService.java b/core/src/main/java/org/apache/accumulo/core/master/thrift/MasterClientService.java index 99bebe0..a9dfe2d 100644 --- a/core/src/main/java/org/apache/accumulo/core/master/thrift/MasterClientService.java +++ b/core/src/main/java/org/apache/accumulo/core/master/thrift/MasterClientService.java @@ -55,41 +55,41 @@ public class MasterClientService { public interface Iface extends FateService.Iface { - public long initiateFlush(org.apache.accumulo.core.trace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.TCredentials credentials, String tableName) throws org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException, org.apache.accumulo.core.client.impl.thrift.ThriftTableOperationException, org.apache.thrift.TException; + public long initiateFlush(org.apache.accumulo.core.trace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.TCredentials credentials, String tableName) throws org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException, org.apache.accumulo.core.client.impl.thrift.ThriftTableOperationException, org.apache.accumulo.core.client.impl.thrift.ThriftNotActiveServiceException, org.apache.thrift.TException; - public void waitForFlush(org.apache.accumulo.core.trace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.TCredentials credentials, String tableName, ByteBuffer startRow, ByteBuffer endRow, long flushID, long maxLoops) throws org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException, org.apache.accumulo.core.client.impl.thrift.ThriftTableOperationException, org.apache.thrift.TException; + public void waitForFlush(org.apache.accumulo.core.trace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.TCredentials credentials, String tableName, ByteBuffer startRow, ByteBuffer endRow, long flushID, long maxLoops) throws org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException, org.apache.accumulo.core.client.impl.thrift.ThriftTableOperationException, org.apache.accumulo.core.client.impl.thrift.ThriftNotActiveServiceException, org.apache.thrift.TException; - public void setTableProperty(org.apache.accumulo.core.trace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.TCredentials credentials, String tableName, String property, String value) throws org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException, org.apache.accumulo.core.client.impl.thrift.ThriftTableOperationException, org.apache.thrift.TException; + public void setTableProperty(org.apache.accumulo.core.trace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.TCredentials credentials, String tableName, String property, String value) throws org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException, org.apache.accumulo.core.client.impl.thrift.ThriftTableOperationException, org.apache.accumulo.core.client.impl.thrift.ThriftNotActiveServiceException, org.apache.thrift.TException; - public void removeTableProperty(org.apache.accumulo.core.trace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.TCredentials credentials, String tableName, String property) throws org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException, org.apache.accumulo.core.client.impl.thrift.ThriftTableOperationException, org.apache.thrift.TException; + public void removeTableProperty(org.apache.accumulo.core.trace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.TCredentials credentials, String tableName, String property) throws org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException, org.apache.accumulo.core.client.impl.thrift.ThriftTableOperationException, org.apache.accumulo.core.client.impl.thrift.ThriftNotActiveServiceException, org.apache.thrift.TException; - public void setNamespaceProperty(org.apache.accumulo.core.trace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.TCredentials credentials, String ns, String property, String value) throws org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException, org.apache.accumulo.core.client.impl.thrift.ThriftTableOperationException, org.apache.thrift.TException; + public void setNamespaceProperty(org.apache.accumulo.core.trace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.TCredentials credentials, String ns, String property, String value) throws org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException, org.apache.accumulo.core.client.impl.thrift.ThriftTableOperationException, org.apache.accumulo.core.client.impl.thrift.ThriftNotActiveServiceException, org.apache.thrift.TException; - public void removeNamespaceProperty(org.apache.accumulo.core.trace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.TCredentials credentials, String ns, String property) throws org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException, org.apache.accumulo.core.client.impl.thrift.ThriftTableOperationException, org.apache.thrift.TException; + public void removeNamespaceProperty(org.apache.accumulo.core.trace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.TCredentials credentials, String ns, String property) throws org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException, org.apache.accumulo.core.client.impl.thrift.ThriftTableOperationException, org.apache.accumulo.core.client.impl.thrift.ThriftNotActiveServiceException, org.apache.thrift.TException; - public void setMasterGoalState(org.apache.accumulo.core.trace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.TCredentials credentials, MasterGoalState state) throws org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException, org.apache.thrift.TException; + public void setMasterGoalState(org.apache.accumulo.core.trace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.TCredentials credentials, MasterGoalState state) throws org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException, org.apache.accumulo.core.client.impl.thrift.ThriftNotActiveServiceException, org.apache.thrift.TException; - public void shutdown(org.apache.accumulo.core.trace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.TCredentials credentials, boolean stopTabletServers) throws org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException, org.apache.thrift.TException; + public void shutdown(org.apache.accumulo.core.trace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.TCredentials credentials, boolean stopTabletServers) throws org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException, org.apache.accumulo.core.client.impl.thrift.ThriftNotActiveServiceException, org.apache.thrift.TException; - public void shutdownTabletServer(org.apache.accumulo.core.trace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.TCredentials credentials, String tabletServer, boolean force) throws org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException, org.apache.thrift.TException; + public void shutdownTabletServer(org.apache.accumulo.core.trace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.TCredentials credentials, String tabletServer, boolean force) throws org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException, org.apache.accumulo.core.client.impl.thrift.ThriftNotActiveServiceException, org.apache.thrift.TException; - public void setSystemProperty(org.apache.accumulo.core.trace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.TCredentials credentials, String property, String value) throws org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException, org.apache.thrift.TException; + public void setSystemProperty(org.apache.accumulo.core.trace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.TCredentials credentials, String property, String value) throws org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException, org.apache.accumulo.core.client.impl.thrift.ThriftNotActiveServiceException, org.apache.thrift.TException; - public void removeSystemProperty(org.apache.accumulo.core.trace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.TCredentials credentials, String property) throws org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException, org.apache.thrift.TException; + public void removeSystemProperty(org.apache.accumulo.core.trace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.TCredentials credentials, String property) throws org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException, org.apache.accumulo.core.client.impl.thrift.ThriftNotActiveServiceException, org.apache.thrift.TException; - public MasterMonitorInfo getMasterStats(org.apache.accumulo.core.trace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.TCredentials credentials) throws org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException, org.apache.thrift.TException; + public MasterMonitorInfo getMasterStats(org.apache.accumulo.core.trace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.TCredentials credentials) throws org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException, org.apache.accumulo.core.client.impl.thrift.ThriftNotActiveServiceException, org.apache.thrift.TException; - public void waitForBalance(org.apache.accumulo.core.trace.thrift.TInfo tinfo) throws org.apache.thrift.TException; + public void waitForBalance(org.apache.accumulo.core.trace.thrift.TInfo tinfo) throws org.apache.accumulo.core.client.impl.thrift.ThriftNotActiveServiceException, org.apache.thrift.TException; public void reportSplitExtent(org.apache.accumulo.core.trace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.TCredentials credentials, String serverName, TabletSplit split) throws org.apache.thrift.TException; public void reportTabletStatus(org.apache.accumulo.core.trace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.TCredentials credentials, String serverName, TabletLoadState status, org.apache.accumulo.core.data.thrift.TKeyExtent tablet) throws org.apache.thrift.TException; - public List getActiveTservers(org.apache.accumulo.core.trace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.TCredentials credentials) throws org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException, org.apache.thrift.TException; + public List getActiveTservers(org.apache.accumulo.core.trace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.TCredentials credentials) throws org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException, org.apache.accumulo.core.client.impl.thrift.ThriftNotActiveServiceException, org.apache.thrift.TException; - public org.apache.accumulo.core.security.thrift.TDelegationToken getDelegationToken(org.apache.accumulo.core.trace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.TCredentials credentials, org.apache.accumulo.core.security.thrift.TDelegationTokenConfig cfg) throws org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException, org.apache.thrift.TException; + public org.apache.accumulo.core.security.thrift.TDelegationToken getDelegationToken(org.apache.accumulo.core.trace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.TCredentials credentials, org.apache.accumulo.core.security.thrift.TDelegationTokenConfig cfg) throws org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException, org.apache.accumulo.core.client.impl.thrift.ThriftNotActiveServiceException, org.apache.thrift.TException; - public boolean drainReplicationTable(org.apache.accumulo.core.trace.thrift.TInfo tfino, org.apache.accumulo.core.security.thrift.TCredentials credentials, String tableName, Set logsToWatch) throws org.apache.thrift.TException; + public boolean drainReplicationTable(org.apache.accumulo.core.trace.thrift.TInfo tfino, org.apache.accumulo.core.security.thrift.TCredentials credentials, String tableName, Set logsToWatch) throws org.apache.accumulo.core.client.impl.thrift.ThriftNotActiveServiceException, org.apache.thrift.TException; } @@ -153,7 +153,7 @@ public class MasterClientService { super(iprot, oprot); } - public long initiateFlush(org.apache.accumulo.core.trace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.TCredentials credentials, String tableName) throws org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException, org.apache.accumulo.core.client.impl.thrift.ThriftTableOperationException, org.apache.thrift.TException + public long initiateFlush(org.apache.accumulo.core.trace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.TCredentials credentials, String tableName) throws org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException, org.apache.accumulo.core.client.impl.thrift.ThriftTableOperationException, org.apache.accumulo.core.client.impl.thrift.ThriftNotActiveServiceException, org.apache.thrift.TException { send_initiateFlush(tinfo, credentials, tableName); return recv_initiateFlush(); @@ -168,7 +168,7 @@ public class MasterClientService { sendBase("initiateFlush", args); } - public long recv_initiateFlush() throws org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException, org.apache.accumulo.core.client.impl.thrift.ThriftTableOperationException, org.apache.thrift.TException + public long recv_initiateFlush() throws org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException, org.apache.accumulo.core.client.impl.thrift.ThriftTableOperationException, org.apache.accumulo.core.client.impl.thrift.ThriftNotActiveServiceException, org.apache.thrift.TException { initiateFlush_result result = new initiateFlush_result(); receiveBase(result, "initiateFlush"); @@ -181,10 +181,13 @@ public class MasterClientService { if (result.tope != null) { throw result.tope; } + if (result.tnase != null) { + throw result.tnase; + } throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "initiateFlush failed: unknown result"); } - public void waitForFlush(org.apache.accumulo.core.trace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.TCredentials credentials, String tableName, ByteBuffer startRow, ByteBuffer endRow, long flushID, long maxLoops) throws org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException, org.apache.accumulo.core.client.impl.thrift.ThriftTableOperationException, org.apache.thrift.TException + public void waitForFlush(org.apache.accumulo.core.trace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.TCredentials credentials, String tableName, ByteBuffer startRow, ByteBuffer endRow, long flushID, long maxLoops) throws org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException, org.apache.accumulo.core.client.impl.thrift.ThriftTableOperationException, org.apache.accumulo.core.client.impl.thrift.ThriftNotActiveServiceException, org.apache.thrift.TException { send_waitForFlush(tinfo, credentials, tableName, startRow, endRow, flushID, maxLoops); recv_waitForFlush(); @@ -203,7 +206,7 @@ public class MasterClientService { sendBase("waitForFlush", args); } - public void recv_waitForFlush() throws org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException, org.apache.accumulo.core.client.impl.thrift.ThriftTableOperationException, org.apache.thrift.TException + public void recv_waitForFlush() throws org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException, org.apache.accumulo.core.client.impl.thrift.ThriftTableOperationException, org.apache.accumulo.core.client.impl.thrift.ThriftNotActiveServiceException, org.apache.thrift.TException { waitForFlush_result result = new waitForFlush_result(); receiveBase(result, "waitForFlush"); @@ -213,10 +216,13 @@ public class MasterClientService { if (result.tope != null) { throw result.tope; } + if (result.tnase != null) { + throw result.tnase; + } return; } - public void setTableProperty(org.apache.accumulo.core.trace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.TCredentials credentials, String tableName, String property, String value) throws org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException, org.apache.accumulo.core.client.impl.thrift.ThriftTableOperationException, org.apache.thrift.TException + public void setTableProperty(org.apache.accumulo.core.trace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.TCredentials credentials, String tableName, String property, String value) throws org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException, org.apache.accumulo.core.client.impl.thrift.ThriftTableOperationException, org.apache.accumulo.core.client.impl.thrift.ThriftNotActiveServiceException, org.apache.thrift.TException { send_setTableProperty(tinfo, credentials, tableName, property, value); recv_setTableProperty(); @@ -233,7 +239,7 @@ public class MasterClientService { sendBase("setTableProperty", args); } - public void recv_setTableProperty() throws org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException, org.apache.accumulo.core.client.impl.thrift.ThriftTableOperationException, org.apache.thrift.TException + public void recv_setTableProperty() throws org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException, org.apache.accumulo.core.client.impl.thrift.ThriftTableOperationException, org.apache.accumulo.core.client.impl.thrift.ThriftNotActiveServiceException, org.apache.thrift.TException { setTableProperty_result result = new setTableProperty_result(); receiveBase(result, "setTableProperty"); @@ -243,10 +249,13 @@ public class MasterClientService { if (result.tope != null) { throw result.tope; } + if (result.tnase != null) { + throw result.tnase; + } return; } - public void removeTableProperty(org.apache.accumulo.core.trace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.TCredentials credentials, String tableName, String property) throws org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException, org.apache.accumulo.core.client.impl.thrift.ThriftTableOperationException, org.apache.thrift.TException + public void removeTableProperty(org.apache.accumulo.core.trace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.TCredentials credentials, String tableName, String property) throws org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException, org.apache.accumulo.core.client.impl.thrift.ThriftTableOperationException, org.apache.accumulo.core.client.impl.thrift.ThriftNotActiveServiceException, org.apache.thrift.TException { send_removeTableProperty(tinfo, credentials, tableName, property); recv_removeTableProperty(); @@ -262,7 +271,7 @@ public class MasterClientService { sendBase("removeTableProperty", args); } - public void recv_removeTableProperty() throws org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException, org.apache.accumulo.core.client.impl.thrift.ThriftTableOperationException, org.apache.thrift.TException + public void recv_removeTableProperty() throws org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException, org.apache.accumulo.core.client.impl.thrift.ThriftTableOperationException, org.apache.accumulo.core.client.impl.thrift.ThriftNotActiveServiceException, org.apache.thrift.TException { removeTableProperty_result result = new removeTableProperty_result(); receiveBase(result, "removeTableProperty"); @@ -272,10 +281,13 @@ public class MasterClientService { if (result.tope != null) { throw result.tope; } + if (result.tnase != null) { + throw result.tnase; + } return; } - public void setNamespaceProperty(org.apache.accumulo.core.trace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.TCredentials credentials, String ns, String property, String value) throws org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException, org.apache.accumulo.core.client.impl.thrift.ThriftTableOperationException, org.apache.thrift.TException + public void setNamespaceProperty(org.apache.accumulo.core.trace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.TCredentials credentials, String ns, String property, String value) throws org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException, org.apache.accumulo.core.client.impl.thrift.ThriftTableOperationException, org.apache.accumulo.core.client.impl.thrift.ThriftNotActiveServiceException, org.apache.thrift.TException { send_setNamespaceProperty(tinfo, credentials, ns, property, value); recv_setNamespaceProperty(); @@ -292,7 +304,7 @@ public class MasterClientService { sendBase("setNamespaceProperty", args); } - public void recv_setNamespaceProperty() throws org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException, org.apache.accumulo.core.client.impl.thrift.ThriftTableOperationException, org.apache.thrift.TException + public void recv_setNamespaceProperty() throws org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException, org.apache.accumulo.core.client.impl.thrift.ThriftTableOperationException, org.apache.accumulo.core.client.impl.thrift.ThriftNotActiveServiceException, org.apache.thrift.TException { setNamespaceProperty_result result = new setNamespaceProperty_result(); receiveBase(result, "setNamespaceProperty"); @@ -302,10 +314,13 @@ public class MasterClientService { if (result.tope != null) { throw result.tope; } + if (result.tnase != null) { + throw result.tnase; + } return; } - public void removeNamespaceProperty(org.apache.accumulo.core.trace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.TCredentials credentials, String ns, String property) throws org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException, org.apache.accumulo.core.client.impl.thrift.ThriftTableOperationException, org.apache.thrift.TException + public void removeNamespaceProperty(org.apache.accumulo.core.trace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.TCredentials credentials, String ns, String property) throws org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException, org.apache.accumulo.core.client.impl.thrift.ThriftTableOperationException, org.apache.accumulo.core.client.impl.thrift.ThriftNotActiveServiceException, org.apache.thrift.TException { send_removeNamespaceProperty(tinfo, credentials, ns, property); recv_removeNamespaceProperty(); @@ -321,7 +336,7 @@ public class MasterClientService { sendBase("removeNamespaceProperty", args); } - public void recv_removeNamespaceProperty() throws org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException, org.apache.accumulo.core.client.impl.thrift.ThriftTableOperationException, org.apache.thrift.TException + public void recv_removeNamespaceProperty() throws org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException, org.apache.accumulo.core.client.impl.thrift.ThriftTableOperationException, org.apache.accumulo.core.client.impl.thrift.ThriftNotActiveServiceException, org.apache.thrift.TException { removeNamespaceProperty_result result = new removeNamespaceProperty_result(); receiveBase(result, "removeNamespaceProperty"); @@ -331,10 +346,13 @@ public class MasterClientService { if (result.tope != null) { throw result.tope; } + if (result.tnase != null) { + throw result.tnase; + } return; } - public void setMasterGoalState(org.apache.accumulo.core.trace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.TCredentials credentials, MasterGoalState state) throws org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException, org.apache.thrift.TException + public void setMasterGoalState(org.apache.accumulo.core.trace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.TCredentials credentials, MasterGoalState state) throws org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException, org.apache.accumulo.core.client.impl.thrift.ThriftNotActiveServiceException, org.apache.thrift.TException { send_setMasterGoalState(tinfo, credentials, state); recv_setMasterGoalState(); @@ -349,17 +367,20 @@ public class MasterClientService { sendBase("setMasterGoalState", args); } - public void recv_setMasterGoalState() throws org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException, org.apache.thrift.TException + public void recv_setMasterGoalState() throws org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException, org.apache.accumulo.core.client.impl.thrift.ThriftNotActiveServiceException, org.apache.thrift.TException { setMasterGoalState_result result = new setMasterGoalState_result(); receiveBase(result, "setMasterGoalState"); if (result.sec != null) { throw result.sec; } + if (result.tnase != null) { + throw result.tnase; + } return; } - public void shutdown(org.apache.accumulo.core.trace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.TCredentials credentials, boolean stopTabletServers) throws org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException, org.apache.thrift.TException + public void shutdown(org.apache.accumulo.core.trace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.TCredentials credentials, boolean stopTabletServers) throws org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException, org.apache.accumulo.core.client.impl.thrift.ThriftNotActiveServiceException, org.apache.thrift.TException { send_shutdown(tinfo, credentials, stopTabletServers); recv_shutdown(); @@ -374,17 +395,20 @@ public class MasterClientService { sendBase("shutdown", args); } - public void recv_shutdown() throws org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException, org.apache.thrift.TException + public void recv_shutdown() throws org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException, org.apache.accumulo.core.client.impl.thrift.ThriftNotActiveServiceException, org.apache.thrift.TException { shutdown_result result = new shutdown_result(); receiveBase(result, "shutdown"); if (result.sec != null) { throw result.sec; } + if (result.tnase != null) { + throw result.tnase; + } return; } - public void shutdownTabletServer(org.apache.accumulo.core.trace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.TCredentials credentials, String tabletServer, boolean force) throws org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException, org.apache.thrift.TException + public void shutdownTabletServer(org.apache.accumulo.core.trace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.TCredentials credentials, String tabletServer, boolean force) throws org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException, org.apache.accumulo.core.client.impl.thrift.ThriftNotActiveServiceException, org.apache.thrift.TException { send_shutdownTabletServer(tinfo, credentials, tabletServer, force); recv_shutdownTabletServer(); @@ -400,17 +424,20 @@ public class MasterClientService { sendBase("shutdownTabletServer", args); } - public void recv_shutdownTabletServer() throws org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException, org.apache.thrift.TException + public void recv_shutdownTabletServer() throws org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException, org.apache.accumulo.core.client.impl.thrift.ThriftNotActiveServiceException, org.apache.thrift.TException { shutdownTabletServer_result result = new shutdownTabletServer_result(); receiveBase(result, "shutdownTabletServer"); if (result.sec != null) { throw result.sec; } + if (result.tnase != null) { + throw result.tnase; + } return; } - public void setSystemProperty(org.apache.accumulo.core.trace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.TCredentials credentials, String property, String value) throws org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException, org.apache.thrift.TException + public void setSystemProperty(org.apache.accumulo.core.trace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.TCredentials credentials, String property, String value) throws org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException, org.apache.accumulo.core.client.impl.thrift.ThriftNotActiveServiceException, org.apache.thrift.TException { send_setSystemProperty(tinfo, credentials, property, value); recv_setSystemProperty(); @@ -426,17 +453,20 @@ public class MasterClientService { sendBase("setSystemProperty", args); } - public void recv_setSystemProperty() throws org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException, org.apache.thrift.TException + public void recv_setSystemProperty() throws org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException, org.apache.accumulo.core.client.impl.thrift.ThriftNotActiveServiceException, org.apache.thrift.TException { setSystemProperty_result result = new setSystemProperty_result(); receiveBase(result, "setSystemProperty"); if (result.sec != null) { throw result.sec; } + if (result.tnase != null) { + throw result.tnase; + } return; } - public void removeSystemProperty(org.apache.accumulo.core.trace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.TCredentials credentials, String property) throws org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException, org.apache.thrift.TException + public void removeSystemProperty(org.apache.accumulo.core.trace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.TCredentials credentials, String property) throws org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException, org.apache.accumulo.core.client.impl.thrift.ThriftNotActiveServiceException, org.apache.thrift.TException { send_removeSystemProperty(tinfo, credentials, property); recv_removeSystemProperty(); @@ -451,17 +481,20 @@ public class MasterClientService { sendBase("removeSystemProperty", args); } - public void recv_removeSystemProperty() throws org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException, org.apache.thrift.TException + public void recv_removeSystemProperty() throws org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException, org.apache.accumulo.core.client.impl.thrift.ThriftNotActiveServiceException, org.apache.thrift.TException { removeSystemProperty_result result = new removeSystemProperty_result(); receiveBase(result, "removeSystemProperty"); if (result.sec != null) { throw result.sec; } + if (result.tnase != null) { + throw result.tnase; + } return; } - public MasterMonitorInfo getMasterStats(org.apache.accumulo.core.trace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.TCredentials credentials) throws org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException, org.apache.thrift.TException + public MasterMonitorInfo getMasterStats(org.apache.accumulo.core.trace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.TCredentials credentials) throws org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException, org.apache.accumulo.core.client.impl.thrift.ThriftNotActiveServiceException, org.apache.thrift.TException { send_getMasterStats(tinfo, credentials); return recv_getMasterStats(); @@ -475,7 +508,7 @@ public class MasterClientService { sendBase("getMasterStats", args); } - public MasterMonitorInfo recv_getMasterStats() throws org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException, org.apache.thrift.TException + public MasterMonitorInfo recv_getMasterStats() throws org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException, org.apache.accumulo.core.client.impl.thrift.ThriftNotActiveServiceException, org.apache.thrift.TException { getMasterStats_result result = new getMasterStats_result(); receiveBase(result, "getMasterStats"); @@ -485,10 +518,13 @@ public class MasterClientService { if (result.sec != null) { throw result.sec; } + if (result.tnase != null) { + throw result.tnase; + } throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getMasterStats failed: unknown result"); } - public void waitForBalance(org.apache.accumulo.core.trace.thrift.TInfo tinfo) throws org.apache.thrift.TException + public void waitForBalance(org.apache.accumulo.core.trace.thrift.TInfo tinfo) throws org.apache.accumulo.core.client.impl.thrift.ThriftNotActiveServiceException, org.apache.thrift.TException { send_waitForBalance(tinfo); recv_waitForBalance(); @@ -501,10 +537,13 @@ public class MasterClientService { sendBase("waitForBalance", args); } - public void recv_waitForBalance() throws org.apache.thrift.TException + public void recv_waitForBalance() throws org.apache.accumulo.core.client.impl.thrift.ThriftNotActiveServiceException, org.apache.thrift.TException { waitForBalance_result result = new waitForBalance_result(); receiveBase(result, "waitForBalance"); + if (result.tnase != null) { + throw result.tnase; + } return; } @@ -539,7 +578,7 @@ public class MasterClientService { sendBaseOneway("reportTabletStatus", args); } - public List getActiveTservers(org.apache.accumulo.core.trace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.TCredentials credentials) throws org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException, org.apache.thrift.TException + public List getActiveTservers(org.apache.accumulo.core.trace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.TCredentials credentials) throws org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException, org.apache.accumulo.core.client.impl.thrift.ThriftNotActiveServiceException, org.apache.thrift.TException { send_getActiveTservers(tinfo, credentials); return recv_getActiveTservers(); @@ -553,7 +592,7 @@ public class MasterClientService { sendBase("getActiveTservers", args); } - public List recv_getActiveTservers() throws org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException, org.apache.thrift.TException + public List recv_getActiveTservers() throws org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException, org.apache.accumulo.core.client.impl.thrift.ThriftNotActiveServiceException, org.apache.thrift.TException { getActiveTservers_result result = new getActiveTservers_result(); receiveBase(result, "getActiveTservers"); @@ -563,10 +602,13 @@ public class MasterClientService { if (result.sec != null) { throw result.sec; } + if (result.tnase != null) { + throw result.tnase; + } throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getActiveTservers failed: unknown result"); } - public org.apache.accumulo.core.security.thrift.TDelegationToken getDelegationToken(org.apache.accumulo.core.trace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.TCredentials credentials, org.apache.accumulo.core.security.thrift.TDelegationTokenConfig cfg) throws org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException, org.apache.thrift.TException + public org.apache.accumulo.core.security.thrift.TDelegationToken getDelegationToken(org.apache.accumulo.core.trace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.TCredentials credentials, org.apache.accumulo.core.security.thrift.TDelegationTokenConfig cfg) throws org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException, org.apache.accumulo.core.client.impl.thrift.ThriftNotActiveServiceException, org.apache.thrift.TException { send_getDelegationToken(tinfo, credentials, cfg); return recv_getDelegationToken(); @@ -581,7 +623,7 @@ public class MasterClientService { sendBase("getDelegationToken", args); } - public org.apache.accumulo.core.security.thrift.TDelegationToken recv_getDelegationToken() throws org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException, org.apache.thrift.TException + public org.apache.accumulo.core.security.thrift.TDelegationToken recv_getDelegationToken() throws org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException, org.apache.accumulo.core.client.impl.thrift.ThriftNotActiveServiceException, org.apache.thrift.TException { getDelegationToken_result result = new getDelegationToken_result(); receiveBase(result, "getDelegationToken"); @@ -591,10 +633,13 @@ public class MasterClientService { if (result.sec != null) { throw result.sec; } + if (result.tnase != null) { + throw result.tnase; + } throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getDelegationToken failed: unknown result"); } - public boolean drainReplicationTable(org.apache.accumulo.core.trace.thrift.TInfo tfino, org.apache.accumulo.core.security.thrift.TCredentials credentials, String tableName, Set logsToWatch) throws org.apache.thrift.TException + public boolean drainReplicationTable(org.apache.accumulo.core.trace.thrift.TInfo tfino, org.apache.accumulo.core.security.thrift.TCredentials credentials, String tableName, Set logsToWatch) throws org.apache.accumulo.core.client.impl.thrift.ThriftNotActiveServiceException, org.apache.thrift.TException { send_drainReplicationTable(tfino, credentials, tableName, logsToWatch); return recv_drainReplicationTable(); @@ -610,13 +655,16 @@ public class MasterClientService { sendBase("drainReplicationTable", args); } - public boolean recv_drainReplicationTable() throws org.apache.thrift.TException + public boolean recv_drainReplicationTable() throws org.apache.accumulo.core.client.impl.thrift.ThriftNotActiveServiceException, org.apache.thrift.TException { drainReplicationTable_result result = new drainReplicationTable_result(); receiveBase(result, "drainReplicationTable"); if (result.isSetSuccess()) { return result.success; } + if (result.tnase != null) { + throw result.tnase; + } throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "drainReplicationTable failed: unknown result"); } @@ -666,7 +714,7 @@ public class MasterClientService { prot.writeMessageEnd(); } - public long getResult() throws org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException, org.apache.accumulo.core.client.impl.thrift.ThriftTableOperationException, org.apache.thrift.TException { + public long getResult() throws org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException, org.apache.accumulo.core.client.impl.thrift.ThriftTableOperationException, org.apache.accumulo.core.client.impl.thrift.ThriftNotActiveServiceException, org.apache.thrift.TException { if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) { throw new IllegalStateException("Method call not finished!"); } @@ -716,7 +764,7 @@ public class MasterClientService { prot.writeMessageEnd(); } - public void getResult() throws org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException, org.apache.accumulo.core.client.impl.thrift.ThriftTableOperationException, org.apache.thrift.TException { + public void getResult() throws org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException, org.apache.accumulo.core.client.impl.thrift.ThriftTableOperationException, org.apache.accumulo.core.client.impl.thrift.ThriftNotActiveServiceException, org.apache.thrift.TException { if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) { throw new IllegalStateException("Method call not finished!"); } @@ -760,7 +808,7 @@ public class MasterClientService { prot.writeMessageEnd(); } - public void getResult() throws org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException, org.apache.accumulo.core.client.impl.thrift.ThriftTableOperationException, org.apache.thrift.TException { + public void getResult() throws org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException, org.apache.accumulo.core.client.impl.thrift.ThriftTableOperationException, org.apache.accumulo.core.client.impl.thrift.ThriftNotActiveServiceException, org.apache.thrift.TException { if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) { throw new IllegalStateException("Method call not finished!"); } @@ -801,7 +849,7 @@ public class MasterClientService { prot.writeMessageEnd(); } - public void getResult() throws org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException, org.apache.accumulo.core.client.impl.thrift.ThriftTableOperationException, org.apache.thrift.TException { + public void getResult() throws org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException, org.apache.accumulo.core.client.impl.thrift.ThriftTableOperationException, org.apache.accumulo.core.client.impl.thrift.ThriftNotActiveServiceException, org.apache.thrift.TException { if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) { throw new IllegalStateException("Method call not finished!"); } @@ -845,7 +893,7 @@ public class MasterClientService { prot.writeMessageEnd(); } - public void getResult() throws org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException, org.apache.accumulo.core.client.impl.thrift.ThriftTableOperationException, org.apache.thrift.TException { + public void getResult() throws org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException, org.apache.accumulo.core.client.impl.thrift.ThriftTableOperationException, org.apache.accumulo.core.client.impl.thrift.ThriftNotActiveServiceException, org.apache.thrift.TException { if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) { throw new IllegalStateException("Method call not finished!"); } @@ -886,7 +934,7 @@ public class MasterClientService { prot.writeMessageEnd(); } - public void getResult() throws org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException, org.apache.accumulo.core.client.impl.thrift.ThriftTableOperationException, org.apache.thrift.TException { + public void getResult() throws org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException, org.apache.accumulo.core.client.impl.thrift.ThriftTableOperationException, org.apache.accumulo.core.client.impl.thrift.ThriftNotActiveServiceException, org.apache.thrift.TException { if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) { throw new IllegalStateException("Method call not finished!"); } @@ -924,7 +972,7 @@ public class MasterClientService { prot.writeMessageEnd(); } - public void getResult() throws org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException, org.apache.thrift.TException { + public void getResult() throws org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException, org.apache.accumulo.core.client.impl.thrift.ThriftNotActiveServiceException, org.apache.thrift.TException { if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) { throw new IllegalStateException("Method call not finished!"); } @@ -962,7 +1010,7 @@ public class MasterClientService { prot.writeMessageEnd(); } - public void getResult() throws org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException, org.apache.thrift.TException { + public void getResult() throws org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException, org.apache.accumulo.core.client.impl.thrift.ThriftNotActiveServiceException, org.apache.thrift.TException { if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) { throw new IllegalStateException("Method call not finished!"); } @@ -1003,7 +1051,7 @@ public class MasterClientService { prot.writeMessageEnd(); } - public void getResult() throws org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException, org.apache.thrift.TException { + public void getResult() throws org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException, org.apache.accumulo.core.client.impl.thrift.ThriftNotActiveServiceException, org.apache.thrift.TException { if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) { throw new IllegalStateException("Method call not finished!"); } @@ -1044,7 +1092,7 @@ public class MasterClientService { prot.writeMessageEnd(); } - public void getResult() throws org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException, org.apache.thrift.TException { + public void getResult() throws org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException, org.apache.accumulo.core.client.impl.thrift.ThriftNotActiveServiceException, org.apache.thrift.TException { if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) { throw new IllegalStateException("Method call not finished!"); } @@ -1082,7 +1130,7 @@ public class MasterClientService { prot.writeMessageEnd(); } - public void getResult() throws org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException, org.apache.thrift.TException { + public void getResult() throws org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException, org.apache.accumulo.core.client.impl.thrift.ThriftNotActiveServiceException, org.apache.thrift.TException { if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) { throw new IllegalStateException("Method call not finished!"); } @@ -1117,7 +1165,7 @@ public class MasterClientService { prot.writeMessageEnd(); } - public MasterMonitorInfo getResult() throws org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException, org.apache.thrift.TException { + public MasterMonitorInfo getResult() throws org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException, org.apache.accumulo.core.client.impl.thrift.ThriftNotActiveServiceException, org.apache.thrift.TException { if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) { throw new IllegalStateException("Method call not finished!"); } @@ -1149,7 +1197,7 @@ public class MasterClientService { prot.writeMessageEnd(); } - public void getResult() throws org.apache.thrift.TException { + public void getResult() throws org.apache.accumulo.core.client.impl.thrift.ThriftNotActiveServiceException, org.apache.thrift.TException { if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) { throw new IllegalStateException("Method call not finished!"); } @@ -1267,7 +1315,7 @@ public class MasterClientService { prot.writeMessageEnd(); } - public List getResult() throws org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException, org.apache.thrift.TException { + public List getResult() throws org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException, org.apache.accumulo.core.client.impl.thrift.ThriftNotActiveServiceException, org.apache.thrift.TException { if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) { throw new IllegalStateException("Method call not finished!"); } @@ -1305,7 +1353,7 @@ public class MasterClientService { prot.writeMessageEnd(); } - public org.apache.accumulo.core.security.thrift.TDelegationToken getResult() throws org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException, org.apache.thrift.TException { + public org.apache.accumulo.core.security.thrift.TDelegationToken getResult() throws org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException, org.apache.accumulo.core.client.impl.thrift.ThriftNotActiveServiceException, org.apache.thrift.TException { if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) { throw new IllegalStateException("Method call not finished!"); } @@ -1346,7 +1394,7 @@ public class MasterClientService { prot.writeMessageEnd(); } - public boolean getResult() throws org.apache.thrift.TException { + public boolean getResult() throws org.apache.accumulo.core.client.impl.thrift.ThriftNotActiveServiceException, org.apache.thrift.TException { if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) { throw new IllegalStateException("Method call not finished!"); } @@ -1412,6 +1460,8 @@ public class MasterClientService { result.sec = sec; } catch (org.apache.accumulo.core.client.impl.thrift.ThriftTableOperationException tope) { result.tope = tope; + } catch (org.apache.accumulo.core.client.impl.thrift.ThriftNotActiveServiceException tnase) { + result.tnase = tnase; } return result; } @@ -1438,6 +1488,8 @@ public class MasterClientService { result.sec = sec; } catch (org.apache.accumulo.core.client.impl.thrift.ThriftTableOperationException tope) { result.tope = tope; + } catch (org.apache.accumulo.core.client.impl.thrift.ThriftNotActiveServiceException tnase) { + result.tnase = tnase; } return result; } @@ -1464,6 +1516,8 @@ public class MasterClientService { result.sec = sec; } catch (org.apache.accumulo.core.client.impl.thrift.ThriftTableOperationException tope) { result.tope = tope; + } catch (org.apache.accumulo.core.client.impl.thrift.ThriftNotActiveServiceException tnase) { + result.tnase = tnase; } return result; } @@ -1490,6 +1544,8 @@ public class MasterClientService { result.sec = sec; } catch (org.apache.accumulo.core.client.impl.thrift.ThriftTableOperationException tope) { result.tope = tope; + } catch (org.apache.accumulo.core.client.impl.thrift.ThriftNotActiveServiceException tnase) { + result.tnase = tnase; } return result; } @@ -1516,6 +1572,8 @@ public class MasterClientService { result.sec = sec; } catch (org.apache.accumulo.core.client.impl.thrift.ThriftTableOperationException tope) { result.tope = tope; + } catch (org.apache.accumulo.core.client.impl.thrift.ThriftNotActiveServiceException tnase) { + result.tnase = tnase; } return result; } @@ -1542,6 +1600,8 @@ public class MasterClientService { result.sec = sec; } catch (org.apache.accumulo.core.client.impl.thrift.ThriftTableOperationException tope) { result.tope = tope; + } catch (org.apache.accumulo.core.client.impl.thrift.ThriftNotActiveServiceException tnase) { + result.tnase = tnase; } return result; } @@ -1566,6 +1626,8 @@ public class MasterClientService { iface.setMasterGoalState(args.tinfo, args.credentials, args.state); } catch (org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException sec) { result.sec = sec; + } catch (org.apache.accumulo.core.client.impl.thrift.ThriftNotActiveServiceException tnase) { + result.tnase = tnase; } return result; } @@ -1590,6 +1652,8 @@ public class MasterClientService { iface.shutdown(args.tinfo, args.credentials, args.stopTabletServers); } catch (org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException sec) { result.sec = sec; + } catch (org.apache.accumulo.core.client.impl.thrift.ThriftNotActiveServiceException tnase) { + result.tnase = tnase; } return result; } @@ -1614,6 +1678,8 @@ public class MasterClientService { iface.shutdownTabletServer(args.tinfo, args.credentials, args.tabletServer, args.force); } catch (org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException sec) { result.sec = sec; + } catch (org.apache.accumulo.core.client.impl.thrift.ThriftNotActiveServiceException tnase) { + result.tnase = tnase; } return result; } @@ -1638,6 +1704,8 @@ public class MasterClientService { iface.setSystemProperty(args.tinfo, args.credentials, args.property, args.value); } catch (org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException sec) { result.sec = sec; + } catch (org.apache.accumulo.core.client.impl.thrift.ThriftNotActiveServiceException tnase) { + result.tnase = tnase; } return result; } @@ -1662,6 +1730,8 @@ public class MasterClientService { iface.removeSystemProperty(args.tinfo, args.credentials, args.property); } catch (org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException sec) { result.sec = sec; + } catch (org.apache.accumulo.core.client.impl.thrift.ThriftNotActiveServiceException tnase) { + result.tnase = tnase; } return result; } @@ -1686,6 +1756,8 @@ public class MasterClientService { result.success = iface.getMasterStats(args.tinfo, args.credentials); } catch (org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException sec) { result.sec = sec; + } catch (org.apache.accumulo.core.client.impl.thrift.ThriftNotActiveServiceException tnase) { + result.tnase = tnase; } return result; } @@ -1706,7 +1778,11 @@ public class MasterClientService { public waitForBalance_result getResult(I iface, waitForBalance_args args) throws org.apache.thrift.TException { waitForBalance_result result = new waitForBalance_result(); - iface.waitForBalance(args.tinfo); + try { + iface.waitForBalance(args.tinfo); + } catch (org.apache.accumulo.core.client.impl.thrift.ThriftNotActiveServiceException tnase) { + result.tnase = tnase; + } return result; } } @@ -1768,6 +1844,8 @@ public class MasterClientService { result.success = iface.getActiveTservers(args.tinfo, args.credentials); } catch (org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException sec) { result.sec = sec; + } catch (org.apache.accumulo.core.client.impl.thrift.ThriftNotActiveServiceException tnase) { + result.tnase = tnase; } return result; } @@ -1792,6 +1870,8 @@ public class MasterClientService { result.success = iface.getDelegationToken(args.tinfo, args.credentials, args.cfg); } catch (org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException sec) { result.sec = sec; + } catch (org.apache.accumulo.core.client.impl.thrift.ThriftNotActiveServiceException tnase) { + result.tnase = tnase; } return result; } @@ -1812,8 +1892,12 @@ public class MasterClientService { public drainReplicationTable_result getResult(I iface, drainReplicationTable_args args) throws org.apache.thrift.TException { drainReplicationTable_result result = new drainReplicationTable_result(); - result.success = iface.drainReplicationTable(args.tfino, args.credentials, args.tableName, args.logsToWatch); - result.setSuccessIsSet(true); + try { + result.success = iface.drainReplicationTable(args.tfino, args.credentials, args.tableName, args.logsToWatch); + result.setSuccessIsSet(true); + } catch (org.apache.accumulo.core.client.impl.thrift.ThriftNotActiveServiceException tnase) { + result.tnase = tnase; + } return result; } } @@ -1890,6 +1974,11 @@ public class MasterClientService { result.setTopeIsSet(true); msg = result; } + else if (e instanceof org.apache.accumulo.core.client.impl.thrift.ThriftNotActiveServiceException) { + result.tnase = (org.apache.accumulo.core.client.impl.thrift.ThriftNotActiveServiceException) e; + result.setTnaseIsSet(true); + msg = result; + } else { msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION; @@ -1951,6 +2040,11 @@ public class MasterClientService { result.setTopeIsSet(true); msg = result; } + else if (e instanceof org.apache.accumulo.core.client.impl.thrift.ThriftNotActiveServiceException) { + result.tnase = (org.apache.accumulo.core.client.impl.thrift.ThriftNotActiveServiceException) e; + result.setTnaseIsSet(true); + msg = result; + } else { msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION; @@ -2012,6 +2106,11 @@ public class MasterClientService { result.setTopeIsSet(true); msg = result; } + else if (e instanceof org.apache.accumulo.core.client.impl.thrift.ThriftNotActiveServiceException) { + result.tnase = (org.apache.accumulo.core.client.impl.thrift.ThriftNotActiveServiceException) e; + result.setTnaseIsSet(true); + msg = result; + } else { msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION; @@ -2073,6 +2172,11 @@ public class MasterClientService { result.setTopeIsSet(true); msg = result; } + else if (e instanceof org.apache.accumulo.core.client.impl.thrift.ThriftNotActiveServiceException) { + result.tnase = (org.apache.accumulo.core.client.impl.thrift.ThriftNotActiveServiceException) e; + result.setTnaseIsSet(true); + msg = result; + } else { msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION; @@ -2134,6 +2238,11 @@ public class MasterClientService { result.setTopeIsSet(true); msg = result; } + else if (e instanceof org.apache.accumulo.core.client.impl.thrift.ThriftNotActiveServiceException) { + result.tnase = (org.apache.accumulo.core.client.impl.thrift.ThriftNotActiveServiceException) e; + result.setTnaseIsSet(true); + msg = result; + } else { msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION; @@ -2195,6 +2304,11 @@ public class MasterClientService { result.setTopeIsSet(true); msg = result; } + else if (e instanceof org.apache.accumulo.core.client.impl.thrift.ThriftNotActiveServiceException) { + result.tnase = (org.apache.accumulo.core.client.impl.thrift.ThriftNotActiveServiceException) e; + result.setTnaseIsSet(true); + msg = result; + } else { msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION; @@ -2251,6 +2365,11 @@ public class MasterClientService { result.setSecIsSet(true); msg = result; } + else if (e instanceof org.apache.accumulo.core.client.impl.thrift.ThriftNotActiveServiceException) { + result.tnase = (org.apache.accumulo.core.client.impl.thrift.ThriftNotActiveServiceException) e; + result.setTnaseIsSet(true); + msg = result; + } else { msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION; @@ -2307,6 +2426,11 @@ public class MasterClientService { result.setSecIsSet(true); msg = result; } + else if (e instanceof org.apache.accumulo.core.client.impl.thrift.ThriftNotActiveServiceException) { + result.tnase = (org.apache.accumulo.core.client.impl.thrift.ThriftNotActiveServiceException) e; + result.setTnaseIsSet(true); + msg = result; + } else { msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION; @@ -2363,6 +2487,11 @@ public class MasterClientService { result.setSecIsSet(true); msg = result; } + else if (e instanceof org.apache.accumulo.core.client.impl.thrift.ThriftNotActiveServiceException) { + result.tnase = (org.apache.accumulo.core.client.impl.thrift.ThriftNotActiveServiceException) e; + result.setTnaseIsSet(true); + msg = result; + } else { msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION; @@ -2419,6 +2548,11 @@ public class MasterClientService { result.setSecIsSet(true); msg = result; } + else if (e instanceof org.apache.accumulo.core.client.impl.thrift.ThriftNotActiveServiceException) { + result.tnase = (org.apache.accumulo.core.client.impl.thrift.ThriftNotActiveServiceException) e; + result.setTnaseIsSet(true); + msg = result; + } else { msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION; @@ -2475,6 +2609,11 @@ public class MasterClientService { result.setSecIsSet(true); msg = result; } + else if (e instanceof org.apache.accumulo.core.client.impl.thrift.ThriftNotActiveServiceException) { + result.tnase = (org.apache.accumulo.core.client.impl.thrift.ThriftNotActiveServiceException) e; + result.setTnaseIsSet(true); + msg = result; + } else { msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION; @@ -2532,6 +2671,11 @@ public class MasterClientService { result.setSecIsSet(true); msg = result; } + else if (e instanceof org.apache.accumulo.core.client.impl.thrift.ThriftNotActiveServiceException) { + result.tnase = (org.apache.accumulo.core.client.impl.thrift.ThriftNotActiveServiceException) e; + result.setTnaseIsSet(true); + msg = result; + } else { msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION; @@ -2583,6 +2727,12 @@ public class MasterClientService { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; waitForBalance_result result = new waitForBalance_result(); + if (e instanceof org.apache.accumulo.core.client.impl.thrift.ThriftNotActiveServiceException) { + result.tnase = (org.apache.accumulo.core.client.impl.thrift.ThriftNotActiveServiceException) e; + result.setTnaseIsSet(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()); @@ -2695,6 +2845,11 @@ public class MasterClientService { result.setSecIsSet(true); msg = result; } + else if (e instanceof org.apache.accumulo.core.client.impl.thrift.ThriftNotActiveServiceException) { + result.tnase = (org.apache.accumulo.core.client.impl.thrift.ThriftNotActiveServiceException) e; + result.setTnaseIsSet(true); + msg = result; + } else { msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION; @@ -2752,6 +2907,11 @@ public class MasterClientService { result.setSecIsSet(true); msg = result; } + else if (e instanceof org.apache.accumulo.core.client.impl.thrift.ThriftNotActiveServiceException) { + result.tnase = (org.apache.accumulo.core.client.impl.thrift.ThriftNotActiveServiceException) e; + result.setTnaseIsSet(true); + msg = result; + } else { msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION; @@ -2805,6 +2965,12 @@ public class MasterClientService { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; drainReplicationTable_result result = new drainReplicationTable_result(); + if (e instanceof org.apache.accumulo.core.client.impl.thrift.ThriftNotActiveServiceException) { + result.tnase = (org.apache.accumulo.core.client.impl.thrift.ThriftNotActiveServiceException) e; + result.setTnaseIsSet(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()); @@ -3418,6 +3584,7 @@ public class MasterClientService { private static final org.apache.thrift.protocol.TField SUCCESS_FIELD_DESC = new org.apache.thrift.protocol.TField("success", org.apache.thrift.protocol.TType.I64, (short)0); private static final org.apache.thrift.protocol.TField SEC_FIELD_DESC = new org.apache.thrift.protocol.TField("sec", org.apache.thrift.protocol.TType.STRUCT, (short)1); private static final org.apache.thrift.protocol.TField TOPE_FIELD_DESC = new org.apache.thrift.protocol.TField("tope", org.apache.thrift.protocol.TType.STRUCT, (short)2); + private static final org.apache.thrift.protocol.TField TNASE_FIELD_DESC = new org.apache.thrift.protocol.TField("tnase", org.apache.thrift.protocol.TType.STRUCT, (short)3); private static final Map, SchemeFactory> schemes = new HashMap, SchemeFactory>(); static { @@ -3428,12 +3595,14 @@ public class MasterClientService { public long success; // required public org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException sec; // required public org.apache.accumulo.core.client.impl.thrift.ThriftTableOperationException tope; // required + public org.apache.accumulo.core.client.impl.thrift.ThriftNotActiveServiceException tnase; // 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"), SEC((short)1, "sec"), - TOPE((short)2, "tope"); + TOPE((short)2, "tope"), + TNASE((short)3, "tnase"); private static final Map byName = new HashMap(); @@ -3454,6 +3623,8 @@ public class MasterClientService { return SEC; case 2: // TOPE return TOPE; + case 3: // TNASE + return TNASE; default: return null; } @@ -3505,6 +3676,8 @@ public class MasterClientService { new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRUCT))); tmpMap.put(_Fields.TOPE, new org.apache.thrift.meta_data.FieldMetaData("tope", org.apache.thrift.TFieldRequirementType.DEFAULT, new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRUCT))); + tmpMap.put(_Fields.TNASE, new org.apache.thrift.meta_data.FieldMetaData("tnase", 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(initiateFlush_result.class, metaDataMap); } @@ -3515,13 +3688,15 @@ public class MasterClientService { public initiateFlush_result( long success, org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException sec, - org.apache.accumulo.core.client.impl.thrift.ThriftTableOperationException tope) + org.apache.accumulo.core.client.impl.thrift.ThriftTableOperationException tope, + org.apache.accumulo.core.client.impl.thrift.ThriftNotActiveServiceException tnase) { this(); this.success = success; setSuccessIsSet(true); this.sec = sec; this.tope = tope; + this.tnase = tnase; } /** @@ -3536,6 +3711,9 @@ public class MasterClientService { if (other.isSetTope()) { this.tope = new org.apache.accumulo.core.client.impl.thrift.ThriftTableOperationException(other.tope); } + if (other.isSetTnase()) { + this.tnase = new org.apache.accumulo.core.client.impl.thrift.ThriftNotActiveServiceException(other.tnase); + } } public initiateFlush_result deepCopy() { @@ -3548,6 +3726,7 @@ public class MasterClientService { this.success = 0; this.sec = null; this.tope = null; + this.tnase = null; } public long getSuccess() { @@ -3621,6 +3800,30 @@ public class MasterClientService { } } + public org.apache.accumulo.core.client.impl.thrift.ThriftNotActiveServiceException getTnase() { + return this.tnase; + } + + public initiateFlush_result setTnase(org.apache.accumulo.core.client.impl.thrift.ThriftNotActiveServiceException tnase) { + this.tnase = tnase; + return this; + } + + public void unsetTnase() { + this.tnase = null; + } + + /** Returns true if field tnase is set (has been assigned a value) and false otherwise */ + public boolean isSetTnase() { + return this.tnase != null; + } + + public void setTnaseIsSet(boolean value) { + if (!value) { + this.tnase = null; + } + } + public void setFieldValue(_Fields field, Object value) { switch (field) { case SUCCESS: @@ -3647,6 +3850,14 @@ public class MasterClientService { } break; + case TNASE: + if (value == null) { + unsetTnase(); + } else { + setTnase((org.apache.accumulo.core.client.impl.thrift.ThriftNotActiveServiceException)value); + } + break; + } } @@ -3661,6 +3872,9 @@ public class MasterClientService { case TOPE: return getTope(); + case TNASE: + return getTnase(); + } throw new IllegalStateException(); } @@ -3678,6 +3892,8 @@ public class MasterClientService { return isSetSec(); case TOPE: return isSetTope(); + case TNASE: + return isSetTnase(); } throw new IllegalStateException(); } @@ -3722,6 +3938,15 @@ public class MasterClientService { return false; } + boolean this_present_tnase = true && this.isSetTnase(); + boolean that_present_tnase = true && that.isSetTnase(); + if (this_present_tnase || that_present_tnase) { + if (!(this_present_tnase && that_present_tnase)) + return false; + if (!this.tnase.equals(that.tnase)) + return false; + } + return true; } @@ -3744,6 +3969,11 @@ public class MasterClientService { if (present_tope) list.add(tope); + boolean present_tnase = true && (isSetTnase()); + list.add(present_tnase); + if (present_tnase) + list.add(tnase); + return list.hashCode(); } @@ -3785,6 +4015,16 @@ public class MasterClientService { return lastComparison; } } + lastComparison = Boolean.valueOf(isSetTnase()).compareTo(other.isSetTnase()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetTnase()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.tnase, other.tnase); + if (lastComparison != 0) { + return lastComparison; + } + } return 0; } @@ -3824,6 +4064,14 @@ public class MasterClientService { sb.append(this.tope); } first = false; + if (!first) sb.append(", "); + sb.append("tnase:"); + if (this.tnase == null) { + sb.append("null"); + } else { + sb.append(this.tnase); + } + first = false; sb.append(")"); return sb.toString(); } @@ -3895,6 +4143,15 @@ public class MasterClientService { org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); } break; + case 3: // TNASE + if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) { + struct.tnase = new org.apache.accumulo.core.client.impl.thrift.ThriftNotActiveServiceException(); + struct.tnase.read(iprot); + struct.setTnaseIsSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; default: org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); } @@ -3925,6 +4182,11 @@ public class MasterClientService { struct.tope.write(oprot); oprot.writeFieldEnd(); } + if (struct.tnase != null) { + oprot.writeFieldBegin(TNASE_FIELD_DESC); + struct.tnase.write(oprot); + oprot.writeFieldEnd(); + } oprot.writeFieldStop(); oprot.writeStructEnd(); } @@ -3952,7 +4214,10 @@ public class MasterClientService { if (struct.isSetTope()) { optionals.set(2); } - oprot.writeBitSet(optionals, 3); + if (struct.isSetTnase()) { + optionals.set(3); + } + oprot.writeBitSet(optionals, 4); if (struct.isSetSuccess()) { oprot.writeI64(struct.success); } @@ -3962,12 +4227,15 @@ public class MasterClientService { if (struct.isSetTope()) { struct.tope.write(oprot); } + if (struct.isSetTnase()) { + struct.tnase.write(oprot); + } } @Override public void read(org.apache.thrift.protocol.TProtocol prot, initiateFlush_result struct) throws org.apache.thrift.TException { TTupleProtocol iprot = (TTupleProtocol) prot; - BitSet incoming = iprot.readBitSet(3); + BitSet incoming = iprot.readBitSet(4); if (incoming.get(0)) { struct.success = iprot.readI64(); struct.setSuccessIsSet(true); @@ -3982,6 +4250,11 @@ public class MasterClientService { struct.tope.read(iprot); struct.setTopeIsSet(true); } + if (incoming.get(3)) { + struct.tnase = new org.apache.accumulo.core.client.impl.thrift.ThriftNotActiveServiceException(); + struct.tnase.read(iprot); + struct.setTnaseIsSet(true); + } } } @@ -5005,6 +5278,7 @@ public class MasterClientService { private static final org.apache.thrift.protocol.TField SEC_FIELD_DESC = new org.apache.thrift.protocol.TField("sec", org.apache.thrift.protocol.TType.STRUCT, (short)1); private static final org.apache.thrift.protocol.TField TOPE_FIELD_DESC = new org.apache.thrift.protocol.TField("tope", org.apache.thrift.protocol.TType.STRUCT, (short)2); + private static final org.apache.thrift.protocol.TField TNASE_FIELD_DESC = new org.apache.thrift.protocol.TField("tnase", org.apache.thrift.protocol.TType.STRUCT, (short)3); private static final Map, SchemeFactory> schemes = new HashMap, SchemeFactory>(); static { @@ -5014,11 +5288,13 @@ public class MasterClientService { public org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException sec; // required public org.apache.accumulo.core.client.impl.thrift.ThriftTableOperationException tope; // required + public org.apache.accumulo.core.client.impl.thrift.ThriftNotActiveServiceException tnase; // 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 { SEC((short)1, "sec"), - TOPE((short)2, "tope"); + TOPE((short)2, "tope"), + TNASE((short)3, "tnase"); private static final Map byName = new HashMap(); @@ -5037,6 +5313,8 @@ public class MasterClientService { return SEC; case 2: // TOPE return TOPE; + case 3: // TNASE + return TNASE; default: return null; } @@ -5084,6 +5362,8 @@ public class MasterClientService { new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRUCT))); tmpMap.put(_Fields.TOPE, new org.apache.thrift.meta_data.FieldMetaData("tope", org.apache.thrift.TFieldRequirementType.DEFAULT, new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRUCT))); + tmpMap.put(_Fields.TNASE, new org.apache.thrift.meta_data.FieldMetaData("tnase", 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(waitForFlush_result.class, metaDataMap); } @@ -5093,11 +5373,13 @@ public class MasterClientService { public waitForFlush_result( org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException sec, - org.apache.accumulo.core.client.impl.thrift.ThriftTableOperationException tope) + org.apache.accumulo.core.client.impl.thrift.ThriftTableOperationException tope, + org.apache.accumulo.core.client.impl.thrift.ThriftNotActiveServiceException tnase) { this(); this.sec = sec; this.tope = tope; + this.tnase = tnase; } /** @@ -5110,6 +5392,9 @@ public class MasterClientService { if (other.isSetTope()) { this.tope = new org.apache.accumulo.core.client.impl.thrift.ThriftTableOperationException(other.tope); } + if (other.isSetTnase()) { + this.tnase = new org.apache.accumulo.core.client.impl.thrift.ThriftNotActiveServiceException(other.tnase); + } } public waitForFlush_result deepCopy() { @@ -5120,6 +5405,7 @@ public class MasterClientService { public void clear() { this.sec = null; this.tope = null; + this.tnase = null; } public org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException getSec() { @@ -5170,6 +5456,30 @@ public class MasterClientService { } } + public org.apache.accumulo.core.client.impl.thrift.ThriftNotActiveServiceException getTnase() { + return this.tnase; + } + + public waitForFlush_result setTnase(org.apache.accumulo.core.client.impl.thrift.ThriftNotActiveServiceException tnase) { + this.tnase = tnase; + return this; + } + + public void unsetTnase() { + this.tnase = null; + } + + /** Returns true if field tnase is set (has been assigned a value) and false otherwise */ + public boolean isSetTnase() { + return this.tnase != null; + } + + public void setTnaseIsSet(boolean value) { + if (!value) { + this.tnase = null; + } + } + public void setFieldValue(_Fields field, Object value) { switch (field) { case SEC: @@ -5188,6 +5498,14 @@ public class MasterClientService { } break; + case TNASE: + if (value == null) { + unsetTnase(); + } else { + setTnase((org.apache.accumulo.core.client.impl.thrift.ThriftNotActiveServiceException)value); + } + break; + } } @@ -5199,6 +5517,9 @@ public class MasterClientService { case TOPE: return getTope(); + case TNASE: + return getTnase(); + } throw new IllegalStateException(); } @@ -5214,6 +5535,8 @@ public class MasterClientService { return isSetSec(); case TOPE: return isSetTope(); + case TNASE: + return isSetTnase(); } throw new IllegalStateException(); } @@ -5249,6 +5572,15 @@ public class MasterClientService { return false; } + boolean this_present_tnase = true && this.isSetTnase(); + boolean that_present_tnase = true && that.isSetTnase(); + if (this_present_tnase || that_present_tnase) { + if (!(this_present_tnase && that_present_tnase)) + return false; + if (!this.tnase.equals(that.tnase)) + return false; + } + return true; } @@ -5266,6 +5598,11 @@ public class MasterClientService { if (present_tope) list.add(tope); + boolean present_tnase = true && (isSetTnase()); + list.add(present_tnase); + if (present_tnase) + list.add(tnase); + return list.hashCode(); } @@ -5297,6 +5634,16 @@ public class MasterClientService { return lastComparison; } } + lastComparison = Boolean.valueOf(isSetTnase()).compareTo(other.isSetTnase()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetTnase()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.tnase, other.tnase); + if (lastComparison != 0) { + return lastComparison; + } + } return 0; } @@ -5332,6 +5679,14 @@ public class MasterClientService { sb.append(this.tope); } first = false; + if (!first) sb.append(", "); + sb.append("tnase:"); + if (this.tnase == null) { + sb.append("null"); + } else { + sb.append(this.tnase); + } + first = false; sb.append(")"); return sb.toString(); } @@ -5393,6 +5748,15 @@ public class MasterClientService { org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); } break; + case 3: // TNASE + if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) { + struct.tnase = new org.apache.accumulo.core.client.impl.thrift.ThriftNotActiveServiceException(); + struct.tnase.read(iprot); + struct.setTnaseIsSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; default: org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); } @@ -5418,6 +5782,11 @@ public class MasterClientService { struct.tope.write(oprot); oprot.writeFieldEnd(); } + if (struct.tnase != null) { + oprot.writeFieldBegin(TNASE_FIELD_DESC); + struct.tnase.write(oprot); + oprot.writeFieldEnd(); + } oprot.writeFieldStop(); oprot.writeStructEnd(); } @@ -5442,19 +5811,25 @@ public class MasterClientService { if (struct.isSetTope()) { optionals.set(1); } - oprot.writeBitSet(optionals, 2); + if (struct.isSetTnase()) { + optionals.set(2); + } + oprot.writeBitSet(optionals, 3); if (struct.isSetSec()) { struct.sec.write(oprot); } if (struct.isSetTope()) { struct.tope.write(oprot); } + if (struct.isSetTnase()) { + struct.tnase.write(oprot); + } } @Override public void read(org.apache.thrift.protocol.TProtocol prot, waitForFlush_result struct) throws org.apache.thrift.TException { TTupleProtocol iprot = (TTupleProtocol) prot; - BitSet incoming = iprot.readBitSet(2); + BitSet incoming = iprot.readBitSet(3); if (incoming.get(0)) { struct.sec = new org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException(); struct.sec.read(iprot); @@ -5465,6 +5840,11 @@ public class MasterClientService { struct.tope.read(iprot); struct.setTopeIsSet(true); } + if (incoming.get(2)) { + struct.tnase = new org.apache.accumulo.core.client.impl.thrift.ThriftNotActiveServiceException(); + struct.tnase.read(iprot); + struct.setTnaseIsSet(true); + } } } @@ -6266,6 +6646,7 @@ public class MasterClientService { private static final org.apache.thrift.protocol.TField SEC_FIELD_DESC = new org.apache.thrift.protocol.TField("sec", org.apache.thrift.protocol.TType.STRUCT, (short)1); private static final org.apache.thrift.protocol.TField TOPE_FIELD_DESC = new org.apache.thrift.protocol.TField("tope", org.apache.thrift.protocol.TType.STRUCT, (short)2); + private static final org.apache.thrift.protocol.TField TNASE_FIELD_DESC = new org.apache.thrift.protocol.TField("tnase", org.apache.thrift.protocol.TType.STRUCT, (short)3); private static final Map, SchemeFactory> schemes = new HashMap, SchemeFactory>(); static { @@ -6275,11 +6656,13 @@ public class MasterClientService { public org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException sec; // required public org.apache.accumulo.core.client.impl.thrift.ThriftTableOperationException tope; // required + public org.apache.accumulo.core.client.impl.thrift.ThriftNotActiveServiceException tnase; // 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 { SEC((short)1, "sec"), - TOPE(