mirror of
				https://github.com/ruby/ruby.git
				synced 2022-11-09 12:17:21 -05:00 
			
		
		
		
	* remove trailing spaces.
git-svn-id: svn+ssh://ci.ruby-lang.org/ruby/trunk@31573 b2dd03c8-39d4-4d8f-98ff-823fe69b080e
This commit is contained in:
		
							parent
							
								
									39da1b6369
								
							
						
					
					
						commit
						3a47cf3395
					
				
					 212 changed files with 846 additions and 846 deletions
				
			
		| 
						 | 
				
			
			@ -1,6 +1,6 @@
 | 
			
		|||
=begin
 | 
			
		||||
 distributed Ruby --- Array
 | 
			
		||||
 	Copyright (c) 1999-2001 Masatoshi SEKI 
 | 
			
		||||
 	Copyright (c) 1999-2001 Masatoshi SEKI
 | 
			
		||||
=end
 | 
			
		||||
 | 
			
		||||
require 'drb/drb'
 | 
			
		||||
| 
						 | 
				
			
			
 | 
			
		|||
| 
						 | 
				
			
			@ -1,6 +1,6 @@
 | 
			
		|||
=begin
 | 
			
		||||
 distributed Ruby --- Array client
 | 
			
		||||
 	Copyright (c) 1999-2001 Masatoshi SEKI 
 | 
			
		||||
 	Copyright (c) 1999-2001 Masatoshi SEKI
 | 
			
		||||
=end
 | 
			
		||||
 | 
			
		||||
require 'drb/drb'
 | 
			
		||||
| 
						 | 
				
			
			@ -19,7 +19,7 @@ p a
 | 
			
		|||
 | 
			
		||||
puts "# find"
 | 
			
		||||
p ro.find { |x| x.kind_of? String }
 | 
			
		||||
  
 | 
			
		||||
 | 
			
		||||
puts "# each, break"
 | 
			
		||||
ro.each do |x|
 | 
			
		||||
  next if x == "five"
 | 
			
		||||
| 
						 | 
				
			
			
 | 
			
		|||
| 
						 | 
				
			
			@ -18,13 +18,13 @@ class Biff
 | 
			
		|||
  def run
 | 
			
		||||
    last = Time.now
 | 
			
		||||
    while true
 | 
			
		||||
      begin 
 | 
			
		||||
      begin
 | 
			
		||||
	sleep(@interval)
 | 
			
		||||
	current = File::mtime(@filename)
 | 
			
		||||
	if current > last
 | 
			
		||||
	  changed
 | 
			
		||||
	  begin
 | 
			
		||||
	    notify_observers(@filename, current) 
 | 
			
		||||
	    notify_observers(@filename, current)
 | 
			
		||||
	  rescue Error
 | 
			
		||||
	  end
 | 
			
		||||
	  last = current
 | 
			
		||||
| 
						 | 
				
			
			
 | 
			
		|||
| 
						 | 
				
			
			@ -1,12 +1,12 @@
 | 
			
		|||
=begin
 | 
			
		||||
 distributed Ruby --- chat client
 | 
			
		||||
 	Copyright (c) 1999-2000 Masatoshi SEKI 
 | 
			
		||||
 	Copyright (c) 1999-2000 Masatoshi SEKI
 | 
			
		||||
=end
 | 
			
		||||
 | 
			
		||||
require 'drb/drb'
 | 
			
		||||
 | 
			
		||||
class ChatClient
 | 
			
		||||
  include DRbUndumped  
 | 
			
		||||
  include DRbUndumped
 | 
			
		||||
 | 
			
		||||
  def initialize(name)
 | 
			
		||||
    @name = name
 | 
			
		||||
| 
						 | 
				
			
			
 | 
			
		|||
| 
						 | 
				
			
			@ -1,6 +1,6 @@
 | 
			
		|||
=begin
 | 
			
		||||
 distributed Ruby --- chat server
 | 
			
		||||
 	Copyright (c) 1999-2000 Masatoshi SEKI 
 | 
			
		||||
 	Copyright (c) 1999-2000 Masatoshi SEKI
 | 
			
		||||
=end
 | 
			
		||||
require 'thread'
 | 
			
		||||
require 'drb/drb'
 | 
			
		||||
| 
						 | 
				
			
			
 | 
			
		|||
| 
						 | 
				
			
			@ -1,13 +1,13 @@
 | 
			
		|||
=begin
 | 
			
		||||
 distributed Ruby --- dRuby Sample Server --- chasen server
 | 
			
		||||
 	Copyright (c) 1999-2001 Masatoshi SEKI 
 | 
			
		||||
 	Copyright (c) 1999-2001 Masatoshi SEKI
 | 
			
		||||
=end
 | 
			
		||||
 | 
			
		||||
=begin
 | 
			
		||||
 How to play.
 | 
			
		||||
 | 
			
		||||
 Terminal 1
 | 
			
		||||
 | % ruby  dhasen.rb 
 | 
			
		||||
 | % ruby  dhasen.rb
 | 
			
		||||
 | druby://yourhost:7640
 | 
			
		||||
 | 
			
		||||
 Terminal 2
 | 
			
		||||
| 
						 | 
				
			
			
 | 
			
		|||
| 
						 | 
				
			
			@ -1,7 +1,7 @@
 | 
			
		|||
# -*- encoding: euc-jp -*-
 | 
			
		||||
=begin
 | 
			
		||||
 distributed Ruby --- dRuby Sample Client -- chasen client
 | 
			
		||||
 	Copyright (c) 1999-2001 Masatoshi SEKI 
 | 
			
		||||
 	Copyright (c) 1999-2001 Masatoshi SEKI
 | 
			
		||||
=end
 | 
			
		||||
 | 
			
		||||
require 'drb/drb'
 | 
			
		||||
| 
						 | 
				
			
			
 | 
			
		|||
| 
						 | 
				
			
			@ -1,6 +1,6 @@
 | 
			
		|||
=begin
 | 
			
		||||
 distributed Ruby --- Log test
 | 
			
		||||
 	Copyright (c) 1999-2001 Masatoshi SEKI 
 | 
			
		||||
 	Copyright (c) 1999-2001 Masatoshi SEKI
 | 
			
		||||
=end
 | 
			
		||||
 | 
			
		||||
require 'drb/drb'
 | 
			
		||||
| 
						 | 
				
			
			
 | 
			
		|||
| 
						 | 
				
			
			@ -1,6 +1,6 @@
 | 
			
		|||
=begin
 | 
			
		||||
 distributed Ruby --- Log server
 | 
			
		||||
 	Copyright (c) 1999-2000 Masatoshi SEKI 
 | 
			
		||||
 	Copyright (c) 1999-2000 Masatoshi SEKI
 | 
			
		||||
=end
 | 
			
		||||
 | 
			
		||||
require 'drb/drb'
 | 
			
		||||
| 
						 | 
				
			
			
 | 
			
		|||
| 
						 | 
				
			
			@ -1,6 +1,6 @@
 | 
			
		|||
=begin
 | 
			
		||||
 distributed Ruby --- store
 | 
			
		||||
 	Copyright (c) 1999-2000 Masatoshi SEKI 
 | 
			
		||||
 	Copyright (c) 1999-2000 Masatoshi SEKI
 | 
			
		||||
=end
 | 
			
		||||
 | 
			
		||||
require 'drb/drb'
 | 
			
		||||
| 
						 | 
				
			
			
 | 
			
		|||
| 
						 | 
				
			
			@ -1,6 +1,6 @@
 | 
			
		|||
=begin
 | 
			
		||||
 distributed Ruby --- fetch
 | 
			
		||||
 	Copyright (c) 1999-2000 Masatoshi SEKI 
 | 
			
		||||
 	Copyright (c) 1999-2000 Masatoshi SEKI
 | 
			
		||||
=end
 | 
			
		||||
 | 
			
		||||
require 'drb/drb'
 | 
			
		||||
| 
						 | 
				
			
			
 | 
			
		|||
| 
						 | 
				
			
			@ -1,6 +1,6 @@
 | 
			
		|||
=begin
 | 
			
		||||
 distributed Ruby --- Queue
 | 
			
		||||
 	Copyright (c) 1999-2000 Masatoshi SEKI 
 | 
			
		||||
 	Copyright (c) 1999-2000 Masatoshi SEKI
 | 
			
		||||
=end
 | 
			
		||||
 | 
			
		||||
require 'thread'
 | 
			
		||||
| 
						 | 
				
			
			
 | 
			
		|||
| 
						 | 
				
			
			@ -1,6 +1,6 @@
 | 
			
		|||
=begin
 | 
			
		||||
 distributed Ruby --- dRuby Sample Client
 | 
			
		||||
 	Copyright (c) 1999-2000 Masatoshi SEKI 
 | 
			
		||||
 	Copyright (c) 1999-2000 Masatoshi SEKI
 | 
			
		||||
=end
 | 
			
		||||
 | 
			
		||||
require 'drb/drb'
 | 
			
		||||
| 
						 | 
				
			
			
 | 
			
		|||
| 
						 | 
				
			
			@ -1,6 +1,6 @@
 | 
			
		|||
=begin
 | 
			
		||||
 distributed Ruby --- dRuby Sample Client
 | 
			
		||||
 	Copyright (c) 1999-2000 Masatoshi SEKI 
 | 
			
		||||
 	Copyright (c) 1999-2000 Masatoshi SEKI
 | 
			
		||||
=end
 | 
			
		||||
 | 
			
		||||
require 'drb/drb'
 | 
			
		||||
| 
						 | 
				
			
			
 | 
			
		|||
| 
						 | 
				
			
			@ -1,13 +1,13 @@
 | 
			
		|||
=begin
 | 
			
		||||
 multiple DRbServer
 | 
			
		||||
 	Copyright (c) 1999-2002 Masatoshi SEKI 
 | 
			
		||||
 	Copyright (c) 1999-2002 Masatoshi SEKI
 | 
			
		||||
=end
 | 
			
		||||
 | 
			
		||||
=begin
 | 
			
		||||
 How to play.
 | 
			
		||||
 | 
			
		||||
 Terminal 1
 | 
			
		||||
 | % ruby  drbm.rb 
 | 
			
		||||
 | % ruby  drbm.rb
 | 
			
		||||
 | druby://yourhost:7640 druby://yourhost:7641
 | 
			
		||||
 | 
			
		||||
 Terminal 2
 | 
			
		||||
| 
						 | 
				
			
			@ -24,7 +24,7 @@ class Hoge
 | 
			
		|||
  def initialize(s)
 | 
			
		||||
    @str = s
 | 
			
		||||
  end
 | 
			
		||||
  
 | 
			
		||||
 | 
			
		||||
  def to_s
 | 
			
		||||
    @str
 | 
			
		||||
  end
 | 
			
		||||
| 
						 | 
				
			
			
 | 
			
		|||
| 
						 | 
				
			
			@ -1,6 +1,6 @@
 | 
			
		|||
=begin
 | 
			
		||||
  multiple DRbServer client
 | 
			
		||||
 	Copyright (c) 1999-2002 Masatoshi SEKI 
 | 
			
		||||
 	Copyright (c) 1999-2002 Masatoshi SEKI
 | 
			
		||||
=end
 | 
			
		||||
 | 
			
		||||
require 'drb/drb'
 | 
			
		||||
| 
						 | 
				
			
			
 | 
			
		|||
| 
						 | 
				
			
			@ -1,13 +1,13 @@
 | 
			
		|||
=begin
 | 
			
		||||
 distributed Ruby --- dRuby Sample Server
 | 
			
		||||
 	Copyright (c) 1999-2000 Masatoshi SEKI 
 | 
			
		||||
 	Copyright (c) 1999-2000 Masatoshi SEKI
 | 
			
		||||
=end
 | 
			
		||||
 | 
			
		||||
=begin
 | 
			
		||||
 How to play.
 | 
			
		||||
 | 
			
		||||
 Terminal 1
 | 
			
		||||
 | % ruby  drbs.rb 
 | 
			
		||||
 | % ruby  drbs.rb
 | 
			
		||||
 | druby://yourhost:7640
 | 
			
		||||
 | 
			
		||||
 Terminal 2
 | 
			
		||||
| 
						 | 
				
			
			@ -41,7 +41,7 @@ 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)
 | 
			
		||||
| 
						 | 
				
			
			
 | 
			
		|||
| 
						 | 
				
			
			@ -1,13 +1,13 @@
 | 
			
		|||
=begin
 | 
			
		||||
 distributed Ruby --- dRuby Sample Server
 | 
			
		||||
 	Copyright (c) 1999-2000,2002 Masatoshi SEKI 
 | 
			
		||||
 	Copyright (c) 1999-2000,2002 Masatoshi SEKI
 | 
			
		||||
=end
 | 
			
		||||
 | 
			
		||||
=begin
 | 
			
		||||
 How to play.
 | 
			
		||||
 | 
			
		||||
 Terminal 1
 | 
			
		||||
 | % ruby  drbs.rb 
 | 
			
		||||
 | % ruby  drbs.rb
 | 
			
		||||
 | druby://yourhost:7640
 | 
			
		||||
 | 
			
		||||
 Terminal 2
 | 
			
		||||
| 
						 | 
				
			
			
 | 
			
		|||
| 
						 | 
				
			
			@ -1,11 +1,11 @@
 | 
			
		|||
=begin
 | 
			
		||||
 dRuby sample
 | 
			
		||||
 	Copyright (c) 2000 Masatoshi SEKI 
 | 
			
		||||
 	Copyright (c) 2000 Masatoshi SEKI
 | 
			
		||||
 | 
			
		||||
= How to play
 | 
			
		||||
 | 
			
		||||
* Terminal 1
 | 
			
		||||
  
 | 
			
		||||
 | 
			
		||||
  % ruby  -I. extserv_test.rb server
 | 
			
		||||
  druby://yourhost:12345
 | 
			
		||||
 | 
			
		||||
| 
						 | 
				
			
			@ -26,11 +26,11 @@ end
 | 
			
		|||
 | 
			
		||||
class Foo
 | 
			
		||||
  include DRbUndumped
 | 
			
		||||
  
 | 
			
		||||
 | 
			
		||||
  def initialize(str)
 | 
			
		||||
    @str = str
 | 
			
		||||
  end
 | 
			
		||||
  
 | 
			
		||||
 | 
			
		||||
  def hello(it)
 | 
			
		||||
    "#{it}: #{self}"
 | 
			
		||||
  end
 | 
			
		||||
| 
						 | 
				
			
			@ -55,7 +55,7 @@ when 'server'
 | 
			
		|||
 | 
			
		||||
  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
 | 
			
		||||
| 
						 | 
				
			
			@ -72,7 +72,7 @@ else
 | 
			
		|||
  t2 = s.service('itest2').front
 | 
			
		||||
  puts t2
 | 
			
		||||
  puts t1.hello(t2)
 | 
			
		||||
  if (cmd == 'quit') 
 | 
			
		||||
  if (cmd == 'quit')
 | 
			
		||||
    s.service('itest1').stop_service
 | 
			
		||||
    s.service('itest2').stop_service
 | 
			
		||||
  end
 | 
			
		||||
| 
						 | 
				
			
			
 | 
			
		|||
| 
						 | 
				
			
			@ -11,7 +11,7 @@ DRb.start_service()
 | 
			
		|||
ro = DRbObject.new(nil, there)
 | 
			
		||||
 | 
			
		||||
ary = []
 | 
			
		||||
10.times do 
 | 
			
		||||
10.times do
 | 
			
		||||
  ary.push(ro.gen)
 | 
			
		||||
end
 | 
			
		||||
 | 
			
		||||
| 
						 | 
				
			
			
 | 
			
		|||
| 
						 | 
				
			
			@ -14,7 +14,7 @@
 | 
			
		|||
 | 
			
		||||
  % ruby  holderc.rb druby://yourhost:1234
 | 
			
		||||
=end
 | 
			
		||||
  
 | 
			
		||||
 | 
			
		||||
 | 
			
		||||
require 'drb/drb'
 | 
			
		||||
 | 
			
		||||
| 
						 | 
				
			
			@ -36,11 +36,11 @@ end
 | 
			
		|||
 | 
			
		||||
class DRbEx4
 | 
			
		||||
  include DRbUndumped
 | 
			
		||||
  
 | 
			
		||||
 | 
			
		||||
  def initialize
 | 
			
		||||
    @curr = 1
 | 
			
		||||
  end
 | 
			
		||||
  
 | 
			
		||||
 | 
			
		||||
  def gen
 | 
			
		||||
    begin
 | 
			
		||||
      @curr += 1
 | 
			
		||||
| 
						 | 
				
			
			
 | 
			
		|||
| 
						 | 
				
			
			@ -46,14 +46,14 @@ module DRb
 | 
			
		|||
 | 
			
		||||
      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
 | 
			
		||||
| 
						 | 
				
			
			@ -66,7 +66,7 @@ module DRb
 | 
			
		|||
	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' 
 | 
			
		||||
	    raise TypeError, 'too large packet'
 | 
			
		||||
	  end
 | 
			
		||||
	end
 | 
			
		||||
	@reply_stream = sio
 | 
			
		||||
| 
						 | 
				
			
			
 | 
			
		|||
| 
						 | 
				
			
			@ -5,7 +5,7 @@ require 'thread'
 | 
			
		|||
 | 
			
		||||
module DRb
 | 
			
		||||
  module HTTP0
 | 
			
		||||
    
 | 
			
		||||
 | 
			
		||||
    def self.open_server(uri, config)
 | 
			
		||||
      unless /^http:/ =~ uri
 | 
			
		||||
	raise(DRbBadScheme, uri) unless uri =~ /^http:/
 | 
			
		||||
| 
						 | 
				
			
			@ -20,7 +20,7 @@ module DRb
 | 
			
		|||
	@drb = drb
 | 
			
		||||
	@queue = Queue.new
 | 
			
		||||
      end
 | 
			
		||||
      
 | 
			
		||||
 | 
			
		||||
      def do_POST(req, res)
 | 
			
		||||
	@req = req
 | 
			
		||||
	@res = res
 | 
			
		||||
| 
						 | 
				
			
			@ -28,7 +28,7 @@ module DRb
 | 
			
		|||
	@res.body = @queue.pop
 | 
			
		||||
	@res['content-type'] = 'application/octet-stream;'
 | 
			
		||||
      end
 | 
			
		||||
      
 | 
			
		||||
 | 
			
		||||
      def req_body
 | 
			
		||||
	@req.body
 | 
			
		||||
      end
 | 
			
		||||
| 
						 | 
				
			
			@ -36,7 +36,7 @@ module DRb
 | 
			
		|||
      def reply(body)
 | 
			
		||||
	@queue.push(body)
 | 
			
		||||
      end
 | 
			
		||||
      
 | 
			
		||||
 | 
			
		||||
      def close
 | 
			
		||||
	@queue.push('')
 | 
			
		||||
      end
 | 
			
		||||
| 
						 | 
				
			
			@ -78,7 +78,7 @@ module DRb
 | 
			
		|||
	s.start
 | 
			
		||||
      end
 | 
			
		||||
    end
 | 
			
		||||
    
 | 
			
		||||
 | 
			
		||||
    class ServerSide
 | 
			
		||||
      def initialize(callback, config)
 | 
			
		||||
	@callback = callback
 | 
			
		||||
| 
						 | 
				
			
			@ -86,7 +86,7 @@ module DRb
 | 
			
		|||
	@msg = DRbMessage.new(@config)
 | 
			
		||||
	@req_stream = StrStream.new(@callback.req_body)
 | 
			
		||||
      end
 | 
			
		||||
      
 | 
			
		||||
 | 
			
		||||
      def close
 | 
			
		||||
	@callback.close if @callback
 | 
			
		||||
	@callback = nil
 | 
			
		||||
| 
						 | 
				
			
			
 | 
			
		|||
| 
						 | 
				
			
			@ -1,12 +1,12 @@
 | 
			
		|||
=begin
 | 
			
		||||
 distributed Ruby --- NamedObject Sample
 | 
			
		||||
 	Copyright (c) 2000-2001 Masatoshi SEKI 
 | 
			
		||||
 	Copyright (c) 2000-2001 Masatoshi SEKI
 | 
			
		||||
=end
 | 
			
		||||
 | 
			
		||||
=begin
 | 
			
		||||
How to play.
 | 
			
		||||
 | 
			
		||||
* start server 
 | 
			
		||||
* start server
 | 
			
		||||
 Terminal 1
 | 
			
		||||
 | % ruby  name.rb druby://yourhost:7640
 | 
			
		||||
 | druby://yourhost:7640
 | 
			
		||||
| 
						 | 
				
			
			@ -28,9 +28,9 @@ How to play.
 | 
			
		|||
 | druby://yourhost:7640
 | 
			
		||||
 | [return] to exit
 | 
			
		||||
 | 
			
		||||
* continue client 
 | 
			
		||||
* continue client
 | 
			
		||||
 Terminal 2
 | 
			
		||||
 type [return] 
 | 
			
		||||
 type [return]
 | 
			
		||||
 | 1
 | 
			
		||||
 | 2
 | 
			
		||||
=end
 | 
			
		||||
| 
						 | 
				
			
			@ -44,7 +44,7 @@ module DRbNamedObject
 | 
			
		|||
 | 
			
		||||
  def drb_name=(name)
 | 
			
		||||
    @drb_name = name
 | 
			
		||||
    Thread.exclusive do 
 | 
			
		||||
    Thread.exclusive do
 | 
			
		||||
      raise(IndexError, name) if DRbNAMEDICT[name]
 | 
			
		||||
      DRbNAMEDICT[name] = self
 | 
			
		||||
    end
 | 
			
		||||
| 
						 | 
				
			
			@ -62,7 +62,7 @@ class DRbNamedIdConv < DRb::DRbIdConv
 | 
			
		|||
 | 
			
		||||
  def to_id(obj)
 | 
			
		||||
    if obj.kind_of? DRbNamedObject
 | 
			
		||||
      return obj.drb_name 
 | 
			
		||||
      return obj.drb_name
 | 
			
		||||
    else
 | 
			
		||||
      return super
 | 
			
		||||
    end
 | 
			
		||||
| 
						 | 
				
			
			@ -98,7 +98,7 @@ class Front
 | 
			
		|||
    @name['seq'] = seq
 | 
			
		||||
    @name['mutex'] = mutex
 | 
			
		||||
  end
 | 
			
		||||
    
 | 
			
		||||
 | 
			
		||||
  def [](k)
 | 
			
		||||
    @name[k]
 | 
			
		||||
  end
 | 
			
		||||
| 
						 | 
				
			
			@ -108,7 +108,7 @@ 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
 | 
			
		||||
| 
						 | 
				
			
			
 | 
			
		|||
| 
						 | 
				
			
			@ -1,6 +1,6 @@
 | 
			
		|||
=begin
 | 
			
		||||
 distributed Ruby --- NamedObject Sample Client
 | 
			
		||||
 	Copyright (c) 2000-2001 Masatoshi SEKI 
 | 
			
		||||
 	Copyright (c) 2000-2001 Masatoshi SEKI
 | 
			
		||||
=end
 | 
			
		||||
 | 
			
		||||
require 'drb/drb'
 | 
			
		||||
| 
						 | 
				
			
			
 | 
			
		|||
| 
						 | 
				
			
			@ -82,7 +82,7 @@ class TupleSpace
 | 
			
		|||
      end
 | 
			
		||||
    end
 | 
			
		||||
    return nil unless found
 | 
			
		||||
    
 | 
			
		||||
 | 
			
		||||
    @que[sz].delete_at(i)
 | 
			
		||||
 | 
			
		||||
    return x
 | 
			
		||||
| 
						 | 
				
			
			@ -167,7 +167,7 @@ if __FILE__ == $0
 | 
			
		|||
  def client(ts, n)
 | 
			
		||||
    Thread.start {
 | 
			
		||||
      ac = Object.new
 | 
			
		||||
      tuples = (1..10).collect { |i| 
 | 
			
		||||
      tuples = (1..10).collect { |i|
 | 
			
		||||
	['req', ac, i * 10 + n]
 | 
			
		||||
      }
 | 
			
		||||
      ts.out(*tuples)
 | 
			
		||||
| 
						 | 
				
			
			@ -201,7 +201,7 @@ if __FILE__ == $0
 | 
			
		|||
    clients.push(client(ts, n))
 | 
			
		||||
  end
 | 
			
		||||
 | 
			
		||||
  (1..3).each do 
 | 
			
		||||
  (1..3).each do
 | 
			
		||||
    watcher(ts)
 | 
			
		||||
  end
 | 
			
		||||
 | 
			
		||||
| 
						 | 
				
			
			
 | 
			
		|||
| 
						 | 
				
			
			@ -8,7 +8,7 @@ class RingEcho
 | 
			
		|||
  def initialize(name)
 | 
			
		||||
    @name = name
 | 
			
		||||
  end
 | 
			
		||||
  
 | 
			
		||||
 | 
			
		||||
  def echo(str)
 | 
			
		||||
    "#{@name}: #{str}"
 | 
			
		||||
  end
 | 
			
		||||
| 
						 | 
				
			
			
 | 
			
		|||
| 
						 | 
				
			
			@ -13,7 +13,7 @@ class SimpleTupleSpace
 | 
			
		|||
    @waiting.taint
 | 
			
		||||
    self.taint
 | 
			
		||||
  end
 | 
			
		||||
   
 | 
			
		||||
 | 
			
		||||
  def out(key, obj)
 | 
			
		||||
    Thread.critical = true
 | 
			
		||||
    @hash[key] ||= []
 | 
			
		||||
| 
						 | 
				
			
			@ -48,7 +48,7 @@ class SimpleTupleSpace
 | 
			
		|||
      Thread.critical = false
 | 
			
		||||
    end
 | 
			
		||||
  end
 | 
			
		||||
end  
 | 
			
		||||
end
 | 
			
		||||
 | 
			
		||||
if __FILE__ == $0
 | 
			
		||||
  ts = SimpleTupleSpace.new
 | 
			
		||||
| 
						 | 
				
			
			@ -75,7 +75,7 @@ if __FILE__ == $0
 | 
			
		|||
    }
 | 
			
		||||
  end
 | 
			
		||||
 | 
			
		||||
  3.times do 
 | 
			
		||||
  3.times do
 | 
			
		||||
    servers.push(server(ts))
 | 
			
		||||
  end
 | 
			
		||||
 | 
			
		||||
| 
						 | 
				
			
			
 | 
			
		|||
| 
						 | 
				
			
			@ -11,7 +11,7 @@ when /^tcpromp:/, /^unixromp:/
 | 
			
		|||
  foo = client.resolve("foo")
 | 
			
		||||
when /^druby:/
 | 
			
		||||
  require 'drb/drb'
 | 
			
		||||
  
 | 
			
		||||
 | 
			
		||||
  DRb.start_service
 | 
			
		||||
  foo = DRbObject.new(nil, uri)
 | 
			
		||||
end
 | 
			
		||||
| 
						 | 
				
			
			
 | 
			
		|||
| 
						 | 
				
			
			@ -3,7 +3,7 @@ class Foo
 | 
			
		|||
  def initialize
 | 
			
		||||
    @i = 0
 | 
			
		||||
  end
 | 
			
		||||
  
 | 
			
		||||
 | 
			
		||||
  def foo(i)
 | 
			
		||||
    @i = i
 | 
			
		||||
    i + i
 | 
			
		||||
| 
						 | 
				
			
			@ -24,7 +24,7 @@ when /^tcpromp:/, /^unixromp:/
 | 
			
		|||
 | 
			
		||||
when /^druby:/
 | 
			
		||||
  require 'drb/drb'
 | 
			
		||||
  
 | 
			
		||||
 | 
			
		||||
  DRb.start_service(uri, Foo.new)
 | 
			
		||||
end
 | 
			
		||||
 | 
			
		||||
| 
						 | 
				
			
			
 | 
			
		|||
		Loading…
	
	Add table
		Add a link
		
	
		Reference in a new issue