module Thrift::Processor
Public Class Methods
new(handler)
click to toggle source
# File lib/thrift/processor.rb, line 22 def initialize(handler) @handler = handler end
Public Instance Methods
process(iprot, oprot)
click to toggle source
# File lib/thrift/processor.rb, line 26 def process(iprot, oprot) name, type, seqid = iprot.read_message_begin if respond_to?("process_#{name}") begin send("process_#{name}", seqid, iprot, oprot) rescue => e x = ApplicationException.new(ApplicationException::INTERNAL_ERROR, 'Internal error') write_error(x, oprot, name, seqid) end true else iprot.skip(Types::STRUCT) iprot.read_message_end x = ApplicationException.new(ApplicationException::UNKNOWN_METHOD, 'Unknown function '+name) write_error(x, oprot, name, seqid) false end end
read_args(iprot, args_class)
click to toggle source
# File lib/thrift/processor.rb, line 45 def read_args(iprot, args_class) args = args_class.new args.read(iprot) iprot.read_message_end args end
write_error(err, oprot, name, seqid)
click to toggle source
# File lib/thrift/processor.rb, line 59 def write_error(err, oprot, name, seqid) p 'write_error' oprot.write_message_begin(name, MessageTypes::EXCEPTION, seqid) err.write(oprot) oprot.write_message_end oprot.trans.flush p 'write_error end' end
write_result(result, oprot, name, seqid)
click to toggle source
# File lib/thrift/processor.rb, line 52 def write_result(result, oprot, name, seqid) oprot.write_message_begin(name, MessageTypes::REPLY, seqid) result.write(oprot) oprot.write_message_end oprot.trans.flush end