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

IO.SocketOption: switch back to one line-per case

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

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

@ -954,24 +954,15 @@ final class IOManagerActor extends Actor with ActorLogging {
private def setSocketOptions(socket: java.net.Socket, options: Seq[IO.SocketOption]) {
options foreach {
case IO.KeepAlive(on) ⇒
forwardFailure(socket.setKeepAlive(on))
case IO.OOBInline(on) ⇒
forwardFailure(socket.setOOBInline(on))
case IO.ReceiveBufferSize(size) ⇒
forwardFailure(socket.setReceiveBufferSize(size))
case IO.ReuseAddress(on) ⇒
forwardFailure(socket.setReuseAddress(on))
case IO.SendBufferSize(size) ⇒
forwardFailure(socket.setSendBufferSize(size))
case IO.SoLinger(linger) ⇒
forwardFailure(socket.setSoLinger(linger.isDefined, math.max(0, linger.getOrElse(socket.getSoLinger))))
case IO.SoTimeout(timeout) ⇒
forwardFailure(socket.setSoTimeout(timeout.toMillis.toInt))
case IO.TcpNoDelay(on) ⇒
forwardFailure(socket.setTcpNoDelay(on))
case IO.TrafficClass(tc) ⇒
forwardFailure(socket.setTrafficClass(tc))
case IO.KeepAlive(on) ⇒ forwardFailure(socket.setKeepAlive(on))
case IO.OOBInline(on) ⇒ forwardFailure(socket.setOOBInline(on))
case IO.ReceiveBufferSize(size) ⇒ forwardFailure(socket.setReceiveBufferSize(size))
case IO.ReuseAddress(on) ⇒ forwardFailure(socket.setReuseAddress(on))
case IO.SendBufferSize(size) ⇒ forwardFailure(socket.setSendBufferSize(size))
case IO.SoLinger(linger) ⇒ forwardFailure(socket.setSoLinger(linger.isDefined, math.max(0, linger.getOrElse(socket.getSoLinger))))
case IO.SoTimeout(timeout) ⇒ forwardFailure(socket.setSoTimeout(timeout.toMillis.toInt))
case IO.TcpNoDelay(on) ⇒ forwardFailure(socket.setTcpNoDelay(on))
case IO.TrafficClass(tc) ⇒ forwardFailure(socket.setTrafficClass(tc))
case IO.PerformancePreferences(connTime, latency, bandwidth) ⇒
forwardFailure(socket.setPerformancePreferences(connTime, latency, bandwidth))
}
@ -989,10 +980,8 @@ final class IOManagerActor extends Actor with ActorLogging {
val sock = channel.socket
options foreach {
case IO.ReceiveBufferSize(size) ⇒
forwardFailure(sock.setReceiveBufferSize(size))
case IO.ReuseAddress(on) ⇒
forwardFailure(sock.setReuseAddress(on))
case IO.ReceiveBufferSize(size) ⇒ forwardFailure(sock.setReceiveBufferSize(size))
case IO.ReuseAddress(on) ⇒ forwardFailure(sock.setReuseAddress(on))
case IO.PerformancePreferences(connTime, latency, bandwidth) ⇒
forwardFailure(sock.setPerformancePreferences(connTime, latency, bandwidth))
}