accumulo-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From vi...@apache.org
Subject svn commit: r1361382 [9/16] - in /accumulo/branches/ACCUMULO-259: ./ bin/ conf/examples/1GB/native-standalone/ conf/examples/1GB/standalone/ conf/examples/2GB/native-standalone/ conf/examples/2GB/standalone/ conf/examples/3GB/native-standalone/ conf/ex...
Date Fri, 13 Jul 2012 20:34:49 GMT
Modified: accumulo/branches/ACCUMULO-259/core/src/main/java/org/apache/accumulo/core/master/thrift/TabletServerStatus.java
URL: http://svn.apache.org/viewvc/accumulo/branches/ACCUMULO-259/core/src/main/java/org/apache/accumulo/core/master/thrift/TabletServerStatus.java?rev=1361382&r1=1361381&r2=1361382&view=diff
==============================================================================
--- accumulo/branches/ACCUMULO-259/core/src/main/java/org/apache/accumulo/core/master/thrift/TabletServerStatus.java (original)
+++ accumulo/branches/ACCUMULO-259/core/src/main/java/org/apache/accumulo/core/master/thrift/TabletServerStatus.java Fri Jul 13 20:34:44 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/branches/ACCUMULO-259/core/src/main/java/org/apache/accumulo/core/master/thrift/TabletSplit.java
URL: http://svn.apache.org/viewvc/accumulo/branches/ACCUMULO-259/core/src/main/java/org/apache/accumulo/core/master/thrift/TabletSplit.java?rev=1361382&r1=1361381&r2=1361382&view=diff
==============================================================================
--- accumulo/branches/ACCUMULO-259/core/src/main/java/org/apache/accumulo/core/master/thrift/TabletSplit.java (original)
+++ accumulo/branches/ACCUMULO-259/core/src/main/java/org/apache/accumulo/core/master/thrift/TabletSplit.java Fri Jul 13 20:34:44 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/branches/ACCUMULO-259/core/src/main/java/org/apache/accumulo/core/security/thrift/AuthInfo.java
URL: http://svn.apache.org/viewvc/accumulo/branches/ACCUMULO-259/core/src/main/java/org/apache/accumulo/core/security/thrift/AuthInfo.java?rev=1361382&r1=1361381&r2=1361382&view=diff
==============================================================================
--- accumulo/branches/ACCUMULO-259/core/src/main/java/org/apache/accumulo/core/security/thrift/AuthInfo.java (original)
+++ accumulo/branches/ACCUMULO-259/core/src/main/java/org/apache/accumulo/core/security/thrift/AuthInfo.java Fri Jul 13 20:34:44 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/branches/ACCUMULO-259/core/src/main/java/org/apache/accumulo/core/security/thrift/SecurityErrorCode.java
URL: http://svn.apache.org/viewvc/accumulo/branches/ACCUMULO-259/core/src/main/java/org/apache/accumulo/core/security/thrift/SecurityErrorCode.java?rev=1361382&r1=1361381&r2=1361382&view=diff
==============================================================================
--- accumulo/branches/ACCUMULO-259/core/src/main/java/org/apache/accumulo/core/security/thrift/SecurityErrorCode.java (original)
+++ accumulo/branches/ACCUMULO-259/core/src/main/java/org/apache/accumulo/core/security/thrift/SecurityErrorCode.java Fri Jul 13 20:34:44 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;
 
@@ -20,7 +21,8 @@ public enum SecurityErrorCode implements
   GRANT_INVALID(6),
   BAD_AUTHORIZATIONS(7),
   INVALID_INSTANCEID(8),
-  TABLE_DOESNT_EXIST(9);
+  TABLE_DOESNT_EXIST(9),
+  UNSUPPORTED_OPERATION(10);
 
   private final int value;
 
@@ -61,6 +63,8 @@ public enum SecurityErrorCode implements
         return INVALID_INSTANCEID;
       case 9:
         return TABLE_DOESNT_EXIST;
+      case 10:
+        return UNSUPPORTED_OPERATION;
       default:
         return null;
     }

Modified: accumulo/branches/ACCUMULO-259/core/src/main/java/org/apache/accumulo/core/security/thrift/ThriftSecurityException.java
URL: http://svn.apache.org/viewvc/accumulo/branches/ACCUMULO-259/core/src/main/java/org/apache/accumulo/core/security/thrift/ThriftSecurityException.java?rev=1361382&r1=1361381&r2=1361382&view=diff
==============================================================================
--- accumulo/branches/ACCUMULO-259/core/src/main/java/org/apache/accumulo/core/security/thrift/ThriftSecurityException.java (original)
+++ accumulo/branches/ACCUMULO-259/core/src/main/java/org/apache/accumulo/core/security/thrift/ThriftSecurityException.java Fri Jul 13 20:34:44 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/branches/ACCUMULO-259/core/src/main/java/org/apache/accumulo/core/tabletserver/thrift/ActionStats.java
URL: http://svn.apache.org/viewvc/accumulo/branches/ACCUMULO-259/core/src/main/java/org/apache/accumulo/core/tabletserver/thrift/ActionStats.java?rev=1361382&r1=1361381&r2=1361382&view=diff
==============================================================================
--- accumulo/branches/ACCUMULO-259/core/src/main/java/org/apache/accumulo/core/tabletserver/thrift/ActionStats.java (original)
+++ accumulo/branches/ACCUMULO-259/core/src/main/java/org/apache/accumulo/core/tabletserver/thrift/ActionStats.java Fri Jul 13 20:34:44 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);
+      }
+    }
+  }
+
 }
 



Mime
View raw message