http://git-wip-us.apache.org/repos/asf/hive/blob/42216997/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py ---------------------------------------------------------------------- diff --git a/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py b/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py index 4cc54e8..e299906 100644 --- a/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py +++ b/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py @@ -1,5 +1,5 @@ # -# Autogenerated by Thrift Compiler (0.9.0) +# Autogenerated by Thrift Compiler (0.9.2) # # DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING # @@ -67,7 +67,7 @@ class Iface(fb303.FacebookService.Iface): """ pass - def get_all_databases(self, ): + def get_all_databases(self): pass def alter_database(self, dbname, db): @@ -789,7 +789,7 @@ class Iface(fb303.FacebookService.Iface): """ pass - def get_role_names(self, ): + def get_role_names(self): pass def grant_role(self, role_name, principal_name, principal_type, grantor, grantorType, grant_option): @@ -911,10 +911,10 @@ class Iface(fb303.FacebookService.Iface): """ pass - def get_open_txns(self, ): + def get_open_txns(self): pass - def get_open_txns_info(self, ): + def get_open_txns_info(self): pass def open_txns(self, rqst): @@ -1008,7 +1008,7 @@ class Iface(fb303.FacebookService.Iface): """ pass - def get_current_notificationEventId(self, ): + def get_current_notificationEventId(self): pass def fire_listener_event(self, rqst): @@ -1042,16 +1042,17 @@ class Client(fb303.FacebookService.Client, Iface): self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_getMetaConf(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + def recv_getMetaConf(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = getMetaConf_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.o1 is not None: @@ -1076,16 +1077,17 @@ class Client(fb303.FacebookService.Client, Iface): self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_setMetaConf(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + def recv_setMetaConf(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = setMetaConf_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.o1 is not None: raise result.o1 return @@ -1106,16 +1108,17 @@ class Client(fb303.FacebookService.Client, Iface): self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_create_database(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + def recv_create_database(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = create_database_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.o1 is not None: raise result.o1 if result.o2 is not None: @@ -1140,16 +1143,17 @@ class Client(fb303.FacebookService.Client, Iface): self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_get_database(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + def recv_get_database(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = get_database_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.o1 is not None: @@ -1178,16 +1182,17 @@ class Client(fb303.FacebookService.Client, Iface): self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_drop_database(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + def recv_drop_database(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = drop_database_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.o1 is not None: raise result.o1 if result.o2 is not None: @@ -1212,43 +1217,45 @@ class Client(fb303.FacebookService.Client, Iface): self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_get_databases(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + def recv_get_databases(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = get_databases_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.o1 is not None: raise result.o1 raise TApplicationException(TApplicationException.MISSING_RESULT, "get_databases failed: unknown result"); - def get_all_databases(self, ): + def get_all_databases(self): self.send_get_all_databases() return self.recv_get_all_databases() - def send_get_all_databases(self, ): + def send_get_all_databases(self): self._oprot.writeMessageBegin('get_all_databases', TMessageType.CALL, self._seqid) args = get_all_databases_args() args.write(self._oprot) self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_get_all_databases(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + def recv_get_all_databases(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = get_all_databases_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.o1 is not None: @@ -1273,16 +1280,17 @@ class Client(fb303.FacebookService.Client, Iface): self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_alter_database(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + def recv_alter_database(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = alter_database_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.o1 is not None: raise result.o1 if result.o2 is not None: @@ -1305,16 +1313,17 @@ class Client(fb303.FacebookService.Client, Iface): self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_get_type(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + def recv_get_type(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = get_type_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.o1 is not None: @@ -1339,16 +1348,17 @@ class Client(fb303.FacebookService.Client, Iface): self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_create_type(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + def recv_create_type(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = create_type_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.o1 is not None: @@ -1375,16 +1385,17 @@ class Client(fb303.FacebookService.Client, Iface): self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_drop_type(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + def recv_drop_type(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = drop_type_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.o1 is not None: @@ -1409,16 +1420,17 @@ class Client(fb303.FacebookService.Client, Iface): self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_get_type_all(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + def recv_get_type_all(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = get_type_all_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.o2 is not None: @@ -1443,16 +1455,17 @@ class Client(fb303.FacebookService.Client, Iface): self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_get_fields(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + def recv_get_fields(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = get_fields_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.o1 is not None: @@ -1483,16 +1496,17 @@ class Client(fb303.FacebookService.Client, Iface): self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_get_fields_with_environment_context(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + def recv_get_fields_with_environment_context(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = get_fields_with_environment_context_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.o1 is not None: @@ -1521,16 +1535,17 @@ class Client(fb303.FacebookService.Client, Iface): self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_get_schema(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + def recv_get_schema(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = get_schema_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.o1 is not None: @@ -1561,16 +1576,17 @@ class Client(fb303.FacebookService.Client, Iface): self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_get_schema_with_environment_context(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + def recv_get_schema_with_environment_context(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = get_schema_with_environment_context_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.o1 is not None: @@ -1597,16 +1613,17 @@ class Client(fb303.FacebookService.Client, Iface): self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_create_table(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + def recv_create_table(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = create_table_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.o1 is not None: raise result.o1 if result.o2 is not None: @@ -1635,16 +1652,17 @@ class Client(fb303.FacebookService.Client, Iface): self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_create_table_with_environment_context(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + def recv_create_table_with_environment_context(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = create_table_with_environment_context_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.o1 is not None: raise result.o1 if result.o2 is not None: @@ -1675,16 +1693,17 @@ class Client(fb303.FacebookService.Client, Iface): self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_drop_table(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + def recv_drop_table(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = drop_table_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.o1 is not None: raise result.o1 if result.o3 is not None: @@ -1713,16 +1732,17 @@ class Client(fb303.FacebookService.Client, Iface): self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_drop_table_with_environment_context(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + def recv_drop_table_with_environment_context(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = drop_table_with_environment_context_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.o1 is not None: raise result.o1 if result.o3 is not None: @@ -1747,16 +1767,17 @@ class Client(fb303.FacebookService.Client, Iface): self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_get_tables(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + def recv_get_tables(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = get_tables_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.o1 is not None: @@ -1779,16 +1800,17 @@ class Client(fb303.FacebookService.Client, Iface): self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_get_all_tables(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + def recv_get_all_tables(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = get_all_tables_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.o1 is not None: @@ -1813,16 +1835,17 @@ class Client(fb303.FacebookService.Client, Iface): self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_get_table(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + def recv_get_table(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = get_table_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.o1 is not None: @@ -1849,16 +1872,17 @@ class Client(fb303.FacebookService.Client, Iface): self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_get_table_objects_by_name(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + def recv_get_table_objects_by_name(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = get_table_objects_by_name_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.o1 is not None: @@ -1889,16 +1913,17 @@ class Client(fb303.FacebookService.Client, Iface): self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_get_table_names_by_filter(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + def recv_get_table_names_by_filter(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = get_table_names_by_filter_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.o1 is not None: @@ -1929,16 +1954,17 @@ class Client(fb303.FacebookService.Client, Iface): self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_alter_table(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + def recv_alter_table(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = alter_table_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.o1 is not None: raise result.o1 if result.o2 is not None: @@ -1967,16 +1993,17 @@ class Client(fb303.FacebookService.Client, Iface): self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_alter_table_with_environment_context(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + def recv_alter_table_with_environment_context(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = alter_table_with_environment_context_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.o1 is not None: raise result.o1 if result.o2 is not None: @@ -2005,16 +2032,17 @@ class Client(fb303.FacebookService.Client, Iface): self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_alter_table_with_cascade(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + def recv_alter_table_with_cascade(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = alter_table_with_cascade_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.o1 is not None: raise result.o1 if result.o2 is not None: @@ -2037,16 +2065,17 @@ class Client(fb303.FacebookService.Client, Iface): self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_add_partition(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + def recv_add_partition(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = add_partition_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.o1 is not None: @@ -2075,16 +2104,17 @@ class Client(fb303.FacebookService.Client, Iface): self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_add_partition_with_environment_context(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + def recv_add_partition_with_environment_context(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = add_partition_with_environment_context_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.o1 is not None: @@ -2111,16 +2141,17 @@ class Client(fb303.FacebookService.Client, Iface): self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_add_partitions(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + def recv_add_partitions(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = add_partitions_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.o1 is not None: @@ -2147,16 +2178,17 @@ class Client(fb303.FacebookService.Client, Iface): self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_add_partitions_pspec(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + def recv_add_partitions_pspec(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = add_partitions_pspec_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.o1 is not None: @@ -2187,16 +2219,17 @@ class Client(fb303.FacebookService.Client, Iface): self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_append_partition(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + def recv_append_partition(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = append_partition_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.o1 is not None: @@ -2223,16 +2256,17 @@ class Client(fb303.FacebookService.Client, Iface): self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_add_partitions_req(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + def recv_add_partitions_req(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = add_partitions_req_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.o1 is not None: @@ -2265,16 +2299,17 @@ class Client(fb303.FacebookService.Client, Iface): self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_append_partition_with_environment_context(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + def recv_append_partition_with_environment_context(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = append_partition_with_environment_context_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.o1 is not None: @@ -2305,16 +2340,17 @@ class Client(fb303.FacebookService.Client, Iface): self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_append_partition_by_name(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + def recv_append_partition_by_name(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = append_partition_by_name_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.o1 is not None: @@ -2347,16 +2383,17 @@ class Client(fb303.FacebookService.Client, Iface): self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_append_partition_by_name_with_environment_context(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + def recv_append_partition_by_name_with_environment_context(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = append_partition_by_name_with_environment_context_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.o1 is not None: @@ -2389,16 +2426,17 @@ class Client(fb303.FacebookService.Client, Iface): self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_drop_partition(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + def recv_drop_partition(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = drop_partition_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.o1 is not None: @@ -2431,16 +2469,17 @@ class Client(fb303.FacebookService.Client, Iface): self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_drop_partition_with_environment_context(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + def recv_drop_partition_with_environment_context(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = drop_partition_with_environment_context_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.o1 is not None: @@ -2471,16 +2510,17 @@ class Client(fb303.FacebookService.Client, Iface): self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_drop_partition_by_name(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + def recv_drop_partition_by_name(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = drop_partition_by_name_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.o1 is not None: @@ -2513,16 +2553,17 @@ class Client(fb303.FacebookService.Client, Iface): self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_drop_partition_by_name_with_environment_context(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + def recv_drop_partition_by_name_with_environment_context(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = drop_partition_by_name_with_environment_context_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.o1 is not None: @@ -2547,16 +2588,17 @@ class Client(fb303.FacebookService.Client, Iface): self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_drop_partitions_req(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + def recv_drop_partitions_req(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = drop_partitions_req_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.o1 is not None: @@ -2585,16 +2627,17 @@ class Client(fb303.FacebookService.Client, Iface): self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_get_partition(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + def recv_get_partition(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = get_partition_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.o1 is not None: @@ -2627,16 +2670,17 @@ class Client(fb303.FacebookService.Client, Iface): self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_exchange_partition(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + def recv_exchange_partition(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = exchange_partition_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.o1 is not None: @@ -2673,16 +2717,17 @@ class Client(fb303.FacebookService.Client, Iface): self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_get_partition_with_auth(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + def recv_get_partition_with_auth(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = get_partition_with_auth_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.o1 is not None: @@ -2711,16 +2756,17 @@ class Client(fb303.FacebookService.Client, Iface): self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_get_partition_by_name(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + def recv_get_partition_by_name(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = get_partition_by_name_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.o1 is not None: @@ -2749,16 +2795,17 @@ class Client(fb303.FacebookService.Client, Iface): self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_get_partitions(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + def recv_get_partitions(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = get_partitions_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.o1 is not None: @@ -2791,16 +2838,17 @@ class Client(fb303.FacebookService.Client, Iface): self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_get_partitions_with_auth(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + def recv_get_partitions_with_auth(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = get_partitions_with_auth_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.o1 is not None: @@ -2829,16 +2877,17 @@ class Client(fb303.FacebookService.Client, Iface): self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_get_partitions_pspec(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + def recv_get_partitions_pspec(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = get_partitions_pspec_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.o1 is not None: @@ -2867,16 +2916,17 @@ class Client(fb303.FacebookService.Client, Iface): self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_get_partition_names(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + def recv_get_partition_names(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = get_partition_names_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.o2 is not None: @@ -2905,16 +2955,17 @@ class Client(fb303.FacebookService.Client, Iface): self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_get_partitions_ps(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + def recv_get_partitions_ps(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = get_partitions_ps_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.o1 is not None: @@ -2949,16 +3000,17 @@ class Client(fb303.FacebookService.Client, Iface): self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_get_partitions_ps_with_auth(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + def recv_get_partitions_ps_with_auth(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = get_partitions_ps_with_auth_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.o1 is not None: @@ -2989,16 +3041,17 @@ class Client(fb303.FacebookService.Client, Iface): self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_get_partition_names_ps(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + def recv_get_partition_names_ps(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = get_partition_names_ps_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.o1 is not None: @@ -3029,16 +3082,17 @@ class Client(fb303.FacebookService.Client, Iface): self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_get_partitions_by_filter(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + def recv_get_partitions_by_filter(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = get_partitions_by_filter_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.o1 is not None: @@ -3069,16 +3123,17 @@ class Client(fb303.FacebookService.Client, Iface): self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_get_part_specs_by_filter(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + def recv_get_part_specs_by_filter(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = get_part_specs_by_filter_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.o1 is not None: @@ -3103,16 +3158,17 @@ class Client(fb303.FacebookService.Client, Iface): self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_get_partitions_by_expr(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + def recv_get_partitions_by_expr(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = get_partitions_by_expr_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.o1 is not None: @@ -3141,16 +3197,17 @@ class Client(fb303.FacebookService.Client, Iface): self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_get_partitions_by_names(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + def recv_get_partitions_by_names(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = get_partitions_by_names_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.o1 is not None: @@ -3179,16 +3236,17 @@ class Client(fb303.FacebookService.Client, Iface): self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_alter_partition(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + def recv_alter_partition(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = alter_partition_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.o1 is not None: raise result.o1 if result.o2 is not None: @@ -3215,16 +3273,17 @@ class Client(fb303.FacebookService.Client, Iface): self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_alter_partitions(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + def recv_alter_partitions(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = alter_partitions_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.o1 is not None: raise result.o1 if result.o2 is not None: @@ -3253,16 +3312,17 @@ class Client(fb303.FacebookService.Client, Iface): self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_alter_partition_with_environment_context(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + def recv_alter_partition_with_environment_context(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = alter_partition_with_environment_context_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.o1 is not None: raise result.o1 if result.o2 is not None: @@ -3291,16 +3351,17 @@ class Client(fb303.FacebookService.Client, Iface): self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_rename_partition(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + def recv_rename_partition(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = rename_partition_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.o1 is not None: raise result.o1 if result.o2 is not None: @@ -3325,16 +3386,17 @@ class Client(fb303.FacebookService.Client, Iface): self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_partition_name_has_valid_characters(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + def recv_partition_name_has_valid_characters(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = partition_name_has_valid_characters_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.o1 is not None: @@ -3359,16 +3421,17 @@ class Client(fb303.FacebookService.Client, Iface): self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_get_config_value(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + def recv_get_config_value(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = get_config_value_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.o1 is not None: @@ -3391,16 +3454,17 @@ class Client(fb303.FacebookService.Client, Iface): self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_partition_name_to_vals(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + def recv_partition_name_to_vals(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = partition_name_to_vals_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.o1 is not None: @@ -3423,16 +3487,17 @@ class Client(fb303.FacebookService.Client, Iface): self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_partition_name_to_spec(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + def recv_partition_name_to_spec(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = partition_name_to_spec_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.o1 is not None: @@ -3461,16 +3526,17 @@ class Client(fb303.FacebookService.Client, Iface): self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_markPartitionForEvent(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + def recv_markPartitionForEvent(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = markPartitionForEvent_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.o1 is not None: raise result.o1 if result.o2 is not None: @@ -3507,16 +3573,17 @@ class Client(fb303.FacebookService.Client, Iface): self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_isPartitionMarkedForEvent(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + def recv_isPartitionMarkedForEvent(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = isPartitionMarkedForEvent_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.o1 is not None: @@ -3551,16 +3618,17 @@ class Client(fb303.FacebookService.Client, Iface): self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_add_index(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + def recv_add_index(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = add_index_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.o1 is not None: @@ -3593,16 +3661,17 @@ class Client(fb303.FacebookService.Client, Iface): self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_alter_index(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + def recv_alter_index(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = alter_index_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.o1 is not None: raise result.o1 if result.o2 is not None: @@ -3631,16 +3700,17 @@ class Client(fb303.FacebookService.Client, Iface): self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_drop_index_by_name(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + def recv_drop_index_by_name(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = drop_index_by_name_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.o1 is not None: @@ -3669,16 +3739,17 @@ class Client(fb303.FacebookService.Client, Iface): self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_get_index_by_name(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + def recv_get_index_by_name(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = get_index_by_name_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.o1 is not None: @@ -3707,16 +3778,17 @@ class Client(fb303.FacebookService.Client, Iface): self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_get_indexes(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + def recv_get_indexes(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = get_indexes_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.o1 is not None: @@ -3745,16 +3817,17 @@ class Client(fb303.FacebookService.Client, Iface): self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_get_index_names(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + def recv_get_index_names(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = get_index_names_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.o2 is not None: @@ -3777,16 +3850,17 @@ class Client(fb303.FacebookService.Client, Iface): self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_update_table_column_statistics(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + def recv_update_table_column_statistics(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = update_table_column_statistics_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.o1 is not None: @@ -3815,16 +3889,17 @@ class Client(fb303.FacebookService.Client, Iface): self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_update_partition_column_statistics(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + def recv_update_partition_column_statistics(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = update_partition_column_statistics_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.o1 is not None: @@ -3857,16 +3932,17 @@ class Client(fb303.FacebookService.Client, Iface): self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_get_table_column_statistics(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + def recv_get_table_column_statistics(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = get_table_column_statistics_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.o1 is not None: @@ -3901,16 +3977,17 @@ class Client(fb303.FacebookService.Client, Iface): self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_get_partition_column_statistics(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + def recv_get_partition_column_statistics(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = get_partition_column_statistics_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.o1 is not None: @@ -3939,16 +4016,17 @@ class Client(fb303.FacebookService.Client, Iface): self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_get_table_statistics_req(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + def recv_get_table_statistics_req(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = get_table_statistics_req_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.o1 is not None: @@ -3973,16 +4051,17 @@ class Client(fb303.FacebookService.Client, Iface): self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_get_partitions_statistics_req(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + def recv_get_partitions_statistics_req(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = get_partitions_statistics_req_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.o1 is not None: @@ -4007,16 +4086,17 @@ class Client(fb303.FacebookService.Client, Iface): self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_get_aggr_stats_for(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + def recv_get_aggr_stats_for(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = get_aggr_stats_for_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.o1 is not None: @@ -4041,16 +4121,17 @@ class Client(fb303.FacebookService.Client, Iface): self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_set_aggr_stats_for(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + def recv_set_aggr_stats_for(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = set_aggr_stats_for_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.o1 is not None: @@ -4085,16 +4166,17 @@ class Client(fb303.FacebookService.Client, Iface): self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_delete_partition_column_statistics(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + def recv_delete_partition_column_statistics(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = delete_partition_column_statistics_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.o1 is not None: @@ -4127,16 +4209,17 @@ class Client(fb303.FacebookService.Client, Iface): self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_delete_table_column_statistics(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + def recv_delete_table_column_statistics(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = delete_table_column_statistics_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.o1 is not None: @@ -4165,16 +4248,17 @@ class Client(fb303.FacebookService.Client, Iface): self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_create_function(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + def recv_create_function(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = create_function_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.o1 is not None: raise result.o1 if result.o2 is not None: @@ -4203,16 +4287,17 @@ class Client(fb303.FacebookService.Client, Iface): self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_drop_function(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + def recv_drop_function(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = drop_function_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.o1 is not None: raise result.o1 if result.o3 is not None: @@ -4239,16 +4324,17 @@ class Client(fb303.FacebookService.Client, Iface): self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_alter_function(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + def recv_alter_function(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = alter_function_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.o1 is not None: raise result.o1 if result.o2 is not None: @@ -4273,16 +4359,17 @@ class Client(fb303.FacebookService.Client, Iface): self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_get_functions(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + def recv_get_functions(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = get_functions_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.o1 is not None: @@ -4307,16 +4394,17 @@ class Client(fb303.FacebookService.Client, Iface): self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_get_function(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + def recv_get_function(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = get_function_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.o1 is not None: @@ -4341,16 +4429,17 @@ class Client(fb303.FacebookService.Client, Iface): self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_create_role(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + def recv_create_role(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = create_role_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.o1 is not None: @@ -4373,43 +4462,45 @@ class Client(fb303.FacebookService.Client, Iface): self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_drop_role(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + def recv_drop_role(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = drop_role_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.o1 is not None: raise result.o1 raise TApplicationException(TApplicationException.MISSING_RESULT, "drop_role failed: unknown result"); - def get_role_names(self, ): + def get_role_names(self): self.send_get_role_names() return self.recv_get_role_names() - def send_get_role_names(self, ): + def send_get_role_names(self): self._oprot.writeMessageBegin('get_role_names', TMessageType.CALL, self._seqid) args = get_role_names_args() args.write(self._oprot) self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_get_role_names(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + def recv_get_role_names(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = get_role_names_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.o1 is not None: @@ -4442,16 +4533,17 @@ class Client(fb303.FacebookService.Client, Iface): self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_grant_role(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + def recv_grant_role(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = grant_role_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.o1 is not None: @@ -4478,16 +4570,17 @@ class Client(fb303.FacebookService.Client, Iface): self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_revoke_role(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + def recv_revoke_role(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = revoke_role_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.o1 is not None: @@ -4512,16 +4605,17 @@ class Client(fb303.FacebookService.Client, Iface): self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_list_roles(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + def recv_list_roles(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = list_roles_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.o1 is not None: @@ -4544,16 +4638,17 @@ class Client(fb303.FacebookService.Client, Iface): self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_grant_revoke_role(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + def recv_grant_revoke_role(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = grant_revoke_role_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.o1 is not None: @@ -4576,16 +4671,17 @@ class Client(fb303.FacebookService.Client, Iface): self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_get_principals_in_role(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + def recv_get_principals_in_role(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = get_principals_in_role_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.o1 is not None: @@ -4608,16 +4704,17 @@ class Client(fb303.FacebookService.Client, Iface): self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_get_role_grants_for_principal(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + def recv_get_role_grants_for_principal(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = get_role_grants_for_principal_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.o1 is not None: @@ -4644,16 +4741,17 @@ class Client(fb303.FacebookService.Client, Iface): self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_get_privilege_set(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + def recv_get_privilege_set(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = get_privilege_set_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.o1 is not None: @@ -4680,16 +4778,17 @@ class Client(fb303.FacebookService.Client, Iface): self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_list_privileges(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + def recv_list_privileges(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = list_privileges_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.o1 is not None: @@ -4712,16 +4811,17 @@ class Client(fb303.FacebookService.Client, Iface): self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_grant_privileges(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + def recv_grant_privileges(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = grant_privileges_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.o1 is not None: @@ -4744,16 +4844,17 @@ class Client(fb303.FacebookService.Client, Iface): self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_revoke_privileges(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + def recv_revoke_privileges(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = revoke_privileges_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.o1 is not None: @@ -4776,16 +4877,17 @@ class Client(fb303.FacebookService.Client, Iface): self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_grant_revoke_privileges(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + def recv_grant_revoke_privileges(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = grant_revoke_privileges_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.o1 is not None: @@ -4810,16 +4912,17 @@ class Client(fb303.FacebookService.Client, Iface): self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_set_ugi(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + def recv_set_ugi(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = set_ugi_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.o1 is not None: @@ -4844,16 +4947,17 @@ class Client(fb303.FacebookService.Client, Iface): self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_get_delegation_token(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + def recv_get_delegation_token(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = get_delegation_token_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.o1 is not None: @@ -4876,16 +4980,17 @@ class Client(fb303.FacebookService.Client, Iface): self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_renew_delegation_token(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + def recv_renew_delegation_token(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = renew_delegation_token_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.o1 is not None: @@ -4908,66 +5013,69 @@ class Client(fb303.FacebookService.Client, Iface): self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_cancel_delegation_token(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + def recv_cancel_delegation_token(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EX
<TRUNCATED>
