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