diff options
author | RaNaN <Mast3rRaNaN@hotmail.de> | 2011-06-27 23:45:45 +0200 |
---|---|---|
committer | RaNaN <Mast3rRaNaN@hotmail.de> | 2011-06-27 23:45:45 +0200 |
commit | 0c1a92dcfa6d9775d5d0da8ef5fc8d9cc40d77b9 (patch) | |
tree | 0fb4ed212d1e9e8d48c30d69644a774eb2424b23 /module/remote/thriftbackend | |
parent | little cli improvement (diff) | |
download | pyload-0c1a92dcfa6d9775d5d0da8ef5fc8d9cc40d77b9.tar.xz |
thrift 0.7.0 from trunk, patched for low mem usage
Diffstat (limited to 'module/remote/thriftbackend')
-rw-r--r-- | module/remote/thriftbackend/Processor.py | 3 | ||||
-rw-r--r-- | module/remote/thriftbackend/ThriftClient.py | 2 | ||||
-rw-r--r-- | module/remote/thriftbackend/Transport.py | 22 | ||||
-rwxr-xr-x | module/remote/thriftbackend/generateThrift.sh | 5 | ||||
-rwxr-xr-x | module/remote/thriftbackend/thriftgen/pyload/Pyload-remote | 4 | ||||
-rw-r--r-- | module/remote/thriftbackend/thriftgen/pyload/Pyload.py | 5926 | ||||
-rw-r--r-- | module/remote/thriftbackend/thriftgen/pyload/constants.py | 6 | ||||
-rw-r--r-- | module/remote/thriftbackend/thriftgen/pyload/ttypes.py | 1761 |
8 files changed, 791 insertions, 6938 deletions
diff --git a/module/remote/thriftbackend/Processor.py b/module/remote/thriftbackend/Processor.py index cd7e81a91..8ea45f109 100644 --- a/module/remote/thriftbackend/Processor.py +++ b/module/remote/thriftbackend/Processor.py @@ -13,7 +13,8 @@ class Processor(Pyload.Processor): self.authenticated[trans] = False oldclose = trans.close def wrap(): - del self.authenticated[trans] + if self.authenticated.has_key(self): + del self.authenticated[trans] oldclose() trans.close = wrap authenticated = self.authenticated[trans] diff --git a/module/remote/thriftbackend/ThriftClient.py b/module/remote/thriftbackend/ThriftClient.py index 6bdbeea90..b3e6ac6ed 100644 --- a/module/remote/thriftbackend/ThriftClient.py +++ b/module/remote/thriftbackend/ThriftClient.py @@ -11,6 +11,7 @@ except ImportError: sys.path.append(abspath(join(dirname(abspath(__file__)), "..", "..", "lib"))) from thrift.transport import TTransport +#from thrift.transport.TZlibTransport import TZlibTransport from Socket import Socket from Protocol import Protocol @@ -74,6 +75,7 @@ class ThriftClient: def createConnection(self, host, port, ssl=False): self.socket = Socket(host, port, ssl) self.transport = TTransport.TBufferedTransport(self.socket) +# self.transport = TZlibTransport(TTransport.TBufferedTransport(self.socket)) protocol = Protocol(self.transport) self.client = Pyload.Client(protocol) diff --git a/module/remote/thriftbackend/Transport.py b/module/remote/thriftbackend/Transport.py index 50638f461..5772c5a9e 100644 --- a/module/remote/thriftbackend/Transport.py +++ b/module/remote/thriftbackend/Transport.py @@ -1,15 +1,37 @@ # -*- coding: utf-8 -*- from thrift.transport.TTransport import TBufferedTransport +from thrift.transport.TZlibTransport import TZlibTransport class Transport(TBufferedTransport): DEFAULT_BUFFER = 4096 def __init__(self, trans, rbuf_size = DEFAULT_BUFFER): TBufferedTransport.__init__(self, trans, rbuf_size) + self.handle = trans.handle + self.remoteaddr = trans.handle.getpeername() + +class TransportCompressed(TZlibTransport): + DEFAULT_BUFFER = 4096 + + def __init__(self, trans, rbuf_size = DEFAULT_BUFFER): + TZlibTransport.__init__(self, trans, rbuf_size) + self.handle = trans.handle self.remoteaddr = trans.handle.getpeername() class TransportFactory: def getTransport(self, trans): buffered = Transport(trans) return buffered + +class TransportFactoryCompressed: + _last_trans = None + _last_z = None + + def getTransport(self, trans, compresslevel=9): + if trans == self._last_trans: + return self._last_z + ztrans = TransportCompressed(Transport(trans), compresslevel) + self._last_trans = trans + self._last_z = ztrans + return ztrans
\ No newline at end of file diff --git a/module/remote/thriftbackend/generateThrift.sh b/module/remote/thriftbackend/generateThrift.sh index 679eb68ed..7acb8531c 100755 --- a/module/remote/thriftbackend/generateThrift.sh +++ b/module/remote/thriftbackend/generateThrift.sh @@ -1,4 +1,9 @@ #!/bin/sh rm -rf thriftgen + +# use thrift 0.7.0 from trunk +# patched if needed https://issues.apache.org/jira/browse/THRIFT-1115?page=com.atlassian.jira.plugin.system.issuetabpanels%3Achangehistory-tabpanel#issue-tabs +# --gen py:slots,dynamic + thrift -strict -v --gen py --gen java pyload.thrift mv gen-py thriftgen diff --git a/module/remote/thriftbackend/thriftgen/pyload/Pyload-remote b/module/remote/thriftbackend/thriftgen/pyload/Pyload-remote index d87ef6e28..88b14bd1d 100755 --- a/module/remote/thriftbackend/thriftgen/pyload/Pyload-remote +++ b/module/remote/thriftbackend/thriftgen/pyload/Pyload-remote @@ -1,9 +1,11 @@ #!/usr/bin/env python # -# Autogenerated by Thrift +# Autogenerated by Thrift Compiler (0.7.0-dev) # # DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING # +# options string: py:slots,dynamic +# import sys import pprint diff --git a/module/remote/thriftbackend/thriftgen/pyload/Pyload.py b/module/remote/thriftbackend/thriftgen/pyload/Pyload.py index e4cfba605..7dbe7874e 100644 --- a/module/remote/thriftbackend/thriftgen/pyload/Pyload.py +++ b/module/remote/thriftbackend/thriftgen/pyload/Pyload.py @@ -1,21 +1,18 @@ # -# Autogenerated by Thrift +# Autogenerated by Thrift Compiler (0.7.0-dev) # # DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING # +# options string: py:slots,dynamic +# -from thrift.Thrift import * +from thrift.Thrift import TType, TMessageType from ttypes import * from thrift.Thrift import TProcessor -from thrift.transport import TTransport -from thrift.protocol import TBinaryProtocol, TProtocol -try: - from thrift.protocol import fastbinary -except: - fastbinary = None +from thrift.protocol.TBase import TBase, TExceptionBase -class Iface: +class Iface(object): def getConfigValue(self, category, option, section): """ Parameters: @@ -364,7 +361,7 @@ class Iface: class Client(Iface): def __init__(self, iprot, oprot=None): self._iprot = self._oprot = iprot - if oprot != None: + if oprot is not None: self._oprot = oprot self._seqid = 0 @@ -398,7 +395,7 @@ class Client(Iface): result = getConfigValue_result() result.read(self._iprot) self._iprot.readMessageEnd() - if result.success != None: + if result.success is not None: return result.success raise TApplicationException(TApplicationException.MISSING_RESULT, "getConfigValue failed: unknown result"); @@ -457,7 +454,7 @@ class Client(Iface): result = getConfig_result() result.read(self._iprot) self._iprot.readMessageEnd() - if result.success != None: + if result.success is not None: return result.success raise TApplicationException(TApplicationException.MISSING_RESULT, "getConfig failed: unknown result"); @@ -482,7 +479,7 @@ class Client(Iface): result = getPluginConfig_result() result.read(self._iprot) self._iprot.readMessageEnd() - if result.success != None: + if result.success is not None: return result.success raise TApplicationException(TApplicationException.MISSING_RESULT, "getPluginConfig failed: unknown result"); @@ -553,7 +550,7 @@ class Client(Iface): result = togglePause_result() result.read(self._iprot) self._iprot.readMessageEnd() - if result.success != None: + if result.success is not None: return result.success raise TApplicationException(TApplicationException.MISSING_RESULT, "togglePause failed: unknown result"); @@ -578,7 +575,7 @@ class Client(Iface): result = statusServer_result() result.read(self._iprot) self._iprot.readMessageEnd() - if result.success != None: + if result.success is not None: return result.success raise TApplicationException(TApplicationException.MISSING_RESULT, "statusServer failed: unknown result"); @@ -603,7 +600,7 @@ class Client(Iface): result = freeSpace_result() result.read(self._iprot) self._iprot.readMessageEnd() - if result.success != None: + if result.success is not None: return result.success raise TApplicationException(TApplicationException.MISSING_RESULT, "freeSpace failed: unknown result"); @@ -628,7 +625,7 @@ class Client(Iface): result = getServerVersion_result() result.read(self._iprot) self._iprot.readMessageEnd() - if result.success != None: + if result.success is not None: return result.success raise TApplicationException(TApplicationException.MISSING_RESULT, "getServerVersion failed: unknown result"); @@ -704,7 +701,7 @@ class Client(Iface): result = getLog_result() result.read(self._iprot) self._iprot.readMessageEnd() - if result.success != None: + if result.success is not None: return result.success raise TApplicationException(TApplicationException.MISSING_RESULT, "getLog failed: unknown result"); @@ -734,7 +731,7 @@ class Client(Iface): result = checkURL_result() result.read(self._iprot) self._iprot.readMessageEnd() - if result.success != None: + if result.success is not None: return result.success raise TApplicationException(TApplicationException.MISSING_RESULT, "checkURL failed: unknown result"); @@ -759,7 +756,7 @@ class Client(Iface): result = isTimeDownload_result() result.read(self._iprot) self._iprot.readMessageEnd() - if result.success != None: + if result.success is not None: return result.success raise TApplicationException(TApplicationException.MISSING_RESULT, "isTimeDownload failed: unknown result"); @@ -784,7 +781,7 @@ class Client(Iface): result = isTimeReconnect_result() result.read(self._iprot) self._iprot.readMessageEnd() - if result.success != None: + if result.success is not None: return result.success raise TApplicationException(TApplicationException.MISSING_RESULT, "isTimeReconnect failed: unknown result"); @@ -809,7 +806,7 @@ class Client(Iface): result = toggleReconnect_result() result.read(self._iprot) self._iprot.readMessageEnd() - if result.success != None: + if result.success is not None: return result.success raise TApplicationException(TApplicationException.MISSING_RESULT, "toggleReconnect failed: unknown result"); @@ -834,7 +831,7 @@ class Client(Iface): result = statusDownloads_result() result.read(self._iprot) self._iprot.readMessageEnd() - if result.success != None: + if result.success is not None: return result.success raise TApplicationException(TApplicationException.MISSING_RESULT, "statusDownloads failed: unknown result"); @@ -868,7 +865,7 @@ class Client(Iface): result = addPackage_result() result.read(self._iprot) self._iprot.readMessageEnd() - if result.success != None: + if result.success is not None: return result.success raise TApplicationException(TApplicationException.MISSING_RESULT, "addPackage failed: unknown result"); @@ -898,9 +895,9 @@ class Client(Iface): result = getPackageData_result() result.read(self._iprot) self._iprot.readMessageEnd() - if result.success != None: + if result.success is not None: return result.success - if result.e != None: + if result.e is not None: raise result.e raise TApplicationException(TApplicationException.MISSING_RESULT, "getPackageData failed: unknown result"); @@ -930,9 +927,9 @@ class Client(Iface): result = getFileData_result() result.read(self._iprot) self._iprot.readMessageEnd() - if result.success != None: + if result.success is not None: return result.success - if result.e != None: + if result.e is not None: raise result.e raise TApplicationException(TApplicationException.MISSING_RESULT, "getFileData failed: unknown result"); @@ -1013,7 +1010,7 @@ class Client(Iface): result = getQueue_result() result.read(self._iprot) self._iprot.readMessageEnd() - if result.success != None: + if result.success is not None: return result.success raise TApplicationException(TApplicationException.MISSING_RESULT, "getQueue failed: unknown result"); @@ -1038,7 +1035,7 @@ class Client(Iface): result = getCollector_result() result.read(self._iprot) self._iprot.readMessageEnd() - if result.success != None: + if result.success is not None: return result.success raise TApplicationException(TApplicationException.MISSING_RESULT, "getCollector failed: unknown result"); @@ -1063,7 +1060,7 @@ class Client(Iface): result = getQueueData_result() result.read(self._iprot) self._iprot.readMessageEnd() - if result.success != None: + if result.success is not None: return result.success raise TApplicationException(TApplicationException.MISSING_RESULT, "getQueueData failed: unknown result"); @@ -1088,7 +1085,7 @@ class Client(Iface): result = getCollectorData_result() result.read(self._iprot) self._iprot.readMessageEnd() - if result.success != None: + if result.success is not None: return result.success raise TApplicationException(TApplicationException.MISSING_RESULT, "getCollectorData failed: unknown result"); @@ -1595,7 +1592,7 @@ class Client(Iface): result = getPackageOrder_result() result.read(self._iprot) self._iprot.readMessageEnd() - if result.success != None: + if result.success is not None: return result.success raise TApplicationException(TApplicationException.MISSING_RESULT, "getPackageOrder failed: unknown result"); @@ -1625,7 +1622,7 @@ class Client(Iface): result = getFileOrder_result() result.read(self._iprot) self._iprot.readMessageEnd() - if result.success != None: + if result.success is not None: return result.success raise TApplicationException(TApplicationException.MISSING_RESULT, "getFileOrder failed: unknown result"); @@ -1650,7 +1647,7 @@ class Client(Iface): result = isCaptchaWaiting_result() result.read(self._iprot) self._iprot.readMessageEnd() - if result.success != None: + if result.success is not None: return result.success raise TApplicationException(TApplicationException.MISSING_RESULT, "isCaptchaWaiting failed: unknown result"); @@ -1680,7 +1677,7 @@ class Client(Iface): result = getCaptchaTask_result() result.read(self._iprot) self._iprot.readMessageEnd() - if result.success != None: + if result.success is not None: return result.success raise TApplicationException(TApplicationException.MISSING_RESULT, "getCaptchaTask failed: unknown result"); @@ -1710,7 +1707,7 @@ class Client(Iface): result = getCaptchaTaskStatus_result() result.read(self._iprot) self._iprot.readMessageEnd() - if result.success != None: + if result.success is not None: return result.success raise TApplicationException(TApplicationException.MISSING_RESULT, "getCaptchaTaskStatus failed: unknown result"); @@ -1770,7 +1767,7 @@ class Client(Iface): result = getEvents_result() result.read(self._iprot) self._iprot.readMessageEnd() - if result.success != None: + if result.success is not None: return result.success raise TApplicationException(TApplicationException.MISSING_RESULT, "getEvents failed: unknown result"); @@ -1800,7 +1797,7 @@ class Client(Iface): result = getAccounts_result() result.read(self._iprot) self._iprot.readMessageEnd() - if result.success != None: + if result.success is not None: return result.success raise TApplicationException(TApplicationException.MISSING_RESULT, "getAccounts failed: unknown result"); @@ -1825,7 +1822,7 @@ class Client(Iface): result = getAccountTypes_result() result.read(self._iprot) self._iprot.readMessageEnd() - if result.success != None: + if result.success is not None: return result.success raise TApplicationException(TApplicationException.MISSING_RESULT, "getAccountTypes failed: unknown result"); @@ -1915,7 +1912,7 @@ class Client(Iface): result = login_result() result.read(self._iprot) self._iprot.readMessageEnd() - if result.success != None: + if result.success is not None: return result.success raise TApplicationException(TApplicationException.MISSING_RESULT, "login failed: unknown result"); @@ -1947,7 +1944,7 @@ class Client(Iface): result = getUserData_result() result.read(self._iprot) self._iprot.readMessageEnd() - if result.success != None: + if result.success is not None: return result.success raise TApplicationException(TApplicationException.MISSING_RESULT, "getUserData failed: unknown result"); @@ -1972,7 +1969,7 @@ class Client(Iface): result = getServices_result() result.read(self._iprot) self._iprot.readMessageEnd() - if result.success != None: + if result.success is not None: return result.success raise TApplicationException(TApplicationException.MISSING_RESULT, "getServices failed: unknown result"); @@ -2004,7 +2001,7 @@ class Client(Iface): result = hasService_result() result.read(self._iprot) self._iprot.readMessageEnd() - if result.success != None: + if result.success is not None: return result.success raise TApplicationException(TApplicationException.MISSING_RESULT, "hasService failed: unknown result"); @@ -2034,11 +2031,11 @@ class Client(Iface): result = call_result() result.read(self._iprot) self._iprot.readMessageEnd() - if result.success != None: + if result.success is not None: return result.success - if result.ex != None: + if result.ex is not None: raise result.ex - if result.e != None: + if result.e is not None: raise result.e raise TApplicationException(TApplicationException.MISSING_RESULT, "call failed: unknown result"); @@ -2797,7 +2794,7 @@ class Processor(Iface, TProcessor): # HELPER FUNCTIONS AND STRUCTURES -class getConfigValue_args: +class getConfigValue_args(TBase): """ Attributes: - category @@ -2805,6 +2802,12 @@ class getConfigValue_args: - section """ + __slots__ = [ + 'category', + 'option', + 'section', + ] + thrift_spec = ( None, # 0 (1, TType.STRING, 'category', None, None, ), # 1 @@ -2817,75 +2820,17 @@ class getConfigValue_args: self.option = option self.section = section - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - if fid == 1: - if ftype == TType.STRING: - self.category = iprot.readString(); - else: - iprot.skip(ftype) - elif fid == 2: - if ftype == TType.STRING: - self.option = iprot.readString(); - else: - iprot.skip(ftype) - elif fid == 3: - if ftype == TType.STRING: - self.section = iprot.readString(); - else: - iprot.skip(ftype) - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('getConfigValue_args') - if self.category != None: - oprot.writeFieldBegin('category', TType.STRING, 1) - oprot.writeString(self.category) - oprot.writeFieldEnd() - if self.option != None: - oprot.writeFieldBegin('option', TType.STRING, 2) - oprot.writeString(self.option) - oprot.writeFieldEnd() - if self.section != None: - oprot.writeFieldBegin('section', TType.STRING, 3) - oprot.writeString(self.section) - oprot.writeFieldEnd() - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return - - - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ - - def __ne__(self, other): - return not (self == other) - -class getConfigValue_result: +class getConfigValue_result(TBase): """ Attributes: - success """ + __slots__ = [ + 'success', + ] + thrift_spec = ( (0, TType.STRING, 'success', None, None, ), # 0 ) @@ -2893,52 +2838,8 @@ class getConfigValue_result: def __init__(self, success=None,): self.success = success - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - if fid == 0: - if ftype == TType.STRING: - self.success = iprot.readString(); - else: - iprot.skip(ftype) - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('getConfigValue_result') - if self.success != None: - oprot.writeFieldBegin('success', TType.STRING, 0) - oprot.writeString(self.success) - oprot.writeFieldEnd() - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return - - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) - - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ - - def __ne__(self, other): - return not (self == other) - -class setConfigValue_args: +class setConfigValue_args(TBase): """ Attributes: - category @@ -2947,6 +2848,13 @@ class setConfigValue_args: - section """ + __slots__ = [ + 'category', + 'option', + 'value', + 'section', + ] + thrift_spec = ( None, # 0 (1, TType.STRING, 'category', None, None, ), # 1 @@ -2961,166 +2869,35 @@ class setConfigValue_args: self.value = value self.section = section - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - if fid == 1: - if ftype == TType.STRING: - self.category = iprot.readString(); - else: - iprot.skip(ftype) - elif fid == 2: - if ftype == TType.STRING: - self.option = iprot.readString(); - else: - iprot.skip(ftype) - elif fid == 3: - if ftype == TType.STRING: - self.value = iprot.readString(); - else: - iprot.skip(ftype) - elif fid == 4: - if ftype == TType.STRING: - self.section = iprot.readString(); - else: - iprot.skip(ftype) - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('setConfigValue_args') - if self.category != None: - oprot.writeFieldBegin('category', TType.STRING, 1) - oprot.writeString(self.category) - oprot.writeFieldEnd() - if self.option != None: - oprot.writeFieldBegin('option', TType.STRING, 2) - oprot.writeString(self.option) - oprot.writeFieldEnd() - if self.value != None: - oprot.writeFieldBegin('value', TType.STRING, 3) - oprot.writeString(self.value) - oprot.writeFieldEnd() - if self.section != None: - oprot.writeFieldBegin('section', TType.STRING, 4) - oprot.writeString(self.section) - oprot.writeFieldEnd() - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return +class setConfigValue_result(TBase): - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) - - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ - - def __ne__(self, other): - return not (self == other) - -class setConfigValue_result: + __slots__ = [ + ] thrift_spec = ( ) - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('setConfigValue_result') - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return - - - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ +class getConfig_args(TBase): - def __ne__(self, other): - return not (self == other) - -class getConfig_args: + __slots__ = [ + ] thrift_spec = ( ) - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('getConfig_args') - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return - - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) - - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ - - def __ne__(self, other): - return not (self == other) - -class getConfig_result: +class getConfig_result(TBase): """ Attributes: - success """ + __slots__ = [ + 'success', + ] + thrift_spec = ( (0, TType.LIST, 'success', (TType.STRUCT,(ConfigSection, ConfigSection.thrift_spec)), None, ), # 0 ) @@ -3128,107 +2905,26 @@ class getConfig_result: def __init__(self, success=None,): self.success = success - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - if fid == 0: - if ftype == TType.LIST: - self.success = [] - (_etype58, _size55) = iprot.readListBegin() - for _i59 in xrange(_size55): - _elem60 = ConfigSection() - _elem60.read(iprot) - self.success.append(_elem60) - iprot.readListEnd() - else: - iprot.skip(ftype) - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('getConfig_result') - if self.success != None: - oprot.writeFieldBegin('success', TType.LIST, 0) - oprot.writeListBegin(TType.STRUCT, len(self.success)) - for iter61 in self.success: - iter61.write(oprot) - oprot.writeListEnd() - oprot.writeFieldEnd() - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return +class getPluginConfig_args(TBase): - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) - - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ - - def __ne__(self, other): - return not (self == other) - -class getPluginConfig_args: + __slots__ = [ + ] thrift_spec = ( ) - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('getPluginConfig_args') - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return - - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) - - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ - - def __ne__(self, other): - return not (self == other) - -class getPluginConfig_result: +class getPluginConfig_result(TBase): """ Attributes: - success """ + __slots__ = [ + 'success', + ] + thrift_spec = ( (0, TType.LIST, 'success', (TType.STRUCT,(ConfigSection, ConfigSection.thrift_spec)), None, ), # 0 ) @@ -3236,271 +2932,62 @@ class getPluginConfig_result: def __init__(self, success=None,): self.success = success - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - if fid == 0: - if ftype == TType.LIST: - self.success = [] - (_etype65, _size62) = iprot.readListBegin() - for _i66 in xrange(_size62): - _elem67 = ConfigSection() - _elem67.read(iprot) - self.success.append(_elem67) - iprot.readListEnd() - else: - iprot.skip(ftype) - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('getPluginConfig_result') - if self.success != None: - oprot.writeFieldBegin('success', TType.LIST, 0) - oprot.writeListBegin(TType.STRUCT, len(self.success)) - for iter68 in self.success: - iter68.write(oprot) - oprot.writeListEnd() - oprot.writeFieldEnd() - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return - - - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) - - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ - def __ne__(self, other): - return not (self == other) +class pauseServer_args(TBase): -class pauseServer_args: + __slots__ = [ + ] thrift_spec = ( ) - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('pauseServer_args') - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return - - - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ +class pauseServer_result(TBase): - def __ne__(self, other): - return not (self == other) - -class pauseServer_result: + __slots__ = [ + ] thrift_spec = ( ) - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('pauseServer_result') - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return - - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) +class unpauseServer_args(TBase): - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ - - def __ne__(self, other): - return not (self == other) - -class unpauseServer_args: + __slots__ = [ + ] thrift_spec = ( ) - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('unpauseServer_args') - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return - - - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ +class unpauseServer_result(TBase): - def __ne__(self, other): - return not (self == other) - -class unpauseServer_result: + __slots__ = [ + ] thrift_spec = ( ) - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('unpauseServer_result') - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return - - - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ +class togglePause_args(TBase): - def __ne__(self, other): - return not (self == other) - -class togglePause_args: + __slots__ = [ + ] thrift_spec = ( ) - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('togglePause_args') - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return - - - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) - - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ - def __ne__(self, other): - return not (self == other) - -class togglePause_result: +class togglePause_result(TBase): """ Attributes: - success """ + __slots__ = [ + 'success', + ] + thrift_spec = ( (0, TType.BOOL, 'success', None, None, ), # 0 ) @@ -3508,98 +2995,26 @@ class togglePause_result: def __init__(self, success=None,): self.success = success - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - if fid == 0: - if ftype == TType.BOOL: - self.success = iprot.readBool(); - else: - iprot.skip(ftype) - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('togglePause_result') - if self.success != None: - oprot.writeFieldBegin('success', TType.BOOL, 0) - oprot.writeBool(self.success) - oprot.writeFieldEnd() - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return - - - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ +class statusServer_args(TBase): - def __ne__(self, other): - return not (self == other) - -class statusServer_args: + __slots__ = [ + ] thrift_spec = ( ) - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('statusServer_args') - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return - - - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) - - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ - def __ne__(self, other): - return not (self == other) - -class statusServer_result: +class statusServer_result(TBase): """ Attributes: - success """ + __slots__ = [ + 'success', + ] + thrift_spec = ( (0, TType.STRUCT, 'success', (ServerStatus, ServerStatus.thrift_spec), None, ), # 0 ) @@ -3607,99 +3022,26 @@ class statusServer_result: def __init__(self, success=None,): self.success = success - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - if fid == 0: - if ftype == TType.STRUCT: - self.success = ServerStatus() - self.success.read(iprot) - else: - iprot.skip(ftype) - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('statusServer_result') - if self.success != None: - oprot.writeFieldBegin('success', TType.STRUCT, 0) - self.success.write(oprot) - oprot.writeFieldEnd() - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return - - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) +class freeSpace_args(TBase): - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ - - def __ne__(self, other): - return not (self == other) - -class freeSpace_args: + __slots__ = [ + ] thrift_spec = ( ) - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('freeSpace_args') - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return - - - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ - - def __ne__(self, other): - return not (self == other) - -class freeSpace_result: +class freeSpace_result(TBase): """ Attributes: - success """ + __slots__ = [ + 'success', + ] + thrift_spec = ( (0, TType.I64, 'success', None, None, ), # 0 ) @@ -3707,98 +3049,26 @@ class freeSpace_result: def __init__(self, success=None,): self.success = success - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - if fid == 0: - if ftype == TType.I64: - self.success = iprot.readI64(); - else: - iprot.skip(ftype) - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('freeSpace_result') - if self.success != None: - oprot.writeFieldBegin('success', TType.I64, 0) - oprot.writeI64(self.success) - oprot.writeFieldEnd() - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return - - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) +class getServerVersion_args(TBase): - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ - - def __ne__(self, other): - return not (self == other) - -class getServerVersion_args: + __slots__ = [ + ] thrift_spec = ( ) - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('getServerVersion_args') - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return - - - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ - - def __ne__(self, other): - return not (self == other) - -class getServerVersion_result: +class getServerVersion_result(TBase): """ Attributes: - success """ + __slots__ = [ + 'success', + ] + thrift_spec = ( (0, TType.STRING, 'success', None, None, ), # 0 ) @@ -3806,221 +3076,53 @@ class getServerVersion_result: def __init__(self, success=None,): self.success = success - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - if fid == 0: - if ftype == TType.STRING: - self.success = iprot.readString(); - else: - iprot.skip(ftype) - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('getServerVersion_result') - if self.success != None: - oprot.writeFieldBegin('success', TType.STRING, 0) - oprot.writeString(self.success) - oprot.writeFieldEnd() - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return - - - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ +class kill_args(TBase): - def __ne__(self, other): - return not (self == other) - -class kill_args: + __slots__ = [ + ] thrift_spec = ( ) - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('kill_args') - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return - - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) +class kill_result(TBase): - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ - - def __ne__(self, other): - return not (self == other) - -class kill_result: + __slots__ = [ + ] thrift_spec = ( ) - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('kill_result') - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return - - - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ +class restart_args(TBase): - def __ne__(self, other): - return not (self == other) - -class restart_args: + __slots__ = [ + ] thrift_spec = ( ) - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('restart_args') - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return - - - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) - - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ - def __ne__(self, other): - return not (self == other) +class restart_result(TBase): -class restart_result: + __slots__ = [ + ] thrift_spec = ( ) - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('restart_result') - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return - - - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) - - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ - def __ne__(self, other): - return not (self == other) - -class getLog_args: +class getLog_args(TBase): """ Attributes: - offset """ + __slots__ = [ + 'offset', + ] + thrift_spec = ( None, # 0 (1, TType.I32, 'offset', None, None, ), # 1 @@ -4029,57 +3131,17 @@ class getLog_args: def __init__(self, offset=None,): self.offset = offset - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - if fid == 1: - if ftype == TType.I32: - self.offset = iprot.readI32(); - else: - iprot.skip(ftype) - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('getLog_args') - if self.offset != None: - oprot.writeFieldBegin('offset', TType.I32, 1) - oprot.writeI32(self.offset) - oprot.writeFieldEnd() - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return - - - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ - - def __ne__(self, other): - return not (self == other) - -class getLog_result: +class getLog_result(TBase): """ Attributes: - success """ + __slots__ = [ + 'success', + ] + thrift_spec = ( (0, TType.LIST, 'success', (TType.STRING,None), None, ), # 0 ) @@ -4087,65 +3149,17 @@ class getLog_result: def __init__(self, success=None,): self.success = success - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - if fid == 0: - if ftype == TType.LIST: - self.success = [] - (_etype72, _size69) = iprot.readListBegin() - for _i73 in xrange(_size69): - _elem74 = iprot.readString(); - self.success.append(_elem74) - iprot.readListEnd() - else: - iprot.skip(ftype) - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('getLog_result') - if self.success != None: - oprot.writeFieldBegin('success', TType.LIST, 0) - oprot.writeListBegin(TType.STRING, len(self.success)) - for iter75 in self.success: - oprot.writeString(iter75) - oprot.writeListEnd() - oprot.writeFieldEnd() - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return - - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) - - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ - - def __ne__(self, other): - return not (self == other) - -class checkURL_args: +class checkURL_args(TBase): """ Attributes: - urls """ + __slots__ = [ + 'urls', + ] + thrift_spec = ( None, # 0 (1, TType.LIST, 'urls', (TType.STRING,None), None, ), # 1 @@ -4154,65 +3168,17 @@ class checkURL_args: def __init__(self, urls=None,): self.urls = urls - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - if fid == 1: - if ftype == TType.LIST: - self.urls = [] - (_etype79, _size76) = iprot.readListBegin() - for _i80 in xrange(_size76): - _elem81 = iprot.readString(); - self.urls.append(_elem81) - iprot.readListEnd() - else: - iprot.skip(ftype) - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('checkURL_args') - if self.urls != None: - oprot.writeFieldBegin('urls', TType.LIST, 1) - oprot.writeListBegin(TType.STRING, len(self.urls)) - for iter82 in self.urls: - oprot.writeString(iter82) - oprot.writeListEnd() - oprot.writeFieldEnd() - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return - - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) - - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ - - def __ne__(self, other): - return not (self == other) - -class checkURL_result: +class checkURL_result(TBase): """ Attributes: - success """ + __slots__ = [ + 'success', + ] + thrift_spec = ( (0, TType.MAP, 'success', (TType.STRING,None,TType.STRING,None), None, ), # 0 ) @@ -4220,108 +3186,26 @@ class checkURL_result: def __init__(self, success=None,): self.success = success - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - if fid == 0: - if ftype == TType.MAP: - self.success = {} - (_ktype84, _vtype85, _size83 ) = iprot.readMapBegin() - for _i87 in xrange(_size83): - _key88 = iprot.readString(); - _val89 = iprot.readString(); - self.success[_key88] = _val89 - iprot.readMapEnd() - else: - iprot.skip(ftype) - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('checkURL_result') - if self.success != None: - oprot.writeFieldBegin('success', TType.MAP, 0) - oprot.writeMapBegin(TType.STRING, TType.STRING, len(self.success)) - for kiter90,viter91 in self.success.items(): - oprot.writeString(kiter90) - oprot.writeString(viter91) - oprot.writeMapEnd() - oprot.writeFieldEnd() - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return - - - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ +class isTimeDownload_args(TBase): - def __ne__(self, other): - return not (self == other) - -class isTimeDownload_args: + __slots__ = [ + ] thrift_spec = ( ) - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('isTimeDownload_args') - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return - - - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ - - def __ne__(self, other): - return not (self == other) - -class isTimeDownload_result: +class isTimeDownload_result(TBase): """ Attributes: - success """ + __slots__ = [ + 'success', + ] + thrift_spec = ( (0, TType.BOOL, 'success', None, None, ), # 0 ) @@ -4329,98 +3213,26 @@ class isTimeDownload_result: def __init__(self, success=None,): self.success = success - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - if fid == 0: - if ftype == TType.BOOL: - self.success = iprot.readBool(); - else: - iprot.skip(ftype) - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('isTimeDownload_result') - if self.success != None: - oprot.writeFieldBegin('success', TType.BOOL, 0) - oprot.writeBool(self.success) - oprot.writeFieldEnd() - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return - - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) +class isTimeReconnect_args(TBase): - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ - - def __ne__(self, other): - return not (self == other) - -class isTimeReconnect_args: + __slots__ = [ + ] thrift_spec = ( ) - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('isTimeReconnect_args') - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return - - - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) - - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ - - def __ne__(self, other): - return not (self == other) -class isTimeReconnect_result: +class isTimeReconnect_result(TBase): """ Attributes: - success """ + __slots__ = [ + 'success', + ] + thrift_spec = ( (0, TType.BOOL, 'success', None, None, ), # 0 ) @@ -4428,98 +3240,26 @@ class isTimeReconnect_result: def __init__(self, success=None,): self.success = success - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - if fid == 0: - if ftype == TType.BOOL: - self.success = iprot.readBool(); - else: - iprot.skip(ftype) - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('isTimeReconnect_result') - if self.success != None: - oprot.writeFieldBegin('success', TType.BOOL, 0) - oprot.writeBool(self.success) - oprot.writeFieldEnd() - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return - - - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) - - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ - def __ne__(self, other): - return not (self == other) +class toggleReconnect_args(TBase): -class toggleReconnect_args: + __slots__ = [ + ] thrift_spec = ( ) - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('toggleReconnect_args') - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return - - - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) - - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ - - def __ne__(self, other): - return not (self == other) -class toggleReconnect_result: +class toggleReconnect_result(TBase): """ Attributes: - success """ + __slots__ = [ + 'success', + ] + thrift_spec = ( (0, TType.BOOL, 'success', None, None, ), # 0 ) @@ -4527,98 +3267,26 @@ class toggleReconnect_result: def __init__(self, success=None,): self.success = success - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - if fid == 0: - if ftype == TType.BOOL: - self.success = iprot.readBool(); - else: - iprot.skip(ftype) - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('toggleReconnect_result') - if self.success != None: - oprot.writeFieldBegin('success', TType.BOOL, 0) - oprot.writeBool(self.success) - oprot.writeFieldEnd() - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return - - - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) - - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ - def __ne__(self, other): - return not (self == other) +class statusDownloads_args(TBase): -class statusDownloads_args: + __slots__ = [ + ] thrift_spec = ( ) - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('statusDownloads_args') - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return - - - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) - - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ - def __ne__(self, other): - return not (self == other) - -class statusDownloads_result: +class statusDownloads_result(TBase): """ Attributes: - success """ + __slots__ = [ + 'success', + ] + thrift_spec = ( (0, TType.LIST, 'success', (TType.STRUCT,(DownloadInfo, DownloadInfo.thrift_spec)), None, ), # 0 ) @@ -4626,61 +3294,8 @@ class statusDownloads_result: def __init__(self, success=None,): self.success = success - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - if fid == 0: - if ftype == TType.LIST: - self.success = [] - (_etype95, _size92) = iprot.readListBegin() - for _i96 in xrange(_size92): - _elem97 = DownloadInfo() - _elem97.read(iprot) - self.success.append(_elem97) - iprot.readListEnd() - else: - iprot.skip(ftype) - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('statusDownloads_result') - if self.success != None: - oprot.writeFieldBegin('success', TType.LIST, 0) - oprot.writeListBegin(TType.STRUCT, len(self.success)) - for iter98 in self.success: - iter98.write(oprot) - oprot.writeListEnd() - oprot.writeFieldEnd() - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return - - - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ - - def __ne__(self, other): - return not (self == other) - -class addPackage_args: +class addPackage_args(TBase): """ Attributes: - name @@ -4688,6 +3303,12 @@ class addPackage_args: - dest """ + __slots__ = [ + 'name', + 'links', + 'dest', + ] + thrift_spec = ( None, # 0 (1, TType.STRING, 'name', None, None, ), # 1 @@ -4700,83 +3321,17 @@ class addPackage_args: self.links = links self.dest = dest - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - if fid == 1: - if ftype == TType.STRING: - self.name = iprot.readString(); - else: - iprot.skip(ftype) - elif fid == 2: - if ftype == TType.LIST: - self.links = [] - (_etype102, _size99) = iprot.readListBegin() - for _i103 in xrange(_size99): - _elem104 = iprot.readString(); - self.links.append(_elem104) - iprot.readListEnd() - else: - iprot.skip(ftype) - elif fid == 3: - if ftype == TType.I32: - self.dest = iprot.readI32(); - else: - iprot.skip(ftype) - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('addPackage_args') - if self.name != None: - oprot.writeFieldBegin('name', TType.STRING, 1) - oprot.writeString(self.name) - oprot.writeFieldEnd() - if self.links != None: - oprot.writeFieldBegin('links', TType.LIST, 2) - oprot.writeListBegin(TType.STRING, len(self.links)) - for iter105 in self.links: - oprot.writeString(iter105) - oprot.writeListEnd() - oprot.writeFieldEnd() - if self.dest != None: - oprot.writeFieldBegin('dest', TType.I32, 3) - oprot.writeI32(self.dest) - oprot.writeFieldEnd() - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return - - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) - - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ - - def __ne__(self, other): - return not (self == other) - -class addPackage_result: +class addPackage_result(TBase): """ Attributes: - success """ + __slots__ = [ + 'success', + ] + thrift_spec = ( (0, TType.I32, 'success', None, None, ), # 0 ) @@ -4784,57 +3339,17 @@ class addPackage_result: def __init__(self, success=None,): self.success = success - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - if fid == 0: - if ftype == TType.I32: - self.success = iprot.readI32(); - else: - iprot.skip(ftype) - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('addPackage_result') - if self.success != None: - oprot.writeFieldBegin('success', TType.I32, 0) - oprot.writeI32(self.success) - oprot.writeFieldEnd() - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return - - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) - - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ - - def __ne__(self, other): - return not (self == other) - -class getPackageData_args: +class getPackageData_args(TBase): """ Attributes: - pid """ + __slots__ = [ + 'pid', + ] + thrift_spec = ( None, # 0 (1, TType.I32, 'pid', None, None, ), # 1 @@ -4843,58 +3358,19 @@ class getPackageData_args: def __init__(self, pid=None,): self.pid = pid - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - if fid == 1: - if ftype == TType.I32: - self.pid = iprot.readI32(); - else: - iprot.skip(ftype) - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('getPackageData_args') - if self.pid != None: - oprot.writeFieldBegin('pid', TType.I32, 1) - oprot.writeI32(self.pid) - oprot.writeFieldEnd() - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return - - - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ - - def __ne__(self, other): - return not (self == other) - -class getPackageData_result: +class getPackageData_result(TBase): """ Attributes: - success - e """ + __slots__ = [ + 'success', + 'e', + ] + thrift_spec = ( (0, TType.STRUCT, 'success', (PackageData, PackageData.thrift_spec), None, ), # 0 (1, TType.STRUCT, 'e', (PackageDoesNotExists, PackageDoesNotExists.thrift_spec), None, ), # 1 @@ -4904,68 +3380,17 @@ class getPackageData_result: self.success = success self.e = e - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - if fid == 0: - if ftype == TType.STRUCT: - self.success = PackageData() - self.success.read(iprot) - else: - iprot.skip(ftype) - elif fid == 1: - if ftype == TType.STRUCT: - self.e = PackageDoesNotExists() - self.e.read(iprot) - else: - iprot.skip(ftype) - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('getPackageData_result') - if self.success != None: - oprot.writeFieldBegin('success', TType.STRUCT, 0) - self.success.write(oprot) - oprot.writeFieldEnd() - if self.e != None: - oprot.writeFieldBegin('e', TType.STRUCT, 1) - self.e.write(oprot) - oprot.writeFieldEnd() - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return - - - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) - - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ - - def __ne__(self, other): - return not (self == other) -class getFileData_args: +class getFileData_args(TBase): """ Attributes: - fid """ + __slots__ = [ + 'fid', + ] + thrift_spec = ( None, # 0 (1, TType.I32, 'fid', None, None, ), # 1 @@ -4974,58 +3399,19 @@ class getFileData_args: def __init__(self, fid=None,): self.fid = fid - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - if fid == 1: - if ftype == TType.I32: - self.fid = iprot.readI32(); - else: - iprot.skip(ftype) - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('getFileData_args') - if self.fid != None: - oprot.writeFieldBegin('fid', TType.I32, 1) - oprot.writeI32(self.fid) - oprot.writeFieldEnd() - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return - - - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) - - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ - def __ne__(self, other): - return not (self == other) - -class getFileData_result: +class getFileData_result(TBase): """ Attributes: - success - e """ + __slots__ = [ + 'success', + 'e', + ] + thrift_spec = ( (0, TType.STRUCT, 'success', (FileData, FileData.thrift_spec), None, ), # 0 (1, TType.STRUCT, 'e', (FileDoesNotExists, FileDoesNotExists.thrift_spec), None, ), # 1 @@ -5035,68 +3421,17 @@ class getFileData_result: self.success = success self.e = e - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - if fid == 0: - if ftype == TType.STRUCT: - self.success = FileData() - self.success.read(iprot) - else: - iprot.skip(ftype) - elif fid == 1: - if ftype == TType.STRUCT: - self.e = FileDoesNotExists() - self.e.read(iprot) - else: - iprot.skip(ftype) - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('getFileData_result') - if self.success != None: - oprot.writeFieldBegin('success', TType.STRUCT, 0) - self.success.write(oprot) - oprot.writeFieldEnd() - if self.e != None: - oprot.writeFieldBegin('e', TType.STRUCT, 1) - self.e.write(oprot) - oprot.writeFieldEnd() - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return - - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) - - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ - - def __ne__(self, other): - return not (self == other) - -class deleteFiles_args: +class deleteFiles_args(TBase): """ Attributes: - fids """ + __slots__ = [ + 'fids', + ] + thrift_spec = ( None, # 0 (1, TType.LIST, 'fids', (TType.I32,None), None, ), # 1 @@ -5105,106 +3440,26 @@ class deleteFiles_args: def __init__(self, fids=None,): self.fids = fids - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - if fid == 1: - if ftype == TType.LIST: - self.fids = [] - (_etype109, _size106) = iprot.readListBegin() - for _i110 in xrange(_size106): - _elem111 = iprot.readI32(); - self.fids.append(_elem111) - iprot.readListEnd() - else: - iprot.skip(ftype) - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('deleteFiles_args') - if self.fids != None: - oprot.writeFieldBegin('fids', TType.LIST, 1) - oprot.writeListBegin(TType.I32, len(self.fids)) - for iter112 in self.fids: - oprot.writeI32(iter112) - oprot.writeListEnd() - oprot.writeFieldEnd() - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return - - - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ +class deleteFiles_result(TBase): - def __ne__(self, other): - return not (self == other) - -class deleteFiles_result: + __slots__ = [ + ] thrift_spec = ( ) - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('deleteFiles_result') - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return - - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) - - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ - - def __ne__(self, other): - return not (self == other) - -class deletePackages_args: +class deletePackages_args(TBase): """ Attributes: - pids """ + __slots__ = [ + 'pids', + ] + thrift_spec = ( None, # 0 (1, TType.LIST, 'pids', (TType.I32,None), None, ), # 1 @@ -5213,147 +3468,35 @@ class deletePackages_args: def __init__(self, pids=None,): self.pids = pids - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - if fid == 1: - if ftype == TType.LIST: - self.pids = [] - (_etype116, _size113) = iprot.readListBegin() - for _i117 in xrange(_size113): - _elem118 = iprot.readI32(); - self.pids.append(_elem118) - iprot.readListEnd() - else: - iprot.skip(ftype) - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('deletePackages_args') - if self.pids != None: - oprot.writeFieldBegin('pids', TType.LIST, 1) - oprot.writeListBegin(TType.I32, len(self.pids)) - for iter119 in self.pids: - oprot.writeI32(iter119) - oprot.writeListEnd() - oprot.writeFieldEnd() - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return +class deletePackages_result(TBase): - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) - - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ - - def __ne__(self, other): - return not (self == other) - -class deletePackages_result: + __slots__ = [ + ] thrift_spec = ( ) - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('deletePackages_result') - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return +class getQueue_args(TBase): - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) - - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ - - def __ne__(self, other): - return not (self == other) - -class getQueue_args: + __slots__ = [ + ] thrift_spec = ( ) - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('getQueue_args') - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return - - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) - - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ - - def __ne__(self, other): - return not (self == other) - -class getQueue_result: +class getQueue_result(TBase): """ Attributes: - success """ + __slots__ = [ + 'success', + ] + thrift_spec = ( (0, TType.LIST, 'success', (TType.STRUCT,(PackageInfo, PackageInfo.thrift_spec)), None, ), # 0 ) @@ -5361,107 +3504,26 @@ class getQueue_result: def __init__(self, success=None,): self.success = success - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - if fid == 0: - if ftype == TType.LIST: - self.success = [] - (_etype123, _size120) = iprot.readListBegin() - for _i124 in xrange(_size120): - _elem125 = PackageInfo() - _elem125.read(iprot) - self.success.append(_elem125) - iprot.readListEnd() - else: - iprot.skip(ftype) - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('getQueue_result') - if self.success != None: - oprot.writeFieldBegin('success', TType.LIST, 0) - oprot.writeListBegin(TType.STRUCT, len(self.success)) - for iter126 in self.success: - iter126.write(oprot) - oprot.writeListEnd() - oprot.writeFieldEnd() - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return +class getCollector_args(TBase): - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) - - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ - - def __ne__(self, other): - return not (self == other) - -class getCollector_args: + __slots__ = [ + ] thrift_spec = ( ) - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('getCollector_args') - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return - - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) - - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ - - def __ne__(self, other): - return not (self == other) - -class getCollector_result: +class getCollector_result(TBase): """ Attributes: - success """ + __slots__ = [ + 'success', + ] + thrift_spec = ( (0, TType.LIST, 'success', (TType.STRUCT,(PackageInfo, PackageInfo.thrift_spec)), None, ), # 0 ) @@ -5469,107 +3531,26 @@ class getCollector_result: def __init__(self, success=None,): self.success = success - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - if fid == 0: - if ftype == TType.LIST: - self.success = [] - (_etype130, _size127) = iprot.readListBegin() - for _i131 in xrange(_size127): - _elem132 = PackageInfo() - _elem132.read(iprot) - self.success.append(_elem132) - iprot.readListEnd() - else: - iprot.skip(ftype) - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('getCollector_result') - if self.success != None: - oprot.writeFieldBegin('success', TType.LIST, 0) - oprot.writeListBegin(TType.STRUCT, len(self.success)) - for iter133 in self.success: - iter133.write(oprot) - oprot.writeListEnd() - oprot.writeFieldEnd() - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return - - - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) - - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ - def __ne__(self, other): - return not (self == other) +class getQueueData_args(TBase): -class getQueueData_args: + __slots__ = [ + ] thrift_spec = ( ) - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('getQueueData_args') - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return - - - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) - - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ - - def __ne__(self, other): - return not (self == other) -class getQueueData_result: +class getQueueData_result(TBase): """ Attributes: - success """ + __slots__ = [ + 'success', + ] + thrift_spec = ( (0, TType.LIST, 'success', (TType.STRUCT,(PackageData, PackageData.thrift_spec)), None, ), # 0 ) @@ -5577,107 +3558,26 @@ class getQueueData_result: def __init__(self, success=None,): self.success = success - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - if fid == 0: - if ftype == TType.LIST: - self.success = [] - (_etype137, _size134) = iprot.readListBegin() - for _i138 in xrange(_size134): - _elem139 = PackageData() - _elem139.read(iprot) - self.success.append(_elem139) - iprot.readListEnd() - else: - iprot.skip(ftype) - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('getQueueData_result') - if self.success != None: - oprot.writeFieldBegin('success', TType.LIST, 0) - oprot.writeListBegin(TType.STRUCT, len(self.success)) - for iter140 in self.success: - iter140.write(oprot) - oprot.writeListEnd() - oprot.writeFieldEnd() - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return - - - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) - - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ - def __ne__(self, other): - return not (self == other) +class getCollectorData_args(TBase): -class getCollectorData_args: + __slots__ = [ + ] thrift_spec = ( ) - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('getCollectorData_args') - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return - - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) - - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ - - def __ne__(self, other): - return not (self == other) - -class getCollectorData_result: +class getCollectorData_result(TBase): """ Attributes: - success """ + __slots__ = [ + 'success', + ] + thrift_spec = ( (0, TType.LIST, 'success', (TType.STRUCT,(PackageData, PackageData.thrift_spec)), None, ), # 0 ) @@ -5685,67 +3585,19 @@ class getCollectorData_result: def __init__(self, success=None,): self.success = success - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - if fid == 0: - if ftype == TType.LIST: - self.success = [] - (_etype144, _size141) = iprot.readListBegin() - for _i145 in xrange(_size141): - _elem146 = PackageData() - _elem146.read(iprot) - self.success.append(_elem146) - iprot.readListEnd() - else: - iprot.skip(ftype) - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('getCollectorData_result') - if self.success != None: - oprot.writeFieldBegin('success', TType.LIST, 0) - oprot.writeListBegin(TType.STRUCT, len(self.success)) - for iter147 in self.success: - iter147.write(oprot) - oprot.writeListEnd() - oprot.writeFieldEnd() - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return - - - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ - - def __ne__(self, other): - return not (self == other) - -class addFiles_args: +class addFiles_args(TBase): """ Attributes: - pid - links """ + __slots__ = [ + 'pid', + 'links', + ] + thrift_spec = ( None, # 0 (1, TType.I32, 'pid', None, None, ), # 1 @@ -5756,115 +3608,26 @@ class addFiles_args: self.pid = pid self.links = links - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - if fid == 1: - if ftype == TType.I32: - self.pid = iprot.readI32(); - else: - iprot.skip(ftype) - elif fid == 2: - if ftype == TType.LIST: - self.links = [] - (_etype151, _size148) = iprot.readListBegin() - for _i152 in xrange(_size148): - _elem153 = iprot.readString(); - self.links.append(_elem153) - iprot.readListEnd() - else: - iprot.skip(ftype) - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('addFiles_args') - if self.pid != None: - oprot.writeFieldBegin('pid', TType.I32, 1) - oprot.writeI32(self.pid) - oprot.writeFieldEnd() - if self.links != None: - oprot.writeFieldBegin('links', TType.LIST, 2) - oprot.writeListBegin(TType.STRING, len(self.links)) - for iter154 in self.links: - oprot.writeString(iter154) - oprot.writeListEnd() - oprot.writeFieldEnd() - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return - - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) +class addFiles_result(TBase): - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ - - def __ne__(self, other): - return not (self == other) - -class addFiles_result: + __slots__ = [ + ] thrift_spec = ( ) - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('addFiles_result') - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return - - - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ - - def __ne__(self, other): - return not (self == other) - -class pushToQueue_args: +class pushToQueue_args(TBase): """ Attributes: - pid """ + __slots__ = [ + 'pid', + ] + thrift_spec = ( None, # 0 (1, TType.I32, 'pid', None, None, ), # 1 @@ -5873,98 +3636,26 @@ class pushToQueue_args: def __init__(self, pid=None,): self.pid = pid - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - if fid == 1: - if ftype == TType.I32: - self.pid = iprot.readI32(); - else: - iprot.skip(ftype) - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('pushToQueue_args') - if self.pid != None: - oprot.writeFieldBegin('pid', TType.I32, 1) - oprot.writeI32(self.pid) - oprot.writeFieldEnd() - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return - - - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) - - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ - def __ne__(self, other): - return not (self == other) +class pushToQueue_result(TBase): -class pushToQueue_result: + __slots__ = [ + ] thrift_spec = ( ) - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('pushToQueue_result') - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return - - - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) - - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ - - def __ne__(self, other): - return not (self == other) -class pullFromQueue_args: +class pullFromQueue_args(TBase): """ Attributes: - pid """ + __slots__ = [ + 'pid', + ] + thrift_spec = ( None, # 0 (1, TType.I32, 'pid', None, None, ), # 1 @@ -5973,98 +3664,26 @@ class pullFromQueue_args: def __init__(self, pid=None,): self.pid = pid - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - if fid == 1: - if ftype == TType.I32: - self.pid = iprot.readI32(); - else: - iprot.skip(ftype) - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('pullFromQueue_args') - if self.pid != None: - oprot.writeFieldBegin('pid', TType.I32, 1) - oprot.writeI32(self.pid) - oprot.writeFieldEnd() - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return - - - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ +class pullFromQueue_result(TBase): - def __ne__(self, other): - return not (self == other) - -class pullFromQueue_result: + __slots__ = [ + ] thrift_spec = ( ) - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('pullFromQueue_result') - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return - - - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) - - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ - def __ne__(self, other): - return not (self == other) - -class restartPackage_args: +class restartPackage_args(TBase): """ Attributes: - pid """ + __slots__ = [ + 'pid', + ] + thrift_spec = ( None, # 0 (1, TType.I32, 'pid', None, None, ), # 1 @@ -6073,98 +3692,26 @@ class restartPackage_args: def __init__(self, pid=None,): self.pid = pid - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - if fid == 1: - if ftype == TType.I32: - self.pid = iprot.readI32(); - else: - iprot.skip(ftype) - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('restartPackage_args') - if self.pid != None: - oprot.writeFieldBegin('pid', TType.I32, 1) - oprot.writeI32(self.pid) - oprot.writeFieldEnd() - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return - - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) +class restartPackage_result(TBase): - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ - - def __ne__(self, other): - return not (self == other) - -class restartPackage_result: + __slots__ = [ + ] thrift_spec = ( ) - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('restartPackage_result') - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return - - - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ - - def __ne__(self, other): - return not (self == other) - -class restartFile_args: +class restartFile_args(TBase): """ Attributes: - fid """ + __slots__ = [ + 'fid', + ] + thrift_spec = ( None, # 0 (1, TType.I32, 'fid', None, None, ), # 1 @@ -6173,98 +3720,26 @@ class restartFile_args: def __init__(self, fid=None,): self.fid = fid - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - if fid == 1: - if ftype == TType.I32: - self.fid = iprot.readI32(); - else: - iprot.skip(ftype) - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('restartFile_args') - if self.fid != None: - oprot.writeFieldBegin('fid', TType.I32, 1) - oprot.writeI32(self.fid) - oprot.writeFieldEnd() - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return - - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) +class restartFile_result(TBase): - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ - - def __ne__(self, other): - return not (self == other) - -class restartFile_result: + __slots__ = [ + ] thrift_spec = ( ) - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('restartFile_result') - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return - - - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ - - def __ne__(self, other): - return not (self == other) - -class recheckPackage_args: +class recheckPackage_args(TBase): """ Attributes: - pid """ + __slots__ = [ + 'pid', + ] + thrift_spec = ( None, # 0 (1, TType.I32, 'pid', None, None, ), # 1 @@ -6273,180 +3748,44 @@ class recheckPackage_args: def __init__(self, pid=None,): self.pid = pid - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - if fid == 1: - if ftype == TType.I32: - self.pid = iprot.readI32(); - else: - iprot.skip(ftype) - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('recheckPackage_args') - if self.pid != None: - oprot.writeFieldBegin('pid', TType.I32, 1) - oprot.writeI32(self.pid) - oprot.writeFieldEnd() - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return - - - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ +class recheckPackage_result(TBase): - def __ne__(self, other): - return not (self == other) - -class recheckPackage_result: + __slots__ = [ + ] thrift_spec = ( ) - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('recheckPackage_result') - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return - - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) +class stopAllDownloads_args(TBase): - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ - - def __ne__(self, other): - return not (self == other) - -class stopAllDownloads_args: + __slots__ = [ + ] thrift_spec = ( ) - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('stopAllDownloads_args') - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return - - - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ +class stopAllDownloads_result(TBase): - def __ne__(self, other): - return not (self == other) - -class stopAllDownloads_result: + __slots__ = [ + ] thrift_spec = ( ) - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('stopAllDownloads_result') - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return - - - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) - - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ - def __ne__(self, other): - return not (self == other) - -class stopDownloads_args: +class stopDownloads_args(TBase): """ Attributes: - fids """ + __slots__ = [ + 'fids', + ] + thrift_spec = ( None, # 0 (1, TType.LIST, 'fids', (TType.I32,None), None, ), # 1 @@ -6455,107 +3794,28 @@ class stopDownloads_args: def __init__(self, fids=None,): self.fids = fids - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - if fid == 1: - if ftype == TType.LIST: - self.fids = [] - (_etype158, _size155) = iprot.readListBegin() - for _i159 in xrange(_size155): - _elem160 = iprot.readI32(); - self.fids.append(_elem160) - iprot.readListEnd() - else: - iprot.skip(ftype) - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('stopDownloads_args') - if self.fids != None: - oprot.writeFieldBegin('fids', TType.LIST, 1) - oprot.writeListBegin(TType.I32, len(self.fids)) - for iter161 in self.fids: - oprot.writeI32(iter161) - oprot.writeListEnd() - oprot.writeFieldEnd() - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return - - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) +class stopDownloads_result(TBase): - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ - - def __ne__(self, other): - return not (self == other) - -class stopDownloads_result: + __slots__ = [ + ] thrift_spec = ( ) - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('stopDownloads_result') - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return - - - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ - - def __ne__(self, other): - return not (self == other) - -class setPackageName_args: +class setPackageName_args(TBase): """ Attributes: - pid - name """ + __slots__ = [ + 'pid', + 'name', + ] + thrift_spec = ( None, # 0 (1, TType.I32, 'pid', None, None, ), # 1 @@ -6566,108 +3826,28 @@ class setPackageName_args: self.pid = pid self.name = name - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - if fid == 1: - if ftype == TType.I32: - self.pid = iprot.readI32(); - else: - iprot.skip(ftype) - elif fid == 2: - if ftype == TType.STRING: - self.name = iprot.readString(); - else: - iprot.skip(ftype) - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('setPackageName_args') - if self.pid != None: - oprot.writeFieldBegin('pid', TType.I32, 1) - oprot.writeI32(self.pid) - oprot.writeFieldEnd() - if self.name != None: - oprot.writeFieldBegin('name', TType.STRING, 2) - oprot.writeString(self.name) - oprot.writeFieldEnd() - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return - - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) +class setPackageName_result(TBase): - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ - - def __ne__(self, other): - return not (self == other) - -class setPackageName_result: + __slots__ = [ + ] thrift_spec = ( ) - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('setPackageName_result') - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return - - - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ - - def __ne__(self, other): - return not (self == other) - -class movePackage_args: +class movePackage_args(TBase): """ Attributes: - destination - pid """ + __slots__ = [ + 'destination', + 'pid', + ] + thrift_spec = ( None, # 0 (1, TType.I32, 'destination', None, None, ), # 1 @@ -6678,108 +3858,28 @@ class movePackage_args: self.destination = destination self.pid = pid - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - if fid == 1: - if ftype == TType.I32: - self.destination = iprot.readI32(); - else: - iprot.skip(ftype) - elif fid == 2: - if ftype == TType.I32: - self.pid = iprot.readI32(); - else: - iprot.skip(ftype) - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('movePackage_args') - if self.destination != None: - oprot.writeFieldBegin('destination', TType.I32, 1) - oprot.writeI32(self.destination) - oprot.writeFieldEnd() - if self.pid != None: - oprot.writeFieldBegin('pid', TType.I32, 2) - oprot.writeI32(self.pid) - oprot.writeFieldEnd() - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return - - - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ +class movePackage_result(TBase): - def __ne__(self, other): - return not (self == other) - -class movePackage_result: + __slots__ = [ + ] thrift_spec = ( ) - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('movePackage_result') - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return - - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) - - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ - - def __ne__(self, other): - return not (self == other) - -class uploadContainer_args: +class uploadContainer_args(TBase): """ Attributes: - filename - data """ + __slots__ = [ + 'filename', + 'data', + ] + thrift_spec = ( None, # 0 (1, TType.STRING, 'filename', None, None, ), # 1 @@ -6790,108 +3890,28 @@ class uploadContainer_args: self.filename = filename self.data = data - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - if fid == 1: - if ftype == TType.STRING: - self.filename = iprot.readString(); - else: - iprot.skip(ftype) - elif fid == 2: - if ftype == TType.STRING: - self.data = iprot.readString(); - else: - iprot.skip(ftype) - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('uploadContainer_args') - if self.filename != None: - oprot.writeFieldBegin('filename', TType.STRING, 1) - oprot.writeString(self.filename) - oprot.writeFieldEnd() - if self.data != None: - oprot.writeFieldBegin('data', TType.STRING, 2) - oprot.writeString(self.data) - oprot.writeFieldEnd() - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return +class uploadContainer_result(TBase): - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) - - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ - - def __ne__(self, other): - return not (self == other) - -class uploadContainer_result: + __slots__ = [ + ] thrift_spec = ( ) - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('uploadContainer_result') - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return - - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) - - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ - - def __ne__(self, other): - return not (self == other) - -class setPriority_args: +class setPriority_args(TBase): """ Attributes: - pid - priority """ + __slots__ = [ + 'pid', + 'priority', + ] + thrift_spec = ( None, # 0 (1, TType.I32, 'pid', None, None, ), # 1 @@ -6902,108 +3922,28 @@ class setPriority_args: self.pid = pid self.priority = priority - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - if fid == 1: - if ftype == TType.I32: - self.pid = iprot.readI32(); - else: - iprot.skip(ftype) - elif fid == 2: - if ftype == TType.BYTE: - self.priority = iprot.readByte(); - else: - iprot.skip(ftype) - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('setPriority_args') - if self.pid != None: - oprot.writeFieldBegin('pid', TType.I32, 1) - oprot.writeI32(self.pid) - oprot.writeFieldEnd() - if self.priority != None: - oprot.writeFieldBegin('priority', TType.BYTE, 2) - oprot.writeByte(self.priority) - oprot.writeFieldEnd() - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return - - - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) - - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ - def __ne__(self, other): - return not (self == other) +class setPriority_result(TBase): -class setPriority_result: + __slots__ = [ + ] thrift_spec = ( ) - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('setPriority_result') - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return - - - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) - - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ - - def __ne__(self, other): - return not (self == other) -class orderPackage_args: +class orderPackage_args(TBase): """ Attributes: - pid - position """ + __slots__ = [ + 'pid', + 'position', + ] + thrift_spec = ( None, # 0 (1, TType.I32, 'pid', None, None, ), # 1 @@ -7014,108 +3954,28 @@ class orderPackage_args: self.pid = pid self.position = position - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - if fid == 1: - if ftype == TType.I32: - self.pid = iprot.readI32(); - else: - iprot.skip(ftype) - elif fid == 2: - if ftype == TType.I16: - self.position = iprot.readI16(); - else: - iprot.skip(ftype) - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('orderPackage_args') - if self.pid != None: - oprot.writeFieldBegin('pid', TType.I32, 1) - oprot.writeI32(self.pid) - oprot.writeFieldEnd() - if self.position != None: - oprot.writeFieldBegin('position', TType.I16, 2) - oprot.writeI16(self.position) - oprot.writeFieldEnd() - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return - - - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) - - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ - def __ne__(self, other): - return not (self == other) +class orderPackage_result(TBase): -class orderPackage_result: + __slots__ = [ + ] thrift_spec = ( ) - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('orderPackage_result') - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return - - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) - - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ - - def __ne__(self, other): - return not (self == other) - -class orderFile_args: +class orderFile_args(TBase): """ Attributes: - fid - position """ + __slots__ = [ + 'fid', + 'position', + ] + thrift_spec = ( None, # 0 (1, TType.I32, 'fid', None, None, ), # 1 @@ -7126,108 +3986,28 @@ class orderFile_args: self.fid = fid self.position = position - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - if fid == 1: - if ftype == TType.I32: - self.fid = iprot.readI32(); - else: - iprot.skip(ftype) - elif fid == 2: - if ftype == TType.I16: - self.position = iprot.readI16(); - else: - iprot.skip(ftype) - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('orderFile_args') - if self.fid != None: - oprot.writeFieldBegin('fid', TType.I32, 1) - oprot.writeI32(self.fid) - oprot.writeFieldEnd() - if self.position != None: - oprot.writeFieldBegin('position', TType.I16, 2) - oprot.writeI16(self.position) - oprot.writeFieldEnd() - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return - - - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ +class orderFile_result(TBase): - def __ne__(self, other): - return not (self == other) - -class orderFile_result: + __slots__ = [ + ] thrift_spec = ( ) - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('orderFile_result') - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return - - - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) - - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ - def __ne__(self, other): - return not (self == other) - -class setPackageData_args: +class setPackageData_args(TBase): """ Attributes: - pid - data """ + __slots__ = [ + 'pid', + 'data', + ] + thrift_spec = ( None, # 0 (1, TType.I32, 'pid', None, None, ), # 1 @@ -7238,281 +4018,62 @@ class setPackageData_args: self.pid = pid self.data = data - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - if fid == 1: - if ftype == TType.I32: - self.pid = iprot.readI32(); - else: - iprot.skip(ftype) - elif fid == 2: - if ftype == TType.MAP: - self.data = {} - (_ktype163, _vtype164, _size162 ) = iprot.readMapBegin() - for _i166 in xrange(_size162): - _key167 = iprot.readString(); - _val168 = iprot.readString(); - self.data[_key167] = _val168 - iprot.readMapEnd() - else: - iprot.skip(ftype) - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('setPackageData_args') - if self.pid != None: - oprot.writeFieldBegin('pid', TType.I32, 1) - oprot.writeI32(self.pid) - oprot.writeFieldEnd() - if self.data != None: - oprot.writeFieldBegin('data', TType.MAP, 2) - oprot.writeMapBegin(TType.STRING, TType.STRING, len(self.data)) - for kiter169,viter170 in self.data.items(): - oprot.writeString(kiter169) - oprot.writeString(viter170) - oprot.writeMapEnd() - oprot.writeFieldEnd() - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return - - - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ +class setPackageData_result(TBase): - def __ne__(self, other): - return not (self == other) - -class setPackageData_result: + __slots__ = [ + ] thrift_spec = ( ) - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('setPackageData_result') - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return - - - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ +class deleteFinished_args(TBase): - def __ne__(self, other): - return not (self == other) - -class deleteFinished_args: + __slots__ = [ + ] thrift_spec = ( ) - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('deleteFinished_args') - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return - - - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) - - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ - def __ne__(self, other): - return not (self == other) +class deleteFinished_result(TBase): -class deleteFinished_result: + __slots__ = [ + ] thrift_spec = ( ) - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('deleteFinished_result') - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return - - - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ +class restartFailed_args(TBase): - def __ne__(self, other): - return not (self == other) - -class restartFailed_args: + __slots__ = [ + ] thrift_spec = ( ) - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('restartFailed_args') - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return - - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) +class restartFailed_result(TBase): - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ - - def __ne__(self, other): - return not (self == other) - -class restartFailed_result: + __slots__ = [ + ] thrift_spec = ( ) - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('restartFailed_result') - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return - - - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ - - def __ne__(self, other): - return not (self == other) - -class getPackageOrder_args: +class getPackageOrder_args(TBase): """ Attributes: - destination """ + __slots__ = [ + 'destination', + ] + thrift_spec = ( None, # 0 (1, TType.I32, 'destination', None, None, ), # 1 @@ -7521,57 +4082,17 @@ class getPackageOrder_args: def __init__(self, destination=None,): self.destination = destination - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - if fid == 1: - if ftype == TType.I32: - self.destination = iprot.readI32(); - else: - iprot.skip(ftype) - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('getPackageOrder_args') - if self.destination != None: - oprot.writeFieldBegin('destination', TType.I32, 1) - oprot.writeI32(self.destination) - oprot.writeFieldEnd() - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return - - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) - - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ - - def __ne__(self, other): - return not (self == other) - -class getPackageOrder_result: +class getPackageOrder_result(TBase): """ Attributes: - success """ + __slots__ = [ + 'success', + ] + thrift_spec = ( (0, TType.MAP, 'success', (TType.I16,None,TType.I32,None), None, ), # 0 ) @@ -7579,67 +4100,17 @@ class getPackageOrder_result: def __init__(self, success=None,): self.success = success - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - if fid == 0: - if ftype == TType.MAP: - self.success = {} - (_ktype172, _vtype173, _size171 ) = iprot.readMapBegin() - for _i175 in xrange(_size171): - _key176 = iprot.readI16(); - _val177 = iprot.readI32(); - self.success[_key176] = _val177 - iprot.readMapEnd() - else: - iprot.skip(ftype) - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('getPackageOrder_result') - if self.success != None: - oprot.writeFieldBegin('success', TType.MAP, 0) - oprot.writeMapBegin(TType.I16, TType.I32, len(self.success)) - for kiter178,viter179 in self.success.items(): - oprot.writeI16(kiter178) - oprot.writeI32(viter179) - oprot.writeMapEnd() - oprot.writeFieldEnd() - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return - - - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ - - def __ne__(self, other): - return not (self == other) - -class getFileOrder_args: +class getFileOrder_args(TBase): """ Attributes: - pid """ + __slots__ = [ + 'pid', + ] + thrift_spec = ( None, # 0 (1, TType.I32, 'pid', None, None, ), # 1 @@ -7648,57 +4119,17 @@ class getFileOrder_args: def __init__(self, pid=None,): self.pid = pid - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - if fid == 1: - if ftype == TType.I32: - self.pid = iprot.readI32(); - else: - iprot.skip(ftype) - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('getFileOrder_args') - if self.pid != None: - oprot.writeFieldBegin('pid', TType.I32, 1) - oprot.writeI32(self.pid) - oprot.writeFieldEnd() - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return - - - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) - - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ - - def __ne__(self, other): - return not (self == other) -class getFileOrder_result: +class getFileOrder_result(TBase): """ Attributes: - success """ + __slots__ = [ + 'success', + ] + thrift_spec = ( (0, TType.MAP, 'success', (TType.I16,None,TType.I32,None), None, ), # 0 ) @@ -7706,108 +4137,26 @@ class getFileOrder_result: def __init__(self, success=None,): self.success = success - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - if fid == 0: - if ftype == TType.MAP: - self.success = {} - (_ktype181, _vtype182, _size180 ) = iprot.readMapBegin() - for _i184 in xrange(_size180): - _key185 = iprot.readI16(); - _val186 = iprot.readI32(); - self.success[_key185] = _val186 - iprot.readMapEnd() - else: - iprot.skip(ftype) - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('getFileOrder_result') - if self.success != None: - oprot.writeFieldBegin('success', TType.MAP, 0) - oprot.writeMapBegin(TType.I16, TType.I32, len(self.success)) - for kiter187,viter188 in self.success.items(): - oprot.writeI16(kiter187) - oprot.writeI32(viter188) - oprot.writeMapEnd() - oprot.writeFieldEnd() - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return - - - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ +class isCaptchaWaiting_args(TBase): - def __ne__(self, other): - return not (self == other) - -class isCaptchaWaiting_args: + __slots__ = [ + ] thrift_spec = ( ) - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('isCaptchaWaiting_args') - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return - - - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) - - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ - def __ne__(self, other): - return not (self == other) - -class isCaptchaWaiting_result: +class isCaptchaWaiting_result(TBase): """ Attributes: - success """ + __slots__ = [ + 'success', + ] + thrift_spec = ( (0, TType.BOOL, 'success', None, None, ), # 0 ) @@ -7815,57 +4164,17 @@ class isCaptchaWaiting_result: def __init__(self, success=None,): self.success = success - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - if fid == 0: - if ftype == TType.BOOL: - self.success = iprot.readBool(); - else: - iprot.skip(ftype) - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('isCaptchaWaiting_result') - if self.success != None: - oprot.writeFieldBegin('success', TType.BOOL, 0) - oprot.writeBool(self.success) - oprot.writeFieldEnd() - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return - - - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ - - def __ne__(self, other): - return not (self == other) - -class getCaptchaTask_args: +class getCaptchaTask_args(TBase): """ Attributes: - exclusive """ + __slots__ = [ + 'exclusive', + ] + thrift_spec = ( None, # 0 (1, TType.BOOL, 'exclusive', None, None, ), # 1 @@ -7874,57 +4183,17 @@ class getCaptchaTask_args: def __init__(self, exclusive=None,): self.exclusive = exclusive - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - if fid == 1: - if ftype == TType.BOOL: - self.exclusive = iprot.readBool(); - else: - iprot.skip(ftype) - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('getCaptchaTask_args') - if self.exclusive != None: - oprot.writeFieldBegin('exclusive', TType.BOOL, 1) - oprot.writeBool(self.exclusive) - oprot.writeFieldEnd() - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return - - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) - - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ - - def __ne__(self, other): - return not (self == other) - -class getCaptchaTask_result: +class getCaptchaTask_result(TBase): """ Attributes: - success """ + __slots__ = [ + 'success', + ] + thrift_spec = ( (0, TType.STRUCT, 'success', (CaptchaTask, CaptchaTask.thrift_spec), None, ), # 0 ) @@ -7932,58 +4201,17 @@ class getCaptchaTask_result: def __init__(self, success=None,): self.success = success - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - if fid == 0: - if ftype == TType.STRUCT: - self.success = CaptchaTask() - self.success.read(iprot) - else: - iprot.skip(ftype) - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('getCaptchaTask_result') - if self.success != None: - oprot.writeFieldBegin('success', TType.STRUCT, 0) - self.success.write(oprot) - oprot.writeFieldEnd() - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return - - - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) - - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ - def __ne__(self, other): - return not (self == other) - -class getCaptchaTaskStatus_args: +class getCaptchaTaskStatus_args(TBase): """ Attributes: - tid """ + __slots__ = [ + 'tid', + ] + thrift_spec = ( None, # 0 (1, TType.I32, 'tid', None, None, ), # 1 @@ -7992,57 +4220,17 @@ class getCaptchaTaskStatus_args: def __init__(self, tid=None,): self.tid = tid - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - if fid == 1: - if ftype == TType.I32: - self.tid = iprot.readI32(); - else: - iprot.skip(ftype) - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('getCaptchaTaskStatus_args') - if self.tid != None: - oprot.writeFieldBegin('tid', TType.I32, 1) - oprot.writeI32(self.tid) - oprot.writeFieldEnd() - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return - - - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ - - def __ne__(self, other): - return not (self == other) - -class getCaptchaTaskStatus_result: +class getCaptchaTaskStatus_result(TBase): """ Attributes: - success """ + __slots__ = [ + 'success', + ] + thrift_spec = ( (0, TType.STRING, 'success', None, None, ), # 0 ) @@ -8050,58 +4238,19 @@ class getCaptchaTaskStatus_result: def __init__(self, success=None,): self.success = success - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - if fid == 0: - if ftype == TType.STRING: - self.success = iprot.readString(); - else: - iprot.skip(ftype) - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('getCaptchaTaskStatus_result') - if self.success != None: - oprot.writeFieldBegin('success', TType.STRING, 0) - oprot.writeString(self.success) - oprot.writeFieldEnd() - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return - - - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) - - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ - - def __ne__(self, other): - return not (self == other) -class setCaptchaResult_args: +class setCaptchaResult_args(TBase): """ Attributes: - tid - result """ + __slots__ = [ + 'tid', + 'result', + ] + thrift_spec = ( None, # 0 (1, TType.I32, 'tid', None, None, ), # 1 @@ -8112,107 +4261,26 @@ class setCaptchaResult_args: self.tid = tid self.result = result - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - if fid == 1: - if ftype == TType.I32: - self.tid = iprot.readI32(); - else: - iprot.skip(ftype) - elif fid == 2: - if ftype == TType.STRING: - self.result = iprot.readString(); - else: - iprot.skip(ftype) - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('setCaptchaResult_args') - if self.tid != None: - oprot.writeFieldBegin('tid', TType.I32, 1) - oprot.writeI32(self.tid) - oprot.writeFieldEnd() - if self.result != None: - oprot.writeFieldBegin('result', TType.STRING, 2) - oprot.writeString(self.result) - oprot.writeFieldEnd() - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return - - - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ +class setCaptchaResult_result(TBase): - def __ne__(self, other): - return not (self == other) - -class setCaptchaResult_result: + __slots__ = [ + ] thrift_spec = ( ) - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('setCaptchaResult_result') - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return - - - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) - - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ - def __ne__(self, other): - return not (self == other) - -class getEvents_args: +class getEvents_args(TBase): """ Attributes: - uuid """ + __slots__ = [ + 'uuid', + ] + thrift_spec = ( None, # 0 (1, TType.STRING, 'uuid', None, None, ), # 1 @@ -8221,57 +4289,17 @@ class getEvents_args: def __init__(self, uuid=None,): self.uuid = uuid - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - if fid == 1: - if ftype == TType.STRING: - self.uuid = iprot.readString(); - else: - iprot.skip(ftype) - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('getEvents_args') - if self.uuid != None: - oprot.writeFieldBegin('uuid', TType.STRING, 1) - oprot.writeString(self.uuid) - oprot.writeFieldEnd() - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return - - - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ - - def __ne__(self, other): - return not (self == other) - -class getEvents_result: +class getEvents_result(TBase): """ Attributes: - success """ + __slots__ = [ + 'success', + ] + thrift_spec = ( (0, TType.LIST, 'success', (TType.STRUCT,(Event, Event.thrift_spec)), None, ), # 0 ) @@ -8279,66 +4307,17 @@ class getEvents_result: def __init__(self, success=None,): self.success = success - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - if fid == 0: - if ftype == TType.LIST: - self.success = [] - (_etype192, _size189) = iprot.readListBegin() - for _i193 in xrange(_size189): - _elem194 = Event() - _elem194.read(iprot) - self.success.append(_elem194) - iprot.readListEnd() - else: - iprot.skip(ftype) - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('getEvents_result') - if self.success != None: - oprot.writeFieldBegin('success', TType.LIST, 0) - oprot.writeListBegin(TType.STRUCT, len(self.success)) - for iter195 in self.success: - iter195.write(oprot) - oprot.writeListEnd() - oprot.writeFieldEnd() - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return - - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) - - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ - - def __ne__(self, other): - return not (self == other) - -class getAccounts_args: +class getAccounts_args(TBase): """ Attributes: - refresh """ + __slots__ = [ + 'refresh', + ] + thrift_spec = ( None, # 0 (1, TType.BOOL, 'refresh', None, None, ), # 1 @@ -8347,57 +4326,17 @@ class getAccounts_args: def __init__(self, refresh=None,): self.refresh = refresh - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - if fid == 1: - if ftype == TType.BOOL: - self.refresh = iprot.readBool(); - else: - iprot.skip(ftype) - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('getAccounts_args') - if self.refresh != None: - oprot.writeFieldBegin('refresh', TType.BOOL, 1) - oprot.writeBool(self.refresh) - oprot.writeFieldEnd() - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return - - - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) - - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ - def __ne__(self, other): - return not (self == other) - -class getAccounts_result: +class getAccounts_result(TBase): """ Attributes: - success """ + __slots__ = [ + 'success', + ] + thrift_spec = ( (0, TType.LIST, 'success', (TType.STRUCT,(AccountInfo, AccountInfo.thrift_spec)), None, ), # 0 ) @@ -8405,107 +4344,26 @@ class getAccounts_result: def __init__(self, success=None,): self.success = success - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - if fid == 0: - if ftype == TType.LIST: - self.success = [] - (_etype199, _size196) = iprot.readListBegin() - for _i200 in xrange(_size196): - _elem201 = AccountInfo() - _elem201.read(iprot) - self.success.append(_elem201) - iprot.readListEnd() - else: - iprot.skip(ftype) - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('getAccounts_result') - if self.success != None: - oprot.writeFieldBegin('success', TType.LIST, 0) - oprot.writeListBegin(TType.STRUCT, len(self.success)) - for iter202 in self.success: - iter202.write(oprot) - oprot.writeListEnd() - oprot.writeFieldEnd() - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return - - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) +class getAccountTypes_args(TBase): - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ - - def __ne__(self, other): - return not (self == other) - -class getAccountTypes_args: + __slots__ = [ + ] thrift_spec = ( ) - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('getAccountTypes_args') - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return - - - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ - - def __ne__(self, other): - return not (self == other) - -class getAccountTypes_result: +class getAccountTypes_result(TBase): """ Attributes: - success """ + __slots__ = [ + 'success', + ] + thrift_spec = ( (0, TType.LIST, 'success', (TType.STRING,None), None, ), # 0 ) @@ -8513,65 +4371,17 @@ class getAccountTypes_result: def __init__(self, success=None,): self.success = success - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - if fid == 0: - if ftype == TType.LIST: - self.success = [] - (_etype206, _size203) = iprot.readListBegin() - for _i207 in xrange(_size203): - _elem208 = iprot.readString(); - self.success.append(_elem208) - iprot.readListEnd() - else: - iprot.skip(ftype) - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('getAccountTypes_result') - if self.success != None: - oprot.writeFieldBegin('success', TType.LIST, 0) - oprot.writeListBegin(TType.STRING, len(self.success)) - for iter209 in self.success: - oprot.writeString(iter209) - oprot.writeListEnd() - oprot.writeFieldEnd() - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return - - - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) - - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ - def __ne__(self, other): - return not (self == other) - -class updateAccounts_args: +class updateAccounts_args(TBase): """ Attributes: - data """ + __slots__ = [ + 'data', + ] + thrift_spec = ( None, # 0 (1, TType.STRUCT, 'data', (AccountData, AccountData.thrift_spec), None, ), # 1 @@ -8580,100 +4390,28 @@ class updateAccounts_args: def __init__(self, data=None,): self.data = data - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - if fid == 1: - if ftype == TType.STRUCT: - self.data = AccountData() - self.data.read(iprot) - else: - iprot.skip(ftype) - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('updateAccounts_args') - if self.data != None: - oprot.writeFieldBegin('data', TType.STRUCT, 1) - self.data.write(oprot) - oprot.writeFieldEnd() - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return - - - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ +class updateAccounts_result(TBase): - def __ne__(self, other): - return not (self == other) - -class updateAccounts_result: + __slots__ = [ + ] thrift_spec = ( ) - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('updateAccounts_result') - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return - - - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) - - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ - def __ne__(self, other): - return not (self == other) - -class removeAccount_args: +class removeAccount_args(TBase): """ Attributes: - plugin - account """ + __slots__ = [ + 'plugin', + 'account', + ] + thrift_spec = ( None, # 0 (1, TType.STRING, 'plugin', None, None, ), # 1 @@ -8684,108 +4422,28 @@ class removeAccount_args: self.plugin = plugin self.account = account - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - if fid == 1: - if ftype == TType.STRING: - self.plugin = iprot.readString(); - else: - iprot.skip(ftype) - elif fid == 2: - if ftype == TType.STRING: - self.account = iprot.readString(); - else: - iprot.skip(ftype) - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('removeAccount_args') - if self.plugin != None: - oprot.writeFieldBegin('plugin', TType.STRING, 1) - oprot.writeString(self.plugin) - oprot.writeFieldEnd() - if self.account != None: - oprot.writeFieldBegin('account', TType.STRING, 2) - oprot.writeString(self.account) - oprot.writeFieldEnd() - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return - - - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ +class removeAccount_result(TBase): - def __ne__(self, other): - return not (self == other) - -class removeAccount_result: + __slots__ = [ + ] thrift_spec = ( ) - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('removeAccount_result') - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return - - - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ - - def __ne__(self, other): - return not (self == other) - -class login_args: +class login_args(TBase): """ Attributes: - username - password """ + __slots__ = [ + 'username', + 'password', + ] + thrift_spec = ( None, # 0 (1, TType.STRING, 'username', None, None, ), # 1 @@ -8796,66 +4454,17 @@ class login_args: self.username = username self.password = password - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - if fid == 1: - if ftype == TType.STRING: - self.username = iprot.readString(); - else: - iprot.skip(ftype) - elif fid == 2: - if ftype == TType.STRING: - self.password = iprot.readString(); - else: - iprot.skip(ftype) - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('login_args') - if self.username != None: - oprot.writeFieldBegin('username', TType.STRING, 1) - oprot.writeString(self.username) - oprot.writeFieldEnd() - if self.password != None: - oprot.writeFieldBegin('password', TType.STRING, 2) - oprot.writeString(self.password) - oprot.writeFieldEnd() - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return - - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) - - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ - - def __ne__(self, other): - return not (self == other) - -class login_result: +class login_result(TBase): """ Attributes: - success """ + __slots__ = [ + 'success', + ] + thrift_spec = ( (0, TType.BOOL, 'success', None, None, ), # 0 ) @@ -8863,58 +4472,19 @@ class login_result: def __init__(self, success=None,): self.success = success - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - if fid == 0: - if ftype == TType.BOOL: - self.success = iprot.readBool(); - else: - iprot.skip(ftype) - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('login_result') - if self.success != None: - oprot.writeFieldBegin('success', TType.BOOL, 0) - oprot.writeBool(self.success) - oprot.writeFieldEnd() - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return - - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) - - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ - - def __ne__(self, other): - return not (self == other) - -class getUserData_args: +class getUserData_args(TBase): """ Attributes: - username - password """ + __slots__ = [ + 'username', + 'password', + ] + thrift_spec = ( None, # 0 (1, TType.STRING, 'username', None, None, ), # 1 @@ -8925,66 +4495,17 @@ class getUserData_args: self.username = username self.password = password - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - if fid == 1: - if ftype == TType.STRING: - self.username = iprot.readString(); - else: - iprot.skip(ftype) - elif fid == 2: - if ftype == TType.STRING: - self.password = iprot.readString(); - else: - iprot.skip(ftype) - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('getUserData_args') - if self.username != None: - oprot.writeFieldBegin('username', TType.STRING, 1) - oprot.writeString(self.username) - oprot.writeFieldEnd() - if self.password != None: - oprot.writeFieldBegin('password', TType.STRING, 2) - oprot.writeString(self.password) - oprot.writeFieldEnd() - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return - - - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ - - def __ne__(self, other): - return not (self == other) - -class getUserData_result: +class getUserData_result(TBase): """ Attributes: - success """ + __slots__ = [ + 'success', + ] + thrift_spec = ( (0, TType.STRUCT, 'success', (UserData, UserData.thrift_spec), None, ), # 0 ) @@ -8992,99 +4513,26 @@ class getUserData_result: def __init__(self, success=None,): self.success = success - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - if fid == 0: - if ftype == TType.STRUCT: - self.success = UserData() - self.success.read(iprot) - else: - iprot.skip(ftype) - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('getUserData_result') - if self.success != None: - oprot.writeFieldBegin('success', TType.STRUCT, 0) - self.success.write(oprot) - oprot.writeFieldEnd() - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return - - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) +class getServices_args(TBase): - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ - - def __ne__(self, other): - return not (self == other) - -class getServices_args: + __slots__ = [ + ] thrift_spec = ( ) - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('getServices_args') - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return - - - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ - - def __ne__(self, other): - return not (self == other) - -class getServices_result: +class getServices_result(TBase): """ Attributes: - success """ + __slots__ = [ + 'success', + ] + thrift_spec = ( (0, TType.MAP, 'success', (TType.STRING,None,TType.STRUCT,(ServiceInfo, ServiceInfo.thrift_spec)), None, ), # 0 ) @@ -9092,69 +4540,19 @@ class getServices_result: def __init__(self, success=None,): self.success = success - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - if fid == 0: - if ftype == TType.MAP: - self.success = {} - (_ktype211, _vtype212, _size210 ) = iprot.readMapBegin() - for _i214 in xrange(_size210): - _key215 = iprot.readString(); - _val216 = ServiceInfo() - _val216.read(iprot) - self.success[_key215] = _val216 - iprot.readMapEnd() - else: - iprot.skip(ftype) - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('getServices_result') - if self.success != None: - oprot.writeFieldBegin('success', TType.MAP, 0) - oprot.writeMapBegin(TType.STRING, TType.STRUCT, len(self.success)) - for kiter217,viter218 in self.success.items(): - oprot.writeString(kiter217) - viter218.write(oprot) - oprot.writeMapEnd() - oprot.writeFieldEnd() - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return - - - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) - - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ - - def __ne__(self, other): - return not (self == other) -class hasService_args: +class hasService_args(TBase): """ Attributes: - plugin - func """ + __slots__ = [ + 'plugin', + 'func', + ] + thrift_spec = ( None, # 0 (1, TType.STRING, 'plugin', None, None, ), # 1 @@ -9165,66 +4563,17 @@ class hasService_args: self.plugin = plugin self.func = func - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - if fid == 1: - if ftype == TType.STRING: - self.plugin = iprot.readString(); - else: - iprot.skip(ftype) - elif fid == 2: - if ftype == TType.STRING: - self.func = iprot.readString(); - else: - iprot.skip(ftype) - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('hasService_args') - if self.plugin != None: - oprot.writeFieldBegin('plugin', TType.STRING, 1) - oprot.writeString(self.plugin) - oprot.writeFieldEnd() - if self.func != None: - oprot.writeFieldBegin('func', TType.STRING, 2) - oprot.writeString(self.func) - oprot.writeFieldEnd() - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return - - - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ - - def __ne__(self, other): - return not (self == other) - -class hasService_result: +class hasService_result(TBase): """ Attributes: - success """ + __slots__ = [ + 'success', + ] + thrift_spec = ( (0, TType.BOOL, 'success', None, None, ), # 0 ) @@ -9232,57 +4581,17 @@ class hasService_result: def __init__(self, success=None,): self.success = success - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - if fid == 0: - if ftype == TType.BOOL: - self.success = iprot.readBool(); - else: - iprot.skip(ftype) - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('hasService_result') - if self.success != None: - oprot.writeFieldBegin('success', TType.BOOL, 0) - oprot.writeBool(self.success) - oprot.writeFieldEnd() - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return - - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) - - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ - - def __ne__(self, other): - return not (self == other) - -class call_args: +class call_args(TBase): """ Attributes: - info """ + __slots__ = [ + 'info', + ] + thrift_spec = ( None, # 0 (1, TType.STRUCT, 'info', (ServiceCall, ServiceCall.thrift_spec), None, ), # 1 @@ -9291,53 +4600,8 @@ class call_args: def __init__(self, info=None,): self.info = info - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - if fid == 1: - if ftype == TType.STRUCT: - self.info = ServiceCall() - self.info.read(iprot) - else: - iprot.skip(ftype) - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('call_args') - if self.info != None: - oprot.writeFieldBegin('info', TType.STRUCT, 1) - self.info.write(oprot) - oprot.writeFieldEnd() - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return - - - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) - - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ - def __ne__(self, other): - return not (self == other) - -class call_result: +class call_result(TBase): """ Attributes: - success @@ -9345,6 +4609,12 @@ class call_result: - e """ + __slots__ = [ + 'success', + 'ex', + 'e', + ] + thrift_spec = ( (0, TType.STRING, 'success', None, None, ), # 0 (1, TType.STRUCT, 'ex', (ServiceDoesNotExists, ServiceDoesNotExists.thrift_spec), None, ), # 1 @@ -9356,67 +4626,3 @@ class call_result: self.ex = ex self.e = e - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - if fid == 0: - if ftype == TType.STRING: - self.success = iprot.readString(); - else: - iprot.skip(ftype) - elif fid == 1: - if ftype == TType.STRUCT: - self.ex = ServiceDoesNotExists() - self.ex.read(iprot) - else: - iprot.skip(ftype) - elif fid == 2: - if ftype == TType.STRUCT: - self.e = ServiceException() - self.e.read(iprot) - else: - iprot.skip(ftype) - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('call_result') - if self.success != None: - oprot.writeFieldBegin('success', TType.STRING, 0) - oprot.writeString(self.success) - oprot.writeFieldEnd() - if self.ex != None: - oprot.writeFieldBegin('ex', TType.STRUCT, 1) - self.ex.write(oprot) - oprot.writeFieldEnd() - if self.e != None: - oprot.writeFieldBegin('e', TType.STRUCT, 2) - self.e.write(oprot) - oprot.writeFieldEnd() - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return - - - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) - - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ - - def __ne__(self, other): - return not (self == other) diff --git a/module/remote/thriftbackend/thriftgen/pyload/constants.py b/module/remote/thriftbackend/thriftgen/pyload/constants.py index 2f17ec34f..7c0918a6d 100644 --- a/module/remote/thriftbackend/thriftgen/pyload/constants.py +++ b/module/remote/thriftbackend/thriftgen/pyload/constants.py @@ -1,9 +1,11 @@ # -# Autogenerated by Thrift +# Autogenerated by Thrift Compiler (0.7.0-dev) # # DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING # +# options string: py:slots,dynamic +# -from thrift.Thrift import * +from thrift.Thrift import TType, TMessageType from ttypes import * diff --git a/module/remote/thriftbackend/thriftgen/pyload/ttypes.py b/module/remote/thriftbackend/thriftgen/pyload/ttypes.py index 6fec5a405..d91aaaa33 100644 --- a/module/remote/thriftbackend/thriftgen/pyload/ttypes.py +++ b/module/remote/thriftbackend/thriftgen/pyload/ttypes.py @@ -1,20 +1,17 @@ # -# Autogenerated by Thrift +# Autogenerated by Thrift Compiler (0.7.0-dev) # # DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING # +# options string: py:slots,dynamic +# -from thrift.Thrift import * +from thrift.Thrift import TType, TMessageType -from thrift.transport import TTransport -from thrift.protocol import TBinaryProtocol, TProtocol -try: - from thrift.protocol import fastbinary -except: - fastbinary = None +from thrift.protocol.TBase import TBase, TExceptionBase -class DownloadStatus: +class DownloadStatus(TBase): Finished = 0 Offline = 1 Online = 2 @@ -67,7 +64,7 @@ class DownloadStatus: "Unknown": 14, } -class Destination: +class Destination(TBase): Queue = 0 Collector = 1 @@ -81,7 +78,7 @@ class Destination: "Collector": 1, } -class ElementType: +class ElementType(TBase): Package = 0 File = 1 @@ -96,7 +93,7 @@ class ElementType: } -class DownloadInfo: +class DownloadInfo(TBase): """ Attributes: - fid @@ -115,6 +112,23 @@ class DownloadInfo: - packageID """ + __slots__ = [ + 'fid', + 'name', + 'speed', + 'eta', + 'format_eta', + 'bleft', + 'size', + 'format_size', + 'percent', + 'status', + 'statusmsg', + 'format_wait', + 'wait_until', + 'packageID', + ] + thrift_spec = ( None, # 0 (1, TType.I32, 'fid', None, None, ), # 1 @@ -149,169 +163,8 @@ class DownloadInfo: self.wait_until = wait_until self.packageID = packageID - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - if fid == 1: - if ftype == TType.I32: - self.fid = iprot.readI32(); - else: - iprot.skip(ftype) - elif fid == 2: - if ftype == TType.STRING: - self.name = iprot.readString(); - else: - iprot.skip(ftype) - elif fid == 3: - if ftype == TType.I64: - self.speed = iprot.readI64(); - else: - iprot.skip(ftype) - elif fid == 4: - if ftype == TType.I32: - self.eta = iprot.readI32(); - else: - iprot.skip(ftype) - elif fid == 5: - if ftype == TType.STRING: - self.format_eta = iprot.readString(); - else: - iprot.skip(ftype) - elif fid == 6: - if ftype == TType.I64: - self.bleft = iprot.readI64(); - else: - iprot.skip(ftype) - elif fid == 7: - if ftype == TType.I64: - self.size = iprot.readI64(); - else: - iprot.skip(ftype) - elif fid == 8: - if ftype == TType.STRING: - self.format_size = iprot.readString(); - else: - iprot.skip(ftype) - elif fid == 9: - if ftype == TType.BYTE: - self.percent = iprot.readByte(); - else: - iprot.skip(ftype) - elif fid == 10: - if ftype == TType.I32: - self.status = iprot.readI32(); - else: - iprot.skip(ftype) - elif fid == 11: - if ftype == TType.STRING: - self.statusmsg = iprot.readString(); - else: - iprot.skip(ftype) - elif fid == 12: - if ftype == TType.STRING: - self.format_wait = iprot.readString(); - else: - iprot.skip(ftype) - elif fid == 13: - if ftype == TType.I64: - self.wait_until = iprot.readI64(); - else: - iprot.skip(ftype) - elif fid == 14: - if ftype == TType.I32: - self.packageID = iprot.readI32(); - else: - iprot.skip(ftype) - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('DownloadInfo') - if self.fid != None: - oprot.writeFieldBegin('fid', TType.I32, 1) - oprot.writeI32(self.fid) - oprot.writeFieldEnd() - if self.name != None: - oprot.writeFieldBegin('name', TType.STRING, 2) - oprot.writeString(self.name) - oprot.writeFieldEnd() - if self.speed != None: - oprot.writeFieldBegin('speed', TType.I64, 3) - oprot.writeI64(self.speed) - oprot.writeFieldEnd() - if self.eta != None: - oprot.writeFieldBegin('eta', TType.I32, 4) - oprot.writeI32(self.eta) - oprot.writeFieldEnd() - if self.format_eta != None: - oprot.writeFieldBegin('format_eta', TType.STRING, 5) - oprot.writeString(self.format_eta) - oprot.writeFieldEnd() - if self.bleft != None: - oprot.writeFieldBegin('bleft', TType.I64, 6) - oprot.writeI64(self.bleft) - oprot.writeFieldEnd() - if self.size != None: - oprot.writeFieldBegin('size', TType.I64, 7) - oprot.writeI64(self.size) - oprot.writeFieldEnd() - if self.format_size != None: - oprot.writeFieldBegin('format_size', TType.STRING, 8) - oprot.writeString(self.format_size) - oprot.writeFieldEnd() - if self.percent != None: - oprot.writeFieldBegin('percent', TType.BYTE, 9) - oprot.writeByte(self.percent) - oprot.writeFieldEnd() - if self.status != None: - oprot.writeFieldBegin('status', TType.I32, 10) - oprot.writeI32(self.status) - oprot.writeFieldEnd() - if self.statusmsg != None: - oprot.writeFieldBegin('statusmsg', TType.STRING, 11) - oprot.writeString(self.statusmsg) - oprot.writeFieldEnd() - if self.format_wait != None: - oprot.writeFieldBegin('format_wait', TType.STRING, 12) - oprot.writeString(self.format_wait) - oprot.writeFieldEnd() - if self.wait_until != None: - oprot.writeFieldBegin('wait_until', TType.I64, 13) - oprot.writeI64(self.wait_until) - oprot.writeFieldEnd() - if self.packageID != None: - oprot.writeFieldBegin('packageID', TType.I32, 14) - oprot.writeI32(self.packageID) - oprot.writeFieldEnd() - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return - - - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) - - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ - - def __ne__(self, other): - return not (self == other) - -class ServerStatus: + +class ServerStatus(TBase): """ Attributes: - pause @@ -323,6 +176,16 @@ class ServerStatus: - reconnect """ + __slots__ = [ + 'pause', + 'active', + 'queue', + 'total', + 'speed', + 'download', + 'reconnect', + ] + thrift_spec = ( None, # 0 (1, TType.BOOL, 'pause', None, None, ), # 1 @@ -343,106 +206,8 @@ class ServerStatus: self.download = download self.reconnect = reconnect - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - if fid == 1: - if ftype == TType.BOOL: - self.pause = iprot.readBool(); - else: - iprot.skip(ftype) - elif fid == 2: - if ftype == TType.I16: - self.active = iprot.readI16(); - else: - iprot.skip(ftype) - elif fid == 3: - if ftype == TType.I16: - self.queue = iprot.readI16(); - else: - iprot.skip(ftype) - elif fid == 4: - if ftype == TType.I16: - self.total = iprot.readI16(); - else: - iprot.skip(ftype) - elif fid == 5: - if ftype == TType.I32: - self.speed = iprot.readI32(); - else: - iprot.skip(ftype) - elif fid == 6: - if ftype == TType.BOOL: - self.download = iprot.readBool(); - else: - iprot.skip(ftype) - elif fid == 7: - if ftype == TType.BOOL: - self.reconnect = iprot.readBool(); - else: - iprot.skip(ftype) - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('ServerStatus') - if self.pause != None: - oprot.writeFieldBegin('pause', TType.BOOL, 1) - oprot.writeBool(self.pause) - oprot.writeFieldEnd() - if self.active != None: - oprot.writeFieldBegin('active', TType.I16, 2) - oprot.writeI16(self.active) - oprot.writeFieldEnd() - if self.queue != None: - oprot.writeFieldBegin('queue', TType.I16, 3) - oprot.writeI16(self.queue) - oprot.writeFieldEnd() - if self.total != None: - oprot.writeFieldBegin('total', TType.I16, 4) - oprot.writeI16(self.total) - oprot.writeFieldEnd() - if self.speed != None: - oprot.writeFieldBegin('speed', TType.I32, 5) - oprot.writeI32(self.speed) - oprot.writeFieldEnd() - if self.download != None: - oprot.writeFieldBegin('download', TType.BOOL, 6) - oprot.writeBool(self.download) - oprot.writeFieldEnd() - if self.reconnect != None: - oprot.writeFieldBegin('reconnect', TType.BOOL, 7) - oprot.writeBool(self.reconnect) - oprot.writeFieldEnd() - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return - - - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) - - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ - - def __ne__(self, other): - return not (self == other) - -class ConfigItem: + +class ConfigItem(TBase): """ Attributes: - name @@ -451,6 +216,13 @@ class ConfigItem: - type """ + __slots__ = [ + 'name', + 'description', + 'value', + 'type', + ] + thrift_spec = ( None, # 0 (1, TType.STRING, 'name', None, None, ), # 1 @@ -465,79 +237,8 @@ class ConfigItem: self.value = value self.type = type - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - if fid == 1: - if ftype == TType.STRING: - self.name = iprot.readString(); - else: - iprot.skip(ftype) - elif fid == 2: - if ftype == TType.STRING: - self.description = iprot.readString(); - else: - iprot.skip(ftype) - elif fid == 3: - if ftype == TType.STRING: - self.value = iprot.readString(); - else: - iprot.skip(ftype) - elif fid == 4: - if ftype == TType.STRING: - self.type = iprot.readString(); - else: - iprot.skip(ftype) - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('ConfigItem') - if self.name != None: - oprot.writeFieldBegin('name', TType.STRING, 1) - oprot.writeString(self.name) - oprot.writeFieldEnd() - if self.description != None: - oprot.writeFieldBegin('description', TType.STRING, 2) - oprot.writeString(self.description) - oprot.writeFieldEnd() - if self.value != None: - oprot.writeFieldBegin('value', TType.STRING, 3) - oprot.writeString(self.value) - oprot.writeFieldEnd() - if self.type != None: - oprot.writeFieldBegin('type', TType.STRING, 4) - oprot.writeString(self.type) - oprot.writeFieldEnd() - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return - - - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) - - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ - - def __ne__(self, other): - return not (self == other) - -class ConfigSection: + +class ConfigSection(TBase): """ Attributes: - name @@ -545,6 +246,12 @@ class ConfigSection: - items """ + __slots__ = [ + 'name', + 'description', + 'items', + ] + thrift_spec = ( None, # 0 (1, TType.STRING, 'name', None, None, ), # 1 @@ -557,79 +264,8 @@ class ConfigSection: self.description = description self.items = items - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - if fid == 1: - if ftype == TType.STRING: - self.name = iprot.readString(); - else: - iprot.skip(ftype) - elif fid == 2: - if ftype == TType.STRING: - self.description = iprot.readString(); - else: - iprot.skip(ftype) - elif fid == 3: - if ftype == TType.LIST: - self.items = [] - (_etype3, _size0) = iprot.readListBegin() - for _i4 in xrange(_size0): - _elem5 = ConfigItem() - _elem5.read(iprot) - self.items.append(_elem5) - iprot.readListEnd() - else: - iprot.skip(ftype) - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('ConfigSection') - if self.name != None: - oprot.writeFieldBegin('name', TType.STRING, 1) - oprot.writeString(self.name) - oprot.writeFieldEnd() - if self.description != None: - oprot.writeFieldBegin('description', TType.STRING, 2) - oprot.writeString(self.description) - oprot.writeFieldEnd() - if self.items != None: - oprot.writeFieldBegin('items', TType.LIST, 3) - oprot.writeListBegin(TType.STRUCT, len(self.items)) - for iter6 in self.items: - iter6.write(oprot) - oprot.writeListEnd() - oprot.writeFieldEnd() - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return - - - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) - - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ - - def __ne__(self, other): - return not (self == other) - -class FileData: + +class FileData(TBase): """ Attributes: - fid @@ -646,6 +282,21 @@ class FileData: - progress """ + __slots__ = [ + 'fid', + 'url', + 'name', + 'plugin', + 'size', + 'format_size', + 'status', + 'statusmsg', + 'packageID', + 'error', + 'order', + 'progress', + ] + thrift_spec = ( None, # 0 (1, TType.I32, 'fid', None, None, ), # 1 @@ -676,151 +327,8 @@ class FileData: self.order = order self.progress = progress - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - if fid == 1: - if ftype == TType.I32: - self.fid = iprot.readI32(); - else: - iprot.skip(ftype) - elif fid == 2: - if ftype == TType.STRING: - self.url = iprot.readString(); - else: - iprot.skip(ftype) - elif fid == 3: - if ftype == TType.STRING: - self.name = iprot.readString(); - else: - iprot.skip(ftype) - elif fid == 4: - if ftype == TType.STRING: - self.plugin = iprot.readString(); - else: - iprot.skip(ftype) - elif fid == 5: - if ftype == TType.I64: - self.size = iprot.readI64(); - else: - iprot.skip(ftype) - elif fid == 6: - if ftype == TType.STRING: - self.format_size = iprot.readString(); - else: - iprot.skip(ftype) - elif fid == 7: - if ftype == TType.I32: - self.status = iprot.readI32(); - else: - iprot.skip(ftype) - elif fid == 8: - if ftype == TType.STRING: - self.statusmsg = iprot.readString(); - else: - iprot.skip(ftype) - elif fid == 9: - if ftype == TType.I32: - self.packageID = iprot.readI32(); - else: - iprot.skip(ftype) - elif fid == 10: - if ftype == TType.STRING: - self.error = iprot.readString(); - else: - iprot.skip(ftype) - elif fid == 11: - if ftype == TType.I16: - self.order = iprot.readI16(); - else: - iprot.skip(ftype) - elif fid == 12: - if ftype == TType.BYTE: - self.progress = iprot.readByte(); - else: - iprot.skip(ftype) - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('FileData') - if self.fid != None: - oprot.writeFieldBegin('fid', TType.I32, 1) - oprot.writeI32(self.fid) - oprot.writeFieldEnd() - if self.url != None: - oprot.writeFieldBegin('url', TType.STRING, 2) - oprot.writeString(self.url) - oprot.writeFieldEnd() - if self.name != None: - oprot.writeFieldBegin('name', TType.STRING, 3) - oprot.writeString(self.name) - oprot.writeFieldEnd() - if self.plugin != None: - oprot.writeFieldBegin('plugin', TType.STRING, 4) - oprot.writeString(self.plugin) - oprot.writeFieldEnd() - if self.size != None: - oprot.writeFieldBegin('size', TType.I64, 5) - oprot.writeI64(self.size) - oprot.writeFieldEnd() - if self.format_size != None: - oprot.writeFieldBegin('format_size', TType.STRING, 6) - oprot.writeString(self.format_size) - oprot.writeFieldEnd() - if self.status != None: - oprot.writeFieldBegin('status', TType.I32, 7) - oprot.writeI32(self.status) - oprot.writeFieldEnd() - if self.statusmsg != None: - oprot.writeFieldBegin('statusmsg', TType.STRING, 8) - oprot.writeString(self.statusmsg) - oprot.writeFieldEnd() - if self.packageID != None: - oprot.writeFieldBegin('packageID', TType.I32, 9) - oprot.writeI32(self.packageID) - oprot.writeFieldEnd() - if self.error != None: - oprot.writeFieldBegin('error', TType.STRING, 10) - oprot.writeString(self.error) - oprot.writeFieldEnd() - if self.order != None: - oprot.writeFieldBegin('order', TType.I16, 11) - oprot.writeI16(self.order) - oprot.writeFieldEnd() - if self.progress != None: - oprot.writeFieldBegin('progress', TType.BYTE, 12) - oprot.writeByte(self.progress) - oprot.writeFieldEnd() - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return - - - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) - - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ - - def __ne__(self, other): - return not (self == other) - -class PackageData: + +class PackageData(TBase): """ Attributes: - pid @@ -834,6 +342,18 @@ class PackageData: - links """ + __slots__ = [ + 'pid', + 'name', + 'folder', + 'site', + 'password', + 'dest', + 'order', + 'priority', + 'links', + ] + thrift_spec = ( None, # 0 (1, TType.I32, 'pid', None, None, ), # 1 @@ -858,133 +378,8 @@ class PackageData: self.priority = priority self.links = links - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - if fid == 1: - if ftype == TType.I32: - self.pid = iprot.readI32(); - else: - iprot.skip(ftype) - elif fid == 2: - if ftype == TType.STRING: - self.name = iprot.readString(); - else: - iprot.skip(ftype) - elif fid == 3: - if ftype == TType.STRING: - self.folder = iprot.readString(); - else: - iprot.skip(ftype) - elif fid == 4: - if ftype == TType.STRING: - self.site = iprot.readString(); - else: - iprot.skip(ftype) - elif fid == 5: - if ftype == TType.STRING: - self.password = iprot.readString(); - else: - iprot.skip(ftype) - elif fid == 6: - if ftype == TType.I32: - self.dest = iprot.readI32(); - else: - iprot.skip(ftype) - elif fid == 7: - if ftype == TType.I16: - self.order = iprot.readI16(); - else: - iprot.skip(ftype) - elif fid == 8: - if ftype == TType.BYTE: - self.priority = iprot.readByte(); - else: - iprot.skip(ftype) - elif fid == 9: - if ftype == TType.LIST: - self.links = [] - (_etype10, _size7) = iprot.readListBegin() - for _i11 in xrange(_size7): - _elem12 = FileData() - _elem12.read(iprot) - self.links.append(_elem12) - iprot.readListEnd() - else: - iprot.skip(ftype) - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('PackageData') - if self.pid != None: - oprot.writeFieldBegin('pid', TType.I32, 1) - oprot.writeI32(self.pid) - oprot.writeFieldEnd() - if self.name != None: - oprot.writeFieldBegin('name', TType.STRING, 2) - oprot.writeString(self.name) - oprot.writeFieldEnd() - if self.folder != None: - oprot.writeFieldBegin('folder', TType.STRING, 3) - oprot.writeString(self.folder) - oprot.writeFieldEnd() - if self.site != None: - oprot.writeFieldBegin('site', TType.STRING, 4) - oprot.writeString(self.site) - oprot.writeFieldEnd() - if self.password != None: - oprot.writeFieldBegin('password', TType.STRING, 5) - oprot.writeString(self.password) - oprot.writeFieldEnd() - if self.dest != None: - oprot.writeFieldBegin('dest', TType.I32, 6) - oprot.writeI32(self.dest) - oprot.writeFieldEnd() - if self.order != None: - oprot.writeFieldBegin('order', TType.I16, 7) - oprot.writeI16(self.order) - oprot.writeFieldEnd() - if self.priority != None: - oprot.writeFieldBegin('priority', TType.BYTE, 8) - oprot.writeByte(self.priority) - oprot.writeFieldEnd() - if self.links != None: - oprot.writeFieldBegin('links', TType.LIST, 9) - oprot.writeListBegin(TType.STRUCT, len(self.links)) - for iter13 in self.links: - iter13.write(oprot) - oprot.writeListEnd() - oprot.writeFieldEnd() - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return - - - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) - - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ - - def __ne__(self, other): - return not (self == other) - -class PackageInfo: + +class PackageInfo(TBase): """ Attributes: - pid @@ -998,6 +393,18 @@ class PackageInfo: - links """ + __slots__ = [ + 'pid', + 'name', + 'folder', + 'site', + 'password', + 'dest', + 'order', + 'priority', + 'links', + ] + thrift_spec = ( None, # 0 (1, TType.I32, 'pid', None, None, ), # 1 @@ -1022,132 +429,8 @@ class PackageInfo: self.priority = priority self.links = links - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - if fid == 1: - if ftype == TType.I32: - self.pid = iprot.readI32(); - else: - iprot.skip(ftype) - elif fid == 2: - if ftype == TType.STRING: - self.name = iprot.readString(); - else: - iprot.skip(ftype) - elif fid == 3: - if ftype == TType.STRING: - self.folder = iprot.readString(); - else: - iprot.skip(ftype) - elif fid == 4: - if ftype == TType.STRING: - self.site = iprot.readString(); - else: - iprot.skip(ftype) - elif fid == 5: - if ftype == TType.STRING: - self.password = iprot.readString(); - else: - iprot.skip(ftype) - elif fid == 6: - if ftype == TType.I32: - self.dest = iprot.readI32(); - else: - iprot.skip(ftype) - elif fid == 7: - if ftype == TType.I16: - self.order = iprot.readI16(); - else: - iprot.skip(ftype) - elif fid == 8: - if ftype == TType.BYTE: - self.priority = iprot.readByte(); - else: - iprot.skip(ftype) - elif fid == 9: - if ftype == TType.LIST: - self.links = [] - (_etype17, _size14) = iprot.readListBegin() - for _i18 in xrange(_size14): - _elem19 = iprot.readI32(); - self.links.append(_elem19) - iprot.readListEnd() - else: - iprot.skip(ftype) - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('PackageInfo') - if self.pid != None: - oprot.writeFieldBegin('pid', TType.I32, 1) - oprot.writeI32(self.pid) - oprot.writeFieldEnd() - if self.name != None: - oprot.writeFieldBegin('name', TType.STRING, 2) - oprot.writeString(self.name) - oprot.writeFieldEnd() - if self.folder != None: - oprot.writeFieldBegin('folder', TType.STRING, 3) - oprot.writeString(self.folder) - oprot.writeFieldEnd() - if self.site != None: - oprot.writeFieldBegin('site', TType.STRING, 4) - oprot.writeString(self.site) - oprot.writeFieldEnd() - if self.password != None: - oprot.writeFieldBegin('password', TType.STRING, 5) - oprot.writeString(self.password) - oprot.writeFieldEnd() - if self.dest != None: - oprot.writeFieldBegin('dest', TType.I32, 6) - oprot.writeI32(self.dest) - oprot.writeFieldEnd() - if self.order != None: - oprot.writeFieldBegin('order', TType.I16, 7) - oprot.writeI16(self.order) - oprot.writeFieldEnd() - if self.priority != None: - oprot.writeFieldBegin('priority', TType.BYTE, 8) - oprot.writeByte(self.priority) - oprot.writeFieldEnd() - if self.links != None: - oprot.writeFieldBegin('links', TType.LIST, 9) - oprot.writeListBegin(TType.I32, len(self.links)) - for iter20 in self.links: - oprot.writeI32(iter20) - oprot.writeListEnd() - oprot.writeFieldEnd() - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return - - - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) - - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ - - def __ne__(self, other): - return not (self == other) - -class CaptchaTask: + +class CaptchaTask(TBase): """ Attributes: - tid @@ -1156,6 +439,13 @@ class CaptchaTask: - resultType """ + __slots__ = [ + 'tid', + 'data', + 'type', + 'resultType', + ] + thrift_spec = ( None, # 0 (1, TType.I16, 'tid', None, None, ), # 1 @@ -1170,79 +460,8 @@ class CaptchaTask: self.type = type self.resultType = resultType - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - if fid == 1: - if ftype == TType.I16: - self.tid = iprot.readI16(); - else: - iprot.skip(ftype) - elif fid == 2: - if ftype == TType.STRING: - self.data = iprot.readString(); - else: - iprot.skip(ftype) - elif fid == 3: - if ftype == TType.STRING: - self.type = iprot.readString(); - else: - iprot.skip(ftype) - elif fid == 4: - if ftype == TType.STRING: - self.resultType = iprot.readString(); - else: - iprot.skip(ftype) - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('CaptchaTask') - if self.tid != None: - oprot.writeFieldBegin('tid', TType.I16, 1) - oprot.writeI16(self.tid) - oprot.writeFieldEnd() - if self.data != None: - oprot.writeFieldBegin('data', TType.STRING, 2) - oprot.writeString(self.data) - oprot.writeFieldEnd() - if self.type != None: - oprot.writeFieldBegin('type', TType.STRING, 3) - oprot.writeString(self.type) - oprot.writeFieldEnd() - if self.resultType != None: - oprot.writeFieldBegin('resultType', TType.STRING, 4) - oprot.writeString(self.resultType) - oprot.writeFieldEnd() - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return - - - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) - - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ - - def __ne__(self, other): - return not (self == other) - -class Event: + +class Event(TBase): """ Attributes: - event @@ -1251,6 +470,13 @@ class Event: - destination """ + __slots__ = [ + 'event', + 'id', + 'type', + 'destination', + ] + thrift_spec = ( None, # 0 (1, TType.STRING, 'event', None, None, ), # 1 @@ -1265,79 +491,8 @@ class Event: self.type = type self.destination = destination - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - if fid == 1: - if ftype == TType.STRING: - self.event = iprot.readString(); - else: - iprot.skip(ftype) - elif fid == 2: - if ftype == TType.I32: - self.id = iprot.readI32(); - else: - iprot.skip(ftype) - elif fid == 3: - if ftype == TType.I32: - self.type = iprot.readI32(); - else: - iprot.skip(ftype) - elif fid == 4: - if ftype == TType.I32: - self.destination = iprot.readI32(); - else: - iprot.skip(ftype) - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('Event') - if self.event != None: - oprot.writeFieldBegin('event', TType.STRING, 1) - oprot.writeString(self.event) - oprot.writeFieldEnd() - if self.id != None: - oprot.writeFieldBegin('id', TType.I32, 2) - oprot.writeI32(self.id) - oprot.writeFieldEnd() - if self.type != None: - oprot.writeFieldBegin('type', TType.I32, 3) - oprot.writeI32(self.type) - oprot.writeFieldEnd() - if self.destination != None: - oprot.writeFieldBegin('destination', TType.I32, 4) - oprot.writeI32(self.destination) - oprot.writeFieldEnd() - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return - - - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) - - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ - - def __ne__(self, other): - return not (self == other) - -class UserData: + +class UserData(TBase): """ Attributes: - name @@ -1347,6 +502,14 @@ class UserData: - template """ + __slots__ = [ + 'name', + 'email', + 'role', + 'permission', + 'template', + ] + thrift_spec = ( None, # 0 (1, TType.STRING, 'name', None, None, ), # 1 @@ -1363,88 +526,8 @@ class UserData: self.permission = permission self.template = template - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - if fid == 1: - if ftype == TType.STRING: - self.name = iprot.readString(); - else: - iprot.skip(ftype) - elif fid == 2: - if ftype == TType.STRING: - self.email = iprot.readString(); - else: - iprot.skip(ftype) - elif fid == 3: - if ftype == TType.I32: - self.role = iprot.readI32(); - else: - iprot.skip(ftype) - elif fid == 4: - if ftype == TType.I32: - self.permission = iprot.readI32(); - else: - iprot.skip(ftype) - elif fid == 5: - if ftype == TType.STRING: - self.template = iprot.readString(); - else: - iprot.skip(ftype) - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('UserData') - if self.name != None: - oprot.writeFieldBegin('name', TType.STRING, 1) - oprot.writeString(self.name) - oprot.writeFieldEnd() - if self.email != None: - oprot.writeFieldBegin('email', TType.STRING, 2) - oprot.writeString(self.email) - oprot.writeFieldEnd() - if self.role != None: - oprot.writeFieldBegin('role', TType.I32, 3) - oprot.writeI32(self.role) - oprot.writeFieldEnd() - if self.permission != None: - oprot.writeFieldBegin('permission', TType.I32, 4) - oprot.writeI32(self.permission) - oprot.writeFieldEnd() - if self.template != None: - oprot.writeFieldBegin('template', TType.STRING, 5) - oprot.writeString(self.template) - oprot.writeFieldEnd() - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return - - - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) - - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ - - def __ne__(self, other): - return not (self == other) - -class AccountInfo: + +class AccountInfo(TBase): """ Attributes: - validuntil @@ -1457,6 +540,17 @@ class AccountInfo: - type """ + __slots__ = [ + 'validuntil', + 'login', + 'options', + 'valid', + 'trafficleft', + 'maxtraffic', + 'premium', + 'type', + ] + thrift_spec = ( None, # 0 (1, TType.I64, 'validuntil', None, None, ), # 1 @@ -1479,125 +573,8 @@ class AccountInfo: self.premium = premium self.type = type - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - if fid == 1: - if ftype == TType.I64: - self.validuntil = iprot.readI64(); - else: - iprot.skip(ftype) - elif fid == 2: - if ftype == TType.STRING: - self.login = iprot.readString(); - else: - iprot.skip(ftype) - elif fid == 3: - if ftype == TType.MAP: - self.options = {} - (_ktype22, _vtype23, _size21 ) = iprot.readMapBegin() - for _i25 in xrange(_size21): - _key26 = iprot.readString(); - _val27 = iprot.readString(); - self.options[_key26] = _val27 - iprot.readMapEnd() - else: - iprot.skip(ftype) - elif fid == 4: - if ftype == TType.BOOL: - self.valid = iprot.readBool(); - else: - iprot.skip(ftype) - elif fid == 5: - if ftype == TType.I64: - self.trafficleft = iprot.readI64(); - else: - iprot.skip(ftype) - elif fid == 6: - if ftype == TType.I64: - self.maxtraffic = iprot.readI64(); - else: - iprot.skip(ftype) - elif fid == 7: - if ftype == TType.BOOL: - self.premium = iprot.readBool(); - else: - iprot.skip(ftype) - elif fid == 8: - if ftype == TType.STRING: - self.type = iprot.readString(); - else: - iprot.skip(ftype) - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('AccountInfo') - if self.validuntil != None: - oprot.writeFieldBegin('validuntil', TType.I64, 1) - oprot.writeI64(self.validuntil) - oprot.writeFieldEnd() - if self.login != None: - oprot.writeFieldBegin('login', TType.STRING, 2) - oprot.writeString(self.login) - oprot.writeFieldEnd() - if self.options != None: - oprot.writeFieldBegin('options', TType.MAP, 3) - oprot.writeMapBegin(TType.STRING, TType.STRING, len(self.options)) - for kiter28,viter29 in self.options.items(): - oprot.writeString(kiter28) - oprot.writeString(viter29) - oprot.writeMapEnd() - oprot.writeFieldEnd() - if self.valid != None: - oprot.writeFieldBegin('valid', TType.BOOL, 4) - oprot.writeBool(self.valid) - oprot.writeFieldEnd() - if self.trafficleft != None: - oprot.writeFieldBegin('trafficleft', TType.I64, 5) - oprot.writeI64(self.trafficleft) - oprot.writeFieldEnd() - if self.maxtraffic != None: - oprot.writeFieldBegin('maxtraffic', TType.I64, 6) - oprot.writeI64(self.maxtraffic) - oprot.writeFieldEnd() - if self.premium != None: - oprot.writeFieldBegin('premium', TType.BOOL, 7) - oprot.writeBool(self.premium) - oprot.writeFieldEnd() - if self.type != None: - oprot.writeFieldBegin('type', TType.STRING, 8) - oprot.writeString(self.type) - oprot.writeFieldEnd() - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return - - - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) - - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ - - def __ne__(self, other): - return not (self == other) - -class AccountData: + +class AccountData(TBase): """ Attributes: - type @@ -1606,6 +583,13 @@ class AccountData: - options """ + __slots__ = [ + 'type', + 'login', + 'password', + 'options', + ] + thrift_spec = ( None, # 0 (1, TType.STRING, 'type', None, None, ), # 1 @@ -1620,94 +604,17 @@ class AccountData: self.password = password self.options = options - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - if fid == 1: - if ftype == TType.STRING: - self.type = iprot.readString(); - else: - iprot.skip(ftype) - elif fid == 2: - if ftype == TType.STRING: - self.login = iprot.readString(); - else: - iprot.skip(ftype) - elif fid == 3: - if ftype == TType.STRING: - self.password = iprot.readString(); - else: - iprot.skip(ftype) - elif fid == 4: - if ftype == TType.MAP: - self.options = {} - (_ktype31, _vtype32, _size30 ) = iprot.readMapBegin() - for _i34 in xrange(_size30): - _key35 = iprot.readString(); - _val36 = iprot.readString(); - self.options[_key35] = _val36 - iprot.readMapEnd() - else: - iprot.skip(ftype) - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('AccountData') - if self.type != None: - oprot.writeFieldBegin('type', TType.STRING, 1) - oprot.writeString(self.type) - oprot.writeFieldEnd() - if self.login != None: - oprot.writeFieldBegin('login', TType.STRING, 2) - oprot.writeString(self.login) - oprot.writeFieldEnd() - if self.password != None: - oprot.writeFieldBegin('password', TType.STRING, 3) - oprot.writeString(self.password) - oprot.writeFieldEnd() - if self.options != None: - oprot.writeFieldBegin('options', TType.MAP, 4) - oprot.writeMapBegin(TType.STRING, TType.STRING, len(self.options)) - for kiter37,viter38 in self.options.items(): - oprot.writeString(kiter37) - oprot.writeString(viter38) - oprot.writeMapEnd() - oprot.writeFieldEnd() - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return - - - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) - - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ - - def __ne__(self, other): - return not (self == other) - -class ServiceInfo: + +class ServiceInfo(TBase): """ Attributes: - funcs """ + __slots__ = [ + 'funcs', + ] + thrift_spec = ( None, # 0 (1, TType.MAP, 'funcs', (TType.STRING,None,TType.STRING,None), None, ), # 1 @@ -1716,62 +623,8 @@ class ServiceInfo: def __init__(self, funcs=None,): self.funcs = funcs - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - if fid == 1: - if ftype == TType.MAP: - self.funcs = {} - (_ktype40, _vtype41, _size39 ) = iprot.readMapBegin() - for _i43 in xrange(_size39): - _key44 = iprot.readString(); - _val45 = iprot.readString(); - self.funcs[_key44] = _val45 - iprot.readMapEnd() - else: - iprot.skip(ftype) - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('ServiceInfo') - if self.funcs != None: - oprot.writeFieldBegin('funcs', TType.MAP, 1) - oprot.writeMapBegin(TType.STRING, TType.STRING, len(self.funcs)) - for kiter46,viter47 in self.funcs.items(): - oprot.writeString(kiter46) - oprot.writeString(viter47) - oprot.writeMapEnd() - oprot.writeFieldEnd() - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return - - - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) - - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ - - def __ne__(self, other): - return not (self == other) - -class ServiceCall: + +class ServiceCall(TBase): """ Attributes: - plugin @@ -1780,6 +633,13 @@ class ServiceCall: - parseArguments """ + __slots__ = [ + 'plugin', + 'func', + 'arguments', + 'parseArguments', + ] + thrift_spec = ( None, # 0 (1, TType.STRING, 'plugin', None, None, ), # 1 @@ -1794,92 +654,17 @@ class ServiceCall: self.arguments = arguments self.parseArguments = parseArguments - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - if fid == 1: - if ftype == TType.STRING: - self.plugin = iprot.readString(); - else: - iprot.skip(ftype) - elif fid == 2: - if ftype == TType.STRING: - self.func = iprot.readString(); - else: - iprot.skip(ftype) - elif fid == 3: - if ftype == TType.LIST: - self.arguments = [] - (_etype51, _size48) = iprot.readListBegin() - for _i52 in xrange(_size48): - _elem53 = iprot.readString(); - self.arguments.append(_elem53) - iprot.readListEnd() - else: - iprot.skip(ftype) - elif fid == 4: - if ftype == TType.BOOL: - self.parseArguments = iprot.readBool(); - else: - iprot.skip(ftype) - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('ServiceCall') - if self.plugin != None: - oprot.writeFieldBegin('plugin', TType.STRING, 1) - oprot.writeString(self.plugin) - oprot.writeFieldEnd() - if self.func != None: - oprot.writeFieldBegin('func', TType.STRING, 2) - oprot.writeString(self.func) - oprot.writeFieldEnd() - if self.arguments != None: - oprot.writeFieldBegin('arguments', TType.LIST, 3) - oprot.writeListBegin(TType.STRING, len(self.arguments)) - for iter54 in self.arguments: - oprot.writeString(iter54) - oprot.writeListEnd() - oprot.writeFieldEnd() - if self.parseArguments != None: - oprot.writeFieldBegin('parseArguments', TType.BOOL, 4) - oprot.writeBool(self.parseArguments) - oprot.writeFieldEnd() - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return - - - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) - - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ - - def __ne__(self, other): - return not (self == other) - -class PackageDoesNotExists(Exception): + +class PackageDoesNotExists(TExceptionBase): """ Attributes: - pid """ + __slots__ = [ + 'pid', + ] + thrift_spec = ( None, # 0 (1, TType.I32, 'pid', None, None, ), # 1 @@ -1888,60 +673,20 @@ class PackageDoesNotExists(Exception): def __init__(self, pid=None,): self.pid = pid - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - if fid == 1: - if ftype == TType.I32: - self.pid = iprot.readI32(); - else: - iprot.skip(ftype) - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('PackageDoesNotExists') - if self.pid != None: - oprot.writeFieldBegin('pid', TType.I32, 1) - oprot.writeI32(self.pid) - oprot.writeFieldEnd() - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return - - def __str__(self): return repr(self) - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) - - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ - - def __ne__(self, other): - return not (self == other) -class FileDoesNotExists(Exception): +class FileDoesNotExists(TExceptionBase): """ Attributes: - fid """ + __slots__ = [ + 'fid', + ] + thrift_spec = ( None, # 0 (1, TType.I32, 'fid', None, None, ), # 1 @@ -1950,61 +695,22 @@ class FileDoesNotExists(Exception): def __init__(self, fid=None,): self.fid = fid - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - if fid == 1: - if ftype == TType.I32: - self.fid = iprot.readI32(); - else: - iprot.skip(ftype) - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('FileDoesNotExists') - if self.fid != None: - oprot.writeFieldBegin('fid', TType.I32, 1) - oprot.writeI32(self.fid) - oprot.writeFieldEnd() - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return - - def __str__(self): return repr(self) - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ - - def __ne__(self, other): - return not (self == other) - -class ServiceDoesNotExists(Exception): +class ServiceDoesNotExists(TExceptionBase): """ Attributes: - plugin - func """ + __slots__ = [ + 'plugin', + 'func', + ] + thrift_spec = ( None, # 0 (1, TType.STRING, 'plugin', None, None, ), # 1 @@ -2015,69 +721,20 @@ class ServiceDoesNotExists(Exception): self.plugin = plugin self.func = func - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - if fid == 1: - if ftype == TType.STRING: - self.plugin = iprot.readString(); - else: - iprot.skip(ftype) - elif fid == 2: - if ftype == TType.STRING: - self.func = iprot.readString(); - else: - iprot.skip(ftype) - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('ServiceDoesNotExists') - if self.plugin != None: - oprot.writeFieldBegin('plugin', TType.STRING, 1) - oprot.writeString(self.plugin) - oprot.writeFieldEnd() - if self.func != None: - oprot.writeFieldBegin('func', TType.STRING, 2) - oprot.writeString(self.func) - oprot.writeFieldEnd() - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return - - def __str__(self): return repr(self) - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) - - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ - def __ne__(self, other): - return not (self == other) - -class ServiceException(Exception): +class ServiceException(TExceptionBase): """ Attributes: - msg """ + __slots__ = [ + 'msg', + ] + thrift_spec = ( None, # 0 (1, TType.STRING, 'msg', None, None, ), # 1 @@ -2086,50 +743,6 @@ class ServiceException(Exception): def __init__(self, msg=None,): self.msg = msg - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - if fid == 1: - if ftype == TType.STRING: - self.msg = iprot.readString(); - else: - iprot.skip(ftype) - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('ServiceException') - if self.msg != None: - oprot.writeFieldBegin('msg', TType.STRING, 1) - oprot.writeString(self.msg) - oprot.writeFieldEnd() - oprot.writeFieldStop() - oprot.writeStructEnd() - def validate(self): - return - - def __str__(self): return repr(self) - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) - - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ - - def __ne__(self, other): - return not (self == other) |