Method: Wakame::MasterManagers::LockQueue#test

Defined in:
lib/wakame/master_managers/action_manager.rb

#test(id) ⇒ Object



248
249
250
251
252
253
254
255
256
257
258
259
# File 'lib/wakame/master_managers/action_manager.rb', line 248

def test(id)
  @self_m.synchronize {
    reslist = @id2res[id]
    return :pass if reslist.nil? || reslist.empty?
    
    if reslist.keys.all? { |r| id == @locks[r.to_s][0] }
      return :runnable
    else
      return :wait
    end
  }
end