mirror of
https://github.com/ruby/ruby.git
synced 2022-11-09 12:17:21 -05:00
* lib/drb/drb.rb (DRb::DRbMessage::send_request, send_reply):
should rescue errors and re-raise DRbConnError on write too. [ruby-dev:22132] git-svn-id: svn+ssh://ci.ruby-lang.org/ruby/trunk@5110 b2dd03c8-39d4-4d8f-98ff-823fe69b080e
This commit is contained in:
parent
05f6ee2183
commit
9c40644850
2 changed files with 10 additions and 0 deletions
|
@ -1,3 +1,9 @@
|
|||
Thu Dec 4 21:50:07 2003 Nobuyoshi Nakada <nobu@ruby-lang.org>
|
||||
|
||||
* lib/drb/drb.rb (DRb::DRbMessage::send_request, send_reply):
|
||||
should rescue errors and re-raise DRbConnError on write too.
|
||||
[ruby-dev:22132]
|
||||
|
||||
Thu Dec 4 16:41:17 2003 Nobuyoshi Nakada <nobu@ruby-lang.org>
|
||||
|
||||
* parse.y (exc_list): allow expanding list. [ruby-dev:22134]
|
||||
|
|
|
@ -582,6 +582,8 @@ module DRb
|
|||
end
|
||||
ary.push(dump(b))
|
||||
stream.write(ary.join(''))
|
||||
rescue
|
||||
raise(DRbConnError, $!.message, $!.backtrace)
|
||||
end
|
||||
|
||||
def recv_request(stream) # :nodoc:
|
||||
|
@ -600,6 +602,8 @@ module DRb
|
|||
|
||||
def send_reply(stream, succ, result) # :nodoc:
|
||||
stream.write(dump(succ) + dump(result))
|
||||
rescue
|
||||
raise(DRbConnError, $!.message, $!.backtrace)
|
||||
end
|
||||
|
||||
def recv_reply(stream) # :nodoc:
|
||||
|
|
Loading…
Reference in a new issue