@@ -37,10 +37,10 @@ class Foo def connection_completed puts "calling connection completed" - #add_periodic_timer(4) { send_data("hello\n")} + # add_periodic_timer(4) { send_data("hello\n")} # start_worker(:worker => :dynamic1_worker, :job_key => :hello_world) -# 100.times do |i| -# thread_pool.defer(i) do |j| + # 100.times do |i| + # thread_pool.defer(i) do |j| # puts "Starting work for #{j} : #{j.class}" # sleep(1) # puts "Work done for #{j}" bin/runner.rb @@ -109,10 +109,14 @@ module Packet [worker_read_end,worker_write_end].each { |x| enable_nonblock(x) } begin if(ARGV[0] == 'start' && Object.const_defined?(:SERVER_LOGGER)) - log_file = File.open(SERVER_LOGGER,"a") - [STDIN, STDOUT, STDERR].each {|desc| desc.reopen(log_file)} + STDOUT.sync = true + STDERR.sync = true + log_file = File.open(SERVER_LOGGER,"w+") + [STDOUT, STDERR].each {|desc| desc.reopen(log_file)} end - rescue; end + rescue + puts $!.backtrace + end exec form_cmd_line(worker_read_end.fileno,worker_write_end.fileno,t_worker_name,option_dump_length) end Process.detach(pid) lib/packet/packet_master.rb e2a9647b30f760e8c31ec912448b218a52b3dae8 gnufied gethemant@gmail.com http://github.com/gnufied/packet/commit/31c933584ac6c564af675e9eb084f1619dff8be9 31c933584ac6c564af675e9eb084f1619dff8be9 2009-01-04T07:02:59-08:00 2009-01-04T07:02:59-08:00 sync the stdout and stdin d1e8b49cc2e54aab36f2931a076b571cd532b1eb gnufied gethemant@gmail.com