You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@accumulo.apache.org by ec...@apache.org on 2012/07/10 14:39:55 UTC
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/...
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<Client> {
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<String> 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<String> 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<String> 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<ByteBuffer> 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<ByteBuffer> 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<ByteBuffer> 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<String,String> 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<String,String> 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<getRootTabletLocation_call> 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<getInstanceId_call> 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<getZooKeepers_call> 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<String> files, String errorDir, boolean setTime, org.apache.thrift.async.AsyncMethodCallback<bulkImportFiles_call> 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<isActive_call> 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<ping_call> 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<authenticateUser_call> 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<listUsers_call> 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<ByteBuffer> authorizations, org.apache.thrift.async.AsyncMethodCallback<createUser_call> 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<dropUser_call> 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<changePassword_call> 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<ByteBuffer> authorizations, org.apache.thrift.async.AsyncMethodCallback<changeAuthorizations_call> 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<getUserAuthorizations_call> 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<hasSystemPermission_call> 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<hasTablePermission_call> 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<grantSystemPermission_call> 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<revokeSystemPermission_call> 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<grantTablePermission_call> 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<revokeTablePermission_call> 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<getConfiguration_call> 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<getTableConfiguration_call> 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<checkClass_call> 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<I extends Iface> extends org.apache.thrift.TBaseProcessor<I> 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<String,ProcessFunction> processMap_ = new HashMap<String,ProcessFunction>();
-
- 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<String, org.apache.thrift.ProcessFunction<I, ? extends org.apache.thrift.TBase>>()));
}
- 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<String, org.apache.thrift.ProcessFunction<I, ? extends org.apache.thrift.TBase>> processMap) {
+ super(iface, getProcessMap(processMap));
+ }
+
+ private static <I extends Iface> Map<String, org.apache.thrift.ProcessFunction<I, ? extends org.apache.thrift.TBase>> getProcessMap(Map<String, org.apache.thrift.ProcessFunction<I, ? extends org.apache.thrift.TBase>> processMap) {
+ processMap.put("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<I extends Iface> extends org.apache.thrift.ProcessFunction<I, getRootTabletLocation_args> {
+ 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<I extends Iface> extends org.apache.thrift.ProcessFunction<I, getInstanceId_args> {
+ 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<I extends Iface> extends org.apache.thrift.ProcessFunction<I, getZooKeepers_args> {
+ 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<I extends Iface> extends org.apache.thrift.ProcessFunction<I, bulkImportFiles_args> {
+ 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<I extends Iface> extends org.apache.thrift.ProcessFunction<I, isActive_args> {
+ 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<I extends Iface> extends org.apache.thrift.ProcessFunction<I, ping_args> {
+ 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<I extends Iface> extends org.apache.thrift.ProcessFunction<I, authenticateUser_args> {
+ 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<I extends Iface> extends org.apache.thrift.ProcessFunction<I, listUsers_args> {
+ 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<I extends Iface> extends org.apache.thrift.ProcessFunction<I, createUser_args> {
+ 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<I extends Iface> extends org.apache.thrift.ProcessFunction<I, dropUser_args> {
+ 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<I extends Iface> extends org.apache.thrift.ProcessFunction<I, changePassword_args> {
+ 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 ...]