1# 2# Autogenerated by Thrift 3# 4# DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING 5# @generated 6# 7 8from __future__ import absolute_import 9import sys 10from thrift.util.Recursive import fix_spec 11from thrift.Thrift import TType, TMessageType, TPriority, TRequestContext, TProcessorEventHandler, TServerInterface, TProcessor, TException, TApplicationException, UnimplementedTypedef 12from thrift.protocol.TProtocol import TProtocolException 13 14 15 16import pprint 17import warnings 18from thrift import Thrift 19from thrift.transport import TTransport 20from thrift.protocol import TBinaryProtocol 21from thrift.protocol import TCompactProtocol 22from thrift.protocol import THeaderProtocol 23fastproto = None 24try: 25 from thrift.protocol import fastproto 26except ImportError: 27 pass 28all_structs = [] 29UTF8STRINGS = bool(0) or sys.version_info.major >= 3 30 31__all__ = ['UTF8STRINGS', 'Foo', 'NegativeId'] 32 33class Foo: 34 """ 35 Attributes: 36 - mymap 37 - myset 38 """ 39 40 thrift_spec = None 41 thrift_field_annotations = None 42 thrift_struct_annotations = None 43 __init__ = None 44 @staticmethod 45 def isUnion(): 46 return False 47 48 def read(self, iprot): 49 if (isinstance(iprot, TBinaryProtocol.TBinaryProtocolAccelerated) or (isinstance(iprot, THeaderProtocol.THeaderProtocolAccelerate) and iprot.get_protocol_id() == THeaderProtocol.THeaderProtocol.T_BINARY_PROTOCOL)) and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastproto is not None: 50 fastproto.decode(self, iprot.trans, [self.__class__, self.thrift_spec, False], utf8strings=UTF8STRINGS, protoid=0) 51 return 52 if (isinstance(iprot, TCompactProtocol.TCompactProtocolAccelerated) or (isinstance(iprot, THeaderProtocol.THeaderProtocolAccelerate) and iprot.get_protocol_id() == THeaderProtocol.THeaderProtocol.T_COMPACT_PROTOCOL)) and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastproto is not None: 53 fastproto.decode(self, iprot.trans, [self.__class__, self.thrift_spec, False], utf8strings=UTF8STRINGS, protoid=2) 54 return 55 iprot.readStructBegin() 56 while True: 57 (fname, ftype, fid) = iprot.readFieldBegin() 58 if ftype == TType.STOP: 59 break 60 if fid == 1: 61 if ftype == TType.MAP: 62 self.mymap = {} 63 (_ktype1, _vtype2, _size0 ) = iprot.readMapBegin() 64 if _size0 >= 0: 65 for _i4 in range(_size0): 66 _key5 = iprot.readString().decode('utf-8') if UTF8STRINGS else iprot.readString() 67 _val6 = iprot.readString().decode('utf-8') if UTF8STRINGS else iprot.readString() 68 self.mymap[_key5] = _val6 69 else: 70 while iprot.peekMap(): 71 _key7 = iprot.readString().decode('utf-8') if UTF8STRINGS else iprot.readString() 72 _val8 = iprot.readString().decode('utf-8') if UTF8STRINGS else iprot.readString() 73 self.mymap[_key7] = _val8 74 iprot.readMapEnd() 75 else: 76 iprot.skip(ftype) 77 elif fid == 2: 78 if ftype == TType.SET: 79 self.myset = set() 80 (_etype12, _size9) = iprot.readSetBegin() 81 if _size9 >= 0: 82 for _i13 in range(_size9): 83 _elem14 = iprot.readString().decode('utf-8') if UTF8STRINGS else iprot.readString() 84 self.myset.add(_elem14) 85 else: 86 while iprot.peekSet(): 87 _elem15 = iprot.readString().decode('utf-8') if UTF8STRINGS else iprot.readString() 88 self.myset.add(_elem15) 89 iprot.readSetEnd() 90 else: 91 iprot.skip(ftype) 92 else: 93 iprot.skip(ftype) 94 iprot.readFieldEnd() 95 iprot.readStructEnd() 96 97 def write(self, oprot): 98 if (isinstance(oprot, TBinaryProtocol.TBinaryProtocolAccelerated) or (isinstance(oprot, THeaderProtocol.THeaderProtocolAccelerate) and oprot.get_protocol_id() == THeaderProtocol.THeaderProtocol.T_BINARY_PROTOCOL)) and self.thrift_spec is not None and fastproto is not None: 99 oprot.trans.write(fastproto.encode(self, [self.__class__, self.thrift_spec, False], utf8strings=UTF8STRINGS, protoid=0)) 100 return 101 if (isinstance(oprot, TCompactProtocol.TCompactProtocolAccelerated) or (isinstance(oprot, THeaderProtocol.THeaderProtocolAccelerate) and oprot.get_protocol_id() == THeaderProtocol.THeaderProtocol.T_COMPACT_PROTOCOL)) and self.thrift_spec is not None and fastproto is not None: 102 oprot.trans.write(fastproto.encode(self, [self.__class__, self.thrift_spec, False], utf8strings=UTF8STRINGS, protoid=2)) 103 return 104 oprot.writeStructBegin('Foo') 105 if self.mymap != None: 106 oprot.writeFieldBegin('mymap', TType.MAP, 1) 107 oprot.writeMapBegin(TType.STRING, TType.STRING, len(self.mymap)) 108 sorted18 = self.mymap.items() 109 sorted18 = sorted(sorted18, key=lambda tuple19: tuple19[0]) 110 for kiter16,viter17 in sorted18: 111 oprot.writeString(kiter16.encode('utf-8')) if UTF8STRINGS and not isinstance(kiter16, bytes) else oprot.writeString(kiter16) 112 oprot.writeString(viter17.encode('utf-8')) if UTF8STRINGS and not isinstance(viter17, bytes) else oprot.writeString(viter17) 113 oprot.writeMapEnd() 114 oprot.writeFieldEnd() 115 if self.myset != None: 116 oprot.writeFieldBegin('myset', TType.SET, 2) 117 oprot.writeSetBegin(TType.STRING, len(self.myset)) 118 for iter20 in sorted(self.myset): 119 oprot.writeString(iter20.encode('utf-8')) if UTF8STRINGS and not isinstance(iter20, bytes) else oprot.writeString(iter20) 120 oprot.writeSetEnd() 121 oprot.writeFieldEnd() 122 oprot.writeFieldStop() 123 oprot.writeStructEnd() 124 125 def __repr__(self): 126 L = [] 127 padding = ' ' * 4 128 if self.mymap is not None: 129 value = pprint.pformat(self.mymap, indent=0) 130 value = padding.join(value.splitlines(True)) 131 L.append(' mymap=%s' % (value)) 132 if self.myset is not None: 133 value = pprint.pformat(self.myset, indent=0) 134 value = padding.join(value.splitlines(True)) 135 L.append(' myset=%s' % (value)) 136 return "%s(%s)" % (self.__class__.__name__, "\n" + ",\n".join(L) if L else '') 137 138 def __eq__(self, other): 139 if not isinstance(other, self.__class__): 140 return False 141 142 return self.__dict__ == other.__dict__ 143 144 def __ne__(self, other): 145 return not (self == other) 146 147 # Override the __hash__ function for Python3 - t10434117 148 __hash__ = object.__hash__ 149 150class NegativeId: 151 """ 152 Attributes: 153 - field1 154 - field2 155 - field3 156 """ 157 158 thrift_spec = None 159 thrift_field_annotations = None 160 thrift_struct_annotations = None 161 __init__ = None 162 @staticmethod 163 def isUnion(): 164 return False 165 166 def read(self, iprot): 167 if (isinstance(iprot, TBinaryProtocol.TBinaryProtocolAccelerated) or (isinstance(iprot, THeaderProtocol.THeaderProtocolAccelerate) and iprot.get_protocol_id() == THeaderProtocol.THeaderProtocol.T_BINARY_PROTOCOL)) and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastproto is not None: 168 fastproto.decode(self, iprot.trans, [self.__class__, self.thrift_spec, False], utf8strings=UTF8STRINGS, protoid=0) 169 return 170 if (isinstance(iprot, TCompactProtocol.TCompactProtocolAccelerated) or (isinstance(iprot, THeaderProtocol.THeaderProtocolAccelerate) and iprot.get_protocol_id() == THeaderProtocol.THeaderProtocol.T_COMPACT_PROTOCOL)) and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastproto is not None: 171 fastproto.decode(self, iprot.trans, [self.__class__, self.thrift_spec, False], utf8strings=UTF8STRINGS, protoid=2) 172 return 173 iprot.readStructBegin() 174 while True: 175 (fname, ftype, fid) = iprot.readFieldBegin() 176 if ftype == TType.STOP: 177 break 178 if fid == -1: 179 if ftype == TType.I32: 180 self.field1 = iprot.readI32() 181 else: 182 iprot.skip(ftype) 183 elif fid == -2: 184 if ftype == TType.I32: 185 self.field2 = iprot.readI32() 186 else: 187 iprot.skip(ftype) 188 elif fid == 1: 189 if ftype == TType.I32: 190 self.field3 = iprot.readI32() 191 else: 192 iprot.skip(ftype) 193 else: 194 iprot.skip(ftype) 195 iprot.readFieldEnd() 196 iprot.readStructEnd() 197 198 def write(self, oprot): 199 if (isinstance(oprot, TBinaryProtocol.TBinaryProtocolAccelerated) or (isinstance(oprot, THeaderProtocol.THeaderProtocolAccelerate) and oprot.get_protocol_id() == THeaderProtocol.THeaderProtocol.T_BINARY_PROTOCOL)) and self.thrift_spec is not None and fastproto is not None: 200 oprot.trans.write(fastproto.encode(self, [self.__class__, self.thrift_spec, False], utf8strings=UTF8STRINGS, protoid=0)) 201 return 202 if (isinstance(oprot, TCompactProtocol.TCompactProtocolAccelerated) or (isinstance(oprot, THeaderProtocol.THeaderProtocolAccelerate) and oprot.get_protocol_id() == THeaderProtocol.THeaderProtocol.T_COMPACT_PROTOCOL)) and self.thrift_spec is not None and fastproto is not None: 203 oprot.trans.write(fastproto.encode(self, [self.__class__, self.thrift_spec, False], utf8strings=UTF8STRINGS, protoid=2)) 204 return 205 oprot.writeStructBegin('NegativeId') 206 if self.field2 != None: 207 oprot.writeFieldBegin('field2', TType.I32, -2) 208 oprot.writeI32(self.field2) 209 oprot.writeFieldEnd() 210 if self.field1 != None: 211 oprot.writeFieldBegin('field1', TType.I32, -1) 212 oprot.writeI32(self.field1) 213 oprot.writeFieldEnd() 214 if self.field3 != None: 215 oprot.writeFieldBegin('field3', TType.I32, 1) 216 oprot.writeI32(self.field3) 217 oprot.writeFieldEnd() 218 oprot.writeFieldStop() 219 oprot.writeStructEnd() 220 221 def __repr__(self): 222 L = [] 223 padding = ' ' * 4 224 if self.field1 is not None: 225 value = pprint.pformat(self.field1, indent=0) 226 value = padding.join(value.splitlines(True)) 227 L.append(' field1=%s' % (value)) 228 if self.field2 is not None: 229 value = pprint.pformat(self.field2, indent=0) 230 value = padding.join(value.splitlines(True)) 231 L.append(' field2=%s' % (value)) 232 if self.field3 is not None: 233 value = pprint.pformat(self.field3, indent=0) 234 value = padding.join(value.splitlines(True)) 235 L.append(' field3=%s' % (value)) 236 return "%s(%s)" % (self.__class__.__name__, "\n" + ",\n".join(L) if L else '') 237 238 def __eq__(self, other): 239 if not isinstance(other, self.__class__): 240 return False 241 242 return self.__dict__ == other.__dict__ 243 244 def __ne__(self, other): 245 return not (self == other) 246 247 # Override the __hash__ function for Python3 - t10434117 248 __hash__ = object.__hash__ 249 250all_structs.append(Foo) 251Foo.thrift_spec = ( 252 None, # 0 253 (1, TType.MAP, 'mymap', (TType.STRING,True,TType.STRING,True), None, 2, ), # 1 254 (2, TType.SET, 'myset', (TType.STRING,True), None, 2, ), # 2 255) 256 257Foo.thrift_struct_annotations = { 258} 259Foo.thrift_field_annotations = { 260} 261 262def Foo__init__(self, mymap=None, myset=None,): 263 self.mymap = mymap 264 self.myset = myset 265 266Foo.__init__ = Foo__init__ 267 268def Foo__setstate__(self, state): 269 state.setdefault('mymap', None) 270 state.setdefault('myset', None) 271 self.__dict__ = state 272 273Foo.__getstate__ = lambda self: self.__dict__.copy() 274Foo.__setstate__ = Foo__setstate__ 275 276all_structs.append(NegativeId) 277NegativeId.thrift_spec = ( 278 (-2, TType.I32, 'field2', None, 2, 2, ), # -2 279 (-1, TType.I32, 'field1', None, 1, 2, ), # -1 280 None, # 0 281 (1, TType.I32, 'field3', None, 3, 2, ), # 1 282) 283 284NegativeId.thrift_struct_annotations = { 285} 286NegativeId.thrift_field_annotations = { 287} 288 289def NegativeId__init__(self, field1=NegativeId.thrift_spec[1][4], field2=NegativeId.thrift_spec[0][4], field3=NegativeId.thrift_spec[3][4],): 290 self.field1 = field1 291 self.field2 = field2 292 self.field3 = field3 293 294NegativeId.__init__ = NegativeId__init__ 295 296def NegativeId__setstate__(self, state): 297 state.setdefault('field1', 1) 298 state.setdefault('field2', 2) 299 state.setdefault('field3', 3) 300 self.__dict__ = state 301 302NegativeId.__getstate__ = lambda self: self.__dict__.copy() 303NegativeId.__setstate__ = NegativeId__setstate__ 304 305fix_spec(all_structs) 306del all_structs 307