Changeset 299

Show
Ignore:
Timestamp:
12/28/07 01:03:07 (8 months ago)
Author:
gethema..@gmail.com
Message:

fixed bug wtih logger and threads

Files:

Legend:

Unmodified
Added
Removed
Modified
Copied
Moved

  • trunk/server/meta_worker.rb

    r298 r299  
    1010    end 
    1111 
    12     def debug 
     12    def debug(p_data) 
    1313      @worker.send_request(:worker => :log_worker, :data => p_data) 
    1414    end 
    …… 
    2424 
    2525  class ThreadPool 
    26     attr_accessor :size 
    27     attr_accessor :threads 
    28     attr_accessor :work_queue 
    29     def initialize(size) 
     26    attr_accessor :size,:threads,:work_queue,:logger 
     27    def initialize(size,logger) 
     28      @logger = logger 
    3029      @size = size 
    3130      @threads = [] 
    …… 
    155154    iattr_accessor :pool_size 
    156155    @pool_size = nil 
    157      
     156 
    158157    def self.pool_size(size = nil) 
    159158      if size 
    …… 
    167166    # user defined worker class 
    168167    def worker_init 
    169       @thread_pool = ThreadPool.new(pool_size || 20) 
    170  
    171168      @config_file = YAML.load(ERB.new(IO.read("#{RAILS_HOME}/config/backgroundrb.yml")).result) 
    172169      # load_rails_env 
    173170      @logger = PacketLogger.new(self) 
     171      @thread_pool = ThreadPool.new(pool_size || 20,@logger) 
     172 
    174173      if(@worker_options && @worker_options[:schedule] && no_auto_load) 
    175174        load_schedule_from_args