in if/py/gen-py/fbnet/command_runner_asyncio/CommandRunner/Command.py [0:0]
def read(self, iprot):
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:
fastproto.decode(self, iprot.trans, [self.__class__, self.thrift_spec, False], utf8strings=UTF8STRINGS, protoid=0)
self.checkRequired()
return
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:
fastproto.decode(self, iprot.trans, [self.__class__, self.thrift_spec, False], utf8strings=UTF8STRINGS, protoid=2)
self.checkRequired()
return
iprot.readStructBegin()
while True:
(fname, ftype, fid) = iprot.readFieldBegin()
if ftype == TType.STOP:
break
if fid == 0:
if ftype == TType.MAP:
self.success = {}
(_ktype49, _vtype50, _size48 ) = iprot.readMapBegin()
if _size48 >= 0:
for _i52 in six.moves.range(_size48):
_key53 = iprot.readString().decode('utf-8') if UTF8STRINGS else iprot.readString()
_val54 = []
(_etype58, _size55) = iprot.readListBegin()
if _size55 >= 0:
for _i59 in six.moves.range(_size55):
_elem60 = CommandResult()
_elem60.read(iprot)
_val54.append(_elem60)
else:
while iprot.peekList():
_elem61 = CommandResult()
_elem61.read(iprot)
_val54.append(_elem61)
iprot.readListEnd()
self.success[_key53] = _val54
else:
while iprot.peekMap():
_key62 = iprot.readString().decode('utf-8') if UTF8STRINGS else iprot.readString()
_val63 = []
(_etype67, _size64) = iprot.readListBegin()
if _size64 >= 0:
for _i68 in six.moves.range(_size64):
_elem69 = CommandResult()
_elem69.read(iprot)
_val63.append(_elem69)
else:
while iprot.peekList():
_elem70 = CommandResult()
_elem70.read(iprot)
_val63.append(_elem70)
iprot.readListEnd()
self.success[_key62] = _val63
iprot.readMapEnd()
else:
iprot.skip(ftype)
else:
iprot.skip(ftype)
iprot.readFieldEnd()
iprot.readStructEnd()
self.checkRequired()