TupleBag
is an unordered collection of tuples. It is the basis of Tuplespace.
# File lib/rinda/tuplespace.rb, line 341 def delete(tuple) key = bin_key(tuple) bin = @hash[key] return nil unless bin bin.delete(tuple) @hash.delete(key) if bin.empty? tuple end
Removes tuple
from the TupleBag
.
# File lib/rinda/tuplespace.rb, line 381 def delete_unless_alive deleted = [] @hash.each do |key, bin| bin.delete_if do |tuple| if tuple.alive? false else deleted.push(tuple) true end end end deleted end
Delete tuples which dead tuples from the TupleBag
, returning the deleted tuples.
# File lib/rinda/tuplespace.rb, line 361 def find(template) bin_for_find(template).find do |tuple| tuple.alive? && template.match(tuple) end end
Finds a live tuple that matches template
.
# File lib/rinda/tuplespace.rb, line 352 def find_all(template) bin_for_find(template).find_all do |tuple| tuple.alive? && template.match(tuple) end end
Finds all live tuples that match template
.
# File lib/rinda/tuplespace.rb, line 371 def find_all_template(tuple) @enum.find_all do |template| template.alive? && template.match(tuple) end end
Finds all tuples in the TupleBag
which when treated as templates, match tuple
and are alive.
# File lib/rinda/tuplespace.rb, line 323 def has_expires? @enum.find do |tuple| tuple.expires end end
true
if the TupleBag
to see if it has any expired entries.
# File lib/rinda/tuplespace.rb, line 332 def push(tuple) key = bin_key(tuple) @hash[key] ||= TupleBin.new @hash[key].add(tuple) end
Add tuple
to the TupleBag
.
# File lib/rinda/tuplespace.rb, line 412 def bin_for_find(template) key = bin_key(template) key ? @hash.fetch(key, []) : @enum end
# File lib/rinda/tuplespace.rb, line 403 def bin_key(tuple) head = tuple[0] if head.class == Symbol return head else false end end
# File lib/rinda/tuplespace.rb, line 397 def each_entry(&blk) @hash.each do |k, v| v.each(&blk) end end
Ruby Core © 1993–2020 Yukihiro Matsumoto
Licensed under the Ruby License.
Ruby Standard Library © contributors
Licensed under their own licenses.