Module | Thrift::Processor |
In: |
lib/thrift/processor.rb
lib/thrift/processor.rb |
# File lib/thrift/processor.rb, line 26 26: def process(iprot, oprot) 27: name, type, seqid = iprot.read_message_begin 28: if respond_to?("process_#{name}") 29: send("process_#{name}", seqid, iprot, oprot) 30: true 31: else 32: iprot.skip(Types::STRUCT) 33: iprot.read_message_end 34: x = ApplicationException.new(ApplicationException::UNKNOWN_METHOD, 'Unknown function '+name) 35: oprot.write_message_begin(name, MessageTypes::EXCEPTION, seqid) 36: x.write(oprot) 37: oprot.write_message_end 38: oprot.trans.flush 39: false 40: end 41: end
# File lib/thrift/processor.rb, line 26 26: def process(iprot, oprot) 27: name, type, seqid = iprot.read_message_begin 28: if respond_to?("process_#{name}") 29: send("process_#{name}", seqid, iprot, oprot) 30: true 31: else 32: iprot.skip(Types::STRUCT) 33: iprot.read_message_end 34: x = ApplicationException.new(ApplicationException::UNKNOWN_METHOD, 'Unknown function '+name) 35: oprot.write_message_begin(name, MessageTypes::EXCEPTION, seqid) 36: x.write(oprot) 37: oprot.write_message_end 38: oprot.trans.flush 39: false 40: end 41: end
# File lib/thrift/processor.rb, line 43 43: def read_args(iprot, args_class) 44: args = args_class.new 45: args.read(iprot) 46: iprot.read_message_end 47: args 48: end
# File lib/thrift/processor.rb, line 43 43: def read_args(iprot, args_class) 44: args = args_class.new 45: args.read(iprot) 46: iprot.read_message_end 47: args 48: end
# File lib/thrift/processor.rb, line 50 50: def write_result(result, oprot, name, seqid) 51: oprot.write_message_begin(name, MessageTypes::REPLY, seqid) 52: result.write(oprot) 53: oprot.write_message_end 54: oprot.trans.flush 55: end