cassandra-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From xe...@apache.org
Subject svn commit: r1169870 - in /cassandra/trunk: ./ interface/ interface/thrift/gen-java/org/apache/cassandra/thrift/ src/java/org/apache/cassandra/thrift/
Date Mon, 12 Sep 2011 19:04:14 GMT
Author: xedin
Date: Mon Sep 12 19:04:14 2011
New Revision: 1169870

URL: http://svn.apache.org/viewvc?rev=1169870&view=rev
Log:
describe_ring should include datacenter/topology information
patch by Mark Guzman; reviewed by Pavel Yaskevich for CASSANDRA-2882

Added:
    cassandra/trunk/interface/thrift/gen-java/org/apache/cassandra/thrift/EndpointDetails.java
Modified:
    cassandra/trunk/CHANGES.txt
    cassandra/trunk/interface/cassandra.thrift
    cassandra/trunk/interface/thrift/gen-java/org/apache/cassandra/thrift/AuthenticationRequest.java
    cassandra/trunk/interface/thrift/gen-java/org/apache/cassandra/thrift/Cassandra.java
    cassandra/trunk/interface/thrift/gen-java/org/apache/cassandra/thrift/CfDef.java
    cassandra/trunk/interface/thrift/gen-java/org/apache/cassandra/thrift/ColumnDef.java
    cassandra/trunk/interface/thrift/gen-java/org/apache/cassandra/thrift/Constants.java
    cassandra/trunk/interface/thrift/gen-java/org/apache/cassandra/thrift/CqlMetadata.java
    cassandra/trunk/interface/thrift/gen-java/org/apache/cassandra/thrift/CqlResult.java
    cassandra/trunk/interface/thrift/gen-java/org/apache/cassandra/thrift/CqlRow.java
    cassandra/trunk/interface/thrift/gen-java/org/apache/cassandra/thrift/KsDef.java
    cassandra/trunk/interface/thrift/gen-java/org/apache/cassandra/thrift/TokenRange.java
    cassandra/trunk/src/java/org/apache/cassandra/thrift/CassandraServer.java

Modified: cassandra/trunk/CHANGES.txt
URL: http://svn.apache.org/viewvc/cassandra/trunk/CHANGES.txt?rev=1169870&r1=1169869&r2=1169870&view=diff
==============================================================================
--- cassandra/trunk/CHANGES.txt (original)
+++ cassandra/trunk/CHANGES.txt Mon Sep 12 19:04:14 2011
@@ -1,5 +1,5 @@
 1.1-dev
-
+ * describe_ring should include datacenter/topology information (CASSANDRA-2882)
 
 1.0.1
 

Modified: cassandra/trunk/interface/cassandra.thrift
URL: http://svn.apache.org/viewvc/cassandra/trunk/interface/cassandra.thrift?rev=1169870&r1=1169869&r2=1169870&view=diff
==============================================================================
--- cassandra/trunk/interface/cassandra.thrift (original)
+++ cassandra/trunk/interface/cassandra.thrift Mon Sep 12 19:04:14 2011
@@ -46,7 +46,7 @@ namespace rb CassandraThrift
 #           for every edit that doesn't result in a change to major/minor.
 #
 # See the Semantic Versioning Specification (SemVer) http://semver.org.
-const string VERSION = "19.14.0"
+const string VERSION = "19.15.0"
 
 
 #
@@ -342,10 +342,17 @@ struct Mutation {
     2: optional Deletion deletion,
 }
 
+struct EndpointDetails {
+	1: string host,
+	2: i32 port,
+	3: string datacenter
+}
+
 struct TokenRange {
     1: required string start_token,
     2: required string end_token,
     3: required list<string> endpoints,
+    4: optional list<EndpointDetails> endpoint_details,
 }
 
 /**

Modified: cassandra/trunk/interface/thrift/gen-java/org/apache/cassandra/thrift/AuthenticationRequest.java
URL: http://svn.apache.org/viewvc/cassandra/trunk/interface/thrift/gen-java/org/apache/cassandra/thrift/AuthenticationRequest.java?rev=1169870&r1=1169869&r2=1169870&view=diff
==============================================================================
--- cassandra/trunk/interface/thrift/gen-java/org/apache/cassandra/thrift/AuthenticationRequest.java (original)
+++ cassandra/trunk/interface/thrift/gen-java/org/apache/cassandra/thrift/AuthenticationRequest.java Mon Sep 12 19:04:14 2011
@@ -308,15 +308,15 @@ public class AuthenticationRequest imple
         case 1: // CREDENTIALS
           if (field.type == org.apache.thrift.protocol.TType.MAP) {
             {
-              org.apache.thrift.protocol.TMap _map24 = iprot.readMapBegin();
-              this.credentials = new HashMap<String,String>(2*_map24.size);
-              for (int _i25 = 0; _i25 < _map24.size; ++_i25)
+              org.apache.thrift.protocol.TMap _map28 = iprot.readMapBegin();
+              this.credentials = new HashMap<String,String>(2*_map28.size);
+              for (int _i29 = 0; _i29 < _map28.size; ++_i29)
               {
-                String _key26;
-                String _val27;
-                _key26 = iprot.readString();
-                _val27 = iprot.readString();
-                this.credentials.put(_key26, _val27);
+                String _key30;
+                String _val31;
+                _key30 = iprot.readString();
+                _val31 = iprot.readString();
+                this.credentials.put(_key30, _val31);
               }
               iprot.readMapEnd();
             }
@@ -343,10 +343,10 @@ public class AuthenticationRequest imple
       oprot.writeFieldBegin(CREDENTIALS_FIELD_DESC);
       {
         oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, this.credentials.size()));
-        for (Map.Entry<String, String> _iter28 : this.credentials.entrySet())
+        for (Map.Entry<String, String> _iter32 : this.credentials.entrySet())
         {
-          oprot.writeString(_iter28.getKey());
-          oprot.writeString(_iter28.getValue());
+          oprot.writeString(_iter32.getKey());
+          oprot.writeString(_iter32.getValue());
         }
         oprot.writeMapEnd();
       }

Modified: cassandra/trunk/interface/thrift/gen-java/org/apache/cassandra/thrift/Cassandra.java
URL: http://svn.apache.org/viewvc/cassandra/trunk/interface/thrift/gen-java/org/apache/cassandra/thrift/Cassandra.java?rev=1169870&r1=1169869&r2=1169870&view=diff
==============================================================================
--- cassandra/trunk/interface/thrift/gen-java/org/apache/cassandra/thrift/Cassandra.java (original)
+++ cassandra/trunk/interface/thrift/gen-java/org/apache/cassandra/thrift/Cassandra.java Mon Sep 12 19:04:14 2011
@@ -7736,14 +7736,14 @@ public class Cassandra {
           case 0: // SUCCESS
             if (field.type == org.apache.thrift.protocol.TType.LIST) {
               {
-                org.apache.thrift.protocol.TList _list75 = iprot.readListBegin();
-                this.success = new ArrayList<ColumnOrSuperColumn>(_list75.size);
-                for (int _i76 = 0; _i76 < _list75.size; ++_i76)
+                org.apache.thrift.protocol.TList _list79 = iprot.readListBegin();
+                this.success = new ArrayList<ColumnOrSuperColumn>(_list79.size);
+                for (int _i80 = 0; _i80 < _list79.size; ++_i80)
                 {
-                  ColumnOrSuperColumn _elem77;
-                  _elem77 = new ColumnOrSuperColumn();
-                  _elem77.read(iprot);
-                  this.success.add(_elem77);
+                  ColumnOrSuperColumn _elem81;
+                  _elem81 = new ColumnOrSuperColumn();
+                  _elem81.read(iprot);
+                  this.success.add(_elem81);
                 }
                 iprot.readListEnd();
               }
@@ -7793,9 +7793,9 @@ public class Cassandra {
         oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
         {
           oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, this.success.size()));
-          for (ColumnOrSuperColumn _iter78 : this.success)
+          for (ColumnOrSuperColumn _iter82 : this.success)
           {
-            _iter78.write(oprot);
+            _iter82.write(oprot);
           }
           oprot.writeListEnd();
         }
@@ -9086,6 +9086,8 @@ public class Cassandra {
 
     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);
         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);
@@ -9595,13 +9597,13 @@ public class Cassandra {
           case 1: // KEYS
             if (field.type == org.apache.thrift.protocol.TType.LIST) {
               {
-                org.apache.thrift.protocol.TList _list79 = iprot.readListBegin();
-                this.keys = new ArrayList<ByteBuffer>(_list79.size);
-                for (int _i80 = 0; _i80 < _list79.size; ++_i80)
+                org.apache.thrift.protocol.TList _list83 = iprot.readListBegin();
+                this.keys = new ArrayList<ByteBuffer>(_list83.size);
+                for (int _i84 = 0; _i84 < _list83.size; ++_i84)
                 {
-                  ByteBuffer _elem81;
-                  _elem81 = iprot.readBinary();
-                  this.keys.add(_elem81);
+                  ByteBuffer _elem85;
+                  _elem85 = iprot.readBinary();
+                  this.keys.add(_elem85);
                 }
                 iprot.readListEnd();
               }
@@ -9651,9 +9653,9 @@ public class Cassandra {
         oprot.writeFieldBegin(KEYS_FIELD_DESC);
         {
           oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, this.keys.size()));
-          for (ByteBuffer _iter82 : this.keys)
+          for (ByteBuffer _iter86 : this.keys)
           {
-            oprot.writeBinary(_iter82);
+            oprot.writeBinary(_iter86);
           }
           oprot.writeListEnd();
         }
@@ -10242,26 +10244,26 @@ public class Cassandra {
           case 0: // SUCCESS
             if (field.type == org.apache.thrift.protocol.TType.MAP) {
               {
-                org.apache.thrift.protocol.TMap _map83 = iprot.readMapBegin();
-                this.success = new HashMap<ByteBuffer,List<ColumnOrSuperColumn>>(2*_map83.size);
-                for (int _i84 = 0; _i84 < _map83.size; ++_i84)
+                org.apache.thrift.protocol.TMap _map87 = iprot.readMapBegin();
+                this.success = new HashMap<ByteBuffer,List<ColumnOrSuperColumn>>(2*_map87.size);
+                for (int _i88 = 0; _i88 < _map87.size; ++_i88)
                 {
-                  ByteBuffer _key85;
-                  List<ColumnOrSuperColumn> _val86;
-                  _key85 = iprot.readBinary();
+                  ByteBuffer _key89;
+                  List<ColumnOrSuperColumn> _val90;
+                  _key89 = iprot.readBinary();
                   {
-                    org.apache.thrift.protocol.TList _list87 = iprot.readListBegin();
-                    _val86 = new ArrayList<ColumnOrSuperColumn>(_list87.size);
-                    for (int _i88 = 0; _i88 < _list87.size; ++_i88)
+                    org.apache.thrift.protocol.TList _list91 = iprot.readListBegin();
+                    _val90 = new ArrayList<ColumnOrSuperColumn>(_list91.size);
+                    for (int _i92 = 0; _i92 < _list91.size; ++_i92)
                     {
-                      ColumnOrSuperColumn _elem89;
-                      _elem89 = new ColumnOrSuperColumn();
-                      _elem89.read(iprot);
-                      _val86.add(_elem89);
+                      ColumnOrSuperColumn _elem93;
+                      _elem93 = new ColumnOrSuperColumn();
+                      _elem93.read(iprot);
+                      _val90.add(_elem93);
                     }
                     iprot.readListEnd();
                   }
-                  this.success.put(_key85, _val86);
+                  this.success.put(_key89, _val90);
                 }
                 iprot.readMapEnd();
               }
@@ -10311,14 +10313,14 @@ public class Cassandra {
         oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
         {
           oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.LIST, this.success.size()));
-          for (Map.Entry<ByteBuffer, List<ColumnOrSuperColumn>> _iter90 : this.success.entrySet())
+          for (Map.Entry<ByteBuffer, List<ColumnOrSuperColumn>> _iter94 : this.success.entrySet())
           {
-            oprot.writeBinary(_iter90.getKey());
+            oprot.writeBinary(_iter94.getKey());
             {
-              oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, _iter90.getValue().size()));
-              for (ColumnOrSuperColumn _iter91 : _iter90.getValue())
+              oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, _iter94.getValue().size()));
+              for (ColumnOrSuperColumn _iter95 : _iter94.getValue())
               {
-                _iter91.write(oprot);
+                _iter95.write(oprot);
               }
               oprot.writeListEnd();
             }
@@ -10906,13 +10908,13 @@ public class Cassandra {
           case 1: // KEYS
             if (field.type == org.apache.thrift.protocol.TType.LIST) {
               {
-                org.apache.thrift.protocol.TList _list92 = iprot.readListBegin();
-                this.keys = new ArrayList<ByteBuffer>(_list92.size);
-                for (int _i93 = 0; _i93 < _list92.size; ++_i93)
+                org.apache.thrift.protocol.TList _list96 = iprot.readListBegin();
+                this.keys = new ArrayList<ByteBuffer>(_list96.size);
+                for (int _i97 = 0; _i97 < _list96.size; ++_i97)
                 {
-                  ByteBuffer _elem94;
-                  _elem94 = iprot.readBinary();
-                  this.keys.add(_elem94);
+                  ByteBuffer _elem98;
+                  _elem98 = iprot.readBinary();
+                  this.keys.add(_elem98);
                 }
                 iprot.readListEnd();
               }
@@ -10962,9 +10964,9 @@ public class Cassandra {
         oprot.writeFieldBegin(KEYS_FIELD_DESC);
         {
           oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, this.keys.size()));
-          for (ByteBuffer _iter95 : this.keys)
+          for (ByteBuffer _iter99 : this.keys)
           {
-            oprot.writeBinary(_iter95);
+            oprot.writeBinary(_iter99);
           }
           oprot.writeListEnd();
         }
@@ -11549,15 +11551,15 @@ public class Cassandra {
           case 0: // SUCCESS
             if (field.type == org.apache.thrift.protocol.TType.MAP) {
               {
-                org.apache.thrift.protocol.TMap _map96 = iprot.readMapBegin();
-                this.success = new HashMap<ByteBuffer,Integer>(2*_map96.size);
-                for (int _i97 = 0; _i97 < _map96.size; ++_i97)
+                org.apache.thrift.protocol.TMap _map100 = iprot.readMapBegin();
+                this.success = new HashMap<ByteBuffer,Integer>(2*_map100.size);
+                for (int _i101 = 0; _i101 < _map100.size; ++_i101)
                 {
-                  ByteBuffer _key98;
-                  int _val99;
-                  _key98 = iprot.readBinary();
-                  _val99 = iprot.readI32();
-                  this.success.put(_key98, _val99);
+                  ByteBuffer _key102;
+                  int _val103;
+                  _key102 = iprot.readBinary();
+                  _val103 = iprot.readI32();
+                  this.success.put(_key102, _val103);
                 }
                 iprot.readMapEnd();
               }
@@ -11607,10 +11609,10 @@ public class Cassandra {
         oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
         {
           oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.I32, this.success.size()));
-          for (Map.Entry<ByteBuffer, Integer> _iter100 : this.success.entrySet())
+          for (Map.Entry<ByteBuffer, Integer> _iter104 : this.success.entrySet())
           {
-            oprot.writeBinary(_iter100.getKey());
-            oprot.writeI32(_iter100.getValue());
+            oprot.writeBinary(_iter104.getKey());
+            oprot.writeI32(_iter104.getValue());
           }
           oprot.writeMapEnd();
         }
@@ -12794,14 +12796,14 @@ public class Cassandra {
           case 0: // SUCCESS
             if (field.type == org.apache.thrift.protocol.TType.LIST) {
               {
-                org.apache.thrift.protocol.TList _list101 = iprot.readListBegin();
-                this.success = new ArrayList<KeySlice>(_list101.size);
-                for (int _i102 = 0; _i102 < _list101.size; ++_i102)
+                org.apache.thrift.protocol.TList _list105 = iprot.readListBegin();
+                this.success = new ArrayList<KeySlice>(_list105.size);
+                for (int _i106 = 0; _i106 < _list105.size; ++_i106)
                 {
-                  KeySlice _elem103;
-                  _elem103 = new KeySlice();
-                  _elem103.read(iprot);
-                  this.success.add(_elem103);
+                  KeySlice _elem107;
+                  _elem107 = new KeySlice();
+                  _elem107.read(iprot);
+                  this.success.add(_elem107);
                 }
                 iprot.readListEnd();
               }
@@ -12851,9 +12853,9 @@ public class Cassandra {
         oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
         {
           oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, this.success.size()));
-          for (KeySlice _iter104 : this.success)
+          for (KeySlice _iter108 : this.success)
           {
-            _iter104.write(oprot);
+            _iter108.write(oprot);
           }
           oprot.writeListEnd();
         }
@@ -14037,14 +14039,14 @@ public class Cassandra {
           case 0: // SUCCESS
             if (field.type == org.apache.thrift.protocol.TType.LIST) {
               {
-                org.apache.thrift.protocol.TList _list105 = iprot.readListBegin();
-                this.success = new ArrayList<KeySlice>(_list105.size);
-                for (int _i106 = 0; _i106 < _list105.size; ++_i106)
+                org.apache.thrift.protocol.TList _list109 = iprot.readListBegin();
+                this.success = new ArrayList<KeySlice>(_list109.size);
+                for (int _i110 = 0; _i110 < _list109.size; ++_i110)
                 {
-                  KeySlice _elem107;
-                  _elem107 = new KeySlice();
-                  _elem107.read(iprot);
-                  this.success.add(_elem107);
+                  KeySlice _elem111;
+                  _elem111 = new KeySlice();
+                  _elem111.read(iprot);
+                  this.success.add(_elem111);
                 }
                 iprot.readListEnd();
               }
@@ -14094,9 +14096,9 @@ public class Cassandra {
         oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
         {
           oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, this.success.size()));
-          for (KeySlice _iter108 : this.success)
+          for (KeySlice _iter112 : this.success)
           {
-            _iter108.write(oprot);
+            _iter112.write(oprot);
           }
           oprot.writeListEnd();
         }
@@ -18941,38 +18943,38 @@ public class Cassandra {
           case 1: // MUTATION_MAP
             if (field.type == org.apache.thrift.protocol.TType.MAP) {
               {
-                org.apache.thrift.protocol.TMap _map109 = iprot.readMapBegin();
-                this.mutation_map = new HashMap<ByteBuffer,Map<String,List<Mutation>>>(2*_map109.size);
-                for (int _i110 = 0; _i110 < _map109.size; ++_i110)
+                org.apache.thrift.protocol.TMap _map113 = iprot.readMapBegin();
+                this.mutation_map = new HashMap<ByteBuffer,Map<String,List<Mutation>>>(2*_map113.size);
+                for (int _i114 = 0; _i114 < _map113.size; ++_i114)
                 {
-                  ByteBuffer _key111;
-                  Map<String,List<Mutation>> _val112;
-                  _key111 = iprot.readBinary();
+                  ByteBuffer _key115;
+                  Map<String,List<Mutation>> _val116;
+                  _key115 = iprot.readBinary();
                   {
-                    org.apache.thrift.protocol.TMap _map113 = iprot.readMapBegin();
-                    _val112 = new HashMap<String,List<Mutation>>(2*_map113.size);
-                    for (int _i114 = 0; _i114 < _map113.size; ++_i114)
+                    org.apache.thrift.protocol.TMap _map117 = iprot.readMapBegin();
+                    _val116 = new HashMap<String,List<Mutation>>(2*_map117.size);
+                    for (int _i118 = 0; _i118 < _map117.size; ++_i118)
                     {
-                      String _key115;
-                      List<Mutation> _val116;
-                      _key115 = iprot.readString();
+                      String _key119;
+                      List<Mutation> _val120;
+                      _key119 = iprot.readString();
                       {
-                        org.apache.thrift.protocol.TList _list117 = iprot.readListBegin();
-                        _val116 = new ArrayList<Mutation>(_list117.size);
-                        for (int _i118 = 0; _i118 < _list117.size; ++_i118)
+                        org.apache.thrift.protocol.TList _list121 = iprot.readListBegin();
+                        _val120 = new ArrayList<Mutation>(_list121.size);
+                        for (int _i122 = 0; _i122 < _list121.size; ++_i122)
                         {
-                          Mutation _elem119;
-                          _elem119 = new Mutation();
-                          _elem119.read(iprot);
-                          _val116.add(_elem119);
+                          Mutation _elem123;
+                          _elem123 = new Mutation();
+                          _elem123.read(iprot);
+                          _val120.add(_elem123);
                         }
                         iprot.readListEnd();
                       }
-                      _val112.put(_key115, _val116);
+                      _val116.put(_key119, _val120);
                     }
                     iprot.readMapEnd();
                   }
-                  this.mutation_map.put(_key111, _val112);
+                  this.mutation_map.put(_key115, _val116);
                 }
                 iprot.readMapEnd();
               }
@@ -19006,19 +19008,19 @@ public class Cassandra {
         oprot.writeFieldBegin(MUTATION_MAP_FIELD_DESC);
         {
           oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.MAP, this.mutation_map.size()));
-          for (Map.Entry<ByteBuffer, Map<String,List<Mutation>>> _iter120 : this.mutation_map.entrySet())
+          for (Map.Entry<ByteBuffer, Map<String,List<Mutation>>> _iter124 : this.mutation_map.entrySet())
           {
-            oprot.writeBinary(_iter120.getKey());
+            oprot.writeBinary(_iter124.getKey());
             {
-              oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.LIST, _iter120.getValue().size()));
-              for (Map.Entry<String, List<Mutation>> _iter121 : _iter120.getValue().entrySet())
+              oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.LIST, _iter124.getValue().size()));
+              for (Map.Entry<String, List<Mutation>> _iter125 : _iter124.getValue().entrySet())
               {
-                oprot.writeString(_iter121.getKey());
+                oprot.writeString(_iter125.getKey());
                 {
-                  oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, _iter121.getValue().size()));
-                  for (Mutation _iter122 : _iter121.getValue())
+                  oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, _iter125.getValue().size()));
+                  for (Mutation _iter126 : _iter125.getValue())
                   {
-                    _iter122.write(oprot);
+                    _iter126.write(oprot);
                   }
                   oprot.writeListEnd();
                 }
@@ -20833,25 +20835,25 @@ public class Cassandra {
           case 0: // SUCCESS
             if (field.type == org.apache.thrift.protocol.TType.MAP) {
               {
-                org.apache.thrift.protocol.TMap _map123 = iprot.readMapBegin();
-                this.success = new HashMap<String,List<String>>(2*_map123.size);
-                for (int _i124 = 0; _i124 < _map123.size; ++_i124)
+                org.apache.thrift.protocol.TMap _map127 = iprot.readMapBegin();
+                this.success = new HashMap<String,List<String>>(2*_map127.size);
+                for (int _i128 = 0; _i128 < _map127.size; ++_i128)
                 {
-                  String _key125;
-                  List<String> _val126;
-                  _key125 = iprot.readString();
+                  String _key129;
+                  List<String> _val130;
+                  _key129 = iprot.readString();
                   {
-                    org.apache.thrift.protocol.TList _list127 = iprot.readListBegin();
-                    _val126 = new ArrayList<String>(_list127.size);
-                    for (int _i128 = 0; _i128 < _list127.size; ++_i128)
+                    org.apache.thrift.protocol.TList _list131 = iprot.readListBegin();
+                    _val130 = new ArrayList<String>(_list131.size);
+                    for (int _i132 = 0; _i132 < _list131.size; ++_i132)
                     {
-                      String _elem129;
-                      _elem129 = iprot.readString();
-                      _val126.add(_elem129);
+                      String _elem133;
+                      _elem133 = iprot.readString();
+                      _val130.add(_elem133);
                     }
                     iprot.readListEnd();
                   }
-                  this.success.put(_key125, _val126);
+                  this.success.put(_key129, _val130);
                 }
                 iprot.readMapEnd();
               }
@@ -20885,14 +20887,14 @@ public class Cassandra {
         oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
         {
           oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.LIST, this.success.size()));
-          for (Map.Entry<String, List<String>> _iter130 : this.success.entrySet())
+          for (Map.Entry<String, List<String>> _iter134 : this.success.entrySet())
           {
-            oprot.writeString(_iter130.getKey());
+            oprot.writeString(_iter134.getKey());
             {
-              oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, _iter130.getValue().size()));
-              for (String _iter131 : _iter130.getValue())
+              oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, _iter134.getValue().size()));
+              for (String _iter135 : _iter134.getValue())
               {
-                oprot.writeString(_iter131);
+                oprot.writeString(_iter135);
               }
               oprot.writeListEnd();
             }
@@ -21491,14 +21493,14 @@ public class Cassandra {
           case 0: // SUCCESS
             if (field.type == org.apache.thrift.protocol.TType.LIST) {
               {
-                org.apache.thrift.protocol.TList _list132 = iprot.readListBegin();
-                this.success = new ArrayList<KsDef>(_list132.size);
-                for (int _i133 = 0; _i133 < _list132.size; ++_i133)
+                org.apache.thrift.protocol.TList _list136 = iprot.readListBegin();
+                this.success = new ArrayList<KsDef>(_list136.size);
+                for (int _i137 = 0; _i137 < _list136.size; ++_i137)
                 {
-                  KsDef _elem134;
-                  _elem134 = new KsDef();
-                  _elem134.read(iprot);
-                  this.success.add(_elem134);
+                  KsDef _elem138;
+                  _elem138 = new KsDef();
+                  _elem138.read(iprot);
+                  this.success.add(_elem138);
                 }
                 iprot.readListEnd();
               }
@@ -21532,9 +21534,9 @@ public class Cassandra {
         oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
         {
           oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, this.success.size()));
-          for (KsDef _iter135 : this.success)
+          for (KsDef _iter139 : this.success)
           {
-            _iter135.write(oprot);
+            _iter139.write(oprot);
           }
           oprot.writeListEnd();
         }
@@ -23247,14 +23249,14 @@ public class Cassandra {
           case 0: // SUCCESS
             if (field.type == org.apache.thrift.protocol.TType.LIST) {
               {
-                org.apache.thrift.protocol.TList _list136 = iprot.readListBegin();
-                this.success = new ArrayList<TokenRange>(_list136.size);
-                for (int _i137 = 0; _i137 < _list136.size; ++_i137)
+                org.apache.thrift.protocol.TList _list140 = iprot.readListBegin();
+                this.success = new ArrayList<TokenRange>(_list140.size);
+                for (int _i141 = 0; _i141 < _list140.size; ++_i141)
                 {
-                  TokenRange _elem138;
-                  _elem138 = new TokenRange();
-                  _elem138.read(iprot);
-                  this.success.add(_elem138);
+                  TokenRange _elem142;
+                  _elem142 = new TokenRange();
+                  _elem142.read(iprot);
+                  this.success.add(_elem142);
                 }
                 iprot.readListEnd();
               }
@@ -23288,9 +23290,9 @@ public class Cassandra {
         oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
         {
           oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, this.success.size()));
-          for (TokenRange _iter139 : this.success)
+          for (TokenRange _iter143 : this.success)
           {
-            _iter139.write(oprot);
+            _iter143.write(oprot);
           }
           oprot.writeListEnd();
         }
@@ -26092,13 +26094,13 @@ public class Cassandra {
           case 0: // SUCCESS
             if (field.type == org.apache.thrift.protocol.TType.LIST) {
               {
-                org.apache.thrift.protocol.TList _list140 = iprot.readListBegin();
-                this.success = new ArrayList<String>(_list140.size);
-                for (int _i141 = 0; _i141 < _list140.size; ++_i141)
+                org.apache.thrift.protocol.TList _list144 = iprot.readListBegin();
+                this.success = new ArrayList<String>(_list144.size);
+                for (int _i145 = 0; _i145 < _list144.size; ++_i145)
                 {
-                  String _elem142;
-                  _elem142 = iprot.readString();
-                  this.success.add(_elem142);
+                  String _elem146;
+                  _elem146 = iprot.readString();
+                  this.success.add(_elem146);
                 }
                 iprot.readListEnd();
               }
@@ -26132,9 +26134,9 @@ public class Cassandra {
         oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
         {
           oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, this.success.size()));
-          for (String _iter143 : this.success)
+          for (String _iter147 : this.success)
           {
-            oprot.writeString(_iter143);
+            oprot.writeString(_iter147);
           }
           oprot.writeListEnd();
         }

Modified: cassandra/trunk/interface/thrift/gen-java/org/apache/cassandra/thrift/CfDef.java
URL: http://svn.apache.org/viewvc/cassandra/trunk/interface/thrift/gen-java/org/apache/cassandra/thrift/CfDef.java?rev=1169870&r1=1169869&r2=1169870&view=diff
==============================================================================
--- cassandra/trunk/interface/thrift/gen-java/org/apache/cassandra/thrift/CfDef.java (original)
+++ cassandra/trunk/interface/thrift/gen-java/org/apache/cassandra/thrift/CfDef.java Mon Sep 12 19:04:14 2011
@@ -2235,14 +2235,14 @@ public class CfDef implements org.apache
         case 13: // COLUMN_METADATA
           if (field.type == org.apache.thrift.protocol.TType.LIST) {
             {
-              org.apache.thrift.protocol.TList _list34 = iprot.readListBegin();
-              this.column_metadata = new ArrayList<ColumnDef>(_list34.size);
-              for (int _i35 = 0; _i35 < _list34.size; ++_i35)
+              org.apache.thrift.protocol.TList _list38 = iprot.readListBegin();
+              this.column_metadata = new ArrayList<ColumnDef>(_list38.size);
+              for (int _i39 = 0; _i39 < _list38.size; ++_i39)
               {
-                ColumnDef _elem36;
-                _elem36 = new ColumnDef();
-                _elem36.read(iprot);
-                this.column_metadata.add(_elem36);
+                ColumnDef _elem40;
+                _elem40 = new ColumnDef();
+                _elem40.read(iprot);
+                this.column_metadata.add(_elem40);
               }
               iprot.readListEnd();
             }
@@ -2352,15 +2352,15 @@ public class CfDef implements org.apache
         case 30: // COMPACTION_STRATEGY_OPTIONS
           if (field.type == org.apache.thrift.protocol.TType.MAP) {
             {
-              org.apache.thrift.protocol.TMap _map37 = iprot.readMapBegin();
-              this.compaction_strategy_options = new HashMap<String,String>(2*_map37.size);
-              for (int _i38 = 0; _i38 < _map37.size; ++_i38)
+              org.apache.thrift.protocol.TMap _map41 = iprot.readMapBegin();
+              this.compaction_strategy_options = new HashMap<String,String>(2*_map41.size);
+              for (int _i42 = 0; _i42 < _map41.size; ++_i42)
               {
-                String _key39;
-                String _val40;
-                _key39 = iprot.readString();
-                _val40 = iprot.readString();
-                this.compaction_strategy_options.put(_key39, _val40);
+                String _key43;
+                String _val44;
+                _key43 = iprot.readString();
+                _val44 = iprot.readString();
+                this.compaction_strategy_options.put(_key43, _val44);
               }
               iprot.readMapEnd();
             }
@@ -2379,15 +2379,15 @@ public class CfDef implements org.apache
         case 32: // COMPRESSION_OPTIONS
           if (field.type == org.apache.thrift.protocol.TType.MAP) {
             {
-              org.apache.thrift.protocol.TMap _map41 = iprot.readMapBegin();
-              this.compression_options = new HashMap<String,String>(2*_map41.size);
-              for (int _i42 = 0; _i42 < _map41.size; ++_i42)
+              org.apache.thrift.protocol.TMap _map45 = iprot.readMapBegin();
+              this.compression_options = new HashMap<String,String>(2*_map45.size);
+              for (int _i46 = 0; _i46 < _map45.size; ++_i46)
               {
-                String _key43;
-                String _val44;
-                _key43 = iprot.readString();
-                _val44 = iprot.readString();
-                this.compression_options.put(_key43, _val44);
+                String _key47;
+                String _val48;
+                _key47 = iprot.readString();
+                _val48 = iprot.readString();
+                this.compression_options.put(_key47, _val48);
               }
               iprot.readMapEnd();
             }
@@ -2468,9 +2468,9 @@ public class CfDef implements org.apache
         oprot.writeFieldBegin(COLUMN_METADATA_FIELD_DESC);
         {
           oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, this.column_metadata.size()));
-          for (ColumnDef _iter45 : this.column_metadata)
+          for (ColumnDef _iter49 : this.column_metadata)
           {
-            _iter45.write(oprot);
+            _iter49.write(oprot);
           }
           oprot.writeListEnd();
         }
@@ -2557,10 +2557,10 @@ public class CfDef implements org.apache
         oprot.writeFieldBegin(COMPACTION_STRATEGY_OPTIONS_FIELD_DESC);
         {
           oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, this.compaction_strategy_options.size()));
-          for (Map.Entry<String, String> _iter46 : this.compaction_strategy_options.entrySet())
+          for (Map.Entry<String, String> _iter50 : this.compaction_strategy_options.entrySet())
           {
-            oprot.writeString(_iter46.getKey());
-            oprot.writeString(_iter46.getValue());
+            oprot.writeString(_iter50.getKey());
+            oprot.writeString(_iter50.getValue());
           }
           oprot.writeMapEnd();
         }
@@ -2577,10 +2577,10 @@ public class CfDef implements org.apache
         oprot.writeFieldBegin(COMPRESSION_OPTIONS_FIELD_DESC);
         {
           oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, this.compression_options.size()));
-          for (Map.Entry<String, String> _iter47 : this.compression_options.entrySet())
+          for (Map.Entry<String, String> _iter51 : this.compression_options.entrySet())
           {
-            oprot.writeString(_iter47.getKey());
-            oprot.writeString(_iter47.getValue());
+            oprot.writeString(_iter51.getKey());
+            oprot.writeString(_iter51.getValue());
           }
           oprot.writeMapEnd();
         }

Modified: cassandra/trunk/interface/thrift/gen-java/org/apache/cassandra/thrift/ColumnDef.java
URL: http://svn.apache.org/viewvc/cassandra/trunk/interface/thrift/gen-java/org/apache/cassandra/thrift/ColumnDef.java?rev=1169870&r1=1169869&r2=1169870&view=diff
==============================================================================
--- cassandra/trunk/interface/thrift/gen-java/org/apache/cassandra/thrift/ColumnDef.java (original)
+++ cassandra/trunk/interface/thrift/gen-java/org/apache/cassandra/thrift/ColumnDef.java Mon Sep 12 19:04:14 2011
@@ -650,15 +650,15 @@ public class ColumnDef implements org.ap
         case 5: // INDEX_OPTIONS
           if (field.type == org.apache.thrift.protocol.TType.MAP) {
             {
-              org.apache.thrift.protocol.TMap _map29 = iprot.readMapBegin();
-              this.index_options = new HashMap<String,String>(2*_map29.size);
-              for (int _i30 = 0; _i30 < _map29.size; ++_i30)
+              org.apache.thrift.protocol.TMap _map33 = iprot.readMapBegin();
+              this.index_options = new HashMap<String,String>(2*_map33.size);
+              for (int _i34 = 0; _i34 < _map33.size; ++_i34)
               {
-                String _key31;
-                String _val32;
-                _key31 = iprot.readString();
-                _val32 = iprot.readString();
-                this.index_options.put(_key31, _val32);
+                String _key35;
+                String _val36;
+                _key35 = iprot.readString();
+                _val36 = iprot.readString();
+                this.index_options.put(_key35, _val36);
               }
               iprot.readMapEnd();
             }
@@ -710,10 +710,10 @@ public class ColumnDef implements org.ap
         oprot.writeFieldBegin(INDEX_OPTIONS_FIELD_DESC);
         {
           oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, this.index_options.size()));
-          for (Map.Entry<String, String> _iter33 : this.index_options.entrySet())
+          for (Map.Entry<String, String> _iter37 : this.index_options.entrySet())
           {
-            oprot.writeString(_iter33.getKey());
-            oprot.writeString(_iter33.getValue());
+            oprot.writeString(_iter37.getKey());
+            oprot.writeString(_iter37.getValue());
           }
           oprot.writeMapEnd();
         }

Modified: cassandra/trunk/interface/thrift/gen-java/org/apache/cassandra/thrift/Constants.java
URL: http://svn.apache.org/viewvc/cassandra/trunk/interface/thrift/gen-java/org/apache/cassandra/thrift/Constants.java?rev=1169870&r1=1169869&r2=1169870&view=diff
==============================================================================
--- cassandra/trunk/interface/thrift/gen-java/org/apache/cassandra/thrift/Constants.java (original)
+++ cassandra/trunk/interface/thrift/gen-java/org/apache/cassandra/thrift/Constants.java Mon Sep 12 19:04:14 2011
@@ -44,6 +44,6 @@ import org.slf4j.LoggerFactory;
 
 public class Constants {
 
-  public static final String VERSION = "19.14.0";
+  public static final String VERSION = "19.15.0";
 
 }

Modified: cassandra/trunk/interface/thrift/gen-java/org/apache/cassandra/thrift/CqlMetadata.java
URL: http://svn.apache.org/viewvc/cassandra/trunk/interface/thrift/gen-java/org/apache/cassandra/thrift/CqlMetadata.java?rev=1169870&r1=1169869&r2=1169870&view=diff
==============================================================================
--- cassandra/trunk/interface/thrift/gen-java/org/apache/cassandra/thrift/CqlMetadata.java (original)
+++ cassandra/trunk/interface/thrift/gen-java/org/apache/cassandra/thrift/CqlMetadata.java Mon Sep 12 19:04:14 2011
@@ -554,15 +554,15 @@ public class CqlMetadata implements org.
         case 1: // NAME_TYPES
           if (field.type == org.apache.thrift.protocol.TType.MAP) {
             {
-              org.apache.thrift.protocol.TMap _map61 = iprot.readMapBegin();
-              this.name_types = new HashMap<ByteBuffer,String>(2*_map61.size);
-              for (int _i62 = 0; _i62 < _map61.size; ++_i62)
+              org.apache.thrift.protocol.TMap _map65 = iprot.readMapBegin();
+              this.name_types = new HashMap<ByteBuffer,String>(2*_map65.size);
+              for (int _i66 = 0; _i66 < _map65.size; ++_i66)
               {
-                ByteBuffer _key63;
-                String _val64;
-                _key63 = iprot.readBinary();
-                _val64 = iprot.readString();
-                this.name_types.put(_key63, _val64);
+                ByteBuffer _key67;
+                String _val68;
+                _key67 = iprot.readBinary();
+                _val68 = iprot.readString();
+                this.name_types.put(_key67, _val68);
               }
               iprot.readMapEnd();
             }
@@ -573,15 +573,15 @@ public class CqlMetadata implements org.
         case 2: // VALUE_TYPES
           if (field.type == org.apache.thrift.protocol.TType.MAP) {
             {
-              org.apache.thrift.protocol.TMap _map65 = iprot.readMapBegin();
-              this.value_types = new HashMap<ByteBuffer,String>(2*_map65.size);
-              for (int _i66 = 0; _i66 < _map65.size; ++_i66)
+              org.apache.thrift.protocol.TMap _map69 = iprot.readMapBegin();
+              this.value_types = new HashMap<ByteBuffer,String>(2*_map69.size);
+              for (int _i70 = 0; _i70 < _map69.size; ++_i70)
               {
-                ByteBuffer _key67;
-                String _val68;
-                _key67 = iprot.readBinary();
-                _val68 = iprot.readString();
-                this.value_types.put(_key67, _val68);
+                ByteBuffer _key71;
+                String _val72;
+                _key71 = iprot.readBinary();
+                _val72 = iprot.readString();
+                this.value_types.put(_key71, _val72);
               }
               iprot.readMapEnd();
             }
@@ -622,10 +622,10 @@ public class CqlMetadata implements org.
       oprot.writeFieldBegin(NAME_TYPES_FIELD_DESC);
       {
         oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, this.name_types.size()));
-        for (Map.Entry<ByteBuffer, String> _iter69 : this.name_types.entrySet())
+        for (Map.Entry<ByteBuffer, String> _iter73 : this.name_types.entrySet())
         {
-          oprot.writeBinary(_iter69.getKey());
-          oprot.writeString(_iter69.getValue());
+          oprot.writeBinary(_iter73.getKey());
+          oprot.writeString(_iter73.getValue());
         }
         oprot.writeMapEnd();
       }
@@ -635,10 +635,10 @@ public class CqlMetadata implements org.
       oprot.writeFieldBegin(VALUE_TYPES_FIELD_DESC);
       {
         oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, this.value_types.size()));
-        for (Map.Entry<ByteBuffer, String> _iter70 : this.value_types.entrySet())
+        for (Map.Entry<ByteBuffer, String> _iter74 : this.value_types.entrySet())
         {
-          oprot.writeBinary(_iter70.getKey());
-          oprot.writeString(_iter70.getValue());
+          oprot.writeBinary(_iter74.getKey());
+          oprot.writeString(_iter74.getValue());
         }
         oprot.writeMapEnd();
       }

Modified: cassandra/trunk/interface/thrift/gen-java/org/apache/cassandra/thrift/CqlResult.java
URL: http://svn.apache.org/viewvc/cassandra/trunk/interface/thrift/gen-java/org/apache/cassandra/thrift/CqlResult.java?rev=1169870&r1=1169869&r2=1169870&view=diff
==============================================================================
--- cassandra/trunk/interface/thrift/gen-java/org/apache/cassandra/thrift/CqlResult.java (original)
+++ cassandra/trunk/interface/thrift/gen-java/org/apache/cassandra/thrift/CqlResult.java Mon Sep 12 19:04:14 2011
@@ -541,14 +541,14 @@ public class CqlResult implements org.ap
         case 2: // ROWS
           if (field.type == org.apache.thrift.protocol.TType.LIST) {
             {
-              org.apache.thrift.protocol.TList _list71 = iprot.readListBegin();
-              this.rows = new ArrayList<CqlRow>(_list71.size);
-              for (int _i72 = 0; _i72 < _list71.size; ++_i72)
+              org.apache.thrift.protocol.TList _list75 = iprot.readListBegin();
+              this.rows = new ArrayList<CqlRow>(_list75.size);
+              for (int _i76 = 0; _i76 < _list75.size; ++_i76)
               {
-                CqlRow _elem73;
-                _elem73 = new CqlRow();
-                _elem73.read(iprot);
-                this.rows.add(_elem73);
+                CqlRow _elem77;
+                _elem77 = new CqlRow();
+                _elem77.read(iprot);
+                this.rows.add(_elem77);
               }
               iprot.readListEnd();
             }
@@ -597,9 +597,9 @@ public class CqlResult implements org.ap
         oprot.writeFieldBegin(ROWS_FIELD_DESC);
         {
           oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, this.rows.size()));
-          for (CqlRow _iter74 : this.rows)
+          for (CqlRow _iter78 : this.rows)
           {
-            _iter74.write(oprot);
+            _iter78.write(oprot);
           }
           oprot.writeListEnd();
         }

Modified: cassandra/trunk/interface/thrift/gen-java/org/apache/cassandra/thrift/CqlRow.java
URL: http://svn.apache.org/viewvc/cassandra/trunk/interface/thrift/gen-java/org/apache/cassandra/thrift/CqlRow.java?rev=1169870&r1=1169869&r2=1169870&view=diff
==============================================================================
--- cassandra/trunk/interface/thrift/gen-java/org/apache/cassandra/thrift/CqlRow.java (original)
+++ cassandra/trunk/interface/thrift/gen-java/org/apache/cassandra/thrift/CqlRow.java Mon Sep 12 19:04:14 2011
@@ -395,14 +395,14 @@ public class CqlRow implements org.apach
         case 2: // COLUMNS
           if (field.type == org.apache.thrift.protocol.TType.LIST) {
             {
-              org.apache.thrift.protocol.TList _list57 = iprot.readListBegin();
-              this.columns = new ArrayList<Column>(_list57.size);
-              for (int _i58 = 0; _i58 < _list57.size; ++_i58)
+              org.apache.thrift.protocol.TList _list61 = iprot.readListBegin();
+              this.columns = new ArrayList<Column>(_list61.size);
+              for (int _i62 = 0; _i62 < _list61.size; ++_i62)
               {
-                Column _elem59;
-                _elem59 = new Column();
-                _elem59.read(iprot);
-                this.columns.add(_elem59);
+                Column _elem63;
+                _elem63 = new Column();
+                _elem63.read(iprot);
+                this.columns.add(_elem63);
               }
               iprot.readListEnd();
             }
@@ -434,9 +434,9 @@ public class CqlRow implements org.apach
       oprot.writeFieldBegin(COLUMNS_FIELD_DESC);
       {
         oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, this.columns.size()));
-        for (Column _iter60 : this.columns)
+        for (Column _iter64 : this.columns)
         {
-          _iter60.write(oprot);
+          _iter64.write(oprot);
         }
         oprot.writeListEnd();
       }

Added: cassandra/trunk/interface/thrift/gen-java/org/apache/cassandra/thrift/EndpointDetails.java
URL: http://svn.apache.org/viewvc/cassandra/trunk/interface/thrift/gen-java/org/apache/cassandra/thrift/EndpointDetails.java?rev=1169870&view=auto
==============================================================================
--- cassandra/trunk/interface/thrift/gen-java/org/apache/cassandra/thrift/EndpointDetails.java (added)
+++ cassandra/trunk/interface/thrift/gen-java/org/apache/cassandra/thrift/EndpointDetails.java Mon Sep 12 19:04:14 2011
@@ -0,0 +1,536 @@
+/**
+ * Autogenerated by Thrift
+ *
+ * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
+ */
+package org.apache.cassandra.thrift;
+/*
+ * 
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ * 
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ * 
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ * 
+ */
+
+
+import org.apache.commons.lang.builder.HashCodeBuilder;
+import java.util.List;
+import java.util.ArrayList;
+import java.util.Map;
+import java.util.HashMap;
+import java.util.EnumMap;
+import java.util.Set;
+import java.util.HashSet;
+import java.util.EnumSet;
+import java.util.Collections;
+import java.util.BitSet;
+import java.nio.ByteBuffer;
+import java.util.Arrays;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+public class EndpointDetails implements org.apache.thrift.TBase<EndpointDetails, EndpointDetails._Fields>, java.io.Serializable, Cloneable {
+  private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("EndpointDetails");
+
+  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 DATACENTER_FIELD_DESC = new org.apache.thrift.protocol.TField("datacenter", org.apache.thrift.protocol.TType.STRING, (short)3);
+
+  public String host;
+  public int port;
+  public String datacenter;
+
+  /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */
+  public enum _Fields implements org.apache.thrift.TFieldIdEnum {
+    HOST((short)1, "host"),
+    PORT((short)2, "port"),
+    DATACENTER((short)3, "datacenter");
+
+    private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
+
+    static {
+      for (_Fields field : EnumSet.allOf(_Fields.class)) {
+        byName.put(field.getFieldName(), field);
+      }
+    }
+
+    /**
+     * Find the _Fields constant that matches fieldId, or null if its not found.
+     */
+    public static _Fields findByThriftId(int fieldId) {
+      switch(fieldId) {
+        case 1: // HOST
+          return HOST;
+        case 2: // PORT
+          return PORT;
+        case 3: // DATACENTER
+          return DATACENTER;
+        default:
+          return null;
+      }
+    }
+
+    /**
+     * Find the _Fields constant that matches fieldId, throwing an exception
+     * if it is not found.
+     */
+    public static _Fields findByThriftIdOrThrow(int fieldId) {
+      _Fields fields = findByThriftId(fieldId);
+      if (fields == null) throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!");
+      return fields;
+    }
+
+    /**
+     * Find the _Fields constant that matches name, or null if its not found.
+     */
+    public static _Fields findByName(String name) {
+      return byName.get(name);
+    }
+
+    private final short _thriftId;
+    private final String _fieldName;
+
+    _Fields(short thriftId, String fieldName) {
+      _thriftId = thriftId;
+      _fieldName = fieldName;
+    }
+
+    public short getThriftFieldId() {
+      return _thriftId;
+    }
+
+    public String getFieldName() {
+      return _fieldName;
+    }
+  }
+
+  // isset id assignments
+  private static final int __PORT_ISSET_ID = 0;
+  private BitSet __isset_bit_vector = new BitSet(1);
+
+  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);
+    tmpMap.put(_Fields.HOST, new org.apache.thrift.meta_data.FieldMetaData("host", org.apache.thrift.TFieldRequirementType.DEFAULT, 
+        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.DEFAULT, 
+        new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I32)));
+    tmpMap.put(_Fields.DATACENTER, new org.apache.thrift.meta_data.FieldMetaData("datacenter", org.apache.thrift.TFieldRequirementType.DEFAULT, 
+        new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
+    metaDataMap = Collections.unmodifiableMap(tmpMap);
+    org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(EndpointDetails.class, metaDataMap);
+  }
+
+  public EndpointDetails() {
+  }
+
+  public EndpointDetails(
+    String host,
+    int port,
+    String datacenter)
+  {
+    this();
+    this.host = host;
+    this.port = port;
+    setPortIsSet(true);
+    this.datacenter = datacenter;
+  }
+
+  /**
+   * Performs a deep copy on <i>other</i>.
+   */
+  public EndpointDetails(EndpointDetails other) {
+    __isset_bit_vector.clear();
+    __isset_bit_vector.or(other.__isset_bit_vector);
+    if (other.isSetHost()) {
+      this.host = other.host;
+    }
+    this.port = other.port;
+    if (other.isSetDatacenter()) {
+      this.datacenter = other.datacenter;
+    }
+  }
+
+  public EndpointDetails deepCopy() {
+    return new EndpointDetails(this);
+  }
+
+  @Override
+  public void clear() {
+    this.host = null;
+    setPortIsSet(false);
+    this.port = 0;
+    this.datacenter = null;
+  }
+
+  public String getHost() {
+    return this.host;
+  }
+
+  public EndpointDetails setHost(String host) {
+    this.host = host;
+    return this;
+  }
+
+  public void unsetHost() {
+    this.host = null;
+  }
+
+  /** Returns true if field host is set (has been assigned a value) and false otherwise */
+  public boolean isSetHost() {
+    return this.host != null;
+  }
+
+  public void setHostIsSet(boolean value) {
+    if (!value) {
+      this.host = null;
+    }
+  }
+
+  public int getPort() {
+    return this.port;
+  }
+
+  public EndpointDetails setPort(int port) {
+    this.port = port;
+    setPortIsSet(true);
+    return this;
+  }
+
+  public void unsetPort() {
+    __isset_bit_vector.clear(__PORT_ISSET_ID);
+  }
+
+  /** Returns true if field port is set (has been assigned a value) and false otherwise */
+  public boolean isSetPort() {
+    return __isset_bit_vector.get(__PORT_ISSET_ID);
+  }
+
+  public void setPortIsSet(boolean value) {
+    __isset_bit_vector.set(__PORT_ISSET_ID, value);
+  }
+
+  public String getDatacenter() {
+    return this.datacenter;
+  }
+
+  public EndpointDetails setDatacenter(String datacenter) {
+    this.datacenter = datacenter;
+    return this;
+  }
+
+  public void unsetDatacenter() {
+    this.datacenter = null;
+  }
+
+  /** Returns true if field datacenter is set (has been assigned a value) and false otherwise */
+  public boolean isSetDatacenter() {
+    return this.datacenter != null;
+  }
+
+  public void setDatacenterIsSet(boolean value) {
+    if (!value) {
+      this.datacenter = null;
+    }
+  }
+
+  public void setFieldValue(_Fields field, Object value) {
+    switch (field) {
+    case HOST:
+      if (value == null) {
+        unsetHost();
+      } else {
+        setHost((String)value);
+      }
+      break;
+
+    case PORT:
+      if (value == null) {
+        unsetPort();
+      } else {
+        setPort((Integer)value);
+      }
+      break;
+
+    case DATACENTER:
+      if (value == null) {
+        unsetDatacenter();
+      } else {
+        setDatacenter((String)value);
+      }
+      break;
+
+    }
+  }
+
+  public Object getFieldValue(_Fields field) {
+    switch (field) {
+    case HOST:
+      return getHost();
+
+    case PORT:
+      return new Integer(getPort());
+
+    case DATACENTER:
+      return getDatacenter();
+
+    }
+    throw new IllegalStateException();
+  }
+
+  /** Returns true if field corresponding to fieldID is set (has been assigned a value) and false otherwise */
+  public boolean isSet(_Fields field) {
+    if (field == null) {
+      throw new IllegalArgumentException();
+    }
+
+    switch (field) {
+    case HOST:
+      return isSetHost();
+    case PORT:
+      return isSetPort();
+    case DATACENTER:
+      return isSetDatacenter();
+    }
+    throw new IllegalStateException();
+  }
+
+  @Override
+  public boolean equals(Object that) {
+    if (that == null)
+      return false;
+    if (that instanceof EndpointDetails)
+      return this.equals((EndpointDetails)that);
+    return false;
+  }
+
+  public boolean equals(EndpointDetails that) {
+    if (that == null)
+      return false;
+
+    boolean this_present_host = true && this.isSetHost();
+    boolean that_present_host = true && that.isSetHost();
+    if (this_present_host || that_present_host) {
+      if (!(this_present_host && that_present_host))
+        return false;
+      if (!this.host.equals(that.host))
+        return false;
+    }
+
+    boolean this_present_port = true;
+    boolean that_present_port = true;
+    if (this_present_port || that_present_port) {
+      if (!(this_present_port && that_present_port))
+        return false;
+      if (this.port != that.port)
+        return false;
+    }
+
+    boolean this_present_datacenter = true && this.isSetDatacenter();
+    boolean that_present_datacenter = true && that.isSetDatacenter();
+    if (this_present_datacenter || that_present_datacenter) {
+      if (!(this_present_datacenter && that_present_datacenter))
+        return false;
+      if (!this.datacenter.equals(that.datacenter))
+        return false;
+    }
+
+    return true;
+  }
+
+  @Override
+  public int hashCode() {
+    HashCodeBuilder builder = new HashCodeBuilder();
+
+    boolean present_host = true && (isSetHost());
+    builder.append(present_host);
+    if (present_host)
+      builder.append(host);
+
+    boolean present_port = true;
+    builder.append(present_port);
+    if (present_port)
+      builder.append(port);
+
+    boolean present_datacenter = true && (isSetDatacenter());
+    builder.append(present_datacenter);
+    if (present_datacenter)
+      builder.append(datacenter);
+
+    return builder.toHashCode();
+  }
+
+  public int compareTo(EndpointDetails other) {
+    if (!getClass().equals(other.getClass())) {
+      return getClass().getName().compareTo(other.getClass().getName());
+    }
+
+    int lastComparison = 0;
+    EndpointDetails typedOther = (EndpointDetails)other;
+
+    lastComparison = Boolean.valueOf(isSetHost()).compareTo(typedOther.isSetHost());
+    if (lastComparison != 0) {
+      return lastComparison;
+    }
+    if (isSetHost()) {
+      lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.host, typedOther.host);
+      if (lastComparison != 0) {
+        return lastComparison;
+      }
+    }
+    lastComparison = Boolean.valueOf(isSetPort()).compareTo(typedOther.isSetPort());
+    if (lastComparison != 0) {
+      return lastComparison;
+    }
+    if (isSetPort()) {
+      lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.port, typedOther.port);
+      if (lastComparison != 0) {
+        return lastComparison;
+      }
+    }
+    lastComparison = Boolean.valueOf(isSetDatacenter()).compareTo(typedOther.isSetDatacenter());
+    if (lastComparison != 0) {
+      return lastComparison;
+    }
+    if (isSetDatacenter()) {
+      lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.datacenter, typedOther.datacenter);
+      if (lastComparison != 0) {
+        return lastComparison;
+      }
+    }
+    return 0;
+  }
+
+  public _Fields fieldForId(int fieldId) {
+    return _Fields.findByThriftId(fieldId);
+  }
+
+  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();
+            setPortIsSet(true);
+          } else { 
+            org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
+          }
+          break;
+        case 3: // DATACENTER
+          if (field.type == org.apache.thrift.protocol.TType.STRING) {
+            this.datacenter = 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();
+  }
+
+  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();
+    if (this.datacenter != null) {
+      oprot.writeFieldBegin(DATACENTER_FIELD_DESC);
+      oprot.writeString(this.datacenter);
+      oprot.writeFieldEnd();
+    }
+    oprot.writeFieldStop();
+    oprot.writeStructEnd();
+  }
+
+  @Override
+  public String toString() {
+    StringBuilder sb = new StringBuilder("EndpointDetails(");
+    boolean first = true;
+
+    sb.append("host:");
+    if (this.host == null) {
+      sb.append("null");
+    } else {
+      sb.append(this.host);
+    }
+    first = false;
+    if (!first) sb.append(", ");
+    sb.append("port:");
+    sb.append(this.port);
+    first = false;
+    if (!first) sb.append(", ");
+    sb.append("datacenter:");
+    if (this.datacenter == null) {
+      sb.append("null");
+    } else {
+      sb.append(this.datacenter);
+    }
+    first = false;
+    sb.append(")");
+    return sb.toString();
+  }
+
+  public void validate() throws org.apache.thrift.TException {
+    // check for required fields
+  }
+
+  private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
+    try {
+      write(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(out)));
+    } catch (org.apache.thrift.TException te) {
+      throw new java.io.IOException(te);
+    }
+  }
+
+  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);
+      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);
+    }
+  }
+
+}
+

Modified: cassandra/trunk/interface/thrift/gen-java/org/apache/cassandra/thrift/KsDef.java
URL: http://svn.apache.org/viewvc/cassandra/trunk/interface/thrift/gen-java/org/apache/cassandra/thrift/KsDef.java?rev=1169870&r1=1169869&r2=1169870&view=diff
==============================================================================
--- cassandra/trunk/interface/thrift/gen-java/org/apache/cassandra/thrift/KsDef.java (original)
+++ cassandra/trunk/interface/thrift/gen-java/org/apache/cassandra/thrift/KsDef.java Mon Sep 12 19:04:14 2011
@@ -718,15 +718,15 @@ public class KsDef implements org.apache
         case 3: // STRATEGY_OPTIONS
           if (field.type == org.apache.thrift.protocol.TType.MAP) {
             {
-              org.apache.thrift.protocol.TMap _map48 = iprot.readMapBegin();
-              this.strategy_options = new HashMap<String,String>(2*_map48.size);
-              for (int _i49 = 0; _i49 < _map48.size; ++_i49)
+              org.apache.thrift.protocol.TMap _map52 = iprot.readMapBegin();
+              this.strategy_options = new HashMap<String,String>(2*_map52.size);
+              for (int _i53 = 0; _i53 < _map52.size; ++_i53)
               {
-                String _key50;
-                String _val51;
-                _key50 = iprot.readString();
-                _val51 = iprot.readString();
-                this.strategy_options.put(_key50, _val51);
+                String _key54;
+                String _val55;
+                _key54 = iprot.readString();
+                _val55 = iprot.readString();
+                this.strategy_options.put(_key54, _val55);
               }
               iprot.readMapEnd();
             }
@@ -745,14 +745,14 @@ public class KsDef implements org.apache
         case 5: // CF_DEFS
           if (field.type == org.apache.thrift.protocol.TType.LIST) {
             {
-              org.apache.thrift.protocol.TList _list52 = iprot.readListBegin();
-              this.cf_defs = new ArrayList<CfDef>(_list52.size);
-              for (int _i53 = 0; _i53 < _list52.size; ++_i53)
+              org.apache.thrift.protocol.TList _list56 = iprot.readListBegin();
+              this.cf_defs = new ArrayList<CfDef>(_list56.size);
+              for (int _i57 = 0; _i57 < _list56.size; ++_i57)
               {
-                CfDef _elem54;
-                _elem54 = new CfDef();
-                _elem54.read(iprot);
-                this.cf_defs.add(_elem54);
+                CfDef _elem58;
+                _elem58 = new CfDef();
+                _elem58.read(iprot);
+                this.cf_defs.add(_elem58);
               }
               iprot.readListEnd();
             }
@@ -798,10 +798,10 @@ public class KsDef implements org.apache
         oprot.writeFieldBegin(STRATEGY_OPTIONS_FIELD_DESC);
         {
           oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, this.strategy_options.size()));
-          for (Map.Entry<String, String> _iter55 : this.strategy_options.entrySet())
+          for (Map.Entry<String, String> _iter59 : this.strategy_options.entrySet())
           {
-            oprot.writeString(_iter55.getKey());
-            oprot.writeString(_iter55.getValue());
+            oprot.writeString(_iter59.getKey());
+            oprot.writeString(_iter59.getValue());
           }
           oprot.writeMapEnd();
         }
@@ -817,9 +817,9 @@ public class KsDef implements org.apache
       oprot.writeFieldBegin(CF_DEFS_FIELD_DESC);
       {
         oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, this.cf_defs.size()));
-        for (CfDef _iter56 : this.cf_defs)
+        for (CfDef _iter60 : this.cf_defs)
         {
-          _iter56.write(oprot);
+          _iter60.write(oprot);
         }
         oprot.writeListEnd();
       }

Modified: cassandra/trunk/interface/thrift/gen-java/org/apache/cassandra/thrift/TokenRange.java
URL: http://svn.apache.org/viewvc/cassandra/trunk/interface/thrift/gen-java/org/apache/cassandra/thrift/TokenRange.java?rev=1169870&r1=1169869&r2=1169870&view=diff
==============================================================================
--- cassandra/trunk/interface/thrift/gen-java/org/apache/cassandra/thrift/TokenRange.java (original)
+++ cassandra/trunk/interface/thrift/gen-java/org/apache/cassandra/thrift/TokenRange.java Mon Sep 12 19:04:14 2011
@@ -48,16 +48,19 @@ public class TokenRange implements org.a
   private static final org.apache.thrift.protocol.TField START_TOKEN_FIELD_DESC = new org.apache.thrift.protocol.TField("start_token", org.apache.thrift.protocol.TType.STRING, (short)1);
   private static final org.apache.thrift.protocol.TField END_TOKEN_FIELD_DESC = new org.apache.thrift.protocol.TField("end_token", org.apache.thrift.protocol.TType.STRING, (short)2);
   private static final org.apache.thrift.protocol.TField ENDPOINTS_FIELD_DESC = new org.apache.thrift.protocol.TField("endpoints", org.apache.thrift.protocol.TType.LIST, (short)3);
+  private static final org.apache.thrift.protocol.TField ENDPOINT_DETAILS_FIELD_DESC = new org.apache.thrift.protocol.TField("endpoint_details", org.apache.thrift.protocol.TType.LIST, (short)4);
 
   public String start_token;
   public String end_token;
   public List<String> endpoints;
+  public List<EndpointDetails> endpoint_details;
 
   /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */
   public enum _Fields implements org.apache.thrift.TFieldIdEnum {
     START_TOKEN((short)1, "start_token"),
     END_TOKEN((short)2, "end_token"),
-    ENDPOINTS((short)3, "endpoints");
+    ENDPOINTS((short)3, "endpoints"),
+    ENDPOINT_DETAILS((short)4, "endpoint_details");
 
     private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
 
@@ -78,6 +81,8 @@ public class TokenRange implements org.a
           return END_TOKEN;
         case 3: // ENDPOINTS
           return ENDPOINTS;
+        case 4: // ENDPOINT_DETAILS
+          return ENDPOINT_DETAILS;
         default:
           return null;
       }
@@ -129,6 +134,9 @@ public class TokenRange implements org.a
     tmpMap.put(_Fields.ENDPOINTS, new org.apache.thrift.meta_data.FieldMetaData("endpoints", org.apache.thrift.TFieldRequirementType.REQUIRED, 
         new org.apache.thrift.meta_data.ListMetaData(org.apache.thrift.protocol.TType.LIST, 
             new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))));
+    tmpMap.put(_Fields.ENDPOINT_DETAILS, new org.apache.thrift.meta_data.FieldMetaData("endpoint_details", org.apache.thrift.TFieldRequirementType.OPTIONAL, 
+        new org.apache.thrift.meta_data.ListMetaData(org.apache.thrift.protocol.TType.LIST, 
+            new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, EndpointDetails.class))));
     metaDataMap = Collections.unmodifiableMap(tmpMap);
     org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(TokenRange.class, metaDataMap);
   }
@@ -164,6 +172,13 @@ public class TokenRange implements org.a
       }
       this.endpoints = __this__endpoints;
     }
+    if (other.isSetEndpoint_details()) {
+      List<EndpointDetails> __this__endpoint_details = new ArrayList<EndpointDetails>();
+      for (EndpointDetails other_element : other.endpoint_details) {
+        __this__endpoint_details.add(new EndpointDetails(other_element));
+      }
+      this.endpoint_details = __this__endpoint_details;
+    }
   }
 
   public TokenRange deepCopy() {
@@ -175,6 +190,7 @@ public class TokenRange implements org.a
     this.start_token = null;
     this.end_token = null;
     this.endpoints = null;
+    this.endpoint_details = null;
   }
 
   public String getStart_token() {
@@ -264,6 +280,45 @@ public class TokenRange implements org.a
     }
   }
 
+  public int getEndpoint_detailsSize() {
+    return (this.endpoint_details == null) ? 0 : this.endpoint_details.size();
+  }
+
+  public java.util.Iterator<EndpointDetails> getEndpoint_detailsIterator() {
+    return (this.endpoint_details == null) ? null : this.endpoint_details.iterator();
+  }
+
+  public void addToEndpoint_details(EndpointDetails elem) {
+    if (this.endpoint_details == null) {
+      this.endpoint_details = new ArrayList<EndpointDetails>();
+    }
+    this.endpoint_details.add(elem);
+  }
+
+  public List<EndpointDetails> getEndpoint_details() {
+    return this.endpoint_details;
+  }
+
+  public TokenRange setEndpoint_details(List<EndpointDetails> endpoint_details) {
+    this.endpoint_details = endpoint_details;
+    return this;
+  }
+
+  public void unsetEndpoint_details() {
+    this.endpoint_details = null;
+  }
+
+  /** Returns true if field endpoint_details is set (has been assigned a value) and false otherwise */
+  public boolean isSetEndpoint_details() {
+    return this.endpoint_details != null;
+  }
+
+  public void setEndpoint_detailsIsSet(boolean value) {
+    if (!value) {
+      this.endpoint_details = null;
+    }
+  }
+
   public void setFieldValue(_Fields field, Object value) {
     switch (field) {
     case START_TOKEN:
@@ -290,6 +345,14 @@ public class TokenRange implements org.a
       }
       break;
 
+    case ENDPOINT_DETAILS:
+      if (value == null) {
+        unsetEndpoint_details();
+      } else {
+        setEndpoint_details((List<EndpointDetails>)value);
+      }
+      break;
+
     }
   }
 
@@ -304,6 +367,9 @@ public class TokenRange implements org.a
     case ENDPOINTS:
       return getEndpoints();
 
+    case ENDPOINT_DETAILS:
+      return getEndpoint_details();
+
     }
     throw new IllegalStateException();
   }
@@ -321,6 +387,8 @@ public class TokenRange implements org.a
       return isSetEnd_token();
     case ENDPOINTS:
       return isSetEndpoints();
+    case ENDPOINT_DETAILS:
+      return isSetEndpoint_details();
     }
     throw new IllegalStateException();
   }
@@ -365,6 +433,15 @@ public class TokenRange implements org.a
         return false;
     }
 
+    boolean this_present_endpoint_details = true && this.isSetEndpoint_details();
+    boolean that_present_endpoint_details = true && that.isSetEndpoint_details();
+    if (this_present_endpoint_details || that_present_endpoint_details) {
+      if (!(this_present_endpoint_details && that_present_endpoint_details))
+        return false;
+      if (!this.endpoint_details.equals(that.endpoint_details))
+        return false;
+    }
+
     return true;
   }
 
@@ -387,6 +464,11 @@ public class TokenRange implements org.a
     if (present_endpoints)
       builder.append(endpoints);
 
+    boolean present_endpoint_details = true && (isSetEndpoint_details());
+    builder.append(present_endpoint_details);
+    if (present_endpoint_details)
+      builder.append(endpoint_details);
+
     return builder.toHashCode();
   }
 
@@ -428,6 +510,16 @@ public class TokenRange implements org.a
         return lastComparison;
       }
     }
+    lastComparison = Boolean.valueOf(isSetEndpoint_details()).compareTo(typedOther.isSetEndpoint_details());
+    if (lastComparison != 0) {
+      return lastComparison;
+    }
+    if (isSetEndpoint_details()) {
+      lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.endpoint_details, typedOther.endpoint_details);
+      if (lastComparison != 0) {
+        return lastComparison;
+      }
+    }
     return 0;
   }
 
@@ -476,6 +568,24 @@ public class TokenRange implements org.a
             org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
           }
           break;
+        case 4: // ENDPOINT_DETAILS
+          if (field.type == org.apache.thrift.protocol.TType.LIST) {
+            {
+              org.apache.thrift.protocol.TList _list23 = iprot.readListBegin();
+              this.endpoint_details = new ArrayList<EndpointDetails>(_list23.size);
+              for (int _i24 = 0; _i24 < _list23.size; ++_i24)
+              {
+                EndpointDetails _elem25;
+                _elem25 = new EndpointDetails();
+                _elem25.read(iprot);
+                this.endpoint_details.add(_elem25);
+              }
+              iprot.readListEnd();
+            }
+          } else { 
+            org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
+          }
+          break;
         default:
           org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
       }
@@ -505,14 +615,28 @@ public class TokenRange implements org.a
       oprot.writeFieldBegin(ENDPOINTS_FIELD_DESC);
       {
         oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, this.endpoints.size()));
-        for (String _iter23 : this.endpoints)
+        for (String _iter26 : this.endpoints)
         {
-          oprot.writeString(_iter23);
+          oprot.writeString(_iter26);
         }
         oprot.writeListEnd();
       }
       oprot.writeFieldEnd();
     }
+    if (this.endpoint_details != null) {
+      if (isSetEndpoint_details()) {
+        oprot.writeFieldBegin(ENDPOINT_DETAILS_FIELD_DESC);
+        {
+          oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, this.endpoint_details.size()));
+          for (EndpointDetails _iter27 : this.endpoint_details)
+          {
+            _iter27.write(oprot);
+          }
+          oprot.writeListEnd();
+        }
+        oprot.writeFieldEnd();
+      }
+    }
     oprot.writeFieldStop();
     oprot.writeStructEnd();
   }
@@ -545,6 +669,16 @@ public class TokenRange implements org.a
       sb.append(this.endpoints);
     }
     first = false;
+    if (isSetEndpoint_details()) {
+      if (!first) sb.append(", ");
+      sb.append("endpoint_details:");
+      if (this.endpoint_details == null) {
+        sb.append("null");
+      } else {
+        sb.append(this.endpoint_details);
+      }
+      first = false;
+    }
     sb.append(")");
     return sb.toString();
   }

Modified: cassandra/trunk/src/java/org/apache/cassandra/thrift/CassandraServer.java
URL: http://svn.apache.org/viewvc/cassandra/trunk/src/java/org/apache/cassandra/thrift/CassandraServer.java?rev=1169870&r1=1169869&r2=1169870&view=diff
==============================================================================
--- cassandra/trunk/src/java/org/apache/cassandra/thrift/CassandraServer.java (original)
+++ cassandra/trunk/src/java/org/apache/cassandra/thrift/CassandraServer.java Mon Sep 12 19:04:14 2011
@@ -20,6 +20,7 @@ package org.apache.cassandra.thrift;
 
 import java.io.IOException;
 import java.io.UnsupportedEncodingException;
+import java.net.InetAddress;
 import java.net.SocketAddress;
 import java.nio.ByteBuffer;
 import java.nio.charset.CharacterCodingException;
@@ -48,6 +49,10 @@ import org.apache.cassandra.db.marshal.M
 import org.apache.cassandra.db.migration.*;
 import org.apache.cassandra.db.context.CounterContext;
 import org.apache.cassandra.dht.*;
+import org.apache.cassandra.gms.ApplicationState;
+import org.apache.cassandra.gms.EndpointState;
+import org.apache.cassandra.gms.Gossiper;
+import org.apache.cassandra.gms.VersionedValue;
 import org.apache.cassandra.io.util.FastByteArrayOutputStream;
 import org.apache.cassandra.locator.*;
 import org.apache.cassandra.scheduler.IRequestScheduler;
@@ -56,6 +61,7 @@ import org.apache.cassandra.service.Sock
 import org.apache.cassandra.service.StorageProxy;
 import org.apache.cassandra.service.StorageService;
 import org.apache.cassandra.utils.ByteBufferUtil;
+import org.apache.cassandra.utils.FBUtilities;
 import org.apache.thrift.TException;
 
 public class CassandraServer implements Cassandra.Iface
@@ -784,14 +790,48 @@ public class CassandraServer implements 
     {
         if (keyspace == null || !Schema.instance.getNonSystemTables().contains(keyspace))
             throw new InvalidRequestException("There is no ring for the keyspace: " + keyspace);
+
         List<TokenRange> ranges = new ArrayList<TokenRange>();
         Token.TokenFactory tf = StorageService.getPartitioner().getTokenFactory();
-        for (Map.Entry<Range, List<String>> entry : StorageService.instance.getRangeToRpcaddressMap(keyspace).entrySet())
+
+        for (Map.Entry<Range, List<InetAddress>> entry : StorageService.instance.getRangeToAddressMap(keyspace).entrySet())
         {
             Range range = entry.getKey();
-            List<String> endpoints = entry.getValue();
-            ranges.add(new TokenRange(tf.toString(range.left), tf.toString(range.right), endpoints));
+            List<String> endpoints = new ArrayList<String>();
+            List<EndpointDetails> epDetails = new ArrayList<EndpointDetails>();
+
+            for (InetAddress endpoint : entry.getValue())
+            {
+                EndpointState eps = Gossiper.instance.getEndpointStateForEndpoint(endpoint);
+                EndpointDetails details = new EndpointDetails();
+                // default to an unknown port since we
+                // don't seem to maintain that knowledge about remote endpoints.
+                details.port = -1;
+
+                if (endpoint.equals(FBUtilities.getBroadcastAddress()))
+                {
+                    details.host = DatabaseDescriptor.getRpcAddress().getHostAddress();
+                    details.port = DatabaseDescriptor.getRpcPort();
+                }
+                else if (eps.getApplicationState(ApplicationState.RPC_ADDRESS) == null)
+                    details.host = endpoint.getHostAddress();
+                else
+                    details.host = eps.getApplicationState(ApplicationState.RPC_ADDRESS).value;
+
+                VersionedValue appStateDc = eps.getApplicationState(ApplicationState.DC);
+                if (appStateDc != null)
+                    details.datacenter = appStateDc.value;
+
+                endpoints.add(details.host);
+
+                if (details.port != -1 || details.datacenter != null)
+                    epDetails.add(details);
+            }
+
+            ranges.add(new TokenRange(tf.toString(range.left), tf.toString(range.right), endpoints)
+                                      .setEndpoint_details(epDetails));
         }
+
         return ranges;
     }
 



Mime
View raw message