Method: BaseChip::Tasker#run

Defined in:
lib/base_chip/tasker.rb

#run ⇒ Object 



62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
 
# File 'lib/base_chip/tasker.rb', line 62

def run
  STDOUT.sync = true 
  if @client_of || @clusters.nil?
    begin
      if @client_of
        init_test_sockets(:client)
      end
      while(t = @server.get_task(@client_id))
        @task_master.tasker_run_task t
      end
    rescue DRb::DRbConnError
      # raise if @options.debug
    end
  else
    DRb.thread.join
  end
end