summaryrefslogtreecommitdiff
path: root/lib/oxidized/nodes.rb
diff options
context:
space:
mode:
Diffstat (limited to 'lib/oxidized/nodes.rb')
-rw-r--r--lib/oxidized/nodes.rb14
1 files changed, 13 insertions, 1 deletions
diff --git a/lib/oxidized/nodes.rb b/lib/oxidized/nodes.rb
index 213f534..4ceee31 100644
--- a/lib/oxidized/nodes.rb
+++ b/lib/oxidized/nodes.rb
@@ -61,8 +61,9 @@ module Oxidized
# @param node [String] name of the node moved into the head of array
def next node, opt={}
with_lock do
- n = del node
+ n = running.del node
if n
+ n = del node
n.user = opt['user']
n.msg = opt['msg']
n.from = opt['from']
@@ -80,6 +81,17 @@ module Oxidized
end
end
+ # @return [Array] list of nodes running now
+ def running
+ select { |node| node.running? }
+ end
+
+ # @return [Array] list of nodes waiting (not running)
+ def waiting
+ select { |node| not node.running? }
+ end
+
+
private
def initialize opts={}