Contents

module Delayed
  class Master
    class Forker
      def initialize(master)
        @master = master
        @config = master.config
      end

      def new_worker(worker)
        @master.logger.info "forking #{worker.name}..."
        fork_worker(worker)
        @master.logger.info "forked #{worker.name} with pid #{worker.pid}"

        @master.workers << worker
      end

      private

      def fork_worker(worker)
        @config.run_callback(:before_fork, @master, worker)
        worker.pid = fork do
          worker.pid = Process.pid
          worker.instance = create_instance(worker)
          @config.run_callback(:after_fork, @master, worker)
          $0 = worker.process_title
          worker.instance.start
        end
      end

      def create_instance(worker)
        require_relative 'worker_extension'

        instance = Delayed::Worker.new(worker.setting.data)
        [:max_run_time, :max_attempts, :destroy_failed_jobs].each do |key|
          if (value = worker.setting.send(key))
            Delayed::Worker.send("#{key}=", value)
          end
        end
        [:max_memory].each do |key|
          if (value = worker.setting.send(key))
            instance.send("#{key}=", value)
          end
        end
        instance.master_logger = @master.logger
        instance
      end
    end
  end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
delayed_job_master-2.0.3	lib/delayed/master/forker.rb
delayed_job_master-2.0.2	lib/delayed/master/forker.rb
delayed_job_master-2.0.1	lib/delayed/master/forker.rb
delayed_job_master-2.0.0	lib/delayed/master/forker.rb