From 764722dc2737f7ee2686c1012539d1c5bd6446b8 Mon Sep 17 00:00:00 2001
From: shugo <shugo@b2dd03c8-39d4-4d8f-98ff-823fe69b080e>
Date: Sat, 11 Oct 2003 01:20:45 +0000
Subject: [PATCH] * lib/monitor.rb: handle exceptions correctly. Thanks,
 Gennady Bystritsky.

git-svn-id: svn+ssh://ci.ruby-lang.org/ruby/trunk@4740 b2dd03c8-39d4-4d8f-98ff-823fe69b080e
---
 ChangeLog      |  5 +++++
 lib/monitor.rb | 33 ++++++++++++++++++++-------------
 2 files changed, 25 insertions(+), 13 deletions(-)

diff --git a/ChangeLog b/ChangeLog
index 742b2058f1..5b1a3785e3 100644
--- a/ChangeLog
+++ b/ChangeLog
@@ -1,3 +1,8 @@
+Sat Oct 11 10:19:39 2003  Shugo Maeda  <shugo@ruby-lang.org>
+
+	* lib/monitor.rb: handle exceptions correctly. Thanks, Gennady
+	Bystritsky.
+
 Fri Oct 10 07:50:54 2003  Nobuyoshi Nakada  <nobu@ruby-lang.org>
 
 	* eval.c (is_defined): inheritance line adjustment as like as
diff --git a/lib/monitor.rb b/lib/monitor.rb
index 5eb7bb4e03..c7f610cef6 100644
--- a/lib/monitor.rb
+++ b/lib/monitor.rb
@@ -130,10 +130,14 @@ module MonitorMixin
       t.wakeup if t
       @waiters.push(Thread.current)
 
-      begin
-	Thread.stop
-      rescue Timeout
-      ensure
+      preserved_exceptions = []
+      while true
+        begin
+          Thread.stop
+        rescue Timeout
+        rescue Exception => exception
+          preserved_exceptions << exception
+        end
 	Thread.critical = true
 	if timeout && timeout_thread.alive?
 	  Thread.kill(timeout_thread)
@@ -141,15 +145,17 @@ module MonitorMixin
 	if @waiters.include?(Thread.current)  # interrupted?
 	  @waiters.delete(Thread.current)
 	end
-	while @monitor.mon_owner &&
-	    @monitor.mon_owner != Thread.current
-	  @monitor.mon_waiting_queue.push(Thread.current)
-	  Thread.stop
-	  Thread.critical = true
-	end
-	@monitor.mon_owner = Thread.current
-	@monitor.mon_count = count
-	Thread.critical = false
+
+        break if @monitor.mon_owner.nil? or @monitor.mon_owner == Thread.current
+        @monitor.mon_waiting_queue.delete(Thread.current)
+        @monitor.mon_waiting_queue.push(Thread.current)
+      end
+      @monitor.mon_owner = Thread.current
+      @monitor.mon_count = count
+      Thread.critical = false
+
+      unless preserved_exceptions.empty?
+        raise preserved_exceptions.first
       end
     end
     
@@ -232,6 +238,7 @@ module MonitorMixin
   def mon_enter
     Thread.critical = true
     while mon_owner != nil && mon_owner != Thread.current
+      mon_entering_queue.delete(Thread.current)
       mon_entering_queue.push(Thread.current)
       Thread.stop
       Thread.critical = true