From 9c5dfa18ed809e0cca090ecb7a1a8f0e3301c053 Mon Sep 17 00:00:00 2001
From: Philipp Haller <hallerp@gmail.com>
Date: Tue, 15 Mar 2011 16:42:00 +0000
Subject: Closes #3838. Review by prokopec.

---
 src/actors/scala/actors/Actor.scala | 27 +++++++++++++++------------
 1 file changed, 15 insertions(+), 12 deletions(-)

(limited to 'src')

diff --git a/src/actors/scala/actors/Actor.scala b/src/actors/scala/actors/Actor.scala
index 98f5d2287f..059ab3abf7 100644
--- a/src/actors/scala/actors/Actor.scala
+++ b/src/actors/scala/actors/Actor.scala
@@ -589,18 +589,21 @@ trait Actor extends AbstractActor with ReplyReactor with ActorCanReply with Inpu
             done = true
             receiveTimeout
           } else {
-            waitingFor = f
-            received = None
-            isSuspended = true
-            val thisActor = this
-            onTimeout = Some(new TimerTask {
-              def run() { thisActor.send(TIMEOUT, thisActor) }
-            })
-            Actor.timer.schedule(onTimeout.get, msec)
-            scheduler.managedBlock(blocker)
-            drainSendBuffer(mailbox)
-            // keep going
-            () => {}
+            if (onTimeout.isEmpty) {
+              waitingFor = f
+              received = None
+              isSuspended = true
+              val thisActor = this
+              onTimeout = Some(new TimerTask {
+                def run() { thisActor.send(TIMEOUT, thisActor) }
+              })
+              Actor.timer.schedule(onTimeout.get, msec)
+              scheduler.managedBlock(blocker)
+              drainSendBuffer(mailbox)
+              // keep going
+              () => {}
+            } else
+              sys.error("unhandled timeout")
           }
         }
         todo()
-- 
cgit v1.2.3