BackgrounDRb::MasterWorker

    # File server/lib/master_worker.rb, line 68
68:     def all_worker_info(t_data)
69:       info_response = []
70:       reactor.live_workers.each do |key,value|
71:         worker_key = (value.worker_key.to_s).gsub(/#{value.worker_name}_?/,"")
72:         info_response << { :worker => value.worker_name,:worker_key => worker_key,:status => :running }
73:       end
74:       send_object(info_response)
75:     end

     # File server/lib/master_worker.rb, line 103
103:     def async_method_invoke(t_data)
104:       worker_name = t_data[:worker]
105:       worker_name_key = gen_worker_key(worker_name,t_data[:worker_key])
106:       t_data.delete(:worker)
107:       t_data.delete(:type)
108:       begin
109:         ask_worker(worker_name_key,:data => t_data, :type => :request, :result => false)
110:       rescue Packet::DisconnectError => sock_error
111:         reactor.live_workers.delete(worker_name_key)
112:       rescue
113:         debug_logger.info($!.message)
114:         debug_logger.info($!.backtrace.join("\n"))
115:         return
116:       end
117:     end

     # File server/lib/master_worker.rb, line 167
167:     def connection_completed; end

    # File server/lib/master_worker.rb, line 79
79:     def delete_drb_worker(t_data)
80:       worker_name = t_data[:worker]
81:       worker_key = t_data[:worker_key]
82:       worker_name_key = gen_worker_key(worker_name,worker_key)
83:       begin
84:         worker_instance = reactor.live_workers[worker_name_key]
85:         raise Packet::InvalidWorker.new("Invalid worker with name #{worker_name} key #{worker_key}") unless worker_instance
86:         Process.kill('TERM',worker_instance.pid)
87:         # Warning: Change is temporary, may break things
88:         reactor.live_workers.delete(worker_name_key)
89:       rescue Packet::DisconnectError => sock_error
90:         reactor.remove_worker(sock_error)
91:       rescue
92:         debug_logger.info($!.to_s)
93:         debug_logger.info($!.backtrace.join("\n"))
94:       end
95:     end

     # File server/lib/master_worker.rb, line 123
123:     def get_result_object(t_data)
124:       worker_name = t_data[:worker]
125:       worker_name_key = gen_worker_key(worker_name,t_data[:worker_key])
126:       t_data.delete(:worker)
127:       t_data.delete(:type)
128:       begin
129:         ask_worker(worker_name_key,:data => t_data, :type => :get_result,:result => true)
130:       rescue Packet::DisconnectError => sock_error
131:         reactor.live_workers.delete(worker_name_key)
132:       rescue
133:         debug_logger.info($!.to_s)
134:         debug_logger.info($!.backtrace.join("\n"))
135:         return
136:       end
137:     end

     # File server/lib/master_worker.rb, line 140
140:     def method_invoke(t_data)
141:       worker_name = t_data[:worker]
142:       worker_name_key = gen_worker_key(worker_name,t_data[:worker_key])
143:       t_data.delete(:worker)
144:       t_data.delete(:type)
145:       begin
146:         ask_worker(worker_name_key,:data => t_data, :type => :request,:result => true)
147:       rescue Packet::DisconnectError => sock_error
148:         reactor.live_workers.delete(worker_name_key)
149:       rescue
150:         debug_logger.info($!.message)
151:         debug_logger.info($!.backtrace.join("\n"))
152:         return
153:       end
154:     end

    # File server/lib/master_worker.rb, line 59
59:     def pass_worker_info(t_data)
60:       worker_name_key = gen_worker_key(t_data[:worker],t_data[:worker_key])
61:       worker_instance = reactor.live_workers[worker_name_key]
62:       info_response = { :worker => t_data[:worker],:worker_key => t_data[:worker_key]}
63:       worker_instance ? (info_response[:status] = :running) : (info_response[:status] = :stopped)
64:       send_object(info_response)
65:     end

     # File server/lib/master_worker.rb, line 164
164:     def post_init
165:       @tokenizer = Packet::BinParser.new
166:     end

    # File server/lib/master_worker.rb, line 31
31:     def receive_data p_data
32:       @tokenizer.extract(p_data) do |b_data|
33:         begin
34:           t_data = load_data b_data
35:           if t_data
36:             case t_data[:type]
37:               # async method invocation
38:             when :async_invoke: async_method_invoke(t_data)
39:               # get status/result
40:             when :get_result: get_result_object(t_data)
41:               # sync method invocation
42:             when :sync_invoke: method_invoke(t_data)
43:             when :start_worker: start_worker_request(t_data)
44:             when :delete_worker: delete_drb_worker(t_data)
45:             when :worker_info: pass_worker_info(t_data)
46:             when :all_worker_info: all_worker_info(t_data)
47:             else; debug_logger.info("Invalid request")
48:             end
49:           end
50:         rescue Exception => e
51:           debug_logger.info(e)
52:           debug_logger.info(e.backtrace.join("\n"))
53:           send_object(nil)
54:         end
55:       end
56:     end

     # File server/lib/master_worker.rb, line 98
 98:     def start_worker_request(p_data)
 99:       start_worker(p_data)
100:     end

     # File server/lib/master_worker.rb, line 161
161:     def unbind; end

     # File server/lib/master_worker.rb, line 157
157:     def worker_receive p_data
158:       send_object(p_data)
159:     end