Class: UpdateTasksThread

Inherits:
BaseThread show all
Defined in:
lib/daemon/update_tasks_thread.rb

Instance Method Summary collapse

Methods inherited from BaseThread

#initialize

Constructor Details

This class inherits a constructor from BaseThread

Instance Method Details

#check_tasks(type) ⇒ Object 



8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
 
# File 'lib/daemon/update_tasks_thread.rb', line 8

def check_tasks(type)
  count = 0
  limit = FC::Var.get("daemon_tasks_#{type}_group_limit", 1000).to_i
  tasks = (type == :copy ? $tasks_copy : $tasks_delete) 
  $storages.select { |storage| storage.write_weight.to_i >= 0 }.each do |storage|
    tasks[storage.name] = [] unless tasks[storage.name]
    ids = tasks[storage.name].map(&:id) + $curr_tasks.compact.map(&:id)
    if ids.length > limit*2
      $log.debug("Too many (#{ids.length}) #{type} tasks")
      next
    end
    cond = "storage_name = '#{storage.name}' AND status='#{type.to_s}'"
    cond << "AND id not in (#{ids.join(',')})" if ids.length > 0
    cond << " LIMIT #{limit}"
    FC::ItemStorage.where(cond).each do |item_storage|
      tasks[storage.name] << item_storage 
      $log.debug("task add: type=#{type}, item_storage=#{item_storage.id}")
      count +=1 
    end
  end
  $log.debug("Add #{count} #{type} tasks")
end

#go ⇒ Object 



2
3
4
5
6
 
# File 'lib/daemon/update_tasks_thread.rb', line 2

def go
  $log.debug('Update tasks')
  check_tasks(:delete)
  check_tasks(:copy)
end