Changeset 211
- Timestamp:
- 12/02/07 23:44:47 (1 year ago)
- Files:
-
- branches/version10/framework/worker.rb (modified) (1 diff)
- branches/version10/lib/backgroundrb.rb (modified) (2 diffs)
- branches/version10/server/master_worker.rb (modified) (1 diff)
Legend:
- Unmodified
- Added
- Removed
- Modified
- Copied
- Moved
branches/version10/framework/worker.rb
r210 r211 29 29 end 30 30 31 # when you directly call send_data from a worker, it always, sends data 32 # as an object 31 33 def send_data p_data 32 34 dump_object(p_data,msg_writer) branches/version10/lib/backgroundrb.rb
r210 r211 45 45 46 46 def do_work p_data 47 p_data[:type] = : start_worker47 p_data[:type] = :do_work 48 48 establish_connection() 49 49 raise "Error Connecting to Master Process" unless @connection_status … … 97 97 begin 98 98 ret_val = select([@connection],nil,nil,3) 99 unless ret_val 100 p "Nothing to read" 101 return nil 102 end 103 99 return nil unless ret_val 104 100 raw_response = read_object() 105 101 master_response = Marshal.load(raw_response) branches/version10/server/master_worker.rb
r210 r211 74 74 Packet::Reactor.server_logger = "#{RAILS_HOME}/log/backgroundrb_server.log" 75 75 Packet::Reactor.run do |t_reactor| 76 t_reactor.start_worker( "log_worker")76 t_reactor.start_worker(:worker => "log_worker") 77 77 t_reactor.start_server(config_file[:backgroundrb][:ip],config_file[:backgroundrb][:port],MasterWorker) 78 78 end
