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 [8/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/master/thrift/TabletServerStatus.java
URL: http://svn.apache.org/viewvc/accumulo/trunk/core/src/main/java/org/apache/accumulo/core/master/thrift/TabletServerStatus.java?rev=1359639&r1=1359638&r2=1359639&view=diff
==============================================================================
--- accumulo/trunk/core/src/main/java/org/apache/accumulo/core/master/thrift/TabletServerStatus.java (original)
+++ accumulo/trunk/core/src/main/java/org/apache/accumulo/core/master/thrift/TabletServerStatus.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.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;
@@ -35,17 +42,23 @@ import org.slf4j.LoggerFactory;
private static final org.apache.thrift.protocol.TField DATA_CACHE_REQUEST_FIELD_DESC = new org.apache.thrift.protocol.TField("dataCacheRequest", org.apache.thrift.protocol.TType.I64, (short)13);
private static final org.apache.thrift.protocol.TField LOG_SORTS_FIELD_DESC = new org.apache.thrift.protocol.TField("logSorts", org.apache.thrift.protocol.TType.LIST, (short)14);
- public Map<String,TableInfo> tableMap;
- public long lastContact;
- public String name;
- public double osLoad;
- public long holdTime;
- public long lookups;
- public long indexCacheHits;
- public long indexCacheRequest;
- public long dataCacheHits;
- public long dataCacheRequest;
- public List<RecoveryStatus> logSorts;
+ private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
+ static {
+ schemes.put(StandardScheme.class, new TabletServerStatusStandardSchemeFactory());
+ schemes.put(TupleScheme.class, new TabletServerStatusTupleSchemeFactory());
+ }
+
+ public Map<String,TableInfo> tableMap; // required
+ public long lastContact; // required
+ public String name; // required
+ public double osLoad; // required
+ public long holdTime; // required
+ public long lookups; // required
+ public long indexCacheHits; // required
+ public long indexCacheRequest; // required
+ public long dataCacheHits; // required
+ public long dataCacheRequest; // required
+ public List<RecoveryStatus> logSorts; // required
/** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */
public enum _Fields implements org.apache.thrift.TFieldIdEnum {
@@ -145,7 +158,6 @@ import org.slf4j.LoggerFactory;
private static final int __DATACACHEHITS_ISSET_ID = 6;
private static final int __DATACACHEREQUEST_ISSET_ID = 7;
private BitSet __isset_bit_vector = new BitSet(8);
-
public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap;
static {
Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class);
@@ -665,31 +677,31 @@ import org.slf4j.LoggerFactory;
return getTableMap();
case LAST_CONTACT:
- return new Long(getLastContact());
+ return Long.valueOf(getLastContact());
case NAME:
return getName();
case OS_LOAD:
- return new Double(getOsLoad());
+ return Double.valueOf(getOsLoad());
case HOLD_TIME:
- return new Long(getHoldTime());
+ return Long.valueOf(getHoldTime());
case LOOKUPS:
- return new Long(getLookups());
+ return Long.valueOf(getLookups());
case INDEX_CACHE_HITS:
- return new Long(getIndexCacheHits());
+ return Long.valueOf(getIndexCacheHits());
case INDEX_CACHE_REQUEST:
- return new Long(getIndexCacheRequest());
+ return Long.valueOf(getIndexCacheRequest());
case DATA_CACHE_HITS:
- return new Long(getDataCacheHits());
+ return Long.valueOf(getDataCacheHits());
case DATA_CACHE_REQUEST:
- return new Long(getDataCacheRequest());
+ return Long.valueOf(getDataCacheRequest());
case LOG_SORTS:
return getLogSorts();
@@ -977,195 +989,11 @@ import org.slf4j.LoggerFactory;
}
public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException {
- org.apache.thrift.protocol.TField field;
- iprot.readStructBegin();
- while (true)
- {
- field = iprot.readFieldBegin();
- if (field.type == org.apache.thrift.protocol.TType.STOP) {
- break;
- }
- switch (field.id) {
- case 1: // TABLE_MAP
- if (field.type == org.apache.thrift.protocol.TType.MAP) {
- {
- org.apache.thrift.protocol.TMap _map0 = iprot.readMapBegin();
- this.tableMap = new HashMap<String,TableInfo>(2*_map0.size);
- for (int _i1 = 0; _i1 < _map0.size; ++_i1)
- {
- String _key2;
- TableInfo _val3;
- _key2 = iprot.readString();
- _val3 = new TableInfo();
- _val3.read(iprot);
- this.tableMap.put(_key2, _val3);
- }
- iprot.readMapEnd();
- }
- } else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
- }
- break;
- case 2: // LAST_CONTACT
- if (field.type == org.apache.thrift.protocol.TType.I64) {
- this.lastContact = iprot.readI64();
- setLastContactIsSet(true);
- } else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
- }
- break;
- case 3: // NAME
- if (field.type == org.apache.thrift.protocol.TType.STRING) {
- this.name = iprot.readString();
- } else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
- }
- break;
- case 5: // OS_LOAD
- if (field.type == org.apache.thrift.protocol.TType.DOUBLE) {
- this.osLoad = iprot.readDouble();
- setOsLoadIsSet(true);
- } else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
- }
- break;
- case 7: // HOLD_TIME
- if (field.type == org.apache.thrift.protocol.TType.I64) {
- this.holdTime = iprot.readI64();
- setHoldTimeIsSet(true);
- } else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
- }
- break;
- case 8: // LOOKUPS
- if (field.type == org.apache.thrift.protocol.TType.I64) {
- this.lookups = iprot.readI64();
- setLookupsIsSet(true);
- } else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
- }
- break;
- case 10: // INDEX_CACHE_HITS
- if (field.type == org.apache.thrift.protocol.TType.I64) {
- this.indexCacheHits = iprot.readI64();
- setIndexCacheHitsIsSet(true);
- } else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
- }
- break;
- case 11: // INDEX_CACHE_REQUEST
- if (field.type == org.apache.thrift.protocol.TType.I64) {
- this.indexCacheRequest = iprot.readI64();
- setIndexCacheRequestIsSet(true);
- } else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
- }
- break;
- case 12: // DATA_CACHE_HITS
- if (field.type == org.apache.thrift.protocol.TType.I64) {
- this.dataCacheHits = iprot.readI64();
- setDataCacheHitsIsSet(true);
- } else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
- }
- break;
- case 13: // DATA_CACHE_REQUEST
- if (field.type == org.apache.thrift.protocol.TType.I64) {
- this.dataCacheRequest = iprot.readI64();
- setDataCacheRequestIsSet(true);
- } else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
- }
- break;
- case 14: // LOG_SORTS
- if (field.type == org.apache.thrift.protocol.TType.LIST) {
- {
- org.apache.thrift.protocol.TList _list4 = iprot.readListBegin();
- this.logSorts = new ArrayList<RecoveryStatus>(_list4.size);
- for (int _i5 = 0; _i5 < _list4.size; ++_i5)
- {
- RecoveryStatus _elem6;
- _elem6 = new RecoveryStatus();
- _elem6.read(iprot);
- this.logSorts.add(_elem6);
- }
- iprot.readListEnd();
- }
- } else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
- }
- break;
- default:
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
- }
- iprot.readFieldEnd();
- }
- iprot.readStructEnd();
-
- // check for required fields of primitive type, which can't be checked in the validate method
- validate();
+ schemes.get(iprot.getScheme()).getScheme().read(iprot, this);
}
public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException {
- validate();
-
- oprot.writeStructBegin(STRUCT_DESC);
- if (this.tableMap != null) {
- oprot.writeFieldBegin(TABLE_MAP_FIELD_DESC);
- {
- oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRUCT, this.tableMap.size()));
- for (Map.Entry<String, TableInfo> _iter7 : this.tableMap.entrySet())
- {
- oprot.writeString(_iter7.getKey());
- _iter7.getValue().write(oprot);
- }
- oprot.writeMapEnd();
- }
- oprot.writeFieldEnd();
- }
- oprot.writeFieldBegin(LAST_CONTACT_FIELD_DESC);
- oprot.writeI64(this.lastContact);
- oprot.writeFieldEnd();
- if (this.name != null) {
- oprot.writeFieldBegin(NAME_FIELD_DESC);
- oprot.writeString(this.name);
- oprot.writeFieldEnd();
- }
- oprot.writeFieldBegin(OS_LOAD_FIELD_DESC);
- oprot.writeDouble(this.osLoad);
- oprot.writeFieldEnd();
- oprot.writeFieldBegin(HOLD_TIME_FIELD_DESC);
- oprot.writeI64(this.holdTime);
- oprot.writeFieldEnd();
- oprot.writeFieldBegin(LOOKUPS_FIELD_DESC);
- oprot.writeI64(this.lookups);
- oprot.writeFieldEnd();
- oprot.writeFieldBegin(INDEX_CACHE_HITS_FIELD_DESC);
- oprot.writeI64(this.indexCacheHits);
- oprot.writeFieldEnd();
- oprot.writeFieldBegin(INDEX_CACHE_REQUEST_FIELD_DESC);
- oprot.writeI64(this.indexCacheRequest);
- oprot.writeFieldEnd();
- oprot.writeFieldBegin(DATA_CACHE_HITS_FIELD_DESC);
- oprot.writeI64(this.dataCacheHits);
- oprot.writeFieldEnd();
- oprot.writeFieldBegin(DATA_CACHE_REQUEST_FIELD_DESC);
- oprot.writeI64(this.dataCacheRequest);
- oprot.writeFieldEnd();
- if (this.logSorts != null) {
- oprot.writeFieldBegin(LOG_SORTS_FIELD_DESC);
- {
- oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, this.logSorts.size()));
- for (RecoveryStatus _iter8 : this.logSorts)
- {
- _iter8.write(oprot);
- }
- oprot.writeListEnd();
- }
- oprot.writeFieldEnd();
- }
- oprot.writeFieldStop();
- oprot.writeStructEnd();
+ schemes.get(oprot.getScheme()).getScheme().write(oprot, this);
}
@Override
@@ -1254,5 +1082,377 @@ import org.slf4j.LoggerFactory;
}
}
+ private static class TabletServerStatusStandardSchemeFactory implements SchemeFactory {
+ public TabletServerStatusStandardScheme getScheme() {
+ return new TabletServerStatusStandardScheme();
+ }
+ }
+
+ private static class TabletServerStatusStandardScheme extends StandardScheme<TabletServerStatus> {
+
+ public void read(org.apache.thrift.protocol.TProtocol iprot, TabletServerStatus struct) throws org.apache.thrift.TException {
+ org.apache.thrift.protocol.TField schemeField;
+ iprot.readStructBegin();
+ while (true)
+ {
+ schemeField = iprot.readFieldBegin();
+ if (schemeField.type == org.apache.thrift.protocol.TType.STOP) {
+ break;
+ }
+ switch (schemeField.id) {
+ case 1: // TABLE_MAP
+ if (schemeField.type == org.apache.thrift.protocol.TType.MAP) {
+ {
+ org.apache.thrift.protocol.TMap _map0 = iprot.readMapBegin();
+ struct.tableMap = new HashMap<String,TableInfo>(2*_map0.size);
+ for (int _i1 = 0; _i1 < _map0.size; ++_i1)
+ {
+ String _key2; // required
+ TableInfo _val3; // required
+ _key2 = iprot.readString();
+ _val3 = new TableInfo();
+ _val3.read(iprot);
+ struct.tableMap.put(_key2, _val3);
+ }
+ iprot.readMapEnd();
+ }
+ struct.setTableMapIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ case 2: // LAST_CONTACT
+ if (schemeField.type == org.apache.thrift.protocol.TType.I64) {
+ struct.lastContact = iprot.readI64();
+ struct.setLastContactIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ case 3: // NAME
+ if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
+ struct.name = iprot.readString();
+ struct.setNameIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ case 5: // OS_LOAD
+ if (schemeField.type == org.apache.thrift.protocol.TType.DOUBLE) {
+ struct.osLoad = iprot.readDouble();
+ struct.setOsLoadIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ case 7: // HOLD_TIME
+ if (schemeField.type == org.apache.thrift.protocol.TType.I64) {
+ struct.holdTime = iprot.readI64();
+ struct.setHoldTimeIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ case 8: // LOOKUPS
+ if (schemeField.type == org.apache.thrift.protocol.TType.I64) {
+ struct.lookups = iprot.readI64();
+ struct.setLookupsIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ case 10: // INDEX_CACHE_HITS
+ if (schemeField.type == org.apache.thrift.protocol.TType.I64) {
+ struct.indexCacheHits = iprot.readI64();
+ struct.setIndexCacheHitsIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ case 11: // INDEX_CACHE_REQUEST
+ if (schemeField.type == org.apache.thrift.protocol.TType.I64) {
+ struct.indexCacheRequest = iprot.readI64();
+ struct.setIndexCacheRequestIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ case 12: // DATA_CACHE_HITS
+ if (schemeField.type == org.apache.thrift.protocol.TType.I64) {
+ struct.dataCacheHits = iprot.readI64();
+ struct.setDataCacheHitsIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ case 13: // DATA_CACHE_REQUEST
+ if (schemeField.type == org.apache.thrift.protocol.TType.I64) {
+ struct.dataCacheRequest = iprot.readI64();
+ struct.setDataCacheRequestIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ case 14: // LOG_SORTS
+ if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
+ {
+ org.apache.thrift.protocol.TList _list4 = iprot.readListBegin();
+ struct.logSorts = new ArrayList<RecoveryStatus>(_list4.size);
+ for (int _i5 = 0; _i5 < _list4.size; ++_i5)
+ {
+ RecoveryStatus _elem6; // required
+ _elem6 = new RecoveryStatus();
+ _elem6.read(iprot);
+ struct.logSorts.add(_elem6);
+ }
+ iprot.readListEnd();
+ }
+ struct.setLogSortsIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ default:
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ iprot.readFieldEnd();
+ }
+ iprot.readStructEnd();
+
+ // check for required fields of primitive type, which can't be checked in the validate method
+ struct.validate();
+ }
+
+ public void write(org.apache.thrift.protocol.TProtocol oprot, TabletServerStatus struct) throws org.apache.thrift.TException {
+ struct.validate();
+
+ oprot.writeStructBegin(STRUCT_DESC);
+ if (struct.tableMap != null) {
+ oprot.writeFieldBegin(TABLE_MAP_FIELD_DESC);
+ {
+ oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRUCT, struct.tableMap.size()));
+ for (Map.Entry<String, TableInfo> _iter7 : struct.tableMap.entrySet())
+ {
+ oprot.writeString(_iter7.getKey());
+ _iter7.getValue().write(oprot);
+ }
+ oprot.writeMapEnd();
+ }
+ oprot.writeFieldEnd();
+ }
+ oprot.writeFieldBegin(LAST_CONTACT_FIELD_DESC);
+ oprot.writeI64(struct.lastContact);
+ oprot.writeFieldEnd();
+ if (struct.name != null) {
+ oprot.writeFieldBegin(NAME_FIELD_DESC);
+ oprot.writeString(struct.name);
+ oprot.writeFieldEnd();
+ }
+ oprot.writeFieldBegin(OS_LOAD_FIELD_DESC);
+ oprot.writeDouble(struct.osLoad);
+ oprot.writeFieldEnd();
+ oprot.writeFieldBegin(HOLD_TIME_FIELD_DESC);
+ oprot.writeI64(struct.holdTime);
+ oprot.writeFieldEnd();
+ oprot.writeFieldBegin(LOOKUPS_FIELD_DESC);
+ oprot.writeI64(struct.lookups);
+ oprot.writeFieldEnd();
+ oprot.writeFieldBegin(INDEX_CACHE_HITS_FIELD_DESC);
+ oprot.writeI64(struct.indexCacheHits);
+ oprot.writeFieldEnd();
+ oprot.writeFieldBegin(INDEX_CACHE_REQUEST_FIELD_DESC);
+ oprot.writeI64(struct.indexCacheRequest);
+ oprot.writeFieldEnd();
+ oprot.writeFieldBegin(DATA_CACHE_HITS_FIELD_DESC);
+ oprot.writeI64(struct.dataCacheHits);
+ oprot.writeFieldEnd();
+ oprot.writeFieldBegin(DATA_CACHE_REQUEST_FIELD_DESC);
+ oprot.writeI64(struct.dataCacheRequest);
+ oprot.writeFieldEnd();
+ if (struct.logSorts != null) {
+ oprot.writeFieldBegin(LOG_SORTS_FIELD_DESC);
+ {
+ oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.logSorts.size()));
+ for (RecoveryStatus _iter8 : struct.logSorts)
+ {
+ _iter8.write(oprot);
+ }
+ oprot.writeListEnd();
+ }
+ oprot.writeFieldEnd();
+ }
+ oprot.writeFieldStop();
+ oprot.writeStructEnd();
+ }
+
+ }
+
+ private static class TabletServerStatusTupleSchemeFactory implements SchemeFactory {
+ public TabletServerStatusTupleScheme getScheme() {
+ return new TabletServerStatusTupleScheme();
+ }
+ }
+
+ private static class TabletServerStatusTupleScheme extends TupleScheme<TabletServerStatus> {
+
+ @Override
+ public void write(org.apache.thrift.protocol.TProtocol prot, TabletServerStatus struct) throws org.apache.thrift.TException {
+ TTupleProtocol oprot = (TTupleProtocol) prot;
+ BitSet optionals = new BitSet();
+ if (struct.isSetTableMap()) {
+ optionals.set(0);
+ }
+ if (struct.isSetLastContact()) {
+ optionals.set(1);
+ }
+ if (struct.isSetName()) {
+ optionals.set(2);
+ }
+ if (struct.isSetOsLoad()) {
+ optionals.set(3);
+ }
+ if (struct.isSetHoldTime()) {
+ optionals.set(4);
+ }
+ if (struct.isSetLookups()) {
+ optionals.set(5);
+ }
+ if (struct.isSetIndexCacheHits()) {
+ optionals.set(6);
+ }
+ if (struct.isSetIndexCacheRequest()) {
+ optionals.set(7);
+ }
+ if (struct.isSetDataCacheHits()) {
+ optionals.set(8);
+ }
+ if (struct.isSetDataCacheRequest()) {
+ optionals.set(9);
+ }
+ if (struct.isSetLogSorts()) {
+ optionals.set(10);
+ }
+ oprot.writeBitSet(optionals, 11);
+ if (struct.isSetTableMap()) {
+ {
+ oprot.writeI32(struct.tableMap.size());
+ for (Map.Entry<String, TableInfo> _iter9 : struct.tableMap.entrySet())
+ {
+ oprot.writeString(_iter9.getKey());
+ _iter9.getValue().write(oprot);
+ }
+ }
+ }
+ if (struct.isSetLastContact()) {
+ oprot.writeI64(struct.lastContact);
+ }
+ if (struct.isSetName()) {
+ oprot.writeString(struct.name);
+ }
+ if (struct.isSetOsLoad()) {
+ oprot.writeDouble(struct.osLoad);
+ }
+ if (struct.isSetHoldTime()) {
+ oprot.writeI64(struct.holdTime);
+ }
+ if (struct.isSetLookups()) {
+ oprot.writeI64(struct.lookups);
+ }
+ if (struct.isSetIndexCacheHits()) {
+ oprot.writeI64(struct.indexCacheHits);
+ }
+ if (struct.isSetIndexCacheRequest()) {
+ oprot.writeI64(struct.indexCacheRequest);
+ }
+ if (struct.isSetDataCacheHits()) {
+ oprot.writeI64(struct.dataCacheHits);
+ }
+ if (struct.isSetDataCacheRequest()) {
+ oprot.writeI64(struct.dataCacheRequest);
+ }
+ if (struct.isSetLogSorts()) {
+ {
+ oprot.writeI32(struct.logSorts.size());
+ for (RecoveryStatus _iter10 : struct.logSorts)
+ {
+ _iter10.write(oprot);
+ }
+ }
+ }
+ }
+
+ @Override
+ public void read(org.apache.thrift.protocol.TProtocol prot, TabletServerStatus struct) throws org.apache.thrift.TException {
+ TTupleProtocol iprot = (TTupleProtocol) prot;
+ BitSet incoming = iprot.readBitSet(11);
+ if (incoming.get(0)) {
+ {
+ org.apache.thrift.protocol.TMap _map11 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.tableMap = new HashMap<String,TableInfo>(2*_map11.size);
+ for (int _i12 = 0; _i12 < _map11.size; ++_i12)
+ {
+ String _key13; // required
+ TableInfo _val14; // required
+ _key13 = iprot.readString();
+ _val14 = new TableInfo();
+ _val14.read(iprot);
+ struct.tableMap.put(_key13, _val14);
+ }
+ }
+ struct.setTableMapIsSet(true);
+ }
+ if (incoming.get(1)) {
+ struct.lastContact = iprot.readI64();
+ struct.setLastContactIsSet(true);
+ }
+ if (incoming.get(2)) {
+ struct.name = iprot.readString();
+ struct.setNameIsSet(true);
+ }
+ if (incoming.get(3)) {
+ struct.osLoad = iprot.readDouble();
+ struct.setOsLoadIsSet(true);
+ }
+ if (incoming.get(4)) {
+ struct.holdTime = iprot.readI64();
+ struct.setHoldTimeIsSet(true);
+ }
+ if (incoming.get(5)) {
+ struct.lookups = iprot.readI64();
+ struct.setLookupsIsSet(true);
+ }
+ if (incoming.get(6)) {
+ struct.indexCacheHits = iprot.readI64();
+ struct.setIndexCacheHitsIsSet(true);
+ }
+ if (incoming.get(7)) {
+ struct.indexCacheRequest = iprot.readI64();
+ struct.setIndexCacheRequestIsSet(true);
+ }
+ if (incoming.get(8)) {
+ struct.dataCacheHits = iprot.readI64();
+ struct.setDataCacheHitsIsSet(true);
+ }
+ if (incoming.get(9)) {
+ struct.dataCacheRequest = iprot.readI64();
+ struct.setDataCacheRequestIsSet(true);
+ }
+ if (incoming.get(10)) {
+ {
+ org.apache.thrift.protocol.TList _list15 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.logSorts = new ArrayList<RecoveryStatus>(_list15.size);
+ for (int _i16 = 0; _i16 < _list15.size; ++_i16)
+ {
+ RecoveryStatus _elem17; // required
+ _elem17 = new RecoveryStatus();
+ _elem17.read(iprot);
+ struct.logSorts.add(_elem17);
+ }
+ }
+ struct.setLogSortsIsSet(true);
+ }
+ }
+ }
+
}
Modified: accumulo/trunk/core/src/main/java/org/apache/accumulo/core/master/thrift/TabletSplit.java
URL: http://svn.apache.org/viewvc/accumulo/trunk/core/src/main/java/org/apache/accumulo/core/master/thrift/TabletSplit.java?rev=1359639&r1=1359638&r2=1359639&view=diff
==============================================================================
--- accumulo/trunk/core/src/main/java/org/apache/accumulo/core/master/thrift/TabletSplit.java (original)
+++ accumulo/trunk/core/src/main/java/org/apache/accumulo/core/master/thrift/TabletSplit.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.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;
@@ -26,8 +33,14 @@ import org.slf4j.LoggerFactory;
private static final org.apache.thrift.protocol.TField OLD_TABLET_FIELD_DESC = new org.apache.thrift.protocol.TField("oldTablet", org.apache.thrift.protocol.TType.STRUCT, (short)1);
private static final org.apache.thrift.protocol.TField NEW_TABLETS_FIELD_DESC = new org.apache.thrift.protocol.TField("newTablets", org.apache.thrift.protocol.TType.LIST, (short)2);
- public org.apache.accumulo.core.data.thrift.TKeyExtent oldTablet;
- public List<org.apache.accumulo.core.data.thrift.TKeyExtent> newTablets;
+ private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
+ static {
+ schemes.put(StandardScheme.class, new TabletSplitStandardSchemeFactory());
+ schemes.put(TupleScheme.class, new TabletSplitTupleSchemeFactory());
+ }
+
+ public org.apache.accumulo.core.data.thrift.TKeyExtent oldTablet; // required
+ public List<org.apache.accumulo.core.data.thrift.TKeyExtent> newTablets; // required
/** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */
public enum _Fields implements org.apache.thrift.TFieldIdEnum {
@@ -91,7 +104,6 @@ import org.slf4j.LoggerFactory;
}
// isset id assignments
-
public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap;
static {
Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class);
@@ -328,75 +340,11 @@ import org.slf4j.LoggerFactory;
}
public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException {
- org.apache.thrift.protocol.TField field;
- iprot.readStructBegin();
- while (true)
- {
- field = iprot.readFieldBegin();
- if (field.type == org.apache.thrift.protocol.TType.STOP) {
- break;
- }
- switch (field.id) {
- case 1: // OLD_TABLET
- if (field.type == org.apache.thrift.protocol.TType.STRUCT) {
- this.oldTablet = new org.apache.accumulo.core.data.thrift.TKeyExtent();
- this.oldTablet.read(iprot);
- } else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
- }
- break;
- case 2: // NEW_TABLETS
- if (field.type == org.apache.thrift.protocol.TType.LIST) {
- {
- org.apache.thrift.protocol.TList _list31 = iprot.readListBegin();
- this.newTablets = new ArrayList<org.apache.accumulo.core.data.thrift.TKeyExtent>(_list31.size);
- for (int _i32 = 0; _i32 < _list31.size; ++_i32)
- {
- org.apache.accumulo.core.data.thrift.TKeyExtent _elem33;
- _elem33 = new org.apache.accumulo.core.data.thrift.TKeyExtent();
- _elem33.read(iprot);
- this.newTablets.add(_elem33);
- }
- iprot.readListEnd();
- }
- } else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
- }
- break;
- default:
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
- }
- iprot.readFieldEnd();
- }
- iprot.readStructEnd();
-
- // check for required fields of primitive type, which can't be checked in the validate method
- validate();
+ schemes.get(iprot.getScheme()).getScheme().read(iprot, this);
}
public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException {
- validate();
-
- oprot.writeStructBegin(STRUCT_DESC);
- if (this.oldTablet != null) {
- oprot.writeFieldBegin(OLD_TABLET_FIELD_DESC);
- this.oldTablet.write(oprot);
- oprot.writeFieldEnd();
- }
- if (this.newTablets != null) {
- oprot.writeFieldBegin(NEW_TABLETS_FIELD_DESC);
- {
- oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, this.newTablets.size()));
- for (org.apache.accumulo.core.data.thrift.TKeyExtent _iter34 : this.newTablets)
- {
- _iter34.write(oprot);
- }
- oprot.writeListEnd();
- }
- oprot.writeFieldEnd();
- }
- oprot.writeFieldStop();
- oprot.writeStructEnd();
+ schemes.get(oprot.getScheme()).getScheme().write(oprot, this);
}
@Override
@@ -443,5 +391,148 @@ import org.slf4j.LoggerFactory;
}
}
+ private static class TabletSplitStandardSchemeFactory implements SchemeFactory {
+ public TabletSplitStandardScheme getScheme() {
+ return new TabletSplitStandardScheme();
+ }
+ }
+
+ private static class TabletSplitStandardScheme extends StandardScheme<TabletSplit> {
+
+ public void read(org.apache.thrift.protocol.TProtocol iprot, TabletSplit struct) throws org.apache.thrift.TException {
+ org.apache.thrift.protocol.TField schemeField;
+ iprot.readStructBegin();
+ while (true)
+ {
+ schemeField = iprot.readFieldBegin();
+ if (schemeField.type == org.apache.thrift.protocol.TType.STOP) {
+ break;
+ }
+ switch (schemeField.id) {
+ case 1: // OLD_TABLET
+ if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) {
+ struct.oldTablet = new org.apache.accumulo.core.data.thrift.TKeyExtent();
+ struct.oldTablet.read(iprot);
+ struct.setOldTabletIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ case 2: // NEW_TABLETS
+ if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
+ {
+ org.apache.thrift.protocol.TList _list62 = iprot.readListBegin();
+ struct.newTablets = new ArrayList<org.apache.accumulo.core.data.thrift.TKeyExtent>(_list62.size);
+ for (int _i63 = 0; _i63 < _list62.size; ++_i63)
+ {
+ org.apache.accumulo.core.data.thrift.TKeyExtent _elem64; // required
+ _elem64 = new org.apache.accumulo.core.data.thrift.TKeyExtent();
+ _elem64.read(iprot);
+ struct.newTablets.add(_elem64);
+ }
+ iprot.readListEnd();
+ }
+ struct.setNewTabletsIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ default:
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ iprot.readFieldEnd();
+ }
+ iprot.readStructEnd();
+
+ // check for required fields of primitive type, which can't be checked in the validate method
+ struct.validate();
+ }
+
+ public void write(org.apache.thrift.protocol.TProtocol oprot, TabletSplit struct) throws org.apache.thrift.TException {
+ struct.validate();
+
+ oprot.writeStructBegin(STRUCT_DESC);
+ if (struct.oldTablet != null) {
+ oprot.writeFieldBegin(OLD_TABLET_FIELD_DESC);
+ struct.oldTablet.write(oprot);
+ oprot.writeFieldEnd();
+ }
+ if (struct.newTablets != null) {
+ oprot.writeFieldBegin(NEW_TABLETS_FIELD_DESC);
+ {
+ oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.newTablets.size()));
+ for (org.apache.accumulo.core.data.thrift.TKeyExtent _iter65 : struct.newTablets)
+ {
+ _iter65.write(oprot);
+ }
+ oprot.writeListEnd();
+ }
+ oprot.writeFieldEnd();
+ }
+ oprot.writeFieldStop();
+ oprot.writeStructEnd();
+ }
+
+ }
+
+ private static class TabletSplitTupleSchemeFactory implements SchemeFactory {
+ public TabletSplitTupleScheme getScheme() {
+ return new TabletSplitTupleScheme();
+ }
+ }
+
+ private static class TabletSplitTupleScheme extends TupleScheme<TabletSplit> {
+
+ @Override
+ public void write(org.apache.thrift.protocol.TProtocol prot, TabletSplit struct) throws org.apache.thrift.TException {
+ TTupleProtocol oprot = (TTupleProtocol) prot;
+ BitSet optionals = new BitSet();
+ if (struct.isSetOldTablet()) {
+ optionals.set(0);
+ }
+ if (struct.isSetNewTablets()) {
+ optionals.set(1);
+ }
+ oprot.writeBitSet(optionals, 2);
+ if (struct.isSetOldTablet()) {
+ struct.oldTablet.write(oprot);
+ }
+ if (struct.isSetNewTablets()) {
+ {
+ oprot.writeI32(struct.newTablets.size());
+ for (org.apache.accumulo.core.data.thrift.TKeyExtent _iter66 : struct.newTablets)
+ {
+ _iter66.write(oprot);
+ }
+ }
+ }
+ }
+
+ @Override
+ public void read(org.apache.thrift.protocol.TProtocol prot, TabletSplit struct) throws org.apache.thrift.TException {
+ TTupleProtocol iprot = (TTupleProtocol) prot;
+ BitSet incoming = iprot.readBitSet(2);
+ if (incoming.get(0)) {
+ struct.oldTablet = new org.apache.accumulo.core.data.thrift.TKeyExtent();
+ struct.oldTablet.read(iprot);
+ struct.setOldTabletIsSet(true);
+ }
+ if (incoming.get(1)) {
+ {
+ org.apache.thrift.protocol.TList _list67 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.newTablets = new ArrayList<org.apache.accumulo.core.data.thrift.TKeyExtent>(_list67.size);
+ for (int _i68 = 0; _i68 < _list67.size; ++_i68)
+ {
+ org.apache.accumulo.core.data.thrift.TKeyExtent _elem69; // required
+ _elem69 = new org.apache.accumulo.core.data.thrift.TKeyExtent();
+ _elem69.read(iprot);
+ struct.newTablets.add(_elem69);
+ }
+ }
+ struct.setNewTabletsIsSet(true);
+ }
+ }
+ }
+
}
Modified: accumulo/trunk/core/src/main/java/org/apache/accumulo/core/security/thrift/AuthInfo.java
URL: http://svn.apache.org/viewvc/accumulo/trunk/core/src/main/java/org/apache/accumulo/core/security/thrift/AuthInfo.java?rev=1359639&r1=1359638&r2=1359639&view=diff
==============================================================================
--- accumulo/trunk/core/src/main/java/org/apache/accumulo/core/security/thrift/AuthInfo.java (original)
+++ accumulo/trunk/core/src/main/java/org/apache/accumulo/core/security/thrift/AuthInfo.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.security.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;
@@ -27,9 +34,15 @@ import org.slf4j.LoggerFactory;
private static final org.apache.thrift.protocol.TField PASSWORD_FIELD_DESC = new org.apache.thrift.protocol.TField("password", org.apache.thrift.protocol.TType.STRING, (short)2);
private static final org.apache.thrift.protocol.TField INSTANCE_ID_FIELD_DESC = new org.apache.thrift.protocol.TField("instanceId", org.apache.thrift.protocol.TType.STRING, (short)3);
- public String user;
- public ByteBuffer password;
- public String instanceId;
+ private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
+ static {
+ schemes.put(StandardScheme.class, new AuthInfoStandardSchemeFactory());
+ schemes.put(TupleScheme.class, new AuthInfoTupleSchemeFactory());
+ }
+
+ public String user; // required
+ public ByteBuffer password; // required
+ public String instanceId; // required
/** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */
public enum _Fields implements org.apache.thrift.TFieldIdEnum {
@@ -96,7 +109,6 @@ import org.slf4j.LoggerFactory;
}
// isset id assignments
-
public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap;
static {
Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class);
@@ -388,68 +400,11 @@ import org.slf4j.LoggerFactory;
}
public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException {
- org.apache.thrift.protocol.TField field;
- iprot.readStructBegin();
- while (true)
- {
- field = iprot.readFieldBegin();
- if (field.type == org.apache.thrift.protocol.TType.STOP) {
- break;
- }
- switch (field.id) {
- case 1: // USER
- if (field.type == org.apache.thrift.protocol.TType.STRING) {
- this.user = iprot.readString();
- } else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
- }
- break;
- case 2: // PASSWORD
- if (field.type == org.apache.thrift.protocol.TType.STRING) {
- this.password = iprot.readBinary();
- } else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
- }
- break;
- case 3: // INSTANCE_ID
- if (field.type == org.apache.thrift.protocol.TType.STRING) {
- this.instanceId = iprot.readString();
- } else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
- }
- break;
- default:
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
- }
- iprot.readFieldEnd();
- }
- iprot.readStructEnd();
-
- // check for required fields of primitive type, which can't be checked in the validate method
- validate();
+ schemes.get(iprot.getScheme()).getScheme().read(iprot, this);
}
public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException {
- validate();
-
- oprot.writeStructBegin(STRUCT_DESC);
- if (this.user != null) {
- oprot.writeFieldBegin(USER_FIELD_DESC);
- oprot.writeString(this.user);
- oprot.writeFieldEnd();
- }
- if (this.password != null) {
- oprot.writeFieldBegin(PASSWORD_FIELD_DESC);
- oprot.writeBinary(this.password);
- oprot.writeFieldEnd();
- }
- if (this.instanceId != null) {
- oprot.writeFieldBegin(INSTANCE_ID_FIELD_DESC);
- oprot.writeString(this.instanceId);
- oprot.writeFieldEnd();
- }
- oprot.writeFieldStop();
- oprot.writeStructEnd();
+ schemes.get(oprot.getScheme()).getScheme().write(oprot, this);
}
@Override
@@ -504,5 +459,135 @@ import org.slf4j.LoggerFactory;
}
}
+ private static class AuthInfoStandardSchemeFactory implements SchemeFactory {
+ public AuthInfoStandardScheme getScheme() {
+ return new AuthInfoStandardScheme();
+ }
+ }
+
+ private static class AuthInfoStandardScheme extends StandardScheme<AuthInfo> {
+
+ public void read(org.apache.thrift.protocol.TProtocol iprot, AuthInfo struct) throws org.apache.thrift.TException {
+ org.apache.thrift.protocol.TField schemeField;
+ iprot.readStructBegin();
+ while (true)
+ {
+ schemeField = iprot.readFieldBegin();
+ if (schemeField.type == org.apache.thrift.protocol.TType.STOP) {
+ break;
+ }
+ switch (schemeField.id) {
+ case 1: // USER
+ if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
+ struct.user = iprot.readString();
+ struct.setUserIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ case 2: // PASSWORD
+ if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
+ struct.password = iprot.readBinary();
+ struct.setPasswordIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ case 3: // INSTANCE_ID
+ if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
+ struct.instanceId = iprot.readString();
+ struct.setInstanceIdIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ default:
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ iprot.readFieldEnd();
+ }
+ iprot.readStructEnd();
+
+ // check for required fields of primitive type, which can't be checked in the validate method
+ struct.validate();
+ }
+
+ public void write(org.apache.thrift.protocol.TProtocol oprot, AuthInfo struct) throws org.apache.thrift.TException {
+ struct.validate();
+
+ oprot.writeStructBegin(STRUCT_DESC);
+ if (struct.user != null) {
+ oprot.writeFieldBegin(USER_FIELD_DESC);
+ oprot.writeString(struct.user);
+ oprot.writeFieldEnd();
+ }
+ if (struct.password != null) {
+ oprot.writeFieldBegin(PASSWORD_FIELD_DESC);
+ oprot.writeBinary(struct.password);
+ oprot.writeFieldEnd();
+ }
+ if (struct.instanceId != null) {
+ oprot.writeFieldBegin(INSTANCE_ID_FIELD_DESC);
+ oprot.writeString(struct.instanceId);
+ oprot.writeFieldEnd();
+ }
+ oprot.writeFieldStop();
+ oprot.writeStructEnd();
+ }
+
+ }
+
+ private static class AuthInfoTupleSchemeFactory implements SchemeFactory {
+ public AuthInfoTupleScheme getScheme() {
+ return new AuthInfoTupleScheme();
+ }
+ }
+
+ private static class AuthInfoTupleScheme extends TupleScheme<AuthInfo> {
+
+ @Override
+ public void write(org.apache.thrift.protocol.TProtocol prot, AuthInfo struct) throws org.apache.thrift.TException {
+ TTupleProtocol oprot = (TTupleProtocol) prot;
+ BitSet optionals = new BitSet();
+ if (struct.isSetUser()) {
+ optionals.set(0);
+ }
+ if (struct.isSetPassword()) {
+ optionals.set(1);
+ }
+ if (struct.isSetInstanceId()) {
+ optionals.set(2);
+ }
+ oprot.writeBitSet(optionals, 3);
+ if (struct.isSetUser()) {
+ oprot.writeString(struct.user);
+ }
+ if (struct.isSetPassword()) {
+ oprot.writeBinary(struct.password);
+ }
+ if (struct.isSetInstanceId()) {
+ oprot.writeString(struct.instanceId);
+ }
+ }
+
+ @Override
+ public void read(org.apache.thrift.protocol.TProtocol prot, AuthInfo struct) throws org.apache.thrift.TException {
+ TTupleProtocol iprot = (TTupleProtocol) prot;
+ BitSet incoming = iprot.readBitSet(3);
+ if (incoming.get(0)) {
+ struct.user = iprot.readString();
+ struct.setUserIsSet(true);
+ }
+ if (incoming.get(1)) {
+ struct.password = iprot.readBinary();
+ struct.setPasswordIsSet(true);
+ }
+ if (incoming.get(2)) {
+ struct.instanceId = iprot.readString();
+ struct.setInstanceIdIsSet(true);
+ }
+ }
+ }
+
}
Modified: accumulo/trunk/core/src/main/java/org/apache/accumulo/core/security/thrift/SecurityErrorCode.java
URL: http://svn.apache.org/viewvc/accumulo/trunk/core/src/main/java/org/apache/accumulo/core/security/thrift/SecurityErrorCode.java?rev=1359639&r1=1359638&r2=1359639&view=diff
==============================================================================
--- accumulo/trunk/core/src/main/java/org/apache/accumulo/core/security/thrift/SecurityErrorCode.java (original)
+++ accumulo/trunk/core/src/main/java/org/apache/accumulo/core/security/thrift/SecurityErrorCode.java Tue Jul 10 12:39:52 2012
@@ -1,7 +1,8 @@
/**
- * 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.security.thrift;
Modified: accumulo/trunk/core/src/main/java/org/apache/accumulo/core/security/thrift/ThriftSecurityException.java
URL: http://svn.apache.org/viewvc/accumulo/trunk/core/src/main/java/org/apache/accumulo/core/security/thrift/ThriftSecurityException.java?rev=1359639&r1=1359638&r2=1359639&view=diff
==============================================================================
--- accumulo/trunk/core/src/main/java/org/apache/accumulo/core/security/thrift/ThriftSecurityException.java (original)
+++ accumulo/trunk/core/src/main/java/org/apache/accumulo/core/security/thrift/ThriftSecurityException.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.security.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;
@@ -26,12 +33,18 @@ import org.slf4j.LoggerFactory;
private static final org.apache.thrift.protocol.TField USER_FIELD_DESC = new org.apache.thrift.protocol.TField("user", org.apache.thrift.protocol.TType.STRING, (short)1);
private static final org.apache.thrift.protocol.TField CODE_FIELD_DESC = new org.apache.thrift.protocol.TField("code", org.apache.thrift.protocol.TType.I32, (short)2);
- public String user;
+ private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
+ static {
+ schemes.put(StandardScheme.class, new ThriftSecurityExceptionStandardSchemeFactory());
+ schemes.put(TupleScheme.class, new ThriftSecurityExceptionTupleSchemeFactory());
+ }
+
+ public String user; // required
/**
*
* @see SecurityErrorCode
*/
- public SecurityErrorCode code;
+ public SecurityErrorCode code; // required
/** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */
public enum _Fields implements org.apache.thrift.TFieldIdEnum {
@@ -99,7 +112,6 @@ import org.slf4j.LoggerFactory;
}
// isset id assignments
-
public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap;
static {
Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class);
@@ -324,56 +336,11 @@ import org.slf4j.LoggerFactory;
}
public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException {
- org.apache.thrift.protocol.TField field;
- iprot.readStructBegin();
- while (true)
- {
- field = iprot.readFieldBegin();
- if (field.type == org.apache.thrift.protocol.TType.STOP) {
- break;
- }
- switch (field.id) {
- case 1: // USER
- if (field.type == org.apache.thrift.protocol.TType.STRING) {
- this.user = iprot.readString();
- } else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
- }
- break;
- case 2: // CODE
- if (field.type == org.apache.thrift.protocol.TType.I32) {
- this.code = SecurityErrorCode.findByValue(iprot.readI32());
- } else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
- }
- break;
- default:
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
- }
- iprot.readFieldEnd();
- }
- iprot.readStructEnd();
-
- // check for required fields of primitive type, which can't be checked in the validate method
- validate();
+ schemes.get(iprot.getScheme()).getScheme().read(iprot, this);
}
public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException {
- validate();
-
- oprot.writeStructBegin(STRUCT_DESC);
- if (this.user != null) {
- oprot.writeFieldBegin(USER_FIELD_DESC);
- oprot.writeString(this.user);
- oprot.writeFieldEnd();
- }
- if (this.code != null) {
- oprot.writeFieldBegin(CODE_FIELD_DESC);
- oprot.writeI32(this.code.getValue());
- oprot.writeFieldEnd();
- }
- oprot.writeFieldStop();
- oprot.writeStructEnd();
+ schemes.get(oprot.getScheme()).getScheme().write(oprot, this);
}
@Override
@@ -420,5 +387,112 @@ import org.slf4j.LoggerFactory;
}
}
+ private static class ThriftSecurityExceptionStandardSchemeFactory implements SchemeFactory {
+ public ThriftSecurityExceptionStandardScheme getScheme() {
+ return new ThriftSecurityExceptionStandardScheme();
+ }
+ }
+
+ private static class ThriftSecurityExceptionStandardScheme extends StandardScheme<ThriftSecurityException> {
+
+ public void read(org.apache.thrift.protocol.TProtocol iprot, ThriftSecurityException struct) throws org.apache.thrift.TException {
+ org.apache.thrift.protocol.TField schemeField;
+ iprot.readStructBegin();
+ while (true)
+ {
+ schemeField = iprot.readFieldBegin();
+ if (schemeField.type == org.apache.thrift.protocol.TType.STOP) {
+ break;
+ }
+ switch (schemeField.id) {
+ case 1: // USER
+ if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
+ struct.user = iprot.readString();
+ struct.setUserIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ case 2: // CODE
+ if (schemeField.type == org.apache.thrift.protocol.TType.I32) {
+ struct.code = SecurityErrorCode.findByValue(iprot.readI32());
+ struct.setCodeIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ default:
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ iprot.readFieldEnd();
+ }
+ iprot.readStructEnd();
+
+ // check for required fields of primitive type, which can't be checked in the validate method
+ struct.validate();
+ }
+
+ public void write(org.apache.thrift.protocol.TProtocol oprot, ThriftSecurityException struct) throws org.apache.thrift.TException {
+ struct.validate();
+
+ oprot.writeStructBegin(STRUCT_DESC);
+ if (struct.user != null) {
+ oprot.writeFieldBegin(USER_FIELD_DESC);
+ oprot.writeString(struct.user);
+ oprot.writeFieldEnd();
+ }
+ if (struct.code != null) {
+ oprot.writeFieldBegin(CODE_FIELD_DESC);
+ oprot.writeI32(struct.code.getValue());
+ oprot.writeFieldEnd();
+ }
+ oprot.writeFieldStop();
+ oprot.writeStructEnd();
+ }
+
+ }
+
+ private static class ThriftSecurityExceptionTupleSchemeFactory implements SchemeFactory {
+ public ThriftSecurityExceptionTupleScheme getScheme() {
+ return new ThriftSecurityExceptionTupleScheme();
+ }
+ }
+
+ private static class ThriftSecurityExceptionTupleScheme extends TupleScheme<ThriftSecurityException> {
+
+ @Override
+ public void write(org.apache.thrift.protocol.TProtocol prot, ThriftSecurityException struct) throws org.apache.thrift.TException {
+ TTupleProtocol oprot = (TTupleProtocol) prot;
+ BitSet optionals = new BitSet();
+ if (struct.isSetUser()) {
+ optionals.set(0);
+ }
+ if (struct.isSetCode()) {
+ optionals.set(1);
+ }
+ oprot.writeBitSet(optionals, 2);
+ if (struct.isSetUser()) {
+ oprot.writeString(struct.user);
+ }
+ if (struct.isSetCode()) {
+ oprot.writeI32(struct.code.getValue());
+ }
+ }
+
+ @Override
+ public void read(org.apache.thrift.protocol.TProtocol prot, ThriftSecurityException struct) throws org.apache.thrift.TException {
+ TTupleProtocol iprot = (TTupleProtocol) prot;
+ BitSet incoming = iprot.readBitSet(2);
+ if (incoming.get(0)) {
+ struct.user = iprot.readString();
+ struct.setUserIsSet(true);
+ }
+ if (incoming.get(1)) {
+ struct.code = SecurityErrorCode.findByValue(iprot.readI32());
+ struct.setCodeIsSet(true);
+ }
+ }
+ }
+
}
Modified: accumulo/trunk/core/src/main/java/org/apache/accumulo/core/tabletserver/thrift/ActionStats.java
URL: http://svn.apache.org/viewvc/accumulo/trunk/core/src/main/java/org/apache/accumulo/core/tabletserver/thrift/ActionStats.java?rev=1359639&r1=1359638&r2=1359639&view=diff
==============================================================================
--- accumulo/trunk/core/src/main/java/org/apache/accumulo/core/tabletserver/thrift/ActionStats.java (original)
+++ accumulo/trunk/core/src/main/java/org/apache/accumulo/core/tabletserver/thrift/ActionStats.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.tabletserver.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;
@@ -32,14 +39,20 @@ import org.slf4j.LoggerFactory;
private static final org.apache.thrift.protocol.TField QUEUE_TIME_FIELD_DESC = new org.apache.thrift.protocol.TField("queueTime", org.apache.thrift.protocol.TType.DOUBLE, (short)7);
private static final org.apache.thrift.protocol.TField QUEUE_SUM_DEV_FIELD_DESC = new org.apache.thrift.protocol.TField("queueSumDev", org.apache.thrift.protocol.TType.DOUBLE, (short)8);
- public int status;
- public double elapsed;
- public int num;
- public long count;
- public double sumDev;
- public int fail;
- public double queueTime;
- public double queueSumDev;
+ private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
+ static {
+ schemes.put(StandardScheme.class, new ActionStatsStandardSchemeFactory());
+ schemes.put(TupleScheme.class, new ActionStatsTupleSchemeFactory());
+ }
+
+ public int status; // required
+ public double elapsed; // required
+ public int num; // required
+ public long count; // required
+ public double sumDev; // required
+ public int fail; // required
+ public double queueTime; // required
+ public double queueSumDev; // required
/** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */
public enum _Fields implements org.apache.thrift.TFieldIdEnum {
@@ -130,7 +143,6 @@ import org.slf4j.LoggerFactory;
private static final int __QUEUETIME_ISSET_ID = 6;
private static final int __QUEUESUMDEV_ISSET_ID = 7;
private BitSet __isset_bit_vector = new BitSet(8);
-
public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap;
static {
Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class);
@@ -482,28 +494,28 @@ import org.slf4j.LoggerFactory;
public Object getFieldValue(_Fields field) {
switch (field) {
case STATUS:
- return new Integer(getStatus());
+ return Integer.valueOf(getStatus());
case ELAPSED:
- return new Double(getElapsed());
+ return Double.valueOf(getElapsed());
case NUM:
- return new Integer(getNum());
+ return Integer.valueOf(getNum());
case COUNT:
- return new Long(getCount());
+ return Long.valueOf(getCount());
case SUM_DEV:
- return new Double(getSumDev());
+ return Double.valueOf(getSumDev());
case FAIL:
- return new Integer(getFail());
+ return Integer.valueOf(getFail());
case QUEUE_TIME:
- return new Double(getQueueTime());
+ return Double.valueOf(getQueueTime());
case QUEUE_SUM_DEV:
- return new Double(getQueueSumDev());
+ return Double.valueOf(getQueueSumDev());
}
throw new IllegalStateException();
@@ -725,120 +737,11 @@ import org.slf4j.LoggerFactory;
}
public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException {
- org.apache.thrift.protocol.TField field;
- iprot.readStructBegin();
- while (true)
- {
- field = iprot.readFieldBegin();
- if (field.type == org.apache.thrift.protocol.TType.STOP) {
- break;
- }
- switch (field.id) {
- case 1: // STATUS
- if (field.type == org.apache.thrift.protocol.TType.I32) {
- this.status = iprot.readI32();
- setStatusIsSet(true);
- } else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
- }
- break;
- case 2: // ELAPSED
- if (field.type == org.apache.thrift.protocol.TType.DOUBLE) {
- this.elapsed = iprot.readDouble();
- setElapsedIsSet(true);
- } else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
- }
- break;
- case 3: // NUM
- if (field.type == org.apache.thrift.protocol.TType.I32) {
- this.num = iprot.readI32();
- setNumIsSet(true);
- } else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
- }
- break;
- case 4: // COUNT
- if (field.type == org.apache.thrift.protocol.TType.I64) {
- this.count = iprot.readI64();
- setCountIsSet(true);
- } else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
- }
- break;
- case 5: // SUM_DEV
- if (field.type == org.apache.thrift.protocol.TType.DOUBLE) {
- this.sumDev = iprot.readDouble();
- setSumDevIsSet(true);
- } else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
- }
- break;
- case 6: // FAIL
- if (field.type == org.apache.thrift.protocol.TType.I32) {
- this.fail = iprot.readI32();
- setFailIsSet(true);
- } else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
- }
- break;
- case 7: // QUEUE_TIME
- if (field.type == org.apache.thrift.protocol.TType.DOUBLE) {
- this.queueTime = iprot.readDouble();
- setQueueTimeIsSet(true);
- } else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
- }
- break;
- case 8: // QUEUE_SUM_DEV
- if (field.type == org.apache.thrift.protocol.TType.DOUBLE) {
- this.queueSumDev = iprot.readDouble();
- setQueueSumDevIsSet(true);
- } else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
- }
- break;
- default:
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
- }
- iprot.readFieldEnd();
- }
- iprot.readStructEnd();
-
- // check for required fields of primitive type, which can't be checked in the validate method
- validate();
+ schemes.get(iprot.getScheme()).getScheme().read(iprot, this);
}
public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException {
- validate();
-
- oprot.writeStructBegin(STRUCT_DESC);
- oprot.writeFieldBegin(STATUS_FIELD_DESC);
- oprot.writeI32(this.status);
- oprot.writeFieldEnd();
- oprot.writeFieldBegin(ELAPSED_FIELD_DESC);
- oprot.writeDouble(this.elapsed);
- oprot.writeFieldEnd();
- oprot.writeFieldBegin(NUM_FIELD_DESC);
- oprot.writeI32(this.num);
- oprot.writeFieldEnd();
- oprot.writeFieldBegin(COUNT_FIELD_DESC);
- oprot.writeI64(this.count);
- oprot.writeFieldEnd();
- oprot.writeFieldBegin(SUM_DEV_FIELD_DESC);
- oprot.writeDouble(this.sumDev);
- oprot.writeFieldEnd();
- oprot.writeFieldBegin(FAIL_FIELD_DESC);
- oprot.writeI32(this.fail);
- oprot.writeFieldEnd();
- oprot.writeFieldBegin(QUEUE_TIME_FIELD_DESC);
- oprot.writeDouble(this.queueTime);
- oprot.writeFieldEnd();
- oprot.writeFieldBegin(QUEUE_SUM_DEV_FIELD_DESC);
- oprot.writeDouble(this.queueSumDev);
- oprot.writeFieldEnd();
- oprot.writeFieldStop();
- oprot.writeStructEnd();
+ schemes.get(oprot.getScheme()).getScheme().write(oprot, this);
}
@Override
@@ -903,5 +806,234 @@ import org.slf4j.LoggerFactory;
}
}
+ private static class ActionStatsStandardSchemeFactory implements SchemeFactory {
+ public ActionStatsStandardScheme getScheme() {
+ return new ActionStatsStandardScheme();
+ }
+ }
+
+ private static class ActionStatsStandardScheme extends StandardScheme<ActionStats> {
+
+ public void read(org.apache.thrift.protocol.TProtocol iprot, ActionStats struct) throws org.apache.thrift.TException {
+ org.apache.thrift.protocol.TField schemeField;
+ iprot.readStructBegin();
+ while (true)
+ {
+ schemeField = iprot.readFieldBegin();
+ if (schemeField.type == org.apache.thrift.protocol.TType.STOP) {
+ break;
+ }
+ switch (schemeField.id) {
+ case 1: // STATUS
+ if (schemeField.type == org.apache.thrift.protocol.TType.I32) {
+ struct.status = iprot.readI32();
+ struct.setStatusIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ case 2: // ELAPSED
+ if (schemeField.type == org.apache.thrift.protocol.TType.DOUBLE) {
+ struct.elapsed = iprot.readDouble();
+ struct.setElapsedIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ case 3: // NUM
+ if (schemeField.type == org.apache.thrift.protocol.TType.I32) {
+ struct.num = iprot.readI32();
+ struct.setNumIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ case 4: // COUNT
+ if (schemeField.type == org.apache.thrift.protocol.TType.I64) {
+ struct.count = iprot.readI64();
+ struct.setCountIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ case 5: // SUM_DEV
+ if (schemeField.type == org.apache.thrift.protocol.TType.DOUBLE) {
+ struct.sumDev = iprot.readDouble();
+ struct.setSumDevIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ case 6: // FAIL
+ if (schemeField.type == org.apache.thrift.protocol.TType.I32) {
+ struct.fail = iprot.readI32();
+ struct.setFailIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ case 7: // QUEUE_TIME
+ if (schemeField.type == org.apache.thrift.protocol.TType.DOUBLE) {
+ struct.queueTime = iprot.readDouble();
+ struct.setQueueTimeIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ case 8: // QUEUE_SUM_DEV
+ if (schemeField.type == org.apache.thrift.protocol.TType.DOUBLE) {
+ struct.queueSumDev = iprot.readDouble();
+ struct.setQueueSumDevIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ default:
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ iprot.readFieldEnd();
+ }
+ iprot.readStructEnd();
+
+ // check for required fields of primitive type, which can't be checked in the validate method
+ struct.validate();
+ }
+
+ public void write(org.apache.thrift.protocol.TProtocol oprot, ActionStats struct) throws org.apache.thrift.TException {
+ struct.validate();
+
+ oprot.writeStructBegin(STRUCT_DESC);
+ oprot.writeFieldBegin(STATUS_FIELD_DESC);
+ oprot.writeI32(struct.status);
+ oprot.writeFieldEnd();
+ oprot.writeFieldBegin(ELAPSED_FIELD_DESC);
+ oprot.writeDouble(struct.elapsed);
+ oprot.writeFieldEnd();
+ oprot.writeFieldBegin(NUM_FIELD_DESC);
+ oprot.writeI32(struct.num);
+ oprot.writeFieldEnd();
+ oprot.writeFieldBegin(COUNT_FIELD_DESC);
+ oprot.writeI64(struct.count);
+ oprot.writeFieldEnd();
+ oprot.writeFieldBegin(SUM_DEV_FIELD_DESC);
+ oprot.writeDouble(struct.sumDev);
+ oprot.writeFieldEnd();
+ oprot.writeFieldBegin(FAIL_FIELD_DESC);
+ oprot.writeI32(struct.fail);
+ oprot.writeFieldEnd();
+ oprot.writeFieldBegin(QUEUE_TIME_FIELD_DESC);
+ oprot.writeDouble(struct.queueTime);
+ oprot.writeFieldEnd();
+ oprot.writeFieldBegin(QUEUE_SUM_DEV_FIELD_DESC);
+ oprot.writeDouble(struct.queueSumDev);
+ oprot.writeFieldEnd();
+ oprot.writeFieldStop();
+ oprot.writeStructEnd();
+ }
+
+ }
+
+ private static class ActionStatsTupleSchemeFactory implements SchemeFactory {
+ public ActionStatsTupleScheme getScheme() {
+ return new ActionStatsTupleScheme();
+ }
+ }
+
+ private static class ActionStatsTupleScheme extends TupleScheme<ActionStats> {
+
+ @Override
+ public void write(org.apache.thrift.protocol.TProtocol prot, ActionStats struct) throws org.apache.thrift.TException {
+ TTupleProtocol oprot = (TTupleProtocol) prot;
+ BitSet optionals = new BitSet();
+ if (struct.isSetStatus()) {
+ optionals.set(0);
+ }
+ if (struct.isSetElapsed()) {
+ optionals.set(1);
+ }
+ if (struct.isSetNum()) {
+ optionals.set(2);
+ }
+ if (struct.isSetCount()) {
+ optionals.set(3);
+ }
+ if (struct.isSetSumDev()) {
+ optionals.set(4);
+ }
+ if (struct.isSetFail()) {
+ optionals.set(5);
+ }
+ if (struct.isSetQueueTime()) {
+ optionals.set(6);
+ }
+ if (struct.isSetQueueSumDev()) {
+ optionals.set(7);
+ }
+ oprot.writeBitSet(optionals, 8);
+ if (struct.isSetStatus()) {
+ oprot.writeI32(struct.status);
+ }
+ if (struct.isSetElapsed()) {
+ oprot.writeDouble(struct.elapsed);
+ }
+ if (struct.isSetNum()) {
+ oprot.writeI32(struct.num);
+ }
+ if (struct.isSetCount()) {
+ oprot.writeI64(struct.count);
+ }
+ if (struct.isSetSumDev()) {
+ oprot.writeDouble(struct.sumDev);
+ }
+ if (struct.isSetFail()) {
+ oprot.writeI32(struct.fail);
+ }
+ if (struct.isSetQueueTime()) {
+ oprot.writeDouble(struct.queueTime);
+ }
+ if (struct.isSetQueueSumDev()) {
+ oprot.writeDouble(struct.queueSumDev);
+ }
+ }
+
+ @Override
+ public void read(org.apache.thrift.protocol.TProtocol prot, ActionStats struct) throws org.apache.thrift.TException {
+ TTupleProtocol iprot = (TTupleProtocol) prot;
+ BitSet incoming = iprot.readBitSet(8);
+ if (incoming.get(0)) {
+ struct.status = iprot.readI32();
+ struct.setStatusIsSet(true);
+ }
+ if (incoming.get(1)) {
+ struct.elapsed = iprot.readDouble();
+ struct.setElapsedIsSet(true);
+ }
+ if (incoming.get(2)) {
+ struct.num = iprot.readI32();
+ struct.setNumIsSet(true);
+ }
+ if (incoming.get(3)) {
+ struct.count = iprot.readI64();
+ struct.setCountIsSet(true);
+ }
+ if (incoming.get(4)) {
+ struct.sumDev = iprot.readDouble();
+ struct.setSumDevIsSet(true);
+ }
+ if (incoming.get(5)) {
+ struct.fail = iprot.readI32();
+ struct.setFailIsSet(true);
+ }
+ if (incoming.get(6)) {
+ struct.queueTime = iprot.readDouble();
+ struct.setQueueTimeIsSet(true);
+ }
+ if (incoming.get(7)) {
+ struct.queueSumDev = iprot.readDouble();
+ struct.setQueueSumDevIsSet(true);
+ }
+ }
+ }
+
}