In Files
- rinda/tuplespace.rb
Parent
Object
Namespace
Class/Module Index
- Rinda
- Rinda::DRbObjectTemplate
- Rinda::InvalidHashTupleKey
- Rinda::NotifyTemplateEntry
- Rinda::RequestCanceledError
- Rinda::RequestExpiredError
- Rinda::RindaError
- Rinda::RingFinger
- Rinda::RingProvider
- Rinda::RingServer
- Rinda::SimpleRenewer
- Rinda::Template
- Rinda::TemplateEntry
- Rinda::Tuple
- Rinda::TupleBag
- Rinda::TupleBag::TupleBin
- Rinda::TupleEntry
- Rinda::TupleSpace
- Rinda::TupleSpaceProxy
- Rinda::WaitTemplateEntry
Rinda::TupleBag
TupleBag is an unordered collection of tuples. It is the basis of Tuplespace.
Public Instance Methods
delete(tuple)
Removes tuple
from the TupleBag.
# File rinda/tuplespace.rb, line 342 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
delete_unless_alive()
Delete tuples which dead tuples from the TupleBag, returning the deleted tuples.
# File rinda/tuplespace.rb, line 382 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
find(template)
Finds a live tuple that matches template
.
# File rinda/tuplespace.rb, line 362 def find(template) bin_for_find(template).find do |tuple| tuple.alive? && template.match(tuple) end end
find_all(template)
Finds all live tuples that match template
.
# File rinda/tuplespace.rb, line 353 def find_all(template) bin_for_find(template).find_all do |tuple| tuple.alive? && template.match(tuple) end end
find_all_template(tuple)
Finds all tuples in the TupleBag which when
treated as templates, match tuple
and are alive.
# File rinda/tuplespace.rb, line 372 def find_all_template(tuple) @enum.find_all do |template| template.alive? && template.match(tuple) end end
has_expires?()
true
if the TupleBag to see if it
has any expired entries.
# File rinda/tuplespace.rb, line 324 def has_expires? @enum.find do |tuple| tuple.expires end end
push(tuple)
Add tuple
to the TupleBag.
# File rinda/tuplespace.rb, line 333 def push(tuple) key = bin_key(tuple) @hash[key] ||= TupleBin.new @hash[key].add(tuple) end