Changeset 314
- Timestamp:
- 01/31/08 05:00:46 (7 months ago)
- Files:
-
- trunk/framework/packet/packet_master.rb (modified) (2 diffs)
- trunk/framework/packet/worker.rb (modified) (2 diffs)
Legend:
- Unmodified
- Added
- Removed
- Modified
- Copied
- Moved
trunk/framework/packet/packet_master.rb
r313 r314 131 131 # socket to which master process is going to write 132 132 worker_read_end,master_write_end = UNIXSocket.pair(Socket::SOCK_STREAM) 133 worker_read_fd,master_write_fd = UNIXSocket.pair133 #worker_read_fd,master_write_fd = UNIXSocket.pair 134 134 135 135 if((pid = fork()).nil?) 136 136 $0 = "ruby #{worker_klass.worker_name}" 137 [master_write_end,master_read_end ,master_write_fd].each { |x| x.close }137 [master_write_end,master_read_end].each { |x| x.close } 138 138 139 139 worker_klass.start_worker(:write_end => worker_write_end,:read_end => worker_read_end,\ 140 : read_fd => worker_read_fd,:options => worker_options)140 :options => worker_options) 141 141 end 142 142 Process.detach(pid) … … 157 157 worker_read_end.close 158 158 worker_write_end.close 159 worker_read_fd.close159 #worker_read_fd.close 160 160 read_ios << master_read_end 161 161 end # end of fork_and_load method trunk/framework/packet/worker.rb
r313 r314 15 15 @msg_writer = messengers[:write_end] 16 16 @msg_reader = messengers[:read_end] 17 @fd_reader = messengers[:read_fd]17 # @fd_reader = messengers[:read_fd] 18 18 t_instance = new 19 19 t_instance.worker_options = messengers[:options] … … 25 25 super 26 26 @read_ios << msg_reader 27 @read_ios << fd_reader27 # @read_ios << fd_reader 28 28 @tokenizer = BinParser.new 29 29 end
