Project

General

Profile

Download (910 Bytes)

Feature #8128 » example-replace-all.rb

vjoel (Joel VanderWerf), 03/20/2013 08:00 AM

 
$LOAD_PATH.unshift "lib"

require 'rinda/rinda'
require 'rinda/replace-all'

rd, wr = IO.pipe

server = fork do
rd.close
require 'rinda/tuplespace'
ts = Rinda::TupleSpace.new
ts.extend Rinda::TupleSpace::ReplaceAll
DRb.start_service(nil, ts)
wr.puts DRb.uri
DRb.thread.join
end

wr.close
uri = rd.gets.chomp

c1 = fork do
DRb.start_service
ts = Rinda::TupleSpaceProxy.new(DRbObject.new_with_uri(uri))
ts.extend Rinda::TupleSpaceProxy::ReplaceAll

puts "read_all:"
p ts.read_all [1,2,nil]

puts "replace_all:"
p ts.replace_all [1,2,nil], [1, 2, "Foo"]

puts "read_all:"
p ts.read_all [1,2,nil]

puts "write..."
ts.write [1,2,3]
ts.write [1,2,4]
ts.write [1,2,5]

puts "read_all:"
p ts.read_all [1,2,nil]

puts "replace_all:"
p ts.replace_all [1,2,nil], [1, 2, "Bar"]

puts "read_all:"
p ts.read_all [1,2,nil]
end

Process.wait c1

Process.kill "TERM", server
(3-3/5)