Module Thrift::Processor
In: lib/thrift/processor.rb
lib/thrift/processor.rb

Methods

new   new   process   process   read_args   read_args   write_result   write_result  

Public Class methods

new(handler)

[Source]

    # File lib/thrift/processor.rb, line 22
22:     def initialize(handler)
23:       @handler = handler
24:     end
new(handler)

[Source]

    # File lib/thrift/processor.rb, line 22
22:     def initialize(handler)
23:       @handler = handler
24:     end

Public Instance methods

process(iprot, oprot)

[Source]

    # 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
process(iprot, oprot)

[Source]

    # 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
read_args(iprot, args_class)

[Source]

    # 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
read_args(iprot, args_class)

[Source]

    # 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
write_result(result, oprot, name, seqid)

[Source]

    # 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
write_result(result, oprot, name, seqid)

[Source]

    # 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

[Validate]