storm-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From bo...@apache.org
Subject [34/50] [abbrv] storm git commit: Regenerated NimbusSummary using thrift-0.9.2
Date Mon, 24 Aug 2015 13:52:19 GMT
Regenerated NimbusSummary using thrift-0.9.2


Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/f7205d29
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/f7205d29
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/f7205d29

Branch: refs/heads/master
Commit: f7205d29f7afeb9e4cf03a31be0ac5737652b07c
Parents: 85e4d5e
Author: Parth Brahmbhatt <brahmbhatt.parth@gmail.com>
Authored: Mon Mar 2 15:26:41 2015 -0800
Committer: Parth Brahmbhatt <brahmbhatt.parth@gmail.com>
Committed: Mon Mar 2 15:52:00 2015 -0800

----------------------------------------------------------------------
 storm-core/src/clj/backtype/storm/ui/core.clj   |   8 +-
 .../backtype/storm/generated/NimbusSummary.java | 381 +++++++++++--------
 2 files changed, 231 insertions(+), 158 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/storm/blob/f7205d29/storm-core/src/clj/backtype/storm/ui/core.clj
----------------------------------------------------------------------
diff --git a/storm-core/src/clj/backtype/storm/ui/core.clj b/storm-core/src/clj/backtype/storm/ui/core.clj
index 7fc9273..0f93f23 100644
--- a/storm-core/src/clj/backtype/storm/ui/core.clj
+++ b/storm-core/src/clj/backtype/storm/ui/core.clj
@@ -25,7 +25,8 @@
                                               ACKER-FAIL-STREAM-ID system-id? mk-authorization-handler]]])
   (:use [ring.middleware.anti-forgery])
   (:use [clojure.string :only [blank? lower-case trim]])
-  (:import [backtype.storm.utils Utils])
+  (:import [backtype.storm.utils Utils]
+           [backtype.storm.generated NimbusSummary])
   (:import [backtype.storm.generated ExecutorSpecificStats
             ExecutorStats ExecutorSummary TopologyInfo SpoutStats BoltStats
             ErrorInfo ClusterSummary SupervisorSummary TopologySummary
@@ -41,7 +42,6 @@
             [ring.util.response :as resp]
             [backtype.storm [thrift :as thrift]])
   (:import [org.apache.commons.lang StringEscapeUtils])
-  (:import [backtype.storm.nimbus NimbusInfo])
   (:gen-class))
 
 (def ^:dynamic *STORM-CONF* (read-storm-config))
@@ -520,14 +520,14 @@
         (.get_nimbuses (.getClusterInfo ^Nimbus$Client nimbus)))))
   ([nimbuses]
     {"nimbuses"
-     (for [^NimbusInfo n nimbuses]
+     (for [^NimbusSummary n nimbuses]
        {
         "host" (.get_host n)
         "port" (.get_port n)
         "nimbusLogLink" (nimbus-log-link (.get_host n) (.get_port n))
         "isLeader" (.is_isLeader n)
         "version" (.get_version n)
-        "nimbusUpTime" (pretty-uptime-sec (.get_uptimeSecs n))})}))
+        "nimbusUpTime" (pretty-uptime-sec (.get_uptime_secs n))})}))
 
 (defn supervisor-summary
   ([]

http://git-wip-us.apache.org/repos/asf/storm/blob/f7205d29/storm-core/src/jvm/backtype/storm/generated/NimbusSummary.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/generated/NimbusSummary.java b/storm-core/src/jvm/backtype/storm/generated/NimbusSummary.java
index 195048a..1d0f3fb 100644
--- a/storm-core/src/jvm/backtype/storm/generated/NimbusSummary.java
+++ b/storm-core/src/jvm/backtype/storm/generated/NimbusSummary.java
@@ -16,13 +16,24 @@
  * limitations under the License.
  */
 /**
- * Autogenerated by Thrift Compiler (0.7.0)
+ * Autogenerated by Thrift Compiler (0.9.2)
  *
  * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
+ *  @generated
  */
 package backtype.storm.generated;
 
-import org.apache.commons.lang.builder.HashCodeBuilder;
+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 org.apache.thrift.protocol.TProtocolException;
+import org.apache.thrift.EncodingUtils;
+import org.apache.thrift.TException;
+import org.apache.thrift.async.AsyncMethodCallback;
+import org.apache.thrift.server.AbstractNonblockingServer.*;
 import java.util.List;
 import java.util.ArrayList;
 import java.util.Map;
@@ -35,21 +46,30 @@ import java.util.Collections;
 import java.util.BitSet;
 import java.nio.ByteBuffer;
 import java.util.Arrays;
+import javax.annotation.Generated;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
-public class NimbusSummary implements org.apache.thrift.TBase<NimbusSummary, NimbusSummary._Fields>,
java.io.Serializable, Cloneable {
+@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-3-2")
+public class NimbusSummary implements org.apache.thrift.TBase<NimbusSummary, NimbusSummary._Fields>,
java.io.Serializable, Cloneable, Comparable<NimbusSummary> {
   private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("NimbusSummary");
 
   private static final org.apache.thrift.protocol.TField HOST_FIELD_DESC = new org.apache.thrift.protocol.TField("host",
org.apache.thrift.protocol.TType.STRING, (short)1);
   private static final org.apache.thrift.protocol.TField PORT_FIELD_DESC = new org.apache.thrift.protocol.TField("port",
org.apache.thrift.protocol.TType.I32, (short)2);
-  private static final org.apache.thrift.protocol.TField UPTIME_SECS_FIELD_DESC = new org.apache.thrift.protocol.TField("uptimeSecs",
org.apache.thrift.protocol.TType.I32, (short)3);
+  private static final org.apache.thrift.protocol.TField UPTIME_SECS_FIELD_DESC = new org.apache.thrift.protocol.TField("uptime_secs",
org.apache.thrift.protocol.TType.I32, (short)3);
   private static final org.apache.thrift.protocol.TField IS_LEADER_FIELD_DESC = new org.apache.thrift.protocol.TField("isLeader",
org.apache.thrift.protocol.TType.BOOL, (short)4);
   private static final org.apache.thrift.protocol.TField VERSION_FIELD_DESC = new org.apache.thrift.protocol.TField("version",
org.apache.thrift.protocol.TType.STRING, (short)5);
 
+  private static final Map<Class<? extends IScheme>, SchemeFactory> schemes =
new HashMap<Class<? extends IScheme>, SchemeFactory>();
+  static {
+    schemes.put(StandardScheme.class, new NimbusSummaryStandardSchemeFactory());
+    schemes.put(TupleScheme.class, new NimbusSummaryTupleSchemeFactory());
+  }
+
   private String host; // required
   private int port; // required
-  private int uptimeSecs; // required
+  private int uptime_secs; // required
   private boolean isLeader; // required
   private String version; // required
 
@@ -57,7 +77,7 @@ public class NimbusSummary implements org.apache.thrift.TBase<NimbusSummary,
Nim
   public enum _Fields implements org.apache.thrift.TFieldIdEnum {
     HOST((short)1, "host"),
     PORT((short)2, "port"),
-    UPTIME_SECS((short)3, "uptimeSecs"),
+    UPTIME_SECS((short)3, "uptime_secs"),
     IS_LEADER((short)4, "isLeader"),
     VERSION((short)5, "version");
 
@@ -125,10 +145,9 @@ public class NimbusSummary implements org.apache.thrift.TBase<NimbusSummary,
Nim
 
   // isset id assignments
   private static final int __PORT_ISSET_ID = 0;
-  private static final int __UPTIMESECS_ISSET_ID = 1;
+  private static final int __UPTIME_SECS_ISSET_ID = 1;
   private static final int __ISLEADER_ISSET_ID = 2;
-  private BitSet __isset_bit_vector = new BitSet(3);
-
+  private byte __isset_bitfield = 0;
   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);
@@ -136,7 +155,7 @@ public class NimbusSummary implements org.apache.thrift.TBase<NimbusSummary,
Nim
         new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
     tmpMap.put(_Fields.PORT, new org.apache.thrift.meta_data.FieldMetaData("port", org.apache.thrift.TFieldRequirementType.REQUIRED,

         new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I32)));
-    tmpMap.put(_Fields.UPTIME_SECS, new org.apache.thrift.meta_data.FieldMetaData("uptimeSecs",
org.apache.thrift.TFieldRequirementType.REQUIRED, 
+    tmpMap.put(_Fields.UPTIME_SECS, new org.apache.thrift.meta_data.FieldMetaData("uptime_secs",
org.apache.thrift.TFieldRequirementType.REQUIRED, 
         new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I32)));
     tmpMap.put(_Fields.IS_LEADER, new org.apache.thrift.meta_data.FieldMetaData("isLeader",
org.apache.thrift.TFieldRequirementType.REQUIRED, 
         new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.BOOL)));
@@ -152,7 +171,7 @@ public class NimbusSummary implements org.apache.thrift.TBase<NimbusSummary,
Nim
   public NimbusSummary(
     String host,
     int port,
-    int uptimeSecs,
+    int uptime_secs,
     boolean isLeader,
     String version)
   {
@@ -160,8 +179,8 @@ public class NimbusSummary implements org.apache.thrift.TBase<NimbusSummary,
Nim
     this.host = host;
     this.port = port;
     set_port_isSet(true);
-    this.uptimeSecs = uptimeSecs;
-    set_uptimeSecs_isSet(true);
+    this.uptime_secs = uptime_secs;
+    set_uptime_secs_isSet(true);
     this.isLeader = isLeader;
     set_isLeader_isSet(true);
     this.version = version;
@@ -171,13 +190,12 @@ public class NimbusSummary implements org.apache.thrift.TBase<NimbusSummary,
Nim
    * Performs a deep copy on <i>other</i>.
    */
   public NimbusSummary(NimbusSummary other) {
-    __isset_bit_vector.clear();
-    __isset_bit_vector.or(other.__isset_bit_vector);
+    __isset_bitfield = other.__isset_bitfield;
     if (other.is_set_host()) {
       this.host = other.host;
     }
     this.port = other.port;
-    this.uptimeSecs = other.uptimeSecs;
+    this.uptime_secs = other.uptime_secs;
     this.isLeader = other.isLeader;
     if (other.is_set_version()) {
       this.version = other.version;
@@ -193,8 +211,8 @@ public class NimbusSummary implements org.apache.thrift.TBase<NimbusSummary,
Nim
     this.host = null;
     set_port_isSet(false);
     this.port = 0;
-    set_uptimeSecs_isSet(false);
-    this.uptimeSecs = 0;
+    set_uptime_secs_isSet(false);
+    this.uptime_secs = 0;
     set_isLeader_isSet(false);
     this.isLeader = false;
     this.version = null;
@@ -233,38 +251,38 @@ public class NimbusSummary implements org.apache.thrift.TBase<NimbusSummary,
Nim
   }
 
   public void unset_port() {
-    __isset_bit_vector.clear(__PORT_ISSET_ID);
+    __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __PORT_ISSET_ID);
   }
 
   /** Returns true if field port is set (has been assigned a value) and false otherwise */
   public boolean is_set_port() {
-    return __isset_bit_vector.get(__PORT_ISSET_ID);
+    return EncodingUtils.testBit(__isset_bitfield, __PORT_ISSET_ID);
   }
 
   public void set_port_isSet(boolean value) {
-    __isset_bit_vector.set(__PORT_ISSET_ID, value);
+    __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __PORT_ISSET_ID, value);
   }
 
-  public int get_uptimeSecs() {
-    return this.uptimeSecs;
+  public int get_uptime_secs() {
+    return this.uptime_secs;
   }
 
-  public void set_uptimeSecs(int uptimeSecs) {
-    this.uptimeSecs = uptimeSecs;
-    set_uptimeSecs_isSet(true);
+  public void set_uptime_secs(int uptime_secs) {
+    this.uptime_secs = uptime_secs;
+    set_uptime_secs_isSet(true);
   }
 
-  public void unset_uptimeSecs() {
-    __isset_bit_vector.clear(__UPTIMESECS_ISSET_ID);
+  public void unset_uptime_secs() {
+    __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __UPTIME_SECS_ISSET_ID);
   }
 
-  /** Returns true if field uptimeSecs is set (has been assigned a value) and false otherwise
*/
-  public boolean is_set_uptimeSecs() {
-    return __isset_bit_vector.get(__UPTIMESECS_ISSET_ID);
+  /** Returns true if field uptime_secs is set (has been assigned a value) and false otherwise
*/
+  public boolean is_set_uptime_secs() {
+    return EncodingUtils.testBit(__isset_bitfield, __UPTIME_SECS_ISSET_ID);
   }
 
-  public void set_uptimeSecs_isSet(boolean value) {
-    __isset_bit_vector.set(__UPTIMESECS_ISSET_ID, value);
+  public void set_uptime_secs_isSet(boolean value) {
+    __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __UPTIME_SECS_ISSET_ID, value);
   }
 
   public boolean is_isLeader() {
@@ -277,16 +295,16 @@ public class NimbusSummary implements org.apache.thrift.TBase<NimbusSummary,
Nim
   }
 
   public void unset_isLeader() {
-    __isset_bit_vector.clear(__ISLEADER_ISSET_ID);
+    __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __ISLEADER_ISSET_ID);
   }
 
   /** Returns true if field isLeader is set (has been assigned a value) and false otherwise
*/
   public boolean is_set_isLeader() {
-    return __isset_bit_vector.get(__ISLEADER_ISSET_ID);
+    return EncodingUtils.testBit(__isset_bitfield, __ISLEADER_ISSET_ID);
   }
 
   public void set_isLeader_isSet(boolean value) {
-    __isset_bit_vector.set(__ISLEADER_ISSET_ID, value);
+    __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __ISLEADER_ISSET_ID, value);
   }
 
   public String get_version() {
@@ -332,9 +350,9 @@ public class NimbusSummary implements org.apache.thrift.TBase<NimbusSummary,
Nim
 
     case UPTIME_SECS:
       if (value == null) {
-        unset_uptimeSecs();
+        unset_uptime_secs();
       } else {
-        set_uptimeSecs((Integer)value);
+        set_uptime_secs((Integer)value);
       }
       break;
 
@@ -366,7 +384,7 @@ public class NimbusSummary implements org.apache.thrift.TBase<NimbusSummary,
Nim
       return Integer.valueOf(get_port());
 
     case UPTIME_SECS:
-      return Integer.valueOf(get_uptimeSecs());
+      return Integer.valueOf(get_uptime_secs());
 
     case IS_LEADER:
       return Boolean.valueOf(is_isLeader());
@@ -390,7 +408,7 @@ public class NimbusSummary implements org.apache.thrift.TBase<NimbusSummary,
Nim
     case PORT:
       return is_set_port();
     case UPTIME_SECS:
-      return is_set_uptimeSecs();
+      return is_set_uptime_secs();
     case IS_LEADER:
       return is_set_isLeader();
     case VERSION:
@@ -430,12 +448,12 @@ public class NimbusSummary implements org.apache.thrift.TBase<NimbusSummary,
Nim
         return false;
     }
 
-    boolean this_present_uptimeSecs = true;
-    boolean that_present_uptimeSecs = true;
-    if (this_present_uptimeSecs || that_present_uptimeSecs) {
-      if (!(this_present_uptimeSecs && that_present_uptimeSecs))
+    boolean this_present_uptime_secs = true;
+    boolean that_present_uptime_secs = true;
+    if (this_present_uptime_secs || that_present_uptime_secs) {
+      if (!(this_present_uptime_secs && that_present_uptime_secs))
         return false;
-      if (this.uptimeSecs != that.uptimeSecs)
+      if (this.uptime_secs != that.uptime_secs)
         return false;
     }
 
@@ -462,90 +480,90 @@ public class NimbusSummary implements org.apache.thrift.TBase<NimbusSummary,
Nim
 
   @Override
   public int hashCode() {
-    HashCodeBuilder builder = new HashCodeBuilder();
+    List<Object> list = new ArrayList<Object>();
 
     boolean present_host = true && (is_set_host());
-    builder.append(present_host);
+    list.add(present_host);
     if (present_host)
-      builder.append(host);
+      list.add(host);
 
     boolean present_port = true;
-    builder.append(present_port);
+    list.add(present_port);
     if (present_port)
-      builder.append(port);
+      list.add(port);
 
-    boolean present_uptimeSecs = true;
-    builder.append(present_uptimeSecs);
-    if (present_uptimeSecs)
-      builder.append(uptimeSecs);
+    boolean present_uptime_secs = true;
+    list.add(present_uptime_secs);
+    if (present_uptime_secs)
+      list.add(uptime_secs);
 
     boolean present_isLeader = true;
-    builder.append(present_isLeader);
+    list.add(present_isLeader);
     if (present_isLeader)
-      builder.append(isLeader);
+      list.add(isLeader);
 
     boolean present_version = true && (is_set_version());
-    builder.append(present_version);
+    list.add(present_version);
     if (present_version)
-      builder.append(version);
+      list.add(version);
 
-    return builder.toHashCode();
+    return list.hashCode();
   }
 
+  @Override
   public int compareTo(NimbusSummary other) {
     if (!getClass().equals(other.getClass())) {
       return getClass().getName().compareTo(other.getClass().getName());
     }
 
     int lastComparison = 0;
-    NimbusSummary typedOther = (NimbusSummary)other;
 
-    lastComparison = Boolean.valueOf(is_set_host()).compareTo(typedOther.is_set_host());
+    lastComparison = Boolean.valueOf(is_set_host()).compareTo(other.is_set_host());
     if (lastComparison != 0) {
       return lastComparison;
     }
     if (is_set_host()) {
-      lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.host, typedOther.host);
+      lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.host, other.host);
       if (lastComparison != 0) {
         return lastComparison;
       }
     }
-    lastComparison = Boolean.valueOf(is_set_port()).compareTo(typedOther.is_set_port());
+    lastComparison = Boolean.valueOf(is_set_port()).compareTo(other.is_set_port());
     if (lastComparison != 0) {
       return lastComparison;
     }
     if (is_set_port()) {
-      lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.port, typedOther.port);
+      lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.port, other.port);
       if (lastComparison != 0) {
         return lastComparison;
       }
     }
-    lastComparison = Boolean.valueOf(is_set_uptimeSecs()).compareTo(typedOther.is_set_uptimeSecs());
+    lastComparison = Boolean.valueOf(is_set_uptime_secs()).compareTo(other.is_set_uptime_secs());
     if (lastComparison != 0) {
       return lastComparison;
     }
-    if (is_set_uptimeSecs()) {
-      lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.uptimeSecs, typedOther.uptimeSecs);
+    if (is_set_uptime_secs()) {
+      lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.uptime_secs, other.uptime_secs);
       if (lastComparison != 0) {
         return lastComparison;
       }
     }
-    lastComparison = Boolean.valueOf(is_set_isLeader()).compareTo(typedOther.is_set_isLeader());
+    lastComparison = Boolean.valueOf(is_set_isLeader()).compareTo(other.is_set_isLeader());
     if (lastComparison != 0) {
       return lastComparison;
     }
     if (is_set_isLeader()) {
-      lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.isLeader, typedOther.isLeader);
+      lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.isLeader, other.isLeader);
       if (lastComparison != 0) {
         return lastComparison;
       }
     }
-    lastComparison = Boolean.valueOf(is_set_version()).compareTo(typedOther.is_set_version());
+    lastComparison = Boolean.valueOf(is_set_version()).compareTo(other.is_set_version());
     if (lastComparison != 0) {
       return lastComparison;
     }
     if (is_set_version()) {
-      lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.version, typedOther.version);
+      lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.version, other.version);
       if (lastComparison != 0) {
         return lastComparison;
       }
@@ -558,87 +576,11 @@ public class NimbusSummary implements org.apache.thrift.TBase<NimbusSummary,
Nim
   }
 
   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: // HOST
-          if (field.type == org.apache.thrift.protocol.TType.STRING) {
-            this.host = iprot.readString();
-          } else { 
-            org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
-          }
-          break;
-        case 2: // PORT
-          if (field.type == org.apache.thrift.protocol.TType.I32) {
-            this.port = iprot.readI32();
-            set_port_isSet(true);
-          } else { 
-            org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
-          }
-          break;
-        case 3: // UPTIME_SECS
-          if (field.type == org.apache.thrift.protocol.TType.I32) {
-            this.uptimeSecs = iprot.readI32();
-            set_uptimeSecs_isSet(true);
-          } else { 
-            org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
-          }
-          break;
-        case 4: // IS_LEADER
-          if (field.type == org.apache.thrift.protocol.TType.BOOL) {
-            this.isLeader = iprot.readBool();
-            set_isLeader_isSet(true);
-          } else { 
-            org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
-          }
-          break;
-        case 5: // VERSION
-          if (field.type == org.apache.thrift.protocol.TType.STRING) {
-            this.version = 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();
-    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.host != null) {
-      oprot.writeFieldBegin(HOST_FIELD_DESC);
-      oprot.writeString(this.host);
-      oprot.writeFieldEnd();
-    }
-    oprot.writeFieldBegin(PORT_FIELD_DESC);
-    oprot.writeI32(this.port);
-    oprot.writeFieldEnd();
-    oprot.writeFieldBegin(UPTIME_SECS_FIELD_DESC);
-    oprot.writeI32(this.uptimeSecs);
-    oprot.writeFieldEnd();
-    oprot.writeFieldBegin(IS_LEADER_FIELD_DESC);
-    oprot.writeBool(this.isLeader);
-    oprot.writeFieldEnd();
-    if (this.version != null) {
-      oprot.writeFieldBegin(VERSION_FIELD_DESC);
-      oprot.writeString(this.version);
-      oprot.writeFieldEnd();
-    }
-    oprot.writeFieldStop();
-    oprot.writeStructEnd();
+    schemes.get(oprot.getScheme()).getScheme().write(oprot, this);
   }
 
   @Override
@@ -658,8 +600,8 @@ public class NimbusSummary implements org.apache.thrift.TBase<NimbusSummary,
Nim
     sb.append(this.port);
     first = false;
     if (!first) sb.append(", ");
-    sb.append("uptimeSecs:");
-    sb.append(this.uptimeSecs);
+    sb.append("uptime_secs:");
+    sb.append(this.uptime_secs);
     first = false;
     if (!first) sb.append(", ");
     sb.append("isLeader:");
@@ -687,8 +629,8 @@ public class NimbusSummary implements org.apache.thrift.TBase<NimbusSummary,
Nim
       throw new org.apache.thrift.protocol.TProtocolException("Required field 'port' is unset!
Struct:" + toString());
     }
 
-    if (!is_set_uptimeSecs()) {
-      throw new org.apache.thrift.protocol.TProtocolException("Required field 'uptimeSecs'
is unset! Struct:" + toString());
+    if (!is_set_uptime_secs()) {
+      throw new org.apache.thrift.protocol.TProtocolException("Required field 'uptime_secs'
is unset! Struct:" + toString());
     }
 
     if (!is_set_isLeader()) {
@@ -699,6 +641,7 @@ public class NimbusSummary implements org.apache.thrift.TBase<NimbusSummary,
Nim
       throw new org.apache.thrift.protocol.TProtocolException("Required field 'version' is
unset! Struct:" + toString());
     }
 
+    // check for sub-struct validity
   }
 
   private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
@@ -712,12 +655,142 @@ public class NimbusSummary implements org.apache.thrift.TBase<NimbusSummary,
Nim
   private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException
{
     try {
       // it doesn't seem like you should have to do this, but java serialization is wacky,
and doesn't call the default constructor.
-      __isset_bit_vector = new BitSet(1);
+      __isset_bitfield = 0;
       read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in)));
     } catch (org.apache.thrift.TException te) {
       throw new java.io.IOException(te);
     }
   }
 
+  private static class NimbusSummaryStandardSchemeFactory implements SchemeFactory {
+    public NimbusSummaryStandardScheme getScheme() {
+      return new NimbusSummaryStandardScheme();
+    }
+  }
+
+  private static class NimbusSummaryStandardScheme extends StandardScheme<NimbusSummary>
{
+
+    public void read(org.apache.thrift.protocol.TProtocol iprot, NimbusSummary 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: // HOST
+            if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
+              struct.host = iprot.readString();
+              struct.set_host_isSet(true);
+            } else { 
+              org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+            }
+            break;
+          case 2: // PORT
+            if (schemeField.type == org.apache.thrift.protocol.TType.I32) {
+              struct.port = iprot.readI32();
+              struct.set_port_isSet(true);
+            } else { 
+              org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+            }
+            break;
+          case 3: // UPTIME_SECS
+            if (schemeField.type == org.apache.thrift.protocol.TType.I32) {
+              struct.uptime_secs = iprot.readI32();
+              struct.set_uptime_secs_isSet(true);
+            } else { 
+              org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+            }
+            break;
+          case 4: // IS_LEADER
+            if (schemeField.type == org.apache.thrift.protocol.TType.BOOL) {
+              struct.isLeader = iprot.readBool();
+              struct.set_isLeader_isSet(true);
+            } else { 
+              org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+            }
+            break;
+          case 5: // VERSION
+            if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
+              struct.version = iprot.readString();
+              struct.set_version_isSet(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();
+      struct.validate();
+    }
+
+    public void write(org.apache.thrift.protocol.TProtocol oprot, NimbusSummary struct) throws
org.apache.thrift.TException {
+      struct.validate();
+
+      oprot.writeStructBegin(STRUCT_DESC);
+      if (struct.host != null) {
+        oprot.writeFieldBegin(HOST_FIELD_DESC);
+        oprot.writeString(struct.host);
+        oprot.writeFieldEnd();
+      }
+      oprot.writeFieldBegin(PORT_FIELD_DESC);
+      oprot.writeI32(struct.port);
+      oprot.writeFieldEnd();
+      oprot.writeFieldBegin(UPTIME_SECS_FIELD_DESC);
+      oprot.writeI32(struct.uptime_secs);
+      oprot.writeFieldEnd();
+      oprot.writeFieldBegin(IS_LEADER_FIELD_DESC);
+      oprot.writeBool(struct.isLeader);
+      oprot.writeFieldEnd();
+      if (struct.version != null) {
+        oprot.writeFieldBegin(VERSION_FIELD_DESC);
+        oprot.writeString(struct.version);
+        oprot.writeFieldEnd();
+      }
+      oprot.writeFieldStop();
+      oprot.writeStructEnd();
+    }
+
+  }
+
+  private static class NimbusSummaryTupleSchemeFactory implements SchemeFactory {
+    public NimbusSummaryTupleScheme getScheme() {
+      return new NimbusSummaryTupleScheme();
+    }
+  }
+
+  private static class NimbusSummaryTupleScheme extends TupleScheme<NimbusSummary>
{
+
+    @Override
+    public void write(org.apache.thrift.protocol.TProtocol prot, NimbusSummary struct) throws
org.apache.thrift.TException {
+      TTupleProtocol oprot = (TTupleProtocol) prot;
+      oprot.writeString(struct.host);
+      oprot.writeI32(struct.port);
+      oprot.writeI32(struct.uptime_secs);
+      oprot.writeBool(struct.isLeader);
+      oprot.writeString(struct.version);
+    }
+
+    @Override
+    public void read(org.apache.thrift.protocol.TProtocol prot, NimbusSummary struct) throws
org.apache.thrift.TException {
+      TTupleProtocol iprot = (TTupleProtocol) prot;
+      struct.host = iprot.readString();
+      struct.set_host_isSet(true);
+      struct.port = iprot.readI32();
+      struct.set_port_isSet(true);
+      struct.uptime_secs = iprot.readI32();
+      struct.set_uptime_secs_isSet(true);
+      struct.isLeader = iprot.readBool();
+      struct.set_isLeader_isSet(true);
+      struct.version = iprot.readString();
+      struct.set_version_isSet(true);
+    }
+  }
+
 }
 


Mime
View raw message