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/05 21:39:05 UTC
svn commit: r1357829 [6/12] - in /accumulo/branches/ACCUMULO-672:
core/src/main/java/org/apache/accumulo/core/client/impl/thrift/
core/src/main/java/org/apache/accumulo/core/data/thrift/
core/src/main/java/org/apache/accumulo/core/gc/thrift/ core/src/m...
Modified: accumulo/branches/ACCUMULO-672/core/src/main/java/org/apache/accumulo/core/master/thrift/MasterClientService.java
URL: http://svn.apache.org/viewvc/accumulo/branches/ACCUMULO-672/core/src/main/java/org/apache/accumulo/core/master/thrift/MasterClientService.java?rev=1357829&r1=1357828&r2=1357829&view=diff
==============================================================================
--- accumulo/branches/ACCUMULO-672/core/src/main/java/org/apache/accumulo/core/master/thrift/MasterClientService.java (original)
+++ accumulo/branches/ACCUMULO-672/core/src/main/java/org/apache/accumulo/core/master/thrift/MasterClientService.java Thu Jul 5 19:39:03 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.master.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;
@@ -94,7 +101,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) {
@@ -107,28 +114,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 long initiateFlush(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String tableName) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, org.apache.accumulo.core.client.impl.thrift.ThriftTableOperationException, org.apache.thrift.TException
@@ -139,30 +129,17 @@ import org.slf4j.LoggerFactory;
public void send_initiateFlush(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String tableName) throws org.apache.thrift.TException
{
- oprot_.writeMessageBegin(new org.apache.thrift.protocol.TMessage("initiateFlush", org.apache.thrift.protocol.TMessageType.CALL, ++seqid_));
initiateFlush_args args = new initiateFlush_args();
args.setTinfo(tinfo);
args.setCredentials(credentials);
args.setTableName(tableName);
- args.write(oprot_);
- oprot_.writeMessageEnd();
- oprot_.getTransport().flush();
+ sendBase("initiateFlush", args);
}
public long recv_initiateFlush() throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, org.apache.accumulo.core.client.impl.thrift.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, "initiateFlush failed: out of sequence response");
- }
initiateFlush_result result = new initiateFlush_result();
- result.read(iprot_);
- iprot_.readMessageEnd();
+ receiveBase(result, "initiateFlush");
if (result.isSetSuccess()) {
return result.success;
}
@@ -183,7 +160,6 @@ import org.slf4j.LoggerFactory;
public void send_waitForFlush(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String tableName, ByteBuffer startRow, ByteBuffer endRow, long flushID, long maxLoops) throws org.apache.thrift.TException
{
- oprot_.writeMessageBegin(new org.apache.thrift.protocol.TMessage("waitForFlush", org.apache.thrift.protocol.TMessageType.CALL, ++seqid_));
waitForFlush_args args = new waitForFlush_args();
args.setTinfo(tinfo);
args.setCredentials(credentials);
@@ -192,25 +168,13 @@ import org.slf4j.LoggerFactory;
args.setEndRow(endRow);
args.setFlushID(flushID);
args.setMaxLoops(maxLoops);
- args.write(oprot_);
- oprot_.writeMessageEnd();
- oprot_.getTransport().flush();
+ sendBase("waitForFlush", args);
}
public void recv_waitForFlush() throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, org.apache.accumulo.core.client.impl.thrift.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, "waitForFlush failed: out of sequence response");
- }
waitForFlush_result result = new waitForFlush_result();
- result.read(iprot_);
- iprot_.readMessageEnd();
+ receiveBase(result, "waitForFlush");
if (result.sec != null) {
throw result.sec;
}
@@ -228,32 +192,19 @@ import org.slf4j.LoggerFactory;
public void send_setTableProperty(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String tableName, String property, String value) throws org.apache.thrift.TException
{
- oprot_.writeMessageBegin(new org.apache.thrift.protocol.TMessage("setTableProperty", org.apache.thrift.protocol.TMessageType.CALL, ++seqid_));
setTableProperty_args args = new setTableProperty_args();
args.setTinfo(tinfo);
args.setCredentials(credentials);
args.setTableName(tableName);
args.setProperty(property);
args.setValue(value);
- args.write(oprot_);
- oprot_.writeMessageEnd();
- oprot_.getTransport().flush();
+ sendBase("setTableProperty", args);
}
public void recv_setTableProperty() throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, org.apache.accumulo.core.client.impl.thrift.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, "setTableProperty failed: out of sequence response");
- }
setTableProperty_result result = new setTableProperty_result();
- result.read(iprot_);
- iprot_.readMessageEnd();
+ receiveBase(result, "setTableProperty");
if (result.sec != null) {
throw result.sec;
}
@@ -271,31 +222,18 @@ import org.slf4j.LoggerFactory;
public void send_removeTableProperty(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String tableName, String property) throws org.apache.thrift.TException
{
- oprot_.writeMessageBegin(new org.apache.thrift.protocol.TMessage("removeTableProperty", org.apache.thrift.protocol.TMessageType.CALL, ++seqid_));
removeTableProperty_args args = new removeTableProperty_args();
args.setTinfo(tinfo);
args.setCredentials(credentials);
args.setTableName(tableName);
args.setProperty(property);
- args.write(oprot_);
- oprot_.writeMessageEnd();
- oprot_.getTransport().flush();
+ sendBase("removeTableProperty", args);
}
public void recv_removeTableProperty() throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, org.apache.accumulo.core.client.impl.thrift.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, "removeTableProperty failed: out of sequence response");
- }
removeTableProperty_result result = new removeTableProperty_result();
- result.read(iprot_);
- iprot_.readMessageEnd();
+ receiveBase(result, "removeTableProperty");
if (result.sec != null) {
throw result.sec;
}
@@ -313,30 +251,17 @@ import org.slf4j.LoggerFactory;
public void send_setMasterGoalState(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, MasterGoalState state) throws org.apache.thrift.TException
{
- oprot_.writeMessageBegin(new org.apache.thrift.protocol.TMessage("setMasterGoalState", org.apache.thrift.protocol.TMessageType.CALL, ++seqid_));
setMasterGoalState_args args = new setMasterGoalState_args();
args.setTinfo(tinfo);
args.setCredentials(credentials);
args.setState(state);
- args.write(oprot_);
- oprot_.writeMessageEnd();
- oprot_.getTransport().flush();
+ sendBase("setMasterGoalState", args);
}
public void recv_setMasterGoalState() 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, "setMasterGoalState failed: out of sequence response");
- }
setMasterGoalState_result result = new setMasterGoalState_result();
- result.read(iprot_);
- iprot_.readMessageEnd();
+ receiveBase(result, "setMasterGoalState");
if (result.sec != null) {
throw result.sec;
}
@@ -351,30 +276,17 @@ import org.slf4j.LoggerFactory;
public void send_shutdown(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, boolean stopTabletServers) throws org.apache.thrift.TException
{
- oprot_.writeMessageBegin(new org.apache.thrift.protocol.TMessage("shutdown", org.apache.thrift.protocol.TMessageType.CALL, ++seqid_));
shutdown_args args = new shutdown_args();
args.setTinfo(tinfo);
args.setCredentials(credentials);
args.setStopTabletServers(stopTabletServers);
- args.write(oprot_);
- oprot_.writeMessageEnd();
- oprot_.getTransport().flush();
+ sendBase("shutdown", args);
}
public void recv_shutdown() 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, "shutdown failed: out of sequence response");
- }
shutdown_result result = new shutdown_result();
- result.read(iprot_);
- iprot_.readMessageEnd();
+ receiveBase(result, "shutdown");
if (result.sec != null) {
throw result.sec;
}
@@ -389,31 +301,18 @@ import org.slf4j.LoggerFactory;
public void send_shutdownTabletServer(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String tabletServer, boolean force) throws org.apache.thrift.TException
{
- oprot_.writeMessageBegin(new org.apache.thrift.protocol.TMessage("shutdownTabletServer", org.apache.thrift.protocol.TMessageType.CALL, ++seqid_));
shutdownTabletServer_args args = new shutdownTabletServer_args();
args.setTinfo(tinfo);
args.setCredentials(credentials);
args.setTabletServer(tabletServer);
args.setForce(force);
- args.write(oprot_);
- oprot_.writeMessageEnd();
- oprot_.getTransport().flush();
+ sendBase("shutdownTabletServer", args);
}
public void recv_shutdownTabletServer() 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, "shutdownTabletServer failed: out of sequence response");
- }
shutdownTabletServer_result result = new shutdownTabletServer_result();
- result.read(iprot_);
- iprot_.readMessageEnd();
+ receiveBase(result, "shutdownTabletServer");
if (result.sec != null) {
throw result.sec;
}
@@ -428,31 +327,18 @@ import org.slf4j.LoggerFactory;
public void send_setSystemProperty(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String property, String value) throws org.apache.thrift.TException
{
- oprot_.writeMessageBegin(new org.apache.thrift.protocol.TMessage("setSystemProperty", org.apache.thrift.protocol.TMessageType.CALL, ++seqid_));
setSystemProperty_args args = new setSystemProperty_args();
args.setTinfo(tinfo);
args.setCredentials(credentials);
args.setProperty(property);
args.setValue(value);
- args.write(oprot_);
- oprot_.writeMessageEnd();
- oprot_.getTransport().flush();
+ sendBase("setSystemProperty", args);
}
public void recv_setSystemProperty() 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, "setSystemProperty failed: out of sequence response");
- }
setSystemProperty_result result = new setSystemProperty_result();
- result.read(iprot_);
- iprot_.readMessageEnd();
+ receiveBase(result, "setSystemProperty");
if (result.sec != null) {
throw result.sec;
}
@@ -467,30 +353,17 @@ import org.slf4j.LoggerFactory;
public void send_removeSystemProperty(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String property) throws org.apache.thrift.TException
{
- oprot_.writeMessageBegin(new org.apache.thrift.protocol.TMessage("removeSystemProperty", org.apache.thrift.protocol.TMessageType.CALL, ++seqid_));
removeSystemProperty_args args = new removeSystemProperty_args();
args.setTinfo(tinfo);
args.setCredentials(credentials);
args.setProperty(property);
- args.write(oprot_);
- oprot_.writeMessageEnd();
- oprot_.getTransport().flush();
+ sendBase("removeSystemProperty", args);
}
public void recv_removeSystemProperty() 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, "removeSystemProperty failed: out of sequence response");
- }
removeSystemProperty_result result = new removeSystemProperty_result();
- result.read(iprot_);
- iprot_.readMessageEnd();
+ receiveBase(result, "removeSystemProperty");
if (result.sec != null) {
throw result.sec;
}
@@ -505,29 +378,16 @@ import org.slf4j.LoggerFactory;
public void send_getMasterStats(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("getMasterStats", org.apache.thrift.protocol.TMessageType.CALL, ++seqid_));
getMasterStats_args args = new getMasterStats_args();
args.setTinfo(tinfo);
args.setCredentials(credentials);
- args.write(oprot_);
- oprot_.writeMessageEnd();
- oprot_.getTransport().flush();
+ sendBase("getMasterStats", args);
}
public MasterMonitorInfo recv_getMasterStats() 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, "getMasterStats failed: out of sequence response");
- }
getMasterStats_result result = new getMasterStats_result();
- result.read(iprot_);
- iprot_.readMessageEnd();
+ receiveBase(result, "getMasterStats");
if (result.isSetSuccess()) {
return result.success;
}
@@ -544,15 +404,12 @@ import org.slf4j.LoggerFactory;
public void send_reportSplitExtent(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String serverName, TabletSplit split) throws org.apache.thrift.TException
{
- oprot_.writeMessageBegin(new org.apache.thrift.protocol.TMessage("reportSplitExtent", org.apache.thrift.protocol.TMessageType.CALL, ++seqid_));
reportSplitExtent_args args = new reportSplitExtent_args();
args.setTinfo(tinfo);
args.setCredentials(credentials);
args.setServerName(serverName);
args.setSplit(split);
- args.write(oprot_);
- oprot_.writeMessageEnd();
- oprot_.getTransport().flush();
+ sendBase("reportSplitExtent", args);
}
public void reportTabletStatus(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String serverName, TabletLoadState status, org.apache.accumulo.core.data.thrift.TKeyExtent tablet) throws org.apache.thrift.TException
@@ -562,16 +419,13 @@ import org.slf4j.LoggerFactory;
public void send_reportTabletStatus(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String serverName, TabletLoadState status, org.apache.accumulo.core.data.thrift.TKeyExtent tablet) throws org.apache.thrift.TException
{
- oprot_.writeMessageBegin(new org.apache.thrift.protocol.TMessage("reportTabletStatus", org.apache.thrift.protocol.TMessageType.CALL, ++seqid_));
reportTabletStatus_args args = new reportTabletStatus_args();
args.setTinfo(tinfo);
args.setCredentials(credentials);
args.setServerName(serverName);
args.setStatus(status);
args.setTablet(tablet);
- args.write(oprot_);
- oprot_.writeMessageEnd();
- oprot_.getTransport().flush();
+ sendBase("reportTabletStatus", args);
}
public long beginTableOperation(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, org.apache.thrift.TException
@@ -582,29 +436,16 @@ import org.slf4j.LoggerFactory;
public void send_beginTableOperation(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("beginTableOperation", org.apache.thrift.protocol.TMessageType.CALL, ++seqid_));
beginTableOperation_args args = new beginTableOperation_args();
args.setTinfo(tinfo);
args.setCredentials(credentials);
- args.write(oprot_);
- oprot_.writeMessageEnd();
- oprot_.getTransport().flush();
+ sendBase("beginTableOperation", args);
}
public long recv_beginTableOperation() 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, "beginTableOperation failed: out of sequence response");
- }
beginTableOperation_result result = new beginTableOperation_result();
- result.read(iprot_);
- iprot_.readMessageEnd();
+ receiveBase(result, "beginTableOperation");
if (result.isSetSuccess()) {
return result.success;
}
@@ -622,7 +463,6 @@ import org.slf4j.LoggerFactory;
public void send_executeTableOperation(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, long opid, TableOperation op, List<ByteBuffer> arguments, Map<String,String> options, boolean autoClean) throws org.apache.thrift.TException
{
- oprot_.writeMessageBegin(new org.apache.thrift.protocol.TMessage("executeTableOperation", org.apache.thrift.protocol.TMessageType.CALL, ++seqid_));
executeTableOperation_args args = new executeTableOperation_args();
args.setTinfo(tinfo);
args.setCredentials(credentials);
@@ -631,25 +471,13 @@ import org.slf4j.LoggerFactory;
args.setArguments(arguments);
args.setOptions(options);
args.setAutoClean(autoClean);
- args.write(oprot_);
- oprot_.writeMessageEnd();
- oprot_.getTransport().flush();
+ sendBase("executeTableOperation", args);
}
public void recv_executeTableOperation() throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, org.apache.accumulo.core.client.impl.thrift.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, "executeTableOperation failed: out of sequence response");
- }
executeTableOperation_result result = new executeTableOperation_result();
- result.read(iprot_);
- iprot_.readMessageEnd();
+ receiveBase(result, "executeTableOperation");
if (result.sec != null) {
throw result.sec;
}
@@ -667,30 +495,17 @@ import org.slf4j.LoggerFactory;
public void send_waitForTableOperation(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, long opid) throws org.apache.thrift.TException
{
- oprot_.writeMessageBegin(new org.apache.thrift.protocol.TMessage("waitForTableOperation", org.apache.thrift.protocol.TMessageType.CALL, ++seqid_));
waitForTableOperation_args args = new waitForTableOperation_args();
args.setTinfo(tinfo);
args.setCredentials(credentials);
args.setOpid(opid);
- args.write(oprot_);
- oprot_.writeMessageEnd();
- oprot_.getTransport().flush();
+ sendBase("waitForTableOperation", args);
}
public String recv_waitForTableOperation() throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, org.apache.accumulo.core.client.impl.thrift.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, "waitForTableOperation failed: out of sequence response");
- }
waitForTableOperation_result result = new waitForTableOperation_result();
- result.read(iprot_);
- iprot_.readMessageEnd();
+ receiveBase(result, "waitForTableOperation");
if (result.isSetSuccess()) {
return result.success;
}
@@ -711,30 +526,17 @@ import org.slf4j.LoggerFactory;
public void send_finishTableOperation(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, long opid) throws org.apache.thrift.TException
{
- oprot_.writeMessageBegin(new org.apache.thrift.protocol.TMessage("finishTableOperation", org.apache.thrift.protocol.TMessageType.CALL, ++seqid_));
finishTableOperation_args args = new finishTableOperation_args();
args.setTinfo(tinfo);
args.setCredentials(credentials);
args.setOpid(opid);
- args.write(oprot_);
- oprot_.writeMessageEnd();
- oprot_.getTransport().flush();
+ sendBase("finishTableOperation", args);
}
public void recv_finishTableOperation() 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, "finishTableOperation failed: out of sequence response");
- }
finishTableOperation_result result = new finishTableOperation_result();
- result.read(iprot_);
- iprot_.readMessageEnd();
+ receiveBase(result, "finishTableOperation");
if (result.sec != null) {
throw result.sec;
}
@@ -761,9 +563,9 @@ import org.slf4j.LoggerFactory;
public void initiateFlush(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String tableName, org.apache.thrift.async.AsyncMethodCallback<initiateFlush_call> resultHandler) throws org.apache.thrift.TException {
checkReady();
- initiateFlush_call method_call = new initiateFlush_call(tinfo, credentials, tableName, resultHandler, this, protocolFactory, transport);
- this.currentMethod = method_call;
- manager.call(method_call);
+ initiateFlush_call method_call = new initiateFlush_call(tinfo, credentials, tableName, resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
}
public static class initiateFlush_call extends org.apache.thrift.async.TAsyncMethodCall {
@@ -799,9 +601,9 @@ import org.slf4j.LoggerFactory;
public void waitForFlush(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String tableName, ByteBuffer startRow, ByteBuffer endRow, long flushID, long maxLoops, org.apache.thrift.async.AsyncMethodCallback<waitForFlush_call> resultHandler) throws org.apache.thrift.TException {
checkReady();
- waitForFlush_call method_call = new waitForFlush_call(tinfo, credentials, tableName, startRow, endRow, flushID, maxLoops, resultHandler, this, protocolFactory, transport);
- this.currentMethod = method_call;
- manager.call(method_call);
+ waitForFlush_call method_call = new waitForFlush_call(tinfo, credentials, tableName, startRow, endRow, flushID, maxLoops, resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
}
public static class waitForFlush_call extends org.apache.thrift.async.TAsyncMethodCall {
@@ -849,9 +651,9 @@ import org.slf4j.LoggerFactory;
public void setTableProperty(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String tableName, String property, String value, org.apache.thrift.async.AsyncMethodCallback<setTableProperty_call> resultHandler) throws org.apache.thrift.TException {
checkReady();
- setTableProperty_call method_call = new setTableProperty_call(tinfo, credentials, tableName, property, value, resultHandler, this, protocolFactory, transport);
- this.currentMethod = method_call;
- manager.call(method_call);
+ setTableProperty_call method_call = new setTableProperty_call(tinfo, credentials, tableName, property, value, resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
}
public static class setTableProperty_call extends org.apache.thrift.async.TAsyncMethodCall {
@@ -893,9 +695,9 @@ import org.slf4j.LoggerFactory;
public void removeTableProperty(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String tableName, String property, org.apache.thrift.async.AsyncMethodCallback<removeTableProperty_call> resultHandler) throws org.apache.thrift.TException {
checkReady();
- removeTableProperty_call method_call = new removeTableProperty_call(tinfo, credentials, tableName, property, resultHandler, this, protocolFactory, transport);
- this.currentMethod = method_call;
- manager.call(method_call);
+ removeTableProperty_call method_call = new removeTableProperty_call(tinfo, credentials, tableName, property, resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
}
public static class removeTableProperty_call extends org.apache.thrift.async.TAsyncMethodCall {
@@ -934,9 +736,9 @@ import org.slf4j.LoggerFactory;
public void setMasterGoalState(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, MasterGoalState state, org.apache.thrift.async.AsyncMethodCallback<setMasterGoalState_call> resultHandler) throws org.apache.thrift.TException {
checkReady();
- setMasterGoalState_call method_call = new setMasterGoalState_call(tinfo, credentials, state, resultHandler, this, protocolFactory, transport);
- this.currentMethod = method_call;
- manager.call(method_call);
+ setMasterGoalState_call method_call = new setMasterGoalState_call(tinfo, credentials, state, resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
}
public static class setMasterGoalState_call extends org.apache.thrift.async.TAsyncMethodCall {
@@ -972,9 +774,9 @@ import org.slf4j.LoggerFactory;
public void shutdown(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, boolean stopTabletServers, org.apache.thrift.async.AsyncMethodCallback<shutdown_call> resultHandler) throws org.apache.thrift.TException {
checkReady();
- shutdown_call method_call = new shutdown_call(tinfo, credentials, stopTabletServers, resultHandler, this, protocolFactory, transport);
- this.currentMethod = method_call;
- manager.call(method_call);
+ shutdown_call method_call = new shutdown_call(tinfo, credentials, stopTabletServers, resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
}
public static class shutdown_call extends org.apache.thrift.async.TAsyncMethodCall {
@@ -1010,9 +812,9 @@ import org.slf4j.LoggerFactory;
public void shutdownTabletServer(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String tabletServer, boolean force, org.apache.thrift.async.AsyncMethodCallback<shutdownTabletServer_call> resultHandler) throws org.apache.thrift.TException {
checkReady();
- shutdownTabletServer_call method_call = new shutdownTabletServer_call(tinfo, credentials, tabletServer, force, resultHandler, this, protocolFactory, transport);
- this.currentMethod = method_call;
- manager.call(method_call);
+ shutdownTabletServer_call method_call = new shutdownTabletServer_call(tinfo, credentials, tabletServer, force, resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
}
public static class shutdownTabletServer_call extends org.apache.thrift.async.TAsyncMethodCall {
@@ -1051,9 +853,9 @@ import org.slf4j.LoggerFactory;
public void setSystemProperty(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String property, String value, org.apache.thrift.async.AsyncMethodCallback<setSystemProperty_call> resultHandler) throws org.apache.thrift.TException {
checkReady();
- setSystemProperty_call method_call = new setSystemProperty_call(tinfo, credentials, property, value, resultHandler, this, protocolFactory, transport);
- this.currentMethod = method_call;
- manager.call(method_call);
+ setSystemProperty_call method_call = new setSystemProperty_call(tinfo, credentials, property, value, resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
}
public static class setSystemProperty_call extends org.apache.thrift.async.TAsyncMethodCall {
@@ -1092,9 +894,9 @@ import org.slf4j.LoggerFactory;
public void removeSystemProperty(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String property, org.apache.thrift.async.AsyncMethodCallback<removeSystemProperty_call> resultHandler) throws org.apache.thrift.TException {
checkReady();
- removeSystemProperty_call method_call = new removeSystemProperty_call(tinfo, credentials, property, resultHandler, this, protocolFactory, transport);
- this.currentMethod = method_call;
- manager.call(method_call);
+ removeSystemProperty_call method_call = new removeSystemProperty_call(tinfo, credentials, property, resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
}
public static class removeSystemProperty_call extends org.apache.thrift.async.TAsyncMethodCall {
@@ -1130,9 +932,9 @@ import org.slf4j.LoggerFactory;
public void getMasterStats(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, org.apache.thrift.async.AsyncMethodCallback<getMasterStats_call> resultHandler) throws org.apache.thrift.TException {
checkReady();
- getMasterStats_call method_call = new getMasterStats_call(tinfo, credentials, resultHandler, this, protocolFactory, transport);
- this.currentMethod = method_call;
- manager.call(method_call);
+ getMasterStats_call method_call = new getMasterStats_call(tinfo, credentials, resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
}
public static class getMasterStats_call extends org.apache.thrift.async.TAsyncMethodCall {
@@ -1165,9 +967,9 @@ import org.slf4j.LoggerFactory;
public void reportSplitExtent(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String serverName, TabletSplit split, org.apache.thrift.async.AsyncMethodCallback<reportSplitExtent_call> resultHandler) throws org.apache.thrift.TException {
checkReady();
- reportSplitExtent_call method_call = new reportSplitExtent_call(tinfo, credentials, serverName, split, resultHandler, this, protocolFactory, transport);
- this.currentMethod = method_call;
- manager.call(method_call);
+ reportSplitExtent_call method_call = new reportSplitExtent_call(tinfo, credentials, serverName, split, resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
}
public static class reportSplitExtent_call extends org.apache.thrift.async.TAsyncMethodCall {
@@ -1205,9 +1007,9 @@ import org.slf4j.LoggerFactory;
public void reportTabletStatus(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String serverName, TabletLoadState status, org.apache.accumulo.core.data.thrift.TKeyExtent tablet, org.apache.thrift.async.AsyncMethodCallback<reportTabletStatus_call> resultHandler) throws org.apache.thrift.TException {
checkReady();
- reportTabletStatus_call method_call = new reportTabletStatus_call(tinfo, credentials, serverName, status, tablet, resultHandler, this, protocolFactory, transport);
- this.currentMethod = method_call;
- manager.call(method_call);
+ reportTabletStatus_call method_call = new reportTabletStatus_call(tinfo, credentials, serverName, status, tablet, resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
}
public static class reportTabletStatus_call extends org.apache.thrift.async.TAsyncMethodCall {
@@ -1248,9 +1050,9 @@ import org.slf4j.LoggerFactory;
public void beginTableOperation(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, org.apache.thrift.async.AsyncMethodCallback<beginTableOperation_call> resultHandler) throws org.apache.thrift.TException {
checkReady();
- beginTableOperation_call method_call = new beginTableOperation_call(tinfo, credentials, resultHandler, this, protocolFactory, transport);
- this.currentMethod = method_call;
- manager.call(method_call);
+ beginTableOperation_call method_call = new beginTableOperation_call(tinfo, credentials, resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
}
public static class beginTableOperation_call extends org.apache.thrift.async.TAsyncMethodCall {
@@ -1283,9 +1085,9 @@ import org.slf4j.LoggerFactory;
public void executeTableOperation(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, long opid, TableOperation op, List<ByteBuffer> arguments, Map<String,String> options, boolean autoClean, org.apache.thrift.async.AsyncMethodCallback<executeTableOperation_call> resultHandler) throws org.apache.thrift.TException {
checkReady();
- executeTableOperation_call method_call = new executeTableOperation_call(tinfo, credentials, opid, op, arguments, options, autoClean, resultHandler, this, protocolFactory, transport);
- this.currentMethod = method_call;
- manager.call(method_call);
+ executeTableOperation_call method_call = new executeTableOperation_call(tinfo, credentials, opid, op, arguments, options, autoClean, resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
}
public static class executeTableOperation_call extends org.apache.thrift.async.TAsyncMethodCall {
@@ -1333,9 +1135,9 @@ import org.slf4j.LoggerFactory;
public void waitForTableOperation(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, long opid, org.apache.thrift.async.AsyncMethodCallback<waitForTableOperation_call> resultHandler) throws org.apache.thrift.TException {
checkReady();
- waitForTableOperation_call method_call = new waitForTableOperation_call(tinfo, credentials, opid, resultHandler, this, protocolFactory, transport);
- this.currentMethod = method_call;
- manager.call(method_call);
+ waitForTableOperation_call method_call = new waitForTableOperation_call(tinfo, credentials, opid, resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
}
public static class waitForTableOperation_call extends org.apache.thrift.async.TAsyncMethodCall {
@@ -1371,9 +1173,9 @@ import org.slf4j.LoggerFactory;
public void finishTableOperation(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, long opid, org.apache.thrift.async.AsyncMethodCallback<finishTableOperation_call> resultHandler) throws org.apache.thrift.TException {
checkReady();
- finishTableOperation_call method_call = new finishTableOperation_call(tinfo, credentials, opid, resultHandler, this, protocolFactory, transport);
- this.currentMethod = method_call;
- manager.call(method_call);
+ finishTableOperation_call method_call = new finishTableOperation_call(tinfo, credentials, opid, resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
}
public static class finishTableOperation_call extends org.apache.thrift.async.TAsyncMethodCall {
@@ -1409,640 +1211,358 @@ 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("initiateFlush", new initiateFlush());
- processMap_.put("waitForFlush", new waitForFlush());
- processMap_.put("setTableProperty", new setTableProperty());
- processMap_.put("removeTableProperty", new removeTableProperty());
- processMap_.put("setMasterGoalState", new setMasterGoalState());
- processMap_.put("shutdown", new shutdown());
- processMap_.put("shutdownTabletServer", new shutdownTabletServer());
- processMap_.put("setSystemProperty", new setSystemProperty());
- processMap_.put("removeSystemProperty", new removeSystemProperty());
- processMap_.put("getMasterStats", new getMasterStats());
- processMap_.put("reportSplitExtent", new reportSplitExtent());
- processMap_.put("reportTabletStatus", new reportTabletStatus());
- processMap_.put("beginTableOperation", new beginTableOperation());
- processMap_.put("executeTableOperation", new executeTableOperation());
- processMap_.put("waitForTableOperation", new waitForTableOperation());
- processMap_.put("finishTableOperation", new finishTableOperation());
- }
-
- 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 initiateFlush implements ProcessFunction {
- public void process(int seqid, org.apache.thrift.protocol.TProtocol iprot, org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException
- {
- initiateFlush_args args = new initiateFlush_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("initiateFlush", org.apache.thrift.protocol.TMessageType.EXCEPTION, seqid));
- x.write(oprot);
- oprot.writeMessageEnd();
- oprot.getTransport().flush();
- return;
- }
- iprot.readMessageEnd();
+ 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("initiateFlush", new initiateFlush());
+ processMap.put("waitForFlush", new waitForFlush());
+ processMap.put("setTableProperty", new setTableProperty());
+ processMap.put("removeTableProperty", new removeTableProperty());
+ processMap.put("setMasterGoalState", new setMasterGoalState());
+ processMap.put("shutdown", new shutdown());
+ processMap.put("shutdownTabletServer", new shutdownTabletServer());
+ processMap.put("setSystemProperty", new setSystemProperty());
+ processMap.put("removeSystemProperty", new removeSystemProperty());
+ processMap.put("getMasterStats", new getMasterStats());
+ processMap.put("reportSplitExtent", new reportSplitExtent());
+ processMap.put("reportTabletStatus", new reportTabletStatus());
+ processMap.put("beginTableOperation", new beginTableOperation());
+ processMap.put("executeTableOperation", new executeTableOperation());
+ processMap.put("waitForTableOperation", new waitForTableOperation());
+ processMap.put("finishTableOperation", new finishTableOperation());
+ return processMap;
+ }
+
+ private static class initiateFlush<I extends Iface> extends org.apache.thrift.ProcessFunction<I, initiateFlush_args> {
+ public initiateFlush() {
+ super("initiateFlush");
+ }
+
+ protected initiateFlush_args getEmptyArgsInstance() {
+ return new initiateFlush_args();
+ }
+
+ protected initiateFlush_result getResult(I iface, initiateFlush_args args) throws org.apache.thrift.TException {
initiateFlush_result result = new initiateFlush_result();
try {
- result.success = iface_.initiateFlush(args.tinfo, args.credentials, args.tableName);
+ result.success = iface.initiateFlush(args.tinfo, args.credentials, args.tableName);
result.setSuccessIsSet(true);
} catch (org.apache.accumulo.core.security.thrift.ThriftSecurityException sec) {
result.sec = sec;
} catch (org.apache.accumulo.core.client.impl.thrift.ThriftTableOperationException tope) {
result.tope = tope;
- } catch (Throwable th) {
- LOGGER.error("Internal error processing initiateFlush", th);
- org.apache.thrift.TApplicationException x = new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, "Internal error processing initiateFlush");
- oprot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("initiateFlush", org.apache.thrift.protocol.TMessageType.EXCEPTION, seqid));
- x.write(oprot);
- oprot.writeMessageEnd();
- oprot.getTransport().flush();
- return;
- }
- oprot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("initiateFlush", org.apache.thrift.protocol.TMessageType.REPLY, seqid));
- result.write(oprot);
- oprot.writeMessageEnd();
- oprot.getTransport().flush();
+ }
+ return result;
}
-
}
- private class waitForFlush implements ProcessFunction {
- public void process(int seqid, org.apache.thrift.protocol.TProtocol iprot, org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException
- {
- waitForFlush_args args = new waitForFlush_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("waitForFlush", org.apache.thrift.protocol.TMessageType.EXCEPTION, seqid));
- x.write(oprot);
- oprot.writeMessageEnd();
- oprot.getTransport().flush();
- return;
- }
- iprot.readMessageEnd();
+ private static class waitForFlush<I extends Iface> extends org.apache.thrift.ProcessFunction<I, waitForFlush_args> {
+ public waitForFlush() {
+ super("waitForFlush");
+ }
+
+ protected waitForFlush_args getEmptyArgsInstance() {
+ return new waitForFlush_args();
+ }
+
+ protected waitForFlush_result getResult(I iface, waitForFlush_args args) throws org.apache.thrift.TException {
waitForFlush_result result = new waitForFlush_result();
try {
- iface_.waitForFlush(args.tinfo, args.credentials, args.tableName, args.startRow, args.endRow, args.flushID, args.maxLoops);
+ iface.waitForFlush(args.tinfo, args.credentials, args.tableName, args.startRow, args.endRow, args.flushID, args.maxLoops);
} catch (org.apache.accumulo.core.security.thrift.ThriftSecurityException sec) {
result.sec = sec;
} catch (org.apache.accumulo.core.client.impl.thrift.ThriftTableOperationException tope) {
result.tope = tope;
- } catch (Throwable th) {
- LOGGER.error("Internal error processing waitForFlush", th);
- org.apache.thrift.TApplicationException x = new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, "Internal error processing waitForFlush");
- oprot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("waitForFlush", org.apache.thrift.protocol.TMessageType.EXCEPTION, seqid));
- x.write(oprot);
- oprot.writeMessageEnd();
- oprot.getTransport().flush();
- return;
- }
- oprot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("waitForFlush", org.apache.thrift.protocol.TMessageType.REPLY, seqid));
- result.write(oprot);
- oprot.writeMessageEnd();
- oprot.getTransport().flush();
+ }
+ return result;
}
-
}
- private class setTableProperty implements ProcessFunction {
- public void process(int seqid, org.apache.thrift.protocol.TProtocol iprot, org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException
- {
- setTableProperty_args args = new setTableProperty_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("setTableProperty", org.apache.thrift.protocol.TMessageType.EXCEPTION, seqid));
- x.write(oprot);
- oprot.writeMessageEnd();
- oprot.getTransport().flush();
- return;
- }
- iprot.readMessageEnd();
+ private static class setTableProperty<I extends Iface> extends org.apache.thrift.ProcessFunction<I, setTableProperty_args> {
+ public setTableProperty() {
+ super("setTableProperty");
+ }
+
+ protected setTableProperty_args getEmptyArgsInstance() {
+ return new setTableProperty_args();
+ }
+
+ protected setTableProperty_result getResult(I iface, setTableProperty_args args) throws org.apache.thrift.TException {
setTableProperty_result result = new setTableProperty_result();
try {
- iface_.setTableProperty(args.tinfo, args.credentials, args.tableName, args.property, args.value);
+ iface.setTableProperty(args.tinfo, args.credentials, args.tableName, args.property, args.value);
} catch (org.apache.accumulo.core.security.thrift.ThriftSecurityException sec) {
result.sec = sec;
} catch (org.apache.accumulo.core.client.impl.thrift.ThriftTableOperationException tope) {
result.tope = tope;
- } catch (Throwable th) {
- LOGGER.error("Internal error processing setTableProperty", th);
- org.apache.thrift.TApplicationException x = new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, "Internal error processing setTableProperty");
- oprot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("setTableProperty", org.apache.thrift.protocol.TMessageType.EXCEPTION, seqid));
- x.write(oprot);
- oprot.writeMessageEnd();
- oprot.getTransport().flush();
- return;
- }
- oprot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("setTableProperty", org.apache.thrift.protocol.TMessageType.REPLY, seqid));
- result.write(oprot);
- oprot.writeMessageEnd();
- oprot.getTransport().flush();
+ }
+ return result;
}
-
}
- private class removeTableProperty implements ProcessFunction {
- public void process(int seqid, org.apache.thrift.protocol.TProtocol iprot, org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException
- {
- removeTableProperty_args args = new removeTableProperty_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("removeTableProperty", org.apache.thrift.protocol.TMessageType.EXCEPTION, seqid));
- x.write(oprot);
- oprot.writeMessageEnd();
- oprot.getTransport().flush();
- return;
- }
- iprot.readMessageEnd();
+ private static class removeTableProperty<I extends Iface> extends org.apache.thrift.ProcessFunction<I, removeTableProperty_args> {
+ public removeTableProperty() {
+ super("removeTableProperty");
+ }
+
+ protected removeTableProperty_args getEmptyArgsInstance() {
+ return new removeTableProperty_args();
+ }
+
+ protected removeTableProperty_result getResult(I iface, removeTableProperty_args args) throws org.apache.thrift.TException {
removeTableProperty_result result = new removeTableProperty_result();
try {
- iface_.removeTableProperty(args.tinfo, args.credentials, args.tableName, args.property);
+ iface.removeTableProperty(args.tinfo, args.credentials, args.tableName, args.property);
} catch (org.apache.accumulo.core.security.thrift.ThriftSecurityException sec) {
result.sec = sec;
} catch (org.apache.accumulo.core.client.impl.thrift.ThriftTableOperationException tope) {
result.tope = tope;
- } catch (Throwable th) {
- LOGGER.error("Internal error processing removeTableProperty", th);
- org.apache.thrift.TApplicationException x = new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, "Internal error processing removeTableProperty");
- oprot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("removeTableProperty", org.apache.thrift.protocol.TMessageType.EXCEPTION, seqid));
- x.write(oprot);
- oprot.writeMessageEnd();
- oprot.getTransport().flush();
- return;
- }
- oprot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("removeTableProperty", org.apache.thrift.protocol.TMessageType.REPLY, seqid));
- result.write(oprot);
- oprot.writeMessageEnd();
- oprot.getTransport().flush();
+ }
+ return result;
}
-
}
- private class setMasterGoalState implements ProcessFunction {
- public void process(int seqid, org.apache.thrift.protocol.TProtocol iprot, org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException
- {
- setMasterGoalState_args args = new setMasterGoalState_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("setMasterGoalState", org.apache.thrift.protocol.TMessageType.EXCEPTION, seqid));
- x.write(oprot);
- oprot.writeMessageEnd();
- oprot.getTransport().flush();
- return;
- }
- iprot.readMessageEnd();
+ private static class setMasterGoalState<I extends Iface> extends org.apache.thrift.ProcessFunction<I, setMasterGoalState_args> {
+ public setMasterGoalState() {
+ super("setMasterGoalState");
+ }
+
+ protected setMasterGoalState_args getEmptyArgsInstance() {
+ return new setMasterGoalState_args();
+ }
+
+ protected setMasterGoalState_result getResult(I iface, setMasterGoalState_args args) throws org.apache.thrift.TException {
setMasterGoalState_result result = new setMasterGoalState_result();
try {
- iface_.setMasterGoalState(args.tinfo, args.credentials, args.state);
+ iface.setMasterGoalState(args.tinfo, args.credentials, args.state);
} catch (org.apache.accumulo.core.security.thrift.ThriftSecurityException sec) {
result.sec = sec;
- } catch (Throwable th) {
- LOGGER.error("Internal error processing setMasterGoalState", th);
- org.apache.thrift.TApplicationException x = new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, "Internal error processing setMasterGoalState");
- oprot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("setMasterGoalState", org.apache.thrift.protocol.TMessageType.EXCEPTION, seqid));
- x.write(oprot);
- oprot.writeMessageEnd();
- oprot.getTransport().flush();
- return;
- }
- oprot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("setMasterGoalState", org.apache.thrift.protocol.TMessageType.REPLY, seqid));
- result.write(oprot);
- oprot.writeMessageEnd();
- oprot.getTransport().flush();
+ }
+ return result;
}
-
}
- private class shutdown implements ProcessFunction {
- public void process(int seqid, org.apache.thrift.protocol.TProtocol iprot, org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException
- {
- shutdown_args args = new shutdown_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("shutdown", org.apache.thrift.protocol.TMessageType.EXCEPTION, seqid));
- x.write(oprot);
- oprot.writeMessageEnd();
- oprot.getTransport().flush();
- return;
- }
- iprot.readMessageEnd();
+ private static class shutdown<I extends Iface> extends org.apache.thrift.ProcessFunction<I, shutdown_args> {
+ public shutdown() {
+ super("shutdown");
+ }
+
+ protected shutdown_args getEmptyArgsInstance() {
+ return new shutdown_args();
+ }
+
+ protected shutdown_result getResult(I iface, shutdown_args args) throws org.apache.thrift.TException {
shutdown_result result = new shutdown_result();
try {
- iface_.shutdown(args.tinfo, args.credentials, args.stopTabletServers);
+ iface.shutdown(args.tinfo, args.credentials, args.stopTabletServers);
} catch (org.apache.accumulo.core.security.thrift.ThriftSecurityException sec) {
result.sec = sec;
- } catch (Throwable th) {
- LOGGER.error("Internal error processing shutdown", th);
- org.apache.thrift.TApplicationException x = new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, "Internal error processing shutdown");
- oprot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("shutdown", org.apache.thrift.protocol.TMessageType.EXCEPTION, seqid));
- x.write(oprot);
- oprot.writeMessageEnd();
- oprot.getTransport().flush();
- return;
- }
- oprot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("shutdown", org.apache.thrift.protocol.TMessageType.REPLY, seqid));
- result.write(oprot);
- oprot.writeMessageEnd();
- oprot.getTransport().flush();
+ }
+ return result;
}
-
}
- private class shutdownTabletServer implements ProcessFunction {
- public void process(int seqid, org.apache.thrift.protocol.TProtocol iprot, org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException
- {
- shutdownTabletServer_args args = new shutdownTabletServer_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("shutdownTabletServer", org.apache.thrift.protocol.TMessageType.EXCEPTION, seqid));
- x.write(oprot);
- oprot.writeMessageEnd();
- oprot.getTransport().flush();
- return;
- }
- iprot.readMessageEnd();
+ private static class shutdownTabletServer<I extends Iface> extends org.apache.thrift.ProcessFunction<I, shutdownTabletServer_args> {
+ public shutdownTabletServer() {
+ super("shutdownTabletServer");
+ }
+
+ protected shutdownTabletServer_args getEmptyArgsInstance() {
+ return new shutdownTabletServer_args();
+ }
+
+ protected shutdownTabletServer_result getResult(I iface, shutdownTabletServer_args args) throws org.apache.thrift.TException {
shutdownTabletServer_result result = new shutdownTabletServer_result();
try {
- iface_.shutdownTabletServer(args.tinfo, args.credentials, args.tabletServer, args.force);
+ iface.shutdownTabletServer(args.tinfo, args.credentials, args.tabletServer, args.force);
} catch (org.apache.accumulo.core.security.thrift.ThriftSecurityException sec) {
result.sec = sec;
- } catch (Throwable th) {
- LOGGER.error("Internal error processing shutdownTabletServer", th);
- org.apache.thrift.TApplicationException x = new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, "Internal error processing shutdownTabletServer");
- oprot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("shutdownTabletServer", org.apache.thrift.protocol.TMessageType.EXCEPTION, seqid));
- x.write(oprot);
- oprot.writeMessageEnd();
- oprot.getTransport().flush();
- return;
- }
- oprot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("shutdownTabletServer", org.apache.thrift.protocol.TMessageType.REPLY, seqid));
- result.write(oprot);
- oprot.writeMessageEnd();
- oprot.getTransport().flush();
+ }
+ return result;
}
-
}
- private class setSystemProperty implements ProcessFunction {
- public void process(int seqid, org.apache.thrift.protocol.TProtocol iprot, org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException
- {
- setSystemProperty_args args = new setSystemProperty_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("setSystemProperty", org.apache.thrift.protocol.TMessageType.EXCEPTION, seqid));
- x.write(oprot);
- oprot.writeMessageEnd();
- oprot.getTransport().flush();
- return;
- }
- iprot.readMessageEnd();
+ private static class setSystemProperty<I extends Iface> extends org.apache.thrift.ProcessFunction<I, setSystemProperty_args> {
+ public setSystemProperty() {
+ super("setSystemProperty");
+ }
+
+ protected setSystemProperty_args getEmptyArgsInstance() {
+ return new setSystemProperty_args();
+ }
+
+ protected setSystemProperty_result getResult(I iface, setSystemProperty_args args) throws org.apache.thrift.TException {
setSystemProperty_result result = new setSystemProperty_result();
try {
- iface_.setSystemProperty(args.tinfo, args.credentials, args.property, args.value);
+ iface.setSystemProperty(args.tinfo, args.credentials, args.property, args.value);
} catch (org.apache.accumulo.core.security.thrift.ThriftSecurityException sec) {
result.sec = sec;
- } catch (Throwable th) {
- LOGGER.error("Internal error processing setSystemProperty", th);
- org.apache.thrift.TApplicationException x = new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, "Internal error processing setSystemProperty");
- oprot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("setSystemProperty", org.apache.thrift.protocol.TMessageType.EXCEPTION, seqid));
- x.write(oprot);
- oprot.writeMessageEnd();
- oprot.getTransport().flush();
- return;
- }
- oprot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("setSystemProperty", org.apache.thrift.protocol.TMessageType.REPLY, seqid));
- result.write(oprot);
- oprot.writeMessageEnd();
- oprot.getTransport().flush();
+ }
+ return result;
}
-
}
- private class removeSystemProperty implements ProcessFunction {
- public void process(int seqid, org.apache.thrift.protocol.TProtocol iprot, org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException
- {
- removeSystemProperty_args args = new removeSystemProperty_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("removeSystemProperty", org.apache.thrift.protocol.TMessageType.EXCEPTION, seqid));
- x.write(oprot);
- oprot.writeMessageEnd();
- oprot.getTransport().flush();
- return;
- }
- iprot.readMessageEnd();
+ private static class removeSystemProperty<I extends Iface> extends org.apache.thrift.ProcessFunction<I, removeSystemProperty_args> {
+ public removeSystemProperty() {
+ super("removeSystemProperty");
+ }
+
+ protected removeSystemProperty_args getEmptyArgsInstance() {
+ return new removeSystemProperty_args();
+ }
+
+ protected removeSystemProperty_result getResult(I iface, removeSystemProperty_args args) throws org.apache.thrift.TException {
removeSystemProperty_result result = new removeSystemProperty_result();
try {
- iface_.removeSystemProperty(args.tinfo, args.credentials, args.property);
+ iface.removeSystemProperty(args.tinfo, args.credentials, args.property);
} catch (org.apache.accumulo.core.security.thrift.ThriftSecurityException sec) {
result.sec = sec;
- } catch (Throwable th) {
- LOGGER.error("Internal error processing removeSystemProperty", th);
- org.apache.thrift.TApplicationException x = new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, "Internal error processing removeSystemProperty");
- oprot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("removeSystemProperty", org.apache.thrift.protocol.TMessageType.EXCEPTION, seqid));
- x.write(oprot);
- oprot.writeMessageEnd();
- oprot.getTransport().flush();
- return;
- }
- oprot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("removeSystemProperty", org.apache.thrift.protocol.TMessageType.REPLY, seqid));
- result.write(oprot);
- oprot.writeMessageEnd();
- oprot.getTransport().flush();
+ }
+ return result;
}
-
}
- private class getMasterStats implements ProcessFunction {
- public void process(int seqid, org.apache.thrift.protocol.TProtocol iprot, org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException
- {
- getMasterStats_args args = new getMasterStats_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("getMasterStats", org.apache.thrift.protocol.TMessageType.EXCEPTION, seqid));
- x.write(oprot);
- oprot.writeMessageEnd();
- oprot.getTransport().flush();
- return;
- }
- iprot.readMessageEnd();
+ private static class getMasterStats<I extends Iface> extends org.apache.thrift.ProcessFunction<I, getMasterStats_args> {
+ public getMasterStats() {
+ super("getMasterStats");
+ }
+
+ protected getMasterStats_args getEmptyArgsInstance() {
+ return new getMasterStats_args();
+ }
+
+ protected getMasterStats_result getResult(I iface, getMasterStats_args args) throws org.apache.thrift.TException {
getMasterStats_result result = new getMasterStats_result();
try {
- result.success = iface_.getMasterStats(args.tinfo, args.credentials);
+ result.success = iface.getMasterStats(args.tinfo, args.credentials);
} catch (org.apache.accumulo.core.security.thrift.ThriftSecurityException sec) {
result.sec = sec;
- } catch (Throwable th) {
- LOGGER.error("Internal error processing getMasterStats", th);
- org.apache.thrift.TApplicationException x = new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, "Internal error processing getMasterStats");
- oprot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("getMasterStats", org.apache.thrift.protocol.TMessageType.EXCEPTION, seqid));
- x.write(oprot);
- oprot.writeMessageEnd();
- oprot.getTransport().flush();
- return;
- }
- oprot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("getMasterStats", org.apache.thrift.protocol.TMessageType.REPLY, seqid));
- result.write(oprot);
- oprot.writeMessageEnd();
- oprot.getTransport().flush();
+ }
+ return result;
}
-
}
- private class reportSplitExtent implements ProcessFunction {
- public void process(int seqid, org.apache.thrift.protocol.TProtocol iprot, org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException
- {
- reportSplitExtent_args args = new reportSplitExtent_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("reportSplitExtent", org.apache.thrift.protocol.TMessageType.EXCEPTION, seqid));
- x.write(oprot);
- oprot.writeMessageEnd();
- oprot.getTransport().flush();
- return;
- }
- iprot.readMessageEnd();
- iface_.reportSplitExtent(args.tinfo, args.credentials, args.serverName, args.split);
- return;
+ private static class reportSplitExtent<I extends Iface> extends org.apache.thrift.ProcessFunction<I, reportSplitExtent_args> {
+ public reportSplitExtent() {
+ super("reportSplitExtent");
+ }
+
+ protected reportSplitExtent_args getEmptyArgsInstance() {
+ return new reportSplitExtent_args();
+ }
+
+ protected org.apache.thrift.TBase getResult(I iface, reportSplitExtent_args args) throws org.apache.thrift.TException {
+ iface.reportSplitExtent(args.tinfo, args.credentials, args.serverName, args.split);
+ return null;
}
}
- private class reportTabletStatus implements ProcessFunction {
- public void process(int seqid, org.apache.thrift.protocol.TProtocol iprot, org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException
- {
- reportTabletStatus_args args = new reportTabletStatus_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("reportTabletStatus", org.apache.thrift.protocol.TMessageType.EXCEPTION, seqid));
- x.write(oprot);
- oprot.writeMessageEnd();
- oprot.getTransport().flush();
- return;
- }
- iprot.readMessageEnd();
- iface_.reportTabletStatus(args.tinfo, args.credentials, args.serverName, args.status, args.tablet);
- return;
+ private static class reportTabletStatus<I extends Iface> extends org.apache.thrift.ProcessFunction<I, reportTabletStatus_args> {
+ public reportTabletStatus() {
+ super("reportTabletStatus");
+ }
+
+ protected reportTabletStatus_args getEmptyArgsInstance() {
+ return new reportTabletStatus_args();
+ }
+
+ protected org.apache.thrift.TBase getResult(I iface, reportTabletStatus_args args) throws org.apache.thrift.TException {
+ iface.reportTabletStatus(args.tinfo, args.credentials, args.serverName, args.status, args.tablet);
+ return null;
}
}
- private class beginTableOperation implements ProcessFunction {
- public void process(int seqid, org.apache.thrift.protocol.TProtocol iprot, org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException
- {
- beginTableOperation_args args = new beginTableOperation_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("beginTableOperation", org.apache.thrift.protocol.TMessageType.EXCEPTION, seqid));
- x.write(oprot);
- oprot.writeMessageEnd();
- oprot.getTransport().flush();
- return;
- }
- iprot.readMessageEnd();
+ private static class beginTableOperation<I extends Iface> extends org.apache.thrift.ProcessFunction<I, beginTableOperation_args> {
+ public beginTableOperation() {
+ super("beginTableOperation");
+ }
+
+ protected beginTableOperation_args getEmptyArgsInstance() {
+ return new beginTableOperation_args();
+ }
+
+ protected beginTableOperation_result getResult(I iface, beginTableOperation_args args) throws org.apache.thrift.TException {
beginTableOperation_result result = new beginTableOperation_result();
try {
- result.success = iface_.beginTableOperation(args.tinfo, args.credentials);
+ result.success = iface.beginTableOperation(args.tinfo, args.credentials);
result.setSuccessIsSet(true);
} catch (org.apache.accumulo.core.security.thrift.ThriftSecurityException sec) {
result.sec = sec;
- } catch (Throwable th) {
- LOGGER.error("Internal error processing beginTableOperation", th);
- org.apache.thrift.TApplicationException x = new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, "Internal error processing beginTableOperation");
- oprot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("beginTableOperation", org.apache.thrift.protocol.TMessageType.EXCEPTION, seqid));
- x.write(oprot);
- oprot.writeMessageEnd();
- oprot.getTransport().flush();
- return;
- }
- oprot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("beginTableOperation", org.apache.thrift.protocol.TMessageType.REPLY, seqid));
- result.write(oprot);
- oprot.writeMessageEnd();
- oprot.getTransport().flush();
+ }
+ return result;
}
-
}
- private class executeTableOperation implements ProcessFunction {
- public void process(int seqid, org.apache.thrift.protocol.TProtocol iprot, org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException
- {
- executeTableOperation_args args = new executeTableOperation_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("executeTableOperation", org.apache.thrift.protocol.TMessageType.EXCEPTION, seqid));
- x.write(oprot);
- oprot.writeMessageEnd();
- oprot.getTransport().flush();
- return;
- }
- iprot.readMessageEnd();
+ private static class executeTableOperation<I extends Iface> extends org.apache.thrift.ProcessFunction<I, executeTableOperation_args> {
+ public executeTableOperation() {
+ super("executeTableOperation");
+ }
+
+ protected executeTableOperation_args getEmptyArgsInstance() {
+ return new executeTableOperation_args();
+ }
+
+ protected executeTableOperation_result getResult(I iface, executeTableOperation_args args) throws org.apache.thrift.TException {
executeTableOperation_result result = new executeTableOperation_result();
try {
- iface_.executeTableOperation(args.tinfo, args.credentials, args.opid, args.op, args.arguments, args.options, args.autoClean);
+ iface.executeTableOperation(args.tinfo, args.credentials, args.opid, args.op, args.arguments, args.options, args.autoClean);
} catch (org.apache.accumulo.core.security.thrift.ThriftSecurityException sec) {
result.sec = sec;
} catch (org.apache.accumulo.core.client.impl.thrift.ThriftTableOperationException tope) {
result.tope = tope;
- } catch (Throwable th) {
- LOGGER.error("Internal error processing executeTableOperation", th);
- org.apache.thrift.TApplicationException x = new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, "Internal error processing executeTableOperation");
- oprot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("executeTableOperation", org.apache.thrift.protocol.TMessageType.EXCEPTION, seqid));
- x.write(oprot);
- oprot.writeMessageEnd();
- oprot.getTransport().flush();
- return;
- }
- oprot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("executeTableOperation", org.apache.thrift.protocol.TMessageType.REPLY, seqid));
- result.write(oprot);
- oprot.writeMessageEnd();
- oprot.getTransport().flush();
+ }
+ return result;
}
-
}
- private class waitForTableOperation implements ProcessFunction {
- public void process(int seqid, org.apache.thrift.protocol.TProtocol iprot, org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException
- {
- waitForTableOperation_args args = new waitForTableOperation_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("waitForTableOperation", org.apache.thrift.protocol.TMessageType.EXCEPTION, seqid));
- x.write(oprot);
- oprot.writeMessageEnd();
- oprot.getTransport().flush();
- return;
- }
- iprot.readMessageEnd();
+ private static class waitForTableOperation<I extends Iface> extends org.apache.thrift.ProcessFunction<I, waitForTableOperation_args> {
+ public waitForTableOperation() {
+ super("waitForTableOperation");
+ }
+
+ protected waitForTableOperation_args getEmptyArgsInstance() {
+ return new waitForTableOperation_args();
+ }
+
+ protected waitForTableOperation_result getResult(I iface, waitForTableOperation_args args) throws org.apache.thrift.TException {
waitForTableOperation_result result = new waitForTableOperation_result();
try {
- result.success = iface_.waitForTableOperation(args.tinfo, args.credentials, args.opid);
+ result.success = iface.waitForTableOperation(args.tinfo, args.credentials, args.opid);
} catch (org.apache.accumulo.core.security.thrift.ThriftSecurityException sec) {
result.sec = sec;
} catch (org.apache.accumulo.core.client.impl.thrift.ThriftTableOperationException tope) {
result.tope = tope;
- } catch (Throwable th) {
- LOGGER.error("Internal error processing waitForTableOperation", th);
- org.apache.thrift.TApplicationException x = new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, "Internal error processing waitForTableOperation");
- oprot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("waitForTableOperation", org.apache.thrift.protocol.TMessageType.EXCEPTION, seqid));
- x.write(oprot);
- oprot.writeMessageEnd();
- oprot.getTransport().flush();
- return;
- }
- oprot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("waitForTableOperation", org.apache.thrift.protocol.TMessageType.REPLY, seqid));
- result.write(oprot);
- oprot.writeMessageEnd();
- oprot.getTransport().flush();
+ }
+ return result;
}
-
}
- private class finishTableOperation implements ProcessFunction {
- public void process(int seqid, org.apache.thrift.protocol.TProtocol iprot, org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException
- {
- finishTableOperation_args args = new finishTableOperation_args();
- try {
- args.read(iprot);
- } catch (org.apache.thrift.protocol.TProtocolException e) {
- iprot.readMessageEnd();
[... 7333 lines stripped ...]