archive/ruby
1
0
Fork 0
mirror of https://github.com/ruby/ruby.git synced 2025-09-16 17:14:01 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions 10

* lib/rinda/tuplespace.rb (TupleSpace#create_entry, TupleBag#push,

Browse source 
delete): extract method, and rename parameter.



git-svn-id: svn+ssh://ci.ruby-lang.org/ruby/branches/ruby_1_8@12229 b2dd03c8-39d4-4d8f-98ff-823fe69b080e
This commit is contained in:
seki 2007-04-29 16:21:31 +00:00
parent dda4527478
commit 858e38c902
2 changed files with 18 additions and 9 deletions
Download patch file Download diff file Expand all files Collapse all files

5
ChangeLog
View file

@ -1,3 +1,8 @@
Mon Apr 30 01:17:51 2007 Masatoshi SEKI <m_seki@mva.biglobe.ne.jp>
* lib/rinda/tuplespace.rb (TupleSpace#create_entry, TupleBag#push,
delete): extract method, and rename parameter.
Fri Apr 27 02:00:17 2007 Ryan Davis <ryand-ruby@zenspider.com>
* signal.c: Fixed backwards compatibility for 'raise Interrupt'.

22
lib/rinda/tuplespace.rb
View file

@ -304,20 +304,20 @@ module Rinda
end
##
# Add +ary+ to the TupleBag.
# Add +tuple+ to the TupleBag.
def push(ary)
size = ary.size
def push(tuple)
size = tuple.size
@hash[size] ||= []
@hash[size].push(ary)
@hash[size].push(tuple)
end
##
# Removes +ary+ from the TupleBag.
# Removes +tuple+ from the TupleBag.
def delete(ary)
size = ary.size
@hash.fetch(size, []).delete(ary)
def delete(tuple)
size = tuple.size
@hash.fetch(size, []).delete(tuple)
end
##
@ -403,7 +403,7 @@ module Rinda
# Adds +tuple+
def write(tuple, sec=nil)
entry = TupleEntry.new(tuple, sec)
entry = create_entry(tuple, sec)
start_keeper
synchronize do
if entry.expired?
@ -529,6 +529,10 @@ module Rinda
private
def create_entry(tuple, sec)
TupleEntry.new(tuple, sec)
end
##
# Removes dead tuples.