module Thrift::Processor

Public Class Methods

new(handler) click to toggle source
   # File lib/thrift/processor.rb
22 def initialize(handler)
23   @handler = handler
24 end

Public Instance Methods

process(iprot, oprot) click to toggle source
   # File lib/thrift/processor.rb
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
read_args(iprot, args_class) click to toggle source
   # File lib/thrift/processor.rb
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
write_result(result, oprot, name, seqid) click to toggle source
   # File lib/thrift/processor.rb
50 def write_result(result, oprot, name, seqid)
51   if @service
52     oprot.write_message_begin(@service + ':' + name, MessageTypes::REPLY, seqid)
53   else
54     oprot.write_message_begin(name, MessageTypes::REPLY, seqid)
55   end
56   result.write(oprot)
57   oprot.write_message_end
58   oprot.trans.flush
59 end