Changeset 307
- Timestamp:
- 01/09/08 14:54:26 (8 months ago)
- Files:
-
- trunk/server/meta_worker.rb (modified) (5 diffs)
Legend:
- Unmodified
- Added
- Removed
- Modified
- Copied
- Moved
trunk/server/meta_worker.rb
r303 r307 13 13 @worker.send_request(:worker => :log_worker, :data => p_data) 14 14 end 15 15 16 16 def error(p_data) 17 17 @worker.send_request(:worker => :log_worker, :data => p_data) … … 64 64 def add_thread 65 65 @threads << Thread.new do 66 puts "calling add thread"67 66 while true 68 69 67 task = @work_queue.pop 70 68 @running_tasks << task … … 241 239 end 242 240 end 243 241 244 242 def load_schedule 245 243 case @my_schedule[:trigger_args] … … 332 330 $logger.info($!.backtrace.join("\n")) 333 331 end 334 332 335 333 return if @worker_method_triggers.nil? or @worker_method_triggers.empty? 336 334 @worker_method_triggers.each do |key,value| … … 380 378 ActiveRecord::Base.allow_concurrency = true 381 379 end 382 380 383 381 end # end of class MetaWorker 384 382 end # end of module BackgrounDRb
