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

Some cleanup

Browse source
This commit is contained in:
Mathias 2013-04-11 14:33:41 +02:00
parent ec13033e5e
commit efaef76444
4 changed files with 4 additions and 12 deletions
Download patch file Download diff file Expand all files Collapse all files

2
akka-actor/src/main/scala/akka/io/TcpListener.scala
View file

@ -32,8 +32,6 @@ private[io] class TcpListener(val selectorRouter: ActorRef,
val tcp: TcpExt,
val bindCommander: ActorRef,
val bind: Bind) extends Actor with ActorLogging {
def selector: ActorRef = context.parent
import TcpListener._
import tcp.Settings._
import bind._

2
akka-actor/src/main/scala/akka/io/UdpConnectedManager.scala
View file

@ -15,7 +15,7 @@ private[io] class UdpConnectedManager(udpConn: UdpConnectedExt) extends Selector
def receive = workerForCommandHandler {
case c: Connect ⇒
val commander = sender
Props(new UdpConnectedection(udpConn, commander, c))
Props(new UdpConnection(udpConn, commander, c))
}
}

6
akka-actor/src/main/scala/akka/io/UdpConnection.scala
View file

@ -16,9 +16,9 @@ import scala.util.control.NonFatal
/**
* INTERNAL API
*/
private[io] class UdpConnectedection(val udpConn: UdpConnectedExt,
val commander: ActorRef,
val connect: Connect) extends Actor with ActorLogging {
private[io] class UdpConnection(val udpConn: UdpConnectedExt,
val commander: ActorRef,
val connect: Connect) extends Actor with ActorLogging {
def selector: ActorRef = context.parent

6
akka-actor/src/main/scala/akka/io/UdpSender.scala
View file

@ -12,8 +12,6 @@ import akka.io.Inet.SocketOption
import scala.util.control.NonFatal
/**
* Base class for TcpIncomingConnection and TcpOutgoingConnection.
*
* INTERNAL API
*/
private[io] class UdpSender(val udp: UdpExt, options: immutable.Traversable[SocketOption], val commander: ActorRef)
@ -45,9 +43,5 @@ private[io] class UdpSender(val udp: UdpExt, options: immutable.Traversable[Sock
case NonFatal(e) ⇒ log.error(e, "Error closing DatagramChannel")
}
}
override def postRestart(reason: Throwable): Unit =
throw new IllegalStateException("Restarting not supported for connection actors.")
}