raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 10

IO#fowardFailure: catch NonFatal rather then all Throwables

Browse source
This commit is contained in:
Scott R. Parish 2012-05-15 09:06:07 -05:00
parent 8aeb313492
commit 4eef9cd341
1 changed files with 2 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

4
akka-actor/src/main/scala/akka/actor/IO.scala
View file

@ -4,7 +4,7 @@
package akka.actor
import akka.dispatch.{ Future, ExecutionContext }
import akka.util.{ ByteString, Duration }
import akka.util.{ ByteString, Duration, NonFatal }
import java.net.{ SocketAddress, InetSocketAddress }
import java.io.IOException
import java.nio.ByteBuffer
@ -949,7 +949,7 @@ final class IOManagerActor extends Actor with ActorLogging {
}
private def forwardFailure(f: ⇒ Unit): Unit = {
try { f } catch { case t: Throwable ⇒ sender ! Status.Failure(t) }
try { f } catch { case NonFatal(e) ⇒ sender ! Status.Failure(e) }
}
private def setSocketOptions(socket: java.net.Socket, options: Seq[IO.SocketOption]) {