summaryrefslogtreecommitdiff
path: root/sample
diff options
context:
space:
mode:
Diffstat (limited to 'sample')
-rw-r--r--sample/drb/README.rd56
-rw-r--r--sample/drb/README.rd.ja59
-rw-r--r--sample/drb/darray.rb13
-rw-r--r--sample/drb/darrayc.rb59
-rw-r--r--sample/drb/dbiff.rb51
-rw-r--r--sample/drb/dcdbiff.rb43
-rw-r--r--sample/drb/dchatc.rb41
-rw-r--r--sample/drb/dchats.rb71
-rw-r--r--sample/drb/dhasen.rb43
-rw-r--r--sample/drb/dhasenc.rb13
-rw-r--r--sample/drb/dlogc.rb16
-rw-r--r--sample/drb/dlogd.rb39
-rw-r--r--sample/drb/dqin.rb13
-rw-r--r--sample/drb/dqlib.rb14
-rw-r--r--sample/drb/dqout.rb14
-rw-r--r--sample/drb/dqueue.rb13
-rw-r--r--sample/drb/drbc.rb45
-rw-r--r--sample/drb/drbch.rb48
-rw-r--r--sample/drb/drbm.rb59
-rw-r--r--sample/drb/drbmc.rb22
-rw-r--r--sample/drb/drbs-acl.rb51
-rw-r--r--sample/drb/drbs.rb64
-rw-r--r--sample/drb/drbssl_c.rb19
-rw-r--r--sample/drb/drbssl_s.rb32
-rw-r--r--sample/drb/extserv_test.rb80
-rw-r--r--sample/drb/gw_ct.rb29
-rw-r--r--sample/drb/gw_cu.rb28
-rw-r--r--sample/drb/gw_s.rb9
-rw-r--r--sample/drb/holderc.rb22
-rw-r--r--sample/drb/holders.rb64
-rw-r--r--sample/drb/http0.rb77
-rw-r--r--sample/drb/http0serv.rb119
-rw-r--r--sample/drb/name.rb118
-rw-r--r--sample/drb/namec.rb36
-rw-r--r--sample/drb/old_tuplespace.rb214
-rw-r--r--sample/drb/rinda_ts.rb7
-rw-r--r--sample/drb/rindac.rb17
-rw-r--r--sample/drb/rindas.rb18
-rw-r--r--sample/drb/ring_echo.rb30
-rw-r--r--sample/drb/ring_inspect.rb30
-rw-r--r--sample/drb/ring_place.rb25
-rw-r--r--sample/drb/simpletuple.rb91
-rw-r--r--sample/drb/speedc.rb21
-rw-r--r--sample/drb/speeds.rb33
44 files changed, 1966 insertions, 0 deletions
diff --git a/sample/drb/README.rd b/sample/drb/README.rd
new file mode 100644
index 00000000000..5cf1f519134
--- /dev/null
+++ b/sample/drb/README.rd
@@ -0,0 +1,56 @@
+= Sample scripts
+
+* array and iteretor
+ * darray.rb --- server
+ * darrayc.rb --- client
+
+* simple chat
+ * dchats.rb --- server
+ * dchatc.rb --- client
+
+* distributed chasen (for Japanese)
+ * dhasen.rb --- server
+ * dhasenc.rb --- client
+
+* simple log server
+ * dlogd.rb --- server
+ * dlogc.rb --- client
+
+* Queue server, and DRbUnknown demo
+ * dqueue.rb --- server
+ * dqin.rb --- client. push DQEntry objects.
+ * dqout.rb --- client. pop DQEntry objects.
+ * dqlib.rb --- define DQEntry
+
+* IdConv customize demo: reference by name
+ * name.rb --- server
+ * namec.rb --- client
+
+* extserv
+ * extserv_test.rb
+
+* IdConv customize demo 2: using TimerIdConv
+ * holders.rb --- server
+ * holderc.rb --- client
+
+* rinda, remote tuplespace
+ * rinda_ts.rb --- TupleSpace server.
+ * rindas.rb --- provide simple service via TupleSpace.
+ * rindac.rb --- service user
+
+* observer
+ cdbiff - ((<URI:http://namazu.org/~satoru/cdbiff/>))
+ * dbiff.rb --- dcdbiff server
+ * dcdbiff.rb --- dcdbiff client
+
+* drbssl
+ * drbssl_s.rb
+ * drbssl_c.rb
+
+* add DRbProtocl
+ * http0.rb
+ * http0serv.rb
+
+* Rinda::Ring
+ * ring_place.rb
+ * ring_echo.rb
diff --git a/sample/drb/README.rd.ja b/sample/drb/README.rd.ja
new file mode 100644
index 00000000000..04143b9ad56
--- /dev/null
+++ b/sample/drb/README.rd.ja
@@ -0,0 +1,59 @@
+= サンプルスクリプト
+
+* Arrayをリモートから利用してイテレータを試す。
+ * darray.rb --- server
+ * darrayc.rb --- client
+
+* 簡易チャット
+ * dchats.rb --- server
+ * dchatc.rb --- client
+
+* 分散chasen
+ * dhasen.rb --- server
+ * dhasenc.rb --- client
+
+* 簡易ログサーバ
+ * dlogd.rb --- server
+ * dlogc.rb --- client
+
+* Queueサーバ。
+ クライアントdqin.rbはQueueサーバの知らないオブジェクト(DQEntry)を
+ pushするがDRbUnknownによりクライアントdqout.rbがpopできる。
+ * dqueue.rb --- server
+ * dqin.rb --- client。DQEntryオブジェクトをpushする
+ * dqout.rb --- client。DQEntryオブジェクトをpopする
+ * dqlib.rb --- DQEntryを定義したライブラリ
+
+* 名前による参照
+ IdConvをカスタマイズしてidでなく名前で参照する例
+ * name.rb --- server
+ * namec.rb --- client
+
+* extservのサンプル
+ * extserv_test.rb
+
+* TimerIdConvの使用例
+ * holders.rb --- server。ruby -d hodlers.rbとするとTimerIdConvを使用する。
+ * holderc.rb --- client
+
+* rinda.rbの使用例
+ * rinda_ts.rb --- TupleSpaceサーバ。
+ * rindac.rb --- TupleSpaceのclientでアプリケーションのclient
+ * rindas.rb --- TupleSpaceのclientでアプリケーションのserver
+
+* observerの使用例
+ cdbiff - ((<URI:http://namazu.org/~satoru/cdbiff/>))
+ * dbiff.rb --- dcdbiff server
+ * dcdbiff.rb --- dcdbiff client
+
+* drbsslの使用例
+ * drbssl_s.rb
+ * drbssl_c.rb
+
+* DRbProtoclの追加例
+ * http0.rb
+ * http0serv.rb
+
+* ringの使用例
+ * ring_place.rb
+ * ring_echo.rb
diff --git a/sample/drb/darray.rb b/sample/drb/darray.rb
new file mode 100644
index 00000000000..bee295d2780
--- /dev/null
+++ b/sample/drb/darray.rb
@@ -0,0 +1,13 @@
+=begin
+ distributed Ruby --- Array
+ Copyright (c) 1999-2001 Masatoshi SEKI
+=end
+
+require 'drb/drb'
+
+here = ARGV.shift
+DRb.start_service(here, [1, 2, "III", 4, "five", 6])
+puts DRb.uri
+puts '[return] to exit'
+gets
+
diff --git a/sample/drb/darrayc.rb b/sample/drb/darrayc.rb
new file mode 100644
index 00000000000..6f5ff6bb5da
--- /dev/null
+++ b/sample/drb/darrayc.rb
@@ -0,0 +1,59 @@
+=begin
+ distributed Ruby --- Array client
+ Copyright (c) 1999-2001 Masatoshi SEKI
+=end
+
+require 'drb/drb'
+
+there = ARGV.shift || raise("usage: #{$0} <server_uri>")
+
+DRb.start_service(nil, nil)
+ro = DRbObject.new(nil, there)
+p ro.size
+
+puts "# collect"
+a = ro.collect { |x|
+ x + x
+}
+p a
+
+puts "# find"
+p ro.find { |x| x.kind_of? String }
+
+puts "# each, break"
+ro.each do |x|
+ next if x == "five"
+ puts x
+end
+
+puts "# each, break"
+ro.each do |x|
+ break if x == "five"
+ puts x
+end
+
+puts "# each, next"
+ro.each do |x|
+ next if x == "five"
+ puts x
+end
+
+puts "# each, redo"
+count = 0
+ro.each do |x|
+ count += 1
+ puts count
+ redo if count == 3
+end
+
+puts "# each, retry"
+retried = false
+ro.each do |x|
+ puts x
+ if x == 4 && !retried
+ puts 'retry'
+ retried = true
+ retry
+ end
+end
+
diff --git a/sample/drb/dbiff.rb b/sample/drb/dbiff.rb
new file mode 100644
index 00000000000..8faef50b07d
--- /dev/null
+++ b/sample/drb/dbiff.rb
@@ -0,0 +1,51 @@
+#
+# dbiff.rb - distributed cdbiff (server)
+# * original: cdbiff by Satoru Takabayashi <http://namazu.org/~satoru/cdbiff>
+
+require 'drb/drb'
+require 'drb/eq'
+require 'drb/observer'
+
+class Biff
+ include DRb::DRbObservable
+
+ def initialize(filename, interval)
+ super()
+ @filename = filename
+ @interval = interval
+ end
+
+ def run
+ last = Time.now
+ while true
+ begin
+ sleep(@interval)
+ current = File::mtime(@filename)
+ if current > last
+ changed
+ begin
+ notify_observers(@filename, current)
+ rescue Error
+ end
+ last = current
+ end
+ rescue
+ next
+ end
+ end
+ end
+end
+
+def main
+ filename = "/var/mail/#{ENV['USER']}"
+ interval = 15
+ uri = 'druby://:19903'
+
+ biff = Biff.new(filename, interval)
+
+ DRb.start_service(uri, biff)
+ biff.run
+end
+
+main
+
diff --git a/sample/drb/dcdbiff.rb b/sample/drb/dcdbiff.rb
new file mode 100644
index 00000000000..6a24680c33f
--- /dev/null
+++ b/sample/drb/dcdbiff.rb
@@ -0,0 +1,43 @@
+#
+# dcdbiff.rb - distributed cdbiff (client)
+# * original: cdbiff by Satoru Takabayashi <http://namazu.org/~satoru/cdbiff>
+
+require 'drb/drb'
+require 'drb/eq'
+
+class Notify
+ include DRbUndumped
+
+ def initialize(biff, command)
+ @biff = biff
+ @command = command
+
+ @biff.add_observer(self)
+ end
+
+ def update(filename, time)
+ p [filename, time] if $DEBUG
+ system(@command)
+ end
+
+ def done
+ begin
+ @biff.delete_observer(self)
+ rescue
+ end
+ end
+end
+
+def main
+ command = 'eject'
+ uri = 'druby://localhost:19903'
+
+ DRb.start_service
+ biff = DRbObject.new(nil, uri)
+ notify = Notify.new(biff, command)
+
+ trap("INT"){ notify.done }
+ DRb.thread.join
+end
+
+main
diff --git a/sample/drb/dchatc.rb b/sample/drb/dchatc.rb
new file mode 100644
index 00000000000..b506f5bbba1
--- /dev/null
+++ b/sample/drb/dchatc.rb
@@ -0,0 +1,41 @@
+=begin
+ distributed Ruby --- chat client
+ Copyright (c) 1999-2000 Masatoshi SEKI
+=end
+
+require 'drb/drb'
+
+class ChatClient
+ include DRbUndumped
+
+ def initialize(name)
+ @name = name
+ @key = nil
+ end
+ attr_reader(:name)
+ attr_accessor(:key)
+
+ def message(there, str)
+ raise 'invalid key' unless @key == there
+ puts str
+ end
+end
+
+if __FILE__ == $0
+ begin
+ there = ARGV.shift
+ name = ARGV.shift
+ raise "usage" unless (there and name)
+ rescue
+ $stderr.puts("usage: #{$0} <server_uri> <your_name>")
+ exit 1
+ end
+ DRb.start_service
+ ro = DRbObject.new(nil, there)
+
+ chat = ChatClient.new(name)
+ entry = ro.add_member(chat)
+ while gets
+ entry.say($_)
+ end
+end
diff --git a/sample/drb/dchats.rb b/sample/drb/dchats.rb
new file mode 100644
index 00000000000..b3133d1163c
--- /dev/null
+++ b/sample/drb/dchats.rb
@@ -0,0 +1,71 @@
+=begin
+ distributed Ruby --- chat server
+ Copyright (c) 1999-2000 Masatoshi SEKI
+=end
+require 'thread'
+require 'drb/drb'
+
+class ChatEntry
+ include DRbUndumped
+
+ def initialize(server, there)
+ @server = server
+ @there = there
+ @name = there.name
+ @key = there.key = Time.now
+ end
+ attr :name, true
+ attr :there
+
+ def say(str)
+ @server.distribute(@there, str)
+ end
+
+ def listen(str)
+ @there.message(@key, str)
+ end
+end
+
+
+class ChatServer
+ def initialize
+ @mutex = Mutex.new
+ @members = {}
+ end
+
+ def add_member(there)
+ client = ChatEntry.new(self, there)
+ @mutex.synchronize do
+ @members[there] = client
+ end
+ client
+ end
+
+ def distribute(there, str)
+ name = @members[there].name
+ msg = "<#{name}> #{str}"
+ msg2 = ">#{name}< #{str}"
+ @mutex.synchronize do
+ for m in @members.keys
+ begin
+ if m == there
+ @members[m].listen(msg2)
+ else
+ @members[m].listen(msg)
+ end
+ rescue
+ p $!
+ @members.delete(m)
+ end
+ end
+ end
+ end
+end
+
+if __FILE__ == $0
+ here = ARGV.shift
+ DRb.start_service(here, ChatServer.new)
+ puts DRb.uri
+ puts '[return] to exit.'
+ gets
+end
diff --git a/sample/drb/dhasen.rb b/sample/drb/dhasen.rb
new file mode 100644
index 00000000000..5dac88853c7
--- /dev/null
+++ b/sample/drb/dhasen.rb
@@ -0,0 +1,43 @@
+=begin
+ distributed Ruby --- dRuby Sample Server --- chasen server
+ Copyright (c) 1999-2001 Masatoshi SEKI
+=end
+
+=begin
+ How to play.
+
+ Terminal 1
+ | % ruby dhasen.rb
+ | druby://yourhost:7640
+
+ Terminal 2
+ | % ruby dhasenc.rb druby://yourhost:7640
+
+=end
+
+require 'drb/drb'
+require 'chasen'
+require 'thread'
+
+class Dhasen
+ include DRbUndumped
+
+ def initialize
+ @mutex = Mutex.new
+ end
+
+ def sparse(str, *arg)
+ @mutex.synchronize do
+ Chasen.getopt(*arg)
+ Chasen.sparse(str)
+ end
+ end
+end
+
+if __FILE__ == $0
+ DRb.start_service(nil, Dhasen.new)
+ puts DRb.uri
+ puts '[return] to exit.'
+ gets
+end
+
diff --git a/sample/drb/dhasenc.rb b/sample/drb/dhasenc.rb
new file mode 100644
index 00000000000..8114e9228dd
--- /dev/null
+++ b/sample/drb/dhasenc.rb
@@ -0,0 +1,13 @@
+=begin
+ distributed Ruby --- dRuby Sample Client -- chasen client
+ Copyright (c) 1999-2001 Masatoshi SEKI
+=end
+
+require 'drb/drb'
+
+there = ARGV.shift || raise("usage: #{$0} <server_uri>")
+DRb.start_service
+dhasen = DRbObject.new(nil, there)
+
+print dhasen.sparse("本日は、晴天なり。", "-F", '(%BB %m %M)\n', "-j")
+print dhasen.sparse("本日は、晴天なり。", "-F", '(%m %M)\n')
diff --git a/sample/drb/dlogc.rb b/sample/drb/dlogc.rb
new file mode 100644
index 00000000000..c75bc7b520c
--- /dev/null
+++ b/sample/drb/dlogc.rb
@@ -0,0 +1,16 @@
+=begin
+ distributed Ruby --- Log test
+ Copyright (c) 1999-2001 Masatoshi SEKI
+=end
+
+require 'drb/drb'
+
+there = ARGV.shift || raise("usage: #{$0} <server_uri>")
+
+DRb.start_service
+ro = DRbObject.new(nil, there)
+ro.log(123)
+ro.log("hello")
+sleep 2
+ro.log("wakeup")
+
diff --git a/sample/drb/dlogd.rb b/sample/drb/dlogd.rb
new file mode 100644
index 00000000000..9f9aa2fd567
--- /dev/null
+++ b/sample/drb/dlogd.rb
@@ -0,0 +1,39 @@
+=begin
+ distributed Ruby --- Log server
+ Copyright (c) 1999-2000 Masatoshi SEKI
+=end
+
+require 'drb/drb'
+require 'thread'
+
+class Logger
+ def initialize(fname)
+ @fname = fname.to_s
+ @fp = File.open(@fname, "a+")
+ @queue = Queue.new
+ @th = Thread.new { self.flush }
+ end
+
+ def log(str)
+ @queue.push("#{Time.now}\t" + str.to_s)
+ end
+
+ def flush
+ begin
+ while(1)
+ @fp.puts(@queue.pop)
+ @fp.flush
+ end
+ ensure
+ @fp.close
+ end
+ end
+end
+
+if __FILE__ == $0
+ here = ARGV.shift
+ DRb.start_service(here, Logger.new('/usr/tmp/dlogd.log'))
+ puts DRb.uri
+ DRb.thread.join
+end
+
diff --git a/sample/drb/dqin.rb b/sample/drb/dqin.rb
new file mode 100644
index 00000000000..3ba1caa80c8
--- /dev/null
+++ b/sample/drb/dqin.rb
@@ -0,0 +1,13 @@
+=begin
+ distributed Ruby --- store
+ Copyright (c) 1999-2000 Masatoshi SEKI
+=end
+
+require 'drb/drb'
+require 'dqlib'
+
+there = ARGV.shift || raise("usage: #{$0} <server_uri>")
+
+DRb.start_service
+queue = DRbObject.new(nil, there)
+queue.push(DQEntry.new(DRb.uri))
diff --git a/sample/drb/dqlib.rb b/sample/drb/dqlib.rb
new file mode 100644
index 00000000000..75f2e6115b7
--- /dev/null
+++ b/sample/drb/dqlib.rb
@@ -0,0 +1,14 @@
+class DQEntry
+ def initialize(name)
+ @name = name
+ end
+
+ def greeting
+ "Hello, This is #{@name}."
+ end
+ alias to_s greeting
+end
+
+if __FILE__ == $0
+ puts DQEntry.new('DQEntry')
+end
diff --git a/sample/drb/dqout.rb b/sample/drb/dqout.rb
new file mode 100644
index 00000000000..4700e55cf7c
--- /dev/null
+++ b/sample/drb/dqout.rb
@@ -0,0 +1,14 @@
+=begin
+ distributed Ruby --- fetch
+ Copyright (c) 1999-2000 Masatoshi SEKI
+=end
+
+require 'drb/drb'
+require 'dqlib'
+
+there = ARGV.shift || raise("usage: #{$0} <server_uri>")
+
+DRb.start_service
+queue = DRbObject.new(nil, there)
+entry = queue.pop
+puts entry.greeting
diff --git a/sample/drb/dqueue.rb b/sample/drb/dqueue.rb
new file mode 100644
index 00000000000..90ec56ce650
--- /dev/null
+++ b/sample/drb/dqueue.rb
@@ -0,0 +1,13 @@
+=begin
+ distributed Ruby --- Queue
+ Copyright (c) 1999-2000 Masatoshi SEKI
+=end
+
+require 'thread'
+require 'drb/drb'
+
+DRb.start_service(nil, Queue.new)
+puts DRb.uri
+puts '[return] to exit'
+gets
+
diff --git a/sample/drb/drbc.rb b/sample/drb/drbc.rb
new file mode 100644
index 00000000000..00132b46c83
--- /dev/null
+++ b/sample/drb/drbc.rb
@@ -0,0 +1,45 @@
+=begin
+ distributed Ruby --- dRuby Sample Client
+ Copyright (c) 1999-2000 Masatoshi SEKI
+=end
+
+require 'drb/drb'
+
+class DRbEx2
+ include DRbUndumped
+
+ def initialize(n)
+ @n = n
+ end
+
+ def to_i
+ @n.to_i
+ end
+end
+
+if __FILE__ == $0
+ there = ARGV.shift
+ unless there
+ $stderr.puts("usage: #{$0} <server_uri>")
+ exit 1
+ end
+
+ DRb.start_service()
+ ro = DRbObject.new_with_uri(there)
+
+ puts ro
+ p ro.to_a
+ puts ro.hello
+ p ro.hello
+ puts ro.sample(DRbEx2.new(1), 2, 3)
+ puts ro.sample(1, ro.sample(DRbEx2.new(1), 2, 3), DRbEx2.new(3))
+
+ begin
+ ro.err
+ rescue DRb::DRbUnknownError
+ p $!
+ p $!.unknown
+ rescue RuntimeError
+ p $!
+ end
+end
diff --git a/sample/drb/drbch.rb b/sample/drb/drbch.rb
new file mode 100644
index 00000000000..495ff1c3469
--- /dev/null
+++ b/sample/drb/drbch.rb
@@ -0,0 +1,48 @@
+=begin
+ distributed Ruby --- dRuby Sample Client
+ Copyright (c) 1999-2000 Masatoshi SEKI
+=end
+
+require 'drb/drb'
+require 'drb/http'
+
+class DRbEx2
+ include DRbUndumped
+
+ def initialize(n)
+ @n = n
+ end
+
+ def to_i
+ @n.to_i
+ end
+end
+
+if __FILE__ == $0
+ there = ARGV.shift
+ unless there
+ $stderr.puts("usage: #{$0} <server_uri>")
+ exit 1
+ end
+
+ DRb::DRbConn.proxy_map['x68k'] = 'http://x68k/~mas/http_cgi.rb'
+
+ DRb.start_service()
+ ro = DRbObject.new(nil, there)
+
+ puts ro
+ p ro.to_a
+ puts ro.hello
+ p ro.hello
+ puts ro.sample(DRbEx2.new(1), 2, 3)
+ puts ro.sample(1, ro.sample(DRbEx2.new(1), 2, 3), DRbEx2.new(3))
+
+ begin
+ ro.err
+ rescue DRb::DRbUnknownError
+ p $!
+ p $!.unknown
+ rescue RuntimeError
+ p $!
+ end
+end
diff --git a/sample/drb/drbm.rb b/sample/drb/drbm.rb
new file mode 100644
index 00000000000..37a26cdfa52
--- /dev/null
+++ b/sample/drb/drbm.rb
@@ -0,0 +1,59 @@
+=begin
+ multiple DRbServer
+ Copyright (c) 1999-2002 Masatoshi SEKI
+=end
+
+=begin
+ How to play.
+
+ Terminal 1
+ | % ruby drbm.rb
+ | druby://yourhost:7640 druby://yourhost:7641
+
+ Terminal 2
+ | % ruby drbmc.rb druby://yourhost:7640 druby://yourhost:7641
+ | [#<DRb::DRbObject .... @uri="druby://yourhost:7640">, "FOO"]
+ | [#<DRb::DRbObject .... @uri="druby://yourhost:7641">, "FOO"]
+
+=end
+
+require 'drb/drb'
+
+class Hoge
+ include DRbUndumped
+ def initialize(s)
+ @str = s
+ end
+
+ def to_s
+ @str
+ end
+end
+
+class Foo
+ def initialize(s='FOO')
+ @hoge = Hoge.new(s)
+ end
+
+ def hello
+ @hoge
+ end
+end
+
+class Bar < Foo
+ def initialize(foo)
+ @hoge = foo.hello
+ end
+end
+
+
+if __FILE__ == $0
+ foo = Foo.new
+ s1 = DRb::DRbServer.new('druby://:7640', foo)
+ s2 = DRb::DRbServer.new('druby://:7641', Bar.new(foo))
+
+ puts "#{s1.uri} #{s2.uri}"
+
+ gets
+end
+
diff --git a/sample/drb/drbmc.rb b/sample/drb/drbmc.rb
new file mode 100644
index 00000000000..c654fcea05e
--- /dev/null
+++ b/sample/drb/drbmc.rb
@@ -0,0 +1,22 @@
+=begin
+ multiple DRbServer client
+ Copyright (c) 1999-2002 Masatoshi SEKI
+=end
+
+require 'drb/drb'
+
+if __FILE__ == $0
+ s1 = ARGV.shift
+ s2 = ARGV.shift
+ unless s1 && s2
+ $stderr.puts("usage: #{$0} <server_uri1> <server_uri2>")
+ exit 1
+ end
+
+ DRb.start_service()
+ r1 = DRbObject.new(nil, s1)
+ r2 = DRbObject.new(nil, s2)
+
+ p [r1.hello, r1.hello.to_s]
+ p [r2.hello, r2.hello.to_s]
+end
diff --git a/sample/drb/drbs-acl.rb b/sample/drb/drbs-acl.rb
new file mode 100644
index 00000000000..151dd945d81
--- /dev/null
+++ b/sample/drb/drbs-acl.rb
@@ -0,0 +1,51 @@
+=begin
+ distributed Ruby --- dRuby Sample Server
+ Copyright (c) 1999-2000 Masatoshi SEKI
+=end
+
+=begin
+ How to play.
+
+ Terminal 1
+ | % ruby drbs.rb
+ | druby://yourhost:7640
+
+ Terminal 2
+ | % ruby drbc.rb druby://yourhost:7640
+ | "hello"
+ | 6
+ | 10
+
+=end
+
+require 'drb/drb'
+require 'acl'
+
+class DRbEx
+ def initialize
+ @hello = 'hello'
+ end
+
+ def hello
+ info = Thread.current['DRb']
+ p info['socket'].peeraddr if info
+ @hello
+ end
+
+ def sample(a, b, c)
+ a.to_i + b.to_i + c.to_i
+ end
+end
+
+if __FILE__ == $0
+ acl = ACL.new(%w(deny all
+ allow 192.168.1.*
+ allow localhost))
+
+ DRb.install_acl(acl)
+
+ DRb.start_service(nil, DRbEx.new)
+ puts DRb.uri
+ DRb.thread.join
+end
+
diff --git a/sample/drb/drbs.rb b/sample/drb/drbs.rb
new file mode 100644
index 00000000000..b76e283c80c
--- /dev/null
+++ b/sample/drb/drbs.rb
@@ -0,0 +1,64 @@
+=begin
+ distributed Ruby --- dRuby Sample Server
+ Copyright (c) 1999-2000,2002 Masatoshi SEKI
+=end
+
+=begin
+ How to play.
+
+ Terminal 1
+ | % ruby drbs.rb
+ | druby://yourhost:7640
+
+ Terminal 2
+ | % ruby drbc.rb druby://yourhost:7640
+ | "hello"
+ | ....
+
+=end
+
+require 'drb/drb'
+
+class DRbEx
+ include DRbUndumped
+
+ def initialize
+ @hello = 'hello'
+ end
+
+ def hello
+ cntxt = Thread.current['DRb']
+ if cntxt
+ p cntxt['server'].uri
+ p cntxt['client'].peeraddr
+ end
+ Foo::Unknown.new
+ end
+
+ def err
+ raise FooError
+ end
+
+ def sample(a, b, c)
+ a.to_i + b.to_i + c.to_i
+ end
+end
+
+class Foo
+ class Unknown
+ end
+end
+
+class FooError < RuntimeError
+end
+
+if __FILE__ == $0
+ DRb.start_service(ARGV.shift || 'druby://:7640', DRbEx.new)
+ puts DRb.uri
+ Thread.new do
+ sleep 10
+ DRb.stop_service
+ end
+ DRb.thread.join
+end
+
diff --git a/sample/drb/drbssl_c.rb b/sample/drb/drbssl_c.rb
new file mode 100644
index 00000000000..65112f6e787
--- /dev/null
+++ b/sample/drb/drbssl_c.rb
@@ -0,0 +1,19 @@
+#!/usr/bin/env ruby
+
+require 'drb'
+require 'drb/ssl'
+
+there = ARGV.shift || "drbssl://localhost:3456"
+
+config = Hash.new
+config[:SSLVerifyMode] = OpenSSL::SSL::VERIFY_PEER
+config[:SSLVerifyCallback] = lambda{|ok,x509_store|
+ p [ok, x509_store.error_string]
+ true
+}
+
+DRb.start_service(nil,nil,config)
+h = DRbObject.new(nil, there)
+while line = gets
+ p h.hello(line.chomp)
+end
diff --git a/sample/drb/drbssl_s.rb b/sample/drb/drbssl_s.rb
new file mode 100644
index 00000000000..94d02f63cca
--- /dev/null
+++ b/sample/drb/drbssl_s.rb
@@ -0,0 +1,32 @@
+#!/usr/bin/env ruby
+
+require 'drb'
+require 'drb/ssl'
+
+here = ARGV.shift || "drbssl://localhost:3456"
+
+class HelloWorld
+ include DRbUndumped
+
+ def hello(name)
+ "Hello, #{name}."
+ end
+end
+
+config = Hash.new
+config[:verbose] = true
+begin
+ data = open("sample.key"){|io| io.read }
+ config[:SSLPrivateKey] = OpenSSL::PKey::RSA.new(data)
+ data = open("sample.crt"){|io| io.read }
+ config[:SSLCertificate] = OpenSSL::X509::Certificate.new(data)
+rescue
+ $stderr.puts "Switching to use self-signed certificate"
+ config[:SSLCertName] =
+ [ ["C","JP"], ["O","Foo.DRuby.Org"], ["CN", "Sample"] ]
+end
+
+DRb.start_service(here, HelloWorld.new, config)
+puts DRb.uri
+$stdin.gets
+DRb.stop_service
diff --git a/sample/drb/extserv_test.rb b/sample/drb/extserv_test.rb
new file mode 100644
index 00000000000..83d871a6a2a
--- /dev/null
+++ b/sample/drb/extserv_test.rb
@@ -0,0 +1,80 @@
+=begin
+ dRuby sample
+ Copyright (c) 2000 Masatoshi SEKI
+
+= How to play
+
+* Terminal 1
+
+ % ruby -I. extserv_test.rb server
+ druby://yourhost:12345
+
+* Terminal 2
+
+ % ruby -I. extserv_test.rb druby://yourhost:12345
+ ...
+
+=end
+
+require 'drb/drb'
+
+def ARGV.shift
+ it = super()
+ raise "usage:\nserver: #{$0} server [<uri>]\nclient: #{$0} [quit] <uri>" unless it
+ it
+end
+
+class Foo
+ include DRbUndumped
+
+ def initialize(str)
+ @str = str
+ end
+
+ def hello(it)
+ "#{it}: #{self}"
+ end
+
+ def to_s
+ @str
+ end
+end
+
+cmd = ARGV.shift
+case cmd
+when 'itest1', 'itest2'
+ require 'drb/extserv'
+
+ front = Foo.new(cmd)
+ server = DRb::DRbServer.new(nil, front)
+ es = DRb::ExtServ.new(ARGV.shift, ARGV.shift, server)
+ server.thread.join
+
+when 'server'
+ require 'drb/extservm'
+
+ DRb::ExtServManager.command['itest1'] = "ruby -I. #{$0} itest1"
+ DRb::ExtServManager.command['itest2'] = "ruby -I. #{$0} itest2"
+
+ s = DRb::ExtServManager.new
+ DRb.start_service(ARGV.shift, s)
+ puts DRb.uri
+ DRb.thread.join
+
+
+else
+ uri = (cmd == 'quit') ? ARGV.shift : cmd
+
+ DRb.start_service
+ s = DRbObject.new(nil, uri)
+ t1 = s.service('itest1').front
+ puts t1
+ t2 = s.service('itest2').front
+ puts t2
+ puts t1.hello(t2)
+ if (cmd == 'quit')
+ s.service('itest1').stop_service
+ s.service('itest2').stop_service
+ end
+end
+
diff --git a/sample/drb/gw_ct.rb b/sample/drb/gw_ct.rb
new file mode 100644
index 00000000000..06227840183
--- /dev/null
+++ b/sample/drb/gw_ct.rb
@@ -0,0 +1,29 @@
+require 'drb/drb'
+
+class Foo
+ include DRbUndumped
+
+ def foo(n)
+ n + n
+ end
+
+ def bar(n)
+ yield(n) + yield(n)
+ end
+end
+
+DRb.start_service(nil)
+puts DRb.uri
+
+ro = DRbObject.new(nil, ARGV.shift)
+ro[:tcp] = Foo.new
+gets
+
+it = ro[:unix]
+p [it, it.foo(1)]
+gets
+
+p it.bar('2') {|n| n * 3}
+gets
+
+
diff --git a/sample/drb/gw_cu.rb b/sample/drb/gw_cu.rb
new file mode 100644
index 00000000000..0e5ed36b8f9
--- /dev/null
+++ b/sample/drb/gw_cu.rb
@@ -0,0 +1,28 @@
+require 'drb/drb'
+require 'drb/unix'
+
+class Foo
+ include DRbUndumped
+
+ def foo(n)
+ n + n
+ end
+
+ def bar(n)
+ yield(n) + yield(n)
+ end
+end
+
+DRb.start_service('drubyunix:', nil)
+puts DRb.uri
+
+ro = DRbObject.new(nil, ARGV.shift)
+ro[:unix] = Foo.new
+gets
+
+it = ro[:tcp]
+p [it, it.foo(1)]
+gets
+
+p it.bar('2') {|n| n * 3}
+gets
diff --git a/sample/drb/gw_s.rb b/sample/drb/gw_s.rb
new file mode 100644
index 00000000000..f91249b3e02
--- /dev/null
+++ b/sample/drb/gw_s.rb
@@ -0,0 +1,9 @@
+require 'drb/drb'
+require 'drb/unix'
+require 'drb/gw'
+
+DRb.install_id_conv(DRb::GWIdConv.new)
+gw = DRb::GW.new
+s1 = DRb::DRbServer.new(ARGV.shift, gw)
+s2 = DRb::DRbServer.new(ARGV.shift, gw)
+gets
diff --git a/sample/drb/holderc.rb b/sample/drb/holderc.rb
new file mode 100644
index 00000000000..8dd72ebd118
--- /dev/null
+++ b/sample/drb/holderc.rb
@@ -0,0 +1,22 @@
+require 'drb/drb'
+
+begin
+ there = ARGV.shift || raise
+rescue
+ $stderr.puts("usage: #{$0} <server_uri>")
+ exit 1
+end
+
+DRb.start_service()
+ro = DRbObject.new(nil, there)
+
+ary = []
+10.times do
+ ary.push(ro.gen)
+end
+
+sleep 5 if $DEBUG
+
+ary.each do |e|
+ p e.sample([1])
+end
diff --git a/sample/drb/holders.rb b/sample/drb/holders.rb
new file mode 100644
index 00000000000..20939034cd2
--- /dev/null
+++ b/sample/drb/holders.rb
@@ -0,0 +1,64 @@
+=begin
+= How to play.
+
+== with timeridconv:
+ % ruby -d holders.rb
+ druby://yourhost:1234
+
+ % ruby holderc.rb druby://yourhost:1234
+
+
+== without timeridconv:
+ % ruby holders.rb
+ druby://yourhost:1234
+
+ % ruby holderc.rb druby://yourhost:1234
+=end
+
+
+require 'drb/drb'
+
+class DRbEx3
+ include DRbUndumped
+
+ def initialize(n)
+ @v = n
+ end
+
+ def sample(list)
+ sum = 0
+ list.each do |e|
+ sum += e.to_i
+ end
+ @v * sum
+ end
+end
+
+class DRbEx4
+ include DRbUndumped
+
+ def initialize
+ @curr = 1
+ end
+
+ def gen
+ begin
+ @curr += 1
+ DRbEx3.new(@curr)
+ ensure
+ GC.start
+ end
+ end
+end
+
+if __FILE__ == $0
+ if $DEBUG
+ require 'drb/timeridconv'
+ DRb.install_id_conv(DRb::TimerIdConv.new(2))
+ end
+
+ DRb.start_service(nil, DRbEx4.new)
+ puts DRb.uri
+ puts '[return] to exit'
+ gets
+end
diff --git a/sample/drb/http0.rb b/sample/drb/http0.rb
new file mode 100644
index 00000000000..7649925282a
--- /dev/null
+++ b/sample/drb/http0.rb
@@ -0,0 +1,77 @@
+require 'drb/drb'
+require 'net/http'
+require 'uri'
+
+module DRb
+ module HTTP0
+ class StrStream
+ def initialize(str='')
+ @buf = str
+ end
+ attr_reader :buf
+
+ def read(n)
+ begin
+ return @buf[0,n]
+ ensure
+ @buf[0,n] = ''
+ end
+ end
+
+ def write(s)
+ @buf.concat s
+ end
+ end
+
+ def self.uri_option(uri, config)
+ return uri, nil
+ end
+
+ def self.open(uri, config)
+ unless /^http:/ =~ uri
+ raise(DRbBadScheme, uri) unless uri =~ /^http:/
+ raise(DRbBadURI, 'can\'t parse uri:' + uri)
+ end
+ ClientSide.new(uri, config)
+ end
+
+ class ClientSide
+ def initialize(uri, config)
+ @uri = uri
+ @res = nil
+ @config = config
+ @msg = DRbMessage.new(config)
+ @proxy = ENV['HTTP_PROXY']
+ end
+
+ def close; end
+ def alive?; false; end
+
+ def send_request(ref, msg_id, *arg, &b)
+ stream = StrStream.new
+ @msg.send_request(stream, ref, msg_id, *arg, &b)
+ @reply_stream = StrStream.new
+ post(@uri, stream.buf)
+ end
+
+ def recv_reply
+ @msg.recv_reply(@reply_stream)
+ end
+
+ def post(url, data)
+ it = URI.parse(url)
+ path = [(it.path=='' ? '/' : it.path), it.query].compact.join('?')
+ http = Net::HTTP.new(it.host, it.port)
+ sio = StrStream.new
+ http.post(path, data, {'Content-Type'=>'application/octetstream;'}) do |str|
+ sio.write(str)
+ if @config[:load_limit] < sio.buf.size
+ raise TypeError, 'too large packet'
+ end
+ end
+ @reply_stream = sio
+ end
+ end
+ end
+ DRbProtocol.add_protocol(HTTP0)
+end
diff --git a/sample/drb/http0serv.rb b/sample/drb/http0serv.rb
new file mode 100644
index 00000000000..100d126b8f5
--- /dev/null
+++ b/sample/drb/http0serv.rb
@@ -0,0 +1,119 @@
+require 'webrick'
+require 'drb/drb'
+require 'drb/http0'
+require 'thread'
+
+module DRb
+ module HTTP0
+
+ def self.open_server(uri, config)
+ unless /^http:/ =~ uri
+ raise(DRbBadScheme, uri) unless uri =~ /^http:/
+ raise(DRbBadURI, 'can\'t parse uri:' + uri)
+ end
+ Server.new(uri, config)
+ end
+
+ class Callback < WEBrick::HTTPServlet::AbstractServlet
+ def initialize(config, drb)
+ @config = config
+ @drb = drb
+ @queue = Queue.new
+ end
+
+ def do_POST(req, res)
+ @req = req
+ @res = res
+ @drb.push(self)
+ @res.body = @queue.pop
+ @res['content-type'] = 'application/octet-stream;'
+ end
+
+ def req_body
+ @req.body
+ end
+
+ def reply(body)
+ @queue.push(body)
+ end
+
+ def close
+ @queue.push('')
+ end
+ end
+
+ class Server
+ def initialize(uri, config)
+ @uri = uri
+ @config = config
+ @queue = Queue.new
+ setup_webrick(uri)
+ end
+ attr_reader :uri
+
+ def close
+ @server.shutdown if @server
+ @server = nil
+ end
+
+ def push(callback)
+ @queue.push(callback)
+ end
+
+ def accept
+ client = @queue.pop
+ ServerSide.new(client, @config)
+ end
+
+ def setup_webrick(uri)
+ logger = WEBrick::Log::new($stderr, WEBrick::Log::FATAL)
+ u = URI.parse(uri)
+ s = WEBrick::HTTPServer.new(:Port => u.port,
+ :AddressFamily => Socket::AF_INET,
+ :BindAddress => u.host,
+ :Logger => logger,
+ :ServerType => Thread)
+ s.mount(u.path, Callback, self)
+ @server = s
+ s.start
+ end
+ end
+
+ class ServerSide
+ def initialize(callback, config)
+ @callback = callback
+ @config = config
+ @msg = DRbMessage.new(@config)
+ @req_stream = StrStream.new(@callback.req_body)
+ end
+
+ def close
+ @callback.close if @callback
+ @callback = nil
+ end
+
+ def alive?; false; end
+
+ def recv_request
+ begin
+ @msg.recv_request(@req_stream)
+ rescue
+ close
+ raise $!
+ end
+ end
+
+ def send_reply(succ, result)
+ begin
+ return unless @callback
+ stream = StrStream.new
+ @msg.send_reply(stream, succ, result)
+ @callback.reply(stream.buf)
+ rescue
+ close
+ raise $!
+ end
+ end
+ end
+ end
+end
diff --git a/sample/drb/name.rb b/sample/drb/name.rb
new file mode 100644
index 00000000000..461f965c16f
--- /dev/null
+++ b/sample/drb/name.rb
@@ -0,0 +1,118 @@
+=begin
+ distributed Ruby --- NamedObject Sample
+ Copyright (c) 2000-2001 Masatoshi SEKI
+=end
+
+=begin
+How to play.
+
+* start server
+ Terminal 1
+ | % ruby name.rb druby://yourhost:7640
+ | druby://yourhost:7640
+ | [return] to exit
+
+* start client
+ Terminal 2
+ | % ruby namec.rb druby://yourhost:7640
+ | #<DRb::DRbObject:0x40164174 @uri="druby://yourhost:7640", @ref="seq">
+ | #<DRb::DRbObject:0x40163c9c @uri="druby://yourhost:7640", @ref="mutex">
+ | 1
+ | 2
+ | [return] to continue
+
+* restart server
+ Terminal 1
+ type [return]
+ | % ruby name.rb druby://yourhost:7640
+ | druby://yourhost:7640
+ | [return] to exit
+
+* continue client
+ Terminal 2
+ type [return]
+ | 1
+ | 2
+=end
+
+require 'thread.rb'
+require 'drb/drb'
+
+module DRbNamedObject
+ DRbNAMEDICT = {}
+ attr_reader(:drb_name)
+
+ def drb_name=(name)
+ @drb_name = name
+ Thread.exclusive do
+ raise(IndexError, name) if DRbNAMEDICT[name]
+ DRbNAMEDICT[name] = self
+ end
+ end
+end
+
+class DRbNamedIdConv < DRb::DRbIdConv
+ def initialize
+ @dict = DRbNamedObject::DRbNAMEDICT
+ end
+
+ def to_obj(ref)
+ @dict.fetch(ref) do super end
+ end
+
+ def to_id(obj)
+ if obj.kind_of? DRbNamedObject
+ return obj.drb_name
+ else
+ return super
+ end
+ end
+end
+
+class Seq
+ include DRbUndumped
+ include DRbNamedObject
+
+ def initialize(v, name)
+ @counter = v
+ @mutex = Mutex.new
+ self.drb_name = name
+ end
+
+ def next_value
+ @mutex.synchronize do
+ @counter += 1
+ return @counter
+ end
+ end
+end
+
+class Front
+ def initialize
+ seq = Seq.new(0, 'seq')
+ mutex = Mutex.new
+ mutex.extend(DRbUndumped)
+ mutex.extend(DRbNamedObject)
+ mutex.drb_name = 'mutex'
+ @name = {}
+ @name['seq'] = seq
+ @name['mutex'] = mutex
+ end
+
+ def [](k)
+ @name[k]
+ end
+end
+
+if __FILE__ == $0
+ uri = ARGV.shift
+
+ name_conv = DRbNamedIdConv.new
+
+ DRb.install_id_conv(name_conv)
+ DRb.start_service(uri, Front.new)
+ puts DRb.uri
+ puts '[return] to exit'
+ gets
+end
+
diff --git a/sample/drb/namec.rb b/sample/drb/namec.rb
new file mode 100644
index 00000000000..f6db6f30221
--- /dev/null
+++ b/sample/drb/namec.rb
@@ -0,0 +1,36 @@
+=begin
+ distributed Ruby --- NamedObject Sample Client
+ Copyright (c) 2000-2001 Masatoshi SEKI
+=end
+
+require 'drb/drb'
+
+begin
+ there = ARGV.shift || raise
+rescue
+ puts "usage: #{$0} <server_uri>"
+ exit 1
+end
+
+DRb.start_service()
+ro = DRbObject.new(nil, there)
+
+seq = ro["seq"]
+mutex = ro["mutex"]
+
+p seq
+p mutex
+
+mutex.synchronize do
+ p seq.next_value
+ p seq.next_value
+end
+
+puts '[return] to continue'
+gets
+
+mutex.synchronize do
+ p seq.next_value
+ p seq.next_value
+end
+
diff --git a/sample/drb/old_tuplespace.rb b/sample/drb/old_tuplespace.rb
new file mode 100644
index 00000000000..3e13b92ee11
--- /dev/null
+++ b/sample/drb/old_tuplespace.rb
@@ -0,0 +1,214 @@
+#!/usr/local/bin/ruby
+# TupleSpace
+# Copyright (c) 1999-2000 Masatoshi SEKI
+# You can redistribute it and/or modify it under the same terms as Ruby.
+
+require 'thread'
+
+class TupleSpace
+ class Template
+ def initialize(list)
+ @list = list
+ @check_idx = []
+ @list.each_with_index do |x, i|
+ @check_idx.push i if x
+ end
+ @size = @list.size
+ end
+
+ attr :size
+ alias length size
+
+ def match(tuple)
+ return nil if tuple.size != self.size
+ @check_idx.each do |i|
+ unless @list[i] === tuple[i]
+ return false
+ end
+ end
+ return true
+ end
+ end
+
+ def initialize
+ @que = {}
+ @waiting = {}
+ @que.taint # enable tainted comunication
+ @waiting.taint
+ self.taint
+ end
+
+ def wakeup_waiting(tuple)
+ sz = tuple.length
+ return nil unless @waiting[sz]
+
+ x = nil
+ i = -1
+ found = false
+ @waiting[sz] = @waiting[sz].find_all { |x|
+ if x[0].match(tuple)
+ begin
+ x[1].wakeup
+ rescue ThreadError
+ end
+ false
+ else
+ true
+ end
+ }
+ end
+
+ def put_waiting(template, thread)
+ sz = template.length
+ @waiting[sz] = [] unless @waiting[sz]
+ @waiting[sz].push([Template.new(template), thread])
+ end
+ private :wakeup_waiting
+ private :put_waiting
+
+ def get_que(template)
+ sz = template.length
+ return nil unless @que[sz]
+
+ template = Template.new(template)
+
+ x = nil
+ i = -1
+ found = false
+ @que[sz].each_with_index do |x, i|
+ if template.match(x)
+ found = true
+ break
+ end
+ end
+ return nil unless found
+
+ @que[sz].delete_at(i)
+
+ return x
+ end
+
+ def put_que(tuple)
+ sz = tuple.length
+ @que[sz] = [] unless @que[sz]
+ @que[sz].push tuple
+ end
+ private :get_que
+ private :put_que
+
+ def out(*tuples)
+ tuples.each do |tuple|
+ Thread.critical = true
+ put_que(tuple)
+ wakeup_waiting(tuple)
+ Thread.critical = false
+ end
+ end
+ alias put out
+ alias write out
+
+ def in(template, non_block=false)
+ begin
+ loop do
+ Thread.critical = true
+ tuple = get_que(template)
+ unless tuple
+ if non_block
+ raise ThreadError, "queue empty"
+ end
+ put_waiting(template, Thread.current)
+ Thread.stop
+ else
+ return tuple
+ end
+ end
+ ensure
+ Thread.critical = false
+ end
+ end
+ alias get in
+ alias take in
+
+ def rd(template, non_block=false)
+ tuple = self.in(template, non_block)
+ out(tuple)
+ tuple
+ end
+ alias read rd
+
+ def mv(dest, template, non_block=false)
+ tuple = self.in(template, non_block)
+ begin
+ dest.out(tuple)
+ rescue
+ self.out(tuple)
+ end
+ end
+ alias move mv
+end
+
+if __FILE__ == $0
+ ts = TupleSpace.new
+ clients = []
+ servers = []
+
+ def server(ts, id)
+ Thread.start {
+ loop do
+ req = ts.in(['req', nil, nil])
+ ac = req[1]
+ num = req[2]
+ sleep id
+ ts.out([ac, id, num, num * num])
+ end
+ }
+ end
+
+ def client(ts, n)
+ Thread.start {
+ ac = Object.new
+ tuples = (1..10).collect { |i|
+ ['req', ac, i * 10 + n]
+ }
+ ts.out(*tuples)
+ ts.out(tuples[0])
+ puts "out: #{n}"
+ 11.times do |i|
+ ans = ts.in([ac, nil, nil, nil])
+ puts "client(#{n}) server(#{ans[1]}) #{ans[2]} #{ans[3]}"
+ end
+ }
+ end
+
+ def watcher(ts)
+ Thread.start {
+ loop do
+ begin
+ sleep 1
+ p ts.rd(['req', nil, nil], true)
+ rescue ThreadError
+ puts "'req' not found."
+ end
+ end
+ }
+ end
+
+ (0..3).each do |n|
+ servers.push(server(ts, n))
+ end
+
+ (1..6).each do |n|
+ clients.push(client(ts, n))
+ end
+
+ (1..3).each do
+ watcher(ts)
+ end
+
+ clients.each do |t|
+ t.join
+ end
+end
+
+
+
diff --git a/sample/drb/rinda_ts.rb b/sample/drb/rinda_ts.rb
new file mode 100644
index 00000000000..6f2fae5c0f2
--- /dev/null
+++ b/sample/drb/rinda_ts.rb
@@ -0,0 +1,7 @@
+require 'drb/drb'
+require 'rinda/tuplespace'
+
+uri = ARGV.shift
+DRb.start_service(uri, Rinda::TupleSpace.new)
+puts DRb.uri
+DRb.thread.join
diff --git a/sample/drb/rindac.rb b/sample/drb/rindac.rb
new file mode 100644
index 00000000000..72be09deafd
--- /dev/null
+++ b/sample/drb/rindac.rb
@@ -0,0 +1,17 @@
+require 'drb/drb'
+require 'rinda/rinda'
+
+uri = ARGV.shift || raise("usage: #{$0} <server_uri>")
+
+DRb.start_service
+ts = Rinda::TupleSpaceProxy.new(DRbObject.new(nil, uri))
+
+(1..10).each do |n|
+ ts.write(['sum', DRb.uri, n])
+end
+
+(1..10).each do |n|
+ ans = ts.take(['ans', DRb.uri, n, nil])
+ p [ans[2], ans[3]]
+end
+
diff --git a/sample/drb/rindas.rb b/sample/drb/rindas.rb
new file mode 100644
index 00000000000..9fd9ada2d10
--- /dev/null
+++ b/sample/drb/rindas.rb
@@ -0,0 +1,18 @@
+require 'drb/drb'
+require 'rinda/rinda'
+
+def do_it(v)
+ puts "do_it(#{v})"
+ v + v
+end
+
+uri = ARGV.shift || raise("usage: #{$0} <server_uri>")
+
+DRb.start_service
+ts = Rinda::TupleSpaceProxy.new(DRbObject.new(nil, uri))
+
+while true
+ r = ts.take(['sum', nil, nil])
+ v = do_it(r[2])
+ ts.write(['ans', r[1], r[2], v])
+end
diff --git a/sample/drb/ring_echo.rb b/sample/drb/ring_echo.rb
new file mode 100644
index 00000000000..0fde11b9e9a
--- /dev/null
+++ b/sample/drb/ring_echo.rb
@@ -0,0 +1,30 @@
+require 'drb/drb'
+require 'drb/eq'
+require 'rinda/ring'
+require 'thread'
+
+class RingEcho
+ include DRbUndumped
+ def initialize(name)
+ @name = name
+ end
+
+ def echo(str)
+ "#{@name}: #{str}"
+ end
+end
+
+DRb.start_service
+
+renewer = Rinda::SimpleRenewer.new
+
+finder = Rinda::RingFinger.new
+ts = finder.lookup_ring_any
+ts.read_all([:name, :RingEcho, nil, nil]).each do |tuple|
+ p tuple[2]
+ puts tuple[2].echo('Hello, World') rescue nil
+end
+ts.write([:name, :RingEcho, RingEcho.new(DRb.uri), ''], renewer)
+
+$stdin.gets
+
diff --git a/sample/drb/ring_inspect.rb b/sample/drb/ring_inspect.rb
new file mode 100644
index 00000000000..c096cd70349
--- /dev/null
+++ b/sample/drb/ring_inspect.rb
@@ -0,0 +1,30 @@
+require 'rinda/ring'
+require 'drb/drb'
+
+class Inspector
+ def initialize
+ end
+
+ def primary
+ Rinda::RingFinger.primary
+ end
+
+ def list_place
+ Rinda::RingFinger.to_a
+ end
+
+ def list(idx = -1)
+ if idx < 0
+ ts = primary
+ else
+ ts = list_place[idx]
+ raise "RingNotFound" unless ts
+ end
+ ts.read_all([:name, nil, nil, nil])
+ end
+end
+
+def main
+ DRb.start_service
+ r = Inspector.new
+end
diff --git a/sample/drb/ring_place.rb b/sample/drb/ring_place.rb
new file mode 100644
index 00000000000..0ceef7c65af
--- /dev/null
+++ b/sample/drb/ring_place.rb
@@ -0,0 +1,25 @@
+require 'drb/drb'
+require 'rinda/ring'
+require 'rinda/tuplespace'
+
+unless $DEBUG
+ # Run as a daemon...
+ exit!( 0 ) if fork
+ Process.setsid
+ exit!( 0 ) if fork
+end
+
+DRb.start_service(ARGV.shift)
+
+ts = Rinda::TupleSpace.new
+place = Rinda::RingServer.new(ts)
+
+if $DEBUG
+ puts DRb.uri
+ DRb.thread.join
+else
+ STDIN.reopen('/dev/null')
+ STDOUT.reopen('/dev/null', 'w')
+ STDERR.reopen('/dev/null', 'w')
+ DRb.thread.join
+end
diff --git a/sample/drb/simpletuple.rb b/sample/drb/simpletuple.rb
new file mode 100644
index 00000000000..3ae9208c799
--- /dev/null
+++ b/sample/drb/simpletuple.rb
@@ -0,0 +1,91 @@
+#!/usr/local/bin/ruby
+# SimpleTupleSpace
+# Copyright (c) 1999-2000 Masatoshi SEKI
+# You can redistribute it and/or modify it under the same terms as Ruby.
+
+require 'thread'
+
+class SimpleTupleSpace
+ def initialize
+ @hash = {}
+ @waiting = {}
+ @hash.taint
+ @waiting.taint
+ self.taint
+ end
+
+ def out(key, obj)
+ Thread.critical = true
+ @hash[key] ||= []
+ @waiting[key] ||= []
+ @hash[key].push obj
+ begin
+ t = @waiting[key].shift
+ @waiting.delete(key) if @waiting[key].length == 0
+ t.wakeup if t
+ rescue ThreadError
+ retry
+ ensure
+ Thread.critical = false
+ end
+ end
+
+ def in(key)
+ Thread.critical = true
+ @hash[key] ||= []
+ @waiting[key] ||= []
+ begin
+ loop do
+ if @hash[key].length == 0
+ @waiting[key].push Thread.current
+ Thread.stop
+ else
+ return @hash[key].shift
+ end
+ end
+ ensure
+ @hash.delete(key) if @hash[key].length == 0
+ Thread.critical = false
+ end
+ end
+end
+
+if __FILE__ == $0
+ ts = SimpleTupleSpace.new
+ clients = []
+ servers = []
+
+ def server(ts)
+ Thread.start {
+ loop do
+ req = ts.in('req')
+ ac = req[0]
+ num = req[1]
+ ts.out(ac, num * num)
+ end
+ }
+ end
+
+ def client(ts, n)
+ Thread.start {
+ ac = Object.new
+ ts.out('req', [ac, n])
+ ans = ts.in(ac)
+ puts "#{n}: #{ans}"
+ }
+ end
+
+ 3.times do
+ servers.push(server(ts))
+ end
+
+ (1..6).each do |n|
+ clients.push(client(ts, n))
+ end
+
+ clients.each do |t|
+ t.join
+ end
+end
+
+
diff --git a/sample/drb/speedc.rb b/sample/drb/speedc.rb
new file mode 100644
index 00000000000..14d526d48da
--- /dev/null
+++ b/sample/drb/speedc.rb
@@ -0,0 +1,21 @@
+#!/usr/local/bin/ruby
+
+uri = ARGV.shift || raise("usage: #{$0} URI")
+N = (ARGV.shift || 100).to_i
+
+case uri
+when /^tcpromp:/, /^unixromp:/
+ require 'romp'
+
+ client = ROMP::Client.new(uri, false)
+ foo = client.resolve("foo")
+when /^druby:/
+ require 'drb/drb'
+
+ DRb.start_service
+ foo = DRbObject.new(nil, uri)
+end
+
+N.times do |n|
+ foo.foo(n)
+end
diff --git a/sample/drb/speeds.rb b/sample/drb/speeds.rb
new file mode 100644
index 00000000000..5dcd02a56b9
--- /dev/null
+++ b/sample/drb/speeds.rb
@@ -0,0 +1,33 @@
+class Foo
+ attr_reader :i
+ def initialize
+ @i = 0
+ end
+
+ def foo(i)
+ @i = i
+ i + i
+ end
+end
+
+# server = ROMP::Server.new('tcpromp://localhost:4242', nil, true)
+
+uri = ARGV.shift || raise("usage: #{$0} URI")
+foo = Foo.new
+
+case uri
+when /^tcpromp:/, /^unixromp:/
+ require 'romp'
+
+ server = ROMP::Server.new(uri, nil, true)
+ server.bind(foo, "foo")
+
+when /^druby:/
+ require 'drb/drb'
+
+ DRb.start_service(uri, Foo.new)
+end
+
+puts '[enter] to exit'
+gets
+