Return-Path: X-Original-To: apmail-accumulo-commits-archive@www.apache.org Delivered-To: apmail-accumulo-commits-archive@www.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 9489DDBAA for ; Tue, 10 Jul 2012 12:40:26 +0000 (UTC) Received: (qmail 84726 invoked by uid 500); 10 Jul 2012 12:40:26 -0000 Delivered-To: apmail-accumulo-commits-archive@accumulo.apache.org Received: (qmail 84626 invoked by uid 500); 10 Jul 2012 12:40:25 -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 84519 invoked by uid 99); 10 Jul 2012 12:40:25 -0000 Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 10 Jul 2012 12:40:25 +0000 X-ASF-Spam-Status: No, hits=-2000.0 required=5.0 tests=ALL_TRUSTED X-Spam-Check-By: apache.org Received: from [140.211.11.4] (HELO eris.apache.org) (140.211.11.4) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 10 Jul 2012 12:40:20 +0000 Received: from eris.apache.org (localhost [127.0.0.1]) by eris.apache.org (Postfix) with ESMTP id A493E2388962 for ; Tue, 10 Jul 2012 12:40:00 +0000 (UTC) Content-Type: text/plain; charset="utf-8" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit Subject: svn commit: r1359639 [2/13] - in /accumulo/trunk: ./ core/ core/src/main/java/org/apache/accumulo/core/client/admin/ core/src/main/java/org/apache/accumulo/core/client/impl/ core/src/main/java/org/apache/accumulo/core/client/impl/thrift/ core/src/main/... Date: Tue, 10 Jul 2012 12:39:55 -0000 To: commits@accumulo.apache.org From: ecn@apache.org X-Mailer: svnmailer-1.0.8-patched Message-Id: <20120710124000.A493E2388962@eris.apache.org> X-Virus-Checked: Checked by ClamAV on apache.org Modified: accumulo/trunk/core/src/main/java/org/apache/accumulo/core/client/impl/thrift/ClientService.java URL: http://svn.apache.org/viewvc/accumulo/trunk/core/src/main/java/org/apache/accumulo/core/client/impl/thrift/ClientService.java?rev=1359639&r1=1359638&r2=1359639&view=diff ============================================================================== --- accumulo/trunk/core/src/main/java/org/apache/accumulo/core/client/impl/thrift/ClientService.java (original) +++ accumulo/trunk/core/src/main/java/org/apache/accumulo/core/client/impl/thrift/ClientService.java Tue Jul 10 12:39:52 2012 @@ -1,10 +1,17 @@ /** - * Autogenerated by Thrift + * Autogenerated by Thrift Compiler (0.8.0) * * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING + * @generated */ package org.apache.accumulo.core.client.impl.thrift; +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 java.util.List; import java.util.ArrayList; import java.util.Map; @@ -118,7 +125,7 @@ import org.slf4j.LoggerFactory; } - public static class Client implements org.apache.thrift.TServiceClient, Iface { + public static class Client extends org.apache.thrift.TServiceClient implements Iface { public static class Factory implements org.apache.thrift.TServiceClientFactory { public Factory() {} public Client getClient(org.apache.thrift.protocol.TProtocol prot) { @@ -131,28 +138,11 @@ import org.slf4j.LoggerFactory; public Client(org.apache.thrift.protocol.TProtocol prot) { - this(prot, prot); - } - - public Client(org.apache.thrift.protocol.TProtocol iprot, org.apache.thrift.protocol.TProtocol oprot) - { - iprot_ = iprot; - oprot_ = oprot; - } - - protected org.apache.thrift.protocol.TProtocol iprot_; - protected org.apache.thrift.protocol.TProtocol oprot_; - - protected int seqid_; - - public org.apache.thrift.protocol.TProtocol getInputProtocol() - { - return this.iprot_; + super(prot, prot); } - public org.apache.thrift.protocol.TProtocol getOutputProtocol() - { - return this.oprot_; + public Client(org.apache.thrift.protocol.TProtocol iprot, org.apache.thrift.protocol.TProtocol oprot) { + super(iprot, oprot); } public String getRootTabletLocation() throws org.apache.thrift.TException @@ -163,27 +153,14 @@ import org.slf4j.LoggerFactory; public void send_getRootTabletLocation() throws org.apache.thrift.TException { - oprot_.writeMessageBegin(new org.apache.thrift.protocol.TMessage("getRootTabletLocation", org.apache.thrift.protocol.TMessageType.CALL, ++seqid_)); getRootTabletLocation_args args = new getRootTabletLocation_args(); - args.write(oprot_); - oprot_.writeMessageEnd(); - oprot_.getTransport().flush(); + sendBase("getRootTabletLocation", args); } public String recv_getRootTabletLocation() throws org.apache.thrift.TException { - org.apache.thrift.protocol.TMessage msg = iprot_.readMessageBegin(); - if (msg.type == org.apache.thrift.protocol.TMessageType.EXCEPTION) { - org.apache.thrift.TApplicationException x = org.apache.thrift.TApplicationException.read(iprot_); - iprot_.readMessageEnd(); - throw x; - } - if (msg.seqid != seqid_) { - throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.BAD_SEQUENCE_ID, "getRootTabletLocation failed: out of sequence response"); - } getRootTabletLocation_result result = new getRootTabletLocation_result(); - result.read(iprot_); - iprot_.readMessageEnd(); + receiveBase(result, "getRootTabletLocation"); if (result.isSetSuccess()) { return result.success; } @@ -198,27 +175,14 @@ import org.slf4j.LoggerFactory; public void send_getInstanceId() throws org.apache.thrift.TException { - oprot_.writeMessageBegin(new org.apache.thrift.protocol.TMessage("getInstanceId", org.apache.thrift.protocol.TMessageType.CALL, ++seqid_)); getInstanceId_args args = new getInstanceId_args(); - args.write(oprot_); - oprot_.writeMessageEnd(); - oprot_.getTransport().flush(); + sendBase("getInstanceId", args); } public String recv_getInstanceId() throws org.apache.thrift.TException { - org.apache.thrift.protocol.TMessage msg = iprot_.readMessageBegin(); - if (msg.type == org.apache.thrift.protocol.TMessageType.EXCEPTION) { - org.apache.thrift.TApplicationException x = org.apache.thrift.TApplicationException.read(iprot_); - iprot_.readMessageEnd(); - throw x; - } - if (msg.seqid != seqid_) { - throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.BAD_SEQUENCE_ID, "getInstanceId failed: out of sequence response"); - } getInstanceId_result result = new getInstanceId_result(); - result.read(iprot_); - iprot_.readMessageEnd(); + receiveBase(result, "getInstanceId"); if (result.isSetSuccess()) { return result.success; } @@ -233,27 +197,14 @@ import org.slf4j.LoggerFactory; public void send_getZooKeepers() throws org.apache.thrift.TException { - oprot_.writeMessageBegin(new org.apache.thrift.protocol.TMessage("getZooKeepers", org.apache.thrift.protocol.TMessageType.CALL, ++seqid_)); getZooKeepers_args args = new getZooKeepers_args(); - args.write(oprot_); - oprot_.writeMessageEnd(); - oprot_.getTransport().flush(); + sendBase("getZooKeepers", args); } public String recv_getZooKeepers() throws org.apache.thrift.TException { - org.apache.thrift.protocol.TMessage msg = iprot_.readMessageBegin(); - if (msg.type == org.apache.thrift.protocol.TMessageType.EXCEPTION) { - org.apache.thrift.TApplicationException x = org.apache.thrift.TApplicationException.read(iprot_); - iprot_.readMessageEnd(); - throw x; - } - if (msg.seqid != seqid_) { - throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.BAD_SEQUENCE_ID, "getZooKeepers failed: out of sequence response"); - } getZooKeepers_result result = new getZooKeepers_result(); - result.read(iprot_); - iprot_.readMessageEnd(); + receiveBase(result, "getZooKeepers"); if (result.isSetSuccess()) { return result.success; } @@ -268,7 +219,6 @@ import org.slf4j.LoggerFactory; public void send_bulkImportFiles(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, long tid, String tableId, List files, String errorDir, boolean setTime) throws org.apache.thrift.TException { - oprot_.writeMessageBegin(new org.apache.thrift.protocol.TMessage("bulkImportFiles", org.apache.thrift.protocol.TMessageType.CALL, ++seqid_)); bulkImportFiles_args args = new bulkImportFiles_args(); args.setTinfo(tinfo); args.setCredentials(credentials); @@ -277,25 +227,13 @@ import org.slf4j.LoggerFactory; args.setFiles(files); args.setErrorDir(errorDir); args.setSetTime(setTime); - args.write(oprot_); - oprot_.writeMessageEnd(); - oprot_.getTransport().flush(); + sendBase("bulkImportFiles", args); } public List recv_bulkImportFiles() throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, ThriftTableOperationException, org.apache.thrift.TException { - org.apache.thrift.protocol.TMessage msg = iprot_.readMessageBegin(); - if (msg.type == org.apache.thrift.protocol.TMessageType.EXCEPTION) { - org.apache.thrift.TApplicationException x = org.apache.thrift.TApplicationException.read(iprot_); - iprot_.readMessageEnd(); - throw x; - } - if (msg.seqid != seqid_) { - throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.BAD_SEQUENCE_ID, "bulkImportFiles failed: out of sequence response"); - } bulkImportFiles_result result = new bulkImportFiles_result(); - result.read(iprot_); - iprot_.readMessageEnd(); + receiveBase(result, "bulkImportFiles"); if (result.isSetSuccess()) { return result.success; } @@ -316,29 +254,16 @@ import org.slf4j.LoggerFactory; public void send_isActive(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, long tid) throws org.apache.thrift.TException { - oprot_.writeMessageBegin(new org.apache.thrift.protocol.TMessage("isActive", org.apache.thrift.protocol.TMessageType.CALL, ++seqid_)); isActive_args args = new isActive_args(); args.setTinfo(tinfo); args.setTid(tid); - args.write(oprot_); - oprot_.writeMessageEnd(); - oprot_.getTransport().flush(); + sendBase("isActive", args); } public boolean recv_isActive() throws org.apache.thrift.TException { - org.apache.thrift.protocol.TMessage msg = iprot_.readMessageBegin(); - if (msg.type == org.apache.thrift.protocol.TMessageType.EXCEPTION) { - org.apache.thrift.TApplicationException x = org.apache.thrift.TApplicationException.read(iprot_); - iprot_.readMessageEnd(); - throw x; - } - if (msg.seqid != seqid_) { - throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.BAD_SEQUENCE_ID, "isActive failed: out of sequence response"); - } isActive_result result = new isActive_result(); - result.read(iprot_); - iprot_.readMessageEnd(); + receiveBase(result, "isActive"); if (result.isSetSuccess()) { return result.success; } @@ -353,28 +278,15 @@ import org.slf4j.LoggerFactory; public void send_ping(org.apache.accumulo.core.security.thrift.AuthInfo credentials) throws org.apache.thrift.TException { - oprot_.writeMessageBegin(new org.apache.thrift.protocol.TMessage("ping", org.apache.thrift.protocol.TMessageType.CALL, ++seqid_)); ping_args args = new ping_args(); args.setCredentials(credentials); - args.write(oprot_); - oprot_.writeMessageEnd(); - oprot_.getTransport().flush(); + sendBase("ping", args); } public void recv_ping() throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, org.apache.thrift.TException { - org.apache.thrift.protocol.TMessage msg = iprot_.readMessageBegin(); - if (msg.type == org.apache.thrift.protocol.TMessageType.EXCEPTION) { - org.apache.thrift.TApplicationException x = org.apache.thrift.TApplicationException.read(iprot_); - iprot_.readMessageEnd(); - throw x; - } - if (msg.seqid != seqid_) { - throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.BAD_SEQUENCE_ID, "ping failed: out of sequence response"); - } ping_result result = new ping_result(); - result.read(iprot_); - iprot_.readMessageEnd(); + receiveBase(result, "ping"); if (result.sec != null) { throw result.sec; } @@ -389,31 +301,18 @@ import org.slf4j.LoggerFactory; public void send_authenticateUser(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String user, ByteBuffer password) throws org.apache.thrift.TException { - oprot_.writeMessageBegin(new org.apache.thrift.protocol.TMessage("authenticateUser", org.apache.thrift.protocol.TMessageType.CALL, ++seqid_)); authenticateUser_args args = new authenticateUser_args(); args.setTinfo(tinfo); args.setCredentials(credentials); args.setUser(user); args.setPassword(password); - args.write(oprot_); - oprot_.writeMessageEnd(); - oprot_.getTransport().flush(); + sendBase("authenticateUser", args); } public boolean recv_authenticateUser() throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, org.apache.thrift.TException { - org.apache.thrift.protocol.TMessage msg = iprot_.readMessageBegin(); - if (msg.type == org.apache.thrift.protocol.TMessageType.EXCEPTION) { - org.apache.thrift.TApplicationException x = org.apache.thrift.TApplicationException.read(iprot_); - iprot_.readMessageEnd(); - throw x; - } - if (msg.seqid != seqid_) { - throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.BAD_SEQUENCE_ID, "authenticateUser failed: out of sequence response"); - } authenticateUser_result result = new authenticateUser_result(); - result.read(iprot_); - iprot_.readMessageEnd(); + receiveBase(result, "authenticateUser"); if (result.isSetSuccess()) { return result.success; } @@ -431,29 +330,16 @@ import org.slf4j.LoggerFactory; public void send_listUsers(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials) throws org.apache.thrift.TException { - oprot_.writeMessageBegin(new org.apache.thrift.protocol.TMessage("listUsers", org.apache.thrift.protocol.TMessageType.CALL, ++seqid_)); listUsers_args args = new listUsers_args(); args.setTinfo(tinfo); args.setCredentials(credentials); - args.write(oprot_); - oprot_.writeMessageEnd(); - oprot_.getTransport().flush(); + sendBase("listUsers", args); } public Set recv_listUsers() throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, org.apache.thrift.TException { - org.apache.thrift.protocol.TMessage msg = iprot_.readMessageBegin(); - if (msg.type == org.apache.thrift.protocol.TMessageType.EXCEPTION) { - org.apache.thrift.TApplicationException x = org.apache.thrift.TApplicationException.read(iprot_); - iprot_.readMessageEnd(); - throw x; - } - if (msg.seqid != seqid_) { - throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.BAD_SEQUENCE_ID, "listUsers failed: out of sequence response"); - } listUsers_result result = new listUsers_result(); - result.read(iprot_); - iprot_.readMessageEnd(); + receiveBase(result, "listUsers"); if (result.isSetSuccess()) { return result.success; } @@ -471,32 +357,19 @@ import org.slf4j.LoggerFactory; public void send_createUser(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String user, ByteBuffer password, List authorizations) throws org.apache.thrift.TException { - oprot_.writeMessageBegin(new org.apache.thrift.protocol.TMessage("createUser", org.apache.thrift.protocol.TMessageType.CALL, ++seqid_)); createUser_args args = new createUser_args(); args.setTinfo(tinfo); args.setCredentials(credentials); args.setUser(user); args.setPassword(password); args.setAuthorizations(authorizations); - args.write(oprot_); - oprot_.writeMessageEnd(); - oprot_.getTransport().flush(); + sendBase("createUser", args); } public void recv_createUser() throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, org.apache.thrift.TException { - org.apache.thrift.protocol.TMessage msg = iprot_.readMessageBegin(); - if (msg.type == org.apache.thrift.protocol.TMessageType.EXCEPTION) { - org.apache.thrift.TApplicationException x = org.apache.thrift.TApplicationException.read(iprot_); - iprot_.readMessageEnd(); - throw x; - } - if (msg.seqid != seqid_) { - throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.BAD_SEQUENCE_ID, "createUser failed: out of sequence response"); - } createUser_result result = new createUser_result(); - result.read(iprot_); - iprot_.readMessageEnd(); + receiveBase(result, "createUser"); if (result.sec != null) { throw result.sec; } @@ -511,30 +384,17 @@ import org.slf4j.LoggerFactory; public void send_dropUser(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String user) throws org.apache.thrift.TException { - oprot_.writeMessageBegin(new org.apache.thrift.protocol.TMessage("dropUser", org.apache.thrift.protocol.TMessageType.CALL, ++seqid_)); dropUser_args args = new dropUser_args(); args.setTinfo(tinfo); args.setCredentials(credentials); args.setUser(user); - args.write(oprot_); - oprot_.writeMessageEnd(); - oprot_.getTransport().flush(); + sendBase("dropUser", args); } public void recv_dropUser() throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, org.apache.thrift.TException { - org.apache.thrift.protocol.TMessage msg = iprot_.readMessageBegin(); - if (msg.type == org.apache.thrift.protocol.TMessageType.EXCEPTION) { - org.apache.thrift.TApplicationException x = org.apache.thrift.TApplicationException.read(iprot_); - iprot_.readMessageEnd(); - throw x; - } - if (msg.seqid != seqid_) { - throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.BAD_SEQUENCE_ID, "dropUser failed: out of sequence response"); - } dropUser_result result = new dropUser_result(); - result.read(iprot_); - iprot_.readMessageEnd(); + receiveBase(result, "dropUser"); if (result.sec != null) { throw result.sec; } @@ -549,31 +409,18 @@ import org.slf4j.LoggerFactory; public void send_changePassword(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String user, ByteBuffer password) throws org.apache.thrift.TException { - oprot_.writeMessageBegin(new org.apache.thrift.protocol.TMessage("changePassword", org.apache.thrift.protocol.TMessageType.CALL, ++seqid_)); changePassword_args args = new changePassword_args(); args.setTinfo(tinfo); args.setCredentials(credentials); args.setUser(user); args.setPassword(password); - args.write(oprot_); - oprot_.writeMessageEnd(); - oprot_.getTransport().flush(); + sendBase("changePassword", args); } public void recv_changePassword() throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, org.apache.thrift.TException { - org.apache.thrift.protocol.TMessage msg = iprot_.readMessageBegin(); - if (msg.type == org.apache.thrift.protocol.TMessageType.EXCEPTION) { - org.apache.thrift.TApplicationException x = org.apache.thrift.TApplicationException.read(iprot_); - iprot_.readMessageEnd(); - throw x; - } - if (msg.seqid != seqid_) { - throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.BAD_SEQUENCE_ID, "changePassword failed: out of sequence response"); - } changePassword_result result = new changePassword_result(); - result.read(iprot_); - iprot_.readMessageEnd(); + receiveBase(result, "changePassword"); if (result.sec != null) { throw result.sec; } @@ -588,31 +435,18 @@ import org.slf4j.LoggerFactory; public void send_changeAuthorizations(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String user, List authorizations) throws org.apache.thrift.TException { - oprot_.writeMessageBegin(new org.apache.thrift.protocol.TMessage("changeAuthorizations", org.apache.thrift.protocol.TMessageType.CALL, ++seqid_)); changeAuthorizations_args args = new changeAuthorizations_args(); args.setTinfo(tinfo); args.setCredentials(credentials); args.setUser(user); args.setAuthorizations(authorizations); - args.write(oprot_); - oprot_.writeMessageEnd(); - oprot_.getTransport().flush(); + sendBase("changeAuthorizations", args); } public void recv_changeAuthorizations() throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, org.apache.thrift.TException { - org.apache.thrift.protocol.TMessage msg = iprot_.readMessageBegin(); - if (msg.type == org.apache.thrift.protocol.TMessageType.EXCEPTION) { - org.apache.thrift.TApplicationException x = org.apache.thrift.TApplicationException.read(iprot_); - iprot_.readMessageEnd(); - throw x; - } - if (msg.seqid != seqid_) { - throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.BAD_SEQUENCE_ID, "changeAuthorizations failed: out of sequence response"); - } changeAuthorizations_result result = new changeAuthorizations_result(); - result.read(iprot_); - iprot_.readMessageEnd(); + receiveBase(result, "changeAuthorizations"); if (result.sec != null) { throw result.sec; } @@ -627,30 +461,17 @@ import org.slf4j.LoggerFactory; public void send_getUserAuthorizations(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String user) throws org.apache.thrift.TException { - oprot_.writeMessageBegin(new org.apache.thrift.protocol.TMessage("getUserAuthorizations", org.apache.thrift.protocol.TMessageType.CALL, ++seqid_)); getUserAuthorizations_args args = new getUserAuthorizations_args(); args.setTinfo(tinfo); args.setCredentials(credentials); args.setUser(user); - args.write(oprot_); - oprot_.writeMessageEnd(); - oprot_.getTransport().flush(); + sendBase("getUserAuthorizations", args); } public List recv_getUserAuthorizations() throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, org.apache.thrift.TException { - org.apache.thrift.protocol.TMessage msg = iprot_.readMessageBegin(); - if (msg.type == org.apache.thrift.protocol.TMessageType.EXCEPTION) { - org.apache.thrift.TApplicationException x = org.apache.thrift.TApplicationException.read(iprot_); - iprot_.readMessageEnd(); - throw x; - } - if (msg.seqid != seqid_) { - throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.BAD_SEQUENCE_ID, "getUserAuthorizations failed: out of sequence response"); - } getUserAuthorizations_result result = new getUserAuthorizations_result(); - result.read(iprot_); - iprot_.readMessageEnd(); + receiveBase(result, "getUserAuthorizations"); if (result.isSetSuccess()) { return result.success; } @@ -668,31 +489,18 @@ import org.slf4j.LoggerFactory; public void send_hasSystemPermission(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String user, byte sysPerm) throws org.apache.thrift.TException { - oprot_.writeMessageBegin(new org.apache.thrift.protocol.TMessage("hasSystemPermission", org.apache.thrift.protocol.TMessageType.CALL, ++seqid_)); hasSystemPermission_args args = new hasSystemPermission_args(); args.setTinfo(tinfo); args.setCredentials(credentials); args.setUser(user); args.setSysPerm(sysPerm); - args.write(oprot_); - oprot_.writeMessageEnd(); - oprot_.getTransport().flush(); + sendBase("hasSystemPermission", args); } public boolean recv_hasSystemPermission() throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, org.apache.thrift.TException { - org.apache.thrift.protocol.TMessage msg = iprot_.readMessageBegin(); - if (msg.type == org.apache.thrift.protocol.TMessageType.EXCEPTION) { - org.apache.thrift.TApplicationException x = org.apache.thrift.TApplicationException.read(iprot_); - iprot_.readMessageEnd(); - throw x; - } - if (msg.seqid != seqid_) { - throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.BAD_SEQUENCE_ID, "hasSystemPermission failed: out of sequence response"); - } hasSystemPermission_result result = new hasSystemPermission_result(); - result.read(iprot_); - iprot_.readMessageEnd(); + receiveBase(result, "hasSystemPermission"); if (result.isSetSuccess()) { return result.success; } @@ -710,32 +518,19 @@ import org.slf4j.LoggerFactory; public void send_hasTablePermission(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String user, String tableName, byte tblPerm) throws org.apache.thrift.TException { - oprot_.writeMessageBegin(new org.apache.thrift.protocol.TMessage("hasTablePermission", org.apache.thrift.protocol.TMessageType.CALL, ++seqid_)); hasTablePermission_args args = new hasTablePermission_args(); args.setTinfo(tinfo); args.setCredentials(credentials); args.setUser(user); args.setTableName(tableName); args.setTblPerm(tblPerm); - args.write(oprot_); - oprot_.writeMessageEnd(); - oprot_.getTransport().flush(); + sendBase("hasTablePermission", args); } public boolean recv_hasTablePermission() throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, ThriftTableOperationException, org.apache.thrift.TException { - org.apache.thrift.protocol.TMessage msg = iprot_.readMessageBegin(); - if (msg.type == org.apache.thrift.protocol.TMessageType.EXCEPTION) { - org.apache.thrift.TApplicationException x = org.apache.thrift.TApplicationException.read(iprot_); - iprot_.readMessageEnd(); - throw x; - } - if (msg.seqid != seqid_) { - throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.BAD_SEQUENCE_ID, "hasTablePermission failed: out of sequence response"); - } hasTablePermission_result result = new hasTablePermission_result(); - result.read(iprot_); - iprot_.readMessageEnd(); + receiveBase(result, "hasTablePermission"); if (result.isSetSuccess()) { return result.success; } @@ -756,31 +551,18 @@ import org.slf4j.LoggerFactory; public void send_grantSystemPermission(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String user, byte permission) throws org.apache.thrift.TException { - oprot_.writeMessageBegin(new org.apache.thrift.protocol.TMessage("grantSystemPermission", org.apache.thrift.protocol.TMessageType.CALL, ++seqid_)); grantSystemPermission_args args = new grantSystemPermission_args(); args.setTinfo(tinfo); args.setCredentials(credentials); args.setUser(user); args.setPermission(permission); - args.write(oprot_); - oprot_.writeMessageEnd(); - oprot_.getTransport().flush(); + sendBase("grantSystemPermission", args); } public void recv_grantSystemPermission() throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, org.apache.thrift.TException { - org.apache.thrift.protocol.TMessage msg = iprot_.readMessageBegin(); - if (msg.type == org.apache.thrift.protocol.TMessageType.EXCEPTION) { - org.apache.thrift.TApplicationException x = org.apache.thrift.TApplicationException.read(iprot_); - iprot_.readMessageEnd(); - throw x; - } - if (msg.seqid != seqid_) { - throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.BAD_SEQUENCE_ID, "grantSystemPermission failed: out of sequence response"); - } grantSystemPermission_result result = new grantSystemPermission_result(); - result.read(iprot_); - iprot_.readMessageEnd(); + receiveBase(result, "grantSystemPermission"); if (result.sec != null) { throw result.sec; } @@ -795,31 +577,18 @@ import org.slf4j.LoggerFactory; public void send_revokeSystemPermission(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String user, byte permission) throws org.apache.thrift.TException { - oprot_.writeMessageBegin(new org.apache.thrift.protocol.TMessage("revokeSystemPermission", org.apache.thrift.protocol.TMessageType.CALL, ++seqid_)); revokeSystemPermission_args args = new revokeSystemPermission_args(); args.setTinfo(tinfo); args.setCredentials(credentials); args.setUser(user); args.setPermission(permission); - args.write(oprot_); - oprot_.writeMessageEnd(); - oprot_.getTransport().flush(); + sendBase("revokeSystemPermission", args); } public void recv_revokeSystemPermission() throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, org.apache.thrift.TException { - org.apache.thrift.protocol.TMessage msg = iprot_.readMessageBegin(); - if (msg.type == org.apache.thrift.protocol.TMessageType.EXCEPTION) { - org.apache.thrift.TApplicationException x = org.apache.thrift.TApplicationException.read(iprot_); - iprot_.readMessageEnd(); - throw x; - } - if (msg.seqid != seqid_) { - throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.BAD_SEQUENCE_ID, "revokeSystemPermission failed: out of sequence response"); - } revokeSystemPermission_result result = new revokeSystemPermission_result(); - result.read(iprot_); - iprot_.readMessageEnd(); + receiveBase(result, "revokeSystemPermission"); if (result.sec != null) { throw result.sec; } @@ -834,32 +603,19 @@ import org.slf4j.LoggerFactory; public void send_grantTablePermission(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String user, String tableName, byte permission) throws org.apache.thrift.TException { - oprot_.writeMessageBegin(new org.apache.thrift.protocol.TMessage("grantTablePermission", org.apache.thrift.protocol.TMessageType.CALL, ++seqid_)); grantTablePermission_args args = new grantTablePermission_args(); args.setTinfo(tinfo); args.setCredentials(credentials); args.setUser(user); args.setTableName(tableName); args.setPermission(permission); - args.write(oprot_); - oprot_.writeMessageEnd(); - oprot_.getTransport().flush(); + sendBase("grantTablePermission", args); } public void recv_grantTablePermission() throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, ThriftTableOperationException, org.apache.thrift.TException { - org.apache.thrift.protocol.TMessage msg = iprot_.readMessageBegin(); - if (msg.type == org.apache.thrift.protocol.TMessageType.EXCEPTION) { - org.apache.thrift.TApplicationException x = org.apache.thrift.TApplicationException.read(iprot_); - iprot_.readMessageEnd(); - throw x; - } - if (msg.seqid != seqid_) { - throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.BAD_SEQUENCE_ID, "grantTablePermission failed: out of sequence response"); - } grantTablePermission_result result = new grantTablePermission_result(); - result.read(iprot_); - iprot_.readMessageEnd(); + receiveBase(result, "grantTablePermission"); if (result.sec != null) { throw result.sec; } @@ -877,32 +633,19 @@ import org.slf4j.LoggerFactory; public void send_revokeTablePermission(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String user, String tableName, byte permission) throws org.apache.thrift.TException { - oprot_.writeMessageBegin(new org.apache.thrift.protocol.TMessage("revokeTablePermission", org.apache.thrift.protocol.TMessageType.CALL, ++seqid_)); revokeTablePermission_args args = new revokeTablePermission_args(); args.setTinfo(tinfo); args.setCredentials(credentials); args.setUser(user); args.setTableName(tableName); args.setPermission(permission); - args.write(oprot_); - oprot_.writeMessageEnd(); - oprot_.getTransport().flush(); + sendBase("revokeTablePermission", args); } public void recv_revokeTablePermission() throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, ThriftTableOperationException, org.apache.thrift.TException { - org.apache.thrift.protocol.TMessage msg = iprot_.readMessageBegin(); - if (msg.type == org.apache.thrift.protocol.TMessageType.EXCEPTION) { - org.apache.thrift.TApplicationException x = org.apache.thrift.TApplicationException.read(iprot_); - iprot_.readMessageEnd(); - throw x; - } - if (msg.seqid != seqid_) { - throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.BAD_SEQUENCE_ID, "revokeTablePermission failed: out of sequence response"); - } revokeTablePermission_result result = new revokeTablePermission_result(); - result.read(iprot_); - iprot_.readMessageEnd(); + receiveBase(result, "revokeTablePermission"); if (result.sec != null) { throw result.sec; } @@ -920,28 +663,15 @@ import org.slf4j.LoggerFactory; public void send_getConfiguration(ConfigurationType type) throws org.apache.thrift.TException { - oprot_.writeMessageBegin(new org.apache.thrift.protocol.TMessage("getConfiguration", org.apache.thrift.protocol.TMessageType.CALL, ++seqid_)); getConfiguration_args args = new getConfiguration_args(); args.setType(type); - args.write(oprot_); - oprot_.writeMessageEnd(); - oprot_.getTransport().flush(); + sendBase("getConfiguration", args); } public Map recv_getConfiguration() throws org.apache.thrift.TException { - org.apache.thrift.protocol.TMessage msg = iprot_.readMessageBegin(); - if (msg.type == org.apache.thrift.protocol.TMessageType.EXCEPTION) { - org.apache.thrift.TApplicationException x = org.apache.thrift.TApplicationException.read(iprot_); - iprot_.readMessageEnd(); - throw x; - } - if (msg.seqid != seqid_) { - throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.BAD_SEQUENCE_ID, "getConfiguration failed: out of sequence response"); - } getConfiguration_result result = new getConfiguration_result(); - result.read(iprot_); - iprot_.readMessageEnd(); + receiveBase(result, "getConfiguration"); if (result.isSetSuccess()) { return result.success; } @@ -956,28 +686,15 @@ import org.slf4j.LoggerFactory; public void send_getTableConfiguration(String tableName) throws org.apache.thrift.TException { - oprot_.writeMessageBegin(new org.apache.thrift.protocol.TMessage("getTableConfiguration", org.apache.thrift.protocol.TMessageType.CALL, ++seqid_)); getTableConfiguration_args args = new getTableConfiguration_args(); args.setTableName(tableName); - args.write(oprot_); - oprot_.writeMessageEnd(); - oprot_.getTransport().flush(); + sendBase("getTableConfiguration", args); } public Map recv_getTableConfiguration() throws ThriftTableOperationException, org.apache.thrift.TException { - org.apache.thrift.protocol.TMessage msg = iprot_.readMessageBegin(); - if (msg.type == org.apache.thrift.protocol.TMessageType.EXCEPTION) { - org.apache.thrift.TApplicationException x = org.apache.thrift.TApplicationException.read(iprot_); - iprot_.readMessageEnd(); - throw x; - } - if (msg.seqid != seqid_) { - throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.BAD_SEQUENCE_ID, "getTableConfiguration failed: out of sequence response"); - } getTableConfiguration_result result = new getTableConfiguration_result(); - result.read(iprot_); - iprot_.readMessageEnd(); + receiveBase(result, "getTableConfiguration"); if (result.isSetSuccess()) { return result.success; } @@ -995,30 +712,17 @@ import org.slf4j.LoggerFactory; public void send_checkClass(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, String className, String interfaceMatch) throws org.apache.thrift.TException { - oprot_.writeMessageBegin(new org.apache.thrift.protocol.TMessage("checkClass", org.apache.thrift.protocol.TMessageType.CALL, ++seqid_)); checkClass_args args = new checkClass_args(); args.setTinfo(tinfo); args.setClassName(className); args.setInterfaceMatch(interfaceMatch); - args.write(oprot_); - oprot_.writeMessageEnd(); - oprot_.getTransport().flush(); + sendBase("checkClass", args); } public boolean recv_checkClass() throws org.apache.thrift.TException { - org.apache.thrift.protocol.TMessage msg = iprot_.readMessageBegin(); - if (msg.type == org.apache.thrift.protocol.TMessageType.EXCEPTION) { - org.apache.thrift.TApplicationException x = org.apache.thrift.TApplicationException.read(iprot_); - iprot_.readMessageEnd(); - throw x; - } - if (msg.seqid != seqid_) { - throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.BAD_SEQUENCE_ID, "checkClass failed: out of sequence response"); - } checkClass_result result = new checkClass_result(); - result.read(iprot_); - iprot_.readMessageEnd(); + receiveBase(result, "checkClass"); if (result.isSetSuccess()) { return result.success; } @@ -1045,9 +749,9 @@ import org.slf4j.LoggerFactory; public void getRootTabletLocation(org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { checkReady(); - getRootTabletLocation_call method_call = new getRootTabletLocation_call(resultHandler, this, protocolFactory, transport); - this.currentMethod = method_call; - manager.call(method_call); + getRootTabletLocation_call method_call = new getRootTabletLocation_call(resultHandler, this, ___protocolFactory, ___transport); + this.___currentMethod = method_call; + ___manager.call(method_call); } public static class getRootTabletLocation_call extends org.apache.thrift.async.TAsyncMethodCall { @@ -1074,9 +778,9 @@ import org.slf4j.LoggerFactory; public void getInstanceId(org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { checkReady(); - getInstanceId_call method_call = new getInstanceId_call(resultHandler, this, protocolFactory, transport); - this.currentMethod = method_call; - manager.call(method_call); + getInstanceId_call method_call = new getInstanceId_call(resultHandler, this, ___protocolFactory, ___transport); + this.___currentMethod = method_call; + ___manager.call(method_call); } public static class getInstanceId_call extends org.apache.thrift.async.TAsyncMethodCall { @@ -1103,9 +807,9 @@ import org.slf4j.LoggerFactory; public void getZooKeepers(org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { checkReady(); - getZooKeepers_call method_call = new getZooKeepers_call(resultHandler, this, protocolFactory, transport); - this.currentMethod = method_call; - manager.call(method_call); + getZooKeepers_call method_call = new getZooKeepers_call(resultHandler, this, ___protocolFactory, ___transport); + this.___currentMethod = method_call; + ___manager.call(method_call); } public static class getZooKeepers_call extends org.apache.thrift.async.TAsyncMethodCall { @@ -1132,9 +836,9 @@ import org.slf4j.LoggerFactory; public void bulkImportFiles(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, long tid, String tableId, List files, String errorDir, boolean setTime, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { checkReady(); - bulkImportFiles_call method_call = new bulkImportFiles_call(tinfo, credentials, tid, tableId, files, errorDir, setTime, resultHandler, this, protocolFactory, transport); - this.currentMethod = method_call; - manager.call(method_call); + bulkImportFiles_call method_call = new bulkImportFiles_call(tinfo, credentials, tid, tableId, files, errorDir, setTime, resultHandler, this, ___protocolFactory, ___transport); + this.___currentMethod = method_call; + ___manager.call(method_call); } public static class bulkImportFiles_call extends org.apache.thrift.async.TAsyncMethodCall { @@ -1182,9 +886,9 @@ import org.slf4j.LoggerFactory; public void isActive(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, long tid, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { checkReady(); - isActive_call method_call = new isActive_call(tinfo, tid, resultHandler, this, protocolFactory, transport); - this.currentMethod = method_call; - manager.call(method_call); + isActive_call method_call = new isActive_call(tinfo, tid, resultHandler, this, ___protocolFactory, ___transport); + this.___currentMethod = method_call; + ___manager.call(method_call); } public static class isActive_call extends org.apache.thrift.async.TAsyncMethodCall { @@ -1217,9 +921,9 @@ import org.slf4j.LoggerFactory; public void ping(org.apache.accumulo.core.security.thrift.AuthInfo credentials, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { checkReady(); - ping_call method_call = new ping_call(credentials, resultHandler, this, protocolFactory, transport); - this.currentMethod = method_call; - manager.call(method_call); + ping_call method_call = new ping_call(credentials, resultHandler, this, ___protocolFactory, ___transport); + this.___currentMethod = method_call; + ___manager.call(method_call); } public static class ping_call extends org.apache.thrift.async.TAsyncMethodCall { @@ -1249,9 +953,9 @@ import org.slf4j.LoggerFactory; public void authenticateUser(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String user, ByteBuffer password, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { checkReady(); - authenticateUser_call method_call = new authenticateUser_call(tinfo, credentials, user, password, resultHandler, this, protocolFactory, transport); - this.currentMethod = method_call; - manager.call(method_call); + authenticateUser_call method_call = new authenticateUser_call(tinfo, credentials, user, password, resultHandler, this, ___protocolFactory, ___transport); + this.___currentMethod = method_call; + ___manager.call(method_call); } public static class authenticateUser_call extends org.apache.thrift.async.TAsyncMethodCall { @@ -1290,9 +994,9 @@ import org.slf4j.LoggerFactory; public void listUsers(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { checkReady(); - listUsers_call method_call = new listUsers_call(tinfo, credentials, resultHandler, this, protocolFactory, transport); - this.currentMethod = method_call; - manager.call(method_call); + listUsers_call method_call = new listUsers_call(tinfo, credentials, resultHandler, this, ___protocolFactory, ___transport); + this.___currentMethod = method_call; + ___manager.call(method_call); } public static class listUsers_call extends org.apache.thrift.async.TAsyncMethodCall { @@ -1325,9 +1029,9 @@ import org.slf4j.LoggerFactory; public void createUser(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String user, ByteBuffer password, List authorizations, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { checkReady(); - createUser_call method_call = new createUser_call(tinfo, credentials, user, password, authorizations, resultHandler, this, protocolFactory, transport); - this.currentMethod = method_call; - manager.call(method_call); + createUser_call method_call = new createUser_call(tinfo, credentials, user, password, authorizations, resultHandler, this, ___protocolFactory, ___transport); + this.___currentMethod = method_call; + ___manager.call(method_call); } public static class createUser_call extends org.apache.thrift.async.TAsyncMethodCall { @@ -1369,9 +1073,9 @@ import org.slf4j.LoggerFactory; public void dropUser(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String user, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { checkReady(); - dropUser_call method_call = new dropUser_call(tinfo, credentials, user, resultHandler, this, protocolFactory, transport); - this.currentMethod = method_call; - manager.call(method_call); + dropUser_call method_call = new dropUser_call(tinfo, credentials, user, resultHandler, this, ___protocolFactory, ___transport); + this.___currentMethod = method_call; + ___manager.call(method_call); } public static class dropUser_call extends org.apache.thrift.async.TAsyncMethodCall { @@ -1407,9 +1111,9 @@ import org.slf4j.LoggerFactory; public void changePassword(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String user, ByteBuffer password, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { checkReady(); - changePassword_call method_call = new changePassword_call(tinfo, credentials, user, password, resultHandler, this, protocolFactory, transport); - this.currentMethod = method_call; - manager.call(method_call); + changePassword_call method_call = new changePassword_call(tinfo, credentials, user, password, resultHandler, this, ___protocolFactory, ___transport); + this.___currentMethod = method_call; + ___manager.call(method_call); } public static class changePassword_call extends org.apache.thrift.async.TAsyncMethodCall { @@ -1448,9 +1152,9 @@ import org.slf4j.LoggerFactory; public void changeAuthorizations(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String user, List authorizations, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { checkReady(); - changeAuthorizations_call method_call = new changeAuthorizations_call(tinfo, credentials, user, authorizations, resultHandler, this, protocolFactory, transport); - this.currentMethod = method_call; - manager.call(method_call); + changeAuthorizations_call method_call = new changeAuthorizations_call(tinfo, credentials, user, authorizations, resultHandler, this, ___protocolFactory, ___transport); + this.___currentMethod = method_call; + ___manager.call(method_call); } public static class changeAuthorizations_call extends org.apache.thrift.async.TAsyncMethodCall { @@ -1489,9 +1193,9 @@ import org.slf4j.LoggerFactory; public void getUserAuthorizations(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String user, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { checkReady(); - getUserAuthorizations_call method_call = new getUserAuthorizations_call(tinfo, credentials, user, resultHandler, this, protocolFactory, transport); - this.currentMethod = method_call; - manager.call(method_call); + getUserAuthorizations_call method_call = new getUserAuthorizations_call(tinfo, credentials, user, resultHandler, this, ___protocolFactory, ___transport); + this.___currentMethod = method_call; + ___manager.call(method_call); } public static class getUserAuthorizations_call extends org.apache.thrift.async.TAsyncMethodCall { @@ -1527,9 +1231,9 @@ import org.slf4j.LoggerFactory; public void hasSystemPermission(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String user, byte sysPerm, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { checkReady(); - hasSystemPermission_call method_call = new hasSystemPermission_call(tinfo, credentials, user, sysPerm, resultHandler, this, protocolFactory, transport); - this.currentMethod = method_call; - manager.call(method_call); + hasSystemPermission_call method_call = new hasSystemPermission_call(tinfo, credentials, user, sysPerm, resultHandler, this, ___protocolFactory, ___transport); + this.___currentMethod = method_call; + ___manager.call(method_call); } public static class hasSystemPermission_call extends org.apache.thrift.async.TAsyncMethodCall { @@ -1568,9 +1272,9 @@ import org.slf4j.LoggerFactory; public void hasTablePermission(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String user, String tableName, byte tblPerm, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { checkReady(); - hasTablePermission_call method_call = new hasTablePermission_call(tinfo, credentials, user, tableName, tblPerm, resultHandler, this, protocolFactory, transport); - this.currentMethod = method_call; - manager.call(method_call); + hasTablePermission_call method_call = new hasTablePermission_call(tinfo, credentials, user, tableName, tblPerm, resultHandler, this, ___protocolFactory, ___transport); + this.___currentMethod = method_call; + ___manager.call(method_call); } public static class hasTablePermission_call extends org.apache.thrift.async.TAsyncMethodCall { @@ -1612,9 +1316,9 @@ import org.slf4j.LoggerFactory; public void grantSystemPermission(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String user, byte permission, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { checkReady(); - grantSystemPermission_call method_call = new grantSystemPermission_call(tinfo, credentials, user, permission, resultHandler, this, protocolFactory, transport); - this.currentMethod = method_call; - manager.call(method_call); + grantSystemPermission_call method_call = new grantSystemPermission_call(tinfo, credentials, user, permission, resultHandler, this, ___protocolFactory, ___transport); + this.___currentMethod = method_call; + ___manager.call(method_call); } public static class grantSystemPermission_call extends org.apache.thrift.async.TAsyncMethodCall { @@ -1653,9 +1357,9 @@ import org.slf4j.LoggerFactory; public void revokeSystemPermission(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String user, byte permission, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { checkReady(); - revokeSystemPermission_call method_call = new revokeSystemPermission_call(tinfo, credentials, user, permission, resultHandler, this, protocolFactory, transport); - this.currentMethod = method_call; - manager.call(method_call); + revokeSystemPermission_call method_call = new revokeSystemPermission_call(tinfo, credentials, user, permission, resultHandler, this, ___protocolFactory, ___transport); + this.___currentMethod = method_call; + ___manager.call(method_call); } public static class revokeSystemPermission_call extends org.apache.thrift.async.TAsyncMethodCall { @@ -1694,9 +1398,9 @@ import org.slf4j.LoggerFactory; public void grantTablePermission(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String user, String tableName, byte permission, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { checkReady(); - grantTablePermission_call method_call = new grantTablePermission_call(tinfo, credentials, user, tableName, permission, resultHandler, this, protocolFactory, transport); - this.currentMethod = method_call; - manager.call(method_call); + grantTablePermission_call method_call = new grantTablePermission_call(tinfo, credentials, user, tableName, permission, resultHandler, this, ___protocolFactory, ___transport); + this.___currentMethod = method_call; + ___manager.call(method_call); } public static class grantTablePermission_call extends org.apache.thrift.async.TAsyncMethodCall { @@ -1738,9 +1442,9 @@ import org.slf4j.LoggerFactory; public void revokeTablePermission(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String user, String tableName, byte permission, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { checkReady(); - revokeTablePermission_call method_call = new revokeTablePermission_call(tinfo, credentials, user, tableName, permission, resultHandler, this, protocolFactory, transport); - this.currentMethod = method_call; - manager.call(method_call); + revokeTablePermission_call method_call = new revokeTablePermission_call(tinfo, credentials, user, tableName, permission, resultHandler, this, ___protocolFactory, ___transport); + this.___currentMethod = method_call; + ___manager.call(method_call); } public static class revokeTablePermission_call extends org.apache.thrift.async.TAsyncMethodCall { @@ -1782,9 +1486,9 @@ import org.slf4j.LoggerFactory; public void getConfiguration(ConfigurationType type, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { checkReady(); - getConfiguration_call method_call = new getConfiguration_call(type, resultHandler, this, protocolFactory, transport); - this.currentMethod = method_call; - manager.call(method_call); + getConfiguration_call method_call = new getConfiguration_call(type, resultHandler, this, ___protocolFactory, ___transport); + this.___currentMethod = method_call; + ___manager.call(method_call); } public static class getConfiguration_call extends org.apache.thrift.async.TAsyncMethodCall { @@ -1814,9 +1518,9 @@ import org.slf4j.LoggerFactory; public void getTableConfiguration(String tableName, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { checkReady(); - getTableConfiguration_call method_call = new getTableConfiguration_call(tableName, resultHandler, this, protocolFactory, transport); - this.currentMethod = method_call; - manager.call(method_call); + getTableConfiguration_call method_call = new getTableConfiguration_call(tableName, resultHandler, this, ___protocolFactory, ___transport); + this.___currentMethod = method_call; + ___manager.call(method_call); } public static class getTableConfiguration_call extends org.apache.thrift.async.TAsyncMethodCall { @@ -1846,9 +1550,9 @@ import org.slf4j.LoggerFactory; public void checkClass(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, String className, String interfaceMatch, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { checkReady(); - checkClass_call method_call = new checkClass_call(tinfo, className, interfaceMatch, resultHandler, this, protocolFactory, transport); - this.currentMethod = method_call; - manager.call(method_call); + checkClass_call method_call = new checkClass_call(tinfo, className, interfaceMatch, resultHandler, this, ___protocolFactory, ___transport); + this.___currentMethod = method_call; + ___manager.call(method_call); } public static class checkClass_call extends org.apache.thrift.async.TAsyncMethodCall { @@ -1884,835 +1588,469 @@ import org.slf4j.LoggerFactory; } - public static class Processor implements org.apache.thrift.TProcessor { + public static class Processor extends org.apache.thrift.TBaseProcessor implements org.apache.thrift.TProcessor { private static final Logger LOGGER = LoggerFactory.getLogger(Processor.class.getName()); - public Processor(Iface iface) - { - iface_ = iface; - processMap_.put("getRootTabletLocation", new getRootTabletLocation()); - processMap_.put("getInstanceId", new getInstanceId()); - processMap_.put("getZooKeepers", new getZooKeepers()); - processMap_.put("bulkImportFiles", new bulkImportFiles()); - processMap_.put("isActive", new isActive()); - processMap_.put("ping", new ping()); - processMap_.put("authenticateUser", new authenticateUser()); - processMap_.put("listUsers", new listUsers()); - processMap_.put("createUser", new createUser()); - processMap_.put("dropUser", new dropUser()); - processMap_.put("changePassword", new changePassword()); - processMap_.put("changeAuthorizations", new changeAuthorizations()); - processMap_.put("getUserAuthorizations", new getUserAuthorizations()); - processMap_.put("hasSystemPermission", new hasSystemPermission()); - processMap_.put("hasTablePermission", new hasTablePermission()); - processMap_.put("grantSystemPermission", new grantSystemPermission()); - processMap_.put("revokeSystemPermission", new revokeSystemPermission()); - processMap_.put("grantTablePermission", new grantTablePermission()); - processMap_.put("revokeTablePermission", new revokeTablePermission()); - processMap_.put("getConfiguration", new getConfiguration()); - processMap_.put("getTableConfiguration", new getTableConfiguration()); - processMap_.put("checkClass", new checkClass()); - } - - protected static interface ProcessFunction { - public void process(int seqid, org.apache.thrift.protocol.TProtocol iprot, org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException; - } - - private Iface iface_; - protected final HashMap processMap_ = new HashMap(); - - public boolean process(org.apache.thrift.protocol.TProtocol iprot, org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException - { - org.apache.thrift.protocol.TMessage msg = iprot.readMessageBegin(); - ProcessFunction fn = processMap_.get(msg.name); - if (fn == null) { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, org.apache.thrift.protocol.TType.STRUCT); - iprot.readMessageEnd(); - org.apache.thrift.TApplicationException x = new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.UNKNOWN_METHOD, "Invalid method name: '"+msg.name+"'"); - oprot.writeMessageBegin(new org.apache.thrift.protocol.TMessage(msg.name, org.apache.thrift.protocol.TMessageType.EXCEPTION, msg.seqid)); - x.write(oprot); - oprot.writeMessageEnd(); - oprot.getTransport().flush(); - return true; - } - fn.process(msg.seqid, iprot, oprot); - return true; + public Processor(I iface) { + super(iface, getProcessMap(new HashMap>())); } - private class getRootTabletLocation implements ProcessFunction { - public void process(int seqid, org.apache.thrift.protocol.TProtocol iprot, org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException - { - getRootTabletLocation_args args = new getRootTabletLocation_args(); - try { - args.read(iprot); - } catch (org.apache.thrift.protocol.TProtocolException e) { - iprot.readMessageEnd(); - org.apache.thrift.TApplicationException x = new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.PROTOCOL_ERROR, e.getMessage()); - oprot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("getRootTabletLocation", org.apache.thrift.protocol.TMessageType.EXCEPTION, seqid)); - x.write(oprot); - oprot.writeMessageEnd(); - oprot.getTransport().flush(); - return; - } - iprot.readMessageEnd(); - getRootTabletLocation_result result = new getRootTabletLocation_result(); - result.success = iface_.getRootTabletLocation(); - oprot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("getRootTabletLocation", org.apache.thrift.protocol.TMessageType.REPLY, seqid)); - result.write(oprot); - oprot.writeMessageEnd(); - oprot.getTransport().flush(); + protected Processor(I iface, Map> processMap) { + super(iface, getProcessMap(processMap)); + } + + private static Map> getProcessMap(Map> processMap) { + processMap.put("getRootTabletLocation", new getRootTabletLocation()); + processMap.put("getInstanceId", new getInstanceId()); + processMap.put("getZooKeepers", new getZooKeepers()); + processMap.put("bulkImportFiles", new bulkImportFiles()); + processMap.put("isActive", new isActive()); + processMap.put("ping", new ping()); + processMap.put("authenticateUser", new authenticateUser()); + processMap.put("listUsers", new listUsers()); + processMap.put("createUser", new createUser()); + processMap.put("dropUser", new dropUser()); + processMap.put("changePassword", new changePassword()); + processMap.put("changeAuthorizations", new changeAuthorizations()); + processMap.put("getUserAuthorizations", new getUserAuthorizations()); + processMap.put("hasSystemPermission", new hasSystemPermission()); + processMap.put("hasTablePermission", new hasTablePermission()); + processMap.put("grantSystemPermission", new grantSystemPermission()); + processMap.put("revokeSystemPermission", new revokeSystemPermission()); + processMap.put("grantTablePermission", new grantTablePermission()); + processMap.put("revokeTablePermission", new revokeTablePermission()); + processMap.put("getConfiguration", new getConfiguration()); + processMap.put("getTableConfiguration", new getTableConfiguration()); + processMap.put("checkClass", new checkClass()); + return processMap; + } + + private static class getRootTabletLocation extends org.apache.thrift.ProcessFunction { + public getRootTabletLocation() { + super("getRootTabletLocation"); + } + + protected getRootTabletLocation_args getEmptyArgsInstance() { + return new getRootTabletLocation_args(); } + protected getRootTabletLocation_result getResult(I iface, getRootTabletLocation_args args) throws org.apache.thrift.TException { + getRootTabletLocation_result result = new getRootTabletLocation_result(); + result.success = iface.getRootTabletLocation(); + return result; + } } - private class getInstanceId implements ProcessFunction { - public void process(int seqid, org.apache.thrift.protocol.TProtocol iprot, org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException - { - getInstanceId_args args = new getInstanceId_args(); - try { - args.read(iprot); - } catch (org.apache.thrift.protocol.TProtocolException e) { - iprot.readMessageEnd(); - org.apache.thrift.TApplicationException x = new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.PROTOCOL_ERROR, e.getMessage()); - oprot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("getInstanceId", org.apache.thrift.protocol.TMessageType.EXCEPTION, seqid)); - x.write(oprot); - oprot.writeMessageEnd(); - oprot.getTransport().flush(); - return; - } - iprot.readMessageEnd(); - getInstanceId_result result = new getInstanceId_result(); - result.success = iface_.getInstanceId(); - oprot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("getInstanceId", org.apache.thrift.protocol.TMessageType.REPLY, seqid)); - result.write(oprot); - oprot.writeMessageEnd(); - oprot.getTransport().flush(); + private static class getInstanceId extends org.apache.thrift.ProcessFunction { + public getInstanceId() { + super("getInstanceId"); + } + + protected getInstanceId_args getEmptyArgsInstance() { + return new getInstanceId_args(); } + protected getInstanceId_result getResult(I iface, getInstanceId_args args) throws org.apache.thrift.TException { + getInstanceId_result result = new getInstanceId_result(); + result.success = iface.getInstanceId(); + return result; + } } - private class getZooKeepers implements ProcessFunction { - public void process(int seqid, org.apache.thrift.protocol.TProtocol iprot, org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException - { - getZooKeepers_args args = new getZooKeepers_args(); - try { - args.read(iprot); - } catch (org.apache.thrift.protocol.TProtocolException e) { - iprot.readMessageEnd(); - org.apache.thrift.TApplicationException x = new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.PROTOCOL_ERROR, e.getMessage()); - oprot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("getZooKeepers", org.apache.thrift.protocol.TMessageType.EXCEPTION, seqid)); - x.write(oprot); - oprot.writeMessageEnd(); - oprot.getTransport().flush(); - return; - } - iprot.readMessageEnd(); - getZooKeepers_result result = new getZooKeepers_result(); - result.success = iface_.getZooKeepers(); - oprot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("getZooKeepers", org.apache.thrift.protocol.TMessageType.REPLY, seqid)); - result.write(oprot); - oprot.writeMessageEnd(); - oprot.getTransport().flush(); + private static class getZooKeepers extends org.apache.thrift.ProcessFunction { + public getZooKeepers() { + super("getZooKeepers"); + } + + protected getZooKeepers_args getEmptyArgsInstance() { + return new getZooKeepers_args(); } + protected getZooKeepers_result getResult(I iface, getZooKeepers_args args) throws org.apache.thrift.TException { + getZooKeepers_result result = new getZooKeepers_result(); + result.success = iface.getZooKeepers(); + return result; + } } - private class bulkImportFiles implements ProcessFunction { - public void process(int seqid, org.apache.thrift.protocol.TProtocol iprot, org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException - { - bulkImportFiles_args args = new bulkImportFiles_args(); - try { - args.read(iprot); - } catch (org.apache.thrift.protocol.TProtocolException e) { - iprot.readMessageEnd(); - org.apache.thrift.TApplicationException x = new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.PROTOCOL_ERROR, e.getMessage()); - oprot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("bulkImportFiles", org.apache.thrift.protocol.TMessageType.EXCEPTION, seqid)); - x.write(oprot); - oprot.writeMessageEnd(); - oprot.getTransport().flush(); - return; - } - iprot.readMessageEnd(); + private static class bulkImportFiles extends org.apache.thrift.ProcessFunction { + public bulkImportFiles() { + super("bulkImportFiles"); + } + + protected bulkImportFiles_args getEmptyArgsInstance() { + return new bulkImportFiles_args(); + } + + protected bulkImportFiles_result getResult(I iface, bulkImportFiles_args args) throws org.apache.thrift.TException { bulkImportFiles_result result = new bulkImportFiles_result(); try { - result.success = iface_.bulkImportFiles(args.tinfo, args.credentials, args.tid, args.tableId, args.files, args.errorDir, args.setTime); + result.success = iface.bulkImportFiles(args.tinfo, args.credentials, args.tid, args.tableId, args.files, args.errorDir, args.setTime); } catch (org.apache.accumulo.core.security.thrift.ThriftSecurityException sec) { result.sec = sec; } catch (ThriftTableOperationException tope) { result.tope = tope; - } catch (Throwable th) { - LOGGER.error("Internal error processing bulkImportFiles", th); - org.apache.thrift.TApplicationException x = new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, "Internal error processing bulkImportFiles"); - oprot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("bulkImportFiles", org.apache.thrift.protocol.TMessageType.EXCEPTION, seqid)); - x.write(oprot); - oprot.writeMessageEnd(); - oprot.getTransport().flush(); - return; - } - oprot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("bulkImportFiles", org.apache.thrift.protocol.TMessageType.REPLY, seqid)); - result.write(oprot); - oprot.writeMessageEnd(); - oprot.getTransport().flush(); + } + return result; } - } - private class isActive implements ProcessFunction { - public void process(int seqid, org.apache.thrift.protocol.TProtocol iprot, org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException - { - isActive_args args = new isActive_args(); - try { - args.read(iprot); - } catch (org.apache.thrift.protocol.TProtocolException e) { - iprot.readMessageEnd(); - org.apache.thrift.TApplicationException x = new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.PROTOCOL_ERROR, e.getMessage()); - oprot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("isActive", org.apache.thrift.protocol.TMessageType.EXCEPTION, seqid)); - x.write(oprot); - oprot.writeMessageEnd(); - oprot.getTransport().flush(); - return; - } - iprot.readMessageEnd(); + private static class isActive extends org.apache.thrift.ProcessFunction { + public isActive() { + super("isActive"); + } + + protected isActive_args getEmptyArgsInstance() { + return new isActive_args(); + } + + protected isActive_result getResult(I iface, isActive_args args) throws org.apache.thrift.TException { isActive_result result = new isActive_result(); - result.success = iface_.isActive(args.tinfo, args.tid); + result.success = iface.isActive(args.tinfo, args.tid); result.setSuccessIsSet(true); - oprot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("isActive", org.apache.thrift.protocol.TMessageType.REPLY, seqid)); - result.write(oprot); - oprot.writeMessageEnd(); - oprot.getTransport().flush(); + return result; } - } - private class ping implements ProcessFunction { - public void process(int seqid, org.apache.thrift.protocol.TProtocol iprot, org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException - { - ping_args args = new ping_args(); - try { - args.read(iprot); - } catch (org.apache.thrift.protocol.TProtocolException e) { - iprot.readMessageEnd(); - org.apache.thrift.TApplicationException x = new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.PROTOCOL_ERROR, e.getMessage()); - oprot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("ping", org.apache.thrift.protocol.TMessageType.EXCEPTION, seqid)); - x.write(oprot); - oprot.writeMessageEnd(); - oprot.getTransport().flush(); - return; - } - iprot.readMessageEnd(); + private static class ping extends org.apache.thrift.ProcessFunction { + public ping() { + super("ping"); + } + + protected ping_args getEmptyArgsInstance() { + return new ping_args(); + } + + protected ping_result getResult(I iface, ping_args args) throws org.apache.thrift.TException { ping_result result = new ping_result(); try { - iface_.ping(args.credentials); + iface.ping(args.credentials); } catch (org.apache.accumulo.core.security.thrift.ThriftSecurityException sec) { result.sec = sec; - } catch (Throwable th) { - LOGGER.error("Internal error processing ping", th); - org.apache.thrift.TApplicationException x = new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, "Internal error processing ping"); - oprot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("ping", org.apache.thrift.protocol.TMessageType.EXCEPTION, seqid)); - x.write(oprot); - oprot.writeMessageEnd(); - oprot.getTransport().flush(); - return; - } - oprot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("ping", org.apache.thrift.protocol.TMessageType.REPLY, seqid)); - result.write(oprot); - oprot.writeMessageEnd(); - oprot.getTransport().flush(); + } + return result; } - } - private class authenticateUser implements ProcessFunction { - public void process(int seqid, org.apache.thrift.protocol.TProtocol iprot, org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException - { - authenticateUser_args args = new authenticateUser_args(); - try { - args.read(iprot); - } catch (org.apache.thrift.protocol.TProtocolException e) { - iprot.readMessageEnd(); - org.apache.thrift.TApplicationException x = new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.PROTOCOL_ERROR, e.getMessage()); - oprot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("authenticateUser", org.apache.thrift.protocol.TMessageType.EXCEPTION, seqid)); - x.write(oprot); - oprot.writeMessageEnd(); - oprot.getTransport().flush(); - return; - } - iprot.readMessageEnd(); + private static class authenticateUser extends org.apache.thrift.ProcessFunction { + public authenticateUser() { + super("authenticateUser"); + } + + protected authenticateUser_args getEmptyArgsInstance() { + return new authenticateUser_args(); + } + + protected authenticateUser_result getResult(I iface, authenticateUser_args args) throws org.apache.thrift.TException { authenticateUser_result result = new authenticateUser_result(); try { - result.success = iface_.authenticateUser(args.tinfo, args.credentials, args.user, args.password); + result.success = iface.authenticateUser(args.tinfo, args.credentials, args.user, args.password); result.setSuccessIsSet(true); } catch (org.apache.accumulo.core.security.thrift.ThriftSecurityException sec) { result.sec = sec; - } catch (Throwable th) { - LOGGER.error("Internal error processing authenticateUser", th); - org.apache.thrift.TApplicationException x = new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, "Internal error processing authenticateUser"); - oprot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("authenticateUser", org.apache.thrift.protocol.TMessageType.EXCEPTION, seqid)); - x.write(oprot); - oprot.writeMessageEnd(); - oprot.getTransport().flush(); - return; - } - oprot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("authenticateUser", org.apache.thrift.protocol.TMessageType.REPLY, seqid)); - result.write(oprot); - oprot.writeMessageEnd(); - oprot.getTransport().flush(); + } + return result; } - } - private class listUsers implements ProcessFunction { - public void process(int seqid, org.apache.thrift.protocol.TProtocol iprot, org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException - { - listUsers_args args = new listUsers_args(); - try { - args.read(iprot); - } catch (org.apache.thrift.protocol.TProtocolException e) { - iprot.readMessageEnd(); - org.apache.thrift.TApplicationException x = new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.PROTOCOL_ERROR, e.getMessage()); - oprot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("listUsers", org.apache.thrift.protocol.TMessageType.EXCEPTION, seqid)); - x.write(oprot); - oprot.writeMessageEnd(); - oprot.getTransport().flush(); - return; - } - iprot.readMessageEnd(); + private static class listUsers extends org.apache.thrift.ProcessFunction { + public listUsers() { + super("listUsers"); + } + + protected listUsers_args getEmptyArgsInstance() { + return new listUsers_args(); + } + + protected listUsers_result getResult(I iface, listUsers_args args) throws org.apache.thrift.TException { listUsers_result result = new listUsers_result(); try { - result.success = iface_.listUsers(args.tinfo, args.credentials); + result.success = iface.listUsers(args.tinfo, args.credentials); } catch (org.apache.accumulo.core.security.thrift.ThriftSecurityException sec) { result.sec = sec; - } catch (Throwable th) { - LOGGER.error("Internal error processing listUsers", th); - org.apache.thrift.TApplicationException x = new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, "Internal error processing listUsers"); - oprot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("listUsers", org.apache.thrift.protocol.TMessageType.EXCEPTION, seqid)); - x.write(oprot); - oprot.writeMessageEnd(); - oprot.getTransport().flush(); - return; - } - oprot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("listUsers", org.apache.thrift.protocol.TMessageType.REPLY, seqid)); - result.write(oprot); - oprot.writeMessageEnd(); - oprot.getTransport().flush(); + } + return result; } - } - private class createUser implements ProcessFunction { - public void process(int seqid, org.apache.thrift.protocol.TProtocol iprot, org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException - { - createUser_args args = new createUser_args(); - try { - args.read(iprot); - } catch (org.apache.thrift.protocol.TProtocolException e) { - iprot.readMessageEnd(); - org.apache.thrift.TApplicationException x = new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.PROTOCOL_ERROR, e.getMessage()); - oprot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("createUser", org.apache.thrift.protocol.TMessageType.EXCEPTION, seqid)); - x.write(oprot); - oprot.writeMessageEnd(); - oprot.getTransport().flush(); - return; - } - iprot.readMessageEnd(); + private static class createUser extends org.apache.thrift.ProcessFunction { + public createUser() { + super("createUser"); + } + + protected createUser_args getEmptyArgsInstance() { + return new createUser_args(); + } + + protected createUser_result getResult(I iface, createUser_args args) throws org.apache.thrift.TException { createUser_result result = new createUser_result(); try { - iface_.createUser(args.tinfo, args.credentials, args.user, args.password, args.authorizations); + iface.createUser(args.tinfo, args.credentials, args.user, args.password, args.authorizations); } catch (org.apache.accumulo.core.security.thrift.ThriftSecurityException sec) { result.sec = sec; - } catch (Throwable th) { - LOGGER.error("Internal error processing createUser", th); - org.apache.thrift.TApplicationException x = new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, "Internal error processing createUser"); - oprot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("createUser", org.apache.thrift.protocol.TMessageType.EXCEPTION, seqid)); - x.write(oprot); - oprot.writeMessageEnd(); - oprot.getTransport().flush(); - return; - } - oprot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("createUser", org.apache.thrift.protocol.TMessageType.REPLY, seqid)); - result.write(oprot); - oprot.writeMessageEnd(); - oprot.getTransport().flush(); + } + return result; } - } - private class dropUser implements ProcessFunction { - public void process(int seqid, org.apache.thrift.protocol.TProtocol iprot, org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException - { - dropUser_args args = new dropUser_args(); - try { - args.read(iprot); - } catch (org.apache.thrift.protocol.TProtocolException e) { - iprot.readMessageEnd(); - org.apache.thrift.TApplicationException x = new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.PROTOCOL_ERROR, e.getMessage()); - oprot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("dropUser", org.apache.thrift.protocol.TMessageType.EXCEPTION, seqid)); - x.write(oprot); - oprot.writeMessageEnd(); - oprot.getTransport().flush(); - return; - } - iprot.readMessageEnd(); + private static class dropUser extends org.apache.thrift.ProcessFunction { + public dropUser() { + super("dropUser"); + } + + protected dropUser_args getEmptyArgsInstance() { + return new dropUser_args(); + } + + protected dropUser_result getResult(I iface, dropUser_args args) throws org.apache.thrift.TException { dropUser_result result = new dropUser_result(); try { - iface_.dropUser(args.tinfo, args.credentials, args.user); + iface.dropUser(args.tinfo, args.credentials, args.user); } catch (org.apache.accumulo.core.security.thrift.ThriftSecurityException sec) { result.sec = sec; - } catch (Throwable th) { - LOGGER.error("Internal error processing dropUser", th); - org.apache.thrift.TApplicationException x = new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, "Internal error processing dropUser"); - oprot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("dropUser", org.apache.thrift.protocol.TMessageType.EXCEPTION, seqid)); - x.write(oprot); - oprot.writeMessageEnd(); - oprot.getTransport().flush(); - return; - } - oprot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("dropUser", org.apache.thrift.protocol.TMessageType.REPLY, seqid)); - result.write(oprot); - oprot.writeMessageEnd(); - oprot.getTransport().flush(); + } + return result; } - } - private class changePassword implements ProcessFunction { - public void process(int seqid, org.apache.thrift.protocol.TProtocol iprot, org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException - { - changePassword_args args = new changePassword_args(); - try { - args.read(iprot); - } catch (org.apache.thrift.protocol.TProtocolException e) { - iprot.readMessageEnd(); - org.apache.thrift.TApplicationException x = new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.PROTOCOL_ERROR, e.getMessage()); - oprot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("changePassword", org.apache.thrift.protocol.TMessageType.EXCEPTION, seqid)); - x.write(oprot); - oprot.writeMessageEnd(); - oprot.getTransport().flush(); - return; - } - iprot.readMessageEnd(); + private static class changePassword extends org.apache.thrift.ProcessFunction { + public changePassword() { + super("changePassword"); + } + + protected changePassword_args getEmptyArgsInstance() { + return new changePassword_args(); + } + + protected changePassword_result getResult(I iface, changePassword_args args) throws org.apache.thrift.TException { changePassword_result result = new changePassword_result(); try { - iface_.changePassword(args.tinfo, args.credentials, args.user, args.password); + iface.changePassword(args.tinfo, args.credentials, args.user, args.password); } catch (org.apache.accumulo.core.security.thrift.ThriftSecurityException sec) { result.sec = sec; - } catch (Throwable th) { - LOGGER.error("Internal error processing changePassword", th); - org.apache.thrift.TApplicationException x = new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, "Internal error processing changePassword"); - oprot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("changePassword", org.apache.thrift.protocol.TMessageType.EXCEPTION, seqid)); - x.write(oprot); - oprot.writeMessageEnd(); - oprot.getTransport().flush(); - return; - } - oprot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("changePassword", org.apache.thrift.protocol.TMessageType.REPLY, seqid)); - result.write(oprot); - oprot.writeMessageEnd(); - oprot.getTransport().flush(); + } + return result; } - } - private class changeAuthorizations implements ProcessFunction { - public void process(int seqid, org.apache.thrift.protocol.TProtocol iprot, org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException - { - changeAuthorizations_args args = new changeAuthorizations_args(); - try { - args.read(iprot); [... 10539 lines stripped ...]