lib/capistrano_multiconfig_parallel/celluloid/celluloid_manager.rb
# call back from actor once it has received it's job
# actor should do this asap
call back from actor once it has received it's job
actor should do this asap
call back from actor once it has received it ' s job actor should do this asap
def register_worker_for_job(job, worker)
      @job_to_worker[job.id] = worker
      @worker_to_job[worker.mailbox.address] = job
      log_to_file("worker #{worker.job_id} registed into manager")
      Actor.current.link worker
      worker.async.start_task if !syncronized_confirmation? || job.rolling_back?
      return unless syncronized_confirmation?
      @registration_complete = true if @job_manager.jobs.size == @jobs.size
    end
def register_worker_for_job ( job , worker ) @job_to_worker [ job . id ] = worker @worker_to_job [ worker . mailbox . address ] = job log_to_file ( "worker #{worker.job_id} registed into manager" ) Actor . current . link worker worker . async . start_task if ! syncronized_confirmation? || job . rolling_back? return unless syncronized_confirmation? @registration_complete = true if @job_manager . jobs . size == @jobs . size end
call back from actor once it has received it's job
actor should do this asap
call back from actor once it has received it ' s job actor should do this asap
job
<not_specific>
worker
<not_specific>