summaryrefslogtreecommitdiff
path: root/lib/drb/invokemethod.rb
diff options
context:
space:
mode:
authorseki <seki@b2dd03c8-39d4-4d8f-98ff-823fe69b080e>2003-06-18 15:45:12 +0000
committerseki <seki@b2dd03c8-39d4-4d8f-98ff-823fe69b080e>2003-06-18 15:45:12 +0000
commit151f1241c665b0307234e931bec2c32bfea0138d (patch)
tree6ca5c5e535d66aaf094e954446846955f2e18a88 /lib/drb/invokemethod.rb
parent34cdb70d14ea1fdddf3f3991f6097fe5c24310ba (diff)
import from drb-2.0.4b3
git-svn-id: svn+ssh://ci.ruby-lang.org/ruby/trunk@3959 b2dd03c8-39d4-4d8f-98ff-823fe69b080e
Diffstat (limited to 'lib/drb/invokemethod.rb')
-rw-r--r--lib/drb/invokemethod.rb39
1 files changed, 39 insertions, 0 deletions
diff --git a/lib/drb/invokemethod.rb b/lib/drb/invokemethod.rb
new file mode 100644
index 0000000000..f8ce0ad09b
--- /dev/null
+++ b/lib/drb/invokemethod.rb
@@ -0,0 +1,39 @@
+
+# for ruby-1.8.0
+
+module DRb
+ class DRbServer
+ module InvokeMethod18Mixin
+ def block_yield(x)
+ block_value = @block.call(*x)
+ end
+
+ def rescue_break(err)
+ return :break, err.exit_value
+ end
+
+ def perform_with_block
+ @obj.__send__(@msg_id, *@argv) do |*x|
+ jump_error = nil
+ begin
+ block_value = block_yield(x)
+ rescue LocalJumpError
+ jump_error = $!
+ end
+ if jump_error
+ reason, jump_value = rescue_local_jump(jump_error)
+ case reason
+ when :retry
+ retry
+ when :break
+ break(jump_value)
+ else
+ raise jump_error
+ end
+ end
+ block_value
+ end
+ end
+ end
+ end
+end