

def process_ping(self, seqid, iprot, oprot):
    args = ping_args()
    args.read(iprot)
    iprot.readMessageEnd()
    result = ping_result()
    result.success = self._handler.ping(args.input)
    oprot.writeMessageBegin('ping', TMessageType.REPLY, seqid)
    result.write(oprot)
    oprot.writeMessageEnd()
    oprot.trans.flush()

dataset/ETHPy150Open cloudera/hue/desktop/core/src/desktop/lib/gen-py/djangothrift_test_gen/TestService.py Processor.process_ping/original