Method: DRbQS::Node::TaskClient#add_new_task

Defined in:
lib/drbqs/node/task_client.rb

#add_new_task(num) ⇒ Object 



61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
 
# File 'lib/drbqs/node/task_client.rb', line 61

def add_new_task(num)
  get_task_id = []
  num.times do |i|
    if ary = get_task
      task_id = ary[0]
      @logger.info("Send accept signal: node #{@node_number} caluclating #{task_id}")
      @result.write([:accept, task_id, @node_number])
      queue_task(ary)
      get_task_id << task_id
    else
      break
    end
  end
  get_task_id.empty? ? nil : get_task_id
end