summaryrefslogtreecommitdiff
path: root/sample/drb/name.rb
diff options
context:
space:
mode:
authorseki <seki@b2dd03c8-39d4-4d8f-98ff-823fe69b080e>2004-02-14 02:28:02 +0000
committerseki <seki@b2dd03c8-39d4-4d8f-98ff-823fe69b080e>2004-02-14 02:28:02 +0000
commit30ff0b6aeb64ce114257710d9a534148515164a9 (patch)
tree0406cb26ba7387c664ef8d180306804a9b27725d /sample/drb/name.rb
parent0562a84558afdc085172c102a4c913bc0c2ec57d (diff)
import drb/sample
git-svn-id: svn+ssh://ci.ruby-lang.org/ruby/trunk@5698 b2dd03c8-39d4-4d8f-98ff-823fe69b080e
Diffstat (limited to 'sample/drb/name.rb')
-rw-r--r--sample/drb/name.rb118
1 files changed, 118 insertions, 0 deletions
diff --git a/sample/drb/name.rb b/sample/drb/name.rb
new file mode 100644
index 0000000..461f965
--- /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
+